設計書: News Reminder + メールサマリー リニューアル

Issue #126 | 2026-03-16 | architect

1. 概要

News Reminder（金融ニュース）とメールダイジェストの Slack 投稿を以下の観点でリニューアルする。

1. 日付スレッド方式: 日付で親メッセージ → 詳細はスレッド内に返信
2. Block Kit フォーマット: 表・リンク・絵文字で視認性向上
3. News Reminder 頻度調整: 毎朝 → 平日のみに変更
4. メールダイジェストのスケジューラ組み込み
5. ニュースのカテゴリ明確化: 「金融ニュース」と明示

2. 日付スレッド方式の設計

2.1 仕組み

2.2 親メッセージ ts の管理

各チャンネル・日付ごとの親メッセージ ts を永続化し、同日再実行時に再利用する。

保存先

フォーマット

{
  "2026-03-16": {
    "channel_id": "C0123ABC",
    "ts": "1710561234.000100"
  }
}

古いエントリは30日超で自動削除（冪等性維持 + ファイル膨張防止）。

2.3 処理フロー

1. 今日の日付キーで thread_ts.json を検索
2. 見つかった → そのスレッドに返信（thread_ts 指定）
3. 見つからない →
   a. 親メッセージを投稿（Block Kit header）
   b. 返された ts を thread_ts.json に保存
   c. スレッドに詳細を返信

3. Block Kit フォーマット設計

3.1 News Reminder — 親メッセージ

Block Kit 構成:

[
  { "type": "header", "text": "📊 金融ニュースダイジェスト" },
  { "type": "section", "text": "2026-03-16（月）| 3銘柄 / 7件のニュース" }
]

3.2 News Reminder — スレッド返信（銘柄ごと）

Block Kit 構成（1銘柄 = 1返信メッセージ）:

[
  { "type": "header", "text": "{銘柄名}（{ティッカー}）" },
  { "type": "divider" },
  // ニュース1件ごとに section
  {
    "type": "section",
    "text": "⚠️ *<{url}|{要約}>* — {出典}\n→ 🔴 ネガティブ: {影響分析}"
  },
  // ... 最大3件
  { "type": "divider" },
  { "type": "context", "elements": [{ "type": "mrkdwn", "text": "💡 {銘柄別コメント}" }] }
]

3.3 News Reminder — 総合コメント（最後のスレッド返信）

3.4 メールダイジェスト — 親メッセージ

3.5 メールダイジェスト — スレッド返信（カテゴリごと）

Block Kit 構成（カテゴリごと = 1返信メッセージ。カテゴリ: 🔴 要対応 / 🟡 情報共有 / ⚪ 無視可能）:

[
  { "type": "header", "text": "🔴 要対応（{N}件）" },
  { "type": "divider" },
  // メール1件ごとに section
  {
    "type": "section",
    "text": "• *{送信者}* — {件名}\n  {要点}"
  },
  // ... 件数分
]

3.6 Claude CLI へのプロンプト変更

summarize.py と digest.py の要約プロンプトを変更し、JSON 形式で出力させる。Block Kit 組み立てはPython側で行う。

News Reminder — 新出力フォーマット

{
  "holdings": [
    {
      "ticker": "VOO",
      "name": "S&P 500",
      "articles": [
        {
          "summary": "FRBが利下げ見送りを示唆、市場に慎重ムード",
          "source": "Reuters",
          "url": "https://...",
          "impact": "negative",
          "impact_detail": "利下げ期待後退でインデックスに下押し圧力",
          "alert": true
        }
      ],
      "comment": "銘柄別の所感"
    }
  ],
  "overall_comment": "全体の総合コメント"
}

メールダイジェスト — 新出力フォーマット

{
  "categories": [
    {
      "level": "action_required",
      "emoji": "🔴",
      "label": "要対応",
      "items": [
        {
          "sender": "田中太郎",
          "subject": "契約書の確認依頼",
          "summary": "3月末までに署名が必要。添付PDFを確認のこと"
        }
      ]
    }
  ]
}

4. 変更対象ファイル一覧

5. 頻度調整の設計

5.1 News Reminder: 平日のみ（推奨案）

推奨: 案A（平日のみ）。金融ニュースという性質上、市場が動く平日のみで十分。土日は市場が休場で新着が少なく、月曜に週末分もまとめて配信される。

5.2 実装方法

# scheduler.py の news_scan 判定に曜日チェックを追加
import jpholiday  # 既にops依存にあり

def _is_business_day(d: date) -> bool:
    """平日（月〜金）かつ祝日でないか判定"""
    return d.weekday() < 5 and not jpholiday.is_holiday(d)

5.3 メールダイジェスト: 毎朝 8:00（現状維持 + スケジューラ追加）

メールは毎日届くため、頻度調整は不要。現在手動実行のみだが、スケジューラに追加して毎朝 8:00 に自動実行する。

既に実装済み: scheduler.py の _run_mail_filing が 8:00 に mail_filing.pipeline run を実行しているが、これは添付ファイル振り分け用。ダイジェストは別コマンドのため追加が必要。

# scheduler.py に追加
MAIL_DIGEST_HOUR = 8  # mail_filing と同時刻でOK（非同期で順次実行）

# run() ループ内に追加
if (
    now.hour == MAIL_DIGEST_HOUR
    and self._last_runs.get("mail_digest") != today
):
    self._last_runs["mail_digest"] = today
    self._save_last_runs()
    await self._run_mail_digest()

async def _run_mail_digest(self) -> None:
    """メールダイジェストを subprocess で実行する。"""
    proc = await asyncio.create_subprocess_exec(
        sys.executable, "-m", "mail_filing.pipeline", "digest",
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE,
        cwd=str(PROJECT_ROOT),
    )
    # ... タイムアウト・エラーハンドリングは _run_mail_filing と同様

6. Slack 送信方式の統一

現状3つの方式が混在している。

理由: Block Kit の blocks パラメータを正しく送信するには slack_sdk が確実。httpx 直書きは blocks の JSON シリアライズでミスが起きやすい。

7. 関数シグネチャ定義

7.1 notify.py（News Reminder）

from __future__ import annotations
from typing import TypedDict

class ArticleSummary(TypedDict):
    summary: str
    source: str
    url: str
    impact: str          # "positive" | "negative" | "neutral"
    impact_detail: str
    alert: bool          # ⚠️ マーク対象

class HoldingSummary(TypedDict):
    ticker: str
    name: str
    articles: list[ArticleSummary]
    comment: str

class NewsSummaryResult(TypedDict):
    holdings: list[HoldingSummary]
    overall_comment: str

# ts管理
def _load_thread_ts(data_dir: Path) -> dict[str, dict]:
    """thread_ts.json を読み込む。30日超のエントリは削除。"""

def _save_thread_ts(data_dir: Path, ts_data: dict[str, dict]) -> None:
    """thread_ts.json を保存する。"""

def _get_or_create_thread(
    client: WebClient,
    channel: str,
    date_str: str,
    data_dir: Path,
) -> str:
    """日付スレッドの ts を取得。なければ親メッセージを投稿して作成。"""

# メイン
def run(cfg: PipelineConfig, summary: NewsSummaryResult) -> None:
    """要約結果を日付スレッド方式・Block Kit で Slack に投稿する。"""

7.2 summarize.py（News Reminder）

# 返り値の変更
async def run(cfg: PipelineConfig) -> NewsSummaryResult | None:
    """取得済みニュースを Claude CLI で要約する。構造化された辞書を返す。"""

# プロンプトにJSON出力指示を追加
# Claude CLI の出力を json.loads() でパース
# パース失敗時は最大1回リトライ（プロンプトに「JSONのみ出力せよ」を強調）

7.3 digest.py（メールダイジェスト）

from __future__ import annotations
from typing import TypedDict

class DigestItem(TypedDict):
    sender: str
    subject: str
    summary: str

class DigestCategory(TypedDict):
    level: str       # "action_required" | "info" | "ignorable"
    emoji: str       # "🔴" | "🟡" | "⚪"
    label: str       # "要対応" | "情報共有" | "無視可能"
    items: list[DigestItem]

class DigestResult(TypedDict):
    categories: list[DigestCategory]

# ts管理（notify.py と同じパターン）
def _load_thread_ts() -> dict[str, dict]: ...
def _save_thread_ts(ts_data: dict[str, dict]) -> None: ...
def _get_or_create_thread(
    client: WebClient,
    channel: str,
    date_str: str,
    mailbox_name: str,
) -> str: ...

# 要約結果のパース
def _parse_summary(raw: str) -> DigestResult: ...

# Block Kit 組み立て
def _build_category_blocks(cat: DigestCategory) -> list[dict]: ...

# Slack投稿（httpx → slack_sdk.WebClient に変更）
def _post_to_slack(
    client: WebClient,
    channel: str,
    thread_ts: str,
    blocks: list[dict],
    text: str,
) -> None: ...

8. データフロー

8.1 News Reminder

fetch (既存)
  → fetched.json（中間データ）
    → summarize.py（Claude CLI）
      → NewsSummaryResult（構造化dict）
        → notify.py
          → 1. thread_ts.json 確認/作成
          → 2. 親メッセージ投稿（or 既存スレッド取得）
          → 3. 銘柄ごとにスレッド返信（Block Kit）
          → 4. 総合コメントをスレッド返信
          → 5. 通知済み記録

8.2 メールダイジェスト

Graph API（未読メール取得）
  → _build_mail_text()
    → Claude CLI（要約）
      → DigestResult（構造化dict）
        → 1. digest_thread_ts.json 確認/作成
        → 2. 親メッセージ投稿（or 既存スレッド取得）
        → 3. カテゴリごとにスレッド返信（Block Kit）
        → 4. 処理済み記録

9. エラーハンドリング

10. scheduler.py 変更詳細

10.1 News Reminder: 平日判定の追加

# run() ループ内の news_scan 条件を変更
if (
    now.hour == self.scan_hour
    and self._last_runs.get("news_scan") != today
    and _is_business_day(today)  # ← 追加
):
    ...

10.2 メールダイジェストのスケジューラ追加

# 定数追加
MAIL_DIGEST_HOUR = 8

# run() ループ内に追加
if (
    now.hour == MAIL_DIGEST_HOUR
    and self._last_runs.get("mail_digest") != today
):
    self._last_runs["mail_digest"] = today
    self._save_last_runs()
    await self._run_mail_digest()

_run_mail_digest() は _run_mail_filing() と同じパターンで python -m mail_filing.pipeline digest を subprocess 実行する。

10.3 ログ出力の改善

# 起動ログにmail_digestも追加
log.info(
    "DailyScheduler 起動: news_scan=%02d:00(平日), mail_filing=%02d:00, mail_digest=%02d:00",
    self.scan_hour, MAIL_FILING_HOUR, MAIL_DIGEST_HOUR,
)

11. AI News スキャン（scheduler.py 内）への影響

scheduler.py の _post_summary() と _ask_if_to_evaluate() は AI News スキャン結果（#ai-ops チャンネル）用であり、今回の金融ニュース（#news-reminder）とは別系統。変更不要。

12. 前提条件・制約

• Slack Block Kit の 50 ブロック/メッセージ制限 → 銘柄/カテゴリごとに別メッセージで回避済み
• Claude CLI の JSON 出力は 100% 保証されない → フォールバック機構を設計
• jpholiday パッケージが利用可能であること（既存依存に含まれる）
• thread_ts.json は各パイプラインの data/ ディレクトリに保存（既存のデータ管理パターンに合わせる）
• notify.py のパイプライン呼び出し元（__main__.py 等）で summary の型変更に追従が必要

13. トレードオフ・検討した代替案

13.1 Claude CLI の出力形式

13.2 thread_ts の管理方法

13.3 Slack送信方式の統一範囲