fix: 修复工作流执行记录卡在运行中的问题

workflow/service/flow/flow_ws_exec.go

@@ -128,10 +128,11 @@ func handleExecute(ctx context.Context, conn *wsCommon.WsConnection, payload int
 			if r := recover(); r != nil {
 				glog.Errorf(execCtx, "workflow panic: %v", r)
 				execErr = fmt.Errorf("工作流异常: %v", r)
-				// panic 被 recover 吞掉时，正常路径的 recordWorkflow 不会执行，
-				// 在此兜底把失败状态落库，避免 exec_workflow 记录卡在 Running
-				if !recorded && !g.IsEmpty(execId) {
-					recordWorkflow(saveCtx, execId, time.Since(start), execErr)
+				// panic 发生在 executeOrResume 内部（如节点 lambda panic）时，
+				// 多返回值赋值不会完成，此处 execId 可能为 0，需走兜底按会话+流程查最近"运行中"记录标记失败，
+				// 避免 exec_workflow 记录卡在 Running
+				if !recorded {
+					recordExecutionFailure(saveCtx, conn.SessionId, execPayload.FlowId, execId, execErr)
 					recorded = true
 				}
 				_ = writeJSON(conn, &wsCommon.WsPushMsg{Type: "error", Message: "工作流异常", Error: fmt.Sprintf("%v", r)})
@@ -159,6 +160,10 @@ func handleExecute(ctx context.Context, conn *wsCommon.WsConnection, payload int
 			glog.Infof(saveCtx, "工作流执行完成，execId: %v", execId)
 			recordWorkflow(saveCtx, execId, time.Since(start), execErr)
 			recorded = true
+		} else if execErr != nil {
+			// 查询/创建执行记录失败（拿不到 execId）时，兜底把该会话+工作流最近一条"运行中"记录标记为失败
+			recordExecutionFailure(saveCtx, conn.SessionId, execPayload.FlowId, execId, execErr)
+			recorded = true
 		}
 		if execErr != nil {
 			_ = writeJSON(conn, &wsCommon.WsPushMsg{Type: "error", Message: "工作流执行失败", Error: execErr.Error()})
@@ -175,6 +180,26 @@ func handleExecute(ctx context.Context, conn *wsCommon.WsConnection, payload int
 	}()
 }
 
+// recordExecutionFailure 记录一次失败状态。有 execId 直接更新该记录；拿不到 execId
+// （executeOrResume 在创建记录后、返回前 panic，或查询/创建执行记录失败）时，
+// 兜底按会话+工作流查最近一条仍处于"运行中"的记录标记为失败，避免前端已报错但记录卡在 Running。
+// 最近记录已是成功/失败状态则不处理（可能是上一次执行的结果，不应误改）。
+func recordExecutionFailure(ctx context.Context, sessionId string, flowId int64, execId int64, runErr error) {
+	if !g.IsEmpty(execId) {
+		recordWorkflow(ctx, execId, 0, runErr)
+		return
+	}
+	lastExec, err := sessionDao.ExecWorkflowDao.GetLatestBySessionAndFlow(ctx, sessionId, flowId)
+	if err != nil || lastExec == nil {
+		glog.Errorf(ctx, "兜底标记失败状态失败: sessionId=%s flowId=%d err=%v", sessionId, flowId, err)
+		return
+	}
+	if lastExec.Status == nil || *lastExec.Status != *flow.FlowExecutionStatusRunning.Code() {
+		return
+	}
+	recordWorkflow(ctx, lastExec.Id, 0, runErr)
+}
+
 // recordWorkflow 把一次工作流执行写入 exec_workflow/exec_workflow_result：运行记录 + 输出文件结果
 func recordWorkflow(ctx context.Context, id int64, duration time.Duration, runErr error) {
 	// exec_workflow 状态沿用 1-运行中,2-成功,3-失败；前端结果卡片也只识别 1/2/3