1326 lines
54 KiB
PHP
1326 lines
54 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
// ============
|
||
|
|
// DecWeb Class
|
||
|
|
// ============
|
||
|
|
|
||
|
|
require_once "vendor/autoload.php";
|
||
|
|
|
||
|
|
use PHPMailer\PHPMailer\PHPMailer;
|
||
|
|
use PHPMailer\PHPMailer\Exception;
|
||
|
|
|
||
|
|
class DecWeb {
|
||
|
|
|
||
|
|
// Variables
|
||
|
|
|
||
|
|
private $log_file = "";
|
||
|
|
private $settings = "";
|
||
|
|
private $decweb_connection = "";
|
||
|
|
private $realestatedatainc_connection = "";
|
||
|
|
private $ftp_access_file = "DEC_Web.mdb";
|
||
|
|
private $data_directory = "data";
|
||
|
|
private $sql_directory = "data/sql";
|
||
|
|
|
||
|
|
// =================
|
||
|
|
// Class Constructor
|
||
|
|
// =================
|
||
|
|
|
||
|
|
public function __construct() {
|
||
|
|
|
||
|
|
// Open the Log
|
||
|
|
|
||
|
|
$this->log_file = fopen("./scripts/decweb_synchronization.log", "w+");
|
||
|
|
|
||
|
|
if ($this->log_file === false) {
|
||
|
|
|
||
|
|
error_log("DecWebSync : Unable to open log file");
|
||
|
|
exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log(str_repeat("*", 50));
|
||
|
|
|
||
|
|
// Get Settings
|
||
|
|
|
||
|
|
$this->settings = new SimpleXMLElement((file_exists("./xml/settings.xml") ? file_get_contents("./xml/settings.xml") : "<settings/>"));
|
||
|
|
|
||
|
|
if ($this->settings->count() === 0) {
|
||
|
|
|
||
|
|
error_log("DecWebSync : Unable to initialize settings");
|
||
|
|
exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
// Open Database Connections
|
||
|
|
$this->decweb_connection = $this->connect_decweb();
|
||
|
|
$this->realestatedatainc_connection = $this->connect_realestatedatainc();
|
||
|
|
}
|
||
|
|
|
||
|
|
// ============================
|
||
|
|
// Synchronize Database Process
|
||
|
|
// ============================
|
||
|
|
|
||
|
|
public function process() {
|
||
|
|
|
||
|
|
$this->log(date("Y-m-d H:i:s") . " - Starting Decweb Synchronization");
|
||
|
|
|
||
|
|
$this->download_access_file();
|
||
|
|
$this->process_access_file();
|
||
|
|
$this->clean_up_sqls();
|
||
|
|
$this->clean_up_mdb();
|
||
|
|
$this->migrateTables();
|
||
|
|
|
||
|
|
$this->email_admins("Database Reload Status", "Database Reload from Access(MDB) file to SQL was successful. See attached logfile for details.");
|
||
|
|
$this->sendWebHookAlert("Database Reload Status", "Database Reload from Access(MDB) file to SQL was successful.");
|
||
|
|
$this->log(date("Y-m-d H:i:s") . " - Synchronization Complete");
|
||
|
|
|
||
|
|
exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==========================================
|
||
|
|
// Return a DecWeb MySQL Database Connection.
|
||
|
|
// ==========================================
|
||
|
|
|
||
|
|
public function connect_decweb() {
|
||
|
|
|
||
|
|
try {
|
||
|
|
|
||
|
|
$host = (string) ($this->settings->DECDatabaseServer ?? "");
|
||
|
|
$database = (string) ($this->settings->DECDatabase ?? "");
|
||
|
|
$user = (string) ($this->settings->DECDatabaseUser ?? "");
|
||
|
|
$password = (string) ($this->settings->DECDatabasePassword ?? "");
|
||
|
|
|
||
|
|
$connection = new PDO("mysql:host={$host};dbname={$database};charset=utf8", $user, $password);
|
||
|
|
|
||
|
|
$connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
|
||
|
|
} catch (PDOException | Exception $e) {
|
||
|
|
|
||
|
|
$this->log($e->getMessage());
|
||
|
|
exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
return $connection;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ====================================================
|
||
|
|
// Return a RealEstateDataInc MySQL Database Connection
|
||
|
|
// ====================================================
|
||
|
|
|
||
|
|
public function connect_realestatedatainc() {
|
||
|
|
|
||
|
|
try {
|
||
|
|
|
||
|
|
$host = (string) ($this->settings->DatabaseServer ?? "");
|
||
|
|
$database = (string) ($this->settings->DatabaseName ?? "");
|
||
|
|
$user = (string) ($this->settings->DatabaseUser ?? "");
|
||
|
|
$password = (string) ($this->settings->DatabasePassword ?? "");
|
||
|
|
|
||
|
|
$connection = new PDO("mysql:host={$host};dbname={$database};charset=utf8", $user, $password);
|
||
|
|
|
||
|
|
$connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
|
||
|
|
} catch (PDOException | Exception $e) {
|
||
|
|
|
||
|
|
$this->log($e->getMessage());
|
||
|
|
exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
return $connection;
|
||
|
|
}
|
||
|
|
|
||
|
|
private function download_access_file() {
|
||
|
|
|
||
|
|
$this->log("Starting Access File Download");
|
||
|
|
|
||
|
|
$ftp_username = (string) $this->settings->DecFtpServerUser;
|
||
|
|
$ftp_password = (string) $this->settings->DecFtpServerPassword;
|
||
|
|
$ftp_url = (string) $this->settings->DecFtpServerURL;
|
||
|
|
$ftp_port = (string) $this->settings->DecFtpServerPort;
|
||
|
|
|
||
|
|
exec("curl -O -u {$ftp_username}:{$ftp_password} ftp://{$ftp_url}:{$ftp_port}/{$this->ftp_access_file}");
|
||
|
|
exec("mv {$this->ftp_access_file} data/.");
|
||
|
|
|
||
|
|
$this->log("Completed Access File Download");
|
||
|
|
}
|
||
|
|
|
||
|
|
// =============================
|
||
|
|
// Log a message to the Log File
|
||
|
|
// =============================
|
||
|
|
|
||
|
|
private function log($message = "") {
|
||
|
|
|
||
|
|
fwrite($this->log_file, date("Y-m-d H:i A") . " : " . "{$message} \n");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==============================
|
||
|
|
// Process Downloaded Access File
|
||
|
|
// ==============================
|
||
|
|
|
||
|
|
private function process_access_file() {
|
||
|
|
|
||
|
|
$this->log("Processing Dec Web Access File");
|
||
|
|
|
||
|
|
// -------------------------------------------
|
||
|
|
// Export Data from Access Tables to SQL files
|
||
|
|
// -------------------------------------------
|
||
|
|
|
||
|
|
$this->log("Export Data from Access Tables to SQL Files");
|
||
|
|
|
||
|
|
$allowed_tables = [
|
||
|
|
'BizFacts_tbl',
|
||
|
|
'PermitFacts_tbl',
|
||
|
|
'PurchasedServices_tbl',
|
||
|
|
'PZ_tbl',
|
||
|
|
'Users_tbl',
|
||
|
|
];
|
||
|
|
|
||
|
|
// mdb-tables outputs a space-separated list with newlines; normalize then split
|
||
|
|
$raw = shell_exec("mdb-tables -1 ./data/DEC_Web.mdb 2>/dev/null");
|
||
|
|
if ($raw === null) {
|
||
|
|
throw new RuntimeException("mdb-tables failed or returned null output.");
|
||
|
|
}
|
||
|
|
|
||
|
|
$access_tables = array_values(array_filter(array_map('trim', preg_split('/\R+/', trim($raw)))));
|
||
|
|
|
||
|
|
// Export only allowed tables that exist in the MDB
|
||
|
|
foreach (array_intersect($access_tables, $allowed_tables) as $access_table) {
|
||
|
|
|
||
|
|
$outFile = rtrim($this->sql_directory, '/') . "/{$access_table}.sql";
|
||
|
|
|
||
|
|
$shell_cmd = sprintf(
|
||
|
|
'mdb-export -D "%%Y-%%m-%%d %%H:%%M:%%S" -H -I mysql %s %s > %s 2>&1',
|
||
|
|
escapeshellarg('./data/DEC_Web.mdb'),
|
||
|
|
escapeshellarg($access_table),
|
||
|
|
escapeshellarg($outFile)
|
||
|
|
);
|
||
|
|
|
||
|
|
$output = [];
|
||
|
|
$rc = 0;
|
||
|
|
exec($shell_cmd, $output, $rc);
|
||
|
|
|
||
|
|
if ($rc !== 0) {
|
||
|
|
$this->log("ERROR exporting {$access_table}: " . implode(" | ", $output));
|
||
|
|
throw new RuntimeException("mdb-export failed for {$access_table} (rc={$rc}).");
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Exported {$access_table} -> {$outFile}");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ----------------
|
||
|
|
// Import SQL files
|
||
|
|
// ----------------
|
||
|
|
|
||
|
|
$this->log("Import SQL Files");
|
||
|
|
|
||
|
|
// Only import allowed tables (avoid importing random files in that folder)
|
||
|
|
foreach ($allowed_tables as $table) {
|
||
|
|
|
||
|
|
$file = rtrim($this->sql_directory, '/') . "/{$table}.sql";
|
||
|
|
|
||
|
|
if (!is_readable($file)) {
|
||
|
|
$this->log("Skipping missing/unreadable SQL file: {$file}");
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Hardening: table identifier validation (extra safety)
|
||
|
|
if (!preg_match('/^[A-Za-z0-9_]+$/', $table)) {
|
||
|
|
throw new RuntimeException("Invalid table name: {$table}");
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Truncating {$table}");
|
||
|
|
$this->decweb_connection->exec("TRUNCATE TABLE `{$table}`");
|
||
|
|
|
||
|
|
$this->log("Importing {$table} from {$file}");
|
||
|
|
|
||
|
|
$fh = fopen($file, 'rb');
|
||
|
|
if ($fh === false) {
|
||
|
|
throw new RuntimeException("Unable to open file: {$file}");
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->decweb_connection->beginTransaction();
|
||
|
|
|
||
|
|
try {
|
||
|
|
$buffer = '';
|
||
|
|
|
||
|
|
while (($line = fgets($fh)) !== false) {
|
||
|
|
|
||
|
|
$trim = trim($line);
|
||
|
|
|
||
|
|
// Skip common dump comments/blank lines
|
||
|
|
if ($trim === '' || str_starts_with($trim, '--') || str_starts_with($trim, '#')) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
$buffer .= $line;
|
||
|
|
|
||
|
|
// Execute each statement as it completes
|
||
|
|
if (str_ends_with(rtrim($trim), ';')) {
|
||
|
|
|
||
|
|
$this->decweb_connection->exec($buffer);
|
||
|
|
$buffer = '';
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (trim($buffer) !== '') {
|
||
|
|
$this->decweb_connection->exec($buffer);
|
||
|
|
}
|
||
|
|
|
||
|
|
fclose($fh);
|
||
|
|
$this->decweb_connection->commit();
|
||
|
|
|
||
|
|
$this->log("Imported {$table}");
|
||
|
|
} catch (Throwable $e) {
|
||
|
|
fclose($fh);
|
||
|
|
$this->decweb_connection->rollBack();
|
||
|
|
$this->log("ERROR importing {$table}: " . $e->getMessage());
|
||
|
|
throw $e;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Completed Processing SQL Files");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==================
|
||
|
|
// Clean Up SQL Files
|
||
|
|
// ==================
|
||
|
|
|
||
|
|
public function clean_up_sqls() {
|
||
|
|
|
||
|
|
$this->log("Cleaning Up...");
|
||
|
|
|
||
|
|
$sql_files = scandir($this->sql_directory);
|
||
|
|
$sql_files = array_diff($sql_files, array('.', '..'));
|
||
|
|
|
||
|
|
foreach ($sql_files as $file) {
|
||
|
|
|
||
|
|
$filename = "{$this->sql_directory}/{$file}";
|
||
|
|
|
||
|
|
unlink($filename);
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Finished Cleaning Up...");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==================
|
||
|
|
// Clean Up MDB Files
|
||
|
|
// ==================
|
||
|
|
|
||
|
|
public function clean_up_mdb() {
|
||
|
|
|
||
|
|
$this->log("Cleaning Up MDB's...");
|
||
|
|
|
||
|
|
$datetime = date("Ymd_His");
|
||
|
|
|
||
|
|
$currentFile = "{$this->data_directory}/DEC_Web.mdb";
|
||
|
|
$archivedFile = "{$this->data_directory}/DEC_Web_{$datetime}.mdb";
|
||
|
|
|
||
|
|
// Rename latest MDB file if it exists
|
||
|
|
if (file_exists($currentFile)) {
|
||
|
|
if (!rename($currentFile, $archivedFile)) {
|
||
|
|
$this->log("Error renaming DEC_Web.mdb.");
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
$this->log("DEC_Web.mdb does not exist. Nothing to rename.");
|
||
|
|
}
|
||
|
|
|
||
|
|
// Keep only the latest 5 MDB files
|
||
|
|
$maxfiles = 5;
|
||
|
|
|
||
|
|
$mdb_files = glob("{$this->data_directory}/*.mdb");
|
||
|
|
|
||
|
|
usort($mdb_files, function ($a, $b) {
|
||
|
|
return filemtime($a) <=> filemtime($b);
|
||
|
|
});
|
||
|
|
|
||
|
|
$filesToDelete = count($mdb_files) - $maxfiles;
|
||
|
|
|
||
|
|
if ($filesToDelete > 0) {
|
||
|
|
for ($i = 0; $i < $filesToDelete; $i++) {
|
||
|
|
if (unlink($mdb_files[$i])) {
|
||
|
|
$this->log("Deleted: " . basename($mdb_files[$i]));
|
||
|
|
} else {
|
||
|
|
$this->log("Error deleting: " . basename($mdb_files[$i]));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Finished Cleaning Up MDB's...");
|
||
|
|
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==========================
|
||
|
|
// Send an Alert/Notification
|
||
|
|
// ==========================
|
||
|
|
|
||
|
|
public function sendWebHookAlert($message, $title = "🚨 Server Alert", $alerttype = "1fff00") {
|
||
|
|
|
||
|
|
$webhookUrl = $this->settings->DiscordWebHookURL;
|
||
|
|
|
||
|
|
$data = [
|
||
|
|
'embeds' => [[
|
||
|
|
'title' => $title,
|
||
|
|
'description' => $message,
|
||
|
|
'color' => hexdec($alerttype),
|
||
|
|
'footer' => [
|
||
|
|
'text' => 'RDI System Notificiation',
|
||
|
|
],
|
||
|
|
'timestamp' => date('c'), // ISO 8601 format
|
||
|
|
]]
|
||
|
|
];
|
||
|
|
|
||
|
|
$jsonData = json_encode($data, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
|
||
|
|
|
||
|
|
$ch = curl_init($webhookUrl);
|
||
|
|
curl_setopt($ch, CURLOPT_POST, true);
|
||
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonData);
|
||
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
|
||
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||
|
|
curl_setopt($ch, CURLOPT_IPRESOLVE, CURL_IPRESOLVE_V4);
|
||
|
|
|
||
|
|
$response = curl_exec($ch);
|
||
|
|
|
||
|
|
if ($response === false) {
|
||
|
|
$this->log('Curl error: ' . curl_error($ch));
|
||
|
|
}
|
||
|
|
|
||
|
|
curl_close($ch);
|
||
|
|
}
|
||
|
|
|
||
|
|
// ============
|
||
|
|
// Email Admins
|
||
|
|
// ============
|
||
|
|
|
||
|
|
public function email_admins($subject = "", $message = "") {
|
||
|
|
|
||
|
|
$this->log(date("Y-m-d H:i:s") . " - Emailing Admins...");
|
||
|
|
|
||
|
|
$settings = new SimpleXMLElement((file_exists("./xml/settings.xml") ? file_get_contents("./xml/settings.xml") : "<settings/>"));
|
||
|
|
|
||
|
|
// Server Variables
|
||
|
|
$host = $settings->SmtpServer;
|
||
|
|
$username = $settings->SmtpUserName;
|
||
|
|
$password = $settings->SmtpPassword;
|
||
|
|
|
||
|
|
// Recipient Variables
|
||
|
|
$from_email = $settings->FromEmail;
|
||
|
|
$from_name = $settings->FromEmail['name'];
|
||
|
|
|
||
|
|
$support_email = $settings->SupportEmail;
|
||
|
|
$support_name = $settings->SupportEmail['name'];
|
||
|
|
|
||
|
|
if ($settings->Environment == 'Production') {
|
||
|
|
|
||
|
|
$admin_email = $settings->AdminEmail;
|
||
|
|
$admin_name = $settings->AdminEmail['name'];
|
||
|
|
}
|
||
|
|
|
||
|
|
// Content Variables
|
||
|
|
|
||
|
|
$subject = "Database Reload Status";
|
||
|
|
$attachment_name = "./scripts/decweb_synchronization.log";
|
||
|
|
|
||
|
|
$mail = new PHPMailer(true);
|
||
|
|
|
||
|
|
try {
|
||
|
|
|
||
|
|
//Server settings
|
||
|
|
$mail->isSMTP();
|
||
|
|
$mail->Host = $host;
|
||
|
|
$mail->SMTPAuth = true;
|
||
|
|
$mail->Username = $username;
|
||
|
|
$mail->Password = $password;
|
||
|
|
$mail->SMTPSecure = PHPMailer::ENCRYPTION_SMTPS;
|
||
|
|
$mail->Port = 465;
|
||
|
|
|
||
|
|
//Recipients
|
||
|
|
$mail->setFrom($from_email, $from_name);
|
||
|
|
$mail->addAddress($support_email, $support_name);
|
||
|
|
|
||
|
|
if ($settings->Environment == 'Production') {
|
||
|
|
$mail->addAddress($admin_email, $admin_name);
|
||
|
|
}
|
||
|
|
|
||
|
|
//Attachments
|
||
|
|
$mail->addAttachment($attachment_name);
|
||
|
|
|
||
|
|
//Content
|
||
|
|
$mail->isHTML(true);
|
||
|
|
$mail->Subject = $subject;
|
||
|
|
$mail->Body = $message;
|
||
|
|
|
||
|
|
$mail->send();
|
||
|
|
} catch (Exception $e) {
|
||
|
|
$this->log("Message could not be sent. Mailer Error: {$mail->ErrorInfo}");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// ============================================
|
||
|
|
// Migrate Tables to RealEstateDataInc Database
|
||
|
|
// ============================================
|
||
|
|
|
||
|
|
public function migrateTables() {
|
||
|
|
|
||
|
|
$this->log("Migrating Tables to RealEstateDataInc Database for New Interface...");
|
||
|
|
|
||
|
|
$this->migrateUsers();
|
||
|
|
$this->migratePurchasedServices();
|
||
|
|
$this->migratePermitFacts();
|
||
|
|
$this->migrateBusinessFacts();
|
||
|
|
$this->migratePZFacts();
|
||
|
|
|
||
|
|
$this->log("Finished Migrating Tables...");
|
||
|
|
}
|
||
|
|
|
||
|
|
// =============
|
||
|
|
// Migrate Users
|
||
|
|
// =============
|
||
|
|
|
||
|
|
private function migrateUsers(): void {
|
||
|
|
|
||
|
|
$this->log("Processing decweb Users");
|
||
|
|
|
||
|
|
$users = $this->getUsers();
|
||
|
|
|
||
|
|
$insertSQL = "INSERT INTO users
|
||
|
|
|
||
|
|
( user_id,
|
||
|
|
user_name,
|
||
|
|
user_email,
|
||
|
|
user_password,
|
||
|
|
user_role,
|
||
|
|
user_change_password,
|
||
|
|
user_active,
|
||
|
|
user_creator,
|
||
|
|
user_created )
|
||
|
|
VALUES (
|
||
|
|
:user_id,
|
||
|
|
:user_name,
|
||
|
|
:user_email,
|
||
|
|
:user_password,
|
||
|
|
:user_role,
|
||
|
|
:user_change_password,
|
||
|
|
:user_active,
|
||
|
|
:user_creator,
|
||
|
|
:user_created )";
|
||
|
|
|
||
|
|
$updateSQL = "UPDATE users
|
||
|
|
SET user_name = :user_name,
|
||
|
|
user_email = :user_email,
|
||
|
|
user_password = :user_password,
|
||
|
|
user_role = :user_role,
|
||
|
|
user_change_password = :user_change_password,
|
||
|
|
user_active = :user_active,
|
||
|
|
user_changer = :user_changer,
|
||
|
|
user_changed = :user_changed
|
||
|
|
WHERE user_id = :user_id";
|
||
|
|
|
||
|
|
$insertStmt = $this->realestatedatainc_connection->prepare($insertSQL);
|
||
|
|
$updateStmt = $this->realestatedatainc_connection->prepare($updateSQL);
|
||
|
|
|
||
|
|
$counter = 0;
|
||
|
|
|
||
|
|
foreach ($users as $user) {
|
||
|
|
|
||
|
|
$user_id = (string) (trim($user['UserName']) ?? '');
|
||
|
|
$user_name = (string) (trim($user['UserName']) ?? '');
|
||
|
|
$user_email = (string) (trim($user['Email']) ?? '');
|
||
|
|
|
||
|
|
$raw_password = (string) ($user['Password'] ?? '');
|
||
|
|
$user_password = password_hash($raw_password, PASSWORD_DEFAULT);
|
||
|
|
|
||
|
|
$user_role = "User";
|
||
|
|
|
||
|
|
if ($user_name == 'D002116') {
|
||
|
|
$user_role = "Administrator";
|
||
|
|
}
|
||
|
|
|
||
|
|
// normalize to 0/1 from "Active"/anything else
|
||
|
|
$user_active = (int) (strcasecmp(trim((string) ($user['AcctStatus'] ?? '')), 'Active') === 0);
|
||
|
|
|
||
|
|
$user_change_password = 0;
|
||
|
|
|
||
|
|
$now = date("Y-m-d H:i:s");
|
||
|
|
|
||
|
|
$exists = $this->userExists($user_id);
|
||
|
|
|
||
|
|
if ($exists) {
|
||
|
|
$statement = $updateStmt;
|
||
|
|
|
||
|
|
// update-only audit fields
|
||
|
|
$statement->bindValue(':user_changer', 'Migrated');
|
||
|
|
$statement->bindValue(':user_changed', $now);
|
||
|
|
} else {
|
||
|
|
$statement = $insertStmt;
|
||
|
|
|
||
|
|
// insert-only audit fields
|
||
|
|
$statement->bindValue(':user_creator', 'Migrated');
|
||
|
|
$statement->bindValue(':user_created', $now);
|
||
|
|
}
|
||
|
|
|
||
|
|
// shared bindings
|
||
|
|
$statement->bindValue(':user_id', $user_id);
|
||
|
|
$statement->bindValue(':user_name', $user_name);
|
||
|
|
$statement->bindValue(':user_email', $user_email);
|
||
|
|
$statement->bindValue(':user_password', $user_password);
|
||
|
|
$statement->bindValue(':user_role', $user_role);
|
||
|
|
$statement->bindValue(':user_change_password', $user_change_password, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':user_active', $user_active, PDO::PARAM_INT);
|
||
|
|
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$counter++;
|
||
|
|
}
|
||
|
|
$this->log("Processed {$counter} User records...");
|
||
|
|
$this->log("Completed migrating {$counter} User records.");
|
||
|
|
}
|
||
|
|
|
||
|
|
// =====================
|
||
|
|
// Return a Users Object
|
||
|
|
// =====================
|
||
|
|
|
||
|
|
private function getUsers() {
|
||
|
|
|
||
|
|
$SQL = "select * from Users_tbl";
|
||
|
|
|
||
|
|
$users = $this->decweb_connection->query($SQL)->fetchAll(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return $users;
|
||
|
|
}
|
||
|
|
|
||
|
|
// =====================
|
||
|
|
// Return a Users Object
|
||
|
|
// =====================
|
||
|
|
|
||
|
|
private function userExists($username) {
|
||
|
|
|
||
|
|
$SQL = "SELECT user_id
|
||
|
|
FROM view_users
|
||
|
|
WHERE user_id = :username
|
||
|
|
LIMIT 1";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
$statement->bindValue(':username', $username, PDO::PARAM_STR);
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$user = $statement->fetch(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return ($user !== false);
|
||
|
|
}
|
||
|
|
|
||
|
|
// =============
|
||
|
|
// Migrate Users
|
||
|
|
// =============
|
||
|
|
|
||
|
|
private function migratePermitFacts(): void {
|
||
|
|
|
||
|
|
$this->log("Migrating Permit Facts from decweb");
|
||
|
|
|
||
|
|
$this->realestatedatainc_connection->exec("TRUNCATE TABLE permitfacts");
|
||
|
|
|
||
|
|
$permitfacts = $this->getPermitFacts();
|
||
|
|
|
||
|
|
$SQL = "INSERT INTO permitfacts (
|
||
|
|
permitfact_legacy_id,
|
||
|
|
permitfact_entry_date,
|
||
|
|
permitfact_permit_number,
|
||
|
|
permitfact_permit_date,
|
||
|
|
permitfact_county,
|
||
|
|
permitfact_project_address,
|
||
|
|
permitfact_project_name,
|
||
|
|
permitfact_project_type,
|
||
|
|
permitfact_project_city,
|
||
|
|
permitfact_project_state,
|
||
|
|
permitfact_project_zip,
|
||
|
|
permitfact_company,
|
||
|
|
permitfact_address,
|
||
|
|
permitfact_city,
|
||
|
|
permitfact_state,
|
||
|
|
permitfact_zip,
|
||
|
|
permitfact_phone,
|
||
|
|
permitfact_size,
|
||
|
|
permitfact_value,
|
||
|
|
permitfact_work_type,
|
||
|
|
permitfact_building_type,
|
||
|
|
permitfact_lot_block,
|
||
|
|
permitfact_dist_ll,
|
||
|
|
permitfact_owner_name,
|
||
|
|
permitfact_owner_address,
|
||
|
|
permitfact_owner_city,
|
||
|
|
permitfact_owner_state,
|
||
|
|
permitfact_owner_zip,
|
||
|
|
permitfact_owner_phone,
|
||
|
|
permitfact_creator,
|
||
|
|
permitfact_created )
|
||
|
|
VALUES (
|
||
|
|
:permitfact_legacy_id,
|
||
|
|
:permitfact_entry_date,
|
||
|
|
:permitfact_permit_number,
|
||
|
|
:permitfact_permit_date,
|
||
|
|
:permitfact_county,
|
||
|
|
:permitfact_project_address,
|
||
|
|
:permitfact_project_name,
|
||
|
|
:permitfact_project_type,
|
||
|
|
:permitfact_project_city,
|
||
|
|
:permitfact_project_state,
|
||
|
|
:permitfact_project_zip,
|
||
|
|
:permitfact_company,
|
||
|
|
:permitfact_address,
|
||
|
|
:permitfact_city,
|
||
|
|
:permitfact_state,
|
||
|
|
:permitfact_zip,
|
||
|
|
:permitfact_phone,
|
||
|
|
:permitfact_size,
|
||
|
|
:permitfact_value,
|
||
|
|
:permitfact_work_type,
|
||
|
|
:permitfact_building_type,
|
||
|
|
:permitfact_lot_block,
|
||
|
|
:permitfact_dist_ll,
|
||
|
|
:permitfact_owner_name,
|
||
|
|
:permitfact_owner_address,
|
||
|
|
:permitfact_owner_city,
|
||
|
|
:permitfact_owner_state,
|
||
|
|
:permitfact_owner_zip,
|
||
|
|
:permitfact_owner_phone,
|
||
|
|
:permitfact_creator,
|
||
|
|
:permitfact_created ) ";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
|
||
|
|
$counter = 0;
|
||
|
|
|
||
|
|
foreach ($permitfacts as $permitfact) {
|
||
|
|
|
||
|
|
$permitfact_legacy_id = $permitfact['PermitFactsID'] ?? null;
|
||
|
|
$permitfact_entry_date = $permitfact['EntryDate'] ?? null;
|
||
|
|
$permitfact_permit_number = $permitfact['PermitNum'] ?? null;
|
||
|
|
$permitfact_permit_date = $permitfact['PermitDate'] ?? null;
|
||
|
|
$permitfact_county = $this->getCountyByCountyName($permitfact['County']) ?? null;
|
||
|
|
$permitfact_project_address = $permitfact['ProjectAddr'] ?? null;
|
||
|
|
$permitfact_project_name = $permitfact['ProjectName'] ?? null;
|
||
|
|
$permitfact_project_type = $this->getDropdownSerialByValue($permitfact['ProjectType'], 3) ?? null;
|
||
|
|
$permitfact_project_city = $this->getCityByCityName($permitfact['ProjectCity']) ?? null;
|
||
|
|
$permitfact_project_state = $permitfact['ProjectState'] ?? null;
|
||
|
|
$permitfact_project_zip = $permitfact['ProjectZip'] ?? null;
|
||
|
|
$permitfact_company = $permitfact['Company'] ?? null;
|
||
|
|
$permitfact_address = $permitfact['Address'] ?? null;
|
||
|
|
$permitfact_city = $this->getCityByCityName($permitfact['City']) ?? null;
|
||
|
|
$permitfact_state = $permitfact['State'] ?? null;
|
||
|
|
$permitfact_zip = $permitfact['Zip'] ?? null;
|
||
|
|
$permitfact_phone = $this->normailizePhoneNumber($permitfact['Phone']) ?? null;
|
||
|
|
$permitfact_size = $permitfact['Size'] ?? null;
|
||
|
|
$permitfact_value = $permitfact['Value'] ?? null;
|
||
|
|
$permitfact_work_type = $this->getDropdownSerialByValue($permitfact['WorkType'], 4) ?? null;
|
||
|
|
$permitfact_building_type = $this->getDropdownSerialByValue($permitfact['BldgType'], 5) ?? null;
|
||
|
|
$permitfact_lot_block = $permitfact['Lot_BLK'] ?? null;
|
||
|
|
$permitfact_dist_ll = $permitfact['Dist_LL'] ?? null;
|
||
|
|
$permitfact_owner_name = $permitfact['OwnerName'] ?? null;
|
||
|
|
$permitfact_owner_address = $permitfact['OwnerAddress'] ?? null;
|
||
|
|
$permitfact_owner_city = $this->getCityByCityName($permitfact['OwnerCity']) ?? null;
|
||
|
|
$permitfact_owner_state = $permitfact['OwnerState'] ?? null;
|
||
|
|
$permitfact_owner_zip = $permitfact['OwnerZip'] ?? null;
|
||
|
|
$permitfact_owner_phone = $this->normailizePhoneNumber($permitfact['OwnerPhone']) ?? null;
|
||
|
|
|
||
|
|
$statement->bindValue(':permitfact_legacy_id', $permitfact_legacy_id, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_entry_date', $permitfact_entry_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_permit_number', $permitfact_permit_number, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_permit_date', $permitfact_permit_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_county', $permitfact_county, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_project_address', $permitfact_project_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_project_name', $permitfact_project_name, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_project_type', $permitfact_project_type, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_project_city', $permitfact_project_city, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_project_state', $permitfact_project_state, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_project_zip', $permitfact_project_zip, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_company', $permitfact_company, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_address', $permitfact_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_city', $permitfact_city, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_state', $permitfact_state, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_zip', $permitfact_zip, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_phone', $permitfact_phone, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_size', $permitfact_size, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_value', $permitfact_value, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_work_type', $permitfact_work_type, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_building_type', $permitfact_building_type, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_lot_block', $permitfact_lot_block, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_dist_ll', $permitfact_dist_ll, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_owner_name', $permitfact_owner_name, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_owner_address', $permitfact_owner_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_owner_city', $permitfact_owner_city, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':permitfact_owner_state', $permitfact_owner_state, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_owner_zip', $permitfact_owner_zip, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_owner_phone', $permitfact_owner_phone, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_creator', 'Migration', PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':permitfact_created', date("Y-m-d"), PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$counter++;
|
||
|
|
}
|
||
|
|
$this->log("Processed $counter Permit Fact records... ");
|
||
|
|
$this->log("Migration of Permit Facts Completed");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ======================
|
||
|
|
// Migrate Business Facts
|
||
|
|
// ======================
|
||
|
|
|
||
|
|
private function migrateBusinessFacts(): void {
|
||
|
|
|
||
|
|
$this->log("Migrating Business Facts from decweb");
|
||
|
|
|
||
|
|
$this->realestatedatainc_connection->exec("TRUNCATE TABLE businessfacts");
|
||
|
|
|
||
|
|
$businessfacts = $this->getBusinessFacts();
|
||
|
|
|
||
|
|
$SQL = "INSERT INTO businessfacts (
|
||
|
|
businessfact_legacy_id,
|
||
|
|
businessfact_company,
|
||
|
|
businessfact_address_one,
|
||
|
|
businessfact_address_two,
|
||
|
|
businessfact_city,
|
||
|
|
businessfact_state,
|
||
|
|
businessfact_zip,
|
||
|
|
businessfact_county,
|
||
|
|
businessfact_phone,
|
||
|
|
businessfact_fax,
|
||
|
|
businessfact_email_address,
|
||
|
|
businessfact_business_class,
|
||
|
|
businessfact_action,
|
||
|
|
businessfact_employee_count,
|
||
|
|
businessfact_inception,
|
||
|
|
businessfact_sic_code,
|
||
|
|
businessfact_contact_name,
|
||
|
|
businessfact_contact_title,
|
||
|
|
businessfact_license_date,
|
||
|
|
businessfact_home_based_business,
|
||
|
|
businessfact_year_established,
|
||
|
|
businessfact_entry_date,
|
||
|
|
businessfact_square_feet,
|
||
|
|
businessfact_source_lease_ending,
|
||
|
|
businessfact_lease_end,
|
||
|
|
businessfact_creator,
|
||
|
|
businessfact_created )
|
||
|
|
|
||
|
|
VALUES ( :businessfact_legacy_id,
|
||
|
|
:businessfact_company,
|
||
|
|
:businessfact_address_one,
|
||
|
|
:businessfact_address_two,
|
||
|
|
:businessfact_city,
|
||
|
|
:businessfact_state,
|
||
|
|
:businessfact_zip,
|
||
|
|
:businessfact_county,
|
||
|
|
:businessfact_phone,
|
||
|
|
:businessfact_fax,
|
||
|
|
:businessfact_email_address,
|
||
|
|
:businessfact_business_class,
|
||
|
|
:businessfact_action,
|
||
|
|
:businessfact_employee_count,
|
||
|
|
:businessfact_inception,
|
||
|
|
:businessfact_sic_code,
|
||
|
|
:businessfact_contact_name,
|
||
|
|
:businessfact_contact_title,
|
||
|
|
:businessfact_license_date,
|
||
|
|
:businessfact_home_based_business,
|
||
|
|
:businessfact_year_established,
|
||
|
|
:businessfact_entry_date,
|
||
|
|
:businessfact_square_feet,
|
||
|
|
:businessfact_source_lease_ending,
|
||
|
|
:businessfact_lease_end,
|
||
|
|
:businessfact_creator,
|
||
|
|
:businessfact_created )";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
|
||
|
|
$counter = 0;
|
||
|
|
|
||
|
|
foreach ($businessfacts as $businessfact) {
|
||
|
|
|
||
|
|
$businessfact_legacy_id = $businessfact['BizFactsRecordID'] ?? null;
|
||
|
|
$businessfact_company = $businessfact['Company'] ?? null;
|
||
|
|
$businessfact_address_one = $businessfact['Address1'] ?? null;
|
||
|
|
$businessfact_address_two = $businessfact['Address2'] ?? null;
|
||
|
|
$businessfact_city = $this->getCityByCityName($businessfact['City']) ?? null;
|
||
|
|
$businessfact_state = $businessfact['State'] ?? null;
|
||
|
|
$businessfact_zip = $businessfact['Zip'] ?? null;
|
||
|
|
$businessfact_county = $this->getCountyByCountyName($businessfact['County']) ?? null;
|
||
|
|
$businessfact_phone = $this->normailizePhoneNumber($businessfact['Phone']) ?? null;
|
||
|
|
$businessfact_fax = $this->normailizePhoneNumber($businessfact['Fax']) ?? null;
|
||
|
|
$businessfact_email_address = $this->normailizeEmailAddress($businessfact['EmailAddress']) ?? null;
|
||
|
|
$businessfact_business_class = $this->getDropdownSerialByValue($businessfact['BC'], 6) ?? null;
|
||
|
|
$businessfact_action = $this->getDropdownSerialByValue($businessfact['Description'], 7) ?? null;
|
||
|
|
$businessfact_employee_count = $businessfact['ES'] ?? null;
|
||
|
|
$businessfact_inception = $businessfact['BizInception'] ?? null;
|
||
|
|
$businessfact_sic_code = $businessfact['SIC'] ?? null;
|
||
|
|
$businessfact_contact_name = $businessfact['ContactName'] ?? null;
|
||
|
|
$businessfact_contact_title = $businessfact['Title'] ?? null;
|
||
|
|
$businessfact_license_date = $businessfact['LicenseDate'] ?? null;
|
||
|
|
$businessfact_home_based_business = $businessfact['Home'] ?? null;
|
||
|
|
$businessfact_year_established = $businessfact['YearEst'] ?? null;
|
||
|
|
$businessfact_entry_date = $businessfact['EntryDate'] ?? null;
|
||
|
|
$businessfact_square_feet = $businessfact['SQUARE_FEET'] ?? null;
|
||
|
|
$businessfact_source_lease_ending = $businessfact['SOURCE_LEASE_ENDING'] ?? null;
|
||
|
|
$businessfact_lease_end = $businessfact['TLEASEEND'] ?? null;
|
||
|
|
|
||
|
|
$statement->bindValue(':businessfact_legacy_id', $businessfact_legacy_id, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':businessfact_company', $businessfact_company, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_address_one', $businessfact_address_one, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_address_two', $businessfact_address_two, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_city', $businessfact_city, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':businessfact_state', $businessfact_state, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_zip', $businessfact_zip, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_county', $businessfact_county, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':businessfact_phone', $businessfact_phone, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_fax', $businessfact_fax, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_email_address', $businessfact_email_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_business_class', $businessfact_business_class, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':businessfact_action', $businessfact_action, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':businessfact_employee_count', $businessfact_employee_count, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_inception', $businessfact_inception, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_sic_code', $businessfact_sic_code, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_contact_name', $businessfact_contact_name, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_contact_title', $businessfact_contact_title, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_license_date', $businessfact_license_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_home_based_business', $businessfact_home_based_business, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_year_established', $businessfact_year_established, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_entry_date', $businessfact_entry_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_square_feet', $businessfact_square_feet, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_source_lease_ending', $businessfact_source_lease_ending, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_lease_end', $businessfact_lease_end, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_creator', 'Migration', PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':businessfact_created', date("Y-m-d"), PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$counter++;
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Processed $counter Business Fact records... ");
|
||
|
|
$this->log("Migration of Business Facts Completed");
|
||
|
|
}
|
||
|
|
|
||
|
|
// =============================
|
||
|
|
// Migrate Planning/Zoning Facts
|
||
|
|
// =============================
|
||
|
|
|
||
|
|
private function migratePZFacts(): void {
|
||
|
|
|
||
|
|
$this->log("Migrating Business Facts from decweb");
|
||
|
|
|
||
|
|
$this->realestatedatainc_connection->exec("TRUNCATE TABLE pzfacts");
|
||
|
|
|
||
|
|
$pzfacts = $this->getPZFacts();
|
||
|
|
|
||
|
|
$SQL = "INSERT INTO pzfacts (
|
||
|
|
pzfact_legacy_id,
|
||
|
|
pzfact_entry_date,
|
||
|
|
pzfact_county,
|
||
|
|
pzfact_professional_name,
|
||
|
|
pzfact_professional_address,
|
||
|
|
pzfact_professional_state,
|
||
|
|
pzfact_professional_phone,
|
||
|
|
pzfact_professional_fax,
|
||
|
|
pzfact_owner_name,
|
||
|
|
pzfact_owner_address,
|
||
|
|
pzfact_owner_state,
|
||
|
|
pzfact_owner_phone,
|
||
|
|
pzfact_owner_fax,
|
||
|
|
pzfact_project_name,
|
||
|
|
pzfact_project_type,
|
||
|
|
pzfact_project_description,
|
||
|
|
pzfact_project_address,
|
||
|
|
pzfact_project_city,
|
||
|
|
pzfact_action_code,
|
||
|
|
pzfact_district,
|
||
|
|
pzfact_land_lot,
|
||
|
|
pzfact_lot,
|
||
|
|
pzfact_block,
|
||
|
|
pzfact_parcel_number,
|
||
|
|
pzfact_action_date,
|
||
|
|
pzfact_acres,
|
||
|
|
pzfact_status,
|
||
|
|
pzfact_dollar_value,
|
||
|
|
pzfact_estimated_ground_break,
|
||
|
|
pzfact_in_city_limit,
|
||
|
|
pzfact_creator,
|
||
|
|
pzfact_created )
|
||
|
|
|
||
|
|
VALUES ( :pzfact_legacy_id,
|
||
|
|
:pzfact_entry_date,
|
||
|
|
:pzfact_county,
|
||
|
|
:pzfact_professional_name,
|
||
|
|
:pzfact_professional_address,
|
||
|
|
:pzfact_professional_state,
|
||
|
|
:pzfact_professional_phone,
|
||
|
|
:pzfact_professional_fax,
|
||
|
|
:pzfact_owner_name,
|
||
|
|
:pzfact_owner_address,
|
||
|
|
:pzfact_owner_state,
|
||
|
|
:pzfact_owner_phone,
|
||
|
|
:pzfact_owner_fax,
|
||
|
|
:pzfact_project_name,
|
||
|
|
:pzfact_project_type,
|
||
|
|
:pzfact_project_description,
|
||
|
|
:pzfact_project_address,
|
||
|
|
:pzfact_project_city,
|
||
|
|
:pzfact_action_code,
|
||
|
|
:pzfact_district,
|
||
|
|
:pzfact_land_lot,
|
||
|
|
:pzfact_lot,
|
||
|
|
:pzfact_block,
|
||
|
|
:pzfact_parcel_number,
|
||
|
|
:pzfact_action_date,
|
||
|
|
:pzfact_acres,
|
||
|
|
:pzfact_status,
|
||
|
|
:pzfact_dollar_value,
|
||
|
|
:pzfact_estimated_ground_break,
|
||
|
|
:pzfact_in_city_limit,
|
||
|
|
:pzfact_creator,
|
||
|
|
:pzfact_created )";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
|
||
|
|
$counter = 0;
|
||
|
|
|
||
|
|
foreach ($pzfacts as $pzfact) {
|
||
|
|
|
||
|
|
$pzfact_legacy_id = $pzfact['PZ_ID'] ?? null;
|
||
|
|
$pzfact_entry_date = $pzfact['EntryDate'] ?? null;
|
||
|
|
$pzfact_county = $this->getCountyByCountyName($pzfact['County']) ?? null;
|
||
|
|
|
||
|
|
/* Professional */
|
||
|
|
$pzfact_professional_name = $pzfact['ProfessionalName'] ?? null;
|
||
|
|
$pzfact_professional_address = $pzfact['ProfessionalAddress'] ?? null;
|
||
|
|
$pzfact_professional_state = $pzfact['ProfessionalState'] ?? null;
|
||
|
|
$pzfact_professional_phone = $this->normailizePhoneNumber($pzfact['ProfessionalPhone']) ?? null;
|
||
|
|
$pzfact_professional_fax = $this->normailizePhoneNumber($pzfact['ProfessionalFax']) ?? null;
|
||
|
|
|
||
|
|
/* Owner */
|
||
|
|
$pzfact_owner_name = $pzfact['OwnerName'] ?? null;
|
||
|
|
$pzfact_owner_address = $pzfact['OwnerAddress'] ?? null;
|
||
|
|
$pzfact_owner_state = $pzfact['OwnerState'] ?? null;
|
||
|
|
$pzfact_owner_phone = $this->normailizePhoneNumber($pzfact['OwnerPhone']) ?? null;
|
||
|
|
$pzfact_owner_fax = $this->normailizePhoneNumber($pzfact['OwnerFax']) ?? null;
|
||
|
|
|
||
|
|
/* Project */
|
||
|
|
$pzfact_project_name = $pzfact['ProjectName'] ?? null;
|
||
|
|
$pzfact_project_type = $this->getDropdownSerialByValue($pzfact['ProjectType'], 3) ?? null;
|
||
|
|
$pzfact_project_description = $pzfact['ProjectDescription'] ?? null;
|
||
|
|
$pzfact_project_address = $pzfact['ProjectAddress'] ?? null;
|
||
|
|
$pzfact_project_city = $this->getCityByCityName($pzfact['ProjectCity']) ?? null;
|
||
|
|
|
||
|
|
/* Zoning / action */
|
||
|
|
$pzfact_action_code = $this->getDropdownSerialByValue($pzfact['ActionCode'], 8) ?? null;
|
||
|
|
$pzfact_district = $pzfact['District'] ?? null;
|
||
|
|
|
||
|
|
/* Parcel */
|
||
|
|
$pzfact_land_lot = $pzfact['LL'] ?? null;
|
||
|
|
$pzfact_lot = $pzfact['Lot'] ?? null;
|
||
|
|
$pzfact_block = $pzfact['Block'] ?? null;
|
||
|
|
$pzfact_parcel_number = $pzfact['Parcel'] ?? null;
|
||
|
|
|
||
|
|
/* Dates / values */
|
||
|
|
$pzfact_action_date = $pzfact['ActionDate'] ?? null;
|
||
|
|
$pzfact_acres = $pzfact['Acres'] ?? null;
|
||
|
|
$pzfact_status = $pzfact['Status'] ?? null;
|
||
|
|
$pzfact_dollar_value = $pzfact['DollarValueID'] ?? null;
|
||
|
|
$pzfact_estimated_ground_break = $pzfact['Est_Ground_Breaking'] ?? null;
|
||
|
|
|
||
|
|
/* Flags */
|
||
|
|
$pzfact_in_city_limit = isset($pzfact['City']) ? (int) $pzfact['City'] : 0;
|
||
|
|
|
||
|
|
/* Audit */
|
||
|
|
$pzfact_creator = 'Migration';
|
||
|
|
$pzfact_created = date('Y-m-d H:i:s');
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_legacy_id', $pzfact_legacy_id, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':pzfact_entry_date', $pzfact_entry_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_county', $pzfact_county, PDO::PARAM_INT);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_professional_name', $pzfact_professional_name, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_professional_address', $pzfact_professional_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_professional_state', $pzfact_professional_state, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_professional_phone', $pzfact_professional_phone, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_professional_fax', $pzfact_professional_fax, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_owner_name', $pzfact_owner_name, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_owner_address', $pzfact_owner_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_owner_state', $pzfact_owner_state, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_owner_phone', $pzfact_owner_phone, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_owner_fax', $pzfact_owner_fax, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_project_name', $pzfact_project_name, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_project_type', $pzfact_project_type, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':pzfact_project_description', $pzfact_project_description, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_project_address', $pzfact_project_address, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_project_city', $pzfact_project_city, PDO::PARAM_INT);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_action_code', $pzfact_action_code, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':pzfact_district', $pzfact_district, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':pzfact_land_lot', $pzfact_land_lot, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_lot', $pzfact_lot, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_block', $pzfact_block, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_parcel_number', $pzfact_parcel_number, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_action_date', $pzfact_action_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_acres', $pzfact_acres, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_status', $pzfact_status, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_dollar_value', $pzfact_dollar_value, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_estimated_ground_break', $pzfact_estimated_ground_break, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_in_city_limit', $pzfact_in_city_limit, PDO::PARAM_INT);
|
||
|
|
|
||
|
|
$statement->bindValue(':pzfact_creator', $pzfact_creator, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':pzfact_created', $pzfact_created, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$counter++;
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Processed $counter Planning/Zoning Fact records... ");
|
||
|
|
$this->log("Migration of Planning/Zoning Facts Completed");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==========================
|
||
|
|
// Migrate Purchased Services
|
||
|
|
// ==========================
|
||
|
|
|
||
|
|
private function migratePurchasedServices(): void {
|
||
|
|
|
||
|
|
$this->log("Migrating Purchased Services from decweb");
|
||
|
|
|
||
|
|
// $this->realestatedatainc_connection->exec("TRUNCATE TABLE usersubscriptions");
|
||
|
|
$this->realestatedatainc_connection->exec("delete from usersubscriptions where usersubscription_user != 1");
|
||
|
|
|
||
|
|
$purchasedservices = $this->getPurchasedServices();
|
||
|
|
|
||
|
|
$SQL = "INSERT INTO usersubscriptions (
|
||
|
|
|
||
|
|
usersubscription_user,
|
||
|
|
usersubscription_subscription,
|
||
|
|
usersubscription_start_date,
|
||
|
|
usersubscription_end_date,
|
||
|
|
usersubscription_creator,
|
||
|
|
usersubscription_created )
|
||
|
|
|
||
|
|
VALUES ( :usersubscription_user,
|
||
|
|
:usersubscription_subscription,
|
||
|
|
:usersubscription_start_date,
|
||
|
|
:usersubscription_end_date,
|
||
|
|
:usersubscription_creator,
|
||
|
|
:usersubscription_created )";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
|
||
|
|
$counter = 0;
|
||
|
|
|
||
|
|
foreach ($purchasedservices as $service) {
|
||
|
|
|
||
|
|
$legacy_user_id = $service['UserName'] ?? null;
|
||
|
|
|
||
|
|
$legacy_subscription_name = preg_replace('/[^\w]/', '', $service['RptDescript']);
|
||
|
|
$legacy_service_level = $service['ServiceLevel'] ?? null;
|
||
|
|
|
||
|
|
$subscription_map = [
|
||
|
|
'PermitFacts' => [
|
||
|
|
'Advanced' => 1,
|
||
|
|
],
|
||
|
|
'PermitFactsColumbus' => [
|
||
|
|
'Advanced' => 2,
|
||
|
|
],
|
||
|
|
'PermitFactsAugusta' => [
|
||
|
|
'Advanced' => 3,
|
||
|
|
],
|
||
|
|
'PermitFactsMacon' => [
|
||
|
|
'Advanced' => 4,
|
||
|
|
],
|
||
|
|
'PlanningZoning' => [
|
||
|
|
'Basic' => 12,
|
||
|
|
'Advanced' => 5,
|
||
|
|
// 'Advanced' => 6,
|
||
|
|
],
|
||
|
|
'BusinessFacts' => [
|
||
|
|
'Advanced' => 7,
|
||
|
|
'Basic' => 11,
|
||
|
|
],
|
||
|
|
];
|
||
|
|
|
||
|
|
$subscription_serial = $subscription_map[$legacy_subscription_name][$legacy_service_level] ?? null;
|
||
|
|
|
||
|
|
$usersubscription_user = $this->getUserByUserId($legacy_user_id) ?? null;
|
||
|
|
$usersubscription_subscription = $subscription_serial;
|
||
|
|
$usersubscription_start_date = date("Y-m-d", strtotime($service['StartDate']));
|
||
|
|
$usersubscription_end_date = date("Y-m-d", strtotime($service['StopDate']));
|
||
|
|
$usersubscription_creator = 'Migration';
|
||
|
|
$usersubscription_created = date('Y-m-d H:i:s');
|
||
|
|
|
||
|
|
$statement->bindValue(':usersubscription_user', $usersubscription_user, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':usersubscription_subscription', $usersubscription_subscription, PDO::PARAM_INT);
|
||
|
|
$statement->bindValue(':usersubscription_start_date', $usersubscription_start_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':usersubscription_end_date', $usersubscription_end_date, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':usersubscription_creator', $usersubscription_creator, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':usersubscription_created', $usersubscription_created, PDO::PARAM_STR);
|
||
|
|
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$counter++;
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->log("Processed $counter Purchased Services records... ");
|
||
|
|
$this->log("Migration of Purchased Services Completed");
|
||
|
|
}
|
||
|
|
|
||
|
|
// ============================
|
||
|
|
// Return a Permit Facts Object
|
||
|
|
// ============================
|
||
|
|
|
||
|
|
private function getPermitFacts() {
|
||
|
|
|
||
|
|
$SQL = "select * from PermitFacts_tbl";
|
||
|
|
|
||
|
|
$permitfacts = $this->decweb_connection->query($SQL)->fetchAll(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return $permitfacts;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ==============================
|
||
|
|
// Return a Business Facts Object
|
||
|
|
// ==============================
|
||
|
|
|
||
|
|
private function getBusinessFacts() {
|
||
|
|
|
||
|
|
$SQL = "select * from BizFacts_tbl";
|
||
|
|
|
||
|
|
$businessfacts = $this->decweb_connection->query($SQL)->fetchAll(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return $businessfacts;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ========================
|
||
|
|
// Return a PZ Facts Object
|
||
|
|
// ========================
|
||
|
|
|
||
|
|
private function getPZFacts() {
|
||
|
|
|
||
|
|
$SQL = "select * from PZ_tbl";
|
||
|
|
|
||
|
|
$pzfacts = $this->decweb_connection->query($SQL)->fetchAll(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return $pzfacts;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ========================
|
||
|
|
// Return a PZ Facts Object
|
||
|
|
// ========================
|
||
|
|
|
||
|
|
private function getPurchasedServices() {
|
||
|
|
|
||
|
|
$SQL = "select * from PurchasedServices_tbl";
|
||
|
|
|
||
|
|
$pzfacts = $this->decweb_connection->query($SQL)->fetchAll(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return $pzfacts;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ======================
|
||
|
|
// Normalize Phone Number
|
||
|
|
// ======================
|
||
|
|
|
||
|
|
private function normailizePhoneNumber($phonenumber) {
|
||
|
|
|
||
|
|
return preg_replace('/\D+/', '', $phonenumber); // \D = non-digit
|
||
|
|
}
|
||
|
|
|
||
|
|
// =======================
|
||
|
|
// Normalize Email Address
|
||
|
|
// =======================
|
||
|
|
|
||
|
|
function normailizeEmailAddress($email) {
|
||
|
|
|
||
|
|
// Split at the first #
|
||
|
|
$clean = explode('#', $email, 2)[0];
|
||
|
|
|
||
|
|
// Normalize case
|
||
|
|
return strtolower(trim($clean));
|
||
|
|
}
|
||
|
|
|
||
|
|
// ============================
|
||
|
|
// Return a Subscription Object
|
||
|
|
// ============================
|
||
|
|
|
||
|
|
private function getUserByUserId($userid) {
|
||
|
|
|
||
|
|
$SQL = "SELECT user_serial
|
||
|
|
FROM users
|
||
|
|
WHERE user_id = :userid
|
||
|
|
LIMIT 1";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
$statement->bindValue(':userid', $userid, PDO::PARAM_STR);
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
$user = $statement->fetch(PDO::FETCH_ASSOC);
|
||
|
|
|
||
|
|
return $user['user_serial'] ?? null;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ========================
|
||
|
|
// Return a Dropdown Object
|
||
|
|
// ========================
|
||
|
|
|
||
|
|
private function getDropdownSerialByValue($description, $dropdown_type) {
|
||
|
|
|
||
|
|
$SQL = "SELECT dropdown_serial
|
||
|
|
FROM dropdowns
|
||
|
|
WHERE dropdown_value = :description
|
||
|
|
and dropdown_dropdowntype = :dropdown_type
|
||
|
|
LIMIT 1";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
|
||
|
|
$statement->bindValue(':description', $description, PDO::PARAM_STR);
|
||
|
|
$statement->bindValue(':dropdown_type', $dropdown_type, PDO::PARAM_INT);
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
return $statement->fetchColumn() ?: null;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ======================
|
||
|
|
// Return a County Object
|
||
|
|
// ======================
|
||
|
|
|
||
|
|
private function getCountyByCountyName($county_name) {
|
||
|
|
|
||
|
|
$SQL = "SELECT county_serial
|
||
|
|
FROM counties
|
||
|
|
WHERE county_name = :county_name
|
||
|
|
LIMIT 1";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
$statement->bindValue(':county_name', $county_name, PDO::PARAM_STR);
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
return $statement->fetchColumn() ?: null;
|
||
|
|
}
|
||
|
|
|
||
|
|
// ====================
|
||
|
|
// Return a City Object
|
||
|
|
// ====================
|
||
|
|
|
||
|
|
private function getCityByCityName($city_name) {
|
||
|
|
|
||
|
|
$SQL = "SELECT city_serial
|
||
|
|
FROM cities
|
||
|
|
WHERE city_name = :city_name
|
||
|
|
LIMIT 1";
|
||
|
|
|
||
|
|
$statement = $this->realestatedatainc_connection->prepare($SQL);
|
||
|
|
$statement->bindValue(':city_name', $city_name, PDO::PARAM_STR);
|
||
|
|
$statement->execute();
|
||
|
|
|
||
|
|
return $statement->fetchColumn() ?: null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
?>
|