| Server IP : 37.220.80.31 / Your IP : 3.149.229.172 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/modules/sender/lib/ |
Upload File : |
<?php
/**
* Bitrix Framework
* @package bitrix
* @subpackage sender
* @copyright 2001-2012 Bitrix
*/
namespace Bitrix\Sender;
use Bitrix\Main\Entity;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM\Query\Query;
use Bitrix\Main\Type\DateTime;
Loc::loadMessages(__FILE__);
/**
* Class MailingTriggerTable
*
* DO NOT WRITE ANYTHING BELOW THIS
*
* <<< ORMENTITYANNOTATION
* @method static EO_MailingTrigger_Query query()
* @method static EO_MailingTrigger_Result getByPrimary($primary, array $parameters = array())
* @method static EO_MailingTrigger_Result getById($id)
* @method static EO_MailingTrigger_Result getList(array $parameters = array())
* @method static EO_MailingTrigger_Entity getEntity()
* @method static \Bitrix\Sender\EO_MailingTrigger createObject($setDefaultValues = true)
* @method static \Bitrix\Sender\EO_MailingTrigger_Collection createCollection()
* @method static \Bitrix\Sender\EO_MailingTrigger wakeUpObject($row)
* @method static \Bitrix\Sender\EO_MailingTrigger_Collection wakeUpCollection($rows)
*/
class MailingTriggerTable extends Entity\DataManager
{
/**
* Get table name.
*
* @return string
*/
public static function getTableName()
{
return 'b_sender_mailing_trigger';
}
/**
* Get map.
*
* @return array
*/
public static function getMap()
{
return array(
'MAILING_CHAIN_ID' => array(
'data_type' => 'integer',
'primary' => true,
'required' => true,
),
'NAME' => array(
'data_type' => 'string',
),
'EVENT' => array(
'data_type' => 'string',
'primary' => true,
'required' => true,
),
'IS_TYPE_START' => array(
'data_type' => 'boolean',
'values' => array(false, true),
'primary' => true,
'required' => true,
),
'ENDPOINT' => array(
'data_type' => 'text',
'serialized' => true,
'required' => true,
),
'MAILING_CHAIN' => array(
'data_type' => 'Bitrix\Sender\MailingChainTable',
'reference' => array('=this.MAILING_CHAIN_ID' => 'ref.ID'),
),
);
}
/**
* Handler of "On after add" event.
*
* @param Entity\Event $event Event.
* @return Entity\EventResult
*/
public static function onAfterAdd(Entity\Event $event)
{
$result = new Entity\EventResult;
$data = $event->getParameters();
if(is_string($data['fields']['ENDPOINT']))
{
$data['fields']['ENDPOINT'] = unserialize($data['fields']['ENDPOINT'], ['allowed_classes' => false]);
}
if(!is_array($data['fields']['ENDPOINT']))
{
$data['fields']['ENDPOINT'] = null;
}
static::actualizeHandlers($data['primary']['MAILING_CHAIN_ID'], $data['fields']['ENDPOINT'], null);
return $result;
}
/**
* Handler of "On update" event.
*
* @param Entity\Event $event Event.
* @return Entity\EventResult
*/
public static function onUpdate(Entity\Event $event)
{
$result = new Entity\EventResult;
$data = $event->getParameters();
$itemDb = static::getByPrimary($data['primary']);
$item = $itemDb->fetch();
if(!is_array($data['fields']['ENDPOINT']))
{
$data['fields']['ENDPOINT'] = null;
}
if(!$item || !is_array($item['ENDPOINT']))
{
$item['ENDPOINT'] = null;
}
static::actualizeHandlers($data['primary']['MAILING_CHAIN_ID'], $data['fields']['ENDPOINT'], $item['ENDPOINT']);
return $result;
}
/**
* Handler of "On delete" event.
*
* @param Entity\Event $event Event.
* @return Entity\EventResult
*/
public static function onDelete(Entity\Event $event)
{
$result = new Entity\EventResult;
$data = $event->getParameters();
$itemDb = static::getByPrimary($data['primary']);
while($item = $itemDb->fetch())
{
if(!is_array($item['ENDPOINT']))
{
$item['ENDPOINT'] = null;
}
static::actualizeHandlers($item['MAILING_CHAIN_ID'], null, $item['ENDPOINT']);
}
return $result;
}
/**
* Actualize handlers.
*
* @param int $chainId Letter ID.
* @param array|null $fieldsNew New fields.
* @param array|null $fieldsOld Old fields.
*/
public static function actualizeHandlers($chainId, array $fieldsNew = null, array $fieldsOld = null)
{
$settingsNew = null;
$settingsOld = null;
if($fieldsNew)
$settingsNew = new Trigger\Settings($fieldsNew);
if($fieldsOld)
$settingsOld = new Trigger\Settings($fieldsOld);
// if old item was closed trigger
if($settingsOld && $settingsOld->isClosedTrigger())
{
// delete agent
$agentName = Trigger\Manager::getClosedEventAgentName(
$settingsOld->getEventModuleId(),
$settingsOld->getEventType(),
$chainId
);
$agent = new \CAgent;
$agentListDb = $agent->GetList(array(), array('MODULE_ID' => 'sender', 'NAME' => $agentName));
while($agentItem = $agentListDb->Fetch())
$agent->Delete($agentItem['ID']);
}
// if new item is closed trigger
if($settingsNew && $settingsNew->isClosedTrigger())
{
// check active state of mailing
$chainDb = MailingChainTable::getList(array(
'select' => array('ID'),
'filter' => array('=ID' => $chainId, '=MAILING.ACTIVE' => 'Y')
));
if(!$chainDb->fetch())
return;
// add new agent
$agentName = Trigger\Manager::getClosedEventAgentName(
$settingsNew->getEventModuleId(),
$settingsNew->getEventType(),
$chainId
);
// set date of next exec
$agentTime = $settingsNew->getClosedTriggerTime();
$agentInterval = $settingsNew->getClosedTriggerInterval();
if($agentInterval <= 0) $agentInterval = 1440;
$agentTimeArray = explode(":", $agentTime);
$agentDate = new DateTime;
$agentDate->setTime((int)$agentTimeArray[0], (int)$agentTimeArray[1]);
// set next exec on next day if exec was today
if($agentDate->getTimestamp() < time())
$agentDate->add("1 days");
// add agent
$agent = new \CAgent;
$agent->AddAgent($agentName, 'sender', 'N', $agentInterval*60, '', 'Y', $agentDate->toString());
return;
}
// actualize deleted/changed event
if($settingsOld && !$settingsOld->isClosedTrigger() && $settingsOld->getFullEventType())
{
// if delete operation(no the NEW)
// or change operation(the NEW is not equal to the OLD)
if(!$settingsNew || $settingsOld->getFullEventType() != $settingsNew->getFullEventType())
{
Trigger\Manager::actualizeHandler(array(
'MODULE_ID' => $settingsOld->getEventModuleId(),
'EVENT_TYPE' => $settingsOld->getEventType(),
'CALLED_BEFORE_CHANGE' => true
));
}
}
// actualize new event
if($settingsNew && $settingsNew->getFullEventType())
{
$calledBeforeChange = ($fieldsOld ? false : true);
Trigger\Manager::actualizeHandler(array(
'MODULE_ID' => $settingsNew->getEventModuleId(),
'EVENT_TYPE' => $settingsNew->getEventType(),
'CALLED_BEFORE_CHANGE' => $calledBeforeChange
));
}
}
/**
* @param array $filter
* @return \Bitrix\Main\DB\Result
* @throws \Bitrix\Main\ArgumentException
* @throws \Bitrix\Main\DB\SqlQueryException
* @throws \Bitrix\Main\SystemException
*/
public static function deleteList(array $filter)
{
$entity = static::getEntity();
$connection = $entity->getConnection();
\CTimeZone::disable();
$sql = sprintf(
'DELETE FROM %s WHERE %s',
$connection->getSqlHelper()->quote($entity->getDbTableName()),
Query::buildFilterSql($entity, $filter)
);
$res = $connection->query($sql);
\CTimeZone::enable();
return $res;
}
}