gdk/class/points/class-points.php

<?php

/**
 * Points_Database class
 */
class Points_Database {
	public static $prefix = "points_";
	public static function points_get_table( $table ) {
		global $wpdb;
		$result = "";
		switch ( $table ) {
			case "users":
				$result = $wpdb->prefix . self::$prefix . "users";
				break;
		}
		return $result;
	}
}


/**
 * Points class
 */
class Points {

	public static function get_points_by_user ( $user_id, $limit = null, $order_by = null, $order = null, $output = OBJECT, $offset = 0 ) {
		global $wpdb;

		$limit_str = '';
		if ( isset( $limit ) && ( $limit !== null ) ) {
			$limit_str = ' LIMIT ' . $offset . ' ,' . $limit;
		}
		$order_by_str = "";
		if ( isset( $order_by ) && ( $order_by !== null ) ) {
			$order_by_str = " ORDER BY " . $order_by;
		}
		$order_str = "";
		if ( isset( $order ) && ( $order !== null ) ) {
			$order_str = " " . $order;
		}

		$result = $wpdb->get_results('SELECT * FROM ' . Points_Database::points_get_table( 'users' ) . " WHERE user_id = '$user_id'" . $order_by_str . $order_str . $limit_str, $output );

		return $result;
	}

	public static function get_user_total_points ( $user_id, $status = null ) {
		global $wpdb;

		$result = 0;

		$where_status = '';
		if ( $status !== null ) {
			$where_status = " AND status = '" . $status . "'";
		}
		$points = $wpdb->get_row("SELECT SUM(points) as total FROM " . Points_Database::points_get_table( "users" ) . " WHERE user_id = '$user_id' " . $where_status);

		if ( $points && ( $points->total !== NULL ) ) {
			$result = $points->total;
		}
		return $result;
	}

	public static function get_users_total_points (  $limit = null, $order_by = null, $order = null, $status = null ) {
		global $wpdb;

		$where_status = '';
		if ( $status !== null ) {
			$where_status = " WHERE status = '" . $status . "'";
		}
		$points = $wpdb->get_results("SELECT SUM(points) as total, user_id FROM " . Points_Database::points_get_table( "users" ) . $where_status . " GROUP BY user_id");

		return $points;
	}

	/**
	 * Get users id who have some points
	 * @param  $user_id
	 * @return array
	 */
	public static function get_users() {
		global $wpdb;

		$users_id = $wpdb->get_results("SELECT user_id FROM " . Points_Database::points_get_table( "users" ) . " GROUP BY user_id");

		$result = array();
		if ( sizeof( $users_id ) > 0 ) {
			foreach ( $users_id as $user_id ) {
				$result[] = $user_id->user_id;
			}
		}
		return $result;
	}

	public static function set_points ( $points, $user_id, $info = array() ) {
		global $wpdb;

		$values = array( 'points' => $points );

		if ( isset( $info['datetime'] ) && ( $info['datetime'] !== "" ) ) {
			$values['datetime'] = $info['datetime'];
		} else {
			$values['datetime'] = date('Y-m-d H:i:s', time() );
		}
		if ( isset( $info['description'] ) ) {
			$values['description'] = $info['description'];
		}
		if ( isset( $info['status'] ) ) {
			$values['status'] = $info['status'];
		}
		if ( isset( $info['type'] ) ) {
			$values['type'] = $info['type'];
		}
		if ( isset( $info['data'] ) ) {
			$values['data'] = $info['data']; // yet serialized
		}
		if ( isset( $info['ip'] ) ) {
			$values['ip'] = $info['ip'];
		}
		if ( isset( $info['ipv6'] ) ) {
			$values['ipv6'] = $info['ipv6'];
		}
		$values['user_id'] = $user_id;

		$rows_affected = $wpdb->insert( Points_Database::points_get_table("users"), $values );

		return $rows_affected;
	}

	/**
	 * Get a points list.
	 * @param int $limit
	 * @param string $order_by
	 * @param string $order
	 * @return Ambigous <mixed, NULL, multitype:, multitype:multitype: , multitype:Ambigous <multitype:, NULL> >
	 */
	public static function get_points ( $limit = null, $order_by = null, $order = null, $output = OBJECT ) {
		global $wpdb;

		$where_str = " WHERE status != 'removed'";

		$limit_str = "";
		if ( isset( $limit ) && ( $limit !== null ) ) {
			$limit_str = " LIMIT 0 ," . $limit;
		}
		$order_by_str = "";
		if ( isset( $order_by ) && ( $order_by !== null ) ) {
			$order_by_str = " ORDER BY " . $order_by;
		}
		$order_str = "";
		if ( isset( $order ) && ( $order !== null ) ) {
			$order_str = " " . $order;
		}

		$result = $wpdb->get_results("SELECT * FROM " . Points_Database::points_get_table( "users" ) . $where_str . $order_by_str . $order_str . $limit_str, $output );

		return $result;
	}

	public static function get_point ( $point_id = null ) {
		global $wpdb;

		$result = null;

		if ( isset( $point_id ) && ( $point_id !== null ) ) {

			$points_id_str = " WHERE point_id = " . (int)$point_id;
			$result = $wpdb->get_row("SELECT * FROM " . Points_Database::points_get_table( "users" ) . $points_id_str );
		}

		return $result;
	}

	public static function remove_points( $point_id ) {
		global $wpdb;

		$values = array();
		$values['status'] = 'removed';

		$rows_affected = $wpdb->update( Points_Database::points_get_table("users"), $values , array( 'point_id' => $point_id ) );

		if ( !$rows_affected ) {
			$rows_affected = null;
		}
		return $rows_affected;
	}

	public static function update_points( $point_id, $info = array() ) {
		global $wpdb;

		$values = array();

		if ( isset( $info['user_id'] ) ) {
			$values['user_id'] = $info['user_id'];
		}
		if ( isset( $info['datetime'] ) ) {
			$values['datetime'] = $info['datetime'];
		}
		if ( isset( $info['description'] ) ) {
			$values['description'] = $info['description'];
		}
		if ( isset( $info['status'] ) ) {
			$values['status'] = $info['status'];
		}
		if ( isset( $info['points'] ) ) {
			$values['points'] = $info['points'];
		}
		if ( isset( $info['type'] ) ) {
			$values['type'] = $info['type'];
		}
		if ( isset( $info['data'] ) ) {
			$values['data'] = $info['data']; // yet serialized
		}
		if ( isset( $info['ip'] ) ) {
			$values['ip'] = $info['ip'];
		}
		if ( isset( $info['ipv6'] ) ) {
			$values['ipv6'] = $info['ipv6'];
		}

		$rows_affected = $wpdb->update( Points_Database::points_get_table("users"), $values , array( 'point_id' => $point_id ) );

		if ( !$rows_affected ) { // insert
			$rows_affected = null;
		}
		return $rows_affected;
	}
}