From f397cc784ec8594890cc03dc12f062cf4ecd8dc7 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期五, 13 十二月 2024 08:21:39 +0800
Subject: [PATCH] #入库逻辑优化

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java |   36 +++++++++++++++++++++++++++++++++++-
 1 files changed, 35 insertions(+), 1 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
index 33e391f..2b00511 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
@@ -380,6 +380,31 @@
                                 break;
                             }
 
+                            if (!liftThread.isIdle()) {
+                                break;
+                            }
+
+                            if (motionService.count(new LambdaQueryWrapper<Motion>()
+                                    .eq(Motion::getDeviceCtg, DeviceCtgType.LIFT.val())
+                                    .eq(Motion::getDevice, inSta.getLiftNo())
+                                    .eq(Motion::getMotionSts, MotionStsType.EXECUTING.val())) > 0) {
+                                break;
+                            }
+
+                            //妫�娴嬫彁鍗囨満鏄惁鏈変换鍔$粦瀹�
+                            boolean liftResult = Utils.checkLiftHasBinding(liftProtocol.getLiftNo(), String.valueOf(workNo));
+                            if (liftResult) {
+                                //瀛樺湪浠诲姟锛岀姝㈡墽琛�
+                                break;
+                            }
+
+                            //姣忔鎵ц鎻愬崌鏈烘寚浠ら兘缁戝畾鎻愬崌鏈�
+                            task.setLiftNo(liftProtocol.getLiftNo());
+                            task.setUpdateTime(new Date());
+                            if (!taskService.updateById(task)) {
+                                break;
+                            }
+
                             List<LiftCommand> command = liftThread.getPalletInOutCommand(workNo, 1, lev, inSta.getDeviceStaNo(), targetSite, LiftCommandModeType.PALLET_INOUT);
 
                             LiftAssignCommand assignCommand = new LiftAssignCommand();
@@ -610,10 +635,19 @@
                     ) {
 
                         Task task = taskService.getOne(new LambdaQueryWrapper<Task>()
-                                .eq(Task::getDestSite, inSta.getDeviceStaNo())
                                 .in(Task::getTaskSts, TaskStsType.NEW_INBOUND.sts)
                                 .eq(Task::getTaskNo, workNo));
                         if (task != null) {
+                            if (!Cools.isEmpty(task.getLiftNo())) {
+                                if (task.getLiftNo() > 0) {
+                                    task.setLiftNo(0);
+                                    task.setUpdateTime(new Date());
+                                    if (!taskService.updateById(task)) {
+                                        News.info("{}浠诲姟鏇存柊閲婃斁鎻愬崌鏈哄け璐�", task.getTaskNo());
+                                    }
+                                }
+                            }
+
                             if (Cools.isEmpty(task.getShuttleNo())) {
                                 //鍒嗛厤灏忚溅
                                 //鎼滅储绌洪棽杞�

--
Gitblit v1.9.1