File indexing completed on 2024-06-16 05:27:01

 <?php
 
 /**
  *  ocs-webserver
  *
  *  Copyright 2016 by pling GmbH.
  *
  *    This file is part of ocs-webserver.
  *
  *    This program is free software: you can redistribute it and/or modify
  *    it under the terms of the GNU Affero General Public License as
  *    published by the Free Software Foundation, either version 3 of the
  *    License, or (at your option) any later version.
  *
  *    This program is distributed in the hope that it will be useful,
  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  *    GNU Affero General Public License for more details.
  *
  *    You should have received a copy of the GNU Affero General Public License
  *    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  **/
 class Default_Model_DbTable_ConfigStore extends Local_Model_Table
 {
 
     const CACHE_STORES_CATEGORIES = 'stores_categories_list';
     const CACHE_STORES_CONFIGS = 'stores_configs_list';
     const CACHE_STORE_CONFIG = 'store_config';
     const CACHE_STORES_CONFIGS_BY_ID = 'stores_configs_id_list';
 
     protected $_keyColumnsForRow = array('store_id');
     protected $_key = 'store_id';
     protected $_name = "config_store";
 
     /**
      * @param null $id
      *
      * @return array
      * @throws Zend_Db_Select_Exception
      */
     public function fetchHostnamesForJTable($id = null)
     {
         $select = $this->select()->from($this->_name)->columns('host')->group('host');
 
         $resultRows = $this->fetchAll($select);
 
         $resultForSelect = array();
         foreach ($resultRows as $row) {
             $resultForSelect[] = array('DisplayText' => $row['host'], 'Value' => $row['store_id']);
         }
 
         return $resultForSelect;
     }
 
     /**
      * @param bool $clearCache
      * @return array
      * @throws Zend_Cache_Exception
      * @throws Zend_Exception
      */
     public function fetchAllStoresAndCategories($clearCache = false)
     {
         /** @var Zend_Cache_Core $cache */
         $cache = Zend_Registry::get('cache');
         $cacheName = self::CACHE_STORES_CATEGORIES;
 
         if ($clearCache) {
             $cache->remove($cacheName);
         }
 
         if (false == ($configArray = $cache->load($cacheName))) {
             $resultSet = $this->queryAllStoresAndCategories();
             $configArray = $this->createArrayAllStoresAndCategories($resultSet);
             $cache->save($configArray, $cacheName, array(), 28800);
         }
 
         return $configArray;
     }
 
     /**
      * @return array
      */
     private function queryAllStoresAndCategories()
     {
         $sql = "
                 SELECT
                     `config_store`.`host`,
                     `config_store_category`.`store_id`,
                     `config_store_category`.`project_category_id`
                 FROM
                     `config_store`
                 JOIN
                     `config_store_category` ON `config_store`.`store_id` = `config_store_category`.`store_id`
                 JOIN
                     `project_category` ON `project_category`.`project_category_id` = `config_store_category`.`project_category_id`
                 ORDER BY `config_store`.`host`,`config_store_category`.`order`,`project_category`.`title`;
         ";
         $resultSet = $this->_db->fetchAll($sql);
 
         return $resultSet;
     }
 
     /**
      * @param array $resultSetConfig
      *
      * @return array
      */
     private function createArrayAllStoresAndCategories($resultSetConfig)
     {
         $result = array();
         foreach ($resultSetConfig as $element) {
             $result[$element['host']][] = $element['project_category_id'];
         }
         array_walk($result, create_function('&$v', '$v = (count($v) == 1)? array_pop($v): $v;'));
 
         return $result;
     }
 
     /**
      * @return array
      * @throws Zend_Cache_Exception
      * @throws Zend_Exception
      */
     public function fetchDomainConfigIdList()
     {
         if (Zend_Registry::isRegistered('cache')) {
             /** @var Zend_Cache_Core $cache */
             $cache = Zend_Registry::get('cache');
             $cacheName = __FUNCTION__;
             if (false == ($configArray = $cache->load($cacheName))) {
                 $resultSet = $this->queryDomainConfigIdList();
                 $configArray = $this->createDomainStoreIdArray($resultSet);
                 $cache->save($configArray, $cacheName);
             }
         } else {
             $resultSet = $this->queryDomainConfigIdList();
             $configArray = $this->createDomainStoreIdArray($resultSet);
         }
 
         return $configArray;
     }
 
     /**
      * @return array
      */
     private function queryDomainConfigIdList()
     {
         $sql = "SELECT `host`, `config_id_name` FROM `config_store` ORDER BY `host`;";
         $resultSet = $this->_db->fetchAll($sql);
 
         return $resultSet;
     }
 
     /**
      * @param array $resultSetConfig
      *
      * @return array
      */
     private function createDomainStoreIdArray($resultSetConfig)
     {
         $result = array();
         foreach ($resultSetConfig as $element) {
             $result[$element['host']] = $element['config_id_name'];
         }
 
         return $result;
     }
 
     /**
      * @return array
      * @throws Zend_Cache_Exception
      * @throws Zend_Exception
      */
     public function fetchDomainsStoreNameList()
     {
         if (Zend_Registry::isRegistered('cache')) {
             /** @var Zend_Cache_Core $cache */
             $cache = Zend_Registry::get('cache');
             $cacheName = __FUNCTION__;
             if (false == ($configArray = $cache->load($cacheName))) {
                 $resultSet = $this->queryDomains();
                 $configArray = $this->createDomainsArray($resultSet);
                 $cache->save($configArray, $cacheName);
             }
         } else {
             $resultSet = $this->queryDomains();
             $configArray = $this->createDomainsArray($resultSet);
         }
 
         return $configArray;
     }
 
     /**
      * @return array
      */
     private function queryDomains()
     {
         $sql = "SELECT `host`, `name` FROM `config_store` ORDER BY `order`;";
         $resultSet = $this->_db->fetchAll($sql);
 
         return $resultSet;
     }
 
     /**
      * @param array $resultSetConfig
      *
      * @return array
      */
     private function createDomainsArray($resultSetConfig)
     {
         $result = array();
         foreach ($resultSetConfig as $element) {
             $result[$element['host']] = $element['name'];
         }
 
         return $result;
     }
 
     /**
      * @return array
      */
     public function fetchDomainObjects()
     {
         $sql = "SELECT *  FROM `config_store` ORDER BY `order`;";
         $resultSet = $this->_db->fetchAll($sql);
 
         return $resultSet;
     }
 
     /**
      * @return array
      */
     public function fetchDomainObjectsByName($name)
     {
         $sql = "SELECT * FROM `config_store` WHERE `name`='" . $name . "'";
         $resultSet = $this->_db->fetchAll($sql);
 
         return array_pop($resultSet);
     }
 
 
     public function deleteId($dataId)
     {
         $sql = "DELETE FROM `config_store` WHERE {$this->_key} = ?";
         $this->_db->query($sql, $dataId)->execute();
 //        return $this->delete(array('store_id = ?' => (int)$dataId));
     }
 
     public function delete($where)
     {
         $where = parent::_whereExpr($where);
 
         /**
          * Build the DELETE statement
          */
         $sql = "UPDATE " . parent::getAdapter()->quoteIdentifier($this->_name,
                 true) . " SET `deleted_at` = NOW() " . (($where) ? " WHERE $where" : '');
 
         /**
          * Execute the statement and return the number of affected rows
          */
         $stmt = parent::getAdapter()->query($sql);
         $result = $stmt->rowCount();
 
         return $result;
     }
 
     /**
      * @param bool $clearCache
      *
      * @return array
      * @throws Zend_Cache_Exception
      * @throws Zend_Exception
      */
     public function fetchAllStoresConfigArray($clearCache = false)
     {
         /** @var Zend_Cache_Core $cache */
         $cache = Zend_Registry::get('cache');
         $cacheName = self::CACHE_STORES_CONFIGS;
 
         if ($clearCache) {
             $cache->remove($cacheName);
         }
 
         if (false == ($configArray = $cache->load($cacheName))) {
             $resultSet = $this->queryStoreConfigArray();
             $configArray = $this->createStoreConfigArray($resultSet);
             $cache->save($configArray, $cacheName, array(), 28800);
         }
 
         return $configArray;
     }
 
     /**
      * @return array
      */
     private function queryStoreConfigArray()
     {
         $sql = "SELECT * FROM `config_store` ORDER BY `order`;";
         $resultSet = $this->_db->fetchAll($sql);
 
         return $resultSet;
     }
 
     /**
      * @param array  $resultSetConfig
      * @param string $key
      *
      * @return array
      */
     private function createStoreConfigArray($resultSetConfig, $key = 'host')
     {
         $result = array();
         foreach ($resultSetConfig as $element) {
             $result[$element[$key]] = $element;
         }
 
         return $result;
     }
 
     /**
      * @param bool $clearCache
      *
      * @return array
      * @throws Zend_Cache_Exception
      * @throws Zend_Exception
      */
     public function fetchAllStoresConfigByIdArray($clearCache = false)
     {
         /** @var Zend_Cache_Core $cache */
         $cache = Zend_Registry::get('cache');
         $cacheName = self::CACHE_STORES_CONFIGS_BY_ID;
 
         if ($clearCache) {
             $cache->remove($cacheName);
         }
 
         if (false == ($configArray = $cache->load($cacheName))) {
             $resultSet = $this->queryStoreConfigArray();
             $configArray = $this->createStoreConfigArray($resultSet, 'store_id');
             $cache->save($configArray, $cacheName, array(), 28800);
         }
 
         return $configArray;
     }
 
     public function fetchConfigForStore($store_id, $clearCache = false)
     {
         /** @var Zend_Cache_Core $cache */
         $cache = Zend_Registry::get('cache');
         $cacheName = self::CACHE_STORE_CONFIG . "_{$store_id}";
 
         if ($clearCache) {
             $cache->remove($cacheName);
         }
 
         if (false == ($config = $cache->load($cacheName))) {
             $config = $this->queryStoreConfig($store_id);
             $cache->save($config, $cacheName, array(), 28800);
         }
 
         return $config;
     }
 
     private function queryStoreConfig($store_id)
     {
         $sql = "SELECT * FROM `config_store` WHERE `store_id` = :store;";
         $resultSet = $this->_db->fetchRow($sql, array('store' => (int)$store_id));
 
         return $resultSet;
     }
 
     /**
      * @return stdClass|bool
      */
     public function fetchDefaultStoreId()
     {
         $sql = "SELECT `store_id`, `package_type` FROM `config_store` WHERE `default` = 1;";
         $resultSet = $this->_db->fetchRow($sql);
         if (count($resultSet) > 0) {
             return (object)$resultSet;
         } else {
             return false;
         }
     }
 
 }