Prechádzať zdrojové kódy

fix: 风控缺陷处理

hidewnd 1 mesiac pred
rodič
commit
093673514d

+ 15 - 0
yt-nofeeds/nofeeds-service/src/main/java/com/ytpm/nofeeds/controller/UserController.java

@@ -2,6 +2,7 @@ package com.ytpm.nofeeds.controller;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
 import com.github.pagehelper.PageInfo;
 import com.ytpm.advertise.enums.AdSourceTypeEnum;
 import com.ytpm.agent.enums.UserStatusEnum;
@@ -18,9 +19,11 @@ import com.ytpm.app.param.AppUserTodayBannedParam;
 import com.ytpm.app.param.YtAppUserListParam;
 import com.ytpm.app.view.HourCountView;
 import com.ytpm.app.view.YtAppUserListView;
+import com.ytpm.feign.RiskFeign;
 import com.ytpm.general.RepMessage;
 import com.ytpm.general.Result;
 import com.ytpm.general.ResultTable;
+import com.ytpm.general.StatusCode;
 import com.ytpm.nofeeds.dao.AdRecordMapper;
 import com.ytpm.nofeeds.dao.AppUserMapper;
 import com.ytpm.nofeeds.dao.LoginRecordMapper;
@@ -65,6 +68,9 @@ public class UserController {
 
     @Autowired
     private RedisService redisService;
+
+    @Autowired
+    private RiskFeign riskFeign;
     /**
      * 根据应用ID查询当月注册用户
      */
@@ -166,6 +172,15 @@ public class UserController {
         user.setTodayAnswerCount(questionMapper.getAnswerCount(userId,1));
         user.setHistoryAnswerCount(questionMapper.getAnswerCount(userId,2));
         user.setAnswerRecordList(questionMapper.getAnswerRecords(userId));
+        Result<?> result = riskFeign.checkAdRisk(user);
+        if (result != null) {
+            user.setIfPowerLimit(false);
+            if (result.getCode() != 200) {
+                if ("766".equals(result.getMessage()) || result.getCode() == StatusCode.ACCESS_RISK_ERROR && StrUtil.isNotEmpty(result.getMessage())) {
+                    user.setIfPowerLimit(true);
+                }
+            }
+        }
         return Result.resultObjOk(user);
     }
 

+ 2 - 2
yt-nofeeds/nofeeds-service/src/main/resources/mapper/AppUserMapper.xml

@@ -155,10 +155,10 @@
             <if test="taskLimitTip != null">
                 task_limit_tip = #{taskLimitTip}
             </if>
-            <if test="taskLimitTip != null">
+            <if test="lowValueTip != null">
                 low_value_tip = #{lowValueTip}
             </if>
-            <if test="taskLimitTip != null">
+            <if test="brushTip != null">
                 brush_tip = #{brushTip}
             </if>
         </set>

+ 4 - 4
yt-risk/risk-manage/src/main/java/com/ytpm/service/impl/RiskServiceImpl.java

@@ -676,10 +676,10 @@ public class RiskServiceImpl implements RiskService {
                         .limit(firstCount).reduce(BigDecimal.ZERO, BigDecimal::add)
                         .divide(new BigDecimal(count), RoundingMode.HALF_UP);
             }
-        }
-        if (averageRevenue.compareTo(averageRevenueLimit) < 0) {
-            // 自定义响应
-            throw new CommonException("766");
+            if (averageRevenue.compareTo(averageRevenueLimit) < 0) {
+                // 自定义响应
+                throw new CommonException("766");
+            }
         }
     }