refactor: 移除 createTask 透传层,taskPolling 直接读 data.body
This commit is contained in:
parent
fe1ce00f66
commit
2cd3f8fad6
@ -1,5 +0,0 @@
|
|||||||
// 所有平台 descriptor 的 buildTaskBody() 已直接返回扁平 modelParams,
|
|
||||||
// 此文件仅做透传,后续可直接移除
|
|
||||||
export async function createTask(data) {
|
|
||||||
return data.body
|
|
||||||
}
|
|
||||||
@ -1,9 +1,8 @@
|
|||||||
import { ElNotification } from 'element-plus'
|
import { ElNotification } from 'element-plus'
|
||||||
import { h } from 'vue'
|
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 { requestCreateTask, requestTaskStatus } from '@/apis/display'
|
||||||
|
import { useDisplayStore, useUserStore } from '@/stores'
|
||||||
|
import { userError } from '@/utils/tokenError'
|
||||||
|
|
||||||
export function getChargeType(chargeType) {
|
export function getChargeType(chargeType) {
|
||||||
switch (chargeType) {
|
switch (chargeType) {
|
||||||
@ -57,7 +56,6 @@ export function websocketSuccess() {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// 当前活跃的轮询定时器集合,用于页面卸载时清理
|
// 当前活跃的轮询定时器集合,用于页面卸载时清理
|
||||||
const activePollIntervals = new Set()
|
const activePollIntervals = new Set()
|
||||||
|
|
||||||
@ -90,8 +88,7 @@ export async function generate(data, generateData) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// 通过 createTask 获取 body 内容(RunningHub workflow payload)
|
const body = data.body
|
||||||
const body = await createTask(data)
|
|
||||||
|
|
||||||
// 构造请求体
|
// 构造请求体
|
||||||
const requestBody = {
|
const requestBody = {
|
||||||
@ -140,7 +137,7 @@ export async function generate(data, generateData) {
|
|||||||
useDisplay.isSubGerenate = false
|
useDisplay.isSubGerenate = false
|
||||||
|
|
||||||
// 提取结果 URL
|
// 提取结果 URL
|
||||||
const urls = taskData.outputs?.map(img => img.url) || []
|
const urls = taskData.outputs?.map((img) => img.url) || []
|
||||||
if (urls.length > 0) {
|
if (urls.length > 0) {
|
||||||
useDisplay.updateItemToSuccess(taskId, urls)
|
useDisplay.updateItemToSuccess(taskId, urls)
|
||||||
websocketSuccess()
|
websocketSuccess()
|
||||||
@ -165,7 +162,6 @@ export async function generate(data, generateData) {
|
|||||||
|
|
||||||
// 5 秒后先做第一次轮询
|
// 5 秒后先做第一次轮询
|
||||||
setTimeout(pollTask, 5000)
|
setTimeout(pollTask, 5000)
|
||||||
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error('创建任务失败:', error)
|
console.error('创建任务失败:', error)
|
||||||
useDisplay.isSubGerenate = false
|
useDisplay.isSubGerenate = false
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user