fengji 机构充值

mec-biz/src/main/java/com/ym/mec/biz/service/impl/OrderPayOpsServiceImpl.java

@@ -279,9 +279,9 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
             //检查5次
             for (int i = 0; i <= 5; i++) {
                 try {
-                    Thread.sleep(3000);//每3秒触发一次
                     Boolean ret = cloudTeacherOrderService.payCheck(record);
                     if (ret) break;
+                    Thread.sleep(3000);//每3秒触发一次
                     log.info("delayCheckCloudTeacherOrder >>>>>  start {}", i);
                 } catch (Exception e) {
                     log.info("delayCheckCloudTeacherOrder exception  ", e);
@@ -302,9 +302,9 @@ public class OrderPayOpsServiceImpl implements OrderPayOpsService {
             //检查5次
             for (int i = 0; i <= 5; i++) {
                 try {
-                    Thread.sleep(3000);//每3秒触发一次
                     Boolean ret = tenantOrderRecordService.rechargeCheck(record);
                     if (ret) break;
+                    Thread.sleep(3000);//每3秒触发一次
                     log.info("delayCheckTenant >>>>>  start {}", i);
                 } catch (InterruptedException e) {
                     return;

mec-biz/src/main/java/com/ym/mec/biz/service/impl/TenantOrderRecordServiceImpl.java

@@ -233,13 +233,14 @@ public class TenantOrderRecordServiceImpl extends ServiceImpl<TenantOrderRecordD
         tenantProductInfoService.updateById(productInfo);
     }
 
-    private void rechargeSuccess(TenantOrderRecord record) throws Exception {
+    private int rechargeSuccess(TenantOrderRecord record) throws Exception {
         // 更新 tenantAssetsInfo
         log.info("checkRechargeCheck  updateAmount>>>>>");
         int ret = assetsInfoService.updateAmount(record.getTenantId(), record.getExpectAmount());
         if (ret != 1) {
             throw new Exception("更新支付失败");
         }
+        return ret;
     }
 
     @Override
@@ -254,7 +255,10 @@ public class TenantOrderRecordServiceImpl extends ServiceImpl<TenantOrderRecordD
             baseMapper.updateById(record);
             try {
                 log.info("checkRechargeCheck  rechargeSuccess>>>>>");
-                this.rechargeSuccess(record); // 充值成功
+                int ret = this.rechargeSuccess(record); // 充值成功
+                if (ret == 0) {
+                    throw new Exception("更新失败");
+                }
                 return true;
             } catch (Exception e) {
                 e.printStackTrace();