From 7e8d0345fa4afce3a0c25f0445c43a80657fd04e Mon Sep 17 00:00:00 2001 From: lyh <925863403@qq.com> Date: 星期一, 25 八月 2025 11:02:12 +0800 Subject: [PATCH] 设备管理首页列表接口 --- lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamReportRepairServiceImpl.java | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 53 insertions(+), 0 deletions(-) diff --git a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamReportRepairServiceImpl.java b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamReportRepairServiceImpl.java index a3e0161..c4cb2a2 100644 --- a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamReportRepairServiceImpl.java +++ b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamReportRepairServiceImpl.java @@ -359,6 +359,7 @@ return entity; } + @Override public List<EchartsDto> reportRepairList() { List<EchartsDto> echartsDtoList = new ArrayList<>(); @@ -457,4 +458,56 @@ dto.setPercentage(percentage); return dto; } + + /** + * 璁惧绠$悊棣栭〉-璁惧鎶ヤ慨鏁呴殰鎯呭喌鍒楄〃 + * @param code + * @param page + * @return + */ + @Override + public IPage<EamReportRepairDto> reportRepairList(String code, Page<EamReportRepairDto> page){ + // 鐢ㄦ埛鏁版嵁鏉冮檺妫�鏌� + LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); + if (sysUser == null) { + return null; + } + + QueryWrapper<EamReportRepairDto> queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("wmo.del_flag", CommonConstant.DEL_FLAG_0); + + // 璁惧杩囨护閫昏緫 + if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) { + List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(",")); + queryWrapper.in("e.equipment_code", equipArr); + } else { + List<BaseFactoryUser> baseFactoryUserList = baseFactoryUserService + .list(new LambdaQueryWrapper<BaseFactoryUser>() + .eq(BaseFactoryUser::getUserId, sysUser.getId())); + + if (CollectionUtils.isEmpty(baseFactoryUserList)) { + return null; + } + + Set<String> factoryIds = baseFactoryUserList.stream() + .map(BaseFactoryUser::getFactoryId) + .collect(Collectors.toSet()); + + Set<String> factoryCodes = baseFactoryService.listByIds(factoryIds) + .stream() + .map(BaseFactory::getOrgCode) + .collect(Collectors.toSet()); + + queryWrapper.in("e.factory_org_code", factoryCodes); + } + queryWrapper.orderByDesc("wmo.create_time"); + switch (code){ + case "bx": + return baseMapper.queryPageList(page,queryWrapper); + case "stop": + return baseMapper.queryPageList(page,queryWrapper.eq("breakdown_flag", "1")); + default: + return baseMapper.queryPageList(page,queryWrapper.eq("breakdown_flag", "0")); + } + } } -- Gitblit v1.9.3