淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 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));

      /* 无uid , 广播 数据插入系统表 */
      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()));
        /* 无uid , 广播 数据插入系统表 */
        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);
    }

}