articleserviceimpl.java

SSHMail Ajax方式提交,自动抓取页面内容,统计关键字个数.

/**
 * 用户Service
 */
package com.leo.service.impl;

import java.util.Date;
import java.util.List;

import org.apache.log4j.Logger;

import com.leo.po.Article;
import com.leo.po.Log;
import com.leo.po.Mail;
import com.leo.service.IArticleService;
import com.leo.service.ILogService;
import com.leo.service.IMailService;
import com.leo.util.JavaMailSenderUtil;
import com.leo.util.RegEx;

/**
 * @author superleo
 * 
 */
public class ArticleServiceImpl extends GenericServiceImpl<Article, Long>
		implements IArticleService {

	private static Logger logger = Logger.getLogger(ArticleServiceImpl.class);

	private IMailService mailService;

	private ILogService logService;

	private JavaMailSenderUtil javaMailSenderUtil;

	public JavaMailSenderUtil getJavaMailSenderUtil() {
		return javaMailSenderUtil;
	}

	public void setJavaMailSenderUtil(JavaMailSenderUtil javaMailSenderUtil) {
		this.javaMailSenderUtil = javaMailSenderUtil;
	}

	public ILogService getLogService() {
		return logService;
	}

	public void setLogService(ILogService logService) {
		this.logService = logService;
	}

	public IMailService getMailService() {
		return mailService;
	}

	public void setMailService(IMailService mailService) {
		this.mailService = mailService;
	}

	public ArticleServiceImpl(Class<Article> type) {
		super(type);
	}

	public int storeByURL() throws Exception {
		int count = RegEx.doRegEx();
		// 保存每5分钟，抓取的记录数量
		Article article = new Article();
		article.setCount(count);
		article.setCreateDate(new Date());
		this.store(article);

		// 群发邮件
		List<Mail> mails = mailService.findByAll();
		logger.info("开始群发邮件........");
		for (Mail mail : mails) {
			Log log = new Log();
			log.setCreateDate(new Date());
			log.setLog("正在向 [" + mail.getName() + "] 发送邮件......");
			log.setMail(mail);
			javaMailSenderUtil.sendMail(mail, count);
			this.logService.store(log);
		}
		logger.info("群发结束邮件........");

		return count;

	}

}