|  |  |  | 
|---|
|  |  |  | import com.zy.core.cache.MessageQueue; | 
|---|
|  |  |  | import com.zy.core.cache.OutputQueue; | 
|---|
|  |  |  | import com.zy.core.cache.SlaveConnection; | 
|---|
|  |  |  | import com.zy.core.enums.CrnLiftPosType; | 
|---|
|  |  |  | import com.zy.core.enums.CrnModeType; | 
|---|
|  |  |  | import com.zy.core.enums.CrnTaskModeType; | 
|---|
|  |  |  | import com.zy.core.enums.SlaveType; | 
|---|
|  |  |  | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | vo.setWorkNo(crnProtocol.getTaskNo());  //  任务号 | 
|---|
|  |  |  | //            if (crnProtocol.getTaskNo()>0) { | 
|---|
|  |  |  | //                WrkMast wrkMast = wrkMastService.selectById(crnProtocol.getTaskNo()); | 
|---|
|  |  |  | //                if (wrkMast != null) { | 
|---|
|  |  |  | //                    vo.setStatusType(CrnStatusType.process(wrkMast.getIoType()).getDesc());   //  模式状态 | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  | //            } else { | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | vo.setStatusType(crnProtocol.modeType.desc);   //  模式状态 | 
|---|
|  |  |  | if (crnProtocol.getTaskFinish() == 1) { | 
|---|
|  |  |  | vo.setStatus("等待确认"); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | vo.setStatus(crnProtocol.getStatusType().desc);     //  状态 | 
|---|
|  |  |  | if (crnProtocol.getStatusType().equals(com.zy.core.enums.CrnStatusType.PUT_COMPLETE)) { | 
|---|
|  |  |  | vo.setStatus("正在作业"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | vo.setStatus(crnProtocol.getStatusType().desc);     //  状态 | 
|---|
|  |  |  | vo.setLoading(crnProtocol.getLoaded()==1?"有物":"无物");  //  有物 | 
|---|
|  |  |  | vo.setBay(crnProtocol.getBay());    //  列 | 
|---|
|  |  |  | vo.setLev(crnProtocol.getLevel());  //  层 | 
|---|
|  |  |  | vo.setLiftPos(crnProtocol.getLiftPosType().desc); | 
|---|
|  |  |  | if (crnProtocol.getPlatformHigh()) { | 
|---|
|  |  |  | vo.setSitePos("站台高位"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (crnProtocol.getPlatformLow()) { | 
|---|
|  |  |  | vo.setSitePos("站台高位"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | vo.setForkOffset(crnProtocol.getForkPosType().desc);    // 货叉位置 | 
|---|
|  |  |  | vo.setXLocation(crnProtocol.getWalkPos() == 1?"是":"否");      // 走行定位 | 
|---|
|  |  |  | vo.setYLocation(crnProtocol.getLiftPosType().equals(CrnLiftPosType.NONE)?"否":"是");      // 升降定位 | 
|---|
|  |  |  | if (crnProtocol.getAlarm1() > 0) { | 
|---|
|  |  |  | BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm1()); | 
|---|
|  |  |  | vo.setAlarm1(crnError==null?"未知异常":crnError.getErrName()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (crnProtocol.getAlarm2() > 0) { | 
|---|
|  |  |  | BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm2()); | 
|---|
|  |  |  | vo.setAlarm2(crnError==null?"未知异常":crnError.getErrName()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (crnProtocol.getAlarm3() > 0) { | 
|---|
|  |  |  | BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm3()); | 
|---|
|  |  |  | vo.setAlarm3(crnError==null?"未知异常":crnError.getErrName()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (crnProtocol.getAlarm4() > 0) { | 
|---|
|  |  |  | BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm4()); | 
|---|
|  |  |  | vo.setAlarm4(crnError==null?"未知异常":crnError.getErrName()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //            vo.setAlarm1(String.valueOf(crnProtocol.getAlarm1())); | 
|---|
|  |  |  | //            vo.setAlarm2(String.valueOf(crnProtocol.getAlarm2())); | 
|---|
|  |  |  | //            vo.setAlarm3(String.valueOf(crnProtocol.getAlarm3())); | 
|---|
|  |  |  | //            vo.setAlarm4(String.valueOf(crnProtocol.getAlarm4())); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | vo.setForkOffset(crnProtocol.getForkPosType().desc);    // 货叉位置 | 
|---|
|  |  |  | vo.setLiftPos(crnProtocol.getLiftPosType().desc); | 
|---|
|  |  |  | vo.setWalkPos(crnProtocol.getWalkPos()==1?"不在定位":"在定位"); | 
|---|
|  |  |  | vo.setWarnCode(String.valueOf(crnProtocol.getAlarm())); | 
|---|
|  |  |  | if (crnProtocol.getAlarm() > 0) { | 
|---|
|  |  |  | BasCrnError crnError = basCrnErrorMapper.selectById(crnProtocol.getAlarm()); | 
|---|
|  |  |  | vo.setAlarm(crnError==null?"未知异常":crnError.getErrName()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return R.ok().add(list); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | vo.setXspeed(crnProtocol.getXSpeed());  //  走行速度(m/min) | 
|---|
|  |  |  | vo.setYspeed(crnProtocol.getYSpeed());  //  升降速度(m/min) | 
|---|
|  |  |  | vo.setZspeed(crnProtocol.getZSpeed());  //  叉牙速度(m/min) | 
|---|
|  |  |  | //            vo.setZspeed(crnProtocol.getZSpeed());  //  叉牙速度(m/min) | 
|---|
|  |  |  | vo.setXdistance(crnProtocol.getXDistance());  //  走行距离(Km) | 
|---|
|  |  |  | vo.setYdistance(crnProtocol.getYDistance());  //  升降距离(Km) | 
|---|
|  |  |  | vo.setXduration(crnProtocol.getXDuration());    //  走行时长(H) | 
|---|
|  |  |  | 
|---|
|  |  |  | return crnControl(command)?R.ok():R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ManagerAuth(memo = "移车") | 
|---|
|  |  |  | @PostMapping("/operator/steMove") | 
|---|
|  |  |  | public R crnSteMove(CrnOperatorParam param){ | 
|---|
|  |  |  | CrnCommand command = new CrnCommand(); | 
|---|
|  |  |  | command.setCrnNo(param.getCrnNo()); // 堆垛机编号 | 
|---|
|  |  |  | command.setTaskNo((short) 0); // 工作号 | 
|---|
|  |  |  | command.setAckFinish((short) 0);  // 任务完成确认位 | 
|---|
|  |  |  | command.setTaskMode(CrnTaskModeType.STE_MOVE); // 任务模式 | 
|---|
|  |  |  | command.setSourcePosX(param.getSourceRow());     // 源库位排 | 
|---|
|  |  |  | command.setSourcePosY(param.getSourceBay());     // 源库位列 | 
|---|
|  |  |  | command.setSourcePosZ(param.getSourceLev());     // 源库位层 | 
|---|
|  |  |  | command.setDestinationPosX(param.getRow());     // 目标库位排 | 
|---|
|  |  |  | command.setDestinationPosY(param.getBay());     // 目标库位列 | 
|---|
|  |  |  | command.setDestinationPosZ(param.getLev());     // 目标库位层 | 
|---|
|  |  |  | return crnControl(command)?R.ok():R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @ManagerAuth(memo = "站到站") | 
|---|
|  |  |  | @PostMapping("/operator/siteMove") | 
|---|
|  |  |  | public R crnSiteMove(CrnOperatorParam param){ | 
|---|
|  |  |  | 
|---|
|  |  |  | command.setCrnNo(param.getCrnNo()); // 堆垛机编号 | 
|---|
|  |  |  | command.setTaskNo((short) 0); // 工作号 | 
|---|
|  |  |  | command.setAckFinish((short) 0);  // 任务完成确认位 | 
|---|
|  |  |  | command.setTaskMode(CrnTaskModeType.SITE_MOVE); // 任务模式 | 
|---|
|  |  |  | command.setTaskMode(CrnTaskModeType.LOC_MOVE); // 任务模式 | 
|---|
|  |  |  | command.setSourcePosX(param.getSourceStaNo());     // 源库位排 | 
|---|
|  |  |  | command.setSourcePosY((short) 0);     // 源库位列 | 
|---|
|  |  |  | command.setSourcePosZ((short) 1);     // 源库位层 | 
|---|
|  |  |  | 
|---|
|  |  |  | @ManagerAuth(memo = "任务完成") | 
|---|
|  |  |  | @PostMapping("/operator/taskComplete") | 
|---|
|  |  |  | public R crnTaskComplete(CrnOperatorParam param){ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 获取堆垛机信息 | 
|---|
|  |  |  | CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, param.getCrnNo()); | 
|---|
|  |  |  | if (crnThread == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | CrnProtocol crnProtocol = crnThread.getCrnProtocol(); | 
|---|
|  |  |  | if (crnProtocol == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //堆垛机状态不是等待WCS确认时,不能下发确认位 | 
|---|
|  |  |  | if (!crnProtocol.getStatusType().equals(com.zy.core.enums.CrnStatusType.WAITING)){ | 
|---|
|  |  |  | return R.error("堆垛机不是等待WCS确认状态"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | CrnCommand command = new CrnCommand(); | 
|---|
|  |  |  | command.setCrnNo(param.getCrnNo()); // 堆垛机编号 | 
|---|
|  |  |  | command.setTaskNo((short) 0); // 工作号 | 
|---|
|  |  |  | 
|---|
|  |  |  | crnCommand.setCrnNo(crn.getId()); // 堆垛机编号 | 
|---|
|  |  |  | crnCommand.setTaskMode(CrnTaskModeType.CLEAR); | 
|---|
|  |  |  | crnCommand.setAckFinish((short) 0);  // 任务完成确认位 | 
|---|
|  |  |  | crnCommand.setCommand((short) 0);  // 任务完成确认位 | 
|---|
|  |  |  | // 延时发送 | 
|---|
|  |  |  | Thread.sleep(1000L); | 
|---|
|  |  |  | if (MessageQueue.offer(SlaveType.Crn, crn.getId(), new Task(2, crnCommand))) { | 
|---|