jsgkj/xtdsp/trunk/src/main/java/com/xt/dsp/controller/JobCtl.java

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<JobBean> 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<JobBean> list = jobService.queryAllJobBean();
		PageInfo<JobBean> 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<JobBean> getJobForDdl(Model model) {
		List<JobBean> list = jobService.queryAllJobBean();
		return list;
	}
}