通过掌上论坛的回帖不触发钩子函数
2022/02/05 14:32:48
我写了一个很简单的钩子函数
这个可以在每次回帖的时候正常的回调，但是我通过掌上论坛API调用的时候却并不触发这个钩子函数，我想问问是什么原因，需要做哪些事情才能让通过掌上论坛API发帖的时间被正确的通过钩子函数回调？
- <?phpif (!defined('IN_DISCUZ')) { exit('Access Denied');}function sendPostRequest($url,$jsonData){ $curl = curl_init($url); curl_setopt($curl, CURLOPT_HEADER, false); curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); curl_setopt($curl, CURLOPT_HTTPHEADER, array("Content-type: application/json")); curl_setopt($curl, CURLOPT_POST, true); curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($jsonData)); // set a very low timeout to avoid blocking curl_exec($curl); curl_close($curl);}class plugin_dhpush {}class plugin_dhpush_forum extends plugin_dhpush{ function __construct() { //全局函数定义 global $_G; $config = $_G['cache']['plugin']['dhpush']; $this->groupid = $_G['groupid']; $this->allowPushGroupIds = unserialize($config["allowPushGroups"]); $this->pushToken = $config["pushToken"]; } function post_reply_output($params) { global $_G; $DEBUG = true; $SEND_URL_PREFIX = "https://dhpushservice.kidozh.com/"; $SEND_URL_PATH = "v1/push/reply/"; if ($DEBUG) { $SEND_URL_PREFIX = "http://localhost:8888/"; } $SEND_URL = $SEND_URL_PREFIX.$SEND_URL_PATH; error_log(print_r($params, TRUE)); // check with post reply succeed if ($params["message"] != "post_reply_succeed") { return; } $fid = $params['values']['fid']; $tid = $params['values']['tid']; $pid = $params['values']['pid']; $mForumPost = C::t("forum_post"); $post = $mForumPost->fetch($tid, $pid); $senderUid = $post["authorid"]; $senderName = $post["author"]; $replyMessage = $post["message"]; $mForumThread = C::t('forum_thread'); $thread = $mForumThread->fetch($tid); //主题作者ID $authorId = $thread['authorid']; $userResult = DB::fetch_first("SELECT groupid FROM " . DB::table("common_member") . " WHERE uid=" . $authorId); $receiverGroupId = $userResult["groupid"]; //判断作者是否开启回贴通知 //$mForumPostNotice = C::t('#post_notice#forum_post_notice'); //$isNotice = $mForumPostNotice->getNoticeState($authorId); // allow notify if (true) { $mCommonMember = C::t('common_member'); $author = $mCommonMember->fetch($authorId);// $email = $author['email']; $title = $senderName . '回复了帖子' . $thread["subject"]; $siteURL = $_G["siteurl"]; // check whether group id is not null and in the allowed group if ($receiverGroupId && in_array($receiverGroupId, $this->allowPushGroupIds)) { // look in the table whether the user in the push database $pushInfo = DB::fetch_first("SELECT uid, token, allowPush FROM " . DB::table("dhpush_token") . " WHERE uid=" . $authorId); // start to push the information to device via firebase $token = $pushInfo["token"]; $deviceToken = $token; $data = [ // belong to a reply "site_url" => $siteURL, "type" => "thread_reply", "sender_name" => $senderName, "sender_id" => $senderUid, "message" => $replyMessage, "title" => $title, "tid" => $tid, "pid" => $pid, "fid" => $fid, "tokenList"=> $deviceToken ]; $SEND_URL_WITH_PARAMTER = $SEND_URL."?token=".$this->pushToken; sendPostRequest($SEND_URL_WITH_PARAMTER,$data); error_log(print_r($data, TRUE)); error_log(print_r($SEND_URL, TRUE)); } else { // the user are not able to get a push } } else { // not to send a information } }}// function post_message($params)// {// return;// //file_put_contents('php://stderr', print_r($params, TRUE));// error_log(print_r($params, TRUE));// global $_G;// $fid = $params['param'][2]['fid'];// $tid = $params['param'][2]['tid'];// $pid = $params['param'][2]['pid'];//// $action=$params['param'][0];// if($action=='post_newthread_succeed'){//newthread// //TODO For newthread// }// elseif($action=='post_reply_succeed'){//new reply// return;// $senderName = $_G["username"];// $senderUid = $_G["uid"];//// $mForumThread = C::t('forum_thread');// //$tid = $params['values']['tid'];// $thread = $mForumThread->fetch($tid);// //主题作者ID// $authorId = $thread['authorid'];// $userResult = DB::fetch_first("SELECT groupid FROM " . DB::table("common_member") . " WHERE uid=" . $authorId);// $receiverGroupId = $userResult["groupid"];// //判断作者是否开启回贴通知// //$mForumPostNotice = C::t('#post_notice#forum_post_notice');// //$isNotice = $mForumPostNotice->getNoticeState($authorId);// // allow notify// if (true) {// $mCommonMember = C::t('common_member');// $author = $mCommonMember->fetch($authorId);// $email = $author['email'];// $subject = '您的贴子有回复了!';// $body = $author['username'] . "\n";// $body .= "您的主题：" . $thread['subject'] . "有回复了!\n";// $body .= "复制链接查看：" . $_G['siteurl'] . "forum.php?mod=viewthread&tid=" . $tid . "\n";//// $replyMessage = $body;// // check whether group id is not null and in the allowed group// if ($receiverGroupId && in_array($receiverGroupId, $this->allowPushGroupIds)) {// // look in the table whether the user in the push database// $pushInfo = DB::fetch_first("SELECT uid, token, allowPush FROM ".DB::table("dhpush_token")." WHERE uid=" . $authorId);// // start to push the information to device via firebase// $token = $pushInfo["token"];// $deviceToken = $token;// $data = [// // belong to a reply// "type" => "thread_reply",// "sender_name" => $author['username'],// "sender_id" => $senderUid,// "message" => $replyMessage,//// ];// sendPostRequest($SEND_URL,$data);// error_log(print_r($data, TRUE));//// } else {// // the user are not able to get a push// }// }//// }//// if ($params['message'] != 'post_reply_succeed') {// }//// }