package com.by4cloud.platformx.business.service.impl;
|
|
import cn.hutool.core.lang.tree.Tree;
|
import cn.hutool.core.lang.tree.TreeNode;
|
import cn.hutool.core.lang.tree.TreeUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.by4cloud.platformx.business.dto.ProductQueryDTO;
|
import com.by4cloud.platformx.business.entity.Product;
|
import com.by4cloud.platformx.business.mapper.ProductMapper;
|
import com.by4cloud.platformx.business.service.ProductService;
|
import com.by4cloud.platformx.business.vo.ProductSelectVo;
|
import com.by4cloud.platformx.common.core.util.R;
|
import com.by4cloud.platformx.common.data.datascope.DataScope;
|
import jakarta.validation.constraints.NotNull;
|
import org.springframework.stereotype.Service;
|
|
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
|
/**
|
* 产品信息
|
*
|
* @author platformx
|
* @date 2026-05-07 10:17:52
|
*/
|
@Service
|
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
|
@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[]{"房租租赁","dianli","water"};
|
// 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);
|
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);
|
}
|
}
|
