<?php
    $conn = null;

	try
    {
	    $dbhost = "localhost";
	    $user = "root";
	    $pass = "vicidialnow";
	    $dbname = "asterisk";

	    $conn = new mysqli($dbhost, $user, $pass, $dbname);
	    $conn->set_charset('utf8');
    }
    catch(mysqli_sql_exception $e)
    {
        echo $e->getMessage();
    	echo $e->getTraceAsString();
    }

    try
    {

    	$queryS = $conn->stmt_init();
	    $queryS->prepare("SELECT *
                        FROM vicidial_list
                        WHERE list_id = 1240 AND status LIKE 'INT' AND (
                            (phone_number NOT LIKE '' AND phone_number NOT IN (
                                SELECT phone_number
                                FROM vicidial_list
                                WHERE list_id = 1241 AND phone_number NOT LIKE ''
                            )) OR (phone_number NOT LIKE '' AND alt_phone NOT IN (
                                SELECT alt_phone
                                FROM vicidial_list
                                WHERE list_id = 1241 AND alt_phone NOT LIKE ''
                            ))
                        )"
        );
        $queryS->execute();
        $queryS->store_result();
        $queryS->bind_result($lead_id, $entry_date, $modify_date, $status, $user, $vendor_lead_code, $source_id, $list_id,
            $gmt_offset_now, $called_since_last_reset, $phone_code, $phone_number, $title, $first_name, $middle_initial, $last_name,
            $address1, $address2, $address3, $city, $state, $province, $postal_code, $country_code, $gender, $date_of_birth, $alt_phone, $email,
            $security_phrase, $comments, $called_count, $last_local_call_time, $rank, $owner, $entry_list_id);

        $insertList = "INSERT INTO vicidial_list (entry_date, modify_date, status, user, vendor_lead_code, source_id, list_id,
                        gmt_offset_now, called_since_last_reset, phone_code, phone_number, title, first_name, middle_initial, last_name,
                        address1, address2, address3, city, state, province, postal_code, country_code, gender, date_of_birth, alt_phone, email,
                        security_phrase, comments, called_count, last_local_call_time, rank, owner, entry_list_id)
                        VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
        $insertCustom = "INSERT INTO custom_1241 (lead_id, nome, indirizzo, codice_fiscale, data_nascita, residenza, operazione_in_corso,
                        durata, datore_lavoro, decorrenza, altre_trattenute, rata, seconda_trattenuta, commenti)
                        VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
        $conn->autocommit(false);

        $count = 0;
        $inTransaction = false;
        $listId = 1241;

        while($queryS->fetch())
        {
            if($count == 0)
            {
                if($inTransaction)
                {
                    $conn->commit();
                    $inTransaction = false;
                }
                $inTransaction = true;
            }

            $queryI1 = $conn->stmt_init();
            $queryI1->prepare("INSERT INTO vicidial_list (entry_date, modify_date, status, user, vendor_lead_code, source_id, list_id,
                        gmt_offset_now, called_since_last_reset, phone_code, phone_number, title, first_name, middle_initial, last_name,
                        address1, address2, address3, city, state, province, postal_code, country_code, gender, date_of_birth, alt_phone, email,
                        security_phrase, comments, called_count, last_local_call_time, rank, owner, entry_list_id)
                        VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");

	    $queryI1->bind_param("ssssssssssssssssssssssssssssssssss",
		$entry_date, $modify_date, $status, $user, $vendor_lead_code, $source_id, $listId,
		$gmt_offset_now, $called_since_last_reset, $phone_code, $phone_number, $title, $first_name,
		$middle_initial, $last_name, $address1, $address2, $address3, $city, $state, $province, $postal_code,
		$country_code, $gender, $date_of_birth, $alt_phone, $email, $security_phrase, $comments,
		$called_count, $last_local_call_time, $rank, $owner, $entry_list_id);
            $queryI1->execute();
            $new_lead_id = $queryI1->insert_id;
            $queryI1->close();

            $queryS2 = $conn->stmt_init();
            $queryS2->prepare("SELECT * FROM custom_1240 WHERE lead_id = ?");
            $queryS2->bind_param("s", $lead_id);
            $queryS2->execute();
            $queryS2->store_result();
            $queryS2->bind_result($lead_id_2, $nome, $indirizzo, $codice_fiscale, $data_nascita, $residenza, $operazione_in_corso,
                $durata, $datore_lavoro, $decorrenza, $altre_trattenute, $rata, $seconda_trattenuta, $commenti);


            if($queryS2->fetch())
            {
                $queryI2 = $conn->stmt_init();
                $queryI2->prepare("INSERT INTO custom_1241 (lead_id, nome, indirizzo, codice_fiscale, data_nascita, residenza, operazione_in_corso,
                        durata, datore_lavoro, decorrenza, altre_trattenute, rata, seconda_trattenuta, commenti)
                        VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
                $queryI2->bind_param("ssssssssssssss", $new_lead_id, $nome, $indirizzo, $codice_fiscale, $data_nascita,
			$residenza, $operazione_in_corso, $durata, $datore_lavoro, $decorrenza, $altre_trattenute,
			$rata, $seconda_trattenuta, $commenti);
                $queryI2->execute();
                $queryI2->close();
            }
            $queryS2->free_result();
            $queryS2->close();

            $count++;
            if($count == 100)
            {
                if($inTransaction)
                {
                    $conn->commit();
                    $inTransaction = false;
                }
                $count = 0;
            }
        }
        if($inTransaction)
            $conn->commit();
        $inTransaction = false;

        $queryS->free_result();
        $queryS->close();
    }
    catch(mysqli_sql_exception $e)
    {
        if($inTransaction)
            $conn->rollback();

    	echo $e->getMessage();
    	echo $e->getTraceAsString();
    }

    $conn->close();
?>