From 3f9c919fb8e3ec8aa804fe6db62163f5cfac41ee Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= Date: Sun, 11 May 2025 21:58:04 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E5=BD=93=E7=8A=B6=E6=80=81=E5=8F=91?= =?UTF-8?q?=E7=94=9F=E5=8F=98=E5=8C=96=E6=97=B6=E6=8E=A8=E9=80=81=E7=BB=99?= =?UTF-8?q?=E5=89=8D=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iflytop/gd/app/core/listener/DeviceStateListener.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/com/iflytop/gd/app/core/listener/DeviceStateListener.java b/src/main/java/com/iflytop/gd/app/core/listener/DeviceStateListener.java index 02ed0ad..d1457e9 100644 --- a/src/main/java/com/iflytop/gd/app/core/listener/DeviceStateListener.java +++ b/src/main/java/com/iflytop/gd/app/core/listener/DeviceStateListener.java @@ -1,5 +1,8 @@ package com.iflytop.gd.app.core.listener; +import com.iflytop.gd.app.service.DeviceStateService; +import com.iflytop.gd.app.service.WebSocketService; +import com.iflytop.gd.common.constant.WebSocketMessageType; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; @@ -11,11 +14,14 @@ import java.beans.PropertyChangeListener; @Component @RequiredArgsConstructor public class DeviceStateListener implements PropertyChangeListener { + private final WebSocketService webSocketService; + private final DeviceStateService deviceStateService; // 在此处理DeviceState的变化事件 @Override public void propertyChange(PropertyChangeEvent event) { log.info("设备状态发生改变，类型{} ，from {} to {}", event.getPropertyName(), event.getOldValue(), event.getNewValue()); + webSocketService.push(WebSocketMessageType.STATUS, deviceStateService.getDeviceState()); } } \ No newline at end of file