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.ES0001BaseModel;
import com.miniframe.generate.comm.es.D_ES0001_ROWS_RECODE;
import com.miniframe.model.es.EsPro;
import com.miniframe.model.es.dao.EsProMapper;
import com.miniframe.model.system.SysUser;
import com.miniframe.model.system.dao.SysUserMapper;
import com.miniframe.tools.XIDataUtils;
import com.miniframe.tools.XIDateTimeUtils;
import com.miniframe.tools.XIUtils;
import org.apache.commons.lang3.StringUtils;
import tk.mybatis.mapper.weekend.Weekend;
import tk.mybatis.mapper.weekend.WeekendCriteria;

/**
 * 无锡发动机,“项目查询”逻辑处理（重新生成不覆盖）。
 */
public class ES0001Service extends ES0001BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 无锡发动机,“项目查询”业务核心处理
 	 */
	public void transExecute() throws Exception {
		Integer count =this.getA_es0001().getCount();
		Integer page =this.getA_es0001().getPage();
		String searchtag =this.getA_es0001().getSearchtag();
		String uid = this.getA_eshead().getUserId();
//		SysUserMapper udao = UtilTools.getBean(SysUserMapper.class);
//		SysUser user = udao.selectByPrimaryKey(uid);
		EsProMapper proMapper = UtilTools.getBean(EsProMapper.class);
		Weekend<EsPro> weekend = new Weekend<>(EsPro.class);
		WeekendCriteria<EsPro, Object> keywordCriteria = weekend.weekendCriteria();
		if (StringUtils.isNotEmpty(searchtag)) {
			searchtag ="%"+searchtag+"%";
			keywordCriteria.orLike(EsPro::getName, searchtag)
					.orLike(EsPro::getRemark, searchtag);
		}
		keywordCriteria.andEqualTo(EsPro::getUid,uid);
		weekend.orderBy("createTime").desc();
		int total = proMapper.selectCountByExample(weekend);
		XIUtils.pageSet(page, count);
		List<EsPro>  eList = proMapper.selectByExample(weekend);
		List<D_ES0001_ROWS_RECODE> rows = new ArrayList<>();
		for (EsPro p :eList) {
			D_ES0001_ROWS_RECODE row = new D_ES0001_ROWS_RECODE();
			row.setUid(p.getUid());
			row.setPid(p.getPid());
			row.setCreateTime(XIDateTimeUtils.getStrFromDate(p.getCreateTime()));
			row.setUpdateTime(XIDateTimeUtils.getStrFromDate(p.getUpdateTime()));
			row.setUname(p.getUname());
			row.setFlow(p.getFlow());
			row.setName(p.getName());
			row.setRemark(p.getRemark());
			row.setDirsize(p.getSize());
			row.setKeywords(p.getKeywords());
			rows.add(row);
		}
		this.getD_es0001().setRows(rows);
		this.getD_es0001().setTotal(total);

	}
	
	/**
	 * 无锡发动机,“项目查询”业务前处理
 	 */
	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();
	}

}