import { GoogleGenAI, Type } from "@google/genai"; import type { AIProvider } from '../types/providers'; import type { ReportData } from '../types'; interface AnalyzeOptions { provider: AIProvider; apiKey: string; model: string; file: File; endpoint?: string; } const fileToGenerativePart = async (file: File) => { const base64EncodedDataPromise = new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); return { inlineData: { data: await base64EncodedDataPromise, mimeType: file.type }, }; }; const cleanAndParseJson = (jsonString: string): any => { let cleanedString = jsonString.trim(); // Tenta encontrar um bloco markdown com json const jsonMatch = cleanedString.match(/```(?:json)?\s*([\s\S]*?)\s*```/i); if (jsonMatch) { cleanedString = jsonMatch[1].trim(); } else { // Se não tiver crases, tenta encontrar o primeiro { e o último } const startIndex = cleanedString.indexOf('{'); const endIndex = cleanedString.lastIndexOf('}'); if (startIndex !== -1 && endIndex !== -1) { cleanedString = cleanedString.substring(startIndex, endIndex + 1); } } try { const parsed = JSON.parse(cleanedString); let finalData = parsed; // Se o modelo aninhou os dados dentro de uma chave "report" ou "reports" if (parsed.reports) { finalData = parsed.reports; } else if (parsed.report && !parsed.identification) { finalData = parsed.report; } return Array.isArray(finalData) ? finalData : [finalData]; } catch (error) { console.error("Failed to parse cleaned JSON:", jsonString); throw new Error("A resposta da IA não estava no formato JSON esperado."); } }; const reportSchema = { type: Type.OBJECT, properties: { confidence: { type: Type.NUMBER, description: "Grau de Confiança da Análise em percentual (ex: 98)." }, identification: { type: Type.OBJECT, properties: { product: { type: Type.STRING, description: "Nome do produto/material (ex: Chapa de Aço)." }, standards: { type: Type.STRING, description: "Norma(s) principal(is) citada(s) no certificado." }, manufacturer: { type: Type.STRING, description: "Nome do fabricante ou revendedor." }, certificateNumber: { type: Type.STRING, description: "Número do certificado." }, certificateDate: { type: Type.STRING, description: "Data do certificado." }, batches: { type: Type.STRING, description: "Lista de lotes (batches)." }, heats: { type: Type.STRING, description: "Lista de corridas (heats)." }, quantity: { type: Type.STRING, description: "Volume, peso ou medida do material." }, }, required: ["product", "standards", "manufacturer", "certificateNumber", "certificateDate", "batches", "heats", "quantity"] }, compliance: { type: Type.OBJECT, properties: { status: { type: Type.STRING, enum: ["CONFORME", "NÃO CONFORME"], description: "Status geral de conformidade." }, nonComplianceReason: { type: Type.STRING, description: "Se o status for 'NÃO CONFORME', explique detalhadamente o motivo da não conformidade, citando quais propriedades ou elementos químicos falharam e quais eram os limites da norma técnica analisada. Se for 'CONFORME', retorne uma string vazia." }, mechanical: { type: Type.ARRAY, items: { type: Type.OBJECT, properties: { property: { type: Type.STRING, description: "Propriedade mecânica (ex: Limite de Escoamento)." }, norm: { type: Type.STRING, description: "Valor exigido pela norma (ex: Mín: 350 MPa)." }, certificate: { type: Type.STRING, description: "Valor encontrado no certificado." }, status: { type: Type.STRING, enum: ["OK", "FALHA"], description: "Status da propriedade." }, differencePercentage: { type: Type.STRING, description: "Calculated percentage difference. MUST use strict formula: ((Certificate_Value - Norm_Value) / Norm_Value) * 100. E.g., if Norm=345 and Cert=404 -> '+17.1%'" } }, required: ["property", "norm", "certificate", "status", "differencePercentage"] } }, chemical: { type: Type.ARRAY, items: { type: Type.OBJECT, properties: { element: { type: Type.STRING, description: "Elemento químico (ex: Carbono (C))." }, norm: { type: Type.STRING, description: "Valor exigido pela norma (ex: Máx: 0.25%)." }, certificate: { type: Type.STRING, description: "Valor encontrado no certificado." }, status: { type: Type.STRING, enum: ["OK", "FALHA"], description: "Status do elemento." }, }, required: ["element", "norm", "certificate", "status"] } }, otherTests: { type: Type.ARRAY, items: { type: Type.OBJECT, properties: { test: { type: Type.STRING, description: "Outro teste relevante (ex: Teste de Impacto Charpy)." }, norm: { type: Type.STRING, description: "Valor exigido pela norma." }, certificate: { type: Type.STRING, description: "Valor encontrado no certificado." }, status: { type: Type.STRING, enum: ["OK", "FALHA"], description: "Status do teste." }, }, required: ["test", "norm", "certificate", "status"] } } }, required: ["status", "mechanical", "chemical", "otherTests"] }, overPerformance: { type: Type.ARRAY, items: { type: Type.OBJECT, properties: { property: { type: Type.STRING, description: "Ponto-chave de superdesempenho." }, value: { type: Type.STRING, description: "Percentual acima do mínimo normativo (ex: 12.5%)." }, }, required: ["property", "value"] }, description: "Lista de pontos onde o material excede os requisitos mínimos. Preencher apenas se o status for 'CONFORME'." }, equivalents: { type: Type.ARRAY, items: { type: Type.OBJECT, properties: { system: { type: Type.STRING, description: "Sistema da norma (ex: EN (Europa))." }, norm: { type: Type.STRING, description: "Norma equivalente (ex: S355J2)." }, }, required: ["system", "norm"] }, description: "Lista de normas internacionais equivalentes." } }, required: ["confidence", "identification", "compliance", "overPerformance", "equivalents"] }; const arraySchema = { type: Type.ARRAY, items: reportSchema }; const PROMPT_BASE = `Você é o "SteelCheck", um especialista sênior em engenharia de materiais, metalurgia, calibração e controle de qualidade industrial. Sua tarefa principal é transcrever com precisão matemática e zero alucinação os dados de um Certificado de Qualidade (Mill Test Report) e gerar um "Relatório de Análise Técnica" em formato JSON. ### DIRETRIZES RÍGIDAS DE TRANSCRIÇÃO (OCR DE ALTA PRECISÃO): 1. **Zero Alucinação de Normas:** No campo "standards", extraia APENAS e EXATAMENTE o que estiver escrito na imagem (ex: no campo "NORMA - ESPECIFICAÇAO - QUALIDADE / NORM - SPECIFICATION - GRADE"). Se o certificado diz "ASTM A572 GR50 / NBR7007 AR350", transcreva exatamente isso. NUNCA adicione normas equivalentes (como "ASTM A992") se elas não estiverem impressas explicitamente no papel do certificado. 2. **Extração de Identificação:** - **Número do Certificado (certificateNumber):** Procure atentamente por campos como "NUMERO / NUMBER" ou "CERTIFICADO Nº". No certificado exemplo, o número é "8183321347/000010". Não confunda com Nota Fiscal ("NF") ou Pedido ("Customer Order"). Nunca retorne "N/A" ou "#N/A" se houver um número legível no topo. - **Peso / Quantidade (quantity):** Transcreva exatamente a quantidade total (ex: "8,560 T" no campo "QTD / QUANT"). Não confunda dígitos (ex: "8" com "0", resultando em "0,960"). - **Corrida / Lote (heats / batches):** Transcreva o número exato do Lote/Corrida (ex: "2715275435"). Verifique cada dígito duas vezes para não confundir "7" com "1", "5" com "6", etc. 3. **Mapeamento Preciso de Colunas (Tabela Lateral/Horizontal):** - Certificados metalúrgicos costumam ter tabelas muito largas (muitas colunas). Faça um rastreamento visual preciso de cada linha, coluna por coluna, da esquerda para a direita. - **Composição Química (chemical):** Mapeie cada elemento à sua respectiva coluna (C, Mn, Si, P, S, Cu, Cr, Nb, Ni, V, etc.). Não pule colunas nem misture a ordem (ex: se a coluna do Enxofre "S" vem antes de Fósforo "P", certifique-se de associar o valor correto de cada um). - **Propriedades Mecânicas (mechanical):** - "LE" significa Limite de Escoamento (Yield Strength). - "LR" significa Limite de Resistência / Tração (Tensile Strength). - "Along" significa Alongamento (Elongation). - Transcreva os valores reais do certificado (ex: LE "415", LR "547"). Não chute valores médios ou mínimos da norma (como 368 ou 505) se no papel estão escritos outros números. 4. **Múltiplas Linhas de Teste por Lote/Corrida:** Se houver múltiplas linhas de testes mecânicos ou químicos independentes para o mesmo lote/corrida, gere um objeto de relatório independente no array JSON para CADA linha de teste, copiando os dados de identificação e cabeçalho para ambos. Isso garante que nenhum resultado de ensaio seja perdido. 5. **Orientação da Imagem:** A imagem pode estar rotacionada. Rotacione mentalmente e leia na direção correta. ### ANÁLISE DE CONFORMIDADE: - Compare os valores reais extraídos com os requisitos mínimos/máximos da norma técnica declarada no certificado (ex: para o ASTM A572 Grau 50, o limite de escoamento LE mínimo é 345 MPa e o limite de resistência LR mínimo é 450 MPa; para NBR 7007 AR350, o LE mínimo é 350 MPa e o LR mínimo é 450 MPa). - **Fórmula de Variação (differencePercentage):** Calcule a variação percentual do valor do certificado em relação ao mínimo exigido pela norma. USE ESTRITAMENTE A FÓRMULA: ((Valor_Certificado - Valor_Norma) / Valor_Norma) * 100. Exemplo: Se a Norma exige Mínimo 345, e o Certificado acusa 415, o resultado é ((415-345)/345)*100 = +20.3%. Retorne APENAS o JSON no formato do array especificado, sem explicações ou markdown. FORMATO DO RETORNO: [ { "confidence": 98, "identification": { "product": "PERFIL I", "standards": "ASTM A572 GR50 / NBR7007 AR350", "manufacturer": "GERDAU AÇOMINAS S.A.", "certificateNumber": "8183321347/000010", "certificateDate": "11.09.2025", "batches": "", "heats": "2715275435", "quantity": "8,560 T" }, "compliance": { "status": "CONFORME", "nonComplianceReason": "", "mechanical": [ { "property": "Yield Strength (Limite de Escoamento)", "norm": "Min: 345 MPa", "certificate": "415 MPa", "status": "OK", "differencePercentage": "+20.3%" } ], "chemical": [ { "element": "C (Carbon)", "norm": "Max: 0.23%", "certificate": "0.22%", "status": "OK" } ], "otherTests": [] }, "overPerformance": [], "equivalents": [] } ]`; export const analyzeWithGemini = async (file: File, apiKey: string, model: string = 'gemini-2.5-flash'): Promise => { if (!apiKey) { throw new Error("A chave de API do Gemini não foi fornecida."); } const ai = new GoogleGenAI({ apiKey: apiKey }); const imagePart = await fileToGenerativePart(file); const response = await ai.models.generateContent({ model, contents: { parts: [imagePart, { text: PROMPT_BASE }] }, config: { responseMimeType: "application/json", responseSchema: arraySchema, temperature: 0.1, } }); try { const text = response.text; const data = cleanAndParseJson(text); return data as ReportData[]; } catch (e) { if (e instanceof Error) { throw e; } throw new Error("A resposta da IA não estava no formato JSON esperado."); } }; export const analyzeWithOpenAI = async (file: File, apiKey: string, model: string = 'gpt-4o'): Promise => { if (!apiKey) { throw new Error("A chave de API da OpenAI não foi fornecida."); } const base64Data = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); const response = await fetch('https://api.openai.com/v1/chat/completions', { method: 'POST', headers: { 'Authorization': `Bearer ${apiKey}`, 'Content-Type': 'application/json', }, body: JSON.stringify({ model, messages: [ { role: 'user', content: [ { type: 'text', text: PROMPT_BASE }, { type: 'image_url', image_url: { url: `data:${file.type};base64,${base64Data}` } } ] } ], max_tokens: 4096, temperature: 0.1, response_format: { type: 'json_object' } }) }); if (!response.ok) { const error = await response.json(); throw new Error(`Erro da OpenAI: ${error.error?.message || 'Erro desconhecido'}`); } const data = await response.json(); const content = data.choices[0]?.message?.content; if (!content) { throw new Error("Resposta vazia da OpenAI"); } return cleanAndParseJson(content) as ReportData[]; }; export const analyzeWithAnthropic = async (file: File, apiKey: string, model: string = 'claude-3-sonnet-20240229'): Promise => { if (!apiKey) { throw new Error("A chave de API da Anthropic não foi fornecida."); } const base64Data = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); const response = await fetch('https://api.anthropic.com/v1/messages', { method: 'POST', headers: { 'x-api-key': apiKey, 'anthropic-version': '2023-06-01', 'Content-Type': 'application/json', }, body: JSON.stringify({ model, max_tokens: 4096, temperature: 0.1, messages: [ { role: 'user', content: [ { type: 'image', source: { type: 'base64', media_type: file.type, data: base64Data } }, { type: 'text', text: PROMPT_BASE + "\n\nRetorne apenas JSON válido sem formatação markdown." } ] } ] }) }); if (!response.ok) { const error = await response.json(); throw new Error(`Erro da Anthropic: ${error.error?.message || 'Erro desconhecido'}`); } const data = await response.json(); const content = data.content[0]?.text; if (!content) { throw new Error("Resposta vazia da Anthropic"); } return cleanAndParseJson(content) as ReportData[]; }; export const analyzeWithAzure = async (file: File, apiKey: string, endpoint: string, deployment: string): Promise => { if (!apiKey || !endpoint) { throw new Error("A chave de API e endpoint do Azure são necessários."); } const base64Data = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); const url = `${endpoint}/openai/deployments/${deployment}/chat/completions?api-version=2024-02-15-preview`; const response = await fetch(url, { method: 'POST', headers: { 'api-key': apiKey, 'Content-Type': 'application/json', }, body: JSON.stringify({ messages: [ { role: 'user', content: [ { type: 'text', text: PROMPT_BASE }, { type: 'image_url', image_url: { url: `data:${file.type};base64,${base64Data}` } } ] } ], max_tokens: 4096, temperature: 0.1 }) }); if (!response.ok) { const error = await response.text(); throw new Error(`Erro do Azure: ${error}`); } const data = await response.json(); const content = data.choices[0]?.message?.content; if (!content) { throw new Error("Resposta vazia do Azure"); } return cleanAndParseJson(content) as ReportData[]; }; export const analyzeCertificate = async (options: AnalyzeOptions): Promise => { const { provider, apiKey, model, file, endpoint } = options; switch (provider) { case 'gemini': return analyzeWithGemini(file, apiKey, model); case 'openai': return analyzeWithOpenAI(file, apiKey, model); case 'anthropic': return analyzeWithAnthropic(file, apiKey, model); case 'azure': return analyzeWithAzure(file, apiKey, endpoint!, model); case 'ollama': return analyzeWithOllama(file, endpoint!, model); case 'openrouter': return analyzeWithOpenRouter(file, apiKey, model); case 'minimax': return analyzeWithMinimax(file, apiKey, model); default: throw new Error(`Provedor não suportado: ${provider}`); } }; export const analyzeWithOllama = async (file: File, endpoint: string, model: string = 'llama3.2-vision'): Promise => { if (!endpoint) { throw new Error("O endpoint do Ollama é necessário. Configure o endereço da sua VPS."); } const base64Data = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); let url = `${endpoint}/api/chat`; // Check if using OpenWebUI (has /api in path but not direct Ollama) const useOpenWebUI = endpoint.includes('/api') || endpoint.includes('llm.reifonas.cloud'); if (useOpenWebUI) { // Use OpenWebUI API format url = `${endpoint}/api/v1/chat/completions`; } const response = await fetch(url, { method: 'POST', headers: { 'Content-Type': 'application/json', ...(useOpenWebUI ? { 'Authorization': 'Bearer no-key-required' } : {}) }, body: JSON.stringify({ model, messages: [ { role: 'user', content: [ { type: 'image_url', image_url: { url: `data:${file.type};base64,${base64Data}` } }, { type: 'text', text: PROMPT_BASE + "\n\nRetorne apenas JSON válido sem formatação markdown." } ] } ], ...(useOpenWebUI ? {} : { format: 'json' }), options: { temperature: 0.1, num_predict: 4096 } }) }); if (!response.ok) { const error = await response.text(); throw new Error(`Erro do Ollama/OpenWebUI: ${error}`); } const data = await response.json(); // OpenWebUI format: data.choices[0].message.content // Ollama native format: data.message.content const content = data.choices?.[0]?.message?.content || data.message?.content; if (!content) { throw new Error("Resposta vazia do Ollama/OpenWebUI"); } return cleanAndParseJson(content) as ReportData[]; }; export const analyzeWithOpenRouter = async (file: File, apiKey: string, model: string = 'google/gemini-2.5-flash'): Promise => { if (!apiKey) { throw new Error("A chave de API do OpenRouter não foi fornecida."); } const base64Data = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); const response = await fetch('https://openrouter.ai/api/v1/chat/completions', { method: 'POST', headers: { 'Authorization': `Bearer ${apiKey}`, 'Content-Type': 'application/json', 'HTTP-Referer': 'https://steelcheck.local', 'X-Title': 'SteelCheck', }, body: JSON.stringify({ model, messages: [ { role: 'user', content: [ { type: 'text', text: PROMPT_BASE + "\n\nRetorne apenas JSON válido sem formatação markdown." }, { type: 'image_url', image_url: { url: `data:${file.type};base64,${base64Data}` } } ] } ], temperature: 0.1 }) }); if (!response.ok) { const error = await response.json(); throw new Error(`Erro do OpenRouter: ${error.error?.message || 'Erro desconhecido'}`); } const data = await response.json(); const content = data.choices[0]?.message?.content; if (!content) { throw new Error("Resposta vazia do OpenRouter"); } return cleanAndParseJson(content) as ReportData[]; }; export const analyzeWithMinimax = async (file: File, apiKey: string, model: string = 'minimax-2.7'): Promise => { if (!apiKey) { throw new Error("A chave de API do MiniMax não foi fornecida."); } const base64Data = await new Promise((resolve) => { const reader = new FileReader(); reader.onloadend = () => resolve((reader.result as string).split(',')[1]); reader.readAsDataURL(file); }); const response = await fetch('https://api.minimaxi.com/v1/chat/completions', { method: 'POST', headers: { 'Authorization': `Bearer ${apiKey}`, 'Content-Type': 'application/json' }, body: JSON.stringify({ model, messages: [ { role: 'user', content: [ { type: 'text', text: PROMPT_BASE + "\n\nRetorne apenas JSON válido sem formatação markdown." }, { type: 'image_url', image_url: { url: `data:${file.type};base64,${base64Data}` } } ] } ], temperature: 0.1 }) }); if (!response.ok) { const error = await response.json().catch(() => ({})); throw new Error(`Erro do MiniMax: ${error.error?.message || 'Erro desconhecido'}`); } const data = await response.json(); const content = data.choices[0]?.message?.content; if (!content) { throw new Error("Resposta vazia do MiniMax"); } return cleanAndParseJson(content) as ReportData[]; }; export const buildStandardWithAI = async ( options: { provider: AIProvider; apiKey: string; model: string; endpoint?: string }, standardName: string, categoryDescription: string ) => { const prompt = `Você é um engenheiro de materiais sênior. O usuário solicitou a criação de uma tabela de limites para a norma técnica: "${standardName}". A categoria deste material é descrita como: "${categoryDescription}". Sua tarefa é acessar seu conhecimento sobre esta norma e gerar os limites estritos (mínimos e máximos) exigidos. RESPONDA APENAS UM JSON VÁLIDO no seguinte formato EXATO: { "codigo": "Nome oficial da norma (ex: ASTM A36/A36M-19)", "produto_especifico": "Descreva o tipo de produto que essa norma cobre", "parametros_controle": { "mecanicos": { "nome_do_parametro_1": valor_numerico, "nome_do_parametro_2": valor_numerico }, "quimicos": { "nome_do_parametro": valor_numerico }, "fisicos": { "nome_do_parametro": valor_numerico } } } Regras Cruciais: 1. USE APENAS NÚMEROS (floats/ints) nos valores. NUNCA use strings como "0.25" ou "250". Use 0.25 e 250. 2. Se a norma não especifica um limite máximo ou mínimo para um elemento, coloque null (sem aspas). 3. O nome da chave dentro de mecânicos/químicos/físicos deve ser em minúsculo, sem acentos, com underscores, e deve conter a unidade ou a palavra min/max (ex: "limite_escoamento_min_mpa", "carbono_max_percentual", "espessura_min_microns"). 4. Crie APENAS os grupos (mecanicos, quimicos, fisicos) que fazem sentido para a norma solicitada. 5. DEVOLVA APENAS O JSON, sem nenhuma formatação ou texto explicativo ao redor.`; try { let resultJson = ''; if (options.provider === 'gemini') { const ai = new GoogleGenAI({ apiKey: options.apiKey }); const response = await ai.models.generateContent({ model: options.model || 'gemini-2.5-flash', contents: prompt }); resultJson = response.text || ''; } else if (options.provider === 'openai') { const response = await fetch('https://api.openai.com/v1/chat/completions', { method: 'POST', headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${options.apiKey}` }, body: JSON.stringify({ model: options.model || 'gpt-4o', messages: [{ role: "user", content: prompt }] }) }); const data = await response.json(); resultJson = data.choices[0].message.content; } else if (options.provider === 'openrouter') { const response = await fetch('https://openrouter.ai/api/v1/chat/completions', { method: 'POST', headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${options.apiKey}`, 'HTTP-Referer': 'https://steelcheck.reifonas.cloud' }, body: JSON.stringify({ model: options.model || 'google/gemini-2.5-flash', messages: [{ role: "user", content: prompt }] }) }); const data = await response.json(); resultJson = data.choices[0].message.content; } const parsed = cleanAndParseJson(resultJson); return parsed; } catch (error) { console.error("Erro no buildStandardWithAI:", error); throw new Error("Falha ao gerar norma com a IA. Tente novamente."); } };