admin
2019-08-26 d28bed1a1275131a5ca37f7da37961e2b518ac07
fanli/src/main/java/com/yeshi/fanli/service/impl/push/PushServiceImpl.java
@@ -60,13 +60,12 @@
   @Resource
   private AccountMessageMapper accountMessageMapper;
   @Resource
   private AppVersionService appVersionService;
   @Override
   public void pushGoods(Long uid, String url, String title, String content, List<String> listIOS,
   public void pushGoods(Long uid, String title, String content, String url, List<String> listIOS,
         List<String> listAndroid) throws PushException {
      String gids = url.split("id=")[1];
      String gid = gids.split("&")[0];
@@ -75,28 +74,33 @@
      if (StringUtil.isNullOrEmpty(title))
         throw new PushException(1, "请填写推送标题");
      if (StringUtil.isNullOrEmpty(content))
         throw new PushException(1, "请填写推送内容");
      /* IOS端推送   (注明:list等于 'null' 时全推, size等于0 不做推送) */
         throw new PushException(1, "请填写推送内容");
      /* IOS端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:0
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if(listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushGoods(uid, Long.parseLong(gid), title, content, codes);
         }
      }
      /* Android端推送    (注明:list等于 'null' 时全推, size等于0 不做推送)  */
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:0
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushGoods(uid, Long.parseLong(gid), title, content, versions);
         }
         // 华为推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            hwPushService.pushGoods(uid, Long.parseLong(gid), title, content, versionCodeList);
         }
      }
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUid(uid);
      pushRecord.setState(1);
@@ -109,9 +113,8 @@
      pushRecordMapper.insertSelective(pushRecord);
   }
   @Override
   public void pushUrl(Long uid, String url, String title, String content, List<String> listIOS,
   public void pushUrl(Long uid, String title, String content, String url, List<String> listIOS,
         List<String> listAndroid) throws PushException {
      if (StringUtil.isNullOrEmpty(url))
@@ -120,28 +123,33 @@
         throw new PushException(1, "无推送标题");
      if (StringUtil.isNullOrEmpty(content))
         throw new PushException(1, "无推送内容");
      /* IOS端推送   (注明:list等于 'null' 时全推, size等于0 不做推送) */
      /* IOS端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:0
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if(listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushUrl(uid, url, title, content, codes);
         }
      }
      /* Android端推送    (注明:list等于 'null' 时全推, size等于0 不做推送)  */
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:0
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushUrl(uid, url, title, content, versions);
            hwPushService.pushUrl(uid, url, title, content, versions);
         }
         // 华为推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            hwPushService.pushUrl(uid, url, title, content, versionCodeList);
         }
      }
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUid(uid);
      pushRecord.setState(1);
@@ -153,10 +161,9 @@
      pushRecordMapper.insertSelective(pushRecord);
   }
   @Override
   public void pushZNX(Long uId, String title, String content, List<String> listIOS,
         List<String> listAndroid) throws PushException {
   public void pushZNX(Long uId, String title, String content, List<String> listIOS, List<String> listAndroid)
         throws PushException {
      if (StringUtil.isNullOrEmpty(title))
         throw new PushException(1, "无推送标题");
      if (StringUtil.isNullOrEmpty(content))
@@ -164,7 +171,7 @@
      SystemZnx systemZnx = null;
      AccountMessage accountMessage = null;
      /* 无uid , 广播 数据插入系统表 */
      if (uId == null || uId == 0) {
         // 插入数据库(系统站内信数据)
@@ -182,28 +189,33 @@
         accountMessage.setContent(content);
         accountMessageMapper.insertSelective(accountMessage);
      }
      /* IOS端推送   (注明:list等于 'null' 时全推, size等于0 不做推送) */
      /* IOS端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:0
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if(listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushZNX(uId, accountMessage, systemZnx, codes);
         }
      }
      /* Android端推送    (注明:list等于 'null' 时全推, size等于0 不做推送)  */
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:0
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushZNX(uId, accountMessage, systemZnx, versions);
            hwPushService.pushZNX(uId, accountMessage, systemZnx, versions);
         }
         // 华为推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            hwPushService.pushZNX(uId, title, content, versionCodeList);
         }
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUid(uId);
@@ -215,7 +227,6 @@
      pushRecordMapper.insertSelective(pushRecord);
   }
   @Override
   public void pushWEEX(Long uid, String title, String content, String weexUrl, List<String> listIOS,
         List<String> listAndroid) throws PushException {
@@ -223,28 +234,35 @@
         throw new PushException(1, "无推送标题");
      if (StringUtil.isNullOrEmpty(content))
         throw new PushException(1, "无推送内容");
      // 适用版本 1.4.8及以后 推送weex页面
      /* IOS端推送   (注明:list等于 'null' 时全推, size等于0 不做推送) */
      /* IOS端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:0
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if(listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushWEEX(uid, title, content, weexUrl, codes);
         }
      }
      /* Android端推送    (注明:list等于 'null' 时全推, size等于0 不做推送)  */
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:31
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
         String versions = getEffectiveVersions(0, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushWEEX(uid, title, content, weexUrl, versions);
         }
      }
      // 华为推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         hwPushService.pushWEEX(uid, title, content, weexUrl, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setTitle(title);
@@ -256,37 +274,43 @@
      pushRecordMapper.insertSelective(pushRecord);
   }
   @Override
   public void pushBaiChuanUrl(Long uid, String title, String content, String url, List<String> listIOS,
         List<String> listAndroid) throws PushException {
      if (StringUtil.isNullOrEmpty(title))
         throw new PushException(1, "无推送标题");
      if (StringUtil.isNullOrEmpty(content))
         throw new PushException(1, "无推送内容");
      // 适用版本 1.4.8及以后 推送百川网页
      /* IOS端推送   (注明:list等于 'null' 时全推, size等于0 不做推送) */
      /* IOS端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:0
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if(listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushBaiChuanUrl(uid, title, content, url, codes);
         }
      }
      /* Android端推送    (注明:list等于 'null' 时全推, size等于0 不做推送)  */
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:31
         String versions = getEffectiveVersions(31, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
         String versions = getEffectiveVersions(31, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushBaiChuanUrl(uid, title, content, url, versions);
         }
      }
      // 华为推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         hwPushService.pushBaiChuanUrl(uid, title, content, url, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUrl(url);
@@ -299,36 +323,41 @@
      pushRecordMapper.insertSelective(pushRecord);
   }
   @Override
   public void pushWelfareCenter(Long uid, String title, String content, List<String> listIOS,
         List<String> listAndroid) throws PushException {
      if (StringUtil.isNullOrEmpty(title))
         throw new PushException(1, "无推送标题");
      if (StringUtil.isNullOrEmpty(content))
         throw new PushException(1, "无推送内容");
      /* IOS端推送   (注明:list等于 'null' 时全推, size等于0 不做推送) */
      /* IOS端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:0
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if(listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
         String codes = getEffectiveVersionCodes(0, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushWelfareCenter(uid, title, content, codes);
         }
      }
      /* Android端推送    (注明:list等于 'null' 时全推, size等于0 不做推送)  */
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:36
         String versions = getEffectiveVersions(36, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
         String versions = getEffectiveVersions(36, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushWelfareCenter(uid, title, content, versions);
         }
      }
      // 华为推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         hwPushService.pushWelfareCenter(uid, title, content, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setTitle(title);
@@ -340,20 +369,19 @@
      pushRecordMapper.insertSelective(pushRecord);
   }
   /**
    * 查询能推送版本号
    *
    * @param versionCode
    * @param listVersion
    * @return
    */
   private String getEffectiveVersions(int minCode, String type, List<String> listVersion) throws PushException{
   private String getEffectiveVersions(int minCode, String type, List<String> listVersion) throws PushException {
      if (minCode == 0 && listVersion == null) {
         return null;
      }
      String versions = "";
      if (listVersion == null) {
         List<AppVersionInfo> list = appVersionService.listByPlatformAndMinVersionCode(type, minCode);
@@ -366,34 +394,34 @@
         List<AppVersionInfo> list = appVersionService.listByVersions(type, listVersion);
         if (list != null) {
            for (AppVersionInfo appVersion : list) {
               Integer code =   appVersion.getVersionCode();
               Integer code = appVersion.getVersionCode();
               if (code != null && code >= minCode) {
                  versions += appVersion.getVersion() + ",";
               }
            }
         }
         }
      }
      if (versions.endsWith(",")) {
         versions = versions.substring(0, versions.length() - 1);
      }
      return versions;
   }
   /**
    * 查询能推送版本号code
    *
    * @param versionCode
    * @param listVersion
    * @return
    */
   private String getEffectiveVersionCodes(int minCode, String type, List<String> listVersion) throws PushException{
   private String getEffectiveVersionCodes(int minCode, String type, List<String> listVersion) throws PushException {
      if (minCode == 0 && listVersion == null) {
         return null;
      }
      String versionCodes = "";
      if (listVersion == null) {
         List<AppVersionInfo> list = appVersionService.listByPlatformAndMinVersionCode(type, minCode);
@@ -406,19 +434,19 @@
         List<AppVersionInfo> list = appVersionService.listByVersions(type, listVersion);
         if (list != null) {
            for (AppVersionInfo appVersion : list) {
               Integer code =   appVersion.getVersionCode();
               Integer code = appVersion.getVersionCode();
               if (code != null && code >= minCode) {
                  versionCodes += appVersion.getVersionCode() + ",";
               }
            }
         }
         }
      }
      if (versionCodes.endsWith(",")) {
         versionCodes = versionCodes.substring(0, versionCodes.length() - 1);
      }
      return versionCodes;
   }
}