From b38019aae593a66c16f7e75d6e37d14eb8d2c42e Mon Sep 17 00:00:00 2001
From: zhuguifei <zhuguifei@zhuguifeideiMac.local>
Date: 星期二, 22 七月 2025 08:55:15 +0800
Subject: [PATCH] 修改接收实时数据接口-故障处理
---
jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttConfig.java | 21 ++++++++++++++-------
1 files changed, 14 insertions(+), 7 deletions(-)
diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttConfig.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttConfig.java
old mode 100644
new mode 100755
index 43c838f..a490a0a
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttConfig.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttConfig.java
@@ -15,6 +15,7 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
import org.springframework.data.redis.core.RedisTemplate;
import java.util.*;
@@ -36,6 +37,8 @@
private String mqttClientId;
@Value(value = "${jeecg.mqtt.role}")
private String role;
+ @Value(value = "${jeecg.mqtt.enable}")
+ private boolean enable;
@Autowired
private MqttSampleCallback mqttSampleCallback;
@@ -59,6 +62,7 @@
* mqtt杩炴帴閰嶇疆
*/
private void conn() {
+ if (!isEnable()) return;
MemoryPersistence persistence = new MemoryPersistence();
MqttConnectOptions mqttConnOpt = new MqttConnectOptions();
mqttConnOpt.setUserName(mqttName);
@@ -98,8 +102,8 @@
mqttClient.subscribe(MqttConstant.MOBILE_UP);
System.err.println("admin璁㈤槄" + MqttConstant.MOBILE_UP);
// 璁㈤槄绉熸埛瀹炴椂鏁版嵁
- mqttClient.subscribe(MqttConstant.TENANT_UP_PREFIX_REALTIME_DATA);
- System.out.println("admin璁㈤槄" + MqttConstant.TENANT_UP_PREFIX_REALTIME_DATA);
+ mqttClient.subscribe(MqttConstant.TENANT_UP_PREFIX_REALTIME_DATA_EQP);
+ System.out.println("admin璁㈤槄" + MqttConstant.TENANT_UP_PREFIX_REALTIME_DATA_EQP);
// 璁㈤槄绉熸埛鎶ヨ鏁版嵁
mqttClient.subscribe(MqttConstant.TENANT_UP_PREFIX_REAL_FAULT_DATA);
System.out.println("admin璁㈤槄" + MqttConstant.TENANT_UP_PREFIX_REAL_FAULT_DATA);
@@ -132,13 +136,14 @@
//閲嶈繛
private void reconn() {
+ if (!isEnable()) return;
Timer timer = new Timer();
TimerTask task = new TimerTask() {
@Override
public void run() {
// 鍦ㄨ繖閲岀紪鍐欏畾鏃舵墽琛岀殑浠诲姟閫昏緫
- System.out.println("瀹氭椂浠诲姟鎵ц锛�" + new java.util.Date());
+ //System.out.println("瀹氭椂浠诲姟鎵ц锛�" + new java.util.Date());
if (mqttUtil.getMqttClient() == null || !mqttUtil.getMqttClient().isConnected()) {
try {
conn();
@@ -174,15 +179,17 @@
for (int i = 0; i < data.size(); i++) {
JSONObject obj = data.getJSONObject(i);
JSONObject item = new JSONObject();
+ //clientid
+ String clientid = obj.getString("clientid");
+ item.put("clientid", clientid);
+ //TODO 鏍￠獙绉熸埛id鏄惁瀛樺湪
+ if(!clientid.matches("^[^-]+-[^-]+-[^-]+$")) continue;
//username
item.put("username", obj.get("username"));
//杩炴帴鏃堕棿
String st = obj.getString("connected_at");
String upTime = DateUtils.zone2Str(st);
item.put("connectedAt", upTime);
- //clientid
- String clientid = obj.getString("clientid");
- item.put("clientid", clientid);
//鏄惁杩炴帴
Boolean connected = obj.getBoolean("connected");
item.put("connected", connected);
@@ -191,7 +198,7 @@
String[] info = clientid.split("-");
item.put("type", info[0]);
item.put("tenantId", info[1]);
- //item.put("code", info[2]);
+ item.put("code", info[2]);
if (connected) {
redisUtil.hset(String.format(MqttConstant.MQTT_ONLINE_CLIENT,item.get("tenantId").toString()) , clientid, item);
--
Gitblit v1.9.3