From c30548d8d42081f2d487d64e6df3ef0bcaa1e828 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 05 十二月 2022 10:15:59 +0800
Subject: [PATCH] Merge branch 'ynwcs' of http://47.97.1.152:5880/r/zy-wcs into ynwcs

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   30 +++++++++++++++++++++++-------
 1 files changed, 23 insertions(+), 7 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 e88ad51..2d9671b 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -777,8 +777,9 @@
                         wrkMast.setModiTime(now);
                         if (wrkMastMapper.updateById(wrkMast) == 0) {
                             log.error("淇敼宸ヤ綔妗g姸鎬� {} => 7.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkSts$(), wrkMast.getWrkNo());
+                        } else {
+                            return true;
                         }
-                        return true;
                     }
                 }
             } else {
@@ -793,11 +794,13 @@
                             // 娌℃湁鍏朵粬浠诲姟
                             if (null == wrkMastMapper.selectPakin(slave.getId(), steNo)) {
                                 this.letCarBeReady(wrkMast, steNo, wrkMast.getLocNo());
+                                return true;
                             }
                         }
                         // 灏忚溅鎼蛋
                         if (wrkMast.getWrkSts() == 3L) {
                             this.carMoveOut(wrkMast, steNo, crnProtocol);
+                            return true;
                         }
                         // 娌℃湁灏忚溅
                     } else {
@@ -834,8 +837,9 @@
                                 wrkMast.setModiTime(now);
                                 if (wrkMastMapper.updateById(wrkMast) == 0) {
                                     log.error("淇敼宸ヤ綔妗g姸鎬� {} => 7.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkSts$(), wrkMast.getWrkNo());
+                                } else {
+                                    return true;
                                 }
-                                return true;
                             }
                         }
 
@@ -852,6 +856,8 @@
                             // 娌℃湁鍏朵粬浠诲姟
                             if (null == wrkMastMapper.selectPakin(slave.getId(), steNo)) {
                                 this.letCarBeWaiting(wrkMast, steNo, wrkMast.getLocNo());
+                            } else {
+                                return true;
                             }
                         }
                         // 鍫嗗灈鏈哄皢璐ф斁鑷冲皬杞︿笂 3.灏忚溅寰呮惉锛堝皬杞︿笉鐢ㄦ惉杩愶紝宸茬粡鍦ㄥ綋鍓嶇粍搴撲綅锛� / 6.灏忚溅寰呭叆  ===>> 7.鍚婅溅鍏ュ簱涓�
@@ -888,8 +894,9 @@
                                     wrkMast.setModiTime(now);
                                     if (wrkMastMapper.updateById(wrkMast) == 0) {
                                         log.error("淇敼宸ヤ綔妗g姸鎬� 3.灏忚溅寰呮惉/6.灏忚溅寰呭叆 => 7.鍚婅溅鍏ュ簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkNo());
+                                    } else {
+                                        return true;
                                     }
-                                    return true;
                                 }
                             }
                         }
@@ -903,12 +910,14 @@
                                 if (null == wrkMastMapper.selectPakin(slave.getId(), steNo)) {
                                     // 璁╁皬杞︾瓑寰呮惉杩愬緟缁�
                                     this.letCarBeReady(wrkMast, steThread.getSlave().getId(), wrkMast.getLocNo());
+                                    return true;
                                 }
                             }
                         }
                         // 鍫嗗灈鏈烘惉杩愬皬杞�
                         if (wrkMast.getWrkSts() == 3L) {
                             this.carMoveIn(wrkMast, wrkMast.getSteNo(), crnProtocol);
+                            return true;
                         }
                     }
                 }
@@ -921,7 +930,7 @@
     /**
      * 鍑哄簱  ===>>  搴撲綅鍒板爢鍨涙満绔�
      */
-    public boolean locToCrnStn(CrnSlave slave, CrnProtocol crnProtocol){
+    public synchronized boolean locToCrnStn(CrnSlave slave, CrnProtocol crnProtocol){
         for (CrnSlave.CrnStn crnStn : slave.getCrnOutStn()) {
             // 鑾峰彇宸ヤ綔鐘舵�佷负11锛堢敓鎴愬嚭搴揑D锛夌殑鍑哄簱宸ヤ綔妗�
             WrkMast wrkMast = wrkMastMapper.selectPakOutStep111215(slave.getId(), crnStn.getStaNo());
@@ -1035,8 +1044,9 @@
                         wrkMast.setModiTime(now);
                         if (wrkMastMapper.updateById(wrkMast) == 0) {
                             log.error("淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 16.鍚婅溅鍑哄簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkNo());
+                        } else {
+                            return true;
                         }
-                        break;
                     }
 
                 } else {
@@ -1070,8 +1080,9 @@
                             wrkMast.setModiTime(now);
                             if (wrkMastMapper.updateById(wrkMast) == 0) {
                                 log.error("淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 16.鍚婅溅鍑哄簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkNo());
+                            } else {
+                                return true;
                             }
-                            return true;
                         }
                     // 涓嶆槸鏈�澶栧眰搴撲綅锛岄渶瑕佷娇鐢ㄧ┛姊溅鎼繍鍚庯紝鍐嶅爢鍨涙満鍑哄簱
                     } else {
@@ -1111,6 +1122,8 @@
                                         wrkMast.setCrnNo(outCrnNo);
                                         if (wrkMastMapper.updateById(wrkMast) == 0) {
                                             log.error("淇敼宸ヤ綔妗g姸鎬� 11.鐢熸垚鍑哄簱ID => 14.灏忚溅鎼嚭搴� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkNo());
+                                        } else {
+                                            return true;
                                         }
                                     }
                                 }
@@ -1143,8 +1156,9 @@
                                     wrkMast.setModiTime(now);
                                     if (wrkMastMapper.updateById(wrkMast) == 0) {
                                         log.error("淇敼宸ヤ綔妗g姸鎬� 15.绛夊緟鍚婅溅 => 16.鍚婅溅鍑哄簱涓� 澶辫触锛侊紒锛屽伐浣滃彿={}", wrkMast.getWrkNo());
+                                    } else {
+                                        return true;
                                     }
-                                    return true;
                                 }
                             }
 
@@ -1158,12 +1172,14 @@
                                     if (null == wrkMastMapper.selectPakout(slave.getId(), steNo)) {
                                         // 璁╁皬杞︾瓑寰呮惉杩愬緟缁�
                                         this.letCarBeReady(wrkMast, steThread.getSlave().getId(), wrkMast.getSourceLocNo());
+                                        return true;
                                     }
                                 }
                             }
                             // 鍫嗗灈鏈烘惉杩愬皬杞�
                             if (wrkMast.getWrkSts() == 12L) {
                                 this.carMoveIn(wrkMast, wrkMast.getSteNo(), crnProtocol);
+                                return true;
                             }
                         }
                     }

--
Gitblit v1.9.1