|
|
@ -39,7 +39,7 @@ public class CMDService { |
|
|
|
Map<String, String> cmdMap; |
|
|
|
|
|
|
|
@Autowired |
|
|
|
public CMDService(DeviceService deviceService, WebSocketService webSocketService, BaseDataService baseDataService, TasksService tasksService, TaskStepsService taskStepsService, ContainerService containerService) { |
|
|
|
public CMDService(DeviceService deviceService, WebSocketService webSocketService, BaseDataService baseDataService, TasksService tasksService, TaskStepsService taskStepsService, ContainerService containerService) { |
|
|
|
this.deviceService = deviceService; |
|
|
|
this.webSocketService = webSocketService; |
|
|
|
this.baseDataService = baseDataService; |
|
|
@ -136,19 +136,19 @@ public class CMDService { |
|
|
|
// 打开钩子 |
|
|
|
cmdList.add(() -> deviceService.openClaw()); |
|
|
|
// 下降高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2 - Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2 - Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
// 闭合钩子 |
|
|
|
cmdList.add(() -> deviceService.closeClaw()); |
|
|
|
// 机械臂抬起高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2 + Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String)map.get("sys_offset_tube_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2 + Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String) map.get("sys_offset_tube_height")))); |
|
|
|
// 机械臂移动到指定加热位 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z2 + Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String)map.get("sys_offset_tube_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z2 + Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String) map.get("sys_offset_tube_height")))); |
|
|
|
// 机械臂下降高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1)); |
|
|
|
// 机械臂打开钩子 |
|
|
|
cmdList.add(() -> deviceService.openClaw()); |
|
|
|
// 机械臂上升高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1 + Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1 + Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
// 关闭钩子 |
|
|
|
cmdList.add(() -> deviceService.closeClaw()); |
|
|
|
|
|
|
@ -311,7 +311,7 @@ public class CMDService { |
|
|
|
if (params.get("temperature") == null) { |
|
|
|
temperature = Double.parseDouble(baseDataService.getHeatAreaTemperatureById((Integer) params.get("heatId"))); |
|
|
|
} else { |
|
|
|
temperature = Double.parseDouble((String) params.get("temperature")) ; |
|
|
|
temperature = Double.parseDouble((String) params.get("temperature")); |
|
|
|
} |
|
|
|
cmdList.add(() -> deviceService.startHeating(hardwareId, temperature)); |
|
|
|
return cmdList; |
|
|
@ -354,19 +354,19 @@ public class CMDService { |
|
|
|
// 打开钩子 |
|
|
|
cmdList.add(() -> deviceService.openClaw()); |
|
|
|
// 下降高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1 - Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1 - Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
// 闭合钩子 |
|
|
|
cmdList.add(() -> deviceService.closeClaw()); |
|
|
|
// 机械臂抬起高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1 + Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String)map.get("sys_offset_tube_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x1, y1, z1 + Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String) map.get("sys_offset_tube_height")))); |
|
|
|
// 机械臂移动到加液位高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z1 + Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String)map.get("sys_offset_tube_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z1 + Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")) + Integer.parseInt((String) map.get("sys_offset_tube_height")))); |
|
|
|
// 机械臂下降高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2)); |
|
|
|
// 机械臂打开钩子 |
|
|
|
cmdList.add(() -> deviceService.openClaw()); |
|
|
|
// 机械臂上升高度 |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2 + Integer.parseInt((String)map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
cmdList.add(() -> deviceService.moveRailArmToPoint(x2, y2, z2 + Integer.parseInt((String) map.get("sys_offset_tube_rack_take_height")))); |
|
|
|
// 关闭钩子 |
|
|
|
cmdList.add(() -> deviceService.closeClaw()); |
|
|
|
|
|
|
@ -410,7 +410,7 @@ public class CMDService { |
|
|
|
List<Supplier<Boolean>> cmdList = new ArrayList<>(); |
|
|
|
// 获取容器信息 |
|
|
|
ContainerListVO container = baseDataService.getContainerBySolutionId((Integer) params.get("solutionId")); |
|
|
|
if(container.getCapacityTotal() - container.getCapacityUsed() < (Integer) params.get("volume")) { |
|
|
|
if (container.getCapacityTotal() - container.getCapacityUsed() < (Integer) params.get("volume")) { |
|
|
|
cmdList.add(() -> false); |
|
|
|
} |
|
|
|
|
|
|
@ -423,10 +423,10 @@ public class CMDService { |
|
|
|
// 泵id |
|
|
|
String pumpId = baseDataService.getPumpIdBySolutionId((Integer) params.get("solutionId")); |
|
|
|
if (params.get("flowRate") != null) { |
|
|
|
cmdList.add(() -> deviceService.setFlowRate(Integer.parseInt(pumpId), (Integer) params.get("flowRate"))); |
|
|
|
cmdList.add(() -> deviceService.setFlowRate(pumpId, (Integer) params.get("flowRate"))); |
|
|
|
} |
|
|
|
cmdList.add(() -> deviceService.moveLiquidArmToPoint(x, y, z)); |
|
|
|
cmdList.add(() -> deviceService.addLiquid(Long.valueOf(pumpId), ((Integer) params.get("volume")))); |
|
|
|
cmdList.add(() -> deviceService.addLiquid(pumpId, ((Integer) params.get("volume")))); |
|
|
|
cmdList.add(() -> updateVolume(params)); |
|
|
|
|
|
|
|
return cmdList; |
|
|
@ -455,13 +455,13 @@ public class CMDService { |
|
|
|
return cmdList; |
|
|
|
} |
|
|
|
|
|
|
|
private boolean updateVolume (Map<String, Object> params) { |
|
|
|
private boolean updateVolume(Map<String, Object> params) { |
|
|
|
// 获取容器信息 |
|
|
|
ContainerListVO container = baseDataService.getContainerBySolutionId((Integer) params.get("solutionId")); |
|
|
|
container.setCapacityUsed(container.getCapacityUsed() + (Integer) params.get("volume")); |
|
|
|
containerService.updateById(container); |
|
|
|
baseDataService.updateConfig(); |
|
|
|
List<ContainerListVO> list = containerService.getAllContainer(); |
|
|
|
List<ContainerListVO> list = containerService.getAllContainer(); |
|
|
|
Map<String, Object> containerMap = new HashMap<>(); |
|
|
|
containerMap.put("containerList", list); |
|
|
|
webSocketService.pushMsg(WebSocketMessageType.CONTAINER, containerMap); |
|
|
@ -513,5 +513,4 @@ public class CMDService { |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |