una/modules/boonex/analytics/classes/BxAnalyticsModule.php

<?php defined('BX_DOL') or die('hack attempt');
      /**
       * Copyright (c) UNA, Inc - https://una.io
       * MIT License - https://opensource.org/licenses/MIT
       *
       * @defgroup    Analytics Analytics
       * @ingroup     UnaModules
       *
       * @{
       */
      
      define('BX_ANALYTICS_SYSTEM', 'system');
      define('BX_ANALYTICS_TOP_BY_LIKES', 'top_by_likes');
      define('BX_ANALYTICS_TOP_BY_VIEWS', 'top_by_views');
      define('BX_ANALYTICS_CONTENT_TOTAL', 'content_total');
      define('BX_ANALYTICS_CONTENT_SPEED', 'content_speed');
      define('BX_ANALYTICS_MOST_FOLLOWED_PROFILES', 'top_by_followers');
      define('BX_ANALYTICS_MOST_ACTIVE_PROFILES', 'top_by_activity');

      class BxAnalyticsModule extends BxDolModule
      {
          protected $aColors = array('#3366CC', '#DC3912', '#FF9900', '#109618', '#990099');
          
          function __construct(&$aModule)
          {
              parent::__construct($aModule);
          }
          
          /**
           * Service methods
           */
          
          /**
           * @page service Service Calls
           * @section bx_analytics Analytics
           * @subsection bx_analytics-other Other
           * @subsubsection bx_analytics get_canvas
           * 
           * @code bx_srv('bx_analytics', 'get_canvas', [...]); @endcode
           * 
           * Get canvas  
           * 
           * @return an html. 
           * 
           * @see BxAnalyticsModule::serviceGetCanvas
           */
          /** 
           * @ref bx_analytics-get_canvas "get_canvas"
           */
          public function serviceGetCanvas()
          {
              return $this->_oTemplate->getCanvas();
          }
          
          /**
           * @page service Service Calls
           * @section bx_analytics Analytics
           * @subsection bx_analytics-other Other
           * @subsubsection bx_analytics get_modules
           * 
           * @code bx_srv('bx_analytics', 'get_modules', [...]); @endcode
           * 
           * Get modules list  
           * 
           * @return an html. 
           * 
           * @see BxAnalyticsModule::serviceGetModules
           */
          /** 
           * @ref bx_analytics-get_modules "get_modules"
           */
          public function serviceGetModules()
          {
              $aResult = array();
              $aResult2 = array();
              $aResult[BX_ANALYTICS_SYSTEM] = _t('_bx_analytics_system_text');
              $BxDolModuleQuery = BxDolModuleQuery::getInstance();
              $aModules = $BxDolModuleQuery->getModulesBy(array('type' => 'modules', 'active' => 1));
              foreach($aModules as $aModule){
                  $oModule = BxDolModule::getInstance($aModule['name']);
                  if($oModule instanceof iBxDolContentInfoService){
                      $aResult[$aModule['name']] = $aModule['title'];
                  }
              }
              return array_merge($aResult, $aResult2);
          }
          
           /**
           * Action methods
           */
          
          public function actionGetReports($sModuleName)
          {
              header('Content-Type: application/json');
             
              $aSystemsVote = BxDolVote::getSystems();
              $aRv = array();
              if ($sModuleName == BX_ANALYTICS_SYSTEM){
                  $aRv[BX_ANALYTICS_TOP_BY_LIKES] = _t('_bx_analytics_type_top_contents_by_likes');
                  $aRv[BX_ANALYTICS_TOP_BY_VIEWS] = _t('_bx_analytics_type_top_by_views');
                  $aRv[BX_ANALYTICS_CONTENT_TOTAL] = _t('_bx_analytics_type_accounts_growth');
                  $aRv[BX_ANALYTICS_CONTENT_SPEED] = _t('_bx_analytics_type_accounts_speed');
              }
              else{
                  $oModule = BxDolModule::getInstance($sModuleName);
                  
                  if(BxDolRequest::serviceExists($sModuleName, 'act_as_profile') && BxDolService::call($sModuleName, 'act_as_profile') == true){
                      $aRv[BX_ANALYTICS_MOST_FOLLOWED_PROFILES] = _t('_bx_analytics_type_most_followed_profiles');
                      $aRv[BX_ANALYTICS_MOST_ACTIVE_PROFILES] = _t('_bx_analytics_type_most_active_profiles');
                  }
                  
                  if(isset($oModule->_oConfig->CNF['OBJECT_VOTES']) && isset($aSystemsVote[$oModule->_oConfig->CNF['OBJECT_VOTES']])){
                      $aRv[BX_ANALYTICS_TOP_BY_LIKES] = _t('_bx_analytics_type_top_contents_by_likes');
                  }
                  
                  if(isset($oModule->_oConfig->CNF['OBJECT_VIEWS'])){
                      $aRv[BX_ANALYTICS_TOP_BY_VIEWS] = _t('_bx_analytics_type_top_by_views');
                  }
                  
                  $aRv[BX_ANALYTICS_CONTENT_TOTAL] = _t('_bx_analytics_type_content_growth');
                  $aRv[BX_ANALYTICS_CONTENT_SPEED] = _t('_bx_analytics_type_content_speed');
              }
              echo json_encode($aRv);
          }
          
          public function actionGetReportsData($sModuleName, $sReportName, $sDateFrom, $sDateTo)
          {
              header('Content-Type: application/json');
              
              $iDateFrom = strtotime($sDateFrom);
              $iDateTo = strtotime($sDateTo);
              $sType = "bar";
              $bIsTimeX = false;
              $iMinValueY = 0;
              $iMaxValueY = 0;
              $bDefaultFillData = true;
              $aValues = array('labels' => array(), 'values' => array(array('legend' => '', 'data' => array())), 'links' => array(), 'strings' => array(0 => _t('_bx_analytics_txt_item'), 1 => _t('_bx_analytics_txt_value')));
   
              if ($sModuleName != BX_ANALYTICS_SYSTEM){
                  $oModule = BxDolModule::getInstance($sModuleName);
                  $aValues['strings'][0] = $oModule->_aModule['title'];
                  $aValues['strings'][1] = _t('_bx_analytics_type_' . $sReportName . '_label');
              }
              else{
                  $aValues['strings'][0] = _t('_bx_analytics_txt_total_content');
                  $aValues['strings'][1] = _t('_bx_analytics_type_' . $sReportName . '_label');
              }
              
              switch ($sReportName) {
                  case BX_ANALYTICS_CONTENT_TOTAL:
                  case BX_ANALYTICS_CONTENT_SPEED:
                      $sType = "line";
                      $bIsTimeX = true;
                      $sTableName = '';
                      $aValues['strings'][0] = _t('_bx_analytics_txt_date');
                      $bDefaultFillData = false;
                      if ($sModuleName != BX_ANALYTICS_SYSTEM){
                          $oModule = BxDolModule::getInstance($sModuleName);
                          if (isset($oModule->_oConfig->CNF['TABLE_ENTRIES']))
                              $sTableName = $oModule->_oConfig->CNF['TABLE_ENTRIES'];
                          $aValues['strings'][1] = $oModule->_aModule['title'] . ($sReportName == BX_ANALYTICS_CONTENT_TOTAL ? _t('_bx_analytics_txt_total_count') : _t('_bx_analytics_txt_count'));
                      }
                      else{
                          $sTableName = 'sys_accounts';
                          $aValues['strings'][1] = _t('_bx_analytics_txt_accounts') . ($sReportName == BX_ANALYTICS_CONTENT_TOTAL ? _t('_bx_analytics_txt_total_count') : _t('_bx_analytics_txt_count'));
                      }
                      if (isset($oModule) && isset($oModule->_oConfig->CNF['FIELD_ADDED']))
                          $sColumnAdded = $oModule->_oConfig->CNF['FIELD_ADDED'];
                      else
                          $sColumnAdded = 'added';
                      if ($sColumnAdded != ''){
                          $aData = $this->_oDb->getGrowth($sTableName, $sColumnAdded, $iDateFrom, $iDateTo);
                          $iValuePrev = $this->_oDb->getGrowthInitValue($sTableName, $sColumnAdded, $iDateFrom);
                          $aTmpDates = array();
                          foreach ($aData as $aValue) {
                              $sX = $aValue['period'];
                              $aTmpDates[$sX] = $aValue['count'];
                          }
                          for ($i = $iDateFrom; $i < $iDateTo ; $i = $i + 86400 ){
                              $sX = date('Y-m-d', $i);
                              if (!array_key_exists($sX, $aTmpDates)){
                                array_push($aValues['values'][0]['data'], array('x' => $sX, 'y' => $sReportName == BX_ANALYTICS_CONTENT_TOTAL ? $iValuePrev : 0));
                              }
                              else{
                                  array_push($aValues['values'][0]['data'], array('x' => $sX, 'y' => $sReportName == BX_ANALYTICS_CONTENT_TOTAL ? $iValuePrev : $aTmpDates[$sX]));
                                  $iValuePrev += $aTmpDates[$sX];
                              }
                              if ($sReportName == BX_ANALYTICS_CONTENT_TOTAL){
                                  if ($iValuePrev > $iMaxValueY)
                                      $iMaxValueY = $iValuePrev;
                              }
                              else{
                                  if (array_key_exists($sX, $aTmpDates) && $aTmpDates[$sX] > $iMaxValueY)
                                      $iMaxValueY = $aTmpDates[$sX];
                              }
                          }
                      }
                      break;
                  
                  case BX_ANALYTICS_TOP_BY_LIKES:
                      $bDefaultFillData = false;
                      $sRv = $this->getViewsOrVotes(BxDolVote::getSystems(), 'OBJECT_VOTES', $sModuleName, $iDateFrom, $iDateTo, $aValues, $iMaxValueY, $iMinValueY);
                      break;
                  
                  case BX_ANALYTICS_TOP_BY_VIEWS:
                      $bDefaultFillData = false;
                      $sRv = $this->getViewsOrVotes(BxDolView::getSystems(), 'OBJECT_VIEWS', $sModuleName, $iDateFrom, $iDateTo, $aValues, $iMaxValueY, $iMinValueY);
                      break;
                  
                  case BX_ANALYTICS_MOST_FOLLOWED_PROFILES:
                      $oModule = BxDolModule::getInstance($sModuleName);
                      $aData = $this->_oDb->getMostFollowedProfiles($sModuleName, $iDateFrom, $iDateTo);
                      break;
                  
                  case BX_ANALYTICS_MOST_ACTIVE_PROFILES:
                      $aData = array();
                      $oModule = BxDolModule::getInstance($sModuleName);
                      $aTmp = $this->getSelectedModules();
                      foreach($aTmp[0] as $sContentModule){
                          $oContentModule = BxDolModule::getInstance($sContentModule);
                          if ($oContentModule && isset($oContentModule->_oConfig->CNF['TABLE_ENTRIES']) && isset($oContentModule->_oConfig->CNF['FIELD_AUTHOR'])){
                              $sContentTable = $oContentModule->_oConfig->CNF['TABLE_ENTRIES'];
                              $sColumnAuthor = $oContentModule->_oConfig->CNF['FIELD_AUTHOR'];
                              $sColumnAdded = $oContentModule->_oConfig->CNF['FIELD_ADDED'];
                              if (!empty($sContentTable) && !empty($sColumnAuthor) && !empty($sColumnAdded) && (!BxDolRequest::serviceExists($sContentModule, 'act_as_profile') || BxDolService::call($sContentModule, 'act_as_profile') == false)){
                                  $aData1 = $this->_oDb->getMostActiveProfiles($sModuleName, $sContentModule, $sContentTable, $sColumnAuthor, $sColumnAuthor, $sColumnAdded, $iDateFrom, $iDateTo);
                                  foreach($aData1 as $aTmp3){
                                      if (array_key_exists($aTmp3['object_id'], $aData))
                                          $aData[$aTmp3['object_id']]['value'] += $aTmp3['value'];
                                      else
                                          $aData[$aTmp3['object_id']] = $aTmp3;
                                  }
                              }
                          }
                      }
                      $aData = $this->sortArrayOfArraysAndSlice($aData, 'value', intval(getParam('bx_analytics_items_count')));
                      break;
              }
              
              if ($bDefaultFillData){
                  foreach ($aData as $aValue) {
                      array_push($aValues['labels'], $this->getItemName($oModule->serviceGetTitle($aValue['object_id'])));
                      array_push($aValues['values'][0]['data'], $aValue['value']);
                      array_push($aValues['links'], $oModule->serviceGetLink($aValue['object_id']));
                      if ($aValue['value'] > $iMaxValueY)
                          $iMaxValueY = $aValue['value'];
                  }
              }
              
              $sRv = '{"type": "' . $sType . '", "data": {"labels":' . json_encode($aValues['labels']) . ',"datasets": [';
              for($i = 0; $i < count($aValues['values']); $i++){
                  $sRv .= '{"label": "' . $aValues['values'][$i]['legend'] . '", "fill": false, "backgroundColor": "' . $this->aColors[$i] . '","borderColor": "' . $this->aColors[$i] . '","borderWidth": 1,"data": ' . json_encode($aValues['values'][$i]['data']) . '}';
                  if ($i != count($aValues['values']) - 1)
                      $sRv .= ',';
              }
              $sRv .= ']}, "options": {"legend": {"position": "bottom" ' . (count($aValues['values']) == 1 ? ', "display": false' : '') . '}, "scales": {';
              
              $iMaxValueY = ceil($iMaxValueY * 1.1);
              $sRv .= '"yAxes": [{"ticks": { "max": ' . $iMaxValueY . ',"min": ' . $iMinValueY . ', "stepSize": ' . $this->getStep($iMinValueY, $iMaxValueY) . ', "autoSkip": true }}]';
              
              if ($bIsTimeX){
                  $sUnit = 'day';
                  $iInterval = ($iDateTo - $iDateFrom) / 86400;
                  if ($iInterval > 50)
                      $sUnit = 'week';
                  if ($iInterval > 100)
                      $sUnit = 'month';
                  $sRv .= ', "xAxes": [{"type": "time", "time": {"tooltipFormat": "DD.MM.YYYY", "unit" : "' . $sUnit . '"}, "ticks": {"autoSkip": true}, "display": "true", "distribution": "linear" }]';
              }
              else{
                  $sRv .= ', "xAxes": [{"ticks": {"autoSkip": false}, "display": "true" }]';
              }
              $sRv .= '}}';

              if (count($aValues['links']) > 0)
                  $sRv .= ', "links": ' . json_encode($aValues['links']);
              $sRv .= ', "strings": ' . json_encode($aValues['strings']);
              $sRv .= '}';
              echo $sRv;
          }
          
          public function getSelectedModules()
          {
              $aModulesList = $this->serviceGetModules();
              $aModules = array_keys($aModulesList);
              $sModulesDisabled = explode(',', getParam('bx_analytics_modules_disabled'));
              return array(array_diff($aModules, $sModulesDisabled), $aModulesList);
          }

          private function getViewsOrVotes($aSystems, $sSystem, $sModuleName, $iDateFrom, $iDateTo, &$aValues, &$iMaxValueY, &$iMinValueY)
          {
              $aData = array();
              if ($sModuleName != BX_ANALYTICS_SYSTEM){
                  $oModule = BxDolModule::getInstance($sModuleName);
                  $sSystem = $oModule->_oConfig->CNF['OBJECT_VIEWS'];
                  if(isset($aSystems[$sSystem]))
                      $aData = $this->_oDb->getTopContentByLikes($sModuleName, $aSystems[$sSystem]['table_track'], $iDateFrom, $iDateTo);
              }
              else{
                  $aTmp = $this->getSelectedModules();
                  foreach ($aTmp[0] as $sModule) {
                      if ($sModule != BX_ANALYTICS_SYSTEM){
                          $oModule = BxDolModule::getInstance($sModule);
                          if (isset($oModule->_oConfig->CNF['OBJECT_VIEWS'])){
                              $sSystem = $oModule->_oConfig->CNF['OBJECT_VIEWS'];
                              if(isset($aSystems[$sSystem])){
                                  $aData1 = $this->_oDb->getTopContentByLikes($sModule, $aSystems[$sSystem]['table_track'], $iDateFrom, $iDateTo);
                                  $aData = array_merge($aData, $aData1);
                              }
                          }
                      }
                  }
                  $aData = $this->sortArrayOfArraysAndSlice($aData, 'value', intval(getParam('bx_analytics_items_count')));
              }
              foreach ($aData as $aValue) {
                  $oModule = BxDolModule::getInstance($aValue['module']);
                  array_push($aValues['labels'], $this->getItemName($oModule->serviceGetTitle($aValue['object_id'])));
                  array_push($aValues['values'][0]['data'], $aValue['value']);
                  array_push($aValues['links'], $oModule->serviceGetLink($aValue['object_id']));
                  if ($aValue['value'] > $iMaxValueY)
                      $iMaxValueY = $aValue['value'];
              }
          }
          
          private function getStep($iMin, $iMax)
          {
              $iCount = 10;
              return ceil(($iMax - $iMin) / $iCount);
          }
          
          private function sortArrayOfArraysAndSlice($aArr, $sFld, $Count)
          {
              $aDataSort = array();
              foreach ($aArr as $sKey => $oRow)
              {
                  $aDataSort[$sKey] = $oRow[$sFld];
              }
              array_multisort($aDataSort, SORT_DESC, $aArr);
              return array_slice($aArr, 0, $Count);
          }
          
          private function getItemName($sString)
          {
              $sString = strip_tags($sString);
              if ($sString == ''){
                  $sString = _t('_bx_analytics_txt_empty_title_item');
              }
              return $sString;
          }
      }

      /** @} */