Enhance batch management functionality by adding node flow execution support and improving batch configuration creation. Introduce new API endpoint for retrieving node flows and update existing batch services to handle execution types. Update frontend components to support new scheduling options and node flow selection.

backend-node/src/services/batchSchedulerService.ts

@@ -122,20 +122,22 @@ export class BatchSchedulerService {
   }
 
   /**
-   * 배치 설정 실행
+   * 배치 설정 실행 - execution_type에 따라 매핑 또는 노드 플로우 실행
    */
   static async executeBatchConfig(config: any) {
     const startTime = new Date();
     let executionLog: any = null;
 
     try {
-      logger.info(`배치 실행 시작: ${config.batch_name} (ID: ${config.id})`);
+      logger.info(`배치 실행 시작: ${config.batch_name} (ID: ${config.id}, type: ${config.execution_type || "mapping"})`);
 
-      // 매핑 정보가 없으면 상세 조회로 다시 가져오기
-      if (!config.batch_mappings || config.batch_mappings.length === 0) {
-        const fullConfig = await BatchService.getBatchConfigById(config.id);
-        if (fullConfig.success && fullConfig.data) {
-          config = fullConfig.data;
+      // 상세 조회 (매핑 또는 노드플로우 정보가 없을 수 있음)
+      if (!config.execution_type || config.execution_type === "mapping") {
+        if (!config.batch_mappings || config.batch_mappings.length === 0) {
+          const fullConfig = await BatchService.getBatchConfigById(config.id);
+          if (fullConfig.success && fullConfig.data) {
+            config = fullConfig.data;
+          }
         }
       }
 
@@ -165,12 +167,17 @@ export class BatchSchedulerService {
 
       executionLog = executionLogResponse.data;
 
-      // 실제 배치 실행 로직 (수동 실행과 동일한 로직 사용)
-      const result = await this.executeBatchMappings(config);
+      let result: { totalRecords: number; successRecords: number; failedRecords: number };
+
+      if (config.execution_type === "node_flow") {
+        result = await this.executeNodeFlow(config);
+      } else {
+        result = await this.executeBatchMappings(config);
+      }
 
       // 실행 로그 업데이트 (성공)
       await BatchExecutionLogService.updateExecutionLog(executionLog.id, {
-        execution_status: "SUCCESS",
+        execution_status: result.failedRecords > 0 ? "PARTIAL" : "SUCCESS",
         end_time: new Date(),
         duration_ms: Date.now() - startTime.getTime(),
         total_records: result.totalRecords,
@@ -182,12 +189,10 @@ export class BatchSchedulerService {
         `배치 실행 완료: ${config.batch_name} (처리된 레코드: ${result.totalRecords})`
       );
 
-      // 성공 결과 반환
       return result;
     } catch (error) {
       logger.error(`배치 실행 중 오류 발생: ${config.batch_name}`, error);
 
-      // 실행 로그 업데이트 (실패)
       if (executionLog) {
         await BatchExecutionLogService.updateExecutionLog(executionLog.id, {
           execution_status: "FAILED",
@@ -198,7 +203,6 @@ export class BatchSchedulerService {
         });
       }
 
-      // 실패 결과 반환
       return {
         totalRecords: 0,
         successRecords: 0,
@@ -207,6 +211,43 @@ export class BatchSchedulerService {
     }
   }
 
+  /**
+   * 노드 플로우 실행 - NodeFlowExecutionService에 위임
+   */
+  private static async executeNodeFlow(config: any) {
+    if (!config.node_flow_id) {
+      throw new Error("노드 플로우 ID가 설정되지 않았습니다.");
+    }
+
+    const { NodeFlowExecutionService } = await import(
+      "./nodeFlowExecutionService"
+    );
+
+    const contextData: Record<string, any> = {
+      companyCode: config.company_code,
+      batchConfigId: config.id,
+      batchName: config.batch_name,
+      executionSource: "batch_scheduler",
+      ...(config.node_flow_context || {}),
+    };
+
+    logger.info(
+      `노드 플로우 실행: flowId=${config.node_flow_id}, batch=${config.batch_name}`
+    );
+
+    const flowResult = await NodeFlowExecutionService.executeFlow(
+      config.node_flow_id,
+      contextData
+    );
+
+    // 노드 플로우 실행 결과를 배치 로그 형식으로 변환
+    return {
+      totalRecords: flowResult.summary.total,
+      successRecords: flowResult.summary.success,
+      failedRecords: flowResult.summary.failed,
+    };
+  }
+
   /**
    * 배치 매핑 실행 (수동 실행과 동일한 로직)
    */