(임수민) 기본계약 코멘트, 법무검토 수정

1 files changed, 201 insertions, 41 deletions

diff --git a/lib/basic-contract/agreement-comments/actions.ts b/lib/basic-contract/agreement-comments/actions.ts
index 13db2fc6..c4ded36e 100644
--- a/lib/basic-contract/agreement-comments/actions.ts
+++ b/lib/basic-contract/agreement-comments/actions.ts
@@ -56,16 +56,17 @@ export async function getAgreementComments(
         
         if (comment.attachments) {
           try {
+            const attachmentData = comment.attachments;
             // 문자열인 경우 파싱 시도
-            if (typeof comment.attachments === 'string') {
-              const trimmed = comment.attachments.trim();
+            if (typeof attachmentData === 'string') {
+              const trimmed = String(attachmentData).trim();
               if (trimmed && trimmed !== '') {
                 attachments = JSON.parse(trimmed);
               }
             } 
             // 이미 배열인 경우 그대로 사용
-            else if (Array.isArray(comment.attachments)) {
-              attachments = comment.attachments;
+            else if (Array.isArray(attachmentData)) {
+              attachments = attachmentData as AgreementCommentAttachment[];
             }
           } catch (parseError) {
             console.warn(`⚠️ [getAgreementComments] 코멘트 ${comment.id}의 attachments 파싱 실패:`, parseError);
@@ -90,12 +91,14 @@ export async function getAgreementComments(
 }
 
 /**
- * 코멘트 추가
+ * 코멘트 추가 (파일 첨부 포함)
  */
 export async function addAgreementComment(data: {
   basicContractId: number;
   comment: string;
   authorName?: string;
+  files?: File[];
+  shouldSendEmail?: boolean; // 이메일 발송 여부 (제출할 때만 true)
 }): Promise<{ success: boolean; data?: AgreementCommentData; error?: string }> {
   try {
     const session = await getServerSession(authOptions);
@@ -152,6 +155,34 @@ export async function addAgreementComment(data: {
       templateName = template?.templateName || null;
     }
 
+    // 파일 업로드 처리 (있을 경우)
+    const uploadedAttachments: AgreementCommentAttachment[] = [];
+    if (data.files && data.files.length > 0) {
+      for (const file of data.files) {
+        try {
+          const saveResult = await saveFile({
+            file,
+            directory: "agreement-comments",
+            originalName: file.name,
+            userId: user.id?.toString(),
+          });
+
+          if (saveResult.success && saveResult.publicPath) {
+            uploadedAttachments.push({
+              id: crypto.randomUUID(),
+              fileName: file.name,
+              filePath: saveResult.publicPath,
+              fileSize: file.size,
+              uploadedAt: new Date(),
+            });
+          }
+        } catch (fileError) {
+          console.error(`파일 업로드 실패 (${file.name}):`, fileError);
+          // 개별 파일 실패는 무시하고 계속 진행
+        }
+      }
+    }
+
     // 코멘트 저장
     const [newComment] = await db
       .insert(agreementComments)
@@ -162,24 +193,27 @@ export async function addAgreementComment(data: {
         authorVendorId: isVendor ? user.companyId : null,
         authorName: data.authorName || user.name,
         comment: data.comment,
-        attachments: JSON.stringify([]),
-      })
+        attachments: uploadedAttachments.length > 0 ? JSON.stringify(uploadedAttachments) : JSON.stringify([]),
+      } as any)
       .returning();
 
-    // 이메일 알림 발송
-    try {
-      await sendCommentNotificationEmail({
-        comment: newComment,
-        contract,
-        vendor,
-        requester,
-        templateName,
-        authorType,
-        authorName: data.authorName || user.name,
-      });
-    } catch (emailError) {
-      console.error("이메일 발송 실패:", emailError);
-      // 이메일 실패는 코멘트 저장 성공에 영향을 주지 않음
+    // 이메일 알림 발송 (shouldSendEmail이 true일 때만)
+    if (data.shouldSendEmail) {
+      try {
+        await sendCommentNotificationEmail({
+          comment: newComment,
+          contract,
+          vendor,
+          requester,
+          templateName,
+          authorType,
+          authorName: data.authorName || user.name,
+          attachmentCount: uploadedAttachments.length,
+        });
+      } catch (emailError) {
+        console.error("이메일 발송 실패:", emailError);
+        // 이메일 실패는 코멘트 저장 성공에 영향을 주지 않음
+      }
     }
 
     // 계약서 상태 업데이트 (협의중으로 변경)
@@ -194,7 +228,7 @@ export async function addAgreementComment(data: {
       data: {
         ...newComment,
         authorType: newComment.authorType as AgreementCommentAuthorType,
-        attachments: [],
+        attachments: uploadedAttachments,
       } as AgreementCommentData,
     };
   } catch (error) {
@@ -246,20 +280,25 @@ export async function deleteAgreementComment(
         isDeleted: true,
         deletedAt: new Date(),
         updatedAt: new Date(),
-      })
+      } as any)
       .where(eq(agreementComments.id, commentId));
 
     // 첨부파일이 있으면 파일 시스템에서도 삭제
     if (comment.attachments) {
-      const attachments: AgreementCommentAttachment[] = JSON.parse(
-        comment.attachments
-      );
-      for (const attachment of attachments) {
-        try {
-          await deleteFile(attachment.filePath);
-        } catch (fileError) {
-          console.error("파일 삭제 실패:", fileError);
+      try {
+        const attachmentsStr = typeof comment.attachments === 'string' 
+          ? comment.attachments 
+          : JSON.stringify(comment.attachments);
+        const attachments: AgreementCommentAttachment[] = JSON.parse(attachmentsStr);
+        for (const attachment of attachments) {
+          try {
+            await deleteFile(attachment.filePath);
+          } catch (fileError) {
+            console.error("파일 삭제 실패:", fileError);
+          }
         }
+      } catch (parseError) {
+        console.error("첨부파일 파싱 실패:", parseError);
       }
     }
 
@@ -322,9 +361,17 @@ export async function uploadCommentAttachment(
     };
 
     // 기존 첨부파일에 추가
-    const existingAttachments: AgreementCommentAttachment[] = comment.attachments
-      ? JSON.parse(comment.attachments)
-      : [];
+    let existingAttachments: AgreementCommentAttachment[] = [];
+    if (comment.attachments) {
+      try {
+        const attachmentsStr = typeof comment.attachments === 'string' 
+          ? comment.attachments 
+          : JSON.stringify(comment.attachments);
+        existingAttachments = JSON.parse(attachmentsStr);
+      } catch (parseError) {
+        console.error("기존 첨부파일 파싱 실패:", parseError);
+      }
+    }
     existingAttachments.push(newAttachment);
 
     // DB 업데이트
@@ -333,7 +380,7 @@ export async function uploadCommentAttachment(
       .set({
         attachments: JSON.stringify(existingAttachments),
         updatedAt: new Date(),
-      })
+      } as any)
       .where(eq(agreementComments.id, commentId));
 
     revalidateTag(`agreement-comments-${comment.basicContractId}`);
@@ -372,9 +419,19 @@ export async function deleteCommentAttachment(
     }
 
     // 첨부파일 목록에서 제거
-    const attachments: AgreementCommentAttachment[] = comment.attachments
-      ? JSON.parse(comment.attachments)
-      : [];
+    let attachments: AgreementCommentAttachment[] = [];
+    if (comment.attachments) {
+      try {
+        const attachmentsStr = typeof comment.attachments === 'string' 
+          ? comment.attachments 
+          : JSON.stringify(comment.attachments);
+        attachments = JSON.parse(attachmentsStr);
+      } catch (parseError) {
+        console.error("첨부파일 파싱 실패:", parseError);
+        return { success: false, error: "첨부파일 정보를 읽을 수 없습니다." };
+      }
+    }
+    
     const targetAttachment = attachments.find((a) => a.id === attachmentId);
 
     if (!targetAttachment) {
@@ -389,7 +446,7 @@ export async function deleteCommentAttachment(
       .set({
         attachments: JSON.stringify(updatedAttachments),
         updatedAt: new Date(),
-      })
+      } as any)
       .where(eq(agreementComments.id, commentId));
 
     // 파일 시스템에서 삭제
@@ -449,8 +506,9 @@ async function sendCommentNotificationEmail(params: {
   templateName: string | null;
   authorType: AgreementCommentAuthorType;
   authorName: string;
+  attachmentCount?: number;
 }) {
-  const { comment, contract, vendor, requester, templateName, authorType, authorName } = params;
+  const { comment, contract, vendor, requester, templateName, authorType, authorName, attachmentCount = 0 } = params;
 
   // 수신자 결정
   let recipientEmail: string | undefined;
@@ -478,7 +536,7 @@ async function sendCommentNotificationEmail(params: {
   // 이메일 발송
   await sendEmail({
     to: recipientEmail,
-    subject: `[eVCP] GTC 기본계약서 협의 코멘트 - ${templateName || '기본계약서'}`,
+    subject: `[eVCP] GTC 기본계약서 협의 코멘트 제출 - ${templateName || '기본계약서'}`,
     template: "agreement-comment-notification",
     context: {
       language: "ko",
@@ -488,6 +546,7 @@ async function sendCommentNotificationEmail(params: {
       comment: comment.comment,
       templateName: templateName || '기본계약서',
       vendorName: vendor?.vendorName || '',
+      attachmentCount,
       contractUrl: `${process.env.NEXT_PUBLIC_APP_URL}/evcp/basic-contract/${contract.id}`,
       systemUrl: process.env.NEXT_PUBLIC_APP_URL || 'https://evcp.com',
       currentYear: new Date().getFullYear(),
@@ -496,6 +555,107 @@ async function sendCommentNotificationEmail(params: {
 }
 
 /**
+ * 협의 완료 처리
+ */
+export async function completeNegotiation(
+  basicContractId: number
+): Promise<{ success: boolean; error?: string }> {
+  try {
+    const session = await getServerSession(authOptions);
+    if (!session?.user) {
+      return { success: false, error: "인증이 필요합니다." };
+    }
+
+    // 기본계약서 정보 조회
+    const [contract] = await db
+      .select()
+      .from(basicContract)
+      .where(eq(basicContract.id, basicContractId))
+      .limit(1);
+
+    if (!contract) {
+      return { success: false, error: "계약서를 찾을 수 없습니다." };
+    }
+
+    // 협의 완료 상태로 업데이트
+    await db
+      .update(basicContract)
+      .set({
+        negotiationCompletedAt: new Date(),
+        updatedAt: new Date(),
+      } as any)
+      .where(eq(basicContract.id, basicContractId));
+
+    // 벤더 정보 조회 (이메일 발송용)
+    let vendor: any = null;
+    if (contract.vendorId) {
+      [vendor] = await db
+        .select()
+        .from(vendors)
+        .where(eq(vendors.id, contract.vendorId))
+        .limit(1);
+    }
+
+    // 요청자 정보 조회 (이메일 발송용)
+    let requester: any = null;
+    if (contract.requestedBy) {
+      [requester] = await db
+        .select()
+        .from(users)
+        .where(eq(users.id, contract.requestedBy))
+        .limit(1);
+    }
+
+    // 템플릿 이름 조회
+    const { basicContractTemplates } = await import("@/db/schema");
+    let templateName: string | null = null;
+    if (contract.templateId) {
+      const [template] = await db
+        .select()
+        .from(basicContractTemplates)
+        .where(eq(basicContractTemplates.id, contract.templateId))
+        .limit(1);
+      templateName = template?.templateName || null;
+    }
+
+    // 이메일 알림 발송
+    try {
+      if (requester) {
+        await sendEmail({
+          to: requester.email || '',
+          subject: `[eVCP] GTC 기본계약서 협의 완료 - ${templateName || '기본계약서'}`,
+          template: "negotiation-complete-notification",
+          context: {
+            language: "ko",
+            recipientName: requester.name || "담당자",
+            templateName: templateName || '기본계약서',
+            vendorName: vendor?.vendorName || '',
+            contractUrl: `${process.env.NEXT_PUBLIC_APP_URL}/evcp/basic-contract/${contract.id}`,
+            systemUrl: process.env.NEXT_PUBLIC_APP_URL || 'https://evcp.com',
+            currentYear: new Date().getFullYear(),
+          },
+        });
+      }
+    } catch (emailError) {
+      console.error("이메일 발송 실패:", emailError);
+      // 이메일 실패는 협의 완료 처리 성공에 영향을 주지 않음
+    }
+
+    // 캐시 무효화
+    revalidateTag(`agreement-comments-${basicContractId}`);
+    revalidateTag(`basic-contracts`);
+
+    return { success: true };
+  } catch (error) {
+    console.error("협의 완료 처리 실패:", error);
+    return {
+      success: false,
+      error: "협의 완료 처리 중 오류가 발생했습니다.",
+    };
+  }
+}
+
+/**
  * 계약서 협의 상태 업데이트
  * 실제로 DB 상태를 변경하지 않고, gtcData 조회 시 agreementComments 존재 여부로 판단
  */