定时任务报错 "RequestContext"不存在

haodoyoudo78950 · 发表于 2014-11-18 10:04:41

在执行定时任务，走断点发现总是在执行SQL语句的时候报错。

2014-11-18 10:02:31 Job jGroup2.jDay2_1 threw an unhandled Exception:
com.justep.exception.BusinessException: 编码: JUSTEP150109; 提示: "RequestContext"不存在
at com.justep.exception.BusinessException.create(Unknown Source)
at com.justep.util.Utils.checkNotExist(Unknown Source)
at com.justep.model.ModelUtils.getRequestContext(Unknown Source)
at com.justep.model.ModelUtils.getRootModel(Unknown Source)
at com.justep.model.impl.ModelImpl.getModel(Unknown Source)
at com.justep.model.impl.ModelImpl.getModel(Unknown Source)
at com.justep.model.impl.UtilImplementInstance.getModel(Unknown Source)
at com.justep.model.ModelUtils.getModel(Unknown Source)
at com.justep.system.data.SQL.select(Unknown Source)
at com.bjinfotech.wzjc.util.DicUtil.getTabNumberByTabTypeId(DicUtil.java:28)
at com.pushdata.quartz.ReportOfTendayJob.execute(ReportOfTendayJob.java:38)
at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
2014-11-18 10:02:31 Job (jGroup2.jDay2_1 threw an exception.
org.quartz.SchedulerException: Job threw an unhandled exception. [See nested exception: com.justep.exception.BusinessException: 编码: JUSTEP150109; 提示: "RequestContext"不存在]
at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
Caused by: com.justep.exception.BusinessException: 编码: JUSTEP150109; 提示: "RequestContext"不存在
at com.justep.exception.BusinessException.create(Unknown Source)
at com.justep.util.Utils.checkNotExist(Unknown Source)
at com.justep.model.ModelUtils.getRequestContext(Unknown Source)
at com.justep.model.ModelUtils.getRootModel(Unknown Source)
at com.justep.model.impl.ModelImpl.getModel(Unknown Source)
at com.justep.model.impl.ModelImpl.getModel(Unknown Source)
at com.justep.model.impl.UtilImplementInstance.getModel(Unknown Source)
at com.justep.model.ModelUtils.getModel(Unknown Source)
at com.justep.system.data.SQL.select(Unknown Source)
at com.bjinfotech.wzjc.util.DicUtil.getTabNumberByTabTypeId(DicUtil.java:28)
at com.pushdata.quartz.ReportOfTendayJob.execute(ReportOfTendayJob.java:38)
at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
... 1 more

wangliang · 发表于 2014-11-18 10:11:22

代码怎么写的？

haodoyoudo78950 · 发表于 2014-11-18 10:19:37

wangliang 发表于 2014-11-18 10:11
代码怎么写的？

package com.pushdata.quartz;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.bjinfotech.wzjc.check.CalcUtil;
import com.bjinfotech.wzjc.util.CommonUtil;
import com.bjinfotech.wzjc.util.DicUtil;
import com.bjinfotech.wzjc.util.TabTypeUtil;
import com.justep.system.data.KSQL;
import com.justep.system.data.Row;
import com.justep.system.data.SQL;
import com.justep.system.data.Table;
import com.justep.system.util.CommonUtils;
public class ReportOfDayJob implements Job {
private static Logger log = Logger.getLogger(ReportOfDayJob.class);
public void execute(JobExecutionContext context) throws JobExecutionException {
Map<String, Object> varMap = new HashMap<String, Object>(); //更新参数
CommonUtil util = new CommonUtil();
String[]tabId = util.getString("job_day_report").split(","); //获取日报报表号
String[]tabNumber = new String[tabId.length];
int index = 0;
for (String string : tabId) {
if(index == tabNumber.length){
break;
}
tabNumber[index] = DicUtil.getTabNumberByTabTypeId(Integer.parseInt(string)).toString();
index ++;
}
List<String> param = new ArrayList<String>();
String procName = "";
param.add("0");
for (int i = 0; i < tabNumber.length; i++) {
procName = "proc_" + tabNumber[i] + "GD" + "(?)"; //拼存储过程
log.info("[" + CommonUtils.getCurrentDate().toString().substring(0,10) + "] exec " + procName);
//除重
TabTypeUtil.fileManager(Integer.parseInt(tabId[i]));
//归档
CalcUtil.execProc(procName, null, param); //执行存储过程
//生成新报告期
varMap = new HashMap<String, Object>(); //更新参数
String ksqls = "update Tab_Type t1 set t1.Report_Interval=:currentDate where t1=:tab_type_id";
String currentDate = CommonUtils.getFirstDateOfMonth(CommonUtils.getCurrentDateTime()).toString();
String tab_type_id = util.getString(tabNumber[i]);
varMap.put("currentDate", currentDate);
varMap.put("tab_type_id", tab_type_id);
KSQL.executeUpdate(ksqls, varMap, "/wzjc/xzbb/data", null);
String filterDW = new CommonUtil().getString("fDW");
varMap = new HashMap<String, Object>();
//问题开始调用 DicUtil.getTabNumberByTabTypeId(tab_type_id);时报错未解决 java.lang.NoClassDefFoundError
varMap.put("tab_type_id", tab_type_id);
Object o = KSQL.select("select t1.Report_Period from Tab_Type t1 where t1=:tab_type_id", varMap, "/wzjc/common/data", null).iterator().next().getValue(0);
String tabType = o.toString();
//问题结束
String tab_time = DicUtil.getReportIntervalByTabTypeId(tab_type_id).toString().substring(0, 10);
Date curr_date = CommonUtils.toDate(tab_time);
Date firstDayOfDate = CommonUtils.getFirstDateOfMonth(curr_date);
List<String> ogns = new ArrayList<String>();
StringBuffer ksql = new StringBuffer("");
ksql.append(" select t1.Affiliation_ID as unit from tab_unit t1, tab_function_user t2 ");
ksql.append(" where t1.Tab_Type_ID=t2.Tab_Type_ID and t1.statu='1' and t2.statu='1' and t2.function_code='B01' and Affiliation_ID not in ("+filterDW+") and t1.Tab_Type_ID="+tab_type_id+" ");
varMap = new HashMap<String, Object>();
varMap.put("tab_type_id", tab_type_id);
Map<String, String> sql = new HashMap<String, String>();
sql.put("MSSQL", ksql.toString());
Table table = SQL.select(sql, null, "/wzjc/xzbb/data"); //KSQL.select(ksql.toString(), varMap, "/wzjc/xzbb/data", null);
for (Iterator<Row> iterator = table.iterator(); iterator.hasNext();) {
String unit = "" + iterator.next().getValue(0);
if(!ogns.contains(unit)){
ogns.add(unit);
}
}
ksql = new StringBuffer("");
ksql.append(" insert into Base_Tab_Affiliation_Stat t1 ");
ksql.append(" (t1, t1.Unit_Tab_ID, t1.Tab_Type_ID, t1.Affiliation_ID, t1.SYNC_ID, t1.Tab_time) ");
ksql.append(" values ( ");
ksql.append(" :nextSeq('Base_Tab_Affiliation_Stat'), :unit_tab_id, :tab_type_id, :af_unit_tab_id, :uuid, :curr_date ");
ksql.append(" ) ");
//进入日期循环
String query = "select t1.* from Base_Tab_Affiliation_Stat t1 where t1.Unit_Tab_ID=:unit_tab_id and t1.Tab_Type_ID=:tab_type_id and t1.Affiliation_ID = :af_unit_tab_id and t1.Tab_time=:curr_date";
if("日报".equals(tabType)){
int totalDay = CommonUtils.getDay(CommonUtils.getLastDateOfMonth(curr_date));
for (int dw = 0; dw < ogns.size(); dw++) {
for (int day = 1; day <= totalDay; day++) {
varMap = new HashMap<String, Object>();
varMap.put("unit_tab_id", ogns.get(dw).concat("_" + (day < 10 ? "0" : "") + day));
varMap.put("tab_type_id", tab_type_id);
varMap.put("af_unit_tab_id", ogns.get(dw));
varMap.put("uuid", CommonUtils.createGUID());
varMap.put("curr_date", CommonUtils.addDays(firstDayOfDate, (day - 1)));
Table tab = KSQL.select(query, varMap, "/wzjc/sjtb/data", null);
if(tab.size()>0){
System.out.println("["+ogns.get(dw).concat("_" + (day < 10 ? "0" : "") + day)+"]["+CommonUtils.addDays(firstDayOfDate, (day - 1))+"][had]已有记录,无需再次添加");
}else{
KSQL.executeUpdate(ksql.toString(), varMap, "/wzjc/sjtb/data", null);
}
}
}
}else if("旬报".equals(tabType)){
for (int dw = 0; dw < ogns.size(); dw++) {
for (int tenday = 1; tenday <= 3; tenday++) {
varMap = new HashMap<String, Object>();
varMap.put("unit_tab_id", ogns.get(dw).concat("_0" + tenday));
varMap.put("tab_type_id", tab_type_id);
varMap.put("af_unit_tab_id", ogns.get(dw));
varMap.put("uuid", CommonUtils.createGUID());
varMap.put("curr_date", CommonUtils.addDays(firstDayOfDate, (tenday - 1) * 10));
Table tab = KSQL.select(query, varMap, "/wzjc/sjtb/data", null);
if(tab.size()>0){
System.out.println("["+ogns.get(dw).concat("_0" + tenday)+"]["+CommonUtils.addDays(firstDayOfDate, (tenday - 1) * 10)+"][had]已有记录,无需再次添加");
}else{
KSQL.executeUpdate(ksql.toString(), varMap, "/wzjc/sjtb/data", null);
}
}
}
}else{
for (int dw = 0; dw < ogns.size(); dw++) {
varMap = new HashMap<String, Object>();
varMap.put("unit_tab_id", ogns.get(dw));
varMap.put("tab_type_id", tab_type_id);
varMap.put("af_unit_tab_id", ogns.get(dw));
varMap.put("uuid", CommonUtils.createGUID());
varMap.put("curr_date", firstDayOfDate);
Table tab = KSQL.select(query, varMap, "/wzjc/sjtb/data", null);
if(tab.size()>0){
System.out.println("["+ogns.get(dw)+"]["+firstDayOfDate+"][had]已有记录,无需再次添加");
}else{
KSQL.executeUpdate(ksql.toString(), varMap, "/wzjc/sjtb/data", null);
}
}
}
}
}
}

复制代码

haodoyoudo78950 · 发表于 2014-11-18 10:20:43

package com.pushdata.quartz;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import org.quartz.CronExpression;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;
public class TriggerRunner {
public static void main(String[] args) {
//SimpleTrigger调度案例
// SimpleTrigger();
//CronTrigger调度案例
// CronTrigger4();
// CommonUtil util = new CommonUtil();
//
// System.out.println(util.getString("job_day_exp"));
StringBuffer kh = new StringBuffer("");
List<String> param = new ArrayList<String>();
param.add("0");
if(param!=null){
kh.append("(");
for (int i = 0, size = param.size(); i < size; i++) {
if(i!=0)
kh.append(",");
kh.append("?");
}
kh.append(")");
}
System.out.println(kh.toString()
);
}
/**
* SimpleTrigger调度案例
*/
public static void SimpleTrigger(String jobName, String jobGroup, Class<?> job, String triggerName, String triggerGroup, Date runDate, int second, int times){
try {
//①创建一个JobDetail实例，指定SimpleJob
JobDetail jobDetail = new JobDetail(jobName, jobGroup, job);
//②通过SimpleTrigger定义调度规则：马上启动，每2秒运行一次，共运行100次
SimpleTrigger simpleTrigger = new SimpleTrigger(triggerName, triggerGroup);
simpleTrigger.setStartTime(runDate); //执行时间
simpleTrigger.setRepeatInterval(second*1000); //多少秒执行一次
simpleTrigger.setRepeatCount(times); //执行多少次
//③通过SchedulerFactory获取一个调度器实例
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//④ 注册并进行调度
scheduler.scheduleJob(jobDetail, simpleTrigger);
//⑤调度启动
scheduler.start();
} catch (SchedulerException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* CronTrigger调度案例
*/
public static void CronTrigger(String jobName, String jobGroup, Class<?> job, String exp, String triggerName, String triggerGroup){
try {
JobDetail jobDetail = new JobDetail(jobName, jobGroup, job);
//①-1：创建CronTrigger，指定组及名称
CronTrigger cronTrigger = new CronTrigger(triggerName, triggerGroup);
//①-2：定义Cron表达式
CronExpression cexp = new CronExpression(exp);
//①-3：设置Cron表达式
cronTrigger.setCronExpression(cexp);
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
scheduler.scheduleJob(jobDetail, cronTrigger);
scheduler.start();
} catch (Exception e) {
e.printStackTrace();
}
}
}

复制代码

haodoyoudo78950 · 发表于 2014-11-18 10:21:12

package com.pushdata.quartz;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import org.apache.log4j.Logger;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.impl.StdSchedulerFactory;
import com.bjinfotech.wzjc.util.CommonUtil;
/**
* Quartz计划任务工具类(集成X5)
* @date 2014.10.27
* @author wei
*/
public class QuartzUtil extends HttpServlet {
/**
*
*/
private static final long serialVersionUID = -378478106008819308L;
private static Logger log = Logger.getLogger(QuartzUtil.class);
private static CommonUtil util = new CommonUtil();
/**
* 加载计划任务列表
* 启动计划任务
*/
public void init() throws ServletException{
try {
log.info("--------------------启动计划任务--------------------");
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
jh_1();
jh_2();
jh_3();
scheduler.start();
log.info("启动计划任务成功！");
} catch (SchedulerException e) {
log.error("启动计划任务发生异常！",e);
}
}
/**
* 将计划从Scheduler中删除
* @param jobName 即task_id
* @throws Exception
*/
public void removeFromScheduler(String jhrwId) throws Exception{
try {
log.info("检索计划任务是否已存在...");
if(jhrwId!=null ){
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
if(scheduler.getJobDetail(jhrwId, null)!=null){
if(scheduler.getTrigger(jhrwId, null)!=null ){
scheduler.pauseTrigger(jhrwId, null);
log.info("删除Trigger完成！");
}
scheduler.unscheduleJob(jhrwId, null);
scheduler.deleteJob(jhrwId, null);
log.info("删除计划任务完成！");
}else{
log.info("未检索到计划任务！任务id："+jhrwId);
}
}else{
log.info("未检索到计划任务！任务id："+jhrwId);
}
} catch (Throwable e) {
throw new Exception("从Scheduler中删除计划异常",e);
}
}
public void jh_1(){
//日报
String jobName = "jDay1_1";
String jobGroup = "jGroup1";
Class<?> job = ReportOfDayJob.class;
String exp = util.getString("job_day_exp");
String triggerName = "tDay1_1";
String triggerGroup = "tGroup1";
TriggerRunner.CronTrigger(jobName, jobGroup, job, exp, triggerName, triggerGroup);
}
public void jh_2(){
//旬报
String jobName = "jDay2_1";
String jobGroup = "jGroup2";
Class<?> job = ReportOfTendayJob.class;
String exp = util.getString("job_tenday_exp");
String triggerName = "tDay2_1";
String triggerGroup = "tGroup2";
TriggerRunner.CronTrigger(jobName, jobGroup, job, exp, triggerName, triggerGroup);
}
public void jh_3(){
//月报
String jobName = "jDay3_1";
String jobGroup = "jGroup3";
Class<?> job = ReportOfMonthJob.class;
String exp = util.getString("job_month_exp");
String triggerName = "tDay3_1";
String triggerGroup = "tGroup3";
TriggerRunner.CronTrigger(jobName, jobGroup, job, exp, triggerName, triggerGroup);
}
}

复制代码

cyteamo · 发表于 2014-11-18 10:23:35

haodoyoudo78950 发表于 2014-11-18 10:21

...执行到哪个地方报错? 哪条SQL?

haodoyoudo78950 · 发表于 2014-11-18 10:38:31

cyteamo 发表于 2014-11-18 10:23
...执行到哪个地方报错? 哪条SQL?

ReportOfDayJob 的 DicUtil.getTabNumberByTabTypeId(Integer.parseInt(string)).toString();执行后报错

public static Object getTabNumberByTabTypeId(int tab_type_id){
Map<String, Object> varMap = new HashMap<String, Object>();
varMap.put("tab_type_id", tab_type_id);
return KSQL.select("select t1.Tab_Number from Tab_Type t1 where t1=:tab_type_id", varMap, "/wzjc/common/data", null).iterator().next().getValue(0);
}

复制代码

走return后就进入JobRunShell.run，然后就报错

jishuang · 发表于 2014-11-18 10:44:54

定时调用可以参考http://bbs.justep.com/thread-40485-1-1.html

haodoyoudo78950 · 发表于 2014-11-18 10:52:00

似乎只要调用方法就会报这个错误。

haodoyoudo78950 · 发表于 2014-11-18 11:01:47

jishuang 发表于 2014-11-18 10:44
定时调用可以参考http://bbs.justep.com/thread-40485-1-1.html

定时任务只能用这种方法吗？

		自动登录	找回密码
密码			注册

[结贴] 定时任务报错 "RequestContext"不存在