|
|
@ -67,11 +67,10 @@ public class PaymentServiceImp implements PaymentService { |
|
|
List<OrderBO> orderList = orderService.queryOrder(date); |
|
|
List<OrderBO> orderList = orderService.queryOrder(date); |
|
|
if(!Optional.ofNullable(orderList).isPresent()) return; |
|
|
if(!Optional.ofNullable(orderList).isPresent()) return; |
|
|
// 遍历查询第三方订单信息
|
|
|
// 遍历查询第三方订单信息
|
|
|
for (OrderBO orderBO : orderList){ |
|
|
orderList.forEach(orderBO -> { |
|
|
// 异步处理数据
|
|
|
|
|
|
queryOrder(orderBO); |
|
|
queryOrder(orderBO); |
|
|
//amqpTemplate.convertSendAndReceive(PaymentConstant.ORDER_QUEUE,orderBO);
|
|
|
//amqpTemplate.convertSendAndReceive(PaymentConstant.ORDER_QUEUE,orderBO);
|
|
|
} |
|
|
}); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
|