From 4e6d844962ae71bfa593de96e68bae5628ad5ffa Mon Sep 17 00:00:00 2001 From: Junjie <540245094@qq.com> Date: 星期六, 22 六月 2024 12:50:03 +0800 Subject: [PATCH] # --- zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java | 126 ++++++++++-------------------------------- 1 files changed, 30 insertions(+), 96 deletions(-) diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java index 230f15c..8f22f11 100644 --- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java +++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/command/ShuttleCommandService.java @@ -192,7 +192,7 @@ if (!liftThread.isLock(new ExecuteSupport() { @Override public Boolean judgement() { - return true; + return true;//鐗涚溂娌℃湁鎻愬崌鏈洪攣锛岀洿鎺ヨ繑鍥瀟rue } })) { return false; @@ -311,54 +311,24 @@ } //鍒ゆ柇鎻愬崌鏈烘槸鍚﹁閿佸畾 - if (liftThread.isLock(new ExecuteSupport() { + if (!liftThread.isLock(new ExecuteSupport() { @Override public Boolean judgement() { return false; } })) { - //瑙i攣鎻愬崌鏈� - List<LiftCommand> lockCommand = liftThread.getLockCommand(motion.getTaskNo(), false);//鑾峰彇鎻愬崌鏈鸿В閿佸懡浠� - - LiftAssignCommand liftAssignCommand = new LiftAssignCommand(); - liftAssignCommand.setLiftNo(liftThread.getStatus().getLiftNo()); - liftAssignCommand.setTaskNo(motion.getTaskNo()); - ArrayList<LiftCommand> list = new ArrayList<>(); - list.addAll(lockCommand); - liftAssignCommand.setCommands(list); - - liftAction.assignWork(liftThread.getDevice(), liftAssignCommand); - return false;//绛夊緟涓嬩竴娆¤疆璇� - } - - //鍒ゆ柇灏忚溅鏄惁宸插埌浣� - if (liftProtocol.getHasCar()) { - List<LiftCommand> signalCommand = liftThread.getShuttleSignalCommand(motion.getTaskNo(), true);//鑾峰彇灏忚溅宸插埌浣嶅懡浠� - if(signalCommand != null) { - boolean hasKey = redisUtil.hasKey(DeviceRedisConstant.COMMAND_TMP + motion.getTaskNo()); - if (!hasKey) { - LiftAssignCommand liftAssignCommand = new LiftAssignCommand(); - liftAssignCommand.setLiftNo(liftThread.getStatus().getLiftNo()); - liftAssignCommand.setTaskNo(motion.getTaskNo()); - ArrayList<LiftCommand> list = new ArrayList<>(); - list.addAll(signalCommand); - liftAssignCommand.setCommands(list); - liftAction.assignWork(liftThread.getDevice(), liftAssignCommand); - redisUtil.set(DeviceRedisConstant.COMMAND_TMP + motion.getTaskNo(), true, 120); - return false; - } - } - } - - //鍒ゆ柇鎻愬崌鏈哄伐浣滃彿鏄惁鍜屽綋鍓嶄换鍔$浉鍚� - if (liftProtocol.getTaskNo().intValue() != motion.getTaskNo()) { return false; } - if (liftProtocol.getTaskNo() != 0) { - //娓呯┖鎻愬崌鏈哄彿 - liftThread.setSyncTaskNo(0); + //鍒ゆ柇灏忚溅鏄惁宸插埌浣� + if (!liftProtocol.getHasCar()) { + return false; } + +// //鍒ゆ柇鎻愬崌鏈哄伐浣滃彿鏄惁鍜屽綋鍓嶄换鍔$浉鍚� +// if (liftProtocol.getTaskNo().intValue() != motion.getTaskNo()) { +// return false; +// } break; case SHUTTLE_MOVE_FROM_LIFT: liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, Integer.parseInt(motion.getTemp())); @@ -372,54 +342,24 @@ } //鍒ゆ柇鎻愬崌鏈烘槸鍚﹁閿佸畾 - if (liftThread.isLock(new ExecuteSupport() { + if (!liftThread.isLock(new ExecuteSupport() { @Override public Boolean judgement() { return false; } })) { - //瑙i攣鎻愬崌鏈� - List<LiftCommand> lockCommand = liftThread.getLockCommand(motion.getTaskNo(), false);//鑾峰彇鎻愬崌鏈鸿В閿佸懡浠� - - LiftAssignCommand liftAssignCommand = new LiftAssignCommand(); - liftAssignCommand.setLiftNo(liftThread.getStatus().getLiftNo()); - liftAssignCommand.setTaskNo(motion.getTaskNo()); - ArrayList<LiftCommand> list = new ArrayList<>(); - list.addAll(lockCommand); - liftAssignCommand.setCommands(list); - - liftAction.assignWork(liftThread.getDevice(), liftAssignCommand); - return false;//绛夊緟涓嬩竴娆¤疆璇� - } - - //鍒ゆ柇灏忚溅鏄惁宸茬寮� - if (!liftProtocol.getHasCar()) { - List<LiftCommand> signalCommand = liftThread.getShuttleSignalCommand(motion.getTaskNo(), false);//鑾峰彇灏忚溅宸查┚绂诲懡浠� - if(signalCommand != null) { - boolean hasKey = redisUtil.hasKey(DeviceRedisConstant.COMMAND_TMP + motion.getTaskNo()); - if (!hasKey) { - redisUtil.set(DeviceRedisConstant.COMMAND_TMP + motion.getTaskNo(), JSON.toJSONString(signalCommand), 120); - LiftAssignCommand liftAssignCommand = new LiftAssignCommand(); - liftAssignCommand.setLiftNo(liftThread.getStatus().getLiftNo()); - liftAssignCommand.setTaskNo(motion.getTaskNo()); - ArrayList<LiftCommand> list = new ArrayList<>(); - list.addAll(signalCommand); - liftAssignCommand.setCommands(list); - liftAction.assignWork(liftThread.getDevice(), liftAssignCommand); - return false; - } - } - } - - //鍒ゆ柇鎻愬崌鏈哄伐浣滃彿鏄惁鍜屽綋鍓嶄换鍔$浉鍚� - if (liftProtocol.getTaskNo().intValue() != motion.getTaskNo()) { return false; } - if (liftProtocol.getTaskNo() != 0) { - //娓呯┖鎻愬崌鏈哄彿 - liftThread.setSyncTaskNo(0); + //鍒ゆ柇灏忚溅鏄惁宸茬寮� + if (liftProtocol.getHasCar()) { + return false; } + +// //鍒ゆ柇鎻愬崌鏈哄伐浣滃彿鏄惁鍜屽綋鍓嶄换鍔$浉鍚� +// if (liftProtocol.getTaskNo().intValue() != motion.getTaskNo()) { +// return false; +// } break; case SHUTTLE_TRANSPORT_FROM_LIFT: case SHUTTLE_TRANSPORT_TO_LIFT: @@ -441,32 +381,26 @@ return false; } })) { - //瑙i攣鎻愬崌鏈� - List<LiftCommand> lockCommand = liftThread.getLockCommand(motion.getTaskNo(), false);//鑾峰彇鎻愬崌鏈鸿В閿佸懡浠� - - LiftAssignCommand liftAssignCommand = new LiftAssignCommand(); - liftAssignCommand.setLiftNo(liftThread.getStatus().getLiftNo()); - liftAssignCommand.setTaskNo(motion.getTaskNo()); - ArrayList<LiftCommand> list = new ArrayList<>(); - list.addAll(lockCommand); - liftAssignCommand.setCommands(list); - - liftAction.assignWork(liftThread.getDevice(), liftAssignCommand); - return false;//绛夊緟涓嬩竴娆¤疆璇� + return false; } //鍒ゆ柇鎻愬崌鏈哄伐浣滃彿鏄惁鍜屽綋鍓嶄换鍔$浉鍚� if (liftProtocol.getTaskNo().intValue() != motion.getTaskNo()) { return false; } - - if (liftProtocol.getTaskNo() != 0) { - //娓呯┖鎻愬崌鏈哄彿 - liftThread.setSyncTaskNo(0); - } break; case SHUTTLE_UPDATE_LOCATION://灏忚溅鍧愭爣鏇存柊 break; + case SHUTTLE_PALLET_LIFT://鎵樼洏椤跺崌 + if (!shuttleProtocol.getHasLift()) { + return false; + } + break; + case SHUTTLE_PALLET_DOWN://鎵樼洏涓嬮檷 + if (shuttleProtocol.getHasLift()) { + return false; + } + break; default: break; } -- Gitblit v1.9.1