59.md

[TOC]

BOS物流项目59———quartz4_定时给取派员发送新单的邮件

一、在BOS项目中引入quartz

导入以下的依赖

        <!--导入quartz对应的依赖-->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.2.3</version>
        </dependency>

        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz-jobs</artifactId>
            <version>2.2.3</version>
        </dependency>

        <!--引入JavaMail的依赖-->
        <dependency>
            <groupId>javax.mail</groupId>
            <artifactId>mail</artifactId>
            <version>1.4.7</version>
        </dependency>

---

二、提供一个作业类，用于为系统管理员发送邮件

在bos-service模块中添加如下的类。

有新单的时候，通知到业务员。

/**
 * @author: qiwenming(杞文明)
 * @date: 18/1/1 下午7:36
 * @className: l
 * @description:
 *  新单的时候,邮件通知取派员
 */
public class MailJob {
    @Resource
    private IWorkbillDao workbillDao;
    private String username;//发件人的邮箱账号
    private String password;//密码
    private String smtpServer;//服务器
    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public void execute() {
        System.out.println("要发邮件了。。。" + new Date());
        try {
            //查询工单类型为新单的所有工单
            List<Workbill> list = workbillDao.findNewWorkbill();
            if(null != list && list.size() > 0){
                final Properties mailProps = new Properties();
                mailProps.put("mail.smtp.host", this.getSmtpServer());
                mailProps.put("mail.smtp.auth", "true");
                mailProps.put("mail.username", this.getUsername());
                mailProps.put("mail.password", this.getPassword());

                // 构建授权信息，用于进行SMTP进行身份验证
                Authenticator authenticator = new Authenticator() {
                    protected PasswordAuthentication getPasswordAuthentication() {
                        // 用户名、密码
                        String userName = mailProps.getProperty("mail.username");
                        String password = mailProps.getProperty("mail.password");
                        return new PasswordAuthentication(userName, password);
                    }
                };
                // 使用环境属性和授权信息，创建邮件会话
                Session mailSession = Session.getInstance(mailProps, authenticator);
                for(Workbill workbill : list){
                    // 创建邮件消息
                    MimeMessage message = new MimeMessage(mailSession);
                    // 设置发件人
                    InternetAddress from = new InternetAddress(mailProps.getProperty("mail.username"));
                    message.setFrom(from);
                    // 设置收件人
                    InternetAddress to = new InternetAddress("对应取派员的邮箱");
                    message.setRecipient(MimeMessage.RecipientType.TO, to);
                    // 设置邮件标题
                    message.setSubject("系统邮件：新单通知");
                    // 设置邮件的内容体
                    message.setContent(workbill.toString(), "text/html;charset=UTF-8");
                    // 发送邮件
                    Transport.send(message);
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public String getSmtpServer() {
        return smtpServer;
    }

    public void setSmtpServer(String smtpServer) {
        this.smtpServer = smtpServer;
    }
}

---

三、在spring配置文件中配置

   <!--注册自定义作业类-->
    <bean id="myJob" class="com.qwm.bos.jobs.MailJob">
        <property name="smtpServer" value="smtp服务"/>
        <property name="username" value="您的邮箱号"/>
        <property name="password" value="您的邮箱密码"/>
    </bean>

    <!--配置JobDetail-->
    <bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <!--注入目标对象-->
        <property name="targetObject" ref="myJob"/>
        <!--注入目标方法-->
        <property name="targetMethod" value="execute"/>
    </bean>

    <!--配置触发器-->
    <bean id="myTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <!--注入任务详情对象-->
        <property name="jobDetail" ref="jobDetail"/>
        <!--注入cron表达式,通过这个表达式指定触发的时间点-->
        <property name="cronExpression" value="0/5 * * * * ?"/>
    </bean>

    <!--配置调度工厂-->
    <bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <!--注入触发器-->
        <property name="triggers">
            <list>
                <ref bean="myTrigger"/>
            </list>
        </property>
    </bean>

---

四、源码下载

https://github.com/wimingxxx/bos-parent