场次限购-platform 退款回调处理

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

@@ -135,7 +135,6 @@ public class DataUtils {
         String redisKeyIdCard;
         String performanceIdKeyIdCard = "";
         String ticketIdKeyIdCard = "";
-        String timeIdKeyIdCard = "";
 
         int isTrueName = getPerformanceIsTrueName(performanceId);
 
@@ -147,7 +146,7 @@ public class DataUtils {
             performanceIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId;
             ticketIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId;
         }
-        timeIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TIME_ID + ":" + timeId;
+        String timeIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TIME_ID + ":" + timeId;
 
         if (buyCount > 0) {
             redisUtil.incr(ticketIdKeyUid, buyCount);

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/refund/KylinRefundsStatusServiceImpl.java

@@ -261,7 +261,7 @@ public class KylinRefundsStatusServiceImpl {
                     int surplusGeneral = dataUtils.changeSurplusGeneral(entitiesInfo.getTicketId(), 1);
                     log.info("refundCallback回滚库存res: [surplusGeneral={},ticketId={},orderRefundCode={}]", surplusGeneral, entitiesInfo.getTicketId(), refundCallbackParam.getOrderRefundCode());
                     log.info(UserPathDto.setData("changeBuyInfo", "UserId=" + orderInfo.getUserId() + "idCard=" + entitiesInfo.getEnterIdCode() + " PerformanceId=" + orderRelations.getPerformanceId() + " TicketId=" + entitiesInfo.getTicketId(), "info"));
-                    dataUtils.changeBuyInfo(orderInfo.getUserId(), entitiesInfo.getEnterIdCode(), orderRelations.getPerformanceId(), entitiesInfo.getTicketId(), -1);
+                    dataUtils.changeBuyInfo(orderInfo.getUserId(), entitiesInfo.getEnterIdCode(), orderRelations.getPerformanceId(), entitiesInfo.getTicketId(), entitiesInfo.getTimeId(), -1);
                 }
             }
             if (newStatus == KylinTableStatusConst.ORDER_STATUS4) {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/DataUtils.java

@@ -283,7 +283,7 @@ public class DataUtils {
      * @param ticketId      票种id
      * @param buyCount      购买数量 大于 0 增加 小于 0 减少 对应 支付 退款表
      */
-    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="";
@@ -299,6 +299,7 @@ public class DataUtils {
             performanceIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId;
             ticketIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId;
         }
+        String timeIdKeyIdCard = redisKeyIdCard + ":" + KylinRedisConst.TIME_ID + ":" + timeId;
 
         if (buyCount > 0) {
             redisDataSourceUtil.getRedisKylinUtil().incr(ticketIdKeyUid, buyCount);
@@ -307,7 +308,9 @@ public class DataUtils {
                 redisDataSourceUtil.getRedisKylinUtil().incr(ticketIdKeyIdCard, buyCount);
                 redisDataSourceUtil.getRedisKylinUtil().incr(performanceIdKeyIdCard, buyCount);
             }
+            redisDataSourceUtil.getRedisKylinUtil().incr(timeIdKeyIdCard, buyCount);
         } else {
+            redisDataSourceUtil.getRedisKylinUtil().decr(timeIdKeyIdCard, Math.abs(buyCount));
             if (isTrueName != 0) {
                 redisDataSourceUtil.getRedisKylinUtil().decr(ticketIdKeyIdCard, Math.abs(buyCount));
                 redisDataSourceUtil.getRedisKylinUtil().decr(performanceIdKeyIdCard, Math.abs(buyCount));