fix:业务指令修改

src/main/java/com/iflytop/sgs/app/cmd/control/CleanStartCommand.java

@@ -25,7 +25,7 @@ import java.util.concurrent.CompletableFuture;
 @Slf4j
 @Component
 @RequiredArgsConstructor
-@CommandMapping("heat_start")//业务指令注解
+@CommandMapping("clean_start")//业务指令注解
 public class CleanStartCommand extends BaseCommandHandler {
     private final SolutionModuleService solutionModuleService;
     private final DevicePositionService devicePositionService;

src/main/java/com/iflytop/sgs/app/cmd/control/DryStartCommand.java

@@ -22,7 +22,7 @@ import java.util.concurrent.CompletableFuture;
 @Slf4j
 @Component
 @RequiredArgsConstructor
-@CommandMapping("_start")//业务指令注解
+@CommandMapping("dry_start")//业务指令注解
 public class DryStartCommand extends BaseCommandHandler {
     private final HeatModuleService heatModuleService;
     private final DeviceStateService deviceStateService;

src/main/java/com/iflytop/sgs/app/cmd/control/LiquidAddCommand.java

@@ -38,9 +38,15 @@ public class LiquidAddCommand extends BaseCommandHandler {
 
     @Override
     public CompletableFuture<Void> handle(CmdDTO cmdDTO) {
+        //todo "params": {
+        //         "columns":[{"column":1,"solutionId":1,"volume":10},
+        //                   {"column":2,"solutionId":2,"volume":10},
+        //                   {"column":3,"solutionId":3,"volume":10}]
+        //    }
+
         String solution = cmdDTO.getStringParam("solution");
         ValveStateCode valveStateCode = ValveStateCode.valueOf(solution);//解析加液通道
-        double volume = cmdDTO.getDoubleParam("volume");//解析加液量
+        double volume = cmdDTO.getDoubleParam("column");//解析加液量
         JSONArray jsonArray = cmdDTO.getJSONArrayParam("index");//解析加液列
         Double scale = Double.valueOf(systemConfigService.getSystemConfigValueByCode(valveStateCode.getSystemConfigCode()));//获取转换系数
         Double position = volume * scale;

src/main/java/com/iflytop/sgs/app/cmd/control/LiquidReduceCommand.java

@@ -38,7 +38,8 @@ public class LiquidReduceCommand extends BaseCommandHandler {
 
     @Override
     public CompletableFuture<Void> handle(CmdDTO cmdDTO) {
-        double volume=cmdDTO.getDoubleParam("volume");//解析加液量
+        //todo 无参数
+        double volume=cmdDTO.getDoubleParam("column");//解析加液量
         JSONArray jsonArray =cmdDTO.getJSONArrayParam("index");//解析加液列
         Double position = volume;//蠕动泵移动距离
         Point3D liquidAreaTrayPoint = devicePositionService.getPosition(DevicePositionCode.liquidAreaTrayPoint).getPoint3D(); //获取加液区上方点位

src/main/java/com/iflytop/sgs/app/service/device/module/SolutionModuleService.java

@@ -112,6 +112,16 @@ public class SolutionModuleService {
         CommandUtil.wait(deviceCommandFuture);
 
     }
+
+    /**
+     * 加液泵排空
+     */
+    public void liquidPumpEmpty(String cmdId, String cmdCode, double position) throws Exception {
+        DeviceCommandBundle deviceCommandBundle = DeviceCommandGenerator.liquidPumpMoveBy(position);
+        CommandFuture deviceCommandFuture = deviceCommandService.sendCommand(cmdId, cmdCode, deviceCommandBundle);
+        CommandUtil.wait(deviceCommandFuture);
+
+    }
     /**
      * 电磁阀转换通道
      * */