| | |
| | | //mark - 3 - .... |
| | | this.locToLoc(crn, crnProtocol,mark); |
| | | //预调度 |
| | | this.crnRebackHp(crnProtocol, crnThread); |
| | | // this.crnRebackHp(crnProtocol, crnThread); |
| | | |
| | | } |
| | | // News.infoNoLog(""+mark+" - 0"+" - 堆垛机入出库作业下发执行完成"); |
| | |
| | | case 5: x =18; break; |
| | | } |
| | | |
| | | if(crnProtocol.getCrnNo() != 5){ |
| | | return; |
| | | } |
| | | // 已经存在吊车执行任务时,则过滤3,12 |
| | | if (wrkMastMapper.selectWorking(crnProtocol.getCrnNo()) != null) { |
| | | return; |
| | |
| | | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(2, new ArrayList<>()))) { |
| | | News.error("{}号LED显示默认命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); |
| | | } |
| | | // if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(4, new ArrayList<>()))) { |
| | | // News.error("{}号LED显示默认命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); |
| | | // } |
| | | } |
| | | } |
| | | } |
| | |
| | | log.error("{}号RGV尚未在数据库进行维护!2", rgvSlave.getRgvNo()); |
| | | continue; |
| | | } |
| | | |
| | | // 只有当RGV空闲、自动,工位一无物//rgv可用 |
| | | if (rgvProtocol.getStatusType() == RgvStatusType.IDLE && |
| | | rgvProtocol.getModeType() == RgvModeType.AUTO |
| | | && !rgvProtocol.isLoaded1ing() //现场修改:叠盘机,不满都算无物,怎么判断需要跟电控对接 |
| | | && rgvProtocol.getTaskNo1()==0 |
| | | && !rgvProtocol.isLoaded2ing() |
| | | && rgvProtocol.getTaskNo2()==0 |
| | | &&rgvThread.isPakMk() |
| | | ) { |
| | | BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo()); |
| | | |
| | | Integer rgvNoOther = basRgvMap.getRgvNoOther((int) rgvProtocol.getRgvNo()); |
| | | RgvThread rgvThreadOther = (RgvThread) SlaveConnection.get(SlaveType.Rgv, rgvNoOther); |
| | | RgvProtocol rgvProtocolOther = rgvThreadOther.getRgvProtocol(); |
| | | if (rgvProtocolOther == null) { |
| | | continue; |
| | | }else { |
| | | rgvProtocolOther = rgvProtocolOther.clone(); |
| | | } |
| | | if (rgvProtocolOther.getStatusType() == RgvStatusType.IDLE |
| | | && rgvProtocolOther.getModeType() == RgvModeType.AUTO |
| | | && !rgvProtocolOther.isLoaded1ing() |
| | | && rgvProtocolOther.getTaskNo1()==0 |
| | | && !rgvProtocolOther.isLoaded2ing() |
| | | && rgvProtocolOther.getTaskNo2()==0 |
| | | &&rgvThreadOther.isPakMk() |
| | | ){ |
| | | //对工作档进行判断 |
| | | basRgvMap.setNowRoute(rgvProtocol.getRgvPosI()); |
| | | if (rgvProtocol.getTaskNo1() >0 && rgvProtocol.getTaskNo1()<=9000){ |
| | | WrkMastSta wrkMastSta = wrkMastStaMapper.selectByWrkNo(rgvProtocol.getTaskNo1().intValue()); |
| | | rgvMapUpdate(basRgvMap, wrkMastSta.getStaStart(), wrkMastSta.getStaEnd(),"2366"); |
| | | }else if (rgvProtocol.getTaskNo1() == 0){ |
| | | rgvMapUpdate(basRgvMap,basRgvMap.getStartRoute(),basRgvMap.getStartRoute(),"2366"); |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | Integer site = rgvProtocol.getRgvNo() == 1 ? rgvProtocol.getRgvPosI1() : rgvProtocol.getRgvPosI2(); |
| | | if (site == 0) { |
| | | continue; |
| | | } |
| | | rgvSlave.setNowRoute(site); // 更新小车当前位置站点号 |
| | | if (!basRgvMapService.updateById(rgvSlave)) { |
| | | log.error("小车更新地图失败"); |
| | | } |
| | | |
| | | } |
| | | }catch (Exception e){ |
| | | log.error("4109行执行小车初始化任务下发失败"); |
| | | log.error("4109行"+e); |
| | | log.error("小车更新地图失败"); |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo()); |
| | | basRgvMap.setNowRoute(rgvProtocol.getRgvNo() == 1?rgvProtocol.getRgvPosI1():rgvProtocol.getRgvPosI2()); //更新小车当前位置站点号 |
| | | basRgvMapService.updateById(basRgvMap); |
| | | Integer workNo = 0; |
| | | if(rgvProtocol.getTaskNo2() > 9999|| rgvProtocol.getTaskNo1() > 9999){ |
| | | workNo = rgvProtocol.getTaskNo1() !=0 ? rgvProtocol.getTaskNo1() : rgvProtocol.getTaskNo2(); |
| | |
| | | } |
| | | BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo()); |
| | | basRgvMap.setNowRoute(rgvProtocol.getRgvNo() == 1?rgvProtocol.getRgvPosI1():rgvProtocol.getRgvPosI2()); //更新小车当前位置站点号 |
| | | basRgvMapService.updateById(basRgvMap); |
| | | Integer workNo = 0; |
| | | if(basRgv.getPakToCrn().equals("1")){ |
| | | workNo = rgvProtocol.getTaskNo1() !=0 ? rgvProtocol.getTaskNo1():rgvProtocol.getTaskNo2(); //正常情况出库放货优先工位1放 |
| | |
| | | basRgvService.updateById(basRgv); |
| | | rgvThread.setPakMk(true); |
| | | } |
| | | List<WrkMastSta> wrkMastStaPakingNum = wrkMastStaService.selectPakingWrkNum(basRgv.getRgvNo()); |
| | | if(wrkMastStaPakingNum.size() <1){ |
| | | basRgv.setPakAll("1"); //防止无其他任务时,连续取货无法恢复 |
| | | basRgvService.updateById(basRgv); |
| | | } |
| | | // List<WrkMastSta> wrkMastStaPakingNum = wrkMastStaService.selectPakingWrkNum(basRgv.getRgvNo()); |
| | | // if(wrkMastStaPakingNum.size() <1){ |
| | | // basRgv.setPakAll("1"); //防止无其他任务时,连续取货无法恢复 |
| | | // basRgvService.updateById(basRgv); |
| | | // } |
| | | |
| | | } |
| | | } |