JobInfoController.java 6.3 KB

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