diff --git a/src/Controllers/TomApi/Tg/HookController.php b/src/Controllers/TomApi/Tg/HookController.php index 442ef4ae..e92729f8 100755 --- a/src/Controllers/TomApi/Tg/HookController.php +++ b/src/Controllers/TomApi/Tg/HookController.php @@ -231,36 +231,45 @@ final class HookController // 快捷回复工单 // /ry 11 你好 if (strpos($sText, '/ry') === 0) { - - $sText = $this->trimText($sText, '/ry'); - - list($iTicketId, $sText) = explode(" ", $sText, 2); - - $oHttp = new Http(); - - $oHttp->sMethod = "put"; - $oHttp->sToUrl = $_ENV['baseUrl']."/api/tg/ticket/".$iTicketId; - $oHttp->bIsJson = true; - $aData['comment'] = $sText; - $aData['admin_name'] = $aUpdate["message"]["from"]["first_name"]; - $oHttp->aData = $aData; - - $r = @json_decode($oHttp->send(), true); - - // 不论失败成功都清除 step - $oTgStep->clearByFromId($aUpdate["message"]["from"]["id"]); - - if ($r["ret"] == 1) { - $sMessage = "成功"; - } else { - $sMessage = "失败"; - Http::response(500, json_encode($aData)); + try { + $sText = $this->trimText($sText, '/ry'); + + list($iTicketId, $sText) = explode(" ", $sText, 2); + + $oHttp = new Http(); + + $oHttp->sMethod = "put"; + $oHttp->sToUrl = $_ENV['baseUrl']."/api/tg/ticket/".$iTicketId; + $oHttp->bIsJson = true; + $aData['comment'] = $sText; + $aData['admin_name'] = $aUpdate["message"]["from"]["first_name"]; + $oHttp->aData = $aData; + + $r = @json_decode($oHttp->send(), true); + + // 不论失败成功都清除 step + $oTgStep->clearByFromId($aUpdate["message"]["from"]["id"]); + + if ($r["ret"] == 1) { + $sMessage = "成功"; + } else { + $sMessage = "失败"; + Http::response(500, json_encode($aData)); + } + + $this->sendMessage($sMessage); + + Http::response(200, 'ok'); + + } catch (Exception $e) { + + $sMessage = "发生错误: " . $e->getMessage(); + + $this->sendMessage($sMessage); + + Http::response(500, '内部服务器错误'); + } - - $this->sendMessage($sMessage); - - Http::response(200, 'ok'); - } // 复制节点