summaryrefslogtreecommitdiff
path: root/lib/soap/ecc/send/delete-rfq.ts
blob: f7e945fef1befeba728d35a60fe725c6d37a93bb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
'use server'

import { sendSoapXml, type SoapSendConfig, type SoapLogInfo, type SoapSendResult } from "@/lib/soap/sender";

// ECC RFQ 삭제 엔드포인트 (WSDL에 명시된 P2038_D 사용)
const ECC_CANCEL_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%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 {
    'p1:MT_P2MM3016_S': {  // WSDL에서 사용하는 p1 접두사 적용
      '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,
      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_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}개`);
    console.log(`🌐 엔드포인트: ${ECC_CANCEL_RFQ_ENDPOINT}`);
    console.log(`📋 네임스페이스: ${config.namespace}`);
    console.log(`🔐 SOAPAction: ${config.soapAction}`);

    // 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;
  statusCode?: number;
  headers?: Record<string, string>;
  endpoint?: string;
  requestXml?: 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,
      statusCode: result.statusCode,
      headers: result.headers,
      endpoint: result.endpoint,
      requestXml: result.requestXml,
      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'
    };
  }
}

// 사용하지 않는 유틸리티 함수들 삭제 (linter 오류 해결)