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
|
"use client"
import { z } from "zod"
import { createItem } from "../service" // 아이템 생성 서버 액션
// 아이템 데이터 검증을 위한 Zod 스키마
const itemSchema = z.object({
itemCode: z.string().min(1, "아이템 코드는 필수입니다"),
itemName: z.string().min(1, "아이템 명은 필수입니다"),
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"] || row["item_code"] || "";
const itemName = row["아이템 명"] || row["itemName"] || row["item_name"] || "";
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(),
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 result = await createItem({
itemCode: cleanedRow.itemCode,
itemName: cleanedRow.itemName,
description: cleanedRow.description,
});
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: errors.length > 0 ? errors : undefined
};
}
|
