通过掌上论坛的回帖不触发钩子函数

kidozh

我写了一个很简单的钩子函数

1. <?php
   
2. 
   
3. if (!defined('IN_DISCUZ')) {
   
4. 
   
5.     exit('Access Denied');
   
6. }
   
7. 
   
8. function sendPostRequest($url,$jsonData){
   
9. 
   
10.     $curl = curl_init($url);
    
11.     curl_setopt($curl, CURLOPT_HEADER, false);
    
12.     curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    
13.     curl_setopt($curl, CURLOPT_HTTPHEADER, array("Content-type: application/json"));
    
14.     curl_setopt($curl, CURLOPT_POST, true);
    
15.     curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($jsonData));
    
16.     // set a very low timeout to avoid blocking
    
17.     curl_exec($curl);
    
18.     curl_close($curl);
    
19. }
    
20. 
    
21. class plugin_dhpush {}
    
22. 
    
23. 
    
24. 
    
25. 
    
26. class plugin_dhpush_forum extends plugin_dhpush
    
27. {
    
28. 
    
29.     function __construct()
    
30.     { //全局函数定义
    
31.         global $_G;
    
32.         $config = $_G['cache']['plugin']['dhpush'];
    
33.         $this->groupid = $_G['groupid'];
    
34.         $this->allowPushGroupIds = unserialize($config["allowPushGroups"]);
    
35.         $this->pushToken = $config["pushToken"];
    
36.     }
    
37. 
    
38.     function post_reply_output($params)
    
39.     {
    
40.         global $_G;
    
41.         $DEBUG = true;
    
42.         $SEND_URL_PREFIX = "https://dhpushservice.kidozh.com/";
    
43.         $SEND_URL_PATH = "v1/push/reply/";
    
44.         if ($DEBUG) {
    
45.             $SEND_URL_PREFIX = "http://localhost:8888/";
    
46. 
    
47.         }
    
48. 
    
49.         $SEND_URL = $SEND_URL_PREFIX.$SEND_URL_PATH;
    
50. 
    
51.         error_log(print_r($params, TRUE));
    
52.         // check with post reply succeed
    
53.         if ($params["message"] != "post_reply_succeed") {
    
54.             return;
    
55.         }
    
56.         $fid = $params['values']['fid'];
    
57.         $tid = $params['values']['tid'];
    
58.         $pid = $params['values']['pid'];
    
59. 
    
60. 
    
61.         $mForumPost = C::t("forum_post");
    
62.         $post = $mForumPost->fetch($tid, $pid);
    
63.         $senderUid = $post["authorid"];
    
64.         $senderName = $post["author"];
    
65.         $replyMessage = $post["message"];
    
66. 
    
67.         $mForumThread = C::t('forum_thread');
    
68. 
    
69.         $thread = $mForumThread->fetch($tid);
    
70.         //主题作者ID
    
71.         $authorId = $thread['authorid'];
    
72.         $userResult = DB::fetch_first("SELECT groupid FROM " . DB::table("common_member") . " WHERE uid=" . $authorId);
    
73.         $receiverGroupId = $userResult["groupid"];
    
74.         //判断作者是否开启回贴通知
    
75.         //$mForumPostNotice = C::t('#post_notice#forum_post_notice');
    
76.         //$isNotice = $mForumPostNotice->getNoticeState($authorId);
    
77.         // allow notify
    
78.         if (true) {
    
79.             $mCommonMember = C::t('common_member');
    
80.             $author = $mCommonMember->fetch($authorId);
    
81. //            $email = $author['email'];
    
82.             $title = $senderName . '回复了帖子' . $thread["subject"];
    
83.             $siteURL = $_G["siteurl"];
    
84.             // check whether group id is not null and in the allowed group
    
85.             if ($receiverGroupId && in_array($receiverGroupId, $this->allowPushGroupIds)) {
    
86.                 // look in the table whether the user in the push database
    
87.                 $pushInfo = DB::fetch_first("SELECT uid, token, allowPush FROM " . DB::table("dhpush_token") . " WHERE uid=" . $authorId);
    
88.                 // start to push the information to device via firebase
    
89.                 $token = $pushInfo["token"];
    
90.                 $deviceToken = $token;
    
91.                 $data = [
    
92.                     // belong to a reply
    
93.                     "site_url" => $siteURL,
    
94.                     "type" => "thread_reply",
    
95.                     "sender_name" => $senderName,
    
96.                     "sender_id" => $senderUid,
    
97.                     "message" => $replyMessage,
    
98.                     "title" => $title,
    
99.                     "tid" => $tid,
    
100.                     "pid" => $pid,
     
101.                     "fid" => $fid,
     
102.                     "tokenList"=> $deviceToken
     
103. 
     
104.                 ];
     
105. 
     
106.                 $SEND_URL_WITH_PARAMTER = $SEND_URL."?token=".$this->pushToken;
     
107. 
     
108.                 sendPostRequest($SEND_URL_WITH_PARAMTER,$data);
     
109.                 error_log(print_r($data, TRUE));
     
110.                 error_log(print_r($SEND_URL, TRUE));
     
111. 
     
112.             } else {
     
113.                 // the user are not able to get a push
     
114.             }
     
115.         } else {
     
116.             // not to send a information
     
117. 
     
118.         }
     
119.     }
     
120. }
     
121. 
     
122. //    function post_message($params)
     
123. //    {
     
124. //        return;
     
125. //        //file_put_contents('php://stderr', print_r($params, TRUE));
     
126. //        error_log(print_r($params, TRUE));
     
127. //        global $_G;
     
128. //        $fid = $params['param'][2]['fid'];
     
129. //        $tid = $params['param'][2]['tid'];
     
130. //        $pid = $params['param'][2]['pid'];
     
131. //
     
132. //        $action=$params['param'][0];
     
133. //        if($action=='post_newthread_succeed'){//newthread
     
134. //            //TODO For newthread
     
135. //        }
     
136. //        elseif($action=='post_reply_succeed'){//new reply
     
137. //            return;
     
138. //            $senderName = $_G["username"];
     
139. //            $senderUid = $_G["uid"];
     
140. //
     
141. //            $mForumThread = C::t('forum_thread');
     
142. //            //$tid = $params['values']['tid'];
     
143. //            $thread = $mForumThread->fetch($tid);
     
144. //            //主题作者ID
     
145. //            $authorId = $thread['authorid'];
     
146. //            $userResult = DB::fetch_first("SELECT groupid FROM " . DB::table("common_member") . " WHERE uid=" . $authorId);
     
147. //            $receiverGroupId = $userResult["groupid"];
     
148. //            //判断作者是否开启回贴通知
     
149. //            //$mForumPostNotice = C::t('#post_notice#forum_post_notice');
     
150. //            //$isNotice = $mForumPostNotice->getNoticeState($authorId);
     
151. //            // allow notify
     
152. //            if (true) {
     
153. //                $mCommonMember = C::t('common_member');
     
154. //                $author = $mCommonMember->fetch($authorId);
     
155. //                $email = $author['email'];
     
156. //                $subject = '您的贴子有回复了!';
     
157. //                $body = $author['username'] . "\n";
     
158. //                $body .= "您的主题：" . $thread['subject'] . "有回复了!\n";
     
159. //                $body .= "复制链接查看：" . $_G['siteurl'] . "forum.php?mod=viewthread&tid=" . $tid . "\n";
     
160. //
     
161. //                $replyMessage = $body;
     
162. //                // check whether group id is not null and in the allowed group
     
163. //                if ($receiverGroupId && in_array($receiverGroupId, $this->allowPushGroupIds)) {
     
164. //                    // look in the table whether the user in the push database
     
165. //                    $pushInfo = DB::fetch_first("SELECT uid, token, allowPush FROM ".DB::table("dhpush_token")." WHERE uid=" . $authorId);
     
166. //                    // start to push the information to device via firebase
     
167. //                    $token = $pushInfo["token"];
     
168. //                    $deviceToken = $token;
     
169. //                    $data = [
     
170. //                        // belong to a reply
     
171. //                        "type" => "thread_reply",
     
172. //                        "sender_name" => $author['username'],
     
173. //                        "sender_id" => $senderUid,
     
174. //                        "message" => $replyMessage,
     
175. //
     
176. //                    ];
     
177. //                    sendPostRequest($SEND_URL,$data);
     
178. //                    error_log(print_r($data, TRUE));
     
179. //
     
180. //                } else {
     
181. //                    // the user are not able to get a push
     
182. //                }
     
183. //            }
     
184. //
     
185. //        }
     
186. //
     
187. //        if ($params['message'] != 'post_reply_succeed') {
     
188. //        }
     
189. //
     
190. //    }
     
191. 
     

复制代码

这个可以在每次回帖的时候正常的回调，但是我通过掌上论坛API调用的时候却并不触发这个钩子函数，我想问问是什么原因，需要做哪些事情才能让通过掌上论坛API发帖的时间被正确的通过钩子函数回调？

老周部落

试试改成 post_message 嵌入点呢？这个嵌入点应该是不依赖前端的，不过 $params["message"] != "post_reply_succeed" 估计得改。

kidozh

老周部落 发表于 2022-2-5 11:39
试试改成 post_message 嵌入点呢？这个嵌入点应该是不依赖前端的，不过 $params["message"] != "post_reply ...

似乎这个也触发不了。。。刚刚试了一下。。。

老周部落

kidozh 发表于 2022-2-5 22:59
似乎这个也触发不了。。。刚刚试了一下。。。

$params["message"] != "post_reply_succeed" 去掉也不行么？

kidozh

老周部落 发表于 2022-2-8 15:37
$params["message"] != "post_reply_succeed" 去掉也不行么？

我试了 没有办法通过掌上论坛API触发，网页端都是可以的

kidozh

老周部落 发表于 2022-2-8 15:37
$params["message"] != "post_reply_succeed" 去掉也不行么？

我回复被吞了，我试了一下 是不行的 我嵌入了移动端也不行。。。