summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/bidding/actions.ts2
-rw-r--r--lib/rfq-last/contract-actions.ts52
-rw-r--r--lib/soap/ecc/send/create-po-bidding.ts (renamed from lib/soap/ecc/send/create-po.ts)4
-rw-r--r--lib/soap/ecc/send/create-po-rfq.ts333
4 files changed, 357 insertions, 34 deletions
diff --git a/lib/bidding/actions.ts b/lib/bidding/actions.ts
index 5909cd62..c4c543d9 100644
--- a/lib/bidding/actions.ts
+++ b/lib/bidding/actions.ts
@@ -16,7 +16,7 @@ import {
biddingDocuments,
users
} from "@/db/schema"
-import { createPurchaseOrder } from "@/lib/soap/ecc/send/create-po"
+import { createPurchaseOrder } from "@/lib/soap/ecc/send/create-po-bidding"
import { getCurrentSAPDate } from "@/lib/soap/utils"
import { generateContractNumber } from "@/lib/general-contracts/service"
import { saveFile } from "@/lib/file-stroage"
diff --git a/lib/rfq-last/contract-actions.ts b/lib/rfq-last/contract-actions.ts
index a4be7e48..1323ba8a 100644
--- a/lib/rfq-last/contract-actions.ts
+++ b/lib/rfq-last/contract-actions.ts
@@ -11,7 +11,7 @@ import { getServerSession } from "next-auth/next"
import { authOptions } from "@/app/api/auth/[...nextauth]/route"
import { generateContractNumber } from "../general-contracts/service";
import { generateBiddingNumber } from "../bidding/service";
-import { createPurchaseOrder } from "@/lib/soap/ecc/send/create-po";
+import { sendRFQInformation } from "@/lib/soap/ecc/send/create-po-rfq";
import { getCurrentSAPDate } from "@/lib/soap/utils";
import { SoapResponseError } from "@/lib/soap/types";
@@ -212,32 +212,24 @@ export async function createPO(params: CreatePOParams) {
const validIncotermsCode = incotermsCode as string;
const validTaxCode = taxCode as string;
- // 5. PO 데이터 구성
- const poData = {
- T_Bidding_HEADER: [{
+ // 5. RFQ 정보 데이터 구성 (IF_EVCP_ECC_RFQ_INFORMATION 인터페이스 사용)
+ const rfqInfoData = {
+ T_RFQ_HEADER: [{
// 필수 필드
ANFNR: validAnfnr,
LIFNR: validVendorCode,
- ZPROC_IND: '9', // 구매 처리 상태: 9 (기존 로그 기준)
WAERS: currency,
ZTERM: validPaymentTermsCode,
INCO1: validIncotermsCode,
INCO2: incotermsDescription.substring(0, 28), // SAP 최대 28자리 제한, incoterms 테이블의 description 사용
MWSKZ: validTaxCode,
LANDS: vendorCountryCode, // 벤더 국가 코드 사용
- ZRCV_DT: getCurrentSAPDate(),
- ZATTEN_IND: 'Y', // 참석 여부: Y (고정값)
- IHRAN: getCurrentSAPDate(),
- // Optional 필드 (명시적으로 포함 - 유지보수를 위해 구조 유지)
- TEXT: rfqData.rfqTitle || rfqData.itemName || '', // PO Header note
- ZDLV_CNTLR: rfqData.picCode || '', // Delivery Controller
- ZDLV_PRICE_T: detailData.materialPriceRelatedYn ? 'Y' : 'N', // 납품대금연동제대상여부
- ZDLV_PRICE_NOTE: detailData.materialPriceRelatedYn ? '연동제 적용' : '', // 연동제 노트
- VSTEL: '', // Shipping Point (데이터 없음)
- LSTEL: '', // Loading Point (데이터 없음)
+ // Optional 필드
+ VSTEL: detailData.placeOfShipping || '', // Place of Shipping
+ LSTEL: detailData.placeOfDestination || '', // Place of Destination
}],
- T_Bidding_ITEM: prItems.map((item, index) => {
+ T_RFQ_ITEM: prItems.map((item, index) => {
// 견적 아이템에서 실제 가격 정보 가져오기 (이미 검증됨)
const quoteItem = quotationItemMap.get(item.id)!; // 검증 통과했으므로 non-null assertion
@@ -259,23 +251,17 @@ export async function createPO(params: CreatePOParams) {
// 필수 필드
ANFNR: validAnfnr,
ANFPS: item.prItem || (index + 1).toString().padStart(5, '0'), // PR Item Number 사용
- LIFNR: validVendorCode,
NETPR: unitPrice.toFixed(2), // 단가 (소수점 2자리)
- PEINH: '1', // 가격 단위: 1 (표준값, 1단위당 가격)
- BPRME: item.uom!, // 검증 통과했으므로 non-null assertion
NETWR: totalPrice.toFixed(2), // 순액 (세금 제외)
BRTWR: totalPrice.toFixed(2), // 총액: SAP이 taxCode(MWSKZ)로 세금 계산하도록 순액과 동일하게 전송
- LFDAT: deliveryDate,
- // Optional 필드 (명시적으로 포함 - 유지보수를 위해 구조 유지)
- ZCON_NO_PO: item.prNo || '', // PR Consolidation Number
- EBELP: '', // Series PO Item Seq (시리즈 PO가 아니면 빈 값)
+ // Optional 필드
+ LFDAT: deliveryDate,
};
})
- // T_PR_RETURN은 응답용 필드이므로 요청에 포함하지 않음
};
- console.log('📤 SAP으로 PO 전송 시작:', {
+ console.log('📤 SAP으로 RFQ 정보 전송 시작:', {
ANFNR: validAnfnr,
LIFNR: validVendorCode,
vendorName: vendorData.vendorName,
@@ -296,19 +282,19 @@ export async function createPO(params: CreatePOParams) {
});
// 디버깅: 전송 데이터 전체 로그 (서버 측 로그이므로 모든 정보 포함)
- console.log('📦 PO 전송 데이터 (전체):', JSON.stringify(poData, null, 2));
+ console.log('📦 RFQ 정보 전송 데이터 (전체):', JSON.stringify(rfqInfoData, null, 2));
- // 6. SAP SOAP 요청 전송
- const sapResult = await createPurchaseOrder(poData);
+ // 6. SAP SOAP 요청 전송 (RFQ 인터페이스 사용)
+ const sapResult = await sendRFQInformation(rfqInfoData);
if (!sapResult.success) {
- throw new Error(`SAP PO 생성 실패: ${sapResult.message}`);
+ throw new Error(`SAP RFQ 정보 전송 실패: ${sapResult.message}`);
}
- console.log('✅ SAP PO 전송 성공:', sapResult);
+ console.log('✅ SAP RFQ 정보 전송 성공:', sapResult);
- // 7. 실제 PO 번호 추출 (SOAP 응답에서 추출하거나 ANFNR 사용)
- const actualPoNumber = sapResult.bidding_number || validAnfnr;
+ // 7. 실제 RFQ 번호 추출 (SOAP 응답에서 추출하거나 ANFNR 사용)
+ const actualPoNumber = sapResult.rfq_number || validAnfnr;
// 8. DB에 실제 PO 번호 저장 및 RFQ 상태 업데이트
await db.transaction(async (tx) => {
@@ -346,7 +332,7 @@ export async function createPO(params: CreatePOParams) {
return {
success: true,
- message: "PO가 성공적으로 생성되어 SAP로 전송되었습니다.",
+ message: "RFQ 정보가 성공적으로 SAP로 전송되었습니다.",
poNumber: actualPoNumber,
};
} catch (error) {
diff --git a/lib/soap/ecc/send/create-po.ts b/lib/soap/ecc/send/create-po-bidding.ts
index 1e21d39c..95013b82 100644
--- a/lib/soap/ecc/send/create-po.ts
+++ b/lib/soap/ecc/send/create-po-bidding.ts
@@ -1,3 +1,7 @@
+/**
+ * RFQ PO 생성 I/F 변경 (IF_EVCP_ECC_PO_CREATE 는 입찰 전용 PO 생성, IF_EVCP_ECC_RFQ_INFORMATION 은 RFQ PO 생성) - RFQ_INFORMATION은 MAINTAIN PO/VO, PO_INFORMATION은 PO List Management (SAP 메뉴)
+ */
+
'use server'
import { sendSoapXml, type SoapSendConfig, type SoapLogInfo, type SoapSendResult } from "@/lib/soap/sender";
diff --git a/lib/soap/ecc/send/create-po-rfq.ts b/lib/soap/ecc/send/create-po-rfq.ts
new file mode 100644
index 00000000..d9c1551d
--- /dev/null
+++ b/lib/soap/ecc/send/create-po-rfq.ts
@@ -0,0 +1,333 @@
+/**
+ * RFQ PO 생성 I/F 변경 (IF_EVCP_ECC_PO_CREATE 는 입찰 전용 PO 생성, IF_EVCP_ECC_RFQ_INFORMATION 은 RFQ PO 생성) - RFQ_INFORMATION은 MAINTAIN PO/VO, PO_INFORMATION은 PO List Management (SAP 메뉴)
+ */
+'use server'
+
+import { sendSoapXml, type SoapSendConfig, type SoapLogInfo, type SoapSendResult } from "@/lib/soap/sender";
+import { getCurrentSAPDate } from "@/lib/soap/utils";
+
+// ECC RFQ 정보 전송 엔드포인트 (WSDL에 명시된 P2MM3014_SO 사용)
+// P2038_Q: Quality 환경 (Bidding과 동일한 환경 사용)
+const ECC_RFQ_ENDPOINT = "http://shii8dvddb01.hec.serp.shi.samsung.net:50000/sap/xi/engine?type=entry&version=3.0&Sender.Service=P2038_Q&Interface=http%3A%2F%2Fshi.samsung.co.kr%2FP2_MM%2FMMM%5EP2MM3014_SO";
+
+// RFQ 헤더 데이터 타입
+export interface RFQHeaderData {
+ ANFNR: string; // RFQ Number (M)
+ LIFNR: string; // Vendor's account number (M)
+ WAERS: string; // Currency Key (M)
+ ZTERM: string; // Terms of Payment Key (M)
+ INCO1: string; // Incoterms (Part 1) (M)
+ INCO2: string; // Incoterms (Part 2) (M)
+ VSTEL?: string; // Place of Shipping (O)
+ LSTEL?: string; // Place of Destination (O)
+ MWSKZ: string; // Tax on Sales/Purchases Code (M)
+ LANDS: string; // Country for Tax Return (M)
+}
+
+// RFQ 아이템 데이터 타입
+export interface RFQItemData {
+ ANFNR: string; // RFQ Number (M)
+ ANFPS: string; // Item Number of RFQ (M)
+ NETPR: string; // Net Price (M)
+ NETWR: string; // Net Order Value (M)
+ BRTWR: string; // Gross order value (M)
+ LFDAT?: string; // Item delivery date (O)
+}
+
+// RFQ 정보 전송 요청 데이터 타입
+export interface RFQInformationRequest {
+ T_RFQ_HEADER: RFQHeaderData[];
+ T_RFQ_ITEM: RFQItemData[];
+}
+
+// SOAP Body Content 생성 함수
+function createRFQSoapBodyContent(rfqData: RFQInformationRequest): Record<string, unknown> {
+ return {
+ 'p1:MT_P2MM3014_S': { // WSDL에서 사용하는 p1 접두사 적용
+ 'T_RFQ_HEADER': rfqData.T_RFQ_HEADER,
+ 'T_RFQ_ITEM': rfqData.T_RFQ_ITEM
+ }
+ };
+}
+
+// RFQ 데이터 검증 함수
+function validateRFQData(rfqData: RFQInformationRequest): { isValid: boolean; errors: string[] } {
+ const errors: string[] = [];
+
+ // 헤더 데이터 검증
+ if (!rfqData.T_RFQ_HEADER || rfqData.T_RFQ_HEADER.length === 0) {
+ errors.push('T_RFQ_HEADER는 필수입니다.');
+ } else {
+ rfqData.T_RFQ_HEADER.forEach((header, index) => {
+ const requiredFields = ['ANFNR', 'LIFNR', 'WAERS', 'ZTERM', 'INCO1', 'INCO2', 'MWSKZ', 'LANDS'];
+ requiredFields.forEach(field => {
+ if (!header[field as keyof RFQHeaderData]) {
+ errors.push(`T_RFQ_HEADER[${index}].${field}는 필수입니다.`);
+ }
+ });
+ });
+ }
+
+ // 아이템 데이터 검증
+ if (!rfqData.T_RFQ_ITEM || rfqData.T_RFQ_ITEM.length === 0) {
+ errors.push('T_RFQ_ITEM은 필수입니다.');
+ } else {
+ rfqData.T_RFQ_ITEM.forEach((item, index) => {
+ const requiredFields = ['ANFNR', 'ANFPS', 'NETPR', 'NETWR', 'BRTWR'];
+ requiredFields.forEach(field => {
+ if (!item[field as keyof RFQItemData]) {
+ errors.push(`T_RFQ_ITEM[${index}].${field}는 필수입니다.`);
+ }
+ });
+ });
+ }
+
+ return {
+ isValid: errors.length === 0,
+ errors
+ };
+}
+
+// ECC로 RFQ 정보 SOAP XML 전송하는 함수
+async function sendRFQToECC(rfqData: RFQInformationRequest): Promise<SoapSendResult> {
+ try {
+ // 데이터 검증 (경고만 출력, 전송은 계속 진행)
+ const validation = validateRFQData(rfqData);
+ if (!validation.isValid) {
+ console.warn('⚠️ RFQ 데이터 검증 경고 (전송은 계속 진행):', validation.errors.join(', '));
+ console.warn('⚠️ 검증 실패한 RFQ 데이터:', JSON.stringify(rfqData, null, 2));
+ }
+
+ // SOAP Body Content 생성
+ const soapBodyContent = createRFQSoapBodyContent(rfqData);
+
+ // SOAP 전송 설정
+ const config: SoapSendConfig = {
+ endpoint: ECC_RFQ_ENDPOINT,
+ envelope: soapBodyContent,
+ soapAction: 'http://sap.com/xi/WebService/soap1.1',
+ timeout: 60000, // RFQ 정보 전송은 60초 타임아웃
+ retryCount: 3,
+ retryDelay: 2000,
+ namespace: 'http://shi.samsung.co.kr/P2_MM/MMM', // ECC MM 모듈 네임스페이스
+ prefix: 'p1' // WSDL에서 사용하는 p1 접두사
+ };
+
+ // 로그 정보
+ const logInfo: SoapLogInfo = {
+ direction: 'OUTBOUND',
+ system: 'S-ERP ECC',
+ interface: 'IF_EVCP_ECC_RFQ_INFORMATION'
+ };
+
+ console.log(`📤 RFQ 정보 전송 시작 - ANFNR: ${rfqData.T_RFQ_HEADER[0]?.ANFNR}`);
+ console.log(`🔍 헤더 ${rfqData.T_RFQ_HEADER.length}개, 아이템 ${rfqData.T_RFQ_ITEM.length}개`);
+
+ // SOAP XML 전송
+ const result = await sendSoapXml(config, logInfo);
+
+ if (result.success) {
+ console.log(`✅ RFQ 정보 전송 성공 - ANFNR: ${rfqData.T_RFQ_HEADER[0]?.ANFNR}`);
+ } else {
+ console.error(`❌ RFQ 정보 전송 실패 - ANFNR: ${rfqData.T_RFQ_HEADER[0]?.ANFNR}, 오류: ${result.message}`);
+ }
+
+ return result;
+
+ } catch (error) {
+ console.error('❌ RFQ 정보 전송 중 오류 발생:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
+// ========================================
+// 메인 RFQ 정보 전송 함수들
+// ========================================
+
+// 단일 RFQ 정보 전송 처리
+export async function sendRFQInformation(rfqData: RFQInformationRequest): Promise<{
+ success: boolean;
+ message: string;
+ responseData?: string;
+ statusCode?: number;
+ headers?: Record<string, string>;
+ endpoint?: string;
+ requestXml?: string;
+ rfq_number?: string;
+}> {
+ try {
+ console.log(`🚀 RFQ 정보 전송 시작 - ANFNR: ${rfqData.T_RFQ_HEADER[0]?.ANFNR}`);
+
+ const result = await sendRFQToECC(rfqData);
+
+ return {
+ success: result.success,
+ message: result.success ? 'RFQ 정보가 성공적으로 전송되었습니다.' : result.message,
+ responseData: result.responseText,
+ statusCode: result.statusCode,
+ headers: result.headers,
+ endpoint: result.endpoint,
+ requestXml: result.requestXml,
+ rfq_number: rfqData.T_RFQ_HEADER[0]?.ANFNR
+ };
+
+ } catch (error) {
+ console.error('❌ RFQ 정보 전송 처리 실패:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
+// 여러 RFQ 배치 전송 처리
+export async function sendMultipleRFQInformation(rfqDataList: RFQInformationRequest[]): Promise<{
+ success: boolean;
+ message: string;
+ results?: Array<{ rfq_number: string; success: boolean; error?: string }>;
+}> {
+ try {
+ console.log(`🚀 배치 RFQ 정보 전송 시작: ${rfqDataList.length}개`);
+
+ const results: Array<{ rfq_number: string; success: boolean; error?: string }> = [];
+
+ for (const rfqData of rfqDataList) {
+ try {
+ const rfq_number = rfqData.T_RFQ_HEADER[0]?.ANFNR || 'Unknown';
+ console.log(`📤 RFQ 정보 전송 중: ${rfq_number}`);
+
+ const result = await sendRFQToECC(rfqData);
+
+ if (result.success) {
+ console.log(`✅ RFQ 정보 전송 성공: ${rfq_number}`);
+ results.push({
+ rfq_number,
+ success: true
+ });
+ } else {
+ console.error(`❌ RFQ 정보 전송 실패: ${rfq_number}, 오류: ${result.message}`);
+ results.push({
+ rfq_number,
+ success: false,
+ error: result.message
+ });
+ }
+
+ // 배치 처리간 지연 (시스템 부하 방지)
+ if (rfqDataList.length > 1) {
+ await new Promise(resolve => setTimeout(resolve, 1000));
+ }
+
+ } catch (error) {
+ const rfq_number = rfqData.T_RFQ_HEADER[0]?.ANFNR || 'Unknown';
+ console.error(`❌ RFQ 정보 전송 처리 실패: ${rfq_number}`, error);
+ results.push({
+ rfq_number,
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error'
+ });
+ }
+ }
+
+ const successCount = results.filter(r => r.success).length;
+ const failCount = results.length - successCount;
+
+ console.log(`🎉 배치 RFQ 정보 전송 완료: 성공 ${successCount}개, 실패 ${failCount}개`);
+
+ return {
+ success: failCount === 0,
+ message: `배치 RFQ 정보 전송 완료: 성공 ${successCount}개, 실패 ${failCount}개`,
+ results
+ };
+
+ } catch (error) {
+ console.error('❌ 배치 RFQ 정보 전송 중 전체 오류 발생:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
+// 테스트용 RFQ 정보 전송 함수 (샘플 데이터 포함)
+export async function sendTestRFQInformation(): Promise<{
+ success: boolean;
+ message: string;
+ responseData?: string;
+ testData?: RFQInformationRequest;
+}> {
+ try {
+ console.log('🧪 테스트용 RFQ 정보 전송 시작');
+
+ // 테스트용 샘플 데이터 생성
+ const testRFQData: RFQInformationRequest = {
+ T_RFQ_HEADER: [{
+ ANFNR: 'TEST001',
+ LIFNR: '1000000001',
+ WAERS: 'KRW',
+ ZTERM: '0001',
+ INCO1: 'FOB',
+ INCO2: 'Seoul, Korea',
+ VSTEL: '001',
+ LSTEL: '001',
+ MWSKZ: 'V0',
+ LANDS: 'KR',
+ }],
+ T_RFQ_ITEM: [{
+ ANFNR: 'TEST001',
+ ANFPS: '00001',
+ NETPR: '1000.00',
+ NETWR: '1000.00',
+ BRTWR: '1100.00',
+ LFDAT: getCurrentSAPDate(),
+ }]
+ };
+
+ const result = await sendRFQToECC(testRFQData);
+
+ return {
+ success: result.success,
+ message: result.success ? '테스트 RFQ 정보가 성공적으로 전송되었습니다.' : result.message,
+ responseData: result.responseText,
+ testData: testRFQData
+ };
+
+ } catch (error) {
+ console.error('❌ 테스트 RFQ 정보 전송 실패:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
+// RFQ 정보 전송 상태 확인 함수 (향후 확장용)
+export async function checkRFQInformationStatus(rfqNumber: string): Promise<{
+ success: boolean;
+ message: string;
+ status?: string;
+}> {
+ try {
+ console.log(`🔍 RFQ 정보 전송 상태 확인: ${rfqNumber}`);
+
+ // 향후 ECC에서 상태 조회 API가 제공될 경우 구현
+ // 현재는 기본 응답만 반환
+
+ return {
+ success: true,
+ message: 'RFQ 정보 전송 상태 확인 기능은 향후 구현 예정입니다.',
+ status: 'PENDING'
+ };
+
+ } catch (error) {
+ console.error('❌ RFQ 상태 확인 실패:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-07 05:12:30 +0000