演出行业票务分销管理系统：如何应对票务预售、场次管理的特殊场景？

// 票务库存管理服务示例
public class TicketInventoryService : ITicketInventoryService
{
    private readonly IDistributedCache _cache;
    
    // 使用分布式锁处理库存扣减
    public async Task ReduceInventoryAsync(int eventId, int quantity)
    {
        var lockKey = $"inventory_lock_{eventId}";
        using (var redLock = await _redLockFactory.CreateLockAsync(lockKey, TimeSpan.FromSeconds(30)))
        {
            if (redLock.IsAcquired)
            {
                // 执行库存扣减操作
                var currentInventory = await GetInventoryAsync(eventId);
                if (currentInventory >= quantity)
                {
                    await _cache.StringSetAsync($"inventory_{eventId}", currentInventory - quantity);
                    return true;
                }
            }
            return false;
        }
    }
}

-- 场次与座位关系数据模型
CREATE TABLE EventSessions (
    SessionId INT PRIMARY KEY IDENTITY,
    EventId INT NOT NULL,
    SessionDateTime DATETIME2 NOT NULL,
    VenueId INT NOT NULL,
    TotalSeats INT NOT NULL,
    AvailableSeats INT NOT NULL,
    PriceStrategy JSON NOT NULL,
    IsActive BIT DEFAULT 1,
    FOREIGN KEY (EventId) REFERENCES Events(EventId),
    FOREIGN KEY (VenueId) REFERENCES Venues(VenueId)
);

-- 创建场次座位明细表
CREATE TABLE SessionSeats (
    SeatId INT PRIMARY KEY IDENTITY,
    SessionId INT NOT NULL,
    SeatNumber VARCHAR(10) NOT NULL,
    Zone VARCHAR(50) NOT NULL,
    RowNumber INT NOT NULL,
    SeatStatus TINYINT DEFAULT 0, -- 0:可用, 1:已锁定, 2:已售出
    LockExpiryTime DATETIME2 NULL,
    FOREIGN KEY (SessionId) REFERENCES EventSessions(SessionId)
);

// 前端购票流程中的异步处理
class TicketPurchaseFlow {
  constructor() {
    this.currentStep = 1;
    this.selectedSeats = [];
    this.timer = null;
  }
  
  // 座位选择与锁定
  async selectSeat(seatId) {
    try {
      const response = await fetch('/api/seats/lock', {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
          'X-CSRF-Token': this.getCSRFToken()
        },
        body: JSON.stringify({
          seatId: seatId,
          timeout: 300 // 锁定5分钟
        })
      });
      
      if (response.ok) {
        this.selectedSeats.push(seatId);
        this.startLockTimer();
        return true;
      }
      return false;
    } catch (error) {
      console.error('座位锁定失败:', error);
      return false;
    }
  }
  
  // 启动锁定计时器
  startLockTimer() {
    if (this.timer) clearTimeout(this.timer);
    this.timer = setTimeout(() => {
      this.releaseExpiredLocks();
    }, 280000); // 提前20秒释放锁定
  }
}