D10010Service.java 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  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.D10010BaseModel;
  8. import com.miniframe.generate.comm.system.D_D10010_ROWS_RECODE;
  9. import com.miniframe.model.system.DSensor;
  10. import com.miniframe.model.system.DSensorSQLBuilder;
  11. import com.miniframe.model.system.dao.DSensorMapper;
  12. import com.miniframe.tools.CommonUtils;
  13. import tk.mybatis.mapper.util.StringUtil;
  14. /**
  15. * 基础系统,“传感器数据查询”逻辑处理(重新生成不覆盖)。
  16. */
  17. public class D10010Service extends D10010BaseModel implements ExecProcessFlow {
  18. private static final long serialVersionUID = -7051358269847459502L;
  19. /**
  20. * 基础系统,“传感器数据查询”业务核心处理
  21. */
  22. public void transExecute() throws Exception {
  23. String type =this.getA_d10010().getType();
  24. DSensorMapper sensorDao = UtilTools.getBean(DSensorMapper.class);
  25. DSensorSQLBuilder sb =new DSensorSQLBuilder();
  26. DSensorSQLBuilder.Criteria sc =sb.createCriteria();
  27. if(StringUtil.isEmpty(type)){
  28. sc.andTypeLike("%"+type+"%");
  29. }
  30. List<DSensor> dSensorList = sensorDao.selectByExample(sb);
  31. List<D_D10010_ROWS_RECODE> rows =new ArrayList<>();
  32. for (DSensor s: dSensorList) {
  33. D_D10010_ROWS_RECODE row =new D_D10010_ROWS_RECODE();
  34. row.setSeid(s.getId());
  35. row.setPid(s.getPid());
  36. row.setSite(CommonUtils.floatTodobule(s.getSite()));
  37. row.setType(s.getType());
  38. row.setPname(s.getPname());
  39. rows.add(row);
  40. }
  41. this.getD_d10010().setRows(rows);
  42. this.getD_d10010().setTotal(rows.size());
  43. }
  44. /**
  45. * 基础系统,“传感器数据查询”业务前处理
  46. */
  47. public void preTransFlow() throws Exception {
  48. this.validater();
  49. }
  50. /**
  51. * 基础系统,“传感器数据查询”业务后处理
  52. */
  53. public void afterTransFlow() throws Exception {
  54. }
  55. /**
  56. * 基础系统,“传感器数据查询”逻辑入口处理方法
  57. */
  58. @SuppressWarnings("rawtypes")
  59. @Override
  60. public Map execute(Map vars) throws Exception {
  61. this.setTransMap(vars);
  62. preTransFlow();// 执行业务开始的规则检查和校验
  63. transExecute();// 执行核心业务段
  64. afterTransFlow();// 执行核心逻辑完成后的收尾逻辑
  65. return this.getTransMap();
  66. }
  67. }