Junjie
2023-04-04 c08e857d010676d45ff5f4fc022613b974563d43
src/main/java/com/zy/asrs/controller/ShuttleController.java
@@ -30,7 +30,6 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Random;
/**
 * 四向穿梭车接口
@@ -246,8 +245,14 @@
            return R.parse(BaseRes.PARAM);
        }
        if (Cools.isEmpty(param.getSourceLocNo(), param.getDistLocNo())) {
            return R.parse(BaseRes.PARAM);
        ShuttleAssignCommand assignCommand = new ShuttleAssignCommand();
        if (param.getShuttleTaskMode() == 1 || param.getShuttleTaskMode() == 2) {
            if (Cools.isEmpty(param.getSourceLocNo(), param.getDistLocNo())) {
                return R.parse(BaseRes.PARAM);
            }
            assignCommand.setSourceLocNo(param.getSourceLocNo());
            assignCommand.setLocNo(param.getDistLocNo());
        }
        for (ShuttleSlave shuttleSlave : slaveProperties.getShuttle()) {
@@ -262,14 +267,12 @@
                }
                ShuttleTaskModeType shuttleTaskModeType = ShuttleTaskModeType.get(param.getShuttleTaskMode());
                ShuttleAssignCommand command = new ShuttleAssignCommand();
                command.setShuttleNo(shuttleSlave.getId().shortValue()); // 四向穿梭车编号
                command.setTaskMode(shuttleTaskModeType.id.shortValue());
                command.setSourceLocNo(param.getSourceLocNo());
                command.setLocNo(param.getDistLocNo());
                command.setTaskNo((short) 9999);
                assignCommand.setShuttleNo(shuttleSlave.getId().shortValue()); // 四向穿梭车编号
                assignCommand.setTaskMode(shuttleTaskModeType.id.shortValue());
                assignCommand.setTaskNo((short) 9999);
                assignCommand.setAuto(false);//手动模式
                if (MessageQueue.offer(SlaveType.Shuttle, shuttleSlave.getId(), new Task(3, command))) {
                if (MessageQueue.offer(SlaveType.Shuttle, shuttleSlave.getId(), new Task(3, assignCommand))) {
                    return R.ok();
                } else {
                    throw new CoolException("命令下发失败");