欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  php教程

hecart 高性能电子购物车-升级版

程序员文章站 2022-05-17 18:06:05
...
 hoojar studio
 *
 * 模块: wcore/speed.php
 * 简述: 生成静态文件或缓冲MEMCACHED
 * 作者: woods·zhang  ->  hoojar@163.com
 * 版本: $Id: speed.php 1 2012-11-20 05:55:12Z Administrator $
 * 版权: Copyright 2006-2013 慧佳工作室拥有此系统所有版权等知识产权
 *
 */
class wcore_speed
{
	/**
	 * 采用哪种类型加速
	 *
	 * @var string {file:文件类型 mem:Memcached}
	 */
	private $_type = 'file';

	/**
	 * 生成哪个类型的文件
	 *
	 * @var string 此参数只有type=file才生效
	 */
	private $_ext = '.html';

	/**
	 * 缓冲在哪个目录当中
	 *
	 * @var string 如果type=file此处才生效
	 */
	private $_floder = '';

	/**
	 * 过滤哪些GET字段
	 *
	 * @var string 需要过滤的内容
	 */
	private $_filter = ',nocache,error,local,';

	/**
	 * MEM缓冲对象
	 *
	 * @var wcore_mem MEM缓冲对象
	 */
	private $_mem = null;

	/**
	 * 当前页面唯一编号 page unique id
	 *
	 * @var string 如果puid为空则代表不启动加速服务
	 */
	private $_puid = '';

	/**
	 * 加速数据有效期(单位分钟)
	 *
	 * @var int 默认为10分钟
	 */
	private $_expire = 10;

	/**
	 * 构造函数
	 *
	 * @param string $type          采用哪种类型加速{file:文件类型 mem:Memcached}
	 * @param int    $expire        加速数据有效期(单位分钟)默认为0是为了采用全局设置的有效期
	 * @param string $puid          缓冲时的唯一编号
	 * @param string $floder        如果type=file生效,缓冲在哪个目录当中
	 * @param string $ext           如果type=file生效,生成哪个类型的文件
	 */
	public function __construct($type = 'file', $expire = 0, $puid = '', $floder = '', $ext = '.html')
	{
		/**
		 * 判断是否启动加速服务,当有POST数据时则不加速内容或者是否设定了启动加速内容常量且为真
		 */
		if (!empty($_POST) || (defined('SPEED_DATA') && !SPEED_DATA))
		{
			return;
		}

		/**
		 * 初始化相关数据
		 */
		$this->_ext    = empty($ext) ? $this->_ext : $ext;
		$this->_type   = (strtolower($type) == 'mem') ? 'mem' : 'file';
		$this->_floder = empty($floder) ? $_SERVER['DOCUMENT_ROOT'] : $floder;
		$expire        = intval($expire); //加速数据有效期(单位分钟)
		$this->_expire = ($expire > 0) ? $expire : (defined('SPEED_DATA_EXPIRE') ? SPEED_DATA_EXPIRE : 10);

		/**
		 * 缓冲时的唯一编号
		 */
		if (!empty($puid))
		{
			$this->_puid = $puid;
		}
		else
		{
			$this->generate_puid(); //生成页面唯一页面编号
		}

		/**
		 * 判断采用哪种媒介存储,如果是采用MEM就创建MEM对象
		 */
		if ($this->_type == 'mem')
		{
			$this->_mem = wcore_object::mem();
		}
	}

	/**
	 * 增加需要过滤的GET字段
	 *
	 * @param string $str 需要过滤的GET字段
	 * @return bool        增加成功返回true失败为false
	 */
	public function add_filter($str)
	{
		if (empty($str))
		{
			return false;
		}
		$this->_filter .= "{$str},";

		return true;
	}

	/**
	 * 产生唯一编号若type类型为mem则在编号上加域名MD5
	 *
	 * @return string 唯一编号
	 */
	public function generate_puid()
	{
		/**
		 * 判断是否有GET数据若有数据则根据GET数据生成编号
		 */
		$puid = '';
		ksort($_GET); //对GET数组的KEY排序,尽量操持puid因GET数据前后而不同
		foreach ($_GET as $k => $v)
		{
			if (strpos($this->_filter, ",{$k},") === false)
			{
				$puid .= $k . (empty($v) ? '' : "-{$v}-");
			}
		}

		/**
		 * 判断由GET数据组合而成的puid是否有数据,若没有的话就只以执行文件名编号
		 */
		if (empty($puid))
		{
			$puid = dirname($_SERVER['SCRIPT_NAME']) . strtok(basename($_SERVER['SCRIPT_NAME']), '.') . "{$puid}";
		}
		else
		{
			if ($puid[strlen($puid) - 1] == '-')
			{
				$puid = substr($puid, 0, -1);
			}
			$puid = strtok($_SERVER['SCRIPT_NAME'], '.') . "/{$puid}";
		}

		/**
		 * 根据存储类型与域名生成编号
		 */
		$domain      = defined(DOMAIN_NAME) ? DOMAIN_NAME : (isset($_SERVER['HTTP_HOST']) ? $_SERVER['HTTP_HOST'] : ''); //主机域名
		$this->_puid = ($this->_type == 'mem') ? md5("{$domain}{$puid}") : "{$puid}{$this->_ext}";
	}

	/**
	 * 获取先前加速已存储好的数据
	 *
	 * @return string 加速的内容
	 */
	public function &get_data()
	{
		$html = ''; //要返回的数据
		if (isset($_GET['nocache']) || empty($this->_puid) || !empty($_POST))
		{
			return $html;
		}

		/**
		 * 采用Memcached加速获取
		 */
		if ($this->_type == 'mem')
		{
			return $this->_mem->get('SPEED-DATA', $this->_puid);
		}

		/**
		 * 采用文件系统加速获取
		 */
		$filename = "{$this->_floder}/{$this->_puid}";
		if (file_exists($filename))
		{
			$lcft = filemtime($filename); //last create file time 上次创建时间
			if (($lcft + ($this->_expire * 60)) < time()) //加速内容过期了
			{
				return $html;
			}
			$html = file_get_contents($filename); //读取加速文件内容
		}

		return $html;
	}

	/**
	 * 存储要加速的数据到指定的媒介
	 *
	 * @param string $html 要存储的HTML内容
	 * @return bool        是否存储成功
	 */
	public function set_data(&$html = '')
	{
		if (empty($this->_puid))
		{
			return false;
		}

		if (empty($html))
		{
			$html = ob_get_flush();
		}

		/**
		 * 采用Memcached加速存储
		 */
		if ($this->_type == 'mem')
		{
			return $this->_mem->set('SPEED-DATA', $this->_puid, $html, $this->_expire);
		}

		/**
		 * 采用文件系统加速存储
		 */
		$filename = "{$this->_floder}/{$this->_puid}";
		$this->make_dir(dirname($filename));
		file_put_contents($filename, $html);

		return true;
	}

	/**
	 * 自动创建目录,可递归创建
	 *
	 * @param    string $path 要创建的目录地址
	 * @return    boolean    创建成功返回true失败为false
	 */
	public function make_dir($path)
	{
		if (empty($path))
		{
			return false;
		}
		if (!file_exists($path))
		{
			$this->make_dir(dirname($path));
			@mkdir($path, 0777);
		}

		return true;
	}
}
?>

2. [文件] object.php ~ 5KB

 hoojar studio
 *
 * 模块: wcore/object.php
 * 简述: 全局对象操作接口
 * 作者: woods·zhang  ->  hoojar@163.com
 * 版本: $Id: object.php 1 2012-11-20 05:55:12Z Administrator $
 * 版权: Copyright 2006-2013 慧佳工作室拥有此系统所有版权等知识产权
 *
 */
class wcore_object
{
	/**
	 * 常用函数接口
	 *
	 * @var wcore_utils
	 */
	private static $_utils = null;

	/**
	 * 提示函数接口
	 *
	 * @var wcore_tip
	 */
	private static $_tip = null;

	/**
	 * 操作数据库接口
	 *
	 * @var wcore_mysql
	 */
	private static $_db = array();

	/**
	 * 操作MEMCACHED库接口
	 *
	 * @var wcore_mem
	 */
	private static $_mem = null;

	/**
	 * 操作MEMCACHED库接口
	 *
	 * @var Smarty
	 */
	private static $_smarty = null;

	/**
	 * 常用函数接口
	 *
	 * @return wcore_utils 返回常用函数对象
	 */
	public static function &utils()
	{
		if (is_object(self::$_utils))
		{
			return self::$_utils;
		}
		self::$_utils = new wcore_utils();

		return self::$_utils;
	}

	/**
	 * 提示函数接口
	 *
	 * @return wcore_tip 返回常用函数对象
	 */
	public static function &tip()
	{
		if (is_object(self::$_tip))
		{
			return self::$_tip;
		}
		self::$_tip = new wcore_tip();

		return self::$_tip;
	}

	/**
	 * 操作数据库接口
	 * @param string $name
	 * @return wcore_mssql|wcore_mysql|wcore_mysqli|wcore_oci 返回操作数据的对象
	 */
	public static function &db($name = '')
	{
		/**
		 * 判断数据库连接是否已生成数组连接池,是则定位到要调用的连接对象
		 */
		if (isset(self::$_db[$name]))
		{
			return self::$_db[$name]; //数据连接从连接池数组当中取
		}

		/**
		 * 生成数据连接数组池
		 */
		$db_servers = json_decode(DB_SERVERS, true);
		foreach ($db_servers as $k => $v)
		{
			if ($k != $name)
			{
				continue; //若$name不为空就只注册连接需要打开的数据库对象
			}

			switch (strtolower($v['dbtype']))
			{
				case 'mysqli':
					$db = new wcore_mysqli($v['host'], $v['user'], $v['pwd'], $v['dbname'], $v['charset'], $v['port'], $v['pconnect']);
					break;
				case 'oci':
					$db = new wcore_oci($v['host'], $v['user'], $v['pwd'], $v['dbname'], $v['charset'], $v['port'], $v['pconnect']);
					break;
				case 'mssql':
					$db = new wcore_mssql($v['host'], $v['user'], $v['pwd'], $v['dbname'], $v['charset'], $v['port'], $v['pconnect']);
					break;
				default:
					$db = new wcore_mysql($v['host'], $v['user'], $v['pwd'], $v['dbname'], $v['charset'], $v['port'], $v['pconnect']);
					break;
			}
			self::$_db[$k] = $db;

			return $db;
		}

		exit("System can't connect '{$name}' connection name objects.");
	}

	/**
	 * 操作MEMCACHED库接口
	 *
	 * @return wcore_mem 返回操作数据的对象
	 */
	public static function &mem()
	{
		if (is_object(self::$_mem))
		{
			return self::$_mem;
		}

		$mem_servers = json_decode(MEM_SERVERS, true);
		self::$_mem  = new wcore_mem($mem_servers, MEM_PORT, MEM_USE, MEM_EXPIRE, MEM_PREFIX);

		return self::$_mem;
	}

	/**
	 * 操作Smarty库接口
	 *
	 * @return Smarty 返回操作Smarty的对象
	 */
	public static function &smarty()
	{
		if (is_object(self::$_smarty))
		{
			return self::$_smarty;
		}

		require(DIR_ROOT . '/smarty/Smarty.class.php');
		$site_theme = get_site_theme(); //获取站点模板主题
		$doc_root   = get_doc_root_name(); //获取站点目录名称

		/**
		 * SMARTY 缓冲目录
		 */
		$smarty_cache_dir = SMARTY_CACHE_DIR . "{$doc_root}/{$site_theme}";
		if (!file_exists($smarty_cache_dir))
		{
			@mkdir($smarty_cache_dir, 0777, true);
		}

		/**
		 * SMARTY 模板目录
		 */
		$smarty_template_dir = DIR_ROOT . "/{$doc_root}/site/{$site_theme}";
		if (!file_exists($smarty_template_dir))
		{
			@mkdir($smarty_template_dir, 0777, true);
		}

		/**
		 * SMARTY 编译目录
		 */
		$smarty_compile_dir = SMARTY_COMPILE_DIR . "{$doc_root}/{$site_theme}";
		if (!file_exists($smarty_compile_dir))
		{
			@mkdir($smarty_compile_dir, 0777, true);
		}

		self::$_smarty                  = new Smarty();
		self::$_smarty->caching         = SMARTY_CACHE;
		self::$_smarty->debugging       = SMARTY_DEBUGGING;
		self::$_smarty->cache_lifetime  = SMARTY_CACHE_LIFETIME;
		self::$_smarty->cache_dir       = $smarty_cache_dir;
		self::$_smarty->template_dir    = $smarty_template_dir;
		self::$_smarty->compile_dir     = $smarty_compile_dir;
		self::$_smarty->left_delimiter  = SMARTY_LEFT_DELIMITER;
		self::$_smarty->right_delimiter = SMARTY_RIGHT_DELIMITER;

		return self::$_smarty;
	}

	/**
	 * 选择或检查数据连接是否已加载,若没有加载则马上加载
	 *
	 * @param string $tname 操作表名
	 * @param string $lname 连接名称(master|slave)
	 * @return modules_dbase
	 */
	public static function &dbase($tname, $lname = '')
	{
		static $dbase_cls = null;
		if (!isset($dbase_cls[$lname]))
		{
			$dbase_cls[$lname] = new modules_dbase();
			$dbase_cls[$lname]->select_db_link($lname);
		}
		$dbase_cls[$lname]->_opt = $tname;

		return $dbase_cls[$lname];
	}

	/**
	 * 主数据库连接操作(可写可读)
	 *
	 * @return wcore_mysql 返回操作数据的对象
	 */
	public static function mdb()
	{
		static $_db = null;
		if (is_null($_db))
		{
			$_db = wcore_object::db('master');
		}

		return $_db;
	}

	/**
	 * 从数据库连接操作(只读)
	 *
	 * @return wcore_mysql 返回操作数据的对象
	 */
	public static function sdb()
	{
		static $_db = null;
		if (is_null($_db))
		{
			$_db = wcore_object::db('slave');
		}

		return $_db;
	}
}
?>