|
@ -7,6 +7,7 @@ import com.iflytop.gd.common.annotation.CommandMapping; |
|
|
import com.iflytop.gd.common.cmd.CommandFuture; |
|
|
import com.iflytop.gd.common.cmd.CommandFuture; |
|
|
import com.iflytop.gd.common.cmd.DeviceCommandBundle; |
|
|
import com.iflytop.gd.common.cmd.DeviceCommandBundle; |
|
|
import com.iflytop.gd.common.cmd.DeviceCommandGenerator; |
|
|
import com.iflytop.gd.common.cmd.DeviceCommandGenerator; |
|
|
|
|
|
import com.iflytop.gd.common.enums.AcidPumpDevice; |
|
|
import com.iflytop.gd.common.enums.cmd.CmdDirection; |
|
|
import com.iflytop.gd.common.enums.cmd.CmdDirection; |
|
|
import lombok.RequiredArgsConstructor; |
|
|
import lombok.RequiredArgsConstructor; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
import lombok.extern.slf4j.Slf4j; |
|
@ -27,22 +28,23 @@ public class LiquidPumpStartCommandHandler extends BaseCommandHandler { |
|
|
@Override |
|
|
@Override |
|
|
public CompletableFuture<Void> handle(CmdDTO cmdDTO) { |
|
|
public CompletableFuture<Void> handle(CmdDTO cmdDTO) { |
|
|
return runAsync(() -> { |
|
|
return runAsync(() -> { |
|
|
Integer index = cmdDTO.getIntegerParam("index"); |
|
|
|
|
|
|
|
|
String index = cmdDTO.getStringParam("index"); |
|
|
String direction = cmdDTO.getStringParam("direction"); |
|
|
String direction = cmdDTO.getStringParam("direction"); |
|
|
Double volume = cmdDTO.getDoubleParam("volume"); |
|
|
Double volume = cmdDTO.getDoubleParam("volume"); |
|
|
Double velocity = cmdDTO.getDoubleParam("velocity"); |
|
|
Double velocity = cmdDTO.getDoubleParam("velocity"); |
|
|
CmdDirection directionEnum = CmdDirection.valueOf(direction); |
|
|
CmdDirection directionEnum = CmdDirection.valueOf(direction); |
|
|
|
|
|
AcidPumpDevice acidPumpDevice = AcidPumpDevice.valueOf(index); |
|
|
DeviceCommandBundle deviceCommand; |
|
|
DeviceCommandBundle deviceCommand; |
|
|
if(velocity != null) { |
|
|
if(velocity != null) { |
|
|
switch (index) { |
|
|
|
|
|
case 1 -> deviceCommand = DeviceCommandGenerator.acidPump1Set(velocity); |
|
|
|
|
|
case 2 -> deviceCommand = DeviceCommandGenerator.acidPump2Set(velocity); |
|
|
|
|
|
case 3 -> deviceCommand = DeviceCommandGenerator.acidPump3Set(velocity); |
|
|
|
|
|
case 4 -> deviceCommand = DeviceCommandGenerator.acidPump4Set(velocity); |
|
|
|
|
|
case 5 -> deviceCommand = DeviceCommandGenerator.acidPump5Set(velocity); |
|
|
|
|
|
case 6 -> deviceCommand = DeviceCommandGenerator.acidPump6Set(velocity); |
|
|
|
|
|
case 7 -> deviceCommand = DeviceCommandGenerator.acidPump7Set(velocity); |
|
|
|
|
|
case 8 -> deviceCommand = DeviceCommandGenerator.acidPump8Set(velocity); |
|
|
|
|
|
|
|
|
switch (acidPumpDevice) { |
|
|
|
|
|
case acid_pump_01 -> deviceCommand = DeviceCommandGenerator.acidPump1Set(velocity); |
|
|
|
|
|
case acid_pump_02 -> deviceCommand = DeviceCommandGenerator.acidPump2Set(velocity); |
|
|
|
|
|
case acid_pump_03 -> deviceCommand = DeviceCommandGenerator.acidPump3Set(velocity); |
|
|
|
|
|
case acid_pump_04 -> deviceCommand = DeviceCommandGenerator.acidPump4Set(velocity); |
|
|
|
|
|
case acid_pump_05 -> deviceCommand = DeviceCommandGenerator.acidPump5Set(velocity); |
|
|
|
|
|
case acid_pump_06 -> deviceCommand = DeviceCommandGenerator.acidPump6Set(velocity); |
|
|
|
|
|
case acid_pump_07 -> deviceCommand = DeviceCommandGenerator.acidPump7Set(velocity); |
|
|
|
|
|
case acid_pump_08 -> deviceCommand = DeviceCommandGenerator.acidPump8Set(velocity); |
|
|
default -> throw new RuntimeException("index 未找到"); |
|
|
default -> throw new RuntimeException("index 未找到"); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
@ -50,15 +52,15 @@ public class LiquidPumpStartCommandHandler extends BaseCommandHandler { |
|
|
commandWait(deviceCommandFuture); |
|
|
commandWait(deviceCommandFuture); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
switch (index) { |
|
|
|
|
|
case 1 -> deviceCommand = DeviceCommandGenerator.acidPump1Move(directionEnum, volume); |
|
|
|
|
|
case 2 -> deviceCommand = DeviceCommandGenerator.acidPump2Move(directionEnum, volume); |
|
|
|
|
|
case 3 -> deviceCommand = DeviceCommandGenerator.acidPump3Move(directionEnum, volume); |
|
|
|
|
|
case 4 -> deviceCommand = DeviceCommandGenerator.acidPump4Move(directionEnum, volume); |
|
|
|
|
|
case 5 -> deviceCommand = DeviceCommandGenerator.acidPump5Move(directionEnum, volume); |
|
|
|
|
|
case 6 -> deviceCommand = DeviceCommandGenerator.acidPump6Move(directionEnum, volume); |
|
|
|
|
|
case 7 -> deviceCommand = DeviceCommandGenerator.acidPump7Move(directionEnum, volume); |
|
|
|
|
|
case 8 -> deviceCommand = DeviceCommandGenerator.acidPump8Move(directionEnum, volume); |
|
|
|
|
|
|
|
|
switch (acidPumpDevice) { |
|
|
|
|
|
case acid_pump_01 -> deviceCommand = DeviceCommandGenerator.acidPump1Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_02 -> deviceCommand = DeviceCommandGenerator.acidPump2Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_03 -> deviceCommand = DeviceCommandGenerator.acidPump3Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_04 -> deviceCommand = DeviceCommandGenerator.acidPump4Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_05 -> deviceCommand = DeviceCommandGenerator.acidPump5Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_06 -> deviceCommand = DeviceCommandGenerator.acidPump6Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_07 -> deviceCommand = DeviceCommandGenerator.acidPump7Move(directionEnum, volume); |
|
|
|
|
|
case acid_pump_08 -> deviceCommand = DeviceCommandGenerator.acidPump8Move(directionEnum, volume); |
|
|
default -> throw new RuntimeException("index 未找到"); |
|
|
default -> throw new RuntimeException("index 未找到"); |
|
|
} |
|
|
} |
|
|
CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); |
|
|
CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); |
|
|