| | |
|---|
| | | rsVo.obj = rmOpenCloseValveHistoryMapper.getLargeOpenCountClients(params); |
|---|
| | | return rsVo ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取指定时间段内开阀次数低于指定值的农户 |
|---|
| | | * @param qo |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public QueryResultVo<List<VoClient>> getSmallOpenCountClients(OpenCountQO qo) { |
|---|
| | | /** |
|---|
| | | * 补齐起止时间，如果开始时间为空，则默认为当前日期 |
|---|
| | | */ |
|---|
| | | String timeStart = qo.getTimeStart(); |
|---|
| | | String timeStop = qo.getTimeStop(); |
|---|
| | | if(timeStart != null) { |
|---|
| | | timeStart = timeStart + " 00:00:00"; |
|---|
| | | }else { |
|---|
| | | timeStart = LocalDate.now() + " 00:00:00"; |
|---|
| | | } |
|---|
| | | if(timeStop != null) { |
|---|
| | | timeStop = timeStop + " 23:59:59"; |
|---|
| | | } |
|---|
| | | qo.setTimeStart(timeStart); |
|---|
| | | qo.setTimeStop(timeStop); |
|---|
| | | |
|---|
| | | // 生成查询参数 |
|---|
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ; |
|---|
| | | |
|---|
| | | // 获取符合条件的记录数 |
|---|
| | | Long itemTotal = Optional.ofNullable(rmOpenCloseValveHistoryMapper.getSmallOpenCountClientsCount(params)).orElse(0L); |
|---|
| | | |
|---|
| | | QueryResultVo<List<VoClient>> rsVo = new QueryResultVo<>() ; |
|---|
| | | |
|---|
| | | rsVo.pageSize = qo.pageSize ; |
|---|
| | | rsVo.pageCurr = qo.pageCurr ; |
|---|
| | | |
|---|
| | | rsVo.calculateAndSet(itemTotal, params); |
|---|
| | | rsVo.obj = rmOpenCloseValveHistoryMapper.getSmallOpenCountClients(params); |
|---|
| | | return rsVo ; |
|---|
| | | } |
|---|
| | | } |
|---|
