From e75b0d79535a6bcd147cca4a54632b70b42afdb9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 29 五月 2021 18:10:18 +0800
Subject: [PATCH] 特价完善

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/push/XMPushServiceImpl.java |  617 +++++++++++++++++++++++++++++++------------------------
 1 files changed, 344 insertions(+), 273 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/XMPushServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/XMPushServiceImpl.java
index 680c6b5..0f65bd7 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/XMPushServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/XMPushServiceImpl.java
@@ -1,273 +1,344 @@
-package com.yeshi.fanli.service.impl.push;
-
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Service;
-
-import com.yeshi.fanli.dao.mybatis.AppVersionInfoMapper;
-import com.yeshi.fanli.entity.AppVersionInfo;
-import com.yeshi.fanli.entity.bus.user.AccountMessage;
-import com.yeshi.fanli.entity.system.SystemZnx;
-import com.yeshi.fanli.entity.xinge.MessageInfo;
-import com.yeshi.fanli.entity.xinge.PushRecord;
-import com.yeshi.fanli.exception.PushException;
-import com.yeshi.fanli.log.PushLogHelper;
-import com.yeshi.fanli.service.inter.push.XMPushService;
-import com.yeshi.fanli.util.Constant;
-import com.yeshi.fanli.util.push.PushUtils;
-
-import net.sf.json.JSONObject;
-
-@Service
-public class XMPushServiceImpl implements XMPushService {
-
-	@Resource
-	private AppVersionInfoMapper appVersionInfoMapper;
-
-	@Override
-	public void pushGoods(Long uid, Long auctionId, String title, String content) throws PushException {
-		String gid = auctionId + "";
-		JSONObject json = new JSONObject();
-		// json.put("url", "http://item.taobao.com/item.htm?id=" + gid);// IOS浣跨敤
-		json.put("id", gid);
-		json.put("type", "goodsdetail");
-		json.put("miPushUrl", String.format("%s.ui.recommend.GoodsBrowserActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		MessageInfo info = new MessageInfo();
-		info.setTitle(title);
-		info.setContent(content);
-		info.setDescription(content);
-		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-		info.setActivty(String.format("%s.ui.recommend.GoodsBrowserActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		PushRecord pushRecord = new PushRecord();
-		if (uid == null || uid == 0) {
-			// 灏忕背 鍏ㄦ帹
-			try {
-				PushUtils.allPushXiaoMi(info, json, pushRecord);
-			} catch (Exception e) {
-				PushLogHelper.xmError(e);
-			}
-		} else {
-			info.setAlias(uid + "");
-			// 灏忕背 鍗曟帹
-			PushUtils.singlePushXiaoMi(info, json, pushRecord);
-		}
-	}
-
-	@Override
-	public void pushUrl(Long uid, String url, String title, String content) throws PushException {
-		JSONObject json = new JSONObject();
-		json.put("url", url);
-		json.put("type", "url");
-		json.put("webUrl", url);
-		json.put("miPushUrl", String.format("%s.ui.invite.ShareBrowserActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		MessageInfo info = new MessageInfo();
-		info.setTitle(title);
-		info.setContent(content);
-		info.setDescription(content);
-		// 灏忕背鎺ㄩ�佺綉椤�
-		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-		info.setActivty(String.format("%s.ui.invite.ShareBrowserActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		PushRecord pushRecord = new PushRecord();
-
-		// 灏忕背 鍏ㄦ帹
-		if (uid == null || uid == 0) {
-			try {
-				PushUtils.allPushXiaoMi(info, json, pushRecord);
-			} catch (Exception e) {
-				PushLogHelper.xmError(e);
-			}
-		} else {
-			info.setAlias(uid + "");
-			PushUtils.singlePushXiaoMi(info, json, pushRecord);
-		}
-
-	}
-
-	@Override
-	public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX) throws PushException {
-		MessageInfo info = new MessageInfo();
-
-		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-
-		JSONObject contentJson = new JSONObject();
-
-		contentJson.put("isOpen", 0);
-		contentJson.put("createTime", java.lang.System.currentTimeMillis());
-
-		/* 鏃爑id , 骞挎挱 鏁版嵁鎻掑叆绯荤粺琛� */
-		if (systemZNX != null) {
-			info.setTitle(systemZNX.getTitle());
-			info.setContent(systemZNX.getContent());
-			contentJson.put("title", systemZNX.getTitle());
-			contentJson.put("content", systemZNX.getContent());
-			info.setDescription(systemZNX.getContent());
-			// 灏忕背寮�濮嬪叏鎺�
-			long id = systemZNX.getId();
-			contentJson.put("id", id);
-
-			JSONObject json = new JSONObject();
-			json.put("type", "ZNX");
-			json.put("content", contentJson);
-			json.put("miPushUrl", String.format("%s.ui.mine.AppMailDetailActivity",
-					Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-			PushRecord pushRecord = new PushRecord();
-
-			// 灏忕背 鍏ㄦ帹
-			try {
-				PushUtils.allPushXiaoMi(info, json, pushRecord);
-			} catch (Exception e1) {
-				PushLogHelper.xmError(e1);
-			}
-		} else if (msg != null) {
-			info.setTitle(msg.getTitle());
-			info.setContent(msg.getContent());
-			contentJson.put("title", msg.getTitle());
-			contentJson.put("content", msg.getContent());
-			info.setDescription(msg.getContent());
-
-			// 鎻掑叆鎺ㄩ�佽褰�
-			PushRecord pushRecord = new PushRecord();
-			info.setAlias(uId + "");
-			info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-			info.setActivty(
-					String.format("%s.ui.BrowserActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
-			contentJson.put("id", msg.getId() + "");
-
-			JSONObject json = new JSONObject();
-			json.put("type", "ZNX");
-			json.put("content", contentJson);
-			json.put("miPushUrl", String.format("%s.ui.mine.AppMailDetailActivity",
-					Constant.systemCommonConfig.getAndroidBaseactivityName()));
-			// 灏忕背 鍗曟帹
-			try {
-				PushUtils.singlePushXiaoMi(info, json, pushRecord);
-			} catch (Exception e) {
-				PushLogHelper.xmError(e);
-			}
-		}
-	}
-
-	@Override
-	public void pushWEEX(Long uid, String title, String content, String weexUrl) throws PushException {
-		// TODO 鎺ㄩ�亀eex椤甸潰
-		JSONObject json = new JSONObject();
-		json.put("url", weexUrl);
-		json.put("type", "weex");
-		// 璁剧疆鍙帹閫佺増鏈�,1.4.8浠ュ悗鐨勭増鏈彲鎺ㄩ��
-		json.put("app_version", getVersionByMinVersionCode(31));
-		MessageInfo info = new MessageInfo();
-		info.setTitle(title);
-		info.setContent(content);
-		info.setDescription(content);
-		// 灏忕背鎺ㄩ�佺綉椤�
-		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-		info.setActivty(String.format("%s.ui.mine.weex.WeexApplicationActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		PushRecord pushRecord = new PushRecord();
-
-		// 灏忕背 鍏ㄦ帹
-		if (uid == null || uid == 0) {
-			try {
-				PushUtils.allPushXiaoMi(info, json, pushRecord);
-			} catch (Exception e) {
-				PushLogHelper.xmError(e);
-			}
-		} else {
-			info.setAlias(uid + "");
-			PushUtils.singlePushXiaoMi(info, json, pushRecord);
-		}
-	}
-
-	private String getVersionByMinVersionCode(int versionCode) {
-		List<AppVersionInfo> list = appVersionInfoMapper
-				.listByPlatformAndMinVersionCode(AppVersionInfo.PLATFORM_ANDROID, versionCode);
-		String versions = "";
-		if (list != null)
-			for (AppVersionInfo appVersion : list) {
-				versions += appVersion.getVersion() + ",";
-
-			}
-		if (versions.endsWith(","))
-			versions = versions.substring(0, versions.length() - 1);
-
-		return versions;
-	}
-
-	@Override
-	public void pushBaiChuanUrl(Long uid, String title, String content, String url) throws PushException {
-		JSONObject json = new JSONObject();
-		json.put("url", url);
-		json.put("type", "baichuan");
-		// 璁剧疆鍙帹閫佺増鏈�,1.4.8浠ュ悗鐨勭増鏈彲鎺ㄩ��
-		json.put("app_version", getVersionByMinVersionCode(31));
-
-		MessageInfo info = new MessageInfo();
-		info.setTitle(title);
-		info.setContent(content);
-		info.setDescription(content);
-		// 灏忕背鎺ㄩ�佺綉椤�
-		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-
-		PushRecord pushRecord = new PushRecord();
-
-		// 灏忕背 鍏ㄦ帹
-		if (uid == null || uid == 0) {
-			try {
-				PushUtils.allPushXiaoMi(info, json, pushRecord);
-			} catch (Exception e) {
-				PushLogHelper.xmError(e);
-			}
-		} else {
-			info.setAlias(uid + "");
-			PushUtils.singlePushXiaoMi(info, json, pushRecord);
-		}
-
-	}
-
-	@Override
-	public void pushWelfareCenter(Long uid, String title, String content) throws PushException {
-		JSONObject json = new JSONObject();
-		json.put("type", "welfare");
-		json.put("miPushUrl", String.format("%s.ui.mine.WelfareCenterActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		// 1.5.1涔嬪悗鐨勭増鏈彲鎺ㄩ��
-		json.put("app_version", getVersionByMinVersionCode(36));
-
-		MessageInfo info = new MessageInfo();
-		info.setTitle(title);
-		info.setContent(content);
-		info.setDescription(content);
-		// 灏忕背鎺ㄩ�佺綉椤�
-		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
-		info.setActivty(String.format("%s.ui.mine.WelfareCenterActivity",
-				Constant.systemCommonConfig.getAndroidBaseactivityName()));
-
-		PushRecord pushRecord = new PushRecord();
-
-		// 灏忕背 鍏ㄦ帹
-		if (uid == null || uid == 0) {
-			try {
-				PushUtils.allPushXiaoMi(info, json, pushRecord);
-			} catch (Exception e) {
-				PushLogHelper.xmError(e);
-			}
-		} else {
-			info.setAlias(uid + "");
-			PushUtils.singlePushXiaoMi(info, json, pushRecord);
-		}
-	}
-
-}
+package com.yeshi.fanli.service.impl.push;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+
+import com.yeshi.fanli.dto.push.PushTypeEnum;
+import com.yeshi.fanli.entity.bus.user.AccountMessage;
+import com.yeshi.fanli.entity.push.DeviceTokenXM;
+import com.yeshi.fanli.entity.system.SystemZnx;
+import com.yeshi.fanli.entity.xinge.MessageInfo;
+import com.yeshi.fanli.entity.xinge.PushRecord;
+import com.yeshi.fanli.exception.push.PushException;
+import com.yeshi.fanli.log.PushLogHelper;
+import com.yeshi.fanli.service.inter.push.DeviceTokenXMService;
+import com.yeshi.fanli.service.inter.push.XMPushService;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.push.PushUtils;
+
+import net.sf.json.JSONObject;
+
+@Service
+public class XMPushServiceImpl implements XMPushService {
+
+	@Resource
+	private DeviceTokenXMService deviceTokenXMService;
+
+	private List<String> getRegIds(Long uid) {
+		List<DeviceTokenXM> list = deviceTokenXMService.listByUid(uid);
+
+		List<String> regIds = new ArrayList<>();
+		if (list != null)
+			for (DeviceTokenXM token : list)
+				regIds.add(token.getRegisterId());
+		return regIds;
+	}
+
+	@Async("pushExecutor")
+	@Override
+	public void pushGoods(Long uid, Long auctionId, String title, String content, String versions)
+			throws PushException {
+
+		String gid = auctionId + "";
+		JSONObject json = new JSONObject();
+		// json.put("url", "http://item.taobao.com/item.htm?id=" + gid);// IOS浣跨敤
+		json.put("id", gid);
+		json.put("type", PushTypeEnum.goodsdetail.name());
+		json.put("miPushUrl", String.format("%s.ui.recommend.GoodsBrowserActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		// 鐗堟湰鎺ㄩ��
+		if (versions != null && versions.trim().length() > 0) {
+			json.put("app_version", versions);
+		}
+
+		MessageInfo info = new MessageInfo();
+		info.setTitle(title);
+		info.setContent(content);
+		info.setDescription(content);
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+		info.setActivty(String.format("%s.ui.recommend.GoodsBrowserActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		PushRecord pushRecord = new PushRecord();
+		if (uid == null || uid == 0) {
+			// 灏忕背 鍏ㄦ帹
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		} else {
+			info.setAlias(uid + "");
+			// 灏忕背 鍗曟帹
+			PushUtils.singlePushXiaoMi(info, json, getRegIds(uid), pushRecord);
+		}
+	}
+
+	@Async("pushExecutor")
+	@Override
+	public void pushUrl(Long uid, String url, String title, String content, String versions) throws PushException {
+
+		JSONObject json = new JSONObject();
+		json.put("url", url);
+		json.put("type", PushTypeEnum.url.name());
+		json.put("webUrl", url);
+		json.put("miPushUrl", String.format("%s.ui.invite.ShareBrowserActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		// 鐗堟湰鎺ㄩ��
+		if (versions != null && versions.trim().length() > 0) {
+			json.put("app_version", versions);
+		}
+
+		MessageInfo info = new MessageInfo();
+		info.setTitle(title);
+		info.setContent(content);
+		info.setDescription(content);
+		// 灏忕背鎺ㄩ�佺綉椤�
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+		info.setActivty(String.format("%s.ui.invite.ShareBrowserActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		PushRecord pushRecord = new PushRecord();
+
+		// 灏忕背 鍏ㄦ帹
+		if (uid == null || uid == 0) {
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		} else {
+			info.setAlias(uid + "");
+			PushUtils.singlePushXiaoMi(info, json, getRegIds(uid), pushRecord);
+		}
+	}
+
+	@Async("pushExecutor")
+	@Override
+	public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX, String versions) throws PushException {
+
+		MessageInfo info = new MessageInfo();
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+
+		JSONObject contentJson = new JSONObject();
+		contentJson.put("isOpen", 0);
+		contentJson.put("createTime", java.lang.System.currentTimeMillis());
+
+		/* 鏃爑id , 骞挎挱 鏁版嵁鎻掑叆绯荤粺琛� */
+		if (systemZNX != null) {
+			info.setTitle(systemZNX.getTitle());
+			info.setContent(systemZNX.getContent());
+			contentJson.put("title", systemZNX.getTitle());
+			contentJson.put("content", systemZNX.getContent());
+			info.setDescription(systemZNX.getContent());
+			// 灏忕背寮�濮嬪叏鎺�
+			long id = systemZNX.getId();
+			contentJson.put("id", id);
+
+			JSONObject json = new JSONObject();
+			json.put("type", PushTypeEnum.ZNX.name());
+			json.put("content", contentJson);
+			json.put("miPushUrl",
+					String.format("%s.ui.main.MainActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+			// 鐗堟湰鎺ㄩ��
+			if (versions != null && versions.trim().length() > 0) {
+				json.put("app_version", versions);
+			}
+
+			PushRecord pushRecord = new PushRecord();
+
+			// 灏忕背 鍏ㄦ帹
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e1) {
+				PushLogHelper.xmError(e1);
+			}
+		} else if (msg != null) {
+			info.setTitle(msg.getTitle());
+			info.setContent(msg.getContent());
+			contentJson.put("title", msg.getTitle());
+			contentJson.put("content", msg.getContent());
+			info.setDescription(msg.getContent());
+
+			// 鎻掑叆鎺ㄩ�佽褰�
+			PushRecord pushRecord = new PushRecord();
+			info.setAlias(uId + "");
+			info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+			info.setActivty(
+					String.format("%s.ui.BrowserActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
+			contentJson.put("id", msg.getId() + "");
+
+			JSONObject json = new JSONObject();
+			json.put("type", PushTypeEnum.ZNX.name());
+			json.put("content", contentJson);
+			json.put("miPushUrl",
+					String.format("%s.ui.main.MainActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+			// 鐗堟湰鎺ㄩ��
+			if (versions != null && versions.trim().length() > 0) {
+				json.put("app_version", versions);
+			}
+
+			// 灏忕背 鍗曟帹
+			try {
+				PushUtils.singlePushXiaoMi(info, json, getRegIds(uId), pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		}
+	}
+
+	@Async("pushExecutor")
+	@Override
+	public void pushWEEX(Long uid, String title, String content, String weexUrl, String versions) throws PushException {
+
+		JSONObject json = new JSONObject();
+		json.put("url", weexUrl);
+		json.put("type", PushTypeEnum.weex.name());
+
+		// 鐗堟湰鎺ㄩ��
+		if (versions != null && versions.trim().length() > 0) {
+			json.put("app_version", versions);
+		}
+
+		MessageInfo info = new MessageInfo();
+		info.setTitle(title);
+		info.setContent(content);
+		info.setDescription(content);
+		// 灏忕背鎺ㄩ�佺綉椤�
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+		info.setActivty(String.format("%s.ui.mine.weex.WeexApplicationActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		PushRecord pushRecord = new PushRecord();
+
+		// 灏忕背 鍏ㄦ帹
+		if (uid == null || uid == 0) {
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		} else {
+			info.setAlias(uid + "");
+			PushUtils.singlePushXiaoMi(info, json, getRegIds(uid), pushRecord);
+		}
+	}
+
+	@Async("pushExecutor")
+	@Override
+	public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versions)
+			throws PushException {
+
+		JSONObject json = new JSONObject();
+		json.put("url", url);
+		json.put("type", PushTypeEnum.baichuan.name());
+		// 鐗堟湰鎺ㄩ��
+		if (versions != null && versions.trim().length() > 0) {
+			json.put("app_version", versions);
+		}
+
+		MessageInfo info = new MessageInfo();
+		info.setTitle(title);
+		info.setContent(content);
+		info.setDescription(content);
+		// 灏忕背鎺ㄩ�佺綉椤�
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+
+		PushRecord pushRecord = new PushRecord();
+
+		// 灏忕背 鍏ㄦ帹
+		if (uid == null || uid == 0) {
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		} else {
+			info.setAlias(uid + "");
+			PushUtils.singlePushXiaoMi(info, json, getRegIds(uid), pushRecord);
+		}
+	}
+
+	@Async("pushExecutor")
+	@Override
+	public void pushWelfareCenter(Long uid, String title, String content, String versions) throws PushException {
+
+		JSONObject json = new JSONObject();
+		json.put("type", PushTypeEnum.welfare.name());
+		json.put("miPushUrl", String.format("%s.ui.mine.WelfareCenterActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+		// 鐗堟湰鎺ㄩ��
+		if (versions != null && versions.trim().length() > 0) {
+			json.put("app_version", versions);
+		}
+
+		MessageInfo info = new MessageInfo();
+		info.setTitle(title);
+		info.setContent(content);
+		info.setDescription(content);
+		// 灏忕背鎺ㄩ�佺綉椤�
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+		info.setActivty(String.format("%s.ui.mine.WelfareCenterActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		PushRecord pushRecord = new PushRecord();
+
+		// 灏忕背 鍏ㄦ帹
+		if (uid == null || uid == 0) {
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		} else {
+			info.setAlias(uid + "");
+			PushUtils.singlePushXiaoMi(info, json, getRegIds(uid), pushRecord);
+		}
+	}
+
+	@Override
+	public void pushUserSignInNotification(Long uid, String title, String content, String versions)
+			throws PushException {
+		JSONObject json = new JSONObject();
+		json.put("type", PushTypeEnum.signin.name());
+		json.put("miPushUrl", String.format("%s.ui.goldtask.GoldTaskActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+		// 鐗堟湰鎺ㄩ��
+		if (versions != null && versions.trim().length() > 0) {
+			json.put("app_version", versions);
+		}
+
+		MessageInfo info = new MessageInfo();
+		info.setTitle(title);
+		info.setContent(content);
+		info.setDescription(content);
+		// 灏忕背鎺ㄩ�佺綉椤�
+		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+		info.setActivty(String.format("%s.ui.goldtask.GoldTaskActivity",
+				Constant.systemCommonConfig.getAndroidBaseactivityName()));
+
+		PushRecord pushRecord = new PushRecord();
+
+		// 灏忕背 鍏ㄦ帹
+		if (uid == null || uid == 0) {
+			try {
+				PushUtils.allPushXiaoMi(info, json, pushRecord);
+			} catch (Exception e) {
+				PushLogHelper.xmError(e);
+			}
+		} else {
+			info.setAlias(uid + "");
+			PushUtils.singlePushXiaoMi(info, json, getRegIds(uid), pushRecord);
+		}
+	}
+
+}

--
Gitblit v1.8.0