1 files changed, 239 insertions, 6 deletions

diff --git a/lib/techsales-rfq/service.ts b/lib/techsales-rfq/service.ts
index c3c14aff..96d6a3c9 100644
--- a/lib/techsales-rfq/service.ts
+++ b/lib/techsales-rfq/service.ts
@@ -11,7 +11,7 @@ import {
   techSalesRfqItems,
   biddingProjects
 } from "@/db/schema";
-import { and, desc, eq, ilike, or, sql, inArray } from "drizzle-orm";
+import { and, desc, eq, ilike, or, sql, inArray, count, asc } from "drizzle-orm";
 import { unstable_cache } from "@/lib/unstable-cache";
 import { filterColumns } from "@/lib/filter-columns";
 import { getErrorMessage } from "@/lib/handle-error";
@@ -3022,9 +3022,9 @@ export async function searchTechVendors(searchTerm: string, limit = 100, rfqType
   
   try {
     // RFQ 타입에 따른 벤더 타입 매핑
-    const vendorTypeFilter = rfqType === "SHIP" ? "SHIP" : 
-                            rfqType === "TOP" ? "OFFSHORE_TOP" :
-                            rfqType === "HULL" ? "OFFSHORE_HULL" : null;
+    const vendorTypeFilter = rfqType === "SHIP" ? "조선" : 
+                            rfqType === "TOP" ? "해양TOP" :
+                            rfqType === "HULL" ? "해양HULL" : null;
 
     const whereConditions = [
       eq(techVendors.status, "ACTIVE"),
@@ -3034,9 +3034,9 @@ export async function searchTechVendors(searchTerm: string, limit = 100, rfqType
       )
     ];
 
-    // RFQ 타입이 지정된 경우 벤더 타입 필터링 추가
+    // RFQ 타입이 지정된 경우 벤더 타입 필터링 추가 (컴마 구분 문자열에서 검색)
     if (vendorTypeFilter) {
-      whereConditions.push(eq(techVendors.techVendorType, vendorTypeFilter));
+      whereConditions.push(sql`${techVendors.techVendorType} LIKE ${'%' + vendorTypeFilter + '%'}`);
     }
 
     const results = await db
@@ -3058,4 +3058,237 @@ export async function searchTechVendors(searchTerm: string, limit = 100, rfqType
     console.error("Error searching tech vendors:", err);
     throw new Error(getErrorMessage(err));
   }
+}
+
+/**
+ * Accepted 상태의 Tech Sales Vendor Quotations 조회 (RFQ, Vendor 정보 포함)
+ */
+export async function getAcceptedTechSalesVendorQuotations(input: {
+  search?: string;
+  filters?: Filter<typeof techSalesVendorQuotations>[];
+  sort?: { id: string; desc: boolean }[];
+  page: number;
+  perPage: number;
+  rfqType?: "SHIP" | "TOP" | "HULL";
+}) {
+  unstable_noStore();
+  
+  try {
+    const offset = (input.page - 1) * input.perPage;
+    
+    // 기본 WHERE 조건: status = 'Accepted'만 조회
+    const baseConditions = [
+      eq(techSalesVendorQuotations.status, 'Accepted')
+    ];
+    
+    // 검색 조건 추가
+    const searchConditions = [];
+    if (input.search) {
+      searchConditions.push(
+        ilike(techSalesRfqs.rfqCode, `%${input.search}%`),
+        ilike(techSalesRfqs.description, `%${input.search}%`),
+        ilike(sql`vendors.vendor_name`, `%${input.search}%`),
+        ilike(sql`vendors.vendor_code`, `%${input.search}%`)
+      );
+    }
+
+    // 정렬 조건 변환
+    const orderByConditions: OrderByType[] = [];
+    if (input.sort?.length) {
+      input.sort.forEach((sortItem) => {
+        switch (sortItem.id) {
+          case "rfqCode":
+            orderByConditions.push(sortItem.desc ? desc(techSalesRfqs.rfqCode) : asc(techSalesRfqs.rfqCode));
+            break;
+          case "description":
+            orderByConditions.push(sortItem.desc ? desc(techSalesRfqs.description) : asc(techSalesRfqs.description));
+            break;
+          case "vendorName":
+            orderByConditions.push(sortItem.desc ? desc(sql`vendors.vendor_name`) : asc(sql`vendors.vendor_name`));
+            break;
+          case "vendorCode":
+            orderByConditions.push(sortItem.desc ? desc(sql`vendors.vendor_code`) : asc(sql`vendors.vendor_code`));
+            break;
+          case "totalPrice":
+            orderByConditions.push(sortItem.desc ? desc(techSalesVendorQuotations.totalPrice) : asc(techSalesVendorQuotations.totalPrice));
+            break;
+          case "acceptedAt":
+            orderByConditions.push(sortItem.desc ? desc(techSalesVendorQuotations.acceptedAt) : asc(techSalesVendorQuotations.acceptedAt));
+            break;
+          default:
+            orderByConditions.push(desc(techSalesVendorQuotations.acceptedAt));
+        }
+      });
+    } else {
+      orderByConditions.push(desc(techSalesVendorQuotations.acceptedAt));
+    }
+
+    // 필터 조건 추가
+    const filterConditions = [];
+    if (input.filters?.length) {
+      const { filterWhere, joinOperator } = filterColumns({
+        table: techSalesVendorQuotations,
+        filters: input.filters,
+        joinOperator: input.joinOperator ?? "and",
+      });
+      if (filterWhere) {  
+        filterConditions.push(filterWhere);
+      }
+    }
+
+    // RFQ 타입 필터
+    if (input.rfqType) {
+      filterConditions.push(eq(techSalesRfqs.rfqType, input.rfqType));
+    }
+
+    // 모든 조건 결합
+    const allConditions = [
+      ...baseConditions,
+      ...filterConditions,
+      ...(searchConditions.length > 0 ? [or(...searchConditions)] : [])
+    ];
+
+    const whereCondition = allConditions.length > 1 
+      ? and(...allConditions) 
+      : allConditions[0];
+
+    // 데이터 조회
+    const data = await db
+      .select({
+        // Quotation 정보
+        id: techSalesVendorQuotations.id,
+        rfqId: techSalesVendorQuotations.rfqId,
+        vendorId: techSalesVendorQuotations.vendorId,
+        quotationCode: techSalesVendorQuotations.quotationCode,
+        quotationVersion: techSalesVendorQuotations.quotationVersion,
+        totalPrice: techSalesVendorQuotations.totalPrice,
+        currency: techSalesVendorQuotations.currency,
+        validUntil: techSalesVendorQuotations.validUntil,
+        status: techSalesVendorQuotations.status,
+        remark: techSalesVendorQuotations.remark,
+        submittedAt: techSalesVendorQuotations.submittedAt,
+        acceptedAt: techSalesVendorQuotations.acceptedAt,
+        createdAt: techSalesVendorQuotations.createdAt,
+        updatedAt: techSalesVendorQuotations.updatedAt,
+        
+        // RFQ 정보
+        rfqCode: techSalesRfqs.rfqCode,
+        rfqType: techSalesRfqs.rfqType,
+        description: techSalesRfqs.description,
+        dueDate: techSalesRfqs.dueDate,
+        rfqStatus: techSalesRfqs.status,
+        materialCode: techSalesRfqs.materialCode,
+        
+        // Vendor 정보
+        vendorName: sql<string>`vendors.vendor_name`,
+        vendorCode: sql<string | null>`vendors.vendor_code`,
+        vendorEmail: sql<string | null>`vendors.email`,
+        vendorCountry: sql<string | null>`vendors.country`,
+        
+        // Project 정보
+        projNm: biddingProjects.projNm,
+        pspid: biddingProjects.pspid,
+        sector: biddingProjects.sector,
+      })
+      .from(techSalesVendorQuotations)
+      .leftJoin(techSalesRfqs, eq(techSalesVendorQuotations.rfqId, techSalesRfqs.id))
+      .leftJoin(sql`vendors`, eq(techSalesVendorQuotations.vendorId, sql`vendors.id`))
+      .leftJoin(biddingProjects, eq(techSalesRfqs.biddingProjectId, biddingProjects.id))
+      .where(whereCondition)
+      .orderBy(...orderByConditions)
+      .limit(input.perPage)
+      .offset(offset);
+
+    // 총 개수 조회
+    const totalCount = await db
+      .select({ count: count() })
+      .from(techSalesVendorQuotations)
+      .leftJoin(techSalesRfqs, eq(techSalesVendorQuotations.rfqId, techSalesRfqs.id))
+      .leftJoin(sql`vendors`, eq(techSalesVendorQuotations.vendorId, sql`vendors.id`))
+      .leftJoin(biddingProjects, eq(techSalesRfqs.biddingProjectId, biddingProjects.id))
+      .where(whereCondition);
+
+    const total = totalCount[0]?.count ?? 0;
+    const pageCount = Math.ceil(total / input.perPage);
+
+    return {
+      data,
+      pageCount,
+      total,
+    };
+
+  } catch (error) {
+    console.error("getAcceptedTechSalesVendorQuotations 오류:", error);
+    throw new Error(`Accepted quotations 조회 실패: ${getErrorMessage(error)}`);
+  }
+}
+
+/**
+ * 벤더 견적서 거절 처리 (벤더가 직접 거절)
+ */
+export async function rejectTechSalesVendorQuotations(input: {
+  quotationIds: number[];
+  rejectionReason?: string;
+}) {
+  try {
+    const session = await getServerSession(authOptions);
+    if (!session?.user?.id) {
+      throw new Error("인증이 필요합니다.");
+    }
+
+    const result = await db.transaction(async (tx) => {
+      // 견적서들이 존재하고 벤더가 권한이 있는지 확인
+      const quotations = await tx
+        .select({
+          id: techSalesVendorQuotations.id,
+          status: techSalesVendorQuotations.status,
+          vendorId: techSalesVendorQuotations.vendorId,
+        })
+        .from(techSalesVendorQuotations)
+        .where(inArray(techSalesVendorQuotations.id, input.quotationIds));
+
+      if (quotations.length !== input.quotationIds.length) {
+        throw new Error("일부 견적서를 찾을 수 없습니다.");
+      }
+
+      // 이미 거절된 견적서가 있는지 확인
+      const alreadyRejected = quotations.filter(q => q.status === "Rejected");
+      if (alreadyRejected.length > 0) {
+        throw new Error("이미 거절된 견적서가 포함되어 있습니다.");
+      }
+
+      // 승인된 견적서가 있는지 확인
+      const alreadyAccepted = quotations.filter(q => q.status === "Accepted");
+      if (alreadyAccepted.length > 0) {
+        throw new Error("이미 승인된 견적서는 거절할 수 없습니다.");
+      }
+
+      // 견적서 상태를 거절로 변경
+      await tx
+        .update(techSalesVendorQuotations)
+        .set({
+          status: "Rejected",
+          rejectionReason: input.rejectionReason || null,
+          updatedBy: parseInt(session.user.id),
+          updatedAt: new Date(),
+        })
+        .where(inArray(techSalesVendorQuotations.id, input.quotationIds));
+
+      return { success: true, updatedCount: quotations.length };
+    });
+    revalidateTag("techSalesRfqs");
+    revalidateTag("techSalesVendorQuotations");
+    revalidatePath("/partners/techsales/rfq-ship", "page");
+    return { 
+      success: true, 
+      message: `${result.updatedCount}개의 견적서가 거절되었습니다.`,
+      data: result
+    };
+  } catch (error) {
+    console.error("견적서 거절 오류:", error);
+    return { 
+      success: false, 
+      error: getErrorMessage(error) 
+    };
+  }
 }
\ No newline at end of file