From d0d2eaa2de58a0c33e9a21604b126961403cd69e Mon Sep 17 00:00:00 2001
From: dujinkim <dujin.kim@dtsolution.co.kr>
Date: Wed, 14 May 2025 06:12:13 +0000
Subject: (최겸) 기술영업 조선, 해양Top, 해양 Hull 아이템 리스트 개발(CRUD,
 excel import/export/template)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/items-tech/table/ship/import-item-handler.tsx | 145 ++++++++++++++++++++++
 1 file changed, 145 insertions(+)
 create mode 100644 lib/items-tech/table/ship/import-item-handler.tsx

(limited to 'lib/items-tech/table/ship/import-item-handler.tsx')

diff --git a/lib/items-tech/table/ship/import-item-handler.tsx b/lib/items-tech/table/ship/import-item-handler.tsx
new file mode 100644
index 00000000..6ad24398
--- /dev/null
+++ b/lib/items-tech/table/ship/import-item-handler.tsx
@@ -0,0 +1,145 @@
+"use client"
+
+import { z } from "zod"
+import { createShipbuildingImportItem } from "../../service" // 아이템 생성 서버 액션
+
+const SHIP_TYPES = ['A-MAX', 'S-MAX', 'LNGC', 'VLCC', 'CONT'] as const;
+
+// 아이템 데이터 검증을 위한 Zod 스키마
+const itemSchema = z.object({
+  itemCode: z.string().min(1, "아이템 코드는 필수입니다"),
+  itemName: z.string().min(1, "아이템 명은 필수입니다"),
+  workType: z.enum(["기장", "전장", "선실", "배관", "철의"], {
+    required_error: "기능(공종)은 필수입니다",
+  }),
+  description: z.string().nullable().optional(),
+});
+
+interface ProcessResult {
+  successCount: number;
+  errorCount: number;
+  errors?: Array<{ row: number; message: string }>;
+}
+
+/**
+ * Excel 파일에서 가져온 조선 아이템 데이터 처리하는 함수
+ */
+export async function processFileImport(
+  jsonData: any[],
+  progressCallback?: (current: number, total: number) => void
+): Promise<ProcessResult> {
+  // 결과 카운터 초기화
+  let successCount = 0;
+  let errorCount = 0;
+  const errors: Array<{ row: number; message: string }> = [];
+  
+  // 빈 행 등 필터링
+  const dataRows = jsonData.filter(row => {
+    // 빈 행 건너뛰기
+    if (Object.values(row).every(val => !val)) {
+      return false;
+    }
+    return true;
+  });
+  
+  // 데이터 행이 없으면 빈 결과 반환
+  if (dataRows.length === 0) {
+    return { successCount: 0, errorCount: 0 };
+  }
+  
+  // 각 행에 대해 처리
+  for (let i = 0; i < dataRows.length; i++) {
+    const row = dataRows[i];
+    const rowIndex = i + 1; // 사용자에게 표시할 행 번호는 1부터 시작
+    
+    // 진행 상황 콜백 호출
+    if (progressCallback) {
+      progressCallback(i + 1, dataRows.length);
+    }
+    
+    try {
+      // 필드 매핑 (한글/영문 필드명 모두 지원)
+      const itemCode = row["아이템 코드"] || row["itemCode"] || "";
+      const itemName = row["아이템 명"] || row["itemName"] || "";
+      const workType = row["기능(공종)"] || row["workType"] || "";
+      const description = row["설명"] || row["description"] || null;
+      
+      // 데이터 정제
+      const cleanedRow = {
+        itemCode: typeof itemCode === 'string' ? itemCode.trim() : String(itemCode).trim(),
+        itemName: typeof itemName === 'string' ? itemName.trim() : String(itemName).trim(),
+        workType: typeof workType === 'string' ? workType.trim() : String(workType).trim(),
+        description: description ? (typeof description === 'string' ? description : String(description)) : null,
+      };
+      
+      // 데이터 유효성 검사
+      const validationResult = itemSchema.safeParse(cleanedRow);
+      
+      if (!validationResult.success) {
+        const errorMessage = validationResult.error.errors.map(
+          err => `${err.path.join('.')}: ${err.message}`
+        ).join(', ');
+        
+        errors.push({ row: rowIndex, message: errorMessage });
+        errorCount++;
+        continue;
+      }
+      
+      // 선종 데이터 처리
+      const shipTypeEntries = SHIP_TYPES.map(type => ({
+        type,
+        value: row[type]?.toUpperCase() === 'O'
+      })).filter(entry => entry.value);
+      console.log('shipTypeEntries:', shipTypeEntries);
+
+      if (shipTypeEntries.length === 0) {
+        errors.push({ 
+          row: rowIndex, 
+          message: "최소 하나 이상의 선종이 'O'로 지정되어야 합니다." 
+        });
+        errorCount++;
+        continue;
+      }
+
+      // 각 선종에 대해 아이템 생성
+      for (const { type } of shipTypeEntries) {
+        const result = await createShipbuildingImportItem({
+          itemCode: cleanedRow.itemCode,
+          itemName: cleanedRow.itemName,
+          workType: cleanedRow.workType as "기장" | "전장" | "선실" | "배관" | "철의",
+          shipTypes: { [type]: true },
+          description: cleanedRow.description,
+        });
+        
+        if (result.success || !result.error) {
+          successCount++;
+        } else {
+          errors.push({
+            row: rowIndex,
+            message: `${type}: ${result.message || result.error || "알 수 없는 오류"}`
+          });
+          errorCount++;
+        }
+      }
+    } catch (error) {
+      console.error(`${rowIndex}행 처리 오류:`, error);
+      errors.push({
+        row: rowIndex,
+        message: error instanceof Error ? error.message : "알 수 없는 오류"
+      });
+      errorCount++;
+    }
+    
+    // 비동기 작업 쓰로틀링
+    if (i % 5 === 0) {
+      await new Promise(resolve => setTimeout(resolve, 10));
+    }
+  }
+  
+  // 처리 결과 반환
+  return {
+    successCount,
+    errorCount,
+    errors: errors.length > 0 ? errors : undefined
+  };
+}
\ No newline at end of file
-- 
cgit v1.2.3

