|
@ -39,6 +39,8 @@ public class SalesOrderDetailGetEAIService extends AbsEAIService { |
|
|
@Override |
|
|
@Override |
|
|
public DWEAIResult execute(Map<String, String> headers, String messageBody) throws Exception { |
|
|
public DWEAIResult execute(Map<String, String> headers, String messageBody) throws Exception { |
|
|
EAIRequest request = EAIRequest.build(messageBody); |
|
|
EAIRequest request = EAIRequest.build(messageBody); |
|
|
|
|
|
List<SalesOrderDetailEntity> salesOrderDetailDTOList = request.getObject("sales_order_detail", new TypeReference<List<SalesOrderDetailEntity>>(){}); |
|
|
|
|
|
List<Long> idList = salesOrderDetailDTOList.stream().map(SalesOrderDetailEntity::getId).collect(Collectors.toList()); |
|
|
|
|
|
|
|
|
// 两次开窗查询 |
|
|
// 两次开窗查询 |
|
|
LambdaQueryWrapper queryWrapper; |
|
|
LambdaQueryWrapper queryWrapper; |
|
@ -48,6 +50,7 @@ public class SalesOrderDetailGetEAIService extends AbsEAIService { |
|
|
}else{ |
|
|
}else{ |
|
|
queryWrapper = Wrappers.<SalesOrderDetailEntity>lambdaQuery() |
|
|
queryWrapper = Wrappers.<SalesOrderDetailEntity>lambdaQuery() |
|
|
.eq(SalesOrderDetailEntity::getTenantSid,1L) |
|
|
.eq(SalesOrderDetailEntity::getTenantSid,1L) |
|
|
|
|
|
.in(SalesOrderDetailEntity::getId,idList) |
|
|
.eq(SalesOrderDetailEntity::getStatus,request.getParameter().get(ParameterConstant.STATUS)); |
|
|
.eq(SalesOrderDetailEntity::getStatus,request.getParameter().get(ParameterConstant.STATUS)); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|