From 2edfe8214e2723dfb6cc1866c58f783f49a7f649 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期一, 12 一月 2026 11:53:07 +0800
Subject: [PATCH] yys 成品入库导出修改

---
 src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java |  105 ++++++++++++++++++----------------------------------
 1 files changed, 36 insertions(+), 69 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 73f3071..158e243 100644
--- a/src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java
+++ b/src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java
@@ -273,7 +273,7 @@
     @Override
     public void exportCopyTwo(HttpServletResponse response,Integer type) {
         LambdaQueryWrapper<CustomStorage> customStorageLambdaQueryWrapper = new LambdaQueryWrapper<>();
-        customStorageLambdaQueryWrapper.groupBy(CustomStorage::getSupplierName, CustomStorage::getProductCategory, CustomStorage::getSpecificationModel);
+        customStorageLambdaQueryWrapper.groupBy(CustomStorage::getProductCategory, CustomStorage::getSpecificationModel);
         List<CustomStorage> list = customStorageMapper.selectList(customStorageLambdaQueryWrapper);
         // 璁$畻寰呭叆搴撴暟閲�
         // 鏌ヨ閲囪喘璁板綍宸插叆搴撴暟閲�
@@ -285,7 +285,6 @@
         }
         LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
         procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
-        procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, type);
         procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, type);
         List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
         if(CollectionUtils.isEmpty( procurementRecords)){
@@ -532,34 +531,21 @@
     public IPage<ProcurementPageDtoCopy> listPageCopyByProduction(Page page, ProcurementPageDto procurementDto) {
         IPage<ProcurementPageDtoCopy> procurementPageDtoCopyIPage = procurementRecordMapper.listPageCopyByProduction(page, procurementDto);
         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;
-        }
-        for (ProcurementPageDtoCopy dto : procurementPageDtoCopyList) {
-            // 鏍规嵁閲囪喘鍙拌处ID绛涢�夊搴旂殑鍑哄簱璁板綍
-            List<ProcurementRecordOut> collect1 = procurementRecords.stream()
-                    .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
-                    .collect(Collectors.toList());
 
-            // 濡傛灉娌℃湁鐩稿叧鐨勫嚭搴撹褰曪紝璺宠繃璇ユ潯鏁版嵁
-            if(CollectionUtils.isEmpty(collect1)){
+        for (ProcurementPageDtoCopy dto : procurementPageDtoCopyList) {
+            List<Long> longs = listCopyIds(dto.getIds());
+            LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, longs);
+            procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, 2);
+            List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
+            if(CollectionUtils.isEmpty(procurementRecords)){
                 dto.setInboundNum0(dto.getInboundNum());
                 dto.setTotalInboundNum(BigDecimal.ZERO);
-                continue;
+                return procurementPageDtoCopyIPage;
             }
 
             // 璁$畻宸插嚭搴撴暟閲忔�诲拰锛屽苟璁剧疆寰呭嚭搴撴暟閲�
-            BigDecimal totalInboundNum = collect1.stream()
+            BigDecimal totalInboundNum = procurementRecords.stream()
                     .map(ProcurementRecordOut::getInboundNum)
                     .reduce(BigDecimal.ZERO, BigDecimal::add);
             // 鍑哄簱鏁伴噺 = 鎬绘暟閲� - 寰呭嚭搴撴暟閲�
@@ -577,36 +563,23 @@
     @Override
     public IPage<CustomStorage> listPageCopyByCustom(Page page, CustomStorage customStorage) {
         IPage<CustomStorage> pageList = customStorageMapper.listPageCopyByCustom(page, customStorage);
-
         List<CustomStorage> procurementPageDtoCopyList = pageList.getRecords();
-        // 璁$畻寰呭叆搴撴暟閲�
-        // 鏌ヨ閲囪喘璁板綍宸插叆搴撴暟閲�
-        List<Integer> collect = procurementPageDtoCopyList.stream().map(CustomStorage::getId).collect(Collectors.toList());
-        if(CollectionUtils.isEmpty( collect)){
-            return pageList;
-        }
-        LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
-        procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, collect);
-        procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, 3);
-        List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
-        if(CollectionUtils.isEmpty( procurementRecords)){
-            return pageList;
-        }
+
         for (CustomStorage dto : procurementPageDtoCopyList) {
             // 鏍规嵁閲囪喘鍙拌处ID绛涢�夊搴旂殑鍑哄簱璁板綍
-            List<ProcurementRecordOut> collect1 = procurementRecords.stream()
-                    .filter(ProcurementRecordOut -> ProcurementRecordOut.getProcurementRecordStorageId().equals(dto.getId()))
-                    .collect(Collectors.toList());
-
-            // 濡傛灉娌℃湁鐩稿叧鐨勫嚭搴撹褰曪紝璺宠繃璇ユ潯鏁版嵁
-            if(CollectionUtils.isEmpty(collect1)){
+            List<Long> longs = listCopyIds(dto.getIds());
+            LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, longs);
+            procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType, 3);
+            List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
+            if(CollectionUtils.isEmpty(procurementRecords)){
                 dto.setInboundNum0(dto.getInboundNum());
                 dto.setTotalInboundNum(BigDecimal.ZERO);
-                continue;
+                return pageList;
             }
 
             // 璁$畻宸插嚭搴撴暟閲忔�诲拰锛屽苟璁剧疆寰呭嚭搴撴暟閲�
-            BigDecimal totalInboundNum = collect1.stream()
+            BigDecimal totalInboundNum = procurementRecords.stream()
                     .map(ProcurementRecordOut::getInboundNum)
                     .reduce(BigDecimal.ZERO, BigDecimal::add);
             // 鍑哄簱鏁伴噺 = 鎬绘暟閲� - 寰呭嚭搴撴暟閲�
@@ -742,38 +715,32 @@
         return procurementPageDtoIPage;
     }
 
+    public List<Long> listCopyIds(String ids) {
+        List<Long> idsSet = new ArrayList<>();
+        String[] split = ids.split(",");
+        for (String s : split) {
+            idsSet.add(Long.valueOf(s));
+        }
+        return idsSet;
+    }
+
     @Override
     public IPage<ProcurementPageDtoCopy> listPageCopy(Page page, ProcurementPageDto procurementDto) {
         IPage<ProcurementPageDtoCopy> procurementPageDtoCopyIPage = procurementRecordMapper.listPageCopy(page, procurementDto);
         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,1);
-        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()) && ProcurementRecordOut.getType().equals(1))
-                    .collect(Collectors.toList());
-
-            // 濡傛灉娌℃湁鐩稿叧鐨勫嚭搴撹褰曪紝璺宠繃璇ユ潯鏁版嵁
-            if(CollectionUtils.isEmpty(collect1)){
+            List<Long> longs = listCopyIds(dto.getIds());
+            LambdaQueryWrapper<ProcurementRecordOut> procurementRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            procurementRecordLambdaQueryWrapper.in(ProcurementRecordOut::getProcurementRecordStorageId, longs);
+            procurementRecordLambdaQueryWrapper.eq(ProcurementRecordOut::getType,1);
+            List<ProcurementRecordOut> procurementRecords = procurementRecordOutMapper.selectList(procurementRecordLambdaQueryWrapper);
+            if(CollectionUtils.isEmpty(procurementRecords)){
                 dto.setInboundNum0(dto.getInboundNum());
                 dto.setTotalInboundNum(BigDecimal.ZERO);
-                continue;
+                return procurementPageDtoCopyIPage;
             }
-
             // 璁$畻宸插嚭搴撴暟閲忔�诲拰锛屽苟璁剧疆寰呭嚭搴撴暟閲�
-            BigDecimal totalInboundNum = collect1.stream()
+            BigDecimal totalInboundNum = procurementRecords.stream()
                     .map(ProcurementRecordOut::getInboundNum)
                     .reduce(BigDecimal.ZERO, BigDecimal::add);
             // 鍑哄簱鏁伴噺 = 鎬绘暟閲� - 寰呭嚭搴撴暟閲�

--
Gitblit v1.9.3