Почтовый скрипт PHP запускается несколько раз (с использованием Mailgun) - PullRequest
Новая
       13

Почтовый скрипт PHP запускается несколько раз (с использованием Mailgun)

1 голос
/ 23 апреля 2019

У нас есть PHP-скрипт, который должен отправить электронное письмо всем пользователям, которые соответствуют определенным критериям.Скрипт использует Mailgun для обработки почтовых сообщений.Сценарий отлично работает с небольшим количеством записей (около 500 или менее), однако, если записей становится слишком много (скажем, 1000, 2000), сценарий не заканчивается и вместо этого запускается несколько раз (пользователи получают одно и то же сообщение электронной почты дваили три раза). 

require __DIR__ . '/../vendor/autoload.php';
use Mailgun\Mailgun;

# Instantiate the client.
$mgClient = new Mailgun('our-private-key');
$mgClient1= new Mailgun('our-public-key');
$domain = "our.domain";

// 1. Connect to database

$pdo = new PDO('mysql:host=localhost;dbname=db', 'user', 'psw');
$pdo->exec('SET NAMES "utf8"');


// 2. Query users table for any records where field "endDate" < the current time

$query = "SELECT userId, firstName, email FROM users WHERE endDate <= now() AND sub = 0";
$expiredQuery = $pdo->prepare($query);
$expiredQuery->execute();

$expired = $expiredQuery->fetchAll(PDO::FETCH_OBJ);

if (empty($expired)) {
    echo 'There are no records to unsubscribe.';
    exit();
}


// 3. If found, loop through results and get the "uId"; save users to a users array

$ids = [];
$usernames = [];
$emails = [];

foreach ($expired as $user) {
  $id = $user->uId;
  $username = $user->fName;
  $useremail = $user->email;
  array_push($ids, $id);
  array_push($usernames, $username);
  array_push($emails, $useremail);
}


// 4. Send email to users

$counter = 0;

foreach ($emails as $email) {

  # Issue the call to the client.
  $resultVer = $mgClient1->get("address/validate", array('address' => $email));
  # is_valid is 0 or 1
  $isValid = $resultVer->http_response_body->is_valid;


  if (!$isValid) {
    echo "Not delivered: " . $email . "<br>"; 
    $counter++;
    continue;
  }

  $firstname = $usernames[$counter];

  # Build recipient email
  $rec_msg = 'Hi '.$firstname.'... etc etc';

  # Send mail to recipient
  $result = $mgClient->sendMessage($domain, array(
    'from'    => 'Sender<Sender@sender.com>',
    'to'      => $email,
    'subject' => 'An email',
    'html'    => $rec_msg,

  ), array(
    'inline'  => array('http://www.oursite.com/images/mail_header.jpg', 'http://www.oursite.com/images/footer.jpg')
  ));

  # Increment the counter
  $counter++;
}


// 6. Send notification

echo "The following users were sent an email <br>" . implode(", ", $emails);
die();

Я пытался добавить die () в конце, но это не помогло.Также я не получаю вывод между несколькими запусками скрипта.

1 Ответ

1 голос
/ 01 мая 2019

Два запрещают запуск почтового скрипта несколько раз, я бы рекомендовал использовать блокирующий компонент, такой как symfony / lock .

Другая проблема заключается в количестве писем, которые вы пытаетесь отправить одновременно. Попробуйте разделить количество писем на более мелкие ненужные файлы, например, 500 сразу. Вы можете использовать фильтр SQL LIMIT x,y или выбрать все строки и разделить строки с помощью array_chunk .

...