wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3282): 修改引入的api名称

Browse Source
This commit is contained in:
zhanghonghao 2024-12-25 14:09:05 +08:00
parent 487fb861f6
commit c0db5f8b1e
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
im-center-server/src/main/java/cn/axzo/im/dependency/UnitGateway.java
View File

@ -2,7 +2,7 @@ package cn.axzo.im.dependency;
import cn.axzo.foundation.page.PageResp; import cn.axzo.foundation.page.PageResp;
import cn.axzo.im.utils.BizAssertions; import cn.axzo.im.utils.BizAssertions;
import cn.axzo.orggateway.api.unit.OrgGatewayUnitApi; import cn.axzo.orggateway.api.unit.OrgUnitApi;
import cn.axzo.orggateway.api.unit.req.OrgUnitPageQueryReq; import cn.axzo.orggateway.api.unit.req.OrgUnitPageQueryReq;
import cn.axzo.orggateway.api.unit.resp.OrgUnitResp; import cn.axzo.orggateway.api.unit.resp.OrgUnitResp;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
@ -25,7 +25,7 @@ import static java.util.stream.Collectors.toMap;
@RequiredArgsConstructor @RequiredArgsConstructor
public class UnitGateway { public class UnitGateway {
private final OrgGatewayUnitApi orgGatewayUnitApi; private final OrgUnitApi orgUnitApi;
public Map<Long, OrgUnitResp> getByOuIdsMapped(Collection<Long> ouIds) { public Map<Long, OrgUnitResp> getByOuIdsMapped(Collection<Long> ouIds) {
return getByOuIds(ouIds).stream().collect(toMap(OrgUnitResp::getId, identity(), (f, s) -> f)); return getByOuIds(ouIds).stream().collect(toMap(OrgUnitResp::getId, identity(), (f, s) -> f));
@ -34,7 +34,7 @@ public class UnitGateway {
public List<OrgUnitResp> getByOuIds(Collection<Long> ouIds) { public List<OrgUnitResp> getByOuIds(Collection<Long> ouIds) {
if (CollectionUtils.isEmpty(ouIds)) if (CollectionUtils.isEmpty(ouIds))
return Collections.emptyList(); return Collections.emptyList();
PageResp<OrgUnitResp> page = BizAssertions.assertResponse(orgGatewayUnitApi.page(OrgUnitPageQueryReq.builder() PageResp<OrgUnitResp> page = BizAssertions.assertResponse(orgUnitApi.page(OrgUnitPageQueryReq.builder()
.pageSize(Integer.MAX_VALUE) .pageSize(Integer.MAX_VALUE)
.unitIds(Sets.newHashSet(ouIds)) .unitIds(Sets.newHashSet(ouIds))
.build())); .build()));

6
im-center-server/src/main/java/cn/axzo/im/service/impl/MessageTaskServiceImpl.java
View File

@ -18,7 +18,7 @@ import cn.axzo.im.service.AccountService;
import cn.axzo.im.service.MessageHistoryService; import cn.axzo.im.service.MessageHistoryService;
import cn.axzo.im.service.MessageTaskService; import cn.axzo.im.service.MessageTaskService;
import cn.axzo.im.utils.UUIDUtil; import cn.axzo.im.utils.UUIDUtil;
import cn.axzo.orggateway.api.orgteamourelation.OrgTeamOuRelationFeignApi; import cn.axzo.orggateway.api.orgteamourelation.OrgTeamOuRelationApi;
import cn.axzo.orggateway.api.orgteamourelation.req.OrgTeamOuRelationReq; import cn.axzo.orggateway.api.orgteamourelation.req.OrgTeamOuRelationReq;
import cn.axzo.orggateway.api.orgteamourelation.resp.OrgTeamOuRelationResp; import cn.axzo.orggateway.api.orgteamourelation.resp.OrgTeamOuRelationResp;
import cn.axzo.pokonyan.dao.converter.PageConverter; import cn.axzo.pokonyan.dao.converter.PageConverter;
@ -63,7 +63,7 @@ public class MessageTaskServiceImpl extends ServiceImpl<MessageTaskMapper, Messa
@Autowired @Autowired
private MessageHistoryService messageHistoryService; private MessageHistoryService messageHistoryService;
@Autowired @Autowired
private OrgTeamOuRelationFeignApi orgTeamOuRelationFeignApi; private OrgTeamOuRelationApi orgTeamOuRelationApi;
private static final Integer DEFAULT_PAGE_SIZE = 500; private static final Integer DEFAULT_PAGE_SIZE = 500;
@ -411,7 +411,7 @@ public class MessageTaskServiceImpl extends ServiceImpl<MessageTaskMapper, Messa
OrgTeamOuRelationReq organizationalTeamOuRelationReq = new OrgTeamOuRelationReq(); OrgTeamOuRelationReq organizationalTeamOuRelationReq = new OrgTeamOuRelationReq();
organizationalTeamOuRelationReq.setTeamOuIds(ouIds); organizationalTeamOuRelationReq.setTeamOuIds(ouIds);
List<OrgTeamOuRelationResp> ouRelationResps = orgTeamOuRelationFeignApi.relationListByParam(organizationalTeamOuRelationReq).getData(); List<OrgTeamOuRelationResp> ouRelationResps = orgTeamOuRelationApi.relationListByParam(organizationalTeamOuRelationReq).getData();
return ouRelationResps.stream() return ouRelationResps.stream()
.collect(Collectors.toMap(OrgTeamOuRelationResp::getTeamOuId, OrgTeamOuRelationResp::getOuId, (f, s) -> f)); .collect(Collectors.toMap(OrgTeamOuRelationResp::getTeamOuId, OrgTeamOuRelationResp::getOuId, (f, s) -> f));