Jelajahi Sumber

feat:缺失定时任务调整

chenjianhua 1 bulan lalu
induk
melakukan
c317f79032

+ 0 - 1
service-manage/src/main/java/com/simuwang/manage/service/impl/DeletionServiceImpl.java

@@ -234,7 +234,6 @@ public class DeletionServiceImpl implements DeletionService {
 
     @Override
     public void computeDeletionTypeNum(List<FundDeletionTypeDO> fundDeletionTypeList) {
-        deletionTypeStatisticsMapper.truncateTable();
         for (FundDeletionTypeDO fundDeletionType : fundDeletionTypeList) {
             String fundId = fundDeletionType.getFundId();
             Integer deletionType = fundDeletionType.getDeletionType();

+ 3 - 0
service-manage/src/main/java/com/simuwang/manage/task/FundDeletionTask.java

@@ -32,6 +32,8 @@ public class FundDeletionTask {
     private DeletionService deletionService;
     @Autowired
     private EmailTaskInfoMapper emailTaskInfoMapper;
+    @Autowired
+    private DeletionTypeStatisticsMapper deletionTypeStatisticsMapper;
 //    @Scheduled(cron = "0 0 5,12,19 * * ?")
     public void computeDeletion(){
         EmailTaskInfoDO emailTaskInfoDO = startEmailTask(null, 1);
@@ -41,6 +43,7 @@ public class FundDeletionTask {
                 deletionService.computeDeletion(mailboxInfoOS);
             }
             //统计缺失类型的处理数据量
+            deletionTypeStatisticsMapper.truncateTable();
             List<FundDeletionTypeDO> fundDeletionTypeList = deletionService.getFundDeletionTypeMapList();
             deletionService.computeDeletionTypeNum(fundDeletionTypeList);
         }catch (Exception e){