feat: add AI-powered finance and project risk analysis features with pgvector support for RAG embeddings

2026-06-06 21:47:50 +03:00
parent 21af4b7a62
commit 83379a5edc
17 changed files with 1104 additions and 241 deletions
@@ -39,22 +39,37 @@ export async function POST(req: Request) {
      model = openai('gpt-4o');
    }

-    // Identify the latest user message to save to Supabase
+    // Identify the latest user message to save to Supabase and use for RAG
    const latestMessage = messages[messages.length - 1];
-    if (sessionId && latestMessage && latestMessage.role === 'user') {
-      // Sadece metin varsa kaydediyoruz
-      if (latestMessage.content) {
+    let ragContext = "";
+    
+    if (latestMessage && latestMessage.role === 'user' && latestMessage.content) {
+      if (sessionId) {
        await supabase.from("chat_messages").insert({
          session_id: sessionId,
          role: "user",
          content: latestMessage.content,
        });
      }
+
+      // Perform RAG search
+      try {
+        const { searchSimilarDocuments } = await import('@/lib/ai/embeddings');
+        const similarDocs = await searchSimilarDocuments(user.id, latestMessage.content, provider, apiKey, 3);
+        if (similarDocs && similarDocs.length > 0) {
+          ragContext = "Aşağıda kullanıcının veri tabanından sistemin otomatik bulduğu geçmiş notlar ve veriler (RAG Context) bulunmaktadır. Gerektiğinde soruları yanıtlarken bunlardan faydalan:\n\n" + similarDocs.map((doc: any) => `- ${doc.content}`).join("\n");
+        }
+      } catch (err) {
+        console.error("RAG araması başarısız:", err);
+      }
    }

    const systemPrompt = `Sen kullanıcının kişisel Freelancer İş Asistanı ve Danışmanısın. Cognis Freelancer OS içinde yaşıyorsun.
 Kullanıcının iş süreçlerini, projelerini ve finansal durumunu organize etmesine yardımcı oluyorsun.
 Gerektiğinde araçları (tools) kullanarak sistemden güncel verileri çek ve doğrudan veri ekle.
+
+${ragContext}
+
 Aşağıdaki yeteneklere sahipsin:
 - Finansal verileri listeleyebilir ve yeni finans kaydı (gelir/gider) girebilirsin.
 - Görevleri okuyabilir ve yeni görevler ekleyebilirsin.
@@ -0,0 +1,80 @@
+import { generateText } from 'ai';
+import { createOpenAI } from '@ai-sdk/openai';
+import { createGoogleGenerativeAI } from '@ai-sdk/google';
+import { createClient } from '@/lib/supabase/server';
+
+export const maxDuration = 30;
+
+export async function POST(req: Request) {
+  try {
+    const supabase = await createClient();
+    const { data: { user } } = await supabase.auth.getUser();
+
+    if (!user) {
+      return new Response(JSON.stringify({ error: 'Yetkisiz erişim' }), { status: 401 });
+    }
+
+    const { data: appSettings } = await supabase
+      .from("app_settings")
+      .select("*")
+      .eq("user_id", user.id)
+      .single();
+
+    const provider = appSettings?.ai_provider || "openai";
+    const apiKey = appSettings?.api_key;
+
+    if (!apiKey) {
+      return new Response(JSON.stringify({ error: 'Ayarlardan AI Sağlayıcı ve API Anahtarı seçmelisiniz.' }), { status: 400 });
+    }
+
+    let model;
+    if (provider === 'gemini') {
+      const google = createGoogleGenerativeAI({ apiKey });
+      model = google('gemini-1.5-pro-latest');
+    } else if (provider === 'groq') {
+      const groq = createOpenAI({ apiKey, baseURL: 'https://api.groq.com/openai/v1' });
+      model = groq('llama-3.1-8b-instant');
+    } else {
+      const openai = createOpenAI({ apiKey });
+      model = openai('gpt-4o');
+    }
+
+    // Fetch finance data (last 30 days)
+    const pastDate = new Date();
+    pastDate.setDate(pastDate.getDate() - 30);
+    const { data: transactions } = await supabase.from('finance_transactions')
+      .select('type, amount, category, transaction_date')
+      .gte('transaction_date', pastDate.toISOString())
+      .eq('user_id', user.id);
+
+    if (!transactions || transactions.length === 0) {
+      return new Response(JSON.stringify({ text: "Son 30 güne ait herhangi bir finansal işleminiz bulunmadığı için analiz yapamıyorum. Lütfen yeni gelir/gider ekleyin." }), { status: 200 });
+    }
+
+    const totalIncome = transactions.filter(t => t.type === 'income').reduce((acc, curr) => acc + Number(curr.amount), 0);
+    const totalExpense = transactions.filter(t => t.type === 'expense').reduce((acc, curr) => acc + Number(curr.amount), 0);
+    const netProfit = totalIncome - totalExpense;
+
+    const dataSummary = `Kullanıcının son 30 günlük finansal durumu:
+- Toplam Gelir: ${totalIncome} $
+- Toplam Gider: ${totalExpense} $
+- Net Kâr: ${netProfit} $
+- İşlem Sayısı: ${transactions.length}
+İşlemler listesi:
+${transactions.map(t => `- ${t.transaction_date.slice(0, 10)} | ${t.type === 'income' ? 'Gelir' : 'Gider'} | ${t.category} | ${t.amount}$`).join('\n')}`;
+
+    const { text } = await generateText({
+      model,
+      system: `Sen profesyonel bir finans danışmanısın. Kullanıcıya verilen finansal verilere dayanarak kısa, motive edici ve yapıcı bir "Finansal Durum Raporu ve Tavsiye" sunmalısın. 
+Gereksiz uzunluktan kaçın, direkt sadede gel. Sadece metin formatında, markdown başlıklar kullanarak (örn: ### Özet, ### Tavsiyeler) cevap ver. Türkçe konuş.`,
+      prompt: `Lütfen aşağıdaki verilere göre bana bir finansal özet ve kâr/gider oranım için tavsiye ver:\n\n${dataSummary}`,
+    });
+
+    return new Response(JSON.stringify({ text }), {
+      headers: { 'Content-Type': 'application/json' },
+    });
+  } catch (error: any) {
+    console.error("AI Finance Error:", error);
+    return new Response(JSON.stringify({ error: error.message }), { status: 500 });
+  }
+}
@@ -0,0 +1,84 @@
+import { generateText } from 'ai';
+import { createOpenAI } from '@ai-sdk/openai';
+import { createGoogleGenerativeAI } from '@ai-sdk/google';
+import { createClient } from '@/lib/supabase/server';
+
+export const maxDuration = 30;
+
+export async function POST(req: Request) {
+  try {
+    const supabase = await createClient();
+    const { data: { user } } = await supabase.auth.getUser();
+
+    if (!user) {
+      return new Response(JSON.stringify({ error: 'Yetkisiz erişim' }), { status: 401 });
+    }
+
+    const { projectId } = await req.json();
+
+    const { data: appSettings } = await supabase
+      .from("app_settings")
+      .select("*")
+      .eq("user_id", user.id)
+      .single();
+
+    const provider = appSettings?.ai_provider || "openai";
+    const apiKey = appSettings?.api_key;
+
+    if (!apiKey) {
+      return new Response(JSON.stringify({ error: 'Ayarlardan AI Sağlayıcı ve API Anahtarı seçmelisiniz.' }), { status: 400 });
+    }
+
+    let model;
+    if (provider === 'gemini') {
+      const google = createGoogleGenerativeAI({ apiKey });
+      model = google('gemini-1.5-pro-latest');
+    } else if (provider === 'groq') {
+      const groq = createOpenAI({ apiKey, baseURL: 'https://api.groq.com/openai/v1' });
+      model = groq('llama-3.1-8b-instant');
+    } else {
+      const openai = createOpenAI({ apiKey });
+      model = openai('gpt-4o');
+    }
+
+    // Fetch project details
+    let projectDataStr = "";
+    if (projectId) {
+      const { data: project } = await supabase.from('projects').select('*, clients(name)').eq('id', projectId).single();
+      if (!project) return new Response(JSON.stringify({ error: 'Proje bulunamadı.' }), { status: 404 });
+      
+      const { data: tasks } = await supabase.from('tasks').select('status').eq('project_id', projectId);
+      
+      const completedTasks = tasks?.filter(t => t.status === 'completed').length || 0;
+      const totalTasks = tasks?.length || 0;
+
+      projectDataStr = `Proje Adı: ${project.name}
+Müşteri: ${project.clients?.name || 'Bilinmiyor'}
+Durum: ${project.status}
+Bütçe: ${project.budget_amount || 0} ${project.currency}
+İlerleme: %${project.progress}
+Başlangıç: ${project.start_date || 'Bilinmiyor'}
+Bitiş (Deadline): ${project.due_date || 'Bilinmiyor'}
+Görevler: ${totalTasks} adet (${completedTasks} tamamlandı)`;
+    } else {
+      // Analyze all active projects
+      const { data: projects } = await supabase.from('projects').select('name, status, due_date, progress').eq('user_id', user.id).eq('status', 'active');
+      if (!projects || projects.length === 0) return new Response(JSON.stringify({ error: 'Aktif proje bulunamadı.' }), { status: 404 });
+      
+      projectDataStr = `Aktif Projeler:\n${projects.map(p => `- ${p.name} | İlerleme: %${p.progress} | Deadline: ${p.due_date || 'Yok'}`).join('\n')}`;
+    }
+
+    const { text } = await generateText({
+      model,
+      system: `Sen bir Proje Yönetim Uzmanısın. Verilen proje bilgilerini analiz ederek kısa, net ve aksiyon odaklı bir "Risk ve Durum Raporu" oluşturmalısın. Türkçe yanıt ver.`,
+      prompt: `Lütfen aşağıdaki proje verilerine göre riskleri ve önerilerini belirt:\n\n${projectDataStr}`,
+    });
+
+    return new Response(JSON.stringify({ text }), {
+      headers: { 'Content-Type': 'application/json' },
+    });
+  } catch (error: any) {
+    console.error("AI Project Risk Error:", error);
+    return new Response(JSON.stringify({ error: error.message }), { status: 500 });
+  }
+}