|
|
@ -39,8 +39,7 @@ public class SalesOrderDetailGetEAIService extends AbsEAIService { |
|
|
|
@Override |
|
|
|
public DWEAIResult execute(Map<String, String> headers, String messageBody) throws Exception { |
|
|
|
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; |
|
|
|
if(request.getParameter().get(ParameterConstant.OPTION).equals(ParameterConstant.SET_NUMBER)){ |
|
|
@ -49,7 +48,7 @@ public class SalesOrderDetailGetEAIService extends AbsEAIService { |
|
|
|
}else{ |
|
|
|
queryWrapper = Wrappers.<SalesOrderDetailEntity>lambdaQuery() |
|
|
|
.eq(SalesOrderDetailEntity::getTenantSid,1L) |
|
|
|
.in(SalesOrderDetailEntity::getId,idList); |
|
|
|
.eq(SalesOrderDetailEntity::getStatus,1); |
|
|
|
} |
|
|
|
|
|
|
|
List<SalesOrderDetailEntity> list = salesOrderDetailService.list(queryWrapper); |
|
|
|