From 8de09297dcc5393cc8542f29318b17f5696d4f8d Mon Sep 17 00:00:00 2001
From: shiyunteng <shiyunteng@example.com>
Date: 星期五, 17 七月 2026 09:28:46 +0800
Subject: [PATCH] feat:单点登录 首页及首页跳转
---
platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ProductServiceImpl.java | 137 ++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 134 insertions(+), 3 deletions(-)
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ProductServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ProductServiceImpl.java
index 72ead27..7e8d4a8 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ProductServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ProductServiceImpl.java
@@ -1,25 +1,37 @@
package com.by4cloud.platformx.business.service.impl;
+import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.lang.tree.Tree;
import cn.hutool.core.lang.tree.TreeNode;
import cn.hutool.core.lang.tree.TreeUtil;
+import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.ObjUtil;
+import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.by4cloud.platformx.admin.api.entity.SysDept;
+import com.by4cloud.platformx.business.dto.ProductAddDTO;
import com.by4cloud.platformx.business.dto.ProductQueryDTO;
import com.by4cloud.platformx.business.entity.Product;
+import com.by4cloud.platformx.business.entity.TaxCode;
import com.by4cloud.platformx.business.mapper.ProductMapper;
+import com.by4cloud.platformx.business.mapper.TaxCodeMapper;
import com.by4cloud.platformx.business.service.ProductService;
+import com.by4cloud.platformx.business.vo.ProductExcelVO;
import com.by4cloud.platformx.business.vo.ProductSelectVo;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.datascope.DataScope;
+import com.by4cloud.platformx.common.excel.vo.ErrorMessage;
import jakarta.validation.constraints.NotNull;
+import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
+import org.springframework.validation.BindingResult;
-import java.util.Arrays;
-import java.util.List;
+import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
+import java.util.stream.IntStream;
/**
* 浜у搧淇℃伅
@@ -28,7 +40,11 @@
* @date 2026-05-07 10:17:52
*/
@Service
+@RequiredArgsConstructor
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
+
+ private final TaxCodeMapper taxCodeMapper;
+
@Override
public List<Tree<Long>> treeList() {
List<TreeNode<Long>> collect = baseMapper
@@ -88,7 +104,7 @@
@Override
public R getProductListByParentId(ProductQueryDTO queryDTO) {
- String[] erpCodes = new String[]{"鎴跨绉熻祦","dianli","water"};
+ String[] erpCodes = new String[]{"house_rental","electricity_bill","water_bill"};
// MPJLambdaWrapper<Product> wrapper = new MPJLambdaWrapper<Product>()
// .selectAs("( SELECT count(1) FROM product t1 WHERE t1.parent_id = t.id )",Product::getChildNum)
// .selectAll(Product.class)
@@ -102,4 +118,119 @@
}
return R.ok(selectVos);
}
+
+ @Override
+ public R saveErpProduct(List<ProductAddDTO> addDTOS) {
+ if (ArrayUtil.isNotEmpty(addDTOS.toArray())){
+ for (ProductAddDTO addDTO:addDTOS
+ ) {
+ List<Product> classPro = baseMapper.selectListByScope(Wrappers.<Product>lambdaQuery()
+ .eq(StrUtil.isNotEmpty(addDTO.getErpTypeCode()),Product::getErpCode,addDTO.getErpTypeCode())
+ .eq(StrUtil.isNotEmpty(addDTO.getErpTypeName()),Product::getProductName,addDTO.getErpTypeName())
+ , DataScope.of("comp_id"));
+ if (ArrayUtil.isEmpty(classPro.toArray())){
+ Product product = new Product();
+ product.setProductName(addDTO.getErpTypeName());
+ product.setProductType(addDTO.getSpecification());
+ product.setParentId(0L);
+ product.setParentName("鏍圭骇浜у搧");
+ product.setErpCode(addDTO.getErpTypeCode());
+ TaxCode taxCode = taxCodeMapper.selectOne(Wrappers.<TaxCode>lambdaQuery().eq(TaxCode::getBm,addDTO.getTaxCode()).last("limit 1"));
+ if (ObjUtil.isNotNull(taxCode)){
+ product.setTaxClass(taxCode.getMc());
+ product.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
+ }
+ baseMapper.insert(product);
+ classPro.add(product);
+ }
+ Product product = new Product();
+ product.setProductName(addDTO.getErpName());
+ product.setProductType(addDTO.getSpecification());
+ product.setParentId(classPro.get(0).getId());
+ product.setParentName(classPro.get(0).getProductName());
+ product.setErpCode(addDTO.getErpCode());
+ TaxCode taxCode = taxCodeMapper.selectOne(Wrappers.<TaxCode>lambdaQuery().eq(TaxCode::getBm,addDTO.getTaxCode()).last("limit 1"));
+ if (ObjUtil.isNotNull(taxCode)){
+ product.setTaxClass(taxCode.getMc());
+ product.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
+ }
+ baseMapper.insert(product);
+ }
+ }
+ return R.ok();
+ }
+
+ @Override
+ public R importProduct(List<ProductExcelVO> excelVOList, BindingResult bindingResult) {
+ List<ErrorMessage> errorMessageList = (List<ErrorMessage>) bindingResult.getTarget();
+ if (ArrayUtil.isNotEmpty(excelVOList.toArray())) {
+ List<List<ProductExcelVO>> groups = splitList(excelVOList, 5000);
+ groups.stream().forEach(group->{
+ for (ProductExcelVO addDTO:group
+ ) {
+ Set<String> errorMsg = new HashSet<>();
+
+ if (StrUtil.isEmpty(addDTO.getErpTypeCode())&&StrUtil.isEmpty(addDTO.getErpTypeName())) {
+ errorMsg.add("浜у搧鍒嗙被淇℃伅娌℃湁");
+ }
+ List<Product> one = this.listByScope(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode, addDTO.getErpCode()));
+ if (ArrayUtil.isNotEmpty(one.toArray())){
+ errorMsg.add("浜у搧erp缂栫爜宸插瓨鍦�");
+ }
+ if (CollUtil.isEmpty(errorMsg)){
+ List<Product> classPro = baseMapper.selectListByScope(Wrappers.<Product>lambdaQuery()
+ .eq(StrUtil.isNotEmpty(addDTO.getErpTypeCode()),Product::getErpCode,addDTO.getErpTypeCode())
+ .eq(StrUtil.isNotEmpty(addDTO.getErpTypeName()),Product::getProductName,addDTO.getErpTypeName())
+ , DataScope.of("comp_id"));
+ if (ArrayUtil.isEmpty(classPro.toArray())){
+ Product product = new Product();
+ product.setProductName(addDTO.getErpTypeName());
+ product.setProductType(addDTO.getSpecification());
+ product.setParentId(0L);
+ product.setParentName("鏍圭骇浜у搧");
+ product.setErpCode(addDTO.getErpTypeCode());
+ TaxCode taxCode = taxCodeMapper.selectOne(Wrappers.<TaxCode>lambdaQuery().eq(TaxCode::getBm,addDTO.getTaxCode()).last("limit 1"));
+ if (ObjUtil.isNotNull(taxCode)){
+ product.setTaxClass(taxCode.getMc());
+ product.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
+ }
+ baseMapper.insert(product);
+ classPro.add(product);
+ }
+ Product product = new Product();
+ product.setProductName(addDTO.getErpName());
+ product.setProductType(addDTO.getSpecification());
+ product.setParentId(classPro.get(0).getId());
+ product.setParentName(classPro.get(0).getProductName());
+ product.setErpCode(addDTO.getErpCode());
+ TaxCode taxCode = taxCodeMapper.selectOne(Wrappers.<TaxCode>lambdaQuery().eq(TaxCode::getBm,addDTO.getTaxCode()).last("limit 1"));
+ if (ObjUtil.isNotNull(taxCode)){
+ product.setTaxClass(taxCode.getMc());
+ product.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
+ }
+ baseMapper.insert(product);
+ }
+ }
+ });
+ }
+ if (CollUtil.isNotEmpty(errorMessageList)) {
+ return R.failed(errorMessageList);
+ }
+ return R.ok();
+ }
+
+ public static <T> List<List<T>> splitList(List<T> list, int batchSize) {
+ if (list == null || list.isEmpty()) {
+ return Collections.emptyList();
+ }
+
+ int totalSize = list.size();
+ // 璁＄畻闇�瑕佸垎鎴愬灏戠粍
+ int batchCount = (totalSize + batchSize - 1) / batchSize;
+
+ return IntStream.range(0, batchCount)
+ .mapToObj(i -> list.subList(i * batchSize,
+ Math.min((i + 1) * batchSize, totalSize)))
+ .collect(Collectors.toList());
+ }
}
\ No newline at end of file
--
Gitblit v1.9.1