设备表-通过EAM中心ids获取设备树

lyh

2025-07-08 a6efc98ddf0afc935ad88d91f8817f5fc2593169

 lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java

@@ -14,6 +14,7 @@
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.common.util.oConvertUtils;
import org.jeecg.modules.eam.aspect.annotation.EquipmentHistoryLog;
import org.jeecg.modules.eam.tree.FindsEquipmentEamCenterUtil;
import org.jeecg.modules.system.entity.BaseFactory;
import org.jeecg.modules.system.entity.BaseFactoryUser;
import org.jeecg.modules.system.service.IBaseFactoryService;
@@ -119,6 +120,32 @@
        List<EamEquipmentTree> treeList = FindsEquipmentProductionUtil.wrapEquipmentProductionTreeList(list);
        //填充设备数据
        fillEquipmentByProduction(treeList);
        return treeList;
    }

    /**
     * 获取EAM中心下的设备信息
     * @param ids EAM中心ids
     * @return
     */
    @Override
    public List<EamEquipmentTree> loadTreeListByEamCenterIds(String ids){
        List<String> baseFactoryIds = Arrays.asList(ids.split(","));
        //获取所有EAM数据
        List<BaseFactory> baseFactoryList = baseFactoryService.list(new LambdaQueryWrapper<BaseFactory>().eq(BaseFactory::getDelFlag, CommonConstant.DEL_FLAG_0.toString()).orderByAsc(BaseFactory::getSorter));
        List<String> allBaseFactoryIds = new ArrayList<>();
        //找到所有产线id的上级id
        if (!baseFactoryIds.isEmpty()) {
            for (String baseFactoryId : baseFactoryIds) {
                this.getAllBaseFactoryIds(baseFactoryList, baseFactoryId, allBaseFactoryIds);
            }
        }
        //过滤EAM数据
        List<BaseFactory> list = baseFactoryList.stream().filter((BaseFactory baseFactory) -> allBaseFactoryIds.contains(baseFactory.getId())).collect(Collectors.toList());
        //组装EAM设备树
        List<EamEquipmentTree> treeList = FindsEquipmentEamCenterUtil.wrapEquipmentBaseFactoryTreeList(list);
        //填充设备数据
        fillEquipmentByBaseFactory(treeList);
        return treeList;
    }

@@ -389,6 +416,26 @@
    }

    /**
     * 获取所有的产线id（包含所有上级）
     */
    private void getAllBaseFactoryIds(List<BaseFactory> baseFactoryList, String baseFactoryId, List<String> allBaseFactoryIds) {
        if (!allBaseFactoryIds.contains(baseFactoryId)) {
            allBaseFactoryIds.add(baseFactoryId);
        }
        for (BaseFactory baseFactory : baseFactoryList) {
            if (StringUtils.isEmpty(baseFactory.getParentId())) {
                continue;
            }
            if (baseFactoryId.equals(baseFactory.getId())) {
                if (!allBaseFactoryIds.contains(baseFactory.getParentId())) {
                    allBaseFactoryIds.add(baseFactory.getParentId());
                    getAllBaseFactoryIds(baseFactoryList, baseFactory.getParentId(), allBaseFactoryIds);
                }
            }
        }
    }

    /**
     * 产线设备树填充设备数据
     */
    private void fillEquipmentByProduction(List<EamEquipmentTree> treeList) {
@@ -409,4 +456,25 @@
        }
    }

    /**
     * 产线设备树填充设备数据
     */
    private void fillEquipmentByBaseFactory(List<EamEquipmentTree> treeList) {
        for (EamEquipmentTree mdcEquipmentTree : treeList) {
            List<EamEquipment> equipmentList = eamEquipmentMapper.queryByEamCenterId(mdcEquipmentTree.getKey());
            if (CollectionUtil.isNotEmpty(equipmentList)) {
                for (EamEquipment mdcEquipment : equipmentList) {
                    EamEquipmentTree tree = new EamEquipmentTree().convert(mdcEquipment);
                    tree.setParentId(mdcEquipmentTree.getKey());
                    tree.setType(2);
                    mdcEquipmentTree.getChildren().add(tree);
                }
                mdcEquipmentTree.setLeaf(false);
            }
            if (CollectionUtil.isNotEmpty(mdcEquipmentTree.getChildren())) {
                fillEquipmentByBaseFactory(mdcEquipmentTree.getChildren());
            }
        }
    }

}