" . sprintf( __( 'Error, problems downloading the file from the URL: %s', 'import-users-from-csv-with-meta' ), $path_to_file->get_error_message() ) . "
";
return false;
}
}
return $path_to_file;
}
function manage_file_upload( $path_to_file ){
$path_to_file = wp_normalize_path( $path_to_file );
$path_to_file = $this->try_download_file( $path_to_file );
if( validate_file( $path_to_file ) !== 0 ){
echo "" . sprintf( __( 'Error, path to file is not well written: %s', 'import-users-from-csv-with-meta' ), $path_to_file ) . "
";
echo sprintf( __( 'Reload or try " . __( 'Error, the file cannot be found', 'import-users-from-csv-with-meta' ) . ": $path_to_file
";
echo sprintf( __( 'Reload or try " . __( 'File must contain at least 2 columns: username and email', 'import-users-from-csv-with-meta' ) . "
";
return false;
}
$restricted_fields = ACUIHelper()->get_restricted_fields();
$restricted_fields_lower = array_map( 'strtolower', $restricted_fields );
$i = 0;
foreach ( $restricted_fields as $acui_restricted_field ) {
$positions[ $acui_restricted_field ] = false;
}
foreach( $data as $element ){
$headers[] = $element;
$restricted_index = array_search( strtolower( $element ), $restricted_fields_lower );
if( $restricted_index !== false )
$positions[ $restricted_fields[ $restricted_index ] ] = $i;
else
$headers_filtered[] = $element;
$i++;
}
update_option( "acui_columns", $headers_filtered );
ACUIHelper()->basic_css();
ACUIHelper()->print_table_header_footer( $headers );
return true;
}
function prepare_array_of_data( &$data ){
for( $i = 0; $i < count( $data ); $i++ ){
$data[$i] = ACUIHelper()->string_conversion( $data[$i] );
if( is_serialized( $data[$i] ) ) // serialized
$data[$i] = @unserialize( trim( $data[$i] ), array( 'allowed_classes' => false ) );
elseif( strpos( $data[$i], "::" ) !== false ) // list of items
$data[$i] = ACUI_Helper::get_array_from_cell( $data[$i] );
}
}
function import_user( $row, $columns, $headers, $data, $positions, $form_data, $settings ){
global $errors, $is_frontend, $is_cron;
$data = apply_filters( 'pre_acui_import_single_user_data', $data, $headers );
do_action( 'pre_acui_import_single_user', $headers, $data );
$username = apply_filters( 'pre_acui_import_single_user_username', $data[0] );
$data[0] = ( $username == $data[0] ) ? $username : sprintf( __( 'Converted to: %s', 'import-users-from-csv-with-meta' ), $username );
$original_email = $data[1];
$email = apply_filters( 'pre_acui_import_single_user_email', $data[1] );
$data[1] = ( $email == $data[1] ) ? $email : sprintf( __( 'Converted to: %s', 'import-users-from-csv-with-meta' ), $email );
$user_id = 0;
$password_position = isset( $positions["password"] ) ? $positions["password"] : false;
$password_changed = false;
$password = ( $password_position === false ) ? wp_generate_password( apply_filters( 'acui_auto_password_length', 12 ), apply_filters( 'acui_auto_password_special_chars', true ), apply_filters( 'acui_auto_password_extra_special_chars', false ) ) : $data[ $password_position ];
$role_position = $positions["role"];
$role = "";
$id_position = isset( $positions["id"] ) ? $positions["id"] : false;
$id = ( empty( $id_position ) ) ? '' : $data[ $id_position ];
$created = true;
if( $role_position === false ){
$role = $settings['role_default'];
}
else{
$roles_cells = explode( ',', $data[ $role_position ] );
if( !is_array( $roles_cells ) )
$roles_cells = array( $roles_cells );
array_walk( $roles_cells, 'trim' );
foreach( $roles_cells as $it => $role_cell )
$roles_cells[ $it ] = strtolower( $role_cell );
$role = $roles_cells;
}
$no_role = ( $role == 'no_role' ) || in_array( 'no_role', $role );
if( !$no_role ){
if( ( !empty( $role ) || is_array( $role ) && empty( $role[0] ) ) && !empty( array_diff( $role, array_keys( wp_roles()->roles ) ) ) && $settings['update_roles_existing_users'] != 'no' ){
if( is_array( $role ) && empty( $role[0] ) )
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'If you are upgrading roles, you must choose at least one role', 'import-users-from-csv-with-meta' ), implode( ', ', $role ) ) );
else
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'Some of the next roles "%s" do not exists', 'import-users-from-csv-with-meta' ), implode( ', ', $role ) ) );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
if ( ( !empty( $role ) || is_array( $role ) && empty( $role[0] ) ) && !empty( array_diff( $role, array_keys( ACUIHelper()->get_editable_roles() ) ) ) ){ // users only are able to import users with a role they are allowed to edit
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'You do not have permission to assign some of the next roles "%s"', 'import-users-from-csv-with-meta' ), implode( ', ', $role ) ) );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
}
if( !empty( $email ) && ( ( sanitize_email( $email ) == '' ) ) ){ // if email is invalid
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'Invalid email "%s"', 'import-users-from-csv-with-meta' ), $email ) );
$data[0] = __('Invalid email','import-users-from-csv-with-meta')." ($email)";
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
elseif( empty( $email ) ) {
$errors[] = ACUIHelper()->new_error( $row, __( 'Email not specified', 'import-users-from-csv-with-meta' ) );
$data[0] = __( 'Email not specified', 'import-users-from-csv-with-meta' );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
if( !empty( $id ) ){ // if user have used id
if( ACUIHelper()->user_id_exists( $id ) ){
if( $settings['update_existing_users'] == 'no' ){
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'User with ID "%s" exists, we ignore it', 'import-users-from-csv-with-meta' ), $id ), 'notice' );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
// we check if username is the same than in row
$user = get_user_by( 'ID', $id );
if( $user->user_login == $username ){
$user_id = $id;
if( $password !== "" && $settings['update_allow_update_passwords'] == 'yes' && $user_id != get_current_user_id() ){
wp_set_password( $password, $user_id );
$password_changed = true;
}
$new_user_id = ACUIHelper()->maybe_update_email( $user_id, $email, $password, $settings['update_emails_existing_users'], $original_email );
if( empty( $new_user_id ) ){
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'User with email "%s" exists, we ignore it', 'import-users-from-csv-with-meta' ), $email ), 'notice' );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
if( is_wp_error( $new_user_id ) ){
$errors[] = ACUIHelper()->new_error( $row, $new_user_id->get_error_message() );
$data[0] = $new_user_id->get_error_message();
$created = false;
}
elseif( $new_user_id == $user_id)
$created = false;
else{
$user_id = $new_user_id;
$new_user = get_user_by( 'id', $new_user_id );
$data[0] = sprintf( __( 'Email has changed, new user created with username %s', 'import-users-from-csv-with-meta' ), $new_user->user_login );
$errors[] = ACUIHelper()->new_error( $row, $data[0], 'notice' );
$created = true;
}
}
else{
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'Problems with ID "%s" username is not the same in the CSV and in database', 'import-users-from-csv-with-meta' ), $id ) );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
}
else{
$user_id = wp_insert_user( array(
'ID' => $id,
'user_login' => $username,
'user_email' => $email,
'user_pass' => $password
) );
$created = true;
$password_changed = true;
}
}
elseif( username_exists( $username ) ){
$user_object = get_user_by( "login", $username );
$user_id = $user_object->ID;
if( $settings['update_existing_users'] == 'no' ){
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'User with username "%s" exists, we ignore it', 'import-users-from-csv-with-meta' ), $username ), 'notice' );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
if( $password !== "" && $settings['update_allow_update_passwords'] == 'yes' && $user_id != get_current_user_id() ){
wp_set_password( $password, $user_id );
$password_changed = true;
}
$new_user_id = ACUIHelper()->maybe_update_email( $user_id, $email, $password, $settings['update_emails_existing_users'], $original_email );
if( empty( $new_user_id ) ){
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'User with email "%s" exists with other username, it will be ignored', 'import-users-from-csv-with-meta' ), $email ), 'notice' );
return array( 'result' => 'ignored', 'user_id' => $new_user_id );
}
if( is_wp_error( $new_user_id ) ){
$data[0] = $new_user_id->get_error_message();
$errors[] = ACUIHelper()->new_error( $row, $data[0] );
$created = false;
}
elseif( $new_user_id == $user_id)
$created = false;
else{
$user_id = $new_user_id;
$new_user = get_user_by( 'id', $new_user_id );
$data[0] = sprintf( __( 'Email has changed, new user created with username %s', 'import-users-from-csv-with-meta' ), $new_user->user_login );
$errors[] = ACUIHelper()->new_error( $row, $data[0], 'warning' );
$created = true;
}
}
elseif( email_exists( $email ) && $settings['allow_multiple_accounts'] == "not_allowed" ){ // if the email is registered, we take the user from this and we don't allow repeated emails
if( $settings['update_existing_users'] == 'no' ){
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'The email %s already exists in the system but is used by a different user than the one indicated in the CSV', 'import-users-from-csv-with-meta' ), $email ), 'warning' );
return array( 'result' => 'ignored', 'user_id' => $user_id );
}
$user_object = get_user_by( "email", $email );
$user_id = $user_object->ID;
$data[0] = sprintf( __( 'User already exists as: %s (in this CSV file, it is called: %s)', 'import-users-from-csv-with-meta' ), $user_object->user_login, $username );
$errors[] = ACUIHelper()->new_error( $row, $data[0], 'warning' );
if( $password !== "" && $settings['update_allow_update_passwords'] == 'yes' && $user_id != get_current_user_id() ){
wp_set_password( $password, $user_id );
$password_changed = true;
}
$created = false;
}
elseif( email_exists( $email ) && $settings['allow_multiple_accounts'] == "allowed" ){ // if the email is registered and repeated emails are allowed
// if user is new, but the password in csv is empty, generate a password for this user
if( $password === "" ) {
$password = wp_generate_password( apply_filters( 'acui_auto_password_length', 12 ), apply_filters( 'acui_auto_password_special_chars', true ), apply_filters( 'acui_auto_password_extra_special_chars', false ) );
}
$hacked_email = ACUI_AllowMultipleAccounts::hack_email( $email );
$user_id = wp_create_user( $username, $password, $hacked_email );
ACUI_AllowMultipleAccounts::hack_restore_remapped_email_address( $user_id, $email );
}
else{
// if user is new, but the password in csv is empty, generate a password for this user
if( $password === "" ) {
$password = wp_generate_password( apply_filters( 'acui_auto_password_length', 12 ), apply_filters( 'acui_auto_password_special_chars', true ), apply_filters( 'acui_auto_password_extra_special_chars', false ) );
}
$user_id = wp_create_user( $username, $password, $email );
$password_changed = true;
}
if( is_wp_error( $user_id ) ){ // in case the user is generating errors after this checks
$errors[] = ACUIHelper()->new_error( $row, sprintf( __( 'Problems with user: "%s" does not exist, error: %s', 'import-users-from-csv-with-meta' ), $username, $user_id->get_error_message() ) );
return array( 'result' => 'ignored', 'user_id' => 0 );
}
$user_object = new WP_User( $user_id );
if( $created || $settings['update_roles_existing_users'] != 'no' ){
if( empty( array_intersect( apply_filters( 'acui_protected_roles', array( 'administrator' ) ), ACUIHelper()->get_roles_by_user_id( $user_id ) ) ) || is_multisite() && is_super_admin( $user_id ) ){
if( $settings['update_roles_existing_users'] == 'yes' || $created ){
$default_roles = $user_object->roles;
foreach ( $default_roles as $default_role ) {
$user_object->remove_role( $default_role );
}
}
if( !$no_role && ( $settings['update_roles_existing_users'] == 'yes' || $settings['update_roles_existing_users'] == 'yes_no_override' || $created ) ){
if( !empty( $role ) ){
if( is_array( $role ) ){
foreach( $role as $single_role ){
$user_object->add_role( $single_role );
}
}
else{
$user_object->add_role( $role );
}
}
$invalid_roles = array();
if( !empty( $role ) ){
if( !is_array( $role ) ){
$role_tmp = $role;
$role = array();
$role[] = $role_tmp;
}
foreach ($role as $single_role) {
$single_role = strtolower($single_role);
if( get_role( $single_role ) ){
$user_object->add_role( $single_role );
}
else{
$invalid_roles[] = trim( $single_role );
}
}
}
if ( !empty( $invalid_roles ) ){
if( count( $invalid_roles ) == 1 )
$data[0] = __('Invalid role','import-users-from-csv-with-meta').' (' . reset( $invalid_roles ) . ')';
else
$data[0] = __('Invalid roles','import-users-from-csv-with-meta').' (' . implode( ', ', $invalid_roles ) . ')';
$errors[] = ACUIHelper()->new_error( $row, $data[0], 'warning' );
}
}
}
}
// Multisite add user to current blog
if( is_multisite() ){
if( $created || $settings['update_roles_existing_users'] != 'no' ){
if( empty( $role ) )
$role = 'subscriber';
if( !is_array( $role ) ){
add_user_to_blog( get_current_blog_id(), $user_id, $role );
}
else{
foreach( $role as $single_role ){
$user_object->add_role( $single_role );
}
}
}
elseif( $settings['update_roles_existing_users'] == 'no' && !is_user_member_of_blog( $user_id, get_current_blog_id() ) ){
add_user_to_blog( get_current_blog_id(), $user_id, 'subscriber' );
}
}
if( $columns > 2 ){
for( $i = 2 ; $i < $columns; $i++ ):
$data[$i] = apply_filters( 'pre_acui_import_single_user_single_data', $data[$i], $headers[$i], $i );
if( !empty( $data ) ){
if( strtolower( $headers[ $i ] ) == "password" ){ // passwords -> continue
continue;
}
elseif( strtolower( $headers[ $i ] ) == "user_pass" ){ // hashed pass
if( !$created && $settings['update_allow_update_passwords'] == 'no' )
continue;
if( !$created && $user_id == get_current_user_id() )
continue;
global $wpdb;
$wpdb->update( $wpdb->users, array( 'user_pass' => wp_slash( $data[ $i ] ) ), array( 'ID' => $user_id ) );
wp_cache_delete( $user_id, 'users' );
continue;
}
elseif( in_array( $headers[ $i ], ACUIHelper()->get_wp_users_fields() ) ){ // wp_user data
if( $data[ $i ] === '' && $settings['empty_cell_action'] == "leave" ){
continue;
}
else{
wp_update_user( array( 'ID' => $user_id, $headers[ $i ] => $data[ $i ] ) );
continue;
}
}
elseif( in_array( $headers[ $i ], ACUIHelper()->get_not_meta_fields() ) ){
continue;
}
else{
if( $data[ $i ] === '' ){
if( $settings['empty_cell_action'] == "delete" )
delete_user_meta( $user_id, $headers[ $i ] );
else
continue;
}
else{
if( is_object( $data[ $i ] ) && get_class( $data[ $i ] ) === '__PHP_Incomplete_Class' )
$errors[] = ACUIHelper()->new_error( $row, __( 'Invalid value __PHP_Incomplete_Class', 'import-users-from-csv-with-meta' ), 'warning' );
else
update_user_meta( $user_id, $headers[ $i ], $data[ $i ] );
continue;
}
}
}
endfor;
}
ACUIHelper()->print_row_imported( $row, $data, $errors );
do_action( 'acui_post_import_single_user', $headers, $data, $user_id, $role, $positions, $form_data, $is_frontend, $is_cron, $password_changed, $created );
$mail_for_this_user = false;
if( $is_cron ){
if( get_option( "acui_cron_send_mail" ) ){
if( $created || ( !$created && get_option( "acui_cron_send_mail_updated" ) ) ){
$mail_for_this_user = true;
}
}
}
else{
if( isset( $form_data["sends_email"] ) && $form_data["sends_email"] ){
if( $created || ( !$created && ( isset( $form_data["send_email_updated"] ) && $form_data["send_email_updated"] ) ) )
$mail_for_this_user = true;
}
}
// wordpress default user created and edited emails
if( get_option('acui_automatic_created_edited_wordpress_email') === 'true' ){
( $created ) ? do_action( 'register_new_user', $user_id ) : do_action( 'edit_user_created_user', $user_id, 'both' );
}
// send email
$mail_for_this_user = apply_filters( 'acui_send_email_for_user', $mail_for_this_user, $headers, $data, $user_id, $role, $positions, $form_data, $is_frontend, $is_cron, $password_changed );
if( isset( $mail_for_this_user ) && $mail_for_this_user ){
if( !$created && $settings['update_allow_update_passwords'] == 'no' )
$password = __( 'Password has not been changed', 'import-users-from-csv-with-meta' );
ACUI_Email_Options::send_email( $user_object, $positions, $headers, $data, $created, $password );
}
return array( 'result' => ( $created ) ? 'created' : 'updated', 'user_id' => $user_id, 'role' => is_array( $role ) ? $role : array( $role ) );
}
function prepare_settings( $form_data ){
global $is_cron;
$settings = array();
$settings['update_existing_users'] = isset( $form_data["update_existing_users"] ) ? sanitize_text_field( $form_data["update_existing_users"] ) : '';
$role_default = isset( $form_data["role"] ) ? $form_data["role"] : array( '' );
if( !is_array( $role_default ) )
$role_default = array( $role_default );
array_walk( $role_default, 'sanitize_text_field' );
$role_default = array_values( array_filter( $role_default ) );
$settings['role_default'] = $role_default;
$settings['update_emails_existing_users'] = isset( $form_data["update_emails_existing_users"] ) ? sanitize_text_field( $form_data["update_emails_existing_users"] ) : 'yes';
$settings['update_roles_existing_users'] = isset( $form_data["update_roles_existing_users"] ) ? sanitize_text_field( $form_data["update_roles_existing_users"] ) : 'no';
$settings['update_allow_update_passwords'] = isset( $form_data["update_allow_update_passwords"] ) ? sanitize_text_field( $form_data["update_allow_update_passwords"] ) : 'yes';
$settings['empty_cell_action'] = isset( $form_data["empty_cell_action"] ) ? sanitize_text_field( $form_data["empty_cell_action"] ) : '';
$settings['delete_users_not_present'] = isset( $form_data["delete_users_not_present"] ) ? sanitize_text_field( $form_data["delete_users_not_present"] ) : '';
$settings['delete_users_assign_posts'] = isset( $form_data["delete_users_assign_posts"] ) ? sanitize_text_field( $form_data["delete_users_assign_posts"] ) : '';
$settings['delete_users_only_specified_role'] = isset( $form_data["delete_users_only_specified_role"] ) ? sanitize_text_field( $form_data["delete_users_only_specified_role"] ) : false;
$settings['change_role_not_present'] = isset( $form_data["change_role_not_present"] ) ? sanitize_text_field( $form_data["change_role_not_present"] ) : '';
$settings['change_role_not_present_role'] = isset( $form_data["change_role_not_present_role"] ) ? sanitize_text_field( $form_data["change_role_not_present_role"] ) : '';
$settings['not_present_same_role'] = isset( $form_data["not_present_same_role"] ) ? sanitize_text_field( $form_data["not_present_same_role"] ) : 'no';
$settings['not_present_only_imported'] = isset( $form_data["not_present_only_imported"] ) ? sanitize_text_field( $form_data["not_present_only_imported"] ) : 'no';
if( $is_cron ){
$settings['allow_multiple_accounts'] = ( get_option( "acui_cron_allow_multiple_accounts" ) == "allowed" ) ? "allowed" : "not_allowed";
}
else {
$settings['allow_multiple_accounts'] = ( empty( $form_data["allow_multiple_accounts"] ) ) ? "not_allowed" : sanitize_text_field( $form_data["allow_multiple_accounts"] );
}
return $settings;
}
function time_exceeded( $time_start, $time_per_step ){
if( $time_per_step == -1 )
return false;
return ( microtime( true ) - $time_start ) >= $time_per_step;
}
function ajax_import_users_batch(){
check_ajax_referer( 'codection-security', 'security' );
if( !current_user_can( apply_filters( 'acui_capability', 'create_users' ) ) )
wp_die( __( 'Only users who are allowed to create users can import them.', 'import-users-from-csv-with-meta' ) );
$step = isset( $_POST['step'] ) ? absint( $_POST['step'] ) : 1;
$row = isset( $_POST['row'] ) ? absint( $_POST['row'] ) : 0;
$file = isset( $_POST['file_path'] ) ? sanitize_text_field( $_POST['file_path'] ) : '';
// On first step, we might need to handle the upload if it's there
if( $step == 1 && empty( $file ) ){
if( !empty( $_FILES['uploadfile']['tmp_name'] ) ){
$original_ext = strtolower( pathinfo( $_FILES['uploadfile']['name'], PATHINFO_EXTENSION ) );
$allowed_extensions = apply_filters( 'acui_allowed_upload_extensions', array( 'csv' ) );
if( !in_array( $original_ext, $allowed_extensions, true ) ){
wp_send_json_error( array( 'message' => __( 'Invalid file type.', 'import-users-from-csv-with-meta' ) ) );
}
$upload_dir = wp_upload_dir();
$file = $upload_dir['basedir'] . '/acui-import-' . uniqid() . '.' . $original_ext;
move_uploaded_file( $_FILES['uploadfile']['tmp_name'], $file );
}
elseif( !empty( $_POST['path_to_file'] ) ){
$file = $this->manage_file_upload( $_POST['path_to_file'] );
}
}
if( empty( $file ) || !file_exists( $file ) ){
wp_send_json_error( array( 'message' => __( 'File not found', 'import-users-from-csv-with-meta' ) ) );
}
$form_data = array();
if( isset( $_POST['form'] ) )
parse_str( $_POST['form'], $form_data );
else
$form_data = $_POST;
// If it's step 1, we also need to get total rows
$total_rows = 0;
if( $step == 1 ){
$handle = fopen( $file, "r" );
while( !feof( $handle ) ){
fgets( $handle );
$total_rows++;
}
fclose( $handle );
// Subtract header row
$total_rows = max( 0, $total_rows - 1 );
set_transient( 'acui_import_total_rows', $total_rows, HOUR_IN_SECONDS );
}
else{
$total_rows = get_transient( 'acui_import_total_rows' );
}
ob_start();
$import_status = $this->import_users( $file, $form_data, false, false, $step, $row, ACUI_IMPORT_TIME_LIMIT, $total_rows, true );
$log = ob_get_clean();
// Accumulate log across batches for Log tab
if ( $step == 1 ) {
set_transient( 'acui_import_log_accumulate', $log, HOUR_IN_SECONDS );
} else {
$accumulated = get_transient( 'acui_import_log_accumulate' );
set_transient( 'acui_import_log_accumulate', ( $accumulated !== false ? $accumulated : '' ) . $log, HOUR_IN_SECONDS );
}
$next_row = $import_status['row'];
$percentage = $total_rows ? min( 100, floor( ( $next_row / ( $total_rows + 1 ) ) * 100 ) ) : 100;
// Results data from import_users() for live progress
$results_data = isset( $import_status['results'] ) ? $import_status['results'] : array( 'created' => 0, 'updated' => 0, 'deleted' => 0 );
$errors_count = isset( $import_status['errors_count'] ) ? $import_status['errors_count'] : 0;
if( $import_status['done'] ){
// Finalize
$users_created = get_transient( 'acui_users_created' );
$users_updated = get_transient( 'acui_users_updated' );
$users_ignored = get_transient( 'acui_users_ignored' );
$users_deleted = get_transient( 'acui_users_deleted' );
if( !is_array( $users_created ) ) $users_created = array();
if( !is_array( $users_updated ) ) $users_updated = array();
if( !is_array( $users_ignored ) ) $users_ignored = array();
if( !is_array( $users_deleted ) ) $users_deleted = array();
do_action( 'acui_after_import_users', $users_created, $users_updated, $users_deleted, $users_ignored );
// Generate results HTML for the Log tab
$errors_for_log = get_transient( 'acui_errors' );
if( !is_array( $errors_for_log ) ) $errors_for_log = array();
ob_start();
ACUIHelper()->print_errors( $errors_for_log );
ACUIHelper()->print_results( $results_data, $errors_for_log );
ACUIHelper()->print_end_of_process();
$results_log_html = ob_get_clean();
// Save full log (rows + results) for the Log tab
$full_log = get_transient( 'acui_import_log_accumulate' );
update_option( 'acui_last_import_log', array(
'date' => current_time( 'mysql' ),
'html' => ( $full_log !== false ? $full_log : $log ) . $results_log_html,
), false );
delete_transient( 'acui_import_log_accumulate' );
// Clean up file if it was our temporary one
if( strpos( $file, 'acui-import-' ) !== false )
@unlink( $file );
wp_send_json_success( array(
'step' => 'done',
'percentage' => 100,
'log' => $log,
'results' => $results_data,
'errors_count' => $errors_count,
'file_path' => $file
) );
}
else{
wp_send_json_success( array(
'step' => $step + 1,
'row' => $next_row,
'percentage' => $percentage,
'total_steps' => ceil( $total_rows / ACUI_IMPORT_BATCH_SIZE ),
'log' => $log,
'results' => $results_data,
'errors_count' => $errors_count,
'file_path' => $file
) );
}
}
function save_transients( $columns, $headers, $headers_filtered, $positions, $errors, $errors_totals, $results, $users_created, $users_updated, $users_ignored, $roles_appeared, $users_deleted = array() ){
$pfx = 'acui' . ( $this->session_id ? '_' . $this->session_id : '' ) . '_';
$ttl = HOUR_IN_SECONDS;
set_transient( $pfx . 'columns', $columns, $ttl );
set_transient( $pfx . 'headers', $headers, $ttl );
set_transient( $pfx . 'headers_filtered', $headers_filtered, $ttl );
set_transient( $pfx . 'positions', $positions, $ttl );
set_transient( $pfx . 'errors', $errors, $ttl );
set_transient( $pfx . 'errors_totals', $errors_totals, $ttl );
set_transient( $pfx . 'results', $results, $ttl );
set_transient( $pfx . 'users_created', $users_created, $ttl );
set_transient( $pfx . 'users_updated', $users_updated, $ttl );
set_transient( $pfx . 'users_ignored', $users_ignored, $ttl );
set_transient( $pfx . 'roles_appeared', $roles_appeared, $ttl );
set_transient( $pfx . 'users_deleted', $users_deleted, $ttl );
}
function import_users( $file, $form_data, $_is_cron = false, $_is_frontend = false, $step = 1, $initial_row = 0, $time_per_step = -1, $total_rows = 0, $is_batch = false ){
if( !function_exists( 'wp_delete_user' ) ) {
require_once( ABSPATH . 'wp-admin/includes/user.php' );
}
$time_start = microtime( true );
if( $time_per_step == -1 || $time_per_step > ACUI_IMPORT_BATCH_SIZE ) // If it's not batch, or a large limit (legacy)
@set_time_limit( 0 );
global $errors, $errors_totals, $is_frontend, $is_cron;
$is_frontend = $_is_frontend;
$is_cron = $_is_cron;
$is_backend = !$is_frontend && !$is_cron;
$row = $initial_row;
$limit = ($time_per_step > 0 && $time_per_step <= 100) ? ACUI_IMPORT_BATCH_SIZE : 0;
$settings = $this->prepare_settings( $form_data );
@ini_set( 'auto_detect_line_endings', TRUE );
ACUIHelper()->maybe_disable_wordpress_core_emails();
if( $step == 1 ){
$columns = 0;
$headers = array();
$headers_filtered = array();
$positions = array();
$errors = array();
$errors_totals = array( 'notices' => 0, 'warnings' => 0, 'errors' => 0 );
$results = array( 'created' => 0, 'updated' => 0, 'deleted' => 0, 'ignored' => 0 );
$users_created = array();
$users_updated = array();
$users_ignored = array();
$roles_appeared = $settings['role_default'];
$users_deleted = array();
}
else{
$pfx = 'acui' . ( $this->session_id ? '_' . $this->session_id : '' ) . '_';
$columns = get_transient( $pfx . 'columns' );
$headers = get_transient( $pfx . 'headers' );
$headers_filtered = get_transient( $pfx . 'headers_filtered' );
$positions = get_transient( $pfx . 'positions' );
$errors = get_transient( $pfx . 'errors' );
$errors_totals = get_transient( $pfx . 'errors_totals' );
$results = get_transient( $pfx . 'results' );
if( !is_array( $results ) ) $results = array( 'created' => 0, 'updated' => 0, 'deleted' => 0, 'ignored' => 0 );
if( !isset( $results['ignored'] ) ) $results['ignored'] = 0;
$users_created = get_transient( $pfx . 'users_created' );
$users_updated = get_transient( $pfx . 'users_updated' );
$users_ignored = get_transient( $pfx . 'users_ignored' );
$roles_appeared = get_transient( $pfx . 'roles_appeared' );
$users_deleted = get_transient( $pfx . 'users_deleted' );
if( !is_array( $users_created ) ) $users_created = array();
if( !is_array( $users_updated ) ) $users_updated = array();
if( !is_array( $users_ignored ) ) $users_ignored = array();
if( !is_array( $users_deleted ) ) $users_deleted = array();
}
echo '';
if( $step == 1 ){
do_action( 'acui_before_import_users' );
echo '
' . apply_filters( 'acui_log_main_title', __('Importing users','import-users-from-csv-with-meta') ) . '
';
echo apply_filters( "acui_log_header", "
" . __('Ready to registers','import-users-from-csv-with-meta') . "
" );
echo apply_filters( "acui_log_header_first_row_explanation", "
" . __('First row represents the format of the sheet','import-users-from-csv-with-meta') . "
" );
} else {
ACUIHelper()->print_table_header_footer( $headers, false );
}
$file = apply_filters( 'acui_import_file_path', $file, $form_data );
$delimiter = ACUIHelper()->detect_delimiter( $file );
$manager = new SplFileObject( $file );
if( $initial_row != 0 )
$manager->seek( $initial_row );
while( $data = $manager->fgetcsv( $delimiter ) ):
$row++;
if( count( $data ) == 1 )
$data = $data[0];
if( $data == NULL ){
break;
}
elseif( !is_array( $data ) ){
echo apply_filters( 'acui_message_csv_file_bad_formed', __( 'CSV file seems to be badly formed. Please use LibreOffice to create and manage a CSV to be sure the format is correct', 'import-users-from-csv-with-meta') );
break;
}
if( $row == 1 ){
$columns = count( $data );
$result = $this->read_first_row( $data, $headers, $positions, $headers_filtered );
if( !$result )
break;
}
else{
$this->prepare_array_of_data( $data );
if( count( $data ) != $columns ):
$errors[] = ACUIHelper()->new_error( $row, __( 'Row does not have the same columns as the header, we are going to ignore this row', 'import-users-from-csv-with-meta') );
continue;
endif;
$result = $this->import_user( $row, $columns, $headers, $data, $positions, $form_data, $settings );
if( empty( $result['role'] ) )
$result['role'] = array();
$roles_appeared = array_unique( array_intersect( $roles_appeared, $result['role'] ) );
switch( $result['result'] ){
case 'created':
$results['created']++;
array_push( $users_created, $result['user_id'] );
break;
case 'updated':
$results['updated']++;
array_push( $users_updated, $result['user_id'] );
break;
case 'ignored':
$results['ignored']++;
if( !empty( $result['user_id'] ) )
array_push( $users_ignored, $result['user_id'] );
break;
}
}
if( $limit > 0 && ($row - $initial_row) >= $limit ){
$this->save_transients( $columns, $headers, $headers_filtered, $positions, $errors, $errors_totals, $results, $users_created, $users_updated, $users_ignored, $roles_appeared, $users_deleted );
if( $is_cron ){
as_enqueue_async_action( 'acui_cron_process_step', array( 'step' => $step + 1, 'initial_row' => $row, 'session_id' => $this->session_id ) );
}
ACUIHelper()->print_table_end( false );
echo '