Browse Source

feat(job): 添加违规处理时间字段并优化导入包

- 在 AiCheckXxlJob 和 AiUserViolationJob 中添加 processingTime 字段
- 使用 Date 类型记录任务处理时间
- 优化 Java 导入包结构,使用通配符减少冗余导入
- 更新违规任务状态时同步设置处理时间
- 提升代码可读性和维护性
zjy 6 days ago
parent
commit
a29e02d930

+ 2 - 4
alien-job/src/main/java/shop/alien/job/second/AiCheckXxlJob.java

@@ -30,10 +30,7 @@ import shop.alien.mapper.second.SecondRiskControlRecordMapper;
 import shop.alien.util.common.Constants;
 
 import java.net.SocketException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -297,6 +294,7 @@ public class AiCheckXxlJob {
                                         boolean isValid = data.getBoolean("is_valid");
                                         violation.setReportResult(data.getString("matched_type"));
                                         violation.setProcessingStatus(isValid ? "1" : "2");
+                                        violation.setProcessingTime(new Date());
                                         lifeUserViolationMapper.updateById(violation);
 
                                         // 发送通知

+ 2 - 0
alien-job/src/main/java/shop/alien/job/second/AiUserViolationJob.java

@@ -24,6 +24,7 @@ import shop.alien.mapper.LifeUserMapper;
 import shop.alien.mapper.LifeUserViolationMapper;
 
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 @Slf4j
@@ -149,6 +150,7 @@ public class AiUserViolationJob {
                             aiTask.setProcessingStatus("2");
                             aiTask.setReportResult(dataJsonObj.getString("decision_reason"));
                         }
+                        aiTask.setProcessingTime(new Date());
                     }
 
                     // 发送通知