hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-08 18:36:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

ES针对于companyId的查询处理

Browse Source
This commit is contained in:
daihh
2022-10-22 19:50:59 +08:00
parent 300e77d19c
commit ac42a232f2
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
modules/boe-module-es/src/main/java/com/xboe/module/elasticsearc/CourseElasticsearchImpl.java
View File

@@ -282,11 +282,20 @@ public class CourseElasticsearchImpl implements ICourseFullTextSearch{
} }
//增加companyId过滤 //增加companyId过滤
if(StringUtils.isNotBlank(params.getCompanyId())) { if(StringUtils.isNotBlank(params.getCompanyId())) {
boolQuery.filter(QueryBuilders.termQuery("companyId", params.getCompanyId())); BoolQueryBuilder companyFilter= QueryBuilders.boolQuery();
companyFilter.should(QueryBuilders.termQuery("source",2));//新系统的数据
BoolQueryBuilder old= QueryBuilders.boolQuery();
old.must(QueryBuilders.termQuery("source",1));//必须是老系统的数据
old.must(QueryBuilders.termQuery("companyId",params.getCompanyId()));//必须是老系统的数据
companyFilter.should(old);
companyFilter.minimumShouldMatch(1);
boolQuery.filter(companyFilter);
} }
//加上Source判断，是为了应对后台查询，后台查询时，不需要权限，但是需要指定数据来源 //加上Source判断，是为了应对后台查询，后台查询时，不需要权限，但是需要指定数据来源
if(params.getSource()==null || params.getSource()==0 ) { if(params.getSource()==null || params.getSource()==0 ) {
//受众权限条件,必须是有受众的课程并且受众条件不为空 //受众权限条件,必须是有受众的课程并且受众条件不为空
if(params.getAudiences()!=null && params.getAudiences().length>0) { if(params.getAudiences()!=null && params.getAudiences().length>0) {