62 lines
2.1 KiB
JavaScript
62 lines
2.1 KiB
JavaScript
const XLSX = require('xlsx');
|
|
const mysql = require('mysql2/promise');
|
|
const dotenv = require('dotenv');
|
|
const path = require('path');
|
|
|
|
dotenv.config({ path: path.join(__dirname, '../.env') });
|
|
|
|
const { DB_HOST, DB_USER, DB_PASS, DB_NAME, DB_PORT } = process.env;
|
|
|
|
async function extractFailures() {
|
|
const connection = await mysql.createConnection({
|
|
host: DB_HOST,
|
|
user: DB_USER,
|
|
password: DB_PASS,
|
|
database: DB_NAME,
|
|
port: parseInt(DB_PORT || '3306')
|
|
});
|
|
|
|
console.log('🔍 실패 데이터 추출 중...');
|
|
|
|
const workbook = XLSX.readFile('asset_pc (2026.06.15).xlsx');
|
|
const sheet = workbook.Sheets[workbook.SheetNames[0]];
|
|
const rawData = XLSX.utils.sheet_to_json(sheet);
|
|
|
|
// 현재 DB에 존재하는 모든 asset_core ID 조회
|
|
const [existingRows] = await connection.query('SELECT id FROM asset_core');
|
|
const existingIds = new Set(existingRows.map(r => r.id));
|
|
|
|
const failures = [];
|
|
|
|
for (let i = 0; i < rawData.length; i++) {
|
|
const row = rawData[i];
|
|
const assetId = `PC_20260615_${String(i + 1).padStart(4, '0')}`;
|
|
|
|
// DB에 해당 ID가 없는 경우 = 실패(충돌 등의 이유로 입력되지 않음) 또는 스킵된 데이터
|
|
// 하지만 이전 로그에서 'Duplicate entry'로 에러가 났던 항목들을 찾는 것이 목적
|
|
// 로직상 ID 생성 규칙에 따라 해당 ID가 DB에 없으면 입력에 실패한 행임
|
|
if (!existingIds.has(assetId)) {
|
|
failures.push({
|
|
excel_row: i + 2,
|
|
generated_id: assetId,
|
|
...row
|
|
});
|
|
}
|
|
}
|
|
|
|
if (failures.length > 0) {
|
|
const newWb = XLSX.utils.book_new();
|
|
const newWs = XLSX.utils.json_to_sheet(failures);
|
|
XLSX.utils.book_append_sheet(newWb, newWs, 'Failures');
|
|
const fileName = 'asset_pc_failures_20260615.xlsx';
|
|
XLSX.writeFile(newWb, fileName);
|
|
console.log(`✅ 추출 완료: ${failures.length}건의 실패 데이터를 ${fileName}에 저장했습니다.`);
|
|
} else {
|
|
console.log('입력되지 않은 데이터가 없습니다.');
|
|
}
|
|
|
|
await connection.end();
|
|
}
|
|
|
|
extractFailures().catch(console.error);
|