From 4871bcf8e6850a4a665c76b1be1fcea67907d9aa Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期一, 04 八月 2025 16:20:11 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   21 +++++++++++++++++++--
 1 files changed, 19 insertions(+), 2 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 99400fb..0298d74 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("${inventory.number}")
+    private Integer inventoryNumber;
 
     public Integer wrkNo = 10000;
 
@@ -1075,6 +1077,12 @@
             for (WrkMast wrkMast : wrkMasts) {
                 if (wrkMast == null) {
                     continue;
+                }
+                if (wrkMast.getIoType() == 107){
+                    int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", wrkMast.getIoType()).eq("wrk_sts", 14));
+                    if (count >= inventoryNumber) {
+                        continue;
+                    }
                 }
                 // 宸ヤ綔妗g姸鎬佸垽鏂�
                 if (wrkMast.getIoType() < 100 || wrkMast.getSourceStaNo() == null) {
@@ -2287,7 +2295,7 @@
     public synchronized void autoEmptyOut() {
         SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
         List<Integer> list = new ArrayList<>();
-        list.add(101);list.add(112);
+        list.add(1108);list.add(112);
         Map<Integer,Integer> map = new HashMap<>();
         map.put(101,102);map.put(112,111);
         for (Integer site:list){
@@ -2343,7 +2351,7 @@
     public synchronized void autoEmptyIn() {
         SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
         List<Integer> list = new ArrayList<>();
-        list.add(153);list.add(157);
+        list.add(1038);
         for (Integer site:list){
             StaProtocol staProtocol = devpThread.getStation().get(site);
             if (staProtocol == null) {
@@ -2497,6 +2505,15 @@
         }
     }
 
+//    /**
+//     *  鑷姩鐢熸垚RGV鎺ラ┏浠诲姟
+//     */
+//    public synchronized  void rgvCreateWrkMastSta(){
+//        try{
+//
+//        }
+//    }
+
 
     /**
      *  瀹屾垚灏忚溅浠诲姟

--
Gitblit v1.9.1