From 43e3fe43675a68c375313abfbeee84ad60e6d9e3 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期二, 03 二月 2026 10:09:17 +0800
Subject: [PATCH] yys  成品库存修改

---
 src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java |   64 ++++++++++++-------------------
 1 files changed, 25 insertions(+), 39 deletions(-)

diff --git a/src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java b/src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java
index 0f13b51..f0bb2ed 100644
--- a/src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java
+++ b/src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java
@@ -437,7 +437,7 @@
         for (ProcurementPageDto dto : procurementPageDtos) {
             // 鏍规嵁閲囪喘鍙拌处ID绛涢�夊搴旂殑鍑哄簱璁板綍
             List<ProcurementRecordOut> collect1 = procurementRecords.stream()
-                    .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
+                    .filter(item -> item.getProcurementRecordStorageId().equals(dto.getId()))
                     .collect(Collectors.toList());
 
             // 濡傛灉娌℃湁鐩稿叧鐨勫嚭搴撹褰曪紝璺宠繃璇ユ潯鏁版嵁
@@ -478,20 +478,6 @@
 
     @Override
     public IPage<CustomStorage> listPageByCustom(Page page, CustomStorage customStorage) {
-//        LambdaQueryWrapper<CustomStorage> customStorageLambdaQueryWrapper = new LambdaQueryWrapper<>();
-//        if(customStorage != null){
-//            if(!StringUtils.isEmpty(customStorage.getSupplierName())){
-//                customStorageLambdaQueryWrapper.like(CustomStorage::getSupplierName, customStorage.getSupplierName());
-//            }
-//            // 绛涢�夊叆搴撴椂闂�
-//            if(customStorage.getTimeStr() != null){
-//                customStorageLambdaQueryWrapper.eq(CustomStorage::getInboundDate, customStorage.getTimeStr());
-//            }
-//            if(!StringUtils.isEmpty(customStorage.getProductCategory())){
-//                customStorageLambdaQueryWrapper.like(CustomStorage::getProductCategory, customStorage.getProductCategory());
-//            }
-//        }
-//        customStorageLambdaQueryWrapper.orderByDesc(CustomStorage::getInboundDate);
         IPage<CustomStorage> procurementPageDtoIPage = customStorageMapper.listPageByCustom(page, customStorage);
         procurementPageDtoIPage.getRecords().forEach(item -> item.setInboundNum0(item.getInboundNum()));
         List<CustomStorage> procurementPageDtos = procurementPageDtoIPage.getRecords();
@@ -537,38 +523,38 @@
         List<ProcurementPageDtoCopy> procurementPageDtoCopyList = procurementPageDtoCopyIPage.getRecords();
         // 璁$畻寰呭叆搴撴暟閲�
         // 鏌ヨ閲囪喘璁板綍宸插叆搴撴暟閲�
-        List<Integer> collect = procurementPageDtoCopyList.stream().map(ProcurementPageDtoCopy::getId).collect(Collectors.toList());
-        if(CollectionUtils.isEmpty( collect)){
-            return procurementPageDtoCopyIPage;
-        }
-        LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
-        procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
-        procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, 2);
-        List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
-        if(CollectionUtils.isEmpty( procurementRecords)){
-            return procurementPageDtoCopyIPage;
-        }
+//        List<Integer> collect = procurementPageDtoCopyList.stream().map(ProcurementPageDtoCopy::getId).collect(Collectors.toList());
+//        if(CollectionUtils.isEmpty( collect)){
+//            return procurementPageDtoCopyIPage;
+//        }
+//        LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
+//        procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
+//        procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, 2);
+//        List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
+//        if(CollectionUtils.isEmpty( procurementRecords)){
+//            return procurementPageDtoCopyIPage;
+//        }
         for (ProcurementPageDtoCopy dto : procurementPageDtoCopyList) {
             // 鏍规嵁閲囪喘鍙拌处ID绛涢�夊搴旂殑鍑哄簱璁板綍
-            List<ProcurementRecordOut> collect1 = procurementRecords.stream()
-                    .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
-                    .collect(Collectors.toList());
+//            List<ProcurementRecordOut> collect1 = procurementRecords.stream()
+//                    .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
+//                    .collect(Collectors.toList());
 
             // 濡傛灉娌℃湁鐩稿叧鐨勫嚭搴撹褰曪紝璺宠繃璇ユ潯鏁版嵁
-            if(CollectionUtils.isEmpty(collect1)){
-                dto.setInboundNum0(dto.getInboundNum());
-                dto.setTotalInboundNum(BigDecimal.ZERO);
-                continue;
-            }
+//            if(CollectionUtils.isEmpty(collect1)){
+//                dto.setInboundNum0(dto.getInboundNum());
+//                dto.setTotalInboundNum(BigDecimal.ZERO);
+//                continue;
+//            }
 
             // 璁$畻宸插嚭搴撴暟閲忔�诲拰锛屽苟璁剧疆寰呭嚭搴撴暟閲�
-            BigDecimal totalInboundNum = collect1.stream()
-                    .map(ProcurementRecordOut::getInboundNum)
-                    .reduce(BigDecimal.ZERO, BigDecimal::add);
+//            BigDecimal totalInboundNum = collect1.stream()
+//                    .map(ProcurementRecordOut::getInboundNum)
+//                    .reduce(BigDecimal.ZERO, BigDecimal::add);
             // 鍑哄簱鏁伴噺 = 鎬绘暟閲� - 寰呭嚭搴撴暟閲�
-            dto.setTotalInboundNum(totalInboundNum);
+            dto.setTotalInboundNum(dto.getInboundNum().subtract(dto.getInboundNum0()));
             // 寰呭嚭搴撴暟閲� = 鎬绘暟閲� - 宸插嚭搴撴暟閲�
-            dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));
+//            dto.setInboundNum0(dto.getInboundNum().subtract(totalInboundNum));
             // 搴撳瓨浠峰��
             if(dto.getUnitPrice() != null){
                 dto.setTotalPrice(dto.getTotalInboundNum().multiply(dto.getUnitPrice()));

--
Gitblit v1.9.3