package com.whyc.task;
|
|
import com.whyc.pojo.MailQueue;
|
import com.whyc.service.MailQueueService;
|
import com.whyc.service.MailService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
import java.util.TimerTask;
|
|
@Component
|
public class MailQueueTask extends TimerTask {
|
|
@Autowired
|
private MailQueueService mailQueueService;
|
|
@Autowired
|
private MailService mailService;
|
|
@Override
|
public void run() {
|
try {
|
//查询邮件队列中的待发送列表
|
List<MailQueue> sendingList = mailQueueService.getList();
|
//发送邮件
|
for (MailQueue queue : sendingList) {
|
mailService.sendQueueMail(queue);
|
}
|
}catch (Exception e){
|
System.out.println("MailQueueTask发生异常:"+e.toString());
|
}
|
}
|
}
|
