package com.yc.crm.schedule;
|
|
import com.sun.mail.imap.IMAPFolder;
|
import com.sun.mail.imap.IMAPStore;
|
import com.yc.api.schedule.ScheduleUtils;
|
import com.yc.crm.mail.entity.FoundationEntity;
|
import com.yc.crm.mail.entity.T482102Entity;
|
import com.yc.crm.mail.service.MailAccountIfc;
|
import com.yc.crm.mail.service.MailServiceIfc;
|
import com.yc.entity.AttachmentConfig;
|
import com.yc.entity.DataSourceEntity;
|
import com.yc.factory.FactoryBean;
|
import com.yc.multiData.MultiDataSource;
|
import com.yc.multiData.SpObserver;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationListener;
|
import org.springframework.context.event.ContextRefreshedEvent;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
|
import org.springframework.stereotype.Service;
|
|
import javax.mail.*;
|
import javax.mail.event.MessageCountEvent;
|
import javax.mail.event.MessageCountListener;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Properties;
|
|
/**
|
* 实时监听邮箱
|
*/
|
@Slf4j
|
@Service
|
public class EmailSchedule implements ApplicationListener<ContextRefreshedEvent> {
|
@Autowired
|
ThreadPoolTaskExecutor threadPoolExecutor;
|
@Autowired
|
private ThreadPoolTaskScheduler threadPoolTaskScheduler;
|
@Autowired
|
MailAccountIfc emailAccountIfc;
|
@Autowired
|
MailServiceIfc mailServiceIfc;
|
|
@Override
|
public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
|
if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
|
return;
|
}
|
threadPoolTaskScheduler = (ThreadPoolTaskScheduler) FactoryBean.getBean("threadPoolTaskScheduler");
|
threadPoolExecutor = (ThreadPoolTaskExecutor) FactoryBean.getBean("threadPoolExecutor");
|
String isStartUpSchedule = AttachmentConfig.get("isStartUpSchedule");//只在设置了定时任务的服务器上运行
|
if ("1".equals(isStartUpSchedule)) {
|
Map<String, DataSourceEntity> infoList = MultiDataSource.getDataSourceMaps();
|
for (Map.Entry<String, DataSourceEntity> entry : infoList.entrySet()) {
|
DataSourceEntity dataSourceEntity = entry.getValue();
|
if (ScheduleUtils.isOnbusPlatform(dataSourceEntity) || dataSourceEntity.getDbId() == 1624) {
|
//dbid=1624,巴士软件(佛山公司),不需要执行定时任务
|
continue;
|
}
|
// if (dataSourceEntity.getDbId() != 82) continue;//TODO 测试用
|
emailTask(dataSourceEntity);
|
}
|
}
|
}
|
|
private void emailTask(DataSourceEntity dataSourceEntity) {
|
try {
|
SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());
|
List<T482102Entity> list = emailAccountIfc.getAccountList();
|
log.info(dataSourceEntity.getDbId()+"-加载邮箱数量："+list.size());
|
for (T482102Entity t482102Entity : list) {
|
threadPoolExecutor.execute(new checkEmailThread(t482102Entity,dataSourceEntity));
|
}
|
} catch (Exception e) {
|
System.out.println("取不到邮箱设置内容：dbid=" + dataSourceEntity.getDbId() + "：" + e.getMessage());
|
e.printStackTrace();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
private class checkEmailThread implements Runnable {
|
T482102Entity emailEntity;
|
FoundationEntity foundation;
|
DataSourceEntity dataSourceEntity;
|
public checkEmailThread(T482102Entity t482102Entity, DataSourceEntity dataSourceEntity) {
|
this.emailEntity = t482102Entity;
|
this.dataSourceEntity = dataSourceEntity;
|
foundation=new FoundationEntity();
|
foundation.setDbId(dataSourceEntity.getDbId());
|
foundation.setCompanyName(emailEntity.getCompanyName());
|
foundation.setCompanyId(emailEntity.getCompanyId());
|
foundation.setUserCode(emailEntity.getUserCode());
|
foundation.setUserName(emailEntity.getUserName());
|
}
|
|
@Override
|
public void run() {
|
checkEmail();
|
}
|
private void checkEmail() {
|
try {
|
String protocol = emailEntity.getReceiveProtocol().toLowerCase();//接收协议 imap pop3
|
String server = emailEntity.getReceiveHost();//"imap.qq.com";
|
Integer port = emailEntity.getReceivePort();//993
|
String user =emailEntity.getReceiveEmail();//邮箱
|
String pwd = emailEntity.getReceivePassword();//密码
|
Properties properties = new Properties();
|
properties.setProperty("mail.store.protocol", protocol); // IMAP over SSL
|
if (protocol.contains("imap")) {//接收协议imap
|
properties.setProperty("mail.imaps.host", server);
|
properties.setProperty("mail.imaps.port", port + "");
|
} else if (protocol.contains("pop3")) {//接收协议pop3
|
properties.setProperty("mail.pop3.host", server);
|
properties.setProperty("mail.pop3.port", port + "");
|
} else {//其他（再加）
|
properties.setProperty("mail.imaps.host", server);
|
properties.setProperty("mail.imaps.port", port + "");
|
}
|
HashMap IAM = new HashMap();
|
//带上IMAP ID信息，由key和value组成，例如name，version，vendor，support-email等。
|
IAM.put("name", user);
|
IAM.put("version", emailEntity.getDocVersion() + "");
|
IAM.put("vendor", emailEntity.getCompanyName());
|
IAM.put("support-email", emailEntity.getEmail());
|
//创建会话
|
Session session = Session.getInstance(properties, new Authenticator() {
|
@Override
|
protected PasswordAuthentication getPasswordAuthentication() {
|
return new PasswordAuthentication(user, pwd);
|
}
|
});
|
//存储对象
|
IMAPStore store = (IMAPStore) session.getStore(protocol);//imap协议或pop3协议类型（推荐你使用IMAP协议来存取服务器上的邮件。）
|
//连接
|
store.connect(server, user, pwd);
|
store.id(IAM);//163邮箱需要，不然会报：A3 NO SELECT Unsafe Login. Please contact kefu@188.com for help
|
Folder folder = null;
|
try {
|
// 获得收件箱
|
folder = store.getFolder("INBOX");
|
// 以读写模式打开收件箱
|
folder.open(Folder.READ_WRITE);
|
log.info(emailEntity.getEmail() + "已就绪接收新邮件....");
|
folder.addMessageCountListener(new MessageCountListener() {
|
@Override
|
public void messagesAdded(MessageCountEvent e) {
|
//TODO 处理新邮件
|
try {
|
SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());
|
mailServiceIfc.setMailContent(e.getMessages(), emailEntity, foundation,true);
|
}catch (Exception e1){
|
e1.printStackTrace();
|
}finally {
|
SpObserver.setDBtoInstance();
|
}
|
log.info(emailEntity.getEmail()+":Message Count Event Fired");
|
}
|
@Override
|
public void messagesRemoved(MessageCountEvent e) {
|
// System.out.println(emailEntity.getEmail()+"Message Count Event Fired");
|
}
|
});
|
|
/* folder.addMessageChangedListener(new MessageChangedListener() {
|
@Override
|
public void messageChanged(MessageChangedEvent e) {
|
System.out.println(emailEntity.getEmail()+"Message Count Event Fired");
|
}
|
});*/
|
// Check mail once in "freq" MILLIseconds
|
int freq = 2000;
|
boolean supportsIdle = false;
|
try {
|
if (folder instanceof IMAPFolder) {
|
IMAPFolder f = (IMAPFolder) folder;
|
f.idle();
|
supportsIdle = true;
|
}
|
} catch (FolderClosedException fex) {
|
throw fex;
|
} catch (MessagingException mex) {
|
supportsIdle = false;
|
}
|
for (; ; ) {
|
if (supportsIdle && folder instanceof IMAPFolder) {
|
IMAPFolder f = (IMAPFolder) folder;
|
f.idle();
|
// System.out.println(emailEntity.getEmail()+"IDLE done");
|
} else {
|
Thread.sleep(freq); // sleep for freq milliseconds
|
// This is to force the IMAP server to send us
|
// EXISTS notifications.
|
folder.getMessageCount();
|
}
|
}
|
|
} catch (FolderClosedException fe) {
|
log.info("FolderClosedException......");
|
checkEmail();
|
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
} finally {
|
try {
|
if (folder != null) {
|
folder.close(false);
|
}
|
if (store != null) {
|
store.close();
|
}
|
} catch (MessagingException e) {
|
throw e;
|
}
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
}
|
}
|
