disaster_sever/src/main/java/com/miniframe/bisiness/system/D00005Service.java

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.D00005BaseModel;
import com.miniframe.generate.comm.system.D_D00003_ROWS_RECODE;
import com.miniframe.generate.comm.system.D_D00005_ROWS_RECODE;
import com.miniframe.model.system.DAccident;
import com.miniframe.model.system.DSource;
import com.miniframe.model.system.DSourceSQLBuilder;
import com.miniframe.model.system.dao.DSourceMapper;
import com.miniframe.tools.CommonUtils;

/**
 * 基础系统,“灾情点源数据查询”逻辑处理（重新生成不覆盖）。
 */
public class D00005Service extends D00005BaseModel implements ExecProcessFlow {
	
	private static final long serialVersionUID = -7051358269847459502L;
		
	/**
	 * 基础系统,“灾情点源数据查询”业务核心处理
 	 */
	public void transExecute() throws Exception {
		Integer aid = this.getA_d00005().getAid();
		String  sType = this.getA_d00005().getStype();
		DSourceMapper dsm = UtilTools.getBean(DSourceMapper.class);
		DSourceSQLBuilder sb =new DSourceSQLBuilder();
		DSourceSQLBuilder.Criteria sc=sb.createCriteria();
		sc.andAidEqualTo(aid);
		sc.andSTypeEqualTo(sType);
		List<DSource> list = dsm.selectByExample(sb);
		List <D_D00005_ROWS_RECODE> rows = new ArrayList<>();
		for (DSource  ds: list) {
			D_D00005_ROWS_RECODE row = new D_D00005_ROWS_RECODE();
			row.setSid(ds.getId());
			row.setAid(ds.getAid());
			row.setPid(ds.getPid());
			row.setPname(ds.getPname());
			row.setStype(ds.getsType());
			row.setSite(CommonUtils.floatTodobule(ds.getSite()));
			rows.add(row);
		}
		this.getD_d00005().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();
	}

}