Commit 61f86b7124a4ebd5b70e30c44533da3702f49d77

Authored by chenjunyu_1481036421
1 parent ed23e24e

feat:分配客户时 如果是普通租户 则根据设备向上当前用户向下组织查询客户

@@ -348,12 +348,17 @@ public class TkUserController extends AbstractUserAccount { @@ -348,12 +348,17 @@ public class TkUserController extends AbstractUserAccount {
348 @GetMapping("/customers/{organizationId}") 348 @GetMapping("/customers/{organizationId}")
349 public ResponseEntity<List<UserDTO>> getMyCustomers(@PathVariable String organizationId) 349 public ResponseEntity<List<UserDTO>> getMyCustomers(@PathVariable String organizationId)
350 throws ThingsboardException { 350 throws ThingsboardException {
  351 + List<String> orgIds= null;
  352 + if(getCurrentUser().isPtCommonTenant()) {
  353 + orgIds = commonTenantOrganizationAllIds();
  354 + }
351 return ResponseEntity.ok( 355 return ResponseEntity.ok(
352 userService.getMyCustomers( 356 userService.getMyCustomers(
353 organizationId, 357 organizationId,
354 getCurrentUser().getCurrentTenantId(), 358 getCurrentUser().getCurrentTenantId(),
355 getCurrentUser().isPtTenantAdmin(), 359 getCurrentUser().isPtTenantAdmin(),
356 - getCurrentUser().isPtCommonTenant())); 360 + getCurrentUser().isPtCommonTenant(),
  361 + orgIds));
357 } 362 }
358 363
359 @PostMapping("/reset_password/{userId}") 364 @PostMapping("/reset_password/{userId}")
@@ -681,13 +681,18 @@ public class SysUserServiceImpl extends AbstractBaseService<UserMapper, SysUserE @@ -681,13 +681,18 @@ public class SysUserServiceImpl extends AbstractBaseService<UserMapper, SysUserE
681 681
682 @Override 682 @Override
683 public List<UserDTO> getMyCustomers( 683 public List<UserDTO> getMyCustomers(
684 - String organizationId, String tenantId, boolean isTenantAdmin,boolean isPtCommonTenant) { 684 + String organizationId, String tenantId, boolean isTenantAdmin,boolean isPtCommonTenant,List<String>orgIds) {
685 if (StringUtils.isEmpty(organizationId)) { 685 if (StringUtils.isEmpty(organizationId)) {
686 throw new TkDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage()); 686 throw new TkDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
687 } 687 }
  688 + List<String> userList =
  689 + userOrganizationMappingService.getUserIdByOrganizationIds(tenantId, OrganizationEnum.UP, organizationId);
  690 + if(isPtCommonTenant){
  691 + List<String> DownUserList =
  692 + userOrganizationMappingService.getUserIdByOrganizationIds(tenantId, null, orgIds.toArray(new String[orgIds.size()]));
  693 + userList = userList.stream().filter(DownUserList::contains).collect(Collectors.toList());
  694 + }
688 if (isTenantAdmin||isPtCommonTenant) { 695 if (isTenantAdmin||isPtCommonTenant) {
689 - List<String> userList =  
690 - userOrganizationMappingService.getUserIdByOrganizationIds(tenantId, OrganizationEnum.UP, organizationId);  
691 if (null != userList && userList.size() > FastIotConstants.MagicNumber.ZERO) { 696 if (null != userList && userList.size() > FastIotConstants.MagicNumber.ZERO) {
692 return baseMapper.getMyCustomers(tenantId, EntityId.NULL_UUID.toString(), userList); 697 return baseMapper.getMyCustomers(tenantId, EntityId.NULL_UUID.toString(), userList);
693 } 698 }
@@ -126,7 +126,7 @@ public interface TkUserService { @@ -126,7 +126,7 @@ public interface TkUserService {
126 * @param isTenantAdmin 是否是租户管理员 126 * @param isTenantAdmin 是否是租户管理员
127 * @return 租户创建的所有用户 127 * @return 租户创建的所有用户
128 */ 128 */
129 - List<UserDTO> getMyCustomers(String organizationId, String tenantId, boolean isTenantAdmin,boolean isPtCommonTenant); 129 + List<UserDTO> getMyCustomers(String organizationId, String tenantId, boolean isTenantAdmin,boolean isPtCommonTenant,List<String> orgIds);
130 130
131 /** 131 /**
132 * 异步获取用户列表 132 * 异步获取用户列表