diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/rfq-last/contract-actions.ts | 209 | ||||
| -rw-r--r-- | lib/soap/ecc/send/create-po.ts | 49 | ||||
| -rw-r--r-- | lib/soap/sender.ts | 103 | ||||
| -rw-r--r-- | lib/soap/types.ts | 64 | ||||
| -rw-r--r-- | lib/soap/utils.ts | 26 |
5 files changed, 280 insertions, 171 deletions
diff --git a/lib/rfq-last/contract-actions.ts b/lib/rfq-last/contract-actions.ts index 26b50c3c..a4be7e48 100644 --- a/lib/rfq-last/contract-actions.ts +++ b/lib/rfq-last/contract-actions.ts @@ -13,6 +13,7 @@ import { generateContractNumber } from "../general-contracts/service"; import { generateBiddingNumber } from "../bidding/service"; import { createPurchaseOrder } from "@/lib/soap/ecc/send/create-po"; import { getCurrentSAPDate } from "@/lib/soap/utils"; +import { SoapResponseError } from "@/lib/soap/types"; // ===== PO (SAP) 생성 ===== interface CreatePOParams { @@ -111,73 +112,121 @@ export async function createPO(params: CreatePOParams) { quotationItems.map(item => [item.rfqPrItemId, item]) ); - // 4. 필수 필드 검증 (경고만 출력, 전송은 계속 진행) + // 4. 필수 필드 설정 - 벤더 견적 응답 조건 우선, 구매자 제시 조건을 fallback으로 사용 + // 우선순위: vendorResponse (벤더 제출 조건) > detailData (구매자 제시 조건) + + const validationErrors: string[] = []; + + // 헤더 필수 필드 검증 및 설정 + // 1. LIFNR - 벤더 코드 if (!vendorData.vendorCode) { - console.warn(`⚠️ 벤더 코드가 없습니다. (Vendor ID: ${vendorData.id}) - 빈 값으로 전송합니다.`); + validationErrors.push(`❌ 벤더 코드 (Vendor ID: ${vendorData.id})`); } - const vendorCode = vendorData.vendorCode || ''; // 빈 값으로 기본값 설정 + const vendorCode = vendorData.vendorCode || ''; - if (!detailData.paymentTermsCode) { - console.warn("⚠️ 지급조건(Payment Terms)이 설정되지 않았습니다. - 빈 값으로 전송합니다."); + // 2. ANFNR - RFQ 번호 + const anfnr = rfqData.ANFNR || rfqData.rfqCode; + if (!anfnr) { + validationErrors.push(`❌ RFQ 번호 (ANFNR 또는 rfqCode)`); } - const paymentTermsCode = detailData.paymentTermsCode || ''; // 빈 값으로 기본값 설정 - if (!detailData.incotermsCode) { - console.warn("⚠️ 인코텀즈(Incoterms)가 설정되지 않았습니다. - 빈 값으로 전송합니다."); + // 3. WAERS - 통화 (벤더 견적 통화 우선) + const currency = vendorResponse.vendorCurrency || vendorResponse.currency || detailData.currency || params.currency || ''; + if (!currency) { + validationErrors.push(`❌ 통화(Currency) - 벤더 견적 또는 RFQ 조건에 통화가 설정되지 않았습니다.`); + } + + // 4. ZTERM - 지급조건 (벤더 제안 조건 우선) + const paymentTermsCode = vendorResponse.vendorPaymentTermsCode || detailData.paymentTermsCode || ''; + if (!paymentTermsCode) { + validationErrors.push(`❌ 지급조건(Payment Terms) - 벤더 견적 또는 RFQ 조건에 지급조건이 설정되지 않았습니다.`); } - const incotermsCode = detailData.incotermsCode || ''; // 빈 값으로 기본값 설정 - // incoterms 테이블에서 description 조회 (INCO2용) + // 5. INCO1 - 인코텀즈 코드 (벤더 제안 조건 우선) + const incotermsCode = vendorResponse.vendorIncotermsCode || detailData.incotermsCode || ''; + if (!incotermsCode) { + validationErrors.push(`❌ 인코텀즈 코드(Incoterms) - 벤더 견적 또는 RFQ 조건에 인코텀즈가 설정되지 않았습니다.`); + } + + // 6. INCO2 - 인코텀즈 상세 설명 (벤더 제안 조건 우선) let incotermsDescription = ''; if (incotermsCode) { - const [incotermsData] = await db - .select({ description: incoterms.description }) - .from(incoterms) - .where(eq(incoterms.code, incotermsCode)) - .limit(1); - - if (incotermsData?.description) { - incotermsDescription = incotermsData.description; + // 우선순위: 1) 벤더 제출 상세 정보, 2) incoterms 테이블 조회, 3) 구매자 제시 상세 정보 + if (vendorResponse.vendorIncotermsDetail) { + incotermsDescription = vendorResponse.vendorIncotermsDetail; } else { - console.warn(`⚠️ 인코텀즈 코드 '${incotermsCode}'에 대한 설명을 찾을 수 없습니다. - detailData.incotermsDetail을 사용합니다.`); - incotermsDescription = detailData.incotermsDetail || ''; + const [incotermsData] = await db + .select({ description: incoterms.description }) + .from(incoterms) + .where(eq(incoterms.code, incotermsCode)) + .limit(1); + + if (incotermsData?.description) { + incotermsDescription = incotermsData.description; + } else if (detailData.incotermsDetail) { + incotermsDescription = detailData.incotermsDetail; + } else { + validationErrors.push(`❌ 인코텀즈 상세 정보(INCO2) - 인코텀즈 코드 '${incotermsCode}'에 대한 설명을 찾을 수 없습니다.`); + } } - } else { - console.warn("⚠️ 인코텀즈 상세 정보(INCO2)가 설정되지 않았습니다. - 빈 값으로 전송합니다."); - incotermsDescription = detailData.incotermsDetail || ''; } - - if (!detailData.taxCode) { - console.warn("⚠️ 세금코드(Tax Code)가 설정되지 않았습니다. - 빈 값으로 전송합니다."); + + // 7. MWSKZ - 세금코드 (벤더 제안 조건 우선) + const taxCode = vendorResponse.vendorTaxCode || detailData.taxCode || ''; + if (!taxCode) { + validationErrors.push(`❌ 세금코드(Tax Code) - 벤더 견적 또는 RFQ 조건에 세금코드가 설정되지 않았습니다.`); } - const taxCode = detailData.taxCode || ''; // 빈 값으로 기본값 설정 + + // PR 아이템 필드를 미리 검증하기 위해 순회 + prItems.forEach((item, index) => { + const itemNum = index + 1; + + if (!item.uom) { + validationErrors.push(`❌ PR 아이템 ${itemNum}번 - 단위(UOM)`); + } + + const quoteItem = quotationItemMap.get(item.id); + if (!quoteItem) { + validationErrors.push(`❌ PR 아이템 ${itemNum}번 - 견적 정보 없음 (PR Item ID: ${item.id})`); + } else { + const unitPrice = Number(quoteItem.unitPrice) || 0; + const totalPrice = Number(quoteItem.totalPrice) || 0; + + if (unitPrice <= 0 || totalPrice <= 0) { + validationErrors.push(`❌ PR 아이템 ${itemNum}번 - 가격 정보 (단가: ${unitPrice}, 총액: ${totalPrice})`); + } + } + }); - if (!detailData.currency && !params.currency) { - console.warn("⚠️ 통화(Currency)가 설정되지 않았습니다. - KRW로 기본 설정합니다."); + // 검증 에러가 있으면 한 번에 throw + if (validationErrors.length > 0) { + const errorMessage = `SAP PO 생성을 위한 필수 필드가 누락되었습니다:\n\n${validationErrors.join('\n')}\n\n위 필드들을 모두 입력해주세요.`; + console.error("❌ 필수 필드 검증 실패:", errorMessage); + throw new Error(errorMessage); } - const currency = detailData.currency || params.currency || 'KRW'; // KRW를 기본값으로 설정 - // ANFNR: rfqsLast.ANFNR 우선, 없으면 rfqCode 사용 (ITB, 일반견적은 ANFNR 없으므로..) - const anfnr = rfqData.ANFNR || rfqData.rfqCode || ''; - if (!anfnr) { - console.warn("⚠️ RFQ 번호(ANFNR 또는 rfqCode)가 없습니다. - 빈 값으로 전송합니다."); - } + // 검증 완료: 이제 안전하게 사용 가능 (타입 단언) + const validAnfnr = anfnr as string; + const validVendorCode = vendorCode as string; + const validPaymentTermsCode = paymentTermsCode as string; + const validIncotermsCode = incotermsCode as string; + const validTaxCode = taxCode as string; // 5. PO 데이터 구성 const poData = { T_Bidding_HEADER: [{ // 필수 필드 - ANFNR: anfnr, - LIFNR: vendorCode, + ANFNR: validAnfnr, + LIFNR: validVendorCode, ZPROC_IND: '9', // 구매 처리 상태: 9 (기존 로그 기준) WAERS: currency, - ZTERM: paymentTermsCode, - INCO1: incotermsCode, + ZTERM: validPaymentTermsCode, + INCO1: validIncotermsCode, INCO2: incotermsDescription.substring(0, 28), // SAP 최대 28자리 제한, incoterms 테이블의 description 사용 - MWSKZ: taxCode, + MWSKZ: validTaxCode, LANDS: vendorCountryCode, // 벤더 국가 코드 사용 ZRCV_DT: getCurrentSAPDate(), - ZATTEN_IND: 'N', // 참석 여부: N (기본값, 실제 데이터 없음) + ZATTEN_IND: 'Y', // 참석 여부: Y (고정값) IHRAN: getCurrentSAPDate(), // Optional 필드 (명시적으로 포함 - 유지보수를 위해 구조 유지) @@ -189,25 +238,18 @@ export async function createPO(params: CreatePOParams) { LSTEL: '', // Loading Point (데이터 없음) }], T_Bidding_ITEM: prItems.map((item, index) => { - if (!item.uom) { - console.warn(`⚠️ PR 아이템 ${index + 1}번의 단위(UOM)가 없습니다. - 빈 값으로 전송합니다.`); - } - - // 견적 아이템에서 실제 가격 정보 가져오기 - const quoteItem = quotationItemMap.get(item.id); - if (!quoteItem) { - console.warn(`⚠️ PR 아이템 ${item.id}에 대한 견적 정보를 찾을 수 없습니다. - 기본값으로 전송합니다.`); - } + // 견적 아이템에서 실제 가격 정보 가져오기 (이미 검증됨) + const quoteItem = quotationItemMap.get(item.id)!; // 검증 통과했으므로 non-null assertion // 가격 계산: SAP은 소수점을 포함한 문자열 형태로 받음 // DB에서 가져온 값을 명시적으로 숫자로 변환 (문자열이나 Decimal 타입일 수 있음) - const unitPrice = Number(quoteItem?.unitPrice) || 0; - const quantity = Number(quoteItem?.quantity || item.quantity) || 0; - const totalPrice = Number(quoteItem?.totalPrice) || (unitPrice * quantity); + const unitPrice = Number(quoteItem.unitPrice); + const quantity = Number(quoteItem.quantity || item.quantity); + const totalPrice = Number(quoteItem.totalPrice) || (unitPrice * quantity); // 납기일 계산 (우선순위: 견적 납기일 > PR 납기일 > 현재일자) let deliveryDate = getCurrentSAPDate(); - if (quoteItem?.vendorDeliveryDate) { + if (quoteItem.vendorDeliveryDate) { deliveryDate = new Date(quoteItem.vendorDeliveryDate).toISOString().split('T')[0].replace(/-/g, ''); } else if (item.deliveryDate) { deliveryDate = new Date(item.deliveryDate).toISOString().split('T')[0].replace(/-/g, ''); @@ -215,12 +257,12 @@ export async function createPO(params: CreatePOParams) { return { // 필수 필드 - ANFNR: anfnr, + ANFNR: validAnfnr, ANFPS: item.prItem || (index + 1).toString().padStart(5, '0'), // PR Item Number 사용 - LIFNR: vendorCode, + LIFNR: validVendorCode, NETPR: unitPrice.toFixed(2), // 단가 (소수점 2자리) PEINH: '1', // 가격 단위: 1 (표준값, 1단위당 가격) - BPRME: item.uom || '', + BPRME: item.uom!, // 검증 통과했으므로 non-null assertion NETWR: totalPrice.toFixed(2), // 순액 (세금 제외) BRTWR: totalPrice.toFixed(2), // 총액: SAP이 taxCode(MWSKZ)로 세금 계산하도록 순액과 동일하게 전송 LFDAT: deliveryDate, @@ -229,31 +271,28 @@ export async function createPO(params: CreatePOParams) { ZCON_NO_PO: item.prNo || '', // PR Consolidation Number EBELP: '', // Series PO Item Seq (시리즈 PO가 아니면 빈 값) }; - }), - T_PR_RETURN: prItems.map((item, index) => ({ - // 필수 필드 - ANFNR: anfnr, - ANFPS: item.prItem || (index + 1).toString().padStart(5, '0'), - EBELN: item.prNo || rfqData.prNumber || '', - EBELP: item.prItem || (index + 1).toString().padStart(5, '0'), - MSGTY: 'S', // Message Type: S (Standard/Success) - - // Optional 필드 (명시적으로 포함 - 유지보수를 위해 구조 유지) - MSGTXT: 'PO Creation from RFQ', // Message Text - })) + }) + // T_PR_RETURN은 응답용 필드이므로 요청에 포함하지 않음 }; console.log('📤 SAP으로 PO 전송 시작:', { - ANFNR: anfnr, - LIFNR: vendorCode, + ANFNR: validAnfnr, + LIFNR: validVendorCode, vendorName: vendorData.vendorName, vendorCountry: vendorCountryCode, itemCount: prItems.length, quotationItemCount: quotationItems.length, totalAmount: params.totalAmount, currency: currency, - taxCode: taxCode, - incoterms: `${incotermsCode} - ${incotermsDescription}`, + paymentTerms: validPaymentTermsCode, + incoterms: `${validIncotermsCode} - ${incotermsDescription}`, + taxCode: validTaxCode, + dataSource: { + currency: vendorResponse.vendorCurrency ? '벤더 견적' : (detailData.currency ? '구매자 조건' : 'params'), + paymentTerms: vendorResponse.vendorPaymentTermsCode ? '벤더 견적' : '구매자 조건', + incoterms: vendorResponse.vendorIncotermsCode ? '벤더 견적' : '구매자 조건', + taxCode: vendorResponse.vendorTaxCode ? '벤더 견적' : '구매자 조건', + } }); // 디버깅: 전송 데이터 전체 로그 (서버 측 로그이므로 모든 정보 포함) @@ -269,7 +308,7 @@ export async function createPO(params: CreatePOParams) { console.log('✅ SAP PO 전송 성공:', sapResult); // 7. 실제 PO 번호 추출 (SOAP 응답에서 추출하거나 ANFNR 사용) - const actualPoNumber = sapResult.bidding_number || anfnr; + const actualPoNumber = sapResult.bidding_number || validAnfnr; // 8. DB에 실제 PO 번호 저장 및 RFQ 상태 업데이트 await db.transaction(async (tx) => { @@ -312,10 +351,30 @@ export async function createPO(params: CreatePOParams) { }; } catch (error) { console.error("❌ PO 생성 오류:", error); - return { + + // 에러 객체에서 추가 정보 추출 (SOAP 응답 포함) + const errorResponse: { + success: false; + error: string; + responseData?: string; + statusCode?: number; + } = { success: false, error: error instanceof Error ? error.message : "PO 생성 중 오류가 발생했습니다." }; + + // SOAP 응답 에러인 경우 상세 정보 추가 + if (error instanceof SoapResponseError) { + if (error.responseText) { + errorResponse.responseData = error.responseText; + console.error("📄 SAP 응답 내용:", error.responseText); + } + if (error.statusCode) { + errorResponse.statusCode = error.statusCode; + } + } + + return errorResponse; } } diff --git a/lib/soap/ecc/send/create-po.ts b/lib/soap/ecc/send/create-po.ts index 0984a208..1e21d39c 100644 --- a/lib/soap/ecc/send/create-po.ts +++ b/lib/soap/ecc/send/create-po.ts @@ -44,23 +44,11 @@ export interface POItemData { EBELP?: string; // Series PO Item Seq } -// PR 반환 데이터 타입 -export interface PRReturnData { - ANFNR: string; // PR Request Number (M) - ANFPS: string; // Item Number of PR Request (M) - EBELN: string; // Purchase Requisition Number (M) - EBELP: string; // Item Number of Purchase Requisition (M) - MSGTY: string; // Message Type (M) - MSGTXT?: string; // Message Text -} - // PO 생성 요청 데이터 타입 +// 참고: T_PR_RETURN, EV_ERDAT, EV_ERZET는 응답용 필드이므로 요청에 포함하지 않음 export interface POCreateRequest { T_Bidding_HEADER: POHeaderData[]; T_Bidding_ITEM: POItemData[]; - T_PR_RETURN: PRReturnData[]; - EV_ERDAT?: string; // Extract Date - EV_ERZET?: string; // Extract Time } @@ -72,10 +60,8 @@ function createPOSoapBodyContent(poData: POCreateRequest): Record<string, unknow return { 'p1:MT_P2MM3015_S': { // WSDL에서 사용하는 p1 접두사 적용 'T_Bidding_HEADER': poData.T_Bidding_HEADER, - 'T_Bidding_ITEM': poData.T_Bidding_ITEM, - 'T_PR_RETURN': poData.T_PR_RETURN, - ...(poData.EV_ERDAT && { 'EV_ERDAT': poData.EV_ERDAT }), - ...(poData.EV_ERZET && { 'EV_ERZET': poData.EV_ERZET }) + 'T_Bidding_ITEM': poData.T_Bidding_ITEM + // T_PR_RETURN, EV_ERDAT, EV_ERZET는 응답용 필드이므로 요청에 포함하지 않음 } }; } @@ -112,19 +98,7 @@ function validatePOData(poData: POCreateRequest): { isValid: boolean; errors: st }); } - // PR 반환 데이터 검증 - if (!poData.T_PR_RETURN || poData.T_PR_RETURN.length === 0) { - errors.push('T_PR_RETURN은 필수입니다.'); - } else { - poData.T_PR_RETURN.forEach((prReturn, index) => { - const requiredFields = ['ANFNR', 'ANFPS', 'EBELN', 'EBELP', 'MSGTY']; - requiredFields.forEach(field => { - if (!prReturn[field as keyof PRReturnData]) { - errors.push(`T_PR_RETURN[${index}].${field}는 필수입니다.`); - } - }); - }); - } + // T_PR_RETURN은 응답용 필드이므로 검증하지 않음 return { isValid: errors.length === 0, @@ -165,7 +139,7 @@ async function sendPOToECC(poData: POCreateRequest): Promise<SoapSendResult> { }; console.log(`📤 PO 생성 요청 전송 시작 - ANFNR: ${poData.T_Bidding_HEADER[0]?.ANFNR}`); - console.log(`🔍 헤더 ${poData.T_Bidding_HEADER.length}개, 아이템 ${poData.T_Bidding_ITEM.length}개, PR 반환 ${poData.T_PR_RETURN.length}개`); + console.log(`🔍 헤더 ${poData.T_Bidding_HEADER.length}개, 아이템 ${poData.T_Bidding_ITEM.length}개`); // SOAP XML 전송 const result = await sendSoapXml(config, logInfo); @@ -341,17 +315,8 @@ export async function createTestPurchaseOrder(): Promise<{ LFDAT: getCurrentSAPDate(), ZCON_NO_PO: 'CON001', EBELP: '00001' - }], - T_PR_RETURN: [{ - ANFNR: 'TEST001', - ANFPS: '00001', - EBELN: 'PR001', - EBELP: '00001', - MSGTY: 'S', - MSGTXT: 'Test message' - }], - EV_ERDAT: getCurrentSAPDate(), - EV_ERZET: getCurrentSAPTime() + }] + // T_PR_RETURN, EV_ERDAT, EV_ERZET는 응답용 필드이므로 요청에 포함하지 않음 }; const result = await sendPOToECC(testPOData); diff --git a/lib/soap/sender.ts b/lib/soap/sender.ts index d12665cb..c0be780d 100644 --- a/lib/soap/sender.ts +++ b/lib/soap/sender.ts @@ -3,43 +3,13 @@ import { withSoapLogging } from "@/lib/soap/utils"; import { XMLBuilder } from 'fast-xml-parser'; import { debugLog, debugError, debugWarn, debugSuccess } from '@/lib/debug-utils'; - -// 기본 인증 정보 타입 -export interface SoapAuthConfig { - username?: string; - password?: string; -} - -// SOAP 전송 설정 타입 -export interface SoapSendConfig { - endpoint: string; - envelope: Record<string, unknown>; - soapAction?: string; - timeout?: number; - retryCount?: number; - retryDelay?: number; - namespace?: string; // 네임스페이스를 동적으로 설정할 수 있도록 추가 - prefix: string; // 네임스페이스 접두사 (필수) -} - -// 로깅 정보 타입 -export interface SoapLogInfo { - direction: 'INBOUND' | 'OUTBOUND'; - system: string; - interface: string; -} - -// 전송 결과 타입 -export interface SoapSendResult { - success: boolean; - message: string; - responseText?: string; - statusCode?: number; - headers?: Record<string, string>; - endpoint?: string; - requestXml?: string; - requestHeaders?: Record<string, string>; -} +import type { + SoapAuthConfig, + SoapSendConfig, + SoapLogInfo, + SoapSendResult +} from './types'; +import { SoapResponseError } from './types'; // 기본 환경변수에서 인증 정보 가져오기 function getDefaultAuth(): SoapAuthConfig { @@ -154,6 +124,7 @@ export async function sendSoapXml( } } + let responseText = ''; const result = await withSoapLogging( logInfo.direction, logInfo.system, @@ -161,17 +132,17 @@ export async function sendSoapXml( xmlData, async () => { // 타임아웃 설정 + let response: Response; if (config.timeout) { const controller = new AbortController(); const timeoutId = setTimeout(() => controller.abort(), config.timeout); try { - const response = await fetch(config.endpoint, { + response = await fetch(config.endpoint, { ...fetchOptions, signal: controller.signal }); clearTimeout(timeoutId); - return response; } catch (error) { clearTimeout(timeoutId); if (error instanceof Error && error.name === 'AbortError') { @@ -180,14 +151,20 @@ export async function sendSoapXml( throw error; } } else { - return await fetch(config.endpoint, fetchOptions); + response = await fetch(config.endpoint, fetchOptions); } - } + + // 응답 텍스트 읽기 (로깅을 위해 여기서 읽음) + responseText = await response.text(); + + return response; + }, + // 응답 데이터 추출 함수: responseText를 반환 + () => responseText ); // 응답 처리 const response = result as Response; - const responseText = await response.text(); // 응답 헤더 수집 (디버깅용) const responseHeadersDebug: Record<string, string> = {}; @@ -203,22 +180,52 @@ export async function sendSoapXml( }); debugLog('🔍 응답 바디 (전체):', responseText); - // HTTP 상태 코드가 비정상이거나 SOAP Fault 포함 시 실패로 처리하되 본문을 그대로 반환 - if (!response.ok || responseText.includes('soap:Fault') || responseText.includes('SOAP:Fault')) { + // SAP 응답 에러 체크: <MSGTY>E</MSGTY> 또는 <EV_TYPE>E</EV_TYPE> 패턴 감지 + const hasSapError = responseText.includes('<MSGTY>E</MSGTY>') || + responseText.includes('<EV_TYPE>E</EV_TYPE>'); + + // HTTP 상태 코드가 비정상이거나 SOAP Fault 또는 SAP 에러 포함 시 실패로 처리 + if (!response.ok || + responseText.includes('soap:Fault') || + responseText.includes('SOAP:Fault') || + hasSapError) { const responseHeaders: Record<string, string> = {}; response.headers.forEach((value, key) => { responseHeaders[key] = value; }); - return { - success: false, - message: !response.ok ? `HTTP ${response.status}: ${response.statusText}` : 'SOAP Fault', + + // 에러 메시지 결정 및 상세 메시지 추출 + let errorMessage = ''; + if (!response.ok) { + errorMessage = `HTTP ${response.status}: ${response.statusText}`; + } else if (hasSapError) { + // SAP 응답에서 에러 메시지 추출 시도 + const msgtxtMatch = responseText.match(/<MSGTXT>(.*?)<\/MSGTXT>/); + const evMessageMatch = responseText.match(/<EV_MESSAGE>(.*?)<\/EV_MESSAGE>/); + const detailMessage = msgtxtMatch?.[1] || evMessageMatch?.[1] || ''; + + errorMessage = 'SAP 응답 에러: MSGTY=E 또는 EV_TYPE=E 감지'; + if (detailMessage) { + errorMessage += ` - ${detailMessage}`; + } + } else { + // SOAP Fault에서 메시지 추출 시도 + const faultStringMatch = responseText.match(/<faultstring>(.*?)<\/faultstring>/); + const faultMessage = faultStringMatch?.[1] || 'SOAP Fault'; + errorMessage = faultMessage; + } + + debugError('❌ SOAP 응답 에러 감지:', errorMessage); + + // 커스텀 에러 객체 생성 (responseText 포함) + throw new SoapResponseError(errorMessage, { responseText, statusCode: response.status, headers: responseHeaders, endpoint: config.endpoint, requestXml: xmlData, requestHeaders - }; + }); } // 응답 헤더 수집 diff --git a/lib/soap/types.ts b/lib/soap/types.ts new file mode 100644 index 00000000..dac8f83b --- /dev/null +++ b/lib/soap/types.ts @@ -0,0 +1,64 @@ +// SOAP 관련 타입 정의 + +// 기본 인증 정보 타입 +export interface SoapAuthConfig { + username?: string; + password?: string; +} + +// SOAP 전송 설정 타입 +export interface SoapSendConfig { + endpoint: string; + envelope: Record<string, unknown>; + soapAction?: string; + timeout?: number; + retryCount?: number; + retryDelay?: number; + namespace?: string; // 네임스페이스를 동적으로 설정할 수 있도록 추가 + prefix: string; // 네임스페이스 접두사 (필수) +} + +// 로깅 정보 타입 +export interface SoapLogInfo { + direction: 'INBOUND' | 'OUTBOUND'; + system: string; + interface: string; +} + +// 전송 결과 타입 +export interface SoapSendResult { + success: boolean; + message: string; + responseText?: string; + statusCode?: number; + headers?: Record<string, string>; + endpoint?: string; + requestXml?: string; + requestHeaders?: Record<string, string>; +} + +// SOAP 에러 타입 (응답 정보 포함) +export class SoapResponseError extends Error { + responseText?: string; + statusCode?: number; + headers?: Record<string, string>; + endpoint?: string; + requestXml?: string; + requestHeaders?: Record<string, string>; + + constructor(message: string, details?: { + responseText?: string; + statusCode?: number; + headers?: Record<string, string>; + endpoint?: string; + requestXml?: string; + requestHeaders?: Record<string, string>; + }) { + super(message); + this.name = 'SoapResponseError'; + if (details) { + Object.assign(this, details); + } + } +} + diff --git a/lib/soap/utils.ts b/lib/soap/utils.ts index 57e3b280..809dd46d 100644 --- a/lib/soap/utils.ts +++ b/lib/soap/utils.ts @@ -466,6 +466,7 @@ export async function cleanupOldSoapLogs(): Promise<void> { * @param interfaceName 인터페이스명 * @param requestData 요청 데이터 * @param processor 실제 비즈니스 로직 함수 + * @param extractResponse 응답 데이터 추출 함수 (선택사항) * @returns 처리 결과 */ export async function withSoapLogging<T>( @@ -473,7 +474,8 @@ export async function withSoapLogging<T>( system: string, interfaceName: string, requestData: string, - processor: () => Promise<T> + processor: () => Promise<T>, + extractResponse?: (result: T) => string | undefined ): Promise<T> { let logId: number | null = null; @@ -484,10 +486,16 @@ export async function withSoapLogging<T>( // 2. 실제 처리 실행 const result = await processor(); - // 3. 성공 로그 완료 - await completeSoapLog(logId, true); + // 3. 응답 데이터 추출 (제공된 경우) + let responseData: string | undefined; + if (extractResponse) { + responseData = extractResponse(result); + } + + // 4. 성공 로그 완료 (응답 데이터 포함) + await completeSoapLog(logId, true, responseData); - // 4. 로그 정리 (백그라운드) + // 5. 로그 정리 (백그라운드) cleanupOldSoapLogs().catch(error => console.error('백그라운드 로그 정리 실패:', error) ); @@ -495,12 +503,18 @@ export async function withSoapLogging<T>( return result; } catch (error) { - // 5. 실패 로그 완료 + // 6. 실패 로그 완료 if (logId !== null) { + // 에러 객체에 응답 데이터가 포함되어 있는지 확인 + let errorResponseData: string | undefined; + if (error && typeof error === 'object' && 'responseText' in error) { + errorResponseData = (error as { responseText?: string }).responseText; + } + await completeSoapLog( logId, false, - undefined, + errorResponseData, error instanceof Error ? error.message : 'Unknown error' ); } |