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 importUsers() {
  const connection = await mysql.createConnection({
    host: DB_HOST,
    user: DB_USER,
    password: DB_PASS,
    database: DB_NAME,
    port: parseInt(DB_PORT || '3306')
  });

  console.log('🚀 Excel 데이터 로드 중...');
  const workbook = XLSX.readFile('system_User (20260615).xlsx');
  const sheetName = workbook.SheetNames[0];
  const sheet = workbook.Sheets[sheetName];
  const data = XLSX.utils.sheet_to_json(sheet);

  console.log(`📊 총 ${data.length}개의 데이터를 찾았습니다.`);

  // 기존 데이터 삭제 여부 (사용자 요구사항에 따라 결정 가능하지만, 보통 초기화 후 재입입)
  // 여기서는 중복 방지를 위해 기존 데이터를 삭제하고 새로 넣는 방식을 취하겠습니다.
  console.log('🧹 기존 system_users 데이터 삭제 중...');
  await connection.query('DELETE FROM system_users');

  console.log('📥 데이터 삽입 중...');
  let successCount = 0;
  
  for (let i = 0; i < data.length; i++) {
    const row = data[i];
    const { emp_no, user_name, dept_name, position, status } = row;
    
    // ID 생성 (USR_ + 인덱스 001 형식)
    const id = `USR_${String(i + 1).padStart(3, '0')}`;
    const createdAt = new Date().toISOString().replace('T', ' ').substring(0, 19);

    try {
      await connection.query(
        'INSERT INTO system_users (id, emp_no, user_name, dept_name, position, status, created_at) VALUES (?, ?, ?, ?, ?, ?, ?)',
        [id, String(emp_no), user_name, dept_name, position, status, createdAt]
      );
      successCount++;
    } catch (err) {
      console.error(`❌ 삽입 실패 (Row ${i + 2}):`, err.message);
    }
  }

  console.log(`✅ 완료: ${successCount}개의 사용자가 성공적으로 등록되었습니다.`);
  await connection.end();
}

importUsers().catch(err => {
  console.error('❌ 작업 중 오류 발생:', err);
  process.exit(1);
});