(김준회) 견적: PO 생성 요청부 개선, 에러처리

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'
       );
     }