推送类型优化

admin

2019-08-26 aad0425e6a103b633aab4c36642cdd34e95ace62

 fanli/src/main/java/com/yeshi/fanli/service/impl/push/IOSPushServiceImpl.java

@@ -12,9 +12,9 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.yeshi.fanli.controller.admin.PushController;

import com.yeshi.fanli.dao.mybatis.push.DeviceTokenIOSMapper;

import com.yeshi.fanli.dao.mybatis.push.PushQueueRecordMapper;

import com.yeshi.fanli.dto.push.PushTypeEnum;

import com.yeshi.fanli.entity.bus.user.AccountMessage;

import com.yeshi.fanli.entity.push.DeviceTokenIOS;

import com.yeshi.fanli.entity.push.PushQueueRecord;

@@ -46,7 +46,8 @@


   @Async("pushExecutor")

   @Override

   public void pushGoods(Long uid, Long auctionId, String title, String content, String versionCodes) throws PushException {

   public void pushGoods(Long uid, Long auctionId, String title, String content, String versionCodes)

         throws PushException {



      String url = "https://item.taobao.com/item.htm?id=" + auctionId;

      JSONObject json = new JSONObject();

@@ -65,14 +66,14 @@


      PushRecord pushRecord = new PushRecord();

      pushRecord.setState(1);

      pushRecord.setType(PushController.GOODS); // 都成功

      pushRecord.setType(PushTypeEnum.goodsdetail.getCode()); // 都成功

      pushRecord.setUrl(url);

      pushRecord.setTitle(title);

      pushRecord.setAppName(Constant.systemCommonConfig.getProjectChineseName());



      if (uid == null || uid == 0) {



         addPushIOSQueue(info, url, PushController.GOODS, versionCodes);

         addPushIOSQueue(info, url, PushTypeEnum.goodsdetail.getCode(), versionCodes);



         /*

          * // 查询IOS所有设备号 // TODO 需要全推 List<String> deviceTokenList =

@@ -101,7 +102,7 @@
            }



         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushController.GOODS);

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushTypeEnum.goodsdetail.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

@@ -133,7 +134,7 @@
      if (uid == null || uid == 0) {

         // TODO 需要全推



         addPushIOSQueue(info, url, PushController.URL, versionCodes);

         addPushIOSQueue(info, url, PushTypeEnum.url.getCode(), versionCodes);



         /*

          * List<String> deviceTokenList = getDeviceTokenList(1, 1000);

@@ -158,13 +159,12 @@
               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushController.URL);

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushTypeEnum.url.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

      }

   }



   

   @Async("pushExecutor")

   @Override

@@ -198,7 +198,7 @@


         // TODO 需要全推



         addPushIOSQueue(info, id + "", PushController.ZNX, versionCodes);

         addPushIOSQueue(info, id + "", PushTypeEnum.ZNX.getCode(), versionCodes);



         /*

          * List<String> deviceTokenList = getDeviceTokenList(1, 1000);

@@ -250,7 +250,7 @@


         // IOS 单推

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, "0", PushController.ZNX);

            IOSPushUtil.allPushIOS(deviceTokenList, info, "0", PushTypeEnum.ZNX.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

@@ -361,7 +361,6 @@
            // 版本号

            pushQueueRecord.setVersions(versionCodes);

            



            if (tokenCount - i < totalCount) {

               // 起始游标

               pushQueueRecord.setStartCursor(i);

@@ -416,11 +415,9 @@
         return;

      }



		
      // 推送的版本号

      String versions = pushQueueRecord.getVersions();

      List<Integer> listCode = convertVersionType(versions);

				
      

      int total = (int) (endCursor - startCursor);



@@ -535,14 +532,15 @@


   @Async("pushExecutor")

   @Override

   public void pushWEEX(Long uid, String title, String content, String weexUrl,String versionCodes) throws PushException {

   public void pushWEEX(Long uid, String title, String content, String weexUrl, String versionCodes)

         throws PushException {

      MessageInfo info = new MessageInfo();

      info.setTitle(title);

      info.setContent(content);

      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, weexUrl, PushController.WEEX, versionCodes);

         addPushIOSQueue(info, weexUrl, PushTypeEnum.weex.getCode(), versionCodes);

      } else {

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid, versionCodes);

         List<String> deviceTokenList = new ArrayList<>();

@@ -551,7 +549,7 @@
               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, weexUrl, PushController.WEEX);

            IOSPushUtil.allPushIOS(deviceTokenList, info, weexUrl, PushTypeEnum.weex.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

@@ -560,14 +558,15 @@


   @Async("pushExecutor")

   @Override

   public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versionCodes) throws PushException {

   public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versionCodes)

         throws PushException {

      MessageInfo info = new MessageInfo();

      info.setTitle(title);

      info.setContent(content);

      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, url, PushController.BAICHUAN, versionCodes);

         addPushIOSQueue(info, url, PushTypeEnum.baichuan.getCode(), versionCodes);

      } else {

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid, versionCodes);

         List<String> deviceTokenList = new ArrayList<>();

@@ -576,7 +575,7 @@
               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushController.BAICHUAN);

            IOSPushUtil.allPushIOS(deviceTokenList, info, url, PushTypeEnum.baichuan.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

@@ -616,7 +615,7 @@
      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, "", PushController.WELFARE_CENTER, versionCodes);

         addPushIOSQueue(info, "", PushTypeEnum.welfare.getCode(), versionCodes);

      } else {

         if (!validateNotDisturbSingle(uid)) {

            return;

@@ -628,7 +627,7 @@
               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, "", PushController.WELFARE_CENTER);

            IOSPushUtil.allPushIOS(deviceTokenList, info, "", PushTypeEnum.welfare.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

@@ -654,4 +653,29 @@
      return listVersionCode;

   }

   

   @Override

   public void pushUserSignInNotification(Long uid, String title, String content, String versions)

         throws PushException {

      MessageInfo info = new MessageInfo();

      info.setTitle(title);

      info.setContent(content);

      info.setDescription(content);

      // IOS 全推

      if (uid == null || uid == 0) {

         addPushIOSQueue(info, "", PushTypeEnum.signin.getCode(), versions);

      } else {

         List<DeviceTokenIOS> deviceTokenIosList = getDeviceTokenListByUid(uid, versions);

         List<String> deviceTokenList = new ArrayList<>();

         if (deviceTokenIosList != null)

            for (DeviceTokenIOS ios : deviceTokenIosList) {

               deviceTokenList.add(ios.getDeviceToken());

            }

         try {

            IOSPushUtil.allPushIOS(deviceTokenList, info, "", PushTypeEnum.signin.getCode());

         } catch (Exception e) {

            PushLogHelper.iosError(e);

         }

      }

   }



}