From a01eec9f761ffcc11d42da0a82595e720427dd68 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 24 六月 2025 23:15:52 +0800
Subject: [PATCH] 望铁关口触发边界

---
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java |   54 +++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 45 insertions(+), 9 deletions(-)

diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java
index efd7117..f63f9e1 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java
@@ -324,7 +324,7 @@
         // 修正计划数据
         LinkedHashMap<String, List<String[]>> predData = new LinkedHashMap<>();
         for (int i = 0; i < reqVO.getPlanCodes().size(); i++) {
-            predData.put(reqVO.getPlanCodes().get(i), getPrePlanData(reqVO.getPlanPreds().get(i), predictTime, endTime));
+            predData.put(reqVO.getPlanCodes().get(i), getPrePlanData(reqVO.getPlanPreds().get(i), startTime, endTime, predictTime));
         }
         result.put("planData", planData);
         result.put("predData", predData);
@@ -366,25 +366,61 @@
     }
 
     //修正计划
-    public List<String[]> getPrePlanData(String charCode, Date startTime, Date endTime) {
+    public List<String[]> getPrePlanData(String charCode, Date startTime, Date endTime, Date predictTime) {
         List<String[]> result = new ArrayList<>();
         PreDataSingleChartReqVO queryDto = new PreDataSingleChartReqVO();
         queryDto.setChartCode(charCode);
         queryDto.setStartTime(startTime);
         queryDto.setEndTime(endTime);
         PreDataSingleChartRespVO chartData = mcsApi.getPreDataSingleChart(queryDto);
-        if (CollectionUtils.isEmpty(chartData.getDataView().getPreDataN())) {
+        if (CollectionUtils.isEmpty(chartData.getDataView().getCurData())) {
             return result;
+        }
+        String lineType = chartData.getDataView().getLineType();
+        List<Object[]> preData = new ArrayList<>();
+        if ("1".equals(lineType)) {
+            // 两部分组成,左侧T+L,右侧当前
+            if(!CollectionUtils.isEmpty(chartData.getDataView().getPreDataL())) {
+                for (int i = 0; i < chartData.getDataView().getPreDataL().size(); i++) {
+                    Object[] dataItem = chartData.getDataView().getPreDataL().get(i);
+                    Date t = DateUtils.parse(dataItem[0].toString(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
+                    if (t.getTime() <= predictTime.getTime()) {
+                        preData.add(dataItem);
+                    }
+                }
+            }
+            if(!CollectionUtils.isEmpty(chartData.getDataView().getCurData())) {
+                for (int i = 0; i < chartData.getDataView().getCurData().size(); i++) {
+                    Object[] dataItem = chartData.getDataView().getCurData().get(i);
+                    preData.add(dataItem);
+                }
+            }
+        } else if ("2".equals(lineType)) {
+            // 展示当前值
+            if(!CollectionUtils.isEmpty(chartData.getDataView().getCurData())) {
+                for (int i = 0; i < chartData.getDataView().getCurData().size(); i++) {
+                    Object[] dataItem = chartData.getDataView().getCurData().get(i);
+                    preData.add(dataItem);
+                }
+            }
+        } else {
+            // 展示T+N
+            if(!CollectionUtils.isEmpty(chartData.getDataView().getPreDataN())) {
+                for (int i = 0; i < chartData.getDataView().getPreDataN().size(); i++) {
+                    Object[] dataItem = chartData.getDataView().getPreDataN().get(i);
+                    preData.add(dataItem);
+                }
+            }
         }
 
         double lastValue = 0;
-        for (int i = 0; i < chartData.getDataView().getPreDataN().size(); i++) {
-            Object[] dataItem = chartData.getDataView().getPreDataN().get(i);
+        for (int i = 0; i < preData.size(); i++) {
+            Object[] dataItem = preData.get(i);
             double cv = new BigDecimal(dataItem[1].toString()).doubleValue();
             if (cv == 1 && cv != lastValue) {
                 String[] sa = new String[3];
                 sa[0] = (String) dataItem[0];
-                sa[1] = getEndTime(chartData.getDataView().getPreDataN(), i);
+                sa[1] = getEndTime(preData, i);
                 sa[2] = "2";
                 result.add(sa);
             }
@@ -393,11 +429,11 @@
         return result;
     }
 
-    private String getEndTime(List<Object[]> preDataN, int startIndex) {
+    private String getEndTime(List<Object[]> preData, int startIndex) {
         String endTime = "";
         double lastValue = 1;
-        for (int i = startIndex; i < preDataN.size(); i++) {
-            Object[] dataItem = preDataN.get(i);
+        for (int i = startIndex; i < preData.size(); i++) {
+            Object[] dataItem = preData.get(i);
             double cv = new BigDecimal(dataItem[1].toString()).doubleValue();
             if (cv == 0 && cv != lastValue) {
                 return (String) dataItem[0];

--
Gitblit v1.9.3