feat(rpa): add browser close option for formal runs

Author: lius-new

plugins/pages/rpa-workflow/src/api/index.ts

@@ -66,6 +66,10 @@ export interface RpaTaskInputVariable {
   required: boolean;
 }
 
+export interface RpaTaskRunOptions {
+  closeBrowserOnComplete: boolean;
+}
+
 export interface PaginatedRpaTaskList {
   items: RpaTask[];
   total: number;
@@ -140,6 +144,7 @@ interface StoredWorkflowMetaVariable {
 interface StoredWorkflowMeta {
   start_step_id?: string | null;
   global_variables?: StoredWorkflowMetaVariable[];
+  close_browser_on_complete?: boolean;
 }
 
 function normalizeStatus(status: string): RpaTask['status'] {
@@ -351,6 +356,14 @@ export function extractTaskInputVariables(detail: RpaTaskDetailDto): RpaTaskInpu
     .filter((variable) => variable.name && variable.promptOnRun);
 }
 
+export function extractTaskRunOptions(detail: RpaTaskDetailDto): RpaTaskRunOptions {
+  const workflowMeta = extractStoredWorkflowMeta(detail);
+
+  return {
+    closeBrowserOnComplete: workflowMeta?.close_browser_on_complete === true,
+  };
+}
+
 export function extractWorkflowSchema(detail: RpaTaskDetailDto): RpaWorkflowSchema | null {
   const tags = toStringArray(detail.task.tags);
   const orderedSteps = [...detail.steps].sort(

plugins/pages/rpa-workflow/src/components/task-editor/index.tsx

@@ -74,6 +74,7 @@ function createDefaultTaskConfig(): TaskConfig {
     timeout: 300,
     concurrency: 1,
     stopOnError: true,
+    closeBrowserOnComplete: false,
     notifyOnComplete: false,
     notifyOnError: false,
   };

plugins/pages/rpa-workflow/src/components/task-editor/task-settings-form.tsx

@@ -45,6 +45,7 @@ export interface TaskConfig {
   timeout: number;
   concurrency: number;
   stopOnError: boolean;
+  closeBrowserOnComplete: boolean;
   notifyOnComplete: boolean;
   notifyOnError: boolean;
 }
@@ -215,6 +216,7 @@ export function TaskSettingsForm({ config, onConfigChange }: TaskSettingsFormPro
     `超时 ${config.timeout}s`,
     `重试 ${config.retryCount} 次`,
     config.stopOnError ? '出错即停止' : '允许继续执行',
+    config.closeBrowserOnComplete ? '结束后关闭浏览器' : '结束后保留浏览器',
   ].join(' · ');
 
   return (
@@ -474,6 +476,12 @@ export function TaskSettingsForm({ config, onConfigChange }: TaskSettingsFormPro
                         checked={config.stopOnError}
                         onCheckedChange={(value) => handleChange('stopOnError', value)}
                       />
+                      <StrategySwitch
+                        label="结束后关闭浏览器"
+                        description="仅影响正式执行。启用后，任务执行完成会自动关闭本次启动的浏览器。"
+                        checked={config.closeBrowserOnComplete}
+                        onCheckedChange={(value) => handleChange('closeBrowserOnComplete', value)}
+                      />
                       <StrategySwitch
                         label="完成时通知"
                         description="任务完成后发送通知。"

plugins/pages/rpa-workflow/src/components/task-editor/workflow-mapper.ts

@@ -44,6 +44,7 @@ interface StoredWorkflowMeta {
     prompt_on_run?: boolean;
     required?: boolean;
   }>;
+  close_browser_on_complete?: boolean;
   start_position?: {
     x?: number;
     y?: number;
@@ -450,6 +451,7 @@ export function buildTaskPayload(
               required: variable.promptOnRun === true && variable.required === true,
             }))
             .filter((variable) => variable.name),
+          close_browser_on_complete: config.closeBrowserOnComplete === true,
           start_position: specialPositions.start,
           end_position: specialPositions.end,
         },
@@ -514,13 +516,14 @@ export function mapTaskDetailToEditorState(detail: RpaTaskDetailDto): EditorStat
     runMode: detail.task.run_mode === 'parallel' ? 'parallel' : 'sequential',
     globalVariables: storedGlobalVariables,
     retryCount: detail.task.retry_count ?? 3,
-    retryInterval: detail.task.retry_interval ?? 5,
-    timeout: detail.task.timeout ?? 300,
-    concurrency: detail.task.concurrency ?? 1,
-    stopOnError: detail.task.stop_on_error ?? true,
-    notifyOnComplete: detail.task.notify_on_complete ?? false,
-    notifyOnError: detail.task.notify_on_error ?? true,
-  };
+    retryInterval: detail.task.retry_interval ?? 5,
+    timeout: detail.task.timeout ?? 300,
+    concurrency: detail.task.concurrency ?? 1,
+    stopOnError: detail.task.stop_on_error ?? true,
+    closeBrowserOnComplete: storedWorkflowMeta?.close_browser_on_complete === true,
+    notifyOnComplete: detail.task.notify_on_complete ?? false,
+    notifyOnError: detail.task.notify_on_error ?? true,
+  };
 
   return {
     config,
@@ -610,6 +613,7 @@ export function mapPortableTaskToEditorState(document: PortableRpaTaskDocument):
     timeout: document.task.timeout ?? 300,
     concurrency: document.task.concurrency ?? 1,
     stopOnError: document.task.stop_on_error ?? true,
+    closeBrowserOnComplete: storedWorkflowMeta?.close_browser_on_complete === true,
     notifyOnComplete: document.task.notify_on_complete ?? false,
     notifyOnError: document.task.notify_on_error ?? true,
   };

plugins/pages/rpa-workflow/src/hooks/use-rpa-execution.ts

@@ -1,6 +1,11 @@
 import { useCallback, useMemo, useRef, useState } from 'react';
 import { toast } from 'sonner';
-import { extractWorkflowSchema, getRpaTaskDetail, type RpaTaskDetailDto } from '../api';
+import {
+  extractTaskRunOptions,
+  extractWorkflowSchema,
+  getRpaTaskDetail,
+  type RpaTaskDetailDto,
+} from '../api';
 import type { RpaTask, RpaWorkflowStep } from '../types';
 import { RpaRunner } from '../runtime/runner';
 import { CdpBrowserAdapter } from '../runtime/cdp-browser-adapter';
@@ -230,6 +235,7 @@ export function useRpaExecution(params: UseRpaExecutionParams): UseRpaExecutionR
       toast.error('任务流程数据无效');
       return;
     }
+    const runOptions = extractTaskRunOptions(pendingExecution.detail);
 
     if (!pendingExecution.detail.environment_uuids?.length) {
       toast.error('请先绑定环境后再执行');
@@ -368,7 +374,7 @@ export function useRpaExecution(params: UseRpaExecutionParams): UseRpaExecutionR
             break;
           }
         } finally {
-          if (startedByRuntime) {
+          if (startedByRuntime && runOptions.closeBrowserOnComplete) {
             await stopEnvironmentRuntime(envUuid).catch(() => undefined);
           }
         }