:art: formatting

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

@@ -49,36 +49,36 @@ class MqPr extends Command
      */
     public function handle()
     {
-        if(\App\Tools\Tools::isStop()){
+        if (\App\Tools\Tools::isStop()) {
             return 0;
         }
         $exchange = 'router';
         $queue = 'suggestion';
-        $this->info(" [*] Waiting for {$queue}. Ver. ".$this->ver);
-        Log::debug("mq:pr start. ver=".$this->ver);
-        Mq::worker($exchange,$queue,function ($message){
+        $this->info(" [*] Waiting for {$queue}. Ver. " . $this->ver);
+        Log::debug("mq:pr start. ver=" . $this->ver);
+        Mq::worker($exchange, $queue, function ($message) {
             /**生成消息内容 */
 
             $msgTitle = '修改建议';
             $prData = $message->data;
             $sent_num = "{$prData->book}-{$prData->paragraph}-{$prData->word_start}-{$prData->word_end}";
-            $this->info('ver='.$this->ver.' request'.$sent_num);
+            $this->info('ver=' . $this->ver . ' request' . $sent_num);
 
             $username = $prData->editor->nickName;
-            $palitext = PaliSentence::where('book',$prData->book)
-                                ->where('paragraph',$prData->paragraph)
-                                ->where('word_begin',$prData->word_start)
-                                ->where('word_end',$prData->word_end)
-                                ->value('text');
-            $orgText = Sentence::where('book_id',$prData->book)
-                                ->where('paragraph',$prData->paragraph)
-                                ->where('word_start',$prData->word_start)
-                                ->where('word_end',$prData->word_end)
-                                ->where('channel_uid',$prData->channel->id)
-                                ->first();
-            $prtext = mb_substr($prData->content,0,140,"UTF-8");
-
-            $link = config('app.url')."/pcd/article/para/{$prData->book}-{$prData->paragraph}";
+            $palitext = PaliSentence::where('book', $prData->book)
+                ->where('paragraph', $prData->paragraph)
+                ->where('word_begin', $prData->word_start)
+                ->where('word_end', $prData->word_end)
+                ->value('text');
+            $orgText = Sentence::where('book_id', $prData->book)
+                ->where('paragraph', $prData->paragraph)
+                ->where('word_start', $prData->word_start)
+                ->where('word_end', $prData->word_end)
+                ->where('channel_uid', $prData->channel->id)
+                ->first();
+            $prtext = mb_substr($prData->content, 0, 140, "UTF-8");
+
+            $link = config('app.url') . "/pcd/article/para/{$prData->book}-{$prData->paragraph}";
             $link .= "?book={$prData->book}&par={$prData->paragraph}&channel={$prData->channel->id}";
 
             $msgContent = "{$username} 就文句`{$palitext}`提出了修改建议：\n";
@@ -87,73 +87,79 @@ class MqPr extends Command
             $msgContent .= "欢迎大家[点击链接]({$link})查看并讨论。";
 
 
-            $result=0;
+            $result = 0;
             //发送站内信
-            try{
+            try {
                 $sendTo = array();
-                if($prData->editor->id !== $prData->channel->studio_id){
+                if ($prData->editor->id !== $prData->channel->studio_id) {
                     $sendTo[] = $prData->channel->studio_id;
                 }
-                if($orgText){
+                if ($orgText) {
                     //原文作者
-                    if(!in_array($orgText->editor_uid,$sendTo) &&
-                        $orgText->editor_uid !== $prData->editor->id){
+                    if (
+                        !in_array($orgText->editor_uid, $sendTo) &&
+                        $orgText->editor_uid !== $prData->editor->id
+                    ) {
                         $sendTo[] = $orgText->editor_uid;
                     }
                     //原文采纳者
-                    if(!empty($orgText->acceptor_uid) &&
-                       !in_array($orgText->acceptor_uid,$sendTo) &&
-                       $orgText->acceptor_uid !== $prData->editor->id){
+                    if (
+                        !empty($orgText->acceptor_uid) &&
+                        !in_array($orgText->acceptor_uid, $sendTo) &&
+                        $orgText->acceptor_uid !== $prData->editor->id
+                    ) {
                         $sendTo[] = $orgText->acceptor_uid;
                     }
                 }
-                if(count($sendTo) > 0){
-                    $sendCount = NotificationController::insert($prData->editor->id,
-                                                    $sendTo,
-                                                    'suggestion',
-                                                    $prData->uid,
-                                                    $prData->channel->id);
+                if (count($sendTo) > 0) {
+                    $sendCount = NotificationController::insert(
+                        from: $prData->editor->id,
+                        to: $sendTo,
+                        res_type: 'suggestion',
+                        res_id: $prData->uid,
+                        channel: $prData->channel->id
+                    );
                 }
 
-                $this->info("send notification success to [".count($sendTo).'] users');
-            }catch(\Exception $e){
+                $this->info("send notification success to [" . count($sendTo) . '] users');
+            } catch (\Exception $e) {
                 $this->error('send notification failed');
-                Log::error('send notification failed',['exception'=>$e]);
+                Log::error('send notification failed', ['exception' => $e]);
             }
 
             //发送webhook
 
-            $webhooks = WebHook::where('res_id',$prData->channel->id)
-                            ->where('status','active')
-                            ->get();
+            $webhooks = WebHook::where('res_id', $prData->channel->id)
+                ->where('status', 'active')
+                ->get();
 
 
             foreach ($webhooks as $key => $hook) {
                 $event = json_decode($hook->event);
-                if(!in_array('pr',$event)){
+                if (!in_array('pr', $event)) {
                     continue;
                 }
                 $command = '';
                 $whSend = new WebHookSend;
                 switch ($hook->receiver) {
                     case 'dingtalk':
-                        $ok = $whSend->dingtalk($hook->url,$msgTitle,$msgContent);
+                        $ok = $whSend->dingtalk($hook->url, $msgTitle, $msgContent);
                         break;
                     case 'wechat':
-                        $ok = $whSend->wechat($hook->url,null,$msgContent);
+                        $ok = $whSend->wechat($hook->url, null, $msgContent);
                         break;
                     default:
-                        $ok=2;
+                        $ok = 2;
                         break;
                 }
                 $this->info("{$command}  ok={$ok}");
-                $result+=$ok;
-                if($ok === 0){
-                    Log::debug('mq:pr: send success {url}',['url'=>$hook->url]);
-                    WebHook::where('id',$hook->id)->increment('success');
-                }else{
-                    Log::error('mq:pr: send fail {url}',['url'=>$hook->url]);
-                    WebHook::where('id',$hook->id)->increment('fail');
+                $result += $ok;
+                if ($ok === 0) {
+                    Log::debug('mq:pr: send success {url}', ['url' => $hook->url]);
+                    WebHook::where('id', $hook->id)->increment('success');
+                } else {
+                    Log::error('mq:pr: send fail {url}', ['url' => $hook->url]);
+                    WebHook::where('id', $hook->id)->increment('fail');
                 }
             }
             return $result;