From 21ab5b4fc4909e475870d9b6dad267a01613df2b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=9D=99?= <lym125@gmail.com>
Date: Tue, 21 Dec 2021 13:46:17 +0800
Subject: [PATCH] WIP

---
 .../Controllers/Product/ProductSkuController.php |  4 ++--
 .../Viewed.php => ProductSkuViewed.php}          | 15 +++++++++++++--
 app/Listeners/CreateProductViewLog.php           | 16 ++++++++++------
 app/Providers/EventServiceProvider.php           |  2 +-
 4 files changed, 26 insertions(+), 11 deletions(-)
 rename app/Events/{ProductSku/Viewed.php => ProductSkuViewed.php} (63%)

diff --git a/app/Endpoint/Api/Http/Controllers/Product/ProductSkuController.php b/app/Endpoint/Api/Http/Controllers/Product/ProductSkuController.php
index a3a9cab5..283ea5b2 100644
--- a/app/Endpoint/Api/Http/Controllers/Product/ProductSkuController.php
+++ b/app/Endpoint/Api/Http/Controllers/Product/ProductSkuController.php
@@ -5,7 +5,7 @@ namespace App\Endpoint\Api\Http\Controllers\Product;
 use App\Endpoint\Api\Http\Controllers\Controller;
 use App\Endpoint\Api\Http\Resources\ProduckSkuResource;
 use App\Endpoint\Api\Http\Resources\ProductSkuTinyResource;
-use App\Events\ProductSku\Viewed;
+use App\Events\ProductSkuViewed;
 use App\Helpers\Paginator;
 use App\Models\ProductSku;
 use App\Models\ProductSkuFavorite;
@@ -89,7 +89,7 @@ class ProductSkuController extends Controller
             }
         }
 
-        Viewed::dispatch($user, $sku, now());
+        ProductSkuViewed::dispatch($user, $sku, now());
 
         // 是否收藏商品
         $isCollected = (bool) $user?->skuFavorites()->where('sku_id', $sku->id)->exists();
diff --git a/app/Events/ProductSku/Viewed.php b/app/Events/ProductSkuViewed.php
similarity index 63%
rename from app/Events/ProductSku/Viewed.php
rename to app/Events/ProductSkuViewed.php
index 1a906ade..b6658c88 100644
--- a/app/Events/ProductSku/Viewed.php
+++ b/app/Events/ProductSkuViewed.php
@@ -1,14 +1,15 @@
 <?php
 
-namespace App\Events\ProductSku;
+namespace App\Events;
 
 use App\Models\ProductSku;
 use App\Models\User;
+use Illuminate\Broadcasting\PrivateChannel;
 use Illuminate\Foundation\Events\Dispatchable;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Carbon;
 
-class Viewed
+class ProductSkuViewed
 {
     use Dispatchable;
     use SerializesModels;
@@ -24,4 +25,14 @@ class Viewed
         public Carbon $viewedAt,
     ) {
     }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return \Illuminate\Broadcasting\Channel|array
+     */
+    public function broadcastOn()
+    {
+        return new PrivateChannel('channel-name');
+    }
 }
diff --git a/app/Listeners/CreateProductViewLog.php b/app/Listeners/CreateProductViewLog.php
index 9346d765..3c37d819 100644
--- a/app/Listeners/CreateProductViewLog.php
+++ b/app/Listeners/CreateProductViewLog.php
@@ -2,19 +2,23 @@
 
 namespace App\Listeners;
 
-use App\Events\ProductSku\Viewed;
+use App\Events\ProductSkuViewed;
 use App\Models\ProductViewLog;
-use Exception;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Queue\InteractsWithQueue;
+use Throwable;
 
-class CreateProductViewLog
+class CreateProductViewLog implements ShouldQueue
 {
+    use InteractsWithQueue;
+
     /**
      * Handle the event.
      *
-     * @param \App\Events\ProductSku\Viewed $event
+     * @param \App\Events\ProductSkuViewed $event
      * @return void
      */
-    public function handle(Viewed $event)
+    public function handle(ProductSkuViewed $event)
     {
         if ($event->user === null) {
             return;
@@ -28,7 +32,7 @@ class CreateProductViewLog
             ], [
                 'sku_id' => $event->sku->id,
             ]);
-        } catch (Exception $e) {
+        } catch (Throwable $e) {
             report($e);
         }
     }
diff --git a/app/Providers/EventServiceProvider.php b/app/Providers/EventServiceProvider.php
index bc2c05a2..e924056c 100644
--- a/app/Providers/EventServiceProvider.php
+++ b/app/Providers/EventServiceProvider.php
@@ -13,7 +13,7 @@ class EventServiceProvider extends ServiceProvider
      * @var array
      */
     protected $listen = [
-        \App\Events\ProductSku\Viewed::class => [
+        \App\Events\ProductSkuViewed::class => [
             \App\Listeners\CreateProductViewLog::class,
         ],
         \App\Events\OrderPaid::class => [