AI Assistant — multi-provider chat (Claude / GPT / Gemini)

Schema: - ai_chats: company_id, user_id, title, provider; index pe activitate - ai_messages: role (system/user/assistant), content, meta JSON (tokens, latency, model) Service AiAssistantService (multi-provider): - ask($chat, $message): persistă mesajul user, build system prompt cu context tenant (statistici clienți/mașini/cereri/datorii), apelează API-ul providerului, persistă răspunsul cu meta (tokens, latency) - callClaude: api.anthropic.com/v1/messages cu claude-sonnet-4-5 - callOpenAI: api.openai.com/v1/chat/completions cu gpt-4o-mini - callGemini: generativelanguage.googleapis.com cu gemini-1.5-flash - Try/catch pe toate; eroare devine mesaj asistent fără să crape System prompt include: - Numele și orașul companiei - Statistici curente (clienți, mașini, cereri noi, fișe active, datorii) - Limita stricta: NU inventează date Custom Filament Page /app/ai-assistant (group Analiză): - Sidebar stâng: listă conversații (last 20), buton 'Nouă' + delete cu confirm - Main: bubble chat (user dreapta albastru, asistent stânga gri) - Meta jos pe răspuns: provider · latency · tokens - Empty state friendly cu instrucțiuni configurare - Loading indicator (3 dots animate) când AI răspunde - Auto-scroll la mesaj nou - Enter trimite, Shift+Enter newline - Auto-titlu chat din primul mesaj user (60 chars) Settings page extins cu secțiune 'Asistent AI': - Provider implicit (claude/gpt/gemini) - 3 chei API (password fields, revealable) - Key-urile salvate în companies.settings.ai (per tenant, izolat)
2026-05-07 14:50:56 +00:00
parent 7ce78c350c
commit 976c0f03e3
7 changed files with 586 additions and 0 deletions
@@ -0,0 +1,112 @@
+<?php
+
+namespace App\Filament\Tenant\Pages;
+
+use App\Models\Tenant\AiChat;
+use App\Services\Ai\AiAssistantService;
+use App\Tenancy\TenantManager;
+use Filament\Pages\Page;
+use Livewire\Attributes\Url;
+
+class AiAssistant extends Page
+{
+    protected static string|\BackedEnum|null $navigationIcon = 'heroicon-o-sparkles';
+
+    protected static ?string $navigationLabel = 'Asistent AI';
+
+    protected static string|\UnitEnum|null $navigationGroup = 'Analiză';
+
+    protected static ?int $navigationSort = 71;
+
+    protected static ?string $title = 'Asistent AI';
+
+    protected string $view = 'filament.tenant.pages.ai-assistant';
+
+    public ?int $chatId = null;
+
+    public string $newMessage = '';
+
+    public bool $loading = false;
+
+    public function mount(): void
+    {
+        // Use last chat for the user, or create a new one.
+        $userId = auth()->id();
+        $companyId = app(TenantManager::class)->currentId();
+        if (! $userId || ! $companyId) return;
+
+        $chat = AiChat::where('user_id', $userId)->latest('updated_at')->first();
+        if (! $chat) {
+            $chat = AiChat::create([
+                'company_id' => $companyId,
+                'user_id' => $userId,
+                'title' => 'Conversație nouă',
+                'provider' => $this->defaultProvider(),
+            ]);
+        }
+        $this->chatId = $chat->id;
+    }
+
+    public function getChat(): ?AiChat
+    {
+        return $this->chatId ? AiChat::with('messages')->find($this->chatId) : null;
+    }
+
+    public function getChats()
+    {
+        return AiChat::where('user_id', auth()->id())
+            ->latest('updated_at')
+            ->limit(20)
+            ->get();
+    }
+
+    public function newChat(): void
+    {
+        $chat = AiChat::create([
+            'company_id' => app(TenantManager::class)->currentId(),
+            'user_id' => auth()->id(),
+            'title' => 'Conversație nouă',
+            'provider' => $this->defaultProvider(),
+        ]);
+        $this->chatId = $chat->id;
+        $this->newMessage = '';
+    }
+
+    public function selectChat(int $id): void
+    {
+        $chat = AiChat::where('user_id', auth()->id())->where('id', $id)->first();
+        if ($chat) $this->chatId = $chat->id;
+    }
+
+    public function deleteChat(int $id): void
+    {
+        AiChat::where('user_id', auth()->id())->where('id', $id)->delete();
+        if ($this->chatId === $id) {
+            $this->chatId = AiChat::where('user_id', auth()->id())->latest('updated_at')->value('id');
+            if (! $this->chatId) $this->newChat();
+        }
+    }
+
+    public function send(): void
+    {
+        $msg = trim($this->newMessage);
+        if ($msg === '' || ! $this->chatId) return;
+
+        $this->loading = true;
+        $this->newMessage = '';
+        $chat = AiChat::find($this->chatId);
+        if (! $chat) { $this->loading = false; return; }
+
+        try {
+            app(AiAssistantService::class)->ask($chat, $msg);
+        } finally {
+            $this->loading = false;
+        }
+    }
+
+    protected function defaultProvider(): string
+    {
+        $tenant = app(TenantManager::class)->current();
+        return ($tenant?->settings['ai']['default_provider'] ?? 'claude');
+    }
+}
@@ -50,6 +50,10 @@ class Settings extends Page
            'notify_payment' => $notify['payment'] ?? true,
            'notify_appointment' => $notify['appointment'] ?? true,
            'notify_reminder' => $notify['reminder'] ?? true,
+            'ai_default_provider' => $settings['ai']['default_provider'] ?? 'claude',
+            'ai_claude_key' => $settings['ai']['claude_key'] ?? null,
+            'ai_gpt_key' => $settings['ai']['gpt_key'] ?? null,
+            'ai_gemini_key' => $settings['ai']['gemini_key'] ?? null,
        ]);
    }

@@ -120,6 +124,18 @@ class Settings extends Page
                        Forms\Components\Toggle::make('notify_appointment')->label('Programare confirmată')->default(true),
                        Forms\Components\Toggle::make('notify_reminder')->label('Reminder ITP / revizie')->default(true),
                    ]),
+                Schemas\Components\Section::make('Asistent AI')
+                    ->description('Adaugă chei API ca să activezi asistentul. Cheile rămân la voi — nu sunt partajate.')
+                    ->columns(2)
+                    ->schema([
+                        Forms\Components\Select::make('ai_default_provider')
+                            ->label('Provider implicit')
+                            ->options(['claude' => 'Claude (Anthropic)', 'gpt' => 'ChatGPT (OpenAI)', 'gemini' => 'Gemini (Google)'])
+                            ->default('claude'),
+                        Forms\Components\TextInput::make('ai_claude_key')->label('Claude API Key')->password()->revealable()->placeholder('sk-ant-...'),
+                        Forms\Components\TextInput::make('ai_gpt_key')->label('OpenAI API Key')->password()->revealable()->placeholder('sk-proj-...'),
+                        Forms\Components\TextInput::make('ai_gemini_key')->label('Gemini API Key')->password()->revealable(),
+                    ]),
            ])
            ->statePath('data');
    }
@@ -151,6 +167,12 @@ class Settings extends Page
                    'appointment' => (bool) ($data['notify_appointment'] ?? true),
                    'reminder' => (bool) ($data['notify_reminder'] ?? true),
                ],
+                'ai' => [
+                    'default_provider' => $data['ai_default_provider'] ?? 'claude',
+                    'claude_key' => $data['ai_claude_key'] ?? null,
+                    'gpt_key' => $data['ai_gpt_key'] ?? null,
+                    'gemini_key' => $data['ai_gemini_key'] ?? null,
+                ],
            ]),
        ]);

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\Models\Tenant;
+
+use App\Models\Concerns\BelongsToTenant;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+use Illuminate\Database\Eloquent\Relations\HasMany;
+
+class AiChat extends Model
+{
+    use BelongsToTenant;
+
+    protected $fillable = ['company_id', 'user_id', 'title', 'provider'];
+
+    public function user(): BelongsTo
+    {
+        return $this->belongsTo(User::class);
+    }
+
+    public function messages(): HasMany
+    {
+        return $this->hasMany(AiMessage::class)->orderBy('created_at');
+    }
+}
@@ -0,0 +1,21 @@
+<?php
+
+namespace App\Models\Tenant;
+
+use App\Models\Concerns\BelongsToTenant;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Relations\BelongsTo;
+
+class AiMessage extends Model
+{
+    use BelongsToTenant;
+
+    protected $fillable = ['company_id', 'ai_chat_id', 'role', 'content', 'meta'];
+
+    protected $casts = ['meta' => 'array'];
+
+    public function chat(): BelongsTo
+    {
+        return $this->belongsTo(AiChat::class, 'ai_chat_id');
+    }
+}
@@ -0,0 +1,206 @@
+<?php
+
+namespace App\Services\Ai;
+
+use App\Models\Central\Company;
+use App\Models\Tenant\AiChat;
+use App\Models\Tenant\AiMessage;
+use App\Models\Tenant\Client;
+use App\Models\Tenant\Lead;
+use App\Models\Tenant\Vehicle;
+use App\Models\Tenant\WorkOrder;
+use Illuminate\Support\Facades\Http;
+
+/**
+ * Multi-provider AI client (Claude / GPT / Gemini). Provider + API key are
+ * read from tenant settings.ai. Chat history persists in ai_chats/ai_messages.
+ */
+class AiAssistantService
+{
+    public function ask(AiChat $chat, string $userMessage): AiMessage
+    {
+        // Persist user message.
+        AiMessage::create([
+            'company_id' => $chat->company_id,
+            'ai_chat_id' => $chat->id,
+            'role' => 'user',
+            'content' => $userMessage,
+        ]);
+
+        $company = Company::withoutGlobalScopes()->findOrFail($chat->company_id);
+        $aiCfg = (array) ($company->settings['ai'] ?? []);
+        $provider = $chat->provider ?: ($aiCfg['default_provider'] ?? 'claude');
+        $apiKey = $aiCfg["{$provider}_key"] ?? null;
+
+        $start = microtime(true);
+
+        if (! $apiKey) {
+            $reply = '⚠️ API key pentru ' . strtoupper($provider) . ' nu e configurat. Mergi la Setări → AI și adaugă cheia.';
+            $meta = ['error' => 'no_api_key'];
+        } else {
+            try {
+                [$reply, $meta] = match ($provider) {
+                    'claude' => $this->callClaude($apiKey, $chat, $userMessage, $company),
+                    'gpt' => $this->callOpenAI($apiKey, $chat, $userMessage, $company),
+                    'gemini' => $this->callGemini($apiKey, $chat, $userMessage, $company),
+                    default => ['Provider necunoscut: ' . $provider, []],
+                };
+            } catch (\Throwable $e) {
+                $reply = '❌ Eroare API: ' . $e->getMessage();
+                $meta = ['error' => $e->getMessage()];
+            }
+        }
+
+        $meta['latency_ms'] = (int) ((microtime(true) - $start) * 1000);
+        $meta['provider'] = $provider;
+
+        $msg = AiMessage::create([
+            'company_id' => $chat->company_id,
+            'ai_chat_id' => $chat->id,
+            'role' => 'assistant',
+            'content' => $reply,
+            'meta' => $meta,
+        ]);
+
+        // Update chat title from first user message.
+        if ($chat->messages()->where('role', 'user')->count() === 1) {
+            $chat->update(['title' => mb_substr($userMessage, 0, 60)]);
+        }
+        $chat->touch();
+
+        return $msg;
+    }
+
+    protected function buildSystemPrompt(Company $company): string
+    {
+        $clientsCount = Client::count();
+        $vehiclesCount = Vehicle::count();
+        $newLeads = Lead::where('status', 'new')->count();
+        $openWO = WorkOrder::whereNotIn('status', ['done', 'cancelled'])->count();
+        $debtTotal = (float) WorkOrder::where('pay_status', '!=', 'paid')
+            ->whereNotIn('status', ['cancelled'])
+            ->get()->sum(fn ($w) => max(0, (float) $w->total - (float) $w->payments()->sum('amount')));
+
+        return <<<TXT
+Ești asistent CRM pentru autoservice "{$company->name}" din {$company->city}.
+Răspunzi în română (sau în limba folosită de utilizator). Fii concis, profesional, util.
+
+Statistici curente:
+- {$clientsCount} clienți, {$vehiclesCount} mașini
+- {$newLeads} cereri noi neprocesate
+- {$openWO} fișe de lucru active
+- Total datorii clienți: {$debtTotal} MDL
+
+Poți ajuta cu: sugestii diagnostic auto, calcul costuri, sumar performanță,
+recomandări piese, redactare mesaje pentru clienți, planificare. NU inventezi
+date care nu apar în context — dacă nu știi, recunoaște.
+TXT;
+    }
+
+    /** Convert chat history to provider-specific message format. */
+    protected function historyMessages(AiChat $chat, int $limit = 20): array
+    {
+        return $chat->messages()
+            ->latest('created_at')
+            ->limit($limit)
+            ->get()
+            ->reverse()
+            ->values()
+            ->map(fn (AiMessage $m) => ['role' => $m->role, 'content' => $m->content])
+            ->all();
+    }
+
+    protected function callClaude(string $key, AiChat $chat, string $msg, Company $company): array
+    {
+        $messages = $this->historyMessages($chat);
+        // Anthropic requires alternating user/assistant; system is separate.
+        $messages = array_values(array_filter($messages, fn ($m) => in_array($m['role'], ['user', 'assistant'], true)));
+
+        $r = Http::withHeaders([
+                'x-api-key' => $key,
+                'anthropic-version' => '2023-06-01',
+                'content-type' => 'application/json',
+            ])
+            ->timeout(60)
+            ->post('https://api.anthropic.com/v1/messages', [
+                'model' => 'claude-sonnet-4-5',
+                'max_tokens' => 1024,
+                'system' => $this->buildSystemPrompt($company),
+                'messages' => $messages,
+            ]);
+
+        if (! $r->successful()) {
+            return ['❌ ' . ($r->json('error.message') ?? 'Anthropic API error ' . $r->status()), ['status' => $r->status()]];
+        }
+
+        $body = $r->json();
+        $text = collect($body['content'] ?? [])
+            ->where('type', 'text')
+            ->pluck('text')
+            ->implode("\n");
+
+        return [$text ?: '(răspuns gol)', [
+            'model' => $body['model'] ?? null,
+            'tokens_in' => $body['usage']['input_tokens'] ?? null,
+            'tokens_out' => $body['usage']['output_tokens'] ?? null,
+        ]];
+    }
+
+    protected function callOpenAI(string $key, AiChat $chat, string $msg, Company $company): array
+    {
+        $messages = array_merge(
+            [['role' => 'system', 'content' => $this->buildSystemPrompt($company)]],
+            $this->historyMessages($chat),
+        );
+
+        $r = Http::withHeaders(['Authorization' => 'Bearer ' . $key, 'content-type' => 'application/json'])
+            ->timeout(60)
+            ->post('https://api.openai.com/v1/chat/completions', [
+                'model' => 'gpt-4o-mini',
+                'messages' => $messages,
+                'max_tokens' => 1024,
+            ]);
+
+        if (! $r->successful()) {
+            return ['❌ ' . ($r->json('error.message') ?? 'OpenAI error ' . $r->status()), ['status' => $r->status()]];
+        }
+        $body = $r->json();
+        return [
+            $body['choices'][0]['message']['content'] ?? '(răspuns gol)',
+            [
+                'model' => $body['model'] ?? null,
+                'tokens_in' => $body['usage']['prompt_tokens'] ?? null,
+                'tokens_out' => $body['usage']['completion_tokens'] ?? null,
+            ],
+        ];
+    }
+
+    protected function callGemini(string $key, AiChat $chat, string $msg, Company $company): array
+    {
+        $contents = [];
+        foreach ($this->historyMessages($chat) as $m) {
+            $contents[] = [
+                'role' => $m['role'] === 'assistant' ? 'model' : 'user',
+                'parts' => [['text' => $m['content']]],
+            ];
+        }
+
+        $r = Http::withHeaders(['content-type' => 'application/json'])
+            ->timeout(60)
+            ->post('https://generativelanguage.googleapis.com/v1beta/models/gemini-1.5-flash:generateContent?key=' . $key, [
+                'systemInstruction' => ['parts' => [['text' => $this->buildSystemPrompt($company)]]],
+                'contents' => $contents,
+                'generationConfig' => ['maxOutputTokens' => 1024],
+            ]);
+
+        if (! $r->successful()) {
+            return ['❌ Gemini error ' . $r->status() . ': ' . $r->body(), ['status' => $r->status()]];
+        }
+        $body = $r->json();
+        $text = $body['candidates'][0]['content']['parts'][0]['text'] ?? '(răspuns gol)';
+        return [$text, [
+            'model' => 'gemini-1.5-flash',
+            'tokens' => $body['usageMetadata'] ?? null,
+        ]];
+    }
+}