Drupal → Программный экспорт товаров в CSV

define('MODULENAME_CSV_DELIMITER', ';');
 
/**
 * Export form.
 */
function modulename_export_form($form, &$form_state) {
  $form['submit'] = array(
    '#type' => 'submit',
    '#value' => t('Run export'),
  );
 
  if (!empty($_SESSION['export_file_ready'])) {
    drupal_add_js('
      jQuery(function() {
        var link = document.createElement("a");
        link.download = "products-export.csv";
        link.href = "' . file_create_url('public://products-export.csv') . '";
        link.click();
      });
    ', 'inline');
    unset($_SESSION['export_file_ready']);
  }
 
  return $form;
}
 
/**
 * Export form submit callback.
 */
function modulename_export_form_submit($form, &$form_state) {
  // Create CSV file with header
  $csv_handle = fopen('temporary://products-export.csv', 'w');
  fputcsv($csv_handle, modulename_get_csv_header_col_names(), MODULENAME_CSV_DELIMITER);
 
  // Create batch operations
  $product_display_nids = modulename_get_product_display_nids();
  $batch_operations = array();
  foreach ($product_display_nids as $product_display_nid) {
    $batch_operations[] = array('modulename_export_node', array($product_display_nid));
  }
 
  // Batch init
  $batch = array(
    'operations' => $batch_operations,
    'finished' => 'modulename_export_batch_finished',
  );
  batch_set($batch);
}
 
/**
 * Batch worker callback.
 */
function modulename_export_node($product_display_nid, &$context) {
  $csv_handle = fopen('temporary://products-export.csv', 'a');
 
  $product_display_wrapper = entity_metadata_wrapper('node', $product_display_nid);
  $product_wrapper = $product_display_wrapper->field_product;
 
  $row = array_fill_keys(modulename_get_csv_header_col_names(), '');
 
  $row['nid']      = $product_display_nid;
  $row['title']    = $product_display_wrapper->title->value();
  $row['body']     = $product_display_wrapper->body->value->value();
  $row['status']   = $product_display_wrapper->status->value();
  $row['category'] = $product_display_wrapper->field_product_category->name->value();
  $row['sku']      = $product_wrapper->sku->value();
  $row['price']    = commerce_currency_amount_to_decimal($product_wrapper->commerce_price->amount->value(), $product_wrapper->commerce_price->currency_code->value());
 
  fputcsv($csv_handle, $row, MODULENAME_CSV_DELIMITER);
  fclose($csv_handle);
}
 
/**
 * Batch finish callback.
 */
function modulename_export_batch_finished($success, $results, $operations) {
  file_unmanaged_move('temporary://products-export.csv', 'public://products-export.csv', FILE_EXISTS_REPLACE);
  $_SESSION['export_file_ready'] = TRUE;
}
 
/**
 * Return all product display nids.
 */
function modulename_get_product_display_nids() {
  return db_select('node', 'node')
    ->fields('node', array('nid'))
    ->condition('node.type', 'product_display')
    ->execute()
    ->fetchCol();
}
 
/**
 * Return CSV header col names.
 */
function modulename_get_csv_header_col_names() {
  return array(
    'nid',
    'title',
    'body',
    'status',
    'category',
    'sku',
    'price',
  );
}