<?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 trackedemail_item_id as id from parsedemail_item where duration > 600 and trackedemail_item_id is not null order by duration 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";