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
|
import { NextRequest } from 'next/server';
import db from '@/db/db';
import { biddingProjects, projectSeries } from '@/db/schema/projects';
import {
ToXMLFields,
serveWsdl,
createXMLParser,
extractRequestData,
convertXMLToDBData,
createSoapResponse,
withSoapLogging,
} from '@/lib/soap/utils';
import {
bulkUpsert,
bulkReplaceSubTableData
} from "@/lib/soap/batch-utils";
// 스키마에서 타입 추론
type BiddingProjectData = typeof biddingProjects.$inferInsert;
type ProjectSeriesData = typeof projectSeries.$inferInsert;
// XML 구조 타입 정의 (XML에서 오는 추가 필드 포함)
type BiddingProjectXML = ToXMLFields<Omit<BiddingProjectData, 'id' | 'createdAt' | 'updatedAt'>> & {
shipMHull?: string; // XML에서 오는 추가 필드
};
type ProjectSeriesXML = ToXMLFields<Omit<ProjectSeriesData, 'id' | 'createdAt' | 'updatedAt'>>;
// 처리된 데이터 구조
interface ProcessedBiddingData {
biddingProjects: BiddingProjectData[];
projectSeries: ProjectSeriesData[];
}
// GET 요청 처리는 ?wsdl 달고 있으면 WSDL 서비스 제공
export async function GET(request: NextRequest) {
const url = new URL(request.url);
if (url.searchParams.has('wsdl')) {
return serveWsdl('IF_ECC_EVCP_BIDDING_PROJECT.wsdl');
}
return new Response('Method Not Allowed', { status: 405 });
}
// POST 요청이 데이터 적재 요구 (SOAP)
export async function POST(request: NextRequest) {
const url = new URL(request.url);
if (url.searchParams.has('wsdl')) {
return serveWsdl('IF_ECC_EVCP_BIDDING_PROJECT.wsdl');
}
const body = await request.text();
// SOAP 로깅 래퍼 함수 사용
return withSoapLogging(
'INBOUND',
'ECC',
'IF_ECC_EVCP_BIDDING_PROJECT',
body,
async () => {
console.log('🚀 BIDDING_PROJECT 수신 시작, 데이터 길이:', body.length);
// 1) XML 파싱
const parser = createXMLParser(['biddingProjects', 'projectSeries']);
const parsedData = parser.parse(body);
// 2) SOAP Body 또는 루트에서 요청 데이터 추출
const requestData = extractRequestData(parsedData, 'IF_ECC_EVCP_BIDDING_PROJECTReq');
if (!requestData) {
console.error('유효한 요청 데이터를 찾을 수 없습니다');
throw new Error('Missing request data - IF_ECC_EVCP_BIDDING_PROJECTReq not found');
}
// 3) XML 데이터를 DB 삽입 가능한 형태로 변환
const processedData = transformBiddingData(requestData as BiddingRequestXML);
// 4) 필수 필드 검증
for (const project of processedData.biddingProjects) {
if (!project.pspid) {
throw new Error('Missing required field: pspid in Bidding Project');
}
}
for (const series of processedData.projectSeries) {
if (!series.pspid || !series.sersNo) {
throw new Error('Missing required fields in Project Series: pspid, sersNo');
}
}
// 5) 데이터베이스 저장
await saveToDatabase(processedData);
console.log(`🎉 처리 완료: ${processedData.biddingProjects.length}개 프로젝트, ${processedData.projectSeries.length}개 시리즈`);
// 6) 성공 응답 반환
return createSoapResponse('http://60.101.108.100/', {
'tns:IF_ECC_EVCP_BIDDING_PROJECTRes': {
EV_TYPE: 'S',
},
});
}
).catch((error) => {
// withSoapLogging에서 이미 에러 로그를 처리하므로, 여기서는 응답만 생성
return createSoapResponse('http://60.101.108.100/', {
'tns:IF_ECC_EVCP_BIDDING_PROJECTRes': {
EV_TYPE: 'E',
EV_MESSAGE:
error instanceof Error ? error.message.slice(0, 100) : 'Unknown error',
},
});
});
}
// -----------------------------------------------------------------------------
// 데이터 변환 및 저장 관련 유틸리티
// -----------------------------------------------------------------------------
// Root XML Request 타입
type BiddingRequestXML = {
biddingProjects?: BiddingProjectXML[];
projectSeries?: ProjectSeriesXML[];
};
// XML -> DB 데이터 변환 함수
function transformBiddingData(requestData: BiddingRequestXML): ProcessedBiddingData {
const projects = requestData.biddingProjects || [];
const series = requestData.projectSeries || [];
// Bidding Projects 변환
const biddingProjectsConverted = projects.map((project) => {
const converted = convertXMLToDBData<BiddingProjectData>(
project as Record<string, string | undefined>,
undefined
);
// shipMHull 값을 기준으로 pjtType 결정
if (project.shipMHull) {
converted.pjtType = 'HULL'; // shipMHull 값이 존재하면 해양(HULL)
} else {
converted.pjtType = 'SHIP'; // shipMHull 값이 없으면 조선(SHIP)
}
return converted;
});
// Project Series 변환
const projectSeriesConverted = series.map((seriesItem) => {
return convertXMLToDBData<ProjectSeriesData>(
seriesItem as Record<string, string | undefined>,
undefined
);
});
return {
biddingProjects: biddingProjectsConverted,
projectSeries: projectSeriesConverted,
};
}
// 데이터베이스 저장 함수
async function saveToDatabase(processedData: ProcessedBiddingData) {
console.log(`데이터베이스(배치) 저장 시작: ${processedData.biddingProjects.length}개 프로젝트, ${processedData.projectSeries.length}개 시리즈`);
try {
await db.transaction(async (tx) => {
// 1) Bidding Projects UPSERT (배치)
const biddingProjectRows = processedData.biddingProjects.filter((p): p is BiddingProjectData => !!p.pspid);
await bulkUpsert(tx, biddingProjects, biddingProjectRows, 'pspid');
// 2) Project Series 교체 (배치)
const projectKeys = biddingProjectRows.map((p) => p.pspid as string);
await bulkReplaceSubTableData(tx, projectSeries, processedData.projectSeries, projectSeries.pspid, projectKeys);
});
console.log(`데이터베이스(배치) 저장 완료: ${processedData.biddingProjects.length}개 프로젝트, ${processedData.projectSeries.length}개 시리즈`);
return true;
} catch (error) {
console.error('데이터베이스(배치) 저장 중 오류 발생:', error);
throw error;
}
}
|
