Java 定时任务详解数据库

 Date nowDate = new Date(); 
          SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
           
          String jobName = lwhbh + "_" + jydm + "_" + jybs + "_"+ cldm + "_bz"; 
           
           
          if ((openTime != null) && (!openTime.equals(""))){ 
              openTime = openTime.trim(); 
              TaskManage task = new TaskManage(BcpJyctrlTask.class); 
              task.addTask(this.datasource, openTime, jobName + "_" + openTime, "bcpJyctrl", null); 
               
              YwBcpJyctrlTime jyct = new YwBcpJyctrlTime(); 
              jyct.setLwhbh(lwhbh); 
              jyct.setJydm(jydm); 
              jyct.setJybs(jybs); 
              jyct.setCldm(cldm); 
              jyct.setYwlx(ywlx); 
              jyct.setJymc(jymc); 
              jyct.setGxrq(gxrq); 
              jyct.setKtbz("1");// 1-开通 
              jyct.setSdsj(df.format(nowDate)); 
              jyct.setYxsj(openTime); 
              jyct.setYxzt("0");// 0-待执行 
               
              saveObj(jyct); 
          }

import hs.util.HsException; 
import java.text.ParseException; 
import java.text.SimpleDateFormat; 
import java.util.Date; 
import java.util.Set; 
import org.quartz.CronScheduleBuilder; 
import org.quartz.CronTrigger; 
import org.quartz.JobBuilder; 
import org.quartz.JobDataMap; 
import org.quartz.JobDetail; 
import org.quartz.JobKey; 
import org.quartz.Scheduler; 
import org.quartz.SchedulerException; 
import org.quartz.SchedulerFactory; 
import org.quartz.TriggerBuilder; 
import org.quartz.impl.matchers.GroupMatcher; 
public class TaskManage { 
private Class taskClass; 
public static final String DATEFORMAT = "yyyy-MM-dd HH:mm:ss"; 
public static final int WAITTIME = 10; 
public TaskManage(Class taskClass) { 
this.taskClass = taskClass; 
} 
private Scheduler getScheduler() throws SchedulerException { 
return SchedulerManage.getSchedulerFactory().getScheduler(); 
} 
public void addJob(String jobName, String groupName, String cronSchedule, Object obj, String datasource) throws SchedulerException { 
JobDetail jobDetail = JobBuilder.newJob(this.taskClass).withIdentity("job-" + jobName, "job-" + groupName).build(); 
CronTrigger cronTrigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity("tri-" + jobName, "tri-" + groupName) 
.withSchedule(CronScheduleBuilder.cronSchedule(cronSchedule)).build(); 
jobDetail.getJobDataMap().put("obj", obj); 
jobDetail.getJobDataMap().put("datasource", datasource); 
getScheduler().scheduleJob(jobDetail, cronTrigger); 
} 
public void deleteTask(String jobName, String groupName) throws SchedulerException { 
getScheduler().deleteJob(new JobKey("job-" + jobName, "job-" + groupName)); 
} 
public boolean judgeIsTaskLive(String jobName, String groupName) throws SchedulerException { 
return getScheduler().checkExists(new JobKey("job-" + jobName, "job-" + groupName)); 
} 
public void addTask(String datasource, String taskTime, String jobName, String groupName, Object obj) throws HsException { 
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
try { 
Date nowDate = new Date(); 
if ((taskTime != null) && (!taskTime.equals(""))) { 
Date openDate = df.parse(taskTime); 
if (openDate.getTime() < nowDate.getTime() + 10L) { 
throw new HsException("", "设定的定时时间小于或等于当前系统时间，请重新设定！"); 
} 
if (judgeIsTaskLive(jobName, groupName)) { 
deleteTask(jobName, groupName); 
} 
StringBuffer cronSchedule = new StringBuffer(); 
cronSchedule.append(taskTime.substring(17)); 
cronSchedule.append(" "); 
cronSchedule.append(taskTime.substring(14, 16)); 
cronSchedule.append(" "); 
cronSchedule.append(taskTime.substring(11, 13)); 
cronSchedule.append(" "); 
cronSchedule.append(taskTime.substring(8, 10)); 
cronSchedule.append(" "); 
cronSchedule.append(taskTime.substring(5, 7)); 
cronSchedule.append(" "); 
cronSchedule.append("?"); 
cronSchedule.append(" "); 
cronSchedule.append(taskTime.substring(0, 4)); 
addJob(jobName, groupName, cronSchedule.toString(), obj, datasource); 
} 
} catch (ParseException e) { 
throw new HsException("", "设定定时时间格式错误！"); 
} catch (SchedulerException e) { 
e.printStackTrace(); 
throw new HsException("", "定时任务设定出错！"); 
} 
} 
public Set getJobNameByGroupName(String groupName) throws HsException { 
try { 
return getScheduler().getJobKeys(GroupMatcher.jobGroupEquals("job-" + groupName)); 
} catch (SchedulerException e) { 
throw new HsException("", "获取定时任务名称出错！/n" + e.getMessage()); 
} 
} 
}

import com.hundsun.log.HsLogger; 
import com.hundsun.tamc.base.BeanFactoryUtil; 
import com.hundsun.tamc.base.HibernateDaoBS; 
import java.io.PrintStream; 
import java.util.Date; 
import org.quartz.Job; 
import org.quartz.JobDataMap; 
import org.quartz.JobDetail; 
import org.quartz.JobExecutionContext; 
import org.quartz.JobExecutionException; 
public abstract class TaskJob implements Job { 
public static final String OBJ_NAME = "obj"; 
public static final String DATASOURCE_NAME = "datasource"; 
protected JobDataMap jobDataMap; 
protected HibernateDaoBS baseHibernate; 
public HibernateDaoBS getHibernateDaoBS(String datasource) { 
HibernateDaoBS baseHibernate = (HibernateDaoBS) BeanFactoryUtil.getBean(datasource, "hibernateBSProxy"); 
return baseHibernate; 
} 
public void execute(JobExecutionContext jobCtx) throws JobExecutionException { 
HsLogger.getInstance().writeInfo("【定时任务：开始】"); 
System.out.println("【定时任务：开始】" + new Date().toLocaleString()); 
HsLogger.getInstance().writeInfo(jobCtx.getJobDetail().getKey() + " triggered. time is:" + new Date()); 
this.jobDataMap = jobCtx.getJobDetail().getJobDataMap(); 
String datasource = (String) this.jobDataMap.get("datasource"); 
this.baseHibernate = getHibernateDaoBS(datasource); 
body(jobCtx); 
HsLogger.getInstance().writeInfo("【定时任务：结束】"); 
System.out.println("【定时任务：结束】" + new Date().toLocaleString()); 
} 
public abstract void body(JobExecutionContext paramJobExecutionContext) throws JobExecutionException; 
}

import com.hundsun.log.HsLogger; 
import com.hundsun.tamc.control.app.timetask.sys.TaskJob; 
import com.hundsun.tamc.hibernate.app.bcp.YwBcpJyctrlTime; 
import hs.util.HsException; 
import java.util.List; 
import org.quartz.JobExecutionContext; 
import org.quartz.JobExecutionException; 
public class BcpJyctrlTask extends TaskJob 
{ 
@SuppressWarnings("rawtypes") 
public void body(JobExecutionContext jobCtx) 
throws JobExecutionException 
{ 
String jobName = jobCtx.getJobDetail().getKey().getName(); 
String yxzt = "1"; 
String yxsj = ""; 
String lwhbh = ""; 
String jydm = ""; 
String jybs = ""; 
String cldm = ""; 
StringBuffer sqlTemp; 
try 
{ 
String[] ywbz = jobName.substring(4, jobName.length() - 20).split("_"); 
yxsj = jobName.substring(jobName.length() - 19); 
lwhbh = ywbz[0]; 
jydm = ywbz[1]; 
jybs = ywbz[2]; 
cldm = ywbz[3]; 
StringBuffer ywStr = new StringBuffer(); 
ywStr.append("from YwBcpJyctrlTime where yxzt='0' and jydm='"); 
ywStr.append(jydm); 
ywStr.append("' and lwhbh='"); 
ywStr.append(lwhbh); 
ywStr.append("' and jybs='"); 
ywStr.append(jybs); 
ywStr.append("' and cldm='"); 
ywStr.append(cldm); 
ywStr.append("' and yxsj='"); 
ywStr.append(yxsj); 
ywStr.append("'"); 
List list = this.baseHibernate.findObjs(ywStr.toString()); 
YwBcpJyctrlTime jyctrlTime; 
if ((list != null) && (list.size() > 0)){ 
jyctrlTime = (YwBcpJyctrlTime)list.get(0); 
}else{ 
throw new HsException("ERR_DEFAULT", "交易控制未找到可运行的定时任务！"); 
} 
StringBuffer sql = new StringBuffer("update YwBcpJyctrl set ktbz='"); 
sql.append(jyctrlTime.getKtbz()); 
sql.append("' where jydm='"); 
sql.append(jyctrlTime.getJydm()); 
sql.append("' and lwhbh='"); 
sql.append(jyctrlTime.getLwhbh()); 
sql.append("' and jybs='"); 
sql.append(jyctrlTime.getJybs()); 
sql.append("' and cldm='"); 
sql.append(jyctrlTime.getCldm()); 
sql.append("'"); 
this.baseHibernate.exeHQL(sql.toString()); 
}catch (HsException e) { 
e.printStackTrace(); 
yxzt = "3"; 
}catch (Exception e) 
{ 
e.printStackTrace(); 
yxzt = "3"; 
} 
finally 
{ 
sqlTemp = new StringBuffer(); 
sqlTemp.append("update YwBcpJyctrlTime set yxzt='" + yxzt + "' where yxzt='0' and jydm='"); 
sqlTemp.append(jydm); 
sqlTemp.append("' and lwhbh='"); 
sqlTemp.append(lwhbh); 
sqlTemp.append("' and jybs='"); 
sqlTemp.append(jybs); 
sqlTemp.append("' and cldm='"); 
sqlTemp.append(cldm); 
sqlTemp.append("' and yxsj='"); 
sqlTemp.append(yxsj); 
sqlTemp.append("'"); 
try { 
this.baseHibernate.exeHQL(sqlTemp.toString()); 
} catch (HsException e) { 
HsLogger.getInstance().writeInfo("交易控制定时任务更新出错!/n" + e.toString()); 
} 
} 
} 
}