2. 程式人生 > >mybatis spring 定時器

mybatis spring 定時器

阿新 • • 發佈：2018-11-17

1、pom.xml 配置

2、加入jar

 

3、Java 程式碼書寫

4、載入項配置

5、方法體書寫

package com.dossp.ods.common.task;

import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

import com.dossp.ods.common.util.ConfUtil;

public class QuartzUtil {
    public static SchedulerFactory schedFact = new StdSchedulerFactory();
    public static Scheduler sched;    
    public static final String GROUP = "time_work";    
    public static void startSched() throws SchedulerException {        
        try {            
            QuartzUtil.sched = QuartzUtil.schedFact.getScheduler();            
            QuartzUtil.sched.start();        
            } catch (Exception e) {    
                e.printStackTrace();        
                }    
        }
    //出口申請待公示是否超出公示時間
    public static boolean quartzAdd(String taskId) throws Exception {
        try {            
            // 若sched未賦值或者未啟動，則先在全域性中啟動它            
            if (QuartzUtil.sched == null || !QuartzUtil.sched.isStarted()) {
                QuartzUtil.startSched();            
                }            
            // 定時規則,跟普通crontable的差不多            
            String rule = "0 0 " + ConfUtil.getProperty("FREQUENCY") + " * * ?";            
            // 設定組名，和任務名            
            String quartz_name = taskId;            
            String quartz_group = GROUP;            
            // 建立jobDetail例項，指定job名以及所屬組            
            JobDetail jobDetail = JobBuilder.newJob(TasktJob.class).withIdentity(quartz_name, quartz_group).build();            
            jobDetail.getJobDataMap().put("taskId", taskId);            
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity(quartz_name, quartz_group).withSchedule(CronScheduleBuilder.cronSchedule(rule)).startNow().build();            
            QuartzUtil.sched.scheduleJob(jobDetail, trigger);            
            QuartzUtil.sched.start();            
            Thread.sleep(1000);            
            return true;        
            } catch (Exception e) {            
                System.out.println("[新增定時任務出錯,任務號:" + taskId + "]");        
                e.printStackTrace();            
                return false;        
                }    
        }
    //進口申請待公示是否超出公示時間
    public static boolean quartiAdd(String taskId) throws Exception {
        try {            
            // 若sched未賦值或者未啟動，則先在全域性中啟動它            
            if (QuartzUtil.sched == null || !QuartzUtil.sched.isStarted()) {
                QuartzUtil.startSched();            
                }            
            // 定時規則,跟普通crontable的差不多            
            String rule = "0 0 " + ConfUtil.getProperty("FREQUENCY") + " * * ?";        
            // 設定組名，和任務名            
            String quartz_name = taskId;            
            String quartz_group = GROUP;            
            // 建立jobDetail例項，指定job名以及所屬組            
            JobDetail jobDetail = JobBuilder.newJob(TaskcJob.class).withIdentity(quartz_name, quartz_group).build();            
            jobDetail.getJobDataMap().put("taskId", taskId);            
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity(quartz_name, quartz_group).withSchedule(CronScheduleBuilder.cronSchedule(rule)).startNow().build();            
            QuartzUtil.sched.scheduleJob(jobDetail, trigger);            
            QuartzUtil.sched.start();            
            Thread.sleep(1000);            
            return true;        
            } catch (Exception e) {            
                System.out.println("[新增定時任務出錯,任務號:" + taskId + "]");        
                e.printStackTrace();            
                return false;        
                }    
        }
    //出口申請預計出口時間是否過期
    public static boolean quartkAdd(String taskId) throws Exception {
        try {            
            // 若sched未賦值或者未啟動，則先在全域性中啟動它            
            if (QuartzUtil.sched == null || !QuartzUtil.sched.isStarted()) {
                QuartzUtil.startSched();            
                }            
            // 定時規則,跟普通crontable的差不多            
            String rule = "0 0 " + ConfUtil.getProperty("FREQUENCY") + " * * ?";        
            // 設定組名，和任務名            
            String quartz_name = taskId;            
            String quartz_group = GROUP;            
            // 建立jobDetail例項，指定job名以及所屬組            
            JobDetail jobDetail = JobBuilder.newJob(TaskkJob.class).withIdentity(quartz_name, quartz_group).build();            
            jobDetail.getJobDataMap().put("taskId", taskId);            
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity(quartz_name, quartz_group).withSchedule(CronScheduleBuilder.cronSchedule(rule)).startNow().build();            
            QuartzUtil.sched.scheduleJob(jobDetail, trigger);            
            QuartzUtil.sched.start();            
            Thread.sleep(1000);            
            return true;        
            } catch (Exception e) {            
                System.out.println("[新增定時任務出錯,任務號:" + taskId + "]");        
                e.printStackTrace();            
                return false;        
                }    
        }
    //進口申請預計出口時間是否過期
    public static boolean quartjAdd(String taskId) throws Exception {
        try {            
            // 若sched未賦值或者未啟動，則先在全域性中啟動它            
            if (QuartzUtil.sched == null || !QuartzUtil.sched.isStarted()) {
                QuartzUtil.startSched();            
                }            
            // 定時規則,跟普通crontable的差不多            
            String rule = "0 0 " + ConfUtil.getProperty("FREQUENCY") + " * * ?";        
            // 設定組名，和任務名            
            String quartz_name = taskId;            
            String quartz_group = GROUP;            
            // 建立jobDetail例項，指定job名以及所屬組            
            JobDetail jobDetail = JobBuilder.newJob(TaskjJob.class).withIdentity(quartz_name, quartz_group).build();            
            jobDetail.getJobDataMap().put("taskId", taskId);            
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity(quartz_name, quartz_group).withSchedule(CronScheduleBuilder.cronSchedule(rule)).startNow().build();            
            QuartzUtil.sched.scheduleJob(jobDetail, trigger);            
            QuartzUtil.sched.start();            
            Thread.sleep(1000);            
            return true;        
            } catch (Exception e) {            
                System.out.println("[新增定時任務出錯,任務號:" + taskId + "]");        
                e.printStackTrace();            
                return false;        
                }    
        }
}

 

6、具體實現

package com.dossp.ods.common.task;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class TaskjJob  implements Job {
    public static InitData initData = new InitData();
    public static TaskkI taskkI = new TaskkI();
    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        taskkI.queryI();
    }
}
 

7、執行程式碼

package com.dossp.ods.common.task;

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

import com.dossp.ods.report.model.ImportApply;
import com.dossp.ods.workflow.dao.ApplyFlowDao;

public class TaskkI {
    private static final ApplyFlowDao applyFlowDao = new ApplyFlowDao();
    private static final String state = "'2'";
    SimpleDateFormat sdf2 = new SimpleDateFormat("EEE MMM dd HH:mm:ss z yyyy", Locale.ENGLISH);
    SimpleDateFormat sdf3 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    public void queryI() {
        try {
            List<ImportApply> listI = applyFlowDao.getAllImportTaskS(state);
            if (listI != null && listI.size() > 0) {
                for (int i = 0; i < listI.size(); i++) {
                    String impPortTime=listI.get(i).getImportTime();
                    String endTime = sdf3.format(sdf2.parse(new Date().toString()));
                    long ant=this.getDaySub(impPortTime, endTime);
                    if(ant<=0){
                        int result = applyFlowDao.updatePortTimeState(listI.get(i).getAppNo(),"I");
                        if(result>0){
                             System.out.println("---待初審申請預計進口時間已過，申請已退回企業"); 
                         }else{
                             System.out.println("---狀態表更新失敗！--");
                         }
                    }else{
                         System.out.println("---沒有超出時間的資料！--");
                    }
                }
            }
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    public  long getDaySub(String firstTime, String endDateStr) throws ParseException {
        long day = 0;
        java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("yyyyMMdd");
        java.util.Date beginDate;
        java.util.Date endDate;
        beginDate = format.parse(firstTime);
        endDate = format.parse(endDateStr);
        day = (endDate.getTime() - beginDate.getTime()) / (24 * 60 * 60 * 1000);
        return day;
    }
}

 

相關推薦

mybatis spring 定時器

1、pom.xml 配置 2、加入jar   3、Java 程式碼書寫 4、載入項配置 5、方法體書寫 package com.dossp.ods.common.task; import org.quartz.CronScheduleBuild

Spring定時器註解配置

springmvc imp blog oca -c ann type conf utf-8 spring-task.xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.s

spring定時器時間設置規則

ref 結束 第一個 可選 -h quartz days 只需要 數值 單純針對時間的設置規則org.springframework.scheduling.quartz.CronTriggerBean允許你更精確地控制任務的運行時間，只需要設置其cronExpression

自定義spring定時器

() spl public == integer service upd imei second package com.wjz.quartz; import java.util.concurrent.Executors; public class QuartzDem

java定時器無法自動註入的問題解析(原來Spring定時器可以這樣註入service)

nco 方法註入 數據庫的操作 div end pub spring定時器 ext 發現 近些日子在做一個項目，在項目中需要用到spring的定時任務，但是在操作數據庫的時候發現總是不能正確的進行數據的插入，經過查看才發現：是因為service層不能夠通過普通的方法註入到a

Spring 定時器schedule實現

執行 掃描 clearing process obj after ice wait code 註解方式： 核心類摘要： 1.ScheduledAnnotationBeanPostProcessor 2.ScheduledTaskRegistrar 3.TaskSchedul

一篇文章搞定你的spring定時器

Cron表示式是一個字串，字串以5或6個空格隔開，分開工6或7個域，每一個域代表一個含義,Cron有如下兩種語法 格式： Seconds Minutes Hours DayofMonth Month DayofWeek Year 或 Seconds Minutes Hours DayofMo

Spring定時器-註解

1、配置applicationContent.xml 加入 xmlns:task="http://www.springframework.org/schema/task"  xsi:schemaLocation中新增     &nb

spring定時器使用註解@Scheduled執行任務，fixedDelay、fixedRate和cron區別

 註解@Scheduled 可以作為一個觸發源新增到一個方法中，例如，以下的方法將以一個固定延遲時間5秒鐘呼叫一次執行，這個週期是以上一個呼叫任務的 完成時間 為基準，在上一個任務完成之後，5s後再次執行：

使用Spring 定時器 + selenium打卡

使用Spring 定時器 + selenium操作頁面 **引入Spring 的配置，開啟定時任務器 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframewor

java定時器、Spring定時器和Quartz定時器

   當前java程式中能夠實現定時的主要有三種方式，分別是：java定時器，spring定時器，quartz定時器。    下面依次講講他們的應用！ java定時器的應用    其實java很早就有解決定時器任務的方法了，ja

spring定時器task為什麼在伺服器上會執行2次

spring定時器task為什麼在伺服器上會執行2次 在本地idea執行專案時spring定時器只運行了一次,通過多次測試沒問題後我就把專案部署到伺服器上面,結果在伺服器上spring定時器竟然運行了2次,這我就想不明白了.我肯定程式碼和配置是沒有問題的,想了想難道是伺

spring定時器及時間寫法

1．秒（0–59） 2．分鐘（0–59） 3．小時（0–23） 4．月份中的日期（1–31） 5．月份（1–12或JAN–DEC） 6．星期中的日期（1–7或SUN–SAT） 7．年份（1970–2099） 秒 0-59 , - * /

Atitit spring 定時器 CRON表示式 含義 目錄 1.1. 大概流程 1 1.2. 核心原始碼springboot 1 1.3. Cron表示式屬性——String 2 1.4

Atitit spring 定時器 CRON表示式    含義      目錄 1.1. 大概流程 1 1.2. 核心原始碼springboot 1 1.3. Cron表示式屬性——String 2 1.4. cron表示

Atitit 定時器timer 總結 目錄 1. 定時器 迴圈定時器 和timeout超時定時器 1 2. Spring定時器 1 2.1. 大概流程 1 2.2. 核心原始碼springboot 1

Atitit 定時器timer 總結   目錄 1. 定時器 迴圈定時器 和timeout超時定時器 1 2. Spring定時器 1 2.1. 大概流程 1 2.2. 核心原始碼springboot 1 3. Js定時器 window.setInte

spring定時器運用

前言：spring 提供了相當強大的定時器功能使用也很簡單 接下來使用的是quartz2的程式碼（quartz1.x和quartz2.x配置不相同，主要使用的類不一樣） 配置程式碼： <?xml version="1.0" encoding="UTF-8"?> &

spring定時器--quartz開發配置時間引數說明

一個cron表示式有至少6個（也可能7個）有空格分隔的時間元素。 按順序依次為 1.秒（0~59） 2.分鐘（0~59） 3.小時（0~23）  4.天（月）（0~31，但是你需要考慮你月的天數） 5.月（0~11） 6.天（星期）（1~7 1=SUN 或 SUN，MON，TUE，WE

【Spring 定時器】定時器 No qualifying bean of type [org.springframework.scheduling.TaskScheduler] is defined

stackoverflow 版 http://stackoverflow.com/questions/31199888/spring-task-scheduler-no-qualifying-bean-of-type-org-springframework-sche

【Spring 定時器】Spring 定時器 No qualifying bean of type [org.springframework.scheduling.TaskScheduler]

Spring 定時器 No qualifying bean of type [org.springframework.scheduling.TaskScheduler] is defined 最近專案裡面，用了spring的定時任務，一直以來，專案執行的不錯。定時器

spring定時器的使用——schedule

applicationContext-schedule.xml配置： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/sch