wenda-php/protected/model/UserDao.php

<?php

class UserDao {
	
	public $uid;
	
	public $username;
	
	public $password;
	
	public $email;
	
	public $avatar;
	
	public $groupid;
	
	public $credits;
	
	public $credit1;
	
	public $credit2;
	
	public $credit3;
	
	public $regip;
	
	public $regtime;
	
	public $lastlogin;
	
	public $bday;
	
	public $phone;
	
	public $qq;
	
	public $msn;
	
	public $signature;
	
	public $authstr;
	
	public $access_token;
	
	public $questions;
	
	public $answers;
	
	public $adopts;
	
	public $isnotify;
	
	public $elect;
	
	public $expert;
	
	public $nickname;
	
	public $cids;
	
	public $refunds;
	
	public $is_email;
	
	public $_table = t_user;
	
	public $_primarykey = "uid";
	
	public $_fields = array ('uid', 'username', 'password', 'email', 'avatar', 'groupid', 'credits', 'credit1', 'credit2', 'regip', 'regtime', 'lastlogin', 'gender', 'bday', 'phone', 'qq', 'msn', 'signature', 'authstr', 'access_token', 'questions', 'answers', 'adopts', 'isnotify', 'elect', 'expert', 'nickname', 'cids', 'refunds','is_email' );
	
	/**
	 * 删除用户和问答
	 * @param unknown_type $uid
	 */
	function delete_user_and_QA($uid = array()) {
		
		$uid = implode ( ",", $uid );
		
		$sql = "delete from " . t_user . " where uid in ( " . $uid . " )";
		
		Doo::db ()->query ( $sql );
		
		$sql = "delete from " . t_answer . " where authorid in ( " . $uid . " )";
		
		Doo::db ()->query ( $sql );
		
		$sql = "delete from " . t_question . " where authorid in ( " . $uid . " )";
		
		Doo::db ()->query ( $sql );
	}
	
	/**
	 * 删除用户
	 * @param unknown_type $uid
	 */
	public function delete_user($uid = array()) {
		
		$uid = implode ( ",", $uid );
		
		$sql = "delete from " . t_user . " where uid in ( " . $uid . " )";
		
		Doo::db ()->query ( $sql );
	}
	
	/**
	 * 获取用户组
	 */
	public function get_group() {
		$sql = "SELECT * FROM  " . t_usergroup;
		
		$query = Doo::db ()->query ( $sql );
		
		$result = $query->fetchAll ();
		
		return $result;
	}
	
	/**
	 * 根据用户民获取用户信息
	 * @param unknown_type $username
	 */
	public function get_users_by_name($username = "") {
		
		if (empty ( $username ))
			return array ();
		
		$sql = "SELECT * FROM  `" . t_user . "` where username like '" . $username . "' limit 1";
		
		$query = Doo::db ()->query ( $sql );
		
		$result = $query->fetch ();
		
		return $result;
	}
	
	/**
	 * 根据uid获取用户信息
	 * @param unknown_type $uid
	 * @return $result array;
	 */
	public function get_userinfo_by_uid($uid = 0) {
		
		if (! is_numeric ( $uid ))
			return array ();
		
		$sql = "SELECT * FROM  `" . t_user . "` where uid = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		$result = $query->fetch ();
		
		return $result;
	}
	
	/**
	 * 添加一定数值的财富
	 * @param unknown_type $price
	 * @param unknown_type $uid
	 */
	public function add_credit3($price = +0, $uid = 0, $action_type = "") {
		
		if (! is_numeric ( $uid ) || ! is_numeric ( $price ))
			return "财富值未成功增加";
		
		if ($price > 0)
			$price = "+" . $price;
		
//		$sql = "UPDATE `" . t_user . "` SET  `credit3` = `credit3` " . $price . " WHERE `uid` = " . $uid;
//		
//		$query = Doo::db ()->query ( $sql );
		
		//记录日常操作 
		$sql = "INSERT INTO " . t_credit . "(uid,time,operation,credit3) VALUES (" . $uid . "," . get_date () . ",'" . $action_type . "'," . $price . ")";
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 减少一定数值的财富
	 * @param unknown_type $price
	 * @param unknown_type $uid
	 */
	public function take_out_credit2($price = 0, $uid = 0, $action_type = "") {
		
		if (! is_numeric ( $uid ) || ! is_numeric ( $price ))
			return "财富值扣除不成功";
		
		$sql = "UPDATE `" . t_user . "` SET  `credit2` = `credit2` - " . $price . " WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		//记录日常操作 //提取到逻辑层
		$sql = "INSERT INTO " . t_credit . "(uid,time,operation,credit1,credit2) VALUES (" . $uid . "," . get_date () . ",'" . $action_type . "',0,-" . $price . ")";
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 添加问题数
	 * @param unknown_type $uid
	 */
	public function add_questions($uid = 0, $cid = 0) {
		
		if (! is_numeric ( $uid ))
			return "问题数未成功增加";
		
		$sql = "UPDATE `" . t_user . "` SET  `questions` = `questions` + 1 WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		$sql = "UPDATE `" . t_category . "` SET  `questions` = `questions` + 1 WHERE `id` = " . $cid;
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 添加回答数
	 * @param unknown_type $uid
	 * @param unknown_type $qid
	 */
	public function add_answers($uid = 0, $qid = 0) {
		if (! is_numeric ( $uid ))
			return "回答数未成功增加";
		
		$sql = "UPDATE `" . t_user . "` SET  `answers` = `answers` + 1 WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		$sql = "UPDATE `" . t_question . "` SET  `answers` = `answers` + 1 WHERE `id` = " . $qid;
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 减少问题数
	 * @param unknown_type $uid
	 */
	public function take_out_questions($uid = 0, $cid = 0) {
		
		if (! is_numeric ( $uid ))
			return "问题数扣除不成功";
		
		$sql = "UPDATE `" . t_user . "` SET  `questions` = `questions` - 1 WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		$sql = "UPDATE `" . t_category . "` SET  `questions` = `questions` - 1 WHERE `id` = " . $cid;
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 减少回答数
	 * @param unknown_type $uid
	 * @param unknown_type $qid
	 */
	public function take_out_answers($uid = 0, $qid = 0) {
		if (! is_numeric ( $uid ))
			return "回答数扣除不成功";
		
		$sql = "UPDATE `" . t_user . "` SET  `answers` = `answers` - 1 WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		$sql = "UPDATE `" . t_question . "` SET  `answers` = `answers` - 1 WHERE `id` = " . $qid;
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 添加一定数值的积分
	 * @param unknown_type $price
	 * @param unknown_type $uid
	 */
	public function add_credit1($point = 0, $uid = 0, $action_type = "") {
		
		if (! is_numeric ( $uid ) || ! is_numeric ( $point ))
			return "积分值未成功增加";
		
		$sql = "UPDATE `" . t_user . "` SET credits = credits + " . $point . " , `credit1` = `credit1` + " . $point . " WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		//记录日常操作 //提取到逻辑层
		$sql = "INSERT INTO " . t_credit . "(uid,time,operation,credit1,credit2) VALUES (" . $uid . "," . get_date () . ",'" . $action_type . "'," . $point . ",0)";
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 减少一定数值的积分
	 * @param unknown_type $price
	 * @param unknown_type $uid
	 */
	public function take_out_credit1($point = 0, $uid = 0, $action_type = "") {
		
		if (! is_numeric ( $uid ) || ! is_numeric ( $point ))
			return "积分值扣除不成功";
		
		$sql = "UPDATE `" . t_user . "` SET credits = credits - " . $point . " ,  `credit1` = `credit1` - " . $point . " WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
		
		//记录日常操作 //提取到逻辑层
		$sql = "INSERT INTO " . t_credit . "(uid,time,operation,credit1,credit2) VALUES (" . $uid . "," . get_date () . ",'" . $action_type . "',-" . $point . ",0)";
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 更新一个用户头像
	 * @param unknown_type $data
	 */
	public function update_avatar($data = array()) {
		
		if (! is_numeric ( $data ['uid'] ))
			return "头像更新不成功";
		
		$sql = "UPDATE `" . t_user . "` SET  `avatar` = '" . $data ['avatar'] . "' WHERE `uid` = " . $data ['uid'];
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 获取用户信息
	 * @param unknown_type $data
	 * @param unknown_type $condition
	 * @param unknown_type $limit
	 */
	function get_users_list($data = array(), $condition = "", $limit = "") {
		
		foreach ( $data as $key => $value ) {
			if (is_numeric ( $value ))
				$condition .= " and " . $key . " = " . $value;
			else
				$condition .= " and " . $key . " like '%" . $value . "%' ";
		}
		
		$condition = ' where 1 ' . $condition . $limit;
		
		$sql = "select * from " . t_user . $condition;
		
		$query = Doo::db ()->query ( $sql );
		
		$result = $query->fetchAll ();
		
		return $result;
	}
	
	/**
	 * 采纳数加1
	 * @param unknown_type $uid
	 * @param unknown_type $adopts
	 */
	function add_adopts($uid = 0, $adopts = 0) {
		$sql = "UPDATE `" . t_user . "` SET  `adopts` = adopts + '" . $adopts . "' WHERE `uid` = " . $uid;
		
		$query = Doo::db ()->query ( $sql );
	}
	
	/**
	 * 更新一条用户信息
	 * @param unknown_type $data
	 * @param unknown_type $condition
	 */
	function update_user($data = array(), $condition = "") {
		
		$prams = array ();
		
		foreach ( $data as $key => $value ) {
			$src = $key . " = '" . $value . "' ";
			
			array_push ( $prams, $src );
		}
		
		$prams = implode ( ",", $prams );
		
		$sql = "UPDATE `" . t_user . "` SET " . $prams . " " . $condition;
		
		$query = Doo::db ()->query ( $sql );
	}

}

?>