|
@@ -331,8 +331,8 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
|
}
|
|
|
//异步
|
|
|
CompletableFuture.runAsync(() -> {
|
|
|
- //检查5次
|
|
|
- for (int i = 0; i <= 5; i++) {
|
|
|
+ //检查10次
|
|
|
+ for (int i = 0; i <= 10; i++) {
|
|
|
try {
|
|
|
Thread.sleep(3000);//每3秒触发一次
|
|
|
tenantOrderRecordService.checkTenantOrder();
|
|
@@ -348,7 +348,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
|
|
|
|
// 检查云教室
|
|
|
private void delayCheckCloudTeacherOrder(TenantOrderRecord record) {
|
|
|
- RBucket<Object> bucket = redissonClient.getBucket("delay_check_tenant");
|
|
|
+ RBucket<Object> bucket = redissonClient.getBucket("delay_check_cloud_tenant");
|
|
|
if (!bucket.trySet(1, 15L, TimeUnit.SECONDS)) {
|
|
|
return;
|
|
|
}
|
|
@@ -376,7 +376,7 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
|
|
|
|
|
|
// 检查机构充值
|
|
|
private void delayCheckTenantRecharge(TenantOrderRecord record) {
|
|
|
- RBucket<Object> bucket = redissonClient.getBucket("delay_check_tenant");
|
|
|
+ RBucket<Object> bucket = redissonClient.getBucket("delay_check_recharge_tenant");
|
|
|
if (!bucket.trySet(1, 15L, TimeUnit.SECONDS)) {
|
|
|
log.info("executePayment bucket retryset >>>>> ");
|
|
|
return;
|