Ver Fonte

fix:任务优化

wangzaijun há 2 semanas atrás
pai
commit
3717e90ab8

+ 13 - 12
mo-daq/src/main/java/com/smppw/modaq/application/service/EmailParseApiServiceImpl.java

@@ -86,18 +86,19 @@ public class EmailParseApiServiceImpl implements EmailParseApiService {
 //            log.error(e.getMessage());
 //        }
 //        Integer finalUserId = userId;
-        asyncExecutor.execute(() -> {
-//                      EmailTaskInfoDO emailTaskInfoDO = startEmailTask(mailboxInfoDTO.getAccount(), 1, finalUserId);
-                    try {
-                        emailParseService.parseEmail(mailboxInfoDTO, startDate, endDate);
-                    } catch (Exception e) {
-                        log.error(e.getMessage(), e);
-//                          endEmailTask(emailTaskInfoDO.getId(),-1);
-//                        return;
-                    }
-//                      endEmailTask(emailTaskInfoDO.getId(),2);
-                }
-        );
+//        asyncExecutor.execute(() -> {
+////                      EmailTaskInfoDO emailTaskInfoDO = startEmailTask(mailboxInfoDTO.getAccount(), 1, finalUserId);
+//                    try {
+//
+//                    } catch (Exception e) {
+//                        log.error(e.getMessage(), e);
+////                          endEmailTask(emailTaskInfoDO.getId(),-1);
+////                        return;
+//                    }
+////                      endEmailTask(emailTaskInfoDO.getId(),2);
+//                }
+//        );
+        emailParseService.parseEmail(mailboxInfoDTO, startDate, endDate);
     }
 
 //    private void endEmailTask(Integer id,Integer taskStatus) {

+ 2 - 3
mo-daq/src/main/java/com/smppw/modaq/domain/entity/TaskRecordDO.java

@@ -1,8 +1,6 @@
 package com.smppw.modaq.domain.entity;
 
-import com.baomidou.mybatisplus.annotation.FieldFill;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -12,6 +10,7 @@ import java.util.Date;
 @Getter
 @TableName("mo_task_record")
 public class TaskRecordDO {
+    @TableId(type = IdType.AUTO)
     private Long id;
 
     private String taskKey;

+ 1 - 1
mo-daq/src/main/java/com/smppw/modaq/domain/service/TaskRecordService.java

@@ -39,7 +39,6 @@ public class TaskRecordService {
             temp.setStartTime(DateUtil.offsetDay(new Date(), -1));
         } else {
             temp.setId(null);
-            temp.setEndTime(null);
             temp.setErrMsg(null);
             temp.setUpdateTime(null);
             if (Objects.equals(1, temp.getStatus())) {
@@ -47,6 +46,7 @@ public class TaskRecordService {
             } else {
                 temp.setStartTime(temp.getStartTime());
             }
+            temp.setEndTime(null);
         }
         temp.setStatus(0);
         temp.setCreateTime(new Date());