fix: stabilize cover extraction

backend/app/commands/queue/river.go

@@ -13,7 +13,9 @@ import (
 	"quyun/v2/database"
 	"quyun/v2/providers/app"
 	"quyun/v2/providers/job"
+	"quyun/v2/providers/jwt"
 	"quyun/v2/providers/postgres"
+	"quyun/v2/providers/storage"
 
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
@@ -24,6 +26,8 @@ func defaultProviders() container.Providers {
 	return commands.Default(container.Providers{
 		postgres.DefaultProvider(),
 		job.DefaultProvider(),
+		jwt.DefaultProvider(),
+		storage.DefaultProvider(),
 		database.DefaultProvider(),
 	}...)
 }

backend/app/jobs/media_process_job.go

@@ -53,13 +53,14 @@ func (j *MediaProcessWorker) Work(ctx context.Context, job *river.Job[args.Media
 	}
 
 	// 2. 更新状态为处理中，标识处理已开始。
-	_, err = models.MediaAssetQuery.WithContext(ctx).
-		Where(models.MediaAssetQuery.ID.Eq(asset.ID)).
-		UpdateSimple(
-			models.MediaAssetQuery.Status.Value(consts.MediaAssetStatusProcessing),
-			models.MediaAssetQuery.UpdatedAt.Value(time.Now()),
-		)
-	if err != nil {
+	if err := models.MediaAssetQuery.WithContext(ctx).
+		UnderlyingDB().
+		Model(&models.MediaAsset{}).
+		Where("id = ?", asset.ID).
+		Updates(map[string]any{
+			"status":     consts.MediaAssetStatusProcessing,
+			"updated_at": time.Now(),
+		}).Error; err != nil {
 		return err
 	}
 
@@ -91,9 +92,13 @@ func (j *MediaProcessWorker) Work(ctx context.Context, job *river.Job[args.Media
 					"-i",
 					inputFile,
 					"-ss",
-					"00:00:01.000",
+					"00:00:00.000",
 					"-vframes",
 					"1",
+					"-vf",
+					"format=yuv420p",
+					"-update",
+					"1",
 					coverFile,
 				)
 				if out, err := cmd.CombinedOutput(); err != nil {
@@ -114,13 +119,17 @@ func (j *MediaProcessWorker) Work(ctx context.Context, job *river.Job[args.Media
 	}
 
 	// 4. 更新最终状态。
-	_, err = models.MediaAssetQuery.WithContext(ctx).
-		Where(models.MediaAssetQuery.ID.Eq(asset.ID)).
-		Updates(&models.MediaAsset{
-			Status:    finalStatus,
-			UpdatedAt: time.Now(),
-		})
-	return err
+	if err := models.MediaAssetQuery.WithContext(ctx).
+		UnderlyingDB().
+		Model(&models.MediaAsset{}).
+		Where("id = ?", asset.ID).
+		Updates(map[string]any{
+			"status":     finalStatus,
+			"updated_at": time.Now(),
+		}).Error; err != nil {
+		return err
+	}
+	return nil
 }
 
 func (j *MediaProcessWorker) registerCoverAsset(ctx context.Context, asset *models.MediaAsset, coverFile string) error {

frontend/portal/src/api/common.js

@@ -2,18 +2,35 @@ import { request } from "../utils/request";
 import { getTenantCode } from "../utils/tenant";
 
 export const commonApi = {
+  normalizeUploadType: (type, file) => {
+    const normalized = (type || "").toLowerCase();
+    const mime = (file && file.type) || "";
+
+    if (
+      normalized === "video" ||
+      normalized === "audio" ||
+      normalized === "image"
+    ) {
+      return normalized;
+    }
+    if (mime.startsWith("video/")) return "video";
+    if (mime.startsWith("audio/")) return "audio";
+    return "image";
+  },
   getOptions: () => request("/common/options"),
   checkHash: (hash) => request(`/upload/check?hash=${hash}`),
   deleteMedia: (id) => request(`/media-assets/${id}`, { method: "DELETE" }),
   upload: (file, type) => {
+    const normalizedType = commonApi.normalizeUploadType(type, file);
     const formData = new FormData();
     formData.append("file", file);
-    formData.append("type", type);
+    formData.append("type", normalizedType);
     return request("/upload", { method: "POST", body: formData });
   },
   uploadMultipart: (file, hash, type, onProgress) => {
     const controller = new AbortController();
     const signal = controller.signal;
+    const normalizedType = commonApi.normalizeUploadType(type, file);
 
     const promise = (async () => {
       // 1. Check Hash
@@ -37,7 +54,7 @@ export const commonApi = {
           size: file.size,
           mime_type: file.type,
           hash: hash,
-          type: type,
+          type: normalizedType,
         },
         signal,
       });
@@ -82,11 +99,12 @@ export const commonApi = {
     return { promise, abort: () => controller.abort() };
   },
   uploadWithProgress: (file, type, onProgress) => {
+    const normalizedType = commonApi.normalizeUploadType(type, file);
     let xhr;
     const promise = new Promise((resolve, reject) => {
       const formData = new FormData();
       formData.append("file", file);
-      formData.append("type", type);
+      formData.append("type", normalizedType);
 
       xhr = new XMLHttpRequest();
       const tenantCode = getTenantCode();