- Модуль: crm
- Путь к файлу: ~/bitrix/modules/crm/lib/widget/data/company/activitystatusstatistics.php
- Класс: Bitrix\Crm\Widget\Data\Company\ActivityStatusStatistics
- Вызов: ActivityStatusStatistics::getList
public function getList(array $params)
{
/** @var Filter $filter */
$filter = isset($params['filter']) ? $params['filter'] : null;
if(!($filter instanceof Filter))
{
throw new Main\ObjectNotFoundException("The 'filter' is not found in params.");
}
$group = isset($params['group'])? mb_strtoupper($params['group']) : '';
if($group !== '' && $group !== self::GROUP_BY_USER && $group !== self::GROUP_BY_DATE && $group !== self::GROUP_BY_STATUS)
{
$group = '';
}
$enableGroupKey = isset($params['enableGroupKey']) ? (bool)$params['enableGroupKey'] : false;
/** @var array $select */
$select = isset($params['select']) && is_array($params['select']) ? $params['select'] : array();
$name = '';
$aggregate = 'SUM';
if(!empty($select))
{
$selectItem = $select[0];
if(isset($selectItem['name']))
{
$name = $selectItem['name'];
}
}
list($providerId, $providerTypeId) = $this->getActivityProviderInfo();
if($name === '')
{
$name = 'TOTAL';
}
$permissionSql = '';
if($this->enablePermissionCheck)
{
$permissionSql = $this->preparePermissionSql();
if($permissionSql === false)
{
//Access denied;
return array();
}
}
$period = $filter->getPeriod();
$periodStartDate = $period['START'];
$periodEndDate = $period['END'];
$query = new Query(CompanyActivityStatusStatisticsTable::getEntity());
$nameAlias = $name;
if($group !== static::GROUP_BY_STATUS)
{
$nameAlias = "{$nameAlias}_R";
$query->registerRuntimeField('', new ExpressionField($nameAlias, "{$aggregate}(%s)", $name));
$query->addSelect($nameAlias);
}
else
{
$query->registerRuntimeField('', new ExpressionField('STATUS_1', "{$aggregate}(%s)", 'UNANSWERED_QTY'));
$query->registerRuntimeField('', new ExpressionField('STATUS_2', "{$aggregate}(%s)", 'ANSWERED_QTY'));
}
$query->addFilter('>=DEADLINE_DATE', $periodStartDate);
$query->addFilter('<=DEADLINE_DATE', $periodEndDate);
if ($providerId)
$query->addFilter('=PROVIDER_ID', $providerId);
if ($providerTypeId)
$query->addFilter('=PROVIDER_TYPE_ID', $providerTypeId);
if (
$filter->getContextEntityTypeName() === \CCrmOwnerType::CompanyName
&& $filter->getContextEntityID() > 0
)
{
$query->addFilter('=OWNER_ID', $filter->getContextEntityID());
}
if($this->enablePermissionCheck && is_string($permissionSql) && $permissionSql !== '')
{
$query->addFilter('@OWNER_ID', new SqlExpression($permissionSql));
}
$responsibleIDs = $filter->getResponsibleIDs();
if(!empty($responsibleIDs))
{
$query->addFilter('@RESPONSIBLE_ID', $responsibleIDs);
}
if($group !== '')
{
if($group === self::GROUP_BY_USER)
{
$query->addSelect('RESPONSIBLE_ID');
$query->addGroup('RESPONSIBLE_ID');
}
elseif($group === self::GROUP_BY_STATUS)
{
$query->addSelect('STATUS_1');
$query->addSelect('STATUS_2');
}
else //if($groupBy === self::GROUP_BY_DATE)
{
$query->addSelect('DEADLINE_DATE');
$query->addGroup('DEADLINE_DATE');
$query->addOrder('DEADLINE_DATE', 'ASC');
}
}
$dbResult = $query->exec();
$result = array();
$useAlias = $nameAlias !== $name;
if($group === self::GROUP_BY_DATE)
{
while($ary = $dbResult->fetch())
{
if($useAlias && isset($ary[$nameAlias]))
{
$ary[$name] = $ary[$nameAlias];
unset($ary[$nameAlias]);
}
$ary['DATE'] = $this->getLocalDate($ary['DEADLINE_DATE'], 'Y-m-d');
unset($ary['DEADLINE_DATE']);
if($ary['DATE'] === '9999-12-31')
{
//Skip empty dates
continue;
}
$result[] = $ary;
}
}
elseif($group === self::GROUP_BY_STATUS)
{
$statuses = StatisticsStatus::getDescriptions();
while($ary = $dbResult->fetch())
{
foreach($statuses as $status => $streamDescription)
{
$resultAry = array(
'STATUS' => $streamDescription,
$name => (int)($ary['STATUS_'.$status] ?? 0)
);
if($enableGroupKey)
{
$result[$status] = $resultAry;
}
else
{
$result[] = $resultAry;
}
}
}
}
elseif($group === self::GROUP_BY_USER)
{
while($ary = $dbResult->fetch())
{
if($useAlias && isset($ary[$nameAlias]))
{
$ary[$name] = $ary[$nameAlias];
unset($ary[$nameAlias]);
}
$result[] = $ary;
}
self::parseUserInfo($result, ['RESPONSIBLE_ID' => 'USER']);
}
else
{
while($ary = $dbResult->fetch())
{
if($useAlias && isset($ary[$nameAlias]))
{
$ary[$name] = $ary[$nameAlias];
unset($ary[$nameAlias]);
}
$result[] = $ary;
}
}
return $result;
}