|
|
@ -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()); |
|
|
|
} |
|
|
|
|
|
|
|
} |