From 43a8301f04a6ea7891ef16861734163b2646e07f Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期三, 14 一月 2026 18:05:49 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev_New' into dev_New

---
 src/main/java/com/ruoyi/sales/service/impl/ReceiptPaymentServiceImpl.java |  127 +++++++++++++++--------------------------
 1 files changed, 47 insertions(+), 80 deletions(-)

diff --git a/src/main/java/com/ruoyi/sales/service/impl/ReceiptPaymentServiceImpl.java b/src/main/java/com/ruoyi/sales/service/impl/ReceiptPaymentServiceImpl.java
index ae93c3b..5a19bde 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/ReceiptPaymentServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/ReceiptPaymentServiceImpl.java
@@ -13,12 +13,15 @@
 import com.ruoyi.sales.mapper.InvoiceLedgerMapper;
 import com.ruoyi.sales.mapper.ReceiptPaymentMapper;
 import com.ruoyi.sales.mapper.SalesLedgerMapper;
+import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
 import com.ruoyi.sales.pojo.InvoiceLedger;
 import com.ruoyi.sales.pojo.ReceiptPayment;
 import com.ruoyi.sales.pojo.SalesLedger;
+import com.ruoyi.sales.pojo.SalesLedgerProduct;
 import com.ruoyi.sales.service.ReceiptPaymentService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.ObjectUtils;
 
@@ -37,39 +40,47 @@
 
     @Autowired
     private SalesLedgerMapper salesLedgerMapper;
+
+    @Autowired
+    private SalesLedgerProductMapper salesLedgerProductMapper;
     @Autowired
     private InvoiceLedgerMapper invoiceLedgerMapper;
 
     /**
      * 鍥炴鐧昏鏂板
-     * @param receiptPayment
+     * @param receiptPaymentList
      * @return
      */
     @Override
-    public int receiptPaymentSaveOrUpdate(ReceiptPayment receiptPayment) {
-        ReceiptPayment byId = receiptPayment;
-        if (!ObjectUtils.isEmpty(receiptPayment.getId())){
-             byId = this.getById(receiptPayment.getId());
+    @Transactional(rollbackFor = Exception.class)
+    public int receiptPaymentSaveOrUpdate(List<ReceiptPayment> receiptPaymentList) {
+        for (ReceiptPayment receiptPayment : receiptPaymentList) {
+            ReceiptPayment byId = receiptPayment;
+            if (!ObjectUtils.isEmpty(receiptPayment.getId())){
+                receiptPayment = this.getById(receiptPayment.getId());
+            }
+//        InvoiceLedger invoiceLedger = invoiceLedgerMapper.selectById(byId.getInvoiceLedgerId());
+            SalesLedger salesLedger = salesLedgerMapper.selectById(receiptPayment.getSalesLedgerId());
+            if(null==salesLedger) throw new RuntimeException("鏈壘鍒伴攢鍞崟");
+            // 宸插洖娆鹃噾棰�
+            SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(receiptPayment.getSalesLedgerProductId());
+            if(null==salesLedgerProduct) throw new RuntimeException("鏈壘鍒伴攢鍞崟浜у搧");
+            if (salesLedgerProduct.getPendingInvoiceTotal().compareTo(receiptPayment.getReceiptPaymentAmount())<0){
+                throw new RuntimeException("鏈鍥炴閲戦涓嶈兘澶т簬寰呭洖娆鹃噾棰�");
+            }
+            if(null==receiptPayment.getId()){
+                salesLedgerProduct.setInvoiceTotal(salesLedgerProduct.getInvoiceTotal().add(receiptPayment.getReceiptPaymentAmount()));
+                salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProduct.getTaxInclusiveTotalPrice().subtract(salesLedgerProduct.getInvoiceTotal()));
+                receiptPaymentMapper.insert(receiptPayment);
+            }else {
+                BigDecimal subtract = receiptPayment.getReceiptPaymentAmount().subtract(byId.getReceiptPaymentAmount());
+                salesLedgerProduct.setInvoiceTotal(salesLedgerProduct.getInvoiceTotal().add(subtract));
+                salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProduct.getTaxInclusiveTotalPrice().subtract(salesLedgerProduct.getInvoiceTotal()));
+                receiptPaymentMapper.updateById(receiptPayment);
+            }
+            salesLedgerProductMapper.updateById(salesLedgerProduct);
         }
-        InvoiceLedger invoiceLedger = invoiceLedgerMapper.selectById(byId.getInvoiceLedgerId());
-        Page<ReceiptPaymentDto> objectPage = new Page<>();
-        ReceiptPaymentDto receiptPaymentDto = new ReceiptPaymentDto();
-        receiptPaymentDto.setInvoiceLedgerId(invoiceLedger.getId());
-        IPage<ReceiptPaymentDto> receiptPaymentDtoIPage = receiptPaymentMapper.bindInvoiceNoRegPage(objectPage, receiptPaymentDto);
-        ReceiptPaymentDto receiptPaymentDto1 = receiptPaymentDtoIPage.getRecords().get(0);
-        if (!ObjectUtils.isEmpty(byId.getId())){
-            receiptPaymentDto1.setNoReceiptAmount(receiptPaymentDto1.getNoReceiptAmount().add(byId.getReceiptPaymentAmount()));
-        }
-        if (receiptPaymentDto1.getNoReceiptAmount().compareTo(receiptPayment.getReceiptPaymentAmount())<0){
-            throw new RuntimeException("鏈鍥炴閲戦涓嶈兘澶т簬寰呭洖娆鹃噾棰�");
-        }
-        if(null==receiptPayment.getId()){
-
-            return receiptPaymentMapper.insert(receiptPayment);
-        }else {
-
-            return receiptPaymentMapper.updateById(receiptPayment);
-        }
+        return 1;
     }
 
     /**
@@ -161,9 +172,16 @@
     @Override
     public IPage<ReceiptPaymentDto> bindInvoiceNoRegPage(Page page, ReceiptPaymentDto receiptPaymentDto) {
         IPage<ReceiptPaymentDto> receiptPaymentDtoIPage = receiptPaymentMapper.bindInvoiceNoRegPage(page, receiptPaymentDto);
-        if (receiptPaymentDto.getStatus()) {
-            receiptPaymentDtoIPage.getRecords().removeIf(receiptPaymentDto1 -> new BigDecimal("0.00").equals(receiptPaymentDto1.getNoReceiptAmount()));
-        }
+//        if (receiptPaymentDto.getStatus()) {
+//            long count = receiptPaymentDtoIPage.getRecords()
+//                    .stream()
+//                    .filter(receiptPaymentDto1 -> new BigDecimal("0.00").equals(receiptPaymentDto1.getNoReceiptAmount()))
+//                    .count();
+//            receiptPaymentDtoIPage
+//                    .getRecords()
+//                    .removeIf(receiptPaymentDto1 -> new BigDecimal("0.00").equals(receiptPaymentDto1.getNoReceiptAmount()));
+//            receiptPaymentDtoIPage.setTotal(receiptPaymentDtoIPage.getTotal() - count);
+//        }
         receiptPaymentDtoIPage.getRecords().forEach(item -> {
             // 姣旇緝鍥炴閲戦 == 寰呭洖娆鹃噾棰�
             if (item.getInvoiceTotal().compareTo(item.getReceiptPaymentAmountTotal()) == 0) {
@@ -238,59 +256,8 @@
      * @return
      */
     @Override
-    public List<CustomerInteractionDto> customerInteractions(ReceiptPaymentDto receiptPaymentDto) {
-        ArrayList<CustomerInteractionDto> result = new ArrayList<>();
-        List<CustomerInteractionDto> customerInteractionDtos = receiptPaymentMapper.customerInteractions(receiptPaymentDto);
-        if(CollectionUtils.isEmpty(customerInteractionDtos)){
-            return result;
-        }
-        // 搴旀敹鎬婚噾棰濋噾棰濊绠�
-        BigDecimal amountTotal = BigDecimal.ZERO;
-        Map<LocalDate, List<CustomerInteractionDto>> dateListMap = customerInteractionDtos.stream().collect(
-                Collectors.groupingBy(
-                        CustomerInteractionDto::getHappenTime,
-                        LinkedHashMap::new,
-                        Collectors.toList()
-                )
-        );
-        for (LocalDate localDate : dateListMap.keySet()) {
-            BigDecimal currentReceiptAmount = BigDecimal.ZERO;
-            BigDecimal invoiceAmount = BigDecimal.ZERO;
-            BigDecimal currentDateTotal = BigDecimal.ZERO;
-            List<CustomerInteractionDto> customerInteractionDtoList = dateListMap.get(localDate);
-            // 璁$畻褰撳ぉ鏀舵鏁�
-            currentReceiptAmount = customerInteractionDtoList.stream()
-                    .filter(item ->item.getType() == 0)
-                    .map(CustomerInteractionDto::getReceiptAmount)
-                    .reduce(BigDecimal.ZERO,BigDecimal::add);
-            // 璁$畻褰撳ぉ寮�绁ㄦ暟
-            invoiceAmount = customerInteractionDtoList.stream()
-                    .filter(item ->item.getType() == 1)
-                    .map(CustomerInteractionDto::getInvoiceAmount)
-                    .reduce(BigDecimal.ZERO,BigDecimal::add);
-            // 璁$畻褰撴棩姹囨��
-            currentDateTotal = currentDateTotal.add(invoiceAmount).subtract(currentReceiptAmount);
-            CustomerInteractionDto customerInteractionDto = new CustomerInteractionDto();
-            customerInteractionDto.setHappenTime(localDate);
-            customerInteractionDto.setInvoiceAmount(invoiceAmount);
-            customerInteractionDto.setReceiptAmount(currentReceiptAmount);
-            amountTotal = customerInteractionDto.getInvoiceAmount().subtract(customerInteractionDto.getReceiptAmount());
-            customerInteractionDto.setUnReceiptAmount(amountTotal);
-            result.add(customerInteractionDto);
-        }
-        ArrayList<CustomerInteractionDto> newResult = new ArrayList<>();
-        for (int i = 0; i < result.size(); i++) {
-            CustomerInteractionDto customerInteractionDto = result.get(i);
-            if (i == 0) {
-                customerInteractionDto.setUnReceiptAmount(customerInteractionDto.getInvoiceAmount().subtract(customerInteractionDto.getReceiptAmount()));
-            }else {
-                CustomerInteractionDto customerInteractionDto1 = result.get(i-1);
-                customerInteractionDto.setUnReceiptAmount(customerInteractionDto1.getUnReceiptAmount()
-                        .add(customerInteractionDto.getInvoiceAmount()).subtract(customerInteractionDto.getReceiptAmount()));
-            }
-            newResult.add(customerInteractionDto);
-        }
-        return newResult;
+    public List<InvoiceLedgerDto> customerInteractions(InvoiceLedgerDto receiptPaymentDto) {
+        return receiptPaymentMapper.invoiceLedgerSalesAccount(receiptPaymentDto);
     }
 
     /**

--
Gitblit v1.9.3