migration showroom ok

2018-12-10 15:22:44 +01:00
parent b17458fe4a
commit f3bd4cb8d3
24 changed files with 610 additions and 66 deletions
--- a/modules/custom/materio_migrate/config/install/migrate_plus.migration.d7_taxonomy_term_showroom.yml
+++ b/modules/custom/materio_migrate/config/install/migrate_plus.migration.d7_taxonomy_term_showroom.yml
@@ -23,23 +23,65 @@ process:
    plugin: default_value
    default_value: showroom
  name: name
-  'description/value': description
-  'description/format': format
  weight: weight
-  # Only attempt to stub real (non-zero) parents.
-  parent_id:
-    -
-      plugin: skip_on_empty
-      method: process
-      source: parent
-    -
-      plugin: migration_lookup
-      migration: d7_taxonomy_term_showroom
  parent:
    plugin: default_value
    default_value: 0
-    source: '@parent_id'
-  forum_container: is_container
  changed: timestamp
+  langcode:
+    plugin: default_value
+    default_value: 'und'
+  field_migration:
+    plugin: default_value
+    default_value: 'migration_imported'
+  field_workflow:
+    plugin: default_value
+    default_value: 'workflow_visible'

-  # TODO: tode node showroom
+  # tode node showroom
+  field_website:
+    plugin: iterator
+    source: field_website
+    process:
+      uri: url
+      title: title
+      options: attributes
+  field_memo: field_memo
+  field_public_phone: public_phone
+  field_public_email:
+    plugin: iterator
+    source: field_public_email
+    process:
+      value: email
+  field_public_address:
+    plugin: iterator
+    source: field_public_address
+    process:
+      # langcode:
+      country_code: country
+      administrative_area: administrative_area
+      locality: locality
+      dependent_locality: dependent_locality
+      postal_code: postal_code
+      # sorting_code:
+      address_line1: thoroughfare
+      # address_line2:
+      organization: organisation_name
+      given_name: first_name
+      # additional_name:
+      family_name: last_name
+
+      # SOURCES
+      # sub_administrative_area
+      # premise
+      # sub_premise
+      # name_line
+      # data
+  description:
+    plugin: iterator
+    source: body
+    process:
+      value: value
+      format:
+        plugin: default_value
+        default_value: wysiwyg
--- a/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermCompany.php
+++ b/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermCompany.php
@@ -159,17 +159,6 @@ class D7TaxonomyTermCompany extends FieldableEntity implements ContainerFactoryP
        $row->setSourceProperty($field_name, $field_values);
      }

-      // $body = $row->getSourceProperty('body');
-      // if(!empty($body)){
-      //   drush_print('body: ');
-      //   print_r($body);
-      // }
-      // $field_infos_from_company = $row->getSourceProperty('field_infos_from_company');
-      // if(!empty($field_infos_from_company)){
-      //   drush_print('field_infos_from_company: ');
-      //   print_r($field_infos_from_company);
-      // }
-
      // make sure that field_website url is absolute
      $field_website = $row->getSourceProperty('field_website');
      if(isset($field_website[0]['url'])){
--- a/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermShowroom.php
+++ b/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermShowroom.php
@@ -4,6 +4,15 @@ namespace Drupal\materio_migrate\Plugin\migrate\source;

 use Drupal\migrate\Row;
 use Drupal\migrate_drupal\Plugin\migrate\source\d7\FieldableEntity;
+use Symfony\Component\DependencyInjection\ContainerInterface;
+use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
+use Drupal\migrate\Plugin\MigrationInterface;
+use Drupal\Core\State\StateInterface;
+use Drupal\Core\Entity\EntityManagerInterface;
+use Drupal\Core\Locale\CountryManagerInterface;
+use libphonenumber\PhoneNumber;
+use libphonenumber\PhoneNumberUtil;
+use libphonenumber\PhoneNumberFormat;

 /**
 * Taxonomy term source from database.
@@ -15,14 +24,52 @@ use Drupal\migrate_drupal\Plugin\migrate\source\d7\FieldableEntity;
 */
 class D7TaxonomyTermShowroom extends FieldableEntity {

+    /**
+     * Phone Number util.
+     *
+     * @var \libphonenumber\PhoneNumberUtil
+     */
+    public $phoneUtils;
+
+    /**
+     * Country Manager service.
+     *
+     * @var \Drupal\Core\Locale\CountryManagerInterface
+     */
+    public $countryManager;
+
+    /**
+     * {@inheritdoc}
+     */
+    public function __construct(array $configuration, $plugin_id, $plugin_definition, MigrationInterface $migration, StateInterface $state, EntityManagerInterface $entity_manager, CountryManagerInterface $country_manager) {
+      parent::__construct($configuration, $plugin_id, $plugin_definition, $migration, $state, $entity_manager);
+      $this->phoneUtils = PhoneNumberUtil::getInstance();
+      $this->countryManager = $country_manager;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition, MigrationInterface $migration = NULL) {
+      return new static(
+        $configuration,
+        $plugin_id,
+        $plugin_definition,
+        $migration,
+        $container->get('state'),
+        $container->get('entity.manager'),
+        $container->get('country_manager')
+      );
+    }
+
  /**
   * {@inheritdoc}
   */
  public function query() {
    $query = $this->select('taxonomy_term_data', 'td')
      ->fields('td')
-      ->distinct()
      ->orderBy('tid');
+
    $query->leftJoin('taxonomy_vocabulary', 'tv', 'td.vid = tv.vid');
    $query->addField('tv', 'machine_name');

@@ -55,12 +102,19 @@ class D7TaxonomyTermShowroom extends FieldableEntity {
   * {@inheritdoc}
   */
  public function prepareRow(Row $row) {
-    print("\n".'-- prepareRow -- '.$row->getSourceProperty('tid')." -- ".$row->getSourceProperty('name')."\n");
+    $language = $row->getSourceProperty('language');
+    $tid = $row->getSourceProperty('tid');
+    drush_print('-- '.$language."\t".$tid."\t".$row->getSourceProperty('name'));
+
+    // vocabulary machine name
+    $machine_name = $row->getSourceProperty('machine_name');
+    $revid = $row->getSourceProperty('revision_id');

    // Get Field API field values.
-    foreach (array_keys($this->getFields('taxonomy_term', $row->getSourceProperty('machine_name'))) as $field) {
-      $tid = $row->getSourceProperty('tid');
-      $row->setSourceProperty($field, $this->getFieldValues('taxonomy_term', $field, $tid));
+    foreach ($this->getFields('taxonomy_term', $machine_name) as $field_name => $field) {
+      // Ensure we're using the right language if the entity is translatable.
+      $field_language = $field['translatable'] ? $language : NULL;
+      $row->setSourceProperty($field_name, $this->getFieldValues('taxonomy_term', $field_name, $tid, $revid, $field_language));
    }

    // Find parents for this row.
@@ -72,23 +126,73 @@ class D7TaxonomyTermShowroom extends FieldableEntity {
    $row->setSourceProperty('parent', $parents);
    // print_r($parents);

-    // If the term name or term description were replaced by real fields using
-    // the Drupal 7 Title module, use the fields value instead of the term name
-    // or term description.
-    // TODO: translations
+    // If the node title was replaced by a real field using the Drupal 7 Title
+    // module, use the field value instead of the node title.
    if ($this->moduleExists('title')) {
      $name_field = $row->getSourceProperty('name_field');
-      // print_r($name_field);
      if (isset($name_field[0]['value'])) {
        $row->setSourceProperty('name', $name_field[0]['value']);
      }
-      $description_field = $row->getSourceProperty('description_field');
-      if (isset($description_field[0]['value'])) {
-        $row->setSourceProperty('description', $description_field[0]['value']);
-      }
    }

-    // TODO: tode node showroom
+    // get the tode nid
+    $tode_nid = $this->select('field_data_field_tode_showroom', 'tode')
+      ->condition('entity_type', 'node')
+      ->condition('field_tode_showroom_tid', $tid)
+      ->fields('tode', ['entity_id'])
+      ->execute()->fetchField();
+    // drush_print('tode_nid: '.$tode_nid);
+
+    // drush_print('tode_nid: ');
+    // print_r($tode_nid);
+    // drush_print(' ');
+    if($tode_nid){
+      // get the tode fields
+      foreach ($this->getFields('node', 'company') as $field_name => $field) {
+        // Ensure we're using the right language if the entity is translatable.
+        $field_language = $field['translatable'] ? $language : NULL;
+        $field_values = $this->getFieldValues('node', $field_name, $tode_nid, null, $field_language);
+
+        $row->setSourceProperty($field_name, $field_values);
+      }
+
+      // make sure that field_website url is absolute
+      $field_website = $row->getSourceProperty('field_website');
+      if(isset($field_website[0]['url'])){
+        $url = $field_website[0]['url'];
+        if(!strpos($url, 'http://')){
+          $field_website[0]['url'] = 'http://'.$url;
+          $row->setSourceProperty('field_website', $field_website);
+        }
+      }
+
+      // convert phone field with libphonenumber
+      $field_phone = $row->getSourceProperty('field_public_phone');
+      if(isset($field_phone[0]['number']) && !empty($field_phone[0]['number'])){
+        $national_number = $field_phone[0]['number'];
+        $region = strtoupper($field_phone[0]['country_codes']);
+        // isValidRegionCode($regionCode)
+        if($this->phoneUtils->isPossibleNumber($national_number, $region)){
+          $number = $this->phoneUtils->parse($national_number, $region);
+          $row->setSourceProperty('public_phone', $this->phoneUtils->format($number, PhoneNumberFormat::E164));
+        }else{
+          // add bad phone number to memo field
+          $memo .= "#migration : invalid phone number: ".$national_number.' region: '.$region."\n";
+          drush_print('WARNING: phone number invalide; number: '.$national_number.' region: '.$region);
+        }
+      }
+
+    }else{
+      // if no tode set workflow to hidden
+      $memo .= "#migration : missing data from tode\n";
+      drush_print('WARNING: no tode');
+    }
+    // record migration errors in field_memo
+    if(isset($memo)){
+      $field_memo = $row->getSourceProperty('field_memo');
+      $field_memo[0]['value'] .= "\n".$memo;
+      $row->setSourceProperty('field_memo', $field_memo);
+    }


    return parent::prepareRow($row);
--- a/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermTags.php
+++ b/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermTags.php
@@ -66,7 +66,7 @@ class D7TaxonomyTermTags extends FieldableEntity {
   */
  public function prepareRow(Row $row) {
    $language = $row->getSourceProperty('language');
-    drush_print('-- '.$language.' -- '.$row->getSourceProperty('tid')." -- ".$row->getSourceProperty('name')." -- ".$row->getSourceProperty('weight'));
+    drush_print('-- '.$language."\t".$row->getSourceProperty('tid')."\t".$row->getSourceProperty('name'));

    $tid = $row->getSourceProperty('tid');
    // vocabulary machine name
--- a/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermTagsI18n.php
+++ b/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermTagsI18n.php
@@ -64,7 +64,7 @@ class D7TaxonomyTermTagsI18n extends FieldableEntity {
    $language = $row->getSourceProperty('language');
    $tid = $row->getSourceProperty('tid');

-    drush_print('-- '. $language .' -- '.$tid." -- ".$row->getSourceProperty('name')." -- ".$row->getSourceProperty('weight'));
+    drush_print('-- '. $language ."\t".$tid."\t".$row->getSourceProperty('name'));

    // vocabulary machine name
    $machine_name = $row->getSourceProperty('machine_name');
--- a/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermThesaurus.php
+++ b/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermThesaurus.php
@@ -66,7 +66,7 @@ class D7TaxonomyTermThesaurus extends FieldableEntity {
   */
  public function prepareRow(Row $row) {
    $language = $row->getSourceProperty('language');
-    drush_print('-- '.$language.' -- '.$row->getSourceProperty('tid')." -- ".$row->getSourceProperty('name')." -- ".$row->getSourceProperty('weight'));
+    drush_print('-- '.$language."\t".$row->getSourceProperty('tid')."\t".$row->getSourceProperty('name'));

    $tid = $row->getSourceProperty('tid');
    // vocabulary machine name
--- a/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermThesaurusI18n.php
+++ b/modules/custom/materio_migrate/src/Plugin/migrate/source/D7TaxonomyTermThesaurusI18n.php
@@ -64,7 +64,7 @@ class D7TaxonomyTermThesaurusI18n extends FieldableEntity {
    $language = $row->getSourceProperty('language');
    $tid = $row->getSourceProperty('tid');

-    drush_print('-- '. $language .' -- '.$tid." -- ".$row->getSourceProperty('name')." -- ".$row->getSourceProperty('weight'));
+    drush_print('-- '. $language ."\t".$tid."\t".$row->getSourceProperty('name'));

    // vocabulary machine name
    $machine_name = $row->getSourceProperty('machine_name');