(김준회) 견적 이메일 발송시, 첨부파일 복호화 처리

1 files changed, 31 insertions, 10 deletions

diff --git a/lib/rfq-last/service.ts b/lib/rfq-last/service.ts
index 65ead12b..462b5604 100644
--- a/lib/rfq-last/service.ts
+++ b/lib/rfq-last/service.ts
@@ -3153,6 +3153,12 @@ export interface SendRfqParams {
     fileName: string;
   }>;
   hasToSendEmail?: boolean; // 이메일 발송 여부
+  currentUser?: { // ⚠️ cronjob 환경을 위한 선택적 파라미터
+    id: string | number;
+    name?: string | null;
+    email?: string | null;
+    epId?: string | null;
+  };
 }
 
 export async function sendRfqToVendors({
@@ -3162,14 +3168,22 @@ export async function sendRfqToVendors({
   attachmentIds,
   message,
   generatedPdfs,
-  hasToSendEmail = true
+  hasToSendEmail = true,
+  currentUser: providedUser // ⚠️ cronjob 환경에서는 payload로 받은 유저 정보 사용
 }: SendRfqParams) {
-  const session = await getServerSession(authOptions);
-  if (!session?.user) {
-    throw new Error("인증이 필요합니다.");
-  }
+  let currentUser;
 
-  const currentUser = session.user;
+  if (providedUser) {
+    // ✅ Cronjob 환경: payload에서 받은 유저 정보 사용
+    currentUser = providedUser;
+  } else {
+    // ✅ 일반 환경: session에서 유저 정보 가져오기
+    const session = await getServerSession(authOptions);
+    if (!session?.user) {
+      throw new Error("인증이 필요합니다.");
+    }
+    currentUser = session.user;
+  }
 
   try {
     // 1. RFQ 기본 정보 조회 (트랜잭션 외부)
@@ -4183,13 +4197,20 @@ async function handleRfqSendEmail({
             ? path.join(process.cwd(), `public`, cleanPath)
             : path.join(`${process.env.NAS_PATH}`, cleanPath);
 
+          // 파일 읽기
           const fileBuffer = await fs.readFile(fullPath);
+          
+          // DRM 복호화 처리
+          const fileName = revision.originalFileName || `${attachment.attachmentType}_${attachment.serialNo}`;
+          const { decryptBufferWithServerAction } = await import('@/components/drm/drmUtils');
+          const decryptedBuffer = await decryptBufferWithServerAction(fileBuffer, fileName);
+          
           emailAttachmentsList.push({
-            filename: revision.originalFileName || `${attachment.attachmentType}_${attachment.serialNo}`,
-            content: fileBuffer
+            filename: fileName,
+            content: decryptedBuffer
           });
         } catch (error) {
-          console.error(`이메일 첨부파일 읽기 실패: ${cleanPath}`, error);
+          console.error(`이메일 첨부파일 처리 실패: ${revision.filePath || 'unknown'}`, error);
         }
       }
     }
@@ -5367,7 +5388,7 @@ export async function getAvlVendorsForRfq(rfqId: number) {
     console.error("AVL 벤더 조회 오류:", error);
     return { 
       success: false, 
-      error: "AVL 벤더 정보를 가져오는 중 오류가 발생했습니다." 
+      error: "-" 
     };
   }
 }