push

yd-email-api/src/main/java/com/yd/email/api/handler/EmailSendJobHandler.java

@@ -50,6 +50,8 @@ public class EmailSendJobHandler {
      */
     @XxlJob("emailSendJobHandler")
     public void execute() throws Exception {
+        //主任务发送时间
+        LocalDateTime taskSendTime = LocalDateTime.now();
         // 从XXL-Job参数中获取任务ID
         String param = XxlJobHelper.getJobParam();
         // 记录任务开始日志
@@ -132,6 +134,8 @@ public class EmailSendJobHandler {
             emailTask.setStatus(failCount == 0 ?
                     EmailTaskStatusEnum.ALL_SUCCESSFUL.getItemValue() :
                     EmailTaskStatusEnum.PARTIAL_FAILURE.getItemValue());
+            //主任务发送时间
+            emailTask.setSendTime(taskSendTime);
             iEmailTaskService.saveOrUpdate(emailTask);
 
             // 记录任务完成日志

yd-email-api/src/main/java/com/yd/email/api/service/impl/ApiEmailSendServiceImpl.java

@@ -102,6 +102,8 @@ public class ApiEmailSendServiceImpl implements ApiEmailSendService {
      * @return
      */
     public Result sendImmediatelyEmail(EmailTask emailTask,List<EmailTaskRecipients> recipients) {
+        //主任务发送时间
+        LocalDateTime taskSendTime = LocalDateTime.now();
         try {
             //调用邮件服务发送邮件入参DTO
             ApiSendMailDto apiSendMailDto = new ApiSendMailDto();
@@ -160,6 +162,8 @@ public class ApiEmailSendServiceImpl implements ApiEmailSendService {
             emailTask.setStatus(failCount == 0 ?
                     EmailTaskStatusEnum.ALL_SUCCESSFUL.getItemValue() :
                     EmailTaskStatusEnum.PARTIAL_FAILURE.getItemValue());
+            //主任务发送时间
+            emailTask.setSendTime(taskSendTime);
             iEmailTaskService.saveOrUpdate(emailTask);
 
             // 记录任务完成日志