diff options
Diffstat (limited to 'app/api')
3 files changed, 35 insertions, 7 deletions
diff --git a/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts b/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts index 44ec3f36..c2b9db46 100644 --- a/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts +++ b/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PO_INFORMATION/route.ts @@ -23,6 +23,10 @@ import { bulkUpsert, bulkReplaceSubTableData } from "@/lib/soap/batch-utils"; +import { + mapAndSaveECCPOData, + ProcessedPOData as POMapperProcessedData +} from "@/lib/soap/ecc/mapper/po-mapper"; // 스키마에서 타입 추론 type HeaderData = typeof ZMM_HD.$inferInsert; @@ -105,12 +109,24 @@ export async function POST(request: NextRequest) { } } - // 5) 데이터베이스 저장 + // 5) 원본 ECC 데이터 저장 (기존 로직 유지) await saveToDatabase(processedData); - console.log(`🎉 처리 완료: ${processedData.length}개 PO 데이터`); + // 6) PO 데이터를 비즈니스 테이블(contracts, contract_items)로 매핑 + // ProcessedPOData를 POMapperProcessedData 형식으로 변환 + const mappingData: POMapperProcessedData[] = processedData.map(poData => ({ + header: poData.header, + details: poData.details + })); + + const poMappingResult = await mapAndSaveECCPOData(mappingData); + if (!poMappingResult.success) { + throw new Error(`PO 비즈니스 테이블 매핑 실패: ${poMappingResult.message}`); + } + + console.log(`🎉 처리 완료: ${processedData.length}개 PO 데이터, ${poMappingResult.processedCount}개 계약 매핑`); - // 6) 성공 응답 반환 + // 7) 성공 응답 반환 return createSoapResponse('http://60.101.108.100/', { 'tns:IF_ECC_EVCP_PO_INFORMATIONRes': { EV_TYPE: 'S', diff --git a/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PR_INFORMATION/route.ts b/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PR_INFORMATION/route.ts index 4ae1bbda..6eddf757 100644 --- a/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PR_INFORMATION/route.ts +++ b/app/api/(S-ERP)/(ECC)/IF_ECC_EVCP_PR_INFORMATION/route.ts @@ -20,7 +20,7 @@ import { } from "@/lib/soap/batch-utils"; import { mapAndSaveECCRfqData -} from "@/lib/soap/ecc-mapper"; +} from "@/lib/soap/ecc/mapper/rfq-and-pr-mapper"; // 스키마에서 타입 추론 diff --git a/app/api/(S-ERP)/(MDG)/IF_MDZ_EVCP_PROJECT_MASTER/route.ts b/app/api/(S-ERP)/(MDG)/IF_MDZ_EVCP_PROJECT_MASTER/route.ts index fd7fb027..a1a016c2 100644 --- a/app/api/(S-ERP)/(MDG)/IF_MDZ_EVCP_PROJECT_MASTER/route.ts +++ b/app/api/(S-ERP)/(MDG)/IF_MDZ_EVCP_PROJECT_MASTER/route.ts @@ -15,6 +15,9 @@ import { withSoapLogging } from "@/lib/soap/utils"; import { bulkUpsert } from "@/lib/soap/batch-utils"; // 서브테이블 없음 +import { + mapAndSaveMDGProjectData +} from "@/lib/soap/mdg/mapper/project-mapper"; // 스키마에서 직접 타입 추론 @@ -51,7 +54,7 @@ export async function POST(request: NextRequest) { 'IF_MDZ_EVCP_PROJECT_MASTER', body, async () => { - console.log('Request Body 일부:', body.substring(0, 200) + (body.length > 200 ? '...' : '')); + console.log('🚀 PROJECT_MASTER 수신 시작, 데이터 길이:', body.length); const parser = createXMLParser(['CMCTB_PROJ_MAST']); const parsedData = parser.parse(body); @@ -83,10 +86,19 @@ export async function POST(request: NextRequest) { } } - // 데이터베이스 저장 + // 1) 원본 MDG 데이터 저장 (기존 로직 유지) await saveToDatabase(processedProjects); - console.log(`Processed ${processedProjects.length} projects`); + // 2) 비즈니스 테이블 projects에 매핑하여 저장 + const projectMappingResult = await mapAndSaveMDGProjectData( + processedProjects.map(p => p.project) + ); + + if (!projectMappingResult.success) { + throw new Error(`프로젝트 비즈니스 테이블 매핑 실패: ${projectMappingResult.message}`); + } + + console.log(`🎉 처리 완료: ${processedProjects.length}개 프로젝트, ${projectMappingResult.processedCount}개 비즈니스 테이블 매핑`); return createSuccessResponse('http://60.101.108.100/api/IF_MDZ_EVCP_PROJECT_MASTER/'); } |