package com.miniframe.bisiness.system;

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.system.model.D00003BaseModel;
import com.miniframe.generate.comm.system.D_D00001_ROWS_RECODE;
import com.miniframe.generate.comm.system.D_D00003_ROWS_RECODE;
import com.miniframe.model.system.DAccident;
import com.miniframe.model.system.DAccidentSQLBuilder;
import com.miniframe.model.system.DPipe;
import com.miniframe.model.system.DPipeSQLBuilder;
import com.miniframe.model.system.dao.DAccidentMapper;
import com.miniframe.model.system.dao.DPipeMapper;
import com.miniframe.tools.XIUtils;
import tk.mybatis.mapper.util.StringUtil;

/**
 * 基础系统,“事故数据查询”逻辑处理（重新生成不覆盖）。
 */
public class D00003Service extends D00003BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 基础系统,“事故数据查询”业务核心处理
 	 */
	public void transExecute() throws Exception {
		Integer page = this.getA_d00003().getPage();
		Integer size = this.getA_d00003().getCount();
		String source =this.getA_d00003().getSource();
		String sid=this.getA_d00003().getSid();
		Integer aid =this.getA_d00003().getAid();
		String stype =this.getA_d00003().getStype();
		String searchtag =this.getA_d00003().getSearchtag();
		DAccidentMapper projectDao  = UtilTools.getBean(DAccidentMapper.class);
		DAccidentSQLBuilder sb =new DAccidentSQLBuilder();

		if(!StringUtil.isEmpty(searchtag)){
			DAccidentSQLBuilder.Criteria sc1 =sb.createCriteria();
			sc1.andNameLike("%"+searchtag+"%");
		}
		if(!StringUtil.isEmpty(source)&&!StringUtil.isEmpty(sid)){
			DAccidentSQLBuilder.Criteria sc1 =sb.createCriteria();
			sc1.andSidEqualTo(sid);
			sc1.andSourceEqualTo(source);
		}
		if(!StringUtil.isEmpty(stype)){
			DAccidentSQLBuilder.Criteria sc1 =sb.createCriteria();
			sc1.andStypeEqualTo(stype);
		}
		if(aid!=null&&aid!=0){
			DAccidentSQLBuilder.Criteria sc1 =sb.createCriteria();
			sc1.andIdEqualTo(aid);
		}


		int count = projectDao.selectCountByExample(sb);
//		sb.setOrderByClause("id");
		sb.setOrderByClause("time desc");

		XIUtils.pageSet(page,size);
		List<DAccident> list = projectDao.selectByExample(sb);
		List <D_D00003_ROWS_RECODE> rows = new ArrayList<>();
		for (DAccident  dp: list) {
			D_D00003_ROWS_RECODE row = new D_D00003_ROWS_RECODE();
			row.setAid(dp.getId());
			row.setName(dp.getName());
			row.setSid(dp.getSid());
			row.setSource(dp.getSource());
			row.setTime(dp.getTime());
			row.setType(dp.getType());
			row.setStype(dp.getStype());
			rows.add(row);
		}
		this.getD_d00003().setRows(rows);
		this.getD_d00003().setTotal(count);
	}
	
	/**
	 * 基础系统,“事故数据查询”业务前处理
 	 */
	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();
	}

}