summaryrefslogtreecommitdiff
path: root/app/api
diff options
context:
space:
mode:
Diffstat (limited to 'app/api')
-rw-r--r--app/api/data-room/[projectId]/[fileId]/route.ts204
-rw-r--r--app/api/email-template/preview/route.ts117
-rw-r--r--app/api/projects/route.ts1
-rw-r--r--app/api/upload/project-doc-template/chunk/route.ts178
4 files changed, 469 insertions, 31 deletions
diff --git a/app/api/data-room/[projectId]/[fileId]/route.ts b/app/api/data-room/[projectId]/[fileId]/route.ts
index 176aaf63..9ee01eb2 100644
--- a/app/api/data-room/[projectId]/[fileId]/route.ts
+++ b/app/api/data-room/[projectId]/[fileId]/route.ts
@@ -1,15 +1,20 @@
-// app/api/files/[projectId]/[fileId]/route.ts
+// app/api/data-room/[projectId]/[fileId]/route.ts
import { NextRequest, NextResponse } from 'next/server';
import { getServerSession } from 'next-auth/next';
import { authOptions } from '@/app/api/auth/[...nextauth]/route'
import { FileService, type FileAccessContext } from '@/lib/services/fileService';
+import { fileActivityLogs, fileItems } from '@/db/schema';
+import { and, eq, sql } from 'drizzle-orm';
+import db from "@/db/db"
// 파일 정보 조회
export async function GET(
request: NextRequest,
- { params }: { params: { projectId: string; fileId: string } }
+ { params }: { params: Promise<{ projectId: string; fileId: string }> }
) {
try {
+ const { projectId, fileId } = await params;
+
const session = await getServerSession(authOptions);
if (!session?.user) {
return NextResponse.json({ error: '인증이 필요합니다' }, { status: 401 });
@@ -25,7 +30,7 @@ export async function GET(
const fileService = new FileService();
const hasAccess = await fileService.checkFileAccess(
- params.fileId,
+ fileId,
context,
'view'
);
@@ -38,7 +43,7 @@ export async function GET(
}
// 파일 정보 반환
- const file = await fileService.downloadFile(params.fileId, context);
+ const file = await fileService.downloadFile(fileId, context);
if (!file) {
return NextResponse.json(
@@ -57,51 +62,157 @@ export async function GET(
}
}
-// 파일 수정
+// 파일 수정 (이름 변경, 카테고리 변경, 파일 이동 통합)
export async function PATCH(
request: NextRequest,
- { params }: { params: { projectId: string; fileId: string } }
+ { params }: { params: Promise<{ projectId: string; fileId: string }> }
) {
try {
+ const { projectId, fileId } = await params;
+
+ console.log('PATCH 요청 받음:', { projectId, fileId });
+
const session = await getServerSession(authOptions);
if (!session?.user) {
return NextResponse.json({ error: '인증이 필요합니다' }, { status: 401 });
}
- const context: FileAccessContext = {
- userId: session.user.id,
- userDomain: session.user.domain || 'partners',
- userEmail: session.user.email,
- ipAddress: request.ip || request.headers.get('x-forwarded-for') || undefined,
- userAgent: request.headers.get('user-agent') || undefined,
+ const body = await request.json();
+ const { name, category, parentId, applyToChildren } = body;
+
+ console.log('요청 본문:', { name, category, parentId, applyToChildren });
+
+ // 권한 확인
+ const fileItem = await db
+ .select()
+ .from(fileItems)
+ .where(
+ and(
+ eq(fileItems.id, fileId),
+ eq(fileItems.projectId, projectId)
+ )
+ )
+ .limit(1);
+
+ if (!fileItem[0]) {
+ return NextResponse.json({ error: 'File not found' }, { status: 404 });
+ }
+
+ // 내부 사용자만 수정 가능
+ if (session.user.domain === 'partners') {
+ return NextResponse.json({ error: 'Permission denied' }, { status: 403 });
+ }
+
+ const updateData: any = {
+ updatedBy: session.user.id,
+ updatedAt: new Date(),
};
- const fileService = new FileService();
- const hasAccess = await fileService.checkFileAccess(
- params.fileId,
- context,
- 'edit'
- );
+ // 이름 변경 처리
+ if (name !== undefined) {
+ // 파일인 경우 확장자 유지
+ if (fileItem[0].type === 'file') {
+ const originalExt = fileItem[0].name.lastIndexOf('.');
+ const newNameWithoutExt = name.lastIndexOf('.') > -1
+ ? name.substring(0, name.lastIndexOf('.'))
+ : name;
+ const ext = originalExt > -1 ? fileItem[0].name.substring(originalExt) : '';
+ updateData.name = newNameWithoutExt + ext;
+ } else {
+ updateData.name = name;
+ }
- if (!hasAccess) {
- return NextResponse.json(
- { error: '파일 수정 권한이 없습니다' },
- { status: 403 }
- );
+ // 경로 업데이트 (하위 항목들도 업데이트 필요)
+ if (fileItem[0].type === 'folder') {
+ const oldPath = fileItem[0].path + fileItem[0].name + '/';
+ const newPath = fileItem[0].path + updateData.name + '/';
+
+ // 하위 항목들의 경로 업데이트
+ await db
+ .update(fileItems)
+ .set({
+ path: sql`REPLACE(path, ${oldPath}, ${newPath})`
+ })
+ .where(
+ and(
+ eq(fileItems.projectId, projectId),
+ sql`path LIKE ${oldPath + '%'}`
+ )
+ );
+ }
}
- const body = await request.json();
+ // 카테고리 변경 처리
+ if (category !== undefined) {
+ updateData.category = category;
+
+ // 폴더인 경우 하위 항목들도 같은 카테고리로 변경할지 옵션 제공
+ if (fileItem[0].type === 'folder' && applyToChildren) {
+ await updateChildrenCategory(fileId, category, projectId);
+ }
+ }
+
+ // 부모 폴더 변경 (파일 이동) 처리
+ if (parentId !== undefined) {
+ updateData.parentId = parentId;
+
+ // 새 부모 폴더의 경로 가져오기
+ if (parentId) {
+ const parentFolder = await db
+ .select()
+ .from(fileItems)
+ .where(eq(fileItems.id, parentId))
+ .limit(1);
+
+ if (parentFolder[0]) {
+ updateData.path = parentFolder[0].path + parentFolder[0].name + '/';
+ }
+ } else {
+ updateData.path = '/';
+ }
+ }
+
+ console.log('업데이트 데이터:', updateData);
+
+ // 업데이트 실행
+ const [updatedItem] = await db
+ .update(fileItems)
+ .set(updateData)
+ .where(eq(fileItems.id, fileId))
+ .returning();
+
+ // 활동 로그 기록
+ const action = name ? 'rename' : category ? 'category_change' : 'move';
+ const actionDetails: any = {};
- // 파일 이동 처리
- if (body.parentId !== undefined) {
- await fileService.moveFile(params.fileId, body.parentId, context);
+ if (name) {
+ actionDetails.from = fileItem[0].name;
+ actionDetails.to = updateData.name;
+ } else if (category) {
+ actionDetails.from = fileItem[0].category;
+ actionDetails.to = category;
+ } else if (parentId !== undefined) {
+ actionDetails.from = fileItem[0].parentId;
+ actionDetails.to = parentId;
}
- return NextResponse.json({ success: true });
+ await db.insert(fileActivityLogs).values({
+ fileItemId: fileId,
+ projectId,
+ action,
+ actionDetails,
+ userId: session.user.id,
+ userEmail: session.user.email,
+ userDomain: session.user.domain,
+ });
+
+ console.log('업데이트 완료:', updatedItem);
+
+ return NextResponse.json(updatedItem);
} catch (error) {
console.error('파일 수정 오류:', error);
return NextResponse.json(
- { error: '파일 수정에 실패했습니다' },
+ { error: '파일 수정에 실패했습니다', details: error.message },
{ status: 500 }
);
}
@@ -110,9 +221,11 @@ export async function PATCH(
// 파일 삭제
export async function DELETE(
request: NextRequest,
- { params }: { params: { projectId: string; fileId: string } }
+ { params }: { params: Promise<{ projectId: string; fileId: string }> }
) {
try {
+ const { projectId, fileId } = await params;
+
const session = await getServerSession(authOptions);
if (!session?.user) {
return NextResponse.json({ error: '인증이 필요합니다' }, { status: 401 });
@@ -127,7 +240,7 @@ export async function DELETE(
};
const fileService = new FileService();
- await fileService.deleteFile(params.fileId, context);
+ await fileService.deleteFile(fileId, context);
return NextResponse.json({ success: true });
} catch (error) {
@@ -144,4 +257,33 @@ export async function DELETE(
{ status: 500 }
);
}
+}
+
+// 하위 항목 카테고리 업데이트 함수
+async function updateChildrenCategory(
+ parentId: string,
+ category: string,
+ projectId: string
+) {
+ const children = await db
+ .select()
+ .from(fileItems)
+ .where(
+ and(
+ eq(fileItems.parentId, parentId),
+ eq(fileItems.projectId, projectId)
+ )
+ );
+
+ for (const child of children) {
+ await db
+ .update(fileItems)
+ .set({ category })
+ .where(eq(fileItems.id, child.id));
+
+ // 재귀적으로 하위 폴더 처리
+ if (child.type === 'folder') {
+ await updateChildrenCategory(child.id, category, projectId);
+ }
+ }
} \ No newline at end of file
diff --git a/app/api/email-template/preview/route.ts b/app/api/email-template/preview/route.ts
new file mode 100644
index 00000000..6e066d27
--- /dev/null
+++ b/app/api/email-template/preview/route.ts
@@ -0,0 +1,117 @@
+import { NextResponse } from 'next/server';
+import db from "@/db/db";
+import { templateDetailView } from '@/db/schema';
+import { eq } from 'drizzle-orm';
+import handlebars from 'handlebars';
+
+// Handlebars helper 등록
+handlebars.registerHelper('formatDate', function(date: any, format: string) {
+ if (!date) return '';
+
+ const d = new Date(date);
+ if (isNaN(d.getTime())) return '';
+
+ const year = d.getFullYear();
+ const month = String(d.getMonth() + 1).padStart(2, '0');
+ const day = String(d.getDate()).padStart(2, '0');
+ const hours = String(d.getHours()).padStart(2, '0');
+ const minutes = String(d.getMinutes()).padStart(2, '0');
+ const seconds = String(d.getSeconds()).padStart(2, '0');
+
+ switch (format) {
+ case 'YYYY-MM-DD':
+ return `${year}-${month}-${day}`;
+ case 'YYYY-MM-DD HH:mm:ss':
+ return `${year}-${month}-${day} ${hours}:${minutes}:${seconds}`;
+ case 'YYYY-MM-DD HH:mm':
+ return `${year}-${month}-${day} ${hours}:${minutes}`;
+ default:
+ return d.toLocaleDateString('ko-KR');
+ }
+});
+
+export async function POST(request: Request) {
+ try {
+ const { templateSlug, sampleData } = await request.json();
+
+ if (!templateSlug) {
+ return NextResponse.json(
+ {
+ success: false,
+ error: '템플릿 슬러그가 필요합니다.'
+ },
+ { status: 400 }
+ );
+ }
+
+ // 데이터베이스에서 템플릿 조회
+ const templates = await db
+ .select()
+ .from(templateDetailView)
+ .where(eq(templateDetailView.slug, templateSlug))
+ .limit(1);
+
+ if (templates.length === 0) {
+ return NextResponse.json(
+ {
+ success: false,
+ error: '템플릿을 찾을 수 없습니다.'
+ },
+ { status: 404 }
+ );
+ }
+
+ const template = templates[0];
+
+ if (!template.isActive) {
+ return NextResponse.json(
+ {
+ success: false,
+ error: '비활성화된 템플릿입니다.'
+ },
+ { status: 400 }
+ );
+ }
+
+ // HTML 템플릿에서 t helper 제거 ({{t 'key'}} -> {{key}})
+ let subjectTemplateStr = template.subject || '';
+ let contentTemplateStr = template.content || '';
+
+ // {{t 'key'}} 패턴을 {{key}}로 치환
+ subjectTemplateStr = subjectTemplateStr.replace(/\{\{t\s+['"]([^'"]+)['"]\}\}/g, '{{$1}}');
+ contentTemplateStr = contentTemplateStr.replace(/\{\{t\s+['"]([^'"]+)['"]\}\}/g, '{{$1}}');
+
+ // Handlebars 템플릿 컴파일 및 렌더링
+ try {
+ const subjectTemplate = handlebars.compile(subjectTemplateStr);
+ const contentTemplate = handlebars.compile(contentTemplateStr);
+
+ const renderedSubject = subjectTemplate(sampleData);
+ const renderedContent = contentTemplate(sampleData);
+
+ return NextResponse.json({
+ success: true,
+ subject: renderedSubject,
+ html: renderedContent
+ });
+ } catch (compileError) {
+ console.error('템플릿 컴파일 오류:', compileError);
+ return NextResponse.json(
+ {
+ success: false,
+ error: '템플릿 처리 중 오류가 발생했습니다.'
+ },
+ { status: 500 }
+ );
+ }
+ } catch (error) {
+ console.error('미리보기 생성 실패:', error);
+ return NextResponse.json(
+ {
+ success: false,
+ error: '미리보기를 생성하는데 실패했습니다.'
+ },
+ { status: 500 }
+ );
+ }
+}
diff --git a/app/api/projects/route.ts b/app/api/projects/route.ts
index c64676c6..69aac8c3 100644
--- a/app/api/projects/route.ts
+++ b/app/api/projects/route.ts
@@ -18,6 +18,7 @@ export async function POST(request: NextRequest) {
const project = await projectService.createProject(
{
name: body.name,
+ code: body.code,
description: body.description,
isPublic: body.isPublic || false,
},
diff --git a/app/api/upload/project-doc-template/chunk/route.ts b/app/api/upload/project-doc-template/chunk/route.ts
new file mode 100644
index 00000000..2cba654a
--- /dev/null
+++ b/app/api/upload/project-doc-template/chunk/route.ts
@@ -0,0 +1,178 @@
+// app/api/upload/project-doc-template/chunk/route.ts
+import { NextRequest, NextResponse } from 'next/server';
+import { mkdir, writeFile, readFile, rm } from 'fs/promises';
+import path from 'path';
+import { saveBuffer, saveDRMFile } from '@/lib/file-stroage';
+import { decryptWithServerAction } from '@/components/drm/drmUtils';
+
+// 허용된 파일 타입
+const ALLOWED_MIME_TYPES = [
+ 'application/msword',
+ 'application/vnd.openxmlformats-officedocument.wordprocessingml.document'
+];
+
+export async function POST(request: NextRequest) {
+ try {
+ const formData = await request.formData();
+
+ const chunk = formData.get('chunk') as File;
+ const filename = formData.get('filename') as string;
+ const chunkIndex = parseInt(formData.get('chunkIndex') as string);
+ const totalChunks = parseInt(formData.get('totalChunks') as string);
+ const fileId = formData.get('fileId') as string;
+
+ // 필수 매개변수 검증
+ if (!chunk || !filename || isNaN(chunkIndex) || isNaN(totalChunks) || !fileId) {
+ return NextResponse.json({
+ success: false,
+ error: '필수 매개변수가 누락되었습니다'
+ }, { status: 400 });
+ }
+
+ // 파일 확장자 검증
+ const fileExtension = filename.toLowerCase().split('.').pop();
+ if (!fileExtension || !['doc', 'docx'].includes(fileExtension)) {
+ return NextResponse.json({
+ success: false,
+ error: '워드 파일(.doc, .docx)만 업로드 가능합니다'
+ }, { status: 400 });
+ }
+
+ // 임시 디렉토리 생성
+ const tempDir = path.join(process.cwd(), 'temp', 'project-doc-templates', fileId);
+ await mkdir(tempDir, { recursive: true });
+
+ // 청크 파일 저장
+ const chunkPath = path.join(tempDir, `chunk-${chunkIndex}`);
+ const buffer = Buffer.from(await chunk.arrayBuffer());
+ await writeFile(chunkPath, buffer);
+
+ console.log(`📄 [ProjectDocTemplate] 청크 저장: ${chunkIndex + 1}/${totalChunks} - ${filename}`);
+
+ // 마지막 청크인 경우 모든 청크를 합쳐 최종 파일 생성
+ if (chunkIndex === totalChunks - 1) {
+ console.log(`🔄 [ProjectDocTemplate] 파일 병합 시작: ${filename}`);
+
+ try {
+ // 모든 청크를 순서대로 읽어서 병합
+ const chunks: Buffer[] = [];
+ let totalSize = 0;
+
+ for (let i = 0; i < totalChunks; i++) {
+ const chunkData = await readFile(path.join(tempDir, `chunk-${i}`));
+ chunks.push(chunkData);
+ totalSize += chunkData.length;
+ }
+
+ // 모든 청크를 하나의 Buffer로 병합
+ const mergedBuffer = Buffer.concat(chunks, totalSize);
+ console.log(`✅ [ProjectDocTemplate] 병합 완료: ${filename} (${totalSize} bytes)`);
+
+ // MIME 타입 결정
+ const mimeType = fileExtension === 'docx'
+ ? 'application/vnd.openxmlformats-officedocument.wordprocessingml.document'
+ : 'application/msword';
+
+ // 환경에 따른 저장 방식 선택
+ const isProduction = process.env.NODE_ENV === 'production';
+ let saveResult;
+
+ if (isProduction) {
+ // Production: DRM 파일 처리
+ console.log(`🔐 [ProjectDocTemplate] Production - DRM 처리: ${filename}`);
+
+ const mergedFile = new File([mergedBuffer], filename, {
+ type: mimeType,
+ lastModified: Date.now(),
+ });
+
+ saveResult = await saveDRMFile(
+ mergedFile,
+ decryptWithServerAction,
+ 'project-doc-templates', // 프로젝트 문서 템플릿 전용 디렉토리
+ );
+ } else {
+ // Development: 일반 파일 저장
+ console.log(`🛠️ [ProjectDocTemplate] Development - 일반 저장: ${filename}`);
+
+ saveResult = await saveBuffer({
+ buffer: mergedBuffer,
+ fileName: filename,
+ directory: 'project-doc-templates', // 프로젝트 문서 템플릿 전용 디렉토리
+ originalName: filename
+ });
+ }
+
+ // 임시 파일 정리 (비동기로 처리)
+ rm(tempDir, { recursive: true, force: true })
+ .then(() => console.log(`🗑️ [ProjectDocTemplate] 임시 파일 정리 완료: ${fileId}`))
+ .catch((e: unknown) => console.error('[ProjectDocTemplate] 청크 정리 오류:', e));
+
+ if (saveResult.success) {
+ const envPrefix = isProduction ? '🔐' : '🛠️';
+ console.log(`${envPrefix} [ProjectDocTemplate] 파일 저장 완료: ${saveResult.fileName}`);
+
+ return NextResponse.json({
+ success: true,
+ fileName: filename,
+ filePath: saveResult.publicPath,
+ hashedFileName: saveResult.fileName,
+ fileSize: totalSize,
+ mimeType,
+ environment: isProduction ? 'production' : 'development',
+ processingType: isProduction ? 'DRM' : 'standard',
+ templateType: 'project-doc-template'
+ });
+ } else {
+ console.error(`[ProjectDocTemplate] 파일 저장 실패:`, saveResult.error);
+ return NextResponse.json({
+ success: false,
+ error: saveResult.error || '파일 저장에 실패했습니다',
+ environment: isProduction ? 'production' : 'development'
+ }, { status: 500 });
+ }
+
+ } catch (mergeError) {
+ console.error('[ProjectDocTemplate] 파일 병합 오류:', mergeError);
+
+ // 오류 발생 시 임시 파일 정리
+ rm(tempDir, { recursive: true, force: true })
+ .catch((e: unknown) => console.error('[ProjectDocTemplate] 임시 파일 정리 오류:', e));
+
+ return NextResponse.json({
+ success: false,
+ error: '파일 병합 중 오류가 발생했습니다'
+ }, { status: 500 });
+ }
+ }
+
+ // 중간 청크 업로드 성공 응답
+ return NextResponse.json({
+ success: true,
+ chunkIndex,
+ message: `청크 ${chunkIndex + 1}/${totalChunks} 업로드 완료`
+ });
+
+ } catch (error) {
+ console.error('[ProjectDocTemplate] 청크 업로드 오류:', error);
+
+ const errorMessage = error instanceof Error ? error.message : '서버 오류가 발생했습니다';
+
+ return NextResponse.json({
+ success: false,
+ error: errorMessage
+ }, { status: 500 });
+ }
+}
+
+// OPTIONS 요청 처리 (CORS)
+export async function OPTIONS(request: NextRequest) {
+ return new NextResponse(null, {
+ status: 200,
+ headers: {
+ 'Access-Control-Allow-Origin': '*',
+ 'Access-Control-Allow-Methods': 'POST, OPTIONS',
+ 'Access-Control-Allow-Headers': 'Content-Type',
+ },
+ });
+} \ No newline at end of file
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-07 15:17:15 +0000