From 18fa07479d3c7f5a9b683ab0f698528d9bd2a9ec Mon Sep 17 00:00:00 2001
From: gongchunyi <deslre0381@gmail.com>
Date: 星期二, 21 四月 2026 11:23:53 +0800
Subject: [PATCH] feat: 入库管理、出库台账增加合同号字段;支持合同模糊查询

---
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java |  315 ++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 264 insertions(+), 51 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 0a277b1..9b21618 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
@@ -418,7 +418,112 @@
 
     @Override
     public IPage<SalesLedger> selectSalesLedgerListPage(Page page, SalesLedgerDto salesLedgerDto) {
-        return salesLedgerMapper.selectSalesLedgerListPage(page, salesLedgerDto);
+        IPage<SalesLedger> iPage = salesLedgerMapper.selectSalesLedgerListPage(page, salesLedgerDto);
+
+        if (CollectionUtils.isEmpty(iPage.getRecords())) {
+            return iPage;
+        }
+
+        List<Long> salesLedgerIds = iPage.getRecords().stream().map(SalesLedger::getId).collect(Collectors.toList());
+
+        boolean hasWidthHeightFilter = salesLedgerDto.getWidth() != null || salesLedgerDto.getHeight() != null;
+        Map<Long, List<SalesLedgerProduct>> matchedProductsMap = Collections.emptyMap();
+        if (hasWidthHeightFilter) {
+            LambdaQueryWrapper<SalesLedgerProduct> productQueryWrapper = new LambdaQueryWrapper<SalesLedgerProduct>()
+                    .in(SalesLedgerProduct::getSalesLedgerId, salesLedgerIds)
+                    .eq(SalesLedgerProduct::getType, 1);
+            if (salesLedgerDto.getWidth() != null) {
+                productQueryWrapper.eq(SalesLedgerProduct::getWidth, salesLedgerDto.getWidth());
+            }
+            if (salesLedgerDto.getHeight() != null) {
+                productQueryWrapper.eq(SalesLedgerProduct::getHeight, salesLedgerDto.getHeight());
+            }
+            List<SalesLedgerProduct> matchedProducts = salesLedgerProductMapper.selectList(productQueryWrapper);
+            matchedProductsMap = CollectionUtils.isEmpty(matchedProducts) ? Collections.emptyMap()
+                    : matchedProducts.stream().collect(Collectors.groupingBy(SalesLedgerProduct::getSalesLedgerId));
+        }
+
+        List<SalesLedgerProductTotalsDto> productTotals = salesLedgerProductMapper.selectSalesLedgerProductTotals(salesLedgerIds, 1);
+        Map<Long, SalesLedgerProductTotalsDto> productTotalsMap = CollectionUtils.isEmpty(productTotals)
+                ? Collections.emptyMap()
+                : productTotals.stream()
+                .filter(t -> t.getSalesLedgerId() != null)
+                .collect(Collectors.toMap(SalesLedgerProductTotalsDto::getSalesLedgerId, Function.identity(), (a, b) -> a));
+
+        List<InvoiceLedgerDto> invoiceLedgerDtoList = invoiceLedgerMapper.invoicedTotal(salesLedgerIds);
+        if (CollectionUtils.isEmpty(invoiceLedgerDtoList)) {
+            invoiceLedgerDtoList = Collections.emptyList();
+        }
+
+        Map<Long, BigDecimal> invoiceTotals = invoiceLedgerDtoList.stream()
+                .filter(dto -> dto.getSalesLedgerId() != null && dto.getInvoiceTotal() != null)
+                .collect(Collectors.toMap(
+                        dto -> dto.getSalesLedgerId().longValue(),
+                        InvoiceLedgerDto::getInvoiceTotal,
+                        BigDecimal::add
+                ));
+
+        List<ReceiptPayment> receiptPayments = Collections.emptyList();
+        if (!CollectionUtils.isEmpty(salesLedgerIds)) {
+            receiptPayments = receiptPaymentMapper.selectList(new LambdaQueryWrapper<ReceiptPayment>()
+                    .in(ReceiptPayment::getSalesLedgerId, salesLedgerIds));
+        }
+
+        Map<Long, BigDecimal> receiptTotals = new HashMap<>();
+        if (!CollectionUtils.isEmpty(receiptPayments)) {
+            for (ReceiptPayment receiptPayment : receiptPayments) {
+                if (receiptPayment.getSalesLedgerId() != null && receiptPayment.getReceiptPaymentAmount() != null) {
+                    receiptTotals.merge(receiptPayment.getSalesLedgerId(), receiptPayment.getReceiptPaymentAmount(), BigDecimal::add);
+                }
+            }
+        }
+
+        for (SalesLedger salesLedger : iPage.getRecords()) {
+            Long ledgerId = salesLedger.getId();
+
+            SalesLedgerProductTotalsDto totals = productTotalsMap.get(ledgerId);
+            if (totals != null) {
+                salesLedger.setProductTotalQuantity(totals.getTotalQuantity() != null ? totals.getTotalQuantity() : BigDecimal.ZERO);
+                salesLedger.setProductTotalArea(totals.getTotalArea() != null ? totals.getTotalArea() : BigDecimal.ZERO);
+            } else {
+                salesLedger.setProductTotalQuantity(BigDecimal.ZERO);
+                salesLedger.setProductTotalArea(BigDecimal.ZERO);
+            }
+            if (hasWidthHeightFilter) {
+                salesLedger.setMatchedProducts(matchedProductsMap.getOrDefault(ledgerId, Collections.emptyList()));
+            }
+
+            BigDecimal contractAmount = salesLedger.getContractAmount() == null ? BigDecimal.ZERO : salesLedger.getContractAmount();
+            BigDecimal invoiceTotal = invoiceTotals.getOrDefault(ledgerId, BigDecimal.ZERO);
+            BigDecimal receiptPaymentAmountTotal = receiptTotals.getOrDefault(ledgerId, BigDecimal.ZERO);
+
+            BigDecimal noInvoiceAmountTotal = contractAmount.subtract(invoiceTotal);
+            if (noInvoiceAmountTotal.compareTo(BigDecimal.ZERO) < 0) {
+                noInvoiceAmountTotal = BigDecimal.ZERO;
+            }
+
+            BigDecimal noReceiptPaymentAmountTotal = invoiceTotal.subtract(receiptPaymentAmountTotal);
+            if (noReceiptPaymentAmountTotal.compareTo(BigDecimal.ZERO) < 0) {
+                noReceiptPaymentAmountTotal = BigDecimal.ZERO;
+            }
+
+            salesLedger.setNoInvoiceAmountTotal(noInvoiceAmountTotal);
+            salesLedger.setInvoiceTotal(invoiceTotal);
+            salesLedger.setReceiptPaymentAmountTotal(receiptPaymentAmountTotal);
+            salesLedger.setNoReceiptAmount(noReceiptPaymentAmountTotal);
+
+            boolean hasInvoiceOperation = invoiceTotal.compareTo(BigDecimal.ZERO) > 0;
+            boolean hasReceiptOperation = receiptPaymentAmountTotal.compareTo(BigDecimal.ZERO) > 0;
+            salesLedger.setIsEdit(!(hasInvoiceOperation || hasReceiptOperation));
+        }
+
+        if (salesLedgerDto.getStatus() != null && salesLedgerDto.getStatus()) {
+            iPage.getRecords().removeIf(salesLedger ->
+                    Objects.equals(salesLedger.getNoInvoiceAmountTotal(), new BigDecimal("0.00")));
+            iPage.setTotal(iPage.getRecords().size());
+        }
+
+        return iPage;
     }
 
     @Override
@@ -1006,7 +1111,15 @@
         if (!updateList.isEmpty()) {
             for (SalesLedgerProduct product : updateList) {
                 product.setType(type.getCode());
-                product.setProductStockStatus(0);
+                SalesLedgerProduct db = salesLedgerProductMapper.selectById(product.getId());
+                if (db != null) {
+                    BigDecimal stockedQty = product.getStockedQuantity() != null ? product.getStockedQuantity() : db.getStockedQuantity();
+                    BigDecimal orderQty = product.getQuantity() != null ? product.getQuantity() : db.getQuantity();
+                    product.setStockedQuantity(stockedQty);
+                    product.setProductStockStatus(calculateProductStockStatus(stockedQty, orderQty));
+                } else {
+                    product.setProductStockStatus(0);
+                }
                 product.fillRemainingQuantity();
                 salesLedgerProductMapper.updateById(product);
                 //  娓呯┖閿�鍞骇鍝佺粦瀹氱殑鍔犲伐
@@ -1020,7 +1133,9 @@
                 salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());
                 salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());
                 salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProduct.getTaxInclusiveTotalPrice());
-                salesLedgerProduct.setProductStockStatus(0);
+                BigDecimal stockedQty = salesLedgerProduct.getStockedQuantity();
+                BigDecimal orderQty = salesLedgerProduct.getQuantity();
+                salesLedgerProduct.setProductStockStatus(calculateProductStockStatus(stockedQty, orderQty));
                 salesLedgerProduct.fillRemainingQuantity();
                 salesLedgerProductMapper.insert(salesLedgerProduct);
                 //  缁戝畾浜у搧棰濆鍔犲伐
@@ -1030,6 +1145,41 @@
 //                salesLedgerProductServiceImpl.addProductionData(salesLedgerProduct);
             }
         }
+        refreshSalesLedgerStockStatus(salesLedgerId);
+    }
+
+    private int calculateProductStockStatus(BigDecimal stockedQty, BigDecimal orderQty) {
+        BigDecimal stocked = stockedQty == null ? BigDecimal.ZERO : stockedQty;
+        BigDecimal order = orderQty == null ? BigDecimal.ZERO : orderQty;
+        if (stocked.compareTo(BigDecimal.ZERO) <= 0) {
+            return 0;
+        }
+        if (order.compareTo(BigDecimal.ZERO) > 0 && stocked.compareTo(order) < 0) {
+            return 1;
+        }
+        return 2;
+    }
+
+    private void refreshSalesLedgerStockStatus(Long salesLedgerId) {
+        if (salesLedgerId == null) return;
+        SalesLedger ledger = baseMapper.selectById(salesLedgerId);
+        if (ledger == null) return;
+        List<SalesLedgerProduct> allProducts = salesLedgerProductMapper.selectList(
+                Wrappers.<SalesLedgerProduct>lambdaQuery()
+                        .eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerId)
+                        .eq(SalesLedgerProduct::getType, SaleEnum.SALE.getCode()));
+        if (CollectionUtils.isEmpty(allProducts)) {
+            ledger.setStockStatus(0);
+            baseMapper.updateById(ledger);
+            return;
+        }
+        boolean anyInbound = allProducts.stream().anyMatch(p -> {
+            BigDecimal sq = p.getStockedQuantity();
+            return sq != null && sq.compareTo(BigDecimal.ZERO) > 0;
+        });
+        boolean allFull = allProducts.stream().allMatch(p -> Objects.equals(p.getProductStockStatus(), 2));
+        ledger.setStockStatus(allFull ? 2 : (anyInbound ? 1 : 0));
+        baseMapper.updateById(ledger);
     }
 
     private SalesLedger convertToEntity(SalesLedgerDto dto) {
@@ -1453,58 +1603,88 @@
 
         //  鏌ヨ鎵�鏈変骇鍝�
         List<SalesLedgerProduct> allProducts = salesLedgerProductMapper.selectList(
-                new LambdaQueryWrapper<SalesLedgerProduct>().in(SalesLedgerProduct::getSalesLedgerId, salesLedgerIds));
+                new LambdaQueryWrapper<SalesLedgerProduct>()
+                        .in(SalesLedgerProduct::getSalesLedgerId, salesLedgerIds)
+                        .eq(SalesLedgerProduct::getType, 1));
 
         if (CollectionUtils.isNotEmpty(allProducts)) {
             Map<Long, SalesLedger> ledgerMap = ledgers.stream()
                     .collect(Collectors.toMap(SalesLedger::getId, Function.identity()));
 
-            Map<Long, List<SalesLedgerProduct>> groupedData = new LinkedHashMap<>();
-            for (SalesLedgerProduct p : allProducts) {
-                groupedData.computeIfAbsent(p.getSalesLedgerId(), k -> new ArrayList<>()).add(p);
-            }
-
             List<SalesInvoicesDto.InvoiceOrderGroupDto> groups = new ArrayList<>();
             BigDecimal totalQty = BigDecimal.ZERO;
             BigDecimal totalArea = BigDecimal.ZERO;
 
-            for (Map.Entry<Long, List<SalesLedgerProduct>> ledgerEntry : groupedData.entrySet()) {
-                SalesLedger ledger = ledgerMap.get(ledgerEntry.getKey());
-                String orderNo = ledger != null ? ledger.getSalesContractNo() : "";
-                List<SalesLedgerProduct> products = ledgerEntry.getValue();
+            Map<String, List<SalesLedgerProduct>> groupedData = new LinkedHashMap<>();
+            Map<String, Set<String>> groupOrderNos = new LinkedHashMap<>();
+            for (SalesLedgerProduct p : allProducts) {
+                String productCategory = StringUtils.defaultString(p.getProductCategory(), "");
+                String specificationModel = StringUtils.defaultString(p.getSpecificationModel(), "");
+                String groupKey = productCategory + "||" + specificationModel;
+                groupedData.computeIfAbsent(groupKey, k -> new ArrayList<>()).add(p);
+
+                SalesLedger ledger = ledgerMap.get(p.getSalesLedgerId());
+                String orderNo = ledger != null ? StringUtils.defaultString(ledger.getSalesContractNo(), "") : "";
+                if (StringUtils.isNotEmpty(orderNo)) {
+                    groupOrderNos.computeIfAbsent(groupKey, k -> new LinkedHashSet<>()).add(orderNo);
+                }
+            }
+
+            for (Map.Entry<String, List<SalesLedgerProduct>> productEntry : groupedData.entrySet()) {
+                String key = productEntry.getKey();
+                String[] parts = key.split("\\|\\|", -1);
+                String productName = parts.length > 0 ? parts[0] : "";
+                String specificationModel = parts.length > 1 ? parts[1] : "";
+                List<SalesLedgerProduct> products = productEntry.getValue();
 
                 SalesInvoicesDto.InvoiceOrderGroupDto group = new SalesInvoicesDto.InvoiceOrderGroupDto();
-                group.setSalesContractNo(orderNo);
-                if (CollectionUtils.isNotEmpty(products)) {
-                    group.setProductName(products.get(0).getProductCategory());
-                }
+                Set<String> orderNos = groupOrderNos.getOrDefault(key, Collections.emptySet());
+                group.setSalesContractNo(String.join(",", orderNos));
+                group.setProductName(productName);
+                group.setSpecificationModel(specificationModel);
 
-                List<SalesInvoicesDto.InvoiceItemDto> itemDtos = new ArrayList<>();
+                Map<String, SalesInvoicesDto.InvoiceItemDto> mergedItems = new LinkedHashMap<>();
                 BigDecimal groupQty = BigDecimal.ZERO;
                 BigDecimal groupArea = BigDecimal.ZERO;
 
                 for (SalesLedgerProduct p : products) {
-                    SalesInvoicesDto.InvoiceItemDto item = new SalesInvoicesDto.InvoiceItemDto();
-                    item.setFloorCode(p.getFloorCode());
-                    item.setWidthHeight((p.getWidth() != null ? p.getWidth().stripTrailingZeros().toPlainString() : "0") +
-                            " * " + (p.getHeight() != null ? p.getHeight().stripTrailingZeros().toPlainString() : "0"));
-                    item.setQuantity(p.getQuantity());
+                    String widthHeight = (p.getWidth() != null ? p.getWidth().stripTrailingZeros().toPlainString() : "0") +
+                            " * " + (p.getHeight() != null ? p.getHeight().stripTrailingZeros().toPlainString() : "0");
+                    String floorCode = StringUtils.defaultString(p.getFloorCode(), "");
+                    String remark = StringUtils.defaultString(p.getRemark(), "");
+                    String processReq = StringUtils.defaultString(p.getProcessRequirement(), "");
+                    String itemKey = floorCode + "||" + widthHeight + "||" + remark + "||" + processReq;
+
+                    BigDecimal qty = p.getQuantity() != null ? p.getQuantity() : BigDecimal.ZERO;
 
                     // 闈㈢Н
                     BigDecimal area = p.getSettleTotalArea() != null ? p.getSettleTotalArea() : p.getActualTotalArea();
                     if (area == null && p.getWidth() != null && p.getHeight() != null && p.getQuantity() != null) {
                         area = p.getWidth().multiply(p.getHeight()).multiply(p.getQuantity()).divide(new BigDecimal(1000000), 2, RoundingMode.HALF_UP);
                     }
-                    item.setArea(area);
-                    item.setRemark(p.getRemark());
-                    item.setProcessRequirement(p.getProcessRequirement());
+                    area = area != null ? area : BigDecimal.ZERO;
 
-                    itemDtos.add(item);
-                    groupQty = groupQty.add(p.getQuantity() != null ? p.getQuantity() : BigDecimal.ZERO);
-                    groupArea = groupArea.add(area != null ? area : BigDecimal.ZERO);
+                    SalesInvoicesDto.InvoiceItemDto item = mergedItems.get(itemKey);
+                    if (item == null) {
+                        item = new SalesInvoicesDto.InvoiceItemDto();
+                        item.setFloorCode(floorCode);
+                        item.setWidthHeight(widthHeight);
+                        item.setSpecificationModel(p.getSpecificationModel());
+                        item.setQuantity(qty);
+                        item.setArea(area);
+                        item.setRemark(remark);
+                        item.setProcessRequirement(processReq);
+                        mergedItems.put(itemKey, item);
+                    } else {
+                        item.setQuantity((item.getQuantity() != null ? item.getQuantity() : BigDecimal.ZERO).add(qty));
+                        item.setArea((item.getArea() != null ? item.getArea() : BigDecimal.ZERO).add(area));
+                    }
+
+                    groupQty = groupQty.add(qty);
+                    groupArea = groupArea.add(area);
                 }
 
-                group.setItems(itemDtos);
+                group.setItems(new ArrayList<>(mergedItems.values()));
                 group.setGroupTotalQuantity(groupQty);
                 group.setGroupTotalArea(groupArea.setScale(2, RoundingMode.HALF_UP));
                 groups.add(group);
@@ -1565,7 +1745,7 @@
                 SalesLabelDto dto = new SalesLabelDto();
                 dto.setCustomerName(salesLedger.getCustomerName());
                 dto.setSalesContractNo(salesLedger.getSalesContractNo());
-                dto.setProductName(p.getProductCategory());
+                dto.setProductName(p.getSpecificationModel());
 
                 // 瀹�*楂�=鏁伴噺
                 String specification = (p.getWidth() != null ? p.getWidth().stripTrailingZeros().toPlainString() : "0") + "*" +
@@ -1690,22 +1870,55 @@
             throw new ServiceException("鍏ュ簱澶辫触,鏈煡璇㈠埌璇ラ攢鍞鍗曠殑閿�鍞骇鍝�");
         }
         for (SalesLedgerProduct product : salesLedgerProducts) {
+            if (!Objects.equals(product.getSalesLedgerId(), ledger.getId())) {
+                throw new ServiceException("鍏ュ簱澶辫触,瀛樺湪涓嶅睘浜庡綋鍓嶉攢鍞鍗曠殑浜у搧");
+            }
             if (product.getProductModelId() == null) {
+                continue;
+            }
+            BigDecimal orderQty = product.getQuantity() == null ? BigDecimal.ZERO : product.getQuantity();
+            BigDecimal oldStocked = product.getStockedQuantity() == null ? BigDecimal.ZERO : product.getStockedQuantity();
+            BigDecimal inboundQty = orderQty.subtract(oldStocked);
+            if (inboundQty.compareTo(BigDecimal.ZERO) < 0) {
+                inboundQty = BigDecimal.ZERO;
+            }
+            if (inboundQty.compareTo(BigDecimal.ZERO) <= 0) {
                 continue;
             }
             StockInventoryDto stockInventoryDto = new StockInventoryDto();
             stockInventoryDto.setRecordId(product.getId());
             stockInventoryDto.setRecordType(StockInQualifiedRecordTypeEnum.SALE_STOCK_IN.getCode());
-            stockInventoryDto.setQualitity(product.getQuantity());
+            stockInventoryDto.setQualitity(inboundQty);
             stockInventoryDto.setProductModelId(product.getProductModelId());
             stockInventoryDto.setSalesLedgerId(ledger.getId());
             stockInventoryDto.setSalesLedgerProductId(product.getId());
             stockInventoryService.addstockInventory(stockInventoryDto);
+
+            BigDecimal newStocked = oldStocked.add(inboundQty);
+            int lineStockStatus;
+            if (newStocked.compareTo(BigDecimal.ZERO) <= 0) {
+                lineStockStatus = 0;
+            } else if (orderQty.compareTo(BigDecimal.ZERO) > 0 && newStocked.compareTo(orderQty) < 0) {
+                lineStockStatus = 1;
+            } else {
+                lineStockStatus = 2;
+            }
+            product.setStockedQuantity(newStocked);
+            product.setProductStockStatus(lineStockStatus);
+            product.fillRemainingQuantity();
+            salesLedgerProductMapper.updateById(product);
         }
         //  鎸夐攢鍞鍗曚骇鍝佸叆搴撴儏鍐垫洿鏂颁富鍗曞叆搴撶姸鎬侊細1-閮ㄥ垎鍏ュ簱锛�2-宸插叆搴�
         List<SalesLedgerProduct> ledgerAllProducts = salesLedgerProductMapper.selectList(Wrappers.<SalesLedgerProduct>lambdaQuery().eq(SalesLedgerProduct::getSalesLedgerId, ledger.getId()));
-        boolean hasStocked = CollectionUtils.isNotEmpty(ledgerAllProducts) && ledgerAllProducts.stream().anyMatch(item -> Objects.equals(item.getProductStockStatus(), 1));
-        boolean allStocked = CollectionUtils.isNotEmpty(ledgerAllProducts) && ledgerAllProducts.stream().allMatch(item -> Objects.equals(item.getProductStockStatus(), 1));
+        boolean hasStocked = CollectionUtils.isNotEmpty(ledgerAllProducts) && ledgerAllProducts.stream().anyMatch(item -> {
+            BigDecimal sq = item.getStockedQuantity();
+            return sq != null && sq.compareTo(BigDecimal.ZERO) > 0;
+        });
+        boolean allStocked = CollectionUtils.isNotEmpty(ledgerAllProducts) && ledgerAllProducts.stream().allMatch(item -> {
+            BigDecimal orderQty = item.getQuantity() == null ? BigDecimal.ZERO : item.getQuantity();
+            BigDecimal stockedQty = item.getStockedQuantity() == null ? BigDecimal.ZERO : item.getStockedQuantity();
+            return orderQty.compareTo(BigDecimal.ZERO) <= 0 || stockedQty.compareTo(orderQty) >= 0;
+        });
         ledger.setStockStatus(allStocked ? 2 : (hasStocked ? 1 : 0));
         baseMapper.updateById(ledger);
     }
@@ -1874,6 +2087,11 @@
             }
             stockUtils.addUnStock(ledgerId, dbProduct.getId(), dbProduct.getProductModelId(), inboundThisLine,
                     StockInUnQualifiedRecordTypeEnum.SALES_SCAN_UNSTOCK_IN.getCode(), dbProduct.getId());
+
+            BigDecimal oldUnStocked = dbProduct.getUnqualifiedStockedQuantity() == null ? BigDecimal.ZERO : dbProduct.getUnqualifiedStockedQuantity();
+            dbProduct.setUnqualifiedStockedQuantity(oldUnStocked.add(inboundThisLine));
+            dbProduct.fillRemainingQuantity();
+            salesLedgerProductMapper.updateById(dbProduct);
         }
     }
 
@@ -1927,12 +2145,6 @@
             }
             stockUtils.assertQualifiedAvailable(dbProduct.getProductModelId(), outboundThisLine);
 
-            BigDecimal oldStocked = dbProduct.getStockedQuantity() == null ? BigDecimal.ZERO : dbProduct.getStockedQuantity();
-            BigDecimal newStocked = oldStocked.subtract(outboundThisLine);
-            if (newStocked.compareTo(BigDecimal.ZERO) < 0) {
-                newStocked = BigDecimal.ZERO;
-            }
-
             StockInventoryDto stockInventoryDto = new StockInventoryDto();
             stockInventoryDto.setRecordId(dbProduct.getId());
             stockInventoryDto.setRecordType(StockOutQualifiedRecordTypeEnum.SALE_SCAN_STOCK_OUT.getCode());
@@ -1942,17 +2154,8 @@
             stockInventoryDto.setSalesLedgerProductId(dbProduct.getId());
             stockInventoryService.subtractStockInventory(stockInventoryDto);
 
-            BigDecimal orderQty = dbProduct.getQuantity() == null ? BigDecimal.ZERO : dbProduct.getQuantity();
-            int lineStockStatus;
-            if (newStocked.compareTo(BigDecimal.ZERO) <= 0) {
-                lineStockStatus = 0;
-            } else if (orderQty.compareTo(BigDecimal.ZERO) > 0 && newStocked.compareTo(orderQty) < 0) {
-                lineStockStatus = 1;
-            } else {
-                lineStockStatus = 2;
-            }
-            dbProduct.setStockedQuantity(newStocked);
-            dbProduct.setProductStockStatus(lineStockStatus);
+            BigDecimal oldShipped = dbProduct.getShippedQuantity() == null ? BigDecimal.ZERO : dbProduct.getShippedQuantity();
+            dbProduct.setShippedQuantity(oldShipped.add(outboundThisLine));
             dbProduct.fillRemainingQuantity();
             salesLedgerProductMapper.updateById(dbProduct);
         }
@@ -2015,9 +2218,19 @@
             if (dbProduct.getProductModelId() == null) {
                 throw new ServiceException("涓嶅悎鏍煎嚭搴撳け璐�,浜у搧瑙勬牸鏈淮鎶�,鏃犳硶鍑哄簱");
             }
+            BigDecimal unStocked = dbProduct.getUnqualifiedStockedQuantity() == null ? BigDecimal.ZERO : dbProduct.getUnqualifiedStockedQuantity();
+            BigDecimal unShipped = dbProduct.getUnqualifiedShippedQuantity() == null ? BigDecimal.ZERO : dbProduct.getUnqualifiedShippedQuantity();
+            BigDecimal canUnShip = unStocked.subtract(unShipped);
+            if (outboundThisLine.compareTo(canUnShip) > 0) {
+                throw new ServiceException("涓嶅悎鏍煎嚭搴撳け璐�,鍑哄簱鏁伴噺涓嶈兘澶т簬涓嶅悎鏍煎叆搴撴暟閲�");
+            }
             stockUtils.assertUnqualifiedAvailable(dbProduct.getProductModelId(), outboundThisLine);
             stockUtils.subtractUnStock(ledgerId, dbProduct.getId(), dbProduct.getProductModelId(), outboundThisLine,
                     StockOutUnQualifiedRecordTypeEnum.SALE_SCAN_UNSTOCK_OUT.getCode(), dbProduct.getId());
+
+            dbProduct.setUnqualifiedShippedQuantity(unShipped.add(outboundThisLine));
+            dbProduct.fillRemainingQuantity();
+            salesLedgerProductMapper.updateById(dbProduct);
         }
     }
 }

--
Gitblit v1.9.3