BillionVerify + Mailchimp 集成 - 发送前验证邮箱

// 示例: 当添加到 Mailchimp 受众时验证邮箱

const axios = require('axios');

// Mailchimp webhook 处理器
app.post('/webhook/mailchimp-subscribe', async (req, res) => {
  const { email, list_id, subscriber_id } = req.body.data;

  try {
    // 步骤 1: 使用 BillionVerify 验证邮箱
    const verificationResult = await axios.post(
      'https://api.billionverify.com/v1/verify',
      { email },
      {
        headers: {
          'Authorization': `Bearer ${process.env.BILLIONVERIFY_API_KEY}`,
          'Content-Type': 'application/json'
        }
      }
    );

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

    // 步骤 2: 根据结果在 Mailchimp 中更新订阅者
    const mailchimpApiKey = process.env.MAILCHIMP_API_KEY;
    const mailchimpServer = mailchimpApiKey.split('-')[1];

    if (status === 'valid' && risk_level === 'low') {
      // 有效邮箱 - 添加到主要细分
      await axios.patch(
        `https://${mailchimpServer}.api.mailchimp.com/3.0/lists/${list_id}/members/${subscriber_id}`,
        {
          status: 'subscribed',
          merge_fields: {
            EMAILSTAT: 'verified',
            RISKLEVEL: 'low'
          },
          tags: ['verified']
        },
        {
          headers: {
            'Authorization': `Bearer ${mailchimpApiKey}`,
            'Content-Type': 'application/json'
          }
        }
      );
    } else if (status === 'invalid') {
      // 无效邮箱 - 取消订阅或归档
      await axios.patch(
        `https://${mailchimpServer}.api.mailchimp.com/3.0/lists/${list_id}/members/${subscriber_id}`,
        {
          status: 'unsubscribed',
          merge_fields: {
            EMAILSTAT: 'invalid'
          },
          tags: ['invalid']
        },
        {
          headers: {
            'Authorization': `Bearer ${mailchimpApiKey}`,
            'Content-Type': 'application/json'
          }
        }
      );
    } else {
      // 有风险邮箱 - 标记以供审核
      await axios.patch(
        `https://${mailchimpServer}.api.mailchimp.com/3.0/lists/${list_id}/members/${subscriber_id}`,
        {
          merge_fields: {
            EMAILSTAT: 'risky',
            RISKLEVEL: risk_level
          },
          tags: ['needs-review', is_disposable ? 'disposable' : '', is_catch_all ? 'catch-all' : ''].filter(Boolean)
        },
        {
          headers: {
            'Authorization': `Bearer ${mailchimpApiKey}`,
            'Content-Type': 'application/json'
          }
        }
      );
    }

    res.status(200).send({ success: true });
  } catch (error) {
    console.error('Verification error:', error);
    res.status(500).send({ error: 'Verification failed' });
  }
});

import requests
from flask import Flask, request

app = Flask(__name__)

BILLIONVERIFY_API_KEY = 'your_billionverify_api_key'
MAILCHIMP_API_KEY = 'your_mailchimp_api_key'
MAILCHIMP_SERVER = MAILCHIMP_API_KEY.split('-')[1]

@app.route('/webhook/mailchimp-subscribe', methods=['POST'])
def verify_mailchimp_subscriber():
    data = request.json.get('data', {})
    email = data.get('email')
    list_id = data.get('list_id')
    subscriber_id = data.get('subscriber_id')

    # 步骤 1: 使用 BillionVerify 验证邮箱
    verification_response = requests.post(
        'https://api.billionverify.com/v1/verify',
        json={'email': email},
        headers={
            'Authorization': f'Bearer {BILLIONVERIFY_API_KEY}',
            'Content-Type': 'application/json'
        }
    )
    result = verification_response.json()

    # 步骤 2: 更新 Mailchimp 订阅者
    mailchimp_url = f'https://{MAILCHIMP_SERVER}.api.mailchimp.com/3.0/lists/{list_id}/members/{subscriber_id}'

    if result['status'] == 'valid' and result['risk_level'] == 'low':
        update_data = {
            'status': 'subscribed',
            'merge_fields': {
                'EMAILSTAT': 'verified',
                'RISKLEVEL': 'low'
            },
            'tags': ['verified']
        }
    elif result['status'] == 'invalid':
        update_data = {
            'status': 'unsubscribed',
            'merge_fields': {
                'EMAILSTAT': 'invalid'
            },
            'tags': ['invalid']
        }
    else:
        update_data = {
            'merge_fields': {
                'EMAILSTAT': 'risky',
                'RISKLEVEL': result['risk_level']
            },
            'tags': ['needs-review']
        }

    requests.patch(
        mailchimp_url,
        json=update_data,
        headers={
            'Authorization': f'Bearer {MAILCHIMP_API_KEY}',
            'Content-Type': 'application/json'
        }
    )

    return {'success': True}, 200

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