CrmCoreUserSyncRelation.php in CRM Core 8

Namespace

Drupal\crm_core_user_sync

File

modules/crm_core_user_sync/src/CrmCoreUserSyncRelation.php

<?php

namespace Drupal\crm_core_user_sync;

use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Logger\LoggerChannelInterface;
use Drupal\crm_core_contact\Entity\Individual;
use Drupal\crm_core_contact\IndividualInterface;
use Drupal\crm_core_user_sync\Entity\Relation;
use Drupal\user\UserInterface;

/**
 * Relation service.
 *
 * @package Drupal\crm_core_user_sync
 */
class CrmCoreUserSyncRelation implements CrmCoreUserSyncRelationInterface {

  /**
   * Relation storage.
   *
   * @var \Drupal\Core\Entity\EntityStorageInterface
   */
  protected $storage;

  /**
   * Relation rules service.
   *
   * @var \Drupal\crm_core_user_sync\CrmCoreUserSyncRelationRules
   */
  protected $rules;

  /**
   * Logger channel.
   *
   * @var \Drupal\Core\Logger\LoggerChannelInterface
   */
  protected $logger;

  /**
   * Constructs a CrmCoreUserSyncRelation object.
   *
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
   *   The entity type manager.
   * @param \Drupal\crm_core_user_sync\CrmCoreUserSyncRelationRules $rules
   *   Relation rules service.
   * @param \Drupal\Core\Logger\LoggerChannelInterface $logger
   *   Logger channel.
   */
  public function __construct(EntityTypeManagerInterface $entity_type_manager, CrmCoreUserSyncRelationRules $rules, LoggerChannelInterface $logger) {
    $this->storage = $entity_type_manager
      ->getStorage('crm_core_user_sync_relation');
    $this->rules = $rules;
    $this->logger = $logger;
  }

  /**
   * {@inheritdoc}
   */
  public function getUserIndividualId($user_id) {
    $individual_id = NULL;
    $rids = $this->storage
      ->getQuery()
      ->condition('user_id', $user_id)
      ->range(0, 1)
      ->execute();
    if (!empty($rids)) {
      $relation_id = reset($rids);

      /* @var $relation \Drupal\crm_core_user_sync\Entity\Relation */
      $relation = $this->storage
        ->load($relation_id);
      $individual_id = $relation
        ->getIndividualId();
    }
    return $individual_id;
  }

  /**
   * {@inheritdoc}
   */
  public function getIndividualUserId($individual_id) {
    $user_id = NULL;
    $rids = $this->storage
      ->getQuery()
      ->condition('individual_id', $individual_id)
      ->range(0, 1)
      ->execute();
    if (!empty($rids)) {
      $relation_id = reset($rids);

      /* @var $relation \Drupal\crm_core_user_sync\Entity\Relation */
      $relation = $this->storage
        ->load($relation_id);
      $user_id = $relation
        ->getIndividualId();
    }
    return $user_id;
  }

  /**
   * {@inheritdoc}
   */
  public function getUserRelationId($user_id) {
    $rids = $this->storage
      ->getQuery()
      ->condition('user_id', $user_id)
      ->range(0, 1)
      ->execute();
    if (!empty($rids)) {
      return reset($rids);
    }
    return NULL;
  }

  /**
   * {@inheritdoc}
   */
  public function getIndividualRelationId($individual_id) {
    $rids = $this->storage
      ->getQuery()
      ->condition('individual_id', $individual_id)
      ->range(0, 1)
      ->execute();
    if (!empty($rids)) {
      return reset($rids);
    }
    return NULL;
  }

  /**
   * {@inheritdoc}
   */
  public function relate(UserInterface $account, IndividualInterface $contact = NULL) {

    // No contact and $account->crm_core_no_auto_sync => no sync.
    if (empty($contact) && !empty($account->crm_core_no_auto_sync)) {
      return NULL;
    }
    if (empty($contact)) {

      // Account already have related contact.
      if ($this
        ->getUserIndividualId($account
        ->id())) {
        return NULL;
      }

      // Get corresponding contact type.
      $contact_type = $this->rules
        ->getContactType($account);

      // No rules configured.
      if (!$contact_type) {
        return NULL;
      }

      // Create the contact.
      $contact = Individual::create([
        'type' => $contact_type,
      ]);
      $contact
        ->setOwner($account);

      // For now we just add the name.
      $contact->name->given = $account
        ->getAccountName();
      $contact
        ->save();
    }

    // Check if contact can be synchronized to a contact.
    if (!$this->rules
      ->valid($account, $contact)) {
      return NULL;
    }

    // Check if crm_core_user_sync relation exists for any of endpoint.
    if ($this
      ->getUserIndividualId($account
      ->id()) || $this
      ->getIndividualUserId($contact
      ->id())) {
      return NULL;
    }
    $relation = Relation::create();
    $relation
      ->setUser($account);
    $relation
      ->setIndividual($contact);
    $relation
      ->save();
    $this->logger
      ->notice('User @user @uid has been synchronized to the contact @contact_id, relation @rid has been created.', [
      '@user' => $account
        ->getDisplayName(),
      '@uid' => $account
        ->id(),
      '@contact_id' => $contact
        ->id(),
      '@rid' => $relation
        ->id(),
    ]);
    return $contact;
  }

}

Classes

Name	Description
CrmCoreUserSyncRelation	Relation service.