通過掌上論壇的回帖不觸發(fā)鉤子函數(shù) - Discuz! 官方交流社區(qū)

<?php
if (!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()
{ //全局函數(shù)定義
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') {
// }
//
// }

復制代碼