Browse Source

任务终止fix

xueli.xue 9 years ago
parent
commit
7c0aaea0b6

+ 7 - 1
xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java View File

18
 
18
 
19
 import com.xxl.job.admin.core.constant.Constants.JobGroupEnum;
19
 import com.xxl.job.admin.core.constant.Constants.JobGroupEnum;
20
 import com.xxl.job.admin.core.model.ReturnT;
20
 import com.xxl.job.admin.core.model.ReturnT;
21
+import com.xxl.job.admin.core.model.XxlJobInfo;
21
 import com.xxl.job.admin.core.model.XxlJobLog;
22
 import com.xxl.job.admin.core.model.XxlJobLog;
23
+import com.xxl.job.admin.dao.IXxlJobInfoDao;
22
 import com.xxl.job.admin.dao.IXxlJobLogDao;
24
 import com.xxl.job.admin.dao.IXxlJobLogDao;
23
 import com.xxl.job.core.handler.HandlerRepository.ActionEnum;
25
 import com.xxl.job.core.handler.HandlerRepository.ActionEnum;
24
 import com.xxl.job.core.handler.HandlerRepository.HandlerParamEnum;
26
 import com.xxl.job.core.handler.HandlerRepository.HandlerParamEnum;
35
 
37
 
36
 	@Resource
38
 	@Resource
37
 	public IXxlJobLogDao xxlJobLogDao;
39
 	public IXxlJobLogDao xxlJobLogDao;
40
+	@Resource
41
+	public IXxlJobInfoDao xxlJobInfoDao;
38
 	
42
 	
39
 	@RequestMapping
43
 	@RequestMapping
40
 	public String index(Model model, String jobGroup, String jobName) {
44
 	public String index(Model model, String jobGroup, String jobName) {
132
 	public ReturnT<String> logKill(int id){
136
 	public ReturnT<String> logKill(int id){
133
 		// base check
137
 		// base check
134
 		XxlJobLog log = xxlJobLogDao.load(id);
138
 		XxlJobLog log = xxlJobLogDao.load(id);
135
-		if (log == null) {
139
+		XxlJobInfo jobInfo = xxlJobInfoDao.load(log.getJobGroup(), log.getJobName());
140
+		if (log == null || jobInfo==null) {
136
 			return new ReturnT<String>(500, "参数异常");
141
 			return new ReturnT<String>(500, "参数异常");
137
 		}
142
 		}
138
 		if (!RemoteCallBack.SUCCESS.equals(log.getTriggerStatus())) {
143
 		if (!RemoteCallBack.SUCCESS.equals(log.getTriggerStatus())) {
143
 		Map<String, String> reqMap = new HashMap<String, String>();
148
 		Map<String, String> reqMap = new HashMap<String, String>();
144
 		reqMap.put(HandlerParamEnum.TIMESTAMP.name(), String.valueOf(System.currentTimeMillis()));
149
 		reqMap.put(HandlerParamEnum.TIMESTAMP.name(), String.valueOf(System.currentTimeMillis()));
145
 		reqMap.put(HandlerParamEnum.ACTION.name(), ActionEnum.KILL.name());
150
 		reqMap.put(HandlerParamEnum.ACTION.name(), ActionEnum.KILL.name());
151
+		reqMap.put(HandlerParamEnum.GLUE_SWITCH.name(), String.valueOf(jobInfo.getGlueSwitch()));
146
 		reqMap.put(HandlerParamEnum.EXECUTOR_HANDLER.name(), log.getExecutorHandler());
152
 		reqMap.put(HandlerParamEnum.EXECUTOR_HANDLER.name(), log.getExecutorHandler());
147
 		reqMap.put(HandlerParamEnum.JOB_GROUP.name(), log.getJobGroup());
153
 		reqMap.put(HandlerParamEnum.JOB_GROUP.name(), log.getJobGroup());
148
 		reqMap.put(HandlerParamEnum.JOB_NAME.name(), log.getJobName());
154
 		reqMap.put(HandlerParamEnum.JOB_NAME.name(), log.getJobName());