<?php
/**
 * @author Prasetyo Pandu <prasetyowira@gmail.com>
 * Date: 22/10/17
 * Time: 14.54
 */
namespace Api;

define( 'BLOCK_LOAD', true );
ini_set('display_errors','on');

use Api\Helpers\Response;
use Api\Helpers\Tools;

class Anak extends BaseClass {
	use Response;
	use Tools;

	protected $anak;

	public function __construct() {
		parent::__construct();
		$this->table = 'milna_anak';
	}

	public function delete($request)
	{
		if (!is_user_logged_in()){
			return $this->json_response('Not Authorize',[],403);
		}

		$user = wp_get_current_user();
		$query = 'SELECT * FROM '.$this->table.' WHERE user_id = '.$user->ID.
		         ' AND id = '.$request[0];
		$anaks = $this->wpdb->get_results($query);

		if (empty($anaks))
		{
			//If Entity Not Found
			return $this->json_response('Not Found',[],422);
		}
		else
		{
			$this->wpdb->delete($this->table,[
				'id' => $request[0],
			]);
			return $this->json_response('Delete Success', [], 200);
		}
	}

	public function addPoint($param, $input)
	{
		if (!is_user_logged_in()){
			return $this->json_response('Not Authorize',[],403);
		}
		if ($param[0] == ''){
			return $this->json_response('Bad Request',[],400);
		}
		if (!is_numeric($input['point']) || $input['point'] == ''){
			return $this->json_response('Bad Request',[
				'error' => 'Not Valid Input'
			],400);
		}

		$user = wp_get_current_user();
		$query = 'SELECT * FROM '.$this->table.' WHERE user_id = '.$user->ID.
		         ' AND id = '.$param[0].' LIMIT 1';
		$anaks = $this->wpdb->get_results($query);

		if (empty($anaks))
		{
			//If Entity Not Found
			return $this->json_response('Entity Not Found',[],422);
		}
		else
		{
			$point = $anaks[0]->point;
			if (!is_null($point) && is_numeric($point)){
				$point = $input['point'];
			}
			
			$args['id'] = $param[0];
			$args['user_id'] = $user->ID;
			$query = $this->queryBuilder('update', $this->table, $input, $args);

			$response = $this->wpdb->query($query);

			if ($response === false)
				return $this->json_response('Internal Server Error', [], 500);

			return $this->json_response('Update Success', [], 201);
		}
	}

	public function update($param, $input)
	{
		if (!is_user_logged_in()){
			return $this->json_response('Not Authorize',[],403);
		}
		if ($param[0] == ''){
			return $this->json_response('Not Found',[],404);
		}
		$user = wp_get_current_user();
		$query = 'SELECT * FROM '.$this->table.' WHERE user_id = '.$user->ID.
		         ' AND id = '.$param[0];
		$anaks = $this->wpdb->get_results($query);

		if (empty($anaks))
		{
			//If Entity Not Found
			return $this->json_response('Not Found',[],422);
		}
		else
		{
			//TODO NEED CHECK EITHER FIELD IS NOT SET OR FIELD IS NULL
			$args['id'] = $param[0];
			$query = $this->queryBuilder('update', $this->table, $input, $args);

			$response = $this->wpdb->query($query);

			if ($response === false)
				return $this->json_response('Internal Server Error', [], 500);

			return $this->json_response('Update Success', [], 201);
		}
	}

	public function store($input)
	{
		global $ultimatemember;
		if (is_user_logged_in()){
			$user = wp_get_current_user();
			$data = [
				'user_id' => $user->ID,
				'first_name' => $input['first_name'],
				'gender' => $input['gender'],
				'birth_date' => $input['birth_date'],
				'photo' => $input['photo']
			];
			$response = $this->wpdb->insert($this->table, $data);
			if ($response == 1)
			{
				return $this->json_response('Success Add Anak', $data, 201);
			}
			else
			{
				return $this->json_response('Internal Server Error', $data, 500);
			}
		}else{
			if (isset($input['user_id'])){
				$data = [
					'user_id' => $input['user_id'],
					'first_name' => $input['first_name'],
					'gender' => $input['gender'],
					'birth_date' => $input['birth_date'],
					'photo' => $input['photo']
				];
				$response = $this->wpdb->insert($this->table, $data);
				if ($response == 1)
				{
					return $this->json_response('Success Add Anak',$data, 201);
				}
				else
				{
					return $this->json_response('Internal Server Error',$data,500);
				}
			}
			return $this->json_response('Bad Request',[],400);
		}
	}

	public function get($param, $request)
	{
		if (!is_user_logged_in()){
			return $this->json_response('Not Authorize',[],403);
		}

		if ($request[0] == '')
		{
			//Get All
			return $this->getAll($param);
		}
		else
		{
			//Get One
			return $this->getOne($request[0]);
		}
	}

	private function getOne($id)
	{
		$user = wp_get_current_user();
		$query = 'SELECT * FROM '.$this->table.' WHERE user_id = '.$user->ID.
		         ' AND id = '.$id;

		$anaks = $this->wpdb->get_results($query);
		if (!empty($anaks)){
			$response = (array) $anaks[0];
			if (is_null($response['point'])){
				unset($response['point']);
			}
			
			$age = array($this->HitungUmur($response['birth_date'], 'complete'));
			$result = array_merge($response, $age);
			return $this->json_response('Success', $result, 200);
		}
		return $this->json_response('Success', [], 200);
	}

	private function getAll($param)
	{
		$user = wp_get_current_user();
		$query = 'SELECT * FROM '.$this->table.' WHERE user_id = '.$user->ID;

		if (isset($param['orderby'])){
			if ($param['orderby'] == 'asc' || $param['orderby'] == 'desc')
				$query = $query.' ORDER BY birth_date '.strtoupper($param['orderby']);
		}

		if (isset($param['limit'])){
			if (is_numeric($param['limit']))
				$query = $query.' LIMIT '.$param['limit'];
		}

		$anaks = $this->wpdb->get_results($query);
		$response = array();
		if (!empty($anaks)){
			foreach ($anaks as $key => $anak){
				$response[$key] = (array) $anak;
				if (is_null($anak->point)){
					unset($response[$key]['point']);
				}
			}
			return $this->json_response('Success',$response, 200);
		}
		return $this->json_response('Success',[], 200);
	}
}