Function distributePrizes

lottery/lottery.ts:526–581

(client: TelegramClient, lottery: any, winners: any[])

      for (const winner of winners) {
        // Get available prize from warehouse
        const prize = getNextAvailablePrize(lottery.prize_warehouse || "default");
        const prizeText = prize ? prize.prize_text : "恭喜中奖！";
        
        const now = Date.now();
        const expiresAt = now + (lottery.claim_timeout * 1000);
        
        // Insert winner record using standard schema
        const stmt = db.prepare(`
          INSERT INTO lottery_winners (lottery_id, user_id, username, first_name, last_name, prize_text, status, assigned_at, expires_at) 
          VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
        `);
        
        stmt.run(
          lottery.id,
          String(winner.user_id),
          winner.username || null,
          winner.first_name || null,
          winner.last_name || null,
          prizeText,
          PrizeStatus.PENDING,
          now,
          expiresAt
        );
        
        // Consume prize stock if from warehouse
        if (prize) {
          consumePrize(prize.id);
        }
      }
    });
    
    transaction();
    
    // Send prizes after transaction completes (if auto-send mode)
    if (lottery.distribution_mode === DistributionMode.AUTO_SEND) {
      for (const winner of winners) {
        const winnerRecord = getLotteryWinners(lottery.id).find(w => w.user_id === winner.user_id);
        if (winnerRecord) {
          await sendPrizeToWinner(client, winner, winnerRecord.prize_text, lottery);
          await new Promise(resolve => setTimeout(resolve, 1000)); // Rate limiting
        }
      }
    }
  } catch (error) {
    console.error("Failed to distribute prizes:", error);
    throw error;
  }
}

// Send prize message to winner
async function sendPrizeToWinner(client: TelegramClient, winner: any, prizeText: string, lottery: any): Promise<boolean> {
  try {
    const displayName = winner.username ? `@${winner.username}` : 
                       (winner.first_name || winner.last_name || `用户 ${winner.user_id}`);

    const prizeMessage =
      `🎉 <b>恭喜中奖!</b>\n\n` +
      `🏆 <b>活动名称:</b> ${htmlEscape(lottery.title)}\n` +