|  |  |  | 
|---|
|  |  |  | // 出库模式 | 
|---|
|  |  |  | switch (wrkMast.getIoType()) { | 
|---|
|  |  |  | case 1: | 
|---|
|  |  |  | case 202: | 
|---|
|  |  |  | ledCommand.setTitle("全板入库"); | 
|---|
|  |  |  | break; | 
|---|
|  |  |  | case 10: | 
|---|
|  |  |  | 
|---|
|  |  |  | Set<Integer> workNos = wrkMasts.stream().map(WrkMast::getWrkNo).collect(Collectors.toSet()); | 
|---|
|  |  |  | // 获取LED线程 | 
|---|
|  |  |  | LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getId()); | 
|---|
|  |  |  | // 相同工作号集合则过滤 | 
|---|
|  |  |  | if (CollectionUtils.equals(ledThread.getWorkNos(), workNos)) { | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //            // 相同工作号集合则过滤 | 
|---|
|  |  |  | //            if (CollectionUtils.equals(ledThread.getWorkNos(), workNos)) { | 
|---|
|  |  |  | //                continue; | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | // 命令下发 ------------------------------------------------------------------------------- | 
|---|
|  |  |  | if (!commands.isEmpty()) { | 
|---|
|  |  |  | if (led.getId() == 7) { | 
|---|
|  |  |  | //                if (led.getId() == 7) { | 
|---|
|  |  |  | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(3, commands))) { | 
|---|
|  |  |  | log.error("{}号LED命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | ledThread.setLedMk(false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(1, commands))) { | 
|---|
|  |  |  | log.error("{}号LED命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | ledThread.setLedMk(false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  | //                else { | 
|---|
|  |  |  | //                    if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(1, commands))) { | 
|---|
|  |  |  | //                        log.error("{}号LED命令下发失败!!![ip:{}] [port:{}]", led.getId(), led.getIp(), led.getPort()); | 
|---|
|  |  |  | //                        continue; | 
|---|
|  |  |  | //                    } else { | 
|---|
|  |  |  | //                        ledThread.setLedMk(false); | 
|---|
|  |  |  | //                    } | 
|---|
|  |  |  | //                } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | && rgvProtocol.getTaskNo1()==0 | 
|---|
|  |  |  | && rgvProtocol.getTaskNo2()==0 | 
|---|
|  |  |  | ) { | 
|---|
|  |  |  | BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo()); | 
|---|
|  |  |  | BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvSlave.getId()); | 
|---|
|  |  |  | basRgvMap.setNowRoute(rgvProtocol.getRgvPosI()); | 
|---|
|  |  |  | rgvMapUpdate(basRgvMap,basRgvMap.getStartRoute(),basRgvMap.getStartRoute()); | 
|---|
|  |  |  | } | 
|---|