|
|
@ -319,7 +319,7 @@ public class IotMachineEventGeneratorJob { |
|
|
newState.getMachineIotMac(), currJobCount); |
|
|
newState.getMachineIotMac(), currJobCount); |
|
|
stopMachineWorkingCommand.setTimestamp(event.getReportTime()); |
|
|
stopMachineWorkingCommand.setTimestamp(event.getReportTime()); |
|
|
out.collect(stopMachineWorkingCommand); |
|
|
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(), |
|
|
StartMachineWorkingCommand startMachineWorkingCommand = new StartMachineWorkingCommand(newState.getMachineId(), |
|
|
newState.getMachineIotMac(), currJobCount); |
|
|
newState.getMachineIotMac(), currJobCount); |
|
|
|