#!/usr/bin/php
<?php
    $DB['host'] = 'localhost';
    $DB['user'] = 'user';
    $DB['pass'] = 'pass';
    $DB['name'] = 'database';

	$access_log_table = "http_access_log";
	$access_tmp_table = "http_access_log_tmp";
	$tmp = '/tmp/stats';
	$basedir = '/home/pookey/secure_sites/my.pengus.net/stats';
	$webalizer = '/usr/bin/webalizer';
	
	mysql_connect ($DB['host'],$DB['user'],$DB['pass']);
    mysql_select_db($DB['name']); 
    
    function RotateLog() {
		global $access_log_table;
		global $access_tmp_table;
        $sql = "DROP TABLE " . $access_tmp_table;
        mysql_query($sql);
        $sql = "ALTER TABLE " . $access_log_table . " RENAME " . $access_tmp_table;
        mysql_query($sql);
        $sql = "CREATE TABLE " . $access_log_table . " (
                    id char(19) ,
                    agent varchar(255) ,
                    bytes_sent int unsigned ,
                    child_pid smallint unsigned,
                    cookie varchar(255),
                    machine_id varchar(25),
                    request_file varchar(255),
                    referer varchar(255) ,
                    remote_host varchar(50) ,
                    remote_logname varchar(50) ,
                    remote_user varchar(50) ,
                    request_duration smallint unsigned ,
                    request_line varchar(255),
                    request_method varchar(10) ,
                    request_protocol varchar(10) ,
                    request_time char(28),
                    request_uri varchar(50),
                    request_args varchar(255),
                    server_port smallint unsigned,
                    ssl_cipher varchar(25),
                    ssl_keysize smallint unsigned,
                    ssl_maxkeysize smallint unsigned,
                    status smallint unsigned ,
                    time_stamp int unsigned ,
                    virtual_host varchar(50)
                )";
        mysql_query($sql);
        $sql = "ALTER TABLE " . $access_tmp_table . " ADD INDEX  (`virtual_host`)";
        mysql_query($sql);
    }
    
    function DumpSite($site_id) {
		global $access_tmp_table;
		global $tmp;
        $sql = "SELECT hostname FROM http_hosts WHERE site_id = " . $site_id;
        $result = mysql_query($sql);
        $logfile = $tmp . '/sas-tmpsite_log' . $site_id . '.tmp';
        $fp = fopen($logfile,'w');
        $total_count=0;
        while ($row = mysql_fetch_array($result)) {
            $sql = "SELECT * FROM " . $access_tmp_table . " WHERE virtual_host = '" . $row['hostname'] . "'";
            $subresult = mysql_query($sql);
            $count = 0;
            while ($subrow = mysql_fetch_array($subresult)) {
                $count++;
                $tmprow =  $subrow['remote_host'] . ' - - ' . date("[d/M/Y:H:i:s O] ",$subrow['time_stamp']) . '"' . $subrow['request_method'] . ' ' .
                           $subrow['request_uri'] . ' ' . $subrow['request_protocol'] . '" ' . $subrow['status'] . ' ';
                if ($subrow['bytes_sent'] > 0) {
                    $tmprow .= $subrow['bytes_sent'];
                } else {
                    $tmprow .=  '-';
                }
                $tmprow .=  ' "' . $subrow['referer'] . '" "' . $subrow['agent'] . '"';
                $tmprow .=  "\n";
                fwrite($fp,$tmprow);
            }
            echo "\t\thost=>\t" . $row['hostname'] .  " (" . $count . ")\n";
            $total_count = $total_count + $count;
        }
        fclose($fp);
        echo "DONE. total " . $total_count . " lines analized\n";
        return 0;
    }
    
    function DoStats($site_id,$report_title) {
		global $tmp;
		global $webalizer;
		global $basedir;
		
        $config_file = implode("",(file('/home/pookey/webalizer.template')));
        $sql = "SELECT hostname FROM http_hosts WHERE site_id = " . $site_id . " LIMIT 0,1";
        $result = mysql_query($sql);
        $row = mysql_fetch_array($result);
        $parameters['hostname'] = $row['hostname'];
        $parameters['site_id'] = $site_id;
        $parameters['report_title'] = $report_title;
		$parameters['tmp'] = $tmp;
		$parameters['basedir'] = $basedir;
        foreach($parameters as $key => $value) { 
            $template_name = '{' . $key . '}';
            $config_file = str_replace($template_name,$value,$config_file);
        }

        $directory = $basedir . "/" . $site_id;
        echo "\n" . $directory . "\n";
        if (!file_exists($directory)) {
            mkdir($directory,0770); 
        }
		
		$webalizer_config = $tmp . '/sas-webalizer.conf';
		$logfile = $tmp . '/sas-tmpsite_log' . $site_id . '.tmp';
		
        $fp = fopen($webalizer_config,'w');
        fwrite($fp,$config_file);
        fclose($fp);
        exec($webalizer . ' -c ' . $webalizer_config);
        unlink($webalizer_config);
        unlink($logfile);
    }
    
    function DumpSites() {
        $sql = "SELECT * FROM http_sites";    
        $result = mysql_query($sql);
        while ($row = mysql_fetch_array($result)) {
            echo "SITE:\t" . $row['description'] . "\n";
            DumpSite($row['site_id']);
            DoStats($row['site_id'],$row['description']);
        }
    } 
   
    RotateLog();
    DumpSites();

?>