1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
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 }>;
}
/**
* 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
};
}
|
