node.inc

<?php

/**
 * Common mappings for the Drupal 6 node migrations.
 */
abstract class DingNodeMigration extends DrupalNode6Migration {
  public function __construct(array $arguments) {
    $common_arguments = array(
      'source_connection' => 'legacy',
      'source_version' => 6,
      'user_migration' => 'DingUser',
    );

    parent::__construct($arguments + $common_arguments);

    // With migrate_ui enabled, migration pages will indicate people involved in
    // the particular migration, with their role and contact info. We default the
    // list in the shared class; it can be overridden for specific migrations.
    $this->team = array(
      new MigrateTeamMember('Ewan Andreasen', 'ea@vejlebib.dk', t('Webdeveloper (Ding1 -> Ding2 Migration)')),
    );

    $this->addFieldMapping('field_legacy_nid', 'nid')
         ->description('We have a common field to save the D6 nid');

    // Unmapped source fields - EXAMPLE
    //$this->addUnmigratedSources(array('vid', 'tnid', 'translate', 'teaser', 'format'));
    // Unmapped destination fields - EXAMPLE
    //$this->addUnmigratedDestinations(array('log', 'tnid', 'translate', 'body:summary', 'body:format', 'body:language', 'comment'))
  }


  // function to create ting objects with relations to the node
  public function createDingNodeTingRefs($node, $row) {

    if (isset($row->field_ting_refs) && count($row->field_ting_refs) > 0) {

      $refs = '';

      foreach ($row->field_ting_refs as $ref) {
        if ($ref) {
          // Save a ting object entity
          $tid = migrate_ding1_ding2_add_ting_object($ref);

          // Create relation
          if ($tid) {
            $rel_ent = ting_reference_create_relation('node', $node->nid, $tid);

            // Append to logging string
            $refs .= $ref . ', ';
          }

        }
      }

      $refs = rtrim($refs, ', ');

      // Logging
      if ($refs != '') {
        watchdog('migrate_ding1_ding2', 'Created Ting object reference(s) (%refs) with relation(s) on item (%title - D7 nid %d7nid)', array('%refs' => $refs, '%title'=>$node->title, '%d7nid'=>$node->nid), WATCHDOG_INFO);
      }
    }
  }


  /**
   * Function to replace IMG-tags in body text with Media tokens
   *
   * @param $row
   *
   * @return modified body text
   */
  public function img2mediatoken($row) {
    // Regex pattern that matches img tags containg /sites/default/files/ in src attribute,
    // and also returns a matching group with the content of src-string after ../sites/default/files/
    $regexp = '/<img.*src\s*=\s*[\"\'].*\/sites\/default\/files\/([^"\']+)[\"\'][^>]+>/i';
    // Returns an array of arrays with
    // first element = full img tag,
    // 2nd element = filepath after "../sites/default/files/"
    preg_match_all($regexp, $row->body, $img_tags, PREG_SET_ORDER);

    // Return if no IMG tags were found
    if (empty($img_tags)) {
      return $row->body;
    }

    // create new array with the keys being the filepaths to lookup in legacy db and the values being tag content
    foreach ($img_tags as $img_tag) {
      $img_file_tag['sites/default/files/' . $img_tag[1]] = array(
        'tag_html' => $img_tag[0],
        'legacy_filepath' => 'sites/default/files/' . $img_tag[1],
      );
    }

    // Check if src exists among the files in the SOURCE and get their fid from source db
    $legacy_files_result = Database::getConnection('default', 'legacy')
      ->select('files', 'f')
      ->fields('f', array('fid', 'filepath'))
      ->condition('filepath', array_keys($img_file_tag), 'IN')
      ->execute();
    $legacy_fids = array();

    foreach ($legacy_files_result as $legacy_row) {
      // append old fid to our $img_file_tag array
      $img_file_tag[$legacy_row->filepath]['legacy_fid'] = $legacy_row->fid;

      // Get and append new fid to array
      $new_fid = $new_fid_query = db_select('migrate_map_dingfile', 'mmf')
        ->fields('mmf', array('destid1'))
        ->condition('sourceid1', $legacy_row->fid)
        ->execute()
        ->fetchField();

      if ($new_fid) {
        // append new fid to array
        $img_file_tag[$legacy_row->filepath]['new_fid'] = $new_fid;
        // Build new media tokens and append to array
        $img_file_tag[$legacy_row->filepath]['new_fid_token'] = '[[{"fid":"' . $new_fid . '","view_mode":"default","fields":{"format":"default","field_file_image_alt_text[und][0][value]":"","field_file_image_title_text[und][0][value]":""},"type":"media","attributes":{"alt":"","title":"","class":"media-element file-default"}}]]';
      }
    }

    // Replace img-tags with media tokens in body text
    $replace_count = 0;
    foreach ($img_file_tag as $img_item) {
      $row->body = str_replace($img_item['tag_html'], $img_item['new_fid_token'], $row->body);
      $replace_count++;
    }

    if ($replace_count > 0) {
      // Logging
      watchdog('migrate_ding1_ding2', 'Found and replaced %count IMG-tags with media tokens on item (title: %title)', array('%count' => $replace_count, '%title'=>$row->title), WATCHDOG_INFO);
    }

    return $row->body;
  }

}


class DingLibraryMigration extends DingNodeMigration {
  public function __construct($arguments) {

    $arguments = array(
      'description' => t('Migration of Libraries from Ding1/D6'),
      'machine_name' => 'DingLibrary',
      'group_name' => 'ding1_group',
      'source_type' => 'library',
      'destination_type' => 'ding_library',
      'dependencies' => array('DingUser','DingFile'),
    );

    // Add to sourceFields before calling parent constructor.
    // See http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture
    $this->sourceFields['list_image_title'] = t('Title text extracted from field_list_image_data');
    $this->sourceFields['image_title'] = t('Title text extracted from field_image_data');

    parent::__construct($arguments);

    $this->addFieldMapping('field_ding_library_body', 'body');
    $this->addFieldMapping('field_ding_library_body:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_library_body:format')
         ->defaultValue('ding_wysiwyg');
    $this->addFieldMapping('field_ding_library_lead', 'teaser');
    $this->addFieldMapping('field_ding_library_lead:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_library_mail', 'field_email');
    $this->addFieldMapping('group_group')
         ->defaultValue('1');

    // Phone and fax comes from location_phone table and is drawn in via the modified query
    $this->addFieldMapping('field_ding_library_phone_number', 'phone');
    $this->addFieldMapping('field_ding_library_phone_number:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_library_fax_number', 'fax');
    $this->addFieldMapping('field_ding_library_fax_number:language')
         ->defaultValue('und');

    // library slug comes from ding_library table and is drawn in via the modified query
    $this->addFieldMapping('field_ding_library_slug', 'slug');
    $this->addFieldMapping('field_ding_library_slug:language')
         ->defaultValue('und');

    // Map the list image field to the new list image field, base this on the DingFile migration
    // to map the files to the imported files table.
    $this->addFieldMapping('field_ding_library_list_image', 'field_list_image')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_library_list_image:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_library_list_image:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_library_list_image:preserve_files')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_library_list_image:alt', 'field_list_image:alt');
    $this->addFieldMapping('field_ding_library_list_image:title', 'list_image_title');
    $this->addFieldMapping(NULL, 'field_list_image:data')
         ->description(t('Split this into list_image_title for D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_list_image:list');

    // Map the image field to the new title image field, base this on the DingFile migration
    // to map the files to the imported files table.
    $this->addFieldMapping('field_ding_library_title_image', 'field_image')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_library_title_image:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_library_title_image:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_library_title_image:preserve_files')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_library_title_image:alt', 'field_image:alt');
    $this->addFieldMapping('field_ding_library_title_image:title', 'image_title');
    $this->addFieldMapping(NULL, 'field_image:data')
         ->description(t('Split this into image_title for D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_image:list');

    // Map to addressfield. See https://drupal.org/node/1996546.
    $this->addFieldMapping('field_ding_library_addresse', 'country');
    $this->addFieldMapping('field_ding_library_addresse:thoroughfare', 'street');
    $this->addFieldMapping('field_ding_library_addresse:premise', 'additional');
    $this->addFieldMapping('field_ding_library_addresse:locality', 'city');
    $this->addFieldMapping('field_ding_library_addresse:administrative_area', 'province');
    $this->addFieldMapping('field_ding_library_addresse:postal_code', 'postal_code');
    $this->addFieldMapping('field_ding_library_addresse:name_line', 'name');

    // Map to geofield.
    $this->addFieldMapping('field_ding_library_geocode')
         ->defaultValue('point');
    $this->addFieldMapping('field_ding_library_geocode:geo_type')
         ->defaultValue('point');
    $this->addFieldMapping('field_ding_library_geocode:lat', 'latitude');
    $this->addFieldMapping('field_ding_library_geocode:top', 'latitude');
    $this->addFieldMapping('field_ding_library_geocode:bottom', 'latitude');
    $this->addFieldMapping('field_ding_library_geocode:lon', 'longitude');
    $this->addFieldMapping('field_ding_library_geocode:left', 'longitude');
    $this->addFieldMapping('field_ding_library_geocode:right', 'longitude');
    $this->addFieldMapping(NULL, 'lid')
         ->issueGroup(t('DNM'));

    // The opening_hours field in Ding2/D7 will be handled by migrating the opening_hours table of the module opening_hours
    $this->addFieldMapping('field_ding_library_opening_hours')
         ->description(t('Initially empty strings - field is populated by use of the site'))
         ->defaultValue('');
    $this->addFieldMapping('field_ding_library_opening_hours:language')
         ->defaultValue('und');

    // library links
    $this->addFieldMapping('field_ding_library_links', 'field_links');
    $this->addFieldMapping('field_ding_library_links:title', 'field_links:title');
    $this->addFieldMapping('field_ding_library_links:attributes', 'field_links:attributes');
    $this->addFieldMapping('field_ding_library_links:language')
         ->defaultValue('und');

    // Unmapped source fields
    $this->addFieldMapping(NULL, 'field_content_images')
         ->description(t('content images are not mapped to Ding2/D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:list')
         ->description(t('content images are not mapped to Ding2/D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:alt')
         ->description(t('content images are not mapped to Ding2/D7'))
         ->issueGroup(t('DNM'));

    $this->addFieldMapping(NULL, '2')
         ->description(t('Ding2 does not employ the Tags taxonomy (taxonomy "2") for library nodes'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_pc_booking_method')
         ->description(t('Ding2/D7 does not employ pc booking'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_pc_booking_url')
         ->description(t('Ding2/D7 does not employ pc booking'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_feature_ref')
         ->description(t('Ding2/D7 does not employ feature nodes'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'log')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision_uid')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:week_start')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:week_end')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:sun_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:sun_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:mon_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:mon_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:tue_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:tue_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:wed_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:wed_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:thu_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:thu_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:fri_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:fri_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:sat_open')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_opening_hours:sat_close')
         ->description(t('Ding2/D7 uses the opening_hours module instead of office_hours module. Handled by separate migration of the opening_hours table'))
         ->issueGroup(t('DNM'));

    // Unmapped destination fields
    $this->addUnmigratedDestinations(array(
      'field_ding_library_addresse:sub_administrative_area',
      'field_ding_library_addresse:dependent_locality',
      'field_ding_library_addresse:sub_premise',
      'field_ding_library_addresse:organisation_name',
      'field_ding_library_addresse:first_name',
      'field_ding_library_addresse:last_name',
      'field_ding_library_addresse:data',
      'field_ding_library_geocode:srid',
      'field_ding_library_geocode:accuracy',
      'field_ding_library_geocode:source',
      'og_group_ref',
    ));
  }

  public function prepareRow($row) {
    // Always include this snippet, in case our parent class decides to ignore the row
    if (parent::prepareRow($row) === FALSE) {
       return FALSE;
    }

    // Get values from serialized data and populate the source fields defined in our constructor
    $list_image_data = unserialize($row->field_list_image_data);
    $row->list_image_alt = $list_image_data['alt'];
    $row->list_image_title = $list_image_data['title'];

    $image_data = unserialize($row->field_image_data);
    $row->image_alt = $image_data['alt'];
    $row->image_title = $image_data['title'];

    // Make country code uppercase
    $row->country = strtoupper($row->country);

    // Replace img-tags found in body with the corresponding media tokens
    $row->body = parent::img2mediatoken($row);
  }

  // Modify the query to include location data
  // For more info, see:
  // http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture as well as
  // http://www.grasmash.com/article/migrate-classes-location-cck-address-field
  protected function query() {
    $query = parent::query();
    $query->leftJoin('location_instance', 'li', 'n.nid=li.nid AND n.vid = li.vid');
    $query->addField('li', 'lid');
    $query->leftJoin('location', 'l', 'li.lid=l.lid');
    $query->addField('l', 'name');
    $query->addField('l', 'street');
    $query->addField('l', 'additional');
    $query->addField('l', 'city');
    $query->addField('l', 'province');
    $query->addField('l', 'postal_code');
    $query->addField('l', 'country');
    $query->addField('l', 'latitude');
    $query->addField('l', 'longitude');
    $query->leftJoin('location_phone', 'lp', 'lp.lid=l.lid');
    $query->addField('lp', 'phone');
    $query->leftJoin('location_fax', 'lf', 'lf.lid=l.lid');
    $query->addField('lf', 'fax');
    $query->leftJoin('ding_library', 'dl', 'n.nid=dl.nid AND n.vid = dl.vid');
    $query->addField('dl', 'slug');
    return $query;
  }
}


class DingCampaignMigration extends DingNodeMigration {
  public function __construct($arguments) {

    $arguments = array(
      'description' => t('Migration of Campaigns from Ding1/D6'),
      'machine_name' => 'DingCampaign',
      'group_name' => 'ding1_group',
      'source_type' => 'campaign',
      'destination_type' => 'ding_campaign',
      'dependencies' => array('DingUser', 'DingFile'),
    );

    // Add to sourceFields before calling parent constructor.
    // See http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture
    $this->sourceFields['campaign_image_alt'] = t('Alt text extracted from field_campaign_image_data');
    $this->sourceFields['campaign_image_title'] = t('Title text extracted from field_campaign_image_data');

    parent::__construct($arguments);

    $this->addFieldMapping('field_camp_text_full', 'body')
         ->description(t('body is mapped to both field_camp_text_full and field_camp_text_plain'));
    $this->addFieldMapping('field_camp_text_plain', 'body')
         ->description(t('body is mapped to both field_camp_text_full and field_camp_text_plain'));
    $this->addFieldMapping('field_camp_link', 'field_campaign_link');
    $this->addFieldMapping('field_camp_image:alt', 'campaign_image_alt');
    $this->addFieldMapping('field_camp_image:title', 'campaign_image_title');
    $this->addFieldMapping(NULL, 'field_campaign_image:data')
         ->description(t('Split this into campaign_image_alt and campaign_image_title for D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, '2')
         ->description(t('Ding2 does not employ the Tags taxonomy (taxonomy "2") for campaigns'));
    $this->addFieldMapping(NULL, 'field_campaign_link:title')
         ->description(t('Ding2 does not have title data on the campaign links'));
    $this->addFieldMapping(NULL, 'field_campaign_link:attributes')
         ->description(t('Ding2 does not have attribute data on the campaign links'));
    $this->addFieldMapping('field_camp_weight', 'campaign_weight');
    $this->addFieldMapping('field_camp_settings', 'campaign_type')
         ->description(t('Handled in prepareRow of DingCampaignMigration'));
    $this->addFieldMapping('field_camp_link:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_camp_text_full:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_camp_text_plain:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_camp_text_full:format')
         ->defaultValue('ding_wysiwyg');
    $this->addFieldMapping(NULL, 'field_campaign_image:list');

    // Map the image field to the new image field, base this on the Files migration
    // to map the files to the imported files table.
    $this->addFieldMapping('field_camp_image', 'field_campaign_image')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_camp_image:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_camp_image:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_camp_image:preserve_files')
         ->defaultValue(TRUE);

    // Unmapped source fields
    $this->addFieldMapping(NULL, 'revision')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'log')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision_uid')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
  }

  public function prepareRow($row) {
    // Always include this snippet, in case our parent class decides to ignore the row
    if (parent::prepareRow($row) === FALSE) {
       return FALSE;
    }

    // Get values from serialized data and populate the source fields defined in our constructor
    $campaign_image_data = unserialize($row->field_campaign_image_data);
    $row->campaign_image_alt = $campaign_image_data['alt'];
    $row->campaign_image_title = $campaign_image_data['title'];

    // Modify text in campaign_type
    $row->campaign_type = str_replace('-only', '', $row->campaign_type);
  }

  // Modify the query to include ding_campaign data
  protected function query() {
    $query = parent::query();
    $query->leftJoin('ding_campaign', 'dc', 'n.nid=dc.nid AND n.vid = dc.vid');
    $query->addField('dc', 'campaign_weight');
    $query->addField('dc', 'campaign_type');
    return $query;
  }
}


class DingPageMigration extends DingNodeMigration {
  public function __construct($arguments) {

    $arguments = array(
      'description' => t('Migration of Pages from Ding1/D6'),
      'machine_name' => 'DingPage',
      'group_name' => 'ding1_group',
      'source_type' => 'page',
      'destination_type' => 'ding_page',
      'dependencies' => array('DingUser','DingTagsTerm', 'DingLibrary', 'DingFile'),
    );

    // Add to sourceFields before calling parent constructor.
    // See http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture
    $this->sourceFields['list_image_title'] = t('Title text extracted from field_list_image_data');

    parent::__construct($arguments);

    $this->addFieldMapping('field_ding_page_body', 'body');
    $this->addFieldMapping('field_ding_page_body:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_page_body:format')
         ->defaultValue('ding_wysiwyg');
    $this->addFieldMapping('field_ding_page_lead', 'field_teaser');
    $this->addFieldMapping('field_ding_page_lead:language')
         ->defaultValue('und');

    // Files mapping
    $this->addFieldMapping('field_ding_page_files', 'field_file_attachments')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_page_files:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_page_files:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_page_files:preserve_files')
         ->defaultValue(TRUE);
    // Mapping remaining page file fields
    $this->addFieldMapping('field_ding_page_files:description', 'field_file_attachments:description');

    // Map the list image field to the new list image field, base this on the DingFile migration
    // to map the files to the imported files table.
    $this->addFieldMapping('field_ding_page_list_image', 'field_list_image')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_page_list_image:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_page_list_image:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_page_list_image:preserve_files')
         ->defaultValue(TRUE);
    // Mapping remaining list image fields
    $this->addFieldMapping('field_ding_page_list_image:alt', 'field_list_image:alt');
    $this->addFieldMapping('field_ding_page_list_image:title', 'list_image_title');
    $this->addFieldMapping(NULL, 'field_list_image:data')
         ->description(t('Split this into list_image_title for D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_list_image:list');

    // ting references
    $this->addFieldMapping(NULL, 'field_ting_refs')
         ->description(t('Handled in complete function'));
    $this->addFieldMapping(NULL, 'field_ting_refs:ting_ref_type')
         ->description(t('Not mapped - Ding2 does not employ ref types'));
    $this->addFieldMapping(NULL, 'field_ting_refs:description')
         ->description(t('Not mapped - Ding2 does not employ descriptions on ting refs.'));

    // Tags term mapping
    $this->addFieldMapping('field_ding_page_tags', '2')
         ->sourceMigration('DingTagsTerm');
    $this->addFieldMapping('field_ding_page_tags:source_type')
         ->defaultValue('tid');
    $this->addFieldMapping('field_ding_page_tags:create_term')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_page_tags:ignore_case')
         ->defaultValue(TRUE);

    // Unmapped source fields
    $this->addFieldMapping(NULL, 'revision')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'log')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision_uid')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:list')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:alt')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_file_attachments:list')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_library_ref')
         ->description(t('Not mapped - Ding2 does not relate pages to libraries'))
         ->issueGroup(t('DNM'));

    // Unmapped destination fields
    $this->addUnmigratedDestinations(array(
      'field_ding_page_title_image',
      'field_ding_page_title_image:file_class',
      'field_ding_page_title_image:language',
      'field_ding_page_title_image:alt',
      'field_ding_page_title_image:title',
      'field_ding_page_title_image:destination_dir',
      'field_ding_page_title_image:destination_file',
      'field_ding_page_title_image:file_replace',
      'field_ding_page_title_image:preserve_files',
      'field_ding_page_title_image:source_dir',
      'field_ding_page_title_image:urlencode',
      'field_ding_page_files:display',
      'ding_page_group_ref',
      'field_ding_page_materials',
    ));

  }

  public function prepareRow($row) {
    // Always include this snippet, in case our parent class decides to ignore the row
    if (parent::prepareRow($row) === FALSE) {
       return FALSE;
    }

    // Get values from serialized data and populate the source fields defined in our constructor
    // file attachments
    $file_attachments_data = unserialize($row->field_file_attachments_data);
    $row->file_attachments_description = $file_attachments_data['description'];

    // list images
    $list_image_data = unserialize($row->field_list_image_data);
    $row->list_image_alt = $list_image_data['alt'];
    $row->list_image_title = $list_image_data['title'];

    // Replace img-tags found in body with the corresponding media tokens
    $row->body = parent::img2mediatoken($row);
  }

  public function complete($node, stdClass $row) {
    // Create Ting objects and relation to it for each item i field_ting_refs
    // We perform this in complete() function since we need the nid on the news node just created
    parent::createDingNodeTingRefs($node, $row);
  }

}


class DingNewsMigration extends DingNodeMigration {
  public function __construct($arguments) {

    $arguments = array(
      'description' => t('Migration of Blogposts/News from Ding1/D6'),
      'machine_name' => 'DingNews',
      'group_name' => 'ding1_group',
      'source_type' => 'article',
      'destination_type' => 'ding_news',
      'dependencies' => array('DingUser','DingNewsCategoryTerm','DingTagsTerm','DingFile','DingLibrary'),
    );

    // Add to sourceFields before calling parent constructor.
    // See http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture
    $this->sourceFields['list_image_title'] = t('Title text extracted from field_list_image_data');

    parent::__construct($arguments);

    $this->addFieldMapping('field_ding_news_body', 'body');
    $this->addFieldMapping('field_ding_news_body:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_news_body:format')
         ->defaultValue('ding_wysiwyg');
    $this->addFieldMapping('field_ding_news_lead', 'field_teaser');
    $this->addFieldMapping('field_ding_news_lead:language')
         ->defaultValue('und');
    $this->addFieldMapping('og_group_ref', 'field_library_ref')
         ->sourceMigration('DingLibrary');

    // Files mapping
    $this->addFieldMapping('field_ding_news_files', 'field_file_attachments')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_news_files:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_news_files:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_news_files:preserve_files')
         ->defaultValue(TRUE);
    // Mapping remaining news file fields
    $this->addFieldMapping('field_ding_news_files:description', 'field_file_attachments:description');

    // Map the list image field to the new list image field, base this on the DingFile migration
    // to map the files to the imported files table.
    $this->addFieldMapping('field_ding_news_list_image', 'field_list_image')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_news_list_image:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_news_list_image:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_news_list_image:preserve_files')
         ->defaultValue(TRUE);
    // Mapping remaining list image fields
    $this->addFieldMapping('field_ding_news_list_image:alt', 'field_list_image:alt');
    $this->addFieldMapping('field_ding_news_list_image:title', 'list_image_title');
    $this->addFieldMapping(NULL, 'field_list_image:list');

    // ting references
    $this->addFieldMapping(NULL, 'field_ting_refs')
         ->description(t('Handled in complete function'));
    $this->addFieldMapping(NULL, 'field_ting_refs:ting_ref_type')
         ->description(t('Not mapped - Ding2 does not employ ref types'));
    $this->addFieldMapping(NULL, 'field_ting_refs:description')
         ->description(t('Not mapped - Ding2 does not employ descriptions on ting refs.'));

    // News Category term mapping
    $this->addFieldMapping('field_ding_news_category', '1')
         ->sourceMigration('DingNewsCategoryTerm');
    $this->addFieldMapping('field_ding_news_category:source_type')
         ->defaultValue('tid');
    $this->addFieldMapping('field_ding_news_category:create_term')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_news_category:ignore_case')
         ->defaultValue(TRUE);

    // News Tags term mapping
    $this->addFieldMapping('field_ding_news_tags', '2')
         ->sourceMigration('DingTagsTerm');
    $this->addFieldMapping('field_ding_news_tags:source_type')
         ->defaultValue('tid');
    $this->addFieldMapping('field_ding_news_tags:create_term')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_news_tags:ignore_case')
         ->defaultValue(TRUE);

      // Unmapped source fields
    $this->addFieldMapping(NULL, 'revision')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'log')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision_uid')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:list')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:alt')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_file_attachments:list')
         ->issueGroup(t('DNM'));

    // Unmapped destination fields
    $this->addUnmigratedDestinations(array(
      'field_ding_news_title_image',
      'field_ding_news_title_image:file_class',
      'field_ding_news_title_image:language',
      'field_ding_news_title_image:alt',
      'field_ding_news_title_image:title',
      'field_ding_news_title_image:destination_dir',
      'field_ding_news_title_image:destination_file',
      'field_ding_news_title_image:file_replace',
      'field_ding_news_title_image:preserve_files',
      'field_ding_news_title_image:source_dir',
      'field_ding_news_title_image:urlencode',
      'field_ding_news_files:display',
      'ding_news_groups_ref',
      'field_ding_news_materials',
    ));

  }

  public function prepareRow($row) {
    // Always include this snippet, in case our parent class decides to ignore the row
    if (parent::prepareRow($row) === FALSE) {
       return FALSE;
    }

    // Get values from serialized data and populate the source fields defined in our constructor
    // list images
    $list_image_data = unserialize($row->field_list_image_data);
    $row->list_image_title = $list_image_data['title'];

    // Replace img-tags found in body with the corresponding media tokens
    $row->body = parent::img2mediatoken($row);
  }

  public function complete($node, stdClass $row) {
    // Create Ting objects and relation to it for each item i field_ting_refs
    // We perform this in complete() function since we need the nid on the news node just created
    parent::createDingNodeTingRefs($node, $row);
  }
}


class DingEventMigration extends DingNodeMigration {
  public function __construct($arguments) {

    $arguments = array(
      'description' => t('Migration of Events from Ding1/D6'),
      'machine_name' => 'DingEvent',
      'group_name' => 'ding1_group',
      'source_type' => 'event',
      'destination_type' => 'ding_event',
      'dependencies' => array('DingUser','DingEventCategoryTerm','DingEventTargetTerm', 'DingTagsTerm', 'DingFile', 'DingLibrary'),
    );

    // Add to sourceFields before calling parent constructor.
    // See http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture
    $this->sourceFields['list_image_alt'] = t('Alt text extracted from field_list_image_data');
    $this->sourceFields['list_image_title'] = t('Title text extracted from field_list_image_data');

    parent::__construct($arguments);

    $this->addFieldMapping('field_ding_event_body', 'body');
    $this->addFieldMapping('field_ding_event_body:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_event_body:format')
         ->defaultValue('ding_wysiwyg');
    $this->addFieldMapping('field_ding_event_lead', 'field_teaser');
    $this->addFieldMapping('field_ding_event_lead:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_event_date', 'field_datetime');
    $this->addFieldMapping('field_ding_event_date:value2', 'field_datetime:value2');
    $this->addFieldMapping('field_ding_event_price', 'field_entry_price');
    $this->addFieldMapping('og_group_ref', 'field_library_ref')
         ->sourceMigration('DingLibrary');

    // Files mapping
    $this->addFieldMapping('field_ding_event_files', 'field_file_attachments')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_event_files:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_event_files:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_event_files:preserve_files')
         ->defaultValue(TRUE);
    // Mapping remaining page file fields
    $this->addFieldMapping('field_ding_event_files:description', 'field_file_attachments:description');

    // Map the list image field to the new list image field, base this on the DingFile migration
    // to map the files to the imported files table.
    $this->addFieldMapping('field_ding_event_list_image', 'field_list_image')
         ->sourceMigration('DingFile');
    $this->addFieldMapping('field_ding_event_list_image:file_class')
         ->defaultValue('MigrateFileFid');
    $this->addFieldMapping('field_ding_event_list_image:language')
         ->defaultValue('und');
    $this->addFieldMapping('field_ding_event_list_image:preserve_files')
         ->defaultValue(TRUE);
    // Mapping remaining list image fields
    $this->addFieldMapping('field_ding_event_list_image:alt', 'list_image_alt');
    $this->addFieldMapping('field_ding_event_list_image:title', 'list_image_title');
    $this->addFieldMapping(NULL, 'field_list_image:data')
         ->description(t('Split this into list_image_alt and list_image_title for D7'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_list_image:list');
    $this->addFieldMapping(NULL, 'field_list_image:alt');

    // Map to addressfield. See https://drupal.org/node/1996546.
    $this->addFieldMapping('field_ding_event_location', 'country');
    $this->addFieldMapping('field_ding_event_location:thoroughfare', 'street');
    $this->addFieldMapping('field_ding_event_location:premise', 'additional');
    $this->addFieldMapping('field_ding_event_location:locality', 'city');
    $this->addFieldMapping('field_ding_event_location:administrative_area', 'province');
    $this->addFieldMapping('field_ding_event_location:postal_code', 'postal_code');
    $this->addFieldMapping('field_ding_event_location:name_line', 'name');

    // Since the excerpt is mapped via an argument, add a null mapping so it's not flagged as unmapped.
    $this->addFieldMapping(NULL, 'latitude');
    $this->addFieldMapping(NULL, 'longitude');
    $this->addFieldMapping(NULL, 'lid');

    // ting references
    $this->addFieldMapping(NULL, 'field_ting_refs')
         ->description(t('Handled in complete function'));
    $this->addFieldMapping(NULL, 'field_ting_refs:ting_ref_type')
         ->description(t('Not mapped - Ding2 does not employ ref types'));
    $this->addFieldMapping(NULL, 'field_ting_refs:description')
         ->description(t('Not mapped - Ding2 does not employ descriptions on ting refs.'));

    // Event Category term mapping
    $this->addFieldMapping('field_ding_event_category', '4')
         ->sourceMigration('DingEventCategoryTerm');
    $this->addFieldMapping('field_ding_event_category:source_type')
         ->defaultValue('tid');
    $this->addFieldMapping('field_ding_event_category:create_term')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_event_category:ignore_case')
         ->defaultValue(TRUE);

    // Event Target term mapping
    $this->addFieldMapping('field_ding_event_target', '5')
         ->sourceMigration('DingEventTargetTerm');
    $this->addFieldMapping('field_ding_event_target:source_type')
         ->defaultValue('tid');
    $this->addFieldMapping('field_ding_event_target:create_term')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_event_target:ignore_case')
         ->defaultValue(TRUE);

         // Event Tags term mapping
    $this->addFieldMapping('field_ding_event_tags', '2')
         ->sourceMigration('DingTagsTerm');
    $this->addFieldMapping('field_ding_event_tags:source_type')
         ->defaultValue('tid');
    $this->addFieldMapping('field_ding_event_tags:create_term')
         ->defaultValue(TRUE);
    $this->addFieldMapping('field_ding_event_tags:ignore_case')
         ->defaultValue(TRUE);

    // Unmapped source fields
    $this->addFieldMapping(NULL, 'field_content_images')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:list')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_content_images:alt')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'field_file_attachments:list')
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'log')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));
    $this->addFieldMapping(NULL, 'revision_uid')
         ->description(t('Migration of revisions is possible, but not implemented in this migration'))
         ->issueGroup(t('DNM'));

    // Unmapped destination fields
    $this->addUnmigratedDestinations(array(
      'field_ding_event_title_image',
      'field_ding_event_title_image:file_class',
      'field_ding_event_title_image:language',
      'field_ding_event_title_image:alt',
      'field_ding_event_title_image:title',
      'field_ding_event_title_image:destination_dir',
      'field_ding_event_title_image:destination_file',
      'field_ding_event_title_image:file_replace',
      'field_ding_event_title_image:preserve_files',
      'field_ding_event_title_image:source_dir',
      'field_ding_event_title_image:urlencode',
      'field_ding_event_files:display',
      'field_ding_event_materials',
      'ding_event_groups_ref',
      'field_ding_event_location:sub_administrative_area',
      'field_ding_event_location:dependent_locality',
      'field_ding_event_location:sub_premise',
      'field_ding_event_location:organisation_name',
      'field_ding_event_location:first_name',
      'field_ding_event_location:last_name',
      'field_ding_event_location:data',
      'field_place2book_tickets', // If this field shows up in the list of destination fields, it should be ignored
      'field_place2book_tickets:language', // If this field shows up in the list of destination fields, it should be ignored
    ));

  }

  public function prepareRow($row) {
    // Make sure that this migration only runs if ding_place2book is turned OFF on the site
    if (module_exists('ding_place2book')) {
      throw new MigrateException(t('Turn ding_place2book module OFF before running DingEventMigration'));
    }

    // Always include this snippet, in case our parent class decides to ignore the row
    if (parent::prepareRow($row) === FALSE) {
       return FALSE;
    }

    // Get values from serialized data and populate the source fields defined in our constructor
    // list images
    $list_image_data = unserialize($row->field_list_image_data);
    $row->list_image_alt = $list_image_data['alt'];
    $row->list_image_title = $list_image_data['title'];

    // Handle date field
    $date_data = array(
      'from' => $row->field_datetime,
      'to' => $row->{'field_datetime:value2'},
    );
    // Datetime field handler accepts data as json array.
    $row->field_datetime = drupal_json_encode($date_data);

    // Make country code uppercase
    $row->country = strtoupper($row->country);

    // Replace img-tags found in body with the corresponding media tokens
    $row->body = parent::img2mediatoken($row);
  }

  public function complete($node, stdClass $row) {
    // Create Ting objects and relation to it for each item i field_ting_refs
    // We perform this in complete() function since we need the nid on the news node just created
    parent::createDingNodeTingRefs($node, $row);
  }

  // Modify the query to include location data
  // For more info, see:
  // http://www.acquia.com/blog/drupal-drupal-data-migration-part-2-architecture as well as
  // http://www.grasmash.com/article/migrate-classes-location-cck-address-field
  protected function query() {
    $query = parent::query();
    $query->leftJoin('location_instance', 'li', 'n.nid=li.nid AND n.vid = li.vid');
    $query->addField('li', 'lid');
    $query->leftJoin('location', 'l', 'li.lid=l.lid');
    $query->addField('l', 'name');
    $query->addField('l', 'street');
    $query->addField('l', 'additional');
    $query->addField('l', 'city');
    $query->addField('l', 'province');
    $query->addField('l', 'postal_code');
    $query->addField('l', 'country');
    $query->addField('l', 'latitude');
    $query->addField('l', 'longitude');
    return $query;
  }

}