| | |
| | | import com.dy.pipIrrGlobal.daoPr.PrIntakeMapper; |
| | | import com.dy.pipIrrGlobal.daoRm.RmOpenCloseValveHistoryMapper; |
| | | import com.dy.pipIrrGlobal.pojoPr.PrIntake; |
| | | import com.dy.pipIrrGlobal.voPr.VoAllIntake; |
| | | import com.dy.pipIrrGlobal.voPr.VoOnLineIntake; |
| | | import com.dy.pipIrrGlobal.voRm.VoOpenClostWechat; |
| | | import com.dy.pipIrrWechat.intake.qo.OnLineIntakesQO; |
| | |
| | | @Autowired |
| | | public IntakeSv(Environment env) { |
| | | this.env = env; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 获取取水口列表 |
| | | * @return |
| | | */ |
| | | public QueryResultVo<List<VoOnLineIntake>> selectSomeIntakes(OnLineIntakesQO qo) { |
| | | // 如果 intakeNum 不为空,则转为小写再写入qo对象 |
| | | String intakeNum = qo.getIntakeNum(); |
| | | if(intakeNum != null) { |
| | | qo.setIntakeNum(intakeNum.toLowerCase()); |
| | | } |
| | | |
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ; |
| | | Long itemTotal = prIntakeMapper.getSomeIntakesCount4Wx(params); |
| | | |
| | | QueryResultVo<List<VoOnLineIntake>> rsVo = new QueryResultVo<>() ; |
| | | rsVo.pageSize = qo.pageSize ; |
| | | rsVo.pageCurr = qo.pageCurr ; |
| | | rsVo.calculateAndSet(itemTotal, params); |
| | | rsVo.obj = prIntakeMapper.getSomeIntakes4Wx(params); |
| | | return rsVo; |
| | | |
| | | } |
| | | |
| | | /** |
| | |
| | | * |
| | | * @return 所有取水口集合 |
| | | */ |
| | | public QueryResultVo<List<PrIntake>> selectAll() { |
| | | QueryResultVo<List<PrIntake>> rsVo = new QueryResultVo<>(); |
| | | public QueryResultVo<List<VoAllIntake>> selectAll() { |
| | | QueryResultVo<List<VoAllIntake>> rsVo = new QueryResultVo<>(); |
| | | rsVo.obj = this.prIntakeMapper.selectAll(); |
| | | return rsVo; |
| | | } |