From f358ba5f1d2a6c8519d9327b13a7abdf5f5b4fe7 Mon Sep 17 00:00:00 2001 From: zz Date: Sat, 18 Jun 2022 15:07:28 +0800 Subject: [PATCH] get back repush failed orders --- ...NotificationChargeOrderInfo4BonusTask.java | 22 +++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationChargeOrderInfo4BonusTask.java b/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationChargeOrderInfo4BonusTask.java index e653c45c..179ac956 100644 --- a/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationChargeOrderInfo4BonusTask.java +++ b/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/notification/NotificationChargeOrderInfo4BonusTask.java @@ -56,17 +56,17 @@ public class NotificationChargeOrderInfo4BonusTask extends CoreDispatcher { xhpcHistoryOrder.setXhpcStatisticsTimeIntervalList(statisticTimeIntervalList); notify(xhpcHistoryOrder, authSecretTokenOut, false); } -// final List pushFailedOrders = -// xhpcHistoryOrderRepository.findTop10JoinPushFailedOrders(authSecretTokenOut.getOperatorId3irdpty()); -// for (XhpcHistoryOrder xhpcHistoryOrder : pushFailedOrders) { -// List statisticTimeIntervalList = -// statisticTimeIntervalRepository.findByHistoryOrderId(xhpcHistoryOrder.getHistoryOrderId()); -// xhpcHistoryOrder.setXhpcStatisticsTimeIntervalList(statisticTimeIntervalList); -// final boolean notify = notify(xhpcHistoryOrder, authSecretTokenOut, true); -// if (notify) { -// etPushFailedOrderRepository.deleteById(xhpcHistoryOrder.getHistoryOrderId()); -// } -// } + final List pushFailedOrders = + xhpcHistoryOrderRepository.findTop10JoinPushFailedOrders(authSecretTokenOut.getOperatorId3irdpty()); + for (XhpcHistoryOrder xhpcHistoryOrder : pushFailedOrders) { + List statisticTimeIntervalList = + statisticTimeIntervalRepository.findByHistoryOrderId(xhpcHistoryOrder.getHistoryOrderId()); + xhpcHistoryOrder.setXhpcStatisticsTimeIntervalList(statisticTimeIntervalList); + final boolean notify = notify(xhpcHistoryOrder, authSecretTokenOut, true); + if (notify) { + etPushFailedOrderRepository.deleteById(xhpcHistoryOrder.getHistoryOrderId()); + } + } } }