From b7f54b06c1ef9e619f5358fb0a5caad9703c8905 Mon Sep 17 00:00:00 2001
From: joonhoekim <26rote@gmail.com>
Date: Thu, 4 Sep 2025 06:27:06 +0000
Subject: (김준회) 매퍼에서 삭제한 pspid 컬럼이 아닌 code 컬럼을 보도록 변경
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/soap/mdg/mapper/project-mapper.ts | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

(limited to 'lib')

diff --git a/lib/soap/mdg/mapper/project-mapper.ts b/lib/soap/mdg/mapper/project-mapper.ts
index 43238731..de189047 100644
--- a/lib/soap/mdg/mapper/project-mapper.ts
+++ b/lib/soap/mdg/mapper/project-mapper.ts
@@ -203,12 +203,12 @@ async function saveProjectsToDatabase(mappedProjects: ProjectData[]): Promise<vo
     await db.transaction(async (tx) => {
       // 기존 데이터와 중복 체크 및 UPSERT
       for (const project of mappedProjects) {
-        if (project.pspid) {
-          // pspid가 있는 경우 기존 데이터 확인
+        if (project.code) {
+          // code가 있는 경우 기존 데이터 확인
           const existingProject = await tx
             .select({ id: projects.id })
             .from(projects)
-            .where(eq(projects.pspid, project.pspid))
+            .where(eq(projects.code, project.code))
             .limit(1);
 
           if (existingProject.length > 0) {
@@ -297,13 +297,13 @@ async function saveProjectsToDatabase(mappedProjects: ProjectData[]): Promise<vo
                 WP_PROJ_TP: project.WP_PROJ_TP,
                 updatedAt: new Date(),
               })
-              .where(eq(projects.pspid, project.pspid));
+              .where(eq(projects.code, project.code));
           } else {
             // 새 데이터 삽입
             await tx.insert(projects).values(project);
           }
         } else {
-          // pspid가 없는 경우 새 데이터 삽입
+          // code가 없는 경우 새 데이터 삽입
           await tx.insert(projects).values(project);
         }
       }
-- 
cgit v1.2.3