From c3a0cb8e8d8025e3937149b64a604b8989b2de18 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期二, 03 六月 2025 16:46:24 +0800
Subject: [PATCH] 1、表阀一体机阀门状态命令结果输出与测控一体阀做兼容; 2、虚拟卡状态写入时机进行修改,由原来的阶段写簇变成随时写入。

---
 pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttClientConnectorPool.java |    6 +-----
 1 files changed, 1 insertions(+), 5 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttClientConnectorPool.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttClientConnectorPool.java
index 56545be..91a47e2 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttClientConnectorPool.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/mqtt/MqttClientConnectorPool.java
@@ -21,17 +21,13 @@
      * 杩炴帴MQTT瀹㈡埛绔�
      * @return 鑾峰彇MQTT杩為槦瀵硅薄
      */
-    public static MqttClient connectMQTT() {
+    public static MqttClient connectMQTT(String broker, String username, String password) {
         if (mqttClient != null){
             log.info("宸插瓨鍦紒");
             return mqttClient;
         }
 
         try {
-            // broker鍙婅繛鎺ヤ俊鎭�
-            String broker = "tcp://127.0.0.1:1883";
-            String username = "mqtt_u";
-            String password = "yjy";
             String clientId = System.currentTimeMillis() + "";
 
             //鍒涘缓MQTT瀹㈡埛绔紙鎸囧畾broker銆佸鎴风id銆佹秷鎭寔涔呯瓥鐣ワ級

--
Gitblit v1.8.0