diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesServiceImpl.java index 26c1ff52..4386b2c6 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesServiceImpl.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesServiceImpl.java @@ -298,10 +298,10 @@ public class CasesServiceImpl implements ICasesService { QueryBuilder queryBuilder = recommendCasesQuery.addFilters(subFilters) .addOrder("sysCreateTime", OrderDirection.DESC) - .addGroupBy("recommendId"); + .addGroupBy("caseId"); List pushRecords = casesRecommendPushRecordDao.findList(queryBuilder.builder()); if (CollUtil.isNotEmpty(pushRecords)) { - List rIds = pushRecords.stream().map(CasesRecommendPushRecord::getRecommendId).collect(Collectors.toList()); + List rIds = pushRecords.stream().map(CasesRecommendPushRecord::getRecommendId).distinct().collect(Collectors.toList()); QueryBuilder builder = QueryBuilder.from(CasesRecommend.class); builder.addField("new CasesRecommend(id,recommendOrgName)"); List recommendFilters = new ArrayList<>();