cq_anquan
/
safety-eval-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: 新增班级参训单位查询调整

dev-tmp1
zhanglei 2026-08-27 09:44:51 +08:00
parent 683a6ec9a8
commit affb0bbedd
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
safety-eval-infrastructure/src/main/java/org/qinan/safetyeval/infrastructure/gatewayimpl/OrgInfoGatewayImpl.java
View File

@ -17,6 +17,7 @@ import org.qinan.safetyeval.domain.exception.ErrorCode;
import org.qinan.safetyeval.domain.gateway.OrgInfoGateway; import org.qinan.safetyeval.domain.gateway.OrgInfoGateway;
import org.qinan.safetyeval.domain.query.OrgInfoQuery; import org.qinan.safetyeval.domain.query.OrgInfoQuery;
import org.qinan.safetyeval.domain.query.PageResult; 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.auth.AuthUserContextAdapter;
import org.qinan.safetyeval.infrastructure.adapter.gbs.GbsUserFacadeClient; import org.qinan.safetyeval.infrastructure.adapter.gbs.GbsUserFacadeClient;
import org.qinan.safetyeval.infrastructure.dataobject.AccountDO; import org.qinan.safetyeval.infrastructure.dataobject.AccountDO;
@ -250,6 +251,10 @@ public class OrgInfoGatewayImpl implements OrgInfoGateway {
if (query.getFilingRecordStatusCode() != null) { if (query.getFilingRecordStatusCode() != null) {
wrapper.eq(OrgInfoDO::getFilingRecordStatusCode, query.getFilingRecordStatusCode()); wrapper.eq(OrgInfoDO::getFilingRecordStatusCode, query.getFilingRecordStatusCode());
} }
Long orgId = ThreadLocalUserInfoAdapter.getOrgId();
if (orgId != null) {
wrapper.eq(OrgInfoDO::getId, orgId);
}
wrapper.orderByDesc(OrgInfoDO::getId); wrapper.orderByDesc(OrgInfoDO::getId);
Page<OrgInfoDO> page = new Page<>(query.getPageNum(), query.getPageSize()); Page<OrgInfoDO> page = new Page<>(query.getPageNum(), query.getPageSize());