const mysql = require('mysql2/promise');
require('dotenv').config();

async function updateDepartments() {
  const connection = await mysql.createConnection({
    host: process.env.DB_HOST,
    user: process.env.DB_USER,
    password: process.env.DB_PASS,
    database: process.env.DB_NAME,
    port: parseInt(process.env.DB_PORT || '3306')
  });

  console.log("🚀 부서명 '삼안' 통합 업데이트 시작...");

  const [result] = await connection.query(`
    UPDATE asset_core 
    SET current_dept = '삼안' 
    WHERE current_dept NOT IN ('총괄기획실', '기술개발센터', '현타', '장헌', '한맥', 'PTC', '', '삼안') 
      AND current_dept IS NOT NULL
  `);

  console.log(`✅ 업데이트 완료: ${result.affectedRows}건의 부서명이 '삼안'으로 변경되었습니다.`);

  // 최종 확인용 카운트
  const [rows] = await connection.query('SELECT current_dept, COUNT(*) as count FROM asset_core GROUP BY current_dept');
  console.log('\n📊 최종 부서 분포:');
  console.table(rows);

  await connection.end();
}

updateDepartments().catch(console.error);