info(" [*] Waiting for {$queue}. To exit press CTRL+C");
Mq::worker($exchange,$queue,function ($message){
/**生成消息内容 */
$msgTitle = '';
$username = $message->editor->nickName;
$palitext = PaliSentence::where('book',$message->book)
->where('paragraph',$message->paragraph)
->where('word_begin',$message->word_start)
->where('word_end',$message->word_end)
->value('text');
$prtext = mb_substr($message->content,0,140,"UTF-8");
$sent_num = "{$message->book}-{$message->paragraph}-{$message->word_start}-{$message->word_end}";
$link = "https://next.wikipali.org/pcd/article/para/{$message->book}-{$message->paragraph}";
$link .= "?book={$message->book}&par={$message->paragraph}&channel={$message->channel->id}";
$msgContent = "{$username} 就文句`{$palitext}`提出了修改建议：
>内容摘要：{$prtext}，\n
>句子编号：{$sent_num}\n
欢迎大家[点击链接]({$link})查看并讨论。";
$webhooks = WebHook::where('res_id',$message->channel->id)
->where('status','active')
->get();
foreach ($webhooks as $key => $hook) {
$event = json_decode($hook->event);
if(!in_array('pr',$event)){
continue;
}
$command = '';
switch ($hook->receiver) {
case 'dingtalk':
$command = 'webhook:dingtalk';
break;
case 'wechat':
$command = 'webhook:wechat';
break;
default:
# code...
break;
}
$ok = $this->call($command,['url'=>$hook->url,
'title'=>$msgTitle,
'message'=>$msgContent,
]);
$this->info("{$command} ok={$ok}");
if($ok===0){
WebHook::where('id',$hook->id)->increment('success');
}else{
WebHook::where('id',$hook->id)->increment('fail');
}
}
});
$callback = function ($msg) {
$message = json_decode($msg->body);
};
$channel->basic_consume('suggestion', '', false, true, false, false, $callback);
while ($channel->is_open()) {
$channel->wait();
}
return 0;
}
}