refactor(prompt): 优化任务等待机制并改进数据结构

service/gateway/gateway_http_service.go

@@ -45,7 +45,7 @@ func UploadByTask(ctx context.Context, _ *entity.AsynchTask, data []byte, fileEx
 		return "", err
 	}
 	contentType := writer.FormDataContentType()
-	if err := writer.Close(); err != nil {
+	if err = writer.Close(); err != nil {
 		return "", err
 	}
 

service/task_service.go

@@ -104,7 +104,6 @@ func (s *taskService) Create(ctx context.Context, req *dto.CreateTaskReq) (res *
 	// 4) 创建成功后立即异步尝试执行当前任务，并仅在任务仍处于 pending(state=0) 时做定向轮询。
 	// 一旦任务进入 running/success/failed/downloaded，就停止轮询，避免一直空转。
 	go s.pollAndRunUntilPicked(context.WithoutCancel(ctx), taskID, req.EpicycleId)
-
 	return &dto.CreateTaskRes{TaskID: taskID}, nil
 }
 
@@ -162,7 +161,6 @@ func (s *taskService) pollAndRunUntilPicked(ctx context.Context, taskID string,
 	if stop := tryRun(); stop {
 		return
 	}
-
 	for {
 		select {
 		case <-ctx.Done():