init

packages/bydauto/src/Jobs/TestdrivePushJob.php

@@ -2,6 +2,7 @@
 
 namespace BYDAuto\Jobs;
 
+use BYDAuto\Models\Activity;
 use BYDAuto\Models\Contact;
 use BYDAuto\Models\Testdrive;
 use BYDAuto\Notifications\TestdirveNotification;
@@ -32,6 +33,14 @@ public function sendNotification()
     {
         $message = new TestdirveNotification($this->model);
         $contacts = Contact::query()->where('status', Contact::STATUS_PUBLISHED)->get();
-        $contacts->each(fn(Contact $contact) => $contact->notify($message));
+        // $contacts->each(fn(Contact $contact) => $contact->notify($message));
+        $contact = $contacts->random();
+        $contact->notify($message);
+        Activity::create([
+            'name' => '试驾通知',
+            'content' => ['testdrive' => $this->model->id, 'contact' => $contact->id],
+            'related_id' => $this->model->id,
+            'related_type' => Testdrive::class,
+        ]);
     }
 }

packages/bydauto/src/Models/Activity.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace BYDAuto\Models;
+
+use Illuminate\Database\Eloquent\Model;
+
+/**
+ * Activity
+ *
+ * @property int id
+ * @property string name
+ * @property array content
+ * @property int related_id
+ * @property string related_type
+ */
+class Activity extends Model
+{
+    public const CREATED_AT = 'date_created';
+    public const UPDATED_AT = 'date_updated';
+    protected $table = 'bydauto_activity';
+    protected $fillable = ['name', 'content', 'related_id', 'related_type'];
+    protected $casts = ['content' => 'json'];
+}