From 89fc27ddebd84a2be3e60856d6a6b2318b10db4f Mon Sep 17 00:00:00 2001
From: maven <2163098428@qq.com>
Date: 星期二, 27 一月 2026 11:27:18 +0800
Subject: [PATCH] yys 删除销售台账同步删除发货台账,发货审批记录

---
 src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java |  326 ++++++++++++++++++++++++++---------------------------
 1 files changed, 161 insertions(+), 165 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 ef909fc..7247b2e 100644
--- a/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
+++ b/src/main/java/com/ruoyi/sales/service/impl/SalesLedgerServiceImpl.java
@@ -12,23 +12,34 @@
 import com.ruoyi.account.pojo.AccountIncome;
 import com.ruoyi.account.service.AccountIncomeService;
 import com.ruoyi.basic.mapper.CustomerMapper;
+import com.ruoyi.basic.mapper.ProductMapper;
+import com.ruoyi.basic.mapper.ProductModelMapper;
 import com.ruoyi.basic.pojo.Customer;
+import com.ruoyi.basic.pojo.Product;
+import com.ruoyi.basic.pojo.ProductModel;
 import com.ruoyi.common.enums.FileNameType;
 import com.ruoyi.common.exception.base.BaseException;
+import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.framework.security.LoginUser;
+import com.ruoyi.framework.web.domain.AjaxResult;
 import com.ruoyi.other.mapper.TempFileMapper;
 import com.ruoyi.other.pojo.TempFile;
+import com.ruoyi.production.dto.ProductStructureDto;
 import com.ruoyi.production.mapper.*;
 import com.ruoyi.production.pojo.*;
 import com.ruoyi.project.system.domain.SysDept;
+import com.ruoyi.project.system.domain.SysUser;
 import com.ruoyi.project.system.mapper.SysDeptMapper;
+import com.ruoyi.project.system.mapper.SysUserMapper;
 import com.ruoyi.quality.mapper.QualityInspectMapper;
 import com.ruoyi.quality.pojo.QualityInspect;
-import com.ruoyi.sales.dto.MonthlyAmountDto;
-import com.ruoyi.sales.dto.SalesLedgerDto;
+import com.ruoyi.sales.dto.*;
 import com.ruoyi.sales.mapper.*;
 import com.ruoyi.sales.pojo.*;
+import com.ruoyi.sales.service.ISalesLedgerProductService;
 import com.ruoyi.sales.service.ISalesLedgerService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -40,10 +51,13 @@
 import org.springframework.data.redis.core.script.DefaultRedisScript;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.io.IOException;
+import java.io.InputStream;
 import java.lang.reflect.Field;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
@@ -74,6 +88,7 @@
     private final CustomerMapper customerMapper;
 
     private final SalesLedgerProductMapper salesLedgerProductMapper;
+    private final SalesLedgerProductServiceImpl salesLedgerProductServiceImpl;
 
     private final CommonFileMapper commonFileMapper;
 
@@ -81,13 +96,17 @@
 
     private final ReceiptPaymentMapper receiptPaymentMapper;
 
+    private final ShippingInfoServiceImpl shippingInfoServiceImpl;
+
+    private final ShippingInfoMapper shippingInfoMapper;
+
     private final InvoiceLedgerMapper invoiceLedgerMapper;
 
     private final SalesLedgerSchedulingMapper salesLedgerSchedulingMapper;
 
     private final SalesLedgerWorkMapper salesLedgerWorkMapper;
 
-    private final SalesLedgerProductionAccountingMapper  salesLedgerProductionAccountingMapper;
+    private final SalesLedgerProductionAccountingMapper salesLedgerProductionAccountingMapper;
 
     private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;
 
@@ -96,6 +115,7 @@
     private final ProductOrderMapper productOrderMapper;
 
     private final ProcessRouteMapper processRouteMapper;
+    private final ProductProcessRouteMapper productProcessRouteMapper;
 
     private final ProcessRouteItemMapper processRouteItemMapper;
 
@@ -122,6 +142,13 @@
     private static final long LOCK_EXPIRE_TIME = 30;  // 閿佽嚜鍔ㄨ繃鏈熸椂闂达紙绉掞級
 
     private final RedisTemplate<String, String> redisTemplate;
+    @Autowired
+    private ProductModelMapper productModelMapper;
+
+    @Autowired
+    private ProductMapper productMapper;
+    @Autowired
+    private ProductStructureMapper productStructureMapper;
 
     @Override
     public List<SalesLedger> selectSalesLedgerList(SalesLedgerDto salesLedgerDto) {
@@ -315,6 +342,123 @@
         return salesLedgerMapper.selectSalesLedgerListPage(page, salesLedgerDto);
     }
 
+    @Autowired
+    private SysUserMapper sysUserMapper;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public AjaxResult importData(MultipartFile file) {
+        LoginUser loginUser = SecurityUtils.getLoginUser();
+        try {
+            InputStream inputStream = file.getInputStream();
+            ExcelUtil<SalesLedgerImportDto> salesLedgerImportDtoExcelUtil = new ExcelUtil<>(SalesLedgerImportDto.class);
+            Map<String, List<SalesLedgerImportDto>> stringListMap = salesLedgerImportDtoExcelUtil.importExcelMultiSheet(Arrays.asList("閿�鍞彴璐︽暟鎹�", "閿�鍞骇鍝佹暟鎹�"), inputStream, 0);
+            if (CollectionUtils.isEmpty(stringListMap)) return AjaxResult.error("閿�鍞〃鏍间负绌猴紒");
+            // 涓氬姟灞傚悎骞�
+            List<SalesLedgerImportDto> salesLedgerImportDtoList = stringListMap.get("閿�鍞彴璐︽暟鎹�");
+            if (CollectionUtils.isEmpty(salesLedgerImportDtoList)) return AjaxResult.error("閿�鍞彴璐︽暟鎹负绌猴紒");
+            List<SalesLedgerImportDto> salesLedgerProductImportDtoList = stringListMap.get("閿�鍞骇鍝佹暟鎹�");
+            if (CollectionUtils.isEmpty(salesLedgerProductImportDtoList)) return AjaxResult.error("閿�鍞骇鍝佹暟鎹负绌猴紒");
+            // 瀹㈡埛鏁版嵁
+            List<Customer> customers = customerMapper.selectList(new LambdaQueryWrapper<Customer>().in(Customer::getCustomerName,
+                    salesLedgerImportDtoList.stream().map(SalesLedgerImportDto::getCustomerName).collect(Collectors.toList())));
+//            // 瑙勬牸鍨嬪彿鏁版嵁
+//            List<ProductModel> productModels = productModelMapper.selectList(new LambdaQueryWrapper<ProductModel>().in(ProductModel::getModel,
+//                    salesLedgerProductImportDtoList.stream().map(SalesLedgerImportDto::getSpecificationModel).collect(Collectors.toList())));
+//            // 浜у搧澶х被鏁版嵁
+//            List<Product> productList = productMapper.selectList(new LambdaQueryWrapper<Product>().in(Product::getProductName,
+//                    salesLedgerProductImportDtoList.stream().map(SalesLedgerImportDto::getProductCategory).collect(Collectors.toList())));
+            List<Map<String,Object>> list = productModelMapper.getProductAndModelList();
+            // 褰曞叆浜烘暟鎹�
+            List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>().in(SysUser::getNickName,
+                    salesLedgerImportDtoList.stream().map(SalesLedgerImportDto::getEntryPerson).collect(Collectors.toList())));
+            for (SalesLedgerImportDto salesLedgerImportDto : salesLedgerImportDtoList) {
+                SalesLedger salesLedger = new SalesLedger();
+                BeanUtils.copyProperties(salesLedgerImportDto, salesLedger);
+                salesLedger.setExecutionDate(DateUtils.toLocalDate(salesLedgerImportDto.getExecutionDate()));
+                // 閫氳繃瀹㈡埛鍚嶇О鏌ヨ瀹㈡埛ID锛屽鎴峰悎鍚屽彿
+                salesLedger.setCustomerId(customers.stream()
+                        .filter(customer -> customer.getCustomerName().equals(salesLedger.getCustomerName()))
+                        .findFirst()
+                        .map(Customer::getId)
+                        .orElse(null));
+                salesLedger.setCustomerContractNo(customers.stream()
+                        .filter(customer -> customer.getCustomerName().equals(salesLedger.getCustomerName()))
+                        .findFirst()
+                        .map(Customer::getTaxpayerIdentificationNumber)
+                        .orElse(null));
+                Long aLong = sysUsers.stream()
+                        .filter(sysUser -> sysUser.getNickName().equals(salesLedger.getEntryPerson()))
+                        .findFirst()
+                        .map(SysUser::getUserId)
+                        .orElse(null);
+                if (aLong == null)
+                    throw new RuntimeException("褰曞叆浜�:" + salesLedger.getEntryPerson() + ",鏃犲搴旂敤鎴凤紒");
+                salesLedger.setEntryPerson(aLong.toString());
+                // 閿�鍞骇鍝佹暟鎹粦瀹氾紝閫氳繃閿�鍞崟鍙疯幏鍙栧搴旈攢鍞骇鍝佹暟鎹�
+                List<SalesLedgerProductImportDto> salesLedgerProductImportDtos = salesLedgerProductImportDtoList.stream()
+                        .filter(salesLedgerProductImportDto -> salesLedgerProductImportDto.getSalesContractNo().equals(salesLedger.getSalesContractNo()))
+                        .collect(Collectors.toList());
+                if (CollectionUtils.isEmpty(salesLedgerProductImportDtos))
+                    throw new RuntimeException("閿�鍞崟鍙�:" + salesLedgerImportDto.getSalesContractNo() + ",鏃犲搴斾骇鍝佹暟鎹紒");
+                salesLedger.setContractAmount(salesLedgerProductImportDtos.stream()
+                        .map(SalesLedgerProductImportDto::getTaxInclusiveTotalPrice)
+                        .reduce(BigDecimal.ZERO,BigDecimal::add));
+                salesLedgerMapper.insert(salesLedger);
+
+
+                for (SalesLedgerProductImportDto salesLedgerProductImportDto : salesLedgerProductImportDtos) {
+                    SalesLedgerProduct salesLedgerProduct = new SalesLedgerProduct();
+                    BeanUtils.copyProperties(salesLedgerProductImportDto, salesLedgerProduct);
+                    salesLedgerProduct.setSalesLedgerId(salesLedger.getId());
+                    salesLedgerProduct.setType(1);
+                    // 璁$畻涓嶅惈绋庢�讳环
+                    salesLedgerProduct.setTaxExclusiveTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice().divide(new BigDecimal(1).add(salesLedgerProduct.getTaxRate().divide(new BigDecimal(100))), 2, RoundingMode.HALF_UP));
+                    salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());
+                    salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxExclusiveTotalPrice());
+                    list.stream()
+                            .filter(map -> map.get("productName").equals(salesLedgerProduct.getProductCategory()) && map.get("model").equals(salesLedgerProduct.getSpecificationModel()))
+                            .findFirst()
+                            .ifPresent(map -> {
+                                salesLedgerProduct.setProductModelId(Long.parseLong(map.get("modelId").toString()));
+                                salesLedgerProduct.setProductId(Long.parseLong(map.get("id").toString()));
+                            });
+//                    salesLedgerProduct.setProductId(productList.stream()
+//                            .filter(product -> product.getProductName().equals(salesLedgerProduct.getProductCategory()))
+//                            .findFirst()
+//                            .map(Product::getId)
+//                            .orElse(null));
+//                    salesLedgerProduct.setProductModelId(productModels.stream()
+//                            .filter(productModel -> productModel.getModel().equals(salesLedgerProduct.getSpecificationModel()))
+//                            .findFirst()
+//                            .map(ProductModel::getId)
+//                            .orElse(null));
+                    salesLedgerProduct.setRegister(loginUser.getNickName());
+                    salesLedgerProduct.setRegisterDate(LocalDateTime.now());
+                    salesLedgerProduct.setApproveStatus(0);
+                    salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProductImportDto.getTaxInclusiveTotalPrice());
+                    salesLedgerProductMapper.insert(salesLedgerProduct);
+                }
+            }
+
+            return AjaxResult.success("瀵煎叆鎴愬姛");
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return AjaxResult.success("瀵煎叆澶辫触");
+    }
+
+    @Override
+    public List<LossProductModelDto> getSalesLedgerWithProductsLoss(Long salesLedgerId) {
+
+
+        List<LossProductModelDto> lossProductModelDtos = salesLedgerProductMapper.selectProductBomStructure(salesLedgerId);
+
+
+        return lossProductModelDtos;
+    }
+
+
     // 鍐呴儴绫荤敤浜庡瓨鍌ㄨ仛鍚堢粨鏋�
     private static class GroupedCustomer {
         private final Long customerId;
@@ -385,82 +529,8 @@
         List<Long> productIds = products.stream()
                 .map(SalesLedgerProduct::getId)
                 .collect(Collectors.toList());
-
-        //鎵归噺鏌ヨproductOrder
-        List<ProductOrder> productOrders = productOrderMapper.selectList(
-                new LambdaQueryWrapper<ProductOrder>()
-                        .in(ProductOrder::getProductModelId, productIds)
-        );
-
-        if (!org.springframework.util.CollectionUtils.isEmpty(productOrders)) {
-            List<Long> orderIds = productOrders.stream()
-                    .map(ProductOrder::getId)
-                    .collect(Collectors.toList());
-
-            // 鎵归噺鏌ヨprocessRouteItems
-            List<ProductProcessRouteItem> allRouteItems = productProcessRouteItemMapper.selectList(
-                    new LambdaQueryWrapper<ProductProcessRouteItem>()
-                            .in(ProductProcessRouteItem::getRouteId, orderIds)
-            );
-
-            if (!CollectionUtils.isEmpty(allRouteItems)) {
-                // 鑾峰彇瑕佸垹闄ょ殑宸ュ簭椤笽D
-                List<Long> routeItemIds = allRouteItems.stream()
-                        .map(ProductProcessRouteItem::getId)
-                        .collect(Collectors.toList());
-
-                // 鏌ヨ鍏宠仈鐨勫伐鍗旾D
-                List<ProductWorkOrder> workOrders = productWorkOrderMapper.selectList(
-                        new LambdaQueryWrapper<ProductWorkOrder>()
-                                .in(ProductWorkOrder::getProductProcessRouteItemId, routeItemIds)
-                );
-                if (!CollectionUtils.isEmpty(workOrders)) {
-                    List<Long> workOrderIds = workOrders.stream()
-                            .map(ProductWorkOrder::getId)
-                            .collect(Collectors.toList());
-
-                    // 鏌ヨ鍏宠仈鐨勭敓浜т富琛↖D
-                    List<ProductionProductMain> productMains = productionProductMainMapper.selectList(
-                            new LambdaQueryWrapper<ProductionProductMain>()
-                                    .in(ProductionProductMain::getWorkOrderId, workOrderIds)
-                    );
-                    List<Long> productMainIds = productMains.stream()
-                            .map(ProductionProductMain::getId)
-                            .collect(Collectors.toList());
-
-                    // 鍒犻櫎浜у嚭琛ㄣ�佹姇鍏ヨ〃鏁版嵁
-                    if (!CollectionUtils.isEmpty(productMainIds)) {
-                        productionProductOutputMapper.deleteByProductMainIds(productMainIds);
-                        productionProductInputMapper.deleteByProductMainIds(productMainIds);
-                        List<QualityInspect> qualityInspects = qualityInspectMapper.selectList(
-                                new LambdaQueryWrapper<QualityInspect>()
-                                        .in(QualityInspect::getProductMainId, productMainIds)
-                        );
-                        qualityInspects.forEach(qualityInspect -> {
-                            //inspectState=1 宸叉彁浜� 涓嶈兘鍒犻櫎
-                            if(qualityInspect.getInspectState() == 1){
-                                throw new RuntimeException("宸叉彁浜ょ殑妫�楠屽崟涓嶈兘鍒犻櫎");
-                            }
-                        });
-                        qualityInspectMapper.deleteByProductMainIds(productMainIds);
-                    }
-
-                    // 鍒犻櫎鐢熶骇涓昏〃鏁版嵁
-                    productionProductMainMapper.deleteByWorkOrderIds(workOrderIds);
-
-                    // 鍒犻櫎宸ュ崟鏁版嵁
-                    productWorkOrderMapper.delete(new LambdaQueryWrapper<ProductWorkOrder>()
-                            .in(ProductWorkOrder::getProductProcessRouteItemId, routeItemIds));
-                }
-            }
-            // 鎵归噺鍒犻櫎processRouteItem
-            productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>()
-                    .in(ProductProcessRouteItem::getRouteId, orderIds));
-
-            // 鎵归噺鍒犻櫎productOrder
-            productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>()
-                    .in(ProductOrder::getProductModelId, productIds));
-        }
+        //鍒犻櫎鐢熶骇鏁版嵁
+        salesLedgerProductServiceImpl.deleteProductionData(productIds);
 
         // 鎵归噺鍒犻櫎浜у搧瀛愯〃
         if (!productIds.isEmpty()) {
@@ -471,11 +541,11 @@
         wrapper.in(InvoiceRegistrationProduct::getSalesLedgerId, idList);
         List<InvoiceRegistrationProduct> invoiceRegistrationProducts = invoiceRegistrationProductMapper.selectList(wrapper);
         List<Integer> invoiceLedgerIds = new ArrayList<>();
-        if(CollectionUtils.isNotEmpty(invoiceRegistrationProducts)){
+        if (CollectionUtils.isNotEmpty(invoiceRegistrationProducts)) {
             LambdaQueryWrapper<InvoiceLedger> wrapperOne = new LambdaQueryWrapper<>();
             wrapperOne.in(InvoiceLedger::getInvoiceRegistrationProductId, invoiceRegistrationProducts.stream().map(InvoiceRegistrationProduct::getId).collect(Collectors.toList()));
             List<InvoiceLedger> invoiceLedgers = invoiceLedgerMapper.selectList(wrapperOne);
-            if(CollectionUtils.isNotEmpty(invoiceLedgers)){
+            if (CollectionUtils.isNotEmpty(invoiceLedgers)) {
                 invoiceLedgerIds = invoiceLedgers.stream().map(InvoiceLedger::getId).collect(Collectors.toList());
             }
             invoiceLedgerMapper.delete(wrapperOne);
@@ -485,10 +555,16 @@
         wrapperTwo.in(InvoiceRegistration::getSalesLedgerId, idList);
         invoiceRegistrationMapper.delete(wrapperTwo);
 
-        if(CollectionUtils.isNotEmpty(invoiceLedgerIds)){
+        if (CollectionUtils.isNotEmpty(invoiceLedgerIds)) {
             LambdaQueryWrapper<ReceiptPayment> wrapperTree = new LambdaQueryWrapper<>();
             wrapperTree.in(ReceiptPayment::getInvoiceLedgerId, invoiceLedgerIds);
             receiptPaymentMapper.delete(wrapperTree);
+        }
+        // 鍒犻櫎鍙戣揣鍙拌处璁板綍
+        List<ShippingInfo> shippingInfos = shippingInfoMapper.selectList(new LambdaQueryWrapper<ShippingInfo>()
+                .eq(ShippingInfo::getSalesLedgerId, idList));
+        if(CollectionUtils.isNotEmpty(shippingInfos)){
+            shippingInfoServiceImpl.delete(shippingInfos.stream().map(ShippingInfo::getId).collect(Collectors.toList()));
         }
 
         // 鍒犻櫎鐢熶骇绠℃帶鏁版嵁
@@ -500,7 +576,7 @@
         LambdaQueryWrapper<SalesLedgerWork> workOrderWrapper = new LambdaQueryWrapper<>();
         workOrderWrapper.in(SalesLedgerWork::getSalesLedgerId, idList);
         salesLedgerWorkMapper.delete(workOrderWrapper);
-        // 鍒犻櫎鐢熶骇鎶ュ伐鏁版嵁
+        // 鍒犻櫎鐢熶骇鏍哥畻鏁版嵁
         LambdaQueryWrapper<SalesLedgerProductionAccounting> reportWrapper = new LambdaQueryWrapper<>();
         reportWrapper.in(SalesLedgerProductionAccounting::getSalesLedgerId, idList);
         salesLedgerProductionAccountingMapper.delete(reportWrapper);
@@ -522,39 +598,13 @@
             SalesLedger salesLedger = convertToEntity(salesLedgerDto);
             salesLedger.setCustomerName(customer.getCustomerName());
             salesLedger.setTenantId(customer.getTenantId());
-
-            AccountIncome accountIncome = new AccountIncome();
-            accountIncome.setIncomeDate(salesLedger.getEntryDate());
-            accountIncome.setIncomeType("0");
-            accountIncome.setCustomerName(customer.getCustomerName());
-            accountIncome.setIncomeMoney(salesLedger.getContractAmount());
-            accountIncome.setIncomeMethod("0");
-            accountIncome.setInputTime(new Date());
-            accountIncome.setInputUser(salesLedger.getEntryPerson());
             // 3. 鏂板鎴栨洿鏂颁富琛�
             if (salesLedger.getId() == null) {
                 String contractNo = generateSalesContractNo();
                 salesLedger.setSalesContractNo(contractNo);
                 salesLedgerMapper.insert(salesLedger);
-                accountIncome.setIncomeDescribed("閿�鍞悎鍚岋細" + salesLedger.getSalesContractNo());
-                accountIncome.setInvoiceNumber(salesLedger.getSalesContractNo());
-                accountIncomeService.save(accountIncome);
             } else {
                 salesLedgerMapper.updateById(salesLedger);
-                SalesLedger salesLedgerDB = salesLedgerMapper.selectById(salesLedger.getId());
-                List<AccountIncome> accountIncomeDBs = accountIncomeService.getByInvoiceNumberList(salesLedger.getSalesContractNo());
-                if (!org.springframework.util.CollectionUtils.isEmpty(accountIncomeDBs)) {
-                    accountIncomeDBs.forEach(accountIncomeDB -> {
-                        accountIncomeDB.setCustomerName(salesLedgerDB.getCustomerName());
-                        accountIncomeDB.setIncomeMoney(salesLedgerDB.getContractAmount());
-                        accountIncomeDB.setIncomeDescribed("閿�鍞悎鍚岋細" + salesLedgerDB.getSalesContractNo());
-                        accountIncomeDB.setInvoiceNumber(salesLedgerDB.getSalesContractNo());
-                        accountIncomeDB.setInputTime(new Date());
-                        accountIncomeDB.setInputUser(salesLedgerDB.getEntryPerson());
-                        accountIncomeService.updateById(accountIncomeDB);
-                    });
-                }
-
             }
 
             // 4. 澶勭悊瀛愯〃鏁版嵁
@@ -682,62 +732,8 @@
                 salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());
                 salesLedgerProduct.setPendingInvoiceTotal(salesLedgerProduct.getTaxInclusiveTotalPrice());
                 salesLedgerProductMapper.insert(salesLedgerProduct);
-
-                ProductOrder productOrder = new ProductOrder();
-                productOrder.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId());
-                productOrder.setProductModelId(salesLedgerProduct.getId());
-                productOrder.setNpsNo("SC" + String.format("%08d", salesLedgerProduct.getId()));
-                productOrderMapper.insert(productOrder);
-
-                ProcessRoute processRoute = processRouteMapper.selectOne(new QueryWrapper<ProcessRoute>().lambda().eq(ProcessRoute::getProductModelId, salesLedgerProduct.getProductModelId()));
-                if (processRoute != null) {
-                    List<ProcessRouteItem> processRouteItems = processRouteItemMapper.selectList(new QueryWrapper<ProcessRouteItem>().lambda().eq(ProcessRouteItem::getRouteId, processRoute.getId()));
-                    // 鐢熸垚褰撳墠鏃ユ湡鐨勫墠缂�锛氬勾鏈堟棩
-                    String datePrefix = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
-                    int dragSort = 1;
-                    for (ProcessRouteItem processRouteItem : processRouteItems) {
-                        ProductProcessRouteItem productProcessRouteItem = new ProductProcessRouteItem();
-                        productProcessRouteItem.setProductModelId(processRouteItem.getProductModelId());
-                        productProcessRouteItem.setProcessId(processRouteItem.getProcessId());
-                        productProcessRouteItem.setRouteId(productOrder.getId());
-                        productProcessRouteItem.setDragSort(dragSort);
-                        int insert = productProcessRouteItemMapper.insert(productProcessRouteItem);
-                        if (insert > 0) {
-                            // 鏌ヨ浠婃棩宸插瓨鍦ㄧ殑鏈�澶у伐鍗曞彿
-                            QueryWrapper<ProductWorkOrder> queryWrapper = new QueryWrapper<>();
-                            queryWrapper.likeRight("work_order_no", datePrefix)
-                                    .orderByDesc("work_order_no")
-                                    .last("LIMIT 1");
-
-                            ProductWorkOrder lastWorkOrder = productWorkOrderMapper.selectOne(queryWrapper);
-
-                            int sequenceNumber = 1; // 榛樿搴忓彿
-                            if (lastWorkOrder != null && lastWorkOrder.getWorkOrderNo() != null) {
-                                String lastNo = lastWorkOrder.getWorkOrderNo().toString();
-                                if (lastNo.startsWith(datePrefix)) {
-                                    String seqStr = lastNo.substring(datePrefix.length());
-                                    try {
-                                        sequenceNumber = Integer.parseInt(seqStr) + 1;
-                                    } catch (NumberFormatException e) {
-                                        sequenceNumber = 1;
-                                    }
-                                }
-                            }
-                            // 鐢熸垚瀹屾暣鐨勫伐鍗曞彿
-                            String workOrderNoStr = String.format("%s%03d", datePrefix, sequenceNumber);
-                            ProductWorkOrder productWorkOrder = new ProductWorkOrder();
-                            productWorkOrder.setProductProcessRouteItemId(productProcessRouteItem.getId());
-                            productWorkOrder.setProductOrderId(productOrder.getId());
-                            productWorkOrder.setPlanQuantity(salesLedgerProduct.getQuantity());
-                            productWorkOrder.setWorkOrderNo(workOrderNoStr);
-                            productWorkOrder.setStatus(1);
-                            productWorkOrderMapper.insert(productWorkOrder);
-                        }
-                        dragSort++;
-                    }
-                    productOrder.setRouteId(processRoute.getId());
-                    productOrderMapper.updateById(productOrder);
-                }
+                // 娣诲姞鐢熶骇鏁版嵁
+                salesLedgerProductServiceImpl.addProductionData(salesLedgerProduct);
             }
         }
     }

--
Gitblit v1.9.3