From 9850352a79244c17f9b7343f85f5abd88227a128 Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期一, 27 四月 2026 10:03:32 +0800
Subject: [PATCH] feat: 已发货导入新增出厂检验数据

---
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java |  103 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 103 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
index ba96498..53b8506 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
@@ -49,6 +49,13 @@
 import com.ruoyi.purchase.dto.SimpleReturnOrderGroupDto;
 import com.ruoyi.purchase.mapper.PurchaseReturnOrderProductsMapper;
 import com.ruoyi.quality.mapper.QualityInspectMapper;
+import com.ruoyi.quality.mapper.QualityInspectParamMapper;
+import com.ruoyi.quality.mapper.QualityTestStandardMapper;
+import com.ruoyi.quality.mapper.QualityTestStandardParamMapper;
+import com.ruoyi.quality.pojo.QualityInspect;
+import com.ruoyi.quality.pojo.QualityInspectParam;
+import com.ruoyi.quality.pojo.QualityTestStandard;
+import com.ruoyi.quality.pojo.QualityTestStandardParam;
 import com.ruoyi.sales.dto.*;
 import com.ruoyi.sales.mapper.*;
 import com.ruoyi.sales.pojo.*;
@@ -139,6 +146,9 @@
     private final ProductionProductOutputMapper productionProductOutputMapper;
     private final ProductionProductInputMapper productionProductInputMapper;
     private final QualityInspectMapper qualityInspectMapper;
+    private final QualityInspectParamMapper qualityInspectParamMapper;
+    private final QualityTestStandardMapper qualityTestStandardMapper;
+    private final QualityTestStandardParamMapper qualityTestStandardParamMapper;
     private final RedisTemplate<String, String> redisTemplate;
 
     private final ISalesLedgerProductProcessService salesLedgerProductProcessService;
@@ -2314,10 +2324,28 @@
                     if (dbProduct.getProductModelId() == null) {
                         throw new ServiceException("瀵煎叆澶辫触,璁㈠崟缂栧彿[" + orderNo + "]浜у搧瑙勬牸鏈淮鎶�,鏃犳硶琛ュ綍鍑哄簱");
                     }
+                    // 鍘嗗彶宸插彂璐цˉ褰曪細鐩存帴鍐欏叆鍏ュ簱+鍑哄簱璁板綍
+                    stockUtils.addStock(
+                            ledger.getId(),
+                            dbProduct.getId(),
+                            dbProduct.getProductModelId(),
+                            allocQty,
+                            StockInQualifiedRecordTypeEnum.SALE_STOCK_IN.getCode(),
+                            dbProduct.getId()
+                    );
+                    stockUtils.substractStock(
+                            ledger.getId(),
+                            dbProduct.getId(),
+                            dbProduct.getProductModelId(),
+                            allocQty,
+                            StockOutQualifiedRecordTypeEnum.SALE_SHIP_STOCK_OUT.getCode(),
+                            dbProduct.getId()
+                    );
                     BigDecimal oldShipped = defaultDecimal(dbProduct.getShippedQuantity());
                     BigDecimal newShipped = oldShipped.add(allocQty);
                     dbProduct.setStockedQuantity(defaultDecimal(dbProduct.getQuantity()));
                     dbProduct.setShippedQuantity(newShipped);
+                    dbProduct.setApproveStatus(3);
                     updateProductStockStatus(dbProduct);
                     dbProduct.fillRemainingQuantity();
                     updateProductShipStatus(dbProduct);
@@ -2336,6 +2364,7 @@
                         throw new ServiceException("瀵煎叆澶辫触,璁㈠崟缂栧彿[" + orderNo + "]瀛樺湪閲嶅鍙戣揣璁板綍,璇峰嬁閲嶅瀵煎叆");
                     }
                     shippingInfoMapper.insert(shippingInfo);
+                    createShippingQualityInspect(ledger, dbProduct, row, allocQty);
                 }
             }
 
@@ -2345,9 +2374,16 @@
                 BigDecimal shipped = defaultDecimal(p.getShippedQuantity());
                 return shipped.compareTo(qty) >= 0;
             });
+            boolean anyInbound = CollectionUtils.isNotEmpty(latestProducts) && latestProducts.stream().anyMatch(p -> defaultDecimal(p.getStockedQuantity()).compareTo(BigDecimal.ZERO) > 0);
+            boolean allInbound = CollectionUtils.isNotEmpty(latestProducts) && latestProducts.stream().allMatch(p -> {
+                BigDecimal qty = defaultDecimal(p.getQuantity());
+                BigDecimal stocked = defaultDecimal(p.getStockedQuantity());
+                return qty.compareTo(BigDecimal.ZERO) <= 0 || stocked.compareTo(qty) >= 0;
+            });
             if (allShipped && rowList.get(0).getReportDate() != null) {
                 ledger.setDeliveryDate(DateUtils.toLocalDate(rowList.get(0).getReportDate()));
             }
+            ledger.setStockStatus(allInbound ? 2 : (anyInbound ? 1 : 0));
             ledger.setDeliveryStatus(allShipped ? 5 : 1);
             salesLedgerMapper.updateById(ledger);
         }
@@ -2832,4 +2868,71 @@
         String subCategory = StringUtils.hasText(row.getProductSubCategory()) ? row.getProductSubCategory().trim() : "";
         return ledgerId + "|" + subCategory + "|" + shippingNo + "|" + dateStr + "|" + defaultDecimal(row.getQuantity());
     }
+
+    private void createShippingQualityInspect(SalesLedger ledger, SalesLedgerProduct dbProduct, SalesShippingImportDto row, BigDecimal inspectQty) {
+        if (ledger == null || dbProduct == null || inspectQty == null || inspectQty.compareTo(BigDecimal.ZERO) <= 0) {
+            return;
+        }
+        Date checkDate = row.getReportDate() != null ? row.getReportDate() : new Date();
+        QualityInspect qualityInspect = new QualityInspect();
+        qualityInspect.setInspectType(2);
+        qualityInspect.setCheckTime(checkDate);
+        qualityInspect.setCustomer(StringUtils.hasText(ledger.getCustomerName()) ? ledger.getCustomerName() : row.getCustomerName());
+        qualityInspect.setCheckName(StringUtils.hasText(row.getCreator()) ? row.getCreator().trim() : null);
+        qualityInspect.setProductId(dbProduct.getProductId());
+        qualityInspect.setProductName(dbProduct.getProductCategory());
+        qualityInspect.setModel(dbProduct.getSpecificationModel());
+        qualityInspect.setUnit(resolveInspectUnit(dbProduct));
+        qualityInspect.setQuantity(inspectQty);
+        qualityInspect.setCheckResult("鍚堟牸");
+        qualityInspect.setInspectState(1);
+        qualityInspect.setApprovalStatus(1);
+        qualityInspect.setProductModelId(dbProduct.getProductModelId());
+
+        QualityTestStandard selectedStandard = null;
+        if (dbProduct.getProductId() != null) {
+            List<QualityTestStandard> standards = qualityTestStandardMapper.getQualityTestStandardByProductId(dbProduct.getProductId(), 2, null);
+            if (CollectionUtils.isNotEmpty(standards)) {
+                selectedStandard = standards.get(0);
+                qualityInspect.setTestStandardId(selectedStandard.getId());
+            }
+        }
+        qualityInspectMapper.insert(qualityInspect);
+
+        if (selectedStandard == null || selectedStandard.getId() == null) {
+            return;
+        }
+        List<QualityTestStandardParam> standardParams = qualityTestStandardParamMapper.selectList(Wrappers.<QualityTestStandardParam>lambdaQuery().eq(QualityTestStandardParam::getTestStandardId, selectedStandard.getId()));
+        if (CollectionUtils.isEmpty(standardParams)) {
+            return;
+        }
+        List<QualityInspectParam> inspectParams = standardParams.stream().map(item -> {
+            QualityInspectParam param = new QualityInspectParam();
+            param.setInspectId(qualityInspect.getId());
+            param.setParameterItem(item.getParameterItem());
+            param.setUnit(item.getUnit());
+            param.setStandardValue(item.getStandardValue());
+            param.setControlValue(item.getControlValue());
+            param.setTestValue("鏃犵憰鐤�");
+            return param;
+        }).collect(Collectors.toList());
+        inspectParams.forEach(qualityInspectParamMapper::insert);
+    }
+
+    private String resolveInspectUnit(SalesLedgerProduct dbProduct) {
+        if (dbProduct == null) {
+            return null;
+        }
+        if (StringUtils.hasText(dbProduct.getUnit())) {
+            return dbProduct.getUnit();
+        }
+        if (dbProduct.getProductModelId() == null) {
+            return null;
+        }
+        ProductModel productModel = productModelMapper.selectById(dbProduct.getProductModelId());
+        if (productModel == null || !StringUtils.hasText(productModel.getUnit())) {
+            return null;
+        }
+        return productModel.getUnit();
+    }
 }

--
Gitblit v1.9.3