diff --git a/web-adapter/src/main/java/com/zcloud/certificate/web/UserCertificateController.java b/web-adapter/src/main/java/com/zcloud/certificate/web/UserCertificateController.java index 02f3533..9fbdbdf 100644 --- a/web-adapter/src/main/java/com/zcloud/certificate/web/UserCertificateController.java +++ b/web-adapter/src/main/java/com/zcloud/certificate/web/UserCertificateController.java @@ -46,9 +46,9 @@ public class UserCertificateController { } @ApiOperation("所有数据") - @GetMapping("/listAll") - public MultiResponse listAll() { - return MultiResponse.of(new ArrayList()); + @PostMapping("/listAll") + public MultiResponse listAll(@RequestBody UserCertificatePageQry qry) { + return MultiResponse.of(userCertificateService.listAll(qry)); } @ApiOperation("详情") diff --git a/web-app/src/main/java/com/zcloud/certificate/command/query/CorpCertificateQueryExe.java b/web-app/src/main/java/com/zcloud/certificate/command/query/CorpCertificateQueryExe.java index e43afa1..9796548 100644 --- a/web-app/src/main/java/com/zcloud/certificate/command/query/CorpCertificateQueryExe.java +++ b/web-app/src/main/java/com/zcloud/certificate/command/query/CorpCertificateQueryExe.java @@ -1,6 +1,8 @@ package com.zcloud.certificate.command.query; import com.alibaba.cola.dto.MultiResponse; +import com.jjb.saas.framework.auth.model.SSOUser; +import com.jjb.saas.framework.auth.utils.AuthContext; import com.zcloud.certificate.command.convertor.CorpCertificateCoConvertor; import com.zcloud.certificate.command.convertor.CorpCertificateStatCoConvertor; import com.zcloud.certificate.dto.CorpCertificatePageQry; @@ -41,8 +43,11 @@ public class CorpCertificateQueryExe { * @return */ public PageResponse execute(CorpCertificatePageQry qry) { + if (qry.getEqCorpinfoId() == null) { + SSOUser ssoUser = AuthContext.getCurrentUser(); + qry.setEqCorpinfoId(ssoUser != null ? ssoUser.getTenantId(): null); + } Map params = PageQueryHelper.toHashMap(qry); - PageResponse pageResponse = corpCertificateRepository.listPage(params); List examCenterCOS = corpCertificateCoConvertor.converDOsToCOs(pageResponse.getData()); return PageResponse.of(examCenterCOS, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex()); diff --git a/web-app/src/main/java/com/zcloud/certificate/command/query/UserCertificateQueryExe.java b/web-app/src/main/java/com/zcloud/certificate/command/query/UserCertificateQueryExe.java index 1de03c3..3bb0be4 100644 --- a/web-app/src/main/java/com/zcloud/certificate/command/query/UserCertificateQueryExe.java +++ b/web-app/src/main/java/com/zcloud/certificate/command/query/UserCertificateQueryExe.java @@ -3,6 +3,7 @@ package com.zcloud.certificate.command.query; import com.jjb.saas.framework.auth.model.SSOUser; import com.jjb.saas.framework.auth.utils.AuthContext; import com.zcloud.certificate.command.convertor.UserCertificateCoConvertor; +import com.zcloud.certificate.domain.model.UserBasicInfo; import com.zcloud.certificate.domain.model.UserCertificateE; import com.zcloud.certificate.dto.CorpCertificateStatPageQry; import com.zcloud.certificate.dto.UserCertificatePageQry; @@ -57,10 +58,13 @@ public class UserCertificateQueryExe { * @return */ public PageResponse execute(UserCertificatePageQry qry) { + SSOUser ssoUser = AuthContext.getCurrentUser(); if (qry.getIsAppQuery() != null) { - SSOUser ssoUser = AuthContext.getCurrentUser(); - qry.setEqUserId(ssoUser.getUserId()); + qry.setEqUserId(ssoUser != null ? ssoUser.getUserId() : null); + }else if (qry.getEqCorpinfoId() == null) { + qry.setEqCorpinfoId(ssoUser != null ? ssoUser.getTenantId(): null); } + Map params = PageQueryHelper.toHashMap(qry); PageResponse iPage = userCertificateRepository.listPageWithUser(params); @@ -70,15 +74,7 @@ public class UserCertificateQueryExe { if (CollectionUtils.isEmpty(userIds)) { return PageResponse.of(Collections.emptyList(), iPage.getTotalCount(), iPage.getPageSize(), iPage.getPageIndex()); } - List userBasicInfos = userCertificateRepository.getUserNamesByUserIds(userIds); - - Map userInfoMap = userBasicInfos.stream() - .collect(Collectors.toMap(com.zcloud.certificate.domain.model.UserBasicInfo::getUserId, info -> info, (k1, k2) -> k1)); - - userCertificateES.forEach(e -> { - com.zcloud.certificate.domain.model.UserBasicInfo userBasicInfo = userInfoMap.get(e.getUserId()); - e.attach(userBasicInfo); - }); + getUserInfo(userCertificateES, userIds); List cos = userCertificateCoConvertor.converEsToCOs(userCertificateES); @@ -95,6 +91,36 @@ public class UserCertificateQueryExe { return PageResponse.of(cos, result.getTotalCount(), result.getPageSize(), result.getPageIndex()); } + /** + * 查询所有人员证照 + */ + public List listAll(UserCertificatePageQry qry) { + Map params = PageQueryHelper.toHashMap(qry); + List list = userCertificateRepository.listAll(params); + if (CollectionUtils.isEmpty(list)) { + return Collections.emptyList(); + } + List userCertificateES = userCertificateCoConvertor.converDOsToEs(list); + List userIds = userCertificateES.stream().map(UserCertificateE::getUserId).distinct().collect(Collectors.toList()); + if (CollectionUtils.isEmpty(userIds)) { + return Collections.emptyList(); + } + getUserInfo(userCertificateES, userIds); + + return userCertificateCoConvertor.converEsToCOs(userCertificateES); + } + + private void getUserInfo(List userCertificateES, List userIds) { + List userBasicInfos = userCertificateRepository.getUserNamesByUserIds(userIds); + + Map userInfoMap = userBasicInfos.stream() + .collect(Collectors.toMap(UserBasicInfo::getUserId, info -> info, (k1, k2) -> k1)); + + userCertificateES.forEach(e -> { + UserBasicInfo userBasicInfo = userInfoMap.get(e.getUserId()); + e.attach(userBasicInfo); + }); + } } diff --git a/web-app/src/main/java/com/zcloud/certificate/service/UserCertificateServiceImpl.java b/web-app/src/main/java/com/zcloud/certificate/service/UserCertificateServiceImpl.java index f470628..ef6ded7 100644 --- a/web-app/src/main/java/com/zcloud/certificate/service/UserCertificateServiceImpl.java +++ b/web-app/src/main/java/com/zcloud/certificate/service/UserCertificateServiceImpl.java @@ -17,6 +17,9 @@ import com.zcloud.certificate.dto.clientobject.UserCertificateStatCO; import lombok.AllArgsConstructor; import org.springframework.stereotype.Service; +import java.util.Collections; +import java.util.List; + /** * web-app * @Author makejava @@ -67,5 +70,10 @@ public class UserCertificateServiceImpl implements UserCertificateServiceI { public PageResponse corpCertificateStatPage(CorpCertificateStatPageQry qry) { return userCertificateQueryExe.execute(qry); } + + @Override + public List listAll(UserCertificatePageQry qry) { + return userCertificateQueryExe.listAll(qry); + } } diff --git a/web-client/src/main/java/com/zcloud/certificate/api/UserCertificateServiceI.java b/web-client/src/main/java/com/zcloud/certificate/api/UserCertificateServiceI.java index 1622fe8..e065faa 100644 --- a/web-client/src/main/java/com/zcloud/certificate/api/UserCertificateServiceI.java +++ b/web-client/src/main/java/com/zcloud/certificate/api/UserCertificateServiceI.java @@ -10,6 +10,8 @@ import com.alibaba.cola.dto.PageResponse; import com.alibaba.cola.dto.SingleResponse; import com.zcloud.certificate.dto.clientobject.UserCertificateStatCO; +import java.util.List; + /** * web-client * @Author makejava @@ -32,5 +34,10 @@ public interface UserCertificateServiceI { * 根据企业/相关方类型查询各企业/相关方各类人员证书数量 */ PageResponse corpCertificateStatPage(CorpCertificateStatPageQry qry); + + /** + * 查询所有人员证照 + */ + List listAll(UserCertificatePageQry qry); } diff --git a/web-client/src/main/java/com/zcloud/certificate/dto/UserCertificatePageQry.java b/web-client/src/main/java/com/zcloud/certificate/dto/UserCertificatePageQry.java index 15a444c..5d5c9d5 100644 --- a/web-client/src/main/java/com/zcloud/certificate/dto/UserCertificatePageQry.java +++ b/web-client/src/main/java/com/zcloud/certificate/dto/UserCertificatePageQry.java @@ -4,6 +4,7 @@ import com.alibaba.cola.dto.PageQuery; import io.swagger.annotations.ApiModelProperty; import lombok.Data; +import java.util.List; /** @@ -68,5 +69,11 @@ public class UserCertificatePageQry extends PageQuery { */ @ApiModelProperty(value = "app 端查询表示", name = "isAppQuery") private Integer isAppQuery; + + /** + * 用户ids + */ + @ApiModelProperty(value = "用户ids", name = "inUserIds") + private List inUserId;; } diff --git a/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/UserCertificateRepository.java b/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/UserCertificateRepository.java index 298f819..86173d3 100644 --- a/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/UserCertificateRepository.java +++ b/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/UserCertificateRepository.java @@ -31,5 +31,10 @@ public interface UserCertificateRepository extends BaseRepository selectCorpCertificateStatPage(@Param("params") Map params); + + /** + * 查询所有人员证照 + */ + List listAll(Map params); } diff --git a/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/impl/UserCertificateRepositoryImpl.java b/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/impl/UserCertificateRepositoryImpl.java index e0ac4b1..b19aae9 100644 --- a/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/impl/UserCertificateRepositoryImpl.java +++ b/web-infrastructure/src/main/java/com/zcloud/certificate/persistence/repository/impl/UserCertificateRepositoryImpl.java @@ -14,6 +14,7 @@ import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; +import java.util.Collections; import java.util.List; import java.util.Map; @@ -55,5 +56,14 @@ public class UserCertificateRepositoryImpl extends BaseRepositoryImpl iPage = userCertificateMapper.selectCorpCertificateStatPage(page, params); return PageHelper.pageToResponse(iPage, iPage.getRecords()); } + + @Override + public List listAll(Map params) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper = PageQueryHelper.createPageQueryWrapper(queryWrapper, params); + queryWrapper.orderByDesc("create_time"); + List result = userCertificateMapper.selectList(queryWrapper); + return result; + } }