From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/service/impl/push/XMPushServiceImpl.java | 552 ++++++++++++++++++++++++++++--------------------------
1 files changed, 283 insertions(+), 269 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 0f65bd7..dffd425 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
@@ -5,6 +5,9 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.entity.SystemEnum;
+import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;
+import com.yeshi.fanli.service.inter.config.SystemConfigService;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
@@ -26,319 +29,330 @@
@Service
public class XMPushServiceImpl implements XMPushService {
- @Resource
- private DeviceTokenXMService deviceTokenXMService;
+ @Resource
+ private DeviceTokenXMService deviceTokenXMService;
- private List<String> getRegIds(Long uid) {
- List<DeviceTokenXM> list = deviceTokenXMService.listByUid(uid);
+ @Resource
+ private SystemConfigService systemConfigService;
- List<String> regIds = new ArrayList<>();
- if (list != null)
- for (DeviceTokenXM token : list)
- regIds.add(token.getRegisterId());
- return regIds;
- }
+ private List<String> getRegIds(Long uid) {
+ List<DeviceTokenXM> list = deviceTokenXMService.listByUid(uid);
- @Async("pushExecutor")
- @Override
- public void pushGoods(Long uid, Long auctionId, String title, String content, String versions)
- throws PushException {
+ List<String> regIds = new ArrayList<>();
+ if (list != null)
+ for (DeviceTokenXM token : list)
+ regIds.add(token.getRegisterId());
+ return regIds;
+ }
- 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()));
+ @Async("pushExecutor")
+ @Override
+ public void pushGoods(Long uid, String auctionId, String title, String content, String versions, SystemEnum system)
+ throws PushException {
- // 鐗堟湰鎺ㄩ��
- if (versions != null && versions.trim().length() > 0) {
- json.put("app_version", versions);
- }
+ 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",
+ getAndroidPackageName(system)));
- 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()));
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- 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);
- }
- }
+ MessageInfo info = new MessageInfo();
+ info.setTitle(title);
+ info.setContent(content);
+ info.setDescription(content);
+ info.setPackageName(getAndroidBaseactivityName(system));
+ info.setActivty(String.format("%s.ui.recommend.GoodsBrowserActivity",
+ getAndroidPackageName(system)));
- @Async("pushExecutor")
- @Override
- public void pushUrl(Long uid, String url, String title, String content, String versions) throws PushException {
+ 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);
+ }
+ }
- 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()));
+ @Async("pushExecutor")
+ @Override
+ public void pushUrl(Long uid, String url, String title, String content, String versions, SystemEnum system) throws PushException {
- // 鐗堟湰鎺ㄩ��
- if (versions != null && versions.trim().length() > 0) {
- json.put("app_version", versions);
- }
+ 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",
+ getAndroidPackageName(system)));
- 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()));
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- PushRecord pushRecord = new PushRecord();
+ MessageInfo info = new MessageInfo();
+ info.setTitle(title);
+ info.setContent(content);
+ info.setDescription(content);
+ // 灏忕背鎺ㄩ�佺綉椤�
+ info.setPackageName(getAndroidBaseactivityName(system));
+ info.setActivty(String.format("%s.ui.invite.ShareBrowserActivity",
+ getAndroidPackageName(system)));
- // 灏忕背 鍏ㄦ帹
- 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);
- }
- }
+ PushRecord pushRecord = new PushRecord();
- @Async("pushExecutor")
- @Override
- public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX, String versions) throws PushException {
+ // 灏忕背 鍏ㄦ帹
+ 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);
+ }
+ }
- MessageInfo info = new MessageInfo();
- info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+ @Async("pushExecutor")
+ @Override
+ public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX, String versions, SystemEnum system) throws PushException {
- JSONObject contentJson = new JSONObject();
- contentJson.put("isOpen", 0);
- contentJson.put("createTime", java.lang.System.currentTimeMillis());
+ MessageInfo info = new MessageInfo();
+ info.setPackageName(getAndroidBaseactivityName(system));
- /* 鏃爑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 contentJson = new JSONObject();
+ contentJson.put("isOpen", 0);
+ contentJson.put("createTime", java.lang.System.currentTimeMillis());
- 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()));
+ /* 鏃爑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);
- // 鐗堟湰鎺ㄩ��
- if (versions != null && versions.trim().length() > 0) {
- json.put("app_version", versions);
- }
+ JSONObject json = new JSONObject();
+ json.put("type", PushTypeEnum.ZNX.name());
+ json.put("content", contentJson);
+ json.put("miPushUrl",
+ String.format("%s.ui.main.MainActivity", getAndroidPackageName(system)));
- PushRecord pushRecord = new PushRecord();
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- // 灏忕背 鍏ㄦ帹
- 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();
- // 鎻掑叆鎺ㄩ�佽褰�
- 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() + "");
+ // 灏忕背 鍏ㄦ帹
+ 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());
- 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()));
+ // 鎻掑叆鎺ㄩ�佽褰�
+ PushRecord pushRecord = new PushRecord();
+ info.setAlias(uId + "");
+ info.setPackageName(getAndroidBaseactivityName(system));
+ info.setActivty(
+ String.format("%s.ui.BrowserActivity", getAndroidPackageName(system)));
+ contentJson.put("id", msg.getId() + "");
- // 鐗堟湰鎺ㄩ��
- if (versions != null && versions.trim().length() > 0) {
- json.put("app_version", versions);
- }
+ JSONObject json = new JSONObject();
+ json.put("type", PushTypeEnum.ZNX.name());
+ json.put("content", contentJson);
+ json.put("miPushUrl",
+ String.format("%s.ui.main.MainActivity", getAndroidPackageName(system)));
- // 灏忕背 鍗曟帹
- try {
- PushUtils.singlePushXiaoMi(info, json, getRegIds(uId), pushRecord);
- } catch (Exception e) {
- PushLogHelper.xmError(e);
- }
- }
- }
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- @Async("pushExecutor")
- @Override
- public void pushWEEX(Long uid, String title, String content, String weexUrl, String versions) throws PushException {
+ // 灏忕背 鍗曟帹
+ try {
+ PushUtils.singlePushXiaoMi(info, json, getRegIds(uId), pushRecord);
+ } catch (Exception e) {
+ PushLogHelper.xmError(e);
+ }
+ }
+ }
- JSONObject json = new JSONObject();
- json.put("url", weexUrl);
- json.put("type", PushTypeEnum.weex.name());
+ @Async("pushExecutor")
+ @Override
+ public void pushWEEX(Long uid, String title, String content, String weexUrl, String versions, SystemEnum system) throws PushException {
- // 鐗堟湰鎺ㄩ��
- if (versions != null && versions.trim().length() > 0) {
- json.put("app_version", versions);
- }
+ JSONObject json = new JSONObject();
+ json.put("url", weexUrl);
+ json.put("type", PushTypeEnum.weex.name());
- 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()));
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- PushRecord pushRecord = new PushRecord();
+ MessageInfo info = new MessageInfo();
+ info.setTitle(title);
+ info.setContent(content);
+ info.setDescription(content);
+ // 灏忕背鎺ㄩ�佺綉椤�
+ info.setPackageName(getAndroidBaseactivityName(system));
+ info.setActivty(String.format("%s.ui.mine.weex.WeexApplicationActivity",
+ getAndroidPackageName(system)));
- // 灏忕背 鍏ㄦ帹
- 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);
- }
- }
+ PushRecord pushRecord = new PushRecord();
- @Async("pushExecutor")
- @Override
- public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versions)
- throws PushException {
+ // 灏忕背 鍏ㄦ帹
+ 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);
+ }
+ }
- 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);
- }
+ @Async("pushExecutor")
+ @Override
+ public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versions, SystemEnum system)
+ throws PushException {
- MessageInfo info = new MessageInfo();
- info.setTitle(title);
- info.setContent(content);
- info.setDescription(content);
- // 灏忕背鎺ㄩ�佺綉椤�
- info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
+ 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);
+ }
- PushRecord pushRecord = new PushRecord();
+ MessageInfo info = new MessageInfo();
+ info.setTitle(title);
+ info.setContent(content);
+ info.setDescription(content);
+ // 灏忕背鎺ㄩ�佺綉椤�
+ info.setPackageName(getAndroidBaseactivityName(system));
- // 灏忕背 鍏ㄦ帹
- 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);
- }
- }
+ PushRecord pushRecord = new PushRecord();
- @Async("pushExecutor")
- @Override
- public void pushWelfareCenter(Long uid, String title, String content, String versions) throws PushException {
+ // 灏忕背 鍏ㄦ帹
+ 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);
+ }
+ }
- 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);
- }
+ @Async("pushExecutor")
+ @Override
+ public void pushWelfareCenter(Long uid, String title, String content, String versions, SystemEnum system) throws PushException {
- 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()));
+ JSONObject json = new JSONObject();
+ json.put("type", PushTypeEnum.welfare.name());
+ json.put("miPushUrl", String.format("%s.ui.mine.WelfareCenterActivity",
+ getAndroidPackageName(system)));
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- PushRecord pushRecord = new PushRecord();
+ MessageInfo info = new MessageInfo();
+ info.setTitle(title);
+ info.setContent(content);
+ info.setDescription(content);
+ // 灏忕背鎺ㄩ�佺綉椤�
+ info.setPackageName(getAndroidBaseactivityName(system));
+ info.setActivty(String.format("%s.ui.mine.WelfareCenterActivity",
+ getAndroidPackageName(system)));
- // 灏忕背 鍏ㄦ帹
- 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);
- }
- }
+ PushRecord pushRecord = new 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);
- }
+ // 灏忕背 鍏ㄦ帹
+ 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);
+ }
+ }
- 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()));
+ @Override
+ public void pushUserSignInNotification(Long uid, String title, String content, String versions, SystemEnum system)
+ throws PushException {
+ JSONObject json = new JSONObject();
+ json.put("type", PushTypeEnum.signin.name());
+ json.put("miPushUrl", String.format("%s.ui.goldtask.GoldTaskActivity",
+ getAndroidPackageName(system)));
+ // 鐗堟湰鎺ㄩ��
+ if (versions != null && versions.trim().length() > 0) {
+ json.put("app_version", versions);
+ }
- PushRecord pushRecord = new PushRecord();
+ MessageInfo info = new MessageInfo();
+ info.setTitle(title);
+ info.setContent(content);
+ info.setDescription(content);
+ // 灏忕背鎺ㄩ�佺綉椤�
+ info.setPackageName(getAndroidBaseactivityName(system));
+ info.setActivty(String.format("%s.ui.goldtask.GoldTaskActivity",
+ getAndroidPackageName(system)));
- // 灏忕背 鍏ㄦ帹
- 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);
- }
- }
+ 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);
+ }
+ }
+
+ private String getAndroidBaseactivityName(SystemEnum system) {
+ return systemConfigService.getValueCache(SystemConfigKeyEnum.androidBaseActivityName, system);
+ }
+
+ private String getAndroidPackageName(SystemEnum system) {
+ return systemConfigService.getValueCache(SystemConfigKeyEnum.androidPackageNames, system);
+ }
}
--
Gitblit v1.8.0