sApiToken = env('telegram_token'); $oTGHttp->sApiChatId = env('telegram_chatid'); $sUpdate = file_get_contents("php://input"); $aUpdate = json_decode($sUpdate, true); @file_put_contents('/www/_tg/bot_log.txt', json_encode($aUpdate, JSON_PRETTY_PRINT)); $aData['chatId'] = $aUpdate["message"]["chat"]["id"]; $aData['fromId'] = $aUpdate["message"]["from"]["id"]; if (!isset($aUpdate["message"]["text"])) { throw new \Exception("?"); } $sText = $aUpdate["message"]["text"]; if (isset($aUpdate["is_dove"])) { $sSendType = "dove"; } else { $sSendType = false; } // test // $sText = "\\//Article#List ni__aaa__bbb 111 222"; // $sText = "///\\\SaleCode#SetRate__zzxx 2"; // $sText = "///\\\SaleCode#List"; // $sText = "///\\\SaleCode#Find zzxx"; // $sText = "/Article#Like__sale_code zzx"; // $sText = "////Article#Add jxxjjjj"; // $sText = "//\\\//Article#Del 9"; // $sText = "/Article#Set__1__user_name xxx"; @$aArg = explode(" ", $sText); @$aOption = explode("__", $aArg[0]); $sCmd = $this->cleanCmd($aOption[0]); list($sClass, $sFunc) = explode("#", $sCmd); $sClass = ucfirst($sClass); $sFunc = ucfirst($sFunc); unset($aOption[0]); unset($aArg[0]); $aParams['aOption'] = $aOption; $aParams['aArg'] = $aArg; $sClassPath = "App\\Services\\TG\\Hook\\Mod\\".$sClass; if (method_exists($sClassPath, $sFunc)) { $oInstans = new $sClassPath(); $r = $oInstans->$sFunc($aParams); // 可以不返回,里面直接send if (isset($r)) { if (empty($r)) { $r = 'hook的mod返回空'; } // 返回可以是数组 if (is_array($r)) { foreach ($r as $row) { $oTGHttp->sendToTG($row, $sSendType); } } else { $oTGHttp->sendToTG($r, $sSendType); } Http::response(200, 'ok'); } } else { throw new \Exception("没有这个方法:".$sClass.'#'.$sFunc); } } catch (\Throwable $e) { $sMessage = "错误(line:".$e->getLine()."): " . $e->getMessage(); $oTGHttp->sendToTG($sMessage, $sSendType); Http::response(200, 'error'); } } private function cleanCmd($input) { $input = str_replace('\\', '', $input); $input = str_replace('/', '', $input); return $input; } }