dev-chiefworks
39 lines
1.2 KiB
PHP
39 lines
1.2 KiB
PHP
<?php
|
|
|
|
function parseEmail($email_id)
|
|
{
|
|
global $httpAuthToken,$oauth_api;
|
|
$url = $oauth_api."parse/" . $email_id;
|
|
$opts = array(
|
|
'http' => array(
|
|
'method' => "GET",
|
|
'timeout' => 60, /* 1 minute */
|
|
'header' =>
|
|
"Content-Type: application/x-www-form-urlencoded\r\n" .
|
|
"Accept: application/json\r\n" .
|
|
"Authorization: Server-Token ${httpAuthToken}\r\n",
|
|
),
|
|
);
|
|
|
|
$context = stream_context_create($opts);
|
|
$body = file_get_contents($url, false, $context);
|
|
$geocoded = json_decode($body, true);
|
|
if (is_array($geocoded) && is_array($geocoded["data"]) && !isset($geocoded["error"])) {
|
|
return $geocoded["data"];
|
|
}
|
|
return null;
|
|
}
|
|
|
|
|
|
function updateParsedEmail($id, $location_start_id, $location_end_id)
|
|
{
|
|
global $conn;
|
|
$q = "UPDATE parsedemail_item SET updated=NOW(), location_start_id=" . $location_start_id . ", location_end_id=" . $location_end_id . "
|
|
WHERE id = " . $id . "";
|
|
$r = pg_query($conn, $q);
|
|
if ($r && pg_num_rows($r) && $f = pg_fetch_assoc($r)) {
|
|
return [$f, null];
|
|
}
|
|
return [null, pg_last_error($conn)];
|
|
}
|