From 656f1c2ebd6508449f5a28fdfc996d6077758e89 Mon Sep 17 00:00:00 2001
From: dohyeons <ddhhss0603@gmail.com>
Date: Tue, 21 Oct 2025 15:25:05 +0900
Subject: [PATCH] =?UTF-8?q?=ED=85=8C=EC=9D=B4=EB=B8=94=20=EB=B3=80?=
 =?UTF-8?q?=EA=B2=BD=20=EC=9D=B4=EB=A0=A5=20=EB=A1=9C=EA=B7=B8=EC=97=90=20?=
 =?UTF-8?q?ip=5Faddress=EC=99=80=20=EB=B3=80=EA=B2=BD=EC=9E=90=20=EC=BB=AC?=
 =?UTF-8?q?=EB=9F=BC=20=EA=B8=B0=EB=A1=9D=20=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/controllers/dynamicFormController.ts  | 10 +++++++++-
 .../src/services/dynamicFormService.ts        | 19 ++++++++++++++++---
 2 files changed, 25 insertions(+), 4 deletions(-)

diff --git a/backend-node/src/controllers/dynamicFormController.ts b/backend-node/src/controllers/dynamicFormController.ts
index bc3e6f52..a5b2f225 100644
--- a/backend-node/src/controllers/dynamicFormController.ts
+++ b/backend-node/src/controllers/dynamicFormController.ts
@@ -36,10 +36,18 @@ export const saveFormData = async (
       formDataWithMeta.company_code = companyCode;
     }
 
+    // 클라이언트 IP 주소 추출
+    const ipAddress =
+      req.ip ||
+      (req.headers["x-forwarded-for"] as string) ||
+      req.socket.remoteAddress ||
+      "unknown";
+
     const result = await dynamicFormService.saveFormData(
       screenId,
       tableName,
-      formDataWithMeta
+      formDataWithMeta,
+      ipAddress
     );
 
     res.json({
diff --git a/backend-node/src/services/dynamicFormService.ts b/backend-node/src/services/dynamicFormService.ts
index 331f980e..999ea6d2 100644
--- a/backend-node/src/services/dynamicFormService.ts
+++ b/backend-node/src/services/dynamicFormService.ts
@@ -1,4 +1,4 @@
-import { query, queryOne } from "../database/db";
+import { query, queryOne, transaction } from "../database/db";
 import { EventTriggerService } from "./eventTriggerService";
 import { DataflowControlService } from "./dataflowControlService";
 
@@ -203,7 +203,8 @@ export class DynamicFormService {
   async saveFormData(
     screenId: number,
     tableName: string,
-    data: Record<string, any>
+    data: Record<string, any>,
+    ipAddress?: string
   ): Promise<FormDataResult> {
     try {
       console.log("💾 서비스: 실제 테이블에 폼 데이터 저장 시작:", {
@@ -432,7 +433,19 @@ export class DynamicFormService {
       console.log("📝 실행할 UPSERT SQL:", upsertQuery);
       console.log("📊 SQL 파라미터:", values);
 
-      const result = await query<any>(upsertQuery, values);
+      // 로그 트리거를 위한 세션 변수 설정 및 UPSERT 실행 (트랜잭션 내에서)
+      const userId = data.updated_by || data.created_by || "system";
+      const clientIp = ipAddress || "unknown";
+
+      const result = await transaction(async (client) => {
+        // 세션 변수 설정
+        await client.query(`SET LOCAL app.user_id = '${userId}'`);
+        await client.query(`SET LOCAL app.ip_address = '${clientIp}'`);
+
+        // UPSERT 실행
+        const res = await client.query(upsertQuery, values);
+        return res.rows;
+      });
 
       console.log("✅ 서비스: 실제 테이블 저장 성공:", result);