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()); + } + } } }