下单回滚 限购

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java

@@ -110,6 +110,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
     public ResponseDto<PayResultVo> checkCanOrder(PayOrderParam payOrderParam) {
         Long currentTime;
         boolean isDownGeneral = false;
+        List<AdamEntersVo> entersVoList = new ArrayList<>();
         Long startTime = System.currentTimeMillis();
         String uid = CurrentUtil.getCurrentUid();
         String lock = "userId:" + uid;
@@ -260,7 +261,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
                 isDownGeneral = true;
 
                 //学生票 判断
-                List<AdamEntersVo> entersVoList = new ArrayList<>();
+                entersVoList = new ArrayList<>();
                 if (isTrueName == 1) {
                     currentTime = System.currentTimeMillis();
                     for (String enterId : payOrderParam.getEnterIdList()) {
@@ -318,6 +319,14 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
                 dataUtils.changeSurplusGeneral(payOrderParam.getTicketId(), payOrderParam.getNumber());
                 currentTime = System.currentTimeMillis() - currentTime;
                 log.debug("redis 修改库存 异常 -> time:" + (currentTime) + "毫秒");
+                for (AdamEntersVo enters : entersVoList) {
+                    dataUtils.changeBuyInfo(uid, enters.getIdCard(), payOrderParam.getPerformanceId(), payOrderParam.getTicketId(), -1);
+                }
+                if (entersVoList.size() == 0) {
+                    for (int i = 0; i < payOrderParam.getNumber(); i++) {
+                        dataUtils.changeBuyInfo(uid, "", payOrderParam.getPerformanceId(), payOrderParam.getTicketId(), -1);
+                    }
+                }
             }
             e.printStackTrace();
             log.error("Kylin Order Pay Error = " + e.getMessage());
@@ -1153,12 +1162,12 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
             }
             Map token = CurrentUtil.getTokenClaims();
             String username = StringUtils.defaultString(((String) token.get("nickname")), "");
-//            String result = refundsStatusService.userOrderTicketRefunding(orderTicketVo, refundSinglePrice.doubleValue(), orderTicketEntitiesId, reason, picList, uid, username, kylinOrderRefundsVoBaseList.size());
-//            if (result != "") {
-//                return ResponseDto.success(result);
-//            } else {
+            String result = refundsStatusService.userOrderTicketRefunding(orderTicketVo, refundSinglePrice.doubleValue(), orderTicketEntitiesId, reason, picList, uid, username, kylinOrderRefundsVoBaseList.size());
+            if (result != "") {
+                return ResponseDto.success(result);
+            } else {
                 return ResponseDto.failure(ErrorMapping.get("20019"));
-//            }
+            }
         } catch (Exception e) {
             e.printStackTrace();
             return ResponseDto.failure(ErrorMapping.get("20019"));