Jev で作る AI リードスコアリング：型安全 Score スキーマと CRM ルーティング

type LeadState = {
  company: string;
  employees: number;
  title: string;
  message: string;
  pricing_page_views_7d: number;
};

// ポリシーはプロンプトではなくアプリケーションコードに置く
const AUTO_ROUTE_MIN_SCORE = 3;
const AUTO_ROUTE_MIN_CONFIDENCE = 0.85;

export async function scoreLead(lead: LeadState) {
  const response = await fetch("https://api.typesafe.ai/v1/jev/evaluate", {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({
      state: lead,
      questions: {
        priority: {
          type: "score",
          instructions: "営業フォロー優先度を評価",
          criteria: {
            "1": "不適合",
            "2": "可能性あり",
            "3": "高適合",
            "4": "即フォロー",
          },
        },
        is_hot_lead: {
          type: "noul",
          instructions: "1営業時間以内に担当営業へ通知すべきか？",
        },
        segment: {
          type: "choice",
          instructions: "CRM セグメントを判定",
          criteria: {
            enterprise: "従業員500名以上",
            mid_market: "従業員50〜499名",
            smb: "従業員50名未満",
          },
        },
      },
    }),
  });
  if (!response.ok) throw new Error("Jev evaluate failed");
  const data = await response.json();

  const { priority, is_hot_lead, segment } = data;
  const confident = priority.confidence >= AUTO_ROUTE_MIN_CONFIDENCE;

  if (priority.answer >= AUTO_ROUTE_MIN_SCORE && confident) {
    return {
      route: is_hot_lead.answer ? "page_rep_now" : "crm_auto",
      priority: priority.answer,
      segment: segment.answer,
      confidence: priority.confidence,
    };
  }
  // スコアまたは確度がしきい値未満 → SDR レビューキューへ
  return {
    route: "sdr_review",
    priority: priority.answer,
    segment: segment.answer,
    confidence: priority.confidence,
  };
}

// 典型パス：1リードあたり ~95ms、入力トークンのみ課金、スキーマエラー 0%

import requests

JEV_ENDPOINT = "https://api.typesafe.ai/v1/jev/evaluate"
AUTO_ROUTE_MIN_SCORE = 3
AUTO_ROUTE_MIN_CONFIDENCE = 0.85

QUESTIONS = {
    "priority": {
        "type": "score",
        "instructions": "営業フォロー優先度を評価",
        "criteria": {
            "1": "不適合",
            "2": "可能性あり",
            "3": "高適合",
            "4": "即フォロー",
        },
    },
    "is_hot_lead": {
        "type": "noul",
        "instructions": "1営業時間以内に担当営業へ通知すべきか？",
    },
}

def score_lead(lead: dict) -> dict:
    resp = requests.post(
        JEV_ENDPOINT,
        json={"state": lead, "questions": QUESTIONS},
        timeout=5,
    )
    resp.raise_for_status()
    result = resp.json()
    priority = result["priority"]
    hot = result["is_hot_lead"]

    if (
        priority["answer"] >= AUTO_ROUTE_MIN_SCORE
        and priority["confidence"] >= AUTO_ROUTE_MIN_CONFIDENCE
    ):
        route = "page_rep_now" if hot["answer"] else "crm_auto"
    else:
        route = "sdr_review"

    return {
        "lead_id": lead.get("id"),
        "priority": priority["answer"],
        "confidence": priority["confidence"],
        "route": route,
    }

def score_batch(leads: list[dict]) -> list[dict]:
    # 1リード ~95ms: 夜間バッチで 1 万リードなら約 16 分で完了し、
    # CRM API のレート制限にも余裕で収まります。
    return [score_lead(lead) for lead in leads]