<?php
$job_name = pathinfo(__FILE__, PATHINFO_FILENAME);
echo "[".date("Y-m-d H:i:s")."] ".$job_name." job is starting.\n";

set_time_limit(0); // No limit!

require('../../backend.php');
require('../common/QuoteApi.php');
$httpAuthToken = $savvyext->cfgReadChar('system.oauth2_token');
$encryptionAlg = $savvyext->cfgReadChar('encryption.algorithm');
$encryptionKey = $savvyext->cfgReadChar('encryption.key');
$encryptionIV = $savvyext->cfgReadChar('encryption.iv');

$baseURL = $savvyext->cfgReadChar('system.api_url');

$db_host = $savvyext->cfgReadChar('database.host');
$db_name = $savvyext->cfgReadChar('database.name');
$db_user = $savvyext->cfgReadChar('database.user');
$db_pass = $savvyext->cfgReadChar('database.pass');
$db_port = $savvyext->cfgReadLong('database.port');
$connstr = "host=${db_host} port=${db_port} dbname=${db_name} user=${db_user} password=${db_pass}";
$conn = pg_connect($connstr);

$country = 'US';
$member_id = 0;

// Uber & Lyft
$transport_providers = [1,2];

// Step 1: Load trips
$q = "select b.*,c.address AS origin, d.address AS destination ";
$q.= " from (select root_id,count(*) as count from trip_price_comparison where root_type=1 group by root_id) as a, ";
$q.= " parsedemail_item b, address c, address d ";
$q.= " where a.count=1 and b.id=a.root_id and b.private='f' and c.id=b.location_start_id and d.id=b.location_end_id and c.country='${country}' ";
$q.= " and b.dup_id is null ";
$q.= " order by b.travel_date desc";
$r = pg_query($conn, $q);

// Step 3: Schedule quotes
$checkQuotes = [];
QuoteApi::$job_name = $job_name;
if ($r && pg_num_rows($r)) {
    $n = pg_num_rows($r);
    echo "[".date("Y-m-d H:i:s")."] Processing ".$n." trips.\n";
    $i = 0;
    while ($f = pg_fetch_assoc($r)) {
        $i++;
        echo "[".date("Y-m-d H:i:s")."] Processing ${i}/${n} (".sprintf("%0.02f",100.0*$i/$n).") trip id=".$f["id"].".\n";
        if ($f["location_start_id"]==$f["location_end_id"]) continue;
        $location_start_id=$f["location_start_id"];
        $location_end_id=$f["location_end_id"];
        foreach ($transport_providers as $transport_provider) {
            $q = "SELECT * FROM quotes ";
            $q.= " WHERE location_start_id=${location_start_id} AND location_end_id=${location_end_id} ";
            $q.= " AND transport_provider_id=${transport_provider} AND cost>0 ";
            $q.= " AND completed>(current_date-1) ORDER BY completed DESC LIMIT 1";
            $quotes = pg_query($conn, $q);
            if ($quotes && pg_num_rows($quotes) && $quote=pg_fetch_assoc($quotes)) {
                echo "[".date("Y-m-d H:i:s")."] Quote ".$quote["cost"]." already exists ID #".$quote["id"]."\n";
                continue;
            }
            list($res,$id) = QuoteApi::schedule_quote($f["origin"],$f["destination"],$country,$member_id,$transport_provider);
            if ($res>0) {
                if ($res==2) {
                    echo "[".date("Y-m-d H:i:s")."] Quote complete! ID #${id}\n";
                } else if ($res==1) {
                    echo "[".date("Y-m-d H:i:s")."] Scheduled quote ID #${id}\n";
                    $checkQuotes[] = $id; 
                } else {
                    echo "[".date("Y-m-d H:i:s")."] Unexpected result for ID #${id} ($res)\n";
                }
            } else {
                echo "[".date("Y-m-d H:i:s")."] schedule_quote failed: ${res}.\n";
                echo "[".date("Y-m-d H:i:s")."] $origin,$destination,$country,$member_id,$transport_provider\n";
            }
        }
    }
}

// Step 4: Check quotes
foreach ($checkQuotes as $id) {
    list($res,$cost) = QuoteApi::check_quote($id);
    echo "[".date("Y-m-d H:i:s")."] Checking quote ID #${id} ($res) cost=${cost}\n";
}

echo "[".date("Y-m-d H:i:s")."] ".$job_name." job complete.\n";