文件审核-动态任务上传bug修复

services/ad-platform-source/src/main/java/com/baiye/module/dao/ClueRecordRepository.java

@@ -20,6 +20,13 @@ public interface ClueRecordRepository extends JpaRepository<ClueRecord, Long>, J
      */
     List<ClueRecord> findByTaskId(Long taskId);
 
+    /**
+     * 任务id与审核状态查询
+     * @param taskId
+     * @return
+     */
+    List<ClueRecord> findByTaskIdAndIsPass(Long taskId, Integer isPass);
+
     /**
      * 删除所有任务相关
      * @param taskIds

services/ad-platform-source/src/main/java/com/baiye/module/service/impl/ClueRecordServiceImpl.java

@@ -88,7 +88,7 @@ public class ClueRecordServiceImpl implements ClueRecordService {
         if (CollUtil.isNotEmpty(taskIdList)) {
             if (isPass == 0) {
                 for (Long taskId : taskIdList) {
-                    List<ClueRecord> clueRecords = clueRecordRepository.findByTaskId(taskId);
+                    List<ClueRecord> clueRecords = clueRecordRepository.findByTaskIdAndIsPass(taskId, DefaultNumberConstants.ONE_NUMBER);
                     // 异步读取文件并更新任务
                     if (CollUtil.isNotEmpty(clueRecords)) {
                         fileAnalysisTask.runFileAnalysisTask(clueRecords, clueRecords.get(0).getOldFile());