(김준회) ECC I/F 관련 작업

- ECC 인터페이스 수신테이블 notNull 조건 제거 (테스트 데이터 문제)
- 수신 라우트의 구조 불일치 문제 처리

3 files changed, 86 insertions, 68 deletions

diff --git a/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts b/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts
index c2b9db46..6b882852 100644
--- a/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts
+++ b/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts
@@ -88,14 +88,18 @@ export async function POST(request: NextRequest) {
     async () => {
       console.log('🚀 PO_INFORMATION 수신 시작, 데이터 길이:', body.length);
 
-      // 1) XML 파싱
-      const parser = createXMLParser(['T_HD', 'T_DT', 'T_PAY', 'T_KN', 'T_NOTE', 'T_NOTE2']);
+      // 1) XML 파싱 - 실제 XML 구조에 맞게 수정
+      const parser = createXMLParser(['ZMM_HD', 'ZMM_DT', 'ZMM_PAY', 'ZMM_KN', 'ZMM_NOTE', 'ZMM_NOTE2']);
       const parsedData = parser.parse(body);
+      console.log('🔍 파싱된 XML 데이터 구조:', JSON.stringify(parsedData, null, 2));
 
       // 2) SOAP Body 또는 루트에서 요청 데이터 추출
       const requestData = extractRequestData(parsedData, 'IF_ECC_EVCP_PO_INFORMATIONReq');
+      console.log('🔍 추출된 요청 데이터:', JSON.stringify(requestData, null, 2));
+      
       if (!requestData) {
         console.error('유효한 요청 데이터를 찾을 수 없습니다');
+        console.error('파싱된 데이터 키들:', Object.keys(parsedData));
         throw new Error('Missing request data - IF_ECC_EVCP_PO_INFORMATIONReq not found');
       }
 
@@ -149,55 +153,68 @@ export async function POST(request: NextRequest) {
 // 데이터 변환 및 저장 관련 유틸리티
 // -----------------------------------------------------------------------------
 
-// Root XML Request 타입
+// Root XML Request 타입 - 실제 XML 구조에 맞게 수정
 type PORequestXML = {
   CHG_GB?: string;
-  T_HD?: HeaderXML[];
-  T_DT?: DetailXML[];
-  T_PAY?: PaymentXML[];
-  T_KN?: AccountXML[];
-  T_NOTE?: NoteXML[];
-  T_NOTE2?: Note2XML[];
+  ZMM_HD?: HeaderXML[];
+  ZMM_DT?: DetailXML[];
+  ZMM_PAY?: PaymentXML[];
+  ZMM_KN?: AccountXML[];
+  ZMM_NOTE?: NoteXML[];
+  ZMM_NOTE2?: Note2XML[];
 };
 
-// XML -> DB 데이터 변환 함수
+// XML -> DB 데이터 변환 함수 - 중첩 구조 처리
 function transformPOData(requestData: PORequestXML): ProcessedPOData[] {
-  const headers = requestData.T_HD || [];
-  const details = requestData.T_DT || [];
-  const payments = requestData.T_PAY || [];
-  const accounts = requestData.T_KN || [];
-  const notes = requestData.T_NOTE || [];
-  const notes2 = requestData.T_NOTE2 || [];
+  console.log('🔍 변환할 요청 데이터:', JSON.stringify(requestData, null, 2));
+  
+  const headers = requestData.ZMM_HD || [];
+  console.log(`📊 처리할 Header 수: ${headers.length}`);
 
   return headers.map((header) => {
     const headerKey = header.EBELN || '';
     const fkData = { EBELN: headerKey };
-
-    // Header 변환
+    console.log(`📦 처리 중인 Header: ${headerKey}`);
+
+    // Header 변환 (ZMM_DT, ZMM_NOTE, ZMM_NOTE2 필드 제외)
+    const headerFields = { ...header };
+    delete (headerFields as any).ZMM_DT;
+    delete (headerFields as any).ZMM_NOTE;
+    delete (headerFields as any).ZMM_NOTE2;
+    
     const headerConverted = convertXMLToDBData<HeaderData>(
-      header as Record<string, string | undefined>,
-      undefined // Header는 자체 필드만 사용
+      headerFields as Record<string, string | undefined>,
+      undefined
     );
 
-    // 해당 Header의 Detail들 필터 후 변환 (ZMM_KN도 함께 처리)
-    const relatedDetails = details.filter((detail) => detail.EBELN === headerKey);
-    const detailsWithAccounts: DetailWithAccounts[] = relatedDetails.map((detail) => {
+    // Header 내부의 중첩된 ZMM_DT 처리
+    const detailsFromHeader = (header as any).ZMM_DT || [];
+    console.log(`📋 ${headerKey}의 Detail 수: ${detailsFromHeader.length}`);
+    
+    const detailsWithAccounts: DetailWithAccounts[] = detailsFromHeader.map((detail: any) => {
       const detailKey = detail.EBELP || '';
       const detailFkData = { EBELN: headerKey, EBELP: detailKey };
+      console.log(`📄 처리 중인 Detail: ${headerKey}-${detailKey}`);
 
-      // Detail 변환
+      // Detail 변환 (ZMM_KN 필드 제외)
+      const detailFields = { ...detail };
+      delete detailFields.ZMM_KN;
+      
       const detailConverted = convertXMLToDBData<DetailData>(
-        detail as Record<string, string | undefined>, 
+        detailFields as Record<string, string | undefined>, 
         fkData
       );
 
-      // 해당 Detail의 Account들 필터 후 변환 (EBELN + EBELP로 매칭)
-      const relatedAccounts = accounts.filter(
-        (account) => account.EBELN === headerKey && account.EBELP === detailKey
-      );
+      // Detail 내부의 중첩된 ZMM_KN 처리
+      const accountsFromDetail = detail.ZMM_KN || [];
+      console.log(`💳 ${headerKey}-${detailKey}의 Account 수: ${Array.isArray(accountsFromDetail) ? accountsFromDetail.length : (accountsFromDetail ? 1 : 0)}`);
+      
+      // ZMM_KN이 배열이 아닌 경우 배열로 변환
+      const accountsArray = Array.isArray(accountsFromDetail) ? accountsFromDetail : (accountsFromDetail ? [accountsFromDetail] : []);
+      
       const accountsConverted = processNestedArray(
-        relatedAccounts,
-        (account) =>
+        accountsArray,
+        (account: any) =>
           convertXMLToDBData<AccountData>(account as Record<string, string | undefined>, detailFkData),
         detailFkData
       );
@@ -212,40 +229,41 @@ function transformPOData(requestData: PORequestXML): ProcessedPOData[] {
     const detailsConverted = detailsWithAccounts.map(d => d.detail);
     const allAccountsConverted = detailsWithAccounts.flatMap(d => d.accounts);
 
-    // 해당 Header의 Payment들 필터 후 변환
-    const relatedPayments = payments.filter((payment) => payment.EBELN === headerKey);
-    const paymentsConverted = processNestedArray(
-      relatedPayments,
-      (payment) =>
-        convertXMLToDBData<PaymentData>(payment as Record<string, string | undefined>, fkData),
-      fkData
-    );
-
-    // 해당 Header의 Note들 필터 후 변환
-    const relatedNotes = notes.filter((note) => note.EBELN === headerKey);
+    // Header 내부의 중첩된 ZMM_NOTE 처리
+    const notesFromHeader = (header as any).ZMM_NOTE || [];
+    console.log(`📝 ${headerKey}의 Note 수: ${Array.isArray(notesFromHeader) ? notesFromHeader.length : (notesFromHeader ? 1 : 0)}`);
+    
+    const notesArray = Array.isArray(notesFromHeader) ? notesFromHeader : (notesFromHeader ? [notesFromHeader] : []);
     const notesConverted = processNestedArray(
-      relatedNotes,
-      (note) =>
+      notesArray,
+      (note: any) =>
         convertXMLToDBData<NoteData>(note as Record<string, string | undefined>, fkData),
       fkData
     );
 
-    // 해당 Header의 Note2들 필터 후 변환
-    const relatedNotes2 = notes2.filter((note2) => note2.EBELN === headerKey);
+    // Header 내부의 중첩된 ZMM_NOTE2 처리
+    const notes2FromHeader = (header as any).ZMM_NOTE2 || [];
+    console.log(`📝 ${headerKey}의 Note2 수: ${Array.isArray(notes2FromHeader) ? notes2FromHeader.length : (notes2FromHeader ? 1 : 0)}`);
+    
+    const notes2Array = Array.isArray(notes2FromHeader) ? notes2FromHeader : (notes2FromHeader ? [notes2FromHeader] : []);
     const notes2Converted = processNestedArray(
-      relatedNotes2,
-      (note2) =>
+      notes2Array,
+      (note2: any) =>
         convertXMLToDBData<Note2Data>(note2 as Record<string, string | undefined>, fkData),
       fkData
     );
 
+    // ZMM_PAY는 별도 처리 (현재 XML에는 없지만 구조상 유지)
+    const paymentsConverted: PaymentData[] = [];
+
+    console.log(`✅ ${headerKey} 변환 완료 - Details: ${detailsConverted.length}, Accounts: ${allAccountsConverted.length}, Notes: ${notesConverted.length}, Notes2: ${notes2Converted.length}`);
+
     return {
       header: headerConverted,
       details: detailsConverted,
       payments: paymentsConverted,
       notes: notesConverted,
       notes2: notes2Converted,
-      // accounts는 이제 detail과 함께 처리되므로 별도로 저장하지 않음
       accounts: allAccountsConverted,
     };
   });
diff --git a/db/schema/ECC/ecc.ts b/db/schema/ECC/ecc.ts
index af726678..4d4198c7 100644
--- a/db/schema/ECC/ecc.ts
+++ b/db/schema/ECC/ecc.ts
@@ -22,7 +22,7 @@ export const PR_INFORMATION_T_BID_HEADER = ECCSchema.table(
     EKGRP: varchar({ length: 10 }), // Purchaing Group // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
     EKORG: varchar({ length: 10 }), // Purchasing Organization // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
     WERKS: varchar({ length: 10 }), // Plant // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
-    ZBSART: varchar({ length: 10 }).notNull(), // Bidding // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
+    ZBSART: varchar({ length: 10 }), // Bidding // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
     ZRFQ_TRS_DT: varchar({ length: 10 }), // Date on Creating Bidding // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
     ZRFQ_TRS_TM: varchar({ length: 10 }), // Time of Creating Bidding // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
 
@@ -37,10 +37,10 @@ export const PR_INFORMATION_T_BID_ITEM = ECCSchema.table(
   {
     id: integer('id').primaryKey().generatedByDefaultAsIdentity(),
     ANFNR: varchar({ length: 10 }).notNull().references(() => PR_INFORMATION_T_BID_HEADER.ANFNR), // Bidding/RFQ Number // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
-    ANFPS: varchar({ length: 10 }).notNull(), // Item Number of Bidding // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
+    ANFPS: varchar({ length: 10 }), // Item Number of Bidding // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
     AUFNR: varchar({ length: 12 }), // Order Number // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
-    BANFN: varchar({ length: 10 }).notNull(), // Purchase Requisition Number // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
-    BANPO: varchar({ length: 10 }).notNull(), // Item Number of Purchase Requisition // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
+    BANFN: varchar({ length: 10 }), // Purchase Requisition Number // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
+    BANPO: varchar({ length: 10 }), // Item Number of Purchase Requisition // From: IF_ECC_EVCP_PR_INFORMATION.wsdl // Required
     BPRME: varchar({ length: 10 }), // Order Price Unit (Purchasing) // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
     BRGEW: decimal({ precision: 15, scale: 3 }), // Gross Weight // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
     DISMM: varchar({ length: 10 }), // MRP Type // From: IF_ECC_EVCP_PR_INFORMATION.wsdl
@@ -87,19 +87,19 @@ export const ZMM_PCR = ECCSchema.table('ZMM_PCR', {
   // 2,ZMM_PCR,PCR_REQ_SEQ,M,NUMC,5,PCR 요청순번
   PCR_REQ_SEQ: varchar({ length: 255 }).notNull(),
   // 3,ZMM_PCR,PCR_REQ_DATE,M,DATS,8,PCR 요청일자
-  PCR_REQ_DATE: varchar({ length: 255 }).notNull(),
+  PCR_REQ_DATE: varchar({ length: 255 }),
   // 4,ZMM_PCR,EBELN,M,CHAR,10,구매오더
-  EBELN: varchar({ length: 255 }).notNull(),
+  EBELN: varchar({ length: 255 }),
   // 5,ZMM_PCR,EBELP,M,NUMC,5,구매오더 품번
-  EBELP: varchar({ length: 255 }).notNull(),
+  EBELP: varchar({ length: 255 }),
   // 6,ZMM_PCR,PCR_TYPE,M,CHAR,2,"물량/Spec 변경 Type : Q, W, S, QW"
-  PCR_TYPE: varchar({ length: 255 }).notNull(),
+  PCR_TYPE: varchar({ length: 255 }),
   // 7,ZMM_PCR,PSPID,,CHAR,24,프로젝트
   PSPID: varchar({ length: 255 }),
   // 8,ZMM_PCR,BANFN,M,CHAR,10,구매요청
-  BANFN: varchar({ length: 255 }).notNull(),
+  BANFN: varchar({ length: 255 }),
   // 9,ZMM_PCR,BNFPO,M,NUMC,5,구매요청 품번
-  BNFPO: varchar({ length: 255 }).notNull(),
+  BNFPO: varchar({ length: 255 }),
   // 10,ZMM_PCR,MATNR,,CHAR,18,자재번호
   MATNR: varchar({ length: 255 }),
   // 11,ZMM_PCR,MAKTX,,CHAR,40,자재명
@@ -358,7 +358,7 @@ export const ZMM_PAY = ECCSchema.table('ZMM_PAY', {
   EBELN: varchar({ length: 255 }).notNull().references(() => ZMM_HD.EBELN),
 
   // 69,ZMM_HD/ZMM_PAY,ZPAYSEQ,M,CHAR,2,선급금차수
-  ZPAYSEQ: varchar({ length: 255 }).notNull(),
+  ZPAYSEQ: varchar({ length: 255 }),
   // 70,ZMM_HD/ZMM_PAY,ZADVTYP,M,CHAR,1,선급금타입
   ZADVTYP: varchar({ length: 255 }),
   // 71,ZMM_HD/ZMM_PAY,ZDWPRT,M,NUMC,3,선급금비율
@@ -632,9 +632,9 @@ export const ZMM_NOTE = ECCSchema.table('ZMM_NOTE', {
   EBELN: varchar({ length: 255 }).notNull().references(() => ZMM_HD.EBELN),
 
   // 187,ZMM_HD/ZMM_NOTE,ZNOTE_SER,M,NUMC,4,발주 Note 순번
-  ZNOTE_SER: varchar({ length: 255 }).notNull(),
+  ZNOTE_SER: varchar({ length: 255 }),
   // 188,ZMM_HD/ZMM_NOTE,ZNOTE_TXT,M,CHAR,4000,발주 Note Text
-  ZNOTE_TXT: varchar({ length: 10000 }).notNull(),
+  ZNOTE_TXT: varchar({ length: 10000 }),
 
   createdAt: timestamp('created_at').defaultNow().notNull(),
   updatedAt: timestamp('updated_at').defaultNow().notNull(),
@@ -649,9 +649,9 @@ export const ZMM_NOTE2 = ECCSchema.table('ZMM_NOTE2', {
   EBELN: varchar({ length: 255 }).notNull().references(() => ZMM_HD.EBELN),
 
   // 189,ZMM_HD/ZMM_NOTE2,ZDLV_PRICE_SER,,NUMC,4,연동제  Note 순번
-  ZDLV_PRICE_SER: varchar({ length: 255 }).notNull(),
+  ZDLV_PRICE_SER: varchar({ length: 255 }),
   // 190,ZMM_HD/ZMM_NOTE2,ZDLV_PRICE_NOTE,,CHAR,4000,연동제 Note Text
-  ZDLV_PRICE_NOTE: varchar({ length: 10000 }).notNull(),
+  ZDLV_PRICE_NOTE: varchar({ length: 10000 }),
 
   createdAt: timestamp('created_at').defaultNow().notNull(),
   updatedAt: timestamp('updated_at').defaultNow().notNull(),
@@ -669,11 +669,11 @@ export const T_CHANGE_PR = ECCSchema.table('T_CHANGE_PR', {
   // 1,메타데이터(저장하지 않음),IV_ERDAT,M,,DATS,8,,Reject Date
   // 2,메타데이터(저장하지 않음),IV_ERZET,M,,TIMS,6,,Reject  Time
   // 3,T_CHANGE_PR,BANFN,M,,CHAR,10,,Purchase Requisition Number
-  BANFN: varchar({ length: 255 }).notNull(),
+  BANFN: varchar({ length: 255 }),
   // 4,T_CHANGE_PR,BANPO,M,,NUMC,5,,Item Number of Purchase Requisition
-  BANPO: varchar({ length: 255 }).notNull(),
+  BANPO: varchar({ length: 255 }),
   // 5,T_CHANGE_PR,ZCHG_NO,M,,CHAR,10,,Change Number
-  ZCHG_NO: varchar({ length: 255 }).notNull(),
+  ZCHG_NO: varchar({ length: 255 }),
   // 6,T_CHANGE_PR,ZACC_IND,,,CHAR,1,,P/R Accept Indicator
   ZACC_IND: varchar({ length: 255 }),
   // 7,T_CHANGE_PR,PCR_REQ,,,CHAR,10,,PCR Request No.
diff --git a/db/schema/projects.ts b/db/schema/projects.ts
index ee3dbf27..e4e2553a 100644
--- a/db/schema/projects.ts
+++ b/db/schema/projects.ts
@@ -5,7 +5,7 @@ export const projects = pgTable("projects", {
   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: 매핑 필요
+  // pspid: char('pspid', { length: 24 }).unique(), // 프로젝트ID = code 필드
   createdAt: timestamp("created_at").defaultNow().notNull(),
   updatedAt: timestamp("updated_at").defaultNow().notNull(),
 })