From 656af501fe1ede8ff9cdc5e75f20eadcdc09f28e Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期三, 02 四月 2025 10:24:54 +0800
Subject: [PATCH] Merge branch 'master' of http://dlindusit.com:53929/r/ansteel

---
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/DataController.java   |   15 +++
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/DataApi.java                   |   11 +
 ansteel-biz/db/mysql.sql                                                                       |   50 +++++++++
 doc/鞍钢数据接口文档_dev_li.doc                                                                        |    0 
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PlanDataChartReqVO.java            |   11 +-
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexDayDao.java        |   12 ++
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexDayEntity.java  |   29 +++++
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexTeamEntity.java |   29 +++++
 ansteel-biz/src/main/resources/application.yaml                                                |    4 
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexTeamDao.java       |   12 ++
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/MainProcessIndexDTO.java           |   22 ++++
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java      |   98 ++++++++++---------
 doc/鞍钢数据接口文档_master.doc                                                                        |    0 
 13 files changed, 236 insertions(+), 57 deletions(-)

diff --git a/ansteel-biz/db/mysql.sql b/ansteel-biz/db/mysql.sql
index a943f56..89f4ec8 100644
--- a/ansteel-biz/db/mysql.sql
+++ b/ansteel-biz/db/mysql.sql
@@ -226,4 +226,52 @@
 CREATE INDEX IDX_QRTZ_FT_J_G ON QRTZ_FIRED_TRIGGERS (SCHED_NAME, JOB_NAME, JOB_GROUP);
 CREATE INDEX IDX_QRTZ_FT_JG ON QRTZ_FIRED_TRIGGERS (SCHED_NAME, JOB_GROUP);
 CREATE INDEX IDX_QRTZ_FT_T_G ON QRTZ_FIRED_TRIGGERS (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP);
-CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS (SCHED_NAME, TRIGGER_GROUP);
\ No newline at end of file
+CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS (SCHED_NAME, TRIGGER_GROUP);
+
+
+DROP TABLE IF EXISTS `t_main_process_index_day`;
+CREATE TABLE `t_main_process_index_day`  (
+                                             `id` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'id',
+                                             `index` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标',
+                                             `his_avg` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '历史平均',
+                                             `theory` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '理论值',
+                                             `actual` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实际值',
+                                             `real_data` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实时数据',
+                                             PRIMARY KEY (`id`) USING BTREE
+) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC;
+
+-- ----------------------------
+-- Records of t_main_process_index_day
+-- ----------------------------
+INSERT INTO `t_main_process_index_day` VALUES ('1', 'COG消耗', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_day` VALUES ('2', 'COG发生', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_day` VALUES ('3', 'BFG消耗', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_day` VALUES ('4', '蒸汽消耗', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_day` VALUES ('5', '蒸汽产生', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_day` VALUES ('6', '电力消耗', NULL, NULL, NULL, NULL);
+
+SET FOREIGN_KEY_CHECKS = 1;
+
+
+DROP TABLE IF EXISTS `t_main_process_index_team`;
+CREATE TABLE `t_main_process_index_team`  (
+                                              `id` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'id',
+                                              `index` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '指标',
+                                              `his_avg` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '历史平均',
+                                              `theory` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '理论值',
+                                              `actual` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实际值',
+                                              `real_data` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '实时数据',
+                                              PRIMARY KEY (`id`) USING BTREE
+) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = DYNAMIC;
+
+-- ----------------------------
+-- Records of t_main_process_index_team
+-- ----------------------------
+INSERT INTO `t_main_process_index_team` VALUES ('1', 'COG消耗', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_team` VALUES ('2', 'COG发生', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_team` VALUES ('3', 'BFG消耗', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_team` VALUES ('4', '蒸汽消耗', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_team` VALUES ('5', '蒸汽产生', NULL, NULL, NULL, NULL);
+INSERT INTO `t_main_process_index_team` VALUES ('6', '电力消耗', NULL, NULL, NULL, NULL);
+
+SET FOREIGN_KEY_CHECKS = 1;
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/DataController.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/DataController.java
index 169a5b3..65904c7 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/DataController.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/DataController.java
@@ -1,11 +1,14 @@
 package com.iailab.module.ansteel.api.controller.admin;
 
 import com.iailab.framework.common.pojo.CommonResult;
+import com.iailab.module.ansteel.api.dto.MainProcessIndexDTO;
 import com.iailab.module.ansteel.api.dto.PlanDataChartReqVO;
 import com.iailab.module.ansteel.api.dto.PowerRunStateDTO;
 import com.iailab.module.ansteel.api.dto.PreDataChartRespVO;
 import com.iailab.module.ansteel.api.service.DataApi;
 import com.iailab.module.model.api.mcs.dto.PreDataSingleChartReqVO;
+import com.iailab.module.model.api.mcs.dto.StAlarmAndSuggestReqVO;
+import com.iailab.module.model.api.mcs.dto.StAlarmAndSuggestRespVO;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -48,4 +51,16 @@
         return CommonResult.success(tMap);
     }
 
+    @GetMapping("/main-process-index/list")
+    @Operation(summary = "主工序指标")
+    public CommonResult<List<MainProcessIndexDTO>> getIndexList(@RequestParam Map<String, Object> params) {
+        List<MainProcessIndexDTO> list = dataApi.getIndexList(params);
+        return success(list);
+    }
+
+    @PostMapping("/schedule-suggest/update-status")
+    @Operation(summary = "修改建议状态")
+    public CommonResult<Boolean> updateSuggestStatus(@RequestBody StAlarmAndSuggestReqVO ReqVO) {
+        return success(dataApi.updateSuggestStatus(ReqVO));
+    }
 }
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexDayDao.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexDayDao.java
new file mode 100644
index 0000000..1e9988f
--- /dev/null
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexDayDao.java
@@ -0,0 +1,12 @@
+package com.iailab.module.ansteel.api.dao;
+
+import com.iailab.framework.common.dao.BaseDao;
+import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
+import com.iailab.module.ansteel.api.entity.MainProcessIndexDayEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+@TenantDS
+@Mapper
+public interface MainProcessIndexDayDao extends BaseDao<MainProcessIndexDayEntity> {
+
+}
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexTeamDao.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexTeamDao.java
new file mode 100644
index 0000000..3537c49
--- /dev/null
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dao/MainProcessIndexTeamDao.java
@@ -0,0 +1,12 @@
+package com.iailab.module.ansteel.api.dao;
+
+import com.iailab.framework.common.dao.BaseDao;
+import com.iailab.framework.tenant.core.db.dynamic.TenantDS;
+import com.iailab.module.ansteel.api.entity.MainProcessIndexTeamEntity;
+import org.apache.ibatis.annotations.Mapper;
+
+@TenantDS
+@Mapper
+public interface MainProcessIndexTeamDao extends BaseDao<MainProcessIndexTeamEntity> {
+
+}
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/MainProcessIndexDTO.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/MainProcessIndexDTO.java
new file mode 100644
index 0000000..8b5a1d2
--- /dev/null
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/MainProcessIndexDTO.java
@@ -0,0 +1,22 @@
+package com.iailab.module.ansteel.api.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author lirm
+ * @date 2025年03月13日
+ */
+@Data
+public class MainProcessIndexDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String id;
+    private String indexName;
+    private String hisAvg;
+    private String theory;
+    private String actual;
+    private String realData;
+}
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PlanDataChartReqVO.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PlanDataChartReqVO.java
index f4a91fb..a531b86 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PlanDataChartReqVO.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/dto/PlanDataChartReqVO.java
@@ -6,6 +6,7 @@
 
 import java.io.Serializable;
 import java.util.Date;
+import java.util.List;
 
 /**
  * @author lirm
@@ -16,7 +17,7 @@
 public class PlanDataChartReqVO implements Serializable {
     private static final long serialVersionUID = 1L;
 
-    @Schema(description = "图标编码")
+    @Schema(description = "图表编码")
     private String chartCode;
 
     @Schema(description = "开始时间")
@@ -25,9 +26,9 @@
     @Schema(description = "结束时间")
     private String endTime;
 
-    @Schema(description = "预测时间")
-    private String predictTime;
+    @Schema(description = "计划编码集合")
+    private List<String> planCodes;
 
-    @Schema(description = "右侧长度")
-    private int lengthRight;
+    @Schema(description = "图表编码集合")
+    private List<String> planPreds;
 }
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexDayEntity.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexDayEntity.java
new file mode 100644
index 0000000..fbb433e
--- /dev/null
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexDayEntity.java
@@ -0,0 +1,29 @@
+package com.iailab.module.ansteel.api.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @description: 主工序指标
+ * @author: lirm
+ * @date: 2025/03/13
+ **/
+@Data
+@TableName("t_main_process_index_day")
+public class MainProcessIndexDayEntity implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId
+    private String id;
+    private String indexName;
+    private String hisAvg;
+    private String theory;
+    private String actual;
+    private String realData;
+}
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexTeamEntity.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexTeamEntity.java
new file mode 100644
index 0000000..25613bd
--- /dev/null
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/entity/MainProcessIndexTeamEntity.java
@@ -0,0 +1,29 @@
+package com.iailab.module.ansteel.api.entity;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @description: 主工序指标
+ * @author: lirm
+ * @date: 2025/03/13
+ **/
+@Data
+@TableName("t_main_process_index_day")
+public class MainProcessIndexTeamEntity implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId
+    private String id;
+    private String indexName;
+    private String hisAvg;
+    private String theory;
+    private String actual;
+    private String realData;
+}
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/DataApi.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/DataApi.java
index 1bc0686..7bd2b1d 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/DataApi.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/DataApi.java
@@ -1,10 +1,9 @@
 package com.iailab.module.ansteel.api.service;
 
-import com.iailab.module.ansteel.api.dto.PlanDataChartReqVO;
-import com.iailab.module.ansteel.api.dto.PlanDataChartRespVO;
-import com.iailab.module.ansteel.api.dto.PowerRunStateDTO;
-import com.iailab.module.ansteel.api.dto.PreDataChartRespVO;
+import com.iailab.module.ansteel.api.dto.*;
 import com.iailab.module.model.api.mcs.dto.PreDataSingleChartReqVO;
+import com.iailab.module.model.api.mcs.dto.StAlarmAndSuggestReqVO;
+import com.iailab.module.model.api.mcs.dto.StAlarmAndSuggestRespVO;
 
 import java.util.List;
 import java.util.Map;
@@ -21,4 +20,8 @@
     PreDataChartRespVO getPreDataChart(PreDataSingleChartReqVO reqVO);
 
     Map<String, Object> getPlanDataChart(PlanDataChartReqVO reqVO);
+
+    List<MainProcessIndexDTO> getIndexList(Map<String, Object> params);
+
+    Boolean updateSuggestStatus(StAlarmAndSuggestReqVO ReqVO);
 }
\ No newline at end of file
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 34ad0dd..dac1073 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
@@ -3,6 +3,8 @@
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.iailab.framework.common.util.date.DateUtils;
 import com.iailab.framework.common.util.object.ConvertUtils;
+import com.iailab.module.ansteel.api.dao.MainProcessIndexDayDao;
+import com.iailab.module.ansteel.api.dao.MainProcessIndexTeamDao;
 import com.iailab.module.ansteel.api.dao.PowerRunStateDao;
 import com.iailab.module.ansteel.api.dto.*;
 import com.iailab.module.ansteel.api.service.DataApi;
@@ -41,6 +43,12 @@
     @Autowired
     private PowerRunStateDao powerRunStateDao;
 
+    @Autowired
+    private MainProcessIndexDayDao mainProcessIndexDayDao;
+
+    @Autowired
+    private MainProcessIndexTeamDao mainProcessIndexTeamDao;
+
     @Override
     public List<PowerRunStateDTO> getPowerRunState() {
         List<PowerRunStateDTO> list = ConvertUtils.sourceToTarget(powerRunStateDao.selectList(new QueryWrapper<>()), PowerRunStateDTO.class);
@@ -77,6 +85,42 @@
             }).collect(Collectors.toList());
         }
         return list;
+    }
+
+    @Override
+    public List<MainProcessIndexDTO> getIndexList(Map<String, Object> params) {
+        List<MainProcessIndexDTO> list = new ArrayList<>();
+        if("day".equals(params.get("type"))) {
+            list = ConvertUtils.sourceToTarget(mainProcessIndexDayDao.selectList(new QueryWrapper<>()), MainProcessIndexDTO.class);
+        }else if("team".equals(params.get("type"))){
+            list = ConvertUtils.sourceToTarget(mainProcessIndexTeamDao.selectList(new QueryWrapper<>()), MainProcessIndexDTO.class);
+        }
+        if (!CollectionUtils.isEmpty(list)) {
+            list.stream().map(item -> {
+                StringBuffer sb = new StringBuffer();
+                sb.append(item.getHisAvg());
+                sb.append(",");
+                sb.append(item.getTheory());
+                sb.append(",");
+                sb.append(item.getActual());
+                sb.append(",");
+                sb.append(item.getRealData());
+                String[] arr = sb.toString().split(",");
+                Map<String, Object> adjValue = dataPointApi.queryPointsRealValue(Arrays.asList(arr));
+                item.setHisAvg(ObjectUtils.isEmpty(adjValue.get(arr[0])) ? "0" : new BigDecimal(adjValue.get(arr[0]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+                item.setTheory(ObjectUtils.isEmpty(adjValue.get(arr[1])) ? "0" : new BigDecimal(adjValue.get(arr[1]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+                item.setActual(ObjectUtils.isEmpty(adjValue.get(arr[2])) ? "0" : new BigDecimal(adjValue.get(arr[2]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+                item.setRealData(ObjectUtils.isEmpty(adjValue.get(arr[3])) ? "0" : new BigDecimal(adjValue.get(arr[3]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+
+                return item;
+            }).collect(Collectors.toList());
+        }
+        return list;
+    }
+
+    @Override
+    public Boolean updateSuggestStatus(StAlarmAndSuggestReqVO ReqVO) {
+        return mcsApi.updateSuggestStatus(ReqVO);
     }
 
     @Override
@@ -186,33 +230,6 @@
         return result;
     }
 
-    private Date[] calResultTime2(Date predictTimeReq,String startTimeReq, String endTimeReq, int lengthLeft, int lengthRight) {
-        Date[] result = new Date[2];
-        Date predictTime = predictTimeReq;
-        Date startTime = new Date();
-        if (startTimeReq == null) {
-            Calendar calendar = Calendar.getInstance();
-            calendar.setTime(predictTime);
-            calendar.add(Calendar.SECOND, -1 * lengthLeft * 60);
-            startTime = calendar.getTime();
-        }
-        Date endTime = new Date();
-        if (endTimeReq == null) {
-            Calendar calendar = Calendar.getInstance();
-            calendar.setTime(predictTime);
-            calendar.add(Calendar.SECOND, lengthRight * 60);
-            endTime = calendar.getTime();
-        }
-        if (endTime.getTime() <= startTime.getTime()) {
-            Calendar calendar = Calendar.getInstance();
-            calendar.setTime(startTime);
-            calendar.add(Calendar.SECOND, lengthRight * 60);
-            endTime = calendar.getTime();
-        }
-        result[0] = startTime;
-        result[1] = endTime;
-        return result;
-    }
     /**
      *  查询原始计划、修正计划数据
      */
@@ -227,44 +244,33 @@
         list.forEach(item -> {
             tMap.put(item.getParamCode(), item.getParamValue());
         });
-        String planCode = tMap.get(CommonConstant.PLAN_CODE);
-        if (planCode == null) {
-            return null;
-        }
-        String itemCode = tMap.get(CommonConstant.ITEM_CODE);
-        if (itemCode == null) {
-            return null;
-        }
 
         PreDataSingleChartReqVO queryDto = new PreDataSingleChartReqVO();
         queryDto.setChartCode(reqVO.getChartCode());
         PreDataSingleChartRespVO chartData = mcsApi.getPreDataSingleChart(queryDto);
 
         Date predictTime = chartData.getPredictTime();
-        int lengthLeft = new BigDecimal(tMap.get(CommonConstant.LENGTH_LEFT)).intValue();
-        int lengthRight = reqVO.getLengthRight();
-
-        Date[] timeArray = calResultTime2(predictTime, reqVO.getStartTime(), reqVO.getEndTime(), lengthLeft, lengthRight);
-        Date startTime = timeArray[0];
-        Date endTime = timeArray[1];
+        Date startTime = chartData.getStartTime();
+        Date endTime = chartData.getEndTime();
 
         // 原始计划数据
-        LinkedHashMap<String, List<String[]>> planData = getRealPlanData(planCode, startTime, endTime, predictTime);
+        LinkedHashMap<String, List<String[]>> planData = getRealPlanData(reqVO.getPlanCodes(), startTime, endTime, predictTime);
 
         // 修正计划数据
         LinkedHashMap<String, List<String[]>> predData = new LinkedHashMap<>();
-        predData.put(reqVO.getChartCode(), getPrePlanData(reqVO.getChartCode(), predictTime, endTime));
+        for (int i = 0; i < reqVO.getPlanCodes().size(); i++) {
+            predData.put(reqVO.getPlanCodes().get(i), getPrePlanData(reqVO.getPlanPreds().get(i), predictTime, endTime));
+        }
         result.put("planData", planData);
         result.put("predData", predData);
         return result;
     }
 
     //原始计划
-    public LinkedHashMap<String, List<String[]>> getRealPlanData(String planCode, Date startTime, Date endTime, Date predictTime) {
+    public LinkedHashMap<String, List<String[]>> getRealPlanData(List<String> planCodes, Date startTime, Date endTime, Date predictTime) {
         LinkedHashMap<String, List<String[]>> result = new LinkedHashMap<>();
         ApiDataQueryDTO apiDataQueryDTO = new ApiDataQueryDTO();
-        List<String> itemList = Arrays.asList(planCode.toString().split(","));
-        apiDataQueryDTO.setItemNos(itemList);
+        apiDataQueryDTO.setItemNos(planCodes);
         apiDataQueryDTO.setStart(startTime);
         apiDataQueryDTO.setEnd(endTime);
         LinkedHashMap<String, List<ApiPlanDataDTO>> planData = planItemApi.queryPlanItemRecordValue(apiDataQueryDTO);
diff --git a/ansteel-biz/src/main/resources/application.yaml b/ansteel-biz/src/main/resources/application.yaml
index 0ae3517..df5f6c1 100644
--- a/ansteel-biz/src/main/resources/application.yaml
+++ b/ansteel-biz/src/main/resources/application.yaml
@@ -4,7 +4,7 @@
     name: ansteel-server
 
   profiles:
-    active: prod
+    active: dev
 
   cloud:
     nacos:
@@ -151,6 +151,8 @@
       - schedule_job
       - schedule_job_log
       - t_power_run_state
+      - t_main_process_index_day
+      - t_main_process_index_team
   swagger:
     title: 选煤厂安全管理平台
     description: 选煤厂安全管理平台
diff --git "a/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_dev_li.doc" "b/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_dev_li.doc"
index 8f9b9a7..041c1bd 100644
--- "a/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_dev_li.doc"
+++ "b/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_dev_li.doc"
Binary files differ
diff --git "a/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_master.doc" "b/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_master.doc"
index 42cf223..4c15ad1 100644
--- "a/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_master.doc"
+++ "b/doc/\351\236\215\351\222\242\346\225\260\346\215\256\346\216\245\345\217\243\346\226\207\346\241\243_master.doc"
Binary files differ

--
Gitblit v1.9.3