D00005Service.java 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. package com.miniframe.bisiness.system;
  2. import java.util.ArrayList;
  3. import java.util.List;
  4. import java.util.Map;
  5. import com.miniframe.core.ExecProcessFlow;
  6. import com.miniframe.core.ext.UtilTools;
  7. import com.miniframe.generate.business.system.model.D00005BaseModel;
  8. import com.miniframe.generate.comm.system.D_D00003_ROWS_RECODE;
  9. import com.miniframe.generate.comm.system.D_D00005_ROWS_RECODE;
  10. import com.miniframe.model.system.DAccident;
  11. import com.miniframe.model.system.DSource;
  12. import com.miniframe.model.system.DSourceSQLBuilder;
  13. import com.miniframe.model.system.dao.DSourceMapper;
  14. import com.miniframe.tools.CommonUtils;
  15. /**
  16. * 基础系统,“灾情点源数据查询”逻辑处理(重新生成不覆盖)。
  17. */
  18. public class D00005Service extends D00005BaseModel implements ExecProcessFlow {
  19. private static final long serialVersionUID = -7051358269847459502L;
  20. /**
  21. * 基础系统,“灾情点源数据查询”业务核心处理
  22. */
  23. public void transExecute() throws Exception {
  24. Integer aid = this.getA_d00005().getAid();
  25. DSourceMapper dsm = UtilTools.getBean(DSourceMapper.class);
  26. DSourceSQLBuilder sb =new DSourceSQLBuilder();
  27. DSourceSQLBuilder.Criteria sc=sb.createCriteria();
  28. sc.andAidEqualTo(aid);
  29. List<DSource> list = dsm.selectByExample(sb);
  30. List <D_D00005_ROWS_RECODE> rows = new ArrayList<>();
  31. for (DSource ds: list) {
  32. D_D00005_ROWS_RECODE row = new D_D00005_ROWS_RECODE();
  33. row.setSid(ds.getId());
  34. row.setAid(ds.getAid());
  35. row.setPid(ds.getPid());
  36. row.setPname(ds.getPname());
  37. row.setSite(CommonUtils.floatTodobule(ds.getSite()));
  38. rows.add(row);
  39. }
  40. this.getD_d00005().setRows(rows);
  41. }
  42. /**
  43. * 基础系统,“灾情点源数据查询”业务前处理
  44. */
  45. public void preTransFlow() throws Exception {
  46. this.validater();
  47. }
  48. /**
  49. * 基础系统,“灾情点源数据查询”业务后处理
  50. */
  51. public void afterTransFlow() throws Exception {
  52. }
  53. /**
  54. * 基础系统,“灾情点源数据查询”逻辑入口处理方法
  55. */
  56. @SuppressWarnings("rawtypes")
  57. @Override
  58. public Map execute(Map vars) throws Exception {
  59. this.setTransMap(vars);
  60. preTransFlow();// 执行业务开始的规则检查和校验
  61. transExecute();// 执行核心业务段
  62. afterTransFlow();// 执行核心逻辑完成后的收尾逻辑
  63. return this.getTransMap();
  64. }
  65. }