(김준회) 비활성화한 node-cron 진입점 (instrumentation.ts) 추가 및 NONSAP 동기화 개발건

5 files changed, 173 insertions, 0 deletions

diff --git a/app/api/nonsap-sync/config/route.ts b/app/api/nonsap-sync/config/route.ts
new file mode 100644
index 00000000..7441088b
--- /dev/null
+++ b/app/api/nonsap-sync/config/route.ts
@@ -0,0 +1,22 @@
+import { NextResponse } from 'next/server';
+import { getSyncConfigInfo } from '@/lib/nonsap-sync/sync-config';
+
+export async function GET() {
+  try {
+    const config = getSyncConfigInfo();
+    
+    return NextResponse.json({
+      success: true,
+      data: config,
+      timestamp: new Date().toISOString()
+    });
+  } catch (error) {
+    console.error('Failed to get sync config:', error);
+    
+    return NextResponse.json({
+      success: false,
+      error: 'Failed to get sync config',
+      timestamp: new Date().toISOString()
+    }, { status: 500 });
+  }
+} 
\ No newline at end of file
diff --git a/app/api/nonsap-sync/cron/route.ts b/app/api/nonsap-sync/cron/route.ts
new file mode 100644
index 00000000..80944280
--- /dev/null
+++ b/app/api/nonsap-sync/cron/route.ts
@@ -0,0 +1,41 @@
+import { NextRequest, NextResponse } from 'next/server';
+
+export async function GET(request: NextRequest) {
+  try {
+    // 인증 확인 (선택적)
+    const authToken = process.env.CRON_AUTH_TOKEN;
+    if (authToken) {
+      const providedToken = new URL(request.url).searchParams.get('token');
+      if (providedToken !== authToken) {
+        return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+      }
+    }
+
+    // 동적 import로 cron 스케줄러 호출
+    const { triggerEnhancedSync } = await import('../../../../lib/nonsap-sync/enhanced-sync-service');
+    
+    // 백그라운드에서 동기화 실행
+    triggerEnhancedSync().catch(error => {
+      console.error('Cron sync failed:', error);
+    });
+    
+    return NextResponse.json({
+      success: true,
+      message: 'NONSAP sync triggered via cron endpoint',
+      timestamp: new Date().toISOString()
+    });
+  } catch (error) {
+    console.error('Cron endpoint error:', error);
+    
+    return NextResponse.json({
+      success: false,
+      error: 'Failed to trigger sync',
+      timestamp: new Date().toISOString()
+    }, { status: 500 });
+  }
+}
+
+export async function POST() {
+  // POST 요청도 동일하게 처리
+  return GET();
+} 
\ No newline at end of file
diff --git a/app/api/nonsap-sync/health/route.ts b/app/api/nonsap-sync/health/route.ts
new file mode 100644
index 00000000..6bfa4ffb
--- /dev/null
+++ b/app/api/nonsap-sync/health/route.ts
@@ -0,0 +1,63 @@
+import { NextResponse } from 'next/server';
+
+export async function GET() {
+  try {
+    // Oracle DB 연결 테스트
+    let oracleStatus = 'unknown';
+    let oracleError = null;
+    
+    try {
+      const { oracleKnex } = await import('@/lib/oracle-db/db');
+      const result = await oracleKnex.raw('SELECT 1 FROM DUAL');
+      oracleStatus = result ? 'connected' : 'disconnected';
+    } catch (error) {
+      oracleStatus = 'disconnected';
+      oracleError = error instanceof Error ? error.message : String(error);
+    }
+
+    // PostgreSQL 연결 테스트
+    let postgresStatus = 'unknown';
+    let postgresError = null;
+    
+    try {
+      const db = await import('@/db/db');
+      await db.default.execute('SELECT 1');
+      postgresStatus = 'connected';
+    } catch (error) {
+      postgresStatus = 'disconnected';
+      postgresError = error instanceof Error ? error.message : String(error);
+    }
+
+    // 전체 상태 판단
+    const overallStatus = oracleStatus === 'connected' && postgresStatus === 'connected' 
+      ? 'healthy' 
+      : 'unhealthy';
+
+    return NextResponse.json({
+      status: overallStatus,
+      timestamp: new Date().toISOString(),
+      databases: {
+        oracle: {
+          status: oracleStatus,
+          error: oracleError
+        },
+        postgres: {
+          status: postgresStatus,
+          error: postgresError
+        }
+      },
+      environment: {
+        nodeEnv: process.env.NODE_ENV,
+        runtime: process.env.NEXT_RUNTIME || 'nodejs'
+      }
+    });
+  } catch (error) {
+    console.error('Health check error:', error);
+    
+    return NextResponse.json({
+      status: 'error',
+      timestamp: new Date().toISOString(),
+      error: error instanceof Error ? error.message : String(error)
+    }, { status: 500 });
+  }
+} 
\ No newline at end of file
diff --git a/app/api/nonsap-sync/status/route.ts b/app/api/nonsap-sync/status/route.ts
new file mode 100644
index 00000000..0a847904
--- /dev/null
+++ b/app/api/nonsap-sync/status/route.ts
@@ -0,0 +1,22 @@
+import { NextResponse } from 'next/server';
+import { getSyncProgressEnhanced } from '../../../../lib/nonsap-sync/enhanced-sync-service';
+
+export async function GET() {
+  try {
+    const progress = await getSyncProgressEnhanced();
+    
+    return NextResponse.json({
+      success: true,
+      data: progress,
+      timestamp: new Date().toISOString()
+    });
+  } catch (error) {
+    console.error('Error getting sync progress:', error);
+    
+    return NextResponse.json({
+      success: false,
+      error: 'Failed to get sync progress',
+      timestamp: new Date().toISOString()
+    }, { status: 500 });
+  }
+} 
\ No newline at end of file
diff --git a/app/api/nonsap-sync/trigger/route.ts b/app/api/nonsap-sync/trigger/route.ts
new file mode 100644
index 00000000..fbad7c4a
--- /dev/null
+++ b/app/api/nonsap-sync/trigger/route.ts
@@ -0,0 +1,25 @@
+import { NextResponse } from 'next/server';
+import { triggerEnhancedSync } from '../../../../lib/nonsap-sync/enhanced-sync-service';
+
+export async function POST() {
+  try {
+    // 수동 동기화 트리거 (백그라운드에서 실행)
+    triggerEnhancedSync().catch(error => {
+      console.error('Manual sync failed:', error);
+    });
+    
+    return NextResponse.json({
+      success: true,
+      message: 'Manual sync triggered successfully',
+      timestamp: new Date().toISOString()
+    });
+  } catch (error) {
+    console.error('Error triggering manual sync:', error);
+    
+    return NextResponse.json({
+      success: false,
+      error: 'Failed to trigger manual sync',
+      timestamp: new Date().toISOString()
+    }, { status: 500 });
+  }
+} 
\ No newline at end of file