路单日志发送邮件

zlz
1 parent 26d3239b
Showing 6 changed files with 416 additions and 21 deletions
src/main/java/com/bsth/email/MailAuthenticator.java
src/main/java/com/bsth/email/SendEmailController.java
src/main/java/com/bsth/email/SimpleMailSender.java
src/main/java/com/bsth/email/entity/EmailBean.java
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
src/main/resources/mailbox.properties
+package com.bsth.email;
+
+import javax.mail.Authenticator;
+import javax.mail.PasswordAuthentication;
+
+/**
+ * 服务器邮箱登录验证
+ */
+public class MailAuthenticator extends Authenticator{
+	/**
+	 * 用户名（登录邮箱）
+	 */
+	private String username;
+	/**
+	 * 密码
+	 */
+	private String password;
+
+	/**
+	 * 初始化邮箱和密码
+	 * 
+	 * @param username
+	 *            邮箱
+	 * @param password
+	 *            密码
+	 */
+	public MailAuthenticator(String username, String password) {
+		this.username = username;
+		this.password = password;
+	}
+
+	String getPassword() {
+		return password;
+	}
+
+	@Override
+	protected PasswordAuthentication getPasswordAuthentication() {
+		return new PasswordAuthentication(username, password);
+	}
+
+	String getUsername() {
+		return username;
+	}
+
+	public void setPassword(String password) {
+		this.password = password;
+	}
+
+	public void setUsername(String username) {
+		this.username = username;
+	}
+}
+package com.bsth.email;
+
+import com.bsth.email.entity.EmailBean;
+import com.bsth.util.Tools;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public class SendEmailController {
+
+	/*
+	 * recipients
+	 * 收件人集合
+	 * mail
+	 * 邮件
+	 */
+	public int sendMail(List<String> recipients,EmailBean mail){
+		Tools t = new Tools("mailbox.properties");
+		SimpleMailSender sms = new SimpleMailSender(t.getValue("username"),t.getValue("password"));
+		 try {
+	            for (String recipient : recipients) {
+	            	sms.send(recipient, mail.getSubject(),mail.getContent());
+	            }
+	        } catch (Exception e) {
+	            e.printStackTrace();
+	            return -1;
+	        }
+		return 1;
+	}
+	
+	/*
+	 * recipient
+	 * 收件人
+	 * mail
+	 * 邮件
+	 */
+	public int sendMail(String recipient,EmailBean mail){
+		Tools t = new Tools("mailbox.properties");
+		SimpleMailSender sms = new SimpleMailSender(t.getValue("username"),t.getValue("password"));
+		 try {
+			 	sms.send(recipient, mail.getSubject(),mail.getContent());
+	        } catch (Exception e) {
+	            e.printStackTrace();
+	            return -1;
+	        }
+		return 1;
+	}
+}
+package com.bsth.email;
+
+import com.bsth.email.entity.EmailBean;
+
+import java.util.List;
+import java.util.Properties;
+ 
+import javax.activation.CommandMap;
+import javax.activation.MailcapCommandMap;
+import javax.mail.MessagingException;
+import javax.mail.Session;
+import javax.mail.Transport;
+import javax.mail.internet.AddressException;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+import javax.mail.internet.MimeMessage.RecipientType;
+
+
+public class SimpleMailSender {
+	/**
+     * 发送邮件的props文件
+     */
+    private final transient Properties props = System.getProperties();
+    /**
+     * 邮件服务器登录验证
+     */
+    private transient MailAuthenticator authenticator;
+ 
+    /**
+     * 邮箱session
+     */
+    private transient Session session;
+ 
+    /**
+     * 初始化邮件发送器
+     * 
+     * @param smtpHostName
+     *                SMTP邮件服务器地址
+     * @param username
+     *                发送邮件的用户名(地址)
+     * @param password
+     *                发送邮件的密码
+     */
+    public SimpleMailSender(final String smtpHostName, final String username,
+        final String password) {
+    init(username, password, smtpHostName);
+    }
+ 
+    /**
+     * 初始化邮件发送器
+     * 
+     * @param username
+     *                发送邮件的用户名(地址)，并以此解析SMTP服务器地址
+     * @param password
+     *                发送邮件的密码
+     */
+    public SimpleMailSender(final String username, final String password) {
+    //通过邮箱地址解析出smtp服务器，对大多数邮箱都管用
+    final String smtpHostName = "smtp." + username.split("@")[1];
+    init(username, password, smtpHostName);
+ 
+    }
+ 
+    /**
+     * 初始化
+     * 
+     * @param username
+     *                发送邮件的用户名(地址)
+     * @param password
+     *                密码
+     * @param smtpHostName
+     *                SMTP主机地址
+     */
+    private void init(String username, String password, String smtpHostName) {
+    // 初始化props
+    props.put("mail.smtp.auth", "true");
+    props.put("mail.smtp.host", smtpHostName);
+    // 验证
+    authenticator = new MailAuthenticator(username, password);
+    // 创建session
+    session = Session.getInstance(props, authenticator);
+    }
+ 
+    /**
+     * 发送邮件
+     * 
+     * @param recipient
+     *                收件人邮箱地址
+     * @param subject
+     *                邮件主题
+     * @param content
+     *                邮件内容
+     * @throws AddressException
+     * @throws MessagingException
+     */
+    public void send(String recipient, String subject, Object content)
+        throws AddressException, MessagingException {
+    // 创建mime类型邮件
+    final MimeMessage message = new MimeMessage(session);
+    // 设置发信人
+    message.setFrom(new InternetAddress(authenticator.getUsername()));
+    // 设置收件人
+    message.setRecipient(RecipientType.TO, new InternetAddress(recipient));
+    // 设置主题
+    message.setSubject(subject);
+    // 设置邮件内容
+    message.setContent(content.toString(), "text/html;charset=utf-8");
+    
+    MailcapCommandMap mc = (MailcapCommandMap) CommandMap.getDefaultCommandMap();
+    mc.addMailcap("text/html;; x-java-content-handler=com.sun.mail.handlers.text_html");
+    mc.addMailcap("text/xml;; x-java-content-handler=com.sun.mail.handlers.text_xml");
+    mc.addMailcap("text/plain;; x-java-content-handler=com.sun.mail.handlers.text_plain");
+    mc.addMailcap("multipart/*;; x-java-content-handler=com.sun.mail.handlers.multipart_mixed");
+    mc.addMailcap("message/rfc822;; x-java-content-handler=com.sun.mail.handlers.message_rfc822");
+    CommandMap.setDefaultCommandMap(mc);
+    // 发送
+    Transport.send(message);
+    }
+ 
+    /**
+     * 群发邮件
+     * 
+     * @param recipients
+     *                收件人们
+     * @param subject
+     *                主题
+     * @param content
+     *                内容
+     * @throws AddressException
+     * @throws MessagingException
+     */
+    public void send(List<String> recipients, String subject, Object content)
+        throws AddressException, MessagingException {
+    // 创建mime类型邮件
+    final MimeMessage message = new MimeMessage(session);
+    // 设置发信人
+    message.setFrom(new InternetAddress(authenticator.getUsername()));
+    // 设置收件人们
+    final int num = recipients.size();
+    InternetAddress[] addresses = new InternetAddress[num];
+    for (int i = 0; i < num; i++) {
+        addresses[i] = new InternetAddress(recipients.get(i));
+    }
+    message.setRecipients(RecipientType.TO, addresses);
+    // 设置主题
+    message.setSubject(subject);
+    // 设置邮件内容
+    message.setContent(content.toString(), "text/html;charset=utf-8");
+    // 发送
+    Transport.send(message);
+    }
+ 
+    /**
+     * 发送邮件
+     * 
+     * @param recipient
+     *                收件人邮箱地址
+     * @param mail
+     *                邮件对象
+     * @throws AddressException
+     * @throws MessagingException
+     */
+    public void send(String recipient, EmailBean mail)
+        throws AddressException, MessagingException {
+    send(recipient, mail.getSubject(), mail.getContent());
+    }
+ 
+    /**
+     * 群发邮件
+     * 
+     * @param recipients
+     *                收件人们
+     * @param mail
+     *                邮件对象
+     * @throws AddressException
+     * @throws MessagingException
+     */
+    public void send(List<String> recipients, EmailBean mail)
+        throws AddressException, MessagingException {
+    send(recipients, mail.getSubject(), mail.getContent());
+    }
+}
+package com.bsth.email.entity;
+
+/**
+ * Created by zlz on 2017-12-29.
+ */
+public class EmailBean {
+    private String subject;// 邮件标题
+    private String content;//邮件内容
+    public String getSubject() {
+        return subject;
+    }
+    public void setSubject(String subject) {
+        this.subject = subject;
+    }
+    public String getContent() {
+        return content;
+    }
+    public void setContent(String content) {
+        this.content = content;
+    }
+}
 package com.bsth.service.impl;
 import com.bsth.data.BasicData;
+import com.bsth.email.SendEmailController;
+import com.bsth.email.entity.EmailBean;
 import com.bsth.entity.*;
 import com.bsth.entity.realcontrol.ChildTaskPlan;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
@@ -109,6 +111,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	@Autowired
 	private YgcBasicDataService ygcBasicDataService;
+	// 发送邮件
+	@Autowired
+	private SendEmailController sendEmailController;
 	// 运管处上传接口
 	private com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap webServiceSoapUp;
@@ -138,6 +143,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private final String userNameUp = "user";
 	// 密码
 	private final String passwordUp = "user";
+	// 接收邮件人
+	private final String emailSendToAddress = "175912183@qq.com";
+	// 记录路单上线的成功、失败线路数
+	private Integer countSuccess,countFailure;
 	private synchronized com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap  getWebServiceSoapUp(){
 		try {
@@ -396,20 +405,27 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	 */
 	private String uploadLD(String theDate){
 		String result = "failure";
+		countSuccess = 0 ;countFailure = 0;
 		Line line;
 		// 取昨天 的日期
 		String date = theDate == null ?sdfnyr.format(DateUtils.addDays(new Date(), -1)) : theDate;
 		StringBuffer sf = new StringBuffer();
-		String str;
+		StringBuffer logSuccess = new StringBuffer("成功：");
+		StringBuffer logFailure = new StringBuffer("失败：");
+		HashMap logXlbmSuccessMap = new HashMap();
+		HashMap logXlbmFailureMap = new HashMap();
+		HashMap logXlbmMap = new HashMap();
+		Results results = null;
+		String str = "",xlbm;
 		try {
 			int counter = 0; // 计数器
 			int per = 10; // 每几条线路上传一次路单
 			List<ScheduleRealInfo> list = scheduleRealInfoRepository.setLD(date);
 			List<Map<String,Object>> listGroup = scheduleRealInfoRepository.setLDGroup(date);
-			Map<String,Object> map = new HashMap<String,Object>();
+			Map<String,Object> map = new HashMap();
 			HashMap<String,String> paramMap;
-			HashMap<String,String> otherMap = new HashMap<String, String>();
+			HashMap<String,String> otherMap = new HashMap();
 			for(Map<String,Object> schRealInfo:listGroup){
 				if(schRealInfo != null){
 					//根据车辆自编号查询车牌号
@@ -425,9 +441,14 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 						sf.append("<DLDS>");
 					}
 					counter ++;
+					xlbm = BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm")+"");
+					// 保存一次路单的线路编码，用于发送邮箱
+					if(logXlbmMap.get(xlbm) == null){
+						logXlbmMap.put(xlbm,xlbm);
+					}
 					sf.append("<DLD>");
 					sf.append("<RQ>"+date+"</RQ>");
-					sf.append("<XLBM>"+BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm")+"")+"</XLBM>");
+					sf.append("<XLBM>"+xlbm+"</XLBM>");
 					sf.append("<LPBH>"+schRealInfo.get("lpName")+"</LPBH>");
 					sf.append("<CPH>"+car.getCarPlate()+"</CPH>");
 					sf.append("<UPDT>"+sdfnyrsfm.format(new Date())+"</UPDT>");
@@ -485,39 +506,85 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					counter = 0;
 					sf.append("</DLDS>");
 					str = sf.toString().replace("'","");// 去掉'号
-					Results results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
-					if(results.isSuccess()){
-						result = "success";
-					}else{
-						result = "failure";
-					}
-					logger.info("setLD:"+str);
-					logger.info("setLD:"+result);
+					results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
+					// 记录日志
+					result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
 				}
 			}
 			// 每per条线路上传后剩下的数据再上传
 			if(counter > 0){
 				sf.append("</DLDS>");
 				str = sf.toString().replace("'","");// 去掉'号
-				Results results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
-				if(results.isSuccess()){
-					result = "success";
-				}else{
-					result = "failure";
-				}
-				logger.info("setLD:"+str);
-				logger.info("setLD:"+result);
+				results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
 			}
+			// 记录日志
+			result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
 		} catch (Exception e) {
 			logger.error("setLD:",e);
+			logFailure.append(e).append("<br/>");
+			for (StackTraceElement traceElement : e.getStackTrace()){
+				logFailure.append("\r\t").append(traceElement);
+			}
 			e.printStackTrace();
 		}finally{
-
+			//发送邮件
+			EmailBean mail = new EmailBean();
+			mail.setSubject("路单日志数据"+date);
+			mail.setContent(logSuccess+"<br/>成功数："+countSuccess+"<br/>" +logFailure+"<br/>失败数："+countFailure);
+			sendEmailController.sendMail(emailSendToAddress, mail);
 		}
 		return result;
 	}
 	/**
+	 * 记录日志
+	 * @param results
+	 * @param logXlbmMap
+	 * @param logXlbmSuccessMap
+	 * @param logXlbmFailureMap
+	 * @param logSuccess
+	 * @param logFailure
+	 * @param str
+	 */
+	private String logRecord(Results results,HashMap logXlbmMap,HashMap logXlbmSuccessMap,HashMap logXlbmFailureMap,StringBuffer logSuccess,
+						   StringBuffer logFailure,String str){
+		String result = "failure";
+		// 记录日志
+		if(results != null){
+			if(results.isSuccess()){// 上传成功
+				// 把上线成功的线路编码放入 logXlbmSuccessMap，并记录logSuccess
+				countSuccess += fillMailXlbmMap(logXlbmMap,logXlbmSuccessMap,logSuccess);
+				result = "success";
+			}else{// 上传失败
+				// 把上线失败的线路编码放入 logXlbmFailureMap，并记录logFailure
+				countFailure += fillMailXlbmMap(logXlbmMap,logXlbmFailureMap,logFailure);
+				result = "failure";
+			}
+			logger.info("setLD:"+str);
+			logger.info("setLD:"+result);
+			results = null;
+			logXlbmMap = new HashMap();
+		}
+		return result;
+	}
+	/**
+	 * 填充线路编码到相应的map
+	 * @param fromMap
+	 * @param toMap
+	 */
+	private int fillMailXlbmMap(HashMap fromMap,HashMap toMap,StringBuffer logStr){
+		int tmpCount = 0;
+		for (Object key : fromMap.keySet()) {
+			if(toMap.get(key) == null){
+				toMap.put(key,fromMap.get(key));
+				logStr.append(key).append(",");
+				tmpCount ++;
+			}
+		}
+		fromMap = new HashMap();
+		return tmpCount;
+	}
+	/**
 	 * 上传路单 xml来自文件
 	 * @return 上传成功标识
 	 */
+username=pdda_zhmm2014@163.COM
+password=ZHMM2014_PDDA
+address=116.236.208.198:9090
+qq.com=http://mail.qq.com
+gmail.com=http://mail.google.com
+sina.com=http://mail.sina.com.cn
+163.com=http://mail.163.com
+126.com=http://mail.126.com
+yeah.net=http://www.yeah.net/
+sohu.com=http://mail.sohu.com/
+tom.com=http://mail.tom.com/
+sogou.com=http://mail.sogou.com/
+139.com=http://mail.10086.cn/
+hotmail.com=http://www.hotmail.com
+live.com=http://login.live.com/
+live.cn=http://login.live.cn/
+live.com.cn=http://login.live.com.cn
+189.com=http://webmail16.189.cn/webmail/
+yahoo.com.cn=http://mail.cn.yahoo.com/
+yahoo.cn=http://mail.cn.yahoo.com/
+eyou.com=http://www.eyou.com/
+21cn.com=http://mail.21cn.com/
+188.com=http://www.188.com/
+foxmail.coom=http\://www.foxmail.com
 \ No newline at end of file