场次限购-consumer.order关闭订单

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/receiver/AbstractOrderCloseReceiver.java

@@ -341,7 +341,7 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                 // redis 改限购
                 for (int i = 0; i < kylinOrderTicketVo.getEntitiesVoList().size(); i++) {
                     KylinOrderTicketEntitiesVo items = kylinOrderTicketVo.getEntitiesVoList().get(i);
-                    kylinOrderUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), -1);
+                    kylinOrderUtils.changeBuyInfo(items.getUserId(), items.getEnterIdCode(), items.getPerformanceId(), items.getTicketId(), items.getTimeId(), -1);
                 }
                 //改库存
                 kylinOrderUtils.changeSurplusGeneral(kylinOrderTicketVo.getTicketId(), kylinOrderTicketVo.getNumber());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/utils/KylinOrderUtils.java

@@ -135,11 +135,12 @@ public class KylinOrderUtils {
      * @param ticketId
      * @param buyCount
      */
-    public void changeBuyInfo(String userId, String idCard, String performanceId, String ticketId, int buyCount) {
+    public void changeBuyInfo(String userId, String idCard, String performanceId, String ticketId, String timeId, int buyCount) {
         String redisKeyUid;
         String redisKeyIdCard;
         String performanceIdKeyIdCard="";
         String ticketIdKeyIdCard="";
+        String timeIdKeyIdCard = "";
 
         int isTrueName = getPerformanceIsTrueName(performanceId);
 
@@ -150,6 +151,7 @@ public class KylinOrderUtils {
         if (isTrueName != 0) {
             performanceIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId;
             ticketIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId;
+            timeIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TIME_ID + ":" + timeId;
         }
 
         if (buyCount > 0) {
@@ -158,11 +160,13 @@ public class KylinOrderUtils {
             if (isTrueName != 0) {
                 redisDataSourceUtil.getRedisKylinUtil().incr(ticketIdKeyIdCard, buyCount);
                 redisDataSourceUtil.getRedisKylinUtil().incr(performanceIdKeyIdCard, buyCount);
+                redisDataSourceUtil.getRedisKylinUtil().incr(timeIdKeyIdCard, buyCount);
             }
         } else {
             if (isTrueName != 0) {
                 redisDataSourceUtil.getRedisKylinUtil().decr(ticketIdKeyIdCard, Math.abs(buyCount));
                 redisDataSourceUtil.getRedisKylinUtil().decr(performanceIdKeyIdCard, Math.abs(buyCount));
+                redisDataSourceUtil.getRedisKylinUtil().decr(timeIdKeyIdCard, Math.abs(buyCount));
             }
             redisDataSourceUtil.getRedisKylinUtil().decr(ticketIdKeyUid, Math.abs(buyCount));
             redisDataSourceUtil.getRedisKylinUtil().decr(performanceIdKeyUid, Math.abs(buyCount));