package com.xxl.job.controller;

import java.util.List;

import javax.annotation.Resource;

import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.xxl.job.core.model.ReturnT;
import com.xxl.job.core.model.XxlJobInfo;
import com.xxl.job.core.model.XxlJobLogGlue;
import com.xxl.job.dao.IXxlJobInfoDao;
import com.xxl.job.dao.IXxlJobLogGlueDao;

/**
 * job code controller
 * @author xuxueli 2015-12-19 16:13:16
 */
@Controller
@RequestMapping("/jobcode")
public class JobCodeController {
	
	@Resource
	private IXxlJobInfoDao xxlJobInfoDao;
	@Resource
	private IXxlJobLogGlueDao xxlJobLogGlueDao;

	@RequestMapping
	public String index(Model model, String jobGroup, String jobName) {
		XxlJobInfo jobInfo = xxlJobInfoDao.load(jobGroup, jobName);
		List<XxlJobLogGlue> jobLogGlues = xxlJobLogGlueDao.selectList(jobGroup, jobName);
		model.addAttribute("jobInfo", jobInfo);
		model.addAttribute("jobLogGlues", jobLogGlues);
		return "jobcode/index";
	}
	
	@RequestMapping("/save")
	@ResponseBody
	public ReturnT<String> save(Model model, String jobGroup, String jobName, String glueSource, String glueRemark) {
		// valid
		if (glueRemark==null) {
			return new ReturnT<String>(500, "请输入备注");
		}
		if (glueRemark.length()<6 || glueRemark.length()>100) {
			return new ReturnT<String>(500, "备注长度应该在6至100之间");
		}
		XxlJobInfo jobInfoOld = xxlJobInfoDao.load(jobGroup, jobName);
		if (jobInfoOld == null) {
			return new ReturnT<String>(500, "任务不存在");
		}
		
		// log old code
		XxlJobLogGlue xxlJobLogGlue = new XxlJobLogGlue();
		xxlJobLogGlue.setJobGroup(jobInfoOld.getJobGroup());
		xxlJobLogGlue.setJobName(jobInfoOld.getJobName());
		xxlJobLogGlue.setGlueSource(jobInfoOld.getGlueSource());
		xxlJobLogGlue.setGlueRemark(jobInfoOld.getGlueRemark());
		
		// init new code
		jobInfoOld.setGlueSource(glueSource);
		jobInfoOld.setGlueRemark(glueRemark);
		
		// update new code ,and log old code
		xxlJobInfoDao.update(jobInfoOld);
		if (StringUtils.isNotBlank(xxlJobLogGlue.getGlueSource()) && StringUtils.isNotBlank(xxlJobLogGlue.getGlueRemark())) {
			xxlJobLogGlueDao.save(xxlJobLogGlue);
			// remove code backup more than 30
			xxlJobLogGlueDao.removeOld(xxlJobLogGlue.getJobGroup(), xxlJobLogGlue.getJobName(), 3);
		}
		
		
		return ReturnT.SUCCESS;
	}
	
}