Obter Contatos da Campanha

# Primeira página com 50 contatos
curl -X GET "https://api.disparador.com/api/campaigns/123/contacts?page=0&size=50" \
  -H "X-Access-Token: seu_token_aqui"

async function getCampaignContacts(campaignId, page = 0, size = 100) {
  const response = await fetch(
    `https://api.disparador.com/api/campaigns/${campaignId}/contacts?page=${page}&size=${size}`,
    {
      headers: {
        'X-Access-Token': 'seu_token_aqui'
      }
    }
  );
  
  return response.json();
}

// Obter todos os contatos paginados
async function getAllContacts(campaignId) {
  const contacts = [];
  let page = 0;
  let hasMore = true;
  
  while (hasMore) {
    const batch = await getCampaignContacts(campaignId, page, 100);
    contacts.push(...batch);
    hasMore = batch.length === 100;
    page++;
  }
  
  return contacts;
}

import requests

def get_campaign_contacts(campaign_id, page=0, size=100):
    url = f"https://api.disparador.com/api/campaigns/{campaign_id}/contacts"
    headers = {"X-Access-Token": "seu_token_aqui"}
    params = {"page": page, "size": size}
    
    response = requests.get(url, headers=headers, params=params)
    return response.json()

# Obter contatos com falha
def get_failed_contacts(campaign_id):
    all_contacts = []
    page = 0
    
    while True:
        contacts = get_campaign_contacts(campaign_id, page)
        if not contacts:
            break
        
        failed = [c for c in contacts if c['status'] == 'FAILED']
        all_contacts.extend(failed)
        
        if len(contacts) < 100:
            break
        page += 1
    
    return all_contacts

function getCampaignContacts($campaignId, $page = 0, $size = 100) {
    $ch = curl_init();
    
    $url = "https://api.disparador.com/api/campaigns/{$campaignId}/contacts";
    $url .= "?page={$page}&size={$size}";
    
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'X-Access-Token: seu_token_aqui'
    ]);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    
    $response = curl_exec($ch);
    curl_close($ch);
    
    return json_decode($response, true);
}

[
  {
    "id": 1001,
    "phoneNumber": "5511999887766",
    "name": "João Silva",
    "status": "SENT",
    "sentAt": "2024-01-20T10:15:30",
    "retryCount": 0
  },
  {
    "id": 1002,
    "phoneNumber": "5511999887777",
    "name": "Maria Santos",
    "status": "FAILED",
    "failedAt": "2024-01-20T10:16:45",
    "failureReason": "Número não registrado no WhatsApp",
    "retryCount": 3
  },
  {
    "id": 1003,
    "phoneNumber": "5511999887788",
    "name": "Pedro Costa",
    "status": "PENDING",
    "retryCount": 0
  }
]

async function generateFailureReport(campaignId) {
  const contacts = await getAllCampaignContacts(campaignId);
  
  const failures = contacts.filter(c => c.status === 'FAILED');
  const failuresByReason = {};
  
  failures.forEach(contact => {
    const reason = contact.failureReason || 'Erro desconhecido';
    failuresByReason[reason] = (failuresByReason[reason] || 0) + 1;
  });
  
  return {
    totalFailed: failures.length,
    byReason: failuresByReason,
    failedNumbers: failures.map(c => ({
      number: c.phoneNumber,
      name: c.name,
      reason: c.failureReason
    }))
  };
}

async function retryFailedContacts(campaignId) {
  const contacts = await getCampaignContacts(campaignId);
  const failed = contacts.filter(c => c.status === 'FAILED');
  
  // Criar nova campanha apenas com contatos que falharam
  const retryContacts = failed.map(c => ({
    phoneNumber: c.phoneNumber,
    name: c.name
  }));
  
  if (retryContacts.length > 0) {
    await createCampaign({
      name: `Reenvio - Campanha ${campaignId}`,
      contacts: retryContacts,
      message: originalMessage
    });
  }
}

async function exportCampaignContacts(campaignId, format = 'csv') {
  const allContacts = await getAllCampaignContacts(campaignId);
  
  if (format === 'csv') {
    const csv = [
      'Nome,Telefone,Status,Data Envio,Motivo Falha',
      ...allContacts.map(c => 
        `"${c.name}","${c.phoneNumber}","${c.status}","${c.sentAt || ''}","${c.failureReason || ''}"`
      )
    ].join('\n');
    
    downloadFile('contatos-campanha.csv', csv);
  }
}

async function monitorCampaignProgress(campaignId) {
  const updateInterval = 5000; // 5 segundos
  
  const updateProgress = async () => {
    const contacts = await getCampaignContacts(campaignId, 0, 1000);
    
    const stats = {
      total: contacts.length,
      sent: contacts.filter(c => c.status === 'SENT').length,
      failed: contacts.filter(c => c.status === 'FAILED').length,
      pending: contacts.filter(c => c.status === 'PENDING').length
    };
    
    updateProgressBar(stats);
    
    if (stats.pending > 0) {
      setTimeout(updateProgress, updateInterval);
    }
  };
  
  updateProgress();
}

{
  "message": "Campanha não encontrada"
}

{
  "message": "Campanha não pertence à sua empresa"
}

{
  "message": "Access token inválido"
}