:sparkles: 支持wbw消息

api-v8/app/Console/Commands/MqDiscussion.php

@@ -3,15 +3,22 @@
 namespace App\Console\Commands;
 
 use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Str;
+
 use App\Models\Sentence;
 use App\Models\WebHook;
 use App\Models\Discussion;
 use App\Models\Article;
+use App\Models\DhammaTerm;
+use App\Models\Wbw;
+use App\Models\WbwBlock;
 use App\Http\Api\Mq;
 use App\Tools\WebHook as WebHookSend;
 use App\Http\Api\MdRender;
 use App\Http\Api\UserApi;
-use Illuminate\Support\Facades\Log;
+use App\Http\Controllers\NotificationController;
+
 
 class MqDiscussion extends Command
 {
@@ -56,12 +63,57 @@ class MqDiscussion extends Command
         Mq::worker($exchange,$queue,function ($message){
             Log::info('mq discussion receive {message}',['message'=>json_encode($message,JSON_UNESCAPED_UNICODE)]);
             $result = 0;
+            $msgParam = array();
+            $msgParam['nickname'] = $message->editor->nickName;
+            $link = config('app.url')."/pcd/discussion/topic/";
+            if($message->parent){
+                $msgParam['topic-title'] = Discussion::where('id',$message->parent)->value('title');
+                $id = $message->id;
+                $msgParam['link'] = $link . $message->parent.'#'.$id;
+                $msgParam['card_title'] = "回复讨论";
+                $type = 'reply';
+            }else{
+                $msgParam['title'] = $message->title;
+                $msgParam['link'] = $link . $message->id;
+                $msgParam['card_title'] = "创建讨论";
+                $type = 'create';
+            }
+            if($message->content){
+                $msgParam['content'] = $message->content;
+            }
+
             switch ($message->res_type) {
                 case 'sentence':
                     $sentence = Sentence::where('uid',$message->res_id)->first();
                     if(!$sentence){
-                        return 0;
+                        Log::error('invalid sentence id '.$message->res_id);
+                        $result = 1;
+                        break;
+                    }
+
+                    //站内信
+                    try{
+                        $sendTo = array();
+                        //句子的channel拥有者
+                        //$sendTo[] = $prData->channel->studio_id;
+                        //句子的作者
+                        if(!in_array($sentence->editor_uid,$sendTo)){
+                            $sendTo[] = $sentence->editor_uid;
+                        }
+                        //句子的采纳者
+                        if(!empty($sentence->acceptor_uid) && !in_array($sentence->acceptor_uid,$sendTo)){
+                            $sendTo[] = $sentence->acceptor_uid;
+                        }
+                        $this->notification($message->editor->uid,
+                                            $sendTo,
+                                            'discussion',
+                                            $message->id,
+                                            $sentence->channel_uid);
+                    }catch(\Exception $e){
+                        Log::error('send notification failed',['exception'=>$e]);
                     }
+
+                    //webhook
                     $contentHtml = MdRender::render($sentence->content,
                                              [$sentence->channel_uid],
                                              null,
@@ -71,90 +123,177 @@ class MqDiscussion extends Command
                     $contentTxt = strip_tags($contentHtml);
                     /**生成消息内容 */
 
-                    $msgParam = array();
                     $msgParam['anchor-content'] = $contentTxt;
-                    $msgParam['nickname'] = $message->editor->nickName;
-                    $link = config('app.url')."/pcd/discussion/topic/";
-                    if($message->parent){
-                        $msgParam['topic-title'] = Discussion::where('id',$message->parent)->value('title');
-                        $id = $message->id;
-                        $msgParam['link'] = $link . $message->parent.'#'.$id;
-                        $msgTitle = "回复讨论";
-                        $type = 'reply';
-                    }else{
-                        $msgParam['title'] = $message->title;
-                        $msgParam['link'] = $link . $message->id;
-                        $msgTitle = "创建讨论";
-                        $type = 'create';
+                    $WebHookResId = $sentence->channel_uid;
+
+                    $this->WebHook($msgParam,$type,$WebHookResId);
+                    break;
+                case 'wbw':
+                    $wbw = Wbw::where('uid',$message->res_id)->first();
+                    if(!$wbw){
+                        Log::error('invalid wbw id '.$message->res_id);
+                        $result = 1;
+                        break;
                     }
-                    if($message->content){
-                        $msgParam['content'] = $message->content;
+                    $wbwBlock = WbwBlock::where('uid',$wbw->block_uid)->first();
+                    if(!$wbwBlock){
+                        Log::error('invalid wbw-block id '.$message->res_id);
+                        $result = 1;
+                        break;
                     }
 
-                    $rootId = UserApi::getById(0)['uid'];
-                    $articleTitle = "webhook://discussion/{$type}/zh-hans";
-                    $tpl = Article::where('owner',$rootId)
-                                  ->where('title',$articleTitle)
-                                  ->value('content');
-                    if(empty($tpl)){
-                        Log::error('mq:discussion 模版不能为空',['tpl_title'=>$articleTitle]);
-                        return 1;
-                    }
-                    $m = new \Mustache_Engine(array('entity_flags'=>ENT_QUOTES,
-                                                'delimiters' => '{% %}',));
-                    $msgContent = $m->render($tpl,$msgParam);
-
-                    $webhooks = WebHook::where('res_id',$sentence->channel_uid)
-                                    ->where('status','active')
-                                    ->get();
-                    foreach ($webhooks as $key => $hook) {
-                        $event = json_decode($hook->event);
-
-                        if(is_array($event)){
-                            if(!in_array('discussion',$event)){
-                                continue;
-                            }
-                        }else{
-                            continue;
-                        }
-                        $command = '';
-                        $whSend = new WebHookSend;
-                        $ok = 0;
-                        switch ($hook->receiver) {
-                            case 'dingtalk':
-                                $ok = $whSend->dingtalk($hook->url,$msgTitle,$msgContent);
-                                break;
-                            case 'wechat':
-                                $ok = $whSend->wechat($hook->url,null,$msgContent);
-                                break;
-                            default:
-                                $ok=2;
-                                break;
+                    //站内信
+                    try{
+                        $sendTo = array();
+                        //channel拥有者
+                        //$sendTo[] = $prData->channel->studio_id;
+                        //作者
+                        if(!in_array($wbw->creator_uid,$sendTo)){
+                            $sendTo[] = $wbw->creator_uid;
                         }
-                        $result += $ok;
-                        $logMsg = "{$command}  ok={$ok}";
-                        if($ok === 0){
-                            $this->info($logMsg);
-                        }else{
-                            $this->error($logMsg);
+                        //提问者
+                        if(!empty($message->parent)){
+                            $topicEditor = Discussion::where('id',$message->parent)
+                                                ->value('editor_uid');
+                            if(!empty($topicEditor) && !in_array($topicEditor,$sendTo)){
+                                $sendTo[] = $topicEditor;
+                                Log::debug('发送给提问者',['data'=>$topicEditor]);
+                            }
                         }
 
-                        if($ok === 0){
-                            Log::debug('mq:discussion: send success {url}',['url'=>$hook->url]);
-                            WebHook::where('id',$hook->id)->increment('success');
-                        }else{
-                            Log::error('mq:discussion: send fail {url}',['url'=>$hook->url]);
-                            WebHook::where('id',$hook->id)->increment('fail');
+                        $this->notification($message->editor->id,
+                                            $sendTo,
+                                            'discussion',
+                                            $message->id,
+                                            $wbwBlock->channel_uid);
+                    }catch(\Exception $e){
+                        Log::error('send notification failed',['exception'=>$e]);
+                    }
+
+                    $msgParam['anchor-content'] = $wbw->word;
+                    $WebHookResId = $wbwBlock->channel_uid;
+                    $this->WebHook($msgParam,$type,$WebHookResId);
+                    break;
+                case 'term':
+                    $term = DhammaTerm::where('guid',$message->res_id)->first();
+                    if(!$term){
+                        Log::error('invalid term id '.$message->res_id);
+                        $result = 1;
+                        break;
+                    }
+                    if(empty($term->channal) || !Str::isUuid($term->channal)){
+                        break;
+                    }
+
+
+                    //站内信
+                    try{
+                        $sendTo = array();
+                        //拥有者
+                        $sendTo[] = $term->term;
+                        //作者
+                        $editor = App\Http\Api\UserApi::getById($term->editor_id);
+                        if($editor['id'] !== 0 && !in_array($editor['uid'],$sendTo)){
+                            $sendTo[] = $editor['uid'];
                         }
+                        $this->notification($message->editor->uid,
+                                            $sendTo,
+                                            'discussion',
+                                            $message->id,
+                                            $term->channal);
+                    }catch(\Exception $e){
+                        Log::error('send notification failed',['exception'=>$e]);
                     }
+                    //webhook
+                    $msgParam['anchor-content'] = $term->meaning . '(' . $term->word . ')';
+                    $WebHookResId = $term->channal;
+                    $this->WebHook($msgParam,$WebHookResId);
+
                     break;
                 default:
                     # code...
                     break;
             }
+
             return $result;
         });
 
         return 0;
     }
+
+    private function WebHook($msgParam,$type,$resId){
+        $rootId = UserApi::getById(0)['uid'];
+        $articleTitle = "webhook://discussion/{$type}/zh-hans";
+        $tpl = Article::where('owner',$rootId)
+                      ->where('title',$articleTitle)
+                      ->value('content');
+        if(empty($tpl)){
+            Log::error('mq:discussion 模版不能为空',['tpl_title'=>$articleTitle]);
+            return 1;
+        }
+        $m = new \Mustache_Engine(array('entity_flags'=>ENT_QUOTES,
+                                    'delimiters' => '{% %}',));
+        $msgContent = $m->render($tpl,$msgParam);
+
+        $webhooks = WebHook::where('res_id',$resId)
+                        ->where('status','active')
+                        ->get();
+        foreach ($webhooks as $key => $hook) {
+            $event = json_decode($hook->event);
+
+            if(is_array($event)){
+                if(!in_array('discussion',$event)){
+                    continue;
+                }
+            }else{
+                continue;
+            }
+            $command = '';
+            $whSend = new WebHookSend;
+            $ok = 0;
+            switch ($hook->receiver) {
+                case 'dingtalk':
+                    $ok = $whSend->dingtalk($hook->url,$msgParam['card_title'],$msgContent);
+                    break;
+                case 'wechat':
+                    $ok = $whSend->wechat($hook->url,null,$msgContent);
+                    break;
+                default:
+                    $ok=2;
+                    break;
+            }
+            $result += $ok;
+            $logMsg = "{$command}  ok={$ok}";
+            if($ok === 0){
+                $this->info($logMsg);
+            }else{
+                $this->error($logMsg);
+            }
+
+            if($ok === 0){
+                Log::debug('mq:discussion: send success {url}',['url'=>$hook->url]);
+                WebHook::where('id',$hook->id)->increment('success');
+            }else{
+                Log::error('mq:discussion: send fail {url}',['url'=>$hook->url]);
+                WebHook::where('id',$hook->id)->increment('fail');
+            }
+        }
+    }
+
+    private function notification($from,$to,$resType,$resId,$channel){
+            //发送站内信
+            try{
+
+                $sendCount = NotificationController::insert(
+                                    $from,
+                                    $to,
+                                    $resType,
+                                    $resId,
+                                    $channel);
+                $this->info("send notification success to [".$sendCount.'] users');
+            }catch(\Exception $e){
+                Log::error('send notification failed',['exception'=>$e]);
+            }
+            return;
+    }
 }