package com.by4cloud.platformx.business.service.impl;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.date.DateUtil;
|
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.ObjUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.http.HttpUtil;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.by4cloud.platformx.business.dto.ProductAddDTO;
|
import com.by4cloud.platformx.business.dto.ProductQueryDTO;
|
import com.by4cloud.platformx.business.dto.SyncProductDTO;
|
import com.by4cloud.platformx.business.entity.BusinessCustomer;
|
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 com.by4cloud.platformx.common.security.util.SecurityUtils;
|
import jakarta.validation.constraints.NotNull;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.validation.BindingResult;
|
|
import java.util.*;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
import java.util.stream.IntStream;
|
|
;
|
|
/**
|
* 产品信息
|
*
|
* @author platformx
|
* @date 2026-05-07 10:17:52
|
*/
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
|
|
private final TaxCodeMapper taxCodeMapper;
|
|
private final StringRedisTemplate redisTemplate;
|
|
@Value("${erp.smj}")
|
private String smjErp;
|
|
@Value("${erp.smjsc}")
|
private String smjscErp;
|
|
@Value("${erp.smjzt}")
|
private String smjztErp;
|
|
@Value("${dept.smj}")
|
private String smj;
|
|
@Value("${dept.smjsc}")
|
private String smjsc;
|
|
@Value("${dept.smjzt}")
|
private String smjzt;
|
|
@Value("${dept.smjhw}")
|
private String smjhw;
|
|
|
@Override
|
public Page pageScope(Page page, Product product) {
|
if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
|
List<String> smjList = new ArrayList<>();
|
smjList.add(smj);
|
smjList.add(smjhw);
|
return baseMapper.page(page,product,smjList);
|
}
|
return baseMapper.pageScope(page,product,DataScope.of("comp_id"));
|
}
|
|
@Override
|
public List<Tree<Long>> treeList() {
|
List<TreeNode<Long>> collect = baseMapper
|
.selectListByScope(Wrappers.<Product>lambdaQuery()
|
.orderByAsc(Product::getCreateTime), DataScope.of("comp_id"))
|
.stream().map(getNodeFunction()).collect(Collectors.toList());
|
|
// 模糊查询 不组装树结构 直接返回 表格方便编辑
|
// if (StrUtil.isNotBlank(productName)) {
|
// return collect.stream().map(node -> {
|
// Tree<Long> tree = new Tree<>();
|
// tree.putAll(node.getExtra());
|
// BeanUtils.copyProperties(node, tree);
|
// return tree;
|
// }).collect(Collectors.toList());
|
// }
|
TreeNode<Long> parent = new TreeNode<>();
|
parent.setId(0L);
|
parent.setName("目录");
|
parent.setParentId(-1L);
|
collect.add(parent);
|
return TreeUtil.build(collect, 0L);
|
}
|
|
@Override
|
public List<ProductSelectVo> getProductList(Product product) {
|
return baseMapper.getProductListByScope(product,DataScope.of("comp_id"));
|
}
|
|
|
@NotNull
|
private Function<Product, TreeNode<Long>> getNodeFunction() {
|
return product -> {
|
TreeNode<Long> node = new TreeNode<>();
|
node.setId(product.getId());
|
node.setName(product.getProductName());
|
node.setParentId(product.getParentId());
|
//node.setWeight(product.getParentId());
|
// 扩展属性
|
// Map<String, Object> extra = new HashMap<>();
|
// extra.put("picPath", category.getPicPath());
|
// extra.put("Type", category.getType());
|
// extra.put("isShow", category.getIsShow());
|
// extra.put("iconPicPath", category.getIconPath());
|
// extra.put("status", category.getStatus());
|
|
// 适配 vue3
|
// Map<String, Object> meta = new HashMap<>();
|
/* meta.put("title", product.getProductName());
|
meta.put("icon", product.getPrice());*/
|
|
//extra.put("meta", meta);
|
//node.setExtra(extra);
|
return node;
|
};
|
}
|
|
@Override
|
public R getProductListByParentId(ProductQueryDTO queryDTO) {
|
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)
|
// .like(StrUtil.isNotEmpty(queryDTO.getProductName()),Product::getProductName,queryDTO.getProductName())
|
// .eq(StrUtil.isNotEmpty(queryDTO.getParentId()),Product::getParentId,queryDTO.getParentId())
|
// .in(StrUtil.isNotEmpty(queryDTO.getContractCategory())&&StrUtil.equals(queryDTO.getContractCategory(), "water_house"),
|
// Product::getErpCode,erpCodes);
|
if (StrUtil.isNotBlank(queryDTO.getProductIds())){
|
String[] arr = queryDTO.getProductIds().split(",");
|
queryDTO.setProductId(Arrays.stream(arr).collect(Collectors.toList()));
|
}
|
if (StrUtil.equals(SecurityUtils.getUser().getCompId()+"","2089995177814495234")||
|
StrUtil.equals(SecurityUtils.getUser().getCompId()+"","2101966257365045249")){
|
List<ProductSelectVo> selectVos = baseMapper.getProductSMJListByParentId(queryDTO, Arrays.asList(erpCodes));
|
if (selectVos.size()>2000){
|
return R.ok(selectVos.subList(0,1999));
|
}
|
return R.ok(selectVos);
|
}
|
List<ProductSelectVo> selectVos = baseMapper.getProductListByParentId(queryDTO, Arrays.asList(erpCodes),DataScope.of("comp_id"));
|
if (selectVos.size()>2000){
|
return R.ok(selectVos.subList(0,1999));
|
}
|
return R.ok(selectVos);
|
}
|
|
@Override
|
public R saveErpProduct(List<ProductAddDTO> addDTOS) {
|
if (CollUtil.isNotEmpty(addDTOS)){
|
for (ProductAddDTO addDTO:addDTOS
|
) {
|
if (StrUtil.isBlank(addDTO.getErpCode())){
|
return R.failed("erp编码不能为空");
|
}
|
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 (CollUtil.isEmpty(classPro)){
|
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.getSphwjc());
|
product.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
|
}
|
baseMapper.insert(product);
|
classPro.add(product);
|
}
|
List<Product> productList = baseMapper.selectListByScope(Wrappers.<Product>lambdaQuery()
|
.eq(StrUtil.isNotEmpty(addDTO.getErpCode()),Product::getErpCode,addDTO.getErpCode())
|
, DataScope.of("comp_id"));
|
if (CollUtil.isEmpty(productList)){
|
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.getSphwjc());
|
product.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
|
}
|
baseMapper.insert(product);
|
}
|
}
|
}
|
return R.failed("数据为空");
|
}
|
|
@Override
|
public R importProduct(List<ProductExcelVO> excelVOList, BindingResult bindingResult) {
|
List<ErrorMessage> errorMessageList = (List<ErrorMessage>) bindingResult.getTarget();
|
if (CollUtil.isNotEmpty(excelVOList)) {
|
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 (CollUtil.isNotEmpty(one)){
|
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 (CollUtil.isEmpty(classPro)){
|
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());
|
}
|
|
@Override
|
public R syncSMJByDate(SyncProductDTO dto) {
|
String startDate = "";
|
if (StrUtil.isBlank(dto.getStartDate())){
|
startDate = DateUtil.formatDate(DateUtil.offsetDay(new Date(), -1));
|
}else {
|
startDate = dto.getStartDate();
|
}
|
String token = "";
|
if (redisTemplate.hasKey("SMJ_ERP_TOKEN")) {
|
token = (String) redisTemplate.opsForValue().get("SMJ_ERP_TOKEN");
|
} else {
|
token = getErpToken();
|
}
|
if (StrUtil.isEmpty(token)){
|
return R.failed("石煤机登录获取token失败");
|
}
|
List<String> list = Arrays.asList("tenant1","tenant2","tenant3");
|
for (int i = 0; i < list.size(); i++) {
|
String tan = list.get(i);
|
HttpResponse response = HttpRequest.get(smjErp + "/api/item/v1/byDateCre?startDate=" + startDate+"&tenantId="+tan)
|
.header("token", token) // 添加认证头
|
.execute(); // 执行请求.post(ymjErp,request.toJSONString());
|
log.info("石煤机——"+tan+"产品获取回参：{}", response.body());
|
JSONObject proResult = JSONObject.parseObject(response.body());
|
JSONArray items = proResult.getJSONArray("data");
|
if (CollUtil.isNotEmpty(items)){
|
log.info("石煤机产品获取数量：{}", items.size());
|
items.stream().forEach(item->{
|
JSONObject product = (JSONObject) item;
|
Product productClass = baseMapper.selectOne(Wrappers.<Product>lambdaQuery()
|
.eq(Product::getProductName,product.getString("itemClassName"))
|
// .and(wrapper -> wrapper.eq(Product::getCompId,"2089995177814495234")
|
// .or().eq(Product::getCompId,"2089996921978040321")
|
// .or().eq(Product::getCompId,"2089997578009128962")
|
// )
|
.eq(StrUtil.equals(tan,"tenant1"),Product::getCompId,"2089995177814495234")
|
.eq(StrUtil.equals(tan,"tenant2"),Product::getCompId,"2089996921978040321")
|
.eq(StrUtil.equals(tan,"tenant3"),Product::getCompId,"2089997578009128962")
|
.last("limit 1")
|
);
|
if(ObjUtil.isNull(productClass)){
|
log.info("产品分类：{}不存在",product.getString("itemClassName"));
|
productClass = new Product();
|
productClass.setProductName(product.getString("itemClassName"));
|
productClass.setErpCode(product.getString("itemClassName"));
|
productClass.setParentId(0L);
|
if(StrUtil.equals(tan,"tenant1")){
|
productClass.setCompId(2089995177814495234L);
|
}
|
if(StrUtil.equals(tan,"tenant2")){
|
productClass.setCompId(2089996921978040321L);
|
}
|
if(StrUtil.equals(tan,"tenant3")){
|
productClass.setCompId(2089997578009128962L);
|
}
|
TaxCode taxCode = taxCodeMapper.selectOne(Wrappers.<TaxCode>lambdaQuery().eq(TaxCode::getBm,product.getString("tfTaxClass")).last("limit 1"));
|
if (ObjUtil.isNotNull(taxCode)){
|
productClass.setTaxClass(taxCode.getSphwjc());
|
productClass.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
|
}
|
baseMapper.insert(productClass);
|
log.info("产品分类：{}新增成功",product.getString("itemClassName"));
|
}
|
Product productNew = baseMapper.selectOne(Wrappers.<Product>lambdaQuery()
|
.eq(Product::getErpCode,product.getString("itemNo"))
|
// .and(wrapper -> wrapper.eq(Product::getCompId,"2089995177814495234")
|
// .or().eq(Product::getCompId,"2089996921978040321")
|
// .or().eq(Product::getCompId,"2089997578009128962")
|
// )
|
.eq(StrUtil.equals(tan,"tenant1"),Product::getCompId,"2089995177814495234")
|
.eq(StrUtil.equals(tan,"tenant2"),Product::getCompId,"2089996921978040321")
|
.eq(StrUtil.equals(tan,"tenant3"),Product::getCompId,"2089997578009128962")
|
.last("limit 1")
|
);
|
if(ObjUtil.isNull(productNew)){
|
log.info("产品：{}不存在",product.getString("itemNo"));
|
productNew = new Product();
|
productNew.setProductName(product.getString("note"));
|
productNew.setErpCode(product.getString("itemNo"));
|
productNew.setProductType(product.getString("grade"));
|
if(StrUtil.equals(tan,"tenant1")){
|
productNew.setCompId(2089995177814495234L);
|
}
|
if(StrUtil.equals(tan,"tenant2")){
|
productNew.setCompId(2089996921978040321L);
|
}
|
if(StrUtil.equals(tan,"tenant3")){
|
productNew.setCompId(2089997578009128962L);
|
}
|
productNew.setParentId(productClass.getId());
|
TaxCode taxCode = taxCodeMapper.selectOne(Wrappers.<TaxCode>lambdaQuery().eq(TaxCode::getBm,product.getString("tfTaxClass")).last("limit 1"));
|
if (ObjUtil.isNotNull(taxCode)){
|
productClass.setTaxClass(taxCode.getSphwjc());
|
productClass.setTaxRate(Double.valueOf(taxCode.getSl().replace("%","")));
|
}
|
baseMapper.insert(productNew);
|
log.info("产品：{}新增成功",product.getString("itemNo"));
|
return;
|
}
|
log.info("产品：{}存在",product.getString("itemNo"));
|
});
|
}
|
}
|
|
return R.ok();
|
}
|
|
private String getErpToken() {
|
JSONObject loginJson = new JSONObject();
|
loginJson.put("username", "admin");
|
loginJson.put("password", "Zimafold@2026");
|
log.info("石煤机产品获取token入参：{}", loginJson.toJSONString());
|
String loginResp = HttpUtil.post(smjErp + "/api/account/v1/login", loginJson.toJSONString());
|
log.info("石煤机产品获取token回参：{}", loginResp);
|
JSONObject respJson = JSONObject.parseObject(loginResp);
|
if (respJson.getInteger("code") == 0) {
|
JSONObject dataJson = JSONObject.parseObject(respJson.getString("data"));
|
redisTemplate.opsForValue().set("SMJ_ERP_TOEKN",dataJson.getString("token"));
|
log.info("石煤机erp token为：{}",dataJson.getString("token"));
|
return dataJson.getString("token");
|
}
|
return "";
|
}
|
}
|
