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