Subversion Repositories cheapmusic

<?php

/*

 * User Class

 * This class is used for database related (connect fetch, insert, and update) operations

 * @author    CodexWorld.com

 * @url       http://www.codexworld.com

 * @license   http://www.codexworld.com/license

 */

class User{

    private $userTbl    = DB_USER_TBL;

    public function __construct(){

        if(!isset($this->db)){

            $this->db = MySessionHandler::getDBSessionId();

            if(!$this->db) {

                die("Failed to initialize MySQL connection.");

            }

        }

    }

    /*

     * Returns rows from the database based on the conditions

     * @param array select, where, order_by, limit and return_type conditions

     */

    public function getRows($conditions = array()){

        $sql = 'SELECT ';

        $sql .= array_key_exists("select",$conditions)?$conditions['select']:'*';

        $sql .= ' FROM '.$this->userTbl;

        if(array_key_exists("where",$conditions)){

            $sql .= ' WHERE ';

            $i = 0;

            foreach($conditions['where'] as $key => $value){

                $pre = ($i > 0)?' AND ':'';

                $sql .= $pre.$key." = '".$value."'";

                $i++;

            }

        }

        if(array_key_exists("where_not",$conditions)){

            $sql .= (strpos($sql, 'WHERE') === false)?' WHERE ':' AND ';

            $i = 0;

            foreach($conditions['where_not'] as $key => $value){

                $pre = ($i > 0)?' AND ':'';

                $sql .= $pre.$key." != '".$value."'";

                $i++;

            }

        }

        if(array_key_exists("order_by",$conditions)){

            $sql .= ' ORDER BY '.$conditions['order_by'];

        }

        if(array_key_exists("start",$conditions) && array_key_exists("limit",$conditions)){

            $sql .= ' LIMIT '.$conditions['start'].','.$conditions['limit'];

        }elseif(!array_key_exists("start",$conditions) && array_key_exists("limit",$conditions)){

            $sql .= ' LIMIT '.$conditions['limit'];

        }

        $result = $this->db->query($sql);

        if(array_key_exists("return_type",$conditions) && $conditions['return_type'] != 'all'){

            switch($conditions['return_type']){

                case 'count':

                    $data = $result->num_rows;

                    break;

                case 'single':

                    $data = ($result->num_rows > 0)?$result->fetch_assoc():false;

                    break;

                default:

                    $data = '';

            }

        }else{

            if($result->num_rows > 0){

                while($row = $result->fetch_assoc()){

                    $data[] = $row;

                }

            }

        }

        return !empty($data)?$data:false;

    }

    /*

     * Insert data into the database

     * @param array the data for inserting into the table

     */

    public function insert($data){

        if(!empty($data) && is_array($data)){

            $columns = '';

            $values  = '';

            $i = 0;

            if(!array_key_exists('created',$data)){

                $data['created'] = date("Y-m-d H:i:s");

            }

            if(!array_key_exists('modified',$data)){

                $data['modified'] = date("Y-m-d H:i:s");

            }

            foreach($data as $key=>$val){

                $pre = ($i > 0)?', ':'';

                $columns .= $pre.$key;

                $values  .= $pre."'".$this->db->real_escape_string($val)."'";

                $i++;

            }

            $query = "INSERT INTO ".$this->userTbl." (".$columns.") VALUES (".$values.")";

            $insert = $this->db->query($query);

            return $insert?$this->db->insert_id:false;

        }else{

            return false;

        }

    }

    /*

     * Update data into the database

     * @param array the data to update into the table

     * @param array where condition on updating data

     */

    public function update($data, $conditions){

        if(!empty($data) && is_array($data) && !empty($conditions)){

            //prepare columns and values sql

            $cols_vals = '';

            $i = 0;

            if(!array_key_exists('modified',$data)){

                $data['modified'] = date("Y-m-d H:i:s");

            }

            foreach($data as $key=>$val){

                $pre = ($i > 0)?', ':'';

                $cols_vals .= $pre.$key." = '".$this->db->real_escape_string($val)."'";

                $i++;

            }

            //prepare where conditions

            $whereSql = '';

            $ci = 0;

            foreach($conditions as $key => $value){

                $pre = ($ci > 0)?' AND ':'';

                $whereSql .= $pre.$key." = '".$value."'";

                $ci++;

            }

            //prepare sql query

            $query = "UPDATE ".$this->userTbl." SET ".$cols_vals." WHERE ".$whereSql;

            //update data

            $update = $this->db->query($query);

            return $update?true:false;

        }else{

            return false;

        }

    }

	/*

     * Insert / Update social user data into the database

     * @param array the data to insert or update into the table

     */

	function checkUser($userData = array()){

		if(!empty($userData)){

			// Check whether user data already exists in database with same oauth info

			$prevQuery = "SELECT * FROM ".$this->userTbl." WHERE oauth_provider = '".$userData['oauth_provider']."' AND oauth_uid = '".$userData['oauth_uid']."'";

			$prevResult = $this->db->query($prevQuery);

			// Check whether user data already exists in database with same email

			$prevQuery2 = "SELECT * FROM ".$this->userTbl." WHERE email != '' AND email = '".$userData['email']."'";

			$prevResult2 = $this->db->query($prevQuery2);

			if($prevResult->num_rows > 0){

                $cols_vals = '';

                $i = 0;

				// Update user data if already exists

                if(!array_key_exists('modified',$userData)){

                    $userData['modified'] = date("Y-m-d H:i:s");

                }

                foreach($userData as $key=>$val){

                    $pre = ($i > 0)?', ':'';

                    $cols_vals .= $pre.$key." = '".$this->db->real_escape_string($val)."'";

                    $i++;

                }

                //prepare sql query

                $query = "UPDATE ".$this->userTbl." SET ".$cols_vals." WHERE oauth_provider = '".$userData['oauth_provider']."' AND oauth_uid = '".$userData['oauth_uid']."'";

                //update data

                $update = $this->db->query($query);

			}elseif($prevResult2->num_rows > 0){

				// Update user data if already exists

                if(!array_key_exists('modified',$userData)){

                    $userData['modified'] = date("Y-m-d H:i:s");

                }

                //prepare sql query

                $query = "UPDATE ".$this->userTbl." SET oauth_provider = '".$userData['oauth_provider']."', oauth_uid = '".$userData['oauth_uid']."', modified = '".$userData['modified']."' WHERE email = '".$userData['email']."'";

                //update data

                $update = $this->db->query($query);

			}else{

                $columns = '';

                $values  = '';

                $i = 0;

				// Insert user data

                $userData['activated'] = '1';

                $userData['status'] = '1';

                if(!array_key_exists('created',$userData)){

                    $userData['created'] = date("Y-m-d H:i:s");

                }

                if(!array_key_exists('modified',$userData)){

                    $userData['modified'] = date("Y-m-d H:i:s");

                }

                foreach($userData as $key=>$val){

                    $pre = ($i > 0)?', ':'';

                    $columns .= $pre.$key;

                    $values  .= $pre."'".$this->db->real_escape_string($val)."'";

                    $i++;

                }

                $query = "INSERT INTO ".$this->userTbl." (".$columns.") VALUES (".$values.")";

                $insert = $this->db->query($query);

			}

			// Get user data from the database

			$result = $this->db->query($prevQuery);

			$userData = $result->fetch_assoc();

		}

		// Return user data

		return $userData;

	}

}