get back repush failed orders

This commit is contained in:
zz 2022-06-18 15:07:28 +08:00
parent 5e699f1ce6
commit f358ba5f1d

View File

@ -56,17 +56,17 @@ public class NotificationChargeOrderInfo4BonusTask extends CoreDispatcher {
xhpcHistoryOrder.setXhpcStatisticsTimeIntervalList(statisticTimeIntervalList);
notify(xhpcHistoryOrder, authSecretTokenOut, false);
}
// final List<XhpcHistoryOrder> pushFailedOrders =
// xhpcHistoryOrderRepository.findTop10JoinPushFailedOrders(authSecretTokenOut.getOperatorId3irdpty());
// for (XhpcHistoryOrder xhpcHistoryOrder : pushFailedOrders) {
// List<XhpcStatisticsTimeInterval> statisticTimeIntervalList =
// statisticTimeIntervalRepository.findByHistoryOrderId(xhpcHistoryOrder.getHistoryOrderId());
// xhpcHistoryOrder.setXhpcStatisticsTimeIntervalList(statisticTimeIntervalList);
// final boolean notify = notify(xhpcHistoryOrder, authSecretTokenOut, true);
// if (notify) {
// etPushFailedOrderRepository.deleteById(xhpcHistoryOrder.getHistoryOrderId());
// }
// }
final List<XhpcHistoryOrder> pushFailedOrders =
xhpcHistoryOrderRepository.findTop10JoinPushFailedOrders(authSecretTokenOut.getOperatorId3irdpty());
for (XhpcHistoryOrder xhpcHistoryOrder : pushFailedOrders) {
List<XhpcStatisticsTimeInterval> statisticTimeIntervalList =
statisticTimeIntervalRepository.findByHistoryOrderId(xhpcHistoryOrder.getHistoryOrderId());
xhpcHistoryOrder.setXhpcStatisticsTimeIntervalList(statisticTimeIntervalList);
final boolean notify = notify(xhpcHistoryOrder, authSecretTokenOut, true);
if (notify) {
etPushFailedOrderRepository.deleteById(xhpcHistoryOrder.getHistoryOrderId());
}
}
}
}