viscous/espocrm
1
0
Fork 0
mirror of https://github.com/espocrm/espocrm.git synced 2026-06-28 06:56:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

save email address logic

Browse Source
This commit is contained in:
Yuri Kuznetsov
2014-01-13 11:58:36 +02:00
parent 411319adc0
commit 4b8b8cc8a4
1 changed files with 23 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
application/Espo/Core/ORM/Repository.php
View File

@@ -102,75 +102,43 @@ class Repository extends \Espo\ORM\Repository
$email = $entity->get('emailAddress');
$pdo = $this->getPDO();
$emailAddressRepository = $this->getEntityManager()->getRepository('EmailAddress');
if (!empty($email)) {
if ($email != $entity->getFetchedValue('emailAddress')) {
$emailAddressRepository = $this->getEntityManager()->getRepository('EmailAddress');
$emailAddress = $emailAddressRepository->where(array('lower' => strtolower($email)))->findOne();
if ($email != $entity->getFetchedValue('emailAddress')) {
$emailAddressNew = $emailAddressRepository->where(array('lower' => strtolower($email)))->findOne();
$isNewEmailAddress = false;
if (!$emailAddress) {
$emailAddress = $emailAddressRepository->get();
$emailAddress->set('name', $email);
$emailAddressRepository->save($emailAddress);
if (!$emailAddressNew) {
$emailAddressNew = $emailAddressRepository->get();
$emailAddressNew->set('name', $email);
$emailAddressRepository->save($emailAddressNew);
$isNewEmailAddress = true;
}
$emailOld = $entity->getFetchedValue('emailAddress');
if (!empty($emailOld)) {
$emailAddressOld = $emailAddressRepository->where(array('lower' => strtolower($emailOld)))->findOne();
$this->unrelate($entity, 'emailAddresses', $emailAddressOld);
}
$this->relate($entity, 'emailAddresses', $emailAddressNew);
$query = "
UPDATE entity_email_address
SET `primary` = 0
SET `primary` = 1
WHERE
entity_id = ".$pdo->quote($entity->id)." AND
entity_type = ".$pdo->quote($this->entityName)."
entity_type = ".$pdo->quote($this->entityName)." AND
email_address_id = ".$pdo->quote($emailAddressNew->id)."
";
$sth = $pdo->prepare($query);
$sth->execute();
$sth = null;
if (!$isNewEmailAddress) {
$query = "
SELECT * FROM entity_email_address
WHERE
entity_id = ".$pdo->quote($entity->id)." AND
entity_type = ".$pdo->quote($this->entityName)." AND
email_address_id = ".$pdo->quote($emailAddress->id)."
";
$sth = $pdo->prepare($query);
$sth->execute();
}
if (!$isNewEmailAddress && $sth->fetch()) {
$query = "
UPDATE entity_email_address
SET `primary` = 1
WHERE
entity_id = ".$pdo->quote($entity->id)." AND
entity_type = ".$pdo->quote($this->entityName)." AND
email_address_id = ".$pdo->quote($emailAddress->id)."
";
$sth = $pdo->prepare($query);
$sth->execute();
} else {
$query = "
INSERT INTO entity_email_address
(entity_id, entity_type, email_address_id, `primary`)
VALUES
(".$pdo->quote($entity->id).", ".$pdo->quote($this->entityName).", ".$pdo->quote($emailAddress->id).", 1)
";
$sth = $pdo->prepare($query);
$sth->execute();
}
}
} else {
$fetched = $entity->getFetchedValue('emailAddress');
if (!empty($fetched)) {
$query = "
DELETE FROM entity_email_address
WHERE
entity_id = ".$pdo->quote($entity->id)." AND
entity_type = ".$pdo->quote($this->entityName)." AND
primary = 1
";
$sth = $pdo->prepare($query);
$sth->execute();
$emailOld = $entity->getFetchedValue('emailAddress');
if (!empty($emailOld)) {
$emailAddressOld = $emailAddressRepository->where(array('lower' => strtolower($emailOld)))->findOne();
$this->unrelate($entity, 'emailAddresses', $emailAddressOld);
}
}
}