xxl-job

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

@@ -12,6 +12,7 @@ import com.yd.email.feign.request.ApiSendEmailRequest;
 import com.yd.email.feign.response.ApiSendEmailResponse;
 import com.yd.email.feign.response.ApiSendEmailResponse;
 import com.yd.email.service.model.EmailTask;
 import com.yd.email.service.model.EmailTask;
 import com.yd.email.service.model.EmailTaskRecipients;
 import com.yd.email.service.model.EmailTaskRecipients;
+import com.yd.email.service.service.IEmailTaskRecipientsService;
 import com.yd.email.service.service.IEmailTaskService;
 import com.yd.email.service.service.IEmailTaskService;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,6 +35,9 @@ public class ApiEmailSendServiceImpl implements ApiEmailSendService {
     @Autowired
     @Autowired
     private IEmailTaskService iEmailTaskService;
     private IEmailTaskService iEmailTaskService;
 
 
+    @Autowired
+    private IEmailTaskRecipientsService iEmailTaskRecipientsService;
+
     /**
     /**
      * 发送邮件
      * 发送邮件
      * @param request
      * @param request
@@ -83,6 +87,7 @@ public class ApiEmailSendServiceImpl implements ApiEmailSendService {
                             mailRecipient.setCcEmail(!CollectionUtils.isEmpty(dto.getCcEmailList()) ? String.join(";",dto.getCcEmailList()) : "");
                             mailRecipient.setCcEmail(!CollectionUtils.isEmpty(dto.getCcEmailList()) ? String.join(";",dto.getCcEmailList()) : "");
                             return mailRecipient;
                             return mailRecipient;
                         }).collect(Collectors.toList());
                         }).collect(Collectors.toList());
+                iEmailTaskRecipientsService.saveOrUpdateBatch(recipientsList);
             }
             }
 
 
             //计划发送时间（为空表示立即发送，不为空表示定时发送）
             //计划发送时间（为空表示立即发送，不为空表示定时发送）