feat: 智能体对话支持生图/生视频模型-模型名关键词识别类型(chat/image/video,前后端一致),后端generate-media端点:通义万相走DashScope异步任务+轮询(生图text2image/生视频text2video,视频约3分钟超时),OpenAI兼容走images/generations(支持url与b64_json),conversation/media端点追加媒体消息到会话历史;前端助手运行页模型下拉显示🎨/🎬标记,生图/生视频模式下发送自动走媒体生成(自动开启会话记录历史),气泡内渲染图片/视频并带下载/打开按钮,生成中显示加载态,媒体模式隐藏图片上传与结束对话按钮,输入框占位提示动态切换,MdContent支持video标签样式

Co-Authored-By: Claude Code <noreply@anthropic.com>

Author: pythonHuang

Juggle.Api/Controllers/Api/AiController.cs

@@ -362,6 +362,33 @@ public async Task<ApiResult> ConversationChat([FromBody] AiConversationChatReque
         catch (Exception ex) { return ApiResult.Fail(ex.Message); }
     }
 
+    /// <summary>生成图片/视频（生图/生视频模型）。</summary>
+    [HttpPost("generate-media")]
+    public async Task<ApiResult> GenerateMedia([FromBody] AiGenerateMediaRequest req)
+    {
+        try
+        {
+            var result = await _aiService.GenerateMediaAsync(req.ProviderId, req.Model, req.Prompt ?? "");
+            return ApiResult.Success(result);
+        }
+        catch (Exception ex) { return ApiResult.Fail(ex.Message); }
+    }
+
+    /// <summary>追加媒体消息（生图/生视频提问与结果）到会话历史。</summary>
+    [HttpPost("conversation/media")]
+    public async Task<ApiResult> ConversationMedia([FromBody] AiConversationMediaRequest req)
+    {
+        try
+        {
+            var conv = await _db.AiConversations.FirstOrDefaultAsync(c => c.Id == req.ConversationId && c.Deleted == 0)
+                ?? throw new Exception("会话不存在");
+            if (conv.Status == 1) throw new Exception("会话已结束，请开启新对话");
+            await _aiService.AppendMediaMessageAsync(conv, req.UserContent ?? "", req.AssistantContent ?? "");
+            return ApiResult.Success();
+        }
+        catch (Exception ex) { return ApiResult.Fail(ex.Message); }
+    }
+
     /// <summary>结束对话：有输出参数时生成最终结果，会话标记已结束</summary>
     [HttpPost("conversation/end")]
     public async Task<ApiResult> EndConversation([FromBody] AiConversationEndRequest req)
@@ -509,6 +536,20 @@ public class AiOptimizePromptRequest
     public string? Purpose { get; set; }
 }
 
+public class AiGenerateMediaRequest
+{
+    public long ProviderId { get; set; }
+    public string? Model { get; set; }
+    public string? Prompt { get; set; }
+}
+
+public class AiConversationMediaRequest
+{
+    public long ConversationId { get; set; }
+    public string? UserContent { get; set; }
+    public string? AssistantContent { get; set; }
+}
+
 public class AiGenerateIconRequest
 {
     public string? Name { get; set; }

Juggle.Application/Services/Impl/AiService.cs

@@ -1,5 +1,6 @@
 using System.Text;
 using System.Text.Json;
+using System.Text.RegularExpressions;
 using Juggle.Domain.Engine.NodeExecutors;
 using Juggle.Domain.Entities;
 using Juggle.Infrastructure.Persistence;
@@ -272,6 +273,128 @@ public async Task<AiChatResult> ChatRequestAsync(AiChatRequest req)
         return result;
     }
 
+    /// <summary>模型类型识别（chat/image/video，按模型名关键词，与前端 utils/aiModel.ts 保持一致）。</summary>
+    public static string DetectModelKind(string? model)
+    {
+        var m = (model ?? "").ToLower();
+        if (Regex.IsMatch(m, @"(t2v|wanx[^a-z0-9]*video|kling|hailuo|pixverse|pika|cogvideo|minimax[^a-z0-9]*video|sora|veo|mochi|ltx|video)"))
+            return "video";
+        if (Regex.IsMatch(m, @"(wanx|t2i|dall|gpt-image|flux|stable|midjourney|kandinsky|playground|image)"))
+            return "image";
+        return "chat";
+    }
+
+    /// <summary>生成图片/视频（生图/生视频模型）：通义万相走 DashScope 异步任务+轮询，OpenAI 兼容走 images/generations。返回 {type,url}。</summary>
+    public async Task<object> GenerateMediaAsync(long providerId, string? model, string prompt)
+    {
+        var kind = DetectModelKind(model);
+        if (kind == "chat")
+            throw new Exception($"模型「{model}」不是生图/生视频模型");
+
+        var provider = providerId > 0
+            ? await _db.AiProviders.FirstOrDefaultAsync(p => p.Id == providerId && p.Deleted == 0)
+            : null;
+        provider ??= await _db.AiProviders.FirstOrDefaultAsync(p => p.Deleted == 0 && p.Enabled == 1)
+            ?? throw new Exception("未配置 AI 大模型：请在系统设置 → 大模型设置中添加并启用供应商");
+
+        var apiKey = provider.ApiKey ?? "";
+        if (string.IsNullOrEmpty(apiKey))
+            throw new Exception("供应商未配置 API Key");
+        var modelName = string.IsNullOrWhiteSpace(model) ? provider.Model ?? "" : model;
+
+        var client = _httpClientFactory.CreateClient();
+        client.Timeout = TimeSpan.FromSeconds(60);
+
+        // 通义万相（DashScope）：异步任务提交 + 轮询结果
+        if ((provider.BaseUrl ?? "").Contains("dashscope", StringComparison.OrdinalIgnoreCase))
+        {
+            var isVideo = kind == "video";
+            var api = isVideo
+                ? "https://dashscope.aliyuncs.com/api/v1/services/aigc/text2video/video-synthesis"
+                : "https://dashscope.aliyuncs.com/api/v1/services/aigc/text2image/image-synthesis";
+            var body = JsonSerializer.Serialize(new
+            {
+                model = modelName,
+                input = new { prompt },
+                parameters = isVideo ? (object)new { size = "1280*720" } : new { size = "1024*1024", n = 1 }
+            });
+            using var reqMsg = new HttpRequestMessage(HttpMethod.Post, api);
+            reqMsg.Headers.TryAddWithoutValidation("Authorization", $"Bearer {apiKey}");
+            reqMsg.Headers.TryAddWithoutValidation("X-DashScope-Async", "enable");
+            reqMsg.Content = new StringContent(body, Encoding.UTF8, "application/json");
+            using var resp = await client.SendAsync(reqMsg);
+            var respBody = await resp.Content.ReadAsStringAsync();
+            if (!resp.IsSuccessStatusCode)
+                throw new Exception($"{(isVideo ? "视频" : "图片")}生成提交失败({(int)resp.StatusCode}): {Truncate(respBody, 200)}");
+            using var doc = JsonDocument.Parse(respBody);
+            var taskId = doc.RootElement.GetProperty("output").GetProperty("task_id").GetString()
+                ?? throw new Exception("未获取到生成任务 ID");
+
+            // 轮询任务结果（最多约 3 分钟，视频生成较慢）
+            for (var i = 0; i < 90; i++)
+            {
+                await Task.Delay(2000);
+                var taskResp = await client.GetAsync($"https://dashscope.aliyuncs.com/api/v1/tasks/{taskId}");
+                var taskBody = await taskResp.Content.ReadAsStringAsync();
+                using var tdoc = JsonDocument.Parse(taskBody);
+                var root = tdoc.RootElement;
+                var output = root.TryGetProperty("output", out var outEl) ? outEl : default;
+                var status = output.ValueKind == JsonValueKind.Object && output.TryGetProperty("task_status", out var st)
+                    ? st.GetString() : "";
+                if (status == "SUCCEEDED")
+                {
+                    var results = output.GetProperty("results");
+                    var url = results[0].GetProperty("url").GetString();
+                    return new { type = kind, url };
+                }
+                if (status == "FAILED")
+                {
+                    var msg = output.TryGetProperty("message", out var me) ? me.GetString() : "未知错误";
+                    throw new Exception($"生成任务失败: {msg}");
+                }
+            }
+            throw new Exception("生成超时（约 3 分钟），请稍后重试");
+        }
+
+        // OpenAI 兼容 images/generations（仅生图）
+        if (kind == "image")
+        {
+            var baseUrl = provider.BaseUrl!.TrimEnd('/');
+            var url = baseUrl.EndsWith("/images/generations", StringComparison.OrdinalIgnoreCase)
+                ? baseUrl : baseUrl + "/images/generations";
+            var body = JsonSerializer.Serialize(new { model = modelName, prompt, n = 1, size = "1024x1024" });
+            using var reqMsg = new HttpRequestMessage(HttpMethod.Post, url);
+            reqMsg.Headers.TryAddWithoutValidation("Authorization", $"Bearer {apiKey}");
+            reqMsg.Content = new StringContent(body, Encoding.UTF8, "application/json");
+            using var resp = await client.SendAsync(reqMsg);
+            var respBody = await resp.Content.ReadAsStringAsync();
+            if (!resp.IsSuccessStatusCode)
+                throw new Exception($"图片生成失败({(int)resp.StatusCode}): {Truncate(respBody, 200)}");
+            using var doc = JsonDocument.Parse(respBody);
+            var data = doc.RootElement.GetProperty("data")[0];
+            if (data.TryGetProperty("url", out var u) && u.ValueKind == JsonValueKind.String)
+                return new { type = "image", url = u.GetString() };
+            if (data.TryGetProperty("b64_json", out var b64) && b64.ValueKind == JsonValueKind.String)
+                return new { type = "image", url = "data:image/png;base64," + b64.GetString() };
+            throw new Exception("图片生成响应缺少 url/b64_json");
+        }
+
+        throw new Exception("视频生成仅支持通义万相（DashScope）供应商，请添加 dashscope 供应商或将模型切换为通义视频模型");
+    }
+
+    /// <summary>追加媒体消息（生图/生视频的提问与结果）到会话历史。</summary>
+    public async Task AppendMediaMessageAsync(AiConversationEntity conv, string userContent, string assistantContent)
+    {
+        var history = ParseMessages(conv.Messages);
+        history.Add(("user", userContent));
+        history.Add(("assistant", assistantContent));
+        conv.Messages = JsonSerializer.Serialize(history.Select(m => new { role = m.Role, content = m.Content }));
+        if (string.IsNullOrEmpty(conv.Title))
+            conv.Title = userContent.Length > 30 ? userContent[..30] : userContent;
+        conv.UpdatedAt = DateTime.Now.ToString("o");
+        await _db.SaveChangesAsync();
+    }
+
     private static string Truncate(string s, int len) => s.Length <= len ? s : s[..len] + "...";
 
     // ==================== 流程生成 ====================

JuggleNet6.Frontend/src/components/MdContent.vue

@@ -138,6 +138,7 @@ onMounted(render)
 .md-content :deep(p) { margin: 4px 0; }
 .md-content :deep(ul), .md-content :deep(ol) { padding-left: 20px; margin: 4px 0; }
 .md-content :deep(img) { max-width: 100%; border-radius: 6px; }
+.md-content :deep(video) { max-width: 100%; border-radius: 6px; display: block; margin: 6px 0; }
 .md-content :deep(table) { border-collapse: collapse; margin: 6px 0; }
 .md-content :deep(th), .md-content :deep(td) { border: 1px solid #e4e7ed; padding: 4px 8px; font-size: 12px; }
 .md-content :deep(blockquote) { border-left: 3px solid #dcdfe6; margin: 6px 0; padding: 2px 10px; color: #666; }

JuggleNet6.Frontend/src/utils/aiModel.ts

@@ -0,0 +1,16 @@
+/**
+ * 模型类型识别（按模型名关键词）：chat 对话 / image 生图 / video 生视频。
+ * 与后端 AiService.DetectModelKind 保持一致。
+ */
+export function detectModelKind(model?: string): 'chat' | 'image' | 'video' {
+  const m = (model || '').toLowerCase()
+  if (/(t2v|wanx[^a-z0-9]*video|kling|hailuo|pixverse|pika|cogvideo|minimax[^a-z0-9]*video|sora|veo|mochi|ltx|video)/.test(m)) return 'video'
+  if (/(wanx|t2i|dall|gpt-image|flux|stable|midjourney|kandinsky|playground|image)/.test(m)) return 'image'
+  return 'chat'
+}
+
+/** 模型类型标记 emoji（下拉/标签展示用） */
+export function modelKindEmoji(model?: string): string {
+  const kind = detectModelKind(model)
+  return kind === 'image' ? '🎨' : kind === 'video' ? '🎬' : ''
+}

JuggleNet6.Frontend/src/views/ai/AiAssistantList.vue

@@ -111,7 +111,9 @@
                 <el-option v-for="p in aiProviders" :key="p.id" :label="p.providerName" :value="p.id" />
               </el-select>
               <el-select v-model="form.model" size="small" style="flex:1" clearable filterable allow-create default-first-option placeholder="模型(空=供应商默认)">
-                <el-option v-for="m in assistantModelOptions" :key="m" :label="m" :value="m" />
+                <el-option v-for="m in assistantModelOptions" :key="m" :value="m">
+                  <span v-if="modelKindEmoji(m)" style="margin-right:4px">{{ modelKindEmoji(m) }}</span>{{ m }}
+                </el-option>
               </el-select>
             </div>
             <div style="display:flex;align-items:center;gap:8px;margin-bottom:6px">
@@ -189,6 +191,7 @@ import { ElMessage, ElMessageBox } from 'element-plus'
 import request from '../../utils/request'
 import MarketPublishDialog from '../../components/MarketPublishDialog.vue'
 import MarketShareDialog from '../../components/MarketShareDialog.vue'
+import { modelKindEmoji } from '../../utils/aiModel'
 
 // 发布到市场
 const publishVisible = ref(false)