Function handleEnhancedLotteryJoin

lottery/lottery.ts:815–933

(msg: any)

      chatId = String(msg.peerId);
    } else if (msg.chatId) {
      chatId = String(msg.chatId);
    } else {
      return;
    }
  } catch {
    return;
  }

  const activeLottery = getActiveLottery(chatId);
  if (!activeLottery || msg.message.trim() !== activeLottery.keyword) {
    return;
  }

  const sender = await msg.getSender();
  if (!sender || sender.bot) {
    return;
  }

  // Check if user already participated
  const participants = getLotteryParticipants(activeLottery.id);
  const alreadyParticipated = participants.some(p => p.user_id === String(sender.id || sender));
  
  if (alreadyParticipated) {
    try {
      const replyMsg = await msg.reply({
        message: `⚠️ <b>重复参与</b>\n\n您已参加过抽奖，请勿重复参加`,
        parseMode: "html",
      });
      
      // Delete both messages after delay (generation-safe)
      const gen1 = getCurrentGeneration();
      const t1 = setTimeout(async () => {
        pendingTimers.delete(t1);
        if (getCurrentGeneration() !== gen1) return;
        try {
          await replyMsg.delete();
          await msg.delete();
        } catch (error) {
          console.warn("Failed to delete duplicate participation messages:", error);
        }
      }, activeLottery.delete_delay * 1000);
      pendingTimers.add(t1);
    } catch (error) {
      console.warn("Failed to handle duplicate participation:", error);
    }
    return;
  }

  // Validate user conditions
  const validation = await validateUserConditions(msg.client, sender, activeLottery, chatId);
  if (!validation.valid) {
    try {
      await msg.delete(); // Silently delete invalid participation
    } catch (error) {
      console.warn("Failed to delete invalid participation message:", error);
    }
    return;
  }