topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2025-12-14 22:25:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(improvement)(headless) opt queryTagMarketPage logic, support query without tagObjectId (#854)

Browse Source
This commit is contained in:
daikon
2024-03-25 10:48:11 +08:00
committed by GitHub
parent da3623c0fa
commit ac2b8cc049
2 changed files with 18 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/TagMetaServiceImpl.java
View File

@@ -144,6 +144,12 @@ public class TagMetaServiceImpl implements TagMetaService {
if (CollectionUtils.isEmpty(modelRespList)) {
return new PageInfo<>();
}
if (Objects.nonNull(tagMarketPageReq.getTagObjectId())) {
modelRespList = modelRespList.stream()
.filter(modelResp -> tagMarketPageReq.getTagObjectId().equals(modelResp.getTagObjectId()))
.collect(Collectors.toList());
}
List<Long> modelIds = modelRespList.stream().map(model -> model.getId()).collect(Collectors.toList());
TagFilter tagFilter = new TagFilter();
@@ -247,19 +253,18 @@ public class TagMetaServiceImpl implements TagMetaService {
if (Objects.isNull(modelResp)) {
continue;
}
if (tagMarketPageReq.getTagObjectId().equals(modelResp.getTagObjectId())) {
if (CollectionUtils.isNotEmpty(tagMarketPageReq.getDomainIds())) {
if (!tagMarketPageReq.getDomainIds().contains(modelResp.getDomainId())) {
continue;
}
if (CollectionUtils.isNotEmpty(tagMarketPageReq.getDomainIds())) {
if (!tagMarketPageReq.getDomainIds().contains(modelResp.getDomainId())) {
continue;
}
if (CollectionUtils.isNotEmpty(tagMarketPageReq.getModelIds())) {
if (!tagMarketPageReq.getModelIds().contains(modelResp.getId())) {
continue;
}
}
modelRespList.add(modelResp);
}
if (CollectionUtils.isNotEmpty(tagMarketPageReq.getModelIds())) {
if (!tagMarketPageReq.getModelIds().contains(modelResp.getId())) {
continue;
}
}
modelRespList.add(modelResp);
}
return modelRespList;
}
@@ -340,7 +345,7 @@ public class TagMetaServiceImpl implements TagMetaService {
ModelResp model = modelService.getModel(dimension.getModelId());
if (Objects.isNull(model.getTagObjectId())) {
throw new RuntimeException(String.format("this dimension:%s is not supported to create tag,"
+ " no related tag object", tagReq.getItemId()));
+ " no related tag object", tagReq.getItemId()));
}
}
if (TagDefineType.METRIC.equals(tagReq.getTagDefineType())) {
@@ -348,7 +353,7 @@ public class TagMetaServiceImpl implements TagMetaService {
ModelResp model = modelService.getModel(metric.getModelId());
if (Objects.isNull(model.getTagObjectId())) {
throw new RuntimeException(String.format("this metric:%s is not supported to create tag,"
+ " no related tag object", tagReq.getItemId()));
+ " no related tag object", tagReq.getItemId()));
}
}
}