From 85988421613383c029a25f1e21dfe8dd09cc562c Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期二, 14 一月 2025 15:29:14 +0800 Subject: [PATCH] queryMathPointCurrentValue --- iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/api/point/DataPointApiImpl.java | 34 ++++++++++++++++++++-------------- 1 files changed, 20 insertions(+), 14 deletions(-) diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/api/point/DataPointApiImpl.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/api/point/DataPointApiImpl.java index aca9940..ec00fd4 100644 --- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/api/point/DataPointApiImpl.java +++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/api/point/DataPointApiImpl.java @@ -13,6 +13,7 @@ import com.iailab.module.data.point.dto.DaPointWriteValueDTO; import com.iailab.module.data.point.service.DaMathPointService; import com.iailab.module.data.point.service.DaPointService; +import com.iailab.module.data.point.vo.DaPointPageReqVO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.CollectionUtils; import org.springframework.validation.annotation.Validated; @@ -139,22 +140,27 @@ } @Override - public PageResult<ApiPointDTO> getPageByNo(String pointNo) { - DaPointDTO daPointDTO = daPointService.getSimpleInfoByNo(pointNo); + public PageResult<ApiPointDTO> queryMathPointCurrentValue(ApiPointPageReqVO reqVO) { + DaPointDTO daPointDTO = daPointService.getSimpleInfoByNo(reqVO.getPointNo()); DaMathPointDTO daMathPointDTO = daMathPointService.getByPoint(daPointDTO.getId()); String[] pointNos = daMathPointDTO.getExpression().split("[-+]+"); - HashMap<Integer, String> map = new HashMap<>(); - IntStream.range(0, pointNos.length).forEach(i -> map.put(i, pointNos[i])); - List<String> pointNosL = new ArrayList<>(); - for (String value : map.values()) { - pointNosL.add(value); - } - PageResult<ApiPointDTO> pageResult = daPointService.getPointPage(map); - Map<String, Object> CurrentValueMap = pointCollector.getCurrentValue(pointNosL); - pageResult.getList().stream().map(item -> { - item.setCurrentValue(CurrentValueMap.get(item.getPointNo())); - return item; + DaPointPageReqVO pageReqVO = new DaPointPageReqVO(); + pageReqVO.setPageNo(reqVO.getPageNo()); + pageReqVO.setPageSize(reqVO.getPageSize()); + pageReqVO.setPointNos(Arrays.asList(pointNos)); + PageResult<DaPointDTO> pageResult = daPointService.queryPage(pageReqVO); + List<String> pointNosL = pageResult.getList().stream().map(item -> { + return item.getPointNo(); }).collect(Collectors.toList()); - return pageResult; + Map<String, Object> currentValueMap = pointCollector.getCurrentValue(pointNosL); + + List<ApiPointDTO> dataList = new ArrayList<>(); + pageResult.getList().forEach(item -> { + ApiPointDTO dto = new ApiPointDTO(); + dto.setPointNo(item.getPointNo()); + dto.setPointName(item.getPointName()); + dto.setCurrentValue(currentValueMap.get(item.getPointNo()).toString()); + }); + return new PageResult<>(dataList, pageResult.getTotal()); } } \ No newline at end of file -- Gitblit v1.9.3