Knox API 임직원 스키마 추가, 동기화 기능 추가

2 files changed, 246 insertions, 0 deletions

diff --git a/lib/knox-api/employee/code-utils.ts b/lib/knox-api/employee/code-utils.ts
new file mode 100644
index 00000000..36a0e283
--- /dev/null
+++ b/lib/knox-api/employee/code-utils.ts
@@ -0,0 +1,95 @@
+// Knox 임직원/조직 코드 → 한글 설명 매핑
+// 가이드의 Note 컬럼을 하드코딩해두었다.
+
+const CODE_MAPS = {
+  accountStatus: {
+    A: '아이디 승인',
+    W: '아이디 신청',
+    M: '아이디 미발급',
+  },
+  defaultCompanyCode: {
+    O: '원소속',
+    S: '파견소속',
+  },
+  employeeStatus: {
+    B: '재직',
+    V: '휴직',
+  },
+  employeeType: {
+    N: '정규직 (@samsung.com)',
+    U: '협력직',
+    C: '자회사',
+    T: '임시직 (@partner.samsung.com)',
+    X: '협력직 (@samsung.com)',
+    Y: '자회사 (@samsung.com)',
+    Z: '임시직 (@samsung.com)',
+  },
+  gradeTitleIndiCode: {
+    G: '직위',
+    T: '직급',
+    B: '직위/직급 모두',
+  },
+  securityLevel: {
+    '1': '회장단',
+    '2': '사장단',
+    '3': '임원진',
+    '4': '간부',
+    '5': '사원',
+    '9': '협력사 임직원',
+  },
+  executiveYn: {
+    Y: '임원',
+    N: '직원',
+  },
+  realNameYn: {
+    R: '실명',
+    V: '가명',
+  },
+  localStaffYn: {
+    Y: '현채인',
+    N: '현채인 아님',
+  },
+  serverLocation: {
+    KR: '한국',
+    GB: '구주',
+    US: '미주',
+  },
+} as const;
+
+type CodeField = keyof typeof CODE_MAPS;
+type CodeValue<F extends CodeField> = keyof (typeof CODE_MAPS)[F];
+
+/**
+ * 개별 코드 설명 반환
+ * @param field 코드 필드명 (예: 'accountStatus')
+ * @param code  코드 값 (예: 'A')
+ * @returns    한글 설명 (없으면 undefined)
+ */
+export function getCodeDescription<F extends CodeField>(
+  field: F,
+  code: CodeValue<F> | string | undefined | null,
+): string | undefined {
+  if (!code) return undefined;
+  // 대소문자 구분 없음 처리
+  const normalized = String(code).toUpperCase() as CodeValue<F>;
+  const map = CODE_MAPS[field] as Record<string, string>;
+  return map[normalized as string];
+}
+
+/**
+ * Employee 객체에 *_Desc 필드로 설명을 붙여 반환
+ * (원본 객체는 수정하지 않음)
+ */
+export function withCodeDescriptions<T extends Record<string, unknown>>(employee: T) {
+  const result: Record<string, unknown> = { ...employee };
+  (Object.keys(CODE_MAPS) as CodeField[]).forEach((field) => {
+    if (field in employee) {
+      const desc = getCodeDescription(field, employee[field] as string);
+      if (desc) result[`${field}Desc`] = desc;
+    }
+  });
+  return result as T & { [K in `${CodeField}Desc`]?: string };
+}
+
+// export 전체 매핑이 필요하면 아래 내보내기
+export { CODE_MAPS }; 
\ No newline at end of file
diff --git a/lib/knox-sync/employee-sync-service.ts b/lib/knox-sync/employee-sync-service.ts
new file mode 100644
index 00000000..c517be14
--- /dev/null
+++ b/lib/knox-sync/employee-sync-service.ts
@@ -0,0 +1,151 @@
+'use server';
+
+import * as cron from 'node-cron';
+import db from '@/db/db';
+import { employee as employeeTable } from '@/db/schema/knox/employee';
+import {
+  searchEmployees,
+  getDepartmentsByCompany,
+  Employee,
+} from '@/lib/knox-api/employee/employee';
+import { sql } from 'drizzle-orm';
+
+// 동기화 대상 회사 코드 (쉼표로 구분된 ENV)
+const COMPANIES = (process.env.KNOX_COMPANY_CODES || 'P2')
+  .split(',')
+  .map((c) => c.trim())
+  .filter(Boolean);
+
+const CRON_STRING = process.env.KNOX_EMPLOYEE_SYNC_CRON || '0 4 * * *';
+
+const DO_FIRST_RUN = process.env.KNOX_EMPLOYEE_SYNC_FIRST_RUN === 'true';
+
+async function upsertEmployees(employees: Employee[]) {
+  if (!employees.length) return;
+
+  const rows = employees.map((e) => ({
+    epId: e.epId,
+    employeeNumber: e.employeeNumber,
+    userId: e.userId,
+    fullName: e.fullName,
+    givenName: e.givenName,
+    sirName: e.sirName,
+    companyCode: e.companyCode,
+    companyName: e.companyName,
+    departmentCode: e.departmentCode,
+    departmentName: e.departmentName,
+    titleCode: e.titleCode,
+    titleName: e.titleName,
+    emailAddress: e.emailAddress,
+    mobile: e.mobile,
+    employeeStatus: e.employeeStatus,
+    employeeType: e.employeeType,
+    accountStatus: e.accountStatus,
+    securityLevel: e.securityLevel,
+    preferredLanguage: e.preferredLanguage,
+    description: e.description,
+    raw: e as unknown as Record<string, unknown>,
+    enCompanyName: e.enCompanyName,
+    enDepartmentName: e.enDepartmentName,
+    enDiscription: e.enDiscription,
+    enFullName: e.enFullName,
+    enGivenName: e.enGivenName,
+    enGradeName: e.enGradeName,
+    enSirName: e.enSirName,
+    enTitleName: e.enTitleName,
+    gradeName: e.gradeName,
+    gradeTitleIndiCode: e.gradeTitleIndiCode,
+    jobName: e.jobName,
+    realNameYn: e.realNameYn,
+    serverLocation: e.serverLocation,
+    titleSortOrder: e.titleSortOrder,
+  }));
+
+  await db
+    .insert(employeeTable)
+    .values(rows)
+    .onConflictDoUpdate({
+      target: employeeTable.epId,
+      set: {
+        fullName: sql.raw('excluded.full_name'),
+        givenName: sql.raw('excluded.given_name'),
+        sirName: sql.raw('excluded.sir_name'),
+        companyCode: sql.raw('excluded.company_code'),
+        companyName: sql.raw('excluded.company_name'),
+        departmentCode: sql.raw('excluded.department_code'),
+        departmentName: sql.raw('excluded.department_name'),
+        titleCode: sql.raw('excluded.title_code'),
+        titleName: sql.raw('excluded.title_name'),
+        emailAddress: sql.raw('excluded.email_address'),
+        mobile: sql.raw('excluded.mobile'),
+        employeeStatus: sql.raw('excluded.employee_status'),
+        employeeType: sql.raw('excluded.employee_type'),
+        accountStatus: sql.raw('excluded.account_status'),
+        securityLevel: sql.raw('excluded.security_level'),
+        preferredLanguage: sql.raw('excluded.preferred_language'),
+        description: sql.raw('excluded.description'),
+        raw: sql.raw('excluded.raw'),
+        updatedAt: sql.raw('CURRENT_TIMESTAMP'),
+      },
+    });
+}
+
+export async function syncKnoxEmployees(): Promise<void> {
+  console.log('[KNOX-SYNC] 임직원 동기화 시작');
+
+  for (const companyCode of COMPANIES) {
+    try {
+      const departments = await getDepartmentsByCompany(companyCode);
+      console.log(`[KNOX-SYNC] ${companyCode}: 부서 ${departments.length}개`);
+
+      for (const dept of departments) {
+        let page = 1;
+        let totalPage = 1;
+        do {
+          const resp = await searchEmployees({
+            companyCode,
+            departmentCode: dept.departmentCode,
+            page: String(page),
+            resultType: 'basic',
+          });
+
+          if (resp.result === 'success') {
+            await upsertEmployees(resp.employees);
+            totalPage = resp.totalPage;
+            console.log(
+              `[KNOX-SYNC] 임직원 동기화 ${companyCode}/${dept.departmentCode} ${page}/${totalPage} 페이지 처리`
+            );
+          } else {
+            console.warn(
+              `[KNOX-SYNC] 임직원 동기화 실패: ${companyCode}/${dept.departmentCode} page ${page}`
+            );
+            break;
+          }
+
+          page += 1;
+        } while (page <= totalPage);
+      }
+    } catch (err) {
+      console.error(
+        `[KNOX-SYNC] 임직원 동기화 오류 (company ${companyCode})`,
+        err
+      );
+    }
+  }
+
+  console.log('[KNOX-SYNC] 임직원 동기화 완료');
+}
+
+export async function startKnoxEmployeeSyncScheduler() {
+  // 환경 변수에 따라 실행시 즉시 실행 여부 결정 (없으면 false)
+  if (DO_FIRST_RUN) {
+    syncKnoxEmployees().catch(console.error);
+  }
+
+  // CRON JOB 등록
+  cron.schedule(CRON_STRING, () => {
+    syncKnoxEmployees().catch(console.error);
+  });
+
+  console.log(`[KNOX-SYNC] 임직원 동기화 스케줄러 등록 (${CRON_STRING})`);
+}