feat(tkuser): Sprint 001 Section A — 연차/휴가 백엔드 전환 (DB + API)

workers/vacation_balance_details → sso_users/sp_vacation_balances 기반 전환. 부서장 설정, 승인권한 CRUD, vacation_settings 테이블, 장기근속 자동부여, startup migration 추가. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
2026-03-23 08:13:03 +09:00
parent b44ae36329
commit c158da7832
11 changed files with 501 additions and 70 deletions
--- a/user-management/api/models/departmentModel.js
+++ b/user-management/api/models/departmentModel.js
@@ -1,7 +1,7 @@
 /**
 * Department Model
 *
- * departments 테이블 CRUD (MariaDB)
+ * departments 테이블 CRUD + 승인권한 관리 (MariaDB)
 */

 const { getPool } = require('./userModel');
@@ -9,8 +9,9 @@ const { getPool } = require('./userModel');
 async function getAll() {
  const db = getPool();
  const [rows] = await db.query(
-    `SELECT d.*
+    `SELECT d.*, su.name AS leader_name
     FROM departments d
+     LEFT JOIN sso_users su ON d.leader_user_id = su.user_id
     ORDER BY d.display_order ASC, d.department_id ASC`
  );
  return rows;
@@ -19,8 +20,9 @@ async function getAll() {
 async function getById(id) {
  const db = getPool();
  const [rows] = await db.query(
-    `SELECT d.*
+    `SELECT d.*, su.name AS leader_name
     FROM departments d
+     LEFT JOIN sso_users su ON d.leader_user_id = su.user_id
     WHERE d.department_id = ?`,
    [id]
  );
@@ -45,6 +47,7 @@ async function update(id, data) {
  if (data.department_name !== undefined) { fields.push('department_name = ?'); values.push(data.department_name); }
  if (data.description !== undefined) { fields.push('description = ?'); values.push(data.description || null); }
  if (data.display_order !== undefined) { fields.push('display_order = ?'); values.push(data.display_order); }
+  if (data.leader_user_id !== undefined) { fields.push('leader_user_id = ?'); values.push(data.leader_user_id || null); }

  if (fields.length === 0) return getById(id);

@@ -61,6 +64,8 @@ async function remove(id) {
  const conn = await db.getConnection();
  try {
    await conn.beginTransaction();
+    // CASCADE가 있지만 방어적으로 명시 삭제
+    await conn.query('DELETE FROM dept_approval_authority WHERE department_id = ?', [id]);
    await conn.query('UPDATE users SET department_id = NULL WHERE department_id = ?', [id]);
    await conn.query('DELETE FROM departments WHERE department_id = ?', [id]);
    await conn.commit();
@@ -72,4 +77,57 @@ async function remove(id) {
  }
 }

-module.exports = { getAll, getById, create, update, remove };
+/* ===== 승인권한 (Approval Authority) ===== */
+
+async function getApprovalAuthorities(departmentId) {
+  const db = getPool();
+  const [rows] = await db.query(
+    `SELECT aa.*, su.name AS approver_name
+     FROM dept_approval_authority aa
+     JOIN sso_users su ON aa.approver_user_id = su.user_id
+     WHERE aa.department_id = ? AND aa.is_active = TRUE
+     ORDER BY aa.approval_type ASC, aa.priority ASC`,
+    [departmentId]
+  );
+  return rows;
+}
+
+async function createApprovalAuthority({ department_id, approval_type, approver_user_id, priority }) {
+  const db = getPool();
+  const [result] = await db.query(
+    `INSERT INTO dept_approval_authority (department_id, approval_type, approver_user_id, priority)
+     VALUES (?, ?, ?, ?)`,
+    [department_id, approval_type, approver_user_id, priority || 1]
+  );
+  const [rows] = await db.query(
+    `SELECT aa.*, su.name AS approver_name
+     FROM dept_approval_authority aa
+     JOIN sso_users su ON aa.approver_user_id = su.user_id
+     WHERE aa.id = ?`,
+    [result.insertId]
+  );
+  return rows[0] || null;
+}
+
+async function deleteApprovalAuthority(id) {
+  const db = getPool();
+  await db.query('DELETE FROM dept_approval_authority WHERE id = ?', [id]);
+}
+
+async function getApproversByType(departmentId, approvalType) {
+  const db = getPool();
+  const [rows] = await db.query(
+    `SELECT aa.*, su.name AS approver_name
+     FROM dept_approval_authority aa
+     JOIN sso_users su ON aa.approver_user_id = su.user_id
+     WHERE aa.department_id = ? AND aa.approval_type = ? AND aa.is_active = TRUE
+     ORDER BY aa.priority ASC`,
+    [departmentId, approvalType]
+  );
+  return rows;
+}
+
+module.exports = {
+  getAll, getById, create, update, remove,
+  getApprovalAuthorities, createApprovalAuthority, deleteApprovalAuthority, getApproversByType
+};
--- a/user-management/api/models/vacationModel.js
+++ b/user-management/api/models/vacationModel.js
@@ -1,8 +1,8 @@
 /**
 * Vacation Model
 *
- * vacation_types + vacation_balance_details CRUD (MariaDB)
- * System 1과 같은 DB를 공유
+ * vacation_types + sp_vacation_balances CRUD (MariaDB)
+ * Sprint 001: workers → sso_users 기반 전환
 */

 const { getPool } = require('./userModel');
@@ -76,34 +76,43 @@ async function updatePriorities(items) {
  }
 }

-/* ===== Vacation Balances (연차 배정) ===== */
+/* ===== Vacation Balances (연차 배정) — sp_vacation_balances + sso_users ===== */

 async function getBalancesByYear(year) {
  const db = getPool();
  const [rows] = await db.query(
-    `SELECT vbd.*, vt.type_code, vt.type_name, vt.deduct_days, vt.priority,
-            w.worker_name, w.hire_date, w.department_id,
+    `SELECT vb.*, vt.type_code, vt.type_name, vt.deduct_days, vt.priority,
+            su.name AS user_name, su.hire_date, su.department_id,
            COALESCE(d.department_name, '미배정') AS department_name
-     FROM vacation_balance_details vbd
-     JOIN vacation_types vt ON vbd.vacation_type_id = vt.id
-     JOIN workers w ON vbd.worker_id = w.worker_id
-     LEFT JOIN departments d ON w.department_id = d.department_id
-     WHERE vbd.year = ?
-     ORDER BY d.department_name ASC, w.worker_name ASC, vt.priority ASC`,
+     FROM sp_vacation_balances vb
+     JOIN vacation_types vt ON vb.vacation_type_id = vt.id
+     JOIN sso_users su ON vb.user_id = su.user_id
+     LEFT JOIN departments d ON su.department_id = d.department_id
+     WHERE su.is_active = 1
+       AND (
+         vb.year = ?
+         OR (vb.balance_type = 'LONG_SERVICE'
+             AND (vb.expires_at IS NULL OR vb.expires_at >= CURDATE()))
+       )
+     ORDER BY d.department_name ASC, su.name ASC, vt.priority ASC`,
    [year]
  );
  return rows;
 }

-async function getBalancesByWorkerYear(workerId, year) {
+async function getBalancesByUserYear(userId, year) {
  const db = getPool();
  const [rows] = await db.query(
-    `SELECT vbd.*, vt.type_code, vt.type_name, vt.deduct_days, vt.priority
-     FROM vacation_balance_details vbd
-     JOIN vacation_types vt ON vbd.vacation_type_id = vt.id
-     WHERE vbd.worker_id = ? AND vbd.year = ?
+    `SELECT vb.*, vt.type_code, vt.type_name, vt.deduct_days, vt.priority
+     FROM sp_vacation_balances vb
+     JOIN vacation_types vt ON vb.vacation_type_id = vt.id
+     WHERE vb.user_id = ? AND (
+       vb.year = ?
+       OR (vb.balance_type = 'LONG_SERVICE'
+           AND (vb.expires_at IS NULL OR vb.expires_at >= CURDATE()))
+     )
     ORDER BY vt.priority ASC`,
-    [workerId, year]
+    [userId, year]
  );
  return rows;
 }
@@ -111,22 +120,22 @@ async function getBalancesByWorkerYear(workerId, year) {
 async function getBalanceById(id) {
  const db = getPool();
  const [rows] = await db.query(
-    `SELECT vbd.*, vt.type_code, vt.type_name
-     FROM vacation_balance_details vbd
-     JOIN vacation_types vt ON vbd.vacation_type_id = vt.id
-     WHERE vbd.id = ?`,
+    `SELECT vb.*, vt.type_code, vt.type_name
+     FROM sp_vacation_balances vb
+     JOIN vacation_types vt ON vb.vacation_type_id = vt.id
+     WHERE vb.id = ?`,
    [id]
  );
  return rows[0] || null;
 }

-async function createBalance({ worker_id, vacation_type_id, year, total_days, used_days, notes, created_by }) {
+async function createBalance({ user_id, vacation_type_id, year, total_days, used_days, notes, created_by, balance_type, expires_at }) {
  const db = getPool();
  const [result] = await db.query(
-    `INSERT INTO vacation_balance_details (worker_id, vacation_type_id, year, total_days, used_days, notes, created_by)
-     VALUES (?, ?, ?, ?, ?, ?, ?)
+    `INSERT INTO sp_vacation_balances (user_id, vacation_type_id, year, total_days, used_days, notes, created_by, balance_type, expires_at)
+     VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
     ON DUPLICATE KEY UPDATE total_days = VALUES(total_days), used_days = VALUES(used_days), notes = VALUES(notes)`,
-    [worker_id, vacation_type_id, year, total_days ?? 0, used_days ?? 0, notes || null, created_by]
+    [user_id, vacation_type_id, year, total_days ?? 0, used_days ?? 0, notes || null, created_by, balance_type || 'AUTO', expires_at || null]
  );
  return result.insertId ? getBalanceById(result.insertId) : null;
 }
@@ -140,13 +149,13 @@ async function updateBalance(id, data) {
  if (data.notes !== undefined) { fields.push('notes = ?'); values.push(data.notes || null); }
  if (fields.length === 0) return getBalanceById(id);
  values.push(id);
-  await db.query(`UPDATE vacation_balance_details SET ${fields.join(', ')} WHERE id = ?`, values);
+  await db.query(`UPDATE sp_vacation_balances SET ${fields.join(', ')} WHERE id = ?`, values);
  return getBalanceById(id);
 }

 async function deleteBalance(id) {
  const db = getPool();
-  await db.query('DELETE FROM vacation_balance_details WHERE id = ?', [id]);
+  await db.query('DELETE FROM sp_vacation_balances WHERE id = ?', [id]);
 }

 async function bulkUpsertBalances(balances) {
@@ -154,41 +163,59 @@ async function bulkUpsertBalances(balances) {
  let count = 0;
  for (const b of balances) {
    await db.query(
-      `INSERT INTO vacation_balance_details (worker_id, vacation_type_id, year, total_days, used_days, notes, created_by)
-       VALUES (?, ?, ?, ?, ?, ?, ?)
+      `INSERT INTO sp_vacation_balances (user_id, vacation_type_id, year, total_days, used_days, notes, created_by, balance_type, expires_at)
+       VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
       ON DUPLICATE KEY UPDATE total_days = VALUES(total_days), notes = VALUES(notes)`,
-      [b.worker_id, b.vacation_type_id, b.year, b.total_days ?? 0, b.used_days ?? 0, b.notes || null, b.created_by]
+      [b.user_id, b.vacation_type_id, b.year, b.total_days ?? 0, b.used_days ?? 0, b.notes || null, b.created_by, b.balance_type || 'AUTO', b.expires_at || null]
    );
    count++;
  }
  return count;
 }

-/* ===== 연차 자동 계산 (근로기준법) ===== */
+/* ===== 연차 자동 계산 (근로기준법 + vacation_settings) ===== */

-function calculateAnnualDays(hireDate, targetYear) {
+function calculateAnnualDays(hireDate, targetYear, settings = {}) {
  if (!hireDate) return 0;
  const hire = new Date(hireDate);
  const yearStart = new Date(targetYear, 0, 1);
  const monthsDiff = (yearStart.getFullYear() - hire.getFullYear()) * 12 + (yearStart.getMonth() - hire.getMonth());

  if (monthsDiff < 0) return 0;
+
+  const firstYearRule = settings.annual_leave_first_year_rule || 'MONTHLY';
+  const baseDays = parseInt(settings.annual_leave_base_days) || 15;
+  const incrementPerYears = parseInt(settings.annual_leave_increment_per_years) || 2;
+  const maxDays = parseInt(settings.annual_leave_max_days) || 25;
+
  if (monthsDiff < 12) {
-    // 1년 미만: 근무 개월 수
+    // 1년 미만
+    if (firstYearRule === 'NONE') return 0;
    return Math.max(0, Math.floor(monthsDiff));
  }
-  // 1년 이상: 15일 + 2년마다 1일 추가 (최대 25일)
+  // 1년 이상: baseDays + incrementPerYears마다 1일 추가 (최대 maxDays)
  const yearsWorked = Math.floor(monthsDiff / 12);
-  const additional = Math.floor((yearsWorked - 1) / 2);
-  return Math.min(15 + additional, 25);
+  const additional = incrementPerYears > 0 ? Math.floor((yearsWorked - 1) / incrementPerYears) : 0;
+  return Math.min(baseDays + additional, maxDays);
 }

-async function autoCalculateForAllWorkers(year, createdBy) {
+async function autoCalculateForAllUsers(year, createdBy, departmentId) {
  const db = getPool();
-  const [workers] = await db.query(
-    'SELECT worker_id, worker_name, hire_date FROM workers WHERE status != ? ORDER BY worker_name',
-    ['inactive']
-  );
+
+  // vacation_settings 로드
+  const vacationSettingsModel = require('./vacationSettingsModel');
+  const settings = await vacationSettingsModel.loadAsObject();
+
+  // sso_users 조회 (부서 필터 선택)
+  let userQuery = 'SELECT user_id, name, hire_date FROM sso_users WHERE is_active = 1 AND partner_company_id IS NULL';
+  const params = [];
+  if (departmentId) {
+    userQuery += ' AND department_id = ?';
+    params.push(departmentId);
+  }
+  userQuery += ' ORDER BY name';
+  const [users] = await db.query(userQuery, params);
+
  // 연차 유형 (ANNUAL_FULL) 찾기
  const [types] = await db.query(
    "SELECT id FROM vacation_types WHERE type_code = 'ANNUAL_FULL' AND is_active = TRUE LIMIT 1"
@@ -197,25 +224,86 @@ async function autoCalculateForAllWorkers(year, createdBy) {
  const annualTypeId = types[0].id;

  const results = [];
-  for (const w of workers) {
-    const days = calculateAnnualDays(w.hire_date, year);
+  for (const u of users) {
+    const days = calculateAnnualDays(u.hire_date, year, settings);
    if (days > 0) {
      await db.query(
-        `INSERT INTO vacation_balance_details (worker_id, vacation_type_id, year, total_days, used_days, notes, created_by)
-         VALUES (?, ?, ?, ?, 0, ?, ?)
+        `INSERT INTO sp_vacation_balances (user_id, vacation_type_id, year, total_days, used_days, notes, created_by, balance_type)
+         VALUES (?, ?, ?, ?, 0, ?, ?, 'AUTO')
         ON DUPLICATE KEY UPDATE total_days = VALUES(total_days), notes = VALUES(notes)`,
-        [w.worker_id, annualTypeId, year, days, `자동계산 (입사: ${w.hire_date ? w.hire_date.toISOString().substring(0,10) : ''})`, createdBy]
+        [u.user_id, annualTypeId, year, days, `자동계산 (입사: ${u.hire_date ? new Date(u.hire_date).toISOString().substring(0, 10) : ''})`, createdBy]
      );
-      results.push({ worker_id: w.worker_id, worker_name: w.worker_name, days, hire_date: w.hire_date });
+      results.push({ user_id: u.user_id, user_name: u.name, days, hire_date: u.hire_date });
    }
  }
+
+  // 장기근속 자동 부여
+  if (settings.long_service_auto_grant === 'true') {
+    const longServiceResults = await autoGrantLongServiceLeave(users, year, createdBy, settings);
+    results.push(...longServiceResults);
+  }
+
  return { count: results.length, results };
 }

+async function autoGrantLongServiceLeave(users, year, createdBy, settings) {
+  const db = getPool();
+
+  const thresholdYears = parseInt(settings.long_service_threshold_years) || 5;
+  const bonusDays = parseInt(settings.long_service_bonus_days) || 3;
+
+  // 연차 유형 (ANNUAL_FULL) 찾기
+  const [types] = await db.query(
+    "SELECT id FROM vacation_types WHERE type_code = 'ANNUAL_FULL' AND is_active = TRUE LIMIT 1"
+  );
+  if (!types.length) return [];
+  const annualTypeId = types[0].id;
+
+  const results = [];
+  for (const u of users) {
+    if (!u.hire_date) continue;
+
+    const hire = new Date(u.hire_date);
+    const yearsWorked = year - hire.getFullYear();
+    // 해당 연도 내 threshold 도래 건만 (소급 없음)
+    if (yearsWorked !== thresholdYears) continue;
+
+    // 기념일이 해당 연도인지 확인
+    const anniversaryDate = new Date(hire);
+    anniversaryDate.setFullYear(hire.getFullYear() + thresholdYears);
+    if (anniversaryDate.getFullYear() !== year) continue;
+
+    // long_service_excluded 체크
+    const [userRows] = await db.query(
+      'SELECT long_service_excluded FROM sso_users WHERE user_id = ?',
+      [u.user_id]
+    );
+    if (userRows[0] && userRows[0].long_service_excluded) continue;
+
+    // 이미 LONG_SERVICE 부여 여부 체크
+    const [existing] = await db.query(
+      `SELECT id FROM sp_vacation_balances
+       WHERE user_id = ? AND balance_type = 'LONG_SERVICE' LIMIT 1`,
+      [u.user_id]
+    );
+    if (existing.length > 0) continue;
+
+    await db.query(
+      `INSERT INTO sp_vacation_balances (user_id, vacation_type_id, year, total_days, used_days, notes, created_by, balance_type, expires_at)
+       VALUES (?, ?, ?, ?, 0, ?, ?, 'LONG_SERVICE', NULL)
+       ON DUPLICATE KEY UPDATE total_days = VALUES(total_days), notes = VALUES(notes)`,
+      [u.user_id, annualTypeId, year, bonusDays, `장기근속 ${thresholdYears}년 자동부여`, createdBy]
+    );
+    results.push({ user_id: u.user_id, user_name: u.name, days: bonusDays, type: 'LONG_SERVICE' });
+  }
+
+  return results;
+}
+
 module.exports = {
  getVacationTypes, getAllVacationTypes, getVacationTypeById,
  createVacationType, updateVacationType, deleteVacationType, updatePriorities,
-  getBalancesByYear, getBalancesByWorkerYear, getBalanceById,
+  getBalancesByYear, getBalancesByUserYear, getBalanceById,
  createBalance, updateBalance, deleteBalance, bulkUpsertBalances,
-  calculateAnnualDays, autoCalculateForAllWorkers
+  calculateAnnualDays, autoCalculateForAllUsers, autoGrantLongServiceLeave
 };
--- a/user-management/api/models/vacationSettingsModel.js
+++ b/user-management/api/models/vacationSettingsModel.js
@@ -0,0 +1,62 @@
+/**
+ * Vacation Settings Model
+ *
+ * vacation_settings 테이블 CRUD + startup migration
+ */
+
+const { getPool } = require('./userModel');
+
+async function getAll() {
+  const db = getPool();
+  const [rows] = await db.query('SELECT * FROM vacation_settings ORDER BY id ASC');
+  return rows;
+}
+
+async function getByKey(key) {
+  const db = getPool();
+  const [rows] = await db.query('SELECT * FROM vacation_settings WHERE setting_key = ?', [key]);
+  return rows[0] || null;
+}
+
+async function updateSettings(settings, updatedBy) {
+  const db = getPool();
+  for (const { setting_key, setting_value } of settings) {
+    await db.query(
+      'UPDATE vacation_settings SET setting_value = ?, updated_by = ? WHERE setting_key = ?',
+      [setting_value, updatedBy, setting_key]
+    );
+  }
+  return getAll();
+}
+
+async function loadAsObject() {
+  const rows = await getAll();
+  const obj = {};
+  for (const row of rows) {
+    obj[row.setting_key] = row.setting_value;
+  }
+  return obj;
+}
+
+async function runMigration() {
+  const db = getPool();
+  const fs = require('fs');
+  const path = require('path');
+  const sqlFile = path.join(__dirname, '..', '..', 'migrations', '20260323_sprint001_vacation_overhaul.sql');
+  const sql = fs.readFileSync(sqlFile, 'utf8');
+  const statements = sql.split(';').map(s => s.trim()).filter(s => s.length > 0);
+  for (const stmt of statements) {
+    try {
+      await db.query(stmt);
+    } catch (err) {
+      if (['ER_DUP_FIELDNAME', 'ER_TABLE_EXISTS_ERROR', 'ER_DUP_KEYNAME'].includes(err.code)) {
+        // Already migrated — safe to ignore
+      } else {
+        throw err;
+      }
+    }
+  }
+  console.log('[tkuser] Sprint 001 migration completed');
+}
+
+module.exports = { getAll, getByKey, updateSettings, loadAsObject, runMigration };