233 lines
8.2 KiB
PHP
233 lines
8.2 KiB
PHP
<?php
|
|
// $Id: booking.import_data.inc,v 0.1
|
|
|
|
/**
|
|
* @file
|
|
* Provide functionality to upload csv for bulk update of payment data
|
|
*/
|
|
|
|
|
|
function booking_import_data_admin()
|
|
{
|
|
global $event;
|
|
|
|
$prefix = t("<p>Upload csv file containing data to import. Minimum fields present should be <strong>nid and booking_status</strong>, " .
|
|
" along with user-specified fields of <strong>!config</strong>. CSV Column names should match exactly (case sensitive).</p>",
|
|
array('!config' => variable_get('booking_import_include_fields', '')));
|
|
|
|
$form = array();
|
|
|
|
$form['file'] = array(
|
|
'#type' => 'file',
|
|
'#title' => t('CSV data'),
|
|
'#description' => t('Upload CSV data to be processed'),
|
|
);
|
|
|
|
$form['submit'] = array (
|
|
'#type' => 'submit',
|
|
'#value' => t('Submit'),
|
|
);
|
|
|
|
return array (
|
|
'first_para' => array (
|
|
'#type' => 'markup',
|
|
'#markup' => $prefix,
|
|
),
|
|
'form' => $form,
|
|
);
|
|
}
|
|
|
|
function booking_import_data_admin_validate($form, &$form_state) {
|
|
$file = file_save_upload('file', array(
|
|
'file_validate_extensions' => array('txt csv'), // Validate extensions.
|
|
));
|
|
// If the file passed validation:
|
|
if ($file) {
|
|
// Move the file, into the Drupal file system
|
|
if ($file = file_move($file, 'public://', FILE_EXISTS_REPLACE )) {
|
|
// Save the file for use in the submit handler.
|
|
$form_state['storage']['file'] = $file;
|
|
}
|
|
else {
|
|
form_set_error('file', t('Failed to write the uploaded file to the site\'s file folder.'));
|
|
}
|
|
}
|
|
else {
|
|
form_set_error('file', t('No file was uploaded.'));
|
|
}
|
|
}
|
|
|
|
function booking_import_data_admin_submit($form, &$form_state)
|
|
{
|
|
global $event;
|
|
$array = array();
|
|
//$expected_fields = array('nid', 'booking_amount_paid', 'booking_total_pay_reqd', 'booking_status');
|
|
$error = false;
|
|
$update_counter = 0;
|
|
$delimiter = ",";
|
|
$result_array = array();
|
|
$update_messages = array();
|
|
$datetime_fields = array('booking_outflight_origin_ts', 'booking_outflight_destination_ts', 'booking_rtrnflight_origin_ts',
|
|
'booking_rtrnflight_destination_ts','booking_dob', 'booking_passport_expiry_date');
|
|
$builtin_fields_to_import = array('nid', 'booking_status');
|
|
$custom_fields_to_import = explode(";", variable_get('booking_import_include_fields', ''));
|
|
$fields_to_import = array_merge($builtin_fields_to_import, $custom_fields_to_import);
|
|
|
|
//get the file name from temporary storage field
|
|
$file = $form_state['storage']['file'];
|
|
// We are done with the file, remove it from storage.
|
|
unset($form_state['storage']['file']);
|
|
|
|
drupal_set_message(t('Input file uploaded successfully, filename: "@filename"', array('@filename' => $file->filename)));
|
|
$filename = drupal_realpath($file->uri);
|
|
|
|
//as per http://stackoverflow.com/questions/4541749/fgetcsv-fails-to-read-line-ending-in-mac-formatted-csv-file-any-better-solution
|
|
ini_set("auto_detect_line_endings", "1");
|
|
|
|
//convert csv to associative array
|
|
//based on http://stackoverflow.com/questions/4801895/csv-to-associative-array
|
|
if( ($handle = fopen( $filename, "r")) !== FALSE) {
|
|
$rowCounter = 0;
|
|
while (($rowData = fgetcsv($handle, 0, $delimiter)) !== FALSE) {
|
|
if( 0 === $rowCounter) {
|
|
$headerRecord = $rowData;
|
|
} else {
|
|
foreach( $rowData as $key => $value) {
|
|
$array[$rowCounter - 1][ $headerRecord[$key] ] = $value;
|
|
}
|
|
}
|
|
$rowCounter++;
|
|
}
|
|
fclose($handle);
|
|
}
|
|
else //unable to open file
|
|
{
|
|
drupal_set_message("Error: Unable to open input file " . $filename, 'error', FALSE);
|
|
return;
|
|
}
|
|
|
|
//watchdog('booking', "<pre>Import data:\n@info</pre>", array('@info' => print_r( $array, true)));
|
|
|
|
//process the input data
|
|
foreach ($array as $record)
|
|
{
|
|
//watchdog('booking', "<pre>Processing row data:\n@info</pre>", array('@info' => print_r( $record, true)));
|
|
$update_counter++;
|
|
$update_text = "";
|
|
$update_array = array();
|
|
|
|
//do some error checking
|
|
foreach($fields_to_import as $field)
|
|
{
|
|
/*
|
|
if (! isset($record[$field]))
|
|
watchdog('booking', 'Non-set field !field: !info', array ('!field' => $field, '!info' => var_export($record, TRUE)));
|
|
if ($record[$field] == '')
|
|
watchdog('booking', 'Blank field !field: !info', array ('!field' => $field, '!info' => var_export($record, TRUE)));
|
|
*/
|
|
|
|
//make sure to skip the nid field since we can't update that
|
|
if ($field == 'nid')
|
|
{
|
|
//do nothing
|
|
}
|
|
//convert the booking status to the number used internally
|
|
elseif ($field == 'booking_status')
|
|
{
|
|
$update_text .= " set booking status to '" . $record[$field] . "'; ";
|
|
$update_array[$field] = _booking_status_lookup($record[$field]);
|
|
}
|
|
//check for fields that need to be converted to a timestamp from text
|
|
elseif (in_array($field, $datetime_fields))
|
|
{
|
|
$update_array[$field] = _datetime_to_ts_nonstrict($record[$field]);
|
|
$update_text .= " set '" . $field . "' to '" . $update_array[$field] . "'; ";
|
|
}
|
|
elseif ( (! isset($record[$field])) || $record[$field] == '' )
|
|
{
|
|
//drupal_set_message("Error: Unable to locate expected field '$field' in input file for record number $update_counter.", 'error', FALSE);
|
|
//watchdog('booking', 'Processing user record: @info', array ('@info' => $record['nid']));
|
|
//$error = true;
|
|
//skip to the next record
|
|
//continue 2;
|
|
}
|
|
else
|
|
{
|
|
$update_text .= " set '" . $field . "' to '" . $record[$field] . "'; ";
|
|
$update_array[$field] = $record[$field];
|
|
}
|
|
}
|
|
|
|
drupal_set_message(t("Updating record !nid as follows: !update", array('!nid' => $record['nid'], '!update' => $update_text)));
|
|
|
|
$query = db_update('booking_person')
|
|
->fields($update_array)
|
|
->condition('nid', $record['nid']);
|
|
$rows = $query->execute();
|
|
|
|
//$args = $query->getArguments();
|
|
/*
|
|
watchdog('booking', "Update Query:<br />@info<br />Condition: @nid<br />Rows affected: @rows<br />Values: <br /><pre>@values</pre>",
|
|
array('@info' => (string) $query, '@nid' => $record['nid'], '@rows' => $rows, '@values' => print_r( $update_array, true) ));
|
|
*/
|
|
|
|
$update_messages[] = t("Update Query:<br />@info<br />Condition: @nid<br />Rows affected: @rows<br />Values: <br /><pre>@values</pre>", array('@info' => (string) $query, '@nid' => $record['nid'], '@rows' => $rows, '@values' => print_r( $update_array, true) ));
|
|
|
|
/*
|
|
$result_array[] = t('Setting payment for id !nid to $!price of total required $!total and status to !status',
|
|
array('!nid' => $record['nid'],
|
|
'!price' => $record['booking_amount_paid'],
|
|
'!total' => $record['booking_total_pay_reqd'],
|
|
'!status' => _booking_status_lookup($record['booking_status'])
|
|
)
|
|
);
|
|
*/
|
|
/*
|
|
//TODO: output this from $result_array
|
|
drupal_set_message(t('Setting payment for id !nid to $!price of total required $!total and status to !status',
|
|
array('!nid' => $record['nid'],
|
|
'!price' => $record['booking_amount_paid'],
|
|
'!total' => $record['booking_total_pay_reqd'],
|
|
'!status' => _booking_status_lookup($record['booking_status']))
|
|
));
|
|
*/
|
|
|
|
// watchdog('booking', 'Setting payment for regn id !nid to $!price and status to !status',
|
|
// array('!nid' => $record['nid'], '!price' => $record['booking_amount_paid'], '!status' => _booking_status_lookup($record['booking_status'])));
|
|
|
|
/*
|
|
db_update('booking_person')
|
|
->fields(array(
|
|
'booking_amount_paid' => $record['booking_amount_paid'],
|
|
'booking_total_pay_reqd' => $record['booking_total_pay_reqd'],
|
|
'booking_status' => _booking_status_lookup($record['booking_status']),
|
|
))
|
|
->condition('nid', $record['nid'])
|
|
->execute();
|
|
*/
|
|
|
|
} //end processing input data
|
|
|
|
//output our results to watchdog
|
|
//watchdog('booking', '<pre>@print_r</pre>', array('@print_r', print_r( $result_array, TRUE)));
|
|
|
|
//delete the uploaded file
|
|
file_delete($file);
|
|
|
|
//let the user know we finished
|
|
drupal_set_message(t("Finished processing @count records from input file \"@filename\"",
|
|
array('@count' => $update_counter, '@filename' => $file->filename)));
|
|
|
|
watchdog('booking', "<pre>Data Import concluded:\n" . implode("\n", $update_messages) . "</pre>");
|
|
|
|
/*
|
|
// Make the storage of the file permanent
|
|
$file->status = FILE_STATUS_PERMANENT;
|
|
// Save file status.
|
|
file_save($file);
|
|
// Set a response to the user.
|
|
drupal_set_message(t('The form has been submitted and the image has been saved, filename: @filename.', array('@filename' => $file->filename)));
|
|
*/
|
|
|
|
|
|
} |