1.为中心值实体类添加平台新增字段。

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizFanPointVarCentralValue.java

 package com.yeejoin.amos.boot.module.jxiop.biz.entity;
 
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
 import lombok.Data;
@@ -27,7 +28,7 @@ public class IdxBizFanPointVarCentralValue{
     /**
      * 
      */
-	@TableField("SEQUENCE_NBR")
+	@TableId("SEQUENCE_NBR")
     private String sequenceNbr;
 
     /**
@@ -81,8 +82,8 @@ public class IdxBizFanPointVarCentralValue{
     /**
      * 
      */
-	@TableField("ANALYSIS_POINT_ID")
-    private String analysisPointId;
+//	@TableField("ANALYSIS_POINT_ID")
+//    private String analysisPointId;
 
     /**
      * 片区
@@ -135,8 +136,8 @@ public class IdxBizFanPointVarCentralValue{
     /**
      * 工况变量1ID
      */
-	@TableField("PROCESS_POINT1_ID")
-    private String processPoint1Id;
+//	@TableField("PROCESS_POINT1_ID")
+//    private String processPoint1Id;
 
     /**
      * 工况量2区间最小值
@@ -174,4 +175,39 @@ public class IdxBizFanPointVarCentralValue{
 	@TableField("PROCESS_POINT2_ID")
     private String processPoint2Id;
 
+    /**
+     * 工况变量1ID
+     */
+    @TableField("PROCESS_POINT1_ID")
+    private String processPoint1Id;
+
+    /**
+     *
+     */
+    @TableField("ANALYSIS_POINT_ID")
+    private String analysisPointId;
+
+    /**
+     * 工况变量3ID
+     */
+    @TableField("PROCESS_POINT3_NAME")
+    private String processPoint3Name;
+
+    /**
+     * 工况变量2ID
+     */
+    @TableField("PROCESS_POINT2_NAME")
+    private String processPoint2Name;
+
+    /**
+     * 工况变量1ID
+     */
+    @TableField("PROCESS_POINT1_NAME")
+    private String processPoint1Name;
+
+    /**
+     *
+     */
+    @TableField("ANALYSIS_POINT_NAME")
+    private String analysisPointName;
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizPvPointVarCentralValue.java

@@ -80,8 +80,8 @@ public class IdxBizPvPointVarCentralValue{
     /**
      * 
      */
-	@TableField("ANALYSIS_POINT_ID")
-    private Integer analysisPointId;
+//	@TableField("ANALYSIS_POINT_ID")
+//    private Integer analysisPointId;
 
     /**
      * 片区
@@ -149,4 +149,45 @@ public class IdxBizPvPointVarCentralValue{
 	@TableField("EQUIPMENT_NAME")
     private String equipmentName;
 
+    /**
+     * 工况变量3ID
+     */
+    @TableField("PROCESS_POINT3_ID_NAME")
+    private String processPoint3IdName;
+
+    /**
+     * 工况变量2ID
+     */
+    @TableField("PROCESS_POINT2_ID_NAME")
+    private String processPoint2IdName;
+
+    /**
+     * 工况变量1ID
+     */
+    @TableField("PROCESS_POINT1_ID_NAME")
+    private String processPoint1IdName;
+
+    /**
+     *
+     */
+    @TableField("ANALYSIS_POINT_ID_NAME")
+    private String analysisPointIdName;
+
+    /**
+     * 工况变量3ID
+     */
+    @TableField("PROCESS_POINT3_ID")
+    private String processPoint3Id;
+
+    /**
+     * 工况变量2ID
+     */
+    @TableField("PROCESS_POINT2_ID")
+    private String processPoint2Id;
+
+    /**
+     * 工况变量1ID
+     */
+    @TableField("PROCESS_POINT1_ID")
+    private String processPoint1Id;
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/CommonServiceImpl.java

@@ -95,7 +95,8 @@ public class CommonServiceImpl {
     @Autowired
     IdxBizFanPointVarCentralValueMapper idxBizFanPointVarCentralValueMapper;
 
-
+    @Autowired
+    IdxBizPvPointVarCentralValueMapper idxBizPvPointVarCentralValueMapper;
 
     /**
      * @return
@@ -510,6 +511,30 @@ public class CommonServiceImpl {
             realParams.put(gkzxzjskey2, requestParams);
             logger.info("------------------------------风机中心值------请求参数---------------------------------------" + JSON.toJSONString(realParams));
             String response = HttpUtil.createPost(baseUrl + gkzxzjsurlfan).body(JSON.toJSONString(realParams)).execute().body();
+            List<IdxBizFanPointVarCentralValue> anaylseList  = idxBizFanPointVarCentralValueMapper.selectList(new QueryWrapper<IdxBizFanPointVarCentralValue>().eq("ANALYSIS_POINT_ID",IdxBizFanPointProcessVariableClassification.getSequenceNbr().toString()));
+            List<IdxBizFanPointVarCentralValue> precessList1  = idxBizFanPointVarCentralValueMapper.selectList(new QueryWrapper<IdxBizFanPointVarCentralValue>().eq("PROCESS_POINT1_ID",list.get(0).getProcessPointId()));
+            List<IdxBizFanPointVarCentralValue> precessList2  = idxBizFanPointVarCentralValueMapper.selectList(new QueryWrapper<IdxBizFanPointVarCentralValue>().eq("PROCESS_POINT2_ID",list.get(1).getProcessPointId()));
+            List<IdxBizFanPointVarCentralValue> precessList3  = idxBizFanPointVarCentralValueMapper.selectList(new QueryWrapper<IdxBizFanPointVarCentralValue>().eq("PROCESS_POINT3_ID",list.get(2).getProcessPointId()));
+            for (int i = 0; i < anaylseList.size(); i++) {
+                IdxBizFanPointVarCentralValue idxBizFanPointVarCentralValue =anaylseList.get(i);
+                idxBizFanPointVarCentralValue.setAnalysisPointName(IdxBizFanPointProcessVariableClassification.getPointName());
+                idxBizFanPointVarCentralValueMapper.updateById(idxBizFanPointVarCentralValue);
+            }
+            for (int i = 0; i < precessList1.size(); i++) {
+                IdxBizFanPointVarCentralValue idxBizFanPointVarCentralValue =precessList1.get(i);
+                idxBizFanPointVarCentralValue.setProcessPoint1Name(idxBizFanPointProcessVariableClassificationList.get(2).getPointName());
+                idxBizFanPointVarCentralValueMapper.updateById(idxBizFanPointVarCentralValue);
+            }
+            for (int i = 0; i < precessList2.size(); i++) {
+                IdxBizFanPointVarCentralValue idxBizFanPointVarCentralValue =precessList2.get(i);
+                idxBizFanPointVarCentralValue.setProcessPoint2Name(idxBizFanPointProcessVariableClassificationList.get(1).getPointName());
+                idxBizFanPointVarCentralValueMapper.updateById(idxBizFanPointVarCentralValue);
+            }
+            for (int i = 0; i < precessList3.size(); i++) {
+                IdxBizFanPointVarCentralValue idxBizFanPointVarCentralValue =precessList3.get(i);
+                idxBizFanPointVarCentralValue.setProcessPoint3Name(idxBizFanPointProcessVariableClassificationList.get(0).getPointName());
+                idxBizFanPointVarCentralValueMapper.updateById(idxBizFanPointVarCentralValue);
+            }
             try {
                 logger.info("------------------风机中心值--repsonse： " + response);
                 TimeUnit.SECONDS.sleep(zxzsleepTime);