瀏覽代碼

增加休眠时间,减少冲突

周箭河 4 年之前
父節點
當前提交
b3071c763a

+ 1 - 1
mec-biz/src/main/java/com/ym/mec/biz/service/SporadicChargeInfoService.java

@@ -17,7 +17,7 @@ public interface SporadicChargeInfoService extends BaseService<Integer, Sporadic
      *
      * @param order
      */
-    Boolean renewForCallback(StudentPaymentOrder order);
+    Boolean renewForCallback(StudentPaymentOrder order) throws Exception;
 
     /**
      * 分页查询

+ 4 - 0
mec-biz/src/main/java/com/ym/mec/biz/service/impl/MusicGroupServiceImpl.java

@@ -314,6 +314,10 @@ public class MusicGroupServiceImpl extends BaseServiceImpl<String, MusicGroup> i
                     flag = true;
                     break;
                 }
+
+                int max=100,min=1;
+                long ran2 = (long) (Math.random()*(max-min)+min);
+                Thread.sleep(ran2);
             }
             if (!flag) {
                 throw new BizException("活动火爆,请稍后再试");

+ 4 - 1
mec-biz/src/main/java/com/ym/mec/biz/service/impl/SporadicChargeInfoImpl.java

@@ -63,7 +63,7 @@ public class SporadicChargeInfoImpl extends BaseServiceImpl<Integer, SporadicCha
 
     @Override
     @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
-    public Boolean renewForCallback(StudentPaymentOrder studentPaymentOrder) {
+    public Boolean renewForCallback(StudentPaymentOrder studentPaymentOrder) throws Exception {
         int updateCount = studentPaymentOrderDao.update(studentPaymentOrder);
         if (updateCount <= 0) {
             throw new BizException("订单更新失败");
@@ -151,6 +151,9 @@ public class SporadicChargeInfoImpl extends BaseServiceImpl<Integer, SporadicCha
                         flag = true;
                         break;
                     }
+                    int max=100,min=1;
+                    long ran2 = (long) (Math.random()*(max-min)+min);
+                    Thread.sleep(ran2);
                 }
                 if (!flag) {
                     throw new BizException("活动火爆,请稍后再试");