用户积分及Swoole扩展包

Author: qiang.sun

.phpstorm.meta.php

@@ -3,8 +3,11 @@
 namespace App\Http\Controllers\Auth;
 
 use App\Http\Controllers\Controller;
+use App\User;
+use GuzzleHttp\Client;
 use Illuminate\Foundation\Auth\AuthenticatesUsers;
 use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
 
 class LoginController extends Controller
 {
@@ -62,4 +65,11 @@ public function credentials(Request $request)
         }
         return $credentials;
     }
+
+    public function personal()
+    {
+        $user = User::where('name', '学院君')->first();
+        $token = $user->createToken('Users')->accessToken;
+        dd($token);
+    }
 }

_ide_helper.php

@@ -61,6 +61,9 @@ class Kernel extends HttpKernel
         'signed' => \Illuminate\Routing\Middleware\ValidateSignature::class,
         'throttle' => \Illuminate\Routing\Middleware\ThrottleRequests::class,
         'verified' => \Illuminate\Auth\Middleware\EnsureEmailIsVerified::class,
+        'client' => \Laravel\Passport\Http\Middleware\CheckClientCredentials::class,
+        'scopes' => \Laravel\Passport\Http\Middleware\CheckScopes::class,
+        'scope' => \Laravel\Passport\Http\Middleware\CheckForAnyScope::class,
     ];
 
     /**

app/Http/Controllers/Auth/LoginController.php

@@ -4,6 +4,11 @@
 
 use App\Events\UserDeleted;
 use App\Events\UserDeleting;
+use App\PointLog;
+use Carbon\Carbon;
+use Illuminate\Auth\Events\Login;
+use Illuminate\Auth\Events\Registered;
+use Illuminate\Auth\Events\Verified;
 use Illuminate\Support\Facades\Log;
 
 class UserEventSubscriber
@@ -22,6 +27,65 @@ public function onUserDeleted($event) {
         Log::info('用户已经删除[' . $event->user->id . ']:' . $event->user->name);
     }
 
+    /**
+     * 处理用户注册事件
+     * @param $event
+     */
+    public function onUserRegistered($event) {
+        // 用户注册成功后初始积分为30
+        $event->user->point += PointLog::$OPT_POINT[PointLog::OPT_USER_REGISTER];
+        $event->user->save();
+        // 保存积分变更日志
+        $pointLog = new PointLog();
+        $pointLog->type = PointLog::OPT_USER_REGISTER;
+        $pointLog->value = PointLog::$OPT_POINT[PointLog::OPT_USER_REGISTER];
+        $event->user->pointLogs()->save($pointLog);
+    }
+
+    /**
+     * 处理验证邮箱事件
+     * @param $event
+     */
+    public function onEmailVerified($event) {
+        // 用户验证邮箱后增加20积分
+        $event->user->point += PointLog::$OPT_POINT[PointLog::OPT_EMAIL_VERIFY];
+        $event->user->save();
+        // 保存积分变更日志
+        $pointLog = new PointLog();
+        $pointLog->type = PointLog::OPT_EMAIL_VERIFY;
+        $pointLog->value = PointLog::$OPT_POINT[PointLog::OPT_EMAIL_VERIFY];
+        $event->user->pointLogs()->save($pointLog);
+    }
+
+    /**
+     * 处理用户登录事件
+     * @param $event
+     */
+    public function onUserLogin($event) {
+        $pointLog = PointLog::where('user_id', $event->user->id)->where('type', PointLog::OPT_USER_LOGIN)->orderBy('created_at', 'desc')->first();
+        $firstLoginToday = false;
+        if (!$pointLog) {
+            // 注册后首次登录
+            $firstLoginToday = true;
+        } else {
+            $lastLoginTime = new Carbon($pointLog->created_at);
+            if ($lastLoginTime->isYesterday()) {
+                // 上次登录时间是昨天
+                $firstLoginToday = true;
+            }
+        }
+        if ($firstLoginToday) {
+            // 用户每日首次登录成功后增加5积分
+            $event->user->point += PointLog::$OPT_POINT[PointLog::OPT_USER_LOGIN];
+            $event->user->save();
+            // 保存积分变更日志
+            $pointLog = new PointLog();
+            $pointLog->type = PointLog::OPT_USER_LOGIN;
+            $pointLog->value = PointLog::$OPT_POINT[PointLog::OPT_USER_LOGIN];
+            $event->user->pointLogs()->save($pointLog);
+        }
+    }
+
     /**
      * 为订阅者注册监听器
      *
@@ -38,5 +102,20 @@ public function subscribe($events)
             UserDeleted::class,
             UserEventSubscriber::class . '@onUserDeleted'
         );
+
+        $events->listen(
+            Registered::class,
+            UserEventSubscriber::class . '@onUserRegistered'
+        );
+
+        $events->listen(
+            Verified::class,
+            UserEventSubscriber::class . '@onEmailVerified'
+        );
+
+        $events->listen(
+            Login::class,
+            UserEventSubscriber::class . '@onUserLogin'
+        );
     }
 }

app/Http/Kernel.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App;
+
+use Illuminate\Database\Eloquent\Model;
+
+class PointLog extends Model
+{
+    const OPT_USER_REGISTER = 1;  // 用户注册
+    const OPT_EMAIL_VERIFY = 2;   // 邮箱验证
+    const OPT_USER_LOGIN = 3;     // 用户登录
+
+    // 不同操作对应积分映射关系
+    public static $OPT_POINT = [
+        self::OPT_USER_REGISTER => 30,
+        self::OPT_EMAIL_VERIFY => 20,
+        self::OPT_USER_LOGIN => 5
+    ];
+}

app/Listeners/UserEventSubscriber.php

@@ -33,7 +33,18 @@ public function boot()
             return new EloquentUserProvider($app->make('hash'), $config['model']);
         });
 
+        // OAuth 相关路由
         Passport::routes();
+
+        // 启用隐式授权令牌
+        Passport::enableImplicitGrant();
+
+        // 令牌作用域
+        Passport::tokensCan([
+            'basic-user-info' => '获取用户名、邮箱信息',
+            'all-user-info' => '获取用户所有信息',
+            'get-post-info' => '获取文章详细信息',
+        ]);
     }
 
 }

app/PointLog.php

@@ -4,16 +4,14 @@
 
 use App\Events\UserDeleted;
 use App\Events\UserDeleting;
-use App\Scopes\EmailVerifiedAtScope;
-use Illuminate\Database\Eloquent\Builder;
-use Illuminate\Notifications\Notifiable;
 use Illuminate\Contracts\Auth\MustVerifyEmail;
+use Illuminate\Notifications\Notifiable;
 use Illuminate\Foundation\Auth\User as Authenticatable;
 use Laravel\Passport\HasApiTokens;
 
-class User extends Authenticatable
+class User extends Authenticatable implements MustVerifyEmail
 {
-    use HasApiTokens, Notifiable;
+    use HasApiTokens, Notifiable, \Illuminate\Auth\MustVerifyEmail;
 
     /**
      * The attributes that are mass assignable.
@@ -87,4 +85,9 @@ public function image()
     {
         return $this->morphOne(Image::class, 'imageable');
     }
+
+    public function pointLogs()
+    {
+        return $this->hasMany(PointLog::class);
+    }
 }

app/Providers/AuthServiceProvider.php

@@ -0,0 +1,23 @@
+#!/usr/bin/env bash
+WORK_DIR=$1
+if [ ! -n "${WORK_DIR}" ] ;then
+    WORK_DIR="."
+fi
+
+echo "Restarting LaravelS..."
+./bin/laravels restart -d -i
+
+echo "Starting fswatch..."
+LOCKING=0
+fswatch -e ".*" -i "\\.php$" ${WORK_DIR} | while read file
+do
+    if [ ${LOCKING} -eq 1 ] ;then
+        echo "Reloading, skipped."
+        continue
+    fi
+    echo "File ${file} has been modified."
+    LOCKING=1
+    ./bin/laravels reload
+    LOCKING=0
+done
+exit 0

app/User.php

@@ -0,0 +1,11 @@
+#!/usr/bin/env php
+<?php
+$basePath = realpath(__DIR__ . '/../');
+include $basePath . '/vendor/autoload.php';
+
+$command = new Hhxsv5\LaravelS\Console\Portal($basePath);
+$input = new Symfony\Component\Console\Input\ArgvInput();
+$output = new Symfony\Component\Console\Output\ConsoleOutput();
+
+$code = $command->run($input, $output);
+exit($code);

bin/fswatch

@@ -6,9 +6,11 @@
     "type": "project",
     "require": {
         "php": "^7.1.3",
+        "barryvdh/laravel-ide-helper": "^2.5",
         "doctrine/dbal": "^2.8",
         "fideloper/proxy": "^4.0",
         "garygreen/pretty-routes": "^1.0",
+        "hhxsv5/laravel-s": "~3.3",
         "laravel/framework": "5.7.*",
         "laravel/passport": "^7.0",
         "laravel/tinker": "^1.0",