风控体系代码提交

alien-entity/src/main/java/shop/alien/entity/second/vo/SecondRiskControlRecordVo.java

@@ -33,4 +33,10 @@ public class SecondRiskControlRecordVo extends SecondRiskControlRecord {
     @ApiModelProperty(value = "规则名称")
     private String riskStatusName;
 
+    @ApiModelProperty(value = "分页页数")
+    private Integer pageNum;
+
+    @ApiModelProperty(value = "分页条数")
+    private Integer pageSize;
+
 }

alien-entity/src/main/java/shop/alien/mapper/second/SecondRiskControlRecordMapper.java

@@ -1,9 +1,12 @@
 package shop.alien.mapper.second;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
+import shop.alien.entity.second.SecondGoodsRecord;
 import shop.alien.entity.second.SecondRiskControlRecord;
 import shop.alien.entity.second.vo.SecondRiskControlRecordVo;
 
@@ -25,8 +28,8 @@ public interface SecondRiskControlRecordMapper extends BaseMapper<SecondRiskCont
             " case when r.rule_type = 1 or r.rule_type = 3 then u.user_phone " +
             " when r.rule_type = 2 then '账号异常' when r.rule_type = 3 then '交易欺诈'end userPhone " +
             " from second_risk_control_record r left join life_user u on r.user_id = u.id " +
-            " where r.delete_flag = 0 ")
-    IPage<SecondRiskControlRecordVo> queryRiskControlRecords(IPage<SecondRiskControlRecordVo> page);
+            " ${ew.customSqlSegment} ")
+    IPage<SecondRiskControlRecordVo> queryRiskControlRecords(IPage<SecondRiskControlRecordVo> page, @Param(Constants.WRAPPER) QueryWrapper<SecondRiskControlRecordVo> queryWrapper);
 
 
     @Select(" select * from second_risk_control_record " +

alien-second/src/main/java/shop/alien/second/platform/PlatformRiskControlController.java

@@ -34,8 +34,8 @@ public class PlatformRiskControlController {
      */
     @ApiOperation("风控数据")
     @PostMapping("/queryRiskControlRecords")
-    public R<IPage<SecondRiskControlRecordVo>> queryRiskControlRecords(@RequestBody SecondUserViolationVo vo) {
-        return R.data(riskControlService.queryRiskControlRecords(vo.getPageNum(), vo.getPageSize()));
+    public R<IPage<SecondRiskControlRecordVo>> queryRiskControlRecords(@RequestBody SecondRiskControlRecordVo vo) {
+        return R.data(riskControlService.queryRiskControlRecords(vo));
     }
 
 

alien-second/src/main/java/shop/alien/second/service/RiskControlService.java

@@ -45,11 +45,10 @@ public interface RiskControlService extends IService<SecondRiskControlRecord> {
     /**
      * 获取相同类型的风控数据
      *
-     * @param page   页码
-     * @param size 条数
+     * @param vo
      * @return 查询风控列表
      */
-    IPage<SecondRiskControlRecordVo> queryRiskControlRecords(Integer page, Integer size);
+    IPage<SecondRiskControlRecordVo> queryRiskControlRecords(SecondRiskControlRecordVo vo);
 
     /**
      * 账号封禁详细查询

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

@@ -105,9 +105,16 @@ public class RiskControlServiceImpl extends ServiceImpl<SecondRiskControlRecordM
     }
 
     @Override
-    public IPage<SecondRiskControlRecordVo> queryRiskControlRecords(Integer page, Integer size) {
+    public IPage<SecondRiskControlRecordVo> queryRiskControlRecords(SecondRiskControlRecordVo vo) {
         try {
-            return secondRiskControlRecordMapper.queryRiskControlRecords(new Page<>(page, size));
+            // 3. 获取商品操作记录集合
+            QueryWrapper<SecondRiskControlRecordVo> recordQueryWrapper = new QueryWrapper<>();
+            recordQueryWrapper
+                    .eq(vo.getRuleType() != null, "r.rule_type", vo.getRuleType())
+                    .eq(vo.getRiskStatus() != null, "r.risk_status", vo.getRiskStatus())
+                    .eq("r.delete_flag",0)
+                    .orderByDesc("r.created_time");
+            return secondRiskControlRecordMapper.queryRiskControlRecords(new Page<>(vo.getPageNum(), vo.getPageSize()), recordQueryWrapper);
         } catch (Exception e) {
             log.error("记录风控数据时发生异常: ", e);
             return null;
@@ -186,7 +193,7 @@ public class RiskControlServiceImpl extends ServiceImpl<SecondRiskControlRecordM
 
     @Override
     public boolean accountBan(SecondRiskRecordVo vo) throws Exception {
-        if (vo.getIsExecute() == 1) {
+        if (1 == vo.getIsExecute()) {
             // 封禁时间
             Date freezeTime = Date.from(LocalDateTime.now().plusDays(7).atZone(ZoneId.systemDefault()).toInstant());