支持主动导入弹幕

app/Http/Controllers/DanmakuConstructController.php

@@ -0,0 +1,71 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use App\Models\VideoDanmakus;
+use App\Models\Videos;
+use App\Util\DanmakuUtil;
+use Illuminate\Http\Request;
+use Illuminate\Routing\Controller as BaseController;
+use Illuminate\Support\Facades\DB;
+
+class DanmakuConstructController extends BaseController
+{
+    public function page(Request $request)
+    {
+        $view = view("danmaku.construct.batch_import");
+        if ($request->has("video_bvid")) {
+            $bvid = $request->get("video_bvid");
+            $video = Videos::query()->where("bvid", "=", $bvid)->first();
+            if ($video == null) {
+                $view->withErrors([
+                    "video_bvid" => "系统无此对应视频",
+                ]);
+            } else {
+                $request->session()->flashInput([
+                    "video_bvid" => $bvid
+                ]);
+            }
+        }
+        return $view;
+    }
+
+    public function do_import(Request $request)
+    {
+        $request->validate([
+            'video_bvid' => ['required'],
+            'platform_id' => ['required', 'int'],
+            'file' => ['required']
+        ]);
+        $payload = $request->only(["video_bvid", "platform_id"]);
+        $files = $request->file("file");
+        if (!is_array($files)) {
+            $files = [$files];
+        }
+        $video = Videos::query()->where("bvid", "=", $payload["video_bvid"])->first();
+        if ($video == null) {
+            return back()->withInput()->withErrors([
+                "video_bvid" => "系统无此对应视频",
+            ]);
+        }
+        foreach ($files as $file) {
+            $danmakus = DanmakuUtil::parse_danmaku($file->getFileInfo());
+            DB::beginTransaction();
+            try {
+                foreach ($danmakus as &$danmaku) {
+                    $danmaku['video_bvid'] = $video->bvid;
+                    $danmaku['platform_id'] = $payload["platform_id"];
+                    unset($danmaku);
+                }
+                VideoDanmakus::insert($danmakus);
+                DB::commit();
+            } catch (\Exception $e) {
+                DB::rollBack();
+                return back()->withInput()->withErrors([
+                    "file" => "文件导入异常：" . $e->getMessage(),
+                ]);
+            }
+        }
+        return redirect("/danmakus/" . $payload["video_bvid"]);
+    }
+}

app/Models/VideoDanmakus.php

@@ -6,8 +6,14 @@ use Illuminate\Database\Eloquent\Model;
 
 class VideoDanmakus extends Model
 {
+    protected $guarded = [];
     protected $table = "video_danmakus";
     protected $dateFormat = 'U';
+    public $timestamps = false;
+    protected $casts = [
+        'created_at' => 'datetime:Y-m-d H:i:s',
+    ];
+    protected $fillable = ["from", "from_mid", "content"];
     public function video(): \Illuminate\Database\Eloquent\Relations\BelongsTo
     {
         return $this->belongsTo(Videos::class, "video_bvid", "bvid");

app/Util/DanmakuUtil.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace App\Util;
+
+use SplFileInfo;
+
+class DanmakuUtil
+{
+    public static function parse_danmaku(SplFileInfo $file): array
+    {
+        $document = new \DOMDocument();
+        $document->load($file->getRealPath());
+        $danmaku_items = $document->getElementsByTagName("d");
+        $result = [];
+        /** @var \DOMNode $item */
+        foreach ($danmaku_items as $item) {
+            $paramsNode = $item->attributes->getNamedItem("p");
+            $param_list = mb_split(",", $paramsNode->value);
+            if (sizeof($param_list) < 7) {
+                throw new \Exception("弹幕格式异常");
+            }
+            $userNode = $item->attributes->getNamedItem("user");
+            $result[] = [
+                "from" => $userNode->value,
+                "from_mid" => $param_list[6],
+                "content" => $item->textContent,
+                "created_at" => intval($param_list[4])/1000,
+            ];
+        }
+        return $result;
+    }
+}