Sales CRM ドメインイベントカタログ / Domain Events Catalog

Sales CRM で発生するドメインイベントの一覧。 イベント名・トリガー・ペイロード・購読者を定義する。

→ 対応ドメイン: docs/ddd/pms/04-domain-events.md (PMS 側のイベントカタログ)

---

凡例

---

1. 営業パイプライン (Sales Pipeline)

内部イベント

PMS 連携イベント (送信)

deal.won → CreateOrderRequest ペイロード

interface CreateOrderRequest {
  customer_code: string;       // Account の PMS 連携コード
  order_date: string;          // ISO 8601
  due_date: string;            // 納期
  line_items: {
    product_code: string;      // PMS 製品コード
    quantity: number;
    unit_price: number;
    description?: string;
  }[];
  total_amount: number;
  correlation_id: string;      // Deal.id (トレーサビリティ用)
  schema_version: string;      // コントラクトバージョン
}

---

2. PMS → Sales CRM (受信イベント)

PMS から Webhook 経由で受信するドメインイベント。

イベント処理フロー

PMS (Webhook)
  │
  ▼
webhookAuth.ts (HMAC 署名検証)
  │
  ▼
eventProcessor.ts (イベントルーティング)
  │
  ├─▶ ProductionTracking 作成/更新
  │
  └─▶ Deal.productionTracking 仮想フィールド (afterRead)

受信イベント一覧

DomainEvent ペイロード (受信)

interface DomainEvent {
  event_id: number;            // 連番 (冪等性チェック用)
  event_type: string;          // EventType
  correlation_id: string;      // Deal.id or Order No
  occurred_at: string;         // ISO 8601
  actor_id: string;            // PMS ユーザー ID
  version: number;             // スキーマバージョン
  payload: {
    order_number: string;      // PMS オーダー番号
    work_order_id?: number;    // 作業指示 ID
    work_type?: string;        // 作業種別
    completed_qty?: number;    // 完了数
    defect_qty?: number;       // 不良数
    scheduled_date?: string;   // 予定日
    actual_completion_date?: string;  // 実完了日
    [key: string]: unknown;
  };
}

冪等性 (Idempotency)

イベント処理は冪等性を保証:

• lastEventId で処理済みイベントをスキップ
• event_id <= lastEventId の場合は { processed: false } を返す
• 未知のイベントタイプはログ出力のみ (クラッシュしない)

---

3. レポート・分析 (Reporting)

レポートは読取専用プロジェクションのため、状態変更イベントは発生しない。 report.generated は監査・利用状況追跡目的のオプショナルイベント。

comment.added ペイロード

interface CommentAddedEvent {
  dealId: string;           // 対象案件 ID
  commentId: string;        // 新規コメント ID
  authorId: string;         // 投稿者 ID
  body: string;             // コメント本文 (truncated)
  occurredAt: string;       // ISO 8601
}

---

3.5 見積管理 (Quote Management)

quote.issued ペイロード

interface QuoteIssuedEvent {
  quoteId: string;          // 見積書 ID
  quoteNumber: string;      // 見積番号
  dealId: string;           // 関連案件 ID
  accountId: string;        // 宛先取引先 ID
  totalAmount: number;      // 合計金額
  fileId: string;           // 生成された PDF の File ID
  occurredAt: string;       // ISO 8601
}

---

3.6 目標管理 (Goal Tracking)

Goal Tracking は読取専用投影に近い性質のため、状態変更イベントは最小限。 goal.evaluated は目標達成率の監査・通知目的のオプショナルイベント。

goal.evaluated ペイロード

interface GoalEvaluatedEvent {
  goalId: string;           // 目標項目 ID
  userId: string;           // 対象ユーザー ID (全体目標時は null)
  periodStart: string;      // 期間開始日 (ISO 8601)
  periodEnd: string;        // 期間終了日 (ISO 8601)
  targetValue: number;      // 目標値
  actualValue: number;      // 実績値
  achievementRate: number;  // 達成率 (%)
  occurredAt: string;       // ISO 8601
}

---

3.7 重複検出 (Duplicate Detection)

duplicate.detected ペイロード

interface DuplicateDetectedEvent {
  entityType: string;       // account / contact
  sourceId: string;         // 元レコード ID
  targetId: string;         // 重複候補 ID
  similarityScore: number;  // 類似度スコア
  occurredAt: string;       // ISO 8601
}

---

3.8 カレンダー連携 (Calendar Sync)

---

3.9 メール取り込み (Email Capture)

email.captured ペイロード

interface EmailCapturedEvent {
  emailAddress: string;     // 送信元メールアドレス
  contactId: string;        // マッチした Contact ID
  activityId: string;       // 作成された Activity ID
  subject: string;          // メール件名
  occurredAt: string;       // ISO 8601
}

---

4. 監査イベント (Audit Events)

全コレクション共通の監査フィールド自動設定。

全コレクションの beforeChange フックで自動的に監査フィールドを設定:

// applyAuditFields の処理
if (operation === "create") {
  data.createdBy = req.user.id;
}
data.updatedBy = req.user.id;

---

5. 楽観ロックイベント (Conflict Events)

// 409 応答ペイロード
{
  latestData: { /* 最新レコード全体 */ },
  modifiedBy: "user-id",
  modifiedAt: "2026-01-25T10:30:00Z"
}

---

6. 製造進捗ステータス遷移図

ProductionTracking コレクション