Skip to content

Commit

Permalink
Merge pull request #433 from compucorp/staging
Browse files Browse the repository at this point in the history 
Sync master with staging
  • Loading branch information
@davialexandre
davialexandre authored Jan 29, 2018
2 parents 6e37630 + d8050e8 commit c32c240
Show file tree
Hide file tree
Showing 38 changed files with 2,769 additions and 1,408 deletions.
321 changes: 175 additions & 146 deletions civihr_employee_portal/civihr_employee_portal.drush.inc
View file
Original file line number Diff line number Diff line change
@@ -1,192 +1,221 @@
<?php

use Drupal\civihr_employee_portal\Helpers\HelperClass;
use Drupal\civihr_employee_portal\Helpers\NodeHelper;

/**
* Implements hook_drush_help().
*
* @param string $command
*
* @return string
*/
function civihr_employee_portal_drush_help($command) {
switch ($command) {
case 'drush:refresh-node-export-files':
return dt('Refreshes the node webform files');
case 'drush:civihr-blocks-cleanup':
return dt('Hides the blocks not used for CiviHR employee portal');
case 'drush:update-external-ids':
return dt('Sets usernames into external IDs');
case 'drush:update-email-type':
return dt('Sets primary email type to "Work" for existing users');
}
switch ($command) {
case 'drush:refresh-node-export-files':
return dt('Refreshes the node webform files');
case 'drush:civihr-blocks-cleanup':
return dt('Hides the blocks not used for CiviHR employee portal');
case 'drush:update-external-ids':
return dt('Sets usernames into external IDs');
case 'drush:update-email-type':
return dt('Sets primary email type to "Work" for existing users');
default:
return '';
}
}

/**
* Implements hook_drush_command().
*/
function civihr_employee_portal_drush_command() {
$items = array();

$items['refresh-node-export-files'] = array(
'description' => dt('Refresh Webform node export files.'),
'arguments' => array(),
'examples' => array(
'Standard example' => 'drush refresh-node-export-files',
),
'aliases' => array('rnef'),
);

$items['civihr-blocks-cleanup'] = array(
'description' => dt('Hides the blocks not used for CiviHR employee portal.'),
'arguments' => array(),
'examples' => array(
'Standard example' => 'drush civihr-blocks-cleanup',
),
'aliases' => array('civihrbc'),
);

$items['update-external-ids'] = array(
'description' => dt('Sets usernames into external IDs'),
'arguments' => array(),
'examples' => array(
'Standard example' => 'drush update-external-ids',
),
'aliases' => array('drush-ueids'),
);

$items['update-email-type'] = array(
'description' => dt('Sets primary email type to "Work" for existing users'),
'arguments' => array(),
'examples' => array(
'Standard example' => 'drush update-email-type',
),
'aliases' => array('drush-uetype'),
);
return $items;
$items = [];

$items['refresh-node-export-files'] = [
'description' => dt('Refresh Webform node export files.'),
'arguments' => [],
'examples' => [
'Standard example' => 'drush refresh-node-export-files',
],
'aliases' => ['rnef'],
];

$items['civihr-blocks-cleanup'] = [
'description' => dt('Hides the blocks not used for CiviHR employee portal.'),
'arguments' => [],
'examples' => [
'Standard example' => 'drush civihr-blocks-cleanup',
],
'aliases' => ['civihrbc'],
];

$items['update-external-ids'] = [
'description' => dt('Sets usernames into external IDs'),
'arguments' => [],
'examples' => [
'Standard example' => 'drush update-external-ids',
],
'aliases' => ['drush-ueids'],
];

$items['update-email-type'] = [
'description' => dt('Sets primary email type to "Work" for existing users'),
'arguments' => [],
'examples' => [
'Standard example' => 'drush update-email-type',
],
'aliases' => ['drush-uetype'],
];

return $items;
}

/**
* Callback function for drush refresh-node-export-files.
* Callback is called by using drush_hook_command() where
* the Drush command with all "-" characters converted to "_" characters (refresh-node-export-files)
* Callback function for 'drush refresh-node-export-files'
*
* Takes all files in the features/node_export_files and refreshes them.
*/
function drush_civihr_employee_portal_refresh_node_export_files() {

// Check for all node export files
$files = file_scan_directory(drupal_get_path('module', 'civihr_employee_portal') . '/features/node_export_files', '/.*\.export$/');

// Loop the export files, import them, and set the config variable
foreach ($files as $filepath => $file) {
$info = node_export_import(file_get_contents($filepath));

variable_set($file->name . '_webform_nid', $info['nids'][0]);
drush_log($file->name . ' webform imported and nid set as variable', 'ok');
$moduleRoot = drupal_get_path('module', 'civihr_employee_portal');
$exportFilesDir = $moduleRoot . '/features/node_export_files';
$files = file_scan_directory($exportFilesDir, '/.*\.export$/');
$count = 0;

foreach ($files as $filepath => $file) {
$contents = file_get_contents($filepath);
$importData = node_export_import($contents, 't', FALSE);
$importNodes = CRM_Utils_Array::value('nodes', $importData);

foreach ($importNodes as $importNode) {
$existingNode = NodeHelper::findOneBy([
'title' => $importNode->title,
'type' => $importNode->type,
]);

// Set these to update existing instead of creating new node
if ($existingNode) {
$importNode->nid = $existingNode->nid;
$importNode->vid = $existingNode->vid;
$importNode->is_new = FALSE;
}

node_export_save($importNode);

// Need to manually update webform_civicrm_form record
if ($importNode->type === 'webform' && !$importNode->is_new) {
$civicrmWebform = $importNode->webform_civicrm;
$civicrmWebform['nid'] = $existingNode->nid;
drupal_write_record('webform_civicrm_forms', $civicrmWebform, ['nid']);
}

variable_set($file->name . '_webform_nid', $importNode->nid);
$count++;
}
}

// Log to the command line with an OK status
drush_log('Node Webform refresh finished', 'ok');
drush_log(sprintf('%d nodes were updated', $count), 'ok');
}

/**
* Callback function for drush civihr-blocks-cleanup.
* Callback is called by using drush_hook_command() where
* the Drush command with all "-" characters converted to "_" characters (civihr-blocks-cleanup)
*
* Callback is called by using drush_hook_command() where the Drush command with
* all "-" characters converted to "_" characters (civihr-blocks-cleanup)
*/
function drush_civihr_employee_portal_civihr_blocks_cleanup() {

// Disable not needed blocks
db_update('block')
->fields(array('region' => -1))
->condition('theme', 'civihr_default_theme')
->condition('region', 'content')
->condition('delta', 'main', '!=')
->execute();
// Disable not needed blocks
db_update('block')
->fields(['region' => -1])
->condition('theme', 'civihr_default_theme')
->condition('region', 'content')
->condition('delta', 'main', '!=')
->execute();

// Log to the command line with an OK status
drush_log('CiviHR not used blocks were hidden', 'ok');
// Log to the command line with an OK status
drush_log('CiviHR not used blocks were hidden', 'ok');
}

/**
* Callback function for drush update-external-ids.
* Callback is called by using drush_hook_command() where
* the Drush command with all "-" characters converted to "_" characters (update-external-ids)
*
* Callback is called by using drush_hook_command() where the Drush command with
* all "-" characters converted to "_" characters (update-external-ids)
*/
function drush_civihr_employee_portal_update_external_ids() {
try {
$uf_data = civicrm_api3('UFMatch', 'get', array(
'sequential' => 1,
'return' => "contact_id,uf_id,contact_type",
));

foreach ($uf_data['values'] as $uf_item) {
$user = user_load($uf_item['uf_id']);

$result = civicrm_api3('Contact', 'create', array(
'sequential' => 1,
'contact_type' => $uf_item['contact_type'],
'id' => $uf_item['contact_id'],
'external_identifier' => $user->name,
));
}
}
catch (CiviCRM_API3_Exception $e) {
$error = $e->getMessage();
drush_log(dt('Error communicating with CiVi API: @err', array('@err' => $error)), 'error');
drush_user_abort();
return;
try {
$uf_data = civicrm_api3('UFMatch', 'get', [
'sequential' => 1,
'return' => "contact_id,uf_id,contact_type",
]);

foreach ($uf_data['values'] as $uf_item) {
$user = user_load($uf_item['uf_id']);

civicrm_api3('Contact', 'create', [
'sequential' => 1,
'contact_type' => $uf_item['contact_type'],
'id' => $uf_item['contact_id'],
'external_identifier' => $user->name,
]);
}

// Log to the command line with an OK status
drush_log('External ID parameters were updated', 'ok');
} catch (CiviCRM_API3_Exception $e) {
$error = $e->getMessage();
$msg = dt('Error communicating with Civi API: @err', ['@err' => $error]);
drush_log($msg, 'error');
drush_user_abort();
return;
}

// Log to the command line with an OK status
drush_log('External ID parameters were updated', 'ok');
}

/**
* Callback function for drush update-email-type.
* Callback is called by using drush_hook_command() where
* the Drush command with all "-" characters converted to "_" characters (update-email-type)
* Callback is called by using drush_hook_command() where the Drush command with
* all "-" characters converted to "_" characters (update-email-type)
*
*/
function drush_civihr_employee_portal_update_email_type() {
try {
$work_type_id = HelperClass::_get_work_location_type_id();

$uf_data = civicrm_api3('UFMatch', 'get', array(
'sequential' => 1,
'return' => "contact_id",
));

//update primary email to "Work" location type for each user
foreach ($uf_data['values'] as $uf_item) {

$email_data = civicrm_api3('Email', 'get', array(
'sequential' => 1,
'contact_id' => $uf_item['contact_id'],
'is_primary' => 1,
'return' => "id,email,contact_id,is_primary,location_type_id",
));

$email_values = reset($email_data['values']);

if ((isset($email_values['id']) && isset($email_values['email']))
&& $email_values['location_type_id'] !== $work_type_id) {
$result = civicrm_api3('Email', 'create', array(
'sequential' => 1,
'id' => $email_values['id'],
'email' => $email_values['email'],
'contact_id' => $email_values['contact_id'],
'is_primary' => $email_values['is_primary'],
'location_type_id' => $work_type_id,
));
}
}
}
catch (CiviCRM_API3_Exception $e) {
$error = $e->getMessage();
drush_log(dt('Error communicating with CiVi API: @err', array('@err' => $error)), 'error');
drush_user_abort();
return;
try {
$work_type_id = HelperClass::_get_work_location_type_id();

$uf_data = civicrm_api3('UFMatch', 'get', [
'sequential' => 1,
'return' => "contact_id",
]);

//update primary email to "Work" location type for each user
foreach ($uf_data['values'] as $uf_item) {

$email_data = civicrm_api3('Email', 'get', [
'sequential' => 1,
'contact_id' => $uf_item['contact_id'],
'is_primary' => 1,
'return' => "id,email,contact_id,is_primary,location_type_id",
]);

$email_values = reset($email_data['values']);

if ((isset($email_values['id']) && isset($email_values['email']))
&& $email_values['location_type_id'] !== $work_type_id) {
civicrm_api3('Email', 'create', [
'sequential' => 1,
'id' => $email_values['id'],
'email' => $email_values['email'],
'contact_id' => $email_values['contact_id'],
'is_primary' => $email_values['is_primary'],
'location_type_id' => $work_type_id,
]);
}
}

// Log to the command line with an OK status
drush_log('Primary email types were changed to "Work"', 'ok');
} catch (CiviCRM_API3_Exception $e) {
$error = $e->getMessage();
$msg = dt('Error communicating with CiVi API: @err', ['@err' => $error]);
drush_log($msg, 'error');
drush_user_abort();
return;
}

// Log to the command line with an OK status
drush_log('Primary email types were changed to "Work"', 'ok');
}
Loading

0 comments on commit c32c240

Please sign in to comment.