|
@@ -80,11 +80,9 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
// 云教练支付
|
|
// 云教练支付
|
|
TenantOrderRecord tenantOrderRecord = tenantOrderRecordService.getOne(new WrapperUtil<TenantOrderRecord>()
|
|
TenantOrderRecord tenantOrderRecord = tenantOrderRecordService.getOne(new WrapperUtil<TenantOrderRecord>()
|
|
.hasEq("order_no_", payParam.getOrderNo()).queryWrapper());
|
|
.hasEq("order_no_", payParam.getOrderNo()).queryWrapper());
|
|
- log.info("executePayment >>>>> {}", payParam.getOrderNo());
|
|
|
|
if (tenantOrderRecord.getOrderState() == 1) {
|
|
if (tenantOrderRecord.getOrderState() == 1) {
|
|
- throw new Exception("tenantOrderRecord order state is 1");
|
|
|
|
|
|
+ throw new Exception("订单已支付, 订单号:" + payParam.getOrderNo());
|
|
}
|
|
}
|
|
- log.info("executePayment checkOrderAndGetParam >>>>> ");
|
|
|
|
payment = checkOrderAndGetParam(payParam,
|
|
payment = checkOrderAndGetParam(payParam,
|
|
tenantOrderRecord,
|
|
tenantOrderRecord,
|
|
TenantOrderRecord::getEnumOrderState,
|
|
TenantOrderRecord::getEnumOrderState,
|
|
@@ -100,7 +98,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
TenantOrderRecord tenantOrderRecord = tenantOrderRecordService.getOne(new WrapperUtil<TenantOrderRecord>()
|
|
TenantOrderRecord tenantOrderRecord = tenantOrderRecordService.getOne(new WrapperUtil<TenantOrderRecord>()
|
|
.hasEq("order_no_", payParam.getOrderNo()).queryWrapper());
|
|
.hasEq("order_no_", payParam.getOrderNo()).queryWrapper());
|
|
if (tenantOrderRecord.getOrderState() == 1) {
|
|
if (tenantOrderRecord.getOrderState() == 1) {
|
|
- throw new Exception("tenantOrderRecord order state is 1");
|
|
|
|
|
|
+ throw new Exception("订单已支付, 订单号:" + payParam.getOrderNo());
|
|
}
|
|
}
|
|
payment = checkOrderAndGetParam(payParam,
|
|
payment = checkOrderAndGetParam(payParam,
|
|
tenantOrderRecord,
|
|
tenantOrderRecord,
|
|
@@ -110,6 +108,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
tenantOrderRecordService::updateById
|
|
tenantOrderRecordService::updateById
|
|
);
|
|
);
|
|
//主动延迟检查订单
|
|
//主动延迟检查订单
|
|
|
|
+ log.info("executePayment delayCheckTenantRecharge >>>>> ");
|
|
delayCheckTenantRecharge(tenantOrderRecord);
|
|
delayCheckTenantRecharge(tenantOrderRecord);
|
|
} else if (platform.equals("teacher")) {
|
|
} else if (platform.equals("teacher")) {
|
|
TenantPaymentOrder tenantPaymentOrder = tenantPaymentOrderService.queryByOrderNo(payParam.getOrderNo());
|
|
TenantPaymentOrder tenantPaymentOrder = tenantPaymentOrderService.queryByOrderNo(payParam.getOrderNo());
|
|
@@ -298,6 +297,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
private void delayCheckTenantRecharge(TenantOrderRecord record) {
|
|
private void delayCheckTenantRecharge(TenantOrderRecord record) {
|
|
RBucket<Object> bucket = redissonClient.getBucket("delay_check_tenant");
|
|
RBucket<Object> bucket = redissonClient.getBucket("delay_check_tenant");
|
|
if (!bucket.trySet(1, 15L, TimeUnit.SECONDS)) {
|
|
if (!bucket.trySet(1, 15L, TimeUnit.SECONDS)) {
|
|
|
|
+ log.info("executePayment bucket retryset >>>>> ");
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
//异步
|
|
//异步
|
|
@@ -308,7 +308,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
Boolean ret = tenantOrderRecordService.rechargeCheck(record);
|
|
Boolean ret = tenantOrderRecordService.rechargeCheck(record);
|
|
if (ret) break;
|
|
if (ret) break;
|
|
Thread.sleep(3000);//每3秒触发一次
|
|
Thread.sleep(3000);//每3秒触发一次
|
|
- log.info("delayCheckTenant >>>>> start {}", i);
|
|
|
|
|
|
+ log.info("executePayment 重试 >>>>> start {}", i);
|
|
} catch (InterruptedException e) {
|
|
} catch (InterruptedException e) {
|
|
return;
|
|
return;
|
|
}
|
|
}
|