Commit 82c2862b98a4c174a593f63c4dcd53d0677ce2f5

Authored by chenjunyu_1481036421
1 parent 4338eca0

feat:组织递归查询增加向上向下参数并更改以前的所有向下

... ... @@ -99,7 +99,7 @@ public class SysNoticeServiceImpl extends AbstractBaseService<SysNoticeMapper, S
99 99 //把拿到的数据用,分割成数组
100 100 userList =
101 101 userOrganizationMappingService.getUserIdByOrganizationIds(
102   - tenantId, sysNoticeDTO.getPointId().split(","));
  102 + tenantId,null, sysNoticeDTO.getPointId().split(","));
103 103 break;
104 104 default:
105 105 throw new EntityCreationException(ErrorMessage.SEND_DESTINATION_NOT_FOUND.getMessage());
... ...
... ... @@ -38,9 +38,9 @@ public class SysUserOrganizationMappingServiceImpl implements UserOrganizationMa
38 38 private final TkOrganizationService organizationService;
39 39
40 40 @Override
41   - public List<String> getUserIdByOrganizationIds(String tenantId, String... ids) {
  41 + public List<String> getUserIdByOrganizationIds(String tenantId,OrganizationEnum sort , String... ids) {
42 42 List<String> collect =
43   - organizationService.findOrganizationTreeList(tenantId, OrganizationEnum.UP, List.of(ids)).stream()
  43 + organizationService.findOrganizationTreeList(tenantId, sort, List.of(ids)).stream()
44 44 .map(OrganizationDTO::getId)
45 45 .collect(Collectors.toList());
46 46 if (null == collect || collect.size() == 0) {
... ...
... ... @@ -34,6 +34,7 @@ import org.thingsboard.server.common.data.yunteng.dto.*;
34 34 import org.thingsboard.server.common.data.yunteng.dto.request.*;
35 35 import org.thingsboard.server.common.data.yunteng.enums.MessageTypeEnum;
36 36 import org.thingsboard.server.common.data.yunteng.enums.MsgTemplatePurposeEnum;
  37 +import org.thingsboard.server.common.data.yunteng.enums.OrganizationEnum;
37 38 import org.thingsboard.server.common.data.yunteng.enums.UserStatusEnum;
38 39 import org.thingsboard.server.common.data.yunteng.utils.ReflectUtils;
39 40 import org.thingsboard.server.common.data.yunteng.utils.tools.TkPageData;
... ... @@ -329,7 +330,7 @@ public class SysUserServiceImpl extends AbstractBaseService<UserMapper, SysUserE
329 330 queryMap.get("organizationId") != null ? (String) queryMap.get("organizationId") : null;
330 331 List<String> userIds = null;
331 332 if (null != organizationId) {
332   - userIds = userOrganizationMappingService.getUserIdByOrganizationIds(tenantId, organizationId);
  333 + userIds = userOrganizationMappingService.getUserIdByOrganizationIds(tenantId,null, organizationId);
333 334 queryMap.put("userIds", userIds);
334 335 }
335 336 if (isPtSysadmin) {
... ... @@ -577,7 +578,7 @@ public class SysUserServiceImpl extends AbstractBaseService<UserMapper, SysUserE
577 578 if (group == null || !group.getTenantId().equals(tenantId)) {
578 579 return Optional.empty();
579 580 }
580   - List<String> userIds = userOrganizationMappingService.getUserIdByOrganizationIds(group.getId());
  581 + List<String> userIds = userOrganizationMappingService.getUserIdByOrganizationIds(group.getId(),null);
581 582 List<SysUserEntity> users = baseMapper.selectBatchIds(userIds);
582 583 return Optional.ofNullable(ReflectUtils.sourceToTarget(users, UserDTO.class));
583 584 }
... ... @@ -662,7 +663,7 @@ public class SysUserServiceImpl extends AbstractBaseService<UserMapper, SysUserE
662 663 }
663 664 if (isTenantAdmin) {
664 665 List<String> userList =
665   - userOrganizationMappingService.getUserIdByOrganizationIds(tenantId, organizationId);
  666 + userOrganizationMappingService.getUserIdByOrganizationIds(tenantId, OrganizationEnum.UP, organizationId);
666 667 if (null != userList && userList.size() > FastIotConstants.MagicNumber.ZERO) {
667 668 return baseMapper.getMyCustomers(tenantId, EntityId.NULL_UUID.toString(), userList);
668 669 }
... ...
1 1 package org.thingsboard.server.dao.yunteng.service;
2 2
  3 +import org.thingsboard.server.common.data.yunteng.enums.OrganizationEnum;
  4 +
3 5 import java.util.List;
4 6 import java.util.Set;
5 7
... ... @@ -10,7 +12,7 @@ import java.util.Set;
10 12 */
11 13 public interface UserOrganizationMappingService {
12 14
13   - List<String> getUserIdByOrganizationIds(String tenantId, String... ids);
  15 + List<String> getUserIdByOrganizationIds(String tenantId, OrganizationEnum sort , String... ids);
14 16
15 17 /**
16 18 * 添加或更新用户组织关系
... ...