package com.whyc.schedule;
|
|
import com.whyc.factory.ThreadPoolExecutorFactory;
|
import com.whyc.pojo.Software;
|
import com.whyc.service.SoftwareService;
|
import com.whyc.service.UserService;
|
import com.whyc.util.DateUtil;
|
import com.whyc.util.MailUtil;
|
import com.whyc.util.ThreadLocalUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.mail.MessagingException;
|
import java.util.Arrays;
|
import java.util.List;
|
|
/**
|
* 软件升级申请邮件推送定时任务
|
*/
|
@EnableScheduling
|
@Component
|
public class SoftwareMailSchedule {
|
|
@Autowired
|
private MailUtil mailUtil;
|
|
@Autowired
|
private SoftwareService softwareService;
|
|
@Autowired
|
private UserService userService;
|
|
/**数据4秒钟获取一次*/
|
@Scheduled(cron = "0/4 * * * * ? ")
|
public void sendMail(){
|
//查询需要发送邮件
|
List<Software> list = softwareService.getSendList();
|
//查询研发角色的所有用户邮箱
|
List<String> toArr = userService.getEmailList();
|
//String[] toArrStr = new String[]{"perryhsu@163.com"};
|
//List toArr = Arrays.asList(toArrStr);
|
|
for (int i = 0; i < list.size(); i++){
|
Software software = list.get(i);
|
ThreadPoolExecutorFactory.getPoolExecutor().execute(() -> {
|
// 发送邮件
|
try {
|
mailUtil.sendMailBatch(toArr, "长城汽车-电池系统软件升级申请", "SN码:"+software.getSnCode()+"\n软件序列号:"+software.getSerialNumber()+ "\n物料编码:"+software.getMaterialCode()+"\n版本:"+software.getVersion()+"\n申请时间:"+ ThreadLocalUtil.format(software.getApplyTime(),1));
|
//更新邮件发送状态
|
softwareService.updateMailStatus(software.getId());
|
} catch (MessagingException e) {
|
throw new RuntimeException(e);
|
}
|
});
|
}
|
}
|
|
|
}
|
