Pipedrive統合 - セールスリードとコンタクトを検証

Pipedriveウェブフック
      ↓
バックエンドサーバー
      ↓
BillionVerify API
      ↓
Pipedrive API(コンタクト更新)

// 例: 人物がPipedriveに追加されたときにメールを検証

const axios = require('axios');

// Pipedriveウェブフックハンドラー
app.post('/webhook/pipedrive-person-added', async (req, res) => {
  const { current } = req.body;
  const { id, email, org_name, name } = current;

  // メールが提供されていない場合はスキップ
  if (!email || !email[0]) {
    return res.status(200).send({ success: true, skipped: 'no_email' });
  }

  const personEmail = email[0].value;
  const personId = id;

  try {
    // ステップ1: BillionVerifyでメールを検証
    const verificationResult = await axios.post(
      'https://api.billionverify.com/v1/verify',
      { email: personEmail },
      {
        headers: {
          'Authorization': `Bearer ${process.env.BILLIONVERIFY_API_KEY}`,
          'Content-Type': 'application/json'
        }
      }
    );

    const { status, risk_level, is_disposable, is_catch_all, is_role } = verificationResult.data;

    // ステップ2: 検証結果でPipedriveの人物を更新
    const pipedriveApiToken = process.env.PIPEDRIVE_API_TOKEN;

    // リード品質スコアを決定
    let leadQuality = 'Unknown';
    if (status === 'valid' && risk_level === 'low' && !is_disposable && !is_role) {
      leadQuality = 'High Quality';
    } else if (status === 'valid' && (risk_level === 'medium' || is_catch_all)) {
      leadQuality = 'Medium Quality';
    } else if (status === 'invalid') {
      leadQuality = 'Invalid';
    } else {
      leadQuality = 'Low Quality';
    }

    // Pipedriveカスタムフィールドを更新
    await axios.put(
      `https://api.pipedrive.com/v1/persons/${personId}`,
      {
        // カスタムフィールド(実際のフィールドキーに置き換え)
        '12345abc': status,                    // メールステータスフィールド
        '67890def': risk_level,                // リスクレベルフィールド
        'abcde123': leadQuality,               // リード品質スコアフィールド
        'fghij456': is_disposable ? 'Yes' : 'No',  // 使い捨てフィールド
        'klmno789': is_catch_all ? 'Yes' : 'No',   // Catch-Allフィールド
        'pqrst012': is_role ? 'Yes' : 'No'         // ロールアカウントフィールド
      },
      {
        params: {
          api_token: pipedriveApiToken
        }
      }
    );

    // ステップ3: 検証詳細を含むノートを人物に追加
    await axios.post(
      'https://api.pipedrive.com/v1/notes',
      {
        content: `メール検証結果:
- ステータス: ${status}
- リスクレベル: ${risk_level}
- リード品質: ${leadQuality}
- 使い捨て: ${is_disposable ? 'はい' : 'いいえ'}
- Catch-All: ${is_catch_all ? 'はい' : 'いいえ'}
- ロールアカウント: ${is_role ? 'はい' : 'いいえ'}

BillionVerifyによって ${new Date().toISOString()} に検証されました`,
        person_id: personId,
        pinned_to_person_flag: 1
      },
      {
        params: {
          api_token: pipedriveApiToken
        }
      }
    );

    // ステップ4: 品質に基づいてラベル/タグを追加
    if (leadQuality === 'Invalid') {
      // 商談を失注としてマークまたは人物をアーカイブ
      console.log(`無効なメール検出: ${personEmail} (${name})`);
    }

    res.status(200).send({ success: true, leadQuality });
  } catch (error) {
    console.error('検証エラー:', error);
    res.status(500).send({ error: '検証に失敗しました' });
  }
});

import requests
from flask import Flask, request

app = Flask(__name__)

BILLIONVERIFY_API_KEY = 'your_billionverify_api_key'
PIPEDRIVE_API_TOKEN = 'your_pipedrive_api_token'

@app.route('/webhook/pipedrive-person-added', methods=['POST'])
def verify_pipedrive_person():
    data = request.json
    current = data.get('current', {})
    person_id = current.get('id')
    emails = current.get('email', [])
    name = current.get('name', 'Unknown')

    # メールがない場合はスキップ
    if not emails or not emails[0].get('value'):
        return {'success': True, 'skipped': 'no_email'}, 200

    person_email = emails[0]['value']

    try:
        # ステップ1: BillionVerifyでメールを検証
        verification_response = requests.post(
            'https://api.billionverify.com/v1/verify',
            json={'email': person_email},
            headers={
                'Authorization': f'Bearer {BILLIONVERIFY_API_KEY}',
                'Content-Type': 'application/json'
            }
        )
        result = verification_response.json()

        # ステップ2: リード品質を決定
        status = result['status']
        risk_level = result['risk_level']
        is_disposable = result.get('is_disposable', False)
        is_catch_all = result.get('is_catch_all', False)
        is_role = result.get('is_role', False)

        if status == 'valid' and risk_level == 'low' and not is_disposable and not is_role:
            lead_quality = 'High Quality'
        elif status == 'valid' and (risk_level == 'medium' or is_catch_all):
            lead_quality = 'Medium Quality'
        elif status == 'invalid':
            lead_quality = 'Invalid'
        else:
            lead_quality = 'Low Quality'

        # ステップ3: Pipedrive人物カスタムフィールドを更新
        update_data = {
            '12345abc': status,
            '67890def': risk_level,
            'abcde123': lead_quality,
            'fghij456': 'Yes' if is_disposable else 'No',
            'klmno789': 'Yes' if is_catch_all else 'No',
            'pqrst012': 'Yes' if is_role else 'No'
        }

        requests.put(
            f'https://api.pipedrive.com/v1/persons/{person_id}',
            json=update_data,
            params={'api_token': PIPEDRIVE_API_TOKEN}
        )

        # ステップ4: 検証詳細を含むノートを追加
        note_content = f"""メール検証結果:
- ステータス: {status}
- リスクレベル: {risk_level}
- リード品質: {lead_quality}
- 使い捨て: {'はい' if is_disposable else 'いいえ'}
- Catch-All: {'はい' if is_catch_all else 'いいえ'}
- ロールアカウント: {'はい' if is_role else 'いいえ'}

BillionVerifyによって検証されました"""

        requests.post(
            'https://api.pipedrive.com/v1/notes',
            json={
                'content': note_content,
                'person_id': person_id,
                'pinned_to_person_flag': 1
            },
            params={'api_token': PIPEDRIVE_API_TOKEN}
        )

        return {'success': True, 'lead_quality': lead_quality}, 200

    except Exception as e:
        print(f'検証エラー: {e}')
        return {'error': '検証に失敗しました'}, 500

if __name__ == '__main__':
    app.run(port=5000)