• Модуль: 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__.'();';
}