diff --git a/tests/migrate/migration.class.php b/tests/migrate/migration.class.php index 49f07f2b19..722da877a8 100644 --- a/tests/migrate/migration.class.php +++ b/tests/migrate/migration.class.php @@ -588,7 +588,7 @@ class Migration { } static function update_transaction($params) { - return false; + //return false; $table = Database::get_main_table(TABLE_MIGRATION_TRANSACTION); if (empty($params['id'])) { error_log('No transaction id provided during update_transaction'); @@ -643,13 +643,15 @@ class Migration { $transactions = self::get_transactions(0, $branch_info['branch_id']); $options = array('where' => array('branch_id = ? and status_id <> ?' => array($branch_info['branch_id'], 0)), 'order' => 'id desc', 'limit' => '1'); - $transaction_info = self::get_transaction_by_params($options, 'first'); - $latest_id = $transaction_info['id']; + $transaction_info = self::get_transaction_by_params($options, 'first'); - $latest_id_attempt = $latest_id + 1; - - $item = 1; - + $latest_id_attempt = 1; + if ($transaction_info) { + $latest_id = $transaction_info['id']; + $latest_id_attempt = $latest_id + 1; + } + + $item = 1;//counter if (!empty($transactions)) { $count = count($transactions); error_log("\nTransactions found: $count"); @@ -666,6 +668,8 @@ class Migration { $item++; //-- + error_log("Waiting for transaction #$latest_id_attempt"); + //Checking "huecos" //Waiting transaction is fine continue: if ($transaction['id'] == $latest_id_attempt) { @@ -675,8 +679,6 @@ class Migration { exit; } - error_log("Waiting for transaction $latest_id_attempt"); - //Loading function $function_to_call = "transaction_" . $transaction['action']; if (method_exists('MigrationCustom', $function_to_call)) { @@ -684,20 +686,23 @@ class Migration { $result = MigrationCustom::$function_to_call($transaction, $matches['web_service_calls']); error_log($result['message']); - exit; + self::update_transaction(array('id' => $transaction['id'] , 'status_id' => $result['status_id'])); + + /* if ($result['error'] == false) { //Updating transaction - self::update_transaction(array('id' => $transaction['id'] , 'status_id' => $result['status_id'])); + } else { //failed self::update_transaction(array('id' => $transaction['id'] , 'status_id' => MigrationCustom::TRANSACTION_STATUS_FAILED)); - } + }*/ } else { // method does not exist error_log("Function does $function_to_call not exists"); //Failed self::update_transaction(array('id' => $transaction['id'] , 'status_id' => MigrationCustom::TRANSACTION_STATUS_FAILED)); } + exit; } } else { error_log('No transactions to load'); diff --git a/tests/migrate/migration.custom.class.php b/tests/migrate/migration.custom.class.php index 708f4949aa..2cf8061528 100644 --- a/tests/migrate/migration.custom.class.php +++ b/tests/migrate/migration.custom.class.php @@ -670,7 +670,7 @@ class MigrationCustom { global $api_failureList; $user_id = UserManager::add($user_info); if ($user_id) { - return array( + return array( 'message' => "User was created : $user_id", 'status_id' => self::TRANSACTION_STATUS_SUCCESSFUL );