JobCodeController.java 2.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. package com.xxl.job.admin.controller;
  2. import com.xxl.job.admin.core.model.XxlJobInfo;
  3. import com.xxl.job.admin.core.model.XxlJobLogGlue;
  4. import com.xxl.job.admin.dao.IXxlJobInfoDao;
  5. import com.xxl.job.admin.dao.IXxlJobLogGlueDao;
  6. import com.xxl.job.core.biz.model.ReturnT;
  7. import org.springframework.stereotype.Controller;
  8. import org.springframework.ui.Model;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import org.springframework.web.bind.annotation.ResponseBody;
  11. import javax.annotation.Resource;
  12. import java.util.Date;
  13. import java.util.List;
  14. /**
  15. * job code controller
  16. * @author xuxueli 2015-12-19 16:13:16
  17. */
  18. @Controller
  19. @RequestMapping("/jobcode")
  20. public class JobCodeController {
  21. @Resource
  22. private IXxlJobInfoDao xxlJobInfoDao;
  23. @Resource
  24. private IXxlJobLogGlueDao xxlJobLogGlueDao;
  25. @RequestMapping
  26. public String index(Model model, int jobId) {
  27. XxlJobInfo jobInfo = xxlJobInfoDao.loadById(jobId);
  28. List<XxlJobLogGlue> jobLogGlues = xxlJobLogGlueDao.findByJobId(jobId);
  29. if (jobInfo == null) {
  30. throw new RuntimeException("抱歉,任务不存在.");
  31. }
  32. model.addAttribute("jobInfo", jobInfo);
  33. model.addAttribute("jobLogGlues", jobLogGlues);
  34. return "jobcode/jobcode.index";
  35. }
  36. @RequestMapping("/save")
  37. @ResponseBody
  38. public ReturnT<String> save(Model model, int id, String glueSource, String glueRemark) {
  39. // valid
  40. if (glueRemark==null) {
  41. return new ReturnT<String>(500, "请输入备注");
  42. }
  43. if (glueRemark.length()<6 || glueRemark.length()>100) {
  44. return new ReturnT<String>(500, "备注长度应该在6至100之间");
  45. }
  46. XxlJobInfo exists_jobInfo = xxlJobInfoDao.loadById(id);
  47. if (exists_jobInfo == null) {
  48. return new ReturnT<String>(500, "参数异常");
  49. }
  50. // log old code
  51. XxlJobLogGlue xxlJobLogGlue = new XxlJobLogGlue();
  52. xxlJobLogGlue.setJobId(exists_jobInfo.getId());
  53. xxlJobLogGlue.setGlueType(exists_jobInfo.getGlueType());
  54. xxlJobLogGlue.setGlueSource(exists_jobInfo.getGlueSource());
  55. xxlJobLogGlue.setGlueRemark(exists_jobInfo.getGlueRemark());
  56. xxlJobLogGlueDao.save(xxlJobLogGlue);
  57. // update new code
  58. exists_jobInfo.setGlueSource(glueSource);
  59. exists_jobInfo.setGlueRemark(glueRemark);
  60. exists_jobInfo.setGlueUpdatetime(new Date());
  61. xxlJobInfoDao.update(exists_jobInfo);
  62. // remove code backup more than 30
  63. xxlJobLogGlueDao.removeOld(exists_jobInfo.getId(), 30);
  64. return ReturnT.SUCCESS;
  65. }
  66. }