wangli/orgmanax
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3282): 岗位接口移除查询角色信息，二期实现

Browse Source
This commit is contained in:
songyuanlun 2024-12-30 18:03:55 +08:00
parent 692035078f
commit c6352b38eb
5 changed files with 54 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
orgmanax-dto/src/main/java/cn/axzo/orgmanax/dto/job/dto/OrgJobDTO.java
View File

@ -135,8 +135,10 @@ public class OrgJobDTO implements Serializable {
/** /**
* 角色信息 * 角色信息
* todo 2024年12月30日 已和周敏确认，暂不用该字段
* 二期才会用到此字段
*/ */
private List<RoleDTO> saasRoles; //private List<RoleDTO> saasRoles;
public Set<Long> mergeAndDistinctRolesIds() { public Set<Long> mergeAndDistinctRolesIds() {
Set<Long> roleIds = Sets.newHashSet(); Set<Long> roleIds = Sets.newHashSet();

4
orgmanax-infra/pom.xml
View File

@ -115,10 +115,10 @@
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>
<dependency> <!--<dependency>
<groupId>cn.axzo.tyr</groupId> <groupId>cn.axzo.tyr</groupId>
<artifactId>tyr-client</artifactId> <artifactId>tyr-client</artifactId>
<version>${revision}</version> <version>${revision}</version>
</dependency> </dependency>-->
</dependencies> </dependencies>
</project> </project>

16
orgmanax-infra/src/main/java/cn/axzo/orgmanax/infra/client/tyr/RoleGateway.java
View File

@ -1,15 +1,11 @@
package cn.axzo.orgmanax.infra.client.tyr; package cn.axzo.orgmanax.infra.client.tyr;
import cn.axzo.foundation.page.PageResp;
import cn.axzo.orgmanax.infra.client.util.RpcWrapper;
import cn.axzo.tyr.feign.api.RoleApi;
import cn.axzo.tyr.feign.req.PageRoleReq;
import cn.axzo.tyr.feign.resp.RoleResp;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
* todo 暂时注释，tyr不上线
* @author syl * @author syl
* @date 2024/12/23 * @date 2024/12/23
*/ */
@ -18,9 +14,9 @@ import org.springframework.stereotype.Component;
@RequiredArgsConstructor @RequiredArgsConstructor
public class RoleGateway { public class RoleGateway {
private final RoleApi roleApi; // private final RoleApi roleApi;
//
public PageResp<RoleResp> page(PageRoleReq req) { // public PageResp<RoleResp> page(PageRoleReq req) {
return RpcWrapper.wrapApiResult(() -> roleApi.page(req)); // return RpcWrapper.wrapApiResult(() -> roleApi.page(req));
} // }
} }

1
orgmanax-server/src/main/java/cn/axzo/orgmanax/server/ExceptionControllerAdvice.java
View File

@ -3,7 +3,6 @@ package cn.axzo.orgmanax.server;
import cn.axzo.foundation.exception.BusinessException; import cn.axzo.foundation.exception.BusinessException;
import cn.axzo.foundation.result.ApiResult; import cn.axzo.foundation.result.ApiResult;
import cn.axzo.orgmanax.common.config.BizResultCode; import cn.axzo.orgmanax.common.config.BizResultCode;
import cn.azxo.framework.common.model.CommonResponse;
import cn.hutool.core.util.ReUtil; import cn.hutool.core.util.ReUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;

88
orgmanax-server/src/main/java/cn/axzo/orgmanax/server/orgjob/service/impl/OrgJobServiceImpl.java
View File

@ -11,7 +11,6 @@ import cn.axzo.orgmanax.dto.cooperateship.req.ListOrgCooperateShipReq;
import cn.axzo.orgmanax.dto.job.dto.OrgJobDTO; import cn.axzo.orgmanax.dto.job.dto.OrgJobDTO;
import cn.axzo.orgmanax.dto.job.dto.OrgJobGroupDTO; import cn.axzo.orgmanax.dto.job.dto.OrgJobGroupDTO;
import cn.axzo.orgmanax.dto.job.dto.OrgJobGroupRelationDTO; import cn.axzo.orgmanax.dto.job.dto.OrgJobGroupRelationDTO;
import cn.axzo.orgmanax.dto.job.dto.RoleDTO;
import cn.axzo.orgmanax.dto.job.enums.OrgJobGroupFlagEnum; import cn.axzo.orgmanax.dto.job.enums.OrgJobGroupFlagEnum;
import cn.axzo.orgmanax.dto.job.enums.OrgJobTypeEnum; import cn.axzo.orgmanax.dto.job.enums.OrgJobTypeEnum;
import cn.axzo.orgmanax.dto.job.req.CreateOrgJobReq; import cn.axzo.orgmanax.dto.job.req.CreateOrgJobReq;
@ -28,8 +27,6 @@ import cn.axzo.orgmanax.server.orgjob.service.OrgJobService;
import cn.axzo.orgmanax.server.orgjob.service.dto.OrgJobGroupPageParam; import cn.axzo.orgmanax.server.orgjob.service.dto.OrgJobGroupPageParam;
import cn.axzo.orgmanax.server.orgjob.service.dto.OrgJobGroupRelationPageParam; import cn.axzo.orgmanax.server.orgjob.service.dto.OrgJobGroupRelationPageParam;
import cn.axzo.orgmanax.server.orgjob.service.dto.OrgJobPageParam; import cn.axzo.orgmanax.server.orgjob.service.dto.OrgJobPageParam;
import cn.axzo.tyr.feign.req.PageRoleReq;
import cn.axzo.tyr.feign.resp.RoleResp;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
@ -108,8 +105,8 @@ public class OrgJobServiceImpl implements OrgJobService {
buildOrgGroup4OrgJob(orgJobs.getData()); buildOrgGroup4OrgJob(orgJobs.getData());
} }
if (BooleanUtils.isTrue(param.getNeedSaasRole())) { if (BooleanUtils.isTrue(param.getNeedSaasRole())) {
// 设置角色信息 // todo 设置角色信息
buildSaasRole4OrgJob(orgJobs.getData()); // buildSaasRole4OrgJob(orgJobs.getData());
} }
return orgJobs; return orgJobs;
} }
@ -180,47 +177,48 @@ public class OrgJobServiceImpl implements OrgJobService {
return flags; return flags;
} }
private void buildSaasRole4OrgJob(List<OrgJobDTO> orgJobs) { // todo 暂时注释，二期才使用
Set<Long> roleIds = orgJobs.stream() // private void buildSaasRole4OrgJob(List<OrgJobDTO> orgJobs) {
.flatMap(e -> e.mergeAndDistinctRolesIds().stream()) // Set<Long> roleIds = orgJobs.stream()
.collect(Collectors.toSet()); // .flatMap(e -> e.mergeAndDistinctRolesIds().stream())
Map<Long, RoleResp> saasRoleMap = listSaasRoles(roleIds); // .collect(Collectors.toSet());
if (CollUtil.isEmpty(saasRoleMap)) { // Map<Long, RoleResp> saasRoleMap = listSaasRoles(roleIds);
return; // if (CollUtil.isEmpty(saasRoleMap)) {
} // return;
orgJobs.forEach(e -> { // }
Set<Long> mergedRoleIds = e.mergeAndDistinctRolesIds(); // orgJobs.forEach(e -> {
if (CollUtil.isNotEmpty(mergedRoleIds)) { // Set<Long> mergedRoleIds = e.mergeAndDistinctRolesIds();
List<RoleResp> roles = mergedRoleIds.stream() // if (CollUtil.isNotEmpty(mergedRoleIds)) {
.map(saasRoleMap::get) // List<RoleResp> roles = mergedRoleIds.stream()
.filter(Objects::nonNull) // .map(saasRoleMap::get)
.collect(Collectors.toList()); // .filter(Objects::nonNull)
e.setSaasRoles(BeanUtil.copyToList(roles, RoleDTO.class)); // .collect(Collectors.toList());
} // e.setSaasRoles(BeanUtil.copyToList(roles, RoleDTO.class));
}); // }
} // });
// }
private Map<Long, RoleResp> listSaasRoles(Set<Long> roleIds) { // private Map<Long, RoleResp> listSaasRoles(Set<Long> roleIds) {
if (CollUtil.isEmpty(roleIds)) { // if (CollUtil.isEmpty(roleIds)) {
return Collections.emptyMap(); // return Collections.emptyMap();
} // }
List<RoleResp> roles = new ArrayList<>(); // List<RoleResp> roles = new ArrayList<>();
PageRoleReq param = PageRoleReq.builder().roleIds(roleIds).build(); // PageRoleReq param = PageRoleReq.builder().roleIds(roleIds).build();
//
PageResp<RoleResp> rolePage; // PageResp<RoleResp> rolePage;
int pageNumber = 0; // int pageNumber = 0;
param.setPageSize(JOB_PAGE_SIZE); // param.setPageSize(JOB_PAGE_SIZE);
do { // do {
param.setPage(++pageNumber); // param.setPage(++pageNumber);
rolePage = roleGateway.page(param); // rolePage = roleGateway.page(param);
if (CollUtil.isNotEmpty(rolePage.getData())) { // if (CollUtil.isNotEmpty(rolePage.getData())) {
roles.addAll(rolePage.getData()); // roles.addAll(rolePage.getData());
} // }
} while (rolePage.hasNext()); // } while (rolePage.hasNext());
//
return roles.stream() // return roles.stream()
.collect(Collectors.toMap(RoleResp::getRoleId, Function.identity(), (oldVal, newVal) -> oldVal)); // .collect(Collectors.toMap(RoleResp::getRoleId, Function.identity(), (oldVal, newVal) -> oldVal));
} // }
private void buildOrgGroup4OrgJob(List<OrgJobDTO> orgJobs) { private void buildOrgGroup4OrgJob(List<OrgJobDTO> orgJobs) {
// 查询岗位与分组的关联关系 // 查询岗位与分组的关联关系