Spring + qyartz+多任务实现任务调度功能。

前记:如果配置多个任务不能触发的请仔细检查配置文件!!!!!!

不存在多个同时间任务不能触发的现象!!!!

Spring + qyartz+多任务实现任务调度功能。

这个东西记得不要设置成false。如果写了就是true。不写的话默认true。

下面开始贴配置:

1.首先配置web.xml 注入spring的xml文件。(记得把quartz的xml也注入了,我这边都是spring开头的。)

Spring + qyartz+多任务实现任务调度功能。

2.Java类:

package com.apexedu.biz.util;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

import com.apexedu.biz.entity.TJhrz;
import com.apexedu.biz.entity.TRyxx;
import com.apexedu.framework.util.DBUtil;
import com.apexedu.sys.util.DateUtil;
import com.apexedu.sys.util.StringUtil;

/**
 * 每天发送微信提醒
 * @author Hpp 2017-3-28
 *
 */
public class JhrzInitUtil {

    /**
     * 前一天下午发送提醒消息
     */
    public void preDay(){
        System.out.println("preDay");
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
        SimpleDateFormat df = new SimpleDateFormat("M/d");//设置日期格式
        Date nextDay = DateUtil.getNextDay(new Date());//明天的日期
        String nextDays=df.format(nextDay);// new Date()为获取当前系统时间
        List<TJhrz> list = DBUtil.queryAllBeanList("select * from t_jhrz where xq=? and day=? and state not in('2','5')", TJhrz.class, years,nextDays);
        for (TJhrz tJhrz : list) {
             SendTip.sendMsg(new String[]{tJhrz.getRyid()},"您明天有"+tJhrz.getJhnr()+"工作需要处理,请您提前做好准备。", tJhrz.getRyid());
        }
    }
    /**
     * 当天9点发送提醒消息
     */
    public void currDay09(){
        System.out.println("currDay09");
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
        SimpleDateFormat df = new SimpleDateFormat("M/d");//设置日期格式
        String currDays=df.format(new Date());// new Date()为获取当前系统时间
        List<TJhrz> list = DBUtil.queryAllBeanList("select * from t_jhrz where xq=? and day=? and state not in('2','5')", TJhrz.class,years,currDays);
        for (TJhrz tJhrz : list) {
             SendTip.sendMsg(new String[]{tJhrz.getRyid()},"您今天有"+tJhrz.getJhnr()+"工作需要处理,请您及时处理。", tJhrz.getRyid());
        }
    }
    /**
     * 当天下午16点发送提醒消息
     */
    public void currDay16(){
        System.out.println("currDay16");
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
        SimpleDateFormat df = new SimpleDateFormat("M/d");//设置日期格式
        String currDays=df.format(new Date());// new Date()为获取当前系统时间
        List<TJhrz> list = DBUtil.queryAllBeanList("select * from t_jhrz where xq=? and day=? and state=0", TJhrz.class, years,currDays);
        for (TJhrz tJhrz : list) {
             SendTip.sendMsg(new String[]{tJhrz.getRyid()},"您今天有"+tJhrz.getJhnr()+"工作系统显示未完成,请您及时处理。", tJhrz.getRyid());
        }
    }
    /**
     * 计划延期后及时提醒09
     * @throws ParseException
     */
    public void nextSDay09() throws ParseException{
        System.out.println("nextSDay09");
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
        SimpleDateFormat df = new SimpleDateFormat("yyyy/M/d");//设置日期格式
        String currWeek=DateUtil.getCurrentWeek(new Date());
        List<TJhrz> list = DBUtil.queryAllBeanList("select * from t_jhrz where state=0 and jhsj=? and xq=?", TJhrz.class, currWeek,years);
        for (TJhrz tJhrz : list) {
            int day = DateUtil.datePDate(df.parse(year+"/"+tJhrz.getDay()), new Date());
            if(day>0){
                 SendTip.sendMsg(new String[]{tJhrz.getRyid()},"您计划"+tJhrz.getDay()+"的"+tJhrz.getJhnr()+"工作系统显示已延误"+day+"天,请您及时处理。", tJhrz.getRyid());
            }
        }
    }
    /**
     * 计划延期后及时提醒16
     * @throws ParseException
     */
    public void nextSDay16() throws ParseException{
        System.out.println("nextSDay16()");
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
        SimpleDateFormat df = new SimpleDateFormat("yyyy/M/d");//设置日期格式
        String currWeek=DateUtil.getCurrentWeek(new Date());
        List<TJhrz> list = DBUtil.queryAllBeanList("select * from t_jhrz where state=0 and jhsj=? and xq=?", TJhrz.class, currWeek,years);
        for (TJhrz tJhrz : list) {
            int day = DateUtil.datePDate(df.parse(year+"/"+tJhrz.getDay()), new Date());
            if(day>0){
                 SendTip.sendMsg(new String[]{tJhrz.getRyid()},"您计划"+tJhrz.getDay()+"的"+tJhrz.getJhnr()+"工作系统显示已延误"+day+"天,请您及时处理。", tJhrz.getRyid());
            }
        }
    }
    /**
     * 每周五4点给科室负责人推送
     */
    public void firDay16(){
        System.out.println("firDay16");
        String currWeek=DateUtil.getCurrentWeek(new Date());
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
        List<TJhrz> list =DBUtil.queryAllBeanList("select t.*,(select name from t_ryxx where gh=t.ryid) ryid_str,(select bmfzr from t_bmxx where wid=(select bmid from t_ryxx b where b.gh=t.ryid )) ksfzr from t_jhrz t where jhsj=? and xq=? and state=0", TJhrz.class, currWeek,years);
        for (TJhrz tJhrz : list) {
             SendTip.sendMsg(new String[]{tJhrz.getKsfzr()},"您科室的"+tJhrz.getRyid_str()+"有"+tJhrz.getJhnr()+"工作系统显示未完成,请您督促处理。", tJhrz.getKsfzr());
        }
    }
    /**
     * 针对上周所分管的科室工作人员“未完成”的工作
     */
    public void Mon1(){
        System.out.println("Mon1");
        Calendar c = Calendar.getInstance();
        int year=c.get(Calendar.YEAR);//获取当前年份
        String years=String.valueOf(year)+"年";//拼接字符串
           c.setTime(new Date());
        c.add(Calendar.DATE,-7);
        Date monday = c.getTime();
        String prevWeek=DateUtil.getCurrentWeek(monday);//上一周的日期
        List<TRyxx> clds = DBUtil.queryAllBeanList("select * from t_ryxx where bmid=(select wid from t_bmxx  where bmmc like ?)", TRyxx.class, "%处领导%");
        for (TRyxx tRyxx : clds) {
            String[] kss = tRyxx.getFgks().split(",");
            for (String string : kss) {
                if(StringUtil.isNotBlank(string)){
                    List<TJhrz> list = DBUtil.queryAllBeanList("select t.*,(select name from t_ryxx where gh=t.ryid) ryid_str,(select bmmc from t_bmxx where wid=?) bmmc from t_jhrz t where ryid in(select gh from t_ryxx where bmid=?) and xq=? and jhsj=? and state=0", TJhrz.class, string,string,years,prevWeek);
                    for (TJhrz tJhrz : list) {
                         SendTip.sendMsg(new String[]{tRyxx.getGh()},"您分管的科室的"+tJhrz.getRyid_str()+"上周有"+tJhrz.getJhnr()+"工作系统显示未完成,请您督促处理。", tRyxx.getGh());
                    }
                }
            }
        }
    }
}

下面看看quartz的xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

    <bean id="JhrzInitUtil"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
    <bean id="JhrzInitUtil2"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
   <bean id="JhrzInitUtil3"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
    <bean id="JhrzInitUtil4"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
   <bean id="JhrzInitUtil5"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
   <bean id="JhrzInitUtil6"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
   <bean id="JhrzInitUtil7"
       class="com.apexedu.biz.util.JhrzInitUtil">
   </bean>
   <!-- 计划任务 -->
    <bean id="preDay"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil" />
       </property>
       <property name="targetMethod">
           <value>preDay</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="preDayInit"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="preDay"/>
       </property>
       <property name="cronExpression">
            <value>0 0 16 * * ? *</value>
       </property>
   </bean>
   <!-- 计划任务 -->

   <bean id="currDay09"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil2" />
       </property>
       <property name="targetMethod">
           <value>currDay09</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="currDay09Init"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="currDay09"/>
       </property>
       <property name="cronExpression">
            <value>0 0 9 * * ? *</value>
       </property>
   </bean>

    <bean id="currDay16"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil3" />
       </property>
       <property name="targetMethod">
           <value>currDay16</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="currDay16Init"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="currDay16"/>
       </property>
       <property name="cronExpression">
            <value>0 0 16 * * ? *</value>
       </property>
   </bean>

   <bean id="nextSDay09"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil4" />
       </property>
       <property name="targetMethod">
           <value>nextSDay09</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="nextSDay09Init"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="nextSDay09"/>
       </property>
       <property name="cronExpression">
            <value>0 0 9 * * ? *</value>
       </property>
   </bean>

   <bean id="nextSDay16"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil5" />
       </property>
       <property name="targetMethod">
           <value>nextSDay16</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="nextSDay16Init"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="nextSDay16"/>
       </property>
       <property name="cronExpression">
            <value>0 0 16 * * ? *</value>
       </property>
   </bean>

    <bean id="firDay16"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil6" />
       </property>
       <property name="targetMethod">
           <value>firDay16</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="firDay16Init"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="firDay16"/>
       </property>
       <property name="cronExpression">
            <value>0 0 16 ? * FRI</value>
       </property>
   </bean>

    <bean id="Mon1"
       class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
       <property name="targetObject">
           <ref bean="JhrzInitUtil7" />
       </property>
       <property name="targetMethod">
           <value>Mon1</value>
       </property>
       <property name="concurrent" value="true"/>
   </bean>   

   <bean id="Mon1Init"
       class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
       <property name="jobDetail">
           <ref bean="Mon1"/>
       </property>
       <property name="cronExpression">
            <value>0 30 13 ? * MON</value>
       </property>
   </bean>

   <bean
       class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
       <property name="triggers">
           <list>
           <ref local="Mon1Init"/>
            <ref local="firDay16Init"/>
           <ref local="nextSDay16Init"/>
                 <ref local="nextSDay09Init"/>
                <ref local="currDay16Init"/>
               <ref local="currDay09Init"/>
               <ref local="preDayInit"/>
           </list>
       </property>
   </bean>
</beans>
    
上一篇:【Ansible 文档】【译文】模式


下一篇:C primer plus 读书笔记第六章和第七章