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

时间:2022-09-17 14:10:03

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

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

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>
    

Spring + qyartz+多任务实现任务调度功能。的更多相关文章

  1. spring boot实现ssm&lpar;2&rpar;功能

    spring 和 mybatis 整合的那篇: ssm(2) . 配置文件比ssm(1) 更多, 在做项目的时候, 配置文件是一个让人头大的事情. 那么在spring boot中, 实现相同功能, 需 ...

  2. Spring框架的IOC核心功能快速入门

    2. 步骤一:下载Spring框架的开发包 * 官网:http://spring.io/ * 下载地址:http://repo.springsource.org/libs-release-local/ ...

  3. Spring常用jar包的功能

    jar名称 描述 spring-framework.jar spring框架比较完整的功能,core+aop+ioc+transaction spring-core.jar 基本上的核心工具类,一些u ...

  4. Spring Security 3&period;1 中功能强大的加密工具 PasswordEncoder

    Spring Security 3.1 中功能强大的加密工具 PasswordEncoder 博客分类: security spring springsecurity  好吧,这种加密机制很复杂,还是 ...

  5. Spring是什么,Spring容器提供了那些功能,Spring的工作机制

    spring是什么 spring 是一个轻型的容器,是J2EE规范的轻量级实现,可以一站式开发,其中提供了,bean工厂,用以构造我们需要的Model ,spring 是非侵入式的,spring应用中 ...

  6. Spring注解方式实现任务调度

    原文:http://docs.spring.io/spring/docs/4.0.1.BUILD-SNAPSHOT/javadoc-api/ 注解类型:EnableScheduling @Target ...

  7. Spring注解方式实现任务调度【官方文档翻译】

    原文:http://docs.spring.io/spring/docs/4.0.1.BUILD-SNAPSHOT/javadoc-api/ 注解类型:EnableScheduling @Target ...

  8. 采用dom4j和反射模拟Spring框架的依赖注入功能

    Spring的依赖注入是指将对象的创建权交给Spring框架,将对象所依赖的属性注入进来的行为.在学习了dom4j后,其实也可以利用dom4j和反射做一个小Demo模拟Spring框架的这种功能.下面 ...

  9. Spring学习之Jar包功能介绍(转)

    spring.jar 是包含有完整发布模块的单个jar 包.但是不包括mock.jar, aspects.jar, spring-portlet.jar, and spring-hibernate2. ...

随机推荐

  1. jQuery-DataTables相关的网址

    DataTables 有没有觉得这张图的数据很熟悉,对,他们都是copy来的. 之前用了一个bootstrap的框架,写那个框架的老师,有点抠门,把很多js都合在了一起,不知道怎么去自定义自己的东西, ...

  2. 阴影:box-shaw

    box-shaw:0px 0px 2px 3px while; 水平方向  垂直方向  模糊半径  模糊系数(大小)颜色

  3. 【云计算】Docker删除名称为none的Image镜像

    先上删除命令: docker images|grep none|awk '{print $3 }'|xargs docker rmi docker强制批量删除none的image镜像   真是有段时间 ...

  4. TFS和VSS的简单对比

    概念: TFS:Team Foundation Server(通常记作“TFS”) 是一种为 Microsoft 产品提供 源代码管理. 数据收集. 报告和项目跟踪,而为协作 软件开发 的项目. 可作 ...

  5. CollectionFramework

  6. solr可用于集群的搜索 【转】

    一. SOLR搭建企业搜索平台 运行环境: 运行容器:Tomcat6.0.20 Solr版本:apache-solr-1.4.0 分词器:mmseg4j-1.6.2  词库:sogou-dic 准备工 ...

  7. mysql 5&period;7&period;19 安装

    下载 官方下载地址,要注意的是要下载的是 MySQL Community Server.根据系统选择相应压缩包,这个是 win 下安装.选择 Zip Archive 安装 将下载好的压缩包解压到想要安 ...

  8. pytorch之张量的理解

    张量==容器 张量是现代机器学习的基础,他的核心是一个容器,多数情况下,它包含数字,因此可以将它看成一个数字的水桶. 张量有很多中形式,首先让我们来看最基本的形式.从0维到5维的形式 0维张量/标量: ...

  9. HW2017笔试编程题

    一.写一个转换字符串的函数 1.题目描述 将输入字符串中下标为偶数的字符连成一个新的字符串输出,需要注意两点: (1)如果输入字符串的长度超过20,则转换失败,返回“ERROR!”字符串: (2)输入 ...

  10. 利用VMware虚拟机安装CentOS7

    CentOS7镜像下载:http://isoredirect.centos.org/centos/7/isos/x86_64/CentOS-7-x86_64-DVD-1804.iso VMware虚拟 ...