From 155b83ba0861dc9033563314bb8a5eb535dd6b60 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期三, 07 五月 2025 15:53:45 +0800
Subject: [PATCH] #联调

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   23 +++++++++++++++++++++++
 1 files changed, 23 insertions(+), 0 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 51ac5cc..f02e02d 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -97,6 +97,8 @@
 
     @Value("${wms.url}")
     private String wmsUrl;
+    @Value("${wcs-slave.isToOrigin}")
+    private boolean isToOrigin;
 
     public Integer wrkNo = 10000;
 
@@ -844,6 +846,27 @@
         }
 //        News.infoNoLog(""+mark+" - 0"+" - 鍫嗗灈鏈虹珯鍑哄簱鍒板嚭搴撶珯  ===銆嬫墽琛屽畬鎴�");
     }
+    /**
+     * 鍫嗗灈鏈洪粯璁ゅ洖鍘熺偣
+     */
+    public synchronized void crnToInStn(Integer mark) {
+        if(isToOrigin){
+            for (CrnSlave crn : slaveProperties.getCrn()){
+                // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+                CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId());
+                CrnProtocol crnProtocol = crnThread.getCrnProtocol();
+                if (crnProtocol == null) {
+                    continue;
+                }
+                BasCrnp basCrnp = basCrnpService.selectById(crn.getId());
+                if (basCrnp == null) {
+                    News.error("" + mark + " - 1" + " - {}鍙峰爢鍨涙満灏氭湭鍦ㄦ暟鎹簱杩涜缁存姢锛�", crn.getId());
+                    continue;
+                }
+            }
+        }
+    }
+
 
     /**
      * 鍏ュ嚭搴�  ===>>  鍫嗗灈鏈哄叆鍑哄簱浣滀笟涓嬪彂

--
Gitblit v1.9.1