diff --git a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java index a8cbd9752..dd00fa7ad 100644 --- a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java +++ b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java @@ -354,6 +354,9 @@ public class JsowellTask { // 查询未分帐订单 PageUtils.startPage(1, 500); List list = orderUnsplitRecordService.queryUnsplitOrders(startTime, endTime); + + log.info("处理未分帐订单start, 当前时间:{}, 查询出[{}]条未分账订单, 下面进行处理", DateUtils.getDateTime(), list.size()); + int count = 0; for (OrderUnsplitRecord orderUnsplitRecord : list) { String paymentId = orderUnsplitRecord.getPaymentId(); String orderCode = orderUnsplitRecord.getOrderCode(); @@ -376,15 +379,17 @@ public class JsowellTask { // 如果确认交易成功,则更新订单状态为已分账 if (paymentConfirmResponse.isSuccess()) { - log.info("processUnsplitOrders, 分账成功, paymentId:{}", paymentId); + count++; orderUnsplitRecord.setStatus(paymentConfirmResponse.getStatus()); orderUnsplitRecordService.updateOrderUnsplitRecord(orderUnsplitRecord); + log.info("processUnsplitOrders, 分账成功, paymentId:{}", paymentId); } else { // 如果失败,打印日志 log.info("processUnsplitOrders, 分账失败, paymentId:{}, 错误信息:{}", paymentId, paymentConfirmResponse.getError_msg()); - return; + break; } } + log.info("处理未分帐订单end, 当前时间:[{}], 成功分账[{}]条订单", DateUtils.getDateTime(), count); } }