lead-import

/digital-marketing-pro:lead-import

スクリプトの場所。 ホストで ${CLAUDE_PLUGIN_ROOT} が設定されていない場合、スクリプトはこのプラグインの scripts/ フォルダーにあり、skills/ と同じ階層にあります。Python 3.10 以降で実行してください。python が見つからない場合は、python の代わりに python3 を使用してください（macOS、多くの Linux システム）。

目的

データ検証、重複排除、リードスコアリング、適切な同意追跡を行いながら、ブランドの CRM にリードをインポートします。CSV ファイル、JSON 配列、手動入力に対応し、ソースを自動的に関連付けます。インポートしたすべてのリードが、営業チームに届く前にデータを整理され、スコア付けと重複排除が行われ、コンプライアンスに準拠していることを確認します。これにより、リードから商談への転換を遅らせる、手作業でのデータ整備をなくします。マーケティングオートメーションのリードスコアリングフレームワークと連携して、インポート時にリードを分類します。そのため、価値の高い見込み客はすぐに営業に引き継がれ、スコアの低いリードは自動的にナーチャリングシーケンスに登録されます。

このコマンドは、スコアリング、ライフサイクルの段階設定、ナーチャリングへの登録を適用するため、リード専用に使用してください。リードスコアリングを行わずに CRM データ（連絡先、取引、キャンペーン）を一般的に同期する場合は、代わりに /digital-marketing-pro:crm-sync を使用してください。

実行ゲート（必須 — 省略不可）

1. 実際のシステムに触れる前に、受信者／費用／変更内容／コンプライアンスを含むプレビュー全体を 実行サマリー として提示します。
2. ユーザーは yes（または同等の明示的な承認）を入力する必要があります。それ以外の入力（曖昧なもの、暗黙のもの、一部のみの承認、承認なし）は、いずれも実行をキャンセルします。
3. 曖昧な入力に基づいて処理を進めてはいけません。失敗した実行を自動的に再試行してはいけません。再実行する前に、人による確認が必要です。
4. ユーザーが yes と入力した後に限り、これを記録します。python "${CLAUDE_PLUGIN_ROOT}/scripts/approval-manager.py" --brand {slug} --action create-approval --data '{"type":"lead-import","platform":"<platform>","content_summary":"<one line from the Execution Summary>","risk_level":"<tier>"}' を実行し、続けて python "${CLAUDE_PLUGIN_ROOT}/scripts/approval-manager.py" --brand {slug} --action approve --id {approval_id} を実行します。どちらかのコマンドでエラーが発生した場合は、処理を止めてエラーを報告してください。他のツールで回避してはいけません。この記録は、このアクションで承認手順が実行されたことを証明しますが、誰が yes と入力したかまでは証明できません。
5. 実行します。connector_executor.py を介して送信する書き込みには --approval-id が必要で、一致する未使用かつ有効期限内の記録がある場合にのみ実行されます（/digital-marketing-pro:execute-action を参照）。接続済みの MCP サーバーのツールを介した書き込みは、このコードチェックの対象外です。入力された yes と、ホストの権限確認プロンプトに依存します。実行後、python "${CLAUDE_PLUGIN_ROOT}/scripts/approval-manager.py" --brand {slug} --action mark-executed --id {approval_id} --data '{"execution_result":"success"}'（または failure）を実行します。

必要な入力情報

ユーザーは次の情報を提供する必要があります（または入力を求められます）。

• リードデータ：CSV ファイルのパス、JSON 配列、または手動でのフィールド入力。重複排除と本人確認のため、メールアドレスまたは電話番号を最低 1 つ含める必要があります
• ソースの帰属情報：リードの獲得元。フォーム名、イベント名、キャンペーン識別子、ランディングページの URL、広告プラットフォームとキャンペーン、パートナーからの紹介、ウェビナー登録、または手動での見込み顧客開拓など
• リードスコアのしきい値（任意）：マーケティング適格リード（MQL）としてインポートする際の最低スコア。しきい値を下回るリードは、優先度を下げたルーティングで未評価のリードとしてインポートされます
• CRM プラットフォーム：インポート先の CRM（Salesforce、HubSpot、Zoho、Pipedrive）と、具体的なオブジェクトタイプ（Lead、Contact、または各プラットフォームに相当するもの）
• 必須フィールド：インポートで必須となるフィールド。メールアドレス、名、姓、会社名、電話番号、役職、またはビジネスの適格性基準に固有のカスタムフィールドなど
• 同意ステータス：リードがオプトインの同意を提供しているかどうか、同意の取得方法（シングルオプトイン、ダブルオプトイン、正当な利益、契約上の必要性）、および適用されるプライバシー規制（GDPR、CCPA、CASL）
• 割り当てルール（任意）：インポートしたリードの割り当て方法。担当者間でのラウンドロビン、地域に基づくテリトリー別、製品ライン別、会社規模の階層別、または手動配分のために特定の担当者へ割り当てる方法など
• 重複の処理方法：重複が見つかった場合の処理。既存レコードを新しいデータで更新する、重複を完全にスキップする、特定のフィールドを統合する（例：既存の担当者は維持しつつ新しいソースを追加する）、または元のレコードに関連付けた別のレコードを作成する方法など
• リードのライフサイクルステージ：割り当てる初期ステータス。新規リード、マーケティング適格、営業受け入れ済み、またはブランドのライフサイクルモデルにおけるカスタムステージ
• タグ付けとリスト登録（任意）：インポートしたリードに関連付けるタグ、リスト、またはキャンペーン。後続のセグメンテーションとレポートに使用します
• 通知設定（任意）：新しいリードについて、割り当てられた営業担当者にすぐ通知するかどうか、またその通知チャネル（CRM 通知、メール、Slack）。高スコアの MQL には優先フラグを設定できます
• ナーチャリングシーケンスのトリガー（任意）：インポートしたリードを、スコア階層、ソース、またはライフサイクルステージに基づいて既存のナーチャリングシーケンスに自動登録するかどうか
• カスタムスコアの上書き（任意）：特定のリードソースに対する手動でのスコア調整。例：イベントからのリードには +20 点、パートナーからの紹介には +15 点を加算します。標準のスコアリングモデルに上乗せして適用します
• インポート頻度：一度限りのインポートか、定期的にデータを提供するソースか。定期的な場合は、インポート用テンプレートを作成するため、想定される頻度（毎日のフォーム送信、毎週のイベントエクスポート、毎月のパートナーリストなど）を指定してください

プロセス

1. ブランドのコンテキストを読み込む: ~/.claude-marketing/brands/_active-brand.json を読み、アクティブなスラッグを確認してから、~/.claude-marketing/brands/{slug}/profile.json を読み込みます。ブランドのトーン、ターゲット市場向けのコンプライアンスルール（skills/context-engine/compliance-rules.md）、業界のコンテキストを適用します。ガイドラインも確認してください：~/.claude-marketing/brands/{slug}/guidelines/_manifest.json が存在する場合は、制限事項と関連するカテゴリファイルを読み込みます。~/.claude-marketing/sops/ に代理店の SOP がないか確認します。ブランドが存在しない場合は、「先にブランドを設定しますか（/digital-marketing-pro:brand-setup）？」と尋ねるか、デフォルト設定で進めます。
2. リードデータを解析して検証する: 入力データソースを読み込み、すべてのレコードを検証します。メール形式（RFC 5322）を確認し、電話番号を E.164 形式に正規化し、必須フィールドがそろっているかを確認し、エンコーディングの問題を検出し、明らかに偽のエントリ（[email protected]、info@ などの役割ベースのメールアドレス）を特定し、不正な形式または不完全なレコードには具体的なエラー理由を付けてフラグを立てます。
3. フィールドを正規化して補完する: 会社名、役職、地理データを標準化します。一貫した形式を適用します。氏名はタイトルケース、メールアドレスは小文字、国と州のコードは標準形式にします。可能な場合は、利用可能なデータから不足フィールドを推測します（例：メールアドレスから会社のドメイン、電話番号の国番号から国）。
4. リードごとに重複を確認する: 各リードについて、メールアドレス、電話番号、または複合キーで一致する既存レコードがないか、対象 CRM に問い合わせます。結果を、新規（該当なし）、完全一致の重複（メールアドレスと氏名が同じ）、類似一致（氏名またはドメインが類似）、データ補完の機会（このリードで不足フィールドを補える既存レコード）に分類します。
5. リードスコアリングフレームワークでリードをスコアリングする: skills/marketing-automation/lead-scoring.md にあるマーケティングオートメーションのリードスコアリングモデルを適用します。デモグラフィック適合度（役職の職位、会社規模、業界の一致）、行動シグナル（ソースの質、コンテンツへのエンゲージメント、インタラクションの新しさ）、エンゲージメントの可能性に基づいてスコアを付けます。しきい値に基づいて、各リードを MQL、未加工リード、ナーチャー候補に分類します。
6. 同意とコンプライアンスを検証する: 各リードの同意状況を、ブランドのターゲット市場向けコンプライアンスルールに照らして確認します。オプトインの仕組みが記録されていることを確認し、同意記録にタイムスタンプを付与し、必須の同意フィールドがないリードにフラグを立て、適用される規制（GDPR 第 6 条、CCPA、CASL）に基づく適法なデータ処理の根拠が記録されていることを確認します。
7. ソースアトリビューションを付けて CRM 登録用のペイロードを準備する: 検証済みリードをプラットフォーム固有のペイロードに変換します。フィールドを CRM スキーマにマッピングし、ソースアトリビューション（utm_source、utm_medium、utm_campaign）を付与し、割り当てルールを適用し、リードのステータスとライフサイクルステージを設定し、タグとリストへの登録を追加して、カスタムフィールドとしてリードスコアを含めます。
8. 承認ゲートを設ける: リスクレベルを評価します。リードが 50 件未満の場合は中、50 件以上の場合は高とします。リード総数、有効・無効の内訳、スコア付きのサンプルレコード上位 5 件、スコア分布（MQL／未加工／ナーチャーの件数）、重複の概要、コンプライアンス状況、検証に関する警告を示すインポートプレビューを提示します。
9. 承認後、CRM MCP 経由でインポートする: プラットフォーム MCP を通じて、リードのペイロードをバッチリクエストで対象 CRM に送信します。レート制限には指数バックオフで対処し、プラットフォームに到達していないことが明確に証明できる書き込み（接続拒否、DNS エラー、または 429 のレート制限拒否）のみを再試行します。タイムアウトまたは応答の消失後は、まずプラットフォーム上でレコードを検索し（メールアドレスまたは外部 ID を使用）、不足分のみを再送します。割り当てルールを適用し、CRM 側の自動化（ウェルカムワークフロー、担当者への通知）をトリガーして、各リードのインポート結果を記録します。
10. 通知とナーチャー登録をトリガーする: スコアの高い MQL については、リードの詳細と推奨される次のアクションを添えて、割り当てられた担当者にすぐ通知します。ナーチャー対象のリードは、メールプラットフォーム MCP 経由で指定されたナーチャーシーケンスに登録します。トリガーした自動化はすべて記録します。
11. インポートの整合性を検証する: インポート後に CRM に問い合わせて、レコード数が想定どおりであることを確認します。インポートしたリードから無作為に 5 件を抽出してスポットチェックし、フィールド値、スコアリングデータ、ソースアトリビューション、割り当てがすべて正しく転送されたことを確認します。
12. インポートの概要を返し、結果を記録する: 最終結果をまとめ、インポート全体（タイムスタンプ、ソースアトリビューション、レコード数、スコア分布、割り当ての内訳、ナーチャー登録、送信通知、エラー、所要時間）を ~/.claude-marketing/brands/{slug}/logs/lead-import-log.json に記録します。

出力

以下を含む、構造化されたリードインポートレポートです。

• インポート結果の概要：処理したリードの総数と内訳（作成、重複としてスキップ、重複を更新／統合、検証エラー、コンプライアンス上の理由による却下）を、割合と件数で表示
• リードスコアの分布：インポートしたリードのスコア層別の内訳（MQL の件数と割合、生のリード件数、ナーチャリング候補、平均スコア、中央値、特にスコアの高いリード）
• ソースアトリビューション記録：すべてのインポート済みリードに適用されたキャンペーン、メディア、ソース、コンテンツのアトリビューション。後続の ROI レポートとマーケティング起点のパイプライン追跡に適した形式
• 検証エラーレポート：検証に失敗したリードと、フィールド単位の具体的なエラー（不正なメールアドレス、必須フィールドの欠落、偽造の疑いがあるエントリー、電話番号の形式の問題、データ型の不一致）および修正案
• 重複排除の概要：見つかった重複リードについて、照合タイプ（完全一致／あいまい一致）、照合フィールド、信頼度スコア、各ペアに対して実行したアクション（更新、スキップ、統合、手動レビュー用にフラグ付け）を表示
• コンプライアンス監査証跡：インポートした各リードの同意状況（オプトインの仕組み、同意のタイムスタンプ、適用される規制、法的根拠）と、同意がない、または不十分なリードのフラグおよび是正措置
• 割り当ての概要：営業担当者へのリードの配分方法（担当者、地域、製品ライン、スコア層別）を示し、担当者ごとの件数と、手動での振り分けが必要な未割り当てリードを表示
• ナーチャリング登録の概要：ナーチャリングシーケンスに登録したリード（シーケンス名、登録数、最初のタッチポイントの予定日）と、ナーチャリングから除外したリード（すでに有効なシーケンスに登録済み、またはオプトアウト済み）を表示
• 通知配信レポート：営業担当者に送信した通知について、担当者名、割り当てられたリード数、配信チャネル、配信状況、失敗した通知を表示します。再送を推奨するのは、通知がプラットフォームに到達しなかったことが確実な場合に限ります
• 実行ログ：インポート処理のタイムスタンプ付き記録（バッチサイズ、API 応答、リトライ〔書き込みがプラットフォームに到達しなかったことが確実な場合に限る〕、レート制限による一時停止、処理時間、作成したレコードの CRM 確認 ID）
• データ品質のベースライン：インポートバッチ全体のフィールド入力率（会社名、電話番号、役職、その他の任意フィールドが入力されているリードの割合）を示し、このソースの品質ベースラインを確立
• ソース品質の比較：このソースからの過去のインポートがある場合、今回のバッチ品質を過去の平均と比較します（検証エラー率の推移、スコア分布の変化、重複率の推移、フィールド入力率の経時変化）
• CRM 自動化トリガー：インポートによって実行された CRM 側のワークフロー（ウェルカムメールの送信、営業担当者向けタスクの作成、リード振り分けルールの実行、ワークフロー登録の確認）
• フォローアップの推奨事項：推奨される次のステップ（追加のナーチャリングシーケンスを開始する、スコアの高い MQL を営業担当者に通知する、30 日後にデータ品質レビューを予定する、このソースの定期インポートを設定する、インポート結果に基づいてリードスコアリングのしきい値を調整する）

使用エージェント

• crm-manager — リードの検証、重複排除、フィールドマッピング、CRM スキーマの解決、リードスコアの適用、同意の確認、割り当てルールの実行、ライフサイクルステージの設定、ナーチャリング登録、インポート管理
• email-specialist — ナーチャリングシーケンスへの登録、メール到達性の検証（インポートしたメールアドレスを既知のバウンスリストおよびスパムトラップリストと照合）、エンゲージメントに基づくスコアリングへの入力