<?php
!defined('P_W') && exit('Forbidden');

/**
 *	type
 *		topic
 *		photo
 *		write
 *		diary
 */
class PW_UsercacheDB extends BaseDB {

	var $_tableName = "pw_usercache";
	var $now = 0;

	function PW_UsercacheDB() {
		parent::BaseDB();
		$this->now = $GLOBALS['timestamp'];
	}

	function update($uid, $type, $typeid, $value) {
		$data = array(
			'uid'	=> $uid,
			'type'	=> $type,
			'typeid'=> $typeid,
			'expire'=> $this->now + 608400,
			'value'	=> $this->_serialize($value)
		);

		$this->_db->update("REPLACE INTO " . $this->_tableName . " SET " . S::sqlSingle($data,false));
	}

	/**
	 * 保存用戶模塊緩存數據
	 * @param $uid int 用戶id
	 * @param $modes array 獲取模塊數據及數量 array('article' => 1, 'write' => 2, ...)
	 */
	function saveModesData($uid, $data, $conf) {
		$array = array();
		foreach ($data as $key => $value) {
			$array[] = array(
				'uid'	=> $uid,
				'type'	=> $key,
				'expire'=> (S::isArray($conf[$key]) && isset($conf[$key]['expire'])) ? $this->now + S::int($conf[$key]['expire']) : $this->now + 608400,
				'num'	=> (S::isArray($conf[$key])) ? S::int($conf[$key]['num']) : $conf[$key],
				'value'	=> $this->_serialize($value)
			);
		}
		if ($array) {
			$this->_db->update("REPLACE INTO " . $this->_tableName . " (uid,type,expire,num,value) VALUES ". S::sqlMulti($array, false));
		}
	}

	function delete($uid, $type = null) {
		$this->_db->update('DELETE FROM ' . $this->_tableName . ' WHERE uid' . $this->_sqlIn($uid) . ($type ? ' AND type' . $this->_sqlIn($type) : ''));
	}
	
	/**
	 * 獲取用戶模塊緩存數據
	 * @param $uid int 用戶id
	 * @param $modes array 獲取模塊數據及數量 array('article' => 1, 'write' => 2, ...)或數組  array('aritcle' => array('num'=>1,'expire'=>1234))
	 * return array
	 */
	function getByModes($uid, $modes) {
		$array = array();
		$query = $this->_db->query("SELECT type,num,value FROM " . $this->_tableName . " WHERE uid=" . S::sqlEscape($uid) . ' AND type IN(' . S::sqlImplode(array_keys($modes)) . ') AND expire>' . S::sqlEscape($this->now, false));
		while ($rt = $this->_db->fetch_array($query)) {
			$num = (S::isArray($modes[$rt['type']])) ? S::int($modes[$rt['type']]['num']) : $modes[$rt['type']];
			if ($num < $rt['num']) {
				$array[$rt['type']] = PwArraySlice($this->_unserialize($rt['value']), 0, $num, true);
			} elseif ($num == $rt['num']) {
				$array[$rt['type']] = $this->_unserialize($rt['value']);
			}
		}
		return $array;
	}

	function get($uid,$type) {
		$rt = $this->_db->get_one("SELECT value,typeid FROM ".$this->_tableName." WHERE uid=".S::sqlEscape($uid,false)."AND type=".S::sqlEscape($type,false));
		$value = $this->_unserialize($rt['value']);
		return array('value'=>$value,'id'=>$rt['typeid']);
	}

	function getStruct() {
		return array('uid','type','typeid','expire','value');
	}

	function _checkData($data) {
		if (!is_array($data) || !count($data)) return null;
		$data = $this->_checkAllowField($data,$this->getStruct());
		return $data;
	}

	function _sqlIn($ids) {
		return (is_array($ids) && $ids) ? ' IN (' . S::sqlImplode($ids) . ')' : '=' . S::sqlEscape($ids);
	}
}
?>