diff --git a/demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/service/order/SalesOrderDetailGetEAIService.java b/demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/service/order/SalesOrderDetailGetEAIService.java index 14aaaad..442bfdb 100644 --- a/demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/service/order/SalesOrderDetailGetEAIService.java +++ b/demo-athenaopt_backend/develop/src/main/java/com/digiwin/athena/app/service/order/SalesOrderDetailGetEAIService.java @@ -39,6 +39,8 @@ public class SalesOrderDetailGetEAIService extends AbsEAIService { @Override public DWEAIResult execute(Map headers, String messageBody) throws Exception { EAIRequest request = EAIRequest.build(messageBody); + List salesOrderDetailDTOList = request.getObject("sales_order_detail", new TypeReference>(){}); + List idList = salesOrderDetailDTOList.stream().map(SalesOrderDetailEntity::getId).collect(Collectors.toList()); // 两次开窗查询 LambdaQueryWrapper queryWrapper; @@ -48,6 +50,7 @@ public class SalesOrderDetailGetEAIService extends AbsEAIService { }else{ queryWrapper = Wrappers.lambdaQuery() .eq(SalesOrderDetailEntity::getTenantSid,1L) + .in(SalesOrderDetailEntity::getId,idList) .eq(SalesOrderDetailEntity::getStatus,request.getParameter().get(ParameterConstant.STATUS)); }