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