<?php
ini_set("memory_limit", "-1");
set_time_limit(0);
error_reporting(E_ALL);
require_once 'Db.php';
require_once 'CPlatosChiffrement.class.php';
$db = new Database('localhost', 'ldc-crm', 'root', '');
//$db = new Database('192.168.34.2', 'ldc-crm', 'ldc-crmadm', 'wai6dahB');
if (!isset($argv[1]) || !isset($argv[2]))
    die('params missing');
$name = $argv[1];
$siteId = $argv[2];
$table = $name."_migration";
$maxdate = date("Y-m-d", strtotime("-36 month", time()));
$db->requestPush("CREATE TABLE IF NOT EXISTS $table (
   `id` BIGINT(20) NOT NULL AUTO_INCREMENT,
   `user_id` BIGINT(20) NOT NULL DEFAULT '0',
   `firstname` VARCHAR(255) NOT NULL DEFAULT '0',
   `lastname` VARCHAR(255) NOT NULL DEFAULT '0',
   `birthdate` VARCHAR(255) NULL DEFAULT '0',
   `address` VARCHAR(255) NULL DEFAULT '0',
   `address2` VARCHAR(255) NULL DEFAULT '0',
   `city` VARCHAR(255) NULL DEFAULT '0',
   `postcode` VARCHAR(255) NULL DEFAULT '0',
   `optin` INT(11) NOT NULL DEFAULT '0',
   `email` VARCHAR(255) NOT NULL DEFAULT '0',
   `pwd` VARCHAR(255) NOT NULL DEFAULT '0',
   `created_at` TIMESTAMP NOT NULL,
   `updated_at` TIMESTAMP NOT NULL,
   `last_cnx` TIMESTAMP NOT NULL,
   PRIMARY KEY (`id`)
) COLLATE='utf8_unicode_ci' ENGINE=InnoDB AUTO_INCREMENT=0;");

$getAccounts = function ($skip) use ($db, $siteId, $maxdate){
    return $db->requestAll("SELECT *
FROM useraccount
INNER JOIN siteuser su ON useraccount.user_id = su.siteuser_useraccountId
WHERE su.siteuser_siteId = :siteid
AND user_id >= 701697
AND user_status = 1
AND user_lastUpdateDate >= :maxdate 
AND (user_emailCheckStatus <> 0 OR user_emailCheckStatus IS NULL)
AND (user_lastCnxDateHeure IS NOT NULL AND user_lastCnxDateHeure <> '0000-00-00 00:00:00')
AND user_lastCnxDateHeure >= :maxdate 
AND user_email IS NOT NULL LIMIT 4600 OFFSET ". ($skip * 4600), ['siteid' => $siteId, 'maxdate' => $maxdate]);
};
$k = 0;
while (count($accounts = $getAccounts($k++))) {
    $sql = [];
    $toto = "";
    foreach ($accounts as $account){
        $crm_id = $account['user_id'];
        $civility = $account['user_civilite'];
        $firstname = ucfirst($account['user_prenom']);
        $lastname = ucfirst($account['user_nom']);
        $birthdate = $account['user_dateNaissance'];
        $address1 = !empty($account['user_adresse1']) ? $account['user_adresse1'] : null;
        $address2 = !empty($account['user_adresse2']) ? $account['user_adresse2'] : null;
        $postcode = (!empty($account['user_codePostal']) && $account['user_codePostal'] !== 0 ? $account['user_codePostal'] : null);
        $city = !empty($account['user_ville']) ? $account['user_ville'] : null;
        $optin = $account['user_inscritNewsletter'];
        $haschcode = $account['user_hashcode'];
        $status = $account['user_status'];
        $created_at = $account['user_creationDate'];
        $updated_at = $account['user_lastUpdateDate'];
        $email = strtolower($account['user_email']);
        //$password = CPlatosChiffrement::decrypt($account['user_pwd']);
        $password = "toto";
        $last_cnx = $account['user_lastCnxDateHeure'];
        $datas = [
            $crm_id,
            $firstname,
            $lastname,
            $birthdate,
            $address1,
            $address2,
            $city,
            $postcode,
            $optin,
            $email,
            $password,
            $created_at,
            $updated_at,
            $last_cnx
        ];
        $toto = "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
        $db->requestPushInsert("INSERT INTO $table (user_id, firstname, lastname, birthdate, address, address2, city, postcode, optin, email, pwd, created_at, updated_at, last_cnx) VALUES $toto", $datas);
    }
}