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