CustomerRewardsRESTAPI/Controller/API/CustomerController.php

<?php
header("Content-Type: application/json");
/*
 * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
 * Click nbfs://nbhost/SystemFileSystem/Templates/Scripting/PHPClass.php to edit this template
 */

/**
 * Description of CustomerController
 *
 * @author SCTN4
 * http://localhost:8000/index.php/customer/process/insert?name=Mike%20Howard&email=sctn4elk@msn.com&phone=208-841-4159&birthday=05/07/1965&loyalty=1&city=Winnsboro&state=TX&zip=75494
 * http://localhost:8000/index.php/customer/process/select?limit=20
 */
class CustomerController extends BaseController{
/** 
* "/customer/list" Endpoint - Get list of users 
*/
    private $customerModel;
    private $requestMethod;
    private $arrQueryStringParams;
    private $strErrorDesc;
    private $strErrorHeader;
	
    public $action;
	
    function __construct() {
        $this->customerModel = new CustomerModel();
        $this->requestMethod = $this->getServerRequestMethod();
        $this->arrQueryStringParams = $this->getQueryStringParams();
    }
    
    public function processAction()
    {
        $this->strErrorDesc = '';
        try {
            switch($this->action) {
                case "select":
                    if (isset($this->arrQueryStringParams['id'])) {
                        $response = $this->selectByIdAction();
                    } else {
                        $response = $this->selectAction();
                    }
                break;
                       
                    case "insert":
                        $customerModel->first = $arrQueryStringParams['first'];
                        $customerModel->last = $arrQueryStringParams['last'];
                        $customerModel->email = $arrQueryStringParams['email'];
                        $customerModel->phone = $arrQueryStringParams['phone'];
                        $customerModel->birthday = $arrQueryStringParams['birthday'];
                        $customerModel->street = $arrQueryStringParams['street'];
                        $customerModel->city = $arrQueryStringParams['city'];
                        $customerModel->state = $arrQueryStringParams['state'];
                        $customerModel->zip = $arrQueryStringParams['zip'];
                        $customerModel->loyalty = $arrQueryStringParams['loyalty'];

                        $arrCustomer = $customerModel->insertCustomer();

                        unset($customerModel->first);
                        unset($customerModel->last);
                        unset($customerModel->email);
                        unset($customerModel->phone);
                        unset($customerModel->birthday);
                        unset($customerModel->street);
                        unset($customerModel->city);
                        unset($customerModel->state);
                        unset($customerModel->zip);
                        unset($customerModel->loyalty);
                    break;

                    case "update":
                        $arrCustomer = $customerModel->updateCustomer($arrQueryStringParams);
                    break;

                    case "delete":
                        $arrCustomer = $customerModel->deleteCustomer($arrQueryStringParams);
                    break;
                
                    default:
                        $strErrorDesc = 'Controller Method not supported for processAction: ' . $action;
                        $strErrorHeader = 'HTTP/1.1 422 Unprocessable Entity';
                    break;
                }
        
                $responseData = json_encode($response);
            } catch (Error $e) {
                $this->strErrorDesc = $e->getMessage().' Something went wrong in processAction! Please contact support.';
                $this->strErrorHeader = 'HTTP/1.1 500 Internal Server Error';
            }
        
        // send output 
        if (!$strErrorDesc) {
            $this->sendOutput(
                $responseData,
                array('Content-Type: application/json', 'HTTP/1.1 200 OK')
            );
        } else {
            $this->sendOutput(json_encode(array('error' => $strErrorDesc)), 
                array('Content-Type: application/json', $strErrorHeader)
            );
        }
    }
    
    private function selectAction(){
        if ($this->checkRequestType('GET') == 'false') {
            $this->strErrorDesc = 'Request Method not supported for processAction';
            $this->strErrorHeader = 'HTTP/1.1 422 Unprocessable Entity';
            return;
        }
        
        $this->customerModel->limit = 10;
            
        if (isset($this->arrQueryStringParams['limit'])) {
            $this->customerModel->limit = $this->arrQueryStringParams['limit'];
        }
        $response = $this->customerModel->findAllCustomers();
        unset($this->customerModel->limit);
        
        return $response;
    }
    
    private function selectByIdAction(){
		
        if ($this->checkRequestType('GET') == 'false') {
            $this->strErrorDesc = 'Request Method not supported for processAction';
            $this->strErrorHeader = 'HTTP/1.1 422 Unprocessable Entity';
            return;
        }

        if (isset($this->arrQueryStringParams['id'])) {
            $this->customerModel->customerId = $this->arrQueryStringParams['id'];
            $response = $this->customerModel->findByCustomerId();
            unset($this->customerModel->customerId);
        } else {
            return $this->notFoundResponse();
        }
        
        return $response;
    }
    
    private function checkRequestType($request)
    {
        $response = 'false';
        if (strtoupper($this->requestMethod) == $request) {
            $response = 'true';
        }
        
        return $response;
    }

    private function createUserFromRequest()
    {
        $input = (array) json_decode(file_get_contents('php://input'), TRUE);
        if (! $this->validatePerson($input)) {
            return $this->unprocessableEntityResponse();
        }
        $this->personGateway->insert($input);
        $response['status_code_header'] = 'HTTP/1.1 201 Created';
        $response['body'] = null;
        return $response;
    }

    private function updateUserFromRequest($id)
    {
        $result = $this->personGateway->find($id);
        if (! $result) {
            return $this->notFoundResponse();
        }
        $input = (array) json_decode(file_get_contents('php://input'), TRUE);
        if (! $this->validatePerson($input)) {
            return $this->unprocessableEntityResponse();
        }
        $this->personGateway->update($id, $input);
        $response['status_code_header'] = 'HTTP/1.1 200 OK';
        $response['body'] = null;
        return $response;
    }

    private function deleteUser($id)
    {
        $result = $this->personGateway->find($id);
        if (! $result) {
            return $this->notFoundResponse();
        }
        $this->personGateway->delete($id);
        $response['status_code_header'] = 'HTTP/1.1 200 OK';
        $response['body'] = null;
        return $response;
    }

    private function validatePerson($input)
    {
        if (! isset($input['firstname'])) {
            return false;
        }
        if (! isset($input['lastname'])) {
            return false;
        }
        return true;
    }

    private function unprocessableEntityResponse()
    {
        $response['status_code_header'] = 'HTTP/1.1 422 Unprocessable Entity';
        $response['body'] = json_encode([
            'error' => 'Invalid input'
        ]);
        return $response;
    }

    private function notFoundResponse()
    {
        $response['status_code_header'] = 'HTTP/1.1 404 Not Found';
        $response['body'] = null;
        return $response;
    }
}