path: root/lib/swp/vendor-actions.ts

"use server";

import { getServerSession } from "next-auth";
import { authOptions } from "@/app/api/auth/[...nextauth]/route";
import db from "@/db/db";
import { vendors } from "@/db/schema/vendors";
import { contracts } from "@/db/schema/contract";
import { projects } from "@/db/schema/projects";
import { eq } from "drizzle-orm";
import { 
  getDocumentList, 
  getDocumentDetail,
  cancelStandbyFile,
  downloadDocumentFile,
  type DocumentListItem,
  type DocumentDetail,
  type DownloadFileResult
} from "./document-service";
import { debugLog, debugError, debugSuccess, debugProcess, debugWarn } from "@/lib/debug-utils";

// ============================================================================
// 벤더 세션 정보 조회
// ============================================================================

interface VendorSessionInfo {
  vendorId: number;
  vendorCode: string;
  vendorName: string;
  companyId: number;
}

export async function getVendorSessionInfo(): Promise<VendorSessionInfo | null> {
  debugProcess("벤더 세션 정보 조회 시작");

  const session = await getServerSession(authOptions);
  debugLog("세션 조회 완료", { hasSession: !!session, hasCompanyId: !!session?.user?.companyId });

  if (!session?.user?.companyId) {
    debugWarn("세션 또는 companyId 없음");
    return null;
  }

  const companyId = typeof session.user.companyId === 'string'
    ? parseInt(session.user.companyId, 10)
    : session.user.companyId as number;

  debugLog("벤더 정보 조회 시작", { companyId });

  // vendors 테이블에서 companyId로 벤더 정보 조회
  const vendor = await db
    .select({
      id: vendors.id,
      vendorCode: vendors.vendorCode,
      vendorName: vendors.vendorName,
    })
    .from(vendors)
    .where(eq(vendors.id, companyId))
    .limit(1);

  debugLog("벤더 정보 조회 완료", { found: !!vendor[0], vendorCode: vendor[0]?.vendorCode });

  if (!vendor[0] || !vendor[0].vendorCode) {
    debugWarn("벤더 정보 또는 벤더 코드 없음", { vendor: vendor[0] });
    return null;
  }

  const result = {
    vendorId: vendor[0].id,
    vendorCode: vendor[0].vendorCode,
    vendorName: vendor[0].vendorName,
    companyId,
  };

  debugSuccess("벤더 세션 정보 조회 성공", { vendorCode: result.vendorCode });
  return result;
}

// ============================================================================
// 벤더의 프로젝트 목록 조회
// ============================================================================

export async function fetchVendorProjects() {
  debugProcess("벤더 프로젝트 목록 조회 시작");

  try {
    const vendorInfo = await getVendorSessionInfo();

    if (!vendorInfo) {
      debugError("벤더 정보 없음 - 프로젝트 조회 실패");
      throw new Error("벤더 정보를 찾을 수 없습니다.");
    }

    debugLog("프로젝트 목록 DB 조회 시작", { vendorId: vendorInfo.vendorId });

    // contracts 테이블에서 해당 벤더의 계약들의 프로젝트 조회
    const vendorProjects = await db
      .selectDistinct({
        PROJ_NO: projects.code,
        PROJ_NM: projects.name,
      })
      .from(contracts)
      .innerJoin(projects, eq(contracts.projectId, projects.id))
      .where(eq(contracts.vendorId, vendorInfo.vendorId))
      .orderBy(projects.code);

    debugSuccess("프로젝트 목록 조회 성공", { count: vendorProjects.length });
    return vendorProjects;
  } catch (error) {
    debugError("프로젝트 목록 조회 실패", error);
    console.error("[fetchVendorProjects] 오류:", error);
    return [];
  }
}

// ============================================================================
// 벤더 필터링된 문서 목록 조회 (Full API 기반)
// ============================================================================

export async function fetchVendorDocuments(projNo?: string): Promise<DocumentListItem[]> {
  debugProcess("벤더 문서 목록 조회 시작", { projNo });

  try {
    const vendorInfo = await getVendorSessionInfo();

    if (!vendorInfo) {
      debugError("벤더 정보 없음 - 문서 조회 실패");
      throw new Error("벤더 정보를 찾을 수 없습니다.");
    }

    if (!projNo) {
      debugWarn("프로젝트 번호 없음");
      return [];
    }

    debugLog("문서 목록 조회 시작", { 
      projNo, 
      vendorCode: vendorInfo.vendorCode 
    });

    // document-service의 getDocumentList 사용
    const documents = await getDocumentList(projNo, vendorInfo.vendorCode);

    debugSuccess("문서 목록 조회 성공", { count: documents.length });
    return documents;
  } catch (error) {
    debugError("문서 목록 조회 실패", error);
    console.error("[fetchVendorDocuments] 오류:", error);
    throw new Error("문서 목록 조회 실패 [담당자에게 문의하세요]");
  }
}

// ============================================================================
// 문서 상세 조회 (Rev-Activity-File 트리)
// ============================================================================

export async function fetchVendorDocumentDetail(
  projNo: string,
  docNo: string
): Promise<DocumentDetail> {
  debugProcess("벤더 문서 상세 조회 시작", { projNo, docNo });

  try {
    const vendorInfo = await getVendorSessionInfo();

    if (!vendorInfo) {
      debugError("벤더 정보 없음");
      throw new Error("벤더 정보를 찾을 수 없습니다.");
    }

    debugLog("문서 상세 조회 시작", { projNo, docNo });

    // document-service의 getDocumentDetail 사용
    const detail = await getDocumentDetail(projNo, docNo);

    debugSuccess("문서 상세 조회 성공", {
      docNo: detail.docNo,
      revisions: detail.revisions.length,
    });

    return detail;
  } catch (error) {
    debugError("문서 상세 조회 실패", error);
    console.error("[fetchVendorDocumentDetail] 오류:", error);
    throw new Error("문서 상세 조회 실패");
  }
}

// ============================================================================
// 파일 취소
// ============================================================================

export async function cancelVendorFile(
  boxSeq: string,
  actvSeq: string
): Promise<void> {
  debugProcess("벤더 파일 취소 시작", { boxSeq, actvSeq });

  try {
    const vendorInfo = await getVendorSessionInfo();

    if (!vendorInfo) {
      debugError("벤더 정보 없음");
      throw new Error("벤더 정보를 찾을 수 없습니다.");
    }

    // vendorId를 문자열로 변환하여 사용
    await cancelStandbyFile(boxSeq, actvSeq, String(vendorInfo.vendorId));

    debugSuccess("파일 취소 완료", { boxSeq, actvSeq });
  } catch (error) {
    debugError("파일 취소 실패", error);
    console.error("[cancelVendorFile] 오류:", error);
    throw new Error("파일 취소 실패");
  }
}

// ============================================================================
// 파일 다운로드
// ============================================================================

export async function downloadVendorFile(
  projNo: string,
  ownDocNo: string,
  fileName: string
): Promise<DownloadFileResult> {
  debugProcess("벤더 파일 다운로드 시작", { projNo, ownDocNo, fileName });

  try {
    const vendorInfo = await getVendorSessionInfo();

    if (!vendorInfo) {
      debugError("벤더 정보 없음");
      return {
        success: false,
        error: "벤더 정보를 찾을 수 없습니다.",
      };
    }

    // document-service의 downloadDocumentFile 사용
    const result = await downloadDocumentFile(projNo, ownDocNo, fileName);

    if (result.success) {
      debugSuccess("파일 다운로드 완료", { fileName });
    } else {
      debugWarn("파일 다운로드 실패", { fileName, error: result.error });
    }

    return result;
  } catch (error) {
    debugError("파일 다운로드 실패", error);
    console.error("[downloadVendorFile] 오류:", error);
    return {
      success: false,
      error: error instanceof Error ? error.message : "파일 다운로드 실패",
    };
  }
}

// ============================================================================
// 벤더 통계 조회 (Full API 기반)
// ============================================================================

export async function fetchVendorSwpStats(projNo?: string) {
  debugProcess("벤더 통계 조회 시작", { projNo });

  try {
    const vendorInfo = await getVendorSessionInfo();

    if (!vendorInfo) {
      debugError("벤더 정보 없음 - 통계 조회 실패");
      throw new Error("벤더 정보를 찾을 수 없습니다.");
    }

    if (!projNo) {
      debugWarn("프로젝트 번호 없음");
      return {
        total_documents: 0,
        total_revisions: 0,
        total_files: 0,
        uploaded_files: 0,
        last_sync: null,
      };
    }

    // API에서 문서 목록 조회
    const documents = await getDocumentList(projNo, vendorInfo.vendorCode);

    // 통계 계산
    let totalRevisions = 0;
    let totalFiles = 0;
    let uploadedFiles = 0;

    for (const doc of documents) {
      totalFiles += doc.fileCount;
      // standbyFileCount가 0이 아니면 업로드된 것으로 간주
      uploadedFiles += doc.fileCount - doc.standbyFileCount;
      
      // 리비전 수 추정 (LTST_REV_NO 기반)
      if (doc.LTST_REV_NO) {
        const revNum = parseInt(doc.LTST_REV_NO, 10);
        if (!isNaN(revNum)) {
          totalRevisions += revNum + 1; // Rev 00부터 시작이므로 +1
        }
      }
    }

    const result = {
      total_documents: documents.length,
      total_revisions: totalRevisions,
      total_files: totalFiles,
      uploaded_files: uploadedFiles,
      last_sync: new Date(), // API 기반이므로 항상 최신
    };

    debugSuccess("통계 조회 성공", {
      documents: result.total_documents,
      revisions: result.total_revisions,
      files: result.total_files,
      uploaded: result.uploaded_files,
    });

    return result;
  } catch (error) {
    debugError("통계 조회 실패", error);
    console.error("[fetchVendorSwpStats] 오류:", error);
    return {
      total_documents: 0,
      total_revisions: 0,
      total_files: 0,
      uploaded_files: 0,
      last_sync: null,
    };
  }
}

// ============================================================================
// 주의: 파일 업로드는 /api/swp/upload 라우트에서 처리됩니다
// ============================================================================