二手风控

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

@@ -65,4 +65,12 @@ public class PlatformSecondTradeController {
         return R.success("操作成功");
     }
 
+    @ApiOperation("查询存在洗钱嫌疑的交易")
+    @ApiOperationSupport(order = 6)
+    @GetMapping("/getTradeRecordListByRiskId")
+    public R<List<SecondTradeRecordVo>> getTradeRecordListByRiskId(Integer id) throws Exception {
+        log.info("PlatformSecondTradeController.getTradeRecordListByRiskId?id={}", id);
+        return R.data(secondTradeRecordService.getTradeRecordListByRiskId(id));
+    }
+
 }

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

@@ -23,4 +23,6 @@ public interface PlatformSecondTradeService extends IService<SecondTradeRecord>
     List<JSONObject> getRankingList(String beginTime, String endTime) throws Exception;
 
     void setTradeFailure(Integer tradeId, String failureReason) throws Exception;
+
+    List<SecondTradeRecordVo> getTradeRecordListByRiskId(Integer id) throws Exception;
 }

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

@@ -1,32 +1,34 @@
 package shop.alien.second.service.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
-import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
+import shop.alien.entity.second.SecondRiskControlRecord;
 import shop.alien.entity.second.SecondTradeOperation;
 import shop.alien.entity.second.SecondTradeRecord;
 import shop.alien.entity.second.vo.SecondTradeRecordVo;
+import shop.alien.mapper.second.SecondRiskControlRecordMapper;
 import shop.alien.mapper.second.SecondTradeOperationMapper;
 import shop.alien.mapper.second.SecondTradeRecordMapper;
 import shop.alien.second.service.PlatformSecondTradeService;
 import shop.alien.second.service.SecondGoodsService;
 
-import java.math.BigDecimal;
-import java.math.RoundingMode;
 import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -37,6 +39,8 @@ public class PlatformSecondTradeServiceImpl extends ServiceImpl<SecondTradeRecor
     private SecondTradeRecordMapper secondTradeRecordMapper;
     @Autowired
     private SecondTradeOperationMapper secondTradeOperationMapper;
+    @Autowired
+    private SecondRiskControlRecordMapper secondRiskControlRecordMapper;
     @Lazy
     @Autowired
     private SecondGoodsService secondGoodsService;
@@ -304,4 +308,22 @@ public class PlatformSecondTradeServiceImpl extends ServiceImpl<SecondTradeRecor
         }
     }
 
+    @Override
+    public List<SecondTradeRecordVo> getTradeRecordListByRiskId(Integer id) throws Exception {
+        try {
+            SecondRiskControlRecord record = secondRiskControlRecordMapper.selectById(id);
+            Page<SecondTradeRecord> page = new Page<>(1, 1000000);
+            QueryWrapper<SecondTradeRecord> wrapper = new QueryWrapper<>();
+            wrapper.in("trade.id", JSONArray.parseArray(record.getDetailInfo()));
+            List<SecondTradeRecordVo> voList = secondTradeRecordMapper.getTradeRecordPage(page, wrapper).getRecords();
+            for (SecondTradeRecordVo item : voList) {
+                item.setOperationJsonList(getOperationJsonList(item.getId()));
+            }
+            return voList;
+        } catch (Exception e) {
+            log.error("PlatformSecondTradeServiceImpl.getTradeRecordListByRiskId(): Error Msg={}", e.getMessage());
+            throw new Exception(e);
+        }
+    }
+
 }

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

@@ -134,7 +134,7 @@ public class SecondUserCreditServiceImpl extends ServiceImpl<SecondUserCreditMap
                 jsonObject.put("msg", "信用分不足无法使用该功能");
             } else if (secondUserCredit.getFreezeTime().after(new Date())) {
                 jsonObject.put("flag", false);
-                jsonObject.put("msg", "无法查看该功能");
+                jsonObject.put("msg", "无法使用该功能");
             } else {
                 jsonObject.put("flag", true);
             }