(김준회) SWP 다운로드, 업로드 api route 처리, 옥프로 컬럼 순서 조정 처리, 환경변수 오타 수정

3 files changed, 99 insertions, 378 deletions

diff --git a/lib/swp/actions.ts b/lib/swp/actions.ts
index 1faa69db..a7b4d3a3 100644
--- a/lib/swp/actions.ts
+++ b/lib/swp/actions.ts
@@ -7,6 +7,7 @@ import { fetchSwpProjectData } from "./api-client";
 import { syncSwpProject } from "./sync-service";
 import * as fs from "fs/promises";
 import * as path from "path";
+import { debugLog, debugError, debugWarn, debugSuccess } from "@/lib/debug-utils";
 
 // ============================================================================
 // 타입 정의
@@ -317,6 +318,8 @@ export interface DownloadFileResult {
 
 export async function downloadSwpFile(fileId: number): Promise<DownloadFileResult> {
   try {
+    debugLog(`[downloadSwpFile] 다운로드 시작`, { fileId });
+    
     // 1. 파일 정보 조회
     const fileInfo = await db
       .select({
@@ -328,6 +331,7 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
       .limit(1);
 
     if (!fileInfo || fileInfo.length === 0) {
+      debugError(`[downloadSwpFile] 파일 정보 없음`, { fileId });
       return {
         success: false,
         error: "파일 정보를 찾을 수 없습니다.",
@@ -335,8 +339,10 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
     }
 
     const { FILE_NM, FLD_PATH } = fileInfo[0];
+    debugLog(`[downloadSwpFile] 파일 정보 조회 완료`, { FILE_NM, FLD_PATH });
 
     if (!FLD_PATH || !FILE_NM) {
+      debugError(`[downloadSwpFile] 파일 경로 또는 이름 없음`, { FILE_NM, FLD_PATH });
       return {
         success: false,
         error: "파일 경로 또는 파일명이 없습니다.",
@@ -344,9 +350,11 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
     }
 
     // 2. NFS 마운트 경로 확인
-    const nfsBasePath = process.env.DOCUMENTUM_NFS;
+    const nfsBasePath = process.env.SWP_MOUNT_DIR;
     if (!nfsBasePath) {
-      console.error("[downloadSwpFile] DOCUMENTUM_NFS 환경변수가 설정되지 않았습니다.");
+      console.error(
+        '[downloadSwpFile] SWP_MOUNT_DIR 환경변수가 설정되지 않았습니다.'
+      );
       return {
         success: false,
         error: "서버 설정 오류: NFS 경로가 설정되지 않았습니다.",
@@ -355,12 +363,15 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
 
     // 3. 전체 파일 경로 생성
     // FLD_PATH가 절대 경로일 수도 있고 상대 경로일 수도 있으므로 처리
-    const fullPath = path.join(nfsBasePath, FLD_PATH, FILE_NM);
+    // Windows 스타일 백슬래시를 리눅스 슬래시로 변환
+    const normalizedFldPath = FLD_PATH.replace(/\\/g, '/');
+    const fullPath = path.join(nfsBasePath, normalizedFldPath, FILE_NM);
 
     console.log("[downloadSwpFile] 파일 다운로드 시도:", {
       fileId,
       FILE_NM,
       FLD_PATH,
+      normalizedFldPath,
       fullPath,
     });
 
@@ -376,8 +387,26 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
     }
 
     // 5. 파일 읽기
+    debugLog(`[downloadSwpFile] 파일 읽기 시작`, { fullPath });
     const fileBuffer = await fs.readFile(fullPath);
+    
+    debugLog(`[downloadSwpFile] 파일 Buffer 읽기 완료`, {
+      bufferLength: fileBuffer.length,
+      isBuffer: Buffer.isBuffer(fileBuffer),
+      bufferType: typeof fileBuffer,
+      constructor: fileBuffer.constructor.name,
+      first20Bytes: fileBuffer.slice(0, 20).toString('hex')
+    });
+    
     const fileData = new Uint8Array(fileBuffer);
+    
+    debugLog(`[downloadSwpFile] Uint8Array 변환 완료`, {
+      uint8ArrayLength: fileData.length,
+      uint8ArrayType: typeof fileData,
+      constructor: fileData.constructor.name,
+      first20Bytes: Array.from(fileData.slice(0, 20)),
+      jsonStringified: JSON.stringify(fileData).substring(0, 100) + '...'
+    });
 
     // 6. MIME 타입 결정
     const mimeType = getMimeType(FILE_NM);
@@ -387,6 +416,14 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
       size: fileData.length,
       mimeType,
     });
+    
+    debugSuccess(`[downloadSwpFile] 다운로드 성공`, {
+      fileName: FILE_NM,
+      dataLength: fileData.length,
+      mimeType,
+      returnDataType: typeof fileData,
+      isUint8Array: fileData instanceof Uint8Array
+    });
 
     return {
       success: true,
@@ -396,6 +433,10 @@ export async function downloadSwpFile(fileId: number): Promise<DownloadFileResul
     };
   } catch (error) {
     console.error("[downloadSwpFile] 오류:", error);
+    debugError(`[downloadSwpFile] 다운로드 실패`, {
+      error: error instanceof Error ? error.message : String(error),
+      stack: error instanceof Error ? error.stack : undefined
+    });
     return {
       success: false,
       error: error instanceof Error ? error.message : "파일 다운로드 실패",
@@ -433,329 +474,3 @@ function getMimeType(fileName: string): string {
 
   return mimeTypes[ext] || "application/octet-stream";
 }
-
-// ============================================================================
-// 서버 액션: 파일 업로드 (네트워크 경로 기반)
-// ============================================================================
-
-export interface UploadFileInfo {
-  fileName: string;
-  fileBuffer: Buffer;
-}
-
-export interface UploadFilesResult {
-  success: boolean;
-  message: string;
-  successCount: number;
-  failedCount: number;
-  details: Array<{
-    fileName: string;
-    success: boolean;
-    error?: string;
-    networkPath?: string;
-  }>;
-}
-
-/**
- * 파일명 파싱: [OWN_DOC_NO]_[REV_NO]_[STAGE]_[YYYYMMDDhhmmss].[확장자]
- */
-function parseFileName(fileName: string) {
-  // 확장자 분리
-  const lastDotIndex = fileName.lastIndexOf(".");
-  const extension = lastDotIndex !== -1 ? fileName.substring(lastDotIndex + 1) : "";
-  const nameWithoutExt = lastDotIndex !== -1 ? fileName.substring(0, lastDotIndex) : fileName;
-
-  // _ 기준으로 분리 (정확히 3개의 _가 있어야 함)
-  const parts = nameWithoutExt.split("_");
-  
-  if (parts.length !== 4) {
-    throw new Error(
-      `잘못된 파일명 형식입니다: ${fileName}. ` +
-      `형식: [OWN_DOC_NO]_[REV_NO]_[STAGE]_[YYYYMMDDhhmmss].확장자`
-    );
-  }
-
-  const [ownDocNo, revNo, stage, timestamp] = parts;
-
-  // 타임스탬프 검증 (14자리 숫자)
-  if (!/^\d{14}$/.test(timestamp)) {
-    throw new Error(
-      `잘못된 타임스탬프 형식입니다: ${timestamp}. ` +
-      `YYYYMMDDhhmmss 형식이어야 합니다.`
-    );
-  }
-
-  return {
-    ownDocNo,
-    revNo,
-    stage,
-    timestamp,
-    extension,
-  };
-}
-
-/**
- * CPY_CD 조회: swpDocuments 테이블에서 PROJ_NO와 VNDR_CD로 조회
- */
-async function getCpyCdForVendor(projNo: string, vndrCd: string): Promise<string> {
-  const result = await db
-    .select({
-      CPY_CD: swpDocuments.CPY_CD,
-    })
-    .from(swpDocuments)
-    .where(
-      and(
-        eq(swpDocuments.PROJ_NO, projNo),
-        eq(swpDocuments.VNDR_CD, vndrCd)
-      )
-    )
-    .limit(1);
-
-  if (!result || result.length === 0 || !result[0].CPY_CD) {
-    throw new Error(
-      `프로젝트 ${projNo}에서 벤더 코드 ${vndrCd}에 해당하는 회사 코드(CPY_CD)를 찾을 수 없습니다.`
-    );
-  }
-
-  return result[0].CPY_CD;
-}
-
-/**
- * 네트워크 경로 생성
- */
-function generateNetworkPath(
-  projNo: string,
-  cpyCd: string,
-  timestamp: string,
-  fileName: string
-): string {
-  const swpMountDir = process.env.SWP_MOUNT_DIR || "/mnt/swp-smb-dir/";
-  return path.join(swpMountDir, projNo, cpyCd, timestamp, fileName);
-}
-
-/**
- * InBox 파일 정보 인터페이스
- */
-interface InBoxFileInfo {
-  CPY_CD: string;
-  FILE_NM: string;
-  OFDC_NO: string | null;
-  PROJ_NO: string;
-  OWN_DOC_NO: string;
-  REV_NO: string;
-  STAGE: string;
-  STAT: string;
-  FILE_SZ: string;
-  FLD_PATH: string;
-}
-
-/**
- * SaveInBoxList API 호출
- */
-async function callSaveInBoxList(fileInfos: InBoxFileInfo[]): Promise<void> {
-  const ddcUrl = process.env.DDC_BASE_URL || "http://60.100.99.217/DDC/Services/WebService.svc";
-  const url = `${ddcUrl}/SaveInBoxList`;
-
-  const request = {
-    externalInboxLists: fileInfos,
-  };
-
-  console.log("[callSaveInBoxList] 요청:", JSON.stringify(request, null, 2));
-
-  const response = await fetch(url, {
-    method: "POST",
-    headers: {
-      "Content-Type": "application/json",
-      Accept: "application/json",
-    },
-    body: JSON.stringify(request),
-  });
-
-  if (!response.ok) {
-    const errorText = await response.text();
-    throw new Error(`SaveInBoxList API 호출 실패: ${response.statusText} - ${errorText}`);
-  }
-
-  const data = await response.json();
-  console.log("[callSaveInBoxList] 응답:", JSON.stringify(data, null, 2));
-
-  // 응답 검증
-  if (data.SaveInBoxListResult && !data.SaveInBoxListResult.success) {
-    throw new Error(
-      `SaveInBoxList API 실패: ${data.SaveInBoxListResult.message || "알 수 없는 오류"}`
-    );
-  }
-}
-
-/**
- * GetExternalInboxList API 응답 인터페이스
- */
-interface ExternalInboxItem {
-  DOC_NO?: string;
-  REV_NO?: string;
-  STAGE?: string;
-  FILE_NM?: string;
-  FILE_SZ?: string;
-  [key: string]: unknown;
-}
-
-/**
- * GetExternalInboxList API 호출
- */
-async function callGetExternalInboxList(projNo: string, cpyCd: string): Promise<ExternalInboxItem[]> {
-  const ddcUrl = process.env.DDC_BASE_URL || "http://60.100.99.217/DDC/Services/WebService.svc";
-  const params = new URLSearchParams({
-    PROJ_NO: projNo,
-    CPY_CD: cpyCd,
-  });
-  const url = `${ddcUrl}/GetExternalInboxList?${params.toString()}`;
-
-  console.log("[callGetExternalInboxList] 요청:", url);
-
-  const response = await fetch(url, {
-    method: "GET",
-    headers: {
-      Accept: "application/json",
-    },
-  });
-
-  if (!response.ok) {
-    const errorText = await response.text();
-    throw new Error(`GetExternalInboxList API 호출 실패: ${response.statusText} - ${errorText}`);
-  }
-
-  const data = await response.json();
-  console.log("[callGetExternalInboxList] 응답:", JSON.stringify(data, null, 2));
-
-  return data.GetExternalInboxListResult || [];
-}
-
-/**
- * 파일 업로드 서버 액션
- */
-export async function uploadSwpFilesAction(
-  projNo: string,
-  vndrCd: string,
-  files: UploadFileInfo[]
-): Promise<UploadFilesResult> {
-  const result: UploadFilesResult = {
-    success: true,
-    message: "",
-    successCount: 0,
-    failedCount: 0,
-    details: [],
-  };
-
-  try {
-    // 1. CPY_CD 조회
-    console.log(`[uploadSwpFilesAction] CPY_CD 조회: projNo=${projNo}, vndrCd=${vndrCd}`);
-    const cpyCd = await getCpyCdForVendor(projNo, vndrCd);
-    console.log(`[uploadSwpFilesAction] CPY_CD: ${cpyCd}`);
-
-    // 2. 각 파일 처리
-    const inBoxFileInfos: InBoxFileInfo[] = [];
-
-    for (const file of files) {
-      try {
-        // 2-1. 파일명 파싱
-        const parsed = parseFileName(file.fileName);
-        console.log(`[uploadSwpFilesAction] 파일명 파싱:`, parsed);
-
-        // 2-2. 네트워크 경로 생성
-        const networkPath = generateNetworkPath(
-          projNo,
-          cpyCd,
-          parsed.timestamp,
-          file.fileName
-        );
-
-        // 2-3. 파일 중복 체크
-        try {
-          await fs.access(networkPath, fs.constants.F_OK);
-          // 파일이 이미 존재하는 경우
-          result.failedCount++;
-          result.details.push({
-            fileName: file.fileName,
-            success: false,
-            error: "파일이 이미 존재합니다.",
-          });
-          console.warn(`[uploadSwpFilesAction] 파일 중복: ${networkPath}`);
-          continue;
-        } catch {
-          // 파일이 존재하지 않음 (정상)
-        }
-
-        // 2-4. 디렉토리 생성
-        const directory = path.dirname(networkPath);
-        await fs.mkdir(directory, { recursive: true });
-
-        // 2-5. 파일 저장
-        await fs.writeFile(networkPath, file.fileBuffer);
-        console.log(`[uploadSwpFilesAction] 파일 저장 완료: ${networkPath}`);
-
-        // 2-6. InBox 파일 정보 준비
-        const dateOnly = parsed.timestamp.substring(0, 8); // YYYYMMDD
-        const fldPath = `\\\\${projNo}\\\\${cpyCd}\\\\${dateOnly}`;
-
-        inBoxFileInfos.push({
-          CPY_CD: cpyCd,
-          FILE_NM: file.fileName,
-          OFDC_NO: null,
-          PROJ_NO: projNo,
-          OWN_DOC_NO: parsed.ownDocNo,
-          REV_NO: parsed.revNo,
-          STAGE: parsed.stage,
-          STAT: "SCW01",
-          FILE_SZ: String(file.fileBuffer.length),
-          FLD_PATH: fldPath,
-        });
-
-        result.successCount++;
-        result.details.push({
-          fileName: file.fileName,
-          success: true,
-          networkPath,
-        });
-      } catch (error) {
-        result.failedCount++;
-        result.details.push({
-          fileName: file.fileName,
-          success: false,
-          error: error instanceof Error ? error.message : "알 수 없는 오류",
-        });
-        console.error(`[uploadSwpFilesAction] 파일 처리 실패: ${file.fileName}`, error);
-      }
-    }
-
-    // 3. SaveInBoxList API 호출 (성공한 파일만)
-    if (inBoxFileInfos.length > 0) {
-      console.log(`[uploadSwpFilesAction] SaveInBoxList API 호출: ${inBoxFileInfos.length}개 파일`);
-      await callSaveInBoxList(inBoxFileInfos);
-    }
-
-    // 4. GetExternalInboxList API 호출
-    console.log(`[uploadSwpFilesAction] GetExternalInboxList API 호출`);
-    const inboxList = await callGetExternalInboxList(projNo, cpyCd);
-    console.log(`[uploadSwpFilesAction] InBox 목록: ${inboxList.length}개`);
-
-    // 5. 결과 메시지 생성
-    if (result.failedCount === 0) {
-      result.message = `${result.successCount}개 파일이 성공적으로 업로드되었습니다.`;
-    } else if (result.successCount === 0) {
-      result.success = false;
-      result.message = `모든 파일 업로드에 실패했습니다. (${result.failedCount}개)`;
-    } else {
-      result.message = 
-        `${result.successCount}개 파일 업로드 성공, ${result.failedCount}개 실패`;
-    }
-
-    console.log(`[uploadSwpFilesAction] 완료:`, result);
-    return result;
-  } catch (error) {
-    console.error("[uploadSwpFilesAction] 오류:", error);
-    result.success = false;
-    result.message = error instanceof Error ? error.message : "알 수 없는 오류가 발생했습니다.";
-    return result;
-  }
-}
-
diff --git a/lib/swp/table/swp-table-columns.tsx b/lib/swp/table/swp-table-columns.tsx
index 9954ab73..9aecea96 100644
--- a/lib/swp/table/swp-table-columns.tsx
+++ b/lib/swp/table/swp-table-columns.tsx
@@ -7,7 +7,6 @@ import { ChevronDown, ChevronRight, FileIcon, Download, Loader2 } from "lucide-r
 import { formatDistanceToNow } from "date-fns";
 import { ko } from "date-fns/locale";
 import type { SwpDocumentWithStats } from "../actions";
-import { downloadSwpFile } from "../actions";
 import { useState } from "react";
 import { toast } from "sonner";
 
@@ -29,6 +28,28 @@ export const swpDocumentColumns: ColumnDef<SwpDocumentWithStats>[] = [
     size: 50,
   },
   {
+    accessorKey: "LTST_ACTV_STAT",
+    header: "상태 (최신 액티비티)",
+    cell: ({ row }) => {
+      const status = row.original.LTST_ACTV_STAT;
+      if (!status) return "-";
+
+      // 상태에 따른 색상 설정 (필요에 따라 조정 가능)
+      const color =
+        status === "Complete" ? "bg-green-100 text-green-800" :
+        status === "In Progress" ? "bg-blue-100 text-blue-800" :
+        status === "Pending" ? "bg-yellow-100 text-yellow-800" :
+        "bg-gray-100 text-gray-800";
+
+      return (
+        <Badge variant="outline" className={color}>
+          {status}
+        </Badge>
+      );
+    },
+    size: 100,
+  },
+  {
     accessorKey: "DOC_NO",
     header: "문서번호",
     cell: ({ row }) => (
@@ -90,12 +111,12 @@ export const swpDocumentColumns: ColumnDef<SwpDocumentWithStats>[] = [
     cell: ({ row }) => {
       const stage = row.original.STAGE;
       if (!stage) return "-";
-      
-      const color = 
+
+      const color =
         stage === "IFC" ? "bg-green-100 text-green-800" :
         stage === "IFA" ? "bg-blue-100 text-blue-800" :
         "bg-gray-100 text-gray-800";
-      
+
       return (
         <Badge variant="outline" className={color}>
           {stage}
@@ -123,28 +144,6 @@ export const swpDocumentColumns: ColumnDef<SwpDocumentWithStats>[] = [
     size: 100,
   },
   {
-    accessorKey: "LTST_ACTV_STAT",
-    header: "상태 (최신 액티비티)",
-    cell: ({ row }) => {
-      const status = row.original.LTST_ACTV_STAT;
-      if (!status) return "-";
-
-      // 상태에 따른 색상 설정 (필요에 따라 조정 가능)
-      const color =
-        status === "Complete" ? "bg-green-100 text-green-800" :
-        status === "In Progress" ? "bg-blue-100 text-blue-800" :
-        status === "Pending" ? "bg-yellow-100 text-yellow-800" :
-        "bg-gray-100 text-gray-800";
-
-      return (
-        <Badge variant="outline" className={color}>
-          {status}
-        </Badge>
-      );
-    },
-    size: 100,
-  },
-  {
     accessorKey: "last_synced_at",
     header: "동기화",
     cell: ({ row }) => (
@@ -399,26 +398,27 @@ function DownloadButton({ fileId, fileName }: DownloadButtonProps) {
     try {
       setIsDownloading(true);
       
-      // 서버 액션 호출
-      const result = await downloadSwpFile(fileId);
+      // API Route 호출 (바이너리 직접 전송)
+      const response = await fetch(`/api/swp/download/${fileId}`);
 
-      if (!result.success || !result.data) {
-        toast.error(result.error || "파일 다운로드 실패");
+      if (!response.ok) {
+        const errorData = await response.json().catch(() => ({ error: "다운로드 실패" }));
+        toast.error(errorData.error || "파일 다운로드 실패");
         return;
       }
 
       // Blob 생성 및 다운로드
-      const blob = new Blob([result.data as unknown as BlobPart], { type: result.mimeType });
+      const blob = await response.blob();
       const url = window.URL.createObjectURL(blob);
       const link = document.createElement("a");
       link.href = url;
-      link.download = result.fileName || fileName;
+      link.download = fileName;
       document.body.appendChild(link);
       link.click();
       document.body.removeChild(link);
       window.URL.revokeObjectURL(url);
 
-      toast.success(`파일 다운로드 완료: ${result.fileName}`);
+      toast.success(`파일 다운로드 완료: ${fileName}`);
     } catch (error) {
       console.error("다운로드 오류:", error);
       toast.error("파일 다운로드 중 오류가 발생했습니다.");
diff --git a/lib/swp/table/swp-table-toolbar.tsx b/lib/swp/table/swp-table-toolbar.tsx
index e7a2ef30..fefff091 100644
--- a/lib/swp/table/swp-table-toolbar.tsx
+++ b/lib/swp/table/swp-table-toolbar.tsx
@@ -10,7 +10,7 @@ import {
 } from "@/components/ui/popover";
 import { Label } from "@/components/ui/label";
 import { RefreshCw, Search, X, Check, ChevronsUpDown, Upload } from "lucide-react";
-import { syncSwpProjectAction, uploadSwpFilesAction, type SwpTableFilters } from "../actions";
+import { syncSwpProjectAction, type SwpTableFilters } from "../actions";
 import { useToast } from "@/hooks/use-toast";
 import { useRouter } from "next/navigation";
 import { cn } from "@/lib/utils";
@@ -137,27 +137,33 @@ export function SwpTableToolbar({
           description: `${selectedFiles.length}개 파일을 업로드합니다...`,
         });
 
-        // 파일을 Buffer로 변환
-        const fileInfos = await Promise.all(
-          Array.from(selectedFiles).map(async (file) => {
-            const arrayBuffer = await file.arrayBuffer();
-            return {
-              fileName: file.name,
-              fileBuffer: Buffer.from(arrayBuffer),
-            };
-          })
-        );
+        // FormData 생성 (바이너리 직접 전송)
+        const formData = new FormData();
+        formData.append("projNo", projectNo);
+        formData.append("vndrCd", vndrCd);
+        
+        Array.from(selectedFiles).forEach((file) => {
+          formData.append("files", file);
+        });
+
+        // API Route 호출
+        const response = await fetch("/api/swp/upload", {
+          method: "POST",
+          body: formData,
+        });
+
+        if (!response.ok) {
+          throw new Error(`업로드 실패: ${response.statusText}`);
+        }
 
-        // 서버 액션 호출
-        const result = await uploadSwpFilesAction(projectNo, vndrCd, fileInfos);
+        const result = await response.json();
 
         // 결과 저장 및 다이얼로그 표시
-        setUploadResults(result.details);
+        setUploadResults(result.details || []);
         setShowResultDialog(true);
 
         // 성공한 파일이 있으면 페이지 새로고침
-        const successCount = result.details.filter((d) => d.success).length;
-        if (successCount > 0) {
+        if (result.successCount > 0) {
           router.refresh();
         }
       } catch (error) {