diff --git a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/OrgInfoGatewayImpl.java b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/OrgInfoGatewayImpl.java index 0388c507..bfccb5d3 100644 --- a/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/OrgInfoGatewayImpl.java +++ b/safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/OrgInfoGatewayImpl.java @@ -17,6 +17,7 @@ import org.qinan.safetyeval.domain.exception.ErrorCode; import org.qinan.safetyeval.domain.gateway.OrgInfoGateway; import org.qinan.safetyeval.domain.query.OrgInfoQuery; import org.qinan.safetyeval.domain.query.PageResult; +import org.qinan.safetyeval.infrastructure.adapter.ThreadLocalUserInfoAdapter; import org.qinan.safetyeval.infrastructure.adapter.auth.AuthUserContextAdapter; import org.qinan.safetyeval.infrastructure.adapter.gbs.GbsUserFacadeClient; import org.qinan.safetyeval.infrastructure.dataobject.AccountDO; @@ -250,6 +251,10 @@ public class OrgInfoGatewayImpl implements OrgInfoGateway { if (query.getFilingRecordStatusCode() != null) { wrapper.eq(OrgInfoDO::getFilingRecordStatusCode, query.getFilingRecordStatusCode()); } + Long orgId = ThreadLocalUserInfoAdapter.getOrgId(); + if (orgId != null) { + wrapper.eq(OrgInfoDO::getId, orgId); + } wrapper.orderByDesc(OrgInfoDO::getId); Page page = new Page<>(query.getPageNum(), query.getPageSize());