summaryrefslogtreecommitdiff
path: root/app/api
diff options
context:
space:
mode:
Diffstat (limited to 'app/api')
-rw-r--r--app/api/swp/download/[fileId]/route.ts172
-rw-r--r--app/api/swp/upload/route.ts364
2 files changed, 536 insertions, 0 deletions
diff --git a/app/api/swp/download/[fileId]/route.ts b/app/api/swp/download/[fileId]/route.ts
new file mode 100644
index 00000000..3af560aa
--- /dev/null
+++ b/app/api/swp/download/[fileId]/route.ts
@@ -0,0 +1,172 @@
+import { NextRequest, NextResponse } from "next/server";
+import * as fs from "fs/promises";
+import * as path from "path";
+import { eq } from "drizzle-orm";
+import db from "@/db/db";
+import { swpDocumentFiles } from "@/db/schema/SWP/swp-documents";
+import { debugLog, debugError, debugSuccess } from "@/lib/debug-utils";
+
+// API Route 설정
+export const runtime = "nodejs";
+export const maxDuration = 60; // 1분 타임아웃
+
+/**
+ * GET /api/swp/download/[fileId]
+ * 파일 다운로드 (바이너리 직접 전송)
+ */
+export async function GET(
+ request: NextRequest,
+ { params }: { params: Promise<{ fileId: string }> }
+) {
+ try {
+ const { fileId: fileIdString } = await params;
+ const fileId = parseInt(fileIdString, 10);
+
+ if (isNaN(fileId)) {
+ return NextResponse.json(
+ { success: false, error: "잘못된 파일 ID입니다." },
+ { status: 400 }
+ );
+ }
+
+ debugLog(`[download] 다운로드 시작`, { fileId });
+
+ // 1. 파일 정보 조회
+ const fileInfo = await db
+ .select({
+ FILE_NM: swpDocumentFiles.FILE_NM,
+ FLD_PATH: swpDocumentFiles.FLD_PATH,
+ })
+ .from(swpDocumentFiles)
+ .where(eq(swpDocumentFiles.id, fileId))
+ .limit(1);
+
+ if (!fileInfo || fileInfo.length === 0) {
+ debugError(`[download] 파일 정보 없음`, { fileId });
+ return NextResponse.json(
+ { success: false, error: "파일 정보를 찾을 수 없습니다." },
+ { status: 404 }
+ );
+ }
+
+ const { FILE_NM, FLD_PATH } = fileInfo[0];
+ debugLog(`[download] 파일 정보 조회 완료`, { FILE_NM, FLD_PATH });
+
+ if (!FLD_PATH || !FILE_NM) {
+ debugError(`[download] 파일 경로 또는 이름 없음`, { FILE_NM, FLD_PATH });
+ return NextResponse.json(
+ { success: false, error: "파일 경로 또는 파일명이 없습니다." },
+ { status: 404 }
+ );
+ }
+
+ // 2. NFS 마운트 경로 확인
+ const nfsBasePath = process.env.SWP_MOUNT_DIR;
+ if (!nfsBasePath) {
+ debugError(`[download] SWP_MOUNT_DIR 환경변수가 설정되지 않았습니다.`);
+ return NextResponse.json(
+ { success: false, error: "서버 설정 오류: NFS 경로가 설정되지 않았습니다." },
+ { status: 500 }
+ );
+ }
+
+ // 3. 전체 파일 경로 생성
+ const normalizedFldPath = FLD_PATH.replace(/\\/g, '/');
+ const fullPath = path.join(nfsBasePath, normalizedFldPath, FILE_NM);
+
+ debugLog(`[download] 파일 경로`, {
+ fileId,
+ FILE_NM,
+ FLD_PATH,
+ normalizedFldPath,
+ fullPath,
+ });
+
+ // 4. 파일 존재 여부 확인
+ try {
+ await fs.access(fullPath, fs.constants.R_OK);
+ } catch (accessError) {
+ debugError(`[download] 파일 접근 불가`, { fullPath, error: accessError });
+ return NextResponse.json(
+ { success: false, error: `파일을 찾을 수 없습니다: ${FILE_NM}` },
+ { status: 404 }
+ );
+ }
+
+ // 5. 파일 읽기
+ debugLog(`[download] 파일 읽기 시작`, { fullPath });
+ const fileBuffer = await fs.readFile(fullPath);
+
+ debugLog(`[download] 파일 Buffer 읽기 완료`, {
+ bufferLength: fileBuffer.length,
+ isBuffer: Buffer.isBuffer(fileBuffer),
+ bufferType: typeof fileBuffer,
+ constructor: fileBuffer.constructor.name,
+ first20Bytes: fileBuffer.slice(0, 20).toString('hex')
+ });
+
+ // 6. MIME 타입 결정
+ const mimeType = getMimeType(FILE_NM);
+
+ debugSuccess(`[download] 다운로드 성공`, {
+ fileName: FILE_NM,
+ size: fileBuffer.length,
+ mimeType,
+ });
+
+ // 7. 바이너리 응답 반환
+ return new NextResponse(fileBuffer, {
+ status: 200,
+ headers: {
+ "Content-Type": mimeType,
+ "Content-Disposition": `attachment; filename="${encodeURIComponent(FILE_NM)}"`,
+ "Content-Length": String(fileBuffer.length),
+ },
+ });
+ } catch (error) {
+ console.error("[download] 오류:", error);
+ debugError(`[download] 다운로드 실패`, {
+ error: error instanceof Error ? error.message : String(error),
+ stack: error instanceof Error ? error.stack : undefined
+ });
+
+ return NextResponse.json(
+ {
+ success: false,
+ error: error instanceof Error ? error.message : "파일 다운로드 실패",
+ },
+ { status: 500 }
+ );
+ }
+}
+
+/**
+ * MIME 타입 결정
+ */
+function getMimeType(fileName: string): string {
+ const ext = path.extname(fileName).toLowerCase();
+
+ const mimeTypes: Record<string, string> = {
+ ".pdf": "application/pdf",
+ ".doc": "application/msword",
+ ".docx": "application/vnd.openxmlformats-officedocument.wordprocessingml.document",
+ ".xls": "application/vnd.ms-excel",
+ ".xlsx": "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
+ ".ppt": "application/vnd.ms-powerpoint",
+ ".pptx": "application/vnd.openxmlformats-officedocument.presentationml.presentation",
+ ".txt": "text/plain",
+ ".csv": "text/csv",
+ ".jpg": "image/jpeg",
+ ".jpeg": "image/jpeg",
+ ".png": "image/png",
+ ".gif": "image/gif",
+ ".zip": "application/zip",
+ ".rar": "application/x-rar-compressed",
+ ".7z": "application/x-7z-compressed",
+ ".dwg": "application/acad",
+ ".dxf": "application/dxf",
+ };
+
+ return mimeTypes[ext] || "application/octet-stream";
+}
+
diff --git a/app/api/swp/upload/route.ts b/app/api/swp/upload/route.ts
new file mode 100644
index 00000000..d17fcff7
--- /dev/null
+++ b/app/api/swp/upload/route.ts
@@ -0,0 +1,364 @@
+import { NextRequest, NextResponse } from "next/server";
+import * as fs from "fs/promises";
+import * as path from "path";
+import { eq, and } from "drizzle-orm";
+import db from "@/db/db";
+import { swpDocuments } from "@/db/schema/SWP/swp-documents";
+import { fetchGetVDRDocumentList, fetchGetExternalInboxList } from "@/lib/swp/api-client";
+import { syncSwpProject } from "@/lib/swp/sync-service";
+import { debugLog, debugError, debugSuccess } from "@/lib/debug-utils";
+
+// API Route 설정
+export const runtime = "nodejs";
+export const maxDuration = 300; // 5분 타임아웃 (대용량 파일 업로드 대응)
+
+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;
+}
+
+/**
+ * 파일명 파싱: [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;
+
+ 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;
+
+ if (!/^\d{14}$/.test(timestamp)) {
+ throw new Error(
+ `잘못된 타임스탬프 형식입니다: ${timestamp}. ` +
+ `YYYYMMDDhhmmss 형식이어야 합니다.`
+ );
+ }
+
+ return { ownDocNo, revNo, stage, timestamp, extension };
+}
+
+/**
+ * CPY_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;
+}
+
+/**
+ * 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));
+
+ // SaveInBoxListResult는 성공한 FLD_PATH들을 쉼표로 구분한 문자열
+ // 예: "\\\\ProjNo\\\\CpyCd\\\\YYYYMMDDhhmmss, \\\\ProjNo\\\\CpyCd\\\\YYYYMMDDhhmmss"
+ if (!data.SaveInBoxListResult) {
+ throw new Error("SaveInBoxList API 실패: 응답에 SaveInBoxListResult가 없습니다.");
+ }
+
+ const result = data.SaveInBoxListResult;
+
+ // 문자열 응답인 경우 (정상)
+ if (typeof result === "string") {
+ if (result.trim().length === 0) {
+ throw new Error("SaveInBoxList API 실패: 빈 응답이 반환되었습니다.");
+ }
+ // 성공한 FLD_PATH 개수 로깅
+ const successPaths = result.split(",").map(p => p.trim()).filter(p => p.length > 0);
+ console.log(`[callSaveInBoxList] 성공: ${successPaths.length}개 파일 등록 완료`);
+ return;
+ }
+
+ // 객체 응답인 경우 (레거시 또는 에러)
+ if (typeof result === "object" && result !== null) {
+ const objResult = result as { success?: boolean; message?: string };
+ if (objResult.success === false) {
+ throw new Error(
+ `SaveInBoxList API 실패: ${objResult.message || "알 수 없는 오류"}`
+ );
+ }
+ }
+}
+
+/**
+ * POST /api/swp/upload
+ * FormData로 파일 업로드
+ */
+export async function POST(request: NextRequest) {
+ try {
+ const formData = await request.formData();
+
+ const projNo = formData.get("projNo") as string;
+ const vndrCd = formData.get("vndrCd") as string;
+
+ if (!projNo || !vndrCd) {
+ return NextResponse.json(
+ { success: false, message: "projNo와 vndrCd는 필수입니다." },
+ { status: 400 }
+ );
+ }
+
+ // CPY_CD 조회
+ console.log(`[upload] CPY_CD 조회: projNo=${projNo}, vndrCd=${vndrCd}`);
+ const cpyCd = await getCpyCdForVendor(projNo, vndrCd);
+ console.log(`[upload] CPY_CD: ${cpyCd}`);
+
+ const files = formData.getAll("files") as File[];
+
+ if (!files || files.length === 0) {
+ return NextResponse.json(
+ { success: false, message: "업로드할 파일이 없습니다." },
+ { status: 400 }
+ );
+ }
+
+ const result = {
+ successCount: 0,
+ failedCount: 0,
+ details: [] as Array<{ fileName: string; success: boolean; error?: string; networkPath?: string }>,
+ };
+
+ const inBoxFileInfos: InBoxFileInfo[] = [];
+ const swpMountDir = process.env.SWP_MOUNT_DIR || "/mnt/swp-smb-dir/";
+
+ for (const file of files) {
+ try {
+ // 파일명 파싱
+ const parsed = parseFileName(file.name);
+ console.log(`[upload] 파일명 파싱:`, parsed);
+
+ // 네트워크 경로 생성
+ const networkPath = path.join(swpMountDir, projNo, cpyCd, parsed.timestamp, file.name);
+
+ // 파일 중복 체크
+ try {
+ await fs.access(networkPath, fs.constants.F_OK);
+ result.failedCount++;
+ result.details.push({
+ fileName: file.name,
+ success: false,
+ error: "파일이 이미 존재합니다.",
+ });
+ console.warn(`[upload] 파일 중복: ${networkPath}`);
+ continue;
+ } catch {
+ // 파일이 존재하지 않음 (정상)
+ }
+
+ // 디렉토리 생성
+ const directory = path.dirname(networkPath);
+ await fs.mkdir(directory, { recursive: true });
+
+ // 파일 저장 (스트리밍 방식)
+ const arrayBuffer = await file.arrayBuffer();
+ debugLog(`[upload] ArrayBuffer 변환 완료: ${file.name}`, {
+ arrayBufferSize: arrayBuffer.byteLength,
+ fileType: file.type,
+ originalSize: file.size
+ });
+
+ const buffer = Buffer.from(arrayBuffer);
+ debugLog(`[upload] Buffer 생성 완료: ${file.name}`, {
+ bufferLength: buffer.length,
+ bufferType: typeof buffer,
+ isBuffer: Buffer.isBuffer(buffer),
+ first20Bytes: buffer.slice(0, 20).toString('hex')
+ });
+
+ console.log(`[upload] 파일 저장: ${file.name} (${buffer.length} bytes)`);
+
+ // 저장 전 buffer 상태 확인
+ debugLog(`[upload] 저장 직전 buffer 상태`, {
+ constructor: buffer.constructor.name,
+ isBuffer: Buffer.isBuffer(buffer),
+ jsonStringified: JSON.stringify(buffer).substring(0, 100) + '...'
+ });
+
+ await fs.writeFile(networkPath, buffer);
+ debugSuccess(`[upload] 파일 저장 완료: ${networkPath}`);
+
+ // 저장된 파일 검증
+ const savedFileStats = await fs.stat(networkPath);
+ debugLog(`[upload] 저장된 파일 정보`, {
+ size: savedFileStats.size,
+ expectedSize: buffer.length,
+ sizeMatch: savedFileStats.size === buffer.length
+ });
+
+ // 저장된 파일 첫 부분 읽어서 검증
+ const verifyBuffer = await fs.readFile(networkPath);
+ debugLog(`[upload] 저장된 파일 검증`, {
+ readSize: verifyBuffer.length,
+ first20Bytes: verifyBuffer.slice(0, 20).toString('hex'),
+ isBuffer: Buffer.isBuffer(verifyBuffer),
+ matchesOriginal: buffer.slice(0, 20).equals(verifyBuffer.slice(0, 20))
+ });
+
+ // InBox 파일 정보 준비
+ const fldPath = `\\\\${projNo}\\\\${cpyCd}\\\\${parsed.timestamp}`;
+
+ inBoxFileInfos.push({
+ CPY_CD: cpyCd,
+ FILE_NM: file.name,
+ OFDC_NO: null,
+ PROJ_NO: projNo,
+ OWN_DOC_NO: parsed.ownDocNo,
+ REV_NO: parsed.revNo,
+ STAGE: parsed.stage,
+ STAT: "SCW01",
+ FILE_SZ: String(buffer.length),
+ FLD_PATH: fldPath,
+ });
+
+ result.successCount++;
+ result.details.push({
+ fileName: file.name,
+ success: true,
+ networkPath,
+ });
+ } catch (error) {
+ result.failedCount++;
+ result.details.push({
+ fileName: file.name,
+ success: false,
+ error: error instanceof Error ? error.message : "알 수 없는 오류",
+ });
+ console.error(`[upload] 파일 처리 실패: ${file.name}`, error);
+ debugError(`[upload] 파일 처리 실패: ${file.name}`, {
+ error: error instanceof Error ? error.message : String(error),
+ stack: error instanceof Error ? error.stack : undefined
+ });
+ }
+ }
+
+ // SaveInBoxList API 호출
+ if (inBoxFileInfos.length > 0) {
+ console.log(`[upload] SaveInBoxList API 호출: ${inBoxFileInfos.length}개 파일`);
+ await callSaveInBoxList(inBoxFileInfos);
+ }
+
+ // 업로드 성공 후 동기화 처리 (현재 벤더의 변경사항만)
+ if (result.successCount > 0) {
+ try {
+ console.log(`[upload] 동기화 시작: projNo=${projNo}, vndrCd=${vndrCd}`);
+
+ // GetVDRDocumentList 및 GetExternalInboxList API 호출 (벤더 필터 적용)
+ const [documents, files] = await Promise.all([
+ fetchGetVDRDocumentList({
+ proj_no: projNo,
+ doc_gb: "V",
+ vndrCd: vndrCd, // 현재 벤더만 필터링
+ }),
+ fetchGetExternalInboxList({
+ projNo: projNo,
+ vndrCd: vndrCd, // 현재 벤더만 필터링
+ }),
+ ]);
+
+ console.log(`[upload] API 조회 완료: 문서 ${documents.length}개, 파일 ${files.length}개`);
+
+ // 동기화 실행
+ const syncResult = await syncSwpProject(projNo, documents, files);
+
+ if (syncResult.success) {
+ console.log(`[upload] 동기화 완료:`, syncResult.stats);
+ } else {
+ console.warn(`[upload] 동기화 경고:`, syncResult.errors);
+ }
+ } catch (syncError) {
+ // 동기화 실패는 경고로만 처리 (업로드 자체는 성공)
+ console.error("[upload] 동기화 실패 (업로드는 성공):", syncError);
+ }
+ }
+
+ // 결과 메시지 생성
+ let message: string;
+ let success: boolean;
+
+ if (result.failedCount === 0) {
+ success = true;
+ message = `${result.successCount}개 파일이 성공적으로 업로드 및 동기화되었습니다.`;
+ } else if (result.successCount === 0) {
+ success = false;
+ message = `모든 파일 업로드에 실패했습니다. (${result.failedCount}개)`;
+ } else {
+ success = true;
+ message = `${result.successCount}개 파일 업로드 성공, ${result.failedCount}개 실패`;
+ }
+
+ console.log(`[upload] 완료:`, { success, message, result });
+
+ return NextResponse.json({
+ success,
+ message,
+ successCount: result.successCount,
+ failedCount: result.failedCount,
+ details: result.details,
+ });
+ } catch (error) {
+ console.error("[upload] 오류:", error);
+ debugError(`[upload] 전체 프로세스 실패`, {
+ error: error instanceof Error ? error.message : String(error),
+ stack: error instanceof Error ? error.stack : undefined
+ });
+ return NextResponse.json(
+ {
+ success: false,
+ message: error instanceof Error ? error.message : "알 수 없는 오류가 발생했습니다.",
+ },
+ { status: 500 }
+ );
+ }
+}
+
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-07 08:42:32 +0000