From 7722a4b738573a4ee2f0902c4bd03ce0ff60c754 Mon Sep 17 00:00:00 2001
From: zhangjunwen <zhangjunwen@inspur.com>
Date: Fri, 14 Jun 2024 15:57:55 +0800
Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/DataQueryService.java        |  21 +-
 .../com/inspur/industrial/utils/IpcUtil.java  |   3 +-
 zfipc-ui/src/views/zf/bigscreen/bigscreen.vue | 269 ++++++++++--------
 3 files changed, 157 insertions(+), 136 deletions(-)

diff --git a/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/service/impl/DataQueryService.java b/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/service/impl/DataQueryService.java
index 3590a7f..1e99983 100644
--- a/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/service/impl/DataQueryService.java
+++ b/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/service/impl/DataQueryService.java
@@ -8,6 +8,8 @@ import com.inspur.industrial.utils.InfluxdbTimeUtil;
 import com.inspur.system.domain.SysConfig;
 import com.inspur.system.service.ISysConfigService;
 import com.inspur.system.service.influx.InfluxDBService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -25,7 +27,7 @@ import java.util.Map;
  */
 @Service
 public class DataQueryService implements IDataQueryService {
-
+    private static final Logger logger = LoggerFactory.getLogger(DataQueryService.class);
     @Resource
     private InfluxDBService influxDBUtils;
 
@@ -230,6 +232,7 @@ public class DataQueryService implements IDataQueryService {
         LocalDateTime etime = LocalDateTime.parse(endTime);
         long intervalHours = ChronoUnit.HOURS.between(stime, etime);
         List<Map<String, Object>> list = new ArrayList<>();
+        logger.info("查询时间差：" + intervalHours);
         if(intervalHours <= 6){//6小时内全查
             list = selectDataByColumnNameandDate(tableName, columnName, utcStartTime, utcEndTime);
         }else if(intervalHours <= 7*24 ){//7天内，每30s一个
@@ -253,12 +256,14 @@ public class DataQueryService implements IDataQueryService {
         }
         for (Map<String, Object> data : list) {
             //取两位小数
-            columnList.add(data.get(columnName) == null ? 0.0 : Math.round(Double.parseDouble(data.get(columnName).toString()) * 100) / 100.0);
-            columnList.add(data.get(columnName));
-            statusList.add((Double)data.get("ipc_status"));
-            LocalDateTime time = InfluxdbTimeUtil.utcToCst(data.get("time").toString());
-            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
-            timelist.add(time.format(formatter));
+//            columnList.add(data.get(columnName) == null ? 0.0 : );
+            if(data.get(columnName) != null) {
+                columnList.add(Math.round(Double.parseDouble(data.get(columnName).toString()) * 100) / 100.0);
+                statusList.add((Double) data.get("ipc_status"));
+                LocalDateTime time = InfluxdbTimeUtil.utcToCst(data.get("time").toString());
+                DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+                timelist.add(time.format(formatter));
+            }
         }
 
         resMap.put("y", columnList);
@@ -426,7 +431,7 @@ public class DataQueryService implements IDataQueryService {
      * @return
      */
     private List<Map<String, Object>> selectLongTimeDataByColumnNameandDate(String tableName, String columnName, String startTime, String endTime, String interval){
-        String sql = "select time, ipc_status, mean(" + columnName + ") from " + tableName + " where time >= '" + startTime + "' and time <= '" + endTime + "' group by time(" + interval  +")";
+        String sql = "select time, mean(ipc_status) as ipc_status, mean(" + columnName + ") from " + tableName + " where time >= '" + startTime + "' and time <= '" + endTime + "' group by time(" + interval  +") fill(null)";
         return influxDBUtils.queryResultProcess(influxDBUtils.query(sql));
     }
 
diff --git a/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/utils/IpcUtil.java b/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/utils/IpcUtil.java
index fc15349..538bd5c 100644
--- a/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/utils/IpcUtil.java
+++ b/zfipc-server/zfipc-system/src/main/java/com/inspur/industrial/utils/IpcUtil.java
@@ -79,8 +79,7 @@ public class IpcUtil {
                     ipcAlarmRecord.setEquipId(rule.getEquipId());
                     ipcAlarmRecord.setSensorId(rule.getSensorId());
                     String name = rule.getAlarmNameKey();
-                    float value =  (float)map.get(name);
-                    ipcAlarmRecord.setAlarmValue(BigDecimal.valueOf(value));
+                    ipcAlarmRecord.setAlarmValue(BigDecimal.valueOf((Float)map.get(name)));
                     ipcAlarmRecord.setNameKey(name);
                     ipcAlarmRecord.setContent(type == 0 ? "(开机监测)" + rule.getReferenceName() : rule.getReferenceName());
                     ipcAlarmRecord.setStatus(0);
diff --git a/zfipc-ui/src/views/zf/bigscreen/bigscreen.vue b/zfipc-ui/src/views/zf/bigscreen/bigscreen.vue
index 4d24675..d76d772 100644
--- a/zfipc-ui/src/views/zf/bigscreen/bigscreen.vue
+++ b/zfipc-ui/src/views/zf/bigscreen/bigscreen.vue
@@ -456,6 +456,20 @@
             >
               <el-header class="header">ZFSC4超压底缸加压系统油品特性</el-header>
               <el-main class="main">
+                <el-row style="height: 10%">
+                  <div
+                    v-if="this.cylipcstatus == 30"
+                    style="text-align:center;margin-left:50px"
+                  >吸油油品监测</div>
+                  <div
+                    v-if="this.cylipcstatus == 40"
+                    style="text-align:center;margin-left:50px"
+                  >回油油品监测</div>
+                  <div
+                    v-if="this.cylipcstatus == 60"
+                    style="text-align:center;margin-left:50px"
+                  >底层油品监测</div>
+                </el-row>
                 <el-row style="height: 40%">
                   <el-col
                     :span="8"
@@ -534,21 +548,8 @@
                     <span class="numCol">{{ cylyykld21 }}</span>
                   </el-col>
                 </el-row>
-                <el-row>
-                  <div
-                    v-if="this.cylipcstatus == 30"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >吸油油品监测</div>
-                  <div
-                    v-if="this.cylipcstatus == 40"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >回油油品监测</div>
-                  <div
-                    v-if="this.cylipcstatus == 60"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >底层油品监测</div>
-                </el-row>
-                <el-row style="height: 50%">
+
+                <el-row style="height: 40%">
                   <el-col
                     :span="24"
                     id="cylyykldtx"
@@ -1319,6 +1320,20 @@
             >
               <el-header class="header">ZFSC4超压底缸加压系统油品特性</el-header>
               <el-main class="main">
+                <el-row style="height:10%">
+                  <div
+                    v-if="this.ipcstatus == 30"
+                    style="text-align:center;margin-left:50px"
+                  >吸油油品监测</div>
+                  <div
+                    v-if="this.ipcstatus == 40"
+                    style="text-align:center;margin-left:50px"
+                  >回油油品监测</div>
+                  <div
+                    v-if="this.ipcstatus == 60"
+                    style="text-align:center;margin-left:50px"
+                  >底层油品监测</div>
+                </el-row>
                 <el-row style="height: 40%">
                   <el-col
                     :span="8"
@@ -1397,21 +1412,8 @@
                     <span class="numCol">{{ yykld21 }}</span>
                   </el-col>
                 </el-row>
-                <el-row>
-                  <div
-                    v-if="this.ipcstatus == 30"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >吸油油品监测</div>
-                  <div
-                    v-if="this.ipcstatus == 40"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >回油油品监测</div>
-                  <div
-                    v-if="this.ipcstatus == 60"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >底层油品监测</div>
-                </el-row>
-                <el-row style="height: 50%">
+
+                <el-row style="height: 40%">
                   <el-col
                     :span="24"
                     id="yykldtx"
@@ -2184,6 +2186,20 @@
             >
               <el-header class="header">ZFSC4超压底缸加压系统油品特性</el-header>
               <el-main class="main">
+                <el-row style="height:10%">
+                  <div
+                    v-if="this.bsipcstatus == 30"
+                    style="text-align:center;margin-left:50px"
+                  >吸油油品监测</div>
+                  <div
+                    v-if="this.bsipcstatus == 40"
+                    style="text-align:center;margin-left:50px"
+                  >回油油品监测</div>
+                  <div
+                    v-if="this.bsipcstatus == 60"
+                    style="text-align:center;margin-left:50px"
+                  >底层油品监测</div>
+                </el-row>
                 <el-row style="height: 40%">
                   <el-col
                     :span="8"
@@ -2262,21 +2278,8 @@
                     <span class="numCol">{{ bsyykld21 }}</span>
                   </el-col>
                 </el-row>
-                <el-row>
-                  <div
-                    v-if="this.bsipcstatus == 30"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >吸油油品监测</div>
-                  <div
-                    v-if="this.bsipcstatus == 40"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >回油油品监测</div>
-                  <div
-                    v-if="this.bsipcstatus == 60"
-                    style="text-align:center;margin-left:50px;margin-top:10px"
-                  >底层油品监测</div>
-                </el-row>
-                <el-row style="height: 50%">
+
+                <el-row style="height: 40%">
                   <el-col
                     :span="24"
                     id="bsyykldtx"
@@ -2576,7 +2579,7 @@
           type="primary"
           icon="el-icon-search"
           size="mini"
-          @click="handleQuery"
+          @click="handleQuery(null)"
         >查 询</el-button>
         <el-button
           icon="el-icon-refresh"
@@ -2934,6 +2937,8 @@ export default {
     },
     handleQuery(key) {
       this.loading = true;
+      // console.log("key:", key);
+      // console.log("queryParams:", this.queryParams);
       if (key != null) {
         if (
           key === "driven_soft_flw" ||
@@ -2953,8 +2958,18 @@ export default {
       this.getData(this.queryParams);
     },
     resetQuery() {
-      this.datetime = this.getDefaultTimeRange();
-      this.handleQuery();
+      var key = this.queryParams.columnName;
+      if (
+        key === "driven_soft_flw" ||
+        key === "driven_hot_flw" ||
+        key === "opr_soft_flw" ||
+        key === "opr_hot_flw"
+      ) {
+        this.datetime = this.getTimeRangeByHours(5);
+      } else {
+        this.datetime = this.getDefaultTimeRange();
+      }
+      this.handleQuery(null);
     },
     getData(queryObj) {
       this.chartLoading = true;
@@ -3156,92 +3171,94 @@ export default {
           ],
         };
         //设置标志区域
-        if (
-          queryObj.columnName === "gran4" ||
-          queryObj.columnName === "gran6" ||
-          queryObj.columnName === "gran14" ||
-          queryObj.columnName === "gran21"
-        ) {
-          var pres = null;
-          var aredata = [];
-          var markData = [];
-          if (status != null) {
-            for (let i = 0; i < status.length; i++) {
-              if (status[i] != pres) {
-                //判断是头或者尾部
-                if (markData.length == 1) {
-                  //尾
+        if (queryObj != null && queryObj.columnName != null) {
+          if (
+            queryObj.columnName === "gran4" ||
+            queryObj.columnName === "gran6" ||
+            queryObj.columnName === "gran14" ||
+            queryObj.columnName === "gran21"
+          ) {
+            var pres = null;
+            var aredata = [];
+            var markData = [];
+            if (status != null) {
+              for (let i = 0; i < status.length; i++) {
+                if (status[i] != pres) {
+                  //判断是头或者尾部
+                  if (markData.length == 1) {
+                    //尾
+                    markData.push({
+                      //收尾
+                      xAxis: xData[i],
+                    });
+                    aredata.push(markData);
+                    markData = [];
+                    // //头
+                    // if (status[i] == 10) {
+                    //   markData.push({
+                    //     xAxis: xData[i],
+                    //     name: "吸油油品监测",
+                    //     itemStyle: {
+                    //       color: "red",
+                    //     },
+                    //   });
+                    // } else if (status[i] == 20) {
+                    //   markData.push({
+                    //     xAxis: xData[i],
+                    //     name: "回油油品监测",
+                    //     itemStyle: {
+                    //       color: "blue",
+                    //     },
+                    //   });
+                    // } else if (status[i] == 50) {
+                    //   markData.push({
+                    //     xAxis: xData[i],
+                    //     name: "底层油品监测",
+                    //     itemStyle: {
+                    //       color: "yellow",
+                    //     },
+                    //   });
+                    // }
+                  }
+
+                  //标记头
+                  if (status[i] == 30) {
+                    markData.push({
+                      xAxis: xData[i],
+                      name: "吸油油品监测",
+                      itemStyle: {
+                        color: "rgba(255, 100, 100, 0.3)",
+                      },
+                    });
+                  } else if (status[i] == 40) {
+                    markData.push({
+                      xAxis: xData[i],
+                      name: "回油油品监测",
+                      itemStyle: {
+                        color: "rgba(100, 200, 100, 0.3)",
+                      },
+                    });
+                  } else if (status[i] == 60) {
+                    markData.push({
+                      xAxis: xData[i],
+                      name: "底层油品监测",
+                      itemStyle: {
+                        color: "rgba(100, 100, 255, 0.3)",
+                      },
+                    });
+                  }
+                }
+                if (markData.length == 1 && i == status.length - 1) {
                   markData.push({
-                    //收尾
                     xAxis: xData[i],
                   });
                   aredata.push(markData);
                   markData = [];
-                  // //头
-                  // if (status[i] == 10) {
-                  //   markData.push({
-                  //     xAxis: xData[i],
-                  //     name: "吸油油品监测",
-                  //     itemStyle: {
-                  //       color: "red",
-                  //     },
-                  //   });
-                  // } else if (status[i] == 20) {
-                  //   markData.push({
-                  //     xAxis: xData[i],
-                  //     name: "回油油品监测",
-                  //     itemStyle: {
-                  //       color: "blue",
-                  //     },
-                  //   });
-                  // } else if (status[i] == 50) {
-                  //   markData.push({
-                  //     xAxis: xData[i],
-                  //     name: "底层油品监测",
-                  //     itemStyle: {
-                  //       color: "yellow",
-                  //     },
-                  //   });
-                  // }
-                }
-
-                //标记头
-                if (status[i] == 30) {
-                  markData.push({
-                    xAxis: xData[i],
-                    name: "吸油油品监测",
-                    itemStyle: {
-                      color: "rgba(255, 100, 100, 0.3)",
-                    },
-                  });
-                } else if (status[i] == 40) {
-                  markData.push({
-                    xAxis: xData[i],
-                    name: "回油油品监测",
-                    itemStyle: {
-                      color: "rgba(100, 200, 100, 0.3)",
-                    },
-                  });
-                } else if (status[i] == 60) {
-                  markData.push({
-                    xAxis: xData[i],
-                    name: "底层油品监测",
-                    itemStyle: {
-                      color: "rgba(100, 100, 255, 0.3)",
-                    },
-                  });
                 }
+                pres = status[i];
               }
-              if (markData.length == 1 && i == status.length - 1) {
-                markData.push({
-                  xAxis: xData[i],
-                });
-                aredata.push(markData);
-                markData = [];
-              }
-              pres = status[i];
+              option.series[0].markArea = { data: aredata };
             }
-            option.series[0].markArea = { data: aredata };
           }
         }
         this.chart.setOption(option);