From fb2f11d7d502ceacbe7fbed176bea4ab0f152f69 Mon Sep 17 00:00:00 2001
From: liulin <lin.liu@88.com>
Date: 星期四, 03 七月 2025 18:17:59 +0800
Subject: [PATCH] 添加mqtt
---
src/main/java/com/lunhan/water/host/mqtt/PushCallback.java | 24 +++++++++++++++++++++---
1 files changed, 21 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/lunhan/water/host/mqtt/PushCallback.java b/src/main/java/com/lunhan/water/host/mqtt/PushCallback.java
index 261ab6f..7d88313 100644
--- a/src/main/java/com/lunhan/water/host/mqtt/PushCallback.java
+++ b/src/main/java/com/lunhan/water/host/mqtt/PushCallback.java
@@ -2,13 +2,17 @@
import com.lunhan.water.common.enums.ELogger;
import com.lunhan.water.common.util.LoggerUtil;
+import com.lunhan.water.common.util.SpringUtil;
import com.lunhan.water.common.util.ThreadPoolUtil;
+import com.lunhan.water.service.PaymentRecordsService;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
import java.nio.charset.StandardCharsets;
+import java.util.Objects;
;
@@ -31,7 +35,8 @@
public class PushCallback implements MqttCallback {
private static final Logger LOGGER_DEBUG = LoggerUtil.get(ELogger.DEBUG);
private static final Logger LOGGER_ERROR = LoggerUtil.get(ELogger.SYS_ERROR);
-
+ @Autowired
+ PaymentRecordsService paymentRecordsService;
private MQTTSubsribe mqttSubsribe;
public PushCallback(MQTTSubsribe mqttSubsribe) {
@@ -73,8 +78,21 @@
//这里可以针对收到的消息做处理
ThreadPoolUtil.getDefaultPool().execute(() -> {
try {
- //调用方法
- //dataUploadYwjRecordService.mqttReceived(topic, msg);
+ if (Objects.nonNull(paymentRecordsService)) {
+ //调用方法
+ paymentRecordsService.mqttReceived(topic, msg);
+ } else {
+ try {
+ System.out.println("paymentRecordsService bean尚未初始化...");
+ paymentRecordsService = SpringUtil.getBean(PaymentRecordsService.class);
+ System.out.println("paymentRecordsService 初始化bean成功！");
+ } catch (Exception ignored) {
+ }
+ if (Objects.nonNull(paymentRecordsService)) {
+ //调用方法
+ paymentRecordsService.mqttReceived(topic, msg);
+ }
+ }
} catch (Exception e) {
LOGGER_ERROR.error("messageArrived", e);
}
--
Gitblit v1.9.3