系统配置改为数据库

admin

2021-06-01 4f5a5b0a00c01491f009074351089f086f950d3e

 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;

@@ -29,6 +32,9 @@
   @Resource
   private DeviceTokenXMService deviceTokenXMService;

    @Resource
    private SystemConfigService systemConfigService;

   private List<String> getRegIds(Long uid) {
      List<DeviceTokenXM> list = deviceTokenXMService.listByUid(uid);

@@ -41,7 +47,7 @@

   @Async("pushExecutor")
   @Override
   public void pushGoods(Long uid, Long auctionId, String title, String content, String versions)
    public void pushGoods(Long uid, Long auctionId, String title, String content, String versions, SystemEnum system)
         throws PushException {

      String gid = auctionId + "";
@@ -50,7 +56,7 @@
      json.put("id", gid);
      json.put("type", PushTypeEnum.goodsdetail.name());
      json.put("miPushUrl", String.format("%s.ui.recommend.GoodsBrowserActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));

      // 版本推送
      if (versions != null && versions.trim().length() > 0) {
@@ -61,9 +67,9 @@
      info.setTitle(title);
      info.setContent(content);
      info.setDescription(content);
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));
      info.setActivty(String.format("%s.ui.recommend.GoodsBrowserActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));

      PushRecord pushRecord = new PushRecord();
      if (uid == null || uid == 0) {
@@ -82,14 +88,14 @@

   @Async("pushExecutor")
   @Override
   public void pushUrl(Long uid, String url, String title, String content, String versions) throws PushException {
    public void pushUrl(Long uid, String url, String title, String content, String versions, SystemEnum system) 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()));
                getAndroidPackageName(system)));

      // 版本推送
      if (versions != null && versions.trim().length() > 0) {
@@ -101,9 +107,9 @@
      info.setContent(content);
      info.setDescription(content);
      // 小米推送网页
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));
      info.setActivty(String.format("%s.ui.invite.ShareBrowserActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));

      PushRecord pushRecord = new PushRecord();

@@ -122,10 +128,10 @@

   @Async("pushExecutor")
   @Override
   public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX, String versions) throws PushException {
    public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX, String versions, SystemEnum system) throws PushException {

      MessageInfo info = new MessageInfo();
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));

      JSONObject contentJson = new JSONObject();
      contentJson.put("isOpen", 0);
@@ -146,7 +152,7 @@
         json.put("type", PushTypeEnum.ZNX.name());
         json.put("content", contentJson);
         json.put("miPushUrl",
               String.format("%s.ui.main.MainActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
                    String.format("%s.ui.main.MainActivity", getAndroidPackageName(system)));

         // 版本推送
         if (versions != null && versions.trim().length() > 0) {
@@ -171,16 +177,16 @@
         // 插入推送记录
         PushRecord pushRecord = new PushRecord();
         info.setAlias(uId + "");
         info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
            info.setPackageName(getAndroidBaseactivityName(system));
         info.setActivty(
               String.format("%s.ui.BrowserActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
                    String.format("%s.ui.BrowserActivity", getAndroidPackageName(system)));
         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()));
                    String.format("%s.ui.main.MainActivity", getAndroidPackageName(system)));

         // 版本推送
         if (versions != null && versions.trim().length() > 0) {
@@ -198,7 +204,7 @@

   @Async("pushExecutor")
   @Override
   public void pushWEEX(Long uid, String title, String content, String weexUrl, String versions) throws PushException {
    public void pushWEEX(Long uid, String title, String content, String weexUrl, String versions, SystemEnum system) throws PushException {

      JSONObject json = new JSONObject();
      json.put("url", weexUrl);
@@ -214,9 +220,9 @@
      info.setContent(content);
      info.setDescription(content);
      // 小米推送网页
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));
      info.setActivty(String.format("%s.ui.mine.weex.WeexApplicationActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));

      PushRecord pushRecord = new PushRecord();

@@ -235,7 +241,7 @@

   @Async("pushExecutor")
   @Override
   public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versions)
    public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versions, SystemEnum system)
         throws PushException {

      JSONObject json = new JSONObject();
@@ -251,7 +257,7 @@
      info.setContent(content);
      info.setDescription(content);
      // 小米推送网页
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));

      PushRecord pushRecord = new PushRecord();

@@ -270,12 +276,12 @@

   @Async("pushExecutor")
   @Override
   public void pushWelfareCenter(Long uid, String title, String content, String versions) throws PushException {
    public void pushWelfareCenter(Long uid, String title, String content, String versions, SystemEnum system) throws PushException {

      JSONObject json = new JSONObject();
      json.put("type", PushTypeEnum.welfare.name());
      json.put("miPushUrl", String.format("%s.ui.mine.WelfareCenterActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));
      // 版本推送
      if (versions != null && versions.trim().length() > 0) {
         json.put("app_version", versions);
@@ -286,9 +292,9 @@
      info.setContent(content);
      info.setDescription(content);
      // 小米推送网页
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));
      info.setActivty(String.format("%s.ui.mine.WelfareCenterActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));

      PushRecord pushRecord = new PushRecord();

@@ -306,12 +312,12 @@
   }

   @Override
   public void pushUserSignInNotification(Long uid, String title, String content, String versions)
    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",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));
      // 版本推送
      if (versions != null && versions.trim().length() > 0) {
         json.put("app_version", versions);
@@ -322,9 +328,9 @@
      info.setContent(content);
      info.setDescription(content);
      // 小米推送网页
      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
        info.setPackageName(getAndroidBaseactivityName(system));
      info.setActivty(String.format("%s.ui.goldtask.GoldTaskActivity",
            Constant.systemCommonConfig.getAndroidBaseactivityName()));
                getAndroidPackageName(system)));

      PushRecord pushRecord = new PushRecord();

@@ -341,4 +347,12 @@
      }
   }

    private String getAndroidBaseactivityName(SystemEnum system) {
        return systemConfigService.getValueCache(SystemConfigKeyEnum.androidBaseActivityName, system);
    }

    private String getAndroidPackageName(SystemEnum system) {
        return systemConfigService.getValueCache(SystemConfigKeyEnum.androidPackageNames, system);
    }

}