Files
FloatBackOfffice/CRONS/trackedemail_item_parse_missing.php
dev-chiefworks f76abffdcd first commit
2022-05-31 16:21:53 -04:00

40 lines
1.4 KiB
PHP

<?php
$job_name ='parsedemail_item_fix_missing email';
echo "[" . date("Y-m-d H:i:s") . "] ".$job_name." job is starting.\n";
require 'common/utils.php';
require 'common/config.php';
require 'common/address_city.php';
require 'common/parser.php';
require 'common/Geocode.php';
$total = $success = $failed = 0;
$q = "SELECT id FROM trackedemail_item WHERE id NOT IN (SELECT trackedemail_item_id FROM parsedemail_item_payment) ORDER BY id DESC;";
$q="select id from trackedemail_item where id not in (select trackedemail_item_id from parsedemail_item p INNER JOIN trackedemail_item t on p.trackedemail_item_id=t.id WHERE member_id=347) AND member_id=347 order by id desc;";
$r = pg_query($conn, $q);
while ($f = pg_fetch_assoc($r)) {
$total++;
$email_id = $f['id'];
if (!empty($email_id)) {
$data = parseEmail($email_id);
if ( isset( $data['parsed_status'] ) && $data['parsed_status']==1 ) {
echo "[" . date("Y-m-d H:i:s") . "] email id: ".$email_id." is success.\n";
$success++;
}else{
echo "[" . date("Y-m-d H:i:s") . "] email id: ".$email_id." is failed.\n";
$failed++;
}
} else {
echo "[" . date("Y-m-d H:i:s") . "] email id: ".$email_id." is failed.\n";
$failed++;
}
}
echo "Total: " . $total . ".\n";
echo "Success: : " . $success . ".\n";
echo "Failed: : " . $failed . ".\n";
echo "[" . date("Y-m-d H:i:s") . "] ".$job_name." job complete.\n";