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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
"use server"; // Next.js 서버 액션에서 직접 import하려면 (선택)
import { revalidateTag, unstable_noStore } from "next/cache";
import db from "@/db/db";
import { unstable_cache } from "@/lib/unstable-cache";
import { GetTagNumberigSchema } from "./validation";
import { filterColumns } from "@/lib/filter-columns";
import { TagSubfieldOption, tagSubfieldOptions, ViewTagSubfields, viewTagSubfields } from "@/db/schema/vendorData";
import { asc, desc, ilike, inArray, and, gte, lte, not, or, eq } from "drizzle-orm";
import { countTagNumbering, selectTagNumbering } from "./repository";
export async function getTagNumbering(input: GetTagNumberigSchema) {
return unstable_cache(
async () => {
try {
const offset = (input.page - 1) * input.perPage;
// const advancedTable = input.flags.includes("advancedTable");
const advancedTable = true;
// advancedTable 모드면 filterColumns()로 where 절 구성
const advancedWhere = filterColumns({
table: viewTagSubfields,
filters: input.filters,
joinOperator: input.joinOperator,
});
let globalWhere
if (input.search) {
const s = `%${input.search}%`
globalWhere = or(ilike(viewTagSubfields.tagTypeCode, s), ilike(viewTagSubfields.tagTypeDescription, s)
, ilike(viewTagSubfields.attributesId, s) , ilike(viewTagSubfields.attributesDescription, s), ilike(viewTagSubfields.expression, s)
, ilike(viewTagSubfields.projectCode, s), ilike(viewTagSubfields.projectName, s)
)
// 필요시 여러 칼럼 OR조건 (status, priority, etc)
}
const finalWhere = and(
// advancedWhere or your existing conditions
advancedWhere,
globalWhere // and()함수로 결합 or or() 등으로 결합
)
// 아니면 ilike, inArray, gte 등으로 where 절 구성
const where = finalWhere
const orderBy =
input.sort.length > 0
? input.sort.map((item) =>
item.desc ? desc(viewTagSubfields[item.id]) : asc(viewTagSubfields[item.id])
)
: [asc(viewTagSubfields.createdAt)];
// 트랜잭션 내부에서 Repository 호출
const { data, total } = await db.transaction(async (tx) => {
const data = await selectTagNumbering(tx, {
where,
orderBy,
offset,
limit: input.perPage,
});
const total = await countTagNumbering(tx, where);
return { data, total };
});
const pageCount = Math.ceil(total / input.perPage);
return { data, pageCount };
} catch (err) {
// 에러 발생 시 디폴트
return { data: [], pageCount: 0 };
}
},
[JSON.stringify(input)], // 캐싱 키
{
revalidate: 3600,
tags: ["tag-numbering"], // revalidateTag("items") 호출 시 무효화
}
)();
}
export const fetchTagSubfieldOptions = (async (attributesId: string,projectId:number ): Promise<TagSubfieldOption[]> => {
try {
// (A) findMany -> 스키마 제네릭 누락 에러 발생 → 대신 select().from().where() 사용
const rows = await db
.select()
.from(tagSubfieldOptions)
.where(and(eq(tagSubfieldOptions.attributesId, attributesId),eq(tagSubfieldOptions.projectId, projectId)))
.orderBy(asc(tagSubfieldOptions.code))
// rows는 TagSubfieldOption[] 형태
return rows
} catch (error) {
console.error("Error fetching tag subfield options:", error)
return []
}
})
export const getTagNumberingRules = (async (tagType: string): Promise<ViewTagSubfields[]> => {
try {
if (!tagType) {
return []
}
// 기존 findMany 대신 select().from().where() + orderBy
const rules = await db
.select()
.from(viewTagSubfields)
.where(eq(viewTagSubfields.tagTypeDescription, tagType))
.orderBy(asc(viewTagSubfields.sortOrder))
return rules
} catch (error) {
console.error("Error fetching tag numbering rules:", error)
return []
}
})
|
