diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/knox-api/employee/code-utils.ts | 95 | ||||
| -rw-r--r-- | lib/knox-sync/employee-sync-service.ts | 151 |
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})`); +} |