<?php

if (!defined('IN_TRAFSTAT')) {
	die("Hacking attempt!");
}

$avlSortCmp = array('count', 'data');

/* определим флаг сортировки */
if (isset($_GET['sort']))
	$temp = in_array($_GET['sort'], $avlSortCmp) ? $_GET['sort'] : 'count';
else
	$temp = 'count';
define('SORT_CMP', $temp);

/* Определим запрашиваемый месяц */
define('PERIOD', get_period());
/* Определим запрашиваемый день месяца */
define('PERIOD_DAY', get_period_day());

/* Сформируем даты, между которыми будет формироваться статистика. */
define('BEGIN_DATE', get_begin_date(PERIOD, PERIOD_DAY));
define('END_DATE', get_end_date(BEGIN_DATE, PERIOD_DAY));

/* количество запросов к базе */
$queryCount = 0;

function my_mysql_query($query)
{
	global $queryCount;

	$queryCount++;
	$result = mysql_query($query) or
		message_die("Query failed: " . mysql_error());
	return $result;
}

/*
 * Хранит всю информацию о топе серверов.
 *
 * Array (
 *   [$serverIp] => Array (
 *     [count] => val,
 *     [data] => val,
 *     [user] => Array (userIp),
 *     [userCount] => val
 *   )
 * )
 */
$dataTraf = array();

/*
 * Запрос возвращает список удаленных серверов к которым были запросы.
 * Различие по протоколу не произодиться.
 */
/* шаблон замены для запроса */
$ptrnTopSrv = array('/%BEGIN_DATE%/', '/%END_DATE%/');

$queryTopSrv = '
select
	dstIp as server,
	count(*) as count
from
	traffic
where
	(srcPort = 0) &&
	(date >= "%BEGIN_DATE%" && date < "%END_DATE%")
group by dstIp';

/* получим данные из базы */
$replacements = array(BEGIN_DATE, END_DATE);
$queryTemp = preg_replace($ptrnTopSrv, $replacements, $queryTopSrv);
$result = my_mysql_query($queryTemp);

while ($line = mysql_fetch_assoc($result)) {
	$index = $line['server'];
	$dataTraf[$index]['count'] = $line['count'];
}

mysql_free_result($result);

/*
 * Сформируем линк для графика суммарной статистики.
 */
/* массив для хранения трафика */
$sumTraf = array();

/* сформируем запрос к базе */
$querySumTraf = 'select case ';

list($year, $month, $day) = split('-', BEGIN_DATE);
$initDate = mktime(0, 0, 0, $month, $day, $year);
list($year, $month, $day) = split('-', END_DATE);
$endDate = mktime(0, 0, 0, $month, $day, $year);

for ($i = 0; $initDate < $endDate; $i++) {
	$dateBegin = date("Y-m-d H:i:s", $initDate);
	$initDate += PERIOD_DAY ? (60 * 60) : (60 * 60 * 24);
	$dateEnd = date("Y-m-d H:i:s", $initDate);

	$sumTraf[$i] = 0;
	$querySumTraf .= "when (date >= '$dateBegin' && date < '$dateEnd') then $i ";
}

$querySumTraf .= 'end as period, sum(psize) as data from traffic where (dstPort = 0) && (date >= "' .
	BEGIN_DATE . '" && date < "' . END_DATE . '") group by period';

/* выполним запрос */
$result = my_mysql_query($querySumTraf);
while ($line = mysql_fetch_assoc($result)) {
	$sumTraf[$line['period']] = $line['data'];
}
mysql_free_result($result);

/* сформируем линк картинки */
$imgSumTraf = './graph.php?graph=timegraph&amp;title=' .
	urlencode('Incoming traffic (total)') . '&amp;xt=' .
	urlencode(PERIOD_DAY ? 'Hours' : 'Days') .
	'&amp;data=' . implode(',', $sumTraf);

/*
 * Запрос возвращает список хостов запрашивавщих сервер.
 */
$querySrvOfHost = '
select
	srcIp
from
	traffic
where
	(srcPort = 0) && (dstIp = %SERVER%) &&
	(date >= "%BEGIN_DATE%" && date < "%END_DATE%")
group by srcIp';

/*
 * Запрос возвращает количество полученного трафика от данного сервера.
 */
$querySrvTraf = '
select
	sum(psize) as data
from
	traffic
where
	(dstPort = 0) && (srcIp = %SERVER%) &&
	(date >= "%BEGIN_DATE%" && date < "%END_DATE%")';

$replacements = array(BEGIN_DATE, END_DATE);
$querySrvOfHost = preg_replace($ptrnTopSrv, $replacements, $querySrvOfHost);
$querySrvTraf = preg_replace($ptrnTopSrv, $replacements, $querySrvTraf);

/* получим данные из базы */
foreach ($dataTraf as $server => $data) {
	$dataTraf[$server]['data'] = 0;

	$queryTemp = preg_replace('/%SERVER%/', $server, $querySrvOfHost);
	$result = my_mysql_query($queryTemp);
	while ($line = mysql_fetch_assoc($result)) {
		$dataTraf[$server]['user'][] = $line['srcIp'];
	}
	$dataTraf[$server]['userCount'] = count($dataTraf[$server]['user']);
	mysql_free_result($result);

	$queryTemp = preg_replace('/%SERVER%/', $server, $querySrvTraf);
	$result = my_mysql_query($queryTemp);
	$line = mysql_fetch_assoc($result);
	$dataTraf[$server]['data'] += $line['data'];
	mysql_free_result($result);
}

/*
 * Функция сортировки данных статистики.
 * Перед сортировкой должны быть определены глобальные
 * переменные:
 * dataTrafCopy - содержит копию сортируемого масива
 * sortCmp - ключ в ассоциативном массиве по которому идет сортировка
 */
$dataTrafCopy = $dataTraf;
function sort_cmp($a, $b)
{
	global $dataTrafCopy;
	global $sortCmp;

	$v1 = $dataTrafCopy[$a][$sortCmp];
	$v2 = $dataTrafCopy[$b][$sortCmp];

	if ($v1 == $v2)
		return 0;
	return ($v1 > $v2) ? -1 : 1;
}

/*
 * Сформируем данные для картинки отображающей топов.
 * Внимание, данные можно формировать только после сортировки
 * данных.
 */
define('PIE_SLICE', 5);

function make_top_image($title)
{
	global $dataTraf;
	global $sortCmp;

	$topLabel = array();
	$topData = array();
	$dataTemp = $dataTraf;
	$i = 0;

	uksort($dataTemp, "sort_cmp");

	foreach ($dataTemp as $client => $traf) {
		if (!$traf[$sortCmp])
			break;

		$i++;
		if ($i < PIE_SLICE) {
			$topLabel[] = long2ip($client);
			$topData[] = $traf[$sortCmp];
		} else if ($i == PIE_SLICE) {
			$topLabel[PIE_SLICE - 1] = urlencode('other');
			$topData[PIE_SLICE - 1] = $traf[$sortCmp];
		} else {
			$topData[PIE_SLICE - 1] += $traf[$sortCmp];
		}
	}

	/* Сформируем линк для картинки топа запросов */
	$imgTop = './graph.php?graph=topgraph';
	if (isset($topData[0])) {
		$imgTop .= '&amp;title=' . urlencode($title) . '&amp;leg=' .
			implode('|', $topLabel) . '&amp;data=' . implode(',', $topData);
	}

	return $imgTop;
}

$sortCmp = 'count';
$imgTopCount = make_top_image('Request');
$sortCmp = 'data';
$imgTopData = make_top_image('Traffic');

/* сортируем данные */
$sortCmp = SORT_CMP;
uksort($dataTraf, "sort_cmp");

/* формирует ссылки для сортировки данных */
function make_sort_link($val, $sort)
{
	if ($sort != SORT_CMP) {
		$link = '<a href="./index.php?content=' . CONTENT .
			'&amp;period=' . PERIOD . '&amp;period_day=' . PERIOD_DAY .
			"&amp;sort=$sort\">$val</a>";
	} else {
		$link = $val;
	}

	return $link;
}

/**
 * Отобразим страницу.
 */
list($year, $month) = split('-', BEGIN_DATE);
$day = PERIOD_DAY;

$title = 'Топ-лист серверов за ' . make_month($year, $month, $day);
print_html_head($title, 'reverse_ip');

/* отобразим название продукта */
print_head();

/* отобразим графики содержащие статистику */
echo "<center><table>\n";
echo '<tr><td class="pointer">';
print_login();
echo "</td></tr>\n";
echo '<tr><th class="title"><h2>Топ-лист серверов за ' .
	make_month($year, $month, $day) . "</h2></th></tr>\n";
echo "<tr><td></td></tr>\n";
echo "<tr><td class=\"title\"><img src=\"$imgSumTraf\" /></td></tr>\n";
echo '<tr><td class="title">';
print_imgtop($imgTopCount, 'ajax-imgtop1');
print_imgtop($imgTopData, 'ajax-imgtop2');
echo "</td></tr>\n";
echo "</table></center>\n";

print_full_line();

/* отобразим таблицу содержащую статистику */
echo "<center><table>\n";

if (SESS_TYPE === 'admin') {
	echo '<tr><td class="navigation" colspan="5">' .
		'<a href="./index.php?content=period">' .
		'<b>Статистика по месяцам</b></a> > ' .
		'<a href="./index.php?content=statistic&amp;period=' . PERIOD .
		"&amp;period_day=$day\"><b>" . make_month($year, $month, $day) .
		"</b></a> > <b>Топ-лист серверов</b></td></tr>\n";
}

echo '<tr><td class="page" colspan="5">';
$endDate = date('t', PERIOD);
for ($i = 1; $i <= $endDate; $i++) {
	if ($i != PERIOD_DAY) {
		echo '<a href="./index.php?content=' . CONTENT .
			'&amp;period=' . PERIOD . "&amp;period_day=${i}&amp;sort=" .
			SORT_CMP . "\">$i</a> ";
	} else {
		echo "[<b>$i</b>] ";
	}
}
if (PERIOD_DAY) {
	echo '<a href="./index.php?content=' . CONTENT .
		'&amp;period=' . PERIOD . '&amp;period_day=0&amp;sort=' .
		SORT_CMP . "\">все</a></td></tr>\n";
} else {
	echo "[<b>все</b>]</td></tr>\n";
}

echo '<tr>';
print_data('Номер', 'head0', 'th');
print_data('Сервер', 'head0', 'th');
print_data('Хосты', 'head0', 'th');
print_data(make_sort_link('Запросов', 'count'), 'head1', 'th');
print_data(make_sort_link('Получено', 'data'), 'head1', 'th');
print_data('', 'page');
echo "</tr>\n";

$count = $sumCount = $sumData = $sumUser = 0;
foreach ($dataTraf as $server => $data) {
	$count++;
	$sumCount += $data['count'];
	$sumData += $data['data'];
	$sumUser += $data['userCount'];

	$serverName = make_span(long2ip($server), 'ajax-reverse_ip');

	$users = '';
	$i = 0;
	foreach ($data['user'] as $val) {
		$users .= '<a href="./index.php?content=user&amp;user=' .
			$val . '&amp;period=' . PERIOD . '&amp;period_day=' .
			PERIOD_DAY . '">' . long2ip($val) . '</a>';
		$users .= (++$i % 5) ? ', ' : ',<br />';
	}
	$users = preg_replace('/,(\s|<br \/>)$/', '', $users);

	echo '<tr>';
	print_data($count, 'data0');
	print_data($serverName, 'data1');
	print_data($users, 'data1');
	print_data(val_trun($data['count']), 'data2');
	print_data(val_trun($data['data']), 'data2');
	echo "</tr>\n";
}

echo '<tr>';
print_data('', 'page');
print_data("Итого:", "head4", "th");
print_data(val_trun($sumUser), 'head3');
print_data(val_trun($sumCount), "head3");
print_data(val_trun($sumData), "head3");
echo '</tr>' . "\n";
echo '</table></center>' . "\n";

print_full_line();

/* отобразим информацию о программе */
print_info($queryCount);
print_html_tail();

?>