From 2cd3f8fad699a61b200d07bbddfe96cb05923314 Mon Sep 17 00:00:00 2001
From: WangLeo <690854599@qq.com>
Date: Tue, 9 Jun 2026 18:09:04 +0800
Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=A7=BB=E9=99=A4=20createTask=20?=
 =?UTF-8?q?=E9=80=8F=E4=BC=A0=E5=B1=82=EF=BC=8CtaskPolling=20=E7=9B=B4?=
 =?UTF-8?q?=E6=8E=A5=E8=AF=BB=20data.body?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/utils/createTask.js  |  5 -----
 src/utils/taskPolling.js | 12 ++++--------
 2 files changed, 4 insertions(+), 13 deletions(-)
 delete mode 100644 src/utils/createTask.js

diff --git a/src/utils/createTask.js b/src/utils/createTask.js
deleted file mode 100644
index 2d47a7d..0000000
--- a/src/utils/createTask.js
+++ /dev/null
@@ -1,5 +0,0 @@
-// 所有平台 descriptor 的 buildTaskBody() 已直接返回扁平 modelParams，
-// 此文件仅做透传，后续可直接移除
-export async function createTask(data) {
-  return data.body
-}
diff --git a/src/utils/taskPolling.js b/src/utils/taskPolling.js
index 627979f..28801e3 100644
--- a/src/utils/taskPolling.js
+++ b/src/utils/taskPolling.js
@@ -1,9 +1,8 @@
 import { ElNotification } from 'element-plus'
 import { h } from 'vue'
-import { useDisplayStore, useUserStore } from '@/stores'
-import { createTask } from '@/utils/createTask'
-import { userError } from '@/utils/tokenError'
 import { requestCreateTask, requestTaskStatus } from '@/apis/display'
+import { useDisplayStore, useUserStore } from '@/stores'
+import { userError } from '@/utils/tokenError'
 
 export function getChargeType(chargeType) {
   switch (chargeType) {
@@ -57,7 +56,6 @@ export function websocketSuccess() {
   })
 }
 
-
 // 当前活跃的轮询定时器集合，用于页面卸载时清理
 const activePollIntervals = new Set()
 
@@ -90,8 +88,7 @@ export async function generate(data, generateData) {
   }
 
   try {
-    // 通过 createTask 获取 body 内容（RunningHub workflow payload）
-    const body = await createTask(data)
+    const body = data.body
 
     // 构造请求体
     const requestBody = {
@@ -140,7 +137,7 @@ export async function generate(data, generateData) {
           useDisplay.isSubGerenate = false
 
           // 提取结果 URL
-          const urls = taskData.outputs?.map(img => img.url) || []
+          const urls = taskData.outputs?.map((img) => img.url) || []
           if (urls.length > 0) {
             useDisplay.updateItemToSuccess(taskId, urls)
             websocketSuccess()
@@ -165,7 +162,6 @@ export async function generate(data, generateData) {
 
     // 5 秒后先做第一次轮询
     setTimeout(pollTask, 5000)
-
   } catch (error) {
     console.error('创建任务失败:', error)
     useDisplay.isSubGerenate = false