From 8b43a1a91c37676e6a1e506e211f60e3e238f669 Mon Sep 17 00:00:00 2001
From: dongyukun <1208714201@qq.com>
Date: 星期四, 20 二月 2025 16:23:48 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/McsApiImpl.java |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/McsApiImpl.java b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/McsApiImpl.java
index 3e8e7da..3ec5fef 100644
--- a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/McsApiImpl.java
+++ b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/McsApiImpl.java
@@ -259,6 +259,14 @@
                 viewDto.setMaxValue(new BigDecimal(values.stream().mapToDouble(Double::doubleValue).max().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
                 viewDto.setMinValue(new BigDecimal(values.stream().mapToDouble(Double::doubleValue).min().getAsDouble()).setScale(2, BigDecimal.ROUND_HALF_UP));
             }
+            //处理预测累计
+            if (output.getIscumulant() == 1) {
+                if (StringUtils.isNotBlank(output.getCumulpoint())) {
+                    viewDto.setCumulantRealData(getHisData(output.getCumulpoint(), startTime, endTime));
+                }
+                viewDto.setCumulantPreData(mmItemResultService.getData(output.getId() + CommonDict.CUMULANT_SUFFIX, startTime, endTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
+            }
+
             dataViewList.add(viewDto);
         }
         result.setStartTime(startTime);
@@ -316,7 +324,7 @@
                 viewDto.setRealData(getHisData(out.getPointid(), startTime, endTime));
             }
             viewDto.setPreDataN(mmItemResultService.getData(out.getId(), startTime, endTime, DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND));
-            //处理累计点
+            //处理预测累计
             if (out.getIscumulant() == 1) {
                 if (StringUtils.isNotBlank(out.getCumulpoint())) {
                     viewDto.setCumulantRealData(getHisData(out.getCumulpoint(), startTime, endTime));
@@ -386,7 +394,7 @@
         } else {
             dataView.setRealData(new ArrayList<>());
         }
-        dataView.setCurData(mmItemResultJsonService.getData(outPut.getId(), predictTime, timeFormat));
+        dataView.setCurData(mmItemResultJsonService.getData(outPut.getId(), predictTime, timeFormat, 3));
         dataView.setLineType(lineType.getCode());
         switch (lineType) {
             case TN:
@@ -529,6 +537,9 @@
      */
     private List<Object[]> getHisData(String pointId, Date startTime, Date endTime) {
         List<Object[]> result = new ArrayList<>();
+        if (StringUtils.isBlank(pointId)) {
+            return result;
+        }
         ApiPointDTO pointDTO = dataPointApi.getInfoById(pointId);
         ApiPointValueQueryDTO queryPointDto = new ApiPointValueQueryDTO();
         queryPointDto.setPointNo(pointDTO.getPointNo());

--
Gitblit v1.9.3