diff --git a/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/timer/QxtrTask.java b/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/timer/QxtrTask.java index 50cb57f..54d24d1 100644 --- a/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/timer/QxtrTask.java +++ b/fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/timer/QxtrTask.java @@ -73,8 +73,7 @@ public class QxtrTask { for (Device item : deviceList) { MaWatereleRecord maWatereleRecord = new MaWatereleRecord(); maWatereleRecord.setDevSn(item.getSerialNumber()); - TableDataInfo tableDataInfo = watereleRecordService.selectMaWatereleRecordList(maWatereleRecord); - List list = (List) tableDataInfo.getRows(); + List list = watereleRecordService.getList(maWatereleRecord); int status = 4; if(list.size() > 0){ MaWatereleRecord record = list.get(0); @@ -87,6 +86,8 @@ public class QxtrTask { } } + + /** * 定时任务 流量计设备 */ diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java index 6325170..841e57f 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/IMaWatereleRecordService.java @@ -31,6 +31,7 @@ public interface IMaWatereleRecordService */ public TableDataInfo selectMaWatereleRecordList(MaWatereleRecord maWatereleRecord); + List getList(MaWatereleRecord maWatereleRecord); /** * 新增水电双计数据记录 * diff --git a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java index f0f498c..f144c1a 100644 --- a/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java +++ b/fastbee-service/fastbee-waterele-service/src/main/java/com/fastbee/waterele/service/impl/MaWatereleRecordServiceImpl.java @@ -1,6 +1,7 @@ package com.fastbee.waterele.service.impl; import java.util.*; +import java.util.function.Function; import cn.hutool.core.util.NumberUtil; import cn.hutool.http.HttpUtil; @@ -51,7 +52,28 @@ public class MaWatereleRecordServiceImpl implements IMaWatereleRecordService @Override public TableDataInfo selectMaWatereleRecordList(MaWatereleRecord maWatereleRecord) { - // + List list = getList(maWatereleRecord); + PageDomain pageDomain = TableSupport.buildPageRequest(); + Integer pageNum = pageDomain.getPageNum(); + Integer pageSize = pageDomain.getPageSize(); + List subList = new ArrayList<>(); + if(list.size() > (pageNum-1)*pageSize){ + if(list.size() < pageNum*pageSize){ + subList = list.subList((pageNum-1)*pageSize, list.size()); + }else{ + subList = list.subList((pageNum-1)*pageSize, pageNum*pageSize); + } + } + TableDataInfo tableDataInfo = new TableDataInfo(); + tableDataInfo.setMsg("获取成功"); + tableDataInfo.setTotal(list.size()); + tableDataInfo.setRows(subList); + tableDataInfo.setCode(200); + return tableDataInfo; + } + + @Override + public List getList(MaWatereleRecord maWatereleRecord){ Long endTime = 0L; Long startTime = 0L; if(null == maWatereleRecord.getParams()){ @@ -124,24 +146,7 @@ public class MaWatereleRecordServiceImpl implements IMaWatereleRecordService } } } - // - PageDomain pageDomain = TableSupport.buildPageRequest(); - Integer pageNum = pageDomain.getPageNum(); - Integer pageSize = pageDomain.getPageSize(); - List subList = new ArrayList<>(); - if(list.size() > (pageNum-1)*pageSize){ - if(list.size() < pageNum*pageSize){ - subList = list.subList((pageNum-1)*pageSize, list.size()); - }else{ - subList = list.subList((pageNum-1)*pageSize, pageNum*pageSize); - } - } - TableDataInfo tableDataInfo = new TableDataInfo(); - tableDataInfo.setMsg("获取成功"); - tableDataInfo.setTotal(list.size()); - tableDataInfo.setRows(subList); - tableDataInfo.setCode(200); - return tableDataInfo; + return list; } /**