From 3c8fa3452ed9fb41ce9d3f68c81bcc4b38d19612 Mon Sep 17 00:00:00 2001
From: yuan <123@>
Date: 星期一, 31 八月 2026 20:14:41 +0800
Subject: [PATCH] fix: 统一销售和采购相关页面金额、单价、数量、总价保留6位小数

---
 src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java |  189 ++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 171 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java
index 7d8373d..3c76a76 100644
--- a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java
+++ b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java
@@ -911,20 +911,37 @@
             List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>().in(SysUser::getNickName,
                     salesLedgerImportDtoList.stream().map(PurchaseLedgerImportDto::getRecorderName).collect(Collectors.toList())));
             for (PurchaseLedgerImportDto salesLedgerImportDto : salesLedgerImportDtoList) {
-                PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectOne(new LambdaQueryWrapper<PurchaseLedger>()
+                PurchaseLedger existPurchaseLedger = purchaseLedgerMapper.selectOne(new LambdaQueryWrapper<PurchaseLedger>()
                         .eq(PurchaseLedger::getPurchaseContractNumber, salesLedgerImportDto.getPurchaseContractNumber())
                         .last("limit 1"));
-                if(purchaseLedger != null){
+                // 宸插鏍搁�氳繃鐨勯噰璐崟璺宠繃锛屼笉鍐嶉噸澶嶅鍏�
+                if (existPurchaseLedger != null && ApprovalStatusEnum.APPROVED.getCode().equals(existPurchaseLedger.getApprovalStatus())) {
                     continue;
                 }
                 PurchaseLedger salesLedger = new PurchaseLedger();
                 BeanUtils.copyProperties(salesLedgerImportDto, salesLedger);
-                // 閫氳繃渚涘簲鍟嗗悕绉版煡璇D
-                salesLedger.setSupplierId(customers.stream()
-                        .filter(customer -> customer.getSupplierName().equals(salesLedger.getSupplierName()))
-                        .findFirst()
-                        .map(SupplierManage::getId)
-                        .orElse(null));
+                // 寰呭鏍哥姸鎬佺殑閲囪喘鍗曪細鍒犻櫎璇ュ崟涓嬬殑浜у搧璇︽儏鍜屽鎵瑰疄渚嬶紝閲嶆柊褰曞叆璇︽儏
+                if (existPurchaseLedger != null) {
+                    salesLedgerProductMapper.delete(new LambdaQueryWrapper<SalesLedgerProduct>()
+                            .eq(SalesLedgerProduct::getSalesLedgerId, existPurchaseLedger.getId())
+                            .eq(SalesLedgerProduct::getType, 2));
+                    // 娓呯悊璇ュ崟涓嬬殑璐ㄦ璁板綍鍙婅川妫�鍙傛暟
+                    deleteQualityInspectByPurchaseLedger(existPurchaseLedger.getId());
+                    ApprovalInstance existApprovalInstance = approvalInstanceService.getOne(
+                            Wrappers.<ApprovalInstance>lambdaQuery()
+                                    .eq(ApprovalInstance::getBusinessId, existPurchaseLedger.getId())
+                                    .eq(ApprovalInstance::getBusinessType, 5L)
+                                    .eq(ApprovalInstance::getDeleted, 0)
+                                    .orderByDesc(ApprovalInstance::getId)
+                                    .last("limit 1"));
+                    if (existApprovalInstance != null) {
+                        approvalInstanceService.delete(Collections.singletonList(existApprovalInstance.getId()));
+                    }
+                    salesLedger.setId(existPurchaseLedger.getId());
+                    salesLedger.setApprovalStatus(ApprovalStatusEnum.PENDING.getCode());
+                }
+                // 閫氳繃渚涘簲鍟嗗悕绉版煡璇D锛屼笉瀛樺湪鍒欒嚜鍔ㄦ柊澧�
+                salesLedger.setSupplierId(findOrCreateSupplier(salesLedger.getSupplierName(), customers));
                 Long aLong = sysUsers.stream()
                         .filter(sysUser -> sysUser.getNickName().equals(salesLedger.getRecorderName()))
                         .findFirst()
@@ -964,7 +981,12 @@
                     String collect = ids.stream().map(Object::toString).collect(Collectors.joining(","));
                     salesLedger.setApproveUserIds(collect);
                 }
-                purchaseLedgerMapper.insert(salesLedger);
+                if (salesLedger.getId() == null) {
+                    purchaseLedgerMapper.insert(salesLedger);
+                } else {
+                    // 寰呭鏍哥姸鎬侀噸鏂板綍鍏ユ椂锛屾洿鏂颁富琛�
+                    purchaseLedgerMapper.updateById(salesLedger);
+                }
 
                 for (PurchaseLedgerProductImportDto salesLedgerProductImportDto : salesLedgerProductImportDtos) {
                     SalesLedgerProduct salesLedgerProduct = new SalesLedgerProduct();
@@ -972,14 +994,21 @@
                     salesLedgerProduct.setSalesLedgerId(salesLedger.getId());
                     salesLedgerProduct.setType(2);
                     // 璁$畻涓嶅惈绋庢�讳环
-                    salesLedgerProduct.setTaxExclusiveTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice().divide(new BigDecimal(1).add(salesLedgerProduct.getTaxRate().divide(new BigDecimal(100))), 2, RoundingMode.HALF_UP));
-                    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.setTaxExclusiveTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice().divide(new BigDecimal(1).add(salesLedgerProduct.getTaxRate().divide(new BigDecimal(100))), 6, RoundingMode.HALF_UP));
+                    // 浜у搧澶х被/瑙勬牸鍨嬪彿涓嶅瓨鍦ㄦ椂鑷姩鍒涘缓
+                    String productName = salesLedgerProduct.getProductCategory();
+                    if (StringUtils.isNotBlank(productName)) {
+                        // 瑙勬牸鍨嬪彿涓虹┖鏃剁敤浜у搧澶х被浣滀负瑙勬牸鍨嬪彿
+                        String model = StringUtils.isNotBlank(salesLedgerProduct.getSpecificationModel())
+                                ? salesLedgerProduct.getSpecificationModel()
+                                : productName;
+                        salesLedgerProduct.setSpecificationModel(model);
+                        Long productId = findOrCreateProduct(productName, list);
+                        Long modelId = findOrCreateProductModel(productId, productName, model,
+                                salesLedgerProduct.getUnit(), list);
+                        salesLedgerProduct.setProductId(productId);
+                        salesLedgerProduct.setProductModelId(modelId);
+                    }
                     salesLedgerProduct.setRegister(loginUser.getNickName());
                     salesLedgerProduct.setRegisterDate(LocalDateTime.now());
                     salesLedgerProduct.setApproveStatus(0);
@@ -993,8 +1022,132 @@
             return AjaxResult.success("瀵煎叆鎴愬姛");
         } catch (Exception e) {
             e.printStackTrace();
-            return AjaxResult.error("瀵煎叆澶辫触锛�" + e.getMessage());
         }
+        return AjaxResult.success("瀵煎叆澶辫触");
+    }
+
+    /**
+     * 鏌ユ壘鎴栨柊澧炰緵搴斿晢锛歴upplier_manage 琛ㄦ寜 supplier_name 鍖归厤锛屼笉瀛樺湪鍒欐柊澧烇紝缂哄け淇℃伅榛樿鍐�"/"
+     */
+    private Long findOrCreateSupplier(String supplierName, List<SupplierManage> supplierList) {
+        if (StringUtils.isBlank(supplierName)) {
+            return null;
+        }
+        // 鍐呭瓨鍒楄〃涓煡鎵撅紙鏈瀵煎叆宸叉柊澧炵殑涔熷寘鍚湪鍐咃級
+        for (SupplierManage supplier : supplierList) {
+            if (supplierName.equals(supplier.getSupplierName())) {
+                return supplier.getId();
+            }
+        }
+        // 鏁版嵁搴撴煡鎵�
+        SupplierManage existSupplier = supplierManageMapper.selectOne(new LambdaQueryWrapper<SupplierManage>()
+                .eq(SupplierManage::getSupplierName, supplierName)
+                .last("limit 1"));
+        if (existSupplier != null) {
+            supplierList.add(existSupplier);
+            return existSupplier.getId();
+        }
+        // 鏂板渚涘簲鍟嗭紝缂哄け淇℃伅锛堢◣鍙枫�佸湴鍧�銆佺數璇濈瓑锛夐粯璁ゅ啓"/"
+        SupplierManage newSupplier = new SupplierManage();
+        newSupplier.setSupplierName(supplierName);
+        newSupplier.setTaxpayerIdentificationNum("/");
+        newSupplier.setCompanyAddress("/");
+        newSupplier.setSupplierType("/");
+        newSupplier.setCompanyPhone("/");
+        newSupplier.setBankAccountName("/");
+        newSupplier.setBankAccountNum("/");
+        newSupplier.setContactUserName("/");
+        newSupplier.setContactUserPhone("/");
+        supplierManageMapper.insert(newSupplier);
+        supplierList.add(newSupplier);
+        return newSupplier.getId();
+    }
+
+    /**
+     * 鏌ユ壘鎴栨柊澧炰骇鍝佸ぇ绫伙細product 琛ㄦ寜 product_name 鍖归厤锛屼笉瀛樺湪鍒欐柊澧烇紝榛樿鐖禝D涓�278
+     */
+    private Long findOrCreateProduct(String productName, List<Map<String, Object>> productAndModelList) {
+        // 鍐呭瓨鍒楄〃涓煡鎵撅紙鏈瀵煎叆宸叉柊澧炵殑涔熷寘鍚湪鍐咃級
+        for (Map<String, Object> map : productAndModelList) {
+            if (map.get("productName") != null && productName.equals(map.get("productName"))) {
+                return Long.valueOf(map.get("id").toString());
+            }
+        }
+        // 鏁版嵁搴撴煡鎵撅紙宸插瓨鍦ㄤ絾鏆傛棤瑙勬牸鍨嬪彿鐨勪骇鍝佷笉鍦ㄥ唴瀛樺垪琛ㄤ腑锛�
+        Product existProduct = productMapper.selectOne(new LambdaQueryWrapper<Product>()
+                .eq(Product::getProductName, productName)
+                .last("limit 1"));
+        if (existProduct != null) {
+            return existProduct.getId();
+        }
+        // 鏂板浜у搧澶х被锛岄粯璁ょ埗ID涓�278
+        Product product = new Product();
+        product.setProductName(productName);
+        product.setParentId(278L);
+        productMapper.insert(product);
+        return product.getId();
+    }
+
+    /**
+     * 鏌ユ壘鎴栨柊澧炰骇鍝佽鏍煎瀷鍙凤細product_model 鎸� 浜у搧ID+瑙勬牸鍨嬪彿 鍖归厤锛屼笉瀛樺湪鍒欐柊澧炪��
+     * 浜у搧缂栫爜 = 瑙勬牸鍨嬪彿 + "_" + 涓変綅娴佹按鍙凤紱瑙勬牸鍨嬪彿涓虹┖鏃剁敤浜у搧澶х被浣滀负瑙勬牸鍨嬪彿銆�
+     */
+    private Long findOrCreateProductModel(Long productId, String productName, String model, String unit,
+                                          List<Map<String, Object>> productAndModelList) {
+        // 鍐呭瓨鍒楄〃涓煡鎵�
+        for (Map<String, Object> map : productAndModelList) {
+            if (map.get("id") != null && Long.valueOf(map.get("id").toString()).equals(productId)
+                    && model.equals(map.get("model"))) {
+                return Long.valueOf(map.get("modelId").toString());
+            }
+        }
+        // 鏁版嵁搴撴煡鎵�
+        ProductModel existProductModel = productModelMapper.selectOne(new LambdaQueryWrapper<ProductModel>()
+                .eq(ProductModel::getProductId, productId)
+                .eq(ProductModel::getModel, model)
+                .last("limit 1"));
+        if (existProductModel != null) {
+            return existProductModel.getId();
+        }
+        // 鏂板瑙勬牸鍨嬪彿锛屼骇鍝佺紪鐮� = 瑙勬牸鍨嬪彿 + "_" + 涓変綅娴佹按鍙凤紙鍚屼骇鍝佷笅鑷锛�
+        long count = productModelMapper.selectCount(new LambdaQueryWrapper<ProductModel>()
+                .eq(ProductModel::getProductId, productId));
+        ProductModel productModel = new ProductModel();
+        productModel.setProductId(productId);
+        productModel.setModel(model);
+        productModel.setUnit(unit);
+        productModel.setProductCode(model + "_" + String.format("%03d", count + 1));
+        productModelMapper.insert(productModel);
+        // 璁板綍鍒板唴瀛樺垪琛紝閬垮厤鏈瀵煎叆鍐呴噸澶嶅垱寤�
+        Map<String, Object> newMap = new HashMap<>();
+        newMap.put("id", productId);
+        newMap.put("modelId", productModel.getId());
+        newMap.put("productName", productName);
+        newMap.put("model", model);
+        productAndModelList.add(newMap);
+        return productModel.getId();
+    }
+
+    /**
+     * 鍒犻櫎閲囪喘鍗曚笅鐨勮川妫�璁板綍鍙婅川妫�鍙傛暟锛堝凡鎻愪氦鐨勬楠屽崟涓嶅厑璁稿垹闄わ級
+     */
+    private void deleteQualityInspectByPurchaseLedger(Long purchaseLedgerId) {
+        LambdaQueryWrapper<QualityInspect> inspectWrapper = new LambdaQueryWrapper<>();
+        inspectWrapper.eq(QualityInspect::getPurchaseLedgerId, purchaseLedgerId);
+        List<QualityInspect> qualityInspects = qualityInspectMapper.selectList(inspectWrapper);
+        for (QualityInspect qualityInspect : qualityInspects) {
+            if (ObjectUtils.isNotEmpty(qualityInspect.getInspectState()) && qualityInspect.getInspectState().equals(1)) {
+                throw new BaseException("宸叉彁浜ょ殑妫�楠屽崟涓嶈兘鍒犻櫎");
+            }
+        }
+        List<Long> inspectIds = qualityInspects.stream()
+                .map(QualityInspect::getId)
+                .collect(Collectors.toList());
+        if (!inspectIds.isEmpty()) {
+            qualityInspectParamMapper.delete(new LambdaQueryWrapper<QualityInspectParam>()
+                    .in(QualityInspectParam::getInspectId, inspectIds));
+        }
+        qualityInspectMapper.delete(inspectWrapper);
     }
 
     @Override

--
Gitblit v1.9.3