Merge branch 'swp' into dujinkim

1 files changed, 67 insertions, 52 deletions

diff --git a/lib/swp/sync-service.ts b/lib/swp/sync-service.ts
index 0a801bd8..787b28ae 100644
--- a/lib/swp/sync-service.ts
+++ b/lib/swp/sync-service.ts
@@ -9,7 +9,6 @@ import {
   type SwpDocumentInsert,
   type SwpDocumentRevisionInsert,
   type SwpDocumentFileInsert,
-  swpSchema,
 } from "@/db/schema/SWP/swp-documents";
 
 // ============================================================================
@@ -17,63 +16,69 @@ import {
 // ============================================================================
 
 export interface SwpDocumentApiResponse {
+  // 필수 필드
   DOC_NO: string;
   DOC_TITLE: string;
-  DOC_GB: string;
-  DOC_TYPE: string;
-  OWN_DOC_NO: string;
-  SHI_DOC_NO: string;
   PROJ_NO: string;
-  PROJ_NM: string;
-  PKG_NO: string;
-  MAT_CD: string;
-  MAT_NM: string;
-  DISPLN: string;
-  CTGRY: string;
-  VNDR_CD: string;
   CPY_CD: string;
   CPY_NM: string;
   PIC_NM: string;
-  PIC_DEPTCD: string;
   PIC_DEPTNM: string;
-  LTST_REV_NO: string;
-  LTST_REV_SEQ: string;
-  LTST_ACTV_STAT: string;
-  STAGE: string;
   SKL_CD: string;
-  MOD_TYPE: string;
-  ACT_TYPE_NM: string;
-  USE_YN: string;
   CRTER: string;
   CRTE_DTM: string;
   CHGR: string;
   CHG_DTM: string;
+  
+  // 선택적 필드 (null 가능)
+  DOC_GB: string | null;
+  DOC_TYPE: string | null;
+  OWN_DOC_NO: string | null;
+  SHI_DOC_NO: string | null;
+  PROJ_NM: string | null;
+  PKG_NO: string | null;
+  MAT_CD: string | null;
+  MAT_NM: string | null;
+  DISPLN: string | null;
+  CTGRY: string | null;
+  VNDR_CD: string | null;
+  PIC_DEPTCD: string | null;
+  LTST_REV_NO: string | null;
+  LTST_REV_SEQ: string | null;
+  LTST_ACTV_STAT: string | null;
+  STAGE: string | null;
+  MOD_TYPE: string | null;
+  ACT_TYPE_NM: string | null;
+  USE_YN: string | null;
   REV_DTM: string | null;
 }
 
 export interface SwpFileApiResponse {
+  // 필수 필드
   OWN_DOC_NO: string;
   REV_NO: string;
   STAGE: string;
   FILE_NM: string;
   FILE_SEQ: string;
-  FILE_SZ: string;
-  FLD_PATH: string;
-  ACTV_NO: string | null;
-  ACTV_SEQ: string;
-  BOX_SEQ: string;
-  OFDC_NO: string;
-  PROJ_NO: string;
-  PKG_NO: string;
-  VNDR_CD: string;
-  CPY_CD: string;
-  STAT: string;
-  STAT_NM: string;
-  IDX: string;
   CRTER: string;
   CRTE_DTM: string;
   CHGR: string;
   CHG_DTM: string;
+  
+  // 선택적 필드 (null 가능)
+  FILE_SZ: string | null;
+  FLD_PATH: string | null;
+  ACTV_NO: string | null;
+  ACTV_SEQ: string | null;
+  BOX_SEQ: string | null;
+  OFDC_NO: string | null;
+  PROJ_NO: string | null;
+  PKG_NO: string | null;
+  VNDR_CD: string | null;
+  CPY_CD: string | null;
+  STAT: string | null;
+  STAT_NM: string | null;
+  IDX: string | null;
 }
 
 // ============================================================================
@@ -220,13 +225,13 @@ async function upsertDocument(
 ): Promise<{ id: string; inserted: boolean; updated: boolean }> {
   const data: SwpDocumentInsert = {
     DOC_NO: doc.DOC_NO,
+    PROJ_NO: doc.PROJ_NO,
     DOC_TITLE: doc.DOC_TITLE,
     DOC_GB: doc.DOC_GB || null,
     DOC_TYPE: doc.DOC_TYPE || null,
-    OWN_DOC_NO: doc.OWN_DOC_NO,
-    SHI_DOC_NO: doc.SHI_DOC_NO,
-    PROJ_NO: doc.PROJ_NO,
-    PROJ_NM: doc.PROJ_NM,
+    OWN_DOC_NO: doc.OWN_DOC_NO || null,
+    SHI_DOC_NO: doc.SHI_DOC_NO || null,
+    PROJ_NM: doc.PROJ_NM || null,
     PKG_NO: doc.PKG_NO || null,
     MAT_CD: doc.MAT_CD || null,
     MAT_NM: doc.MAT_NM || null,
@@ -256,11 +261,16 @@ async function upsertDocument(
     updated_at: new Date(),
   };
 
-  // 기존 문서 확인
+  // 기존 문서 확인 (복합키: DOC_NO + PROJ_NO)
   const existing = await tx
     .select()
     .from(swpDocuments)
-    .where(eq(swpDocuments.DOC_NO, doc.DOC_NO))
+    .where(
+      and(
+        eq(swpDocuments.DOC_NO, doc.DOC_NO),
+        eq(swpDocuments.PROJ_NO, doc.PROJ_NO)
+      )
+    )
     .limit(1);
 
   if (existing.length > 0) {
@@ -268,12 +278,17 @@ async function upsertDocument(
     await tx
       .update(swpDocuments)
       .set(data)
-      .where(eq(swpDocuments.DOC_NO, doc.DOC_NO));
-    return { id: doc.DOC_NO, inserted: false, updated: true };
+      .where(
+        and(
+          eq(swpDocuments.DOC_NO, doc.DOC_NO),
+          eq(swpDocuments.PROJ_NO, doc.PROJ_NO)
+        )
+      );
+    return { id: `${doc.DOC_NO}|${doc.PROJ_NO}`, inserted: false, updated: true };
   } else {
     // 삽입
     await tx.insert(swpDocuments).values(data);
-    return { id: doc.DOC_NO, inserted: true, updated: false };
+    return { id: `${doc.DOC_NO}|${doc.PROJ_NO}`, inserted: true, updated: false };
   }
 }
 
@@ -287,13 +302,13 @@ async function upsertRevision(
     REV_NO: file.REV_NO,
     STAGE: file.STAGE,
     ACTV_NO: file.ACTV_NO || null,
-    ACTV_SEQ: file.ACTV_SEQ,
-    BOX_SEQ: file.BOX_SEQ,
-    OFDC_NO: file.OFDC_NO,
-    PROJ_NO: file.PROJ_NO,
+    ACTV_SEQ: file.ACTV_SEQ || null,
+    BOX_SEQ: file.BOX_SEQ || null,
+    OFDC_NO: file.OFDC_NO || null,
+    PROJ_NO: file.PROJ_NO || null,
     PKG_NO: file.PKG_NO || null,
     VNDR_CD: file.VNDR_CD || null,
-    CPY_CD: file.CPY_CD,
+    CPY_CD: file.CPY_CD || null,
     sync_status: "synced",
     last_synced_at: new Date(),
     updated_at: new Date(),
@@ -339,11 +354,11 @@ async function upsertFile(
     DOC_NO: docNo,
     FILE_NM: file.FILE_NM,
     FILE_SEQ: file.FILE_SEQ,
-    FILE_SZ: file.FILE_SZ,
-    FLD_PATH: file.FLD_PATH,
-    STAT: file.STAT,
-    STAT_NM: file.STAT_NM,
-    IDX: file.IDX,
+    FILE_SZ: file.FILE_SZ || null,
+    FLD_PATH: file.FLD_PATH || null,
+    STAT: file.STAT || null,
+    STAT_NM: file.STAT_NM || null,
+    IDX: file.IDX || null,
     ACTV_NO: file.ACTV_NO || null,
     CRTER: file.CRTER,
     CRTE_DTM: file.CRTE_DTM,