From 6736ba1679dbafee38f034b8555875078c012063 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期三, 03 九月 2025 12:21:09 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   38 +++++++++++++++++++++++---------------
 1 files changed, 23 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 6edd73e..6178177 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -6,7 +6,6 @@
 import com.baomidou.mybatisplus.mapper.Wrapper;
 import com.core.common.Cools;
 import com.core.common.DateUtils;
-import com.core.common.R;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.mapper.BasCrnErrorMapper;
@@ -447,10 +446,10 @@
                     }
 
                     try {
-                        // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
-                        if (wrkMastMapper.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
-                            throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
-                        }
+//                        // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
+//                        if (wrkMastMapper.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
+//                            throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
+//                        }
                         // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
                         if (wrkMastMapper.saveWrkMastLog(wrkMast.getWrkNo()) == 0) {
                             throw new CoolException("淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗eけ璐�");
@@ -589,10 +588,10 @@
                     }
 
                     try {
-                        // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
-                        if (wrkMastMapper.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
-                            throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
-                        }
+//                        // 淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。
+//                        if (wrkMastMapper.saveWrkDetlLog(wrkMast.getWrkNo()) == 0) {
+//                            throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏妗e巻鍙叉。澶辫触");
+//                        }
                         // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗�
                         if (wrkMastMapper.saveWrkMastLog(wrkMast.getWrkNo()) == 0) {
                             throw new CoolException("淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗eけ璐�");
@@ -749,7 +748,7 @@
 //            }
 
             //鍫嗗灈鏈哄洖鍘熺偣浠诲姟涓�
-            Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK);
+            Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK + crn.getId());
             if (object != null) {
                 continue;
             }
@@ -821,7 +820,7 @@
                     continue;
                 }
 
-                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK);
+                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK + crn.getId());
                 if (object != null) {
                     continue;
                 }
@@ -893,7 +892,7 @@
                     continue;
                 }
 
-                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK);
+                Object object = redisUtil.get(RedisConstantType.CRN_MOVE_LOCK + crn.getId());
                 if (object != null) {
                     continue;
                 }
@@ -1251,7 +1250,7 @@
                             turnCrnExecuteCurrentChannel = turnCrnExecuteCurrentChannelConfig.getValue();
                         }
 
-                        if(turnCrnExecuteCurrentChannel.equals("Y")) {
+                        if (turnCrnExecuteCurrentChannel.equals("Y")) {
                             //鍒ゆ柇鍫嗗灈鏈哄拰褰撳墠浠诲姟鏄惁澶勪簬涓�涓贩閬�
                             if (Utils.getLaneByLocNo(wrkMast.getSourceLocNo()) != crnProtocol.getCrnLane()) {
                                 //鍒ゆ柇鍫嗗灈鏈烘墍鍦ㄥ贩閬撴槸鍚﹀瓨鍦ㄥ叾浠栦换鍔★紝濡傚瓨鍦ㄥ垯浼樺厛鎵ц
@@ -1662,7 +1661,7 @@
                 }
 
                 Date now = new Date();
-                if(wrkMast.getIoType() < 100){
+                if (wrkMast.getIoType() < 100) {
                     // 鍏ュ簱 + 搴撲綅杞Щ  ==> 4.鍏ュ簱瀹屾垚
                     if (wrkMast.getWrkSts() == 3 || (wrkMast.getWrkSts() == 12 && (wrkMast.getIoType() == 11 || wrkMast.getIoType() == 111))) {
                         wrkMast.setWrkSts(4L);
@@ -1678,7 +1677,7 @@
                         News.warnNoLog("" + mark + " - 2" + " - 淇敼鎴愬姛鍚庡浣嶅爢鍨涙満 : 鍫嗗灈鏈哄彿={}", crnThread.getCrnProtocol().getCrnNo());
                         crnThread.setResetFlag(true);
                     }
-                }else {
+                } else {
                     List<Long> list = new ArrayList<>();
                     list.add(14L);
                     list.add(15L);
@@ -2428,6 +2427,15 @@
                 return false;
 //                throw new CoolException("鍙屾繁搴撲綅 --- 娴呭簱浣嶉樆濉炲紓甯革紒 寰呯Щ杞祬搴撲綅锛�" + shallowLoc.getLocNo());
             } else {
+                String deepLoc2 = Utils.getDeepLoc2(slaveProperties, loc.getLocNo());
+                if (deepLoc2 != null) {
+                    LocMast locnew = locMastService.selectById(deepLoc2);
+                    if (locnew != null && locnew.getLocSts().equals("O")) {
+                        loc = locnew;
+                    }
+                }
+
+
                 try {
                     // 鑾峰彇宸ヤ綔鍙�
                     int workNo = commonService.getWorkNo(0);

--
Gitblit v1.9.1