From 7d22ff04f867071ed77809fb08f103446738eeec Mon Sep 17 00:00:00 2001
From: baoshiwei <baoshiwei@shlanbao.cn>
Date: 星期三, 11 十二月 2024 09:43:27 +0800
Subject: [PATCH] 增加mqtt启用开关
---
jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/DryRealTimeDataController.java | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/DryRealTimeDataController.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/DryRealTimeDataController.java
index 09ee499..e58f432 100644
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/DryRealTimeDataController.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/DryRealTimeDataController.java
@@ -94,7 +94,7 @@
@PostMapping("/sendRealTimeDataJson")
public Result<?> realTimeDataJson(@RequestBody RealTimeDataVo realTimeDataVo) {
try {
- if ("user".equals(mqttConfig.getRole())){
+ if (mqttConfig.isEnable() && "user".equals(mqttConfig.getRole())){
MqttMessage mqttMessage = new MqttMessage();
mqttMessage.setQos(0);
mqttMessage.setPayload(JSONObject.toJSONString(realTimeDataVo).getBytes());
@@ -178,6 +178,14 @@
// return Result.error("AI璇嗗埆鏈嶅姟寮傚父");
// }
// }
+
+ /**
+ * 鏍规嵁璁惧鍜岀鎴锋煡璇㈣璁惧绫诲瀷鐨勫共鐕ラ厤鏂癸紝灏嗛厤鏂硅浆鎴恱ml鏍煎紡锛屼互瀛楃涓叉柟寮忚繑鍥�
+ * @param tenantId
+ * @param eqpCode
+ * @return
+ * @throws JAXBException
+ */
@ApiOperation(value="骞茬嚗閰嶆柟鑾峰彇", notes="骞茬嚗閰嶆柟涓嬪彂")
@GetMapping(value = "/queryFormula")
public Result<String> queryFormulaByEqpType(Integer tenantId, String eqpCode) throws JAXBException {
--
Gitblit v1.9.3