| Server IP : 37.220.80.31 / Your IP : 18.118.142.245 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/sale/general/ |
Upload File : |
<?
use Bitrix\Sale\Internals\StatusTable,
Bitrix\Sale\Internals\StatusLangTable,
Bitrix\Sale\Internals\StatusGroupTaskTable,
Bitrix\Sale\Internals\OrderTable,
Bitrix\Sale\Internals\OrderArchiveTable,
Bitrix\Sale\Compatible,
Bitrix\Main\TaskTable,
Bitrix\Main\OperationTable,
Bitrix\Main\TaskOperationTable,
Bitrix\Main\Application,
Bitrix\Main\SystemException,
Bitrix\Main\Entity\Result,
Bitrix\Main\Localization\LanguageTable,
Bitrix\Main\Localization\Loc;
Loc::loadMessages(__FILE__);
/** @deprecated */
class CSaleStatus
{
public static function GetByID($statusId, $languageId = LANGUAGE_ID, $type = null)
{
$allowTypes = array(
\Bitrix\Sale\OrderStatus::TYPE,
\Bitrix\Sale\DeliveryStatus::TYPE,
);
$filter = array(
'select' => array(
'ID',
'SORT',
'NOTIFY',
'TYPE',
'LID' => 'Bitrix\Sale\Internals\StatusLangTable:STATUS.LID',
'NAME' => 'Bitrix\Sale\Internals\StatusLangTable:STATUS.NAME',
'DESCRIPTION' => 'Bitrix\Sale\Internals\StatusLangTable:STATUS.DESCRIPTION'
),
'filter' => array(
'=ID' => $statusId,
'=Bitrix\Sale\Internals\StatusLangTable:STATUS.LID' => $languageId,
),
'limit' => 1,
);
if ($type !== null && in_array($type, $allowTypes))
{
$filter['filter']['=TYPE'] = $type;
}
return StatusTable::getList($filter)->fetch();
}
public static function GetLangByID($statusId, $languageId = LANGUAGE_ID)
{
return StatusLangTable::getList(array(
'select' => array('*'),
'filter' => array('=STATUS_ID' => $statusId, '=LID' => $languageId),
'limit' => 1,
))->fetch();
}
/**
* @param array $arOrder
* @param array $arFilter
* @param bool|array $arGroupBy
* @param bool|array $arNavStartParams
* @param array $arSelectFields
* @return CDBResult|int
*/
public static function GetList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
{
if (!is_array($arOrder) && !is_array($arFilter))
{
$arOrder = strval($arOrder);
$arFilter = strval($arFilter);
if ('' != $arOrder && '' != $arFilter)
$arOrder = array($arOrder => $arFilter);
else
$arOrder = array();
$arFilter = array();
$arFilter["LID"] = LANGUAGE_ID;
if ($arGroupBy)
{
$arGroupBy = strval($arGroupBy);
if ('' != $arGroupBy)
$arFilter["LID"] = $arGroupBy;
}
$arGroupBy = false;
$arSelectFields = array("ID", "SORT", "LID", "NAME", "DESCRIPTION");
}
if (! in_array('TYPE', $arSelectFields))
$arFilter['TYPE'] = 'O';
$query = new Compatible\OrderQuery(StatusTable::getEntity());
$query->addAliases(array(
'LID' => 'Bitrix\Sale\Internals\StatusLangTable:STATUS.LID',
'NAME' => 'Bitrix\Sale\Internals\StatusLangTable:STATUS.NAME',
'DESCRIPTION' => 'Bitrix\Sale\Internals\StatusLangTable:STATUS.DESCRIPTION',
'GROUP_ID' => 'Bitrix\Sale\Internals\StatusGroupTaskTable:STATUS.GROUP_ID',
));
$taskIdName = 'Bitrix\Sale\Internals\StatusGroupTaskTable:STATUS.TASK_ID';
CSaleStatusAdapter::addAliasesTo($query, $taskIdName);
$query->prepare($arOrder, $arFilter, $arGroupBy, $arSelectFields);
if ($query->counted())
{
return $query->exec()->getSelectedRowsCount();
}
else
{
$result = new Compatible\CDBResult();
CSaleStatusAdapter::adaptResult($result, $query, $taskIdName);
return $query->compatibleExec($result, $arNavStartParams);
}
}
/*
* For modern api see: Bitrix\Sale\OrderStatus and Bitrix\Sale\DeliveryStatus
*/
public static function GetPermissionsList($arOrder = array(), $arFilter = array(), $arGroupBy = false, $arNavStartParams = false, $arSelectFields = array())
{
$query = new Compatible\OrderQuery(StatusGroupTaskTable::getEntity());
$taskIdName = 'TASK_ID';
CSaleStatusAdapter::addAliasesTo($query, $taskIdName);
$query->prepare($arOrder, $arFilter, $arGroupBy, $arSelectFields);
if ($query->counted())
{
return $query->exec()->getSelectedRowsCount();
}
else
{
$result = new Compatible\CDBResult();
return $query->compatibleExec($result, $arNavStartParams);
}
}
private static $statusFields, $langFields, $taskFields;
public static function CheckFields($ACTION, &$arFields, $statusId = '')
{
if ((is_set($arFields, "SORT") || $ACTION=="ADD") && intval($arFields["SORT"])<= 0)
$arFields["SORT"] = 100;
if ((is_set($arFields, "ID") || $ACTION=="ADD") && $arFields["ID"] == '')
return false;
if (is_set($arFields, "ID") && $statusId <> '' && $statusId!=$arFields["ID"])
return false;
if((is_set($arFields, "ID") && !preg_match("#[A-Za-z]#i", $arFields["ID"])) || ($statusId <> '' && !preg_match("#[A-Za-z]#i", $statusId)))
{
$GLOBALS["APPLICATION"]->ThrowException(Loc::getMessage("SKGS_ID_NOT_SYMBOL"), "ERROR_ID_NOT_SYMBOL");
return false;
}
$result = new Result;
if (! self::$statusFields)
{
self::$statusFields = StatusTable::getEntity()->getScalarFields();
self::$langFields = StatusLangTable::getEntity()->getScalarFields();
self::$taskFields = StatusGroupTaskTable::getEntity()->getScalarFields();
}
switch ($ACTION)
{
case 'ADD':
$statusId = $arFields['ID'];
StatusTable::checkFields($result, null, array_intersect_key($arFields, self::$statusFields));
break;
case 'UPDATE':
StatusTable::checkFields($result, $statusId, array_intersect_key(array_diff_key($arFields, array('ID'=>1)), self::$statusFields));
break;
default: throw new SystemException('Invalid action: '.$ACTION, 0, __FILE__, __LINE__);
}
if (isset($arFields['LANG']) && is_array($arFields['LANG']) && ! empty($arFields['LANG']))
{
$availableLanguages = array_map('current', LanguageTable::getList(array(
'select' => array('LID'),
'filter' => array('=ACTIVE' => 'Y')
))->fetchAll());
foreach ($arFields['LANG'] as $data)
{
if ($data['NAME'] && in_array($data['LID'], $availableLanguages))
StatusLangTable::checkFields($result, null, array('STATUS_ID' => $statusId) + array_intersect_key($data, self::$langFields));
else
return false;
}
}
return $result->isSuccess();
}
private static function addLanguagesBy($statusId, array $rows)
{
foreach ($rows as $row)
StatusLangTable::add(array('STATUS_ID' => $statusId) + array_intersect_key($row, self::$langFields));
}
private static function addTasksBy($statusId, array $rows)
{
foreach ($rows as $row)
StatusGroupTaskTable::add(array(
'STATUS_ID' => $statusId,
'TASK_ID' => CSaleStatusAdapter::getTaskId($row, CSaleStatusAdapter::permissions(),
CSaleStatusAdapter::getTasksOperations()),
) + array_intersect_key($row, self::$taskFields));
}
public static function Add($arFields)
{
if (! self::CheckFields('ADD', $arFields))
return false;
$statusId = $arFields['ID'];
foreach (GetModuleEvents("sale", "OnBeforeStatusAdd", true) as $arEvent)
if (ExecuteModuleEventEx($arEvent, array($statusId, &$arFields))===false)
return false;
StatusTable::add(array_intersect_key($arFields, self::$statusFields));
if (isset($arFields['LANG']) && is_array($arFields['LANG']) && ! empty($arFields['LANG']))
self::addLanguagesBy($statusId, $arFields['LANG']);
if (isset($arFields['PERMS']) && is_array($arFields['PERMS']) && ! empty($arFields['PERMS']))
self::addTasksBy($statusId, $arFields['PERMS']);
if (\Bitrix\Main\Config\Option::get('sale', 'expiration_processing_events', 'N') === 'N')
{
foreach (GetModuleEvents("sale", "OnStatusAdd", true) as $arEvent)
ExecuteModuleEventEx($arEvent, array($statusId, $arFields));
}
return $statusId;
}
public static function Update($statusId, $arFields)
{
if (! self::CheckFields('UPDATE', $arFields, $statusId))
return false;
foreach (GetModuleEvents("sale", "OnBeforeStatusUpdate", true) as $arEvent)
if (ExecuteModuleEventEx($arEvent, array($statusId, &$arFields))===false)
return false;
StatusTable::update($statusId, array_intersect_key($arFields, self::$statusFields));
if (isset($arFields['LANG']) && is_array($arFields['LANG']) && ! empty($arFields['LANG']))
{
StatusLangTable::deleteByStatus($statusId);
self::addLanguagesBy($statusId, $arFields['LANG']);
}
if (isset($arFields['PERMS']) && is_array($arFields['PERMS']) && ! empty($arFields['PERMS']))
{
StatusGroupTaskTable::deleteByStatus($statusId);
self::addTasksBy($statusId, $arFields['PERMS']);
}
if (\Bitrix\Main\Config\Option::get('sale', 'expiration_processing_events', 'N') === 'N')
{
foreach (GetModuleEvents("sale", "OnStatusUpdate", true) as $arEvent)
ExecuteModuleEventEx($arEvent, array($statusId, $arFields));
}
return $statusId;
}
public static function Delete($statusId)
{
if (! $statusId)
return false;
global $DB, $APPLICATION;
$statusId = $DB->ForSql($statusId, 2);
if (OrderTable::getList(array(
'filter' => array('=STATUS_ID' => $statusId),
'limit' => 1
))->fetch())
{
$APPLICATION->ThrowException(Loc::getMessage("SKGS_ERROR_DELETE"), "ERROR_DELETE_STATUS_TO_ORDER");
return false;
}
if (OrderArchiveTable::getList(array(
'filter' => array('=STATUS_ID' => $statusId),
'limit' => 1
))->fetch())
{
$APPLICATION->ThrowException(Loc::getMessage("SKGS_ERROR_ARCHIVED_DELETE"), "ERROR_DELETE_STATUS_TO_ARCHIVED_ORDER");
return false;
}
foreach (GetModuleEvents("sale", "OnBeforeStatusDelete", true) as $arEvent)
if (ExecuteModuleEventEx($arEvent, array($statusId))===false)
return false;
foreach (GetModuleEvents("sale", "OnStatusDelete", true) as $arEvent)
ExecuteModuleEventEx($arEvent, array($statusId));
StatusLangTable::deleteByStatus($statusId);
StatusGroupTaskTable::deleteByStatus($statusId);
return StatusTable::delete($statusId)->isSuccess();
}
public static function CreateMailTemplate($ID)
{
$ID = trim($ID);
if ($ID == '')
return false;
$eventType = new CEventType();
$eventMessage = new CEventMessage();
if ( $statusData = self::GetByID($ID, LANGUAGE_ID))
{
$eventType->Delete("SALE_STATUS_CHANGED_".$ID);
}
$dbSiteList = CSite::GetList();
while ($arSiteList = $dbSiteList->Fetch())
{
\Bitrix\Main\Localization\Loc::loadLanguageFile($_SERVER["DOCUMENT_ROOT"]."/bitrix/modules/sale/general/status.php", $arSiteList["LANGUAGE_ID"]);
$arStatusLang = self::GetLangByID($ID, $arSiteList["LANGUAGE_ID"]);
$dbEventType = $eventType->GetList(
array(
"EVENT_NAME" => "SALE_STATUS_CHANGED_".$ID,
"LID" => $arSiteList["LANGUAGE_ID"]
)
);
if (!($arEventType = $dbEventType->Fetch()))
{
$str = "";
$str .= "#ORDER_ID# - ".Loc::getMessage("SKGS_ORDER_ID", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#ORDER_DATE# - ".Loc::getMessage("SKGS_ORDER_DATE", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#ORDER_STATUS# - ".Loc::getMessage("SKGS_ORDER_STATUS", null, $arSiteList["LANGUAGE_ID"])."\n";
$eventTypeName = Loc::getMessage("SKGS_CHANGING_STATUS_TO", null, $arSiteList["LANGUAGE_ID"])." \"".$arStatusLang["NAME"]."\"";
if ($statusData['TYPE'] == \Bitrix\Sale\DeliveryStatus::TYPE)
{
$eventTypeName = Loc::getMessage("SKGS_CHANGING_SHIPMENT_STATUS_TO", null, $arSiteList["LANGUAGE_ID"])." \"".$arStatusLang["NAME"]."\"";
$str .= "#SHIPMENT_ID# - ".\Bitrix\Main\Localization\Loc::getMessage("SKGS_SHIPMENT_ID", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#SHIPMENT_DATE# - ".\Bitrix\Main\Localization\Loc::getMessage("SKGS_SHIPMENT_DATE", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#SHIPMENT_STATUS# - ".\Bitrix\Main\Localization\Loc::getMessage("SKGS_SHIPMENT_STATUS", null, $arSiteList["LANGUAGE_ID"])."\n";
}
$str .= "#EMAIL# - ".Loc::getMessage("SKGS_ORDER_EMAIL", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#ORDER_DESCRIPTION# - ".Loc::getMessage("SKGS_STATUS_DESCR", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#TEXT# - ".Loc::getMessage("SKGS_STATUS_TEXT", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#SALE_EMAIL# - ".Loc::getMessage("SKGS_SALE_EMAIL", null, $arSiteList["LANGUAGE_ID"])."\n";
$str .= "#ORDER_PUBLIC_URL# - ".Loc::getMessage("SKGS_ORDER_PUBLIC_LINK", null, $arSiteList["LANGUAGE_ID"])."\n";
$eventTypeID = $eventType->Add(
array(
"LID" => $arSiteList["LANGUAGE_ID"],
"EVENT_NAME" => "SALE_STATUS_CHANGED_".$ID,
"NAME" => $eventTypeName,
"DESCRIPTION" => $str
)
);
}
$dbEventMessage = $eventMessage->GetList(
'',
'',
array(
"EVENT_NAME" => "SALE_STATUS_CHANGED_".$ID,
"SITE_ID" => $arSiteList["LID"]
)
);
if (!($arEventMessage = $dbEventMessage->Fetch()))
{
if ($statusData['TYPE'] == \Bitrix\Sale\DeliveryStatus::TYPE)
{
$subject = Loc::getMessage("SKGS_SHIPMENT_STATUS_MAIL_SUBJ", null, $arSiteList["LANGUAGE_ID"]);
$message = Loc::getMessage("SKGS_SHIPMENT_STATUS_MAIL_BODY1", null, $arSiteList["LANGUAGE_ID"]);
$message .= "------------------------------------------\n\n";
$message .= Loc::getMessage("SKGS_SHIPMENT_STATUS_MAIL_BODY2", null, $arSiteList["LANGUAGE_ID"]);
$message .= Loc::getMessage("SKGS_SHIPMENT_STATUS_MAIL_BODY3", null, $arSiteList["LANGUAGE_ID"]);
$message .= "#SHIPMENT_STATUS#\n";
}
else
{
$subject = Loc::getMessage("SKGS_STATUS_MAIL_SUBJ", null, $arSiteList["LANGUAGE_ID"]);
$message = Loc::getMessage("SKGS_STATUS_MAIL_BODY1", null, $arSiteList["LANGUAGE_ID"]);
$message .= "------------------------------------------\n\n";
$message .= Loc::getMessage("SKGS_STATUS_MAIL_BODY2", null, $arSiteList["LANGUAGE_ID"]);
$message .= Loc::getMessage("SKGS_STATUS_MAIL_BODY3", null, $arSiteList["LANGUAGE_ID"]);
$message .= "#ORDER_STATUS#\n";
$message .= "#ORDER_DESCRIPTION#\n";
}
$message .= "#TEXT#\n\n";
$message .= "#SITE_NAME#\n";
$arFields = Array(
"ACTIVE" => "Y",
"EVENT_NAME" => "SALE_STATUS_CHANGED_".$ID,
"LID" => $arSiteList["LID"],
"EMAIL_FROM" => "#SALE_EMAIL#",
"EMAIL_TO" => "#EMAIL#",
"SUBJECT" => $subject,
"MESSAGE" => $message,
"BODY_TYPE" => "text"
);
$eventMessageID = $eventMessage->Add($arFields);
}
}
return true;
}
}
/** @deprecated */
final class CSaleStatusAdapter implements Compatible\FetchAdapter
{
// M I G R A T I O N ///////////////////////////////////////////////////////////////////////////////////////////////
public static function perms2opers()
{
static $lazy = array(
'PERM_VIEW' => 'sale_status_view',
'PERM_CANCEL' => 'sale_status_cancel',
'PERM_MARK' => 'sale_status_mark',
'PERM_DELIVERY' => 'sale_status_delivery',
'PERM_DEDUCTION' => 'sale_status_deduction',
'PERM_PAYMENT' => 'sale_status_payment',
'PERM_STATUS' => 'sale_status_to',
'PERM_UPDATE' => 'sale_status_update',
'PERM_DELETE' => 'sale_status_delete',
'PERM_STATUS_FROM' => 'sale_status_from',
);
return $lazy;
}
private static function field($name, array $field)
{
$field['NAME'] = $name;
$field['MODULE_ID'] = 'sale';
$field['BINDING'] = 'status';
return $field;
}
public static function migrate()
{
$errors = '';
// install all permissions as operations
$permissions = array(/* permission name => operation id */);
foreach (self::perms2opers() as $perm => $oper)
{
$result = OperationTable::add(self::field($oper, array()));
if ($result->isSuccess())
$permissions[$perm] = $result->getId();
else
$errors .= 'cannot add operation: '.$oper."\n".implode("\n", $result->getErrorMessages())."\n\n";
}
asort($permissions);
// install system tasks
$tasks = array(/* task id => array of operations ids */);
try
{
$tasks[self::addTask(self::field('sale_status_none', array('SYS' => 'Y', 'LETTER' => 'D')), array())] = array();
}
catch (SystemException $e)
{
$errors .= $e->getMessage();
}
try
{
$tasks[self::addTask(self::field('sale_status_all', array('SYS' => 'Y', 'LETTER' => 'X')), $permissions)] = array_values($permissions);
}
catch (SystemException $e)
{
$errors .= $e->getMessage();
}
// migrate permissions to tasks
$result = Application::getConnection()->query('SELECT * FROM b_sale_status2group');
while ($row = $result->fetch())
{
try
{
$taskId = self::getTaskId($row, $permissions, $tasks);
$res = StatusGroupTaskTable::add(array(
'STATUS_ID' => $row['STATUS_ID'],
'GROUP_ID' => $row['GROUP_ID'],
'TASK_ID' => $taskId,
));
if (! $res->isSuccess())
$errors .= 'cannot add status: '.$row['STATUS_ID'].', group: '.$row['GROUP_ID'].', task: '.$taskId."\n".implode("\n", $res->getErrorMessages())."\n\n";
}
catch (SystemException $e)
{
$errors .= $e->getMessage();
}
}
if ($errors)
throw new SystemException($errors, 0, __FILE__, __LINE__);
}
public static function getTaskId(array $data, array $permissions, array &$tasks)
{
$permissions = array_values(array_intersect_key($permissions, array_intersect($data, array('Y'))));
if (! $taskId = array_search($permissions, $tasks))
{
$taskId = self::addTask(self::field('sale_status_custom'.(count($tasks) + 1), array('SYS' => 'N')), $permissions);
$tasks[$taskId] = $permissions;
}
return $taskId;
}
public static function addTask(array $field, array $permissions)
{
// add task
$result = TaskTable::add($field);
if (! $result->isSuccess())
throw new SystemException('cannot add task: '.$field['NAME']."\n".implode("\n", $result->getErrorMessages())."\n\n", 0, __FILE__, __LINE__);
// add task-operations
$errors = '';
$taskId = $result->getId();
foreach ($permissions as $operId)
{
$result = TaskOperationTable::add(array(
'TASK_ID' => $taskId,
'OPERATION_ID' => $operId,
));
if (! $result->isSuccess())
$errors .= 'cannot add task: '.$taskId.', operation: '.$operId."\n".implode("\n", $result->getErrorMessages())."\n\n";
}
if ($errors)
throw new SystemException($errors, 0, __FILE__, __LINE__);
return $taskId;
}
// A D A P T E R ///////////////////////////////////////////////////////////////////////////////////////////////////
public static function permissions()
{
static $lazy = array();
if (! $lazy)
{
$result = OperationTable::getList(array(
'select' => array('ID', 'NAME'),
'filter' => array('=MODULE_ID' => 'sale', '=BINDING' => 'status'),
));
$operations = array();
while ($row = $result->fetch())
$operations[$row['NAME']] = $row['ID'];
foreach (self::perms2opers() as $perm => $oper)
$lazy[$perm] = $operations[$oper];
asort($lazy);
}
return $lazy; // permission name => operation id
}
public static function addFieldsTo(array &$fields, $statusIdName, $prefix)
{
$fields[$prefix.'GROUP_ID'] = array(
'TYPE' => 'int',
'FIELD' => 'SSGT.GROUP_ID',
'FROM' => 'INNER JOIN b_sale_status_group_task SSGT ON (SSGT.STATUS_ID = '.$statusIdName.')',
);
foreach (self::permissions() as $name => $id)
$fields[$prefix.$name] = array(
'TYPE' => 'char',
'FIELD' => self::permExpression('SSGT.TASK_ID', $id),
'FROM' => 'INNER JOIN b_sale_status_group_task SSGT ON (SSGT.STATUS_ID = '.$statusIdName.')'
);
}
public static function permExpression($taskIdName, $operationId)
{
return 'CASE WHEN EXISTS('.
'SELECT 1 FROM b_task_operation SSTO WHERE SSTO.TASK_ID = '.$taskIdName.' AND SSTO.OPERATION_ID = '.$operationId.
') THEN "Y" ELSE "N" END';
}
public static function addAliasesTo(Compatible\AliasedQuery $query, $taskIdName)
{
foreach (self::permissions() as $name => $id)
$query->addAlias($name, array(
'expression' => array(self::permExpression('%s', $id), $taskIdName),
));
}
public static function adaptResult(Compatible\CDBResult $result, Compatible\OrderQuery $query, $taskIdName)
{
if (! ($query->grouped() || $query->aggregated()))
{
$select = $query->allSelected()
? self::permissions()
: array_intersect_key(self::permissions(), $query->getSelect());
if ($select)
{
$query->setSelect(array_diff_key($query->getSelect(), $select));
$query->addAlias('TASK_ID', $taskIdName);
$query->addAliasSelect('TASK_ID');
$result->addFetchAdapter(new self($select));
}
}
}
/** Get map of: task id => array of operations ids
*/
public static function getTasksOperations()
{
$result = TaskTable::getList(array(
'select' => array(
'TASK' => 'ID',
'OPERATION' => 'Bitrix\Main\TaskOperationTable:TASK.OPERATION_ID',
),
'filter' => array(
'=MODULE_ID' => 'sale',
'=BINDING' => 'status',
),
'order' => array(
'Bitrix\Main\TaskOperationTable:TASK.OPERATION_ID' => 'ASC',
),
));
$tasks = array();
while ($row = $result->fetch())
{
if (! $tasks[$row['TASK']])
$tasks[$row['TASK']] = array();
if ($row['OPERATION'])
$tasks[$row['TASK']][] = $row['OPERATION'];
}
return $tasks;
}
// I N S T A N C E /////////////////////////////////////////////////////////////////////////////////////////////////
private $select, $tasks;
private function __construct(array $select)
{
$this->select = $select;
$this->tasks = self::getTasksOperations();
}
public function adapt(array $row)
{
$tasks = $this->tasks;
$taskId = $row['TASK_ID'];
foreach ($this->select as $perm => $operId)
{
$row[$perm] = $taskId
? (in_array($operId, $tasks[$taskId]) ? 'Y' : 'N')
: '';
}
unset($row['TASK_ID']);
return $row;
}
}