View source
<?php
define('PMPERSON_MIGRATE_MAX_JOB_PER_BATCH', 5);
function pmperson_migrate(&$sandbox) {
_pmperson_migrate_create_pmperson_node_type();
if (empty($sandbox['pmperson_current_nid_of_user_being_created'])) {
$sandbox['pmperson_current_nid_of_user_being_created'] = 0;
}
if (pmperson_migrate_create_users_if_required($sandbox) == FALSE) {
$sandbox['#finished'] = 0;
return;
}
if (empty($sandbox['pmperson_fields_and_instance_created'])) {
pmperson_migrate_create_fields($sandbox);
$sandbox['#finished'] = 0.25;
return;
}
if (empty($sandbox['pmperson_current_nid_of_field_being_migrated'])) {
$sandbox['pmperson_current_nid_of_field_being_migrated'] = 0;
}
if (pmperson_migrate_field_data($sandbox) == FALSE) {
$sandbox['#finished'] = 0.5;
return;
}
if (empty($sandbox['pmperson_current_nid_of_node_being_deleted'])) {
$sandbox['pmperson_current_nid_of_node_being_deleted'] = 0;
}
if (pmperson_migrate_content_kill($sandbox) == FALSE) {
$sandbox['#finished'] = 0.75;
return;
}
node_type_delete('pmperson');
variable_del('node_options_pmperson');
variable_del('node_permissions_pmperson');
module_load_include('inc', 'pmpermission', 'includes/pmpermission.migrate');
pmpermission_migrate_execute('pmperson');
$sandbox['#finished'] = 1;
return 'PM Person nodes have been migrated to fields on Drupal users.';
}
function pmperson_migrate_content_kill(&$sandbox) {
$results = db_select('node', 'n')
->fields('n', array(
'nid',
))
->condition('type', 'pmperson')
->condition('nid', $sandbox['pmperson_current_nid_of_node_being_deleted'], '>')
->range(0, PMPERSON_MIGRATE_MAX_JOB_PER_BATCH)
->execute();
$count = 0;
foreach ($results as $result) {
$count++;
$nids[] = $result->nid;
$sandbox['pmperson_current_nid_of_node_being_deleted'] = $result->nid;
}
if (!empty($nids)) {
node_delete_multiple($nids);
}
return empty($count);
}
function _pmperson_migrate_create_pmperson_node_type() {
$names = node_type_get_names();
if (empty($names['pmperson'])) {
$type = array(
'type' => 'pmperson',
'name' => 'Person',
'base' => 'pmperson',
'description' => 'A person for Project Management.',
'title_label' => 'Name',
'body_label' => 'Description',
);
$content_type = node_type_set_defaults($type);
node_type_save($content_type);
}
}
function pmperson_migrate_update_could_be_performed() {
if (db_table_exists('pmperson')) {
$counts = pmperson_migrate_email_missmatch_count();
if ($counts > 0) {
return FALSE;
}
}
return TRUE;
}
function pmperson_migrate_email_missmatch_count() {
$results = db_query(" SELECT pm.nid FROM {pmperson} as pm\n LEFT JOIN {users} as u\n ON pm.user_uid = u.uid\n WHERE pm.email <> u.mail AND u.mail <> ''");
$count = $results
->rowCount();
$results = db_query(" SELECT pm.nid FROM {pmperson} as pm\n LEFT JOIN {users} as u\n ON pm.user_uid <> u.uid\n WHERE pm.email = u.mail AND pm.user_uid = '0'");
$count += $results
->rowCount();
return $count;
}
function pmperson_migrate_page_callback() {
if (pmperson_migrate_update_could_be_performed()) {
drupal_set_message(t('PM Person migration conflicts have been resolved.'));
drupal_goto('update.php', array(
'script' => 'update.php',
));
}
$form_fix_1 = drupal_get_form('pmperson_migrate_fix_existing_users_form');
$render = array(
'preface' => array(
'#markup' => "\n <p>The information captured by legacy PM Person nodes is now incorporated\n into user accounts.</p>\n <p>This page will ensure that all PM Person nodes can be uniquely matched\n to existing users so that the data migration can take place.</p>\n ",
),
'table_1_info' => array(
'#markup' => "\n <h2>Suggested matches</h2>\n <p>\n This table shows PM Person nodes with the same email address as a user\n account.\n </p><p>\n Normally these can be matched automatically by clicking the button below.\n Remaining PM Person nodes will need to be manually matched.\n </p>\n ",
),
'table_issue_1' => _pmperson_migrate_get_conflicting_email_with_existing_users_table(),
'try_fix_1' => array(
'#type' => 'markup',
'#markup' => render($form_fix_1),
),
'table_2_info' => array(
'#markup' => "<br />\n <h2>Conflicts</h2>\n <p>This table shows PM Person nodes where a match cannot be made automatically due to data differences between them.</p>\n <p>Edit the PM Person node or user accounts until there are no remaining\n conflicts.</p>\n ",
),
'table_issue_2' => _pmperson_migrate_get_conflicting_email_with_attached_users_table(),
);
return $render;
}
function pmperson_migrate_fix_existing_users_form($form, $form_state) {
$form['submit'] = array(
'#type' => 'submit',
'#value' => t('Adjust pmperson nodes'),
'#prefix' => '<br />',
'#suffix' => t('Automatically match Drupal user with pmperson node using
email if Drupal user is not associated with any other pmperson node.'),
);
return $form;
}
function pmperson_migrate_fix_existing_users_form_submit($form, $form_state) {
$unmapped_results = db_select('pmperson', 'pmp')
->fields('pmp')
->condition('pmp.user_uid', '0')
->execute();
foreach ($unmapped_results as $record) {
if ($account = user_load_by_mail($record->email)) {
if (_pmperson_migrate_get_pmperson_from_uid($account->uid) == FALSE) {
_pmperson_migrate_associate_user_with_pmperson($record, $account);
}
}
}
}
function _pmperson_migrate_get_conflicting_email_with_attached_users_table() {
$header = array(
'person' => array(
'data' => t('PM Person'),
'field' => 'email',
),
'user' => array(
'data' => t('Drupal User'),
'field' => 'mail',
),
'help' => array(
'data' => t('Help'),
),
);
if (db_table_exists('pmperson')) {
$query = db_select('pmperson', 'p')
->extend('PagerDefault')
->limit(10);
$query
->join('users', 'u', 'p.user_uid = u.uid AND p.email <> u.mail');
$query
->fields('p', array(
'nid',
'email',
))
->fields('u', array(
'mail',
'uid',
'name',
))
->condition('u.uid', '', '!=');
$query = $query
->extend('TableSort')
->orderByHeader($header);
$result = $query
->execute()
->fetchAllAssoc('nid');
}
else {
$result = array();
}
$render = array(
'table' => array(
'#theme' => 'table',
'#header' => $header,
'#rows' => array_map(function ($row) {
return _pmperson_migrate_adjust_row($row);
}, $result),
'#sticky' => TRUE,
'#caption' => t('Conflicts.'),
'#empty' => t('No issues found.'),
),
'pager' => array(
'#theme' => 'pager',
),
);
return $render;
}
function _pmperson_migrate_get_conflicting_email_with_existing_users_table() {
$header = array(
'person' => array(
'data' => t('PM Person'),
'field' => 'email',
),
'user' => array(
'data' => t('Drupal User'),
'field' => 'mail',
),
'help' => array(
'data' => t('Help'),
),
);
if (db_table_exists('pmperson')) {
$query = db_select('pmperson', 'p')
->extend('PagerDefault')
->limit(10);
$query
->join('users', 'u', 'p.email = u.mail AND p.user_uid <> u.uid');
$query
->fields('p', array(
'nid',
'email',
))
->fields('u', array(
'mail',
'uid',
'name',
))
->condition('p.user_uid', '0');
$query = $query
->extend('TableSort')
->orderByHeader($header);
$result = $query
->execute()
->fetchAllAssoc('nid');
}
else {
$result = array();
}
$render = array(
'table' => array(
'#theme' => 'table',
'#header' => $header,
'#rows' => array_map(function ($row) {
return _pmperson_migrate_adjust_row($row);
}, $result),
'#sticky' => TRUE,
'#caption' => t("Suggested Matches."),
'#empty' => t('No issues found.'),
),
'pager' => array(
'#theme' => 'pager',
),
);
return $render;
}
function _pmperson_migrate_adjust_row($row) {
$user_email_form = drupal_get_form("pmperson_migrate_email_adjust_form_user_{$row->uid}", 'user', $row->uid, $row->mail);
$row_data['user'] = $user_email_form['col_data']['#value']['user'];
$pmperson_email_form = drupal_get_form("pmperson_migrate_email_adjust_form_pmperson_{$row->nid}", 'pmperson', $row->nid, $row->email);
$row_data['pmperson'] = $pmperson_email_form['col_data']['#value']['pmperson'];
$out = array(
'person' => drupal_render($pmperson_email_form),
'user' => drupal_render($user_email_form),
'help' => pmperson_migrate_get_help_text($row_data),
);
return $out;
}
function pmperson_migrate_get_help_text($row_data) {
$message = '-';
$du = $row_data['user'];
$pmp = $row_data['pmperson'];
if ($pmp['linked_id'] == NULL and $du['linked_id'] == NULL and $du['mail'] == $pmp['mail']) {
$message = t('Clicking <b>"Adjust pmperson nodes"</b> button should fix this issue');
}
if ($pmp['linked_id'] == NULL and $du['linked_id'] != NULL and $du['mail'] == $pmp['mail']) {
$message = t('Since drupal user is already associated with another PM Person,
it is highly recommended to <b>change PM Person email</b>. You may delete the PM
Person email and the migration will generate a random one automatically.');
}
if ($pmp['linked_id'] != NULL and $du['linked_id'] == $pmp['id'] and $du['mail'] != $pmp['mail']) {
$message = t('PM Person account and Drupal user account are linked,
but their email doesn\'t match. Please edit PM Person email to <b>match</b>
Drupal user email');
}
return $message;
}
function pmperson_migrate_create_users_if_required(&$sandbox) {
$unmapped_results = db_select('pmperson', 'pmp')
->fields('pmp')
->condition('pmp.user_uid', '0')
->condition('nid', $sandbox['pmperson_current_nid_of_user_being_created'], '>')
->range(0, PMPERSON_MIGRATE_MAX_JOB_PER_BATCH)
->execute();
$count = 0;
foreach ($unmapped_results as $record) {
$count++;
$account = NULL;
if ($account = user_load_by_mail($record->email)) {
if (_pmperson_migrate_get_pmperson_from_uid($account->uid)) {
$account = _pmperson_migrate_create_user($record);
db_update('pmperson')
->fields(array(
'email' => $account->mail,
))
->condition('user_uid', $account->uid)
->execute();
}
}
else {
$account = _pmperson_migrate_create_user($record);
}
_pmperson_migrate_associate_user_with_pmperson($record, $account);
}
return empty($count);
}
function _pmperson_migrate_associate_user_with_pmperson($record, $account) {
if (!$record or !$record->nid or !$account or !$account->uid) {
watchdog('pmperson', 'message', array(
'record' => $record,
), WATCHDOG_NOTICE);
return FALSE;
}
db_update('pmperson')
->fields(array(
'user_uid' => $account->uid,
'email' => $account->mail,
))
->condition('nid', $record->nid)
->execute();
return TRUE;
}
function _pmperson_migrate_get_pmperson_from_uid($uid) {
$record = db_select('pmperson', 'pmp')
->fields('pmp')
->condition('pmp.user_uid', $uid)
->execute()
->fetchAssoc();
if ($record and $node = node_load($record['nid'])) {
return $node;
}
return FALSE;
}
function _pmperson_migrate_create_user($record) {
$account = FALSE;
$node = node_load($record->nid);
if ($node) {
$mail = $record->email;
if (empty($mail) or user_load_by_mail($record->email)) {
$mail = 'pmperson_' . $node->nid . '@example.com';
}
$name = check_plain($node->title);
$name = _pmperson_migrate_generate_unique_username($name, TRUE, array(
$mail,
));
$account = user_save(NULL, array(
'name' => $name,
'mail' => $mail,
'init' => $mail,
'pass' => user_password(),
));
}
return $account;
}
function _pmperson_migrate_generate_unique_username($username, $reset = FALSE, $tries = array()) {
static $suffix = 1;
if ($reset) {
$suffix = 1;
}
if ($suffix < 2) {
$duplicate = _pmperson_migrate_check_if_username_exists($username);
if ($duplicate == FALSE) {
return $username;
}
}
else {
$duplicate = _pmperson_migrate_check_if_username_exists("{$username} {$suffix}");
}
if (!empty($duplicate) and !empty($tries)) {
foreach ($tries as $try) {
if (_pmperson_migrate_check_if_username_exists($try) == FALSE) {
return $try;
}
}
}
if (!empty($duplicate)) {
$suffix++;
_pmperson_migrate_generate_unique_username($username);
}
$username = $suffix < 2 ? $username : "{$username} {$suffix}";
return $username;
}
function _pmperson_migrate_check_if_username_exists($username) {
$result = db_query('SELECT u.uid FROM {users} u WHERE name = :name', array(
':name' => $username,
));
if ($result) {
foreach ($result as $r) {
return TRUE;
}
}
return FALSE;
}
function pmperson_migrate_create_fields(&$sandbox) {
module_load_include('inc', 'pmperson', 'includes/pmperson.field_base');
module_load_include('inc', 'pmperson', 'includes/pmperson.field_instance');
module_load_include('inc', 'pm', 'includes/pm.field');
$field_bases = pmperson_default_field_bases();
pm_field_bases_create_if_required($field_bases);
$field_instances = pmperson_default_field_instances();
pm_field_instances_create_if_required($field_instances);
$sandbox['pmperson_fields_and_instance_created'] = TRUE;
return TRUE;
}
function pmperson_migrate_field_data(&$sandbox) {
$results = db_select('pmperson', 'pmp')
->fields('pmp')
->condition('nid', $sandbox['pmperson_current_nid_of_field_being_migrated'], '>')
->range(0, PMPERSON_MIGRATE_MAX_JOB_PER_BATCH)
->execute();
$count = 0;
foreach ($results as $pmperson) {
$count++;
$sandbox['pmperson_current_nid_of_field_being_migrated'] = $pmperson->nid;
_pmperson_migrate_field_data($pmperson);
}
return empty($count);
}
function _pmperson_migrate_field_data($pmperson) {
$field_mapping = array(
'im' => 'pmperson_im',
'email' => 'pmperson_mail',
'phone' => 'pmperson_phone',
'prefix' => 'pmperson_prefix',
);
try {
$account = user_load($pmperson->user_uid);
$title = _pmperson_migrate_node_get_title($pmperson->nid);
$edit['pmperson_name'][LANGUAGE_NONE][0]['value'] = $title;
$body = _pmperson_migrate_node_get_body($pmperson->nid);
$edit['pm_description'][LANGUAGE_NONE][0]['value'] = $body;
foreach ($field_mapping as $key => $field_name) {
if ($pmperson->{$key}) {
$edit[$field_name][LANGUAGE_NONE][0]['value'] = $pmperson->{$key};
}
}
$edit['pmperson_www'][LANGUAGE_NONE][0]['url'] = $pmperson->www;
$edit['pmperson_www'][LANGUAGE_NONE][0]['title'] = $pmperson->www;
user_save($account, $edit);
} catch (EntityMetadataWrapperException $exc) {
watchdog('pmperson', 'See ' . __FUNCTION__ . '() ' . $exc
->getTraceAsString(), NULL, WATCHDOG_ERROR);
}
}
function _pmperson_migrate_node_get_title($nid) {
return db_query('SELECT title FROM {node} WHERE nid = :nid', array(
':nid' => $nid,
))
->fetchField();
}
function _pmperson_migrate_node_get_body($nid) {
$v = db_query('SELECT body_value FROM {field_data_body} WHERE entity_id = :nid AND entity_type = :entity_type', array(
':nid' => $nid,
':entity_type' => 'node',
))
->fetchField();
return $v;
}
function pmperson_migrate_email_adjust_form($form, $form_state, $type = NULL, $id = NULL, $mail = NULL) {
$form = array();
$col_data[$type] = array(
'id' => $id,
'mail' => $mail,
);
if ($id) {
$form['type'] = array(
'#type' => 'value',
'#value' => $type,
);
$form['id'] = array(
'#type' => 'value',
'#value' => $id,
);
$description = '';
switch ($type) {
case 'user':
$nid = db_query('SELECT nid FROM {pmperson} WHERE user_uid = :user_uid', array(
':user_uid' => $id,
))
->fetchField();
if ($nid) {
$description = 'uid: ' . $id . ' - linked to pmperson: ' . _pmperson_migrate_node_get_title($nid) . " (nid: {$nid})";
$col_data[$type]['linked_id'] = $nid;
}
else {
$description = 'uid: ' . $id . ' - ' . t('unlinked');
$col_data[$type]['linked_id'] = NULL;
}
break;
case 'pmperson':
$uid = db_query('SELECT user_uid FROM {pmperson} WHERE nid = :nid', array(
':nid' => $id,
))
->fetchField();
if ($uid and $account = user_load($uid)) {
$description = 'nid: ' . $id . ' - linked to user: ' . $account->name . " (uid: {$account->uid})";
$col_data[$type]['linked_id'] = $account->uid;
}
else {
$description = 'nid: ' . $id . ' - ' . t('unlinked');
$col_data[$type]['linked_id'] = NULL;
}
default:
break;
}
$form['mail'] = array(
'#type' => 'textfield',
'#default_value' => $mail,
'#description' => $description,
);
$form['submit'] = array(
'#type' => 'submit',
'#value' => t('Save'),
'#submit' => array(
'pmperson_migrate_email_adjust_form_save_submit',
),
'#validate' => array(
'pmperson_migrate_email_adjust_form_save_validate',
),
);
$form['delete'] = array(
'#type' => 'submit',
'#value' => t('Delete'),
'#submit' => array(
'pmperson_migrate_email_adjust_form_delete_submit',
),
);
}
$form['col_data'] = array(
'#type' => 'value',
'#value' => $col_data,
);
return $form;
}
function pmperson_migrate_email_adjust_form_save_validate($form, $form_state) {
$id = $form_state['values']['id'];
$type = $form_state['values']['type'];
$mail = $form_state['values']['mail'];
switch ($type) {
case 'user':
if (valid_email_address($mail)) {
$account = user_load_by_mail($mail);
if ($account and $account->uid != $id) {
form_set_error('mail', t('User already exists with the given E-mail'));
}
}
else {
form_set_error('mail', t('E-mail address provided is not valid'));
}
break;
case 'pmperson':
if ($mail and !valid_email_address($mail)) {
form_set_error('mail', t('E-mail address provided is not valid'));
}
break;
}
}
function pmperson_migrate_email_adjust_form_save_submit($form, $form_state) {
$id = $form_state['values']['id'];
$type = $form_state['values']['type'];
$mail = $form_state['values']['mail'];
switch ($type) {
case 'user':
$account = user_load($id);
$edit['mail'] = $mail;
$edit['init'] = $mail;
user_save($account, $edit);
break;
case 'pmperson':
db_update('pmperson')
->fields(array(
'email' => $mail,
))
->condition('nid', $id)
->execute();
break;
}
}
function pmperson_migrate_email_adjust_form_delete_submit($form, &$form_state) {
$id = $form_state['values']['id'];
$type = $form_state['values']['type'];
switch ($type) {
case 'user':
if ($id != 0 and $id != 1) {
$query_string = array(
'destination' => PMPERSON_RESOLVE_DEPENDENCIES_LINK,
);
drupal_goto("user/{$id}/cancel", array(
'query' => $query_string,
));
}
break;
case 'pmperson':
db_delete('pmperson')
->condition('nid', $id)
->execute();
break;
}
}
