diff options
| author | joonhoekim <26rote@gmail.com> | 2025-09-04 06:27:06 +0000 |
|---|---|---|
| committer | joonhoekim <26rote@gmail.com> | 2025-09-04 06:27:06 +0000 |
| commit | b7f54b06c1ef9e619f5358fb0a5caad9703c8905 (patch) | |
| tree | fdeb8a80bd26f4893881960aa7046b3337dafc4b /lib | |
| parent | 2d4fc5d4c4fb5136b1a90f374e1090658129c8a5 (diff) | |
(김준회) 매퍼에서 삭제한 pspid 컬럼이 아닌 code 컬럼을 보도록 변경
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/soap/mdg/mapper/project-mapper.ts | 10 |
1 files changed, 5 insertions, 5 deletions
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); } } |
