From 67de53af3d78d28eda960037f39646b6886a9ee8 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期五, 27 三月 2026 15:13:05 +0800
Subject: [PATCH] yys 1.生产修改物料投入逻辑

---
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java |   61 +++++++++++++++++++++++++++---
 1 files changed, 55 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java
index 68b52cb..1f376ce 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java
@@ -6,9 +6,14 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.enums.FileNameType;
 import com.ruoyi.common.enums.StockOutQualifiedRecordTypeEnum;
 import com.ruoyi.common.enums.StockInUnQualifiedRecordTypeEnum;
 import com.ruoyi.framework.web.domain.R;
+import com.ruoyi.procurementrecord.mapper.ReturnManagementMapper;
+import com.ruoyi.procurementrecord.mapper.ReturnSaleProductMapper;
+import com.ruoyi.procurementrecord.pojo.ReturnManagement;
+import com.ruoyi.procurementrecord.pojo.ReturnSaleProduct;
 import com.ruoyi.procurementrecord.utils.StockUtils;
 import com.ruoyi.production.dto.ProductStructureDto;
 import com.ruoyi.production.mapper.*;
@@ -62,8 +67,11 @@
     private SalesLedgerMapper salesLedgerMapper;
 
     private PurchaseLedgerMapper purchaseLedgerMapper;
+    private ProductStructureRecordMapper productStructureRecordMapper;
 
     private ProductOrderMapper productOrderMapper;
+
+    private CommonFileServiceImpl commonFileService;
 
     private ProcessRouteItemMapper processRouteItemMapper;
 
@@ -81,6 +89,9 @@
     private QualityInspectMapper qualityInspectMapper;
     private ShippingInfoMapper shippingInfoMapper;
     private ShippingInfoServiceImpl shippingInfoService;
+    private ReturnSaleProductMapper returnSaleProductMapper;
+    private ReturnManagementMapper returnManagementMapper;
+
 
     private StockUtils stockUtils;
 
@@ -100,9 +111,6 @@
 
     @Override
     public List<SalesLedgerProduct> selectSalesLedgerProductList(SalesLedgerProduct salesLedgerProduct) {
-//        LambdaQueryWrapper<SalesLedgerProduct> queryWrapper = new LambdaQueryWrapper<>();
-//        queryWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerProduct.getSalesLedgerId())
-//                .eq(SalesLedgerProduct::getType, salesLedgerProduct.getType());
         List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectSalesLedgerProductList(salesLedgerProduct);
         if(!CollectionUtils.isEmpty(salesLedgerProducts)){
             salesLedgerProducts.forEach(item -> {
@@ -380,8 +388,8 @@
 
                     // 鍒犻櫎浜у嚭琛ㄣ�佹姇鍏ヨ〃鏁版嵁
                     if (!com.baomidou.mybatisplus.core.toolkit.CollectionUtils.isEmpty(productMainIds)) {
-                        productionProductOutputMapper.deleteByProductMainIds(productMainIds);
-                        productionProductInputMapper.deleteByProductMainIds(productMainIds);
+                        productionProductOutputMapper.deleteByProductMainIds(orderIds);
+                        productionProductInputMapper.deleteByProductMainIds(orderIds);
                         List<QualityInspect> qualityInspects = qualityInspectMapper.selectList(
                                 new LambdaQueryWrapper<QualityInspect>()
                                         .in(QualityInspect::getProductMainId, productMainIds)
@@ -423,6 +431,11 @@
             // 鎵归噺鍒犻櫎productOrder
             productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>()
                     .in(ProductOrder::getSaleLedgerProductId, productIds));
+            // 鍒犻櫎闄勪欢
+            commonFileService.deleteByBusinessIds(productIds, FileNameType.PRODUCT_ORDER.getValue());
+            // 鍒犻櫎鐢熶骇璁㈠崟-鐗╂枡娓呭崟
+            productStructureRecordMapper.delete(new LambdaQueryWrapper<ProductStructureRecord>()
+                    .in(ProductStructureRecord::getProductOrderId, productIds));
         }
     }
 
@@ -495,7 +508,7 @@
         if (processRoute == null) {
             return R.fail("璇峰厛璁剧疆宸ヨ壓璺嚎");
         }
-        List<ProductStructureDto> productStructureDtos = productStructureMapper.listBybomId(processRoute.getBomId());
+        List<ProductStructureDto> productStructureDtos = productStructureMapper.listBybomId(processRoute.getBomId(),false);
         if (productStructureDtos.isEmpty()) {
             return R.fail("璇峰厛璁剧疆浜у搧缁撴瀯");
         }
@@ -523,4 +536,40 @@
             return R.ok();
         }
     }
+
+    @Override
+    public String cancelDelivery(SalesLedgerProduct salesLedgerProduct) {
+        List<ShippingInfo> shippingInfos = shippingInfoMapper.selectList(new QueryWrapper<ShippingInfo>()
+                .lambda()
+                .eq(ShippingInfo::getSalesLedgerProductId, salesLedgerProduct.getId())
+                .in(ShippingInfo::getStatus, "宸插彂璐�", "鍙戣揣涓�"));
+        if(CollectionUtils.isEmpty(shippingInfos)){
+            throw new RuntimeException("娌℃湁鍙彇娑堢殑鍙戣揣淇℃伅");
+        }
+        shippingInfos.forEach(item -> {
+            item.setStatus("宸叉挙閿�");
+            shippingInfoMapper.updateById(item);
+        });
+        List<ReturnSaleProduct> returnSaleProducts = returnSaleProductMapper.selectList(new LambdaQueryWrapper<ReturnSaleProduct>()
+                .eq(ReturnSaleProduct::getReturnSaleLedgerProductId, salesLedgerProduct.getId())
+                .eq(ReturnSaleProduct::getStatus, 1));
+        if(CollectionUtils.isEmpty(returnSaleProducts)){
+            throw new RuntimeException("娌℃湁鍙彇娑堢殑閫�璐т俊鎭�");
+        }
+        returnSaleProducts.forEach(item -> {
+            item.setStatus(2);
+            returnSaleProductMapper.updateById(item);
+        });
+        List<ReturnManagement> returnManagements = returnManagementMapper.selectList(new QueryWrapper<ReturnManagement>()
+                .lambda()
+                .in(ReturnManagement::getId, returnSaleProducts.stream().map(ReturnSaleProduct::getReturnManagementId).collect(Collectors.toSet())));
+        if(CollectionUtils.isEmpty(returnManagements)){
+            throw new RuntimeException("娌℃湁鍙彇娑堢殑閫�璐т俊鎭�");
+        }
+        returnManagements.forEach(item -> {
+            item.setStatus(2);
+            returnManagementMapper.updateById(item);
+        });
+        return "鎾ら攢鎴愬姛";
+    }
 }

--
Gitblit v1.9.3