feat: add deficiency analysis route
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
import { Response } from 'express';
|
||||
import { supabase } from '../lib/supabase';
|
||||
import { AuthenticatedRequest } from '../middleware/auth';
|
||||
import { runIddianameAnalysis, runCaseNarrativeAnalysis, runStatementAnalysis } from './document.controller';
|
||||
import { runIddianameAnalysis, runCaseNarrativeAnalysis, runStatementAnalysis, runDeficiencyAnalysis } from './document.controller';
|
||||
import { findOrCreateCaseByTitle } from '../lib/caseLookup';
|
||||
|
||||
export const createCase = async (req: AuthenticatedRequest, res: Response) => {
|
||||
@@ -160,6 +160,67 @@ export const analyzeStatements = async (req: AuthenticatedRequest, res: Response
|
||||
}
|
||||
};
|
||||
|
||||
export const analyzeDeficiencies = async (req: AuthenticatedRequest, res: Response) => {
|
||||
try {
|
||||
const { caseId } = req.params;
|
||||
if (!caseId) {
|
||||
return res.status(400).json({ error: 'Geçersiz caseId' });
|
||||
}
|
||||
|
||||
const { data: docs, error: docsError } = await supabase
|
||||
.from('documents')
|
||||
.select('filename, extracted_text')
|
||||
.eq('case_id', caseId)
|
||||
.order('uploaded_at', { ascending: true });
|
||||
if (docsError) throw docsError;
|
||||
|
||||
// Sadece tensip, zaptı, tutanak, karar, müzekkere gibi evrakları filtrele
|
||||
const keywords = ['tensip', 'zaptı', 'tutanak', 'duruşma', 'müzekkere', 'karar', 'iddianame'];
|
||||
const deficiencyDocs = (docs || []).filter((d) => {
|
||||
if (!d.extracted_text || !String(d.extracted_text).trim()) return false;
|
||||
const fn = normalizeTr(d.filename);
|
||||
return keywords.some(kw => fn.includes(kw));
|
||||
});
|
||||
|
||||
// Eğer hiç spesifik evrak yoksa, çöp olmayanları al
|
||||
let targetDocs = deficiencyDocs;
|
||||
if (targetDocs.length === 0) {
|
||||
const trashKeywords = ['tebligat', 'makbuz', 'pul', 'zarf', 'masraf', 'havale', 'barkod', 'alındı', 'görüldü', 'ilan', 'talimat', 'nüfus', 'sicil', 'sabıka'];
|
||||
targetDocs = (docs || []).filter(d => {
|
||||
if (!d.extracted_text || !String(d.extracted_text).trim()) return false;
|
||||
const fn = normalizeTr(d.filename);
|
||||
return !trashKeywords.some(kw => fn.includes(kw));
|
||||
});
|
||||
}
|
||||
|
||||
if (targetDocs.length === 0) {
|
||||
return res.status(400).json({ error: 'Bu dosyada analiz edilecek uygun evrak bulunamadı.' });
|
||||
}
|
||||
|
||||
const perDocLimit = Math.max(1000, Math.floor(15000 / targetDocs.length));
|
||||
const combinedText = targetDocs
|
||||
.map((d) => `--- ${d.filename} ---\n${String(d.extracted_text).slice(0, perDocLimit)}`)
|
||||
.join('\n\n');
|
||||
|
||||
const analysisInput = `Aşağıdaki belgeler dava dosyasına aittir:\n\n${combinedText}`;
|
||||
|
||||
const { summaryJson, aiModel } = await runDeficiencyAnalysis(analysisInput);
|
||||
|
||||
// Eksiklik analizi sonucunu 'analyses' tablosuna kaydet
|
||||
const { data: analysisRecord, error: analysisError } = await supabase
|
||||
.from('analyses')
|
||||
.insert([{ case_id: caseId, document_id: null, summary_json: { deficiencyAnalysis: summaryJson }, model_used: aiModel }])
|
||||
.select()
|
||||
.single();
|
||||
if (analysisError) throw analysisError;
|
||||
|
||||
res.json({ analysis: analysisRecord });
|
||||
} catch (error: any) {
|
||||
console.error('Analyze Deficiencies Error:', error);
|
||||
res.status(500).json({ error: error.message || 'Internal Server Error' });
|
||||
}
|
||||
};
|
||||
|
||||
// UYAP Evrak İndirici eklentisinin "Taraf Bilgileri" sekmesinden yakaladığı
|
||||
// davacı/davalı/sanık + vekil bilgisini kaydeder. AI'nin OCR metninden tahmin
|
||||
// ettiği "Taraflar" alanından çok daha güvenilir — doğrudan UYAP'ın yapılandırılmış
|
||||
|
||||
Reference in New Issue
Block a user