From 1ca5584d7e3200a9af65a099bd26d3593e2ba702 Mon Sep 17 00:00:00 2001
From: liyong <18434998025@163.com>
Date: 星期四, 07 五月 2026 14:36:08 +0800
Subject: [PATCH] 迁移pro

---
 src/main/java/com/ruoyi/sales/service/impl/ShippingInfoServiceImpl.java |   38 +++++++++++++++++++++++++++++++-------
 1 files changed, 31 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/ruoyi/sales/service/impl/ShippingInfoServiceImpl.java b/src/main/java/com/ruoyi/sales/service/impl/ShippingInfoServiceImpl.java
index 08322a2..545ac7d 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/ShippingInfoServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/ShippingInfoServiceImpl.java
@@ -14,17 +14,18 @@
 import com.ruoyi.procurementrecord.utils.StockUtils;
 import com.ruoyi.sales.dto.SalesLedgerProductDto;
 import com.ruoyi.sales.dto.ShippingInfoDto;
+import com.ruoyi.sales.dto.ShippingProductDetailDto;
 import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
 import com.ruoyi.sales.mapper.ShippingInfoMapper;
-import com.ruoyi.sales.pojo.SalesLedgerProduct;
+import com.ruoyi.sales.mapper.ShippingProductDetailMapper;
 import com.ruoyi.sales.pojo.ShippingInfo;
+import com.ruoyi.sales.pojo.ShippingProductDetail;
 import com.ruoyi.sales.service.ShippingInfoService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.stereotype.Service;
 
-import java.util.Collections;
 import java.util.List;
 
 /**
@@ -48,6 +49,7 @@
 
     private final ApproveProcessServiceImpl approveProcessService;
     private final FileUtil fileUtil;
+    private final ShippingProductDetailMapper shippingProductDetailMapper;
 
     @Override
     public IPage<ShippingInfoDto> listPage(Page page, ShippingInfo req) {
@@ -66,8 +68,14 @@
         }
         //鎵e噺搴撳瓨
         if(!"宸插彂璐�".equals(byId.getStatus())){
-            SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(byId.getSalesLedgerProductId());
-            stockUtils.substractStock(salesLedgerProduct.getProductModelId(), salesLedgerProduct.getQuantity(), StockOutQualifiedRecordTypeEnum.SALE_SHIP_STOCK_OUT.getCode(), req.getId());
+//            SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(byId.getSalesLedgerProductId());
+            List<ShippingProductDetail> shippingProductDetails = shippingProductDetailMapper.selectList(new LambdaQueryWrapper<ShippingProductDetail>().eq(ShippingProductDetail::getShippingInfoId, req.getId()));
+            if (CollectionUtils.isEmpty(shippingProductDetails)) {
+                throw new RuntimeException("鍙戣揣淇℃伅涓嶅瓨鍦�");
+            }
+            for (ShippingProductDetail shippingProductDetail : shippingProductDetails) {
+                stockUtils.substractStock(shippingProductDetail.getProductModelId(), shippingProductDetail.getQuantity(), StockOutQualifiedRecordTypeEnum.SALE_SHIP_STOCK_OUT.getCode(), req.getId(), shippingProductDetail.getBatchNo());
+            }
         }
         byId.setExpressNumber(req.getExpressNumber());
         byId.setExpressCompany(req.getExpressCompany());
@@ -96,15 +104,18 @@
         // 鍒犻櫎鍙戣揣瀹℃壒
         if(CollectionUtils.isNotEmpty(shippingInfos)){
             for (ShippingInfo shippingInfo : shippingInfos){
-                ApproveProcess one = approveProcessService.getOne(new LambdaQueryWrapper<ApproveProcess>()
+                List<ApproveProcess> one = approveProcessService.list(new LambdaQueryWrapper<ApproveProcess>()
                         .like(ApproveProcess::getApproveReason, shippingInfo.getShippingNo()));
                 if(one != null){
-                    approveProcessService.delByIds(Collections.singletonList(one.getId()));
+                    List<Long> list = one.stream().map(ApproveProcess::getId).toList();
+                    approveProcessService.delByIds(list);
                 }
             }
         }
+        //鍒犻櫎鍙戣揣鏄庣粏
+        shippingProductDetailMapper.delete(new LambdaQueryWrapper<ShippingProductDetail>().in(ShippingProductDetail::getShippingInfoId, ids));
 
-        return this.removeBatchByIds(ids);
+        return this.removeByIds(ids);
     }
 
     @Override
@@ -117,4 +128,17 @@
     public List<ShippingInfo> getShippingInfoByCustomerName(String customerName) {
         return shippingInfoMapper.getShippingInfoByCustomerName(customerName);
     }
+
+    @Override
+    public boolean add(ShippingInfoDto req) {
+        this.save( req);
+        req.getBatchNoDetailList().forEach(item -> item.setShippingInfoId(req.getId()));
+        shippingProductDetailMapper.insert(req.getBatchNoDetailList());
+        return true;
+    }
+
+    @Override
+    public List<ShippingProductDetailDto> getDetail(Long id) {
+        return shippingProductDetailMapper.getDetail(id);
+    }
 }

--
Gitblit v1.9.3