Browse Source

移至commandFeedback 监听

master
王梦远 4 days ago
parent
commit
683ba953aa
  1. 14
      src/main/java/com/iflytop/handacid/app/core/event/StateChangeEvent.java
  2. 18
      src/main/java/com/iflytop/handacid/app/core/listener/CommandFeedbackListener.java
  3. 2
      src/main/java/com/iflytop/handacid/app/service/DeviceInitService.java

14
src/main/java/com/iflytop/handacid/app/core/event/StateChangeEvent.java

@ -1,14 +0,0 @@
package com.iflytop.handacid.app.core.event;
import lombok.AllArgsConstructor;
import lombok.Data;
/**
* 状态变更事件
*/
@Data
@AllArgsConstructor
public class StateChangeEvent {
private String fieldPath;
private Object oldValue;
private Object newValue;
}

18
src/main/java/com/iflytop/handacid/app/core/listener/CommandFeedbackListener.java

@ -0,0 +1,18 @@
package com.iflytop.handacid.app.core.listener;
import com.iflytop.handacid.app.core.event.CommandFeedbackEvent;
import com.iflytop.handacid.app.service.DeviceCommandService;
import lombok.RequiredArgsConstructor;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
@Component
@RequiredArgsConstructor
public class CommandFeedbackListener {
private final DeviceCommandService deviceCommandService;
@EventListener
public void handleCommandFeedbackEvent(CommandFeedbackEvent event) {
deviceCommandService.completeCommandResponse(event.getJsonResponse());
}
}

2
src/main/java/com/iflytop/handacid/app/service/DeviceInitService.java

@ -74,7 +74,7 @@ public class DeviceInitService {
/**
* 初始化所有设备使能
*/
public void initEnable() throws Exception {
public void initEnable() {
DeviceCommand pump1Enable = DeviceCommandGenerator.pump1Enable();
deviceCommandService.sendCommand(pump1Enable);

Loading…
Cancel
Save