- Модуль: main
- Путь к файлу: ~/bitrix/modules/main/lib/analytics/counterdata.php
- Класс: BitrixMainAnalyticsCounterDataTable
- Вызов: CounterDataTable::submitData
static function submitData($limit = 50)
{
if (!Catalog::isOn())
{
return '\'.__METHOD__.'();';
}
$rows = array();
$r = static::getList(array(
'order' => array('ID' => 'ASC'),
'limit' => $limit
));
while ($row = $r->fetch())
{
$rows[$row['ID']] = array(
'type' => $row['TYPE'],
'data' => $row['DATA']
);
}
if (!empty($rows))
{
// get queue size
$totalCount = static::getCount();
$queueSize = $totalCount > $limit ? $totalCount-$limit : 0;
// set limit
$dataSizeLimit = 45000;
// make an optimal dataset
$dataSize = mb_strlen(base64_encode(json_encode(array_values($rows))));
// records to delete
$toDelete = array();
if ($dataSize > $dataSizeLimit)
{
$reducedRows = array();
foreach ($rows as $id => $row)
{
$rowSize = mb_strlen(base64_encode(json_encode(array_values($row))));
$reducedDataSize = mb_strlen(base64_encode(json_encode(array_values($reducedRows))));
if ($rowSize > $dataSizeLimit)
{
// abnormally big row, delete it
$toDelete[] = $id;
}
elseif (!empty($reducedRows) && ($reducedDataSize + $rowSize) > $dataSizeLimit)
{
// it's enough
break;
}
else
{
$reducedRows[$id] = $row;
}
}
$rows = $reducedRows;
}
if (!empty($rows))
{
// if there are still some data, send it
$data = http_build_query(array(
'op' => 'e',
'aid' => Counter::getAccountId(),
'ad[cd][value]' => base64_encode(json_encode(array_values($rows))),
'ad[cd][queue]' => $queueSize
));
$f = fsockopen('bitrix.info', 80, $errno, $errstr, 3);
if ($f)
{
$out = "POST /bx_stat HTTP/1.1rn";
$out .= "Host: bitrix.inforn";
$out .= "Content-type: application/x-www-form-urlencodedrn";
$out .= "Content-length: ".mb_strlen($data) . "rn";
$out .= "User-Agent: Bitrix Stats Counterrn";
$out .= "Connection: Closern";
$out .= "rn";
$out .= $data . "rnrn";
fwrite($f, $out);
$response = '';
while (!feof($f))
{
$response .= fgets($f, 128);
}
fclose($f);
// delete rows if service received data
if(mb_strpos($response, '200 OK'))
{
$toDelete = array_merge($toDelete, array_keys($rows));
}
}
}
// delete abnormally big and sent rows
foreach ($toDelete as $id)
{
static::delete($id);
}
}
return '\'.__METHOD__.'();';
}