summaryrefslogtreecommitdiff
path: root/lib/items-tech/table/ship/import-item-handler.tsx
diff options
context:
space:
mode:
Diffstat (limited to 'lib/items-tech/table/ship/import-item-handler.tsx')
-rw-r--r--lib/items-tech/table/ship/import-item-handler.tsx266
1 files changed, 128 insertions, 138 deletions
diff --git a/lib/items-tech/table/ship/import-item-handler.tsx b/lib/items-tech/table/ship/import-item-handler.tsx
index 57546cc6..b0f475ff 100644
--- a/lib/items-tech/table/ship/import-item-handler.tsx
+++ b/lib/items-tech/table/ship/import-item-handler.tsx
@@ -1,139 +1,129 @@
-"use client"
-
-import { z } from "zod"
-import { createShipbuildingImportItem } from "../../service" // 아이템 생성 서버 액션
-
-// 아이템 데이터 검증을 위한 Zod 스키마
-const itemSchema = z.object({
- itemCode: z.string().optional(),
- workType: z.enum(["기장", "전장", "선실", "배관", "철의", "선체"], {
- required_error: "기능(공종)은 필수입니다",
- }),
- shipTypes: z.string().nullable().optional(),
- itemList: z.string().nullable().optional(),
-});
-
-interface ProcessResult {
- successCount: number;
- errorCount: number;
- errors: Array<{ row: number; message: string; itemCode?: string; workType?: string }>;
-}
-
-/**
- * Excel 파일에서 가져온 조선 아이템 데이터 처리하는 함수
- */
-export async function processFileImport(
- jsonData: Record<string, unknown>[],
- 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, errors: [] };
- }
-
- // 각 행에 대해 처리
- 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 workType = row["기능(공종)"] || row["workType"] || "";
- const shipTypes = row["선종"] || row["shipTypes"] || null;
- const itemList = row["자재명"] || row["itemList"] || null;
-
- // 데이터 정제
- const cleanedRow = {
- itemCode: typeof itemCode === 'string' ? itemCode.trim() : String(itemCode).trim(),
- workType: typeof workType === 'string' ? workType.trim() : String(workType).trim(),
- shipTypes: shipTypes ? (typeof shipTypes === 'string' ? shipTypes.trim() : String(shipTypes).trim()) : null,
- itemList: itemList ? (typeof itemList === 'string' ? itemList : String(itemList)) : 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,
- itemCode: cleanedRow.itemCode,
- workType: cleanedRow.workType
- });
- errorCount++;
- continue;
- }
-
- // 아이템 생성
- const result = await createShipbuildingImportItem({
- itemCode: cleanedRow.itemCode,
- workType: cleanedRow.workType as "기장" | "전장" | "선실" | "배관" | "철의" | "선체",
- shipTypes: cleanedRow.shipTypes,
- itemList: cleanedRow.itemList,
- });
-
- if (result.success || !result.error) {
- successCount++;
- } else {
- errors.push({
- row: rowIndex,
- message: result.message || result.error || "알 수 없는 오류",
- itemCode: cleanedRow.itemCode,
- workType: cleanedRow.workType
- });
- errorCount++;
- }
-
- } catch (error) {
- console.error(`${rowIndex}행 처리 오류:`, error);
-
- // cleanedRow가 정의되지 않은 경우를 처리
- const itemCode = row["자재 그룹"] || row["itemCode"] || "";
- const workType = row["기능(공종)"] || row["workType"] || "";
-
- errors.push({
- row: rowIndex,
- message: error instanceof Error ? error.message : "알 수 없는 오류",
- itemCode: typeof itemCode === 'string' ? itemCode.trim() : String(itemCode).trim(),
- workType: typeof workType === 'string' ? workType.trim() : String(workType).trim()
- });
- errorCount++;
- }
-
- // 비동기 작업 쓰로틀링
- if (i % 5 === 0) {
- await new Promise(resolve => setTimeout(resolve, 10));
- }
- }
-
- // 처리 결과 반환
- return {
- successCount,
- errorCount,
- errors
- };
+"use client"
+
+import { z } from "zod"
+import { createShipbuildingImportItem } from "../../service" // 아이템 생성 서버 액션
+
+// 아이템 데이터 검증을 위한 Zod 스키마
+const itemSchema = z.object({
+ itemCode: z.string().optional(),
+ workType: z.enum(["기장", "전장", "선실", "배관", "철의", "선체"], {
+ required_error: "기능(공종)은 필수입니다",
+ }),
+ shipTypes: z.string().nullable().optional(),
+ itemList: z.string().nullable().optional(),
+});
+
+interface ProcessResult {
+ successCount: number;
+ errorCount: number;
+ errors: Array<{ row: number; message: string }>;
+}
+
+/**
+ * Excel 파일에서 가져온 조선 아이템 데이터 처리하는 함수
+ */
+export async function processFileImport(
+ jsonData: Record<string, unknown>[],
+ 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, errors: [] };
+ }
+
+ // 각 행에 대해 처리
+ 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 workType = row["기능(공종)"] || row["workType"] || "";
+ const shipTypes = row["선종"] || row["shipTypes"] || null;
+ const itemList = row["자재명"] || row["itemList"] || null;
+
+ // 데이터 정제
+ const cleanedRow = {
+ itemCode: typeof itemCode === 'string' ? itemCode.trim() : String(itemCode).trim(),
+ workType: typeof workType === 'string' ? workType.trim() : String(workType).trim(),
+ shipTypes: shipTypes ? (typeof shipTypes === 'string' ? shipTypes.trim() : String(shipTypes).trim()) : null,
+ itemList: itemList ? (typeof itemList === 'string' ? itemList : String(itemList)) : 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 result = await createShipbuildingImportItem({
+ itemCode: cleanedRow.itemCode,
+ workType: cleanedRow.workType as "기장" | "전장" | "선실" | "배관" | "철의" | "선체",
+ shipTypes: cleanedRow.shipTypes,
+ itemList: cleanedRow.itemList,
+ });
+
+ if (result.success || !result.error) {
+ successCount++;
+ } else {
+ errors.push({
+ row: rowIndex,
+ message: 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
+ };
} \ No newline at end of file