| | |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 出入库模式切换 |
|---|
| | | */ |
|---|
| | | public synchronized void outAndIn() { |
|---|
| | | try { |
|---|
| | | // 根据输送线plc遍历 |
|---|
| | | for (DevpSlave devp : slaveProperties.getDevp()) { |
|---|
| | | for (DevpSlave.Sta inSta : devp.getInSta()) { |
|---|
| | | Thread.sleep(500); |
|---|
| | | boolean a=true,b=true; |
|---|
| | | List<WrkMast> wrkMasts = wrkMastMapper.selectAll(inSta.getStaNo()); |
|---|
| | | if (Cools.isEmpty(wrkMasts)){ |
|---|
| | | b=false; |
|---|
| | | }else { |
|---|
| | | for (WrkMast wrkMast:wrkMasts){ |
|---|
| | | if (wrkMast.getSourceStaNo() > wrkMast.getStaNo()){ |
|---|
| | | a=false; |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | switch (inSta.getStaNo()) { |
|---|
| | | case 102://1F |
|---|
| | | if (a && b){ |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 11)); |
|---|
| | | }else if (b){ |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 12)); |
|---|
| | | }else { |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 10)); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | case 202://2F |
|---|
| | | if (a && b){ |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 21)); |
|---|
| | | }else if (b){ |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 22)); |
|---|
| | | }else { |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 20)); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | case 302://3F |
|---|
| | | if (a && b){ |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 31)); |
|---|
| | | }else if (b){ |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 32)); |
|---|
| | | }else { |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, 30)); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //扫描设备PakMk标记是否超时 |
|---|
| | | public synchronized void scanDevicePakMk() { |
|---|
| | | //扫描小车 |
|---|
| | | for (ShuttleSlave slave : slaveProperties.getShuttle()) { |
|---|
| | | NyShuttleThread shuttleThread = (NyShuttleThread) SlaveConnection.get(SlaveType.Shuttle, slave.getId()); |
|---|
| | | NyShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol(); |
|---|
| | | if (shuttleProtocol == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | if ((System.currentTimeMillis() - shuttleProtocol.getSendTime() > (1000*60*5)) && shuttleProtocol.getPakMk()) { |
|---|
| | | //设备超过5分钟还没复位标记 |
|---|
| | | shuttleProtocol.setPakMk(false);//复位标记 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //扫描提升机 |
|---|
| | | for (LiftSlave slave : slaveProperties.getLift()) { |
|---|
| | | LiftThread liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, slave.getId()); |
|---|
| | | LiftProtocol liftProtocol = liftThread.getLiftProtocol(); |
|---|
| | | if (liftProtocol == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if ((System.currentTimeMillis() - liftProtocol.getSendTime() > (1000*60*5)) && liftProtocol.getPakMk()) { |
|---|
| | | //设备超过5分钟还没复位标记 |
|---|
| | | liftProtocol.setPakMk(false);//复位标记 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
