Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

/api/record/data/uriList录制信息模糊查询接口存在问题,只需要修改下面的类 #77

Open
zhouliangiseeyou opened this issue May 17, 2024 · 0 comments

Comments

@zhouliangiseeyou
Copy link

image
moonbox-server/moonbox-service-data-es/src/main/java/com/vivo/internet/moonbox/service/data/es/record/service/RecordDataServiceImpl.java

` @OverRide
public List getRecordUriCountList(RecordUriCountQuery query) {
SearchRequest searchRequest = new SearchRequest(INDEX_NAME).indicesOptions(IndicesOptions.lenientExpandOpen())
.preference("_local");

    List<CompositeValuesSourceBuilder<?>> aggBuilder = Lists.newArrayList();
    aggBuilder.add(new TermsValuesSourceBuilder("uri").field(EsRecordEntity.Fields.entranceDesc));
    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder().size(0)
            .query(QueryBuilders.boolQuery().filter(
                    QueryBuilders.termQuery(EsRecordEntity.Fields.recordTaskRunId, query.getRecordTaskRunId())));
    if (StringUtils.isNotBlank(query.getUriMatchCondition())) {
        sourceBuilder.query(QueryBuilders.boolQuery().filter(
                QueryBuilders.termQuery(EsReplayEntity.Fields.entranceDesc, query.getUriMatchCondition())));
    }
    sourceBuilder.aggregation(new CompositeAggregationBuilder("myBuckets", aggBuilder).size(1000));
    searchRequest.source(sourceBuilder);

    // 获取聚合查询结果
    SearchResponse r = search(searchRequest);
    ParsedComposite parsedComposite = r.getAggregations().get("myBuckets");
    if (CollectionUtils.isEmpty(parsedComposite.getBuckets())) {
        return Lists.newArrayList();
    }
    return parsedComposite.getBuckets().stream().map(item -> {
        Map<String, Object> keys = item.getKey();
        return RecordUriCountResult.builder().recordUri(keys.get("uri").toString())
                .recordTaskRunId(query.getRecordTaskRunId()).recordCount(item.getDocCount())
                .invokeType(InvokeType.getInvokeTypeByUri(keys.get("uri").toString()).getInvokeName()).build();
    }).collect(Collectors.toList());
}`
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant