diff options
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); } } |