1 files changed, 40 insertions, 0 deletions
diff --git a/lib/techsales-rfq/service.ts b/lib/techsales-rfq/service.ts
index f7a30b3b..f3bb2e59 100644
--- a/lib/techsales-rfq/service.ts
+++ b/lib/techsales-rfq/service.ts
@@ -2490,6 +2490,46 @@ export interface TechSalesComment {
 }
 
 /**
+ * 특정 RFQ의 벤더별 읽지 않은 메시지 개수를 조회하는 함수
+ * 
+ * @param rfqId RFQ ID
+ * @returns 벤더별 읽지 않은 메시지 개수 (vendorId: count)
+ */
+export async function getTechSalesUnreadMessageCounts(rfqId: number): Promise<Record<number, number>> {
+  try {
+    // 벤더가 보낸 읽지 않은 메시지를 벤더별로 카운트
+    const unreadCounts = await db
+      .select({
+        vendorId: techSalesRfqComments.vendorId,
+        count: sql<number>`count(*)`,
+      })
+      .from(techSalesRfqComments)
+      .where(
+        and(
+          eq(techSalesRfqComments.rfqId, rfqId),
+          eq(techSalesRfqComments.isVendorComment, true), // 벤더가 보낸 메시지
+          eq(techSalesRfqComments.isRead, false), // 읽지 않은 메시지
+          sql`${techSalesRfqComments.vendorId} IS NOT NULL` // vendorId가 null이 아닌 것
+        )
+      )
+      .groupBy(techSalesRfqComments.vendorId);
+
+    // Record<number, number> 형태로 변환
+    const result: Record<number, number> = {};
+    unreadCounts.forEach(item => {
+      if (item.vendorId) {
+        result[item.vendorId] = item.count;
+      }
+    });
+
+    return result;
+  } catch (error) {
+    console.error('techSales 읽지 않은 메시지 개수 조회 오류:', error);
+    return {};
+  }
+}
+
+/**
  * 특정 RFQ와 벤더 간의 커뮤니케이션 메시지를 가져오는 서버 액션
  * 
  * @param rfqId RFQ ID