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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
|
'use server'
import db from "@/db/db"
import { eq, desc, and, sql } from "drizzle-orm"
import { contractsDetailView, ContractDetailParsed } from "@/db/schema/contract"
export interface ContractHistoryFilters {
vendorId?: number
projectId?: number
status?: string
startDate?: Date
endDate?: Date
contractNo?: string
search?: string
}
export interface ContractHistoryResult {
data: ContractDetailParsed[]
totalCount: number
pageCount: number
}
export interface ContractHistoryQueryOptions {
page?: number
pageSize?: number
sortBy?: string
sortOrder?: 'asc' | 'desc'
filters?: ContractHistoryFilters
}
/**
* 벤더별 계약 히스토리 조회 (contractsDetailView 사용)
*/
export async function getVendorContractHistory(
vendorId: number,
options: ContractHistoryQueryOptions = {}
): Promise<ContractHistoryResult> {
const {
page = 1,
pageSize = 10,
sortBy = 'createdAt',
sortOrder = 'desc',
filters = {}
} = options
const offset = (page - 1) * pageSize
// where 조건들을 한 번에 구성
const conditions = [eq(contractsDetailView.vendorId, vendorId)]
if (filters.projectId) {
conditions.push(eq(contractsDetailView.projectId, filters.projectId))
}
if (filters.status) {
conditions.push(eq(contractsDetailView.status, filters.status))
}
if (filters.startDate) {
conditions.push(sql`${contractsDetailView.startDate} >= ${filters.startDate}`)
}
if (filters.endDate) {
conditions.push(sql`${contractsDetailView.endDate} <= ${filters.endDate}`)
}
if (filters.contractNo) {
conditions.push(sql`${contractsDetailView.contractNo} ILIKE ${`%${filters.contractNo}%`}`)
}
if (filters.search) {
conditions.push(sql`(
${contractsDetailView.contractNo} ILIKE ${`%${filters.search}%`} OR
${contractsDetailView.contractName} ILIKE ${`%${filters.search}%`} OR
${contractsDetailView.projectName} ILIKE ${`%${filters.search}%`}
)`)
}
const whereCondition = conditions.length === 1 ? conditions[0] : and(...conditions)
// 정렬 설정
const orderByField = sortBy === 'createdAt' ? contractsDetailView.createdAt : contractsDetailView.contractNo
const orderBy = sortOrder === 'desc' ? desc(orderByField) : orderByField
// 데이터 조회
const data = await db
.select()
.from(contractsDetailView)
.where(whereCondition)
.orderBy(orderBy)
.limit(pageSize)
.offset(offset)
// 전체 개수 조회
const [{ count }] = await db
.select({ count: sql<number>`count(*)` })
.from(contractsDetailView)
.where(whereCondition)
const totalCount = count
const pageCount = Math.ceil(totalCount / pageSize)
// ContractDetailParsed 타입으로 변환
const parsedData: ContractDetailParsed[] = data.map(item => ({
...item,
envelopes: JSON.parse(item.envelopes || '[]'),
items: JSON.parse(item.items || '[]')
}))
return {
data: parsedData,
totalCount,
pageCount
}
}
/**
* 벤더별 계약 히스토리 조회 (contractsDetailView 사용)
* contract.ts 스키마를 기준으로 데이터를 가져옴
*/
export async function getVendorContractHistoryExtended(
vendorId: number,
options: ContractHistoryQueryOptions = {}
): Promise<ContractHistoryResult> {
// 기본 함수와 동일한 로직 사용
return getVendorContractHistory(vendorId, options)
}
/**
* 무한 스크롤용 계약 히스토리 조회
*/
export async function getVendorContractHistoryInfinite(
vendorId: number,
cursor?: number,
pageSize: number = 50,
filters?: ContractHistoryFilters
): Promise<{
data: ContractDetailParsed[]
hasNextPage: boolean
nextCursor?: number
}> {
// where 조건들을 한 번에 구성
const conditions = [eq(contractsDetailView.vendorId, vendorId)]
if (cursor) {
conditions.push(sql`${contractsDetailView.id} < ${cursor}`)
}
if (filters?.status) {
conditions.push(eq(contractsDetailView.status, filters.status))
}
if (filters?.contractNo) {
conditions.push(sql`${contractsDetailView.contractNo} ILIKE ${`%${filters.contractNo}%`}`)
}
const whereCondition = conditions.length === 1 ? conditions[0] : and(...conditions)
const data = await db
.select()
.from(contractsDetailView)
.where(whereCondition)
.orderBy(desc(contractsDetailView.createdAt))
.limit(pageSize + 1) // 다음 페이지 확인용 +1
const hasNextPage = data.length > pageSize
const items = hasNextPage ? data.slice(0, -1) : data
const nextCursor = hasNextPage ? items[items.length - 1]?.id : undefined
// ContractDetailParsed 타입으로 변환
const parsedData: ContractDetailParsed[] = items.map(item => ({
...item,
envelopes: JSON.parse(item.envelopes || '[]'),
items: JSON.parse(item.items || '[]')
}))
return {
data: parsedData,
hasNextPage,
nextCursor
}
}
|
