From c69781e2b78ed7a5ffe9b59c0c555f07deabe735 Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期六, 07 二月 2026 11:08:48 +0800
Subject: [PATCH] 出库完结

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaOutStockServiceImpl.java |   29 +++++++++++++++++++++++++++++
 1 files changed, 29 insertions(+), 0 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 4fc12ff..67775d1 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
@@ -43,6 +43,7 @@
 import java.math.BigDecimal;
 import java.util.*;
 import java.util.stream.Collectors;
+import java.util.Date;
 
 @Service
 public class PdaOutStockServiceImpl implements PdaOutStockService {
@@ -356,6 +357,34 @@
                 if (!taskItemService.updateById(item)) {
                     throw new CoolException("鐘舵�佸畬鎴愬け璐ワ紒锛�");
                 }
+                
+                // 鎵e噺搴撲綅鏄庣粏搴撳瓨锛堜笌鍑哄簱瀹屾垚閫昏緫淇濇寔涓�鑷达級
+                if (StringUtils.isNotBlank(task.getOrgLoc())) {
+                    LocItem locItem = locItemService.getOne(new LambdaQueryWrapper<LocItem>()
+                            .eq(LocItem::getLocCode, task.getOrgLoc())
+                            .eq(LocItem::getMatnrId, item.getMatnrId())
+                            .eq(StringUtils.isNotBlank(item.getBatch()), LocItem::getBatch, item.getBatch())
+                            .eq(StringUtils.isNotBlank(item.getFieldsIndex()), LocItem::getFieldsIndex, item.getFieldsIndex()));
+                    
+                    if (Objects.nonNull(locItem)) {
+                        // 浣跨敤瀹為檯鎷h揣鏁伴噺锛坱askItem.getAnfme()锛夋墸鍑忓簱浣嶆槑缁�
+                        Double newAnfme = Math.round((locItem.getAnfme() - taskItem.getAnfme()) * 1000000) / 1000000.0;
+                        
+                        if (newAnfme.compareTo(0.0) <= 0) {
+                            // 鏁伴噺灏忎簬绛変簬0锛屽垹闄ゅ簱浣嶆槑缁�
+                            locItemService.removeById(locItem.getId());
+                        } else {
+                            // 鏇存柊搴撲綅鏄庣粏鏁伴噺
+                            locItem.setAnfme(newAnfme)
+                                    .setUpdateBy(SystemAuthUtils.getLoginUserId())
+                                    .setUpdateTime(new Date());
+                            if (!locItemService.updateById(locItem)) {
+                                throw new CoolException("搴撲綅鏄庣粏鏁伴噺鎵e噺澶辫触锛侊紒");
+                            }
+                        }
+                    }
+                }
+                
                 StockItem stockItem = new StockItem();
                 BeanUtils.copyProperties(item, stockItem);
                 //taskItem涓轰笂鎶ユ暟鎹�

--
Gitblit v1.9.1