class CrmCoreUserSyncRelation in CRM Core 8.3
Same name and namespace in other branches
- 8 modules/crm_core_user_sync/src/CrmCoreUserSyncRelation.php \Drupal\crm_core_user_sync\CrmCoreUserSyncRelation
Relation service.
@package Drupal\crm_core_user_sync
Hierarchy
- class \Drupal\crm_core_user_sync\CrmCoreUserSyncRelation implements CrmCoreUserSyncRelationInterface
Expanded class hierarchy of CrmCoreUserSyncRelation
1 string reference to 'CrmCoreUserSyncRelation'
- crm_core_user_sync.services.yml in modules/
crm_core_user_sync/ crm_core_user_sync.services.yml - modules/crm_core_user_sync/crm_core_user_sync.services.yml
1 service uses CrmCoreUserSyncRelation
- crm_core_user_sync.relation in modules/
crm_core_user_sync/ crm_core_user_sync.services.yml - Drupal\crm_core_user_sync\CrmCoreUserSyncRelation
File
- modules/
crm_core_user_sync/ src/ CrmCoreUserSyncRelation.php, line 17
Namespace
Drupal\crm_core_user_syncView source
class CrmCoreUserSyncRelation implements CrmCoreUserSyncRelationInterface {
/**
* Entity type manager.
*
* @var \Drupal\Core\Entity\EntityTypeManagerInterface
*/
protected $entityTypeManager;
/**
* Relation Storage.
*
* @var \Drupal\Core\Entity\EntityStorageInterface
*/
protected $relationStorage;
/**
* Entity Storage.
*
* @var \Drupal\Core\Entity\EntityStorageInterface
*/
protected $individualStorage;
/**
* Relation rules service.
*
* @var \Drupal\crm_core_user_sync\CrmCoreUserSyncRelationRules
*/
protected $rules;
/**
* Logger channel.
*
* @var \Drupal\Core\Logger\LoggerChannelInterface
*/
protected $logger;
/**
* Current user.
*
* @var \Drupal\Core\Session\AccountProxyInterface
*/
protected $currentUser;
/**
* 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, AccountProxyInterface $current_user) {
$this->entityTypeManager = $entity_type_manager;
$this->relationStorage = $entity_type_manager
->getStorage('crm_core_user_sync_relation');
$this->individualStorage = $entity_type_manager
->getStorage('crm_core_individual');
$this->rules = $rules;
$this->logger = $logger;
$this->currentUser = $current_user;
}
/**
* {@inheritdoc}
*/
public function getIndividualIdFromUserId($user_id) {
$individual_id = NULL;
$rids = $this->relationStorage
->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->relationStorage
->load($relation_id);
$individual_id = $relation
->getIndividualId();
}
return $individual_id;
}
/**
* {@inheritdoc}
*/
public function getUserIdFromIndividualId($individual_id) {
$user_id = NULL;
$rids = $this->relationStorage
->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->relationStorage
->load($relation_id);
$user_id = $relation
->getUserId();
}
return $user_id;
}
/**
* {@inheritdoc}
*/
public function getRelationIdFromUserId($user_id) {
$rids = $this->relationStorage
->getQuery()
->condition('user_id', $user_id)
->range(0, 1)
->execute();
if (!empty($rids)) {
return reset($rids);
}
return NULL;
}
/**
* {@inheritdoc}
*/
public function getRelationIdFromIndividualId($individual_id) {
$rids = $this->relationStorage
->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 $individual = NULL) {
// No contact and $account->crm_core_no_auto_sync => no sync.
if (empty($individual) && !empty($account->crm_core_no_auto_sync)) {
return NULL;
}
if (empty($individual)) {
if ($this
->getIndividualIdFromUserId($account
->id())) {
// Account already has related contact.
return NULL;
}
$contact_type = $this->rules
->getContactType($account);
if (!$contact_type) {
// No rules configured on this type.
return NULL;
}
/** @var \Drupal\crm_core_contact\Entity\IndividualType $type */
$type = $this->entityTypeManager
->getStorage('crm_core_individual_type')
->load($contact_type);
$fields = $type
->getPrimaryFields();
// TODO: Inject.
$config = \Drupal::config('crm_core_user_sync.settings');
if ($config
->get('auto_sync_user_relate') && isset($fields['email']) && !empty($fields['email'])) {
$matches = $this->individualStorage
->loadByProperties([
$fields['email'] => $account
->getEmail(),
'type' => $contact_type,
]);
if (count($matches) === 1) {
$individual = reset($matches);
}
}
if (empty($individual)) {
/** @var \Drupal\crm_core_contact\Entity\Individual $individual */
$individual = $this->individualStorage
->create([
'type' => $contact_type,
]);
$individual
->setOwnerId($this->currentUser
->id());
// For now we just add the name.
$individual->name->given = $account
->getAccountName();
if (isset($fields['email']) && !empty($fields['email'])) {
$individual
->set($fields['email'], $account
->getEmail());
}
$individual
->save();
}
}
// Check if contact can be synchronized to a contact.
if (!$this->rules
->valid($account, $individual)) {
return NULL;
}
// Check if crm_core_user_sync relation exists for any of endpoint.
if ($this
->getIndividualIdFromUserId($account
->id()) || $this
->getUserIdFromIndividualId($individual
->id())) {
return NULL;
}
$relation = Relation::create();
$relation
->setUser($account);
$relation
->setIndividual($individual);
$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' => $individual
->id(),
'@rid' => $relation
->id(),
]);
return $individual;
}
}