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);