本文详解如何通过 php 调用 telegram bot api，结合数据库状态管理，安全、分批地将管理员回复的消息转发给所有已注册用户，并解决因函数未调用导致的“无消息发送”问题。
在构建 Telegram 机器人时，实现「管理员选定一条消息 → 批量转发给全体用户」的功能非常实用（如公告推送、活动通知等）。但实践中常因逻辑断层导致功能静默失败——正如案例中所示：/send 命令能更新数据库并提示“Message sending started!”，却无任何用户收到消息。根本原因在于：触发逻辑与执行逻辑脱节——sendpost() 函数从未被调用。
✅ 正确的流程设计
整个功能需分为两个关键环节：
- 触发阶段（命令响应）：检测 /send 指令 + 管理员身份 + 存在回复消息（$reply_to_message），保存待转发消息 ID 并启用发送开关；
- 执行阶段（异步轮询）：独立函数 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 消息触达场景。