From 17a7110753d9efeeaca28d7869fec4d084fc2d46 Mon Sep 17 00:00:00 2001
From: yaowanxin <3588231647@qq.com>
Date: 星期五, 16 一月 2026 17:19:39 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev_New' into dev_New

---
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java |  102 +++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 83 insertions(+), 19 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 515bee2..d4ad7e0 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerProductServiceImpl.java
@@ -3,19 +3,25 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+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.utils.StringUtils;
 import com.ruoyi.production.mapper.*;
 import com.ruoyi.production.pojo.*;
 import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;
 import com.ruoyi.purchase.pojo.PurchaseLedger;
 import com.ruoyi.sales.dto.InvoiceRegistrationProductDto;
+import com.ruoyi.sales.dto.SalesLedgerProductDto;
 import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;
 import com.ruoyi.sales.mapper.SalesLedgerMapper;
 import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
+import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;
 import com.ruoyi.sales.pojo.SalesLedger;
 import com.ruoyi.sales.pojo.SalesLedgerProduct;
 import com.ruoyi.sales.service.ISalesLedgerProductService;
 import lombok.AllArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
@@ -24,10 +30,7 @@
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Objects;
-import java.util.Set;
+import java.util.*;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -56,6 +59,7 @@
     private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;
 
     private ProcessRouteMapper processRouteMapper;
+    private ProductProcessRouteMapper productProcessRouteMapper;
 
     private ProductWorkOrderMapper productWorkOrderMapper;
 
@@ -66,11 +70,12 @@
 
     @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.selectList(queryWrapper);
-        if (!CollectionUtils.isEmpty(salesLedgerProducts)) {
+//        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)){
+            // 寮�绁�
             InvoiceRegistrationProductDto invoiceRegistrationProductDto = new InvoiceRegistrationProductDto();
             invoiceRegistrationProductDto.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId().intValue());
             List<InvoiceRegistrationProductDto> invoiceRegistrationProductDtoList = invoiceRegistrationProductMapper.invoiceRegistrationProductList(invoiceRegistrationProductDto);
@@ -79,14 +84,20 @@
                 for (SalesLedgerProduct ledgerProduct : salesLedgerProducts) {
                     BigDecimal invoiceNum = BigDecimal.ZERO;
                     BigDecimal invoiceAmount = BigDecimal.ZERO;
+                    BigDecimal noInvoiceNum = BigDecimal.ZERO;
+                    BigDecimal noInvoiceAmount = BigDecimal.ZERO;
                     for (InvoiceRegistrationProductDto registrationProductDto : invoiceRegistrationProductDtoList) {
-                        if (ledgerProduct.getId().intValue() == registrationProductDto.getSalesLedgerProductId()) {
-                            invoiceNum = invoiceNum.add(registrationProductDto.getInvoiceNum());
+                        if(ledgerProduct.getId().intValue() == registrationProductDto.getSalesLedgerProductId()){
+                            invoiceNum =  invoiceNum.add(registrationProductDto.getInvoiceNum());
                             invoiceAmount = invoiceAmount.add(registrationProductDto.getInvoiceAmount());
+                            noInvoiceNum = ledgerProduct.getQuantity().subtract(invoiceNum);
+                            noInvoiceAmount = ledgerProduct.getTaxInclusiveTotalPrice().subtract(invoiceAmount);
                         }
                     }
                     ledgerProduct.setInvoiceNum(invoiceNum);
                     ledgerProduct.setInvoiceAmount(invoiceAmount);
+                    ledgerProduct.setNoInvoiceNum(noInvoiceNum);
+                    ledgerProduct.setNoInvoiceAmount(noInvoiceAmount);
                 }
             }
 
@@ -104,7 +115,7 @@
         // 1. 鍏堟煡璇㈣鍒犻櫎鐨勫瓙琛ㄨ褰曪紝鑾峰彇瀵瑰簲鐨� salesLedgerId
         List<SalesLedgerProduct> deletedProducts = salesLedgerProductMapper.selectBatchIds(Arrays.asList(ids));
         if (deletedProducts.isEmpty()) {
-            return 0;
+            return 0; // 娌℃湁鍙垹闄ょ殑鏁版嵁
         }
 
         // 鍙兘灞炰簬澶氫釜涓昏〃
@@ -130,7 +141,7 @@
             // 鎵归噺鏌ヨprocessRouteItems
             List<ProductProcessRouteItem> allRouteItems = productProcessRouteItemMapper.selectList(
                     new LambdaQueryWrapper<ProductProcessRouteItem>()
-                            .in(ProductProcessRouteItem::getRouteId, orderIds)
+                            .in(ProductProcessRouteItem::getProductOrderId, orderIds)
             );
 
             if (!CollectionUtils.isEmpty(allRouteItems)) {
@@ -143,9 +154,13 @@
                                 .in(ProductWorkOrder::getProductProcessRouteItemId, routeItemIds));
             }
 
-            // 鎵归噺鍒犻櫎processRouteItem
+            // 鎵归噺鍒犻櫎productProcessRouteItem
             productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>()
-                            .in(ProductProcessRouteItem::getRouteId, orderIds));
+                            .in(ProductProcessRouteItem::getProductOrderId, orderIds));
+
+            // 鎵归噺鍒犻櫎productProcessRoute
+            productProcessRouteMapper.delete(new LambdaQueryWrapper<ProductProcessRoute>()
+                    .in(ProductProcessRoute::getProductOrderId, orderIds));
 
             // 鎵归噺鍒犻櫎productOrder
             productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>()
@@ -173,9 +188,19 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public int addOrUpdateSalesLedgerProduct(SalesLedgerProduct salesLedgerProduct) {
-        //鏈紑绁ㄦ暟閲�+閲戦
-        salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());
-        salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());
+        // 寰呭洖娆撅紝浠樻
+        if(salesLedgerProduct.getType().equals(1)){
+            salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProduct.getTaxInclusiveTotalPrice().subtract(salesLedgerProduct.getInvoiceTotal()));
+            //鏈紑绁ㄦ暟閲�+閲戦
+            salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());
+            salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());
+        }else{
+            salesLedgerProduct.setPendingTicketsTotal(salesLedgerProduct.getTaxInclusiveTotalPrice().subtract(salesLedgerProduct.getTicketsTotal()));
+            // 鏈潵绁ㄦ暟閲�+閲戦
+            salesLedgerProduct.setFutureTickets(salesLedgerProduct.getQuantity());
+            salesLedgerProduct.setFutureTicketsAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());
+        }
+
         int result;
         Long salesLedgerId = salesLedgerProduct.getSalesLedgerId();
         if (salesLedgerProduct.getId() == null) {
@@ -184,10 +209,20 @@
             productOrder.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId());
             productOrder.setProductModelId(salesLedgerProduct.getId());
             productOrder.setNpsNo("SC" + String.format("%08d", salesLedgerProduct.getId()));
+            productOrder.setQuantity(salesLedgerProduct.getQuantity());//闇�姹傛暟閲�
+            productOrder.setCompleteQuantity(BigDecimal.ZERO);//瀹屾垚鏁伴噺
             productOrderMapper.insert(productOrder);
 
             ProcessRoute processRoute = processRouteMapper.selectOne(new QueryWrapper<ProcessRoute>().lambda().eq(ProcessRoute::getProductModelId, salesLedgerProduct.getProductModelId()));
             if (processRoute != null) {
+                //鏂板鐢熶骇璁㈠崟宸ヨ壓璺嚎涓昏〃
+                ProductProcessRoute productProcessRoute = new ProductProcessRoute();
+                productProcessRoute.setProductModelId(processRoute.getProductModelId());
+                productProcessRoute.setProcessRouteCode(processRoute.getProcessRouteCode());
+                productProcessRoute.setProductOrderId(productOrder.getId());
+                productProcessRoute.setBomId(processRoute.getBomId());
+                productProcessRouteMapper.insert(productProcessRoute);
+                //鏂板鐢熶骇璁㈠崟宸ヨ壓璺嚎瀛愯〃
                 List<ProcessRouteItem> processRouteItems = processRouteItemMapper.selectList(new QueryWrapper<ProcessRouteItem>().lambda().eq(ProcessRouteItem::getRouteId, processRoute.getId()));
                 // 鐢熸垚褰撳墠鏃ユ湡鐨勫墠缂�锛氬勾鏈堟棩
                 String datePrefix = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
@@ -195,7 +230,8 @@
                     ProductProcessRouteItem productProcessRouteItem = new ProductProcessRouteItem();
                     productProcessRouteItem.setProductModelId(processRouteItem.getProductModelId());
                     productProcessRouteItem.setProcessId(processRouteItem.getProcessId());
-                    productProcessRouteItem.setRouteId(productOrder.getId());
+                    productProcessRouteItem.setProductOrderId(productOrder.getId());
+                    productProcessRouteItem.setProductRouteId(productProcessRoute.getId());
                     int insert = productProcessRouteItemMapper.insert(productProcessRouteItem);
                     if (insert > 0) {
                         // 鏌ヨ浠婃棩宸插瓨鍦ㄧ殑鏈�澶у伐鍗曞彿
@@ -271,6 +307,34 @@
         return result;
     }
 
+    @Override
+    public IPage<SalesLedgerProductDto> listPage(Page page, SalesLedgerProductDto salesLedgerProduct) {
+        IPage<SalesLedgerProductDto> salesLedgerProductDtoIPage = salesLedgerProductMapper.listPage(page, salesLedgerProduct);
+        salesLedgerProductDtoIPage.getRecords().forEach(item -> {
+            // 鍒ゆ柇鐘舵��
+            if(item.getTaxInclusiveTotalPrice().compareTo(item.getInvoiceTotal()) == 0){
+                item.setStatusName("宸插畬鎴愪粯娆�");
+            }else{
+                item.setStatusName("鏈畬鎴愪粯娆�");
+            }
+        });
+        return salesLedgerProductDtoIPage;
+    }
+
+    @Override
+    public IPage<SalesLedgerProductDto> listPagePurchaseLedger(Page page, SalesLedgerProductDto salesLedgerProduct) {
+        IPage<SalesLedgerProductDto> salesLedgerProductDtoIPage = salesLedgerProductMapper.listPagePurchaseLedger(page, salesLedgerProduct);
+        salesLedgerProductDtoIPage.getRecords().forEach(item -> {
+            // 鍒ゆ柇鐘舵��
+            if(item.getTaxInclusiveTotalPrice().compareTo(item.getInvoiceTotal()) == 0){
+                item.setStatusName("宸插畬鎴愪粯娆�");
+            }else{
+                item.setStatusName("鏈畬鎴愪粯娆�");
+            }
+        });
+        return salesLedgerProductDtoIPage;
+    }
+
     /**
      * 閫氱敤鏂规硶锛氭牴鎹富琛↖D鍜屽瓙琛ㄥ垪琛紝鏇存柊涓昏〃鐨勫悎鍚岄噾棰�
      */

--
Gitblit v1.9.3