jccp_a/laravel/app/Services/OpenApi/Telegram.php
hellcat ac91e1fbe4 1
2025-11-12 17:57:30 +08:00

67 lines
1.7 KiB
PHP

<?php
declare(strict_types=1);
namespace App\Services\OpenApi;
use Illuminate\Http\Request;
//use App\Services\TomTool\TelegramV2;
use App\Services\TomTool\Flow;
use App\Services\TomTool\Telegram\Master as TeleMaster;
//use App\Services\TomTool\Telegram\Slave as TeleSlave;
use Telegram\Bot\Api;
use Telegram\Bot\Exceptions\TelegramSDKException;
final class Telegram
{
public function post()
{
$oFlow = Flow::make("master::tgpost");
$sArg = file_get_contents('php://input');
$aArg = json_decode($sArg, true);
$sBotCode = $aArg["sBotCode"] ?? '';
$sChatCode = $aArg["sChatCode"] ?? '';
$sBotToken = $aArg["sBotToken"] ?? '';
$iChatId = (int) ($aArg["iChatId"] ?? 0);
$enableMasterQueue = $aArg["enableMasterQueue"] ?? false; // 用不着了
$sMsg = $aArg["sMsg"] ?? '';
$r = TeleMaster::start()
->setBotCode($sBotCode)
->setChatCode($sChatCode)
->setBotToken($sBotToken)
->setChatId($iChatId)
->send($sMsg);
return $oFlow->done();
}
public function queueAdd_meiyong(Request $oRequest)
{
$oResult = Flow::make("master::queueAdd");
$sArg = $oRequest->post("arg");
if (!$sArg) {
return $oResult->fail("没有arg");
}
$oHttpQueue = new ModelHttpQueue();
$oHttpQueue->name = "telegram";
$oHttpQueue->arg = $sArg;
$r = $oHttpQueue->save();
if (!$r) {
return $oResult->fail("进入队列失败");
}
return $oResult->done();
}
}