summaryrefslogtreecommitdiff
path: root/lib/soap/ecc/send/cancel-rfq.ts
diff options
context:
space:
mode:
Diffstat (limited to 'lib/soap/ecc/send/cancel-rfq.ts')
-rw-r--r--lib/soap/ecc/send/cancel-rfq.ts346
1 files changed, 346 insertions, 0 deletions
diff --git a/lib/soap/ecc/send/cancel-rfq.ts b/lib/soap/ecc/send/cancel-rfq.ts
new file mode 100644
index 00000000..fcddddf8
--- /dev/null
+++ b/lib/soap/ecc/send/cancel-rfq.ts
@@ -0,0 +1,346 @@
+'use server'
+
+import { sendSoapXml, type SoapSendConfig, type SoapLogInfo, type SoapSendResult } from "@/lib/soap/sender";
+
+// ECC RFQ 취소 엔드포인트
+const ECC_CANCEL_RFQ_ENDPOINT = "http://shii8dvddb01.hec.serp.shi.samsung.net:50000/sap/xi/engine?type=entry&version=3.0&Sender.Service=P2038_D&Interface=http%3A%2F%2Fshi.samsung.co.kr%2FP2_MM%2FMMM%5EP2MM3016_SO";
+
+// RFQ 취소 요청 데이터 타입
+export interface CancelRFQRequest {
+ T_ANFNR: Array<{
+ ANFNR: string; // RFQ Number (M)
+ }>;
+}
+
+// RFQ 취소 응답 데이터 타입 (참고용)
+export interface CancelRFQResponse {
+ EV_TYPE?: string; // 응답 타입 (S: 성공, E: 에러)
+ EV_MESSAGE?: string; // 응답 메시지
+}
+
+// SOAP Body Content 생성 함수
+function createCancelRFQSoapBodyContent(rfqData: CancelRFQRequest): Record<string, unknown> {
+ return {
+ 'ns0:MT_P2MM3016_S': {
+ 'T_ANFNR': rfqData.T_ANFNR
+ }
+ };
+}
+
+// RFQ 데이터 검증 함수
+function validateCancelRFQData(rfqData: CancelRFQRequest): { isValid: boolean; errors: string[] } {
+ const errors: string[] = [];
+
+ // T_ANFNR 배열 검증
+ if (!rfqData.T_ANFNR || !Array.isArray(rfqData.T_ANFNR) || rfqData.T_ANFNR.length === 0) {
+ errors.push('T_ANFNR은 필수이며 최소 1개 이상의 RFQ 번호가 있어야 합니다.');
+ } else {
+ rfqData.T_ANFNR.forEach((item, index) => {
+ if (!item.ANFNR || typeof item.ANFNR !== 'string' || item.ANFNR.trim() === '') {
+ errors.push(`T_ANFNR[${index}].ANFNR은 필수입니다.`);
+ }
+ });
+ }
+
+ return {
+ isValid: errors.length === 0,
+ errors
+ };
+}
+
+// ECC로 RFQ 취소 SOAP XML 전송하는 함수
+async function sendCancelRFQToECC(rfqData: CancelRFQRequest): Promise<SoapSendResult> {
+ try {
+ // 데이터 검증
+ const validation = validateCancelRFQData(rfqData);
+ if (!validation.isValid) {
+ return {
+ success: false,
+ message: `데이터 검증 실패: ${validation.errors.join(', ')}`
+ };
+ }
+
+ // SOAP Body Content 생성
+ const soapBodyContent = createCancelRFQSoapBodyContent(rfqData);
+
+ // SOAP 전송 설정
+ const config: SoapSendConfig = {
+ endpoint: ECC_CANCEL_RFQ_ENDPOINT,
+ envelope: soapBodyContent,
+ soapAction: 'http://sap.com/xi/WebService/soap1.1',
+ timeout: 30000, // RFQ 취소는 30초 타임아웃
+ retryCount: 3,
+ retryDelay: 1000
+ };
+
+ // 로그 정보
+ const logInfo: SoapLogInfo = {
+ direction: 'OUTBOUND',
+ system: 'S-ERP ECC',
+ interface: 'IF_ECC_EVCP_CANCEL_RFQ'
+ };
+
+ const rfqNumbers = rfqData.T_ANFNR.map(item => item.ANFNR).join(', ');
+ console.log(`📤 RFQ 취소 요청 전송 시작 - RFQ Numbers: ${rfqNumbers}`);
+ console.log(`🔍 취소 대상 RFQ ${rfqData.T_ANFNR.length}개`);
+
+ // SOAP XML 전송
+ const result = await sendSoapXml(config, logInfo);
+
+ if (result.success) {
+ console.log(`✅ RFQ 취소 요청 전송 성공 - RFQ Numbers: ${rfqNumbers}`);
+ } else {
+ console.error(`❌ RFQ 취소 요청 전송 실패 - RFQ Numbers: ${rfqNumbers}, 오류: ${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 cancelRFQ(rfqNumber: string): Promise<{
+ success: boolean;
+ message: string;
+ responseData?: string;
+ rfqNumber?: string;
+}> {
+ try {
+ console.log(`🚀 RFQ 취소 요청 시작 - RFQ Number: ${rfqNumber}`);
+
+ const rfqData: CancelRFQRequest = {
+ T_ANFNR: [{
+ ANFNR: rfqNumber
+ }]
+ };
+
+ const result = await sendCancelRFQToECC(rfqData);
+
+ return {
+ success: result.success,
+ message: result.success ? 'RFQ 취소 요청이 성공적으로 전송되었습니다.' : result.message,
+ responseData: result.responseText,
+ rfqNumber
+ };
+
+ } catch (error) {
+ console.error('❌ RFQ 취소 요청 처리 실패:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
+// 여러 RFQ 배치 취소 요청 처리
+export async function cancelMultipleRFQs(rfqNumbers: string[]): Promise<{
+ success: boolean;
+ message: string;
+ results?: Array<{ rfqNumber: string; success: boolean; error?: string }>;
+}> {
+ try {
+ console.log(`🚀 배치 RFQ 취소 요청 시작: ${rfqNumbers.length}개`);
+
+ // 모든 RFQ를 하나의 요청으로 처리
+ const rfqData: CancelRFQRequest = {
+ T_ANFNR: rfqNumbers.map(rfqNumber => ({ ANFNR: rfqNumber }))
+ };
+
+ const result = await sendCancelRFQToECC(rfqData);
+
+ // 결과 정리
+ const results = rfqNumbers.map(rfqNumber => ({
+ rfqNumber,
+ success: result.success,
+ error: result.success ? undefined : result.message
+ }));
+
+ const successCount = result.success ? rfqNumbers.length : 0;
+ const failCount = rfqNumbers.length - successCount;
+
+ console.log(`🎉 배치 RFQ 취소 완료: 성공 ${successCount}개, 실패 ${failCount}개`);
+
+ return {
+ success: result.success,
+ message: result.success
+ ? `배치 RFQ 취소 성공: ${successCount}개`
+ : `배치 RFQ 취소 실패: ${result.message}`,
+ results
+ };
+
+ } catch (error) {
+ console.error('❌ 배치 RFQ 취소 중 전체 오류 발생:', error);
+ return {
+ success: false,
+ message: error instanceof Error ? error.message : 'Unknown error'
+ };
+ }
+}
+
+// 개별 처리 방식의 배치 RFQ 취소 (각각 따로 전송)
+export async function cancelMultipleRFQsIndividually(rfqNumbers: string[]): Promise<{
+ success: boolean;
+ message: string;
+ results?: Array<{ rfqNumber: string; success: boolean; error?: string }>;
+}> {
+ try {
+ console.log(`🚀 개별 RFQ 취소 요청 시작: ${rfqNumbers.length}개`);
+
+ const results: Array<{ rfqNumber: string; success: boolean; error?: string }> = [];
+
+ for (const rfqNumber of rfqNumbers) {
+ try {
+ console.log(`📤 RFQ 취소 처리 중: ${rfqNumber}`);
+
+ const rfqData: CancelRFQRequest = {
+ T_ANFNR: [{ ANFNR: rfqNumber }]
+ };
+
+ const result = await sendCancelRFQToECC(rfqData);
+
+ if (result.success) {
+ console.log(`✅ RFQ 취소 성공: ${rfqNumber}`);
+ results.push({
+ rfqNumber,
+ success: true
+ });
+ } else {
+ console.error(`❌ RFQ 취소 실패: ${rfqNumber}, 오류: ${result.message}`);
+ results.push({
+ rfqNumber,
+ success: false,
+ error: result.message
+ });
+ }
+
+ // 개별 처리간 지연 (시스템 부하 방지)
+ if (rfqNumbers.length > 1) {
+ await new Promise(resolve => setTimeout(resolve, 500));
+ }
+
+ } catch (error) {
+ console.error(`❌ RFQ 취소 처리 실패: ${rfqNumber}`, error);
+ results.push({
+ rfqNumber,
+ 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 cancelTestRFQ(): Promise<{
+ success: boolean;
+ message: string;
+ responseData?: string;
+ testData?: CancelRFQRequest;
+}> {
+ try {
+ console.log('🧪 테스트용 RFQ 취소 시작');
+
+ // 테스트용 샘플 데이터 생성
+ const testRFQData: CancelRFQRequest = {
+ T_ANFNR: [{
+ ANFNR: 'TEST_RFQ_001'
+ }]
+ };
+
+ const result = await sendCancelRFQToECC(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 취소 데이터 생성 헬퍼 함수
+function createCancelRFQData(rfqNumbers: string[]): CancelRFQRequest {
+ return {
+ T_ANFNR: rfqNumbers.map(rfqNumber => ({ ANFNR: rfqNumber }))
+ };
+}
+
+// RFQ 번호 검증 함수
+function validateRFQNumber(rfqNumber: string): { isValid: boolean; error?: string } {
+ if (!rfqNumber || typeof rfqNumber !== 'string') {
+ return { isValid: false, error: 'RFQ 번호는 문자열이어야 합니다.' };
+ }
+
+ const trimmed = rfqNumber.trim();
+ if (trimmed === '') {
+ return { isValid: false, error: 'RFQ 번호는 비어있을 수 없습니다.' };
+ }
+
+ // 기본적인 길이 검증 (10자 제한 - WSDL에서 CHAR 10으로 정의)
+ if (trimmed.length > 10) {
+ return { isValid: false, error: 'RFQ 번호는 10자를 초과할 수 없습니다.' };
+ }
+
+ return { isValid: true };
+}
+
+// 여러 RFQ 번호 검증 함수
+function validateRFQNumbers(rfqNumbers: string[]): { isValid: boolean; errors: string[] } {
+ const errors: string[] = [];
+
+ if (!Array.isArray(rfqNumbers) || rfqNumbers.length === 0) {
+ errors.push('최소 1개 이상의 RFQ 번호가 필요합니다.');
+ return { isValid: false, errors };
+ }
+
+ rfqNumbers.forEach((rfqNumber, index) => {
+ const validation = validateRFQNumber(rfqNumber);
+ if (!validation.isValid) {
+ errors.push(`RFQ[${index}]: ${validation.error}`);
+ }
+ });
+
+ return {
+ isValid: errors.length === 0,
+ errors
+ };
+} \ No newline at end of file
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-07 22:39:40 +0000