Реализация Lead Scoring (оценка лидов) на сайте

Реализация системы лид-скоринга на сайте

Лид-скоринг — присвоение числового балла каждому лиду на основе демографических данных и поведения. Позволяет менеджерам по продажам сосредоточиться на горячих лидах и автоматически передавать их в CRM при достижении порога.

Модель данных

// Схема таблиц
Schema::create('lead_scores', function (Blueprint $table) {
    $table->id();
    $table->foreignId('user_id')->nullable()->constrained()->nullOnDelete();
    $table->string('session_id')->index();
    $table->string('email')->nullable()->index();
    $table->integer('score')->default(0);
    $table->json('score_breakdown');      // {"pricing_visit": 15, "demo_watched": 25}
    $table->string('stage')->default('cold');  // cold, warm, hot, mql, sql
    $table->timestamp('mql_reached_at')->nullable();
    $table->timestamp('qualified_at')->nullable();
    $table->timestamps();
    $table->index(['score', 'stage']);
});

Schema::create('lead_events', function (Blueprint $table) {
    $table->id();
    $table->foreignId('lead_score_id')->constrained()->cascadeOnDelete();
    $table->string('event');
    $table->integer('points');
    $table->json('metadata')->nullable();
    $table->timestamps();
});

Конфигурация баллов

// config/lead_scoring.php
return [
    'events' => [
        // Поведенческие сигналы
        'page_view_pricing'          => 15,
        'page_view_case_study'       => 10,
        'page_view_demo'             => 20,
        'demo_requested'             => 50,
        'whitepaper_downloaded'      => 20,
        'webinar_registered'         => 25,
        'free_trial_started'         => 40,
        'pricing_calculator_used'    => 30,
        'comparison_page_viewed'     => 15,
        'contact_form_submitted'     => 40,

        // Engagement
        'email_opened'               => 5,
        'email_clicked'              => 10,
        'return_visit'               => 5,
        'visited_3_days_in_row'      => 15,

        // Fit-сигналы (через форму)
        'company_size_50_plus'       => 20,
        'role_decision_maker'        => 25,
        'budget_confirmed'           => 30,

        // Негативные сигналы
        'unsubscribed'               => -20,
        'inactive_30_days'           => -10,
        'student_email_domain'       => -25,
    ],

    'thresholds' => [
        'warm' => 30,
        'hot'  => 60,
        'mql'  => 80,   // Marketing Qualified Lead → передаётся в CRM
        'sql'  => 100,  // Sales Qualified Lead → немедленный звонок менеджера
    ],
];

Сервис скоринга

class LeadScoringService
{
    public function track(string $sessionId, string $event, array $metadata = [], ?int $userId = null): LeadScore
    {
        $points = config("lead_scoring.events.{$event}", 0);

        $lead = LeadScore::firstOrCreate(
            ['session_id' => $sessionId],
            ['user_id' => $userId, 'score_breakdown' => []]
        );

        if ($userId && !$lead->user_id) {
            $lead->update(['user_id' => $userId]);
        }

        // Идентификация по email из metadata
        if (!empty($metadata['email']) && !$lead->email) {
            $lead->update(['email' => $metadata['email']]);
        }

        // Некоторые события засчитываем только раз
        $onceEvents = ['demo_requested', 'free_trial_started', 'contact_form_submitted'];
        if (in_array($event, $onceEvents)) {
            if (LeadEvent::where('lead_score_id', $lead->id)->where('event', $event)->exists()) {
                return $lead;
            }
        }

        // Записываем событие
        LeadEvent::create([
            'lead_score_id' => $lead->id,
            'event'         => $event,
            'points'        => $points,
            'metadata'      => $metadata,
        ]);

        // Обновляем счёт и breakdown
        $breakdown = $lead->score_breakdown ?? [];
        $breakdown[$event] = ($breakdown[$event] ?? 0) + $points;

        $newScore = $lead->score + $points;
        $newStage = $this->calculateStage($newScore);

        $lead->update([
            'score'           => $newScore,
            'score_breakdown' => $breakdown,
            'stage'           => $newStage,
        ]);

        // Триггеры при достижении порогов
        $thresholds = config('lead_scoring.thresholds');
        $prevStage  = $this->calculateStage($lead->score - $points);

        if ($newStage !== $prevStage) {
            $this->onStageChange($lead, $prevStage, $newStage);
        }

        return $lead->fresh();
    }

    private function calculateStage(int $score): string
    {
        $thresholds = config('lead_scoring.thresholds');
        if ($score >= $thresholds['sql'])  return 'sql';
        if ($score >= $thresholds['mql'])  return 'mql';
        if ($score >= $thresholds['hot'])  return 'hot';
        if ($score >= $thresholds['warm']) return 'warm';
        return 'cold';
    }

    private function onStageChange(LeadScore $lead, string $from, string $to): void
    {
        Log::info("Lead stage change: {$from} → {$to}", ['lead_id' => $lead->id, 'score' => $lead->score]);

        if ($to === 'mql') {
            $lead->update(['mql_reached_at' => now()]);
            // Передаём в CRM
            SyncLeadToCrm::dispatch($lead);
            // Уведомление маркетингу
            Notification::route('slack', '#leads-hot')
                ->notify(new MqlReachedNotification($lead));
        }

        if ($to === 'sql') {
            $lead->update(['qualified_at' => now()]);
            // Немедленное уведомление менеджеру продаж
            $salesManager = User::salesManager()->inRandomOrder()->first();
            $salesManager?->notify(new SqlLeadAssigned($lead));
        }
    }
}

Frontend: отслеживание событий

// lib/lead-tracking.ts
class LeadTracker {
  private sessionId: string;

  constructor() {
    this.sessionId = sessionStorage.getItem('ls_session') || this.generateId();
    sessionStorage.setItem('ls_session', this.sessionId);
  }

  async track(event: string, metadata: Record<string, any> = {}): Promise<void> {
    try {
      await fetch('/api/lead-score/track', {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({
          session_id: this.sessionId,
          event,
          metadata: { ...metadata, page: window.location.pathname },
        }),
      });
    } catch (e) {
      // Не блокируем UI при ошибке трекинга
    }
  }

  private generateId(): string {
    return Date.now().toString(36) + Math.random().toString(36).substr(2);
  }
}

export const tracker = new LeadTracker();

// Использование:
// Просмотр страницы цен
tracker.track('page_view_pricing');

// Просмотр демо-видео (> 60 секунд)
videoElement.addEventListener('timeupdate', () => {
  if (videoElement.currentTime > 60 && !trackedDemo) {
    trackedDemo = true;
    tracker.track('demo_watched');
  }
});

// Скачивание whitepaper
function downloadWhitepaper(email: string) {
  tracker.track('whitepaper_downloaded', { email });
}

Dashboard для менеджеров

-- Горячие лиды за последние 7 дней
SELECT
  ls.email,
  ls.score,
  ls.stage,
  ls.mql_reached_at,
  COUNT(le.id) AS events_count,
  MAX(le.created_at) AS last_activity
FROM lead_scores ls
JOIN lead_events le ON le.lead_score_id = ls.id
WHERE ls.stage IN ('mql', 'sql', 'hot')
  AND ls.mql_reached_at >= now() - interval '7 days'
GROUP BY ls.id, ls.email, ls.score, ls.stage, ls.mql_reached_at
ORDER BY ls.score DESC;

Сроки

Система лид-скоринга с конфигурируемыми правилами, CRM-интеграцией и дашбордом: 8–12 рабочих дней.