149 lines
4.2 KiB
PHP
149 lines
4.2 KiB
PHP
<?php
|
|
/**
|
|
* Created by PhpStorm.
|
|
* User: exodus4d
|
|
* Date: 14.06.2015
|
|
* Time: 15:24
|
|
*/
|
|
|
|
namespace controller;
|
|
use DB;
|
|
|
|
class LogController extends \Prefab {
|
|
|
|
/**
|
|
* buffered activity log data for this singleton LogController() class
|
|
* -> this buffered data can be stored somewhere (e.g. DB) before HTTP response
|
|
* -> should be cleared afterwards!
|
|
* @var array
|
|
*/
|
|
protected $activityLogBuffer = [];
|
|
|
|
/**
|
|
* reserve a "new" character activity for logging
|
|
* @param $characterId
|
|
* @param $mapId
|
|
* @param $action
|
|
*/
|
|
public function bufferActivity($characterId, $mapId, $action){
|
|
$characterId = (int)$characterId;
|
|
$mapId = (int)$mapId;
|
|
|
|
if(
|
|
$characterId > 0 &&
|
|
$mapId > 0
|
|
){
|
|
$key = $this->getBufferedActivityKey($characterId, $mapId);
|
|
|
|
if( is_null($key) ){
|
|
$activity = [
|
|
'characterId' => $characterId,
|
|
'mapId' => $mapId,
|
|
$action => 1
|
|
];
|
|
$this->activityLogBuffer[] = $activity;
|
|
}else{
|
|
$this->activityLogBuffer[$key][$action]++;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* store all buffered activity log data to DB
|
|
*/
|
|
public function storeActivities(){
|
|
if( !empty($this->activityLogBuffer) ){
|
|
$db = DB\Database::instance()->getDB('PF');
|
|
|
|
$quoteStr = function($str) use ($db) {
|
|
return $db->quotekey($str);
|
|
};
|
|
|
|
$placeholderStr = function($str){
|
|
return ':' . $str;
|
|
};
|
|
|
|
$updateRule = function($str){
|
|
return $str . " = " . $str . " + VALUES(" . $str . ")";
|
|
};
|
|
|
|
$year = (int)date('o');
|
|
$yearWeek = (int)date('W');
|
|
$db->begin();
|
|
|
|
foreach($this->activityLogBuffer as $activityData){
|
|
$activityData['year'] = $year;
|
|
$activityData['week'] = $yearWeek;
|
|
|
|
$columns = array_keys($activityData);
|
|
$columnsQuoted = array_map($quoteStr, $columns);
|
|
$placeholder = array_map($placeholderStr, $columns);
|
|
$args = array_combine($placeholder, $activityData);
|
|
|
|
// "filter" columns that can be updated
|
|
$columnsForUpdate = array_diff($columns, ['year', 'week', 'characterId', 'mapId']);
|
|
$updateSql = array_map($updateRule, $columnsForUpdate);
|
|
|
|
$sql = "INSERT DELAYED INTO
|
|
activity_log (" . implode(', ', $columnsQuoted) . ") values(
|
|
" . implode(', ', $placeholder) . "
|
|
)
|
|
ON DUPLICATE KEY UPDATE
|
|
updated = NOW(),
|
|
" . implode(', ', $updateSql) . "
|
|
";
|
|
|
|
$db->exec($sql, $args);
|
|
}
|
|
|
|
$db->commit();
|
|
|
|
// clear activity data for this instance
|
|
$this->activityLogBuffer = [];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* get array key from "buffered activity log" array
|
|
* @param int $characterId
|
|
* @param int $mapId
|
|
* @return int|null
|
|
*/
|
|
private function getBufferedActivityKey($characterId, $mapId){
|
|
$activityKey = null;
|
|
|
|
if(
|
|
$characterId > 0 &&
|
|
$mapId > 0
|
|
){
|
|
foreach($this->activityLogBuffer as $key => $activityData){
|
|
if(
|
|
$activityData['characterId'] === $characterId &&
|
|
$activityData['mapId'] === $mapId
|
|
){
|
|
$activityKey = $key;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
return $activityKey;
|
|
}
|
|
|
|
/**
|
|
* get Logger instance
|
|
* @param string $type
|
|
* @return \Log|null
|
|
*/
|
|
public static function getLogger($type){
|
|
$f3 = \Base::instance();
|
|
$logFiles = $f3->get('PATHFINDER.LOGFILES');
|
|
|
|
$logFileName = empty($logFiles[$type]) ? 'error' : $logFiles[$type];
|
|
$logFile = $logFileName . '.log';
|
|
$logger = new \Log($logFile);
|
|
|
|
return $logger;
|
|
}
|
|
|
|
} |