autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-05-16 15:58:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

定时任务处理未分帐订单

Browse Source
This commit is contained in:
Guoqs
2025-04-16 15:55:14 +08:00
parent b7f04d2159
commit 033972b87d
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
View File

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