package com.by4cloud.platformx.business.service.impl; import cn.hutool.core.bean.BeanUtil; 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.StrUtil; 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.entity.TaxCode; 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.business.vo.ProductTreeVo; import com.by4cloud.platformx.common.core.util.R; import com.by4cloud.platformx.common.data.datascope.DataScope; import com.github.yulichang.wrapper.MPJLambdaWrapper; import jakarta.validation.constraints.NotNull; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import java.lang.reflect.Array; 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 implements ProductService { @Override public List> treeList() { List> collect = baseMapper .selectListByScope(Wrappers.lambdaQuery() .orderByAsc(Product::getCreateTime), DataScope.of("comp_id")) .stream().map(getNodeFunction()).collect(Collectors.toList()); // 模糊查询 不组装树结构 直接返回 表格方便编辑 // if (StrUtil.isNotBlank(productName)) { // return collect.stream().map(node -> { // Tree tree = new Tree<>(); // tree.putAll(node.getExtra()); // BeanUtils.copyProperties(node, tree); // return tree; // }).collect(Collectors.toList()); // } TreeNode parent = new TreeNode<>(); parent.setId(0L); parent.setName("目录"); parent.setParentId(-1L); collect.add(parent); return TreeUtil.build(collect, 0L); } @Override public List getProductList(Product product) { return baseMapper.getProductListByScope(product,DataScope.of("comp_id")); } @NotNull private Function> getNodeFunction() { return product -> { TreeNode node = new TreeNode<>(); node.setId(product.getId()); node.setName(product.getProductName()); node.setParentId(product.getParentId()); //node.setWeight(product.getParentId()); // 扩展属性 // Map 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 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 wrapper = new MPJLambdaWrapper() // .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); return R.ok(baseMapper.getProductListByParentId(queryDTO, Arrays.asList(erpCodes),DataScope.of("comp_id"))); } }