From d36f413965c4ef2ea35a7e0ecefd32001a1e66f8 Mon Sep 17 00:00:00 2001
From: skyouc <creaycat@gmail.com>
Date: 星期四, 04 十二月 2025 18:59:08 +0800
Subject: [PATCH] 1. 拣料出库不换库位 2. 缓存代码优化 3. 库存按批次先进先出

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaOutStockServiceImpl.java |   21 +++++++++++++++------
 1 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaOutStockServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaOutStockServiceImpl.java
index df9a7dd..4fc12ff 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaOutStockServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaOutStockServiceImpl.java
@@ -248,7 +248,7 @@
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public R wavePickItems(WavePickItemsParams params) {
+    public synchronized R wavePickItems(WavePickItemsParams params) {
         if (Objects.isNull(params.getBarcode())) {
             return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒锛�");
         }
@@ -326,19 +326,26 @@
                 TaskItem item = taskItemService.getById(taskItem.getId());
                 //鍒ゆ柇鏄惁鍏佽瓒呮敹锛屼笉鍏佽瓒呮敹娣诲姞鎷掓敹鍒ゆ柇
                 if (!Objects.isNull(config)) {
-                    LocItemWorking serviceOne = locItemWorkingService.getOne(new LambdaQueryWrapper<LocItemWorking>().eq(LocItemWorking::getFieldsIndex, item.getFieldsIndex()));
+                    TaskItem serviceOne = taskItemService.getOne(new LambdaQueryWrapper<TaskItem>()
+                            .eq(TaskItem::getTaskId, task.getId())
+                            .eq(TaskItem::getFieldsIndex, item.getFieldsIndex()));
                     if (Objects.isNull(serviceOne)) {
                         throw new CoolException("缂撳瓨鏁版嵁涓㈠け锛侊紒");
                     }
+                    LocItemWorking workItem = locItemWorkingService.getOne(new LambdaQueryWrapper<LocItemWorking>()
+                            .eq(LocItemWorking::getTaskId, task.getId())
+                            .eq(LocItemWorking::getFieldsIndex, item.getFieldsIndex()));
+                    if (Objects.isNull(workItem)) {
+                        throw new CoolException("缂撳瓨鏁版嵁涓㈠け锛侊紒");
+                    }
+                    Double v1 = Math.round((workItem.getAnfme() - serviceOne.getQty()) * 1000000) / 1000000.0;
                     //涓嶇鏄惁鍏佽瓒呮敹锛岄兘闇�鍒ゆ柇鏄惁瓒呭嚭搴撳瓨鑼冨洿
-                    if (taskItem.getAnfme().compareTo(serviceOne.getAnfme()) > 0) {
+                    if (taskItem.getAnfme().compareTo(v1) > 0) {
                         throw new CoolException("鎷h揣鏁伴噺瓒呭嚭褰撳墠绁ㄥ彿搴撳瓨鏁伴噺锛侊紒");
                     }
-
                     if (!Boolean.parseBoolean(config.getVal())) {
                         Double v = Math.round((item.getQty() + taskItem.getAnfme()) * 1000000) / 1000000.0;
                         if (item.getAnfme().compareTo(v) < 0.0) {
-
                             throw new CoolException("鍓嶅綋鐗╂枡宸茶秴鍑哄彲鎷h寖鍥达紝璇锋牳瀵瑰悗鍐嶆搷浣滐紒锛�");
                         }
                     }
@@ -442,13 +449,15 @@
                throw new CoolException("浠诲姟鏄庣粏淇敼澶辫触");
             }
             LocItemWorking oldOne = locItemWorkingService.getOne(new LambdaQueryWrapper<LocItemWorking>()
+                    .eq(LocItemWorking::getTaskId, byId.getTaskId())
                     .eq(LocItemWorking::getMatnrCode, byId.getMatnrCode())
                     .eq(LocItemWorking::getFieldsIndex, byId.getFieldsIndex()));
             if (Objects.isNull(oldOne)) {
                 throw new CoolException("鏄庣粏涓嶅瓨鍦ㄦ垨宸插嚭搴擄紒锛�");
             }
             LocItemWorking one = locItemWorkingService.getOne(new LambdaQueryWrapper<LocItemWorking>()
-                            .eq(LocItemWorking::getMatnrCode, byId.getMatnrCode())
+                    .eq(LocItemWorking::getTaskId, byId.getTaskId())
+                    .eq(LocItemWorking::getMatnrCode, byId.getMatnrCode())
                     .eq(LocItemWorking::getFieldsIndex, uuid));
             if (Objects.isNull(one)) {
                 throw new CoolException("鏄庣粏涓嶅瓨鍦ㄦ垨宸插嚭搴擄紒锛�");

--
Gitblit v1.9.1