schema_name = $wpdb->dbname;
$this->action =
isset( $_REQUEST['action'] ) ? // phpcs:ignore WordPress.Security.NonceVerification
sanitize_text_field( wp_unslash( $_REQUEST['action'] ) ) : null; // phpcs:ignore WordPress.Security.NonceVerification
}
/**
* Show HTML page
*
* @return void
*/
public function show() {
?>
action ) { // phpcs:ignore WordPress.Security.NonceVerification
if ( isset( $_REQUEST['action2'] ) && 'save' === $_REQUEST['action2'] ) { // phpcs:ignore WordPress.Security.NonceVerification
$this->upload_file();
} else {
$this->show_body_upload();
}
} elseif ( 'mapping' === $this->action ) {
$this->show_body_mapping();
} elseif ( 'import_start' === $this->action ) {
$this->show_body_import_start();
} elseif ( 'import' === $this->action ) {
$this->show_body_import();
} elseif ( 'reload' === $this->action ) {
$this->show_body_reload();
} else {
$this->show_body_main();
}
}
/**
* Show mapping page
*
* @return void
*/
protected function show_body_mapping() {
$csv_mapping = new WPDA_CSV_Mapping();
$csv_mapping->show();
}
/**
* Show main page body
*
* @return void
*/
protected function show_body_main() {
$csv_list_view = new WPDA_List_View(
array(
'page_hook_suffix' => 'CSV',
'table_name' => WPDA_CSV_Uploads_Model::get_base_table_name(),
'list_table_class' => 'WPDataAccess\\CSV_Files\\WPDA_CSV_List_Table',
'edit_form_class' => 'WPDataAccess\\Simple_Form\\WPDA_Simple_Form',
'subtitle' => '',
)
);
$csv_list_view->show();
}
/**
* Show upload body
*
* @return void
*/
protected function show_body_upload() {
$csv_id =
isset( $_REQUEST['csv_id'] ) ? // phpcs:ignore WordPress.Security.NonceVerification
sanitize_text_field( wp_unslash( $_REQUEST['csv_id'] ) ) : ''; // phpcs:ignore WordPress.Security.NonceVerification
$csv_name =
isset( $_REQUEST['csv_name'] ) ? // phpcs:ignore WordPress.Security.NonceVerification
sanitize_text_field( wp_unslash( $_REQUEST['csv_name'] ) ) : ''; // phpcs:ignore WordPress.Security.NonceVerification
$csv_encoding =
isset( $_REQUEST['csv_encoding'] ) ? // phpcs:ignore WordPress.Security.NonceVerification
sanitize_text_field( wp_unslash( $_REQUEST['csv_encoding'] ) ) : ''; // phpcs:ignore WordPress.Security.NonceVerification
?>
Reading CSV file info...';
$dbrow = WPDA_CSV_Uploads_Model::query( $csv_id );
global $wpdb;
if ( 1 === $wpdb->num_rows ) {
if ( ! isset( $dbrow[0]->csv_real_file_name ) ) {
echo 'ERROR: No CSV file found for this import
';
return;
}
if ( ! isset( $dbrow[0]->csv_mapping ) ) {
echo 'ERROR: Cannot import CSV file without column mapping
';
return;
}
echo 'Validating column mapping...
';
$upload_dir = WPDA::get_plugin_upload_dir();
$file_name = $upload_dir . $dbrow[0]->csv_real_file_name;
$mapping = json_decode( $dbrow[0]->csv_mapping, true );
$delimiter = isset( $mapping['settings']['delimiter'] ) ? $mapping['settings']['delimiter'] : ',';
$date_format = isset( $mapping['settings']['date_format'] ) ? $mapping['settings']['date_format'] : '%Y-%m-%d';
$has_header_columns = isset( $mapping['settings']['has_header_columns'] ) ? $mapping['settings']['has_header_columns'] : true;
$schema_name = isset( $mapping['database']['wpdaschema_name'] ) ? esc_attr( $mapping['database']['wpdaschema_name'] ) : '';
$table_name = isset( $mapping['database']['table_name'] ) ? esc_attr( $mapping['database']['table_name'] ) : '';
$table_name = str_replace( '`', '', $table_name );
$table_columns = isset( $mapping['columns'] ) ? $mapping['columns'] : array();
if ( 'on' === $truncate_table ) {
// Truncate table.
$wpdadb = WPDADB::get_db_connection( $schema_name );
$wpdadb->query(
$wpdb->prepare(
'truncate table `%1s`', // phpcs:ignore WordPress.DB.PreparedSQLPlaceholders
array(
WPDA::remove_backticks( $table_name ),
)
)
);
echo 'Table `' . esc_attr( $table_name ) . '` truncated...
';
}
$columns_inserted = '';
foreach ( $table_columns as $table_column ) {
$columns_inserted .= $table_column . ',';
}
$columns_inserted = substr( $columns_inserted, 0, strlen( $columns_inserted ) - 1 );
$data_type = array();
$data_type_before = array();
$data_type_after = array();
$wpda_list_columns = WPDA_List_Columns_Cache::get_list_columns( $schema_name, $table_name );
$column_data_types = $wpda_list_columns->get_table_columns();
foreach ( $column_data_types as $column ) {
$data_type[ $column['column_name'] ] = WPDA::get_type( $column['data_type'] );
switch ( $data_type[ $column['column_name'] ] ) {
case 'number':
$data_type_before[ $column['column_name'] ] = '';
$data_type_after[ $column['column_name'] ] = '';
break;
case 'date':
$data_type_before[ $column['column_name'] ] = "str_to_date('";
$data_type_after[ $column['column_name'] ] = "','$date_format')";
break;
default:
$data_type_before[ $column['column_name'] ] = "'";
$data_type_after[ $column['column_name'] ] = "'";
}
}
// phpcs:disable Squiz.PHP.DiscouragedFunctions.Discouraged, PluginCheck.CodeAnalysis.PHPErrorReporting.IniDirectiveDisplay_errors
echo 'Enabling buffering...
';
set_time_limit( 0 );
@ini_set( 'zlib.output_compression', false );
@ini_set( 'implicit_flush', true );
@ini_set( 'output_buffering', true );
@ini_set( 'display_errors', false );
ob_implicit_flush( true );
echo 'Reading CSV file...
';
@ini_set( 'auto_detect_line_endings', true );
// phpcs:enable Squiz.PHP.DiscouragedFunctions.Discouraged, PluginCheck.CodeAnalysis.PHPErrorReporting.IniDirectiveDisplay_errors
if ( false !== ( $fp = fopen( $file_name, 'rb' ) ) ) { // phpcs:ignore
$wpdadb = WPDADB::get_db_connection( $schema_name );
if ( null !== $wpdadb ) {
$row = 0;
$inserted = 0;
$errors = 0;
echo 'Connecting to database...
';
$suppress_errors = $wpdadb->suppress_errors( true );
while ( false !== ( $data = fgetcsv( $fp, 0, $delimiter, '"' ) ) ) { // phpcs:ignore
if ( 0 === $row && 'true' === $has_header_columns ) { // phpcs:ignore
// Skip first row.
} else {
// Prepare insert array.
$wpda_insert_column_values = array();
$row_values_valid = true;
for ( $column = 0; $column < count( $data ); $column++ ) { // phpcs:ignore
if ( isset( $table_columns[ $column ] ) ) {
// Add column to array.
if ( isset( $table_columns[ $column ] ) ) {
if (
'number' === $data_type[ $table_columns[ $column ] ] ||
'date' === $data_type[ $table_columns[ $column ] ]
) {
if ( null === $data[ $column ] || 'null' === $data[ $column ] || '' === $data[ $column ] ) {
$wpda_insert_column_values[ $table_columns[ $column ] ] = null;
} else {
if ( 'number' === $data_type[ $table_columns[ $column ] ] ) {
$wpda_insert_column_values[ $table_columns[ $column ] ] = $data[ $column ];
} else {
try {
$date_value = substr( $data[ $column ], 0, 10 );
$convert_date = \DateTime::createFromFormat( str_replace( '%', '', $date_format ), $date_value );
if ( false === $convert_date ) {
$error_msg = 'Cannot convert ' . esc_attr( $date_value ) . ' to date (using format ' . esc_attr( $date_format ) . ')';
echo 'ERROR: ' . esc_attr( $error_msg ) . '
';
$row_values_valid = false;
// Write error to log file
WPDA::wpda_log_wp_error( $error_msg );
} else {
$wpda_insert_column_values[ $table_columns[ $column ] ] = $convert_date->format( 'Y-m-d' );
}
} catch ( \Exception $e ) {
echo 'Cannot convert ' . esc_attr( $date_value ) . ' to date (using format ' . esc_attr( $date_format ) . ')
';
echo 'ERROR: ' . esc_attr( $error_msg ) . '
';
$row_values_valid = false;
// Write error to log file
WPDA::wpda_log_wp_error( $error_msg );
}
}
}
} else {
$wpda_insert_column_values[ $table_columns[ $column ] ] = $data[ $column ];
}
}
}
}
if ( $row_values_valid ) {
// Insert row.
$result = $wpdadb->insert(
$table_name,
$wpda_insert_column_values
); // db call ok; no-cache ok.
if ( 1 === $result ) {
$inserted++;
} else {
// Try to insert with plain sql.
$insert = "insert into `{$wpdadb->dbname}`.`{$table_name}` ";
$insert .= "({$columns_inserted}) values (";
for ( $column = 0; $column < count( $data ); $column++ ) { // phpcs:ignore
if ( isset( $table_columns[ $column ] ) ) {
if (
'' === $data[ $column ] &&
(
'number' === $data_type[ $table_columns[ $column ] ] ||
'date' === $data_type[ $table_columns[ $column ] ]
)
) {
$insert .=
'null,';
} else {
$insert .=
$data_type_before[ $table_columns[ $column ] ] .
str_replace( "'", "\'", $data[ $column ] ) .
$data_type_after[ $table_columns[ $column ] ] .
',';
}
}
}
$insert = substr( $insert, 0, strlen( $insert ) - 1 );
$insert .= ')';
if ( false === $wpdadb->query( $insert ) ) {
if ( '' === $wpdadb->last_error ) {
echo 'Error: ' . esc_attr( $insert ) . '
';
// Write error to log file
WPDA::wpda_log_wp_error( $insert );
} else {
echo 'Error: ' . esc_attr( $wpdadb->last_error ) . '
';
// Write error to log file
WPDA::wpda_log_wp_error( $wpdadb->last_error );
}
$errors++;
} else {
$inserted++;
}
}
} else {
$errors++;
}
}
$row++;
}
$wpdadb->suppress_errors( $suppress_errors );
}
fclose( $fp ); // phpcs:ignore
$row--;
echo "Import ready!
";
echo esc_attr( $row ) . ' rows processed
';
echo esc_attr( $inserted ) . ' rows inserted
';
echo esc_attr( $errors ) . ' rows with errors
';
} else {
echo 'ERROR: File not found
';
}
}
}
/**
* Body reload
*
* @return void
*/
protected function show_body_reload() {
$csv_id =
isset( $_REQUEST['csv_id'] ) ?
sanitize_text_field( wp_unslash( $_REQUEST['csv_id'] ) ) : ''; // input var okay.
// Security check.
$wp_nonce = isset( $_REQUEST['_wpnonce'] ) ? sanitize_text_field( wp_unslash( $_REQUEST['_wpnonce'] ) ) : '?'; // input var okay.
if ( ! wp_verify_nonce( $wp_nonce, "wpda-reload-csv-{$csv_id}" ) ) {
wp_die( esc_html__( 'ERROR: Not authorized', 'wp-data-access' ) );
}
$this->show_body_upload();
}
/**
* Upload file
*
* @return void
*/
protected function upload_file() {
// Security check.
$wp_nonce = isset( $_REQUEST['_wpnonce'] ) ? sanitize_text_field( wp_unslash( $_REQUEST['_wpnonce'] ) ) : '?'; // input var okay.
if ( ! wp_verify_nonce( $wp_nonce, "wpda-import-csv-{$this->schema_name}" ) ) {
wp_die( esc_html__( 'ERROR: Not authorized', 'wp-data-access' ) );
}
// phpcs:disable Squiz.PHP.DiscouragedFunctions.Discouraged
$temp_file_name = isset( $_FILES['filename']['tmp_name'] ) ?
sanitize_text_field( $_FILES['filename']['tmp_name'] ) : ''; // For Windows: do NOT unslash!
// phpcs:enable Squiz.PHP.DiscouragedFunctions.Discouraged
$orig_file_name = isset( $_FILES['filename']['name'] ) ?
sanitize_text_field( wp_unslash( $_FILES['filename']['name'] ) ) : '';
if ( isset( $_FILES['filename'] ) && isset( $_REQUEST['csv_name'] ) ) {
if (
isset( $_FILES['filename']['error'] ) &&
UPLOAD_ERR_OK === $_FILES['filename']['error'] &&
is_uploaded_file( $temp_file_name )
) {
echo '
';
esc_html_e( 'Uploading file', 'wp-data-access' ) . ' ' . esc_attr( $orig_file_name ) . '...';
echo '
';
$upload_dir = WPDA::get_plugin_upload_dir();
$real_file_name = 'wpda_csv_upload_' . gmdate( 'YmdHis' ) . '.csv';
$csv_id = isset( $_REQUEST['csv_id'] ) ?
sanitize_text_field( wp_unslash( $_REQUEST['csv_id'] ) ) : ''; // input var okay.
$csv_name = sanitize_text_field( wp_unslash( $_REQUEST['csv_name'] ) ); // input var okay.
$csv_encoding = isset( $_REQUEST['csv_encoding'] ) ? 'UTF-8' : '';
// Process file and save a local copy.
$fp = $this->file_pointer = fopen( $temp_file_name, 'rb' ); // phpcs:ignore
if ( false !== $this->file_pointer ) {
if ( ! is_dir( $upload_dir ) ) {
WPDA::wpda_create_content_folder();
}
$fw = fopen( $upload_dir . "{$real_file_name}", 'w' ); // phpcs:ignore
while ( ! feof( $this->file_pointer ) ) {
$file_content = fread( $this->file_pointer, 1024 ); // phpcs:ignore
if ( 'UTF-8' === $csv_encoding ) {
// UTF-8 encoding
fwrite( $fw, mb_convert_encoding( $file_content, 'UTF-8', 'ISO-8859-1' ) ); // phpcs:ignore
} else {
// No encoding
fwrite( $fw, $file_content ); // phpcs:ignore
}
}
}
fclose( $fp ); // phpcs:ignore
fclose( $fw ); // phpcs:ignore
esc_html_e( 'Saving file info...', 'wp-data-access' );
echo '
';
if ( '' === $csv_id ) {
// New CSV import.
$result = WPDA_CSV_Uploads_Model::insert( $csv_name, $real_file_name, $orig_file_name, $csv_encoding );
} else {
// Reload CSV.
$oldrow = WPDA_CSV_Uploads_Model::query( $csv_id );
$result = WPDA_CSV_Uploads_Model::update( $csv_id, $real_file_name, $orig_file_name, $csv_encoding );
if ( $result ) {
// Remove old file.
if ( isset( $oldrow[0]->csv_real_file_name ) ) {
unlink( WPDA::get_plugin_upload_dir() . $oldrow[0]->csv_real_file_name ); // phpcs:ignore
}
}
}
if ( false === $result ) {
$msg = new WPDA_Message_Box(
array(
'message_text' => esc_html__( 'Processing CSV file failed', 'wp-data-access' ),
'message_type' => 'error',
'message_is_dismissible' => false,
)
);
$msg->box();
} else {
$wp_nonce_csv_id = '' === $csv_id ? $result : $csv_id;
$wp_nonce_action = "wpda-mapping-{$wp_nonce_csv_id}";
$wp_nonce = esc_attr( wp_create_nonce( $wp_nonce_action ) );
?>
Upload successful
esc_html__( 'File upload failed', 'wp-data-access' ),
'message_type' => 'error',
'message_is_dismissible' => false,
)
);
$msg->box();
}
}
}
}