From 9aec7c5d4e11dcd66f0c886c759bbaa54efe6211 Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期五, 23 一月 2026 14:53:22 +0800
Subject: [PATCH] yys  销售导入

---
 src/main/java/com/ruoyi/sales/service/impl/InvoiceRegistrationServiceImpl.java |  119 ++++++++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 92 insertions(+), 27 deletions(-)

diff --git a/src/main/java/com/ruoyi/sales/service/impl/InvoiceRegistrationServiceImpl.java b/src/main/java/com/ruoyi/sales/service/impl/InvoiceRegistrationServiceImpl.java
index 3130872..d1ec847 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/InvoiceRegistrationServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/InvoiceRegistrationServiceImpl.java
@@ -2,18 +2,22 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 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.basic.excel.SupplierManageExcelDto;
+import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.poi.ExcelUtil;
 import com.ruoyi.sales.dto.InvoiceRegistrationDto;
 import com.ruoyi.sales.dto.InvoiceRegistrationProductDto;
+import com.ruoyi.sales.dto.SalesLedgerDto;
 import com.ruoyi.sales.excel.InvoiceRegisAndProductExcelDto;
-import com.ruoyi.sales.mapper.InvoiceRegistrationMapper;
-import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;
+import com.ruoyi.sales.mapper.*;
+import com.ruoyi.sales.pojo.InvoiceLedger;
 import com.ruoyi.sales.pojo.InvoiceRegistration;
 import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;
+import com.ruoyi.sales.pojo.SalesLedgerProduct;
 import com.ruoyi.sales.service.InvoiceRegistrationService;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.BeanUtils;
@@ -23,6 +27,7 @@
 import org.springframework.util.ObjectUtils;
 
 import javax.servlet.http.HttpServletResponse;
+import java.math.BigDecimal;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -35,39 +40,99 @@
     @Autowired
     private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;
 
+    @Autowired
+    private SalesLedgerProductMapper salesLedgerProductMapper;
+
+    @Autowired
+    private InvoiceLedgerMapper invoiceLedgerMapper;
 
     /**
-     * 寮�绁ㄧ櫥璁版柊澧�
-     * @param invoiceRegistrationDto
+     * 寮�绁ㄧ櫥璁拌褰曟柊澧�
+     * @param salesLedgerDto
      * @return
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void invoiceRegistrationSaveOrUpdate(InvoiceRegistrationDto invoiceRegistrationDto) {
+    public void invoiceRegistrationSave(SalesLedgerDto salesLedgerDto) {
+        //  鏂板寮�绁ㄧ櫥璁颁富琛�
         InvoiceRegistration invoiceRegistration = new InvoiceRegistration();
-        BeanUtils.copyProperties(invoiceRegistrationDto, invoiceRegistration);
-        List<InvoiceRegistrationProductDto> productDtoList = invoiceRegistrationDto.getProductDtoList();
-        // 鏂板寮�绁ㄧ櫥璁�
-        if(invoiceRegistrationDto.getId() == null){
-            invoiceRegistrationMapper.insert(invoiceRegistration);
-            // 鏂板寮�绁ㄤ骇鍝佺櫥璁�
-            if(CollectionUtils.isNotEmpty(productDtoList)){
-                for (InvoiceRegistrationProductDto invoiceRegistrationProductDto : productDtoList) {
-                    InvoiceRegistrationProduct invoiceRegistrationProduct = new InvoiceRegistrationProduct();
-                    BeanUtils.copyProperties(invoiceRegistrationProductDto, invoiceRegistrationProduct);
-                    invoiceRegistrationProduct.setInvoiceRegistrationId(invoiceRegistration.getId());
-                    invoiceRegistrationProductMapper.insert(invoiceRegistrationProduct);
-                }
+        BeanUtils.copyProperties(salesLedgerDto, invoiceRegistration);
+        invoiceRegistration.setId(null);
+        invoiceRegistration.setCustomerId(salesLedgerDto.getCustomerId().intValue());
+        invoiceRegistration.setSalesLedgerId(salesLedgerDto.getId().intValue());
+        invoiceRegistrationMapper.insert(invoiceRegistration);
+
+        List<SalesLedgerProduct> productData = salesLedgerDto.getProductData();
+        if (CollectionUtils.isEmpty(productData)) {
+            return;
+        }
+
+        for (SalesLedgerProduct productDatum : productData) {
+            //  鏈寮�绁ㄦ暟 / 閲戦
+            BigDecimal currentInvoiceNum = productDatum.getCurrentInvoiceNum();
+            BigDecimal currentInvoiceAmount = productDatum.getCurrentInvoiceAmount();
+
+            if (currentInvoiceNum == null || BigDecimal.ZERO.compareTo(currentInvoiceNum) == 0) {
+                continue;
             }
-        // 寮�绁ㄧ櫥璁颁慨鏀�
-        }else {
-            if(CollectionUtils.isNotEmpty(productDtoList)){
-                for (InvoiceRegistrationProductDto invoiceRegistrationProductDto : productDtoList) {
-                    InvoiceRegistrationProduct invoiceRegistrationProduct = new InvoiceRegistrationProduct();
-                    BeanUtils.copyProperties(invoiceRegistrationProductDto, invoiceRegistrationProduct);
-                    invoiceRegistrationProductMapper.updateById(invoiceRegistrationProduct);
-                }
+
+            LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductLambdaQueryWrapper = new LambdaQueryWrapper<SalesLedgerProduct>()
+                    .eq(SalesLedgerProduct::getId, productDatum.getId())
+                    .eq(SalesLedgerProduct::getSalesLedgerId, productDatum.getSalesLedgerId());
+            SalesLedgerProduct dbProduct = salesLedgerProductMapper.selectOne(salesLedgerProductLambdaQueryWrapper);
+
+            if (dbProduct == null) {
+                throw new RuntimeException("閿�鍞彴璐︿骇鍝佷笉瀛樺湪锛孖D锛�" + productDatum.getId());
             }
+
+            //  璁$畻绱寮�绁�
+            BigDecimal newInvoiceNum = dbProduct.getInvoiceNum().add(currentInvoiceNum);
+
+            BigDecimal newInvoiceAmount = dbProduct.getInvoiceAmount().add(currentInvoiceAmount);
+
+            //  璁$畻鏈紑绁�
+            BigDecimal newNoInvoiceNum = dbProduct.getQuantity().subtract(newInvoiceNum);
+
+            BigDecimal newNoInvoiceAmount = dbProduct.getTaxInclusiveTotalPrice().subtract(newInvoiceAmount);
+
+            if (newNoInvoiceNum.compareTo(BigDecimal.ZERO) < 0
+                    || newNoInvoiceAmount.compareTo(BigDecimal.ZERO) < 0) {
+                throw new RuntimeException("寮�绁ㄦ暟閲忔垨閲戦瓒呰繃鍚堝悓鎬婚噺");
+            }
+
+            //  鏇存柊 sales_ledger_product
+            salesLedgerProductMapper.update(
+                    null,
+                    new LambdaUpdateWrapper<SalesLedgerProduct>()
+                            .eq(SalesLedgerProduct::getId, dbProduct.getId())
+                            .set(SalesLedgerProduct::getInvoiceNum, newInvoiceNum)
+                            .set(SalesLedgerProduct::getInvoiceAmount, newInvoiceAmount)
+                            .set(SalesLedgerProduct::getNoInvoiceNum, newNoInvoiceNum)
+                            .set(SalesLedgerProduct::getNoInvoiceAmount, newNoInvoiceAmount)
+            );
+
+            InvoiceRegistrationProduct invoiceRegistrationProduct = new InvoiceRegistrationProduct();
+            BeanUtils.copyProperties(dbProduct, invoiceRegistrationProduct);
+
+            invoiceRegistrationProduct.setId(null);
+            invoiceRegistrationProduct.setSalesLedgerId(salesLedgerDto.getId().intValue());
+            invoiceRegistrationProduct.setInvoiceRegistrationId(invoiceRegistration.getId());
+            invoiceRegistrationProduct.setSalesLedgerProductId(dbProduct.getId().intValue());
+            invoiceRegistrationProduct.setInvoiceNum(currentInvoiceNum);
+            invoiceRegistrationProduct.setInvoiceAmount(currentInvoiceAmount);
+            invoiceRegistrationProduct.setNoInvoiceAmount(newNoInvoiceAmount);
+
+            invoiceRegistrationProductMapper.insert(invoiceRegistrationProduct);
+
+            InvoiceLedger invoiceLedger = new InvoiceLedger();
+            invoiceLedger.setInvoiceDate(salesLedgerDto.getIssueDate());
+            invoiceLedger.setInvoiceRegistrationProductId(invoiceRegistrationProduct.getId());
+            invoiceLedger.setInvoiceTotal(currentInvoiceAmount);
+            invoiceLedger.setInvoiceNo(salesLedgerDto.getInvoiceNo());
+            invoiceLedger.setCreateUser(SecurityUtils.getUserId().intValue());
+            invoiceLedger.setInvoicePerson(dbProduct.getRegister());
+
+            invoiceLedgerMapper.insert(invoiceLedger);
         }
     }
 

--
Gitblit v1.9.3