70 lines
3.8 KiB
PHP
70 lines
3.8 KiB
PHP
<?php
|
|
namespace SYSTEM\CRON;
|
|
class cron_log2sqlite extends \SYSTEM\CRON\cronjob{
|
|
public static function run(){
|
|
//find oldest value
|
|
$oldest = \SYSTEM\DBD\SYS_LOG_OLDEST::Q1();
|
|
list( $now_month, $now_year ) = preg_split( "/ /", date("m Y"));
|
|
//All fine -> abort
|
|
if( $oldest['year'] >= $now_year &&
|
|
$oldest['month'] >= $now_month){
|
|
return cronstatus::CRON_STATUS_SUCCESFULLY;}
|
|
|
|
$filename = \SYSTEM\CONFIG\config::get(\SYSTEM\CONFIG\config_ids::SYS_CRON_LOG2SQLITE_PATH).$oldest['year'].'.'.$oldest['month'].'.db';
|
|
//extract whole month to file
|
|
$con = new \SYSTEM\DB\Connection(new \SYSTEM\DB\DBInfoSQLite($filename));
|
|
|
|
//create table
|
|
$con->query('CREATE TABLE IF NOT EXISTS `system_log` ('.
|
|
' `ID` INT(10) NOT NULL,'.
|
|
' `class` TEXT NOT NULL,'.
|
|
' `message` TEXT NOT NULL,'.
|
|
' `code` INT(11) NOT NULL,'.
|
|
' `file` TEXT NOT NULL,'.
|
|
' `line` INT(11) NOT NULL,'.
|
|
' `trace` TEXT NOT NULL,'.
|
|
' `ip` TEXT NOT NULL,'.
|
|
' `querytime` DOUBLE NOT NULL,'.
|
|
' `time` DATETIME NOT NULL,'.
|
|
' `server_name` CHAR(255) NOT NULL,'.
|
|
' `server_port` INT(10) NOT NULL,'.
|
|
' `request_uri` CHAR(255) NOT NULL,'.
|
|
' `post` TEXT NOT NULL,'.
|
|
' `http_referer` CHAR(255) NULL DEFAULT NULL,'.
|
|
' `http_user_agent` TEXT NOT NULL,'.
|
|
' `user` INT(11) NULL DEFAULT NULL,'.
|
|
' `thrown` BIT(1) NOT NULL,'.
|
|
' PRIMARY KEY (`ID`)'.');');
|
|
|
|
//write data as trasaction
|
|
$con->exec('begin transaction');
|
|
$res = \SYSTEM\DBD\SYS_LOG_MONTH::QQ(array($oldest['month'],$oldest['year']));
|
|
$i = 0;
|
|
while($row = $res->next()){
|
|
set_time_limit(30);
|
|
$i++;
|
|
if(!$con->exec('INSERT OR IGNORE INTO '.\SYSTEM\DBD\system_log::NAME_MYS.
|
|
'(`ID`, `class`, `message`, `code`, `file`, `line`, `trace`, `ip`, `querytime`, `time`,'.
|
|
' `server_name`, `server_port`, `request_uri`, `post`,'.
|
|
' `http_referer`, `http_user_agent`, `user`, `thrown`)'.
|
|
'VALUES ('.$row['ID'].', \''.\SQLite3::escapeString($row['class']).'\', \''.\SQLite3::escapeString($row['message']).'\', '.
|
|
$row['code'].', \''.\SQLite3::escapeString($row['file']).'\', '.$row['line'].', \''.\SQLite3::escapeString($row['trace']).'\', \''.
|
|
$row['ip'].'\', '.$row['querytime'].', \''.$row['time'].'\', \''.
|
|
\SQLite3::escapeString($row['server_name']).'\', '.$row['server_port'].', \''.\SQLite3::escapeString($row['request_uri']).'\', \''.\SQLite3::escapeString($row['post']).'\', \''.
|
|
\SQLite3::escapeString($row['http_referer']).'\', \''.\SQLite3::escapeString($row['http_user_agent']).'\', '.$row['user'].','.true.');')){
|
|
new \SYSTEM\LOG\ERROR('failed to insert into log archiev');
|
|
return cronstatus::CRON_STATUS_FAIL;
|
|
}
|
|
}
|
|
if(!$con->exec('end transaction')){
|
|
new \SYSTEM\LOG\ERROR('failed to insert into log archiev');
|
|
return cronstatus::CRON_STATUS_FAIL;};
|
|
|
|
//delete from database
|
|
if(!\SYSTEM\DBD\SYS_LOG_MONTH_DEL::QI(array($oldest['month'],$oldest['year']))){
|
|
new \SYSTEM\LOG\ERROR('failed to delete log entries');
|
|
return cronstatus::CRON_STATUS_FAIL;}
|
|
|
|
return cronstatus::CRON_STATUS_SUCCESFULLY;
|
|
}
|
|
} |