JobLogController.java 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204
  1. package com.xxl.job.admin.controller;
  2. import com.xxl.job.admin.core.model.XxlJobGroup;
  3. import com.xxl.job.admin.core.model.XxlJobInfo;
  4. import com.xxl.job.admin.core.model.XxlJobLog;
  5. import com.xxl.job.admin.core.schedule.XxlJobDynamicScheduler;
  6. import com.xxl.job.admin.core.util.I18nUtil;
  7. import com.xxl.job.admin.dao.XxlJobGroupDao;
  8. import com.xxl.job.admin.dao.XxlJobInfoDao;
  9. import com.xxl.job.admin.dao.XxlJobLogDao;
  10. import com.xxl.job.core.biz.ExecutorBiz;
  11. import com.xxl.job.core.biz.model.LogResult;
  12. import com.xxl.job.core.biz.model.ReturnT;
  13. import com.xxl.job.core.util.DateUtil;
  14. import org.slf4j.Logger;
  15. import org.slf4j.LoggerFactory;
  16. import org.springframework.stereotype.Controller;
  17. import org.springframework.ui.Model;
  18. import org.springframework.web.bind.annotation.RequestMapping;
  19. import org.springframework.web.bind.annotation.RequestParam;
  20. import org.springframework.web.bind.annotation.ResponseBody;
  21. import javax.annotation.Resource;
  22. import java.text.ParseException;
  23. import java.util.Date;
  24. import java.util.HashMap;
  25. import java.util.List;
  26. import java.util.Map;
  27. /**
  28. * index controller
  29. * @author xuxueli 2015-12-19 16:13:16
  30. */
  31. @Controller
  32. @RequestMapping("/joblog")
  33. public class JobLogController {
  34. private static Logger logger = LoggerFactory.getLogger(JobLogController.class);
  35. @Resource
  36. private XxlJobGroupDao xxlJobGroupDao;
  37. @Resource
  38. public XxlJobInfoDao xxlJobInfoDao;
  39. @Resource
  40. public XxlJobLogDao xxlJobLogDao;
  41. @RequestMapping
  42. public String index(Model model, @RequestParam(required = false, defaultValue = "0") Integer jobId) {
  43. // 执行器列表
  44. List<XxlJobGroup> jobGroupList = xxlJobGroupDao.findAll();
  45. model.addAttribute("JobGroupList", jobGroupList);
  46. // 任务
  47. if (jobId > 0) {
  48. XxlJobInfo jobInfo = xxlJobInfoDao.loadById(jobId);
  49. model.addAttribute("jobInfo", jobInfo);
  50. }
  51. return "joblog/joblog.index";
  52. }
  53. @RequestMapping("/getJobsByGroup")
  54. @ResponseBody
  55. public ReturnT<List<XxlJobInfo>> getJobsByGroup(int jobGroup){
  56. List<XxlJobInfo> list = xxlJobInfoDao.getJobsByGroup(jobGroup);
  57. return new ReturnT<List<XxlJobInfo>>(list);
  58. }
  59. @RequestMapping("/pageList")
  60. @ResponseBody
  61. public Map<String, Object> pageList(@RequestParam(required = false, defaultValue = "0") int start,
  62. @RequestParam(required = false, defaultValue = "10") int length,
  63. int jobGroup, int jobId, int logStatus, String filterTime) {
  64. // parse param
  65. Date triggerTimeStart = null;
  66. Date triggerTimeEnd = null;
  67. if (filterTime!=null && filterTime.trim().length()>0) {
  68. String[] temp = filterTime.split(" - ");
  69. if (temp!=null && temp.length == 2) {
  70. triggerTimeStart = DateUtil.parseDateTime(temp[0]);
  71. triggerTimeEnd = DateUtil.parseDateTime(temp[1]);
  72. }
  73. }
  74. // page query
  75. List<XxlJobLog> list = xxlJobLogDao.pageList(start, length, jobGroup, jobId, triggerTimeStart, triggerTimeEnd, logStatus);
  76. int list_count = xxlJobLogDao.pageListCount(start, length, jobGroup, jobId, triggerTimeStart, triggerTimeEnd, logStatus);
  77. // package result
  78. Map<String, Object> maps = new HashMap<String, Object>();
  79. maps.put("recordsTotal", list_count); // 总记录数
  80. maps.put("recordsFiltered", list_count); // 过滤后的总记录数
  81. maps.put("data", list); // 分页列表
  82. return maps;
  83. }
  84. @RequestMapping("/logDetailPage")
  85. public String logDetailPage(int id, Model model){
  86. // base check
  87. ReturnT<String> logStatue = ReturnT.SUCCESS;
  88. XxlJobLog jobLog = xxlJobLogDao.load(id);
  89. if (jobLog == null) {
  90. throw new RuntimeException(I18nUtil.getString("joblog_logid_unvalid"));
  91. }
  92. model.addAttribute("triggerCode", jobLog.getTriggerCode());
  93. model.addAttribute("handleCode", jobLog.getHandleCode());
  94. model.addAttribute("executorAddress", jobLog.getExecutorAddress());
  95. model.addAttribute("triggerTime", jobLog.getTriggerTime().getTime());
  96. model.addAttribute("logId", jobLog.getId());
  97. return "joblog/joblog.detail";
  98. }
  99. @RequestMapping("/logDetailCat")
  100. @ResponseBody
  101. public ReturnT<LogResult> logDetailCat(String executorAddress, long triggerTime, int logId, int fromLineNum){
  102. try {
  103. ExecutorBiz executorBiz = XxlJobDynamicScheduler.getExecutorBiz(executorAddress);
  104. ReturnT<LogResult> logResult = executorBiz.log(triggerTime, logId, fromLineNum);
  105. // is end
  106. if (logResult.getContent()!=null && logResult.getContent().getFromLineNum() > logResult.getContent().getToLineNum()) {
  107. XxlJobLog jobLog = xxlJobLogDao.load(logId);
  108. if (jobLog.getHandleCode() > 0) {
  109. logResult.getContent().setEnd(true);
  110. }
  111. }
  112. return logResult;
  113. } catch (Exception e) {
  114. logger.error(e.getMessage(), e);
  115. return new ReturnT<LogResult>(ReturnT.FAIL_CODE, e.getMessage());
  116. }
  117. }
  118. @RequestMapping("/logKill")
  119. @ResponseBody
  120. public ReturnT<String> logKill(int id){
  121. // base check
  122. XxlJobLog log = xxlJobLogDao.load(id);
  123. XxlJobInfo jobInfo = xxlJobInfoDao.loadById(log.getJobId());
  124. if (jobInfo==null) {
  125. return new ReturnT<String>(500, I18nUtil.getString("jobinfo_glue_jobid_unvalid"));
  126. }
  127. if (ReturnT.SUCCESS_CODE != log.getTriggerCode()) {
  128. return new ReturnT<String>(500, I18nUtil.getString("joblog_kill_log_limit"));
  129. }
  130. // request of kill
  131. ReturnT<String> runResult = null;
  132. try {
  133. ExecutorBiz executorBiz = XxlJobDynamicScheduler.getExecutorBiz(log.getExecutorAddress());
  134. runResult = executorBiz.kill(jobInfo.getId());
  135. } catch (Exception e) {
  136. logger.error(e.getMessage(), e);
  137. runResult = new ReturnT<String>(500, e.getMessage());
  138. }
  139. if (ReturnT.SUCCESS_CODE == runResult.getCode()) {
  140. log.setHandleCode(ReturnT.FAIL_CODE);
  141. log.setHandleMsg( I18nUtil.getString("joblog_kill_log_byman")+":" + (runResult.getMsg()!=null?runResult.getMsg():""));
  142. log.setHandleTime(new Date());
  143. xxlJobLogDao.updateHandleInfo(log);
  144. return new ReturnT<String>(runResult.getMsg());
  145. } else {
  146. return new ReturnT<String>(500, runResult.getMsg());
  147. }
  148. }
  149. @RequestMapping("/clearLog")
  150. @ResponseBody
  151. public ReturnT<String> clearLog(int jobGroup, int jobId, int type){
  152. Date clearBeforeTime = null;
  153. int clearBeforeNum = 0;
  154. if (type == 1) {
  155. clearBeforeTime = DateUtil.addMonths(new Date(), -1); // 清理一个月之前日志数据
  156. } else if (type == 2) {
  157. clearBeforeTime = DateUtil.addMonths(new Date(), -3); // 清理三个月之前日志数据
  158. } else if (type == 3) {
  159. clearBeforeTime = DateUtil.addMonths(new Date(), -6); // 清理六个月之前日志数据
  160. } else if (type == 4) {
  161. clearBeforeTime = DateUtil.addYears(new Date(), -1); // 清理一年之前日志数据
  162. } else if (type == 5) {
  163. clearBeforeNum = 1000; // 清理一千条以前日志数据
  164. } else if (type == 6) {
  165. clearBeforeNum = 10000; // 清理一万条以前日志数据
  166. } else if (type == 7) {
  167. clearBeforeNum = 30000; // 清理三万条以前日志数据
  168. } else if (type == 8) {
  169. clearBeforeNum = 100000; // 清理十万条以前日志数据
  170. } else if (type == 9) {
  171. clearBeforeNum = 0; // 清理所有日志数据
  172. } else {
  173. return new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("joblog_clean_type_unvalid"));
  174. }
  175. xxlJobLogDao.clearLog(jobGroup, jobId, clearBeforeTime, clearBeforeNum);
  176. return ReturnT.SUCCESS;
  177. }
  178. }