summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorjoonhoekim <26rote@gmail.com>2025-09-04 06:27:06 +0000
committerjoonhoekim <26rote@gmail.com>2025-09-04 06:27:06 +0000
commitb7f54b06c1ef9e619f5358fb0a5caad9703c8905 (patch)
treefdeb8a80bd26f4893881960aa7046b3337dafc4b
parent2d4fc5d4c4fb5136b1a90f374e1090658129c8a5 (diff)
(김준회) 매퍼에서 삭제한 pspid 컬럼이 아닌 code 컬럼을 보도록 변경
-rw-r--r--lib/soap/mdg/mapper/project-mapper.ts10
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);
}
}