From 46422e8544c73148f51dd36894aebca114fd991b Mon Sep 17 00:00:00 2001 From: Taehoon Date: Tue, 2 Jun 2026 14:44:45 +0900 Subject: [PATCH] cleanup: remove database migration and utility scripts --- fix_pc_codes.js | 92 ------------------------ generate_codes.js | 94 ------------------------- sync_all_from_excel.js | 98 -------------------------- update_db_from_excel.js | 150 ---------------------------------------- 4 files changed, 434 deletions(-) delete mode 100644 fix_pc_codes.js delete mode 100644 generate_codes.js delete mode 100644 sync_all_from_excel.js delete mode 100644 update_db_from_excel.js diff --git a/fix_pc_codes.js b/fix_pc_codes.js deleted file mode 100644 index 4348d00..0000000 --- a/fix_pc_codes.js +++ /dev/null @@ -1,92 +0,0 @@ -import mysql from 'mysql2/promise'; -import dotenv from 'dotenv'; - -dotenv.config(); - -const { DB_HOST, DB_USER, DB_PASS, DB_NAME, DB_PORT } = process.env; - -async function run() { - const pool = mysql.createPool({ - host: DB_HOST, - user: DB_USER, - password: DB_PASS, - database: DB_NAME, - port: parseInt(DB_PORT || '3306') - }); - - console.log('πŸ”„ Step 1: Updating purchase_date for PC-000000 assets to 2015-12-01...'); - const [updateResult] = await pool.query( - "UPDATE asset_pc SET purchase_date = '2015-12-01' WHERE asset_code LIKE 'PC-000000%'" - ); - console.log(`βœ… Updated ${updateResult.affectedRows} records.`); - - console.log('πŸ”„ Step 2: Re-sequencing all PC asset codes by Year...'); - const [pcs] = await pool.query('SELECT * FROM asset_pc'); - - const getPrefix = (type) => { - const t = type || ''; - if (t.includes('곡용PC') || t.includes('개인PC') || t.includes('μ„œλ²„PC') || t === 'PC') return 'PC'; - return 'ETC'; - }; - - const parseYYYYMM = (dateStr) => { - if (!dateStr) return '000000'; - const clean = dateStr.replace(/[^0-9]/g, ''); - if (clean.length >= 6) return clean.substring(0, 6); - return '000000'; - }; - - const parseYYYY = (dateStr) => { - const yyyymm = parseYYYYMM(dateStr); - return yyyymm.substring(0, 4); - }; - - // Group and sort - const mapped = pcs.map(item => { - const prefix = getPrefix(item.asset_type); - const yyyymm = parseYYYYMM(item.purchase_date); - const yyyy = yyyymm.substring(0, 4); - const sortKey = [ - item.purchase_date || '9999-99-99', - item.model_name || '', - item.mainboard || '', - item.os || '', - item.id - ].join('|'); - return { ...item, prefix, yyyymm, yyyy, sortKey }; - }); - - mapped.sort((a, b) => a.sortKey.localeCompare(b.sortKey)); - - const counters = {}; - const updates = mapped.map(item => { - const groupKey = `${item.prefix}-${item.yyyy}`; - counters[groupKey] = (counters[groupKey] || 0) + 1; - const serial = String(counters[groupKey]).padStart(4, '0'); - const newCode = `${item.prefix}-${item.yyyymm}-${serial}`; - return { id: item.id, asset_code: newCode }; - }); - - console.log('πŸ’Ύ Reflecting changes to DB...'); - const connection = await pool.getConnection(); - try { - await connection.beginTransaction(); - // Clear codes to avoid unique constraint issues - await connection.query("UPDATE asset_pc SET asset_code = CONCAT('TEMP_', id)"); - - for (const u of updates) { - await connection.query("UPDATE asset_pc SET asset_code = ? WHERE id = ?", [u.asset_code, u.id]); - } - await connection.commit(); - console.log(`βœ… Re-sequencing completed for ${updates.length} PCs.`); - } catch (err) { - await connection.rollback(); - console.error('❌ Failed to re-sequence:', err); - } finally { - connection.release(); - } - - await pool.end(); -} - -run().catch(console.error); diff --git a/generate_codes.js b/generate_codes.js deleted file mode 100644 index 58bc19e..0000000 --- a/generate_codes.js +++ /dev/null @@ -1,94 +0,0 @@ -import mysql from 'mysql2/promise'; -import XLSX from 'xlsx'; -import dotenv from 'dotenv'; - -dotenv.config(); - -const { DB_HOST, DB_USER, DB_PASS, DB_NAME, DB_PORT } = process.env; - -async function run() { - const pool = mysql.createPool({ - host: DB_HOST, - user: DB_USER, - password: DB_PASS, - database: DB_NAME, - port: parseInt(DB_PORT || '3306') - }); - - console.log('πŸ“‘ Fetching data from DB...'); - const [pcs] = await pool.query('SELECT * FROM asset_pc'); - const [servers] = await pool.query('SELECT * FROM asset_server'); - - const getPrefix = (type) => { - const t = type || ''; - if (t.includes('μ„œλ²„ λ ‰') || t.includes('μ›Œν¬μŠ€ν…Œμ΄μ…˜')) return 'SVR'; - if (t.includes('μŠ€ν† λ¦¬μ§€ λ ‰')) return 'STO'; - if (t.includes('곡용PC') || t.includes('개인PC') || t.includes('μ„œλ²„PC') || t === 'PC') return 'PC'; - return 'ETC'; - }; - - const parseYYYYMM = (dateStr) => { - if (!dateStr) return '000000'; - const clean = dateStr.replace(/[^0-9]/g, ''); - if (clean.length >= 6) return clean.substring(0, 6); - return '000000'; - }; - - const processList = (list) => { - // 1. Prepare data with sorting keys and groups - const mapped = list.map(item => { - const prefix = getPrefix(item.asset_type); - const yyyymm = parseYYYYMM(item.purchase_date); - // Sort by: purchase_date -> model_name -> mainboard -> os -> id (stability) - const sortKey = [ - item.purchase_date || '9999-99-99', - item.model_name || '', - item.mainboard || '', - item.os || '', - item.id - ].join('|'); - - return { ...item, prefix, yyyymm, sortKey }; - }); - - // 2. Sort the list - mapped.sort((a, b) => a.sortKey.localeCompare(b.sortKey)); - - // 3. Assign new codes - const counters = {}; - return mapped.map(item => { - const groupKey = `${item.prefix}-${item.yyyymm}`; - counters[groupKey] = (counters[groupKey] || 0) + 1; - const serial = String(counters[groupKey]).padStart(4, '0'); - const newCode = `${groupKey}-${serial}`; - - return { - asset_code: newCode, - category: item.category, - asset_type: item.asset_type, - asset_purpose: item.asset_purpose || '', - memo: `[Legacy: ${item.asset_code || 'N/A'}] ${item.memo || ''}`.trim() - }; - }); - }; - - console.log('πŸ”„ Processing codes...'); - const finalServers = processList(servers); - const finalPcs = processList(pcs); - - console.log('πŸ“Š Generating Excel...'); - const wb = XLSX.utils.book_new(); - const wsServers = XLSX.utils.json_to_sheet(finalServers); - const wsPcs = XLSX.utils.json_to_sheet(finalPcs); - - XLSX.utils.book_append_sheet(wb, wsServers, 'asset_server'); - XLSX.utils.book_append_sheet(wb, wsPcs, 'asset_pc'); - - const fileName = 'Asset_Code_Preview_20260602.xlsx'; - XLSX.writeFile(wb, fileName); - - console.log(`βœ… Completed! File saved as: ${fileName}`); - await pool.end(); -} - -run().catch(console.error); diff --git a/sync_all_from_excel.js b/sync_all_from_excel.js deleted file mode 100644 index 396be98..0000000 --- a/sync_all_from_excel.js +++ /dev/null @@ -1,98 +0,0 @@ -import mysql from 'mysql2/promise'; -import XLSX from 'xlsx'; -import dotenv from 'dotenv'; - -dotenv.config(); - -const { DB_HOST, DB_USER, DB_PASS, DB_NAME, DB_PORT } = process.env; - -async function run() { - const pool = mysql.createPool({ - host: DB_HOST, - user: DB_USER, - password: DB_PASS, - database: DB_NAME, - port: parseInt(DB_PORT || '3306') - }); - - const excelFile = 'Asset_Code_Preview_MOD 20260602.xlsx'; - console.log(`πŸ“– Reading corrected info from: ${excelFile}`); - const workbook = XLSX.readFile(excelFile); - - const syncTable = async (sheetName, tableName) => { - console.log(`πŸ” Processing ${sheetName}...`); - const data = XLSX.utils.sheet_to_json(workbook.Sheets[sheetName]); - const [dbRecords] = await pool.query(`SELECT id, asset_code FROM ${tableName}`); - - const extractLegacyCode = (memo) => { - const match = (memo || '').match(/\[Legacy:\s*([^\]]+)\]/); - return match ? match[1] : 'N/A'; - }; - - const extractOriginalMemo = (memo) => { - return (memo || '').replace(/\[Legacy:\s*[^\]]+\]\s*/, '').trim(); - }; - - const updates = []; - for (const row of data) { - const legacyCode = extractLegacyCode(row.memo); - const match = dbRecords.find(db => (db.asset_code || 'N/A') === legacyCode); - - if (match) { - // μ—‘μ…€μ˜ μžμ‚°λ²ˆν˜Έμ—μ„œ λ‚ μ§œ μΆ”μΆœ (PC-201512-0001 -> 2015-12-01) - const codeParts = row.asset_code.split('-'); - let purchaseDate = null; - if (codeParts.length >= 2 && codeParts[1].length === 6) { - const ym = codeParts[1]; - purchaseDate = `${ym.substring(0, 4)}-${ym.substring(4, 6)}-01`; - } - - updates.push({ - id: match.id, - asset_code: row.asset_code, // 엑셀에 적힌 번호 κ·ΈλŒ€λ‘œ (μ‚¬μš©μž μˆ˜μ • 반영) - purchase_date: purchaseDate, - memo: extractOriginalMemo(row.memo) - }); - } - } - - console.log(`πŸ’Ύ Updating ${updates.length} records in ${tableName}...`); - const connection = await pool.getConnection(); - try { - await connection.beginTransaction(); - await connection.query(`UPDATE ${tableName} SET asset_code = CONCAT('TEMP_', id)`); - for (const u of updates) { - if (u.purchase_date) { - await connection.query( - `UPDATE ${tableName} SET asset_code = ?, purchase_date = ?, memo = ? WHERE id = ?`, - [u.asset_code, u.purchase_date, u.memo, u.id] - ); - } else { - await connection.query( - `UPDATE ${tableName} SET asset_code = ?, memo = ? WHERE id = ?`, - [u.asset_code, u.memo, u.id] - ); - } - } - await connection.commit(); - console.log(`βœ… ${tableName} Sync Completed.`); - } catch (err) { - await connection.rollback(); - console.error(`❌ ${tableName} Error:`, err); - } finally { - connection.release(); - } - }; - - await syncTable('asset_pc', 'asset_pc'); - await syncTable('asset_server', 'asset_server'); - - console.log('πŸ”„ Re-sequencing all PC and Server codes by YEAR for absolute consistency...'); - // μ—¬κΈ°μ„œ λ§ˆμ§€λ§‰μœΌλ‘œ 전체 μ •λ ¬ 및 일련번호 μž¬λΆ€μ—¬λ₯Ό μˆ˜ν–‰ν•˜μ—¬ μ€‘λ³΅μ΄λ‚˜ λˆ„λ½μ„ μ™„λ²½νžˆ 방지 - await pool.end(); - - // Re-run the existing update script to ensure yearly sequencing is perfect - // (Using the relaxed matching logic we already improved) -} - -run().catch(console.error); diff --git a/update_db_from_excel.js b/update_db_from_excel.js deleted file mode 100644 index e6f5164..0000000 --- a/update_db_from_excel.js +++ /dev/null @@ -1,150 +0,0 @@ -import mysql from 'mysql2/promise'; -import XLSX from 'xlsx'; -import dotenv from 'dotenv'; - -dotenv.config(); - -const { DB_HOST, DB_USER, DB_PASS, DB_NAME, DB_PORT } = process.env; - -async function run() { - const pool = mysql.createPool({ - host: DB_HOST, - user: DB_USER, - password: DB_PASS, - database: DB_NAME, - port: parseInt(DB_PORT || '3306') - }); - - const fileName = 'Asset_Code_Preview_MOD 20260602.xlsx'; - console.log(`πŸ“– Reading modified Excel: ${fileName}`); - const workbook = XLSX.readFile(fileName); - - // 1. Fetch current DB state for matching - console.log('πŸ“‘ Fetching current DB state...'); - const [dbPcs] = await pool.query('SELECT * FROM asset_pc'); - const [dbServers] = await pool.query('SELECT * FROM asset_server'); - - const processSheet = async (sheetName, dbRecords, tableName) => { - console.log(`πŸ” Processing sheet: ${sheetName}`); - const sheet = workbook.Sheets[sheetName]; - if (!sheet) { - console.warn(`⚠️ Sheet ${sheetName} not found.`); - return; - } - const data = XLSX.utils.sheet_to_json(sheet); - - // Helper to extract legacy code from memo - const extractLegacyCode = (memo) => { - const match = memo.match(/\[Legacy:\s*([^\]]+)\]/); - return match ? match[1] : 'N/A'; - }; - - // Helper to extract original memo (without legacy tag) - const extractOriginalMemo = (memo) => { - return memo.replace(/\[Legacy:\s*[^\]]+\]\s*/, '').trim(); - }; - - // Helper to parse current asset_code into parts (Prefix-YYYYMM-Serial) - const parseCodeParts = (code) => { - const parts = code.split('-'); - if (parts.length >= 3) { - return { - prefix: parts[0], - yyyymm: parts[1], - yyyy: parts[1].substring(0, 4), // Extract Year - serial: parts[parts.length - 1] - }; - } - return { prefix: 'ETC', yyyymm: '000000', yyyy: '0000', serial: '0000' }; - }; - - // 2. Map Excel rows back to DB records - const updates = []; - const usedDbIds = new Set(); - const groups = {}; - - for (const row of data) { - const legacyCode = extractLegacyCode(row.memo || ''); - const originalMemo = extractOriginalMemo(row.memo || ''); - - let match = null; - if (legacyCode !== 'N/A') { - match = dbRecords.find(db => !usedDbIds.has(db.id) && (db.asset_code || 'N/A') === legacyCode); - } - if (!match) { - match = dbRecords.find(db => !usedDbIds.has(db.id) && db.asset_type === row.asset_type && (db.asset_purpose || '') === row.asset_purpose); - } - if (!match) { - match = dbRecords.find(db => !usedDbIds.has(db.id) && db.asset_type === row.asset_type); - } - - if (match) { - usedDbIds.add(match.id); - const parts = parseCodeParts(row.asset_code); - // Group by Prefix and Year (YYYY) - const groupKey = `${parts.prefix}-${parts.yyyy}`; - - if (!groups[groupKey]) groups[groupKey] = []; - groups[groupKey].push({ - dbId: match.id, - originalRow: row, - yyyymm: parts.yyyymm, // Keep the specific month for the code - requestedSerial: parts.serial - }); - } - } - - // 3. Resolve Duplicates and Re-sequence BY YEAR - console.log(`βš–οΈ Resolving duplicates for ${sheetName} (Yearly Sequencing)...`); - for (const key in groups) { - const items = groups[key]; - // Sort by YearMonth first, then by the serial provided to maintain order - items.sort((a, b) => { - const monthCompare = a.yyyymm.localeCompare(b.yyyymm); - if (monthCompare !== 0) return monthCompare; - return a.requestedSerial.localeCompare(b.requestedSerial); - }); - - items.forEach((item, index) => { - const newSerial = String(index + 1).padStart(4, '0'); - // Format remains Prefix-YYYYMM-Serial - const finalCode = `${item.originalRow.asset_code.split('-').slice(0, 2).join('-')}-${newSerial}`; - updates.push({ id: item.dbId, asset_code: finalCode, memo: extractOriginalMemo(item.originalRow.memo || '') }); - }); - } - - // 4. Perform DB Updates - console.log(`πŸ’Ύ Updating ${tableName} in DB...`); - const connection = await pool.getConnection(); - try { - await connection.beginTransaction(); - - // IMPORTANT: To avoid UNIQUE constraint errors during the update process, - // we first set all asset_codes to a temporary unique value. - console.log(`πŸ”„ Clearing existing codes in ${tableName} for safe update...`); - await connection.query(`UPDATE ${tableName} SET asset_code = CONCAT('TEMP_', id)`); - - for (const update of updates) { - await connection.query( - `UPDATE ${tableName} SET asset_code = ?, memo = ? WHERE id = ?`, - [update.asset_code, update.memo, update.id] - ); - } - await connection.commit(); - console.log(`βœ… Updated ${updates.length} records in ${tableName}.`); - } catch (err) { - await connection.rollback(); - console.error(`❌ Failed to update ${tableName}:`, err); - } finally { - connection.release(); - } - }; - - await processSheet('asset_server', dbServers, 'asset_server'); - await processSheet('asset_pc', dbPcs, 'asset_pc'); - - console.log('🏁 All updates completed.'); - await pool.end(); -} - -run().catch(console.error);