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

email notifications

Browse Source
This commit is contained in:
yuri
2015-04-09 11:56:47 +03:00
parent 761d85a112
commit bab7f3e9fc
4 changed files with 62 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
application/Espo/Core/Hooks/Base.php
View File

@@ -52,6 +52,11 @@ abstract class Base implements Injectable
return $this->dependencies;
}
protected function addDependency($name)
{
$this->dependencies[] = $name;
}
protected function getInjection($name)
{
return $this->injections[$name];

5
application/Espo/Core/Notificators/Base.php
View File

@@ -46,6 +46,11 @@ class Base implements Injectable
{
}
protected function addDependency($name)
{
$this->dependencies[] = $name;
}
public function getDependencyList()
{
return $this->dependencies;

5
application/Espo/Core/Services/Base.php
View File

@@ -53,6 +53,11 @@ abstract class Base implements Injectable
return $this->injections[$name];
}
protected function addDependency($name)
{
$this->dependencies[] = $name;
}
public function getDependencyList()
{
return $this->dependencies;

63
application/Espo/Notificators/Email.php
View File

@@ -26,29 +26,41 @@ use \Espo\ORM\Entity;
class Email extends \Espo\Core\Notificators\Base
{
protected function init()
{
$this->addDependency('serviceFactory');
}
private $streamService = null;
protected function getStreamService()
{
if (empty($this->streamService)) {
$this->streamService = $this->getInjection('serviceFactory')->create('Stream');
}
return $this->streamService;
}
public function process(Entity $entity)
{
if (!$entity->isNew()) {
if ($entity->get('status') != 'Archived') {
return;
}
$previousUserIdList = $entity->getFetched('usersIds');
if (!is_array($previousUserIdList)) {
$previousUserIdList = [];
}
$emailUserIdList = $entity->get('usersIds');
if (is_null($emailUserIdList) || !is_array($emailUserIdList)) {
return;
}
$userIdList = [];
if ($entity->has('assignedUserId') && $entity->get('assignedUserId')) {
$assignedUserId = $entity->get('assignedUserId');
if ($assignedUserId != $this->getUser()->id && $entity->isFieldChanged('assignedUserId')) {
$userIdList[] = $assignedUserId;
}
}
$emailUserIdList = $entity->get('usersIds');
if (is_null($emailUserIdList)) {
$entity->loadLinkMultipleField('from');
$emailUserIdList = $entity->get('usersIds');
}
if (!is_array($emailUserIdList)) {
$emailUserIdList = [];
}
foreach ($emailUserIdList as $userId) {
if (!in_array($userId, $userIdList)) {
if (!in_array($userId, $userIdList) && !in_array() && $userId != $this->getUser()->id) {
$userIdList[] = $userId;
}
}
@@ -68,7 +80,26 @@ class Email extends \Espo\Core\Notificators\Base
}
}
$parent = null;
if ($entity->get('parentId') && $entity->get('parentType')) {
$parent = $this->getEntityManager()->getEntity($entity->get('parentType'), $entity->get('parentId'));
}
$account = null;
if ($entity->get('accountId')) {
$account = $this->getEntityManager()->getEntity('Account', $entity->get('accountId'));
}
foreach ($userIdList as $userId) {
if ($parent) {
if ($this->getStreamService()->checkIsFollowed($parent, $userId)) {
continue;
}
}
if ($account) {
if ($this->getStreamService()->checkIsFollowed($account, $userId)) {
continue;
}
}
$notification = $this->getEntityManager()->getEntity('Notification');
$notification->set(array(
'type' => 'EmailReceived',