From 7dfed8e62e3f2416f94ca57ab2e842696ab57863 Mon Sep 17 00:00:00 2001 From: "xueli.xue" Date: Tue, 12 Jan 2016 23:25:05 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E5=BA=A6=E4=BF=A1=E6=81=AF=E8=BF=81?= =?UTF-8?q?=E7=A7=BB=E8=87=B3DB=E4=B8=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/xxl/job/controller/JobController.java | 80 ++++++++++-- .../com/xxl/job/core/model/XxlJobInfo.java | 77 ++++++++++++ .../job/core/util/DynamicSchedulerUtil.java | 38 +++++- .../java/com/xxl/job/dao/IXxlJobInfoDao.java | 25 ++++ .../java/com/xxl/job/dao/IXxlJobLogDao.java | 4 + .../xxl/job/dao/impl/XxlJobInfoDaoImpl.java | 69 ++++++++++ .../xxl/job/dao/impl/XxlJobLogDaoImpl.java | 4 + .../com/xxl/job/service/job/HttpJobBean.java | 18 ++- .../resources/applicationcontext-database.xml | 2 +- .../mybatis-mapper/XxlJobInfoMapper.xml | 102 +++++++++++++++ .../mybatis-mapper}/XxlJobLogMapper.xml | 0 .../src/main/webapp/WEB-INF/template/help.ftl | 2 - .../webapp/WEB-INF/template/job/index.ftl | 79 ++++++++---- .../webapp/WEB-INF/template/joblog/index.ftl | 2 - .../src/main/webapp/static/js/job.index.1.js | 118 ++++++++++++++++-- .../main/webapp/static/js/joblog.index.1.js | 8 +- .../com/xxl/job/dao/impl/XxlJobInfoTest.java | 55 ++++++++ .../com/xxl/job/client/util/HttpUtil.java | 3 + 18 files changed, 622 insertions(+), 64 deletions(-) create mode 100644 xxl-job-admin/src/main/java/com/xxl/job/core/model/XxlJobInfo.java create mode 100644 xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobInfoDao.java create mode 100644 xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobInfoDaoImpl.java create mode 100644 xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml rename xxl-job-admin/src/main/{java/com/xxl/job/core/model/mapper => resources/mybatis-mapper}/XxlJobLogMapper.xml (100%) create mode 100644 xxl-job-admin/src/test/java/com/xxl/job/dao/impl/XxlJobInfoTest.java diff --git a/xxl-job-admin/src/main/java/com/xxl/job/controller/JobController.java b/xxl-job-admin/src/main/java/com/xxl/job/controller/JobController.java index daa227c7..2a3b9412 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/controller/JobController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/controller/JobController.java @@ -7,6 +7,7 @@ import java.util.Map; import java.util.Map.Entry; import java.util.Set; +import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import org.apache.commons.lang.StringUtils; @@ -16,11 +17,15 @@ import org.quartz.SchedulerException; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import com.xxl.job.client.handler.HandlerRepository; +import com.xxl.job.client.util.JacksonUtil; import com.xxl.job.core.model.ReturnT; +import com.xxl.job.core.model.XxlJobInfo; import com.xxl.job.core.util.DynamicSchedulerUtil; +import com.xxl.job.dao.IXxlJobInfoDao; import com.xxl.job.service.job.HttpJobBean; /** @@ -31,19 +36,47 @@ import com.xxl.job.service.job.HttpJobBean; @RequestMapping("/job") public class JobController { + @Resource + private IXxlJobInfoDao xxlJobInfoDao; + @RequestMapping public String index(Model model) { - List> jobList = DynamicSchedulerUtil.getJobList(); - model.addAttribute("jobList", jobList); + //List> jobList = DynamicSchedulerUtil.getJobList(); + //model.addAttribute("jobList", jobList); return "job/index"; } + @RequestMapping("/pageList") + @ResponseBody + public Map pageList(@RequestParam(required = false, defaultValue = "0") int start, + @RequestParam(required = false, defaultValue = "10") int length, + String jobName, String filterTime) { + + // page list + List list = xxlJobInfoDao.pageList(start, length, jobName, null, null); + int list_count = xxlJobInfoDao.pageListCount(start, length, jobName, null, null); + + // fill job info + if (list!=null && list.size()>0) { + for (XxlJobInfo jobInfo : list) { + DynamicSchedulerUtil.fillJobInfo(jobInfo); + } + } + + // package result + Map maps = new HashMap(); + maps.put("recordsTotal", list_count); // 总记录数 + maps.put("recordsFiltered", list_count); // 过滤后的总记录数 + maps.put("data", list); // 分页列表 + return maps; + } + @RequestMapping("/add") @ResponseBody public ReturnT add(HttpServletRequest request) { String triggerKeyName = null; String cronExpression = null; - Map jobData = new HashMap(); + Map jobData = new HashMap(); try { request.setCharacterEncoding("utf-8"); @@ -58,7 +91,7 @@ public class JobController { } else if (param.getKey().equals("cronExpression")) { cronExpression = param.getValue()[0]; } else { - jobData.put(param.getKey(), param.getValue().length>0?param.getValue()[0]:param.getValue()); + jobData.put(param.getKey(), (String) (param.getValue().length>0?param.getValue()[0]:param.getValue())); } } @@ -90,10 +123,19 @@ public class JobController { Class jobClass = HttpJobBean.class; try { - boolean result = DynamicSchedulerUtil.addJob(triggerKeyName, cronExpression, jobClass, jobData); + // add job 2 quartz + boolean result = DynamicSchedulerUtil.addJob(triggerKeyName, cronExpression, jobClass, null); if (!result) { return new ReturnT(500, "任务ID重复，请更换确认"); } + // Backup to the database + XxlJobInfo jobInfo = new XxlJobInfo(); + jobInfo.setJobName(triggerKeyName); + jobInfo.setJobCron(cronExpression); + jobInfo.setJobClass(jobClass.getName()); + jobInfo.setJobData(JacksonUtil.writeValueAsString(jobData)); + xxlJobInfoDao.save(jobInfo); + return ReturnT.SUCCESS; } catch (SchedulerException e) { e.printStackTrace(); @@ -117,6 +159,13 @@ public class JobController { } try { DynamicSchedulerUtil.rescheduleJob(triggerKeyName, cronExpression); + + // update + XxlJobInfo jobInfo = xxlJobInfoDao.load(triggerKeyName); + if (jobInfo!=null) { + jobInfo.setJobCron(cronExpression); + xxlJobInfoDao.update(jobInfo); + } return ReturnT.SUCCESS; } catch (SchedulerException e) { e.printStackTrace(); @@ -128,12 +177,15 @@ public class JobController { @ResponseBody public ReturnT remove(String triggerKeyName) { try { - DynamicSchedulerUtil.removeJob(triggerKeyName); - return ReturnT.SUCCESS; + if (triggerKeyName!=null) { + DynamicSchedulerUtil.removeJob(triggerKeyName); + xxlJobInfoDao.delete(triggerKeyName); + return ReturnT.SUCCESS; + } } catch (SchedulerException e) { e.printStackTrace(); - return ReturnT.FAIL; } + return ReturnT.FAIL; } @RequestMapping("/pause") @@ -141,6 +193,12 @@ public class JobController { public ReturnT pause(String triggerKeyName) { try { DynamicSchedulerUtil.pauseJob(triggerKeyName); + // update + XxlJobInfo jobInfo = xxlJobInfoDao.load(triggerKeyName); + if (jobInfo!=null) { + jobInfo.setJobStatus("PAUSED"); + xxlJobInfoDao.update(jobInfo); + } return ReturnT.SUCCESS; } catch (SchedulerException e) { e.printStackTrace(); @@ -153,6 +211,12 @@ public class JobController { public ReturnT resume(String triggerKeyName) { try { DynamicSchedulerUtil.resumeJob(triggerKeyName); + // update + XxlJobInfo jobInfo = xxlJobInfoDao.load(triggerKeyName); + if (jobInfo!=null) { + jobInfo.setJobStatus("NORMAL"); + xxlJobInfoDao.update(jobInfo); + } return ReturnT.SUCCESS; } catch (SchedulerException e) { e.printStackTrace(); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/core/model/XxlJobInfo.java b/xxl-job-admin/src/main/java/com/xxl/job/core/model/XxlJobInfo.java new file mode 100644 index 00000000..e539af01 --- /dev/null +++ b/xxl-job-admin/src/main/java/com/xxl/job/core/model/XxlJobInfo.java @@ -0,0 +1,77 @@ +package com.xxl.job.core.model; + +import java.util.Date; + +/** + * xxl-job info + * @author xuxueli 2016-1-12 18:25:49 + */ +public class XxlJobInfo { + + private int id; + // job info + private String jobName; + private String jobCron; // base on quartz + private String jobClass; // base on quartz + private String jobStatus; // base on quartz + private String jobData; // base on db, Map-JSON-String + private Date addTime; + private Date updateTime; + + public int getId() { + return id; + } + public void setId(int id) { + this.id = id; + } + public String getJobName() { + return jobName; + } + public void setJobName(String jobName) { + this.jobName = jobName; + } + public String getJobCron() { + return jobCron; + } + public void setJobCron(String jobCron) { + this.jobCron = jobCron; + } + public String getJobClass() { + return jobClass; + } + public void setJobClass(String jobClass) { + this.jobClass = jobClass; + } + public String getJobStatus() { + return jobStatus; + } + public void setJobStatus(String jobStatus) { + this.jobStatus = jobStatus; + } + public String getJobData() { + return jobData; + } + public void setJobData(String jobData) { + this.jobData = jobData; + } + public Date getAddTime() { + return addTime; + } + public void setAddTime(Date addTime) { + this.addTime = addTime; + } + public Date getUpdateTime() { + return updateTime; + } + public void setUpdateTime(Date updateTime) { + this.updateTime = updateTime; + } + + @Override + public String toString() { + return "XxlJobInfo [id=" + id + ", jobName=" + jobName + ", jobCron=" + jobCron + ", jobClass=" + jobClass + + ", jobStatus=" + jobStatus + ", jobData=" + jobData + ", addTime=" + addTime + ", updateTime=" + + updateTime + "]"; + } + +} diff --git a/xxl-job-admin/src/main/java/com/xxl/job/core/util/DynamicSchedulerUtil.java b/xxl-job-admin/src/main/java/com/xxl/job/core/util/DynamicSchedulerUtil.java index fdd1f6a4..79526ff7 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/core/util/DynamicSchedulerUtil.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/core/util/DynamicSchedulerUtil.java @@ -23,11 +23,14 @@ import org.quartz.Trigger.TriggerState; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; import org.quartz.impl.matchers.GroupMatcher; +import org.quartz.impl.triggers.CronTriggerImpl; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.InitializingBean; import org.springframework.util.Assert; +import com.xxl.job.core.model.XxlJobInfo; +import com.xxl.job.dao.IXxlJobInfoDao; import com.xxl.job.dao.IXxlJobLogDao; /** @@ -43,8 +46,11 @@ public final class DynamicSchedulerUtil implements InitializingBean { public void setXxlJobLogDao(IXxlJobLogDao xxlJobLogDao) { DynamicSchedulerUtil.xxlJobLogDao = xxlJobLogDao; } - public static IXxlJobLogDao getXxlJobLogDao() { - return xxlJobLogDao; + // xxlJobInfoDao + public static IXxlJobInfoDao xxlJobInfoDao; + @Resource + public void setXxlJobInfoDao(IXxlJobInfoDao xxlJobInfoDao) { + DynamicSchedulerUtil.xxlJobInfoDao = xxlJobInfoDao; } // Scheduler @@ -90,6 +96,34 @@ public final class DynamicSchedulerUtil implements InitializingBean { } return jobList; } + + // fill job info + public static void fillJobInfo(XxlJobInfo jobInfo) { + // TriggerKey : name + group + TriggerKey triggerKey = TriggerKey.triggerKey(jobInfo.getJobName(), Scheduler.DEFAULT_GROUP); + JobKey jobKey = new JobKey(jobInfo.getJobName(), Scheduler.DEFAULT_GROUP); + try { + Trigger trigger = scheduler.getTrigger(triggerKey); + JobDetail jobDetail = scheduler.getJobDetail(jobKey); + TriggerState triggerState = scheduler.getTriggerState(triggerKey); + + // parse params + if (trigger!=null && trigger instanceof CronTriggerImpl) { + String cronExpression = ((CronTriggerImpl) trigger).getCronExpression(); + jobInfo.setJobCron(cronExpression); + } + if (jobDetail!=null) { + String jobClass = jobDetail.getJobClass().getName(); + jobInfo.setJobClass(jobClass); + } + if (triggerState!=null) { + jobInfo.setJobStatus(triggerState.name()); + } + + } catch (SchedulerException e) { + e.printStackTrace(); + } + } // addJob 新增 public static boolean addJob(String triggerKeyName, String cronExpression, Class jobClass, Map jobData) throws SchedulerException { diff --git a/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobInfoDao.java b/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobInfoDao.java new file mode 100644 index 00000000..2d718dea --- /dev/null +++ b/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobInfoDao.java @@ -0,0 +1,25 @@ +package com.xxl.job.dao; + +import java.util.Date; +import java.util.List; + +import com.xxl.job.core.model.XxlJobInfo; + +/** + * job info + * @author xuxueli 2016-1-12 18:03:45 + */ +public interface IXxlJobInfoDao { + + public List pageList(int offset, int pagesize, String jobName, Date addTimeStart, Date addTimeEnd); + public int pageListCount(int offset, int pagesize, String jobName, Date addTimeStart, Date addTimeEnd); + + public int save(XxlJobInfo info); + + public XxlJobInfo load(String jobName); + + public int update(XxlJobInfo item); + + public int delete(String jobName); + +} diff --git a/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobLogDao.java b/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobLogDao.java index 3efc5795..40394dc4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobLogDao.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/dao/IXxlJobLogDao.java @@ -6,6 +6,10 @@ import java.util.List; import com.xxl.job.core.model.XxlJobLog; +/** + * job log + * @author xuxueli 2016-1-12 18:03:06 + */ public interface IXxlJobLogDao { public int save(XxlJobLog xxlJobLog); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobInfoDaoImpl.java b/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobInfoDaoImpl.java new file mode 100644 index 00000000..77c287b5 --- /dev/null +++ b/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobInfoDaoImpl.java @@ -0,0 +1,69 @@ +package com.xxl.job.dao.impl; + +import java.util.Date; +import java.util.HashMap; +import java.util.List; + +import javax.annotation.Resource; + +import org.mybatis.spring.SqlSessionTemplate; +import org.springframework.stereotype.Repository; + +import com.xxl.job.core.model.XxlJobInfo; +import com.xxl.job.dao.IXxlJobInfoDao; + +/** + * job info + * @author xuxueli 2016-1-12 18:03:45 + */ +@Repository +public class XxlJobInfoDaoImpl implements IXxlJobInfoDao { + + @Resource + public SqlSessionTemplate sqlSessionTemplate; + + @Override + public List pageList(int offset, int pagesize, String jobName, Date addTimeStart, Date addTimeEnd) { + HashMap params = new HashMap(); + params.put("offset", offset); + params.put("pagesize", pagesize); + params.put("jobName", jobName); + params.put("addTimeStart", addTimeStart); + params.put("addTimeEnd", addTimeEnd); + + return sqlSessionTemplate.selectList("XxlJobInfoMapper.pageList", params); + } + + @Override + public int pageListCount(int offset, int pagesize, String jobName, Date addTimeStart, Date addTimeEnd) { + HashMap params = new HashMap(); + params.put("offset", offset); + params.put("pagesize", pagesize); + params.put("jobName", jobName); + params.put("addTimeStart", addTimeStart); + params.put("addTimeEnd", addTimeEnd); + + return sqlSessionTemplate.selectOne("XxlJobInfoMapper.pageListCount", params); + } + + @Override + public int save(XxlJobInfo info) { + return sqlSessionTemplate.insert("XxlJobInfoMapper.save", info); + } + + @Override + public XxlJobInfo load(String jobName) { + return sqlSessionTemplate.selectOne("XxlJobInfoMapper.load", jobName); + } + + @Override + public int update(XxlJobInfo item) { + return sqlSessionTemplate.update("XxlJobInfoMapper.update", item); + } + + @Override + public int delete(String jobName) { + return sqlSessionTemplate.update("XxlJobInfoMapper.delete", jobName); + } + +} diff --git a/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobLogDaoImpl.java b/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobLogDaoImpl.java index 2ec15b97..a3185a3e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobLogDaoImpl.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/dao/impl/XxlJobLogDaoImpl.java @@ -12,6 +12,10 @@ import org.springframework.stereotype.Repository; import com.xxl.job.core.model.XxlJobLog; import com.xxl.job.dao.IXxlJobLogDao; +/** + * job log + * @author xuxueli 2016-1-12 18:03:06 + */ @Repository public class XxlJobLogDaoImpl implements IXxlJobLogDao { diff --git a/xxl-job-admin/src/main/java/com/xxl/job/service/job/HttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/service/job/HttpJobBean.java index d90e33ff..51210d39 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/service/job/HttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/service/job/HttpJobBean.java @@ -3,7 +3,6 @@ package com.xxl.job.service.job; import java.util.Date; import java.util.HashMap; import java.util.Map; -import java.util.Map.Entry; import org.apache.commons.lang.StringUtils; import org.quartz.JobExecutionContext; @@ -16,6 +15,7 @@ import org.springframework.scheduling.quartz.QuartzJobBean; import com.xxl.job.client.handler.HandlerRepository; import com.xxl.job.client.util.HttpUtil; import com.xxl.job.client.util.JacksonUtil; +import com.xxl.job.core.model.XxlJobInfo; import com.xxl.job.core.model.XxlJobLog; import com.xxl.job.core.util.DynamicSchedulerUtil; import com.xxl.job.core.util.PropertiesUtil; @@ -27,18 +27,17 @@ import com.xxl.job.core.util.PropertiesUtil; public class HttpJobBean extends QuartzJobBean { private static Logger logger = LoggerFactory.getLogger(HttpJobBean.class); + @SuppressWarnings("unchecked") @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { - String triggerKey = context.getTrigger().getJobKey().getName(); + // jobDataMap 2 params - Map jobDataMap = context.getMergedJobDataMap().getWrappedMap(); Map params = new HashMap(); - if (jobDataMap!=null && jobDataMap.size()>0) { - for (Entry item : jobDataMap.entrySet()) { - params.put(item.getKey(), String.valueOf(item.getValue())); - } + XxlJobInfo jobInfo = DynamicSchedulerUtil.xxlJobInfoDao.load(triggerKey); + if (jobInfo!=null && jobInfo.getJobData()!=null) { + params = JacksonUtil.readValue(jobInfo.getJobData(), Map.class); } // corn @@ -53,7 +52,7 @@ public class HttpJobBean extends QuartzJobBean { jobLog.setJobName(triggerKey); jobLog.setJobCron(cornExp); jobLog.setJobClass(HttpJobBean.class.getName()); - jobLog.setJobData(JacksonUtil.writeValueAsString(params)); + jobLog.setJobData(jobInfo.getJobData()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); logger.info(">>>>>>>>>>> xxl-job trigger start, jobLog:{}", jobLog); @@ -70,8 +69,7 @@ public class HttpJobBean extends QuartzJobBean { jobLog.setTriggerTime(new Date()); jobLog.setTriggerStatus(HttpUtil.FAIL); jobLog.setTriggerMsg("[responseMsg]:"+responseMsg+"
[exceptionMsg]:"+exceptionMsg); - if (StringUtils.isNotBlank(responseMsg)) { - @SuppressWarnings("unchecked") + if (StringUtils.isNotBlank(responseMsg) && responseMsg.indexOf("{")>-1 ) { Map responseMap = JacksonUtil.readValue(responseMsg, Map.class); if (responseMap!=null && StringUtils.isNotBlank(responseMap.get(HttpUtil.status))) { jobLog.setTriggerStatus(responseMap.get(HttpUtil.status)); diff --git a/xxl-job-admin/src/main/resources/applicationcontext-database.xml b/xxl-job-admin/src/main/resources/applicationcontext-database.xml index 96874386..2a8bd8a3 100644 --- a/xxl-job-admin/src/main/resources/applicationcontext-database.xml +++ b/xxl-job-admin/src/main/resources/applicationcontext-database.xml @@ -31,7 +31,7 @@ - + diff --git a/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml new file mode 100644 index 00000000..669afef9 --- /dev/null +++ b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml @@ -0,0 +1,102 @@ + + + + + + + + + + + + + + + + + + t.id, + t.job_name, + t.job_cron, + t.job_class, + t.job_data, + t.add_time, + t.update_time + + + + + + + + INSERT INTO `xxl_job_qrtz_trigger_info` ( + `job_name`, + `job_cron`, + `job_class`, + `job_data`, + `add_time`, + `update_time` + ) VALUES ( + #{jobName}, + #{jobCron}, + #{jobClass}, + #{jobData}, + NOW(), + NOW() + ); + + SELECT LAST_INSERT_ID() + + + + + + + UPDATE `xxl_job_qrtz_trigger_info` + SET `job_cron`= #{jobCron}, + `job_data`= #{jobData}, + `update_time`= NOW() + WHERE `id`= #{id} + + + + delete from xxl_job_qrtz_trigger_info + where job_name = #{jobName} + + + \ No newline at end of file diff --git a/xxl-job-admin/src/main/java/com/xxl/job/core/model/mapper/XxlJobLogMapper.xml b/xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobLogMapper.xml similarity index 100% rename from xxl-job-admin/src/main/java/com/xxl/job/core/model/mapper/XxlJobLogMapper.xml rename to xxl-job-admin/src/main/resources/mybatis-mapper/XxlJobLogMapper.xml diff --git a/xxl-job-admin/src/main/webapp/WEB-INF/template/help.ftl b/xxl-job-admin/src/main/webapp/WEB-INF/template/help.ftl index 9ce7eaf6..e489f5d5 100644 --- a/xxl-job-admin/src/main/webapp/WEB-INF/template/help.ftl +++ b/xxl-job-admin/src/main/webapp/WEB-INF/template/help.ftl @@ -68,8 +68,6 @@ <@netCommon.commonFooter /> - - <@netCommon.commonControl /> <@netCommon.commonScript /> diff --git a/xxl-job-admin/src/main/webapp/WEB-INF/template/job/index.ftl b/xxl-job-admin/src/main/webapp/WEB-INF/template/job/index.ftl index 7a37c29b..6aaf3b3f 100644 --- a/xxl-job-admin/src/main/webapp/WEB-INF/template/job/index.ftl +++ b/xxl-job-admin/src/main/webapp/WEB-INF/template/job/index.ftl @@ -28,32 +28,53 @@
+ +
+
+
+ + jobName + + +
+
+
+ +
+
+ +
+
+

调度列表

-
- - - + + + + + - + + + <#-- <#if jobList?exists && jobList?size gt 0> <#list jobList as item> - + + + --> - - - - - - - - - - +
调度keycronid任务Key任务Cron任务Class状态Status 参数状态addTimeupdateTime 操作
${item['TriggerKey'].name} ${item['Trigger'].cronExpression}${item['JobDetail'].jobClass} <#assign jobDataMap = item['JobDetail'].jobDataMap /> <#if jobDataMap?exists && jobDataMap?keys?size gt 0> @@ -89,17 +110,10 @@
调度keycron参数状态操作
@@ -110,8 +124,6 @@ <@netCommon.commonFooter /> - - <@netCommon.commonControl />
@@ -129,19 +141,19 @@
-
+
-
+
-
+
-
+
@@ -166,12 +178,24 @@
- -
+ +
+
+
+ +
- -
+ +
+
+
+ +
+
+
+ +
@@ -191,6 +215,9 @@ + + + diff --git a/xxl-job-admin/src/main/webapp/WEB-INF/template/joblog/index.ftl b/xxl-job-admin/src/main/webapp/WEB-INF/template/joblog/index.ftl index b09248dc..ce141da3 100644 --- a/xxl-job-admin/src/main/webapp/WEB-INF/template/joblog/index.ftl +++ b/xxl-job-admin/src/main/webapp/WEB-INF/template/joblog/index.ftl @@ -84,8 +84,6 @@ <@netCommon.commonFooter /> - - <@netCommon.commonControl />
<@netCommon.commonScript /> diff --git a/xxl-job-admin/src/main/webapp/static/js/job.index.1.js b/xxl-job-admin/src/main/webapp/static/js/job.index.1.js index 87747caa..256ba220 100644 --- a/xxl-job-admin/src/main/webapp/static/js/job.index.1.js +++ b/xxl-job-admin/src/main/webapp/static/js/job.index.1.js @@ -1,6 +1,75 @@ $(function() { // init date tables - $("#job_list").DataTable({ + var jobTable = $("#job_list").dataTable({ + "deferRender": true, + "processing" : true, + "serverSide": true, + "ajax": { + url: base_url + "/job/pageList", + data : function ( d ) { + d.jobName = $('#jobName').val() + } + }, + //"scrollX": true, // X轴滚动条，取消自适应 + "columns": [ + { "data": 'id', "bSortable": false, "visible" : false}, + { "data": 'jobName', "bSortable": false}, + { "data": 'jobCron', "bSortable": false, "visible" : true}, + { "data": 'jobClass', "bSortable": false, "visible" : false}, + { "data": 'jobStatus', "bSortable": false, "visible" : true}, + { "data": 'jobData', "bSortable": false, "visible" : true}, + { + "data": 'addTime', + "bSortable": false, + "render": function ( data, type, row ) { + return data?moment(new Date(data)).format("YYYY-MM-DD HH:mm:ss"):""; + } + }, + { + "data": 'updateTime', + "bSortable": false, + "render": function ( data, type, row ) { + return data?moment(new Date(data)).format("YYYY-MM-DD HH:mm:ss"):""; + } + }, + { "data": '操作' , "bSortable": false, + "render": function ( data, type, row ) { + return function(){ + // status + var pause_resume = ""; + if ('NORMAL' == row.jobStatus) { + pause_resume = ' '; + } else if ('PAUSED' == row.jobStatus){ + pause_resume = ' '; + } + // log url + var logUrl = base_url +'/joblog?jobName='+ row.jobName; + + // job data + var jobDataMap = eval('(' + row.jobData + ')'); + + var html = '

'+ + pause_resume + + ' '+ + ' '+ + ' '+ + ''+ + '

'; + + + return html; + }; + } + } + ], + "searching": false, + "ordering": true, "language" : { "sProcessing" : "处理中...", "sLengthMenu" : "每页 _MENU_ 条记录", @@ -27,8 +96,13 @@ $(function() { } }); + // 搜索按钮 + $('#searchBtn').on('click', function(){ + jobTable.fnDraw(); + }); + // job operate - $(".job_operate").click(function() { + $("#job_list").on('click', '.job_operate',function() { var typeName; var url; var type = $(this).attr("type"); @@ -48,22 +122,21 @@ $(function() { return; } - var name = $(this).parent('p').attr("name"); - var group = $(this).parent('p').attr("group"); + var name = $(this).parent('p').attr("jobName"); ComConfirm.show("确认" + typeName + "?", function(){ $.ajax({ type : 'POST', url : url, data : { - "triggerKeyName" : name, - "group" : group + "triggerKeyName" : name }, dataType : "json", success : function(data){ if (data.code == 200) { ComAlert.show(1, typeName + "成功", function(){ - window.location.reload(); + //window.location.reload(); + jobTable.fnDraw(); }); } else { ComAlert.show(1, typeName + "失败"); @@ -215,9 +288,12 @@ $(function() { }); // 更新 - $(".update").click(function(){ - $("#updateModal .form input[name='triggerKeyName']").val($(this).parent('p').attr("name")); + $("#job_list").on('click', '.update',function() { + $("#updateModal .form input[name='triggerKeyName']").val($(this).parent('p').attr("jobName")); $("#updateModal .form input[name='cronExpression']").val($(this).parent('p').attr("cronExpression")); + $("#updateModal .form input[name='job_desc']").val($(this).parent('p').attr("job_desc")); + $("#updateModal .form input[name='job_url']").val($(this).parent('p').attr("job_url")); + $("#updateModal .form input[name='handleName']").val($(this).parent('p').attr("handleName")); $('#updateModal').modal({backdrop: false, keyboard: false}).modal('show'); }); var updateModalValidate = $("#updateModal .form").validate({ @@ -233,6 +309,18 @@ $(function() { cronExpression : { required : true , maxlength: 100 + }, + job_desc : { + required : true , + maxlength: 200 + }, + job_url : { + required : true , + maxlength: 200 + }, + handleName : { + required : true , + maxlength: 200 } }, messages : { @@ -244,6 +332,18 @@ $(function() { cronExpression : { required :"请输入“任务Corn”." , maxlength:"“任务Corn”不应超过100位" + }, + job_desc : { + required :"请输入“任务描述”." , + maxlength:"“任务描述”长度不应超过200位" + }, + job_url : { + required :"请输入“任务URL”." , + maxlength:"“任务URL”长度不应超过200位" + }, + handleName : { + required : "请输入“任务handler”." , + maxlength: "“任务handler”长度不应超过200位" } }, highlight : function(element) { diff --git a/xxl-job-admin/src/main/webapp/static/js/joblog.index.1.js b/xxl-job-admin/src/main/webapp/static/js/joblog.index.1.js index d1e4c28d..154a4873 100644 --- a/xxl-job-admin/src/main/webapp/static/js/joblog.index.1.js +++ b/xxl-job-admin/src/main/webapp/static/js/joblog.index.1.js @@ -29,7 +29,7 @@ $(function() { { "data": 'triggerStatus', "bSortable": false}, { "data": 'triggerMsg',"bSortable": false, "render": function ( data, type, row ) { - return data?'调度日志':"无"; + return data?'调度日志'+ data +'':"无"; } }, { @@ -42,7 +42,7 @@ $(function() { { "data": 'handleStatus',"bSortable": false}, { "data": 'handleMsg' , "bSortable": false, "render": function ( data, type, row ) { - return data?'执行日志':"无"; + return data?'执行日志'+ data +'':"无"; } } ], @@ -76,8 +76,8 @@ $(function() { // 日志弹框提示 $('#joblog_list').on('click', '.logTips', function(){ - var title = $(this).attr('title'); - ComAlertTec.show(title); + var msg = $(this).find('span').html(); + ComAlertTec.show(msg); }); // 过滤时间 diff --git a/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/XxlJobInfoTest.java b/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/XxlJobInfoTest.java new file mode 100644 index 00000000..5812a557 --- /dev/null +++ b/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/XxlJobInfoTest.java @@ -0,0 +1,55 @@ +package com.xxl.job.dao.impl; + +import java.util.List; + +import javax.annotation.Resource; + +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.test.context.ContextConfiguration; +import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; + +import com.xxl.job.core.model.XxlJobInfo; +import com.xxl.job.dao.IXxlJobInfoDao; + +@RunWith(SpringJUnit4ClassRunner.class) +@ContextConfiguration(locations = "classpath*:applicationcontext-*.xml") +public class XxlJobInfoTest { + + @Resource + private IXxlJobInfoDao xxlJobInfoDao; + + @Test + public void pageList(){ + List list = xxlJobInfoDao.pageList(0, 20, null, null, null); + int list_count = xxlJobInfoDao.pageListCount(0, 20, null, null, null); + + System.out.println(list); + System.out.println(list_count); + } + + @Test + public void save_load(){ + XxlJobInfo info = new XxlJobInfo(); + info.setJobName("job_name"); + info.setJobCron("jobCron"); + info.setJobClass("jobClass"); + info.setJobData("jobData"); + int count = xxlJobInfoDao.save(info); + System.out.println(count); + System.out.println(info.getId()); + + XxlJobInfo item = xxlJobInfoDao.load(info.getId()); + System.out.println(item); + } + + @Test + public void update(){ + XxlJobInfo item = xxlJobInfoDao.load(2); + + item.setJobCron("jobCron2"); + item.setJobData("jobData2"); + xxlJobInfoDao.update(item); + } + +} diff --git a/xxl-job-client/src/main/java/com/xxl/job/client/util/HttpUtil.java b/xxl-job-client/src/main/java/com/xxl/job/client/util/HttpUtil.java index 99d7fcd5..4d233226 100644 --- a/xxl-job-client/src/main/java/com/xxl/job/client/util/HttpUtil.java +++ b/xxl-job-client/src/main/java/com/xxl/job/client/util/HttpUtil.java @@ -64,6 +64,9 @@ public class HttpUtil { responseMsg = EntityUtils.toString(entity, "UTF-8"); EntityUtils.consume(entity); } + if (response.getStatusLine().getStatusCode() != 200) { + exceptionMsg = "response.getStatusLine().getStatusCode() = " + response.getStatusLine().getStatusCode(); + } } catch (Exception e) { e.printStackTrace(); StringWriter out = new StringWriter();