drupal - Drupal 7 批处理页面示例

Question

我正在尝试设置一个批处理页面进行处理，我需要一个示例。示例模块中给出的示例在一个表单中，我需要一个可以独立于处理批处理请求的表单运行的页面。

例如：

function mymodule_batch_2() {
 $operations[] = array('mymodule_onefunction','mymodule_anotherfunction') 
 $batch = array(
  'operations' => $operations, 
  'finished' => 'mymodule_finished',
  // We can define custom messages instead of the default ones. 
  'title' => t('Processing batch 2'), 
  'init_message' => t('Batch 2 is starting.'), 
  'progress_message' => t('Processed @current out of @total.'), 
  'error_message' => t('Batch 2 has encountered an error.'),
);
  batch_set($batch);
  batch_process('');
}

批处理函数将以 $operations 的形式调用其他函数。

Answer 1

你需要给批处理一个 id 来工作。batch_process('mybatch') 否则 yourmexample 是正确的。你对这个策略有什么特别的问题吗？

Answer 2

在这里，您可以看到我的批处理 relization 示例，其中包含调用批处理的表单：

    function my_module_menu() {
      $items['admin/commerce/import'] = array(
        'title' => t('Import'),
        'page callback' => 'drupal_get_form',
        'page arguments' => array('my_module_settings_form'),
        'access arguments' => array('administer site settings'),
        'type' => MENU_NORMAL_ITEM,
      );
      return $items;
    }

    /**
     * Import form
     */
    function my_module_settings_form() {
      $form = array();
      $form['import'] = array(
        '#type' => 'fieldset',
        '#title' => t('Import'),
        '#collapsible' => TRUE,
        '#collapsed' => FALSE,
      );

      $form['import']['submit'] = array(
        '#type' => 'submit',
        '#value' => t('Import'),
      );
      return $form;
    }

    function my_module_settings_form_submit($form, &$form_state) {
      batch_my_module_import_start();
    }


    /**
     * Batch start function
     */
    function batch_my_module_import_start() {

      $batch = array(
        'title' => t('Import products'),
        'operations' => array(
          array('_batch_my_module_import', array()),
        ),
        'progress_message' => t('Import. Operation @current out of @total.'),
        'error_message' => t('Error!'),
        'finished' => 'my_module_batch_finished',
      );

      batch_set($batch);
    }

    /**
     * Import from 1C operation. Deletes Products
     */
    function _batch_my_module_import(&$context) {
      // Your iterms. In my case select all products
      $pids = db_select('commerce_product', 'p')
          ->fields('p', array('sku', 'product_id', 'title'))
          ->condition('p.type', 'product')
          ->execute()
          ->fetchAll();

      // Get Count of products
      if (empty($context['sandbox']['progress'])) {
        $context['sandbox']['progress'] = 0;
        $context['sandbox']['max'] = count($pids);
        watchdog('import', 'import products');
      }
      // Create Iteration variable
      if (empty($context['sandbox']['iteration'])) {
        $context['sandbox']['iteration'] = 0;
      }
      // Check for the end of cycle
      if ($context['sandbox']['iteration'] < $context['sandbox']['max']) {
        // Count of operation in one batch step
        $limit = 10;
        // Counts completed operations in one batch step
        $counter = 0;
        if ($context['sandbox']['progress'] != 0) {
          $context['sandbox']['iteration'] = $context['sandbox']['iteration'] + $limit;
        }
        // Loop all Product items in xml
        for ($i = $context['sandbox']['iteration']; $i < $context['sandbox']['max'] && $counter < $limit; $i++) {

          /* Loop items here */
          /* ... */
          /* ... */
          $context['results']['added']['products'][] = $product_item->title;


          // Update Progress
          $context['sandbox']['progress']++;
          $counter++;
          // Messages
          $context['message'] = t('Now processing product %name. Product %progress of %count', array('%name' => $product_item->title, '%progress' => $context['sandbox']['progress'], '%count' => $context['sandbox']['max']));
          $context['results']['processed'] = $context['sandbox']['progress'];
        }
      }

      if ($context['sandbox']['progress'] != $context['sandbox']['max']) {
        $context['finished'] = $context['sandbox']['progress'] / $context['sandbox']['max'];
      }
    }


/**
 * Finish of batch. Messagess
 */
function my_module_batch_finished($success, $results, $operations) {
  if ($success) {
    drupal_set_message(t('@count products added.', array('@count' => isset($results['added']) ? count($results['added']) : 0)));
  }
  else {
    $error_operation = reset($operations);
    drupal_set_message(t('An error occurred while processing @operation with arguments : @args', array('@operation' => $error_operation[0], '@args' => print_r($error_operation[0], TRUE))));
  }
  watchdog('import', 'import finished');
}

Answer 3

    function module_name_import_form_submit($form, $form_state) {
  // Check to make sure that the file was uploaded to the server properly
  $uri = db_query("SELECT uri FROM {file_managed} WHERE fid = :fid", array(
    ':fid' => $form_state['input']['import']['fid'],
  ))->fetchField();
  if(!empty($uri)) {
    if(file_exists(drupal_realpath($uri))) { 
      // Open the csv
      $handle = fopen(drupal_realpath($uri), "r");
      // Go through each row in the csv and run a function on it. In this case we are parsing by '|' (pipe) characters.
      // If you want commas are any other character, replace the pipe with it.
      while (($data = fgetcsv($handle, 0, '|', '"')) !== FALSE) {
        $operations[] = array(
          'module_name_import_batch_processing',  // The function to run on each row
          array($data),  // The row in the csv
        );
      }

      // Once everything is gathered and ready to be processed... well... process it!
      $batch = array(
        'title' => t('Importing CSV...'),
        'operations' => $operations,  // Runs all of the queued processes from the while loop above.
        'finished' => 'module_name_import_finished', // Function to run when the import is successful
        'error_message' => t('The installation has encountered an error.'),
        'progress_message' => t('Imported @current of @total products.'),
      );
      batch_set($batch);
      fclose($handle);    
    }
  }
  else {
    drupal_set_message(t('There was an error uploading your file. Please contact a System administator.'), 'error');
  }
}

/**
 * This function runs the batch processing and creates nodes with then given information
 * @see
 * module_name_import_form_submit()
 */
function module_name_import_batch_processing($data) {
  // Lets make the variables more readable.
  $title = $data[0];
  $body = $data[1];
  $serial_num = $data[2];
  // Find out if the node already exists by looking up its serial number. Each serial number should be unique. You can use whatever you want.
  $nid = db_query("SELECT DISTINCT n.nid FROM {node} n " . 
    "INNER JOIN {field_data_field_serial_number} s ON s.revision_id = n.vid AND s.entity_id = n.nid " .
    "WHERE field_serial_number_value = :serial", array(
      ':serial' => $serial_num,
    ))->fetchField();
  if(!empty($nid)) {
    // The node exists! Load it.
    $node = node_load($nid);

    // Change the values. No need to update the serial number though.
    $node->title = $title;
    $node->body['und'][0]['value'] = $body;
    $node->body['und'][0]['safe_value'] = check_plain($body);
    node_save($node);
  }
  else {
    // The node does not exist! Create it.
    global $user;
    $node = new StdClass();
    $node->type = 'page'; // Choose your type
    $node->status = 1; // Sets to published automatically, 0 will be unpublished
    $node->title = $title;
    $node->uid = $user->uid;        
    $node->body['und'][0]['value'] = $body;
    $node->body['und'][0]['safe_value'] = check_plain($body);
    $node->language = 'und';

    $node->field_serial_number['und'][0]['value'] = $serial_num;
    $node->field_serial_number['und'][0]['safe_value'] = check_plain($serial_num);
    node_save($node);
  }
}

/**
 * This function runs when the batch processing is complete
 *
 * @see
 * module_name_import_form_submit()
 */
function module_name_import_finished() {
    drupal_set_message(t('Import Completed Successfully'));
}