D20010Service.java 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  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.D20010BaseModel;
  8. import com.miniframe.generate.comm.system.D_D20010_ROWS_RECODE;
  9. import com.miniframe.model.system.DVentdoor;
  10. import com.miniframe.model.system.DVentdoorSQLBuilder;
  11. import com.miniframe.model.system.dao.DVentdoorMapper;
  12. import com.miniframe.tools.CommonUtils;
  13. /**
  14. * 基础系统,“风门查询”逻辑处理(重新生成不覆盖)。
  15. */
  16. public class D20010Service extends D20010BaseModel implements ExecProcessFlow {
  17. private static final long serialVersionUID = -7051358269847459502L;
  18. /**
  19. * 基础系统,“风门查询”业务核心处理
  20. */
  21. public void transExecute() throws Exception {
  22. Integer aid =this.getA_d20010().getAid();
  23. DVentdoorMapper doorDao = UtilTools.getBean(DVentdoorMapper.class);
  24. DVentdoorSQLBuilder sb =new DVentdoorSQLBuilder();
  25. DVentdoorSQLBuilder.Criteria sc =sb.createCriteria();
  26. sc.andAidEqualTo(aid);
  27. List<DVentdoor> doors = doorDao.selectByExample(sb);
  28. List<D_D20010_ROWS_RECODE> rows =new ArrayList<>();
  29. for (DVentdoor d:doors) {
  30. D_D20010_ROWS_RECODE row =new D_D20010_ROWS_RECODE();
  31. row.setDoorid(d.getId());
  32. row.setDoorname(d.getName());
  33. row.setDragcoe(CommonUtils.floatTodobule(d.getDragcoe()));
  34. row.setAid(aid);
  35. row.setPid(d.getPid());
  36. row.setPcode(d.getPcode());
  37. row.setPname(d.getPname());
  38. row.setOnoff(d.getOnoff());
  39. row.setSite(CommonUtils.floatTodobule(d.getSite()));
  40. row.setDoorcode(d.getCode());
  41. row.setDoorbaseid(d.getDoorbaseid());
  42. rows.add(row);
  43. }
  44. this.getD_d20010().setRows(rows);
  45. }
  46. /**
  47. * 基础系统,“风门查询”业务前处理
  48. */
  49. public void preTransFlow() throws Exception {
  50. this.validater();
  51. }
  52. /**
  53. * 基础系统,“风门查询”业务后处理
  54. */
  55. public void afterTransFlow() throws Exception {
  56. }
  57. /**
  58. * 基础系统,“风门查询”逻辑入口处理方法
  59. */
  60. @SuppressWarnings("rawtypes")
  61. @Override
  62. public Map execute(Map vars) throws Exception {
  63. this.setTransMap(vars);
  64. preTransFlow();// 执行业务开始的规则检查和校验
  65. transExecute();// 执行核心业务段
  66. afterTransFlow();// 执行核心逻辑完成后的收尾逻辑
  67. return this.getTransMap();
  68. }
  69. }