package com.miniframe.bisiness.es;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import com.miniframe.core.ExecProcessFlow;
import com.miniframe.core.ext.UtilTools;
import com.miniframe.generate.business.es.model.ES0014BaseModel;
import com.miniframe.generate.comm.es.D_ES0009_ROWS_RECODE;
import com.miniframe.generate.comm.es.D_ES0014_ROWS_RECODE;
import com.miniframe.mappers.es.dao.EsMapper;
import com.miniframe.model.es.EsProComAttDataSQLBuilder;
import com.miniframe.model.es.EsProJob;
import com.miniframe.model.es.EsProJobSQLBuilder;
import com.miniframe.model.es.dao.EsProJobMapper;
import com.miniframe.tools.XIDateTimeUtils;

/**
 * 无锡发动机,“任务查询”逻辑处理（重新生成不覆盖）。
 */
public class ES0014Service extends ES0014BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 无锡发动机,“任务查询”业务核心处理
 	 */
	public void transExecute() throws Exception {
		String pid = this.getA_es0014().getPid();
		/*
		EsMapper epjmapper = UtilTools.getBean(EsMapper.class);
		List<EsProJob> jobList = epjmapper.selectEsProJobList(pid);*/

		EsProJobSQLBuilder builder = new EsProJobSQLBuilder();
		EsProJobSQLBuilder.Criteria epjsbc = builder.createCriteria();
		epjsbc.andPidEqualTo(pid);
		builder.setOrderByClause("ser asc");
		EsProJobMapper mapper = UtilTools.getBean(EsProJobMapper.class);
		List<EsProJob> jobList = mapper.selectByExample(builder);

		List<D_ES0014_ROWS_RECODE> rows = new ArrayList<>();
		for(EsProJob job:jobList){
			D_ES0014_ROWS_RECODE row = new D_ES0014_ROWS_RECODE();
			row.setJobId(job.getJobId());
			row.setStartTime(XIDateTimeUtils.getStrFromDate(job.getStartTime()));
			row.setEndTime(XIDateTimeUtils.getStrFromDate(job.getEndTime()));
			row.setSer(job.getSer());
			row.setUid(job.getUid());
			row.setCreateTime(XIDateTimeUtils.getStrFromDate(job.getCreateTime()));
			row.setUpdateTime(XIDateTimeUtils.getStrFromDate(job.getUpdateTime()));
			row.setRemark(job.getRemark());
			rows.add(row);
		}
		this.getD_es0014().setRows(rows);
	}
	
	/**
	 * 无锡发动机,“任务查询”业务前处理
 	 */
	public void preTransFlow() throws Exception {
		this.validater();
	}
	
	/**
	 * 无锡发动机,“任务查询”业务后处理
 	 */
	public void afterTransFlow() throws Exception {
	
	}
	
	/**
	 * 无锡发动机,“任务查询”逻辑入口处理方法
 	 */
 	@SuppressWarnings("rawtypes")
	@Override
	public Map execute(Map vars) throws Exception {
		this.setTransMap(vars);
		preTransFlow();// 执行业务开始的规则检查和校验
		transExecute();// 执行核心业务段
		afterTransFlow();// 执行核心逻辑完成后的收尾逻辑
		return this.getTransMap();
	}

}