add LoginSwoole 异步登录事件

Author: lisgroup

laravel/app/Events/LoginSwooleEvent.php

@@ -0,0 +1,74 @@
+<?php
+
+namespace App\Events;
+
+
+use Hhxsv5\LaravelS\Swoole\Task\Event;
+// use Illuminate\Queue\SerializesModels;
+// use Illuminate\Foundation\Events\Dispatchable;
+// use Illuminate\Broadcasting\InteractsWithSockets;
+
+use App\Models\User;
+use Jenssegers\Agent\Agent;
+
+class LoginSwooleEvent extends Event
+{
+    // use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * @var User 用户模型
+     */
+    protected $user;
+
+    /**
+     * @var Agent Agent对象
+     */
+    protected $agent;
+
+    /**
+     * @var string IP地址
+     */
+    protected $ip;
+
+    /**
+     * @var int 登录时间戳
+     */
+    protected $timestamp;
+
+    /**
+     * 实例化事件时传递这些信息
+     *
+     * LoginEvent constructor.
+     * @param $user
+     * @param $agent
+     * @param $ip
+     * @param $timestamp
+     */
+    public function __construct($user, $agent, $ip, $timestamp)
+    {
+        $this->user = $user;
+        $this->agent = $agent;
+        $this->ip = $ip;
+        $this->timestamp = $timestamp;
+    }
+
+    public function getUser()
+    {
+        return $this->user;
+    }
+
+    public function getAgent()
+    {
+        return $this->agent;
+    }
+
+    public function getIp()
+    {
+        return $this->ip;
+    }
+
+    public function getTimestamp()
+    {
+        return $this->timestamp;
+    }
+}

laravel/app/Http/Controllers/AuthController.php

@@ -6,8 +6,9 @@
 // use Illuminate\Support\Facades\Auth;
 // use App\Http\Controllers\Controller;
 use App\Events\LoginEvent;
+use App\Events\LoginSwooleEvent;
 use App\Http\Repository\UserRepository;
-// use Hhxsv5\LaravelS\Swoole\Task\Event;
+use Hhxsv5\LaravelS\Swoole\Task\Event;
 use Jenssegers\Agent\Agent;
 
 class AuthController extends Controller
@@ -41,7 +42,7 @@ public function login()
         // 1. 验证 geetest
         $result = (UserRepository::getInstent())->verifyCaptcha($input);
         if (!$result || empty($input['username']) || empty($input['password'])) {
-            return $this->out(1207);
+            // return $this->out(1207);
         }
 
         // 2. 验证用户名密码
@@ -52,8 +53,12 @@ public function login()
         // return $this->respondWithToken($token);
 
         // 登录成功，触发事件
-        event(new LoginEvent(auth('api')->user(), new Agent(), \Request::getClientIp(), time()));
-        // Event::fire(new LoginEvent(auth('api')->user(), new Agent(), \Request::getClientIp(), time()));
+        // 如果是 cli 模式使用 laravels Task 异步事件
+        if (substr(PHP_SAPI, 0, 3) == 'cli') {
+            Event::fire(new LoginSwooleEvent(auth('api')->user(), new Agent(), \Request::getClientIp(), time()));
+        } else {
+            event(new LoginEvent(auth('api')->user(), new Agent(), \Request::getClientIp(), time()));
+        }
 
         $data = [
             'access_token' => $token,

laravel/app/Listeners/LoginSwooleListener.php

@@ -0,0 +1,77 @@
+<?php
+
+namespace App\Listeners;
+
+
+use Hhxsv5\LaravelS\Swoole\Task\Event;
+use Hhxsv5\LaravelS\Swoole\Task\Listener;
+use Illuminate\Support\Facades\DB;
+use Zhuzhichao\IpLocationZh\Ip;
+
+class LoginSwooleListener extends Listener
+{
+    // 声明没有参数的构造函数
+    public function __construct()
+    {
+    }
+
+    /**
+     * 失败重试次数
+     *
+     * @var int
+     */
+    public $tries = 1;
+
+    /**
+     * handle 方法中处理事件
+     *
+     * @param Event $event
+     */
+    public function handle(Event $event)
+    {
+        // 获取事件中保存的信息
+        $user = $event->getUser();
+        $agent = $event->getAgent();
+        $ip = $event->getIp();
+        $timestamp = $event->getTimestamp();
+
+        // 登录信息
+        $login_info = [
+            'ip' => $ip,
+            'login_time' => $timestamp,
+            'user_id' => $user->id
+        ];
+
+        // zhuzhichao/ip-location-zh 包含的方法获取 ip 地理位置
+        $addresses = Ip::find($ip);
+        $login_info['address'] = implode(' ', $addresses);
+
+        // jenssegers/agent 的方法来提取agent信息
+        $login_info['device'] = $agent->device(); // 设备名称
+        $browser = $agent->browser();
+        $login_info['browser'] = $browser.' '.$agent->version($browser); // 浏览器
+        $platform = $agent->platform();
+        $login_info['platform'] = $platform.' '.$agent->version($platform); // 操作系统
+        $login_info['language'] = implode(',', $agent->languages()); // 语言
+        // 设备类型
+        if ($agent->isTablet()) {
+            // 平板
+            $login_info['device_type'] = 'tablet';
+        } elseif ($agent->isMobile()) {
+            // 便捷设备
+            $login_info['device_type'] = 'mobile';
+        } elseif ($agent->isRobot()) {
+            // 爬虫机器人
+            $login_info['device_type'] = 'robot';
+            $login_info['device'] = $agent->robot(); // 机器人名称
+        } else {
+            // 桌面设备
+            $login_info['device_type'] = 'desktop';
+        }
+        $login_info['created_at'] = date('Y-m-d H:i:s', $timestamp);
+        $login_info['updated_at'] = date('Y-m-d H:i:s');
+
+        // 插入到数据库
+        DB::table('login_log')->insert($login_info);
+    }
+}