<?php
/**
 * $Header$
 *
 * $Id$
 * @package stats
**/

/**
 * @package stats
 * @subpackage Stats
**/
namespace Bitweaver\Stats;

use Bitweaver\BitBase;
use Bitweaver\Liberty\LibertyContent;
use Bitweaver\BitDb;

class Statistics extends BitBase {

	/**
	 * Summary of prepGetList
	 * @param array $pListHash
	 * @return void
	 */
	public static function prepGetList( &$pListHash ): void {

		if( !empty( $pListHash['period'] ) ) {
			$pListHash['period_format'] = BitDb::getPeriodFormat( $pListHash['period'] );
		}

		parent::prepGetList( $pListHash );
	}

	/**
	 * getRefererList gets a list of referers
	 *
	 * @param array $pListHash
	 * @return array of referers
	 */
	public function getRefererList( &$pListHash ) {
		global $gBitSystem;
		$hashKey = '';

		$ret = $bindVars = [];
		$selectSql = $joinSql = $whereSql = $groupSql = "";

		$hashSql = "uu.`user_id` AS `hash_key`, ";

		if( empty( $pListHash['sort_mode'] )) {
			$pListHash['sort_mode'] = 'uu.`registration_date_desc`';
		}

		static::prepGetList( $pListHash );

		if( empty( $pListHash['period_format'] ) ) {
			$pListHash['period_format'] = 'Y-W';
		}

		if( !empty( $pListHash['period_format'] ) && !empty( $pListHash['timeframe'] ) ) {
			$whereSql .= empty( $whereSql ) ? ' WHERE ' : ' AND ';
			$whereSql .= $this->mDb->SQLDate( $pListHash['period_format'], $this->mDb->SQLIntToTimestamp( 'registration_date' )).'=?';
			$bindVars[] = $pListHash['timeframe'];
			$hashKey = 'host';
		} else {
			$hashSql = $this->mDb->SQLDate( $pListHash['period_format'], $this->mDb->SQLIntToTimestamp( 'registration_date' )).' AS `hash_key`,';
			$hashKey = 'period';
		}

		if( !empty( $pListHash['find'] ) && is_string( $pListHash['find'] )) {
			$whereSql  .= empty( $whereSql ) ? ' WHERE ' : ' AND ';
			$whereSql  .= " UPPER( `referer_url` ) LIKE ?";
			$bindVars[] = '%'.strtoupper( $pListHash['find'] ).'%';
			if( empty( $pListHash['timeframe'] ) && !empty( $pListHash['period_format'] ) ) {
				$hashSql = $this->mDb->SQLDate( $pListHash['period_format'], $this->mDb->SQLIntToTimestamp( 'registration_date' )).' AS `hash_key`,';
				$hashKey = 'period';
			}
		}

		$query = "SELECT $hashSql uu.*, sru.`referer_url`
					FROM `".BIT_DB_PREFIX."users_users` uu
					 	LEFT JOIN `".BIT_DB_PREFIX."stats_referer_users_map` srum ON(uu.`user_id`=srum.`user_id`)
						LEFT JOIN  `".BIT_DB_PREFIX."stats_referer_urls` sru ON (sru.`referer_url_id`=srum.`referer_url_id`)
				$whereSql ORDER BY ".$this->mDb->convertSortmode( $pListHash['sort_mode'] );
		if( $rs = $this->mDb->query( $query, $bindVars, -1, $pListHash['offset'], $gBitSystem->isLive() ? 3600 : BIT_QUERY_DEFAULT ) ) {

			while( $row = $rs->fetchRow() ) {
				$key = $row['hash_key'];
				if( $hashKey == 'host' ) {
					$key = 'none';
					if( !empty( $row['referer_url'] ) ) {
						$parseUrl = parse_url( $row['referer_url'] );
						if( !empty( $parseUrl['query'] ) ) {
							parse_str( $parseUrl['query'], $params );
							if( !empty( $params['adurl'] ) ) {
								parse_str( $params['adurl'], $params );
							}
						}
						$key = $parseUrl['host'];
					}
				}
				$ret[$key][$row['user_id']] = $row;
			}
		}

		LibertyContent::postGetList( $pListHash );

		if( $hashKey == 'host' ) {
			uasort( $ret, [ $this, 'sortRefererHash' ] );
		}

		return $ret;
	}

	public function sortRefererHash( $a, $b ) {
		return count( $a ) < count( $b );
	}

	/**
	 * expungeReferers will remove all referers unconditionally
	 *
	 * @return bool TRUE on success, FALSE on failure
	 */
	public function expungeReferers() {
		return $this->mDb->query( "DELETE FROM `" . BIT_DB_PREFIX . "stats_referers`" );
	}

	/**
	 * storeReferer will insert new record in referer table
	 *
	 * @return bool TRUE on success, FALSE on failure - mErrors will contain reason for failure
	 */
	public function storeReferer() {
		global $gBitSystem;

		if( !empty( $_SERVER['HTTP_REFERER'] ) && $parsed = parse_url( $_SERVER['HTTP_REFERER'] )) {
			if( !empty( $parsed["host"] ) && !strstr( $_SERVER["HTTP_HOST"], $parsed["host"] )) {
				if( !empty( $parsed['scheme'] ) ) {
					$now = $gBitSystem->getUTCTime();

					$store = $parsed['scheme'].'://'.$parsed['host'];

					$this->StartTrans();
					$query = "UPDATE `".BIT_DB_PREFIX."stats_referers` SET `hits`=`hits`+1,`last`=? WHERE `referer`=?";
					$this->mDb->query( $query, [ $now, $store ]);

					// if the above didn't affect the db, we know that the entry doesn't exist yet.
					if( !$this->mDb->Affected_Rows() ) {
						$query = "INSERT INTO `".BIT_DB_PREFIX."stats_referers`( `last`, `referer`, `hits` ) VALUES( ?, ?, ? )";
						$this->mDb->query( $query, [ $now, $store, 1 ]);
					}
					$this->CompleteTrans();
				}
			}
		}
		return TRUE;
	}

	/**
	 * addPageview to the pageview count
	 *
	 * @return void
	 */
	public function addPageview() {
		$dayzero = mktime( 0, 0, 0, date( "m" ), date( "d" ), date( "Y" ));
		$this->mDb->StartTrans(); // base method StartTrans will clearFromCache
		$query = "UPDATE `".BIT_DB_PREFIX."stats_pageviews` SET `pageviews`=`pageviews`+1 WHERE `stats_day`=?";
		$this->mDb->query( $query, [ $dayzero ]);
		// if the above didn't affect the db, we know that the entry doesn't exist yet.
		if( !$this->mDb->Affected_Rows() ) {
			$query = "INSERT INTO `".BIT_DB_PREFIX."stats_pageviews`( `pageviews`, `stats_day` ) VALUES( ?, ? )";
			$this->mDb->query( $query, [ 1, $dayzero ]);
		}
		$this->mDb->CompleteTrans();
	}

	/**
	 * registrationStats
	 *
	 * @param array $pPeriod
	 * @return array|bool TRUE on success, FALSE on failure - mErrors will contain reason for failure
	 */
	public function registrationStats( $pPeriodFormat ) {
		global $gBitDbType;

		$sqlPeriod = $this->mDb->SQLDate( $pPeriodFormat, $this->mDb->SQLIntToTimestamp( 'registration_date' ));
		$query = "
			SELECT $sqlPeriod AS period, COUNT(`user_id`)
			FROM `".BIT_DB_PREFIX."users_users`
			GROUP BY( $sqlPeriod )
			ORDER BY COUNT(`user_id`) DESC";
		$ret['per_period'] = $this->mDb->getAssoc( $query );
		$ret['max'] = !empty( $ret['per_period'] ) ? current( $ret['per_period'] ) : 0;
		krsort( $ret['per_period'] );
		return $ret;
	}

	/**
	 * getSiteStats will get a brief overview over the site
	 *
	 * @return array with site stats
	 */
	public function getSiteStats() {
		$ret["started"]   = $this->mDb->getOne( "SELECT MIN(`stats_day`) FROM `".BIT_DB_PREFIX."stats_pageviews`" );
		$ret["days"]      = $this->mDb->getOne( "SELECT COUNT(*) FROM `".BIT_DB_PREFIX."stats_pageviews`" );
		$ret["pageviews"] = $this->mDb->getOne( "SELECT SUM(`pageviews`) FROM `".BIT_DB_PREFIX."stats_pageviews`" );
		$ret["ppd"]       = $ret["days"] ? $ret["pageviews"] / $ret["days"] : 0;
		$ret["bestpvs"]   = $this->mDb->getOne( "SELECT MAX(`pageviews`) FROM `".BIT_DB_PREFIX."stats_pageviews`" );
		$ret["bestday"]   = $this->mDb->getOne( "SELECT `stats_day` FROM `".BIT_DB_PREFIX."stats_pageviews` WHERE `pageviews`=?",[ (int)$ret["bestpvs"] ]);
		$ret["worstpvs"]  = $this->mDb->getOne( "SELECT MIN(`pageviews`) FROM `".BIT_DB_PREFIX."stats_pageviews`" );
		$ret["worstday"]  = $this->mDb->getOne( "SELECT `stats_day` FROM `".BIT_DB_PREFIX."stats_pageviews` WHERE `pageviews`=?",[ (int)$ret["worstpvs"] ]);
		return $ret;
	}

	/**
	 * getContentOverview will get a simple overview based on stats available available in liberty
	 *
	 * @param array $pParamHash
	 * @return array with content type stats
	 */
	public function getContentOverview( $pParamHash = NULL ) {
		global $gLibertySystem;

		if( empty( $pParamHash['sort_mode'] )) {
			$pParamHash['sort_mode'] = 'content_count_desc';
		}

		$query = "
			SELECT lc.`content_type_guid` AS `hash_key`, COUNT( lc.`content_id` ) AS `content_count`, SUM( lch.`hits` ) AS `total_hits`
			FROM `".BIT_DB_PREFIX."liberty_content` lc
			LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content_hits` lch ON( lc.`content_id` = lch.`content_id` )
			GROUP BY lc.`content_type_guid` ORDER BY ".$this->mDb->convertSortmode( $pParamHash['sort_mode'] );
		$ret = $this->mDb->getAssoc( $query );

		return $ret;
	}

	/**
	 * getContentStats will check all available content for the method Object::getStats() and will call and include the data
	 *
	 * @return array with content-specific stats
	 */
	public function getContentStats() {
		global $gLibertySystem;

		$ret = [];
		foreach( $gLibertySystem->mContentTypes as $guid => $type ) {
			if( $typeClass = $gLibertySystem->getContentClassName( $guid )) {
				$object = new $typeClass();
				if( method_exists( $object, 'getStats' )) {
					$ret[$guid] = $object->getStats();
				}
			}
		}

		return $ret;
	}

	/**
	 * getPageviewChartData will fetch all data needed to create a graph with PHPlot
	 *
	 * @param numeric $pDays Number of days we will use to create a graph
	 * @return array for PHPlot graph
	 */
	public function getPageviewChartData( $pDays = 7 ) {
		$now = mktime( 0, 0, 0, date( "m" ), date( "d" ), date( "Y" ));
		$dfrom = 0;
		if( $pDays != 0 ) $dfrom = $now - $pDays * 24 * 60 * 60;

		$query = "SELECT `stats_day`, `pageviews` FROM `".BIT_DB_PREFIX."stats_pageviews` WHERE `stats_day`<=? AND `stats_day`>=? ORDER BY `stats_day` ASC";
		$result = $this->mDb->query( $query,[ ( int )$now, ( int )$dfrom ]);
		$ret = [];
		$n = ceil( $result->numRows() / 20 );
		$i = 0;

		while( $res = $result->fetchRow() ) {
			$data = ( $i % $n == 0 ) ? [
				date( "j M Y", $res["stats_day"] ),
				$res["pageviews"],
			] : [
				"",
				$res["pageviews"],
			];
			$ret[] = $data;
			$i++;
		}

		return $ret;
	}

	/**
	 * getUsageChartData will fetch all data needed to create a graph with PHPlot
	 *
	 * @return array for PHPlot graph
	 */
	public function getUsageChartData() {
		global $gBitSystem, $gLibertySystem;
		$ret['data'][0][] = 'a';
		foreach( $gLibertySystem->mContentTypes as $contentType ) {
			if( $gBitSystem->isPackageActive( $contentType['handler_package'] )) {
				$guid = $contentType['content_type_guid'];
				$hits = $this->mDb->getOne( "
					SELECT SUM(`hits`)
					FROM `".BIT_DB_PREFIX."liberty_content` lc
						LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content_hits` liberty_content_hits
							ON (lc.`content_id` = liberty_content_hits.`content_id`)
					WHERE content_type_guid=?", [ $guid ],
				);
				if( !empty( $hits )) {
					$ret['legend'][] = $gLibertySystem->getContentTypeName( $guid );
					$ret['data'][0][] = $hits;
				}
			}
		}
		return $ret;
	}

	/**
	 * getContentTypeChartData will fetch all data needed to create a graph with PHPlot
	 *
	 * @param string $pContentTypeGuid specify the content_type_guid you want to create a graph for
	 * @return array for PHPlot graph
	 */
	public function getContentTypeChartData( $pContentTypeGuid = '' ) {
		global $gLibertySystem;
		$ret['data'] = [];

		if( in_array( $pContentTypeGuid, array_keys( $gLibertySystem->mContentTypes ))) {
			$query = "
				SELECT `hits`, `title`, `content_type_guid`
				FROM `".BIT_DB_PREFIX."liberty_content` lc
					LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content_hits` liberty_content_hits
						ON (lc.`content_id` = liberty_content_hits.`content_id`)
				WHERE `content_type_guid`=?
				ORDER BY `hits` DESC";
			$result = $this->mDb->query( $query, [ $pContentTypeGuid ], 40 );
			$tmpHash = [];
			// this is needed to ensure all arrays have same size
			while( $res = $result->fetchRow() ) {
				$tmpHash = [
					$res['title'],
					$res['hits'],
				];
			}
			$ret['data'][$pContentTypeGuid] = array_chunk( $tmpHash, 40 );
			$ret['title'] = $gLibertySystem->getContentTypeName( $pContentTypeGuid );
		} else {
			foreach( $gLibertySystem->mContentTypes as $contentType ) {
				$query = "
					SELECT `hits`, `title`, `content_type_guid`
					FROM `".BIT_DB_PREFIX."liberty_content` lc
					LEFT OUTER JOIN `".BIT_DB_PREFIX."liberty_content_hits` liberty_content_hits
					ON (lc.`content_id` = liberty_content_hits.`content_id`)
					WHERE `content_type_guid`=?
					ORDER BY `hits` DESC";
				$result = $this->mDb->query( $query, [ $contentType['content_type_guid'] ], 40 );
				// this is needed to ensure all arrays have same size
				$i = 0;
				$tmpHash = [ null, null ];
				while( $res = $result->fetchRow() ) {
					$tmpHash = [
						$res['title'],
						$res['hits'],
					];
				}
			  $ret['data'][$contentType['content_type_guid']] = array_chunk( $tmpHash, 40 );
			}
			$ret['title'] = 'All Content';
		}
		return $ret;
	}
}