淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -1,236 +1,250 @@
package com.yeshi.fanli.service.impl.push;



import java.util.ArrayList;

import java.util.Calendar;

import java.util.HashSet;

import java.util.List;

import java.util.Set;



import javax.annotation.Resource;



import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;



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

import com.yeshi.fanli.entity.AppVersionInfo;

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

import com.yeshi.fanli.entity.bus.user.UserCustomSettings.UserSettingTypeEnum;

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

import com.yeshi.fanli.exception.push.PushException;

import com.yeshi.fanli.log.PushLogHelper;

import com.yeshi.fanli.service.inter.config.AppVersionService;

import com.yeshi.fanli.service.inter.push.DeviceTokenVIVOService;

import com.yeshi.fanli.service.inter.push.VIVOPushService;

import com.yeshi.fanli.service.inter.user.UserCustomSettingsService;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.push.VIVOPushUtil;



@Service

public class VIVOPushServiceImpl implements VIVOPushService {



   @Resource

   private DeviceTokenVIVOService deviceTokenVIVOService;



   @Resource

   private AppVersionService appVersionService;



   @Resource

   private UserCustomSettingsService userCustomSettingsService;



   private List<Integer> getVersionCodeList(List<Integer> versionCodeList) {

      List<Integer> versionList = new ArrayList<>();

      if (versionCodeList == null) {// 全推

         List<AppVersionInfo> appInfoList = appVersionService.listByPlatformAndMinVersionCode("android", 51);

         if (appInfoList != null)

            for (AppVersionInfo version : appInfoList) {

               versionList.add(version.getVersionCode());

            }



      } else {// 按版本推送

         for (Integer versionCode : versionCodeList) {

            if (versionCode.intValue() >= 51) {// 2.0.1开始支持

               versionList.add(versionCode);

            }

         }

      }

      return versionList;

   }



   @Async("pushExecutor")

   @Override

   public void pushGoods(Long uid, Long auctionId, String title, String content, List<Integer> versionCodeList)

         throws PushException {

      push(PushTypeEnum.goodsdetail, uid, title, content, null, null, auctionId, versionCodeList);

   }



   @Async("pushExecutor")

   @Override

   public void pushUrl(Long uid, String url, String title, String content, List<Integer> versionCodeList)

         throws PushException {

      push(PushTypeEnum.url, uid, title, content, null, url, null, versionCodeList);

   }



   @Async("pushExecutor")

   @Override

   public void pushZNX(Long uid, String title, String content, List<Integer> versionCodeList) throws PushException {

      push(PushTypeEnum.ZNX, uid, title, content, null, null, null, versionCodeList);

   }



   @Async("pushExecutor")

   @Override

   public void pushWEEX(Long uid, String title, String content, String weexUrl, List<Integer> versionCodeList)

         throws PushException {

      push(PushTypeEnum.weex, uid, title, content, weexUrl, null, null, versionCodeList);

   }



   @Async("pushExecutor")

   @Override

   public void pushBaiChuanUrl(Long uid, String title, String content, String url, List<Integer> versionCodeList)

         throws PushException {



      push(PushTypeEnum.baichuan, uid, title, content, null, url, null, versionCodeList);

   }



   @Async("pushExecutor")

   @Override

   public void pushWelfareCenter(Long uid, String title, String content, List<Integer> versionCodeList)

         throws PushException {

      push(PushTypeEnum.welfare, uid, title, content, null, null, null, versionCodeList);

   }



   @Override

   public void pushUserSignInNotification(Long uid, String title, String content, List<Integer> versionCodeList)

         throws PushException {

      push(PushTypeEnum.signin, uid, title, content, null, null, null, versionCodeList);

   }



   private List<DeviceTokenVIVO> filterDeviceToken(List<DeviceTokenVIVO> deviceList, int hour) {

      // 处理消息免打扰

      if (hour >= 20 || hour < 8) {

         Set<Long> uidSets = new HashSet<>();

         for (DeviceTokenVIVO dt : deviceList)

            if (dt.getUid() != null)

               uidSets.add(dt.getUid());

         List<Long> uidList = new ArrayList<>();

         uidList.addAll(uidSets);

         List<UserCustomSettings> settingList = userCustomSettingsService.listByUidListAndTypeAndState(uidList,

               UserSettingTypeEnum.cancelNotice.name(), UserCustomSettings.STATE_VALID);

         uidSets.clear();

         if (settingList != null) {

            for (UserCustomSettings seeting : settingList)

               uidSets.add(seeting.getUserInfo().getId());

         }

         if (uidSets.size() > 0)

            for (int i = 0; i < deviceList.size(); i++) {

               if (deviceList.get(i).getUid() != null && uidSets.contains(deviceList.get(i).getUid())) {

                  deviceList.remove(i--);

               }

            }

      }

      return deviceList;

   }



   /**

    * 推送

    * 
    * @param type

    * @param uid

    * @param title

    * @param content

    * @param url

    * @param webUrl

    * @param versionCodeList

    */

   private void push(PushTypeEnum type, Long uid, String title, String content, String url, String webUrl,

         Long goodsId, List<Integer> versionCodeList) throws PushException {

      int hour = Calendar.getInstance().get(Calendar.HOUR_OF_DAY);

      List<Integer> newVersionList = getVersionCodeList(versionCodeList);

      // 2.0.1后开始推送

      for (int i = 0; i < newVersionList.size(); i++) {

         if (newVersionList.get(i) < 51)

            newVersionList.remove(i--);

      }



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

         int pageSize = 200;

         long deviceCount = deviceTokenVIVOService.countDeviceToken(newVersionList);

         int page = (int) (deviceCount % pageSize == 0 ? deviceCount / pageSize : deviceCount / pageSize + 1);

         for (int p = 1; p <= page; p++) {

            List<DeviceTokenVIVO> deviceList = deviceTokenVIVOService.listDeviceToken(p, pageSize, newVersionList);

            deviceList = filterDeviceToken(deviceList, hour);



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

            for (DeviceTokenVIVO token : deviceList)

               tokenList.add(token.getRegisterId());

            try {

               if (type == PushTypeEnum.goodsdetail) {// 商品详情

                  if (goodsId == null)

                     throw new PushException(2, "参数不完整");

                  VIVOPushUtil.pushGoods(tokenList, title, content, 1, goodsId);

               } else if (type == PushTypeEnum.url) {// 链接

                  if (StringUtil.isNullOrEmpty(webUrl))

                     throw new PushException(2, "参数不完整");

                  VIVOPushUtil.pushUrl(tokenList, title, content, webUrl);

               } else if (type == PushTypeEnum.ZNX) {// 站内信

                  VIVOPushUtil.pushZNX(tokenList, title, content);

               } else if (type == PushTypeEnum.weex) {// weex

                  if (StringUtil.isNullOrEmpty(url))

                     throw new PushException(2, "参数不完整");

                  VIVOPushUtil.pushWEEX(tokenList, title, content, url);

               } else if (type == PushTypeEnum.baichuan) {// 百川链接

                  if (StringUtil.isNullOrEmpty(webUrl))

                     throw new PushException(2, "参数不完整");

                  VIVOPushUtil.pushBaiChuanUrl(tokenList, title, content, webUrl);

               } else if (type == PushTypeEnum.welfare) {// 福利中心

                  VIVOPushUtil.pushWelfareCenter(tokenList, title, content);

               } else if (type == PushTypeEnum.signin) {// 签到

                  VIVOPushUtil.pushUserSignInNotification(tokenList, title, content);

               }

            } catch (Exception e) {

               PushLogHelper.hwError(e);

            }



         }

      } else {

         // 单推

         List<DeviceTokenVIVO> deviceList = deviceTokenVIVOService.listByUid(uid, newVersionList);

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

         if (deviceList != null) {

            deviceList = filterDeviceToken(deviceList, hour);

            for (DeviceTokenVIVO token : deviceList)

               tokenList.add(token.getRegisterId());

         }

         if (tokenList.size() == 0)

            return;



         try {

            if (type == PushTypeEnum.goodsdetail) {// 商品详情

               if (goodsId == null)

                  throw new PushException(2, "参数不完整");

               VIVOPushUtil.pushGoods(tokenList, title, content, 1, goodsId);

            } else if (type == PushTypeEnum.url) {// 链接

               if (StringUtil.isNullOrEmpty(webUrl))

                  throw new PushException(2, "参数不完整");

               VIVOPushUtil.pushUrl(tokenList, title, content, webUrl);

            } else if (type == PushTypeEnum.ZNX) {// 站内信

               VIVOPushUtil.pushZNX(tokenList, title, content);

            } else if (type == PushTypeEnum.weex) {// weex

               if (StringUtil.isNullOrEmpty(url))

                  throw new PushException(2, "参数不完整");

               VIVOPushUtil.pushWEEX(tokenList, title, content, url);

            } else if (type == PushTypeEnum.baichuan) {// 百川链接

               if (StringUtil.isNullOrEmpty(webUrl))

                  throw new PushException(2, "参数不完整");

               VIVOPushUtil.pushBaiChuanUrl(tokenList, title, content, webUrl);

            } else if (type == PushTypeEnum.welfare) {// 福利中心

               VIVOPushUtil.pushWelfareCenter(tokenList, title, content);

            } else if (type == PushTypeEnum.signin) {// 签到

               VIVOPushUtil.pushUserSignInNotification(tokenList, title, content);

            }

         } catch (Exception e) {

            PushLogHelper.vivoError(e);

         }



      }

   }

}

package com.yeshi.fanli.service.impl.push;

import java.util.*;

import javax.annotation.Resource;

import com.yeshi.fanli.dto.push.PushBaseContent;
import com.yeshi.fanli.entity.SystemEnum;
import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;
import com.yeshi.fanli.service.inter.config.SystemConfigService;
import com.yeshi.fanli.util.Constant;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import com.yeshi.fanli.dto.push.PushTypeEnum;
import com.yeshi.fanli.entity.AppVersionInfo;
import com.yeshi.fanli.entity.bus.user.UserCustomSettings;
import com.yeshi.fanli.entity.bus.user.UserCustomSettings.UserSettingTypeEnum;
import com.yeshi.fanli.entity.push.DeviceTokenVIVO;
import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.log.PushLogHelper;
import com.yeshi.fanli.service.inter.config.AppVersionService;
import com.yeshi.fanli.service.inter.push.DeviceTokenVIVOService;
import com.yeshi.fanli.service.inter.push.VIVOPushService;
import com.yeshi.fanli.service.inter.user.UserCustomSettingsService;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.push.VIVOPushUtil;

@Service
public class VIVOPushServiceImpl implements VIVOPushService {

   @Resource
   private DeviceTokenVIVOService deviceTokenVIVOService;

   @Resource
   private AppVersionService appVersionService;

   @Resource
   private UserCustomSettingsService userCustomSettingsService;

   @Resource
   private SystemConfigService systemConfigService;

   private List<Integer> getVersionCodeList(List<Integer> versionCodeList,SystemEnum system) {
      List<Integer> versionList = new ArrayList<>();
      if (versionCodeList == null) {// 全推
         List<AppVersionInfo> appInfoList = appVersionService.listByPlatformAndMinVersionCode("android", 51,system);
         if (appInfoList != null)
            for (AppVersionInfo version : appInfoList) {
               versionList.add(version.getVersionCode());
            }

      } else {// 按版本推送
         for (Integer versionCode : versionCodeList) {
            if (versionCode.intValue() >= 51) {// 2.0.1开始支持
               versionList.add(versionCode);
            }
         }
      }
      return versionList;
   }

   @Async("pushExecutor")
   @Override
   public void pushGoods(Long uid, String auctionId, PushBaseContent content)
         throws PushException {
      push(PushTypeEnum.goodsdetail, uid,  null, null, auctionId, content);
   }

   @Async("pushExecutor")
   @Override
   public void pushUrl(Long uid, String url, PushBaseContent content)
         throws PushException {
      push(PushTypeEnum.url, uid, null, url, null, content);
   }

   @Async("pushExecutor")
   @Override
   public void pushZNX(Long uid, PushBaseContent content) throws PushException {
      push(PushTypeEnum.ZNX, uid,  null, null, null, content);
   }

   @Async("pushExecutor")
   @Override
   public void pushWEEX(Long uid,  String weexUrl, PushBaseContent content)
         throws PushException {
      push(PushTypeEnum.weex, uid,  weexUrl, null, null, content);
   }

   @Async("pushExecutor")
   @Override
   public void pushBaiChuanUrl(Long uid, String url, PushBaseContent content)
         throws PushException {

      push(PushTypeEnum.baichuan, uid,  null, url, null, content);
   }

   @Async("pushExecutor")
   @Override
   public void pushWelfareCenter(Long uid, PushBaseContent content)
         throws PushException {
      push(PushTypeEnum.welfare, uid,  null, null, null, content);
   }

   @Override
   public void pushUserSignInNotification(Long uid, PushBaseContent content)
         throws PushException {
      push(PushTypeEnum.signin, uid, null, null, null, content);
   }

   private List<DeviceTokenVIVO> filterDeviceToken(List<DeviceTokenVIVO> deviceList, int hour) {
      // TODO 消息免打扰关闭
      if (1 > 0)
         return deviceList;
      // 处理消息免打扰
      if (hour >= 20 || hour < 8) {
         Set<Long> uidSets = new HashSet<>();
         for (DeviceTokenVIVO dt : deviceList)
            if (dt.getUid() != null)
               uidSets.add(dt.getUid());
         List<Long> uidList = new ArrayList<>();
         uidList.addAll(uidSets);
         List<UserCustomSettings> settingList = userCustomSettingsService.listByUidListAndTypeAndState(uidList,
               UserSettingTypeEnum.cancelNotice.name(), UserCustomSettings.STATE_VALID);
         uidSets.clear();
         if (settingList != null) {
            for (UserCustomSettings seeting : settingList)
               uidSets.add(seeting.getUserInfo().getId());
         }
         if (uidSets.size() > 0)
            for (int i = 0; i < deviceList.size(); i++) {
               if (deviceList.get(i).getUid() != null && uidSets.contains(deviceList.get(i).getUid())) {
                  deviceList.remove(i--);
               }
            }
      }
      return deviceList;
   }

   /**
    * 推送
    * 
    * @param type
    * @param uid
    * @param content
    * @param url
    * @param webUrl
    */
   private void push(PushTypeEnum type, Long uid, String url, String webUrl,
         String goodsId, PushBaseContent content) throws PushException {

      String androidBaseActivity=getAndroidBaseActivity(content.getSystem());
      int hour = Calendar.getInstance().get(Calendar.HOUR_OF_DAY);
      List<Integer> newVersionList = getVersionCodeList(content.getVersionCodeList(),content.getSystem());
      // 2.0.1后开始推送
      for (int i = 0; i < newVersionList.size(); i++) {
         if (newVersionList.get(i) < 51)
            newVersionList.remove(i--);
      }

      if (uid == null || uid == 0) {
         Date minUpdatetime=new Date(System.currentTimeMillis()- Constant.PUSH_MIN_TIME);
         int pageSize = 200;
         long deviceCount = deviceTokenVIVOService.countDeviceToken(newVersionList,minUpdatetime);
         int page = (int) (deviceCount % pageSize == 0 ? deviceCount / pageSize : deviceCount / pageSize + 1);
         for (int p = 1; p <= page; p++) {
            List<DeviceTokenVIVO> deviceList = deviceTokenVIVOService.listDeviceToken(p, pageSize, newVersionList,minUpdatetime);
            deviceList = filterDeviceToken(deviceList, hour);

            List<String> tokenList = new ArrayList<>();
            for (DeviceTokenVIVO token : deviceList)
               tokenList.add(token.getRegisterId());
            try {
               if (type == PushTypeEnum.goodsdetail) {// 商品详情
                  if (goodsId == null)
                     throw new PushException(2, "参数不完整");
                  VIVOPushUtil.pushGoods(tokenList, content.getTitle(),content.getContent(), 1, goodsId,androidBaseActivity);
               } else if (type == PushTypeEnum.url) {// 链接
                  if (StringUtil.isNullOrEmpty(webUrl))
                     throw new PushException(2, "参数不完整");
                  VIVOPushUtil.pushUrl(tokenList,  content.getTitle(),content.getContent(),  webUrl,androidBaseActivity);
               } else if (type == PushTypeEnum.ZNX) {// 站内信
                  VIVOPushUtil.pushZNX(tokenList,  content.getTitle(),content.getContent());
               } else if (type == PushTypeEnum.weex) {// weex
                  if (StringUtil.isNullOrEmpty(url))
                     throw new PushException(2, "参数不完整");
                  VIVOPushUtil.pushWEEX(tokenList,  content.getTitle(),content.getContent(),  url,androidBaseActivity);
               } else if (type == PushTypeEnum.baichuan) {// 百川链接
                  if (StringUtil.isNullOrEmpty(webUrl))
                     throw new PushException(2, "参数不完整");
                  VIVOPushUtil.pushBaiChuanUrl(tokenList,  content.getTitle(),content.getContent(),  webUrl);
               } else if (type == PushTypeEnum.welfare) {// 福利中心
                  VIVOPushUtil.pushWelfareCenter(tokenList,  content.getTitle(),content.getContent(),androidBaseActivity);
               } else if (type == PushTypeEnum.signin) {// 签到
                  VIVOPushUtil.pushUserSignInNotification(tokenList,  content.getTitle(),content.getContent(),androidBaseActivity);
               }
            } catch (Exception e) {
               PushLogHelper.hwError(e);
            }

         }
      } else {
         // 单推
         List<DeviceTokenVIVO> deviceList = deviceTokenVIVOService.listByUid(uid, newVersionList);
         List<String> tokenList = new ArrayList<>();
         if (deviceList != null) {
            deviceList = filterDeviceToken(deviceList, hour);
            for (DeviceTokenVIVO token : deviceList)
               tokenList.add(token.getRegisterId());
         }
         if (tokenList.size() == 0)
            return;

         try {
            if (type == PushTypeEnum.goodsdetail) {// 商品详情
               if (goodsId == null)
                  throw new PushException(2, "参数不完整");
               VIVOPushUtil.pushGoods(tokenList, content.getTitle(), content.getContent(), 1, goodsId,androidBaseActivity);
            } else if (type == PushTypeEnum.url) {// 链接
               if (StringUtil.isNullOrEmpty(webUrl))
                  throw new PushException(2, "参数不完整");
               VIVOPushUtil.pushUrl(tokenList, content.getTitle(), content.getContent(), webUrl,androidBaseActivity);
            } else if (type == PushTypeEnum.ZNX) {// 站内信
               VIVOPushUtil.pushZNX(tokenList, content.getTitle(), content.getContent());
            } else if (type == PushTypeEnum.weex) {// weex
               if (StringUtil.isNullOrEmpty(url))
                  throw new PushException(2, "参数不完整");
               VIVOPushUtil.pushWEEX(tokenList, content.getTitle(), content.getContent(), url,androidBaseActivity);
            } else if (type == PushTypeEnum.baichuan) {// 百川链接
               if (StringUtil.isNullOrEmpty(webUrl))
                  throw new PushException(2, "参数不完整");
               VIVOPushUtil.pushBaiChuanUrl(tokenList, content.getTitle(), content.getContent(), webUrl);
            } else if (type == PushTypeEnum.welfare) {// 福利中心
               VIVOPushUtil.pushWelfareCenter(tokenList, content.getTitle(), content.getContent(),androidBaseActivity);
            } else if (type == PushTypeEnum.signin) {// 签到
               VIVOPushUtil.pushUserSignInNotification(tokenList,content.getTitle(), content.getContent(),androidBaseActivity);
            }
         } catch (Exception e) {
            PushLogHelper.vivoError(e);
         }

      }
   }

   private String getAndroidBaseActivity(SystemEnum system) {

      return systemConfigService.getValueCache(SystemConfigKeyEnum.androidBaseActivityName, system);

   }
}