CRM/Activity/Import/Parser/Activity.php

   1 <?php
   2 /*
   3  +--------------------------------------------------------------------+
   4  | Copyright CiviCRM LLC. All rights reserved.                        |
   5  |                                                                    |
   6  | This work is published under the GNU AGPLv3 license with some      |
   7  | permitted exceptions and without any warranty. For full license    |
   8  | and copyright information, see https://civicrm.org/licensing       |
   9  +--------------------------------------------------------------------+
  10  */
  11
  12 /**
  13  *
  14  * @package CRM
  15  * @copyright CiviCRM LLC https://civicrm.org/licensing
  16  */
  17
  18
  19 /**
  20  * Class to parse activity csv files.
  21  */
  22 class CRM_Activity_Import_Parser_Activity extends CRM_Activity_Import_Parser {
  23
  24   protected $_mapperKeys;
  25
  26   private $_contactIdIndex;
  27   private $_activityTypeIndex;
  28   private $_activityLabelIndex;
  29   private $_activityDateIndex;
  30
  31   /**
  32    * Array of successfully imported activity id's
  33    *
  34    * @var array
  35    */
  36   protected $_newActivity;
  37
  38   /**
  39    * Class constructor.
  40    *
  41    * @param array $mapperKeys
  42    */
  43   public function __construct(&$mapperKeys) {
  44     parent::__construct();
  45     $this->_mapperKeys = &$mapperKeys;
  46   }
  47
  48   /**
  49    * Function of undocumented functionality required by the interface.
  50    */
  51   protected function fini() {}
  52
  53   /**
  54    * The initializer code, called before the processing.
  55    */
  56   public function init() {
  57     $activityContact = CRM_Activity_BAO_ActivityContact::import();
  58     $activityTarget['target_contact_id'] = $activityContact['contact_id'];
  59     $fields = array_merge(CRM_Activity_BAO_Activity::importableFields(),
  60       $activityTarget
  61     );
  62
  63     $fields = array_merge($fields, [
  64       'source_contact_id' => [
  65         'title' => ts('Source Contact'),
  66         'headerPattern' => '/Source.Contact?/i',
  67       ],
  68       'activity_label' => [
  69         'title' => ts('Activity Type Label'),
  70         'headerPattern' => '/(activity.)?type label?/i',
  71       ],
  72     ]);
  73
  74     foreach ($fields as $name => $field) {
  75       $field['type'] = CRM_Utils_Array::value('type', $field, CRM_Utils_Type::T_INT);
  76       $field['dataPattern'] = CRM_Utils_Array::value('dataPattern', $field, '//');
  77       $field['headerPattern'] = CRM_Utils_Array::value('headerPattern', $field, '//');
  78       $this->addField($name, $field['title'], $field['type'], $field['headerPattern'], $field['dataPattern']);
  79     }
  80
  81     $this->_newActivity = [];
  82
  83     $this->setActiveFields($this->_mapperKeys);
  84
  85     // FIXME: we should do this in one place together with Form/MapField.php
  86     $this->_contactIdIndex = -1;
  87     $this->_activityTypeIndex = -1;
  88     $this->_activityLabelIndex = -1;
  89     $this->_activityDateIndex = -1;
  90
  91     $index = 0;
  92     foreach ($this->_mapperKeys as $key) {
  93       switch ($key) {
  94         case 'target_contact_id':
  95         case 'external_identifier':
  96           $this->_contactIdIndex = $index;
  97           break;
  98
  99         case 'activity_label':
 100           $this->_activityLabelIndex = $index;
 101           break;
 102
 103         case 'activity_type_id':
 104           $this->_activityTypeIndex = $index;
 105           break;
 106
 107         case 'activity_date_time':
 108           $this->_activityDateIndex = $index;
 109           break;
 110       }
 111       $index++;
 112     }
 113   }
 114
 115   /**
 116    * Handle the values in mapField mode.
 117    *
 118    * @param array $values
 119    *   The array of values belonging to this line.
 120    *
 121    * @return bool
 122    */
 123   public function mapField(&$values) {
 124     return CRM_Import_Parser::VALID;
 125   }
 126
 127   /**
 128    * Handle the values in preview mode.
 129    *
 130    * @param array $values
 131    *   The array of values belonging to this line.
 132    *
 133    * @return bool
 134    *   the result of this processing
 135    */
 136   public function preview(&$values) {
 137     return $this->summary($values);
 138   }
 139
 140   /**
 141    * Handle the values in summary mode.
 142    *
 143    * @param array $values
 144    *   The array of values belonging to this line.
 145    *
 146    * @return bool
 147    *   the result of this processing
 148    */
 149   public function summary(&$values) {
 150     $erroneousField = NULL;
 151     $this->setActiveFieldValues($values, $erroneousField);
 152     $index = -1;
 153
 154     if ($this->_activityTypeIndex > -1 && $this->_activityLabelIndex > -1) {
 155       array_unshift($values, ts('Please select either Activity Type ID OR Activity Type Label.'));
 156       return CRM_Import_Parser::ERROR;
 157     }
 158     elseif ($this->_activityLabelIndex > -1) {
 159       $index = $this->_activityLabelIndex;
 160     }
 161     elseif ($this->_activityTypeIndex > -1) {
 162       $index = $this->_activityTypeIndex;
 163     }
 164
 165     if ($index < 0 or $this->_activityDateIndex < 0) {
 166       $errorRequired = TRUE;
 167     }
 168     else {
 169       $errorRequired = !CRM_Utils_Array::value($index, $values) || !CRM_Utils_Array::value($this->_activityDateIndex, $values);
 170     }
 171
 172     if ($errorRequired) {
 173       array_unshift($values, ts('Missing required fields'));
 174       return CRM_Import_Parser::ERROR;
 175     }
 176
 177     $params = &$this->getActiveFieldParams();
 178
 179     $errorMessage = NULL;
 180
 181     // For date-Formats
 182     $session = CRM_Core_Session::singleton();
 183     $dateType = $session->get('dateTypes');
 184     if (!isset($params['source_contact_id'])) {
 185       $params['source_contact_id'] = $session->get('userID');
 186     }
 187     foreach ($params as $key => $val) {
 188       if ($key == 'activity_date_time') {
 189         if ($val) {
 190           $dateValue = CRM_Utils_Date::formatDate($val, $dateType);
 191           if ($dateValue) {
 192             $params[$key] = $dateValue;
 193           }
 194           else {
 195             CRM_Contact_Import_Parser_Contact::addToErrorMsg('Activity date', $errorMessage);
 196           }
 197         }
 198       }
 199       elseif ($key == 'activity_engagement_level' && $val &&
 200         !CRM_Utils_Rule::positiveInteger($val)
 201       ) {
 202         CRM_Contact_Import_Parser_Contact::addToErrorMsg('Activity Engagement Index', $errorMessage);
 203       }
 204     }
 205     // Date-Format part ends.
 206
 207     // Checking error in custom data.
 208     $params['contact_type'] = $this->_contactType ?? 'Activity';
 209
 210     CRM_Contact_Import_Parser_Contact::isErrorInCustomData($params, $errorMessage);
 211
 212     if ($errorMessage) {
 213       $tempMsg = "Invalid value for field(s) : $errorMessage";
 214       array_unshift($values, $tempMsg);
 215       $errorMessage = NULL;
 216       return CRM_Import_Parser::ERROR;
 217     }
 218
 219     return CRM_Import_Parser::VALID;
 220   }
 221
 222   /**
 223    * Handle the values in import mode.
 224    *
 225    * @param int $onDuplicate
 226    *   The code for what action to take on duplicates.
 227    * @param array $values
 228    *   The array of values belonging to this line.
 229    *
 230    * @return bool
 231    *   the result of this processing
 232    */
 233   public function import($onDuplicate, &$values) {
 234     // First make sure this is a valid line
 235     $response = $this->summary($values);
 236
 237     if ($response != CRM_Import_Parser::VALID) {
 238       return $response;
 239     }
 240     $params = &$this->getActiveFieldParams();
 241     $activityLabel = array_search('activity_label', $this->_mapperKeys);
 242     if ($activityLabel) {
 243       $params = array_merge($params, ['activity_label' => $values[$activityLabel]]);
 244     }
 245     // For date-Formats.
 246     $session = CRM_Core_Session::singleton();
 247     $dateType = $session->get('dateTypes');
 248     if (!isset($params['source_contact_id'])) {
 249       $params['source_contact_id'] = $session->get('userID');
 250     }
 251
 252     $customFields = CRM_Core_BAO_CustomField::getFields('Activity');
 253
 254     foreach ($params as $key => $val) {
 255       if ($customFieldID = CRM_Core_BAO_CustomField::getKeyID($key)) {
 256         if ($key == 'activity_date_time' && $val) {
 257           $params[$key] = CRM_Utils_Date::formatDate($val, $dateType);
 258         }
 259         elseif (!empty($customFields[$customFieldID]) && $customFields[$customFieldID]['data_type'] == 'Date') {
 260           CRM_Contact_Import_Parser_Contact::formatCustomDate($params, $params, $dateType, $key);
 261         }
 262         elseif (!empty($customFields[$customFieldID]) && $customFields[$customFieldID]['data_type'] == 'Boolean') {
 263           $params[$key] = CRM_Utils_String::strtoboolstr($val);
 264         }
 265       }
 266       elseif ($key == 'activity_date_time') {
 267         $params[$key] = CRM_Utils_Date::formatDate($val, $dateType);
 268       }
 269       elseif ($key == 'activity_subject') {
 270         $params['subject'] = $val;
 271       }
 272     }
 273     // Date-Format part ends.
 274     require_once 'CRM/Utils/DeprecatedUtils.php';
 275     $formatError = _civicrm_api3_deprecated_activity_formatted_param($params, $params, TRUE);
 276
 277     if ($formatError) {
 278       array_unshift($values, $formatError['error_message']);
 279       return CRM_Import_Parser::ERROR;
 280     }
 281
 282     $params['custom'] = CRM_Core_BAO_CustomField::postProcess($params,
 283       NULL,
 284       'Activity'
 285     );
 286
 287     if ($this->_contactIdIndex < 0) {
 288
 289       // Retrieve contact id using contact dedupe rule.
 290       // Since we are supporting only individual's activity import.
 291       $params['contact_type'] = 'Individual';
 292       $params['version'] = 3;
 293       $error = _civicrm_api3_deprecated_duplicate_formatted_contact($params);
 294
 295       if (CRM_Core_Error::isAPIError($error, CRM_Core_ERROR::DUPLICATE_CONTACT)) {
 296         $matchedIDs = explode(',', $error['error_message']['params'][0]);
 297         if (count($matchedIDs) > 1) {
 298           array_unshift($values, 'Multiple matching contact records detected for this row. The activity was not imported');
 299           return CRM_Import_Parser::ERROR;
 300         }
 301         $cid = $matchedIDs[0];
 302         $params['target_contact_id'] = $cid;
 303         $params['version'] = 3;
 304         $newActivity = civicrm_api('activity', 'create', $params);
 305         if (!empty($newActivity['is_error'])) {
 306           array_unshift($values, $newActivity['error_message']);
 307           return CRM_Import_Parser::ERROR;
 308         }
 309
 310         $this->_newActivity[] = $newActivity['id'];
 311         return CRM_Import_Parser::VALID;
 312
 313       }
 314       // Using new Dedupe rule.
 315       $ruleParams = [
 316         'contact_type' => 'Individual',
 317         'used' => 'Unsupervised',
 318       ];
 319       $fieldsArray = CRM_Dedupe_BAO_Rule::dedupeRuleFields($ruleParams);
 320
 321       $disp = NULL;
 322       foreach ($fieldsArray as $value) {
 323         if (array_key_exists(trim($value), $params)) {
 324           $paramValue = $params[trim($value)];
 325           if (is_array($paramValue)) {
 326             $disp .= $params[trim($value)][0][trim($value)] . " ";
 327           }
 328           else {
 329             $disp .= $params[trim($value)] . " ";
 330           }
 331         }
 332       }
 333
 334       if (!empty($params['external_identifier'])) {
 335         if ($disp) {
 336           $disp .= "AND {$params['external_identifier']}";
 337         }
 338         else {
 339           $disp = $params['external_identifier'];
 340         }
 341       }
 342
 343       array_unshift($values, 'No matching Contact found for (' . $disp . ')');
 344       return CRM_Import_Parser::ERROR;
 345     }
 346     if (!empty($params['external_identifier'])) {
 347       $targetContactId = CRM_Core_DAO::getFieldValue('CRM_Contact_DAO_Contact',
 348         $params['external_identifier'], 'id', 'external_identifier'
 349       );
 350
 351       if (!empty($params['target_contact_id']) &&
 352         $params['target_contact_id'] != $targetContactId
 353       ) {
 354         array_unshift($values, 'Mismatch of External ID:' . $params['external_identifier'] . ' and Contact Id:' . $params['target_contact_id']);
 355         return CRM_Import_Parser::ERROR;
 356       }
 357       if ($targetContactId) {
 358         $params['target_contact_id'] = $targetContactId;
 359       }
 360       else {
 361         array_unshift($values, 'No Matching Contact for External ID:' . $params['external_identifier']);
 362         return CRM_Import_Parser::ERROR;
 363       }
 364     }
 365
 366     $params['version'] = 3;
 367     $newActivity = civicrm_api('activity', 'create', $params);
 368     if (!empty($newActivity['is_error'])) {
 369       array_unshift($values, $newActivity['error_message']);
 370       return CRM_Import_Parser::ERROR;
 371     }
 372
 373     $this->_newActivity[] = $newActivity['id'];
 374     return CRM_Import_Parser::VALID;
 375   }
 376
 377 }