Claude API で『解約されにくい』マイクロSaaS を作る — 月10万円を安定生産する6つの実装パターン

// Cloudflare Workers + KV を前提とした月次レポート生成
import Anthropic from "@anthropic-ai/sdk";
 
interface UsageStats {
  email: string;
  requestCount: number;
  tokensTotal: number;
  estimatedManualHours: number; // 人が同じ作業をした場合の想定時間
}
 
async function generateMonthlyReport(env: Env, stats: UsageStats): Promise<string> {
  const anthropic = new Anthropic({ apiKey: env.ANTHROPIC_API_KEY });
  try {
    const message = await anthropic.messages.create({
      model: "claude-sonnet-4-6",
      max_tokens: 400,
      messages: [
        {
          role: "user",
          content: `次のユーザー利用統計から、購読を続けたくなる『価値レポート』を3行以内の日本語で作成してください。誇張せず、具体的な数字を必ず含めること。
リクエスト数: ${stats.requestCount}
トークン総数: ${stats.tokensTotal}
人手なら ${stats.estimatedManualHours} 時間相当`,
        },
      ],
    });
    const block = message.content[0];
    return block.type === "text" ? block.text : "";
  } catch (error) {
    // 失敗時はテンプレ文に切り替え（ユーザー側のメール送信は止めない）
    console.error("Report generation failed:", error);
    return `今月は ${stats.requestCount} 件のリクエストを処理しました（推定 ${stats.estimatedManualHours} 時間相当）。`;
  }
}

// ダッシュボードに表示する累積価値の取得
interface AccumulatedValue {
  totalProcessed: number;
  firstUsedAt: string;
  topUseCases: { label: string; count: number }[];
  estimatedSavedHours: number;
}
 
async function getAccumulatedValue(env: Env, userId: string): Promise<AccumulatedValue> {
  const raw = await env.USER_STATS.get(`accumulated:${userId}`, "json");
  if (!raw) {
    return {
      totalProcessed: 0,
      firstUsedAt: new Date().toISOString(),
      topUseCases: [],
      estimatedSavedHours: 0,
    };
  }
  return raw as AccumulatedValue;
}
 
// ダッシュボード表示用の文章を Claude で1行に
async function summarizeAccumulation(
  env: Env,
  value: AccumulatedValue
): Promise<string> {
  const anthropic = new Anthropic({ apiKey: env.ANTHROPIC_API_KEY });
  const message = await anthropic.messages.create({
    model: "claude-haiku-4-5-20251001",
    max_tokens: 120,
    messages: [
      {
        role: "user",
        content: `以下のユーザー累積データを、本人が誇らしく感じる1行のサマリーに変換してください。日本語、80文字以内。
初回利用: ${value.firstUsedAt}
処理件数: ${value.totalProcessed}
節約時間: ${value.estimatedSavedHours} 時間`,
      },
    ],
  });
  const block = message.content[0];
  return block.type === "text" ? block.text : "";
}

// 毎日0:00 JST に走る Cron Trigger
export default {
  async scheduled(_event: ScheduledEvent, env: Env): Promise<void> {
    const candidates = await env.DB.prepare(
      `SELECT user_id, email, last_login_at, last_action_at
       FROM users
       WHERE last_action_at < datetime('now', '-7 days')
         AND last_login_at >= datetime('now', '-14 days')
         AND churn_email_sent_at IS NULL`
    ).all<{ user_id: string; email: string; last_login_at: string; last_action_at: string }>();
 
    for (const user of candidates.results ?? []) {
      try {
        await sendChurnPreventionEmail(env, user);
        await env.DB.prepare(
          "UPDATE users SET churn_email_sent_at = datetime('now') WHERE user_id = ?"
        ).bind(user.user_id).run();
      } catch (error) {
        console.error(`Churn email failed for ${user.user_id}:`, error);
        // 失敗しても他ユーザーへの送信は続ける
      }
    }
  },
};
 
async function sendChurnPreventionEmail(env: Env, user: { email: string; last_action_at: string }) {
  // 件名は固定、本文だけ Claude API でユーザーごとにパーソナライズ
  const anthropic = new Anthropic({ apiKey: env.ANTHROPIC_API_KEY });
  const body = await anthropic.messages.create({
    model: "claude-haiku-4-5-20251001",
    max_tokens: 250,
    messages: [
      {
        role: "user",
        content: `休眠ユーザーへの『そっと再訪を促す』メール本文を日本語で書いてください。最終利用 ${user.last_action_at}。営業色は出さず、相手の状況を尊重するトーンで。`,
      },
    ],
  });
  const block = body.content[0];
  const text = block.type === "text" ? block.text : "";
  await env.MAIL.send({ to: user.email, subject: "最近どうですか？", text });
}

// Workers から SSE でストリーミング応答
export async function streamHandler(request: Request, env: Env): Promise<Response> {
  const { prompt } = await request.json<{ prompt: string }>();
  const anthropic = new Anthropic({ apiKey: env.ANTHROPIC_API_KEY });
 
  const stream = await anthropic.messages.stream({
    model: "claude-sonnet-4-6",
    max_tokens: 1000,
    messages: [{ role: "user", content: prompt }],
  });
 
  const encoder = new TextEncoder();
  const readable = new ReadableStream({
    async start(controller) {
      try {
        for await (const event of stream) {
          if (event.type === "content_block_delta" && event.delta.type === "text_delta") {
            controller.enqueue(encoder.encode(`data: ${JSON.stringify({ text: event.delta.text })}\n\n`));
          }
        }
        controller.close();
      } catch (err) {
        controller.enqueue(encoder.encode(`data: ${JSON.stringify({ error: String(err) })}\n\n`));
        controller.close();
      }
    },
  });
 
  return new Response(readable, {
    headers: { "Content-Type": "text/event-stream", "Cache-Control": "no-cache" },
  });
}

// 解約フロー前の引き留め画面 — 一時停止オプションを提示
interface CancelIntent {
  customerId: string;
  reason: "too_expensive" | "not_using" | "found_alternative" | "other";
}
 
async function offerRetention(env: Env, intent: CancelIntent): Promise<{ action: string }> {
  const stripe = new Stripe(env.STRIPE_SECRET_KEY);
  switch (intent.reason) {
    case "too_expensive":
      // 30日間 50% オフのクーポンを発行
      await stripe.subscriptions.update(await getSubId(env, intent.customerId), {
        coupon: "RETENTION_50_30D",
      });
      return { action: "discount_applied" };
    case "not_using":
      // 1か月の支払い停止（Pause Collection）
      await stripe.subscriptions.update(await getSubId(env, intent.customerId), {
        pause_collection: { behavior: "void", resumes_at: Math.floor(Date.now() / 1000) + 30 * 86400 },
      });
      return { action: "paused_for_30_days" };
    default:
      return { action: "none" };
  }
}