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 list = dsm.selectByExample(sb); List 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(); } }