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