diff --git a/src/main/java/com/iflytop/handacid/app/command/control/SolutionDrainStartCommand.java b/src/main/java/com/iflytop/handacid/app/command/control/SolutionDrainStartCommand.java index de7afa8..368d552 100644 --- a/src/main/java/com/iflytop/handacid/app/command/control/SolutionDrainStartCommand.java +++ b/src/main/java/com/iflytop/handacid/app/command/control/SolutionDrainStartCommand.java @@ -1,6 +1,7 @@ package com.iflytop.handacid.app.command.control; import com.iflytop.handacid.app.common.annotation.CommandMapping; +import com.iflytop.handacid.app.common.enums.ChannelCode; import com.iflytop.handacid.app.common.enums.ChannelStateCode; import com.iflytop.handacid.app.common.enums.SystemConfigKey; import com.iflytop.handacid.app.common.utils.CommandUtil; @@ -36,17 +37,18 @@ public class SolutionDrainStartCommand extends BaseCommandHandler { @Override public CompletableFuture handle(CommandDTO commandDTO) { - List channelCodeList = deviceState.filterChannelStatesIsPre(); return runAsync(() -> { List commandFutureList = new ArrayList<>(); - for (ChannelState channelState : channelCodeList) { + for(ChannelCode channelCode : ChannelCode.values()){ + ChannelState channelState = deviceState.getChannelStateMap().get(channelCode); channelState.setStateCode(ChannelStateCode.DRAIN); Double drainRevolutions = systemConfigService.getValueByKeyToDouble(SystemConfigKey.DRAIN_REVOLUTIONS); DeviceCommand deviceCommand = channelCtrlService.getPumpMoveByCommandByChannel(channelState.getChannelCode(), -drainRevolutions); commandFutureList.add(deviceCommandService.sendCommand(deviceCommand)); } CommandUtil.wait(commandFutureList); - for (ChannelState channelState : channelCodeList) { + for(ChannelCode channelCode : ChannelCode.values()){ + ChannelState channelState = deviceState.getChannelStateMap().get(channelCode); channelState.setStateCode(ChannelStateCode.IDLE); } }); diff --git a/src/main/java/com/iflytop/handacid/app/service/ChannelCtrlService.java b/src/main/java/com/iflytop/handacid/app/service/ChannelCtrlService.java index d10715d..5b12b9e 100644 --- a/src/main/java/com/iflytop/handacid/app/service/ChannelCtrlService.java +++ b/src/main/java/com/iflytop/handacid/app/service/ChannelCtrlService.java @@ -158,13 +158,13 @@ public class ChannelCtrlService { } CommandUtil.wait(commandFutureList); - for (ChannelState channelState : channelStateList) {//与缓存的位置比较计算加液量 - PreFill preFill = preFillService.lambdaQuery() - .eq(PreFill::getSolutionId, channelState.getSolutionId()) - .eq(PreFill::getConcentration, channelState.getConcentration()) - .one(); - handleCalculateActualDispensedVolume(channelState, preFill.getVolume(), preFill.getConcentration()); - } +// for (ChannelState channelState : channelStateList) {//与缓存的位置比较计算加液量 +// PreFill preFill = preFillService.lambdaQuery() +// .eq(PreFill::getSolutionId, channelState.getSolutionId()) +// .eq(PreFill::getConcentration, channelState.getConcentration()) +// .one(); +// handleCalculateActualDispensedVolume(channelState, preFill.getVolume(), preFill.getConcentration()); +// } } catch (Exception e) { throw new RuntimeException(e); }