本文详解如何通过 php 调用 telegram bot api，结合数据库状态管理，安全、分批地将管理员回复的消息转发给所有已注册用户，并解决因函数未调用导致的“无消息发送”问题。

在构建 Telegram 机器人时，实现「管理员选定一条消息 → 批量转发给全体用户」的功能非常实用（如公告推送、活动通知等）。但实践中常因逻辑断层导致功能静默失败——正如案例中所示：/send 命令能更新数据库并提示“Message sending started!”，却无任何用户收到消息。根本原因在于：触发逻辑与执行逻辑脱节——sendpost() 函数从未被调用。

✅ 正确的流程设计

整个功能需分为两个关键环节：

1. 触发阶段（命令响应）：检测 /send 指令 + 管理员身份 + 存在回复消息（$reply_to_message），保存待转发消息 ID 并启用发送开关；
2. 执行阶段（异步轮询）：独立函数 sendpost() 主动读取数据库状态，按分页（LIMIT 60 OFFSET $offset）查询用户，逐条调用 forwardMessage()，并控制频率防限流。

⚠️ 注意：Telegram 对同一 bot 的 forwardMessage 有严格速率限制（约 30 msg/sec），usleep(200000)（即 200ms）确保每秒最多 5 条，符合安全实践。

✅ 完整可运行代码结构

// 1. 命令触发入口（在主消息处理循环中）
if ($text === '/send' && isset($reply_to_message) && $chat_id == $config['admin_id']) {
    $message_id = $reply_to_message->message_id;
    $db->query("UPDATE `bot_settings` SET `send_status` = '1', `message_id` = '$message_id' WHERE `id` = '1'");
  
  $telegram->sendMessage($chat_id, ['text' => "✅ Message sending started!"]);
    sendpost(); // ? 关键：显式调用执行函数
}

// 2. 批量转发核心函数（需定义在全局作用域）
function sendpost() {
    global $config, $db, $telegram;

    $settings = $db->query("SELECT * FROM `bot_settings` WHERE `id` = '1'")->fetch_assoc();

    if ($settings['send_status'] != 1) {
        return; // 未启用发送，直接退出
    }

    $message_id = (int)$settings['message_id'];
    $offset     = (int)$settings['send_offset'];

    // 分页查询用户（每次最多60人）
    $users = $db->query("SELECT `user_id` FROM `bot_users` LIMIT 60 OFFSET $offset");

    if ($users->num_rows > 0) {
        $new_offset = $offset + 60;
        $db->query("UPDATE `bot_settings` SET `send_offset` = '$new_offset' WHERE `id` = '1'");

        while ($row = $users->fetch_assoc()) {
            try {
                $telegram->forwardMessage($row['user_id'], $config['admin_id'], $message_id);
                usleep(200000); // 200ms 间隔，避免 flood wait
            } catch (Exception $e) {
                // 记录错误（如用户已退订、bot被拉黑等）
                error_log("Forward failed for user {$row['user_id']}: " . $e->getMessage());
                continue;
            }
        }
        // 当前批次完成，向管理员反馈
        $telegram->sendMessage($config['admin_id'], [
            'text' => "? Sent to next 60 users. Continuing..."
        ]);
        sendpost(); // 递归调用，处理下一批（或改用循环更稳妥）

    } else {
        // 全部发送完毕
        $db->query("UPDATE `bot_settings` SET `send_offset` = '0', `send_status` = '0' WHERE `id` = '1'");
        $telegram->sendMessage($config['admin_id'], [
            'text' => "? Message sending finished successfully!"
        ]);
    }
}

? 常见问题排查清单

• ✅ 确认 sendpost() 已定义且可访问：避免因作用域或加载顺序导致函数未声明；
• ✅ 检查 bot_users.user_id 类型匹配：数据库中为 INT(20)，PHP 中应保持整型传递（避免字符串 ID 导致转发失败）；
• ✅ 验证 $config['admin_id'] 正确性：forwardMessage 的 from_chat_id 必须是管理员的 chat_id（非 bot token 所属账号）；
• ✅ 开启错误日志：在 forwardMessage 外包裹 try-catch，捕获 403 Forbidden（用户已屏蔽 bot）或 400 Bad Request（消息 ID 无效）等异常；
• ✅ 避免递归过深：若用户量极大（如 >10,000），建议改用 while 循环替代递归调用，防止栈溢出。

✅ 总结

该方案以轻量状态机（send_status + send_offset）驱动批量任务，兼顾可靠性与合规性。核心要点在于：触发即执行、状态即契约、分批即安全。只要确保函数被正确调用、参数类型准确、异常可监控，即可稳定支撑万级用户的 Telegram 消息触达场景。