summaryrefslogtreecommitdiff
path: root/lib/soap/mdg/mapper
diff options
context:
space:
mode:
Diffstat (limited to 'lib/soap/mdg/mapper')
-rw-r--r--lib/soap/mdg/mapper/project-mapper.ts171
1 files changed, 159 insertions, 12 deletions
diff --git a/lib/soap/mdg/mapper/project-mapper.ts b/lib/soap/mdg/mapper/project-mapper.ts
index 6de2b38a..43238731 100644
--- a/lib/soap/mdg/mapper/project-mapper.ts
+++ b/lib/soap/mdg/mapper/project-mapper.ts
@@ -76,14 +76,7 @@ export async function mapAndSaveMDGProjectData(
/**
* MDG 프로젝트 데이터를 비즈니스 테이블 projects 구조로 변환
- *
- id: serial("id").primaryKey(), << 자동
- code: varchar("code", { length: 50 }).notNull(),
- name: text("name").notNull(),
- type: varchar("type", { length: 20 }).default("ship").notNull(),
- pspid: char('pspid', { length: 24 }).unique(), // 프로젝트ID (ECC), TODO: 매핑 필요
- createdAt: timestamp("created_at").defaultNow().notNull(),
- updatedAt: timestamp("updated_at").defaultNow().notNull(),
+ * 모든 MDG 컬럼을 비즈니스 테이블에 매핑
*/
function mapMDGToProject(mdgProject: MDGProjectData): ProjectData | null {
try {
@@ -93,16 +86,94 @@ function mapMDGToProject(mdgProject: MDGProjectData): ProjectData | null {
return null;
}
- // 현재는 기본 구조만 제공
+ // MDG의 모든 컬럼을 비즈니스 테이블에 매핑
const mappedProject: ProjectData = {
+ // 기존 매핑 컬럼들
code: mdgProject.PROJ_NO || '',
name: mdgProject.PROJ_DSC || '',
type: checkProjectType(mdgProject.TYPE || ''), // 기본값, 필요시 매핑 로직 추가
// type 매핑 방법: TYPE 네임스페이스에서 null 값을 수신한 경우 조선(ship)이고, 그 외는 해양(plant)이다.
// 수신할 수 있는 경우의 수는 H, T, H/T, null 인데, 필요시 hull / top 구분 처리하자. 현재는 조선/해양 구분만 필요하고, 기존 코드들도 plant 값인지 ship 값인지만 따지고 있다.
// 의미상으로는 H = 해양 Hull, T = 해양 Top, H/T = 해양 Hull과 Top 둘 다 하는 프로젝트 인데, 일단은 조선/해양 구분만 ship/plant 값을 넣어주는 것으로 하자.
- // TODO: pspid를 구해야 하는데 mdg에서 안주는 것 같음. 나프로에게 문의함.
- pspid: mdgProject.PROJ_NO || null, // ECC 프로젝트 ID와 연결
+
+ // MDG의 모든 컬럼 매핑 (그대로 수신)
+ AS_GRNT_PRD: mdgProject.AS_GRNT_PRD || null,
+ BIZCLS: mdgProject.BIZCLS || null,
+ BIZLOC_CD: mdgProject.BIZLOC_CD || null,
+ BIZ_DMN: mdgProject.BIZ_DMN || null,
+ BP_DL_DT: mdgProject.BP_DL_DT || null,
+ CHN_PROJ_TP: mdgProject.CHN_PROJ_TP || null,
+ CLS_1: mdgProject.CLS_1 || null,
+ CLS_2: mdgProject.CLS_2 || null,
+ CNRT_CNTN_YN: mdgProject.CNRT_CNTN_YN || null,
+ CNRT_DL_DT: mdgProject.CNRT_DL_DT || null,
+ CNRT_DT: mdgProject.CNRT_DT || null,
+ CNRT_RESV_YN: mdgProject.CNRT_RESV_YN || null,
+ CO_CD: mdgProject.CO_CD || null,
+ CSTM_PO_NO: mdgProject.CSTM_PO_NO || null,
+ DEL_YN: mdgProject.DEL_YN || null,
+ DIGT_PDT_GRP: mdgProject.DIGT_PDT_GRP || null,
+ DIST_PATH: mdgProject.DIST_PATH || null,
+ DL_BF_PROJ_NM: mdgProject.DL_BF_PROJ_NM || null,
+ DL_CSTM_CD: mdgProject.DL_CSTM_CD || null,
+ DOCK_CD: mdgProject.DOCK_CD || null,
+ DSN_CHRGR: mdgProject.DSN_CHRGR || null,
+ FIN_GRNT_FN_DT: mdgProject.FIN_GRNT_FN_DT || null,
+ GENT_CNT: mdgProject.GENT_CNT || null,
+ GOV: mdgProject.GOV || null,
+ GRNT_STDT: mdgProject.GRNT_STDT || null,
+ IF_STAT: mdgProject.IF_STAT || null,
+ IMO_NO: mdgProject.IMO_NO || null,
+ INQY_NO: mdgProject.INQY_NO || null,
+ INQY_SEQ: mdgProject.INQY_SEQ || null,
+ IO_GB: mdgProject.IO_GB || null,
+ MNG_ACOT_DMN: mdgProject.MNG_ACOT_DMN || null,
+ MN_ENGN_TP_CD: mdgProject.MN_ENGN_TP_CD || null,
+ MSHIP_NO: mdgProject.MSHIP_NO || null,
+ NEW_MC_YN: mdgProject.NEW_MC_YN || null,
+ NTTP: mdgProject.NTTP || null,
+ ORDR_GRNT_FN_DT: mdgProject.ORDR_GRNT_FN_DT || null,
+ ORDR_GRNT_PRD: mdgProject.ORDR_GRNT_PRD || null,
+ OWN_1: mdgProject.OWN_1 || null,
+ OWN_AB: mdgProject.OWN_AB || null,
+ OWN_NM: mdgProject.OWN_NM || null,
+ PDT_LVL_4: mdgProject.PDT_LVL_4 || null,
+ PLNT_CD: mdgProject.PLNT_CD || null,
+ PRCTR: mdgProject.PRCTR || null,
+ PRGS_STAT: mdgProject.PRGS_STAT || null,
+ PROJ_CRTE_REQ_DT: mdgProject.PROJ_CRTE_REQ_DT || null,
+ PROJ_CRTE_REQ_EMPNO: mdgProject.PROJ_CRTE_REQ_EMPNO || null,
+ PROJ_DL_PLN_DT: mdgProject.PROJ_DL_PLN_DT || null,
+ PROJ_DL_RT_DT: mdgProject.PROJ_DL_RT_DT || null,
+ PROJ_DTL_TP: mdgProject.PROJ_DTL_TP || null,
+ PROJ_ETC_TP: mdgProject.PROJ_ETC_TP || null,
+ PROJ_GB: mdgProject.PROJ_GB || null,
+ PROJ_PRGS_YN: mdgProject.PROJ_PRGS_YN || null,
+ PROJ_PROF: mdgProject.PROJ_PROF || null,
+ PROJ_SCP: mdgProject.PROJ_SCP || null,
+ PROJ_WBS_TP: mdgProject.PROJ_WBS_TP || null,
+ PRO_PROJ_NO: mdgProject.PRO_PROJ_NO || null,
+ QM_CLS: mdgProject.QM_CLS || null,
+ REF_NO: mdgProject.REF_NO || null,
+ RLTD_PROJ: mdgProject.RLTD_PROJ || null,
+ RL_DL_DT: mdgProject.RL_DL_DT || null,
+ SALE_GRP: mdgProject.SALE_GRP || null,
+ SALE_ORG_CD: mdgProject.SALE_ORG_CD || null,
+ SA_DT: mdgProject.SA_DT || null,
+ SERS_NO: mdgProject.SERS_NO || null,
+ SERS_YN: mdgProject.SERS_YN || null,
+ SHTYPE: mdgProject.SHTYPE || null,
+ SHTYPE_CD: mdgProject.SHTYPE_CD || null,
+ SHTYPE_GRP: mdgProject.SHTYPE_GRP || null,
+ SHTYPE_UOM: mdgProject.SHTYPE_UOM || null,
+ SKND: mdgProject.SKND || null,
+ SRC_SYS_ID: mdgProject.SRC_SYS_ID || null,
+ STDT: mdgProject.STDT || null,
+ SYS_ACOT_CLSD_DT: mdgProject.SYS_ACOT_CLSD_DT || null,
+ TOT_CNRT_CNT: mdgProject.TOT_CNRT_CNT || null,
+ TYPE: mdgProject.TYPE || null, // 원본 TYPE 컬럼
+ WP_PROJ_TP: mdgProject.WP_PROJ_TP || null,
+
// id, createdAt, updatedAt는 자동 생성
};
@@ -141,13 +212,89 @@ async function saveProjectsToDatabase(mappedProjects: ProjectData[]): Promise<vo
.limit(1);
if (existingProject.length > 0) {
- // 기존 데이터 업데이트
+ // 기존 데이터 업데이트 - 모든 MDG 컬럼 포함
await tx
.update(projects)
.set({
code: project.code,
name: project.name,
type: project.type,
+ AS_GRNT_PRD: project.AS_GRNT_PRD,
+ BIZCLS: project.BIZCLS,
+ BIZLOC_CD: project.BIZLOC_CD,
+ BIZ_DMN: project.BIZ_DMN,
+ BP_DL_DT: project.BP_DL_DT,
+ CHN_PROJ_TP: project.CHN_PROJ_TP,
+ CLS_1: project.CLS_1,
+ CLS_2: project.CLS_2,
+ CNRT_CNTN_YN: project.CNRT_CNTN_YN,
+ CNRT_DL_DT: project.CNRT_DL_DT,
+ CNRT_DT: project.CNRT_DT,
+ CNRT_RESV_YN: project.CNRT_RESV_YN,
+ CO_CD: project.CO_CD,
+ CSTM_PO_NO: project.CSTM_PO_NO,
+ DEL_YN: project.DEL_YN,
+ DIGT_PDT_GRP: project.DIGT_PDT_GRP,
+ DIST_PATH: project.DIST_PATH,
+ DL_BF_PROJ_NM: project.DL_BF_PROJ_NM,
+ DL_CSTM_CD: project.DL_CSTM_CD,
+ DOCK_CD: project.DOCK_CD,
+ DSN_CHRGR: project.DSN_CHRGR,
+ FIN_GRNT_FN_DT: project.FIN_GRNT_FN_DT,
+ GENT_CNT: project.GENT_CNT,
+ GOV: project.GOV,
+ GRNT_STDT: project.GRNT_STDT,
+ IF_STAT: project.IF_STAT,
+ IMO_NO: project.IMO_NO,
+ INQY_NO: project.INQY_NO,
+ INQY_SEQ: project.INQY_SEQ,
+ IO_GB: project.IO_GB,
+ MNG_ACOT_DMN: project.MNG_ACOT_DMN,
+ MN_ENGN_TP_CD: project.MN_ENGN_TP_CD,
+ MSHIP_NO: project.MSHIP_NO,
+ NEW_MC_YN: project.NEW_MC_YN,
+ NTTP: project.NTTP,
+ ORDR_GRNT_FN_DT: project.ORDR_GRNT_FN_DT,
+ ORDR_GRNT_PRD: project.ORDR_GRNT_PRD,
+ OWN_1: project.OWN_1,
+ OWN_AB: project.OWN_AB,
+ OWN_NM: project.OWN_NM,
+ PDT_LVL_4: project.PDT_LVL_4,
+ PLNT_CD: project.PLNT_CD,
+ PRCTR: project.PRCTR,
+ PRGS_STAT: project.PRGS_STAT,
+ PROJ_CRTE_REQ_DT: project.PROJ_CRTE_REQ_DT,
+ PROJ_CRTE_REQ_EMPNO: project.PROJ_CRTE_REQ_EMPNO,
+ PROJ_DL_PLN_DT: project.PROJ_DL_PLN_DT,
+ PROJ_DL_RT_DT: project.PROJ_DL_RT_DT,
+ PROJ_DTL_TP: project.PROJ_DTL_TP,
+ PROJ_ETC_TP: project.PROJ_ETC_TP,
+ PROJ_GB: project.PROJ_GB,
+ PROJ_PRGS_YN: project.PROJ_PRGS_YN,
+ PROJ_PROF: project.PROJ_PROF,
+ PROJ_SCP: project.PROJ_SCP,
+ PROJ_WBS_TP: project.PROJ_WBS_TP,
+ PRO_PROJ_NO: project.PRO_PROJ_NO,
+ QM_CLS: project.QM_CLS,
+ REF_NO: project.REF_NO,
+ RLTD_PROJ: project.RLTD_PROJ,
+ RL_DL_DT: project.RL_DL_DT,
+ SALE_GRP: project.SALE_GRP,
+ SALE_ORG_CD: project.SALE_ORG_CD,
+ SA_DT: project.SA_DT,
+ SERS_NO: project.SERS_NO,
+ SERS_YN: project.SERS_YN,
+ SHTYPE: project.SHTYPE,
+ SHTYPE_CD: project.SHTYPE_CD,
+ SHTYPE_GRP: project.SHTYPE_GRP,
+ SHTYPE_UOM: project.SHTYPE_UOM,
+ SKND: project.SKND,
+ SRC_SYS_ID: project.SRC_SYS_ID,
+ STDT: project.STDT,
+ SYS_ACOT_CLSD_DT: project.SYS_ACOT_CLSD_DT,
+ TOT_CNRT_CNT: project.TOT_CNRT_CNT,
+ TYPE: project.TYPE,
+ WP_PROJ_TP: project.WP_PROJ_TP,
updatedAt: new Date(),
})
.where(eq(projects.pspid, project.pspid));
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-07 22:48:20 +0000