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
|
import {
pgTable, serial, integer, varchar, text, jsonb, timestamp,
pgEnum, index
} from "drizzle-orm/pg-core";
import { users } from "./users";
/* ---------- ① ENUM 정의 ---------- */
export const integrationTypeEnum = pgEnum("integration_type", [
"rest_api", // REST/JSON
"soap", // SOAP/XML
"db_to_db" // DB Link·ETL·FDW 등
]);
export const integrationStatusEnum = pgEnum("integration_status", [
"active",
"inactive",
"deprecated"
]);
export const integrationChangeEnum = pgEnum("integration_change_type", [
"create",
"update",
"status_change",
"delete"
]);
/* ---------- ② 통합 리스트 ---------- */
export const integrations = pgTable(
"integrations",
{
id: serial("id").primaryKey(),
/** 업무식별용 코드('INT_OPS_001') — URL·로그 등 여러 곳에서 쓰기 좋음 */
code: varchar("code", { length: 50 }).unique().notNull(),
name: varchar("name", { length: 255 }).notNull(),
type: integrationTypeEnum("type").notNull(),
description: text("description"),
/** 양쪽 시스템 식별자(ERP, WMS 등) */
sourceSystem: varchar("source_system", { length: 100 }).notNull(),
targetSystem: varchar("target_system", { length: 100 }).notNull(),
status: integrationStatusEnum("status").default("active").notNull(),
/** 각 통합별 개별 설정(JSON)—엔드포인트·쿼리·스케줄 등 */
metadata: jsonb("metadata"),
/* 생성·수정 메타 */
createdBy: integer("created_by")
.references(() => users.id, { onDelete: "set null" }),
updatedBy: integer("updated_by")
.references(() => users.id, { onDelete: "set null" }),
createdAt: timestamp("created_at").defaultNow().notNull(),
updatedAt: timestamp("updated_at").defaultNow().notNull()
},
(t) => ({
/* 조회용 보조 인덱스 */
idxTypeStatus: index("idx_integrations_type_status")
.on(t.type, t.status)
})
);
/* ---------- ③ 이력 테이블 ---------- */
export const integrationHistory = pgTable(
"integration_history",
{
id: serial("id").primaryKey(),
integrationId: integer("integration_id")
.references(() => integrations.id, { onDelete: "cascade" })
.notNull(),
changeType: integrationChangeEnum("change_type").notNull(),
/*
* 변경 전·후 diff 또는 전체 스냅샷.
* { before: {...}, after: {...} } 구조로 저장해 두면
* UI에서 쉽게 '줄바꿈 diff' 로 표시 가능
*/
diff: jsonb("diff").notNull(),
changedBy: integer("changed_by")
.references(() => users.id, { onDelete: "set null" }),
changedAt: timestamp("changed_at").defaultNow().notNull(),
/* 필요 시 다중 변경 그룹핑용 트랜잭션-ID */
txId: varchar("tx_id", { length: 50 })
},
(t) => ({
idxIntegration: index("idx_history_integration")
.on(t.integrationId),
idxChangedAt: index("idx_history_changed_at")
.on(t.changedAt)
})
);
// 타입 정의
export type Integration = typeof integrations.$inferSelect;
export type NewIntegration = typeof integrations.$inferInsert;
export type IntegrationHistory = typeof integrationHistory.$inferSelect;
export type NewIntegrationHistory = typeof integrationHistory.$inferInsert;
|
