风控体系代码提交

alien-second/src/main/java/shop/alien/second/service/impl/RiskControlServiceImpl.java

@@ -49,7 +49,7 @@ public class RiskControlServiceImpl extends ServiceImpl<SecondRiskControlRecordM
     private final PlatformSecondTradeServiceImpl tradeService;
     private final SecondUserCreditMapper secondUserCreditMapper;
     private final SecondUserCreditRecordServiceImpl sreditRecordService;
-    
+
     @Lazy
     @Autowired
     private SecondGoodsServiceImpl secondGoodsService;
@@ -250,11 +250,16 @@ public class RiskControlServiceImpl extends ServiceImpl<SecondRiskControlRecordM
         }
         // 方式1: 使用LambdaUpdateWrapper
         LambdaUpdateWrapper<SecondRiskControlRecord> updateWrapper = new LambdaUpdateWrapper<>();
-        updateWrapper.in(SecondRiskControlRecord::getBusinessId, vo.getBusinessId())
-                .eq(SecondRiskControlRecord::getDeleteFlag, 0)
+        updateWrapper.eq(SecondRiskControlRecord::getDeleteFlag, 0)
                 .eq(SecondRiskControlRecord::getRuleType, vo.getRuleType())
                 .set(SecondRiskControlRecord::getRiskStatus, vo.getIsExecute())
                 .set(SecondRiskControlRecord::getUpdatedTime, new Date());
+        if (vo.getRuleType() == 4) {
+            updateWrapper.in(SecondRiskControlRecord::getUserId, vo.getUserId());
+
+        } else {
+            updateWrapper.in(SecondRiskControlRecord::getBusinessId, vo.getBusinessId());
+        }
         secondRiskControlRecordMapper.update(null, updateWrapper);
         return true;
     }

alien-store/src/main/java/shop/alien/store/service/LifeUserService.java

@@ -388,11 +388,11 @@ public class LifeUserService extends ServiceImpl<LifeUserMapper, LifeUser> {
                 String endDate = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
                 List<LifeUserLog> lsit = lifeUserLogMapper.getLifeUserLogByDate(startDate, endDate, macIp);
 
-                if (lsit.size() >= riskControlProperties.getAccountAbnormal().getRegCount24h() && !isViolation(startDate, endDate, macIp, user.getId())) {
+                if (lsit.size() > riskControlProperties.getAccountAbnormal().getRegCount24h() && !isViolation(startDate, endDate, macIp, user.getId())) {
                     String detailInfo = lsit.stream()
                             .map(row -> row.getUserId().toString())
                             .collect(Collectors.joining(","));
-                    alienSecondFeign.recordRiskControlData(user.getId(), 2, "账号异常", macIp, detailInfo + "," + user.getId());
+                    alienSecondFeign.recordRiskControlData(user.getId(), 2, "账号异常", macIp, detailInfo);
                 }
             }
             // 第一次登录，添加用户基础积分