刷单风险规则优化

admin

2020-11-09 2147d023563a7c9d05d97547c00d6b0162c0644c

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

@@ -1,13 +1,12 @@
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 java.util.*;



import javax.annotation.Resource;



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

import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.util.Constant;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;



@@ -37,10 +36,10 @@
   @Resource

   private UserCustomSettingsService userCustomSettingsService;



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

   private List<Integer> getVersionCodeList(List<Integer> versionCodeList, SystemEnum system) {

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

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

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

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

         if (appInfoList != null)

            for (AppVersionInfo version : appInfoList) {

               versionList.add(version.getVersionCode());

@@ -58,50 +57,50 @@


   @Async("pushExecutor")

   @Override

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

   public void pushGoods(Long uid, Long auctionId, PushBaseContent content)

         throws PushException {

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

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

   }



   @Async("pushExecutor")

   @Override

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

   public void pushUrl(Long uid, String url, PushBaseContent content)

         throws PushException {

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

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

   }



   @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);

   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 title, String content, String weexUrl, List<Integer> versionCodeList)

   public void pushWEEX(Long uid,  String weexUrl, PushBaseContent content)

         throws PushException {

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

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

   }



   @Async("pushExecutor")

   @Override

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

   public void pushBaiChuanUrl(Long uid, String url, PushBaseContent content)

         throws PushException {



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

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

   }



   @Async("pushExecutor")

   @Override

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

   public void pushWelfareCenter(Long uid, PushBaseContent content)

         throws PushException {

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

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

   }



   @Override

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

   public void pushUserSignInNotification(Long uid, PushBaseContent content)

         throws PushException {

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

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

   }



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

@@ -138,16 +137,14 @@
    * 

    * @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 {

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

         Long goodsId, PushBaseContent content) throws PushException {

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

      List<Integer> newVersionList = getVersionCodeList(versionCodeList);

      List<Integer> newVersionList = getVersionCodeList(content.getVersionCodeList(),content.getSystem());

      // 2.0.1后开始推送

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

         if (newVersionList.get(i) < 51)

@@ -155,11 +152,12 @@
      }



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

         Date minUpdatetime=new Date(System.currentTimeMillis()- Constant.PUSH_MIN_TIME);

         int pageSize = 200;

         long deviceCount = deviceTokenVIVOService.countDeviceToken(newVersionList);

         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);

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

            deviceList = filterDeviceToken(deviceList, hour);



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

@@ -169,25 +167,25 @@
               if (type == PushTypeEnum.goodsdetail) {// 商品详情

                  if (goodsId == null)

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

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

                  VIVOPushUtil.pushGoods(tokenList, content.getTitle(),content.getContent(), 1, goodsId);

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

                  if (StringUtil.isNullOrEmpty(webUrl))

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

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

                  VIVOPushUtil.pushUrl(tokenList,  content.getTitle(),content.getContent(),  webUrl);

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

                  VIVOPushUtil.pushZNX(tokenList, title, content);

                  VIVOPushUtil.pushZNX(tokenList,  content.getTitle(),content.getContent());

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

                  if (StringUtil.isNullOrEmpty(url))

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

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

                  VIVOPushUtil.pushWEEX(tokenList,  content.getTitle(),content.getContent(),  url);

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

                  if (StringUtil.isNullOrEmpty(webUrl))

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

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

                  VIVOPushUtil.pushBaiChuanUrl(tokenList,  content.getTitle(),content.getContent(),  webUrl);

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

                  VIVOPushUtil.pushWelfareCenter(tokenList, title, content);

                  VIVOPushUtil.pushWelfareCenter(tokenList,  content.getTitle(),content.getContent());

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

                  VIVOPushUtil.pushUserSignInNotification(tokenList, title, content);

                  VIVOPushUtil.pushUserSignInNotification(tokenList,  content.getTitle(),content.getContent());

               }

            } catch (Exception e) {

               PushLogHelper.hwError(e);

@@ -210,25 +208,25 @@
            if (type == PushTypeEnum.goodsdetail) {// 商品详情

               if (goodsId == null)

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

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

               VIVOPushUtil.pushGoods(tokenList, content.getTitle(), content.getContent(), 1, goodsId);

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

               if (StringUtil.isNullOrEmpty(webUrl))

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

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

               VIVOPushUtil.pushUrl(tokenList, content.getTitle(), content.getContent(), webUrl);

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

               VIVOPushUtil.pushZNX(tokenList, title, content);

               VIVOPushUtil.pushZNX(tokenList, content.getTitle(), content.getContent());

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

               if (StringUtil.isNullOrEmpty(url))

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

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

               VIVOPushUtil.pushWEEX(tokenList, content.getTitle(), content.getContent(), url);

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

               if (StringUtil.isNullOrEmpty(webUrl))

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

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

               VIVOPushUtil.pushBaiChuanUrl(tokenList, content.getTitle(), content.getContent(), webUrl);

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

               VIVOPushUtil.pushWelfareCenter(tokenList, title, content);

               VIVOPushUtil.pushWelfareCenter(tokenList, content.getTitle(), content.getContent());

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

               VIVOPushUtil.pushUserSignInNotification(tokenList, title, content);

               VIVOPushUtil.pushUserSignInNotification(tokenList,content.getTitle(), content.getContent());

            }

         } catch (Exception e) {

            PushLogHelper.vivoError(e);