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
|
'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 { sql } from 'drizzle-orm';
const COMPANIES = (process.env.KNOX_COMPANY_CODES || 'P2')
.split(',')
.map((c) => c.trim())
.filter(Boolean);
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 upsertTitles(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)
.onConflictDoUpdate({
target: [titleTable.companyCode, titleTable.titleCode],
set: {
titleName: sql.raw('excluded.title_name'),
enTitleName: sql.raw('excluded.en_title_name'),
sortOrder: sql.raw('excluded.sort_order'),
raw: sql.raw('excluded.raw'),
updatedAt: sql.raw('CURRENT_TIMESTAMP'),
},
});
}
export async function syncKnoxTitles(): Promise<void> {
console.log('[KNOX-SYNC] 직급 동기화 시작');
for (const companyCode of COMPANIES) {
try {
const titles = await getTitlesByCompany(companyCode);
await upsertTitles(titles);
console.log(`[KNOX-SYNC] 직급 동기화 완료 - ${companyCode}: ${titles.length}건`);
} catch (err) {
console.error(`[KNOX-SYNC] 직급 동기화 오류 (company ${companyCode})`, err);
}
}
console.log('[KNOX-SYNC] 직급 동기화 전체 완료');
}
export async function startKnoxTitleSyncScheduler() {
if (DO_FIRST_RUN) {
syncKnoxTitles().catch(console.error);
}
cron.schedule(CRON_STRING, () => {
syncKnoxTitles().catch(console.error);
});
console.log(`[KNOX-SYNC] 직급 동기화 스케줄러 등록 (${CRON_STRING})`);
}
|
