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.ES0012BaseModel;
import com.miniframe.generate.comm.es.D_ES0009_ROWS_RECODE;
import com.miniframe.generate.comm.es.D_ES0012_ROWS_RECODE;
import com.miniframe.mappers.es.dao.EsMapper;
import com.miniframe.mappers.es.model.ProComAttDto;
import com.miniframe.model.es.*;
import com.miniframe.model.es.dao.EsProComMapper;
import com.miniframe.model.es.dao.EsUnitSysDelMapper;
import com.miniframe.model.es.dao.EsUnitSysUsMapper;

/**
 * 无锡发动机,“项目模拟数据组件属性查询”逻辑处理（重新生成不覆盖）。
 */
public class ES0012Service extends ES0012BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 无锡发动机,“项目模拟数据组件属性查询”业务核心处理
 	 */
	public void transExecute() throws Exception {
		EsUnitSysUsMapper sudao = UtilTools.getBean(EsUnitSysUsMapper.class);
		EsUnitSysUsSQLBuilder susb = new EsUnitSysUsSQLBuilder();
		EsUnitSysUsSQLBuilder.Criteria susc = susb.createCriteria();
		susc.andUidEqualTo(getA_eshead().getUserId());
		List<EsUnitSysUs> sus = sudao.selectByExample(susb);
		String sutId = "";
		if(sus ==null||sus.isEmpty()){//获取系统单位
			sutId="1";//系统单位
		}else{
			sutId=sus.get(0).getSutId();
		}

		String pid = this.getA_es0012().getPid();
		EsProComMapper pcdao = UtilTools.getBean(EsProComMapper.class);
		EsProComSQLBuilder pcsb = new EsProComSQLBuilder();
		EsProComSQLBuilder.Criteria pcsc = pcsb.createCriteria();
		pcsc.andPidEqualTo(pid);
		pcsc.andComIdEqualTo("-1");//模拟数据
		List<EsProCom> proComs = pcdao.selectByExample(pcsb);
		if(proComs!=null&&!proComs.isEmpty()){
			EsProCom pc= proComs.get(0);
			EsMapper esdao = UtilTools.getBean(EsMapper.class);
			List<ProComAttDto> dtos = esdao.selectPrComAttList(pc.getPcId());
			List<D_ES0012_ROWS_RECODE> rows = new ArrayList<>();
			for (ProComAttDto dto:dtos) {
				D_ES0012_ROWS_RECODE row = new D_ES0012_ROWS_RECODE();
				row.setPcaId(dto.getPcaId());
				row.setValue(dto.getValue());
				row.setUnit(dto.getUnit());
				row.setUnitType(dto.getUnitType());
				row.setName(dto.getName());
				row.setCode(dto.getCode());
				row.setValueType(dto.getValueType());
				row.setValueDef(dto.getValueDef());
				row.setDataType(dto.getDataType()==null?-1: dto.getDataType());
				row.setUnitDef(getUnitByGutIdAndStuId(dto.getUnitType(),sutId));
				rows.add(row);
			}
			this.getD_es0012().setRows(rows);
		}
	}
	private String getUnitByGutIdAndStuId(String gutId,String sutId){
		String unitValue = "";
		EsUnitSysDelMapper sddao = UtilTools.getBean(EsUnitSysDelMapper.class);
		EsUnitSysDelSQLBuilder sdsb = new EsUnitSysDelSQLBuilder();
		EsUnitSysDelSQLBuilder.Criteria sdcs =sdsb.createCriteria();
		sdcs.andGutIdEqualTo(gutId);
		sdcs.andSutIdEqualTo(sutId);
		List<EsUnitSysDel> dels = sddao.selectByExample(sdsb);
		if(dels !=null&&!dels.isEmpty()){//获取单位
			unitValue=dels.get(0).getValue();
		}
		return unitValue;
	}
	/**
	 * 无锡发动机,“项目模拟数据组件属性查询”业务前处理
 	 */
	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();
	}

}