update

app/Console/Commands/ContentFeedCreate.php

@@ -82,11 +82,8 @@ class ContentFeedCreate extends Command
         $callback = function ($msg) {
             $param = \GuzzleHttp\json_decode($msg->body,true);
             $this->line('收到消息'.$msg->body);
-            $row = $this->feedRepositories->feedCreate($param);
-            $this->line('处理消息'.$row);
-            if($row){
-                $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
-            }
+            $this->feedRepositories->contentCreate($param);
+            $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
         };
         $this->channel->basic_qos(null, 1, null);
         $this->channel->basic_consume($this->queue, '', false, false, false, false, $callback);

app/Repositories/FeedRepositories.php

@@ -15,9 +15,10 @@ use Illuminate\Support\Facades\Log;
 
 class FeedRepositories
 {
-    public function __construct(Feed $feed)
+    public function __construct(Feed $feed,PostRepositories $postRepositories)
     {
         $this->feed = $feed;
+        $this->postRepositories = $postRepositories;
     }
 
     public function getFeedType($action)
@@ -33,6 +34,15 @@ class FeedRepositories
         return isset($type[$action]) ? $type[$action] : 0;
     }
 
+    /**
+     *  创建feed流
+     *  更新帖子统计数
+     * @param $request
+     */
+    public function contentCreate($request){
+        $this->feedCreate($request);
+        $this->postRepositories->updatePostData($request);
+    }
 
 
     /**
@@ -61,13 +71,13 @@ class FeedRepositories
                 if(in_array($feedType,[1,2,3])){
                     $data['relate_id'] = $request['post_id'];
                     $content['post_desc'] = $request['post_desc'];
-                }elseif ($feedType==4){
+                }elseif ($feedType==4){//评论
                     $data['relate_id'] = $request['post_id'];
                     $content['post_desc'] = $request['post_desc'];
                     $content['comment_desc'] = $request['comment_content'];
-                }elseif ($feedType==6){
+                }elseif ($feedType==6){//发布
                     $data['relate_id'] = $request['post_id'];
-                }elseif ($feedType==5){
+                }elseif ($feedType==5){//关注
                     $data['relate_id'] = $request['focus_uid'];
                 }
                 $data['content'] = json_encode($content);
@@ -75,6 +85,7 @@ class FeedRepositories
                 $this->feed->insert($data);
             }
         }
+        return true;
     }
 
 

app/Repositories/PostRepositories.php

@@ -110,32 +110,40 @@ class PostRepositories
         if (isset($request['behavior_flag']) && $request['behavior_flag'] == 'read') {
             $post->pv += 1;
             $post->pv_real += 1;
+            Log::debug("帖子：".$postId."被阅读，pv +1");
         } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'unlike') {
             $post->dislike += 1;
+            Log::debug("帖子：".$postId."被不喜欢，unlike +1");
         } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'like') {
             if($request['behavior_value']){
                 $post->praise_count += 1;
                 $post->praise_real_count += 1;
                 PostLike::create(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
+                Log::debug("帖子：".$postId."被点赞，praise_count +1");
             }else{
                 $post->praise_count -= 1;
                 $post->praise_real_count -= 1;
                 PostLike::where(['uid'=>$request['target_id'],'post_id'=>$request['post_id']])->delete();
+                Log::debug("帖子：".$postId."被取消点赞，praise_count -1");
             }
         } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'forward') {
             $post->share_count += 1;
             $post->share_real_count += 1;
+            Log::debug("帖子：".$postId."被分享，share_count +1");
         } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'comment') {
             $post->comment_count += 1;
+            Log::debug("帖子：".$postId."被评论，comment_count +1");
         } elseif (isset($request['behavior_flag']) && $request['behavior_flag'] == 'collect') {
             if($request['behavior_value']) {
                 $post->collect_count += 1;
                 $post->collect_real_count += 1;
                 PostCollect::create(['uid'=>$request['target_id'],'post_id'=>$request['post_id']]);
+                Log::debug("帖子：".$postId."被收藏，collect_count +1");
             }else{
                 $post->collect_count -= 1;
                 $post->collect_real_count -= 1;
                 PostCollect::where(['uid'=>$request['target_id'],'post_id'=>$request['post_id']])->delete();
+                Log::debug("帖子：".$postId."被取消收藏，collect_count -1");
             }
         }
         return $post->save();