package com.xt.dsp.controller; import java.util.Date; import java.util.List; import org.h2.util.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import com.xt.dsp.common.BaseAction; import com.xt.dsp.common.util.CommonUtil; import com.xt.dsp.common.util.DateUtil; import com.xt.dsp.model.JobBean; import com.xt.dsp.service.JobService; import com.xt.dsp.vo.JobVo; import com.yuanxd.tools.pagehelper.PageHelper; import com.yuanxd.tools.pagehelper.PageInfo; @Controller @RequestMapping("job") public class JobCtl extends BaseAction { @Autowired private JobService jobService; @RequestMapping("reschedule/{code}") @ResponseBody public int rescheduleJob(@PathVariable String code) { JobBean job = jobService.selectByCode(code); return jobService.rescheduleJob(job); } /** * 主画面 * * @return */ @RequestMapping("main") public String main() { return "rwgl/job/job"; } /** * 初始化页面加载数据 */ @RequestMapping("initJob") @ResponseBody public PageInfo initJob(Model model, JobVo vo) { // 初始化参数 if (vo.getPage() < 1) { vo.setPage(1); } if (vo.getRows() < 1) { vo.setRows(1); } PageHelper.startPage(vo.getPage(), vo.getRows()); List list = jobService.queryAllJobBean(); PageInfo pageResult = new PageInfo<>(list); return pageResult; } /** * 保存实体 * * @param vo * @return */ @RequestMapping("save") @ResponseBody public JobBean saveJob(Model model, JobVo vo) { JobBean saveBean = new JobBean(); // 新增 if (StringUtils.isNullOrEmpty(vo.getId())) { BeanUtils.copyProperties(vo, saveBean); saveBean.setId(CommonUtil.getUUID()); saveBean.setCreateTime(new Date()); saveBean.setStartTime(DateUtil.format(vo.getStartTime(), DateUtil.DATE_SECOND_FMT)); saveBean.setEndTime(DateUtil.format(vo.getEndTime(), DateUtil.DATE_SECOND_FMT)); // saveBean.setStatus("0"); } else { // 修改 saveBean = jobService.findOne(vo.getId()); saveBean.setName(vo.getName()); saveBean.setCode(vo.getCode()); saveBean.setStartTime(DateUtil.format(vo.getStartTime(), DateUtil.DATE_SECOND_FMT)); saveBean.setEndTime(DateUtil.format(vo.getEndTime(), DateUtil.DATE_SECOND_FMT)); saveBean.setCircle(vo.getCircle()); saveBean.setParam(vo.getParam()); saveBean.setInterval(vo.getInterval()); saveBean.setResult(vo.getResult()); saveBean.setCronExpression(vo.getCronExpression()); } jobService.save(saveBean); return saveBean; } /** * 初始化页面加载数据 */ @RequestMapping("initEditJob") @ResponseBody public JobBean initEditJob(Model model, String id) { JobBean bean = jobService.findOne(id); return bean; } /** * 删除数据 */ @RequestMapping("delJob") @ResponseBody public JobBean delJob(Model model, String ids) { JobBean bean = jobService.findOne(ids); return bean; } /** * 启用数据 */ @RequestMapping("enableJob") @ResponseBody public JobBean enableJob(Model model, String ids) { JobBean bean = jobService.findOne(ids); jobService.addJob(bean); return bean; } /** * 停止数据 */ @RequestMapping("stopJob") @ResponseBody public JobBean stopJob(Model model, String ids) { JobBean bean = jobService.findOne(ids); jobService.deleteJob(bean); return bean; } /** * 暂停数据 */ @RequestMapping("pauseJob") @ResponseBody public JobBean pauseJob(Model model, String ids) { JobBean bean = jobService.findOne(ids); jobService.pauseJob(bean); return bean; } /** * 恢复数据 */ @RequestMapping("renewJob") @ResponseBody public JobBean renewJob(Model model, String ids) { JobBean bean = jobService.findOne(ids); jobService.resumeJob(bean); return bean; } /** * 获取工作下拉数据 */ @RequestMapping("getJobForDdl") @ResponseBody public List getJobForDdl(Model model) { List list = jobService.queryAllJobBean(); return list; } }