根据机场单位人员id批量获取对应amos平台账号id

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/IOrgUsrService.java

@@ -227,6 +227,15 @@ public interface IOrgUsrService {
     AgencyUserModel getAmosIdByOrgUserId(String orgUserId) throws Exception;
 
     /**
+     * 根据机场人员id(逗号分割)获取amos账号信息列表
+     *
+     * @param orgUserIds
+     * @return
+     * @exception
+     */
+    List<String> getAmosIdListByOrgUserId(String orgUserIds) throws Exception;
+
+    /**
      * 查询目标公司下所有人员的简要信息，数据包含：所在公司id和name ,人员id和name,岗位id和name
      * @param ids
      * @return

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/OrgUsrController.java

@@ -515,13 +515,26 @@ public class OrgUsrController extends BaseController {
      * @return
      */
     @TycloudOperation(ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/amos/{orgUserId}", method = RequestMethod.GET)
     @ApiOperation(httpMethod = "GET", value = "根据机场人员id获取amos平台人员信息", notes = "根据机场人员id获取amos平台人员信息")
+    @GetMapping(value = "/amos/{orgUserId}")
     public ResponseModel<AgencyUserModel> getAmosIdByOrgUserId(@PathVariable String orgUserId) throws Exception {
         return ResponseHelper.buildResponse(iOrgUsrService.getAmosIdByOrgUserId(orgUserId));
     }
 
     /**
+     * 根据机场人员id(逗号分割)获取amos平台人员id列表
+     *
+     * @param
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "根据机场人员id(逗号分割)获取amos平台人员id列表", notes = "根据机场人员id(逗号分割)获取amos平台人员id列表")
+    @GetMapping(value = "/amos/orgUserIds")
+    public ResponseModel<List<String>> getAmosIdListByOrgUserId(@RequestParam String orgUserIds) throws Exception {
+        return ResponseHelper.buildResponse(iOrgUsrService.getAmosIdListByOrgUserId(orgUserIds));
+    }
+
+    /**
      * 根据单位id列表或未同步的机场单位列表
      *
      * @return

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/OrgUsrServiceImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.google.common.base.Joiner;
 import com.google.common.collect.Lists;
 import com.yeejoin.amos.boot.biz.common.constants.CommonConstant;
 import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
@@ -1720,6 +1721,26 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
     }
 
 	@Override
+	public List<String> getAmosIdListByOrgUserId(String orgUserIds) throws Exception {
+		if (ValidationUtil.isEmpty(orgUserIds)) {
+			throw new Exception("账号不存在");
+		}
+		List<String> orgUserIdList = Lists.newArrayList(orgUserIds.split(","));
+		List<OrgUsr> orgUsrList = this.baseMapper.selectList(new LambdaQueryWrapper<OrgUsr>().in(OrgUsr::getSequenceNbr,
+				orgUserIdList));
+		if (ValidationUtil.isEmpty(orgUsrList)) {
+			throw new Exception("账号不存在");
+		}
+		List<AgencyUserModel> amosUserList =
+				Privilege.agencyUserClient.queryByIds(Joiner.on(",").join(orgUsrList.stream().map(OrgUsr::getAmosOrgId).collect(Collectors.toList())), false).getResult();
+		if (ValidationUtil.isEmpty(amosUserList)) {
+			throw new Exception("账号不存在");
+		}
+
+		return amosUserList.stream().map(AgencyUserModel::getUserId).collect(Collectors.toList());
+	}
+
+	@Override
 	public List<OrgUsrFormDto> getUnSyncOrgCompanyList(List<Long> companyIdList) {
 		LambdaQueryWrapper<OrgUsr> queryWrapper = new LambdaQueryWrapper<>();
 		queryWrapper.notIn(OrgUsr::getSequenceNbr, companyIdList).eq(OrgUsr::getIsDelete, false).eq(OrgUsr::getBizOrgType, "COMPANY");