From ca1d4a60b4493b0925552791da5effb42962fa39 Mon Sep 17 00:00:00 2001
From: zhuguifei <zhuguifei@zhuguifeideiMac.local>
Date: 星期四, 12 十二月 2024 13:28:21 +0800
Subject: [PATCH] 添加mqtt故障上报开关
---
jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
index 8def570..63f85c1 100755
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
@@ -71,6 +71,9 @@
@Autowired
private MqttUtil mqttUtil;
+ @Value(value = "${jeecg.mqtt.enable}")
+ private boolean mqttEnable;
+
public String getTemporaryToken() {
if (token == null) {
RedisUtil redisUtil = SpringContextUtils.getBean(RedisUtil.class);
@@ -480,7 +483,7 @@
}
@Override
- public Result<?> fitFultRecord(RealTimeDataVo vo) {
+ public Result<?> fitFaultRecord(RealTimeDataVo vo) {
TenantContext.setTenant(vo.getTenantid()+"");
ThreadUtil.execute(() -> {
try {
@@ -492,7 +495,7 @@
//澶勭悊缁撴潫鍚庯紝灏唕edis涓疄鏃舵暟鎹彂閫佽嚦浜戞湇鍔″櫒
Map<Object, Object> toCloudFaultMap = redisUtil.hmget(MqttConstant.MQTT_REAL_FAULT);
- if(!toCloudFaultMap.isEmpty()){
+ if(mqttEnable && !toCloudFaultMap.isEmpty()){
MqMessage< Map<Object, Object>> message = new MqMessage<>();
message.setData(toCloudFaultMap);
message.setTentId(vo.getTenantid()+"");
--
Gitblit v1.9.3