File manager

File manager - Edit - /home/newsbmcs.com/public_html/play1/includes/statistics.php

Back
<?php if (session_status() == PHP_SESSION_NONE) { session_start(); } require_once( dirname(__FILE__)."/../config.php" ); class Stats { public static $debug = false; public static function debug() { if ( self::$debug ) : $bt = debug_backtrace(); $caller = array_shift($bt); ?> <pre class='__debug'><?php print_r([ "file" => $caller["file"], "line" => $caller["line"], "args" => func_get_args() ]); ?> </pre> <?php endif; } public static function migration_db() { // create table stats try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $table_db_stats = 'statistics'; $sql = "CREATE TABLE IF NOT EXISTS `".$table_db_stats."` ( `id` INT(11) UNSIGNED AUTO_INCREMENT PRIMARY KEY, `created_date` DATE, `page_views` VARCHAR(255), `unique_visitor` VARCHAR(255), `data` MEDIUMTEXT, )"; $pdo->exec($sql); self::debug("Table ".$table_db_stats." created successfully<br>"); } catch(PDOException $e) { self::debug($sql . "<br>" . $e->getMessage()); } // create table stats_ip_address try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $table_db_stats_ip_address = 'stats_ip_address'; $sql = "CREATE TABLE IF NOT EXISTS `".$table_db_stats_ip_address."` ( `id` INT(11) UNSIGNED AUTO_INCREMENT PRIMARY KEY, `ip_address` VARCHAR(255), `created_date` DATE )"; $pdo->exec($sql); self::debug("Table ".$table_db_stats_ip_address." created successfully<br>"); } catch(PDOException $e) { self::debug($sql . "<br>" . $e->getMessage()); } } public static function create_stats( $page_views = 0, $unique_visitor = 0, $data = '' ){ try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // $ip_address = get_visitor_ip(); $created_date = date('Y-m-d'); $sql = "INSERT INTO `statistics` (page_views,unique_visitor,created_date,data) VALUES ('$page_views','$unique_visitor','$created_date','$data')"; $pdo->exec($sql); //self::debug("New record created successfully in stats"); } catch( PDOException $e ) { self::debug($sql . "<br>" . $e->getMessage()); } } public static function update_stats( $page_views = 0, $unique_visitor = 0, $data = '' ) { try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // $ip_address = get_visitor_ip(); $created_date = date('Y-m-d'); $sql = "UPDATE `statistics` SET page_views='$page_views',unique_visitor='$unique_visitor',data='$data' WHERE `created_date` = '$created_date'"; $pdo->exec($sql); self::debug("New record update successfully in stats"); } catch( PDOException $e ) { self::debug($sql . "<br>" . $e->getMessage()); } } public static function create_stats_ip($ip_address = null, $conn = null) { if(!$ip_address){ $ip_address = self::get_visitor_ip(); } try { $close_conn = false; if($conn){ $close_conn = true; $conn = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } $created_date = date('Y-m-d'); $sql = "INSERT INTO `stats_ip_address` (ip_address,created_date) VALUES ('$ip_address','$created_date')"; $conn->exec($sql); if($close_conn){ $conn = null; } //self::debug("New record created successfully in stats_ip_address"); } catch( PDOException $e ) { //self::debug($sql . "<br>" . $e->getMessage()); } } public static function delete_stats_ip() { try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $created_date = date('Y-m-d'); $sql = "DELETE FROM stats_ip_address"; $pdo->exec($sql); //self::debug("Record deleted successfully in stats_ip_address"); } catch( PDOException $e ) { self::debug($sql . "<br>" . $e->getMessage()); } } public static function get_stats_ip( $args = [] ) { $stats_ip = []; try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $ip_address = self::get_visitor_ip(); $created_date = date('Y-m-d'); $sql = "SELECT * FROM `stats_ip_address` WHERE `ip_address` = '$ip_address'"; $created_date = ''; if ( isset( $args['created_date']) && !empty( $args['created_date'] ) ) : $created_date = $args['created_date']; endif; if ( $created_date ) : $sql .= " AND `created_date` = '$created_date'"; endif; if ( empty($created_date) ) : $created_date_before = ''; if ( isset( $args['created_date_before']) && !empty( $args['created_date_before'] ) ) : $created_date_before = $args['created_date_before']; endif; if ( $created_date_before ) : $sql .= " AND `created_date` < '$created_date_before'"; endif; endif; $limit = -1; $offset = 0; if ( isset( $args['limit'] ) && !empty( $args['limit'] ) ) : $limit = intval($args['limit']); endif; if ( isset( $args['offset'] ) && !empty( $args['offset'] ) ) : $offset = intval($args['offset']); endif; if ( !empty($limit) && $limit != -1 ) : $sql .= " LIMIT ".$limit." OFFSET ".$offset.""; endif; $stmt = $pdo->prepare($sql); $stmt->execute(); // set the resulting array to associative $result = $stmt->setFetchMode(PDO::FETCH_ASSOC); $stats_ip = $stmt->fetchAll(); } catch(PDOException $e) { self::migration_db(); self::debug("Error: " . $e->getMessage()); } return $stats_ip; } public static function is_unique_visitor($ip, $conn = null) { $close_conn = false; if(!$conn){ $close_conn = true; $conn = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } $sql = 'SELECT * FROM stats_ip_address WHERE ip_address = :ip'; $st = $conn->prepare($sql); $st->bindValue(":ip", $ip, PDO::PARAM_STR); $st->execute(); $row = $st->fetch(); if($close_conn){ $conn = null; } if($row){ return false; } else { return true; } } public static function update_data($data = []) { $ip_address = self::get_visitor_ip(); $date_time = date('Y-m-d'); $conn = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $sql = 'SELECT data FROM statistics WHERE created_date = :date_time'; $st = $conn->prepare($sql); $st->bindValue(":date_time", $date_time, PDO::PARAM_STR); $st->execute(); $row = $st->fetch(); if($row){ $row = json_decode($row['data'], true); $json_data = ''; $unique_visitor = 0; if(self::is_unique_visitor($ip_address, $conn)){ $unique_visitor = 1; self::create_stats_ip($ip_address, $conn); foreach ($data as $item => $value) { if(isset($row[$item][$value])){ $row[$item][$value]++; } else { $row[$item][$value] = 1; } } $json_data = json_encode($row); } else { if($row === ''){ $json_data = json_encode($data); } else { $json_data = json_encode($row); } } $sql = 'UPDATE statistics SET page_views = page_views + 1, unique_visitor = unique_visitor + :uv, data = :data WHERE created_date = :date_time'; $st = $conn->prepare($sql); $st->bindValue(":date_time", $date_time, PDO::PARAM_STR); $st->bindValue(":uv", $unique_visitor, PDO::PARAM_INT); $st->bindValue(":data", $json_data, PDO::PARAM_STR); $st->execute(); } else { self::delete_stats_ip(); self::create_stats(1,1, json_encode(self::convert_array_data($data))); } $conn = null; } public static function convert_array_data( $data = [] ) { $array = []; foreach ($data as $item => $value) { $array[$item][$value] = 1; } return $array; } public static function get_data( $args = [] ) { $stats = []; try { $pdo = new PDO(DB_DSN, DB_USERNAME, DB_PASSWORD); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $start_date = ''; $end_date = ''; if ( isset( $args['start_date']) && !empty( $args['start_date'] ) ) : $start_date = $args['start_date']; endif; if ( isset( $args['end_date']) && !empty( $args['end_date'] ) ) : $end_date = $args['end_date']; endif; $sql = "SELECT * FROM `statistics`"; if ( $start_date && $end_date ) : $sql .= " WHERE `created_date` BETWEEN '$start_date' AND '$end_date'"; endif; $limit = -1; $offset = 0; if ( isset( $args['limit'] ) && !empty( $args['limit'] ) ) : $limit = intval($args['limit']); endif; if ( isset( $args['offset'] ) && !empty( $args['offset'] ) ) : $offset = intval($args['offset']); endif; if ( !empty($limit) && $limit != -1 ) : $sql .= " LIMIT ".$limit." OFFSET ".$offset.""; endif; $stmt = $pdo->prepare($sql); $stmt->execute(); // set the resulting array to associative $result = $stmt->setFetchMode(PDO::FETCH_ASSOC); $stats = $stmt->fetchAll(); } catch(PDOException $e) { self::migration_db(); self::debug("Error: " . $e->getMessage()); } return $stats; } public static function get_data_range( $data ) { $args = array( 'limit' => $data['limit'], 'offset' => $data['offset'], 'start_date' => date("Y-m-d", strtotime($data['sub']." days")), 'end_date' => date('Y-m-d'), ); $result = self::get_data($args); $conv_result = []; foreach($result as $item){ $conv_result[$item['created_date']] = array('page_views'=>$item['page_views'], 'unique_visitor'=>$item['unique_visitor']); } $begin = new DateTime( $args['start_date'] ); $end = new DateTime( $args['end_date'] ); $end = $end->modify( '+1 day' ); $interval = new DateInterval('P1D'); $daterange = new DatePeriod($begin, $interval ,$end); $final_result = []; foreach($daterange as $date){ $time = $date->format("Y-m-d"); if(isset($conv_result[$time])){ array_push($final_result, array( 'page_views' => $conv_result[$time]['page_views'], 'unique_visitor' => $conv_result[$time]['unique_visitor'], 'date' => $time, )); } else { array_push($final_result, array( 'page_views' => 0, 'unique_visitor' => 0, 'date' => $time, )); } } return $final_result; } public static function get_visitor_ip() { if (isset($_SERVER["HTTP_CF_CONNECTING_IP"])) { $ipAddr = $_SERVER["HTTP_CF_CONNECTING_IP"]; } elseif (!empty($_SERVER['HTTP_CLIENT_IP'])) { $ipAddr = $_SERVER['HTTP_CLIENT_IP']; } elseif (!empty($_SERVER['HTTP_X_FORWARDED_FOR'])) { $ipAddr = strtok($_SERVER['HTTP_X_FORWARDED_FOR'], ','); } else { $ipAddr = $_SERVER['REMOTE_ADDR']; } return $ipAddr; } public static function init() { self::migration_db(); self::update_data(); $args = [ 'limit'=>-1, 'offset'=>0, // 'start_date'=>date('Y-m-d'), // 'end_date'=>date('Y-m-d'), ]; //$stats = Stats::get_data($args); //echo '<pre>'.print_r($stats,1).'</pre>'; } } if(isset($_POST['action'])){ if($_POST['action'] === 'update'){ if(isset($_POST['data'])){ $data = json_decode($_POST['data'], true); Stats::update_data($data); } } } if( isset($_GET['data']) ){ //- Any login users can get the data, even it's not Admin user $username = isset( $_SESSION['username'] ) ? $_SESSION['username'] : ""; if ( !$username ) { exit('logout'); } if(isset($_POST['limit']) && isset($_POST['offset']) && isset($_POST['sub'])){ $data = array( 'limit' => (int)$_POST['limit'], 'offset' => (int)$_POST['offset'], 'sub' => (int)$_POST['sub'] ); echo json_encode(Stats::get_data_range($data)); } } ?>

| ver. 1.4 | Github | . | PHP 8.2.28 | Generation time: 0.02 | proxy | phpinfo | Settings