JobInfoController.java 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180
  1. package com.xxl.job.admin.controller;
  2. import com.xxl.job.admin.core.cron.CronExpression;
  3. import com.xxl.job.admin.core.exception.XxlJobException;
  4. import com.xxl.job.admin.core.model.XxlJobGroup;
  5. import com.xxl.job.admin.core.model.XxlJobInfo;
  6. import com.xxl.job.admin.core.model.XxlJobUser;
  7. import com.xxl.job.admin.core.route.ExecutorRouteStrategyEnum;
  8. import com.xxl.job.admin.core.scheduler.MisfireStrategyEnum;
  9. import com.xxl.job.admin.core.scheduler.ScheduleTypeEnum;
  10. import com.xxl.job.admin.core.thread.JobScheduleHelper;
  11. import com.xxl.job.admin.core.thread.JobTriggerPoolHelper;
  12. import com.xxl.job.admin.core.trigger.TriggerTypeEnum;
  13. import com.xxl.job.admin.core.util.I18nUtil;
  14. import com.xxl.job.admin.dao.XxlJobGroupDao;
  15. import com.xxl.job.admin.service.LoginService;
  16. import com.xxl.job.admin.service.XxlJobService;
  17. import com.xxl.job.core.biz.model.ReturnT;
  18. import com.xxl.job.core.enums.ExecutorBlockStrategyEnum;
  19. import com.xxl.job.core.glue.GlueTypeEnum;
  20. import com.xxl.job.core.util.DateUtil;
  21. import org.slf4j.Logger;
  22. import org.slf4j.LoggerFactory;
  23. import org.springframework.stereotype.Controller;
  24. import org.springframework.ui.Model;
  25. import org.springframework.web.bind.annotation.RequestMapping;
  26. import org.springframework.web.bind.annotation.RequestParam;
  27. import org.springframework.web.bind.annotation.ResponseBody;
  28. import javax.annotation.Resource;
  29. import javax.servlet.http.HttpServletRequest;
  30. import java.text.ParseException;
  31. import java.util.*;
  32. /**
  33. * index controller
  34. * @author xuxueli 2015-12-19 16:13:16
  35. */
  36. @Controller
  37. @RequestMapping("/jobinfo")
  38. public class JobInfoController {
  39. private static Logger logger = LoggerFactory.getLogger(JobInfoController.class);
  40. @Resource
  41. private XxlJobGroupDao xxlJobGroupDao;
  42. @Resource
  43. private XxlJobService xxlJobService;
  44. @RequestMapping
  45. public String index(HttpServletRequest request, Model model, @RequestParam(required = false, defaultValue = "-1") int jobGroup) {
  46. // 枚举-字典
  47. model.addAttribute("ExecutorRouteStrategyEnum", ExecutorRouteStrategyEnum.values()); // 路由策略-列表
  48. model.addAttribute("GlueTypeEnum", GlueTypeEnum.values()); // Glue类型-字典
  49. model.addAttribute("ExecutorBlockStrategyEnum", ExecutorBlockStrategyEnum.values()); // 阻塞处理策略-字典
  50. model.addAttribute("ScheduleTypeEnum", ScheduleTypeEnum.values()); // 调度类型
  51. model.addAttribute("MisfireStrategyEnum", MisfireStrategyEnum.values()); // 调度过期策略
  52. // 执行器列表
  53. List<XxlJobGroup> jobGroupList_all = xxlJobGroupDao.findAll();
  54. // filter group
  55. List<XxlJobGroup> jobGroupList = filterJobGroupByRole(request, jobGroupList_all);
  56. if (jobGroupList==null || jobGroupList.size()==0) {
  57. throw new XxlJobException(I18nUtil.getString("jobgroup_empty"));
  58. }
  59. model.addAttribute("JobGroupList", jobGroupList);
  60. model.addAttribute("jobGroup", jobGroup);
  61. return "jobinfo/jobinfo.index";
  62. }
  63. public static List<XxlJobGroup> filterJobGroupByRole(HttpServletRequest request, List<XxlJobGroup> jobGroupList_all){
  64. List<XxlJobGroup> jobGroupList = new ArrayList<>();
  65. if (jobGroupList_all!=null && jobGroupList_all.size()>0) {
  66. XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
  67. if (loginUser.getRole() == 1) {
  68. jobGroupList = jobGroupList_all;
  69. } else {
  70. List<String> groupIdStrs = new ArrayList<>();
  71. if (loginUser.getPermission()!=null && loginUser.getPermission().trim().length()>0) {
  72. groupIdStrs = Arrays.asList(loginUser.getPermission().trim().split(","));
  73. }
  74. for (XxlJobGroup groupItem:jobGroupList_all) {
  75. if (groupIdStrs.contains(String.valueOf(groupItem.getId()))) {
  76. jobGroupList.add(groupItem);
  77. }
  78. }
  79. }
  80. }
  81. return jobGroupList;
  82. }
  83. public static void validPermission(HttpServletRequest request, int jobGroup) {
  84. XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY);
  85. if (!loginUser.validPermission(jobGroup)) {
  86. throw new RuntimeException(I18nUtil.getString("system_permission_limit") + "[username="+ loginUser.getUsername() +"]");
  87. }
  88. }
  89. @RequestMapping("/pageList")
  90. @ResponseBody
  91. public Map<String, Object> pageList(@RequestParam(required = false, defaultValue = "0") int start,
  92. @RequestParam(required = false, defaultValue = "10") int length,
  93. int jobGroup, int triggerStatus, String jobDesc, String executorHandler, String author) {
  94. return xxlJobService.pageList(start, length, jobGroup, triggerStatus, jobDesc, executorHandler, author);
  95. }
  96. @RequestMapping("/add")
  97. @ResponseBody
  98. public ReturnT<String> add(XxlJobInfo jobInfo) {
  99. return xxlJobService.add(jobInfo);
  100. }
  101. @RequestMapping("/update")
  102. @ResponseBody
  103. public ReturnT<String> update(XxlJobInfo jobInfo) {
  104. return xxlJobService.update(jobInfo);
  105. }
  106. @RequestMapping("/remove")
  107. @ResponseBody
  108. public ReturnT<String> remove(int id) {
  109. return xxlJobService.remove(id);
  110. }
  111. @RequestMapping("/stop")
  112. @ResponseBody
  113. public ReturnT<String> pause(int id) {
  114. return xxlJobService.stop(id);
  115. }
  116. @RequestMapping("/start")
  117. @ResponseBody
  118. public ReturnT<String> start(int id) {
  119. return xxlJobService.start(id);
  120. }
  121. @RequestMapping("/trigger")
  122. @ResponseBody
  123. //@PermissionLimit(limit = false)
  124. public ReturnT<String> triggerJob(int id, String executorParam, String addressList) {
  125. // force cover job param
  126. if (executorParam == null) {
  127. executorParam = "";
  128. }
  129. JobTriggerPoolHelper.trigger(id, TriggerTypeEnum.MANUAL, -1, null, executorParam, addressList);
  130. return ReturnT.SUCCESS;
  131. }
  132. @RequestMapping("/nextTriggerTime")
  133. @ResponseBody
  134. public ReturnT<List<String>> nextTriggerTime(String scheduleType, String scheduleConf) {
  135. XxlJobInfo paramXxlJobInfo = new XxlJobInfo();
  136. paramXxlJobInfo.setScheduleType(scheduleType);
  137. paramXxlJobInfo.setScheduleConf(scheduleConf);
  138. List<String> result = new ArrayList<>();
  139. try {
  140. Date lastTime = new Date();
  141. for (int i = 0; i < 5; i++) {
  142. lastTime = JobScheduleHelper.generateNextValidTime(paramXxlJobInfo, lastTime);
  143. if (lastTime != null) {
  144. result.add(DateUtil.formatDateTime(lastTime));
  145. } else {
  146. break;
  147. }
  148. }
  149. } catch (Exception e) {
  150. logger.error(e.getMessage(), e);
  151. return new ReturnT<List<String>>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")+I18nUtil.getString("system_unvalid")) + e.getMessage());
  152. }
  153. return new ReturnT<List<String>>(result);
  154. }
  155. }