admin
2020-05-19 744594ef1a2f530fc3e86ea9dc48b62247f79420
fanli/src/main/java/com/yeshi/fanli/service/impl/push/PushServiceImpl.java
@@ -6,21 +6,23 @@
import org.springframework.stereotype.Service;
import com.yeshi.fanli.controller.admin.PushController;
import com.yeshi.fanli.dao.mybatis.AccountMessageMapper;
import com.yeshi.fanli.dao.mybatis.push.PushRecordMapper;
import com.yeshi.fanli.dto.push.PushTypeEnum;
import com.yeshi.fanli.entity.AppVersionInfo;
import com.yeshi.fanli.entity.bus.user.AccountMessage;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.system.SystemZnx;
import com.yeshi.fanli.entity.xinge.PushRecord;
import com.yeshi.fanli.exception.PushException;
import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.service.inter.config.AppVersionService;
import com.yeshi.fanli.service.inter.push.DeviceTokenHWService;
import com.yeshi.fanli.service.inter.push.HWPushService;
import com.yeshi.fanli.service.inter.push.IOSPushService;
import com.yeshi.fanli.service.inter.push.OPPOPushService;
import com.yeshi.fanli.service.inter.push.PushRecordService;
import com.yeshi.fanli.service.inter.push.PushService;
import com.yeshi.fanli.service.inter.push.VIVOPushService;
import com.yeshi.fanli.service.inter.push.XMPushService;
import com.yeshi.fanli.service.inter.user.SystemZnxService;
import com.yeshi.fanli.util.Constant;
@@ -54,6 +56,12 @@
   @Resource
   private XMPushService xmPushService;
   @Resource
   private OPPOPushService oPPOPushService;
   @Resource
   private VIVOPushService vIVOPushService;
   @Resource
   private PushRecordMapper pushRecordMapper;
@@ -99,12 +107,28 @@
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            hwPushService.pushGoods(uid, Long.parseLong(gid), title, content, versionCodeList);
         }
         // OPPO推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            oPPOPushService.pushGoods(uid, Long.parseLong(gid), title, content, versionCodeList);
         }
         // VIVO推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            vIVOPushService.pushGoods(uid, Long.parseLong(gid), title, content, versionCodeList);
         }
      }
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUid(uid);
      pushRecord.setState(1);
      pushRecord.setType(PushController.GOODS); // 都成功
      pushRecord.setType(PushTypeEnum.goodsdetail.getCode()); // 都成功
      pushRecord.setUrl(url);
      pushRecord.setTitle(title);
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
@@ -148,12 +172,29 @@
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            hwPushService.pushUrl(uid, url, title, content, versionCodeList);
         }
         // OPPO推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            oPPOPushService.pushUrl(uid, url, title, content, versionCodeList);
         }
         // VIVO推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            vIVOPushService.pushUrl(uid, url, title, content, versionCodeList);
         }
      }
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUid(uid);
      pushRecord.setState(1);
      pushRecord.setType(PushController.URL);
      pushRecord.setType(PushTypeEnum.url.getCode());
      pushRecord.setUrl(url);
      pushRecord.setTitle(title);
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
@@ -214,6 +255,22 @@
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            hwPushService.pushZNX(uId, title, content, versionCodeList);
         }
         // OPPO推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            oPPOPushService.pushZNX(uId, title, content, versionCodeList);
         }
         // VIVO推送
         if (listAndroid == null || listAndroid.size() > 0) {
            List<Integer> versionCodeList = null;
            if (listAndroid != null)
               versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
            vIVOPushService.pushZNX(uId, title, content, versionCodeList);
         }
      }
      // 插入推送记录
@@ -221,7 +278,7 @@
      pushRecord.setUid(uId);
      pushRecord.setTitle(title);
      pushRecord.setState(1); // 成功
      pushRecord.setType(PushController.ZNX); // 类型:站内信
      pushRecord.setType(PushTypeEnum.ZNX.getCode()); // 类型:站内信
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
      pushRecord.setCreatetime(java.lang.System.currentTimeMillis());
      pushRecordMapper.insertSelective(pushRecord);
@@ -263,12 +320,28 @@
         hwPushService.pushWEEX(uid, title, content, weexUrl, versionCodeList);
      }
      // OPPO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         oPPOPushService.pushWEEX(uid, title, content, weexUrl, versionCodeList);
      }
      // VIVO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         vIVOPushService.pushWEEX(uid, title, content, weexUrl, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setTitle(title);
      pushRecord.setUid(uid);
      pushRecord.setState(1); // 成功
      pushRecord.setType(PushController.WEEX); // 类型:WEEX
      pushRecord.setType(PushTypeEnum.weex.getCode()); // 类型:WEEX
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
      pushRecord.setCreatetime(java.lang.System.currentTimeMillis());
      pushRecordMapper.insertSelective(pushRecord);
@@ -311,13 +384,29 @@
         hwPushService.pushBaiChuanUrl(uid, title, content, url, versionCodeList);
      }
      // OPPO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         oPPOPushService.pushBaiChuanUrl(uid, title, content, url, versionCodeList);
      }
      // VIVO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         vIVOPushService.pushBaiChuanUrl(uid, title, content, url, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setUrl(url);
      pushRecord.setTitle(title);
      pushRecord.setUid(uid);
      pushRecord.setState(1); // 成功
      pushRecord.setType(PushController.BAICHUAN); // 类型:百川
      pushRecord.setType(PushTypeEnum.baichuan.getCode()); // 类型:百川
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
      pushRecord.setCreatetime(java.lang.System.currentTimeMillis());
      pushRecordMapper.insertSelective(pushRecord);
@@ -358,12 +447,28 @@
         hwPushService.pushWelfareCenter(uid, title, content, versionCodeList);
      }
      // OPPO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         oPPOPushService.pushWelfareCenter(uid, title, content, versionCodeList);
      }
      // VIVO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         vIVOPushService.pushWelfareCenter(uid, title, content, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setTitle(title);
      pushRecord.setUid(uid);
      pushRecord.setState(1); // 成功
      pushRecord.setType(PushController.WELFARE_CENTER); // 类型:百川
      pushRecord.setType(PushTypeEnum.welfare.getCode()); // 类型:百川
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
      pushRecord.setCreatetime(java.lang.System.currentTimeMillis());
      pushRecordMapper.insertSelective(pushRecord);
@@ -449,4 +554,65 @@
      return versionCodes;
   }
   @Override
   public void pushUserSignInNotification(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 不做推送) */
      if (listIOS == null || listIOS.size() > 0) {
         // 限制推送版本号:1.6.5以后
         String codes = getEffectiveVersionCodes(60, AppVersionInfo.PLATFORM_IOS, listIOS);
         if (listIOS == null || (listIOS.size() > 0 && codes != null && codes.trim().length() > 0)) {
            iosPushService.pushUserSignInNotification(uid, title, content, codes);
         }
      }
      /* Android端推送 (注明:list等于 'null' 时全推, size等于0 不做推送) */
      if (listAndroid == null || listAndroid.size() > 0) {
         // 限制推送版本号:1.6.5以后
         String versions = getEffectiveVersions(47, AppVersionInfo.PLATFORM_ANDROID, listAndroid);
         if (listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {
            xmPushService.pushUserSignInNotification(uid, title, content, versions);
         }
      }
      // 华为推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         hwPushService.pushUserSignInNotification(uid, title, content, versionCodeList);
      }
      // OPPO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         oPPOPushService.pushUserSignInNotification(uid, title, content, versionCodeList);
      }
      // VIVO推送
      if (listAndroid == null || listAndroid.size() > 0) {
         List<Integer> versionCodeList = null;
         if (listAndroid != null)
            versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);
         vIVOPushService.pushUserSignInNotification(uid, title, content, versionCodeList);
      }
      // 插入推送记录
      PushRecord pushRecord = new PushRecord();
      pushRecord.setTitle(title);
      pushRecord.setUid(uid);
      pushRecord.setState(1); // 成功
      pushRecord.setType(PushTypeEnum.signin.getCode()); // 类型:百川
      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());
      pushRecord.setCreatetime(java.lang.System.currentTimeMillis());
      pushRecordMapper.insertSelective(pushRecord);
   }
}