From 9e9cc2231327011ad719b2a307fe047aee1059a2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= Date: Mon, 26 May 2025 11:20:02 +0800 Subject: [PATCH] =?UTF-8?q?=E9=98=80=E6=8C=87=E4=BB=A4=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cmd/debug/DebugDisabledAllMotorCommand.java | 31 ------------------- .../app/cmd/debug/DebugEnableAllMotorCommand.java | 31 ------------------- .../sgs/app/cmd/debug/DebugValveCloseCommand.java | 36 ---------------------- .../cmd/debug/DebugValveOpenThickWayCommand.java | 36 ---------------------- .../cmd/debug/DebugValveOpenThinWayCommand.java | 36 ---------------------- .../cmd/debug/DebugValveOpenVacantWayCommand.java | 36 ---------------------- .../cmd/debug/DebugValveOpenWasteWayCommand.java | 36 ---------------------- .../cmd/debug/DebugValveSwitchThickCommand.java | 36 ++++++++++++++++++++++ .../app/cmd/debug/DebugValveSwitchThinCommand.java | 36 ++++++++++++++++++++++ .../cmd/debug/DebugValveSwitchVacantCommand.java | 36 ++++++++++++++++++++++ .../cmd/debug/DebugValveSwitchWasteCommand.java | 36 ++++++++++++++++++++++ .../cmd/debug/DebugValveSwitchWaterCommand.java | 36 ++++++++++++++++++++++ .../debug/step/DebugDisabledAllMotorCommand.java | 31 +++++++++++++++++++ .../cmd/debug/step/DebugEnableAllMotorCommand.java | 31 +++++++++++++++++++ 14 files changed, 242 insertions(+), 242 deletions(-) delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugDisabledAllMotorCommand.java delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugEnableAllMotorCommand.java delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveCloseCommand.java delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThickWayCommand.java delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThinWayCommand.java delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenVacantWayCommand.java delete mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenWasteWayCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThickCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThinCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchVacantCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWasteCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWaterCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugDisabledAllMotorCommand.java create mode 100644 src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugEnableAllMotorCommand.java diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugDisabledAllMotorCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugDisabledAllMotorCommand.java deleted file mode 100644 index e1e102b..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugDisabledAllMotorCommand.java +++ /dev/null @@ -1,31 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug.step; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.StepCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 失能所有电机 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("debug_disabled_all_motor") -public class DebugDisabledAllMotorCommand extends BaseCommandHandler { - private final StepCommandService stepCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) throws Exception { - - return runAsync(() -> { - //stepCommandService.disabilityAll(); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugEnableAllMotorCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugEnableAllMotorCommand.java deleted file mode 100644 index 5b37cff..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugEnableAllMotorCommand.java +++ /dev/null @@ -1,31 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug.step; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.StepCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 使能所有电机 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("debug_enable_all_motor") -public class DebugEnableAllMotorCommand extends BaseCommandHandler { - private final StepCommandService stepCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) throws Exception { - - return runAsync(() -> { - //stepCommandService.enableAll(); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveCloseCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveCloseCommand.java deleted file mode 100644 index 10d9490..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveCloseCommand.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.DeviceCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import com.iflytop.sgs.common.cmd.CommandFuture; -import com.iflytop.sgs.common.cmd.DeviceCommandBundle; -import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; -import com.iflytop.sgs.common.utils.CommandUtil; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 打开冷却风扇 todo 需要与小何确定次序 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("liquid_valve_open_vacant") -public class DebugValveCloseCommand extends BaseCommandHandler { - private final DeviceCommandService deviceCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) { - return runAsync(() -> { - DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveClose(); - CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); - CommandUtil.wait(deviceCommandFuture); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThickWayCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThickWayCommand.java deleted file mode 100644 index a489507..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThickWayCommand.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.DeviceCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import com.iflytop.sgs.common.cmd.CommandFuture; -import com.iflytop.sgs.common.cmd.DeviceCommandBundle; -import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; -import com.iflytop.sgs.common.utils.CommandUtil; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 打开冷却风扇 todo 需要与小何确定次序 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("liquid_valve_open_thick") -public class DebugValveOpenThickWayCommand extends BaseCommandHandler { - private final DeviceCommandService deviceCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) { - return runAsync(() -> { - DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(1); - CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); - CommandUtil.wait(deviceCommandFuture); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThinWayCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThinWayCommand.java deleted file mode 100644 index fba9081..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenThinWayCommand.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.DeviceCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import com.iflytop.sgs.common.cmd.CommandFuture; -import com.iflytop.sgs.common.cmd.DeviceCommandBundle; -import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; -import com.iflytop.sgs.common.utils.CommandUtil; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 打开冷却风扇 todo 需要与小何确定次序 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("liquid_valve_open_thin") -public class DebugValveOpenThinWayCommand extends BaseCommandHandler { - private final DeviceCommandService deviceCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) { - return runAsync(() -> { - DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(2); - CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); - CommandUtil.wait(deviceCommandFuture); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenVacantWayCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenVacantWayCommand.java deleted file mode 100644 index 049b61d..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenVacantWayCommand.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.DeviceCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import com.iflytop.sgs.common.cmd.CommandFuture; -import com.iflytop.sgs.common.cmd.DeviceCommandBundle; -import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; -import com.iflytop.sgs.common.utils.CommandUtil; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 打开冷却风扇 todo 需要与小何确定次序 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("liquid_valve_open_vacant") -public class DebugValveOpenVacantWayCommand extends BaseCommandHandler { - private final DeviceCommandService deviceCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) { - return runAsync(() -> { - DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(3); - CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); - CommandUtil.wait(deviceCommandFuture); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenWasteWayCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenWasteWayCommand.java deleted file mode 100644 index fa875f8..0000000 --- a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveOpenWasteWayCommand.java +++ /dev/null @@ -1,36 +0,0 @@ -package com.iflytop.sgs.app.cmd.debug; - -import com.iflytop.sgs.app.core.BaseCommandHandler; -import com.iflytop.sgs.app.model.dto.CmdDTO; -import com.iflytop.sgs.app.service.device.DeviceCommandService; -import com.iflytop.sgs.common.annotation.CommandMapping; -import com.iflytop.sgs.common.cmd.CommandFuture; -import com.iflytop.sgs.common.cmd.DeviceCommandBundle; -import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; -import com.iflytop.sgs.common.utils.CommandUtil; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.util.concurrent.CompletableFuture; - -/** - * 打开冷却风扇 todo 需要与小何确定次序 - */ -@Slf4j -@Component -@RequiredArgsConstructor -@CommandMapping("liquid_valve_open_waste") -public class DebugValveOpenWasteWayCommand extends BaseCommandHandler { - private final DeviceCommandService deviceCommandService; - - @Override - public CompletableFuture handle(CmdDTO cmdDTO) { - return runAsync(() -> { - DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(4); - CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); - CommandUtil.wait(deviceCommandFuture); - }); - } -} - diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThickCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThickCommand.java new file mode 100644 index 0000000..3d124e2 --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThickCommand.java @@ -0,0 +1,36 @@ +package com.iflytop.sgs.app.cmd.debug; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.DeviceCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import com.iflytop.sgs.common.cmd.CommandFuture; +import com.iflytop.sgs.common.cmd.DeviceCommandBundle; +import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; +import com.iflytop.sgs.common.utils.CommandUtil; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 阀转换到浓硝酸通道 todo 需要与小何确定次序 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("valve_switch_thick") +public class DebugValveSwitchThickCommand extends BaseCommandHandler { + private final DeviceCommandService deviceCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) { + return runAsync(() -> { + DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(1); + CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); + CommandUtil.wait(deviceCommandFuture); + }); + } +} + diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThinCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThinCommand.java new file mode 100644 index 0000000..d82d807 --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchThinCommand.java @@ -0,0 +1,36 @@ +package com.iflytop.sgs.app.cmd.debug; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.DeviceCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import com.iflytop.sgs.common.cmd.CommandFuture; +import com.iflytop.sgs.common.cmd.DeviceCommandBundle; +import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; +import com.iflytop.sgs.common.utils.CommandUtil; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 阀转换到稀硝酸通道 todo 需要与小何确定次序 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("valve_switch_thin") +public class DebugValveSwitchThinCommand extends BaseCommandHandler { + private final DeviceCommandService deviceCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) { + return runAsync(() -> { + DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(2); + CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); + CommandUtil.wait(deviceCommandFuture); + }); + } +} + diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchVacantCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchVacantCommand.java new file mode 100644 index 0000000..4dee67c --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchVacantCommand.java @@ -0,0 +1,36 @@ +package com.iflytop.sgs.app.cmd.debug; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.DeviceCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import com.iflytop.sgs.common.cmd.CommandFuture; +import com.iflytop.sgs.common.cmd.DeviceCommandBundle; +import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; +import com.iflytop.sgs.common.utils.CommandUtil; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 阀转换到空通道 todo 需要与小何确定次序 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("valve_switch_vacant") +public class DebugValveSwitchVacantCommand extends BaseCommandHandler { + private final DeviceCommandService deviceCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) { + return runAsync(() -> { + DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveClose(); + CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); + CommandUtil.wait(deviceCommandFuture); + }); + } +} + diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWasteCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWasteCommand.java new file mode 100644 index 0000000..6673fc1 --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWasteCommand.java @@ -0,0 +1,36 @@ +package com.iflytop.sgs.app.cmd.debug; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.DeviceCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import com.iflytop.sgs.common.cmd.CommandFuture; +import com.iflytop.sgs.common.cmd.DeviceCommandBundle; +import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; +import com.iflytop.sgs.common.utils.CommandUtil; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 阀转换到废液通道 todo 需要与小何确定次序 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("valve_switch_waste") +public class DebugValveSwitchWasteCommand extends BaseCommandHandler { + private final DeviceCommandService deviceCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) { + return runAsync(() -> { + DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(4); + CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); + CommandUtil.wait(deviceCommandFuture); + }); + } +} + diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWaterCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWaterCommand.java new file mode 100644 index 0000000..319d153 --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/DebugValveSwitchWaterCommand.java @@ -0,0 +1,36 @@ +package com.iflytop.sgs.app.cmd.debug; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.DeviceCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import com.iflytop.sgs.common.cmd.CommandFuture; +import com.iflytop.sgs.common.cmd.DeviceCommandBundle; +import com.iflytop.sgs.common.cmd.DeviceCommandGenerator; +import com.iflytop.sgs.common.utils.CommandUtil; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 阀转换到蒸馏水通道 todo 需要与小何确定次序 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("valve_switch_water") +public class DebugValveSwitchWaterCommand extends BaseCommandHandler { + private final DeviceCommandService deviceCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) { + return runAsync(() -> { + DeviceCommandBundle deviceCommand = DeviceCommandGenerator.valveTurn(3); + CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdDTO.getCommandId(), cmdDTO.getCommand(), deviceCommand); + CommandUtil.wait(deviceCommandFuture); + }); + } +} + diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugDisabledAllMotorCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugDisabledAllMotorCommand.java new file mode 100644 index 0000000..e1e102b --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugDisabledAllMotorCommand.java @@ -0,0 +1,31 @@ +package com.iflytop.sgs.app.cmd.debug.step; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.StepCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 失能所有电机 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("debug_disabled_all_motor") +public class DebugDisabledAllMotorCommand extends BaseCommandHandler { + private final StepCommandService stepCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) throws Exception { + + return runAsync(() -> { + //stepCommandService.disabilityAll(); + }); + } +} + diff --git a/src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugEnableAllMotorCommand.java b/src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugEnableAllMotorCommand.java new file mode 100644 index 0000000..5b37cff --- /dev/null +++ b/src/main/java/com/iflytop/sgs/app/cmd/debug/step/DebugEnableAllMotorCommand.java @@ -0,0 +1,31 @@ +package com.iflytop.sgs.app.cmd.debug.step; + +import com.iflytop.sgs.app.core.BaseCommandHandler; +import com.iflytop.sgs.app.model.dto.CmdDTO; +import com.iflytop.sgs.app.service.device.StepCommandService; +import com.iflytop.sgs.common.annotation.CommandMapping; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.concurrent.CompletableFuture; + +/** + * 使能所有电机 + */ +@Slf4j +@Component +@RequiredArgsConstructor +@CommandMapping("debug_enable_all_motor") +public class DebugEnableAllMotorCommand extends BaseCommandHandler { + private final StepCommandService stepCommandService; + + @Override + public CompletableFuture handle(CmdDTO cmdDTO) throws Exception { + + return runAsync(() -> { + //stepCommandService.enableAll(); + }); + } +} +