Merge branch 'jskim-node' of http://39.117.244.52:3000/kjs/ERP-node into gbpark-node

backend-node/src/services/nodeFlowExecutionService.ts

@@ -2830,12 +2830,12 @@ export class NodeFlowExecutionService {
     inputData: any,
     context: ExecutionContext
   ): Promise<any> {
-    const { conditions, logic } = node.data;
+    const { conditions, logic, targetLookup } = node.data;
 
     logger.info(
       `🔍 조건 노드 실행 - inputData 타입: ${typeof inputData}, 배열 여부: ${Array.isArray(inputData)}, 길이: ${Array.isArray(inputData) ? inputData.length : "N/A"}`
     );
-    logger.info(`🔍 조건 개수: ${conditions?.length || 0}, 로직: ${logic}`);
+    logger.info(`🔍 조건 개수: ${conditions?.length || 0}, 로직: ${logic}, 타겟조회: ${targetLookup ? targetLookup.tableName : "없음"}`);
 
     if (inputData) {
       console.log(
@@ -2865,6 +2865,9 @@ export class NodeFlowExecutionService {
 
       // 배열의 각 항목에 대해 조건 평가 (EXISTS 조건은 비동기)
       for (const item of inputData) {
+        // 타겟 테이블 조회 (DB 기존값 비교용)
+        const targetRow = await this.lookupTargetRow(targetLookup, item, context);
+
         const results: boolean[] = [];
 
         for (const condition of conditions) {
@@ -2887,9 +2890,14 @@ export class NodeFlowExecutionService {
               `🔍 EXISTS 조건: ${condition.field} (${fieldValue}) ${condition.operator} ${condition.lookupTable}.${condition.lookupField} => ${existsResult}`
             );
           } else {
-            // 일반 연산자 처리
+            // 비교값 결정: static(고정값) / field(같은 데이터 내 필드) / target(DB 기존값)
             let compareValue = condition.value;
-            if (condition.valueType === "field") {
+            if (condition.valueType === "target" && targetRow) {
+              compareValue = targetRow[condition.value];
+              logger.info(
+                `🎯 타겟(DB) 비교: ${condition.field} (${fieldValue}) vs DB.${condition.value} (${compareValue})`
+              );
+            } else if (condition.valueType === "field") {
               compareValue = item[condition.value];
               logger.info(
                 `🔄 필드 참조 비교: ${condition.field} (${fieldValue}) vs ${condition.value} (${compareValue})`
@@ -2931,6 +2939,9 @@ export class NodeFlowExecutionService {
     }
 
     // 단일 객체인 경우
+    // 타겟 테이블 조회 (DB 기존값 비교용)
+    const targetRow = await this.lookupTargetRow(targetLookup, inputData, context);
+
     const results: boolean[] = [];
 
     for (const condition of conditions) {
@@ -2953,9 +2964,14 @@ export class NodeFlowExecutionService {
           `🔍 EXISTS 조건: ${condition.field} (${fieldValue}) ${condition.operator} ${condition.lookupTable}.${condition.lookupField} => ${existsResult}`
         );
       } else {
-        // 일반 연산자 처리
+        // 비교값 결정: static(고정값) / field(같은 데이터 내 필드) / target(DB 기존값)
         let compareValue = condition.value;
-        if (condition.valueType === "field") {
+        if (condition.valueType === "target" && targetRow) {
+          compareValue = targetRow[condition.value];
+          logger.info(
+            `🎯 타겟(DB) 비교: ${condition.field} (${fieldValue}) vs DB.${condition.value} (${compareValue})`
+          );
+        } else if (condition.valueType === "field") {
           compareValue = inputData[condition.value];
           logger.info(
             `🔄 필드 참조 비교: ${condition.field} (${fieldValue}) vs ${condition.value} (${compareValue})`
@@ -2990,6 +3006,63 @@ export class NodeFlowExecutionService {
     };
   }
 
+  /**
+   * 조건 노드의 타겟 테이블 조회 (DB 기존값 비교용)
+   * targetLookup 설정이 있을 때, 소스 데이터의 키값으로 DB에서 기존 레코드를 조회
+   */
+  private static async lookupTargetRow(
+    targetLookup: any,
+    sourceRow: any,
+    context: ExecutionContext
+  ): Promise<any | null> {
+    if (!targetLookup?.tableName || !targetLookup?.lookupKeys?.length) {
+      return null;
+    }
+
+    try {
+      const whereConditions = targetLookup.lookupKeys
+        .map((key: any, idx: number) => `"${key.targetField}" = $${idx + 1}`)
+        .join(" AND ");
+
+      const lookupValues = targetLookup.lookupKeys.map(
+        (key: any) => sourceRow[key.sourceField]
+      );
+
+      // 키값이 비어있으면 조회 불필요
+      if (lookupValues.some((v: any) => v === null || v === undefined || v === "")) {
+        logger.info(`⚠️ 조건 노드 타겟 조회: 키값이 비어있어 스킵`);
+        return null;
+      }
+
+      // company_code 필터링 (멀티테넌시)
+      const companyCode = context.buttonContext?.companyCode || sourceRow.company_code;
+      let sql = `SELECT * FROM "${targetLookup.tableName}" WHERE ${whereConditions}`;
+      const params = [...lookupValues];
+
+      if (companyCode && companyCode !== "*") {
+        sql += ` AND company_code = $${params.length + 1}`;
+        params.push(companyCode);
+      }
+
+      sql += " LIMIT 1";
+
+      logger.info(`🎯 조건 노드 타겟 조회: ${targetLookup.tableName}, 조건: ${whereConditions}, 값: ${JSON.stringify(lookupValues)}`);
+
+      const targetRow = await queryOne(sql, params);
+
+      if (targetRow) {
+        logger.info(`🎯 타겟 데이터 조회 성공`);
+      } else {
+        logger.info(`🎯 타겟 데이터 없음 (신규 레코드)`);
+      }
+
+      return targetRow;
+    } catch (error: any) {
+      logger.warn(`⚠️ 조건 노드 타겟 조회 실패: ${error.message}`);
+      return null;
+    }
+  }
+
   /**
    * EXISTS_IN / NOT_EXISTS_IN 조건 평가
    * 다른 테이블에 값이 존재하는지 확인