master
xueli.xue 9 years ago
parent 65243e7649
commit 9f3dd8b3a1
  1. 8
      xxl-job-admin/src/main/java/com/xxl/controller/IndexController.java
  2. 30
      xxl-job-admin/src/main/java/com/xxl/quartz/DynamicSchedulerUtil.java
  3. 5
      xxl-job-admin/src/main/webapp/WEB-INF/template/job/index.ftl

@ -1,8 +1,8 @@
package com.xxl.controller;
import java.util.Set;
import java.util.List;
import java.util.Map;
import org.quartz.JobKey;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
@ -16,8 +16,8 @@ public class IndexController {
@RequestMapping("index")
public String index(Model model) {
Set<JobKey> list = DynamicSchedulerUtil.getJobKeys();
model.addAttribute("jobList", list);
List<Map<String, Object>> jobList = DynamicSchedulerUtil.getJobList();
model.addAttribute("jobList", jobList);
return "job/index";
}

@ -1,6 +1,9 @@
package com.xxl.quartz;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
@ -38,21 +41,30 @@ public final class DynamicSchedulerUtil implements InitializingBean {
}
// getJobKeys
public static Set<JobKey> getJobKeys(){
public static List<Map<String, Object>> getJobList(){
List<Map<String, Object>> jobList = new ArrayList<Map<String,Object>>();
try {
String groupName = scheduler.getJobGroupNames().get(0);
return scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName));
Set<JobKey> jobKeys = scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName));
if (jobKeys!=null && jobKeys.size()>0) {
for (JobKey jobKey : jobKeys) {
TriggerKey triggerKey = TriggerKey.triggerKey(jobKey.getName(), Scheduler.DEFAULT_GROUP);
Trigger trigger = scheduler.getTrigger(triggerKey);
JobDetail jobDetail = scheduler.getJobDetail(jobKey);
Map<String, Object> jobMap = new HashMap<String, Object>();
jobMap.put("TriggerKey", triggerKey);
jobMap.put("Trigger", trigger);
jobMap.put("JobDetail", jobDetail);
jobList.add(jobMap);
}
}
} catch (SchedulerException e) {
e.printStackTrace();
return null;
}
}
public static void getJobDetail(String triggerKeyName){
// TriggerKey : name + group
String group = Scheduler.DEFAULT_GROUP;
TriggerKey triggerKey = TriggerKey.triggerKey(triggerKeyName, group);
return jobList;
}
// addJob 新增

@ -29,7 +29,10 @@
<h4>在线任务:</h4>
<#if jobList?exists && jobList?size gt 0>
<#list jobList as item>
<p>${item}</p>
<p>${item['TriggerKey']}</p>
<p>${item['Trigger']}</p>
<p>${item['Trigger'].cronExpression}</p>
<p>${item['JobDetail']}</p>
</#list>
</#if>
</div>

Loading…
Cancel
Save