1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
'use server';
import * as cron from 'node-cron';
import db from '@/db/db';
import { title as titleTable } from '@/db/schema/knox/titles';
import { getTitlesByCompany, Title } from '@/lib/knox-api/employee/employee';
import { eq } from 'drizzle-orm';
import {
KNOX_COMPANIES,
delay,
API_CALL_DELAY_MS,
checkTimeRestriction,
checkApiLimitStatus,
initializeApiTracker,
logSyncStart,
logSyncComplete,
logSchedulerInfo,
} from './common';
const CRON_STRING = process.env.KNOX_TITLE_SYNC_CRON || '30 4 * * *';
const DO_FIRST_RUN = process.env.KNOX_TITLE_SYNC_FIRST_RUN === 'true';
async function insertTitles(titles: Title[]) {
if (!titles.length) return;
const rows = titles.map((t) => ({
companyCode: t.companyCode,
titleCode: t.titleCode,
titleName: t.titleName,
enTitleName: t.enTitleName,
sortOrder: t.sortOrder,
raw: t as unknown as Record<string, unknown>,
}));
await db.insert(titleTable).values(rows);
}
/**
* 회사별 기존 직급 데이터 삭제
*/
async function deleteExistingTitles(companyCode: string): Promise<number> {
const result = await db
.delete(titleTable)
.where(eq(titleTable.companyCode, companyCode));
const deletedCount = result.rowCount || 0;
console.log(`[KNOX-SYNC] ${companyCode}: 기존 직급 데이터 ${deletedCount}건 삭제 완료`);
return deletedCount;
}
export async function syncKnoxTitles(): Promise<void> {
logSyncStart('직급');
initializeApiTracker(); // API 추적기 초기화
let totalApiCalls = 0;
const startTime = Date.now();
let currentDelay = API_CALL_DELAY_MS;
for (const companyCode of KNOX_COMPANIES) {
try {
console.log(`[KNOX-SYNC] ${companyCode}: 직급 동기화 시작 (Delete-Insert 방식)`);
// 1단계: 기존 데이터 삭제
await deleteExistingTitles(companyCode);
// 2단계: 회사 간 딜레이 적용 (첫 번째 회사 제외)
if (totalApiCalls > 0) {
await delay(currentDelay);
}
// 3단계: 새로운 직급 데이터 조회 및 삽입
const titles = await getTitlesByCompany(companyCode);
// API 제한 체크 및 delay 조절
const limitStatus = checkApiLimitStatus(1);
currentDelay = limitStatus.recommendedDelay;
totalApiCalls++;
await insertTitles(titles);
console.log(`[KNOX-SYNC] ${companyCode}: 직급 동기화 완료 - ${titles.length}건, API 호출 1회`);
} catch (err) {
console.error(`[KNOX-SYNC] ${companyCode}: 직급 동기화 오류`, err);
}
}
logSyncComplete('직급', totalApiCalls, startTime);
}
export async function startKnoxTitleSyncScheduler() {
if (DO_FIRST_RUN) {
if (!checkTimeRestriction()) {
return;
}
syncKnoxTitles().catch(console.error);
}
cron.schedule(CRON_STRING, () => {
syncKnoxTitles().catch(console.error);
});
logSchedulerInfo('직급', CRON_STRING);
}
|
