启用即时风控

yt-adage/adage-service/src/main/java/com/ytpm/adage/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,9 +15,11 @@ import com.ytpm.adage.service.AdService;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
+import com.ytpm.handle.CustomerException;
 import com.ytpm.middle.view.AppRankingListVO;
 import com.ytpm.middle.view.AppRevenueHourVO;
 import com.ytpm.middle.view.AppUserHourVO;
@@ -55,6 +58,8 @@ public class AdServiceImpl implements AdService {
     private AdRecordMapper adRecordMapper;
     @Autowired
     private AppUserMapper appUserMapper;
+    @Autowired
+    private RiskFeign riskFeign;
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
@@ -73,13 +78,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-algebraic/algebraic-service/src/main/java/com/ytpm/algebraic/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.algebraic.service.AdService;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -55,6 +57,8 @@ public class AdServiceImpl implements AdService {
     private AdRecordMapper adRecordMapper;
     @Autowired
     private AppUserMapper appUserMapper;
+    @Autowired
+    private RiskFeign riskFeign;
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR,result.getMessage());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-allusion/allusion-service/src/main/java/com/ytpm/allusion/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.allusion.service.AdService;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR,result.getMessage());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-answer/answer-service/src/main/java/com/ytpm/answer/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.answer.service.AdService;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,7 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
-
+    @Autowired
+    private RiskFeign riskFeign;
     /**
      * 保存广告记录
      */
@@ -73,13 +76,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR,result.getMessage());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-app/app-service/src/main/java/com/ytpm/service/dyz/impl/AdServiceImpl.java

@@ -75,8 +75,8 @@ public class AdServiceImpl implements AdService {
     private QNUserMapper qnUserMapper;
     @Resource
     private NFUserMapper nfUserMapper;
-//    @Resource
-//    private RiskFeign riskFeign;
+    @Resource
+    private RiskFeign riskFeign;
     @Value("${risk.config.banned.tips}")
     private String tips;
 
@@ -94,13 +94,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR,result.getMessage());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-app/app-service/src/main/java/com/ytpm/service/nofeeds/impl/NfAdServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ytpm.service.nofeeds.impl;
 
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
 import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
@@ -22,6 +23,7 @@ import com.ytpm.service.nofeeds.NfAdService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
@@ -43,6 +45,8 @@ public class NfAdServiceImpl implements NfAdService {
     @Qualifier("com.ytpm.feign.RiskFeign")
     @Autowired
     private RiskFeign riskFeign;
+    @Value("${risk.config.banned.tips}")
+    private String tips;
 
     /**
      * 保存广告记录
@@ -62,12 +66,15 @@ public class NfAdServiceImpl implements NfAdService {
         if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
             Result<?> result = riskFeign.checkAdRisk(user);
             if(result.getCode()!=200){
-                throw new CustomerException(result.getMessage());
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
             }
         }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
-
+    private String getTipsMsg(){
+        String[] split = tips.split(",");
+        return split[RandomUtil.randomInt(split.length)];
+    }
     /**
      * 根据应用查询广告数量
      */

yt-app/app-service/src/main/java/com/ytpm/service/qnjz/impl/QnAdServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ytpm.service.qnjz.impl;
 
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
 import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
@@ -22,6 +23,7 @@ import com.ytpm.service.qnjz.QnAdService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
@@ -43,6 +45,8 @@ public class QnAdServiceImpl implements QnAdService {
     @Qualifier("com.ytpm.feign.RiskFeign")
     @Autowired
     private RiskFeign riskFeign;
+    @Value("${risk.config.banned.tips}")
+    private String tips;
 
     /**
      * 保存广告记录
@@ -62,12 +66,15 @@ public class QnAdServiceImpl implements QnAdService {
         if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
             Result<?> result = riskFeign.checkAdRisk(user);
             if(result.getCode()!=200){
-                throw new CustomerException(result.getMessage());
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
             }
         }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
-
+    private String getTipsMsg(){
+        String[] split = tips.split(",");
+        return split[RandomUtil.randomInt(split.length)];
+    }
     /**
      * 根据应用查询广告数量
      */

yt-app/app-service/src/main/java/com/ytpm/service/qnmjz/impl/QnmAdServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ytpm.service.qnmjz.impl;
 
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
 import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
@@ -22,6 +23,7 @@ import com.ytpm.service.qnmjz.QnmAdService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
@@ -44,6 +46,8 @@ public class QnmAdServiceImpl implements QnmAdService {
     @Autowired
     private RiskFeign riskFeign;
 
+    @Value("${risk.config.banned.tips}")
+    private String tips;
     /**
      * 保存广告记录
      */
@@ -62,12 +66,15 @@ public class QnmAdServiceImpl implements QnmAdService {
         if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
             Result<?> result = riskFeign.checkAdRisk(user);
             if(result.getCode()!=200){
-                throw new CustomerException(result.getMessage());
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
             }
         }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
-
+    private String getTipsMsg(){
+        String[] split = tips.split(",");
+        return split[RandomUtil.randomInt(split.length)];
+    }
     /**
      * 根据应用查询广告数量
      */

yt-app/app-service/src/main/java/com/ytpm/service/xjlrl/impl/XjlrlAdServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ytpm.service.xjlrl.impl;
 
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
 import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
@@ -22,6 +23,7 @@ import com.ytpm.service.xjlrl.XjlrlAdService;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
@@ -44,6 +46,9 @@ public class XjlrlAdServiceImpl implements XjlrlAdService {
     @Autowired
     private RiskFeign riskFeign;
 
+    @Value("${risk.config.banned.tips}")
+    private String tips;
+
     /**
      * 保存广告记录
      */
@@ -62,12 +67,15 @@ public class XjlrlAdServiceImpl implements XjlrlAdService {
         if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
             Result<?> result = riskFeign.checkAdRisk(user);
             if(result.getCode()!=200){
-                throw new CustomerException(result.getMessage());
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
             }
         }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
-
+    private String getTipsMsg(){
+        String[] split = tips.split(",");
+        return split[RandomUtil.randomInt(split.length)];
+    }
     /**
      * 根据应用查询广告数量
      */

yt-arithmetic/arithmetic-service/src/main/java/com/ytpm/arithmetic/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.arithmetic.dao.AdRecordMapper;
 import com.ytpm.arithmetic.dao.AppUserMapper;
 import com.ytpm.arithmetic.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -59,6 +61,8 @@ public class AdServiceImpl implements AdService {
     @Value(" ${risk.config.banned.tips}")
     private String tips;
 
+    @Autowired
+    private RiskFeign riskFeign;
     /**
      * 保存广告记录
      */
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-calculator/calculator-service/src/main/java/com/ytpm/calculator/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.calculator.dao.AdRecordMapper;
 import com.ytpm.calculator.dao.AppUserMapper;
 import com.ytpm.calculator.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-carp/carp-service/src/main/java/com/ytpm/carp/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.carp.dao.AdRecordMapper;
 import com.ytpm.carp.dao.AppUserMapper;
 import com.ytpm.carp.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-countstep/countstep-service/src/main/java/com/ytpm/countstep/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.countstep.dao.AdRecordMapper;
 import com.ytpm.countstep.dao.AppUserMapper;
 import com.ytpm.countstep.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-diary/diary-service/src/main/java/com/ytpm/diary/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.diary.dao.AdRecordMapper;
 import com.ytpm.diary.dao.AppUserMapper;
 import com.ytpm.diary.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,7 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
-
+    @Autowired
+    private RiskFeign riskFeign;
     /**
      * 保存广告记录
      */
@@ -73,13 +76,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-dtw/dtw-service/src/main/java/com/ytpm/dtw/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.dtw.dao.AdRecordMapper;
 import com.ytpm.dtw.dao.AppUserMapper;
 import com.ytpm.dtw.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-emoticons/emoticons-service/src/main/java/com/ytpm/emoticons/service/impl/AdServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
@@ -14,6 +15,7 @@ import com.ytpm.app.param.DyzAdRecordParam;
 import com.ytpm.emoticons.dao.AdRecordMapper;
 import com.ytpm.emoticons.dao.AppUserMapper;
 import com.ytpm.emoticons.service.AdService;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-funarith/funarith-service/src/main/java/com/ytpm/funarith/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.funarith.dao.AdRecordMapper;
 import com.ytpm.funarith.dao.AppUserMapper;
 import com.ytpm.funarith.service.AdService;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-idiom/idiom-service/src/main/java/com/ytpm/idiom/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-irun/irun-service/src/main/java/com/ytpm/irun/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-lemon/lemon-service/src/main/java/com/ytpm/lemon/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-lime/lime-service/src/main/java/com/ytpm/lime/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-mileage/mileage-service/src/main/java/com/ytpm/mileage/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-nofeeds/nofeeds-service/src/main/java/com/ytpm/nofeeds/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-picking/picking-service/src/main/java/com/ytpm/picking/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-raisepig/raisepig-service/src/main/java/com/ytpm/raisepig/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-summary/summary-service/src/main/java/com/ytpm/summary/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-vitality/vitality-service/src/main/java/com/ytpm/vitality/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR, getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }
 

yt-walk/walk-service/src/main/java/com/ytpm/walk/service/impl/AdServiceImpl.java

@@ -5,12 +5,14 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
 import com.ytpm.advertise.enums.AdPlatformTypeEnum;
+import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
 import com.ytpm.agent.view.AgentAdGroupStaticsVO;
 import com.ytpm.agent.view.AgentTopCountView;
 import com.ytpm.app.model.YtDyzAdRecord;
 import com.ytpm.app.model.YtDyzUser;
 import com.ytpm.app.param.DyzAdRecordParam;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.StatusCode;
@@ -58,6 +60,8 @@ public class AdServiceImpl implements AdService {
 
     @Value(" ${risk.config.banned.tips}")
     private String tips;
+    @Autowired
+    private RiskFeign riskFeign;
 
     /**
      * 保存广告记录
@@ -73,13 +77,13 @@ public class AdServiceImpl implements AdService {
             return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
         }
         saveRecordAndChangeUser(param, user);
-//        //调用风控广告校验
-//        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
-//            Result<?> result = riskFeign.checkAdRisk(user);
-//            if(result.getCode()!=200){
-//                throw new CustomerException(result.getMessage());
-//            }
-//        }
+        //调用风控广告校验
+        if(AdSourceTypeEnum.rewarded_video.getAdSourceType() == param.getAdSourceType()){
+            Result<?> result = riskFeign.checkAdRisk(user);
+            if(result.getCode()!=200){
+                return new Result<>(StatusCode.ACCESS_ERR,getTipsMsg());
+            }
+        }
         return Result.resultOk(RepMessage.SAVE_SUCCESS);
     }