文件上传失败状态修改(未测试)

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

@@ -1,7 +1,10 @@
 package com.baiye.module.service;
 
+import com.baiye.module.entity.ClueRecord;
 import com.baiye.module.service.dto.ClueRecordQueryCriteria;
 
+import java.util.List;
+
 public interface ClueRecordService {
 
     /**
@@ -17,4 +20,10 @@ public interface ClueRecordService {
      * @return
      */
     Object auditFile(ClueRecordQueryCriteria clueRecordQueryCriteria);
+
+    /**
+     * 修改为上传失败状态
+     * @param clueRecords
+     */
+    void updateList(List<ClueRecord> clueRecords);
 }

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

@@ -2,21 +2,18 @@ package com.baiye.module.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baiye.constant.DefaultNumberConstants;
-import com.baiye.exception.BadRequestException;
 import com.baiye.feign.UserClient;
 import com.baiye.http.CommonResponse;
 import com.baiye.module.dao.ClueRecordRepository;
 import com.baiye.module.entity.ClueRecord;
 import com.baiye.module.service.ClueRecordService;
-import com.baiye.module.service.dto.ClueRecordDto;
 import com.baiye.module.service.dto.ClueRecordQueryCriteria;
-import com.baiye.module.service.mapstruct.ClueRecordMapper;
 import com.baiye.task.FileAnalysisTask;
-import com.baiye.util.QueryHelp;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
@@ -102,4 +99,13 @@ public class ClueRecordServiceImpl implements ClueRecordService {
         }
         return null;
     }
+
+    @Override
+    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
+    public void updateList(List<ClueRecord> clueRecords) {
+        //导入文件记录失败修改状态
+        clueRecords.forEach(cs -> cs.setStatus(false));
+        log.info("===================0.0执行更新0.0========================={}",clueRecords);
+        clueRecordRepository.saveAll(clueRecords);
+    }
 }

services/ad-platform-source/src/main/java/com/baiye/task/FileAnalysisTask.java

@@ -22,6 +22,7 @@ import com.baiye.module.listener.KsExcelListener;
 import com.baiye.module.listener.TaskZdyExcelListener;
 import com.baiye.module.listener.UcCsvListener;
 import com.baiye.module.listener.ZdyExcelListener;
+import com.baiye.module.service.ClueRecordService;
 import com.baiye.module.service.ClueService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
@@ -43,6 +44,8 @@ public class FileAnalysisTask {
     @Resource
     private ClueService clueService;
     @Resource
+    private ClueRecordService clueRecordService;
+    @Resource
     private ClueJpa clueJpa;
     @Resource
     private ClueRepository clueRepository;
@@ -96,9 +99,7 @@ public class FileAnalysisTask {
                 }
             } catch (Exception e) {
                 taskClient.sendErrMessage("导入资源错误,请检查数据格式后重新导入", clueRecords.get(0).getCreateBy());
-                //导入文件记录失败修改状态
+                clueRecordService.updateList(clueRecords);
-                clueRecords.forEach(cs -> cs.setStatus(false));
-                clueRecordRepository.saveAll(clueRecords);
                 e.printStackTrace();
                 throw new BadRequestException("=========读取资源错误============");
             }