From 7efbf921192559cad13a4f8086c46c3617ad2a05 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 31 十月 2024 08:34:42 +0800
Subject: [PATCH] 1、协议解析中,关阀报(83)中的RTU时钟改为关阀时间,但代码误注解掉了这行代码,修改之; 2、通信中间件测试web系统增加查询所在在线情况的命令下发。

---
 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java |   19 +++++++++----------
 1 files changed, 9 insertions(+), 10 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java
index 6118669..218b9ef 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java
@@ -28,9 +28,7 @@
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 
 /**
  * @author ZhuBaoMin
@@ -50,7 +48,8 @@
     private final PrIntakeVcMapper prIntakeVcMapper;
     private final SeClientCardMapper seClientCardMapper;
     private final RmIrrigateProfileMapper rmIrrigateProfileMapper;
-    private RmOpenCloseValveLastMapper rmOpenCloseValveLastMapper;
+    private final RmOpenCloseValveLastMapper rmOpenCloseValveLastMapper;
+    //private final PrCommonIntakesMapper prCommonIntakesMapper;
 
     /**
      * pro_mw锛氬睘鎬�
@@ -64,6 +63,7 @@
     public CommandSv(RmCommandHistoryMapper rmCommandHistoryMapper,RmOpenCloseValveLastMapper rmOpenCloseValveLastMapper, SeVirtualCardMapper seVirtualCardMapper, PrIntakeMapper prIntakeMapper, PrWaterPriceMapper prWaterPriceMapper, PrIntakeVcMapper prIntakeVcMapper, SeClientCardMapper seClientCardMapper, RmIrrigateProfileMapper rmIrrigateProfileMapper, Environment env) {
         this.rmCommandHistoryMapper = rmCommandHistoryMapper;
         this.rmOpenCloseValveLastMapper = rmOpenCloseValveLastMapper;
+        //this.prCommonIntakesMapper = prCommonIntakesMapper;
         this.seVirtualCardMapper = seVirtualCardMapper;
         this.prIntakeMapper = prIntakeMapper;
         this.prWaterPriceMapper = prWaterPriceMapper;
@@ -103,17 +103,17 @@
 
         JSONObject response = (JSONObject) JSON.toJSON(sendCom2Mw(com));
         if(response != null && response.getString("code").equals("0001")) {
-            JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment").getJSONObject("onLineMap");
+            JSONObject attachment = response.getJSONObject("content").getJSONObject("attachment");
 
             JSONArray jsonArray = new JSONArray();
             if(attachment != null) {
-                HashMap<String, Boolean> onLineMap = JSON.parseObject(attachment.toJSONString(), HashMap.class);
-                for (Map.Entry<String, Boolean> entry : onLineMap.entrySet()) {
+                attachment.forEach((key, value) -> {
                     JSONObject jsonObject = new JSONObject();
-                    jsonObject.put("rtuAddr", entry.getKey());
-                    jsonObject.put("isOnLine", entry.getValue());
+                    jsonObject.put("rtuAddr", key);
+                    jsonObject.put("isOnLine", value);
                     jsonArray.add(jsonObject);
-                }
+
+                });
             }
 
             System.out.println(jsonArray.toJSONString());
@@ -195,5 +195,4 @@
         rsVo.obj = rmIrrigateProfileMapper.getIrrPro(type);
         return rsVo ;
     }
-
 }

--
Gitblit v1.8.0