. * * @author D3 Data Development - Daniel Seifert * @link http://www.oxidmodule.com */ class d3usersonline extends oxbase { protected $_sCoreTbl = 'd3usersonline'; protected $_sClassName = 'd3usersonline'; protected $_remoteAddr = null; protected $_httpClientIp = null; protected $_httpXForwardedFor = null; protected $_httpXForwarded = null; protected $_httpForwardedFor = null; protected $_httpForwarded = null; protected $_httpVia = null; protected $_httpXComingFrom = null; protected $_httpComingFrom = null; protected $_iDeleteThreshold = 30; // Zeitdifferenz für Löschaufträge /** * constructor */ public function __construct() { parent::__construct(); $this->init('d3usersonline'); } /** * @param $iExpTime */ public function clearOldItems($iExpTime) { startProfile(__METHOD__); $iTime = time(); $iLastDeleteTime = oxRegistry::getConfig()->getShopConfVar('iLastDeleteTime', null, 'd3usersonline'); if ($iTime > $iLastDeleteTime + $this->_iDeleteThreshold) { $iExptime = $iTime - $iExpTime; oxDb::getDb()->Execute("delete from " . $this->getViewName() . " where timevisit < $iExptime"); oxRegistry::getConfig()->saveShopConfVar('int', 'iLastDeleteTime', $iTime, null, 'd3usersonline'); } stopProfile(__METHOD__); } /** * @return array */ public function getUserCount($blGroupByClass = false) { startProfile(__METHOD__); if ($blGroupByClass) { $sSelect = "SELECT count(oxid) AS counter, oxclass FROM " . $this->getViewName() . " GROUP BY oxclass ORDER BY counter DESC"; } else { $sSelect = "select count(oxid) AS counter, oxclass, oxpage from ". $this->getViewName()." GROUP BY oxclass, oxpage ORDER BY counter desc"; } $aRecords = oxDb::getDb(oxDb::FETCH_MODE_ASSOC)->getAll($sSelect); $iAllCounter = 0; $aUserClasses = array(); if ($aRecords && is_array($aRecords) && count($aRecords)) { foreach ($aRecords as $aRecord) { $aRecord = array_change_key_case($aRecord, CASE_UPPER); $oTmp = new stdClass; $oTmp->classname = $aRecord['OXCLASS']; $oTmp->page = $aRecord['OXPAGE']; $oTmp->counter = $aRecord['COUNTER']; $iAllCounter += $aRecord['COUNTER']; $aUserClasses['classes'][] = $oTmp; } } $aUserClasses['all'] = $iAllCounter; stopProfile(__METHOD__); return $aUserClasses; } public function setActTimeVisit() { startProfile(__METHOD__); $this->setId($this->_getIPHash()); $aValues = array( 'timevisit' => time(), 'oxclass' => oxRegistry::getConfig()->getActiveView()->getClassName(), 'oxpage' => $this->getPageIdent(), ); $this->assign($aValues); $this->save(); stopProfile(__METHOD__); } /** * @return null|string */ public function getPageIdent() { switch (strtolower(oxRegistry::getConfig()->getActiveView()->getClassName())) { case 'details': case 'oxwarticledetails': if (($oView = oxRegistry::getConfig()->getActiveView()) && method_exists($oView, 'getProduct') ) { return $oView->getProduct()->getFieldData('oxtitle'); } return null; case 'alist': case 'manufacturerlist': case 'vendorlist': if (($oView = oxRegistry::getConfig()->getActiveView()) && method_exists($oView, 'getTitle') ) { return $oView->getTitle(); } return null; case 'search': return oxRegistry::getConfig()->getRequestParameter('searchparam'); case 'content': if (($oView = oxRegistry::getConfig()->getActiveView()) && method_exists($oView, 'getContent') ) { return $oView->getContent()->getFieldData('oxtitle'); } return null; case 'tag': if (($oView = oxRegistry::getConfig()->getActiveView()) && method_exists($oView, 'getTag') ) { return $oView->getTag(); } return null; } return null; } /** * @return string */ protected function _getIPHash() { return md5($this->_getTrueIP()); } /** * @return null|string */ protected function _getTrueIP() { $sDirectIp = ''; $this->_getIpData('_remoteAddr', 'REMOTE_ADDR'); $this->_getIpData('_httpClientIp', 'HTTP_CLIENT_IP'); $this->_getIpData('_httpXForwardedFor', 'HTTP_X_FORWARDED_FOR'); $this->_getIpData('_httpXForwarded', 'HTTP_X_FORWARDED'); $this->_getIpData('_httpForwardedFor', 'HTTP_FORWARDED_FOR'); $this->_getIpData('_httpForwarded', 'HTTP_FORWARDED'); $this->_getIpData('_httpVia', 'HTTP_VIA'); $this->_getIpData('_httpXComingFrom', 'HTTP_X_COMING_FROM'); $this->_getIpData('_httpComingFrom', 'HTTP_COMING_FROM'); // Gets the default ip sent by the user if (!empty($this->_remoteAddr)) { $sDirectIp = $this->_remoteAddr; } // Gets the proxy ip sent by the user if (!empty($this->_httpXForwardedFor)) { $sProxyIp = $this->_httpXForwardedFor; } elseif (!empty($this->_httpXForwarded)) { $sProxyIp = $this->_httpXForwarded; } elseif (!empty($this->_httpForwardedFor)) { $sProxyIp = $this->_httpForwardedFor; } elseif (!empty($this->_httpForwarded)) { $sProxyIp = $this->_httpForwarded; } elseif (!empty($this->_httpVia)) { $sProxyIp = $this->_httpVia; } elseif (!empty($this->_httpXComingFrom)) { $sProxyIp = $this->_httpXComingFrom; } elseif (!empty($this->_httpComingFrom)) { $sProxyIp = $this->_httpComingFrom; } // Returns the true IP if it has been found, else ... if (empty($sProxyIp)) { // True IP without proxy return $sDirectIp; } else { $blIsIp = preg_match('@^([0-9]{1,3}.){3,3}[0-9]{1,3}@', $sProxyIp, $aMatches); if ($blIsIp && (count($aMatches) > 0)) { // True IP behind a proxy return $aMatches[0]; } else { if (empty($this->_httpClientIp)) { // Can't define IP: there is a proxy but we don't have // information about the true IP return "(unbekannt) " . $sProxyIp; } else { // better than nothing return $this->_httpClientIp; } } } } /** * @param $sTargetVarName * @param $sDataName */ protected function _getIpData($sTargetVarName, $sDataName) { if (empty($this->{$sTargetVarName})) { if (!empty($_SERVER) && isset($_SERVER[$sDataName])) { $this->{$sTargetVarName} = $_SERVER[$sDataName]; } elseif (!empty($_ENV) && isset($_ENV[$sDataName])) { $this->{$sTargetVarName} = $_ENV[$sDataName]; } elseif (@getenv($sDataName)) { $this->{$sTargetVarName} = getenv($sDataName); } } } }