From 284f9f40d9494168f3e68eedd9af067c38362eea Mon Sep 17 00:00:00 2001 From: joonhoekim <26rote@gmail.com> Date: Thu, 30 Oct 2025 10:35:26 +0900 Subject: (김준회) refactor: POS: 온디맨드로 다운로드받도록 변경, 매핑로직에선 pos 관련 로직 제거 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lib/pos/components/pos-file-selection-dialog.tsx | 134 ++++++++ lib/pos/download-on-demand-action.ts | 193 +++++++++++ lib/pos/index.ts | 24 +- lib/pos/sync-rfq-pos-files.ts | 407 ----------------------- 4 files changed, 346 insertions(+), 412 deletions(-) create mode 100644 lib/pos/components/pos-file-selection-dialog.tsx create mode 100644 lib/pos/download-on-demand-action.ts delete mode 100644 lib/pos/sync-rfq-pos-files.ts (limited to 'lib/pos') diff --git a/lib/pos/components/pos-file-selection-dialog.tsx b/lib/pos/components/pos-file-selection-dialog.tsx new file mode 100644 index 00000000..29936d21 --- /dev/null +++ b/lib/pos/components/pos-file-selection-dialog.tsx @@ -0,0 +1,134 @@ +"use client" + +import * as React from "react" +import { Download, FileText } from "lucide-react" +import { + Dialog, + DialogContent, + DialogDescription, + DialogHeader, + DialogTitle, +} from "@/components/ui/dialog" +import { + Table, + TableBody, + TableCell, + TableHead, + TableHeader, + TableRow, +} from "@/components/ui/table" +import { Button } from "@/components/ui/button" +import { ScrollArea } from "@/components/ui/scroll-area" +import { Badge } from "@/components/ui/badge" + +interface PosFileInfo { + fileName: string + dcmtmId: string + projNo: string + posNo: string + posRevNo: string + fileSer: string +} + +interface PosFileSelectionDialogProps { + isOpen: boolean + onClose: () => void + materialCode: string + files: PosFileInfo[] + onDownload: (fileIndex: number, fileName: string) => void + downloadingIndex: number | null +} + +export function PosFileSelectionDialog({ + isOpen, + onClose, + materialCode, + files, + onDownload, + downloadingIndex, +}: PosFileSelectionDialogProps) { + return ( + + + + + + POS 파일 선택 + + + 자재코드 {materialCode}에 대한 + POS 파일 {files.length}개가 있습니다. + 다운로드할 파일을 선택해주세요. + + + + + + + + 번호 + 파일명 + 프로젝트 + POS 번호 + 리비전 + 파일 SEQ + 다운로드 + + + + {files.map((file, index) => ( + + + #{index + 1} + + +
+ + + {file.fileName} + +
+ + + {file.projNo} + + + {file.posNo} + + + + {file.posRevNo} + + + + {file.fileSer} + + + + + + ))} + +
+ + + {files.length === 0 && ( +
+ +

사용 가능한 POS 파일이 없습니다.

+
+ )} + + + ) +} + diff --git a/lib/pos/download-on-demand-action.ts b/lib/pos/download-on-demand-action.ts new file mode 100644 index 00000000..568bae22 --- /dev/null +++ b/lib/pos/download-on-demand-action.ts @@ -0,0 +1,193 @@ +/** + * POS 파일 온디맨드 다운로드 서버 액션 + * + * 클라이언트 컴포넌트에서 자재코드로 POS 파일을 다운로드할 수 있는 함수들을 제공합니다. + */ + +'use server'; + +import { getDcmtmIdByMaterialCode } from './get-dcmtm-id'; + +export interface DownloadPosOnDemandResult { + success: boolean; + downloadUrl?: string; + fileName?: string; + availableFiles?: Array<{ + fileName: string; + dcmtmId: string; + projNo: string; + posNo: string; + posRevNo: string; + fileSer: string; + }>; + error?: string; +} + +/** + * 자재코드로 POS 파일 다운로드 URL을 생성합니다. + * + * @param materialCode - 자재코드 (MATNR) + * @param fileIndex - 여러 파일이 있을 경우 선택할 파일 인덱스 (기본값: 0) + * @returns 다운로드 URL과 파일 정보 + * + * @example + * ```typescript + * const result = await getDownloadUrlByMaterialCode('SN2693A6410100001'); + * if (result.success && result.downloadUrl) { + * window.open(result.downloadUrl, '_blank'); + * } + * ``` + */ +export async function getDownloadUrlByMaterialCode( + materialCode: string, + fileIndex: number = 0 +): Promise { + try { + if (!materialCode || materialCode.trim() === '') { + return { + success: false, + error: '자재코드가 제공되지 않았습니다.', + }; + } + + // 1. 자재코드로 DCMTM_ID 및 파일 정보 조회 + const dcmtmResult = await getDcmtmIdByMaterialCode({ materialCode }); + + if (!dcmtmResult.success || !dcmtmResult.files || dcmtmResult.files.length === 0) { + return { + success: false, + error: dcmtmResult.error || '해당 자재코드에 대한 POS 파일을 찾을 수 없습니다.', + }; + } + + // 파일 인덱스 범위 검증 + if (fileIndex >= dcmtmResult.files.length) { + return { + success: false, + error: `파일 인덱스가 범위를 벗어났습니다. 사용 가능한 파일 수: ${dcmtmResult.files.length}`, + availableFiles: dcmtmResult.files.map(file => ({ + fileName: file.fileName, + dcmtmId: file.dcmtmId, + projNo: file.projNo, + posNo: file.posNo, + posRevNo: file.posRevNo, + fileSer: file.fileSer, + })), + }; + } + + const selectedFile = dcmtmResult.files[fileIndex]; + + // 2. 다운로드 URL 생성 + const downloadUrl = `/api/pos/download-on-demand?materialCode=${encodeURIComponent(materialCode)}&fileIndex=${fileIndex}`; + + return { + success: true, + downloadUrl, + fileName: selectedFile.fileName, + availableFiles: dcmtmResult.files.map(file => ({ + fileName: file.fileName, + dcmtmId: file.dcmtmId, + projNo: file.projNo, + posNo: file.posNo, + posRevNo: file.posRevNo, + fileSer: file.fileSer, + })), + }; + } catch (error) { + return { + success: false, + error: error instanceof Error ? error.message : '알 수 없는 오류가 발생했습니다.', + }; + } +} + +/** + * 여러 자재코드에 대한 POS 파일 다운로드 URL을 일괄 조회합니다. + * + * @param materialCodes - 자재코드 배열 + * @returns 각 자재코드별 다운로드 정보 + * + * @example + * ```typescript + * const results = await getDownloadUrlsForMaterialCodes([ + * 'SN2693A6410100001', + * 'SN2693A6410100002' + * ]); + * + * results.forEach(result => { + * if (result.success) { + * console.log(`${result.materialCode}: ${result.downloadUrl}`); + * } + * }); + * ``` + */ +export async function getDownloadUrlsForMaterialCodes( + materialCodes: string[] +): Promise> { + const results = await Promise.all( + materialCodes.map(async (materialCode) => { + const result = await getDownloadUrlByMaterialCode(materialCode); + return { + materialCode, + ...result, + }; + }) + ); + + return results; +} + +/** + * 자재코드의 POS 파일 존재 여부를 확인합니다. + * + * @param materialCode - 자재코드 (MATNR) + * @returns 파일 존재 여부와 파일 수 + */ +export async function checkPosFileExists( + materialCode: string +): Promise<{ + exists: boolean; + fileCount: number; + files?: Array<{ + fileName: string; + dcmtmId: string; + projNo: string; + posNo: string; + posRevNo: string; + fileSer: string; + }>; + error?: string; +}> { + try { + const dcmtmResult = await getDcmtmIdByMaterialCode({ materialCode }); + + if (!dcmtmResult.success || !dcmtmResult.files) { + return { + exists: false, + fileCount: 0, + error: dcmtmResult.error, + }; + } + + return { + exists: dcmtmResult.files.length > 0, + fileCount: dcmtmResult.files.length, + files: dcmtmResult.files.map(file => ({ + fileName: file.fileName, + dcmtmId: file.dcmtmId, + projNo: file.projNo, + posNo: file.posNo, + posRevNo: file.posRevNo, + fileSer: file.fileSer, + })), + }; + } catch (error) { + return { + exists: false, + fileCount: 0, + error: error instanceof Error ? error.message : '알 수 없는 오류', + }; + } +} + diff --git a/lib/pos/index.ts b/lib/pos/index.ts index 75309bdd..d889f8c1 100644 --- a/lib/pos/index.ts +++ b/lib/pos/index.ts @@ -1,4 +1,16 @@ -// POS 관련 모든 기능을 하나로 통합하는 인덱스 파일 +/** + * POS (Purchase Order Specification) 파일 관련 기능 통합 모듈 + * + * 주요 기능: + * - MATNR(자재코드)로 DCMTM_ID 조회 + * - SOAP API를 통한 POS 파일 경로 조회 + * - NFS 네트워크 드라이브에서 파일 다운로드 + * - 온디맨드 방식의 POS 파일 다운로드 (자동 동기화 제거됨) + * + * 주요 변경사항: + * - syncRfqPosFiles 함수 제거됨 (온디맨드 방식으로 대체) + * - getDownloadUrlByMaterialCode 등 새로운 온디맨드 함수 추가 + */ import { getEncryptDocumentumFile } from './get-pos'; import { createDownloadUrl } from './download-pos-file'; @@ -19,10 +31,6 @@ export { getFirstDcmtmId } from './get-dcmtm-id'; -export { - syncRfqPosFiles -} from './sync-rfq-pos-files'; - export { getDesignDocumentByMaterialCode, getDesignDocumentsForRfqItems, @@ -30,6 +38,12 @@ export { getDesignDocumentsForRfqItemsAction } from './design-document-service'; +export { + getDownloadUrlByMaterialCode, + getDownloadUrlsForMaterialCodes, + checkPosFileExists +} from './download-on-demand-action'; + // 타입들은 ./types 에서 export export type * from './types'; diff --git a/lib/pos/sync-rfq-pos-files.ts b/lib/pos/sync-rfq-pos-files.ts deleted file mode 100644 index acb34f20..00000000 --- a/lib/pos/sync-rfq-pos-files.ts +++ /dev/null @@ -1,407 +0,0 @@ -'use server'; - -import db from '@/db/db'; -import { rfqPrItems, rfqLastAttachments, rfqLastAttachmentRevisions } from '@/db/schema/rfqLast'; -import { eq, and, ne } from 'drizzle-orm'; -import { getDcmtmIdByMaterialCode } from './get-dcmtm-id'; -import { getEncryptDocumentumFile } from './get-pos'; -import { downloadPosFile } from './download-pos-file'; -import type { PosFileSyncResult } from './types'; -import path from 'path'; -import fs from 'fs/promises'; -import { revalidatePath } from 'next/cache'; -import { debugLog, debugError, debugSuccess, debugProcess, debugWarn } from '@/lib/debug-utils'; - - -/** - * RFQ의 모든 PR Items의 MATNR로 POS 파일을 조회하고 서버에 다운로드하여 저장 - */ -export async function syncRfqPosFiles( - rfqId: number, - userId: number -): Promise { - debugLog(`🚀 POS 파일 동기화 시작`, { rfqId, userId }); - - const result: PosFileSyncResult = { - success: false, - processedCount: 0, - successCount: 0, - failedCount: 0, - errors: [], - details: [] - }; - - try { - // 1. RFQ의 모든 PR Items 조회 (materialCode 중복 제거) - debugProcess(`📋 RFQ PR Items 조회 시작 (RFQ ID: ${rfqId})`); - - const prItems = await db - .selectDistinct({ - materialCode: rfqPrItems.materialCode, - materialDescription: rfqPrItems.materialDescription, - }) - .from(rfqPrItems) - .where(and( - eq(rfqPrItems.rfqsLastId, rfqId), - // materialCode가 null이 아닌 것만 - )) - .then(items => items.filter(item => item.materialCode && item.materialCode.trim() !== '')); - - debugLog(`📦 조회된 PR Items`, { - totalCount: prItems.length, - materialCodes: prItems.map(item => item.materialCode) - }); - - if (prItems.length === 0) { - debugWarn(`⚠️ 처리할 자재코드가 없습니다 (RFQ ID: ${rfqId})`); - result.errors.push('처리할 자재코드가 없습니다.'); - return result; - } - - result.processedCount = prItems.length; - debugSuccess(`✅ 처리할 자재코드 ${prItems.length}개 발견`); - - // 2. 각 자재코드별로 POS 파일 처리 - debugProcess(`🔄 자재코드별 POS 파일 처리 시작`); - - for (const prItem of prItems) { - const materialCode = prItem.materialCode!; - debugLog(`📋 자재코드 처리 시작: ${materialCode}`); - - try { - // 2-1. 자재코드로 DCMTM_ID 조회 - debugProcess(`🔍 DCMTM_ID 조회 시작 (자재코드: ${materialCode})`); - const dcmtmResult = await getDcmtmIdByMaterialCode({ materialCode }); - - debugLog(`🎯 DCMTM_ID 조회 결과`, { - materialCode, - success: dcmtmResult.success, - fileCount: dcmtmResult.files?.length || 0, - files: dcmtmResult.files - }); - - if (!dcmtmResult.success || !dcmtmResult.files || dcmtmResult.files.length === 0) { - debugWarn(`⚠️ DCMTM_ID 조회 실패 또는 파일 없음 (자재코드: ${materialCode})`, dcmtmResult.error); - result.details.push({ - materialCode, - status: 'no_files', - error: dcmtmResult.error || 'POS 파일을 찾을 수 없음' - }); - continue; - } - - // 여러 파일이 있을 경우 첫 번째 파일만 처리 - const posFile = dcmtmResult.files[0]; - debugLog(`📁 처리할 POS 파일 선택`, { - materialCode, - selectedFile: posFile, - totalFiles: dcmtmResult.files.length - }); - - // 2-2. POS API로 파일 경로 가져오기 - debugProcess(`🌐 POS API 호출 시작 (DCMTM_ID: ${posFile.dcmtmId})`); - const posResult = await getEncryptDocumentumFile({ - objectID: posFile.dcmtmId - }); - - debugLog(`🌐 POS API 호출 결과`, { - materialCode, - dcmtmId: posFile.dcmtmId, - success: posResult.success, - resultPath: posResult.result, - error: posResult.error - }); - - if (!posResult.success || !posResult.result) { - debugError(`❌ POS API 호출 실패 (자재코드: ${materialCode})`, posResult.error); - result.details.push({ - materialCode, - fileName: posFile.fileName, - status: 'failed', - error: posResult.error || 'POS 파일 경로 조회 실패' - }); - result.failedCount++; - continue; - } - - // 2-3. 내부망에서 파일 다운로드 - debugProcess(`⬇️ 파일 다운로드 시작 (경로: ${posResult.result})`); - const downloadResult = await downloadPosFile({ - relativePath: posResult.result - }); - - debugLog(`⬇️ 파일 다운로드 결과`, { - materialCode, - success: downloadResult.success, - fileName: downloadResult.fileName, - fileSize: downloadResult.fileBuffer?.length, - mimeType: downloadResult.mimeType, - error: downloadResult.error - }); - - if (!downloadResult.success || !downloadResult.fileBuffer) { - debugError(`❌ 파일 다운로드 실패 (자재코드: ${materialCode})`, downloadResult.error); - result.details.push({ - materialCode, - fileName: posFile.fileName, - status: 'failed', - error: downloadResult.error || '파일 다운로드 실패' - }); - result.failedCount++; - continue; - } - - // 2-4. 서버 파일 시스템에 저장 - debugProcess(`💾 서버 파일 저장 시작 (파일명: ${downloadResult.fileName || `${materialCode}.pdf`})`); - const saveResult = await saveFileToServer( - downloadResult.fileBuffer, - downloadResult.fileName || `${materialCode}.pdf` - ); - - debugLog(`💾 서버 파일 저장 결과`, { - materialCode, - success: saveResult.success, - filePath: saveResult.filePath, - fileName: saveResult.fileName, - error: saveResult.error - }); - - if (!saveResult.success) { - debugError(`❌ 서버 파일 저장 실패 (자재코드: ${materialCode})`, saveResult.error); - result.details.push({ - materialCode, - fileName: posFile.fileName, - status: 'failed', - error: saveResult.error || '서버 파일 저장 실패' - }); - result.failedCount++; - continue; - } - - // 2-5. 데이터베이스에 첨부파일 정보 저장 - debugProcess(`🗄️ DB 첨부파일 정보 저장 시작 (자재코드: ${materialCode})`); - const dbResult = await saveAttachmentToDatabase( - rfqId, - materialCode, - { dcmtmId: posFile.dcmtmId, fileName: posFile.fileName }, - saveResult.filePath!, - saveResult.fileName!, - downloadResult.fileBuffer.length, - downloadResult.mimeType || 'application/pdf', - userId - ); - - debugLog(`🗄️ DB 저장 결과`, { - materialCode, - success: dbResult.success, - error: dbResult.error - }); - - if (!dbResult.success) { - debugError(`❌ DB 저장 실패 (자재코드: ${materialCode})`, dbResult.error); - result.details.push({ - materialCode, - fileName: posFile.fileName, - status: 'failed', - error: dbResult.error || 'DB 저장 실패' - }); - result.failedCount++; - continue; - } - - debugSuccess(`✅ 자재코드 ${materialCode} 처리 완료`); - result.details.push({ - materialCode, - fileName: posFile.fileName, - status: 'success' - }); - result.successCount++; - - } catch (error) { - const errorMessage = error instanceof Error ? error.message : '알 수 없는 오류'; - debugError(`❌ 자재코드 ${materialCode} 처리 중 예외 발생`, { error: errorMessage, stack: error instanceof Error ? error.stack : undefined }); - result.details.push({ - materialCode, - status: 'failed', - error: errorMessage - }); - result.failedCount++; - result.errors.push(`${materialCode}: ${errorMessage}`); - } - } - - result.success = result.successCount > 0; - - debugLog(`📊 POS 파일 동기화 최종 결과`, { - rfqId, - processedCount: result.processedCount, - successCount: result.successCount, - failedCount: result.failedCount, - success: result.success, - errors: result.errors - }); - - // 캐시 무효화 - debugProcess(`🔄 캐시 무효화 (경로: /evcp/rfq-last/${rfqId})`); - revalidatePath(`/evcp/rfq-last/${rfqId}`); - - debugSuccess(`🎉 POS 파일 동기화 완료 (성공: ${result.successCount}건, 실패: ${result.failedCount}건)`); - return result; - - } catch (error) { - const errorMessage = error instanceof Error ? error.message : '알 수 없는 오류'; - debugError(`❌ POS 파일 동기화 전체 처리 오류`, { error: errorMessage, stack: error instanceof Error ? error.stack : undefined }); - result.errors.push(`전체 처리 오류: ${errorMessage}`); - return result; - } -} - -/** - * 파일을 서버 파일 시스템에 저장 - */ -async function saveFileToServer( - fileBuffer: Buffer, - originalFileName: string -): Promise<{ - success: boolean; - filePath?: string; - fileName?: string; - error?: string; -}> { - try { - // uploads/pos 디렉토리 생성 - const uploadDir = path.join(process.cwd(), 'uploads', 'pos'); - - try { - await fs.access(uploadDir); - } catch { - await fs.mkdir(uploadDir, { recursive: true }); - } - - // 고유한 파일명 생성 (타임스탬프 + 원본명) - const timestamp = Date.now(); - const sanitizedFileName = originalFileName.replace(/[^a-zA-Z0-9.-]/g, '_'); - const fileName = `${timestamp}_${sanitizedFileName}`; - const filePath = path.join(uploadDir, fileName); - - // 파일 저장 - await fs.writeFile(filePath, fileBuffer); - - return { - success: true, - filePath: `uploads/pos/${fileName}`, // 상대 경로로 저장 - fileName: originalFileName - }; - } catch (error) { - return { - success: false, - error: error instanceof Error ? error.message : '파일 저장 실패' - }; - } -} - -/** - * 첨부파일 정보를 데이터베이스에 저장 - */ -async function saveAttachmentToDatabase( - rfqId: number, - materialCode: string, - posFileInfo: { dcmtmId: string; fileName: string }, - filePath: string, - originalFileName: string, - fileSize: number, - fileType: string, - userId: number -): Promise<{ - success: boolean; - error?: string; -}> { - try { - await db.transaction(async (tx) => { - // 1. 기존 동일한 자재코드의 설계 첨부파일이 있는지 확인 - const existingAttachment = await tx - .select() - .from(rfqLastAttachments) - .where(and( - eq(rfqLastAttachments.rfqId, rfqId), - eq(rfqLastAttachments.attachmentType, '설계'), - eq(rfqLastAttachments.serialNo, materialCode) - )) - .limit(1); - - let attachmentId: number; - - if (existingAttachment.length > 0) { - // 기존 첨부파일이 있으면 업데이트 - attachmentId = existingAttachment[0].id; - - await tx - .update(rfqLastAttachments) - .set({ - currentRevision: 'Rev.1', // 새 리비전으로 업데이트 - description: `${posFileInfo.fileName} (자재코드: ${materialCode})`, - updatedAt: new Date() - }) - .where(eq(rfqLastAttachments.id, attachmentId)); - } else { - // 새 첨부파일 생성 - const [newAttachment] = await tx - .insert(rfqLastAttachments) - .values({ - attachmentType: '설계', - serialNo: materialCode, - rfqId, - currentRevision: 'Rev.0', - description: `${posFileInfo.fileName} (자재코드: ${materialCode})`, - createdBy: userId, - createdAt: new Date(), - updatedAt: new Date() - }) - .returning({ id: rfqLastAttachments.id }); - - attachmentId = newAttachment.id; - } - - // 2. 새 리비전 생성 - const [newRevision] = await tx - .insert(rfqLastAttachmentRevisions) - .values({ - attachmentId, - revisionNo: 'Rev.0', - fileName: path.basename(filePath), - originalFileName, - filePath, - fileSize, - fileType, - isLatest: true, - revisionComment: `POS 시스템에서 자동 동기화됨 (DCMTM_ID: ${posFileInfo.dcmtmId})`, - createdBy: userId - }) - .returning({ id: rfqLastAttachmentRevisions.id }); - - // 3. 첨부파일의 latestRevisionId 업데이트 - await tx - .update(rfqLastAttachments) - .set({ - latestRevisionId: newRevision.id - }) - .where(eq(rfqLastAttachments.id, attachmentId)); - - // 4. 기존 리비전들의 isLatest를 false로 업데이트 - await tx - .update(rfqLastAttachmentRevisions) - .set({ isLatest: false }) - .where(and( - eq(rfqLastAttachmentRevisions.attachmentId, attachmentId), - ne(rfqLastAttachmentRevisions.id, newRevision.id) - )); - }); - - return { success: true }; - } catch (error) { - return { - success: false, - error: error instanceof Error ? error.message : 'DB 저장 실패' - }; - } -} -- cgit v1.2.3