|
|
@@ -50,30 +50,17 @@ class TelegramWebHook extends BaseController
|
|
|
public function handle(Request $request)
|
|
|
{
|
|
|
Log::error('Telegram 日志写入测试: ' . json_encode([$request->ip()], JSON_UNESCAPED_UNICODE));
|
|
|
- // try {
|
|
|
- $m = new Message();
|
|
|
- $m->json = $request->ip();
|
|
|
- $m->save();
|
|
|
$telegram = new Api(config('services.telegram.token'));
|
|
|
- // } catch (TelegramSDKException $e) {
|
|
|
- // return response()->json(['status' => 'ok']);
|
|
|
- // }
|
|
|
$update = $telegram->getWebhookUpdate(); // 获取更新数据
|
|
|
$update->callbackQuery;
|
|
|
if ($update->has('callback_query')) {
|
|
|
- $json['type'] = 'callback_query';
|
|
|
$callbackQuery = $update->callbackQuery;
|
|
|
- $json['update'] = $callbackQuery;
|
|
|
$message = $callbackQuery->message;
|
|
|
$from = $callbackQuery->from;
|
|
|
$data = $callbackQuery->data; // 获取 callback_data
|
|
|
$callbackId = $callbackQuery->id; // 获取 callback_query 的 ID
|
|
|
- $m = new Message();
|
|
|
- $m->json = $data;
|
|
|
- $m->save();
|
|
|
Util::delCache($message->chat->id);
|
|
|
// Log::error('Telegram 回调数据(JSON): ' . json_encode($update, JSON_UNESCAPED_UNICODE));
|
|
|
-
|
|
|
DB::beginTransaction();
|
|
|
try {
|
|
|
$chatId = $message->chat->id;
|