dev-chiefworks
50 lines
1.9 KiB
PHP
50 lines
1.9 KiB
PHP
<?php
|
|
|
|
echo "[".date("Y-m-d H:i:s")."] update_address_postal job is starting.\n";
|
|
|
|
require('../backend.php');
|
|
|
|
$httpAuthToken = $savvyext->cfgReadChar('system.oauth2_token');
|
|
|
|
$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) or die ("Could not connect to server\n");
|
|
|
|
$db_host = $savvyext->cfgReadChar('database_replica.host');
|
|
$db_name = $savvyext->cfgReadChar('database_replica.name');
|
|
$db_user = $savvyext->cfgReadChar('database_replica.user');
|
|
$db_pass = $savvyext->cfgReadChar('database_replica.pass');
|
|
$db_port = $savvyext->cfgReadLong('database_replica.port');
|
|
$readOnlyReplicaConnstr = "host=${db_host} port=${db_port} dbname=${db_name} user=${db_user} password=${db_pass}";
|
|
$readOnlyReplicaConn = pg_connect($readOnlyReplicaConnstr);
|
|
|
|
$query = "SELECT id,address,postal FROM address WHERE country='SG' AND (postal='' OR LOWER(postal)='singapore' OR postal IS NULL)";
|
|
|
|
$rs = pg_query($readOnlyReplicaConn, $query) or die("Cannot execute query: $query\n");
|
|
|
|
while ($row = pg_fetch_assoc($rs)) {
|
|
$id = $row['id'];
|
|
$address = $row['address'];
|
|
$postal = $row['postal'];
|
|
$pos = strrpos($address,' ');
|
|
if ($pos!==false) {
|
|
$s = trim(substr($address,$pos));
|
|
if (strlen($s)==6 && is_numeric($s)) {
|
|
$updateQuery = "UPDATE address SET postal = '".pg_escape_string($s)."' where id = $id";
|
|
$result = pg_query($conn, $updateQuery);
|
|
echo "[".date("Y-m-d H:i:s")."] Update postal=${s} data for record: $id\n";
|
|
}
|
|
}
|
|
}
|
|
|
|
pg_close($conn);
|
|
pg_close($readOnlyReplicaConn);
|
|
|
|
echo "[".date("Y-m-d H:i:s")."] update_address_postal job complete.\n";
|
|
|
|
?>
|