3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.6 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2014 |
7 +--------------------------------------------------------------------+
8 | This file is a part of CiviCRM. |
10 | CiviCRM is free software; you can copy, modify, and distribute it |
11 | under the terms of the GNU Affero General Public License |
12 | Version 3, 19 November 2007 and the CiviCRM Licensing Exception. |
14 | CiviCRM is distributed in the hope that it will be useful, but |
15 | WITHOUT ANY WARRANTY; without even the implied warranty of |
16 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. |
17 | See the GNU Affero General Public License for more details. |
19 | You should have received a copy of the GNU Affero General Public |
20 | License and the CiviCRM Licensing Exception along |
21 | with this program; if not, contact CiviCRM LLC |
22 | at info[AT]civicrm[DOT]org. If you have questions about the |
23 | GNU Affero General Public License or the licensing of CiviCRM, |
24 | see the CiviCRM license FAQ at http://civicrm.org/licensing |
25 +--------------------------------------------------------------------+
31 * @copyright CiviCRM LLC (c) 2004-2014
35 class CRM_Contact_BAO_Relationship
extends CRM_Contact_DAO_Relationship
{
38 * Various constants to indicate different type of relationships
42 const PAST
= 1, DISABLED
= 2, CURRENT
= 4, INACTIVE
= 8;
45 * Create function. (Use the API instead)
46 * Note that the previous create function has been renamed 'createMultiple'
47 * and this is new in 4.6
48 * All existing calls have been changed to createMultiple except the api call - however, it is recommended
49 * that you call that as the end to end testing here is based on the api & refactoring may still be done
51 * @return \CRM_Contact_BAO_Relationship
52 * @throws \CRM_Core_Exception
54 public static function create(&$params) {
55 self
::setContactABFromIDs($params);
56 if (self
::checkDuplicateRelationship($params, $params['contact_id_a'], $params['contact_id_b'], CRM_Utils_Array
::value('id', $params, 0))) {
57 throw new CRM_Core_Exception('Duplicate Relationship');
59 if (self
::checkValidRelationship($params, $params, 0)) {
60 throw new CRM_Core_Exception('Invalid Relationship');
62 $relationship = self
::add($params);
63 if (!empty($params['contact_id_a'])) {
64 $ids = array('contactTarget' => $relationship->contact_id_b
, 'contact' => $params['contact_id_a']);
65 CRM_Contact_BAO_Relationship
::relatedMemberships($params['contact_id_a'], $values, $ids, (empty($params['id']) ? CRM_Core_Action
::ADD
: CRM_Core_Action
::UPDATE
));
67 self
::addRecent($params, $relationship);
71 * Takes an associative array and creates a relationship object
72 * @deprecated For single creates use the api instead (it's tested).
73 * For multiple a new variant of this function needs to be written and migrated to as this is a bit
76 * @param array $params
77 * (reference ) an assoc array of name/value pairs.
79 * The array that holds all the db ids.
80 * per http://wiki.civicrm.org/confluence/display/CRM/Database+layer
81 * "we are moving away from the $ids param "
83 * @return CRM_Contact_BAO_Relationship object
86 public static function createMultiple(&$params, $ids = array()) {
87 $valid = $invalid = $duplicate = $saved = 0;
88 $relationships = $relationshipIds = array();
89 $relationshipId = CRM_Utils_Array
::value('relationship', $ids, CRM_Utils_Array
::value('id', $params));
90 //CRM-9015 - the hooks are called here & in add (since add doesn't call create)
91 // but in future should be tidied per ticket
92 if (empty($relationshipId)) {
94 $action = CRM_Core_Action
::ADD
;
98 $action = CRM_Core_Action
::UPDATE
;
101 CRM_Utils_Hook
::pre($hook, 'Relationship', $relationshipId, $params);
103 if (!$relationshipId) {
104 // creating a new relationship
105 $dataExists = self
::dataExists($params);
107 return array(FALSE, TRUE, FALSE, FALSE, NULL);
109 $relationshipIds = array();
110 foreach ($params['contact_check'] as $key => $value) {
112 // check if the relationship is valid between contacts.
113 // step 1: check if the relationship is valid if not valid skip and keep the count
114 // step 2: check the if two contacts already have a relationship if yes skip and keep the count
115 // step 3: if valid relationship then add the relation and keep the count
118 $errors = self
::checkValidRelationship($params, $ids, $key);
125 self
::checkDuplicateRelationship(
127 CRM_Utils_Array
::value('contact', $ids),
135 self
::setContactABFromIDs($params, $ids, $key);
136 $relationship = self
::add($params);
137 $relationshipIds[] = $relationship->id
;
138 $relationships[$relationship->id
] = $relationship;
141 // editing the relationship
144 // check for duplicate relationship
145 // @todo this code doesn't cope well with updates - causes e-Notices.
146 // API has a lot of code to work around
147 // this but should review this code & remove the extra handling from the api
148 // it seems doubtful any of this is relevant if the contact fields & relationship
149 // type fields are not set
151 self
::checkDuplicateRelationship(
153 CRM_Utils_Array
::value('contact', $ids),
154 $ids['contactTarget'],
159 return array($valid, $invalid, $duplicate, $saved, NULL);
162 $validContacts = TRUE;
163 //validate contacts in update mode also.
164 if (!empty($ids['contact']) && !empty($ids['contactTarget'])) {
165 if (self
::checkValidRelationship($params, $ids, $ids['contactTarget'])) {
166 $validContacts = FALSE;
170 if ($validContacts) {
171 // editing an existing relationship
172 $relationship = self
::add($params, $ids, $ids['contactTarget']);
173 $relationshipIds[] = $relationship->id
;
174 $relationships[$relationship->id
] = $relationship;
179 // do not add to recent items for import, CRM-4399
180 if (!(!empty($params['skipRecentView']) ||
$invalid ||
$duplicate)) {
181 self
::addRecent($params, $relationship);
184 return array($valid, $invalid, $duplicate, $saved, $relationshipIds, $relationships);
188 * This is the function that check/add if the relationship created is valid
190 * @param array $params
191 * (reference ) an assoc array of name/value pairs.
192 * @param int $contactId
193 * This is contact id for adding relationship.
195 * The array that holds all the db ids.
197 * @return CRM_Contact_BAO_Relationship
200 public static function add(&$params, $ids = array(), $contactId = NULL) {
202 CRM_Utils_Array
::value('relationship', $ids, CRM_Utils_Array
::value('id', $params));
205 if ($relationshipId) {
208 //@todo hook are called from create and add - remove one
209 CRM_Utils_Hook
::pre($hook , 'Relationship', $relationshipId, $params);
211 self
::setContactABFromIDs($params);
212 $relationshipTypes = CRM_Utils_Array
::value('relationship_type_id', $params);
214 // explode the string with _ to get the relationship type id
215 // and to know which contact has to be inserted in
216 // contact_id_a and which one in contact_id_b
217 list($type) = explode('_', $relationshipTypes);
219 // check if the relationship type is Head of Household then update the
220 // household's primary contact with this contact.
222 CRM_Contact_BAO_Household
::updatePrimaryContact($params['contact_id_b'], $params['contact_id_a']);
225 $relationship = new CRM_Contact_BAO_Relationship();
226 //@todo this code needs to be updated for the possibility that not all fields are set
228 $relationship->contact_id_b
= $params['contact_id_b'];
229 $relationship->contact_id_a
= $params['contact_id_a'];
230 $relationship->relationship_type_id
= $type;
231 $relationship->id
= $relationshipId;
233 $dateFields = array('end_date', 'start_date');
235 foreach (self
::getdefaults() as $defaultField => $defaultValue) {
236 if (isset($params[$defaultField])) {
237 if (in_array($defaultField, $dateFields)) {
238 $relationship->$defaultField = CRM_Utils_Date
::format(CRM_Utils_Array
::value($defaultField, $params));
239 if (!$relationship->$defaultField) {
240 $relationship->$defaultField = 'NULL';
244 $relationship->$defaultField = $params[$defaultField];
247 elseif(!$relationshipId) {
248 $relationship->$defaultField = $defaultValue;
252 $relationship->save();
254 // add custom field values
255 if (!empty($params['custom'])) {
256 CRM_Core_BAO_CustomValueTable
::store($params['custom'], 'civicrm_relationship', $relationship->id
);
259 $relationship->free();
261 CRM_Utils_Hook
::post($hook, 'Relationship', $relationship->id
, $relationship);
263 return $relationship;
267 * Add relationship to recent links
268 * @param array $params
269 * @param CRM_Contact_DAO_Relationship $relationship
271 public static function addRecent($params, $relationship) {
272 $url = CRM_Utils_System
::url('civicrm/contact/view/rel',
273 "action=view&reset=1&id={$relationship->id}&cid={$relationship->contact_id_a}&context=home"
275 $session = CRM_Core_Session
::singleton();
276 $recentOther = array();
277 if (($session->get('userID') == $relationship->contact_id_a
) ||
278 CRM_Contact_BAO_Contact_Permission
::allow($relationship->contact_id_a
, CRM_Core_Permission
::EDIT
)
280 $rType = substr(CRM_Utils_Array
::value('relationship_type_id', $params), -3);
281 $recentOther = array(
282 'editUrl' => CRM_Utils_System
::url('civicrm/contact/view/rel',
283 "action=update&reset=1&id={$relationship->id}&cid={$relationship->contact_id_a}&rtype={$rType}&context=home"
285 'deleteUrl' => CRM_Utils_System
::url('civicrm/contact/view/rel',
286 "action=delete&reset=1&id={$relationship->id}&cid={$relationship->contact_id_a}&rtype={$rType}&context=home"
290 $title = CRM_Contact_BAO_Contact
::displayName($relationship->contact_id_a
) . ' (' . CRM_Core_DAO
::getFieldValue('CRM_Contact_DAO_RelationshipType',
291 $relationship->relationship_type_id
, 'label_a_b'
292 ) . ' ' . CRM_Contact_BAO_Contact
::displayName($relationship->contact_id_b
) . ')';
294 CRM_Utils_Recent
::add($title,
298 $relationship->contact_id_a
,
305 * Resolve passed in contact IDs to contact_id_a & contact_id_b
308 * @param null $contactID
309 * @throws \CRM_Core_Exception
311 public static function setContactABFromIDs(&$params, $ids = array(), $contactID = NULL) {
312 if (!empty($params['contact_id_a']) && !empty($params['contact_id_b'])) {
315 if (empty($ids['contact'])) {
316 if (!empty($params['id'])) {
317 //let's load the missing ids here since other things tend to rely on them.
318 $fieldsToFill = array('contact_id_a', 'contact_id_b', 'relationship_type_id');
319 $result = CRM_Core_DAO
::executeQuery("SELECT " . implode(',', $fieldsToFill) . " FROM civicrm_relationship WHERE id = %1", array(1 => array($params['id'], 'Integer')));
320 while ($result->fetch()) {
321 foreach ($fieldsToFill as $field) {
322 $params[$field] = !empty($params[$field]) ?
$params[$field] : $result->$field;
327 throw new CRM_Core_Exception('Cannot create relationship, insufficient contact IDs provided');
329 $relationshipTypes = CRM_Utils_Array
::value('relationship_type_id', $params);
330 list($relationshipTypeID, $first, $second) = explode('_', $relationshipTypes);
331 if (empty($params['relationship_type_id'])) {
332 $params['relationship_type_id'] = $relationshipTypeID;
334 foreach (array('a', 'b') as $contactLetter) {
335 if (empty($params['contact_' . $contactLetter])) {
336 if ($first == $contactLetter) {
337 $params['contact_id_' . $contactLetter] = CRM_Utils_Array
::value('contact', $ids);
340 $params['contact_id_' . $contactLetter] = $contactID;
347 * Specifiy defaults for creating a relationship
349 * @return array $defaults array of defaults for creating relationship
352 public static function getdefaults() {
355 'is_permission_a_b' => 0,
356 'is_permission_b_a' => 0,
358 'start_date' => 'NULL',
360 'end_date' => 'NULL',
366 * Check if there is data to create the object
368 * @param array $params
369 * (reference ) an assoc array of name/value pairs.
374 public static function dataExists(&$params) {
375 // return if no data present
376 if (!is_array(CRM_Utils_Array
::value('contact_check', $params))) {
383 * Get get list of relationship type based on the contact type.
385 * @param int $contactId
386 * This is the contact id of the current contact.
387 * @param null $contactSuffix
388 * @param string $relationshipId
389 * The id of the existing relationship if any.
390 * @param string $contactType
393 * If true returns relationship types in both the direction.
394 * @param string $column
395 * Name/label that going to retrieve from db.
396 * @param bool $biDirectional
397 * @param string $contactSubType
398 * Includes relationshiptypes between this subtype.
399 * @param bool $onlySubTypeRelationTypes
400 * If set only subtype which is passed by $contactSubType.
401 * related relationshiptypes get return
405 * @return array - array reference of all relationship types with context to current contact.
407 static function getContactRelationshipType(
409 $contactSuffix = NULL,
410 $relationshipId = NULL,
414 $biDirectional = TRUE,
415 $contactSubType = NULL,
416 $onlySubTypeRelationTypes = FALSE
418 $allRelationshipType = array();
419 $relationshipType = array();
420 $allRelationshipType = CRM_Core_PseudoConstant
::relationshipType($column);
422 $otherContactType = NULL;
423 if ($relationshipId) {
424 $relationship = new CRM_Contact_DAO_Relationship();
425 $relationship->id
= $relationshipId;
426 if ($relationship->find(TRUE)) {
427 $contact = new CRM_Contact_DAO_Contact();
428 $contact->id
= ($relationship->contact_id_a
=== $contactId) ?
$relationship->contact_id_b
: $relationship->contact_id_a
;
430 if ($contact->find(TRUE)) {
431 $otherContactType = $contact->contact_type
;
432 //CRM-5125 for contact subtype specific relationshiptypes
433 if ($contact->contact_sub_type
) {
434 $otherContactSubType = $contact->contact_sub_type
;
440 $contactSubType = array();
442 $contactType = CRM_Contact_BAO_Contact
::getContactType($contactId);
443 $contactSubType = CRM_Contact_BAO_Contact
::getContactSubType($contactId);
446 foreach ($allRelationshipType as $key => $value) {
447 // the contact type is required or matches
448 if (((!$value['contact_type_a']) ||
449 $value['contact_type_a'] == $contactType
451 // the other contact type is required or present or matches
452 ((!$value['contact_type_b']) ||
453 (!$otherContactType) ||
454 $value['contact_type_b'] == $otherContactType
456 (in_array($value['contact_sub_type_a'], $contactSubType) ||
457 in_array($value['contact_sub_type_b'], $contactSubType) ||
458 (!$value['contact_sub_type_a'] && !$onlySubTypeRelationTypes)
461 $relationshipType[$key . '_a_b'] = $value["{$column}_a_b"];
464 if (((!$value['contact_type_b']) ||
465 $value['contact_type_b'] == $contactType
467 ((!$value['contact_type_a']) ||
468 (!$otherContactType) ||
469 $value['contact_type_a'] == $otherContactType
471 (in_array($value['contact_sub_type_b'], $contactSubType) ||
472 in_array($value['contact_sub_type_a'], $contactSubType) ||
473 (!$value['contact_sub_type_b'] && !$onlySubTypeRelationTypes)
476 $relationshipType[$key . '_b_a'] = $value["{$column}_b_a"];
480 $relationshipType[$key . '_a_b'] = $value["{$column}_a_b"];
481 $relationshipType[$key . '_b_a'] = $value["{$column}_b_a"];
485 if ($biDirectional) {
486 // lets clean up the data and eliminate all duplicate values
487 // (i.e. the relationship is bi-directional)
488 $relationshipType = array_unique($relationshipType);
491 // sort the relationshipType in ascending order CRM-7736
492 asort($relationshipType);
493 return $relationshipType;
500 * @return CRM_Contact_DAO_Relationship
502 public static function clearCurrentEmployer($id, $action) {
503 $relationship = new CRM_Contact_DAO_Relationship();
504 $relationship->id
= $id;
505 $relationship->find(TRUE);
507 //to delete relationship between household and individual \
508 //or between individual and orgnization
509 if (($action & CRM_Core_Action
::DISABLE
) ||
($action & CRM_Core_Action
::DELETE
)) {
510 $relTypes = CRM_Utils_Array
::index(array('name_a_b'), CRM_Core_PseudoConstant
::relationshipType('name'));
511 if ($relationship->relationship_type_id
== $relTypes['Employee of']['id'] ||
512 $relationship->relationship_type_id
== $relTypes['Household Member of']['id']) {
513 $sharedContact = new CRM_Contact_DAO_Contact();
514 $sharedContact->id
= $relationship->contact_id_a
;
515 $sharedContact->find(TRUE);
517 if ($relationship->relationship_type_id
== 4 && $relationship->contact_id_b
== $sharedContact->employer_id
) {
518 CRM_Contact_BAO_Contact_Utils
::clearCurrentEmployer($relationship->contact_id_a
);
522 return $relationship;
526 * Delete the relationship
535 public static function del($id) {
536 // delete from relationship table
537 CRM_Utils_Hook
::pre('delete', 'Relationship', $id, CRM_Core_DAO
::$_nullArray);
539 $relationship = self
::clearCurrentEmployer($id, CRM_Core_Action
::DELETE
);
540 if (CRM_Core_Permission
::access('CiviMember')) {
541 // create $params array which isrequired to delete memberships
542 // of the related contacts.
544 'relationship_type_id' => "{$relationship->relationship_type_id}_a_b",
545 'contact_check' => array($relationship->contact_id_b
=> 1),
549 // calling relatedMemberships to delete the memberships of
551 self
::relatedMemberships($relationship->contact_id_a
,
554 CRM_Core_Action
::DELETE
,
559 $relationship->delete();
560 CRM_Core_Session
::setStatus(ts('Selected relationship has been deleted successfully.'), ts('Record Deleted'), 'success');
562 CRM_Utils_Hook
::post('delete', 'Relationship', $id, $relationship);
564 // delete the recently created Relationship
565 $relationshipRecent = array(
567 'type' => 'Relationship',
569 CRM_Utils_Recent
::del($relationshipRecent);
571 return $relationship;
575 * Disable/enable the relationship
585 public static function disableEnableRelationship($id, $action) {
586 $relationship = self
::clearCurrentEmployer($id, $action);
587 if (CRM_Core_Permission
::access('CiviMember')) {
588 // create $params array which isrequired to delete memberships
589 // of the related contacts.
591 'relationship_type_id' => "{$relationship->relationship_type_id}_a_b",
592 'contact_check' => array($relationship->contact_id_b
=> 1),
596 // calling relatedMemberships to delete/add the memberships of
598 if ($action & CRM_Core_Action
::DISABLE
) {
599 CRM_Contact_BAO_Relationship
::relatedMemberships($relationship->contact_id_a
,
602 CRM_Core_Action
::DELETE
,
606 elseif ($action & CRM_Core_Action
::ENABLE
) {
607 $ids['contact'] = $relationship->contact_id_a
;
608 CRM_Contact_BAO_Relationship
::relatedMemberships($relationship->contact_id_a
,
611 CRM_Core_Action
::ADD
,
619 * Delete the object records that are associated with this contact
621 * @param int $contactId
622 * Id of the contact to delete.
627 public static function deleteContact($contactId) {
628 $relationship = new CRM_Contact_DAO_Relationship();
629 $relationship->contact_id_a
= $contactId;
630 $relationship->delete();
632 $relationship = new CRM_Contact_DAO_Relationship();
633 $relationship->contact_id_b
= $contactId;
634 $relationship->delete();
636 CRM_Contact_BAO_Household
::updatePrimaryContact(NULL, $contactId);
640 * Get the other contact in a relationship
645 * $returns returns the contact ids in the realtionship
647 * @return \CRM_Contact_DAO_Relationship
650 public static function getContactIds($id) {
651 $relationship = new CRM_Contact_DAO_Relationship();
653 $relationship->id
= $id;
654 $relationship->selectAdd();
655 $relationship->selectAdd('contact_id_a, contact_id_b');
656 $relationship->find(TRUE);
658 return $relationship;
662 * Check if the relationship type selected between two contacts is correct
664 * @param int $contact_a
666 * @param int $contact_b
668 * @param int $relationshipTypeId
669 * Relationship type id.
671 * @return boolean true if it is valid relationship else false
674 public static function checkRelationshipType($contact_a, $contact_b, $relationshipTypeId) {
675 $relationshipType = new CRM_Contact_DAO_RelationshipType();
676 $relationshipType->id
= $relationshipTypeId;
677 $relationshipType->selectAdd();
678 $relationshipType->selectAdd('contact_type_a, contact_type_b, contact_sub_type_a, contact_sub_type_b');
679 if ($relationshipType->find(TRUE)) {
680 $contact_type_a = CRM_Contact_BAO_Contact
::getContactType($contact_a);
681 $contact_type_b = CRM_Contact_BAO_Contact
::getContactType($contact_b);
683 $contact_sub_type_a = CRM_Contact_BAO_Contact
::getContactSubType($contact_a);
684 $contact_sub_type_b = CRM_Contact_BAO_Contact
::getContactSubType($contact_b);
686 if (((!$relationshipType->contact_type_a
) ||
($relationshipType->contact_type_a
== $contact_type_a)) &&
687 ((!$relationshipType->contact_type_b
) ||
($relationshipType->contact_type_b
== $contact_type_b)) &&
688 ((!$relationshipType->contact_sub_type_a
) ||
(in_array($relationshipType->contact_sub_type_a
,
691 ((!$relationshipType->contact_sub_type_b
) ||
(in_array($relationshipType->contact_sub_type_b
,
705 * This function does the validtion for valid relationship
707 * @param array $params
708 * This array contains the values there are subitted by the form.
710 * The array that holds all the db ids.
711 * @param int $contactId
712 * This is contact id for adding relationship.
718 public static function checkValidRelationship($params, $ids, $contactId) {
720 self
::setContactABFromIDs($params, $ids, $contactId);
721 // get the string of relationship type
722 $relationshipTypes = CRM_Utils_Array
::value('relationship_type_id', $params);
723 list($type) = explode('_', $relationshipTypes);
724 // function to check if the relationship selected is correct
725 // i.e. employer relationship can exit between Individual and Organization (not between Individual and Individual)
726 if (!CRM_Contact_BAO_Relationship
::checkRelationshipType($params['contact_id_a'], $params['contact_id_b'], $type)) {
727 $errors = 'Please select valid relationship between these two contacts.';
733 * This function checks for duplicate relationship
735 * @param array $params
736 * (reference ) an assoc array of name/value pairs.
738 * This the id of the contact whom we are adding relationship.
739 * @param int $contactId
740 * This is contact id for adding relationship.
741 * @param int $relationshipId
742 * This is relationship id for the contact.
744 * @return boolean true if record exists else false
747 public static function checkDuplicateRelationship(&$params, $id, $contactId = 0, $relationshipId = 0) {
748 $relationshipTypeId = CRM_Utils_Array
::value('relationship_type_id', $params);
749 list($type) = explode('_', $relationshipTypeId);
753 FROM civicrm_relationship
754 WHERE relationship_type_id = " . CRM_Utils_Type
::escape($type, 'Integer');
757 * CRM-11792 - date fields from API are in ISO format, but this function
758 * supports date arrays BAO has increasingly standardised to ISO format
759 * so I believe this function should support ISO rather than make API
760 * format it - however, need to support array format for now to avoid breakage
761 * @ time of writing this function is called from Relationship::createMultiple (twice)
762 * CRM_BAO_Contact_Utils::clearCurrentEmployer (seemingly without dates)
763 * CRM_Contact_Form_Task_AddToOrganization::postProcess &
764 * CRM_Contact_Form_Task_AddToHousehold::postProcess
765 * (I don't think the last 2 support dates but not sure
768 $dateFields = array('end_date', 'start_date');
769 foreach ($dateFields as $dateField) {
770 if (array_key_exists($dateField, $params)) {
771 if (empty($params[$dateField]) ||
$params[$dateField] == 'null') {
772 //this is most likely coming from an api call & probably loaded
773 // from the DB to deal with some of the
774 // other myriad of excessive checks still in place both in
775 // the api & the create functions
776 $queryString .= " AND $dateField IS NULL";
779 elseif (is_array($params[$dateField])) {
780 $queryString .= " AND $dateField = " .
781 CRM_Utils_Type
::escape(CRM_Utils_Date
::format($params[$dateField]), 'Date');
784 $queryString .= " AND $dateField = " .
785 CRM_Utils_Type
::escape($params[$dateField], 'Date');
791 " AND ( ( contact_id_a = " . CRM_Utils_Type
::escape($id, 'Integer') .
792 " AND contact_id_b = " . CRM_Utils_Type
::escape($contactId, 'Integer') .
793 " ) OR ( contact_id_a = " . CRM_Utils_Type
::escape($contactId, 'Integer') .
794 " AND contact_id_b = " . CRM_Utils_Type
::escape($id, 'Integer') . " ) ) ";
796 //if caseId is provided, include it duplicate checking.
797 if ($caseId = CRM_Utils_Array
::value('case_id', $params)) {
798 $queryString .= " AND case_id = " . CRM_Utils_Type
::escape($caseId, 'Integer');
801 if ($relationshipId) {
802 $queryString .= " AND id !=" . CRM_Utils_Type
::escape($relationshipId, 'Integer');
805 $relationship = new CRM_Contact_BAO_Relationship();
806 $relationship->query($queryString);
807 $relationship->fetch();
808 $relationship->free();
809 return ($relationship->id
) ?
TRUE : FALSE;
813 * Update the is_active flag in the db
816 * Id of the database record.
817 * @param bool $is_active
818 * Value we want to set the is_active field.
820 * @throws CiviCRM_API3_Exception
821 * @return Object DAO object on success, null otherwise
824 public static function setIsActive($id, $is_active) {
825 // as both the create & add functions have a bunch of logic in them that
826 // doesn't seem to cope with a normal update we will call the api which
827 // has tested handling for this
828 // however, a longer term solution would be to simplify the add, create & api functions
829 // to be more standard. It is debatable @ that point whether it's better to call the BAO
830 // direct as the api is more tested.
831 $result = civicrm_api('relationship', 'create', array(
833 'is_active' => $is_active,
837 if (is_array($result) && !empty($result['is_error']) && $result['error_message'] != 'Relationship already exists') {
838 throw new CiviCRM_API3_Exception($result['error_message'], CRM_Utils_Array
::value('error_code', $result, 'undefined'), $result);
841 // call (undocumented possibly deprecated) hook
842 CRM_Utils_Hook
::enableDisable('CRM_Contact_BAO_Relationship', $id, $is_active);
848 * Given the list of params in the params array, fetch the object
849 * and store the values in the values array
851 * @param array $params
852 * Input parameters to find object.
853 * @param array $values
854 * Output values of the object.
856 * @return array (reference) the values that could be potentially assigned to smarty
859 public static function &getValues(&$params, &$values) {
860 if (empty($params)) {
865 // get the specific number of relationship or all relationships.
866 if (!empty($params['numRelationship'])) {
867 $v['data'] = &CRM_Contact_BAO_Relationship
::getRelationship($params['contact_id'], NULL, $params['numRelationship']);
870 $v['data'] = CRM_Contact_BAO_Relationship
::getRelationship($params['contact_id']);
873 // get the total count of relationships
874 $v['totalCount'] = CRM_Contact_BAO_Relationship
::getRelationship($params['contact_id'], NULL, NULL, TRUE);
876 $values['relationship']['data'] = &$v['data'];
877 $values['relationship']['totalCount'] = &$v['totalCount'];
883 * Helper function to form the sql for relationship retrieval
885 * @param int $contactId
888 * (check const at top of file).
889 * @param int $numRelationship
890 * No of relationships to display (limit).
892 * Get the no of relationships.
893 * $param int $relationshipId relationship id
894 * @param int $relationshipId
895 * @param string $direction
896 * The direction we are interested in a_b or b_a.
897 * @param array $params
898 * Array of extra values including relationship_type_id per api spec.
900 * return string the query for this diretion
905 public static function makeURLClause($contactId, $status, $numRelationship, $count, $relationshipId, $direction, $params = array()) {
906 $select = $from = $where = '';
910 if ($direction == 'a_b') {
911 $select .= ' SELECT count(DISTINCT civicrm_relationship.id) as cnt1, 0 as cnt2 ';
914 $select .= ' SELECT 0 as cnt1, count(DISTINCT civicrm_relationship.id) as cnt2 ';
918 $select .= ' SELECT civicrm_relationship.id as civicrm_relationship_id,
919 civicrm_contact.sort_name as sort_name,
920 civicrm_contact.display_name as display_name,
921 civicrm_contact.job_title as job_title,
922 civicrm_contact.employer_id as employer_id,
923 civicrm_contact.organization_name as organization_name,
924 civicrm_address.street_address as street_address,
925 civicrm_address.city as city,
926 civicrm_address.postal_code as postal_code,
927 civicrm_state_province.abbreviation as state,
928 civicrm_country.name as country,
929 civicrm_email.email as email,
930 civicrm_contact.contact_type as contact_type,
931 civicrm_phone.phone as phone,
932 civicrm_contact.id as civicrm_contact_id,
933 civicrm_relationship.contact_id_b as contact_id_b,
934 civicrm_relationship.contact_id_a as contact_id_a,
935 civicrm_relationship_type.id as civicrm_relationship_type_id,
936 civicrm_relationship.start_date as start_date,
937 civicrm_relationship.end_date as end_date,
938 civicrm_relationship.description as description,
939 civicrm_relationship.is_active as is_active,
940 civicrm_relationship.is_permission_a_b as is_permission_a_b,
941 civicrm_relationship.is_permission_b_a as is_permission_b_a,
942 civicrm_relationship.case_id as case_id';
944 if ($direction == 'a_b') {
945 $select .= ', civicrm_relationship_type.label_a_b as label_a_b,
946 civicrm_relationship_type.label_b_a as relation ';
949 $select .= ', civicrm_relationship_type.label_a_b as label_a_b,
950 civicrm_relationship_type.label_a_b as relation ';
955 FROM civicrm_relationship
956 INNER JOIN civicrm_relationship_type ON ( civicrm_relationship.relationship_type_id = civicrm_relationship_type.id )
957 INNER JOIN civicrm_contact ";
958 if ($direction == 'a_b') {
959 $from .= 'ON ( civicrm_contact.id = civicrm_relationship.contact_id_a ) ';
962 $from .= 'ON ( civicrm_contact.id = civicrm_relationship.contact_id_b ) ';
965 LEFT JOIN civicrm_address ON (civicrm_address.contact_id = civicrm_contact.id AND civicrm_address.is_primary = 1)
966 LEFT JOIN civicrm_phone ON (civicrm_phone.contact_id = civicrm_contact.id AND civicrm_phone.is_primary = 1)
967 LEFT JOIN civicrm_email ON (civicrm_email.contact_id = civicrm_contact.id AND civicrm_email.is_primary = 1)
968 LEFT JOIN civicrm_state_province ON (civicrm_address.state_province_id = civicrm_state_province.id)
969 LEFT JOIN civicrm_country ON (civicrm_address.country_id = civicrm_country.id)
971 $where = 'WHERE ( 1 )';
973 if ($direction == 'a_b') {
974 $where .= ' AND civicrm_relationship.contact_id_b = ' . CRM_Utils_Type
::escape($contactId, 'Positive');
977 $where .= ' AND civicrm_relationship.contact_id_a = ' . CRM_Utils_Type
::escape($contactId, 'Positive') . '
978 AND civicrm_relationship.contact_id_a != civicrm_relationship.contact_id_b ';
981 if ($relationshipId) {
982 $where .= ' AND civicrm_relationship.id = ' . CRM_Utils_Type
::escape($relationshipId, 'Positive');
985 $date = date('Y-m-d');
986 if ($status == self
::PAST
) {
987 //this case for showing past relationship
988 $where .= ' AND civicrm_relationship.is_active = 1 ';
989 $where .= " AND civicrm_relationship.end_date < '" . $date . "'";
991 elseif ($status == self
::DISABLED
) {
992 // this case for showing disabled relationship
993 $where .= ' AND civicrm_relationship.is_active = 0 ';
995 elseif ($status == self
::CURRENT
) {
996 //this case for showing current relationship
997 $where .= ' AND civicrm_relationship.is_active = 1 ';
998 $where .= " AND (civicrm_relationship.end_date >= '" . $date . "' OR civicrm_relationship.end_date IS NULL) ";
1000 elseif ($status == self
::INACTIVE
) {
1001 //this case for showing inactive relationships
1002 $where .= " AND (civicrm_relationship.end_date < '" . $date . "'";
1003 $where .= ' OR civicrm_relationship.is_active = 0 )';
1007 $where .= ' AND civicrm_contact.is_deleted = 0';
1008 if (!empty($params['membership_type_id']) && empty($params['relationship_type_id'])) {
1009 $where .= self
::membershipTypeToRelationshipTypes($params, $direction);
1011 if (!empty($params['relationship_type_id'])) {
1012 if (is_array($params['relationship_type_id'])) {
1013 $where .= " AND " . CRM_Core_DAO
::createSQLFilter('relationship_type_id', $params['relationship_type_id'], 'Integer');
1016 $where .= ' AND relationship_type_id = ' . CRM_Utils_Type
::escape($params['relationship_type_id'], 'Positive');
1019 if ($direction == 'a_b') {
1020 $where .= ' ) UNION ';
1026 return array($select, $from, $where);
1030 * This is the function to get the list of relationships
1032 * @param int $contactId
1034 * @param int $status
1035 * 1: Past 2: Disabled 3: Current.
1036 * @param int $numRelationship
1037 * No of relationships to display (limit).
1039 * Get the no of relationships.
1040 * $param int $relationshipId relationship id
1041 * $param array $links the list of links to display
1042 * $param int $permissionMask the permission mask to be applied for the actions
1043 * $param boolean $permissionedContact to return only permissioned Contact
1044 * $param array $params array of variables consistent with filters supported by the api
1045 * return array $values relationship records
1046 * @param int $relationshipId
1047 * @param null $links
1048 * @param null $permissionMask
1049 * @param bool $permissionedContact
1050 * @param array $params
1055 static function getRelationship(
1057 $status = 0, $numRelationship = 0,
1058 $count = 0, $relationshipId = 0,
1059 $links = NULL, $permissionMask = NULL,
1060 $permissionedContact = FALSE,
1064 if (!$contactId && !$relationshipId) {
1068 list($select1, $from1, $where1) = self
::makeURLClause($contactId, $status, $numRelationship,
1069 $count, $relationshipId, 'a_b', $params
1071 list($select2, $from2, $where2) = self
::makeURLClause($contactId, $status, $numRelationship,
1072 $count, $relationshipId, 'b_a', $params
1075 $order = $limit = '';
1077 if (empty($params['sort'])) {
1078 $order = ' ORDER BY civicrm_relationship_type_id, sort_name ';
1081 $order = " ORDER BY {$params['sort']} ";
1085 if (!empty($params['offset']) && $params['offset'] > 0) {
1086 $offset = $params['offset'];
1089 if ($numRelationship) {
1090 $limit = " LIMIT {$offset}, $numRelationship";
1094 // building the query string
1095 $queryString = $select1 . $from1 . $where1 . $select2 . $from2 . $where2 . $order . $limit;
1097 $relationship = new CRM_Contact_DAO_Relationship();
1099 $relationship->query($queryString);
1102 $relationshipCount = 0;
1103 while ($relationship->fetch()) {
1104 $relationshipCount +
= $relationship->cnt1 +
$relationship->cnt2
;
1106 return $relationshipCount;
1111 if ($status != self
::INACTIVE
) {
1113 $mask = array_sum(array_keys($links));
1114 if ($mask & CRM_Core_Action
::DISABLE
) {
1115 $mask -= CRM_Core_Action
::DISABLE
;
1117 if ($mask & CRM_Core_Action
::ENABLE
) {
1118 $mask -= CRM_Core_Action
::ENABLE
;
1121 if ($status == self
::CURRENT
) {
1122 $mask |
= CRM_Core_Action
::DISABLE
;
1124 elseif ($status == self
::DISABLED
) {
1125 $mask |
= CRM_Core_Action
::ENABLE
;
1127 $mask = $mask & $permissionMask;
1130 while ($relationship->fetch()) {
1131 $rid = $relationship->civicrm_relationship_id
;
1132 $cid = $relationship->civicrm_contact_id
;
1133 if (($permissionedContact) &&
1134 (!CRM_Contact_BAO_Contact_Permission
::relationship($cid, $contactId))
1138 $values[$rid]['id'] = $rid;
1139 $values[$rid]['cid'] = $cid;
1140 $values[$rid]['contact_id_a'] = $relationship->contact_id_a
;
1141 $values[$rid]['contact_id_b'] = $relationship->contact_id_b
;
1142 $values[$rid]['contact_type'] = $relationship->contact_type
;
1143 $values[$rid]['relationship_type_id'] = $relationship->civicrm_relationship_type_id
;
1144 $values[$rid]['relation'] = $relationship->relation
;
1145 $values[$rid]['name'] = $relationship->sort_name
;
1146 $values[$rid]['display_name'] = $relationship->display_name
;
1147 $values[$rid]['job_title'] = $relationship->job_title
;
1148 $values[$rid]['email'] = $relationship->email
;
1149 $values[$rid]['phone'] = $relationship->phone
;
1150 $values[$rid]['employer_id'] = $relationship->employer_id
;
1151 $values[$rid]['organization_name'] = $relationship->organization_name
;
1152 $values[$rid]['country'] = $relationship->country
;
1153 $values[$rid]['city'] = $relationship->city
;
1154 $values[$rid]['state'] = $relationship->state
;
1155 $values[$rid]['start_date'] = $relationship->start_date
;
1156 $values[$rid]['end_date'] = $relationship->end_date
;
1157 $values[$rid]['description'] = $relationship->description
;
1158 $values[$rid]['is_active'] = $relationship->is_active
;
1159 $values[$rid]['is_permission_a_b'] = $relationship->is_permission_a_b
;
1160 $values[$rid]['is_permission_b_a'] = $relationship->is_permission_b_a
;
1161 $values[$rid]['case_id'] = $relationship->case_id
;
1164 $values[$rid]['status'] = $status;
1167 $values[$rid]['civicrm_relationship_type_id'] = $relationship->civicrm_relationship_type_id
;
1169 if ($relationship->contact_id_a
== $contactId) {
1170 $values[$rid]['rtype'] = 'a_b';
1173 $values[$rid]['rtype'] = 'b_a';
1179 'rtype' => $values[$rid]['rtype'],
1180 'cid' => $contactId,
1181 'cbid' => $values[$rid]['cid'],
1182 'caseid' => $values[$rid]['case_id'],
1183 'clientid' => $contactId,
1186 if ($status == self
::INACTIVE
) {
1187 // setting links for inactive relationships
1188 $mask = array_sum(array_keys($links));
1189 if (!$values[$rid]['is_active']) {
1190 $mask -= CRM_Core_Action
::DISABLE
;
1193 $mask -= CRM_Core_Action
::ENABLE
;
1194 $mask -= CRM_Core_Action
::DISABLE
;
1198 // Give access to manage case link by copying to MAX_ACTION index temporarily, depending on case permission of user.
1199 if ($values[$rid]['case_id']) {
1200 // Borrowed logic from CRM_Case_Page_Tab
1201 $hasCaseAccess = FALSE;
1202 if (CRM_Core_Permission
::check('access all cases and activities')) {
1203 $hasCaseAccess = TRUE;
1206 $userCases = CRM_Case_BAO_Case
::getCases(FALSE);
1207 if (array_key_exists($values[$rid]['case_id'], $userCases)) {
1208 $hasCaseAccess = TRUE;
1212 if ($hasCaseAccess) {
1213 // give access by copying to MAX_ACTION temporarily, otherwise leave at NONE which won't display
1214 $links[CRM_Core_Action
::MAX_ACTION
] = $links[CRM_Core_Action
::NONE
];
1215 $links[CRM_Core_Action
::MAX_ACTION
]['name'] = ts('Manage Case #%1', array(1 => $values[$rid]['case_id']));
1216 $links[CRM_Core_Action
::MAX_ACTION
]['class'] = 'no-popup';
1218 // Also make sure we have the right client cid since can get here from multiple relationship tabs.
1219 if ($values[$rid]['rtype'] == 'b_a') {
1220 $replace['clientid'] = $values[$rid]['cid'];
1225 $values[$rid]['action'] = CRM_Core_Action
::formLink(
1231 'relationship.selector.row',
1234 unset($links[CRM_Core_Action
::MAX_ACTION
]);
1238 $relationship->free();
1244 * Get get list of relationship type based on the target contact type.
1246 * @param string $targetContactType
1247 * It's valid contact tpye(may be Individual , Organization , Household).
1249 * @return array - array reference of all relationship types with context to current contact type .
1252 public function getRelationType($targetContactType) {
1253 $relationshipType = array();
1254 $allRelationshipType = CRM_Core_PseudoConstant
::relationshipType();
1256 foreach ($allRelationshipType as $key => $type) {
1257 if ($type['contact_type_b'] == $targetContactType) {
1258 $relationshipType[$key . '_a_b'] = $type['label_a_b'];
1262 return $relationshipType;
1266 * Create / update / delete membership for related contacts.
1268 * This function will create/update/delete membership for related
1269 * contact based on 1) contact have active membership 2) that
1270 * membership is is extedned by the same relationship type to that
1271 * of the existing relationship.
1276 * Array array of values submitted by POST.
1278 * Array array of ids.
1279 * @param \const|\which $action which action called this function
1281 * @param bool $active
1285 public static function relatedMemberships($contactId, &$params, $ids, $action = CRM_Core_Action
::ADD
, $active = TRUE) {
1286 // Check the end date and set the status of the relationship
1288 $status = self
::CURRENT
;
1290 if (!empty($params['end_date'])) {
1291 $endDate = CRM_Utils_Date
::setDateDefaults(CRM_Utils_Date
::format($params['end_date']), NULL, 'Ymd');
1292 $today = date('Ymd');
1294 if ($today > $endDate) {
1295 $status = self
::PAST
;
1299 if (($action & CRM_Core_Action
::ADD
) &&
1300 ($status & self
::PAST
)
1302 // if relationship is PAST and action is ADD, no qustion
1303 // of creating RELATED membership and return back to
1308 $rel = explode('_', $params['relationship_type_id']);
1310 $relTypeId = $rel[0];
1311 if (!empty($rel[1])) {
1312 $relDirection = "_{$rel[1]}_{$rel[2]}";
1315 // this call is coming from somewhere where the direction was resolved early on (e.g an api call)
1316 // so we can assume _a_b
1317 $relDirection = "_a_b";
1319 $targetContact = array();
1320 if (($action & CRM_Core_Action
::ADD
) ||
1321 ($action & CRM_Core_Action
::DELETE
)
1323 $contact = $contactId;
1324 $targetContact = CRM_Utils_Array
::value('contact_check', $params);
1326 elseif ($action & CRM_Core_Action
::UPDATE
) {
1327 $contact = $ids['contact'];
1328 $targetContact = array($ids['contactTarget'] => 1);
1331 // Build the 'values' array for
1334 // This will allow us to check if either of the contacts in
1335 // relationship have active memberships.
1340 $values[$contact] = array(
1341 'relatedContacts' => $targetContact,
1342 'relationshipTypeId' => $relTypeId,
1343 'relationshipTypeDirection' => $relDirection,
1346 if (!empty($targetContact)) {
1347 foreach ($targetContact as $cid => $donCare) {
1348 $values[$cid] = array(
1349 'relatedContacts' => array($contact => 1),
1350 'relationshipTypeId' => $relTypeId,
1353 $relTypeParams = array('id' => $relTypeId);
1354 $relTypeValues = array();
1355 CRM_Contact_BAO_RelationshipType
::retrieve($relTypeParams, $relTypeValues);
1357 if (CRM_Utils_Array
::value('name_a_b', $relTypeValues) == CRM_Utils_Array
::value('name_b_a', $relTypeValues)) {
1358 $values[$cid]['relationshipTypeDirection'] = '_a_b';
1361 $values[$cid]['relationshipTypeDirection'] = ($relDirection == '_a_b') ?
'_b_a' : '_a_b';
1366 // Now get the active memberships for all the contacts.
1367 // If contact have any valid membership(s), then add it to
1369 foreach ($values as $cid => $subValues) {
1370 $memParams = array('contact_id' => $cid);
1371 $memberships = array();
1373 CRM_Member_BAO_Membership
::getValues($memParams, $memberships, $active);
1375 if (empty($memberships)) {
1379 $values[$cid]['memberships'] = $memberships;
1381 $deceasedStatusId = array_search('Deceased', CRM_Member_PseudoConstant
::membershipStatus());
1383 // done with 'values' array.
1384 // Finally add / edit / delete memberships for the related contacts
1385 foreach ($values as $cid => $details) {
1386 if (!array_key_exists('memberships', $details)) {
1390 $mainRelatedContactId = key(CRM_Utils_Array
::value('relatedContacts', $details, array()));
1392 foreach ($details['memberships'] as $membershipId => $membershipValues) {
1393 $relTypeIds = array();
1394 if ($action & CRM_Core_Action
::DELETE
) {
1395 // Delete memberships of the related contacts only if relationship type exists for membership type
1397 SELECT relationship_type_id, relationship_direction
1398 FROM civicrm_membership_type
1399 WHERE id = {$membershipValues['membership_type_id']}";
1400 $dao = CRM_Core_DAO
::executeQuery($query);
1401 $relTypeDirs = array();
1402 while ($dao->fetch()) {
1403 $relTypeId = $dao->relationship_type_id
;
1404 $relDirection = $dao->relationship_direction
;
1406 $relTypeIds = explode(CRM_Core_DAO
::VALUE_SEPARATOR
, $relTypeId);
1407 if (in_array($values[$cid]['relationshipTypeId'], $relTypeIds)) {
1408 CRM_Member_BAO_Membership
::deleteRelatedMemberships($membershipId, $mainRelatedContactId);
1412 if (($action & CRM_Core_Action
::UPDATE
) &&
1413 ($status & self
::PAST
) &&
1414 ($membershipValues['owner_membership_id'])
1416 // If relationship is PAST and action is UPDATE
1417 // then delete the RELATED membership
1418 CRM_Member_BAO_Membership
::deleteRelatedMemberships($membershipValues['owner_membership_id'],
1419 $membershipValues['membership_contact_id']
1424 // add / edit the memberships for related
1427 // Get the Membership Type Details.
1428 $membershipType = CRM_Member_BAO_MembershipType
::getMembershipTypeDetails($membershipValues['membership_type_id']);
1429 // Check if contact's relationship type exists in membership type
1430 $relTypeDirs = array();
1431 if (!empty($membershipType['relationship_type_id'])) {
1432 $relTypeIds = explode(CRM_Core_DAO
::VALUE_SEPARATOR
, $membershipType['relationship_type_id']);
1434 if (!empty($membershipType['relationship_direction'])) {
1435 $relDirections = explode(CRM_Core_DAO
::VALUE_SEPARATOR
, $membershipType['relationship_direction']);
1437 foreach ($relTypeIds as $key => $value) {
1438 $relTypeDirs[] = $value . '_' . $relDirections[$key];
1440 $relTypeDir = $details['relationshipTypeId'] . $details['relationshipTypeDirection'];
1441 if (in_array($relTypeDir, $relTypeDirs)) {
1442 // Check if relationship being created/updated is
1443 // similar to that of membership type's
1446 $membershipValues['owner_membership_id'] = $membershipId;
1447 unset($membershipValues['id']);
1448 unset($membershipValues['membership_contact_id']);
1449 unset($membershipValues['contact_id']);
1450 unset($membershipValues['membership_id']);
1451 foreach ($details['relatedContacts'] as $relatedContactId => $donCare) {
1452 $membershipValues['contact_id'] = $relatedContactId;
1453 if ($deceasedStatusId &&
1454 CRM_Core_DAO
::getFieldValue('CRM_Contact_DAO_Contact', $relatedContactId, 'is_deceased')
1456 $membershipValues['status_id'] = $deceasedStatusId;
1457 $membershipValues['skipStatusCal'] = TRUE;
1460 'join_date', 'start_date', 'end_date') as $dateField) {
1461 if (!empty($membershipValues[$dateField])) {
1462 $membershipValues[$dateField] = CRM_Utils_Date
::processDate($membershipValues[$dateField]);
1466 if ($action & CRM_Core_Action
::UPDATE
) {
1467 //delete the membership record for related
1468 //contact before creating new membership record.
1469 CRM_Member_BAO_Membership
::deleteRelatedMemberships($membershipId, $relatedContactId);
1472 // check whether we have some related memberships still available
1475 FROM civicrm_membership
1476 LEFT JOIN civicrm_membership_status ON (civicrm_membership_status.id = civicrm_membership.status_id)
1477 WHERE membership_type_id = {$membershipValues['membership_type_id']} AND owner_membership_id = {$membershipValues['owner_membership_id']}
1478 AND is_current_member = 1";
1479 $result = CRM_Core_DAO
::singleValueQuery($query);
1480 if ($result < CRM_Utils_Array
::value('max_related', $membershipValues, PHP_INT_MAX
)) {
1481 CRM_Member_BAO_Membership
::create($membershipValues, CRM_Core_DAO
::$_nullArray);
1485 elseif ($action & CRM_Core_Action
::UPDATE
) {
1486 // if action is update and updated relationship do
1487 // not match with the existing
1488 // membership=>relationship then we need to
1489 // delete the membership record created for
1490 // previous relationship.
1492 if (self
::isDeleteRelatedMembership($relTypeIds, $contactId, $mainRelatedContactId, $relTypeId, CRM_Utils_Array
::value('relationship_ids', $params))) {
1493 CRM_Member_BAO_Membership
::deleteRelatedMemberships($membershipId, $mainRelatedContactId);
1501 * Helper function to check whether to delete the membership or
1507 public static function isDeleteRelatedMembership($relTypeIds, $contactId, $mainRelatedContactId, $relTypeId, $relIds) {
1508 if (in_array($relTypeId, $relTypeIds)) {
1512 if (empty($relIds)) {
1516 $relParamas = array(1 => array($contactId, 'Integer'),
1517 2 => array($mainRelatedContactId, 'Integer'),
1520 if ($contactId == $mainRelatedContactId) {
1521 $recordsFound = (int)CRM_Core_DAO
::singleValueQuery("SELECT COUNT(*) FROM civicrm_relationship WHERE relationship_type_id IN ( " . implode(',', $relTypeIds) . " ) AND contact_id_a IN ( %1 ) OR contact_id_b IN ( %1 ) AND id IN (" . implode(',', $relIds) . ")", $relParamas);
1522 if ($recordsFound) {
1528 $recordsFound = (int)CRM_Core_DAO
::singleValueQuery("SELECT COUNT(*) FROM civicrm_relationship WHERE relationship_type_id IN ( " . implode(',', $relTypeIds) . " ) AND contact_id_a IN ( %1, %2 ) AND contact_id_b IN ( %1, %2 ) AND id NOT IN (" . implode(',', $relIds) . ")", $relParamas);
1530 if ($recordsFound) {
1538 * Get Current Employer for Contact
1540 * @param $contactIds
1543 * @return array $currentEmployer array of the current employer@static
1545 public static function getCurrentEmployer($contactIds) {
1546 $contacts = implode(',', $contactIds);
1549 SELECT organization_name, id, employer_id
1550 FROM civicrm_contact
1551 WHERE id IN ( {$contacts} )
1554 $dao = CRM_Core_DAO
::executeQuery($query, CRM_Core_DAO
::$_nullArray);
1555 $currentEmployer = array();
1556 while ($dao->fetch()) {
1557 $currentEmployer[$dao->id
]['org_id'] = $dao->employer_id
;
1558 $currentEmployer[$dao->id
]['org_name'] = $dao->organization_name
;
1561 return $currentEmployer;
1565 * Return list of permissioned employer for a given contact.
1568 * Int contact id whose employers.
1571 * String employers sort name.
1575 * @return array array of employers.
1578 public static function getPermissionedEmployer($contactID, $name = NULL) {
1579 //get the relationship id
1580 $relTypeId = CRM_Core_DAO
::getFieldValue('CRM_Contact_DAO_RelationshipType',
1581 'Employee of', 'id', 'name_a_b'
1584 return self
::getPermissionedContacts($contactID, $relTypeId, $name);
1589 * Function to return list of permissioned contacts for a given contact and relationship type
1592 * Int contact id whose permissioned contacts are to be found.
1594 * String one or more relationship type id's.
1600 * @return array of contacts
1602 public static function getPermissionedContacts($contactID, $relTypeId, $name = NULL) {
1603 $contacts = array();
1607 SELECT cc.id as id, cc.sort_name as name
1608 FROM civicrm_relationship cr, civicrm_contact cc
1610 cr.contact_id_a = %1 AND
1611 cr.relationship_type_id IN (%2) AND
1612 cr.is_permission_a_b = 1 AND
1613 IF(cr.end_date IS NULL, 1, (DATEDIFF( CURDATE( ), cr.end_date ) <= 0)) AND
1614 cr.is_active = 1 AND
1615 cc.id = cr.contact_id_b AND
1618 if (!empty($name)) {
1619 $name = CRM_Utils_Type
::escape($name, 'String');
1621 AND cc.sort_name LIKE '%$name%'";
1624 $args = array(1 => array($contactID, 'Integer'), 2 => array($relTypeId, 'String'));
1625 $dao = CRM_Core_DAO
::executeQuery($query, $args);
1627 while ($dao->fetch()) {
1628 $contacts[$dao->id
] = array(
1629 'name' => $dao->name
,
1630 'value' => $dao->id
,
1638 * Merge relationships from otherContact to mainContact
1639 * Called during contact merge operation
1641 * @param int $mainId
1642 * Contact id of main contact record.
1643 * @param int $otherId
1644 * Contact id of record which is going to merge.
1645 * @param array $sqls
1646 * (reference) array of sql statements to append to.
1648 * @see CRM_Dedupe_Merger::cpTables()
1652 public static function mergeRelationships($mainId, $otherId, &$sqls) {
1653 // Delete circular relationships
1654 $sqls[] = "DELETE FROM civicrm_relationship
1655 WHERE (contact_id_a = $mainId AND contact_id_b = $otherId)
1656 OR (contact_id_b = $mainId AND contact_id_a = $otherId)";
1658 // Delete relationship from other contact if main contact already has that relationship
1659 $sqls[] = "DELETE r2
1660 FROM civicrm_relationship r1, civicrm_relationship r2
1661 WHERE r1.relationship_type_id = r2.relationship_type_id
1664 r1.contact_id_a = $mainId AND r2.contact_id_a = $otherId AND r1.contact_id_b = r2.contact_id_b
1665 OR r1.contact_id_b = $mainId AND r2.contact_id_b = $otherId AND r1.contact_id_a = r2.contact_id_a
1667 (r1.contact_id_a = $mainId AND r2.contact_id_b = $otherId AND r1.contact_id_b = r2.contact_id_a
1668 OR r1.contact_id_b = $mainId AND r2.contact_id_a = $otherId AND r1.contact_id_a = r2.contact_id_b)
1669 AND r1.relationship_type_id IN (SELECT id FROM civicrm_relationship_type WHERE name_b_a = name_a_b)
1673 // Move relationships
1674 $sqls[] = "UPDATE IGNORE civicrm_relationship SET contact_id_a = $mainId WHERE contact_id_a = $otherId";
1675 $sqls[] = "UPDATE IGNORE civicrm_relationship SET contact_id_b = $mainId WHERE contact_id_b = $otherId";
1677 // Move current employer id (name will get updated later)
1678 $sqls[] = "UPDATE civicrm_contact SET employer_id = $mainId WHERE employer_id = $otherId";
1682 * Set 'is_valid' field to false for all relationships whose end date is in the past, ie. are expired.
1684 * @return True on success, false if error is encountered.
1686 public static function disableExpiredRelationships() {
1687 $query = "SELECT id FROM civicrm_relationship WHERE is_active = 1 AND end_date < CURDATE()";
1689 $dao = CRM_Core_DAO
::executeQuery($query);
1690 while ($dao->fetch()) {
1691 $result = CRM_Contact_BAO_Relationship
::setIsActive($dao->id
, FALSE);
1692 // Result will be NULL if error occurred. We abort early if error detected.
1693 if ($result == NULL) {
1701 * Function filters the query by possible relationships for the membership type
1702 * It is intended to be called when constructing queries for the api (reciprocal & non-reciprocal)
1703 * and to add clauses to limit the return to those relationships which COULD inherit a membership type
1704 * (as opposed to those who inherit a particular membership
1706 * @param array $params
1708 * @param null $direction
1712 public static function membershipTypeToRelationshipTypes(&$params, $direction = NULL) {
1713 $membershipType = civicrm_api3('membership_type', 'getsingle', array('id' => $params['membership_type_id'], 'return' => 'relationship_type_id, relationship_direction'));
1714 $relationshipTypes = $membershipType['relationship_type_id'];
1715 if (empty($relationshipTypes)) {
1718 // if we don't have any contact data we can only filter on type
1719 if (empty($params['contact_id']) && empty($params['contact_id_a']) && empty($params['contact_id_a'])) {
1720 $params['relationship_type_id'] = array('IN' => $relationshipTypes);
1724 $relationshipDirections = (array) $membershipType['relationship_direction'];
1725 // if we have contact_id_a OR contact_id_b we can make a call here
1726 // if we have contact??
1727 foreach ($relationshipDirections as $index => $mtdirection) {
1728 if (isset($params['contact_id_a']) && $mtdirection == 'a_b' ||
$direction == 'a_b') {
1729 $types[] = $relationshipTypes[$index];
1731 if (isset($params['contact_id_b']) && $mtdirection == 'b_a' ||
$direction == 'b_a') {
1732 $types[] = $relationshipTypes[$index];
1735 if (!empty($types)) {
1736 $params['relationship_type_id'] = array('IN' => $types);
1738 elseif(!empty($clauses)) {
1739 return explode(' OR ', $clauses);
1742 // effectively setting it to return no results
1743 $params['relationship_type_id'] = 0;
1750 * This function is a wrapper for contact relationship selector
1752 * @param array $params
1753 * Associated array for params record id.
1755 * @return array $contactRelationships associated array of contact relationships
1757 public static function getContactRelationshipSelector(&$params) {
1758 // format the params
1759 $params['offset'] = ($params['page'] - 1) * $params['rp'];
1760 $params['sort'] = CRM_Utils_Array
::value('sortBy', $params);
1762 if ($params['context'] == 'past') {
1763 $relationshipStatus = CRM_Contact_BAO_Relationship
::INACTIVE
;
1766 $relationshipStatus = CRM_Contact_BAO_Relationship
::CURRENT
;
1769 // check logged in user for permission
1770 $page = new CRM_Core_Page();
1771 CRM_Contact_Page_View
::checkUserPermission($page, $params['contact_id']);
1772 $permissions = array($page->_permission
);
1773 if ($page->_permission
== CRM_Core_Permission
::EDIT
) {
1774 $permissions[] = CRM_Core_Permission
::DELETE
;
1776 $mask = CRM_Core_Action
::mask($permissions);
1778 if ($params['context'] != 'user') {
1779 $links = CRM_Contact_Page_View_Relationship
::links();
1780 $permissionedContacts = FALSE;
1783 $links = CRM_Contact_Page_View_UserDashBoard
::links();
1784 $permissionedContacts = TRUE;
1787 // get contact relationships
1788 $relationships = CRM_Contact_BAO_Relationship
::getRelationship($params['contact_id'],
1789 $relationshipStatus,
1790 $params['rp'], 0, 0,
1792 $permissionedContacts,
1796 $contactRelationships = array();
1797 $params['total'] = 0;
1798 if (!empty($relationships)) {
1799 // get the total relationships
1800 if ($params['context'] != 'user') {
1801 $params['total'] = CRM_Contact_BAO_Relationship
::getRelationship($params['contact_id'],
1802 $relationshipStatus, 0, 1, 0, NULL, NULL, $permissionedContacts);
1805 // FIX ME: we cannot directly determine total permissioned relationship, hence re-fire query
1806 $permissionedRelationships = CRM_Contact_BAO_Relationship
::getRelationship($params['contact_id'],
1807 $relationshipStatus,
1811 $params['total'] = count($permissionedRelationships);
1815 foreach ($relationships as $relationshipId => $values) {
1816 //Add image icon for related contacts: CRM-14919
1817 $icon = CRM_Contact_BAO_Contact_Utils
::getImage($values['contact_type'],
1821 $contactRelationships[$relationshipId]['name'] = $icon.' '.CRM_Utils_System
::href(
1823 'civicrm/contact/view',
1824 "reset=1&cid={$values['cid']}");
1826 $contactRelationships[$relationshipId]['relation'] = CRM_Utils_System
::href(
1827 $values['relation'],
1828 'civicrm/contact/view/rel',
1829 "action=view&reset=1&cid={$values['cid']}&id={$values['id']}&rtype={$values['rtype']}");
1831 if ($params['context'] == 'current') {
1832 if (($params['contact_id'] == $values['contact_id_a'] AND $values['is_permission_a_b'] == 1) OR
1833 ($params['contact_id'] == $values['contact_id_b'] AND $values['is_permission_b_a'] == 1)
1835 $contactRelationships[$relationshipId]['name'] .= '<span id="permission-a-b" class="crm-marker permission-relationship"> *</span>';
1838 if (($values['cid'] == $values['contact_id_a'] AND $values['is_permission_a_b'] == 1) OR
1839 ($values['cid'] == $values['contact_id_b'] AND $values['is_permission_b_a'] == 1)
1841 $contactRelationships[$relationshipId]['relation'] .= '<span id="permission-b-a" class="crm-marker permission-relationship"> *</span>';
1845 if (!empty($values['description'])) {
1846 $contactRelationships[$relationshipId]['relation'] .= "<p class='description'>{$values['description']}</p>";
1849 $contactRelationships[$relationshipId]['start_date'] = CRM_Utils_Date
::customFormat($values['start_date']);
1850 $contactRelationships[$relationshipId]['end_date'] = CRM_Utils_Date
::customFormat($values['end_date']);
1851 $contactRelationships[$relationshipId]['city'] = $values['city'];
1852 $contactRelationships[$relationshipId]['state'] = $values['state'];
1853 $contactRelationships[$relationshipId]['email'] = $values['email'];
1854 $contactRelationships[$relationshipId]['phone'] = $values['phone'];
1855 $contactRelationships[$relationshipId]['links'] = $values['action'];
1856 $contactRelationships[$relationshipId]['id'] = $values['id'];
1857 $contactRelationships[$relationshipId]['is_active'] = $values['is_active'];
1860 return $contactRelationships;