feat(plugins): DashScope Wan3 - 新增 wan3.0 原生视频协议插件

对齐 dashscope-wan-video 风格，支持 media type+url、originPath 与 UNKNOWN 失败映射；序列化 providerOptions 供声明式校验引用。

backend/internal/protocol/dashscope_wan3_video_test.go

@@ -0,0 +1,76 @@
+package protocol
+
+import (
+	"context"
+	"testing"
+)
+
+func TestDashscopeWan3VideoCreateAndLifecycle(t *testing.T) {
+	adapter := officialPackageAdapter(t, "dashscope-wan3-video.yingce-plugin", "dashscope-wan3-video")
+	create, err := adapter.BuildCreate(context.Background(), RequestContext{Request: GenerationRequest{
+		Model: "wan3.0-video-prime", Prompt: "一只猫在海边奔跑", Duration: 6, AspectRatio: "16:9", Resolution: "1080P",
+		GenerateAudio: true, Watermark: true,
+		Inputs: []MediaReference{
+			{URL: "https://cdn.example/audio.mp3", Kind: "audio", Role: "reference_audio", Order: 3},
+			{URL: "https://cdn.example/image.png", Kind: "image", Role: "reference_image", Order: 1},
+			{URL: "https://cdn.example/video.mp4", Kind: "video", Role: "reference_video", Order: 2},
+		},
+		ProviderOptions: map[string]map[string]any{"dashscope-wan3-video": {"seed": 42, "prompt_extend": false}},
+	}})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if create.Method != "POST" || create.Path != "/api/v1/services/aigc/video-generation/video-synthesis" || !create.OriginPath || create.Headers["X-DashScope-Async"] != "enable" {
+		t.Fatalf("create = %#v", create)
+	}
+	body := manifestTestBody(t, create)
+	input, _ := body["input"].(map[string]any)
+	media, _ := input["media"].([]any)
+	if input["prompt"] != "一只猫在海边奔跑" || len(media) != 3 {
+		t.Fatalf("input = %#v", input)
+	}
+	first, _ := media[0].(map[string]any)
+	if first["type"] != "reference_image" || first["url"] != "https://cdn.example/image.png" {
+		t.Fatalf("media[0] = %#v", first)
+	}
+	parameters, _ := body["parameters"].(map[string]any)
+	if parameters["resolution"] != "1080P" || parameters["ratio"] != "16:9" || parameters["duration"] != float64(6) || parameters["audio"] != true || parameters["seed"] != float64(42) || parameters["prompt_extend"] != false {
+		t.Fatalf("parameters = %#v", parameters)
+	}
+
+	keyframes, err := adapter.BuildCreate(context.Background(), RequestContext{Request: GenerationRequest{
+		Model: "wan3.0-video", Prompt: "首尾帧",
+		Images: []MediaReference{
+			{URL: "https://cdn.example/last.png", Role: "last_frame", Order: 2},
+			{URL: "https://cdn.example/first.png", Role: "first_frame", Order: 1},
+		},
+	}})
+	if err != nil {
+		t.Fatal(err)
+	}
+	keyMedia, _ := manifestTestBody(t, keyframes)["input"].(map[string]any)["media"].([]any)
+	if len(keyMedia) != 2 || keyMedia[0].(map[string]any)["type"] != "first_frame" || keyMedia[1].(map[string]any)["type"] != "last_frame" {
+		t.Fatalf("keyframes = %#v", keyMedia)
+	}
+
+	if _, err := adapter.BuildCreate(context.Background(), RequestContext{Request: GenerationRequest{Model: "wan2.2-kf2v-flash", Prompt: "x"}}); err == nil {
+		t.Fatal("unsupported model accepted")
+	}
+
+	created, err := adapter.ParseCreate(context.Background(), []byte(`{"output":{"task_id":"wan3-task-1","task_status":"PENDING"}}`))
+	if err != nil || created.TaskID != "wan3-task-1" || created.Status != StatusPending {
+		t.Fatalf("create result = %#v err=%v", created, err)
+	}
+	poll, err := adapter.BuildPoll(context.Background(), PollContext{TaskID: created.TaskID})
+	if err != nil || poll.Path != "/api/v1/tasks/wan3-task-1" || !poll.OriginPath {
+		t.Fatalf("poll = %#v err=%v", poll, err)
+	}
+	succeeded, err := adapter.ParsePoll(context.Background(), PollContext{TaskID: created.TaskID}, []byte(`{"output":{"task_id":"wan3-task-1","task_status":"SUCCEEDED","video_url":"https://dashscope-result.example/wan3.mp4"},"usage":{"video_count":1}}`))
+	if err != nil || succeeded.Status != StatusSucceeded || len(succeeded.Result.Videos) != 1 || !succeeded.Result.Videos[0].Ephemeral {
+		t.Fatalf("success = %#v err=%v", succeeded, err)
+	}
+	unknown, err := adapter.ParsePoll(context.Background(), PollContext{TaskID: created.TaskID}, []byte(`{"output":{"task_id":"wan3-task-1","task_status":"UNKNOWN"}}`))
+	if err != nil || unknown.Status != StatusFailed {
+		t.Fatalf("unknown = %#v err=%v", unknown, err)
+	}
+}

backend/internal/protocol/manifest.go

@@ -1088,6 +1088,10 @@ func manifestRequestValues(request GenerationRequest) map[string]any {
 	output.GenerateAudio = output.GenerateAudio || request.GenerateAudio
 	output.Watermark = output.Watermark || request.Watermark
 	outputValue, _ := requestAsManifestValue(output)
+	providerOptionsValue, _ := requestAsManifestValue(request.ProviderOptions)
+	if providerOptionsValue == nil {
+		providerOptionsValue = map[string]any{}
+	}
 
 	return map[string]any{
 		"capability":      request.Capability,
@@ -1108,7 +1112,7 @@ func manifestRequestValues(request GenerationRequest) map[string]any {
 		"watermark":       request.Watermark,
 		"operation":       request.Operation,
 		"output":          outputValue,
-		"providerOptions": request.ProviderOptions,
+		"providerOptions": providerOptionsValue,
 		"extra":           request.Extra,
 	}
 }