diff --git a/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/plate/PlateServiceImpl.java b/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/plate/PlateServiceImpl.java index eb664cac4..82e04d930 100644 --- a/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/plate/PlateServiceImpl.java +++ b/cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/plate/PlateServiceImpl.java @@ -207,7 +207,7 @@ public class PlateServiceImpl implements PlateService { .in(OrderItemDO::getBodyId, bodyIds) .select(OrderItemDO::getBodyId) ); - Set plateIds = list.stream().map(BodyPlateIdDTO::getPlateId).collect(Collectors.toSet()); + List plateIds = list.stream().map(BodyPlateIdDTO::getPlateId).collect(Collectors.toList()); List orderModelDOS = buildRespByPlateIds(plateIds, ORDER_PLATE_MODEL); Map> map = orderModelDOS.stream().collect(Collectors.groupingBy(e -> { return list.stream().filter(f -> Objects.equals(f.getPlateId(), e.getPlateId())).map(BodyPlateIdDTO::getBodyId).findAny().orElse(null); @@ -241,6 +241,7 @@ public class PlateServiceImpl implements PlateService { SearchRequest.Builder builder = new SearchRequest.Builder(); builder.index(index); builder.query(q -> q.terms(b -> b.field("plateId").terms(e->e.value(fieldValues)))); + builder.size(plateIds.size()); try { SearchResponse search = elasticsearchClient.search(builder.build(), OrderModelDO.class); List> hits = search.hits().hits();