diff --git a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java index fa77720..bd70535 100644 --- a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java +++ b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java @@ -319,7 +319,7 @@ public class IotMachineEventGeneratorJob { newState.getMachineIotMac(), currJobCount); stopMachineWorkingCommand.setTimestamp(event.getReportTime()); out.collect(stopMachineWorkingCommand); - } else if (oldState.getStatus() == 2 && newState.getStatus() == 1) { + } else if ((oldState.getStatus() == 2 || oldState.getStatus() == 1) && newState.getStatus() == 1) { // 设备开始工作 StartMachineWorkingCommand startMachineWorkingCommand = new StartMachineWorkingCommand(newState.getMachineId(), newState.getMachineIotMac(), currJobCount);