访客记录离线处理

Author: xutl

Bootstrap.php

@@ -30,10 +30,8 @@ public function bootstrap($app)
             $app->controllerMap['user'] = [
                 'class' => 'yuncms\user\console\UserController',
             ];
-        }
-        else if ($app->hasModule('user') && ($module = $app->getModule('user')) instanceof Module) {
-             if (class_exists('\xutl\wechat\Application') && $app instanceof \xutl\wechat\Application) {
-                //微信过来的用户
+        } else if ($app->hasModule('user') && ($module = $app->getModule('user')) instanceof Module) {
+            if (class_exists('\xutl\wechat\Application') && $app instanceof \xutl\wechat\Application) {//微信过来的用户
                 Yii::$container->set('yii\web\User', [
                     'enableAutoLogin' => true,
                     'loginUrl' => ['/user/security/login'],
@@ -61,7 +59,7 @@ public function bootstrap($app)
                 /** @var \yii\web\UserEvent $event */
                 $app->on(\yii\web\Application::EVENT_AFTER_REQUEST, function ($event) use ($app) {
                     if (!$app->user->isGuest && Yii::$app->has('queue')) {
-                        Yii::$app->queue->push(new LastVisitJob(['user_id' => $app->user->identity->id,'time'=>time()]));
+                        Yii::$app->queue->push(new LastVisitJob(['user_id' => $app->user->identity->id, 'time' => time()]));
                     }
                 });
             } elseif ($module instanceof \yuncms\user\frontend\Module) {//前台判断放最后
@@ -99,7 +97,7 @@ public function bootstrap($app)
                 $app->on(\yii\web\Application::EVENT_AFTER_REQUEST, function ($event) use ($app) {
                     if (!$app->user->isGuest && Yii::$app->has('queue')) {
                         //记录最后活动时间
-                        Yii::$app->queue->push(new LastVisitJob(['user_id' => $app->user->identity->id,'time'=>time()]));
+                        Yii::$app->queue->push(new LastVisitJob(['user_id' => $app->user->identity->id, 'time' => time()]));
                     }
                 });
             }

frontend/controllers/SpaceController.php

@@ -14,6 +14,7 @@
 use yii\data\ActiveDataProvider;
 use yii\web\Response;
 use yuncms\doing\models\Doing;
+use yuncms\user\jobs\VisitJob;
 use yuncms\user\models\User;
 use yuncms\user\models\Visit;
 use yuncms\tag\models\Tag;
@@ -34,7 +35,7 @@ public function behaviors()
                 'rules' => [
                     [
                         'allow' => true,
-                        'actions' => ['index','tag'],
+                        'actions' => ['index', 'tag'],
                         'roles' => ['@']
                     ],
                     [
@@ -70,16 +71,11 @@ public function actionIndex()
     public function actionShow($slug)
     {
         $model = $this->findModelBySlug($slug);
-        if (!Yii::$app->user->isGuest && Yii::$app->user->id != $model->id) {
-            //记录访客
-            if (($visit = Visit::findOne(['user_id' => Yii::$app->user->id, 'source_id' => $model->id])) == null) {
-                $visit = new Visit(['user_id' => Yii::$app->user->id, 'source_id' => $model->id]);
-                $visit->save(false);
-                //更新访客计数
-                $model->extend->updateCounters(['views' => 1]);
-            } else {
-                $visit->updateAttributes(['updated_at' => time()]);
-            }
+        if (!Yii::$app->user->isGuest && Yii::$app->has('queue')) {
+            Yii::$app->queue->push(new VisitJob([
+                'user_id' => Yii::$app->user->id,
+                'source_id' => $model->id
+            ]));
         }
         $dataProvider = $this->getDoingDataProvider($model->id);
         return $this->render('view', [
@@ -97,16 +93,11 @@ public function actionShow($slug)
     public function actionView($id)
     {
         $model = $this->findModel($id);
-        if (!Yii::$app->user->isGuest && Yii::$app->user->id != $id) {
-            //记录访客
-            if (($visit = Visit::findOne(['user_id' => Yii::$app->user->id, 'source_id' => $id])) == null) {
-                $visit = new Visit(['user_id' => Yii::$app->user->id, 'source_id' => $id]);
-                $visit->save(false);
-                //更新访客计数
-                $model->extend->updateCounters(['views' => 1]);
-            } else {
-                $visit->updateAttributes(['updated_at' => time()]);
-            }
+        if (!Yii::$app->user->isGuest && Yii::$app->has('queue')) {
+            Yii::$app->queue->push(new VisitJob([
+                'user_id' => Yii::$app->user->id,
+                'source_id' => $model->id
+            ]));
         }
 
         $dataProvider = $this->getDoingDataProvider($model->id);

jobs/VisitJob.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace yuncms\user\jobs;
+
+use Yii;
+use yii\base\Object;
+use yii\queue\RetryableJob;
+use yuncms\user\models\User;
+use yuncms\user\models\Visit;
+use yuncms\user\models\Extend;
+
+/**
+ * 记录访客
+ * @package yuncms\user\jobs
+ */
+class VisitJob extends Object implements RetryableJob
+{
+    public $user_id;
+
+    public $source_id;
+
+    /**
+     * @inheritdoc
+     */
+    public function execute($queue)
+    {
+        if ($this->user_id != $this->source_id) {
+            //记录访客
+            if (($visit = Visit::findOne(['user_id' => $this->user_id, 'source_id' => $this->source_id])) == null) {
+                $visit = new Visit(['user_id' => $this->user_id, 'source_id' => $this->source_id]);
+                $visit->save(false);
+                //更新访客计数
+                Extend::updateAllCounters(['views' => 1], ['user_id' => $this->source_id]);
+            } else {
+                $visit->updateAttributes(['updated_at' => time()]);
+            }
+        }
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function getTtr()
+    {
+        return 60;
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function canRetry($attempt, $error)
+    {
+        return $attempt < 3;
+    }
+}