From 1879eaa3af5e45c6228ec2188a6c324000b3d7fa Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期一, 30 三月 2026 18:01:39 +0800
Subject: [PATCH] 海康电表维护
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttPushCallback.java | 2 --
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttClientCache.java | 1 +
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java | 3 +--
3 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttClientCache.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttClientCache.java
index 26afe2f..f9c5a50 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttClientCache.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttClientCache.java
@@ -6,4 +6,5 @@
public class MqttClientCache {
public static LinkedHashMap<String, MqttClient> clientMapCache = new LinkedHashMap<>();
+ public static MqttClient clientSignleCache=null;
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttPushCallback.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttPushCallback.java
index a4372cf..992eddd 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttPushCallback.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttPushCallback.java
@@ -30,8 +30,6 @@
@Service
@Slf4j
public class MqttPushCallback implements MqttCallback {
-
-
@Autowired
private DeviceMapper deviceMapper;
@Autowired
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java
index a3a9859..b05f62b 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java
@@ -17,7 +17,7 @@
@Slf4j
public class MqttSubServiceImpl implements MqttBizService {
@Autowired
- private MqttPushCallback callBack ;
+ private MqttPushCallback callBack;
@Override
public MqttClient subscribe(MqttClient client,MqttConfig config,String[] topics){
log.error("mqtt璁㈤槄寮�濮�========寮�濮�"+ JSONObject.toJSONString(config));
@@ -32,7 +32,6 @@
log.error("mqtt璁㈤槄寮�濮�========缁撴潫"+ JSONObject.toJSONString(config));
return client;
}
-
@Override
public MqttClient publish(MqttClient client,MqttConfig config, String topic, String param){
log.error("mqtt鍙戝竷娑堟伅========寮�濮�"+ JSONObject.toJSONString(config)+"\n"+param);
--
Gitblit v1.9.3