| | |
| | | import com.zy.asrs.domain.param.ShuttleOperatorParam; |
| | | import com.zy.asrs.domain.vo.*; |
| | | import com.zy.asrs.entity.BasShuttle; |
| | | import com.zy.asrs.entity.LocMast; |
| | | import com.zy.asrs.entity.WrkMast; |
| | | import com.zy.asrs.service.BasShuttleService; |
| | | import com.zy.asrs.service.LocMastService; |
| | | import com.zy.asrs.service.WrkMastService; |
| | | import com.zy.asrs.utils.Utils; |
| | | import com.zy.common.utils.NavigatePositionConvert; |
| | | import com.zy.common.utils.NavigateUtils; |
| | | import com.zy.core.cache.MessageQueue; |
| | | import com.zy.core.cache.OutputQueue; |
| | | import com.zy.core.cache.SlaveConnection; |
| | |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Random; |
| | | |
| | | /** |
| | | * 四向穿梭车接口 |
| | |
| | | private BasShuttleService basShuttleService; |
| | | @Autowired |
| | | private WrkMastService wrkMastService; |
| | | @Autowired |
| | | private LocMastService locMastService; |
| | | |
| | | @PostMapping("/table/shuttle/state") |
| | | @ManagerAuth(memo = "四向穿梭车信息表") |
| | |
| | | vo.setBusyStatus(shuttleProtocol.getBusyStatusType().desc); //四向穿梭车状态 |
| | | vo.setStatus(shuttleProtocol.getProtocolStatusType().desc);//当前任务状态 |
| | | vo.setCurrentCode(shuttleProtocol.getCurrentCode());//当前二维码 |
| | | LocMast currentLocMast = locMastService.queryByQrCode(shuttleProtocol.getCurrentCode().toString()); |
| | | vo.setLocNo(currentLocMast.getLocNo());//获取当前库位号 |
| | | int[] locNoXY = NavigatePositionConvert.positionToXY(currentLocMast.getLocNo());//获取库位号XY坐标 |
| | | vo.setLocNoX(locNoXY[0]); |
| | | vo.setLocNoY(locNoXY[1]); |
| | | vo.setLocNoLev(Utils.getLev(currentLocMast.getLocNo()));//当前库位层高 |
| | | vo.setBatteryPower(shuttleProtocol.getBatteryPower$() == null ? "" : shuttleProtocol.getBatteryPower$() + "%");//电池电量 |
| | | vo.setBatteryTemp(shuttleProtocol.getBatteryTemp$() == null ? "" : shuttleProtocol.getBatteryTemp$() + "°");//电池温度 |
| | | if (!Cools.isEmpty(shuttleProtocol.getErrorCode())) { |
| | |
| | | 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()) { |
| | |
| | | } |
| | | |
| | | 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.setDistLocNo(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("命令下发失败"); |