File manager

File manager - Edit - /home/autoph/public_html/tasks/src.tar

Back
helpers.php��0000644��00000006532�15025010271�0006716 0��ustar�00��<?php use Pecee\SimpleRouter\SimpleRouter as Router; use Pecee\Http\Url; use Pecee\Http\Response; use Pecee\Http\Request; /** * Get url for a route by using either name/alias, class or method name. * * The name parameter supports the following values: * - Route name * - Controller/resource name (with or without method) * - Controller class name * * When searching for controller/resource by name, you can use this syntax "route.name@method". * You can also use the same syntax when searching for a specific controller-class "MyController@home". * If no arguments is specified, it will return the url for the current loaded route. * * @param string\|null $name * @param string\|array\|null $parameters * @param array\|null $getParams * @return \Pecee\Http\Url * @throws \InvalidArgumentException / function url(?string $name = null, $parameters = null, ?array $getParams = null): Url { return Router::getUrl($name, $parameters, $getParams); } /* * @return \Pecee\Http\Response / function response(): Response { return Router::response(); } /* * @return \Pecee\Http\Request / function request(): Request { return Router::request(); } /* * Get input class * @param string\|null $index Parameter index name * @param string\|null $defaultValue Default return value * @param array ...$methods Default methods * @return \Pecee\Http\Input\InputHandler\|array\|string\|null / function input($index = null, $defaultValue = null, ...$methods) { if ($index !== null) { return request()->getInputHandler()->value($index, $defaultValue, ...$methods); } return request()->getInputHandler(); } /* * @param string $url * @param int\|null $code / function redirect(string $url, ?int $code = null): void { if ($code !== null) { response()->httpCode($code); } response()->redirect($url); } /* * Get current csrf-token * @return string\|null / function csrf_token(): ?string { $baseVerifier = Router::router()->getCsrfVerifier(); if ($baseVerifier !== null) { return $baseVerifier->getTokenProvider()->getToken(); } return null; } //Custom Helpers /* * Flatten the array * @return array\|null / function array_flatten(array $array) { $return = array(); array_walk_recursive($array, function ($a) use (&$return) { $return[] = $a; }); return $return; } function escape($string) { return htmlspecialchars($string, ENT_QUOTES, 'UTF-8'); // return htmlspecialchars($string, ENT_QUOTES \| ENT_HTML5, 'UTF-8'); // return htmlentities($string, ENT_QUOTES \| ENT_HTML5, 'UTF-8'); } function config($config) { // return (object) include(__DIR__ . '/../config/' . $config . '.php'); return (object) include(__DIR__ . '/config/' . $config . '.php'); } function sanitize($array) { if (!is_array($array)) { $array = preg_replace('/\h+/', ' ', escape(trim($array))); if (empty($array) && !strlen($array)) { $array = NULL; } } else { foreach ($array as $key => $value) { if (is_array($value)) { $array[$key] = sanitize($value); } else { $array[$key] = preg_replace('/\h+/', ' ', escape(trim($value))); if (empty($value) && !strlen($value)) { $array[$key] = NULL; } } } } return $array; } ��Utilities/Token.php��0000644��00000000257�15025010271�0010305 0��ustar�00��<?php namespace App\Utilities; use Ramsey\Uuid\Uuid; // use App\Core\View; class Token { public static function generate() { return Uuid::uuid4(); } } ��Utilities/Slug.php��0000644��00000000333�15025010271�0010132 0��ustar�00��<?php namespace App\Utilities; class Slug { public static function create($data){ $data = strtolower(trim($data)); $slug=preg_replace('/[^A-Za-z0-9-]+/', '-', $data); return $slug; } }��Utilities/Auth.php��0000644��00000005346�15025010271�0010132 0��ustar�00��<?php namespace App\Utilities; use App\Utilities\Session; class Auth { private static $instance; function __construct() { if (!empty(Session::get('user'))) { // $user = new \App\Models\User; // $response = $user->getUser(array(Session::get('uid'))); // foreach ($response as $key => $value) { foreach ($_SESSION['user'] as $key => $value) { $this->{$key} = $value; } } } public static function user() { if (is_null(self::$instance)) { self::$instance = new self(); } return self::$instance; } public static function check() { if (!empty(Session::get('user'))) { return true; } return false; } // public static function getPerm() // { // $roleId = Auth::user()->roleId; // $permissions_arr = array(); // if (!empty($roleId)) { // $permissions_json = \App\Models\Role::rolePermissions($roleId); // if (!empty($permissions_json)) { // $permissions_arr = json_decode($permissions_json, true); // } // } // if (!empty(Auth::user()->admin)) { // $permissions_arr = array_merge($permissions_arr, array('admin' => true)); // } // if (!empty(Auth::user()->vendor)) { // $permissions_arr = array_merge($permissions_arr, array('vendor' => true)); // } // return $permissions_arr; // } // public static function hasPermission($perm) // { // $permissions_arr = self::getPerm(); // if (!empty($permissions_arr['admin'])) { // return true; // } // if (is_array($perm)) { // foreach ($perm as $perm_row) { // if (empty($permissions_arr[$perm_row])) { // return false; // } // } // return true; // } else { // if (!empty($permissions_arr[$perm])) { // return true; // } // } // return false; // } // public static function hasAnyPermission($perm) // { // $permissions_arr = self::getPerm(); // if (!empty($permissions_arr['admin'])) { // return true; // } // if (is_array($perm)) { // foreach ($perm as $perm_row) { // if (!empty($permissions_arr[$perm_row])) { // return true; // } // } // return false; // } else { // if (!empty($permissions_arr[$perm])) { // return true; // } // } // return false; // } } ��Utilities/MobileFormatter.php��0000644��00000001727�15025010271�0012323 0��ustar�00��<?php namespace App\Utilities; class MobileFormatter { public static function format($data) { if (strlen($data) < 5) { return ""; } $final_data = ""; //if area code equal to 639xx it will change to 09xxxxxxxxx if (substr($data, 0, 2) === "09") { $final_data = "9" . substr($data, 2, strlen($data)); } else if (substr($data, 0, 3) === "639") { $final_data = "9" . substr($data, 3, strlen($data)); } else if (substr($data, 0, 1) === "9" && strlen($data) == 10) { $final_data = "9" . substr($data, 1, strlen($data)); } else { $final_data = $data; } //if number start with 09xxx, check the length, if length is not 11 return blank, if not 09xxx return it if (substr($final_data, 0, 1) === "9") { if (strlen($final_data) == 10) { return $final_data; } } return ''; } } ��Utilities/Hash.php��0000644��00000000425�15025010271�0010105 0��ustar�00��<?php namespace App\Utilities; class Hash { public static function verify($password, $hash_password) { return password_verify($password, $hash_password); } public static function hash($password) { return password_hash($password, PASSWORD_DEFAULT); } } ?>��Utilities/Uuid.php��0000644��00000001126�15025010271�0010127 0��ustar�00��<?php namespace App\Utilities; use Ramsey\Uuid\Uuid as rUuid; // use App\Core\View; class Uuid { public static function long() { return rUuid::uuid4(); // $sql = "SELECT UUID()"; // $db_handle = new \App\Core\Database; // $result = $db_handle->selectBaseQuery($sql); // return $result; } public static function short() { return rUuid::uuid4(); // $sql = "SELECT UUID_SHORT()"; // $db_handle = new \App\Core\Database; // $result = $db_handle->selectBaseQuery($sql); // return $result; } } ��Utilities/Utility.php��0000644��00000005066�15025010271�0010673 0��ustar�00��<?php namespace App\Utilities; class Utility { public static function removeNotAlphaNumeric($data) { $str = preg_replace("/[^a-zA-Z0-9]+/", "", $data); return $str; } public static function toSqlDate($date) { return !empty($date) ? date('Y-m-d H:i:s', strtotime($date)) : NULL; } public static function toDateTimePicker($date) { return !empty($date) ? date('m/d/Y h:i A', strtotime($date)) : NULL; } public static function nullEmptyArray($array) { foreach ($array as $key => $value) { if (is_array($value)) { $array[$key] = self::nullEmptyArray($value); } if (empty($value) && !is_numeric($value)) { $array[$key] = NULL; } } return $array; } public static function base64_url_encode($input) { return strtr(base64_encode($input), '+/=', '-_-'); } public static function upperCaseNestedArray($value) { if (is_array($value)) { return array_map(array(new Utility(), 'upperCaseNestedArray'), $value); } return trim(mb_strtoupper($value)); } public static function maskString($str, $first = 3, $last = 2, $maskChar = '') { if (!$str) { return ""; } $len = strlen($str); $toShow = $first + $last; return substr($str, 0, $len <= $toShow ? 0 : $first) . str_repeat($maskChar, $len - ($len <= $toShow ? 0 : $toShow)) . substr($str, $len - $last, $len <= $toShow ? 0 : $last); } public static function maskEmail($email, $maskChar = "") { if (!$email) { return ""; } $mail_parts = explode("@", $email); $domain_parts = explode('.', $mail_parts[1]); $mail_parts[0] = self::maskString($mail_parts[0], 2, 1, $maskChar); // show first 2 letters and last 1 letter $mail_parts[1] = implode('.', $domain_parts); return implode("@", $mail_parts); } public static function includeFiles($directory) { if (is_dir($directory)) { $scan = scandir($directory); unset($scan[0], $scan[1]); //unset . and .. foreach ($scan as $file) { if (is_dir($directory . "/" . $file)) { self::includeFiles($directory . "/" . $file); } else { if (strpos($file, '.php') !== false) { include_once($directory . "/" . $file); } } } } } } ��Utilities/Session.php��0000644��00000002114�15025010271�0010642 0��ustar�00��<?php namespace App\Utilities; class Session { /* * Create session * * @param $name * @param $value * @return mixed / public static function set($data) { if(!is_array($data)) { return $_SESSION[$data] = $data; } foreach($data as $row => $value) { $_SESSION[$row] = $value; } return; } /* * Get session * * @param $name * @return mixed / public static function get($name) { if (isset($_SESSION[$name])) { return $_SESSION[$name]; } } /* * Check session * * @param $name * @return bool / public static function exists($name) { return isset($_SESSION[$name]); } /* * Delete session * * @param $name / public static function delete($name) { unset($_SESSION[$name]); } public static function destroy() { if (session_status() == PHP_SESSION_ACTIVE) { session_destroy(); } } } ?>��Utilities/Cookie.php��0000644��00000002162�15025010271�0010433 0��ustar�00��<?php namespace App\Utilities; /* * Cookie: * * @author Igor Veselov <dev@xfor.top> / class Cookie { /* * Delete: * @access public * @param string $key * @return void / public static function delete($key) { self::put($key, '', time() - 1); } /* * Exists: * @access public * @param string $key * @return boolean / public static function exists($key): bool { return isset($_COOKIE[$key]); } /* * Get: Returns the value of a specific key of the COOKIE super-global * @access public * @param string $key * @return string / public static function get($key): string { if(self::exists($key)){ return $_COOKIE[$key]; }else{ return ''; } } /* * Put: * @access public * @param string $key * @param string $value * @param integer $expiry * @return boolean / public static function put($key, $value, $expiry): bool { return setcookie($key, $value, time() + $expiry, '/'); } }��Handlers/CustomExceptionHandler.php��0000644��00000002273�15025010271�0013441 0��ustar�00��<?php namespace App\Handlers; use Pecee\Http\Request; use Pecee\SimpleRouter\Exceptions\NotFoundHttpException; use Pecee\SimpleRouter\Handlers\IExceptionHandler; class CustomExceptionHandler implements IExceptionHandler { /* * @param Request $request * @param \Exception $error * @throws \Exception / public function handleError(Request $request, \Exception $error): void { / You can use the exception handler to format errors depending on the request and type. / if ($request->getUrl()->contains('/api')) { response()->json([ 'error' => $error->getMessage(), 'code' => $error->getCode(), ]); } / The router will throw the NotFoundHttpException on 404 / if ($error instanceof NotFoundHttpException) { / * Render your own custom 404-view, rewrite the request to another route, * or simply return the $request object to ignore the error and continue on rendering the route. * * The code below will make the router render our page.notfound route. / // $request->setRewriteCallback('DefaultController@notFound'); $request->setRewriteCallback(function () { echo "404 Error not found."; }); return; } throw $error; } } ��Core/Database1.php��0000644��00000011222�15025010271�0007721 0��ustar�00��<?php namespace App\Core; class Database { private static $host = DB_HOST; private static $user = DB_USER; private static $password = DB_PASS; private static $database = DB_NAME; private static $conn; private static $instance; function __construct() { self::$conn = self::connectDB(); //Server Config self::$conn->query("SET SESSION sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''));"); } public static function connect() { if (is_null(self::$instance)) { self::$instance = new self(); } return self::$instance; } public static function connectDB() { $conn = mysqli_connect(self::$host, self::$user, self::$password, self::$database); return $conn; } public static function runQuery($query, $param_type, $param_value_array) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } self::bindQueryParams($sql, $param_type, $param_value_array); $sql->execute(); $result = $sql->get_result(); $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } public static function bindQueryParams($sql, $param_type, $param_value_array) { $param_value_reference[] = &$param_type; for ($i = 0; $i < count($param_value_array); $i++) { $param_value_reference[] = &$param_value_array[$i]; } call_user_func_array(array( $sql, 'bind_param' ), $param_value_reference); } public static function insert($query, $param_type, $param_value_array) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } self::bindQueryParams($sql, $param_type, $param_value_array); $sql->execute(); $insertId = $sql->insert_id; return $insertId; } public static function update($query, $param_type, $param_value_array) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } self::bindQueryParams($sql, $param_type, $param_value_array); $sql->execute(); return $sql->affected_rows; } public static function select($query, $param_type, $param_value_array) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } self::bindQueryParams($sql, $param_type, $param_value_array); $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } else { return ''; } } public static function runBaseQuery($query) { $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } public static function selectBaseQuery($query) { $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } else { return ''; } } public static function insertBaseQuery($query) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); $insertId = $sql->insert_id; return $insertId; } public static function updateBaseQuery($query) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); return $sql->affected_rows; } } ��Core/Model.php��0000644��00000000251�15025010271�0007174 0��ustar�00��<?php namespace App\Core; class Model{ // public $db_handle; // function __construct() { // $this->db_handle = new \App\Core\Database; // } } ?>��Core/View.php��0000644��00000000550�15025010271�0007050 0��ustar�00��<?php namespace App\Core; class View{ public static function render($view, $args = []) { extract($args, EXTR_SKIP); $file = APP_ROOT.'/resources/views/' . $view . '.php'; if (is_readable($file)) { require_once $file; } else { throw new \Exception("$file not found"); } } } ?>��Core/Database05-06-24.php��0000644��00000015662�15025010271�0010467 0��ustar�00��<?php namespace App\Core; class Database { private static $host = DB_HOST; private static $user = DB_USER; private static $password = DB_PASS; private static $database = DB_NAME; private static $conn; private static $instance; function __construct() { self::$conn = self::connectDB(); //Server Config self::$conn->query("SET SESSION sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''));"); } public static function connect() { if (is_null(self::$instance)) { self::$instance = new self(); } return self::$instance; } public static function connectDB() { $conn = mysqli_connect(self::$host, self::$user, self::$password, self::$database); return $conn; } public static function bindQueryParams($sql, $param_type, $param_value_array) { $param_value_reference[] = &$param_type; for ($i = 0; $i < count($param_value_array); $i++) { $param_value_reference[] = &$param_value_array[$i]; } call_user_func_array(array( $sql, 'bind_param' ), $param_value_reference); } public static function runQuery($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } catch (\Exception $e) { return $e->getMessage(); } } public static function selectQuery($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { return $row; } } return []; } catch (\Exception $e) { return $e->getMessage(); } } public static function insert($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); return $sql->insert_id; } catch (\Exception $e) { return $e->getMessage(); } } public static function update($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); return $sql->affected_rows; } catch (\Exception $e) { return $e->getMessage(); } } public static function select($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } return ''; } catch (\Exception $e) { return $e->getMessage(); } } public static function runBaseQuery($query) { $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } public static function selectBaseQuery($query) { $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } else { return ''; } } public static function insertBaseQuery($query) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); $insertId = $sql->insert_id; return $insertId; } public static function updateBaseQuery($query) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); return $sql->affected_rows; } //modify public static function return_result($query) { $result = self::connectDB()->query($query); $output = array(); while ($row = $result->fetch_assoc()) { array_push($output, $row); } return $output; } public static function select2($query) { $result = self::connectDB()->query($query); if ($result === false) { return false; } $row = $this->index_arr_values($result->fetch_assoc()); if (empty($row)) { return ""; } return $row[0]; } public function index_arr_values($value) { if (empty($value)) { return array(); } return array_values($value); } } ��Core/Database.php��0000644��00000016741�15025010271�0007653 0��ustar�00��<?php namespace App\Core; class Database { private static $host = DB_HOST; private static $user = DB_USER; private static $password = DB_PASS; private static $database = DB_NAME; private static $conn; private static $instance; function __construct() { self::$conn = self::connectDB(); //Server Config self::$conn->query("SET SESSION sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''));"); } public static function connect() { if (is_null(self::$instance)) { self::$instance = new self(); } return self::$instance; } public static function connectDB() { $conn = mysqli_connect(self::$host, self::$user, self::$password, self::$database); return $conn; } public static function bindQueryParams($sql, $param_type, $param_value_array) { $param_value_reference[] = &$param_type; for ($i = 0; $i < count($param_value_array); $i++) { $param_value_reference[] = &$param_value_array[$i]; } call_user_func_array(array( $sql, 'bind_param' ), $param_value_reference); } public static function runQuery($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } catch (\Exception $e) { return $e->getMessage(); } } public static function selectQuery($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { return $row; } } return []; } catch (\Exception $e) { return $e->getMessage(); } } public static function insert($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); return $sql->insert_id; } catch (\Exception $e) { return $e->getMessage(); } } public static function update($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); return $sql->affected_rows; } catch (\Exception $e) { return $e->getMessage(); } } public static function select($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } return ''; } catch (\Exception $e) { return $e->getMessage(); } } public static function runBaseQuery($query) { $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } public static function selectBaseQuery($query) { $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } else { return ''; } } public static function insertBaseQuery($query) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); $insertId = $sql->insert_id; return $insertId; } public static function updateBaseQuery($query) { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); return $sql->affected_rows; } public static function checkQuery($query) { return $query; // $sql = self::$conn->prepare($query); // if (self::$conn->error) { // return self::$conn->error; // } // $sql->execute(); // return $sql->affected_rows; } //modify public static function return_result($query) { $result = self::connectDB()->query($query); $output = array(); while ($row = $result->fetch_assoc()) { array_push($output, $row); } return $output; } public static function select2($query) { $result = self::connectDB()->query($query); if ($result === false) { return false; } $row = $this->index_arr_values($result->fetch_assoc()); if (empty($row)) { return ""; } return $row[0]; } public function index_arr_values($value) { if (empty($value)) { return array(); } return array_values($value); } } ��Core/Mail.php��0000644��00000005343�15025010271�0007025 0��ustar�00��<?php namespace App\Core; use PHPMailer\PHPMailer\PHPMailer; use PHPMailer\PHPMailer\SMTP; use PHPMailer\PHPMailer\Exception; class Mail extends PHPMailer{ public static function sendEmail($args){ $mail_sent = 0; //validation if(empty($args['to_email']) \|\| empty($args['subject']) \|\| (empty($args['html_body']) && empty($args['email_body']))){ return "Email, Subject and Message are required."; } $to_email = $args['to_email']; $to_name = empty($args['to_name']) ? '' : $args['to_name'] ; $subject = $args['subject']; $html_body = empty($args['html_body']) ? '' : $args['html_body'] ; $email_body = empty($args['email_body']) ? '' : $args['email_body'] ; try{ $mail = new PHPMailer; $mail->SMTPDebug = SMTP::DEBUG_OFF; $mail->isSMTP(); //Send using SMTP $mail->Host = MAIL_HOST; //Set the SMTP server to send through $mail->SMTPAuth = true; //Enable SMTP authentication $mail->Username = MAIL_USERNAME; //SMTP username $mail->Password = MAIL_PASSWORD; //SMTP password $mail->SMTPSecure = MAIL_ENCRYPTION; //Enable TLS encryption; `PHPMailer::ENCRYPTION_SMTPS` encouraged $mail->Port = MAIL_PORT; $mail->setFrom(MAIL_FROM_ADDRESS, MAIL_FROM_NAME); $mail->addAddress($to_email,$to_name); // $mail->addReplyTo('info@example.com', 'Information'); // $mail->addCC('cc@example.com'); // $mail->addBCC('bcc@example.com'); //Attachments // $mail->addAttachment('/var/tmp/file.tar.gz'); //Add attachments // $mail->addAttachment('/tmp/image.jpg', 'new.jpg'); //Optional name $mail->Subject = $subject; if(!empty($html_body)) { $mail->isHTML(true); $mail->AltBody = $email_body; $mail->Body = $html_body; } else{ $mail->Body = $email_body; } // added Gmail hack $mail->SMTPOptions = array( 'ssl' => array( 'verify_peer' => false, 'verify_peer_name' => false, 'allow_self_signed' => true ) ); if($mail->send()) $mail_sent = 1; } catch (Exception $e) { return "Message could not be sent. Mailer Error: {$mail->ErrorInfo}"; } return $mail_sent; } } ?>��Core/Controller.php��0000644��00000000065�15025010271�0010262 0��ustar�00��<?php namespace App\Core; class Controller{ } ?>��Core/Database2.php��0000644��00000015301�15025010271�0007724 0��ustar�00��<?php namespace App\Core; class Database { private static $host; private static $user; private static $password; private static $database; private static $conn; private static $instance; function __construct() { self::$host = env('DB_HOST'); self::$user = env('DB_USERNAME'); self::$password = env('DB_PASSWORD'); self::$database = env('DB_DATABASE'); self::$conn = self::connectDB(); //Server Config self::$conn->query("SET SESSION sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''));"); // ini_set('memory_limit', '-1'); } public static function connect() { if (is_null(self::$instance)) { self::$instance = new self(); } return self::$instance; } public static function connectDB() { $conn = mysqli_connect(self::$host, self::$user, self::$password, self::$database); return $conn; } public static function bindQueryParams($sql, $param_type, $param_value_array) { $param_value_reference[] = &$param_type; for ($i = 0; $i < count($param_value_array); $i++) { $param_value_reference[] = &$param_value_array[$i]; } call_user_func_array(array( $sql, 'bind_param' ), $param_value_reference); } public static function runQuery($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } catch (\Exception $e) { return $e->getMessage(); } } public static function selectQuery($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { return $row; } } return []; } catch (\Exception $e) { return $e->getMessage(); } } public static function insert($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); return $sql->insert_id; } catch (\Exception $e) { return $e->getMessage(); } } public static function update($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); return $sql->affected_rows; } catch (\Exception $e) { return $e->getMessage(); } } public static function select($query, $param_type = "", $param_value_array = []) { try { $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } if (!empty($param_value_array)) { self::bindQueryParams($sql, $param_type, $param_value_array); } $sql->execute(); $result = $sql->get_result(); if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } return ''; } catch (\Exception $e) { return $e->getMessage(); } } public static function runBaseQuery($query) { /* * deprecated do not use / $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } $resultset = []; if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; } } return $resultset; } public static function selectBaseQuery($query) { /* * deprecated do not use / $result = self::$conn->query($query); if (self::$conn->error) { return self::$conn->error; } if ($result->num_rows > 0) { while ($row = $result->fetch_assoc()) { $resultset[] = $row; foreach ($resultset as $resultsetRow) { foreach ($resultsetRow as $resultsetRowRow) { return $resultsetRowRow; } } } } else { return ''; } } public static function insertBaseQuery($query) { /* * deprecated do not use / $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); if ($sql->errno) { return $sql->error; } $insertId = $sql->insert_id; return $insertId; } public static function updateBaseQuery($query) { /* * deprecated do not use / $sql = self::$conn->prepare($query); if (self::$conn->error) { return self::$conn->error; } $sql->execute(); if ($sql->errno) { return $sql->error; } return $sql->affected_rows; } } ��Core/Sms.php��0000644��00000011474�15025010271�0006707 0��ustar�00��<?php namespace App\Core; class Sms { public function SmsactiveProvider() { $query = "SELECT FROM sms_provider WHERE 1 AND status = ?"; $queryType = "i"; $queryValue = array( 1 ); $activeProvider= Database::connect()->runQuery($query, $queryType, $queryValue); $smsProvider=[]; if(count($activeProvider)==1) { foreach($activeProvider as $provider) { $smsProvider = $provider; } unset($provider); } return $smsProvider; } // public static function sendSMS($args) // { // if (empty($args['mobile']) && empty($args['message'])) { // return "Mobile and Message are required."; // } // //clean message // // $args['message'] = strtr($args['message'], array("\n" => "\\n", "\r" => "\\r")); // $args['message'] = preg_replace("/&([a-z])[a-z]+;/i", "$1", htmlentities($args['message'])); // $args['message'] = strtr($args['message'], array("\n" => "\\n")); // $args['message'] = preg_replace('/[\x00-\x1F\x7F\xA0]/u', '', $args['message']); // //convert enye to normal text to fix problewm from sms provider // $replace_parameter = array( // '[no]' => $args['mobile'], // '[msg]' => $args['message'], // '[key]' => SMS_KEY, // '[pwd]' => SMS_PASSWORD, // ); // $final_template = strtr(SMS_BODY, $replace_parameter); // // if ($args['mobile'] == '+639771424322') { // // print_r($final_template); // // exit; // // } // $ch = curl_init(); // curl_setopt($ch, CURLOPT_URL, SMS_URI); // curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); // curl_setopt($ch, CURLOPT_POST, 1); // // curl_setopt($ch, CURLOPT_POSTFIELDS, json_decode($final_template, true)); // curl_setopt($ch, CURLOPT_POSTFIELDS, $final_template); // if (count(SMS_HEADER) > 0) { // curl_setopt($ch, CURLOPT_HTTPHEADER, SMS_HEADER); // } // $result = curl_exec($ch); // // return $result; // $response = json_decode($result, true); // // return $response; // return $response['status'] == 201 ? 0 : $result; // } public static function sendSMS($args) { $sms = new Sms(); $smsProvider = $sms->SmsactiveProvider(); if (empty($args['mobile']) && empty($args['message'])) { return "Mobile and Message are required."; } //clean message // $args['message'] = strtr($args['message'], array("\n" => "\\n", "\r" => "\\r")); $args['message'] = preg_replace("/&([a-z])[a-z]+;/i", "$1", htmlentities($args['message'])); $args['message'] = strtr($args['message'], array("\n" => "\\n")); $args['message'] = preg_replace('/[\x00-\x1F\x7F\xA0]/u', '', $args['message']); if($smsProvider['code'] =='philsms') { $replace_parameter = array( '[no]' => $args['mobile'], '[msg]' => $args['message'], '[key]' => SMS_KEY, '[pwd]' => SMS_PASSWORD, ); $final_template = strtr(SMS_BODY, $replace_parameter); $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, SMS_URI); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_POST, 1); // curl_setopt($ch, CURLOPT_POSTFIELDS, json_decode($final_template, true)); curl_setopt($ch, CURLOPT_POSTFIELDS, $final_template); if (count(SMS_HEADER) > 0) { curl_setopt($ch, CURLOPT_HTTPHEADER, SMS_HEADER); } // $result = curl_exec($ch); // return $result; } //convert enye to normal text to fix problewm from sms provider if($smsProvider['code'] =='itexmo') { $ch = curl_init(); $itexmo_arr = array( 'Email' => 'aendaya@autohubgroup.com', 'Password' => 'JRE@jre0911', 'ApiCode' => 'PR-AUTOH172111_IE74I', 'SenderId'=> 'AUTOHUB GRP', 'Recipients' => [$args['mobile']], 'Message' =>$args['message']//$message ); curl_setopt($ch, CURLOPT_URL,$smsProvider['uri']); curl_setopt($ch, CURLOPT_POST, 1); curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($itexmo_arr)); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); } $result = curl_exec($ch); curl_close ($ch); $response = json_decode($result, true); return $response['status'] == 201 ? 0 : $result; } } ��config.php��0000644��00000003272�15025010271�0006517 0��ustar�00��<?php //Site define('SITE_NAME', 'AutoHub Connect'); define('SITE_LOGO', '/public/storage/app/image/AGC.png'); define('SITE_FAVICON', '/public/storage/app/image/AGC.png'); define('SITE_URL', 'http://' . $_SERVER['HTTP_HOST']); define('SITE_EMAIL', 'contact@autopartshub.com'); define('SITE_PHONE', '+63 2 8860-8888'); define('SITE_LOCATION', 'Blk 15 Rizal Drive, Crescent Park West, Taguig.'); //Api define('API_URL', SITE_URL . '/api'); //App define('APP_ROOT', dirname(dirname(__FILE__))); define('APP_DEV', 'AutoHub Devs'); define('APP_VERSION', '1.0.0'); define('APP_ASSETS_URL', '/'); define('APP_DISK', 'public/storage/'); //Images define('BRAND_DEFAULT_LOGO', '/assets/img/logo/brands/default_logo.png'); define('USER_DEFAULT_LOGO', '/storage/users/default.png'); //Url define('URL_ROOT', ''); define('URL_SUBFOLDER', ''); //DB Params define('DB_HOST', '127.0.0.1'); define('DB_USER', 'autoph_db'); define('DB_PASS', '@4u70hu36r0up007#'); define('DB_NAME', 'autoph_db'); //Mailer define('MAIL_MAILER', 'smtp'); define('MAIL_HOST', 'smtp.mailtrap.io'); define('MAIL_PORT', '587'); define('MAIL_USERNAME', 'c7d299fcce9c40'); define('MAIL_PASSWORD', 'ff0f928a82987e'); define('MAIL_ENCRYPTION', 'TLS'); define('MAIL_FROM_ADDRESS', SITE_EMAIL); define('MAIL_FROM_NAME', SITE_NAME); //SMS define('SMS_DRIVER', 'PhilSMS'); define('SMS_URI', 'https://api.philsms.com/outbound/v1'); define('SMS_BODY', '{"apiKey": "[key]","apiPass": "[pwd]","mask": "AUTOHUB GRP","content": "[msg]","msisdn": " [no]"}'); define('SMS_KEY', 'aenda-5XRDT'); define('SMS_PASSWORD', '3[#kQ.Rx~E'); define('SMS_HEADER', ["Content-Type: application/json"]); define('SMS_SUCCESS', '0'); // Application debug mode define('debug', true); ��Controllers/CompanyController.php��0000644��00000001024�15025010271�0013223 0��ustar�00��<?php namespace App\Controllers; use App\Core\Controller; use App\Core\Sms; use App\Utilities\Session; use App\Utilities\Uuid; use App\Utilities\Utility; class CompanyController extends Controller { private $company; function __construct() { $this->company = new \App\Models\Company; } public function userCompanies() { $ids = implode(",", Session::get('company_permissions')); $response = $this->company->getUserAccessCompany($ids); response()->json($response); } } ��Controllers/LtoController.php��0000644��00000127050�15025010271�0012363 0��ustar�00��<?php namespace App\Controllers; use App\Core\Controller; use App\Core\Sms; use App\Utilities\Session; use App\Utilities\Uuid; use App\Utilities\Utility; class LtoController extends Controller { private $lto; function __construct() { $this->lto = new \App\Models\Lto; } public function ltoIndex() { response()->redirect(url('lto.orcr.plate')); } public function OrcrPlateIndex() { // if (!(isset($global_action_permissions['7']['33']) && // in_array("1", $global_action_permissions['7']['33']))) { // header('location:signin.php'); // } // print_r(Session::get('action_permissions')); if (!in_array("1", Session::get('action_permissions')['10'])) { response()->redirect("/index.php"); } $page_title = "OR/CR & Plate Update"; include('resources/views/lto/orcr_plate_update/list.php'); } public function orcrPlateList() { $array_data['search_keyword'] = Utility::removeNotAlphaNumeric(input('search')); // $array_data['search_keyword_name'] = input('search'); $array_data['search_type'] = input('search_type'); $array_data['search_type'] = json_decode($array_data['search_type'], true)[0]; $array_data['offset'] = input('offset'); $array_data['limit'] = input('limit'); $array_data['sort'] = input('sort'); $array_data['user_id'] = Session::get('user')['id']; switch ($array_data['sort']) { case "date": $array_data['sort'] = " ORDER BY vops.date_added " . input('order'); break; case "date_received": $array_data['sort'] = " ORDER BY vops.date_received " . input('order'); break; case "type": $array_data['sort'] = " ORDER BY vops.type " . input('order'); break; case "status": $array_data['sort'] = " ORDER BY vops.sms_response " . input('order') . " ,vops.sms_date " . input('order') . ""; break; default: $array_data['sort'] = " ORDER BY vops.date_added DESC"; } // start search using keywords switch ($array_data['search_type']) { case "Customer": $array_data['search'] = " AND CONCAT(c.first_name,' ',c.last_name,' ',c.corporation_name) LIKE ? "; $array_data['search_keyword'] = "%" . input('search') . "%"; break; case "Conduction Sticker": $array_data['search'] = " AND v.conduction_sticker = ? "; break; case "Plate Number": $array_data['search'] = " AND v.plate_number = ? "; break; case "MV File": $array_data['search'] = " AND v.mv_file = ? "; break; case "Engine Number": $array_data['search'] = " AND v.engine_number = ? "; break; case "Chassis Number": $array_data['search'] = " AND v.chassis_number = ? "; break; } if (empty($array_data['search_keyword'])) { $array_data['search_keyword'] = "1"; $array_data['search'] = " AND ? "; } //end search using keywords // start date filter if (empty(input('start_date_add'))) { $array_data['date_added'] = ""; } else { $array_data['date_added'] = " AND DATE_FORMAT(vops.date_added,'%Y-%m-%d') BETWEEN '" . input('start_date_add') . "' AND '" . input('end_date_add') . "' "; } if (empty(input('start_date_receive'))) { $array_data['date_received'] = ""; } else { $array_data['date_received'] = " AND DATE_FORMAT(vops.date_received,'%Y-%m-%d') BETWEEN '" . input('start_date_receive') . "' AND '" . input('end_date_receive') . "' "; } //sms status filter switch (input('sms_status')) { case "Sent": $array_data['sms_status'] = " AND (vops.sms_date IS NOT NULL AND vops.sms_response IS NOT NULL)"; break; case "Pending": $array_data['sms_status'] = " AND (vops.sms_date IS NULL AND vops.sms_response IS NULL)"; break; case "Error": $array_data['sms_status'] = " AND (vops.sms_date IS NULL AND vops.sms_response IS NOT NULL)"; break; default: $array_data['sms_status'] = ""; } $array_data['company_access'] = input('company_id') ? input('company_id') : implode(",", Session::get('company_permissions')); $array_data['dealer_access'] = input('dealer_id'); $result = $this->lto->getOrcrPlateList($array_data); $response['rows'] = array(); $response['total'] = $this->lto->getOrcrPlateListCount($array_data); foreach ($result as $row) { if ($row['sms_date'] && $row['sms_response'] != NULL) { $status = '<span class="right text-sm badge font-weight-normal badge-success">SMS Sent</span>'; } else if (!$row['sms_date'] && $row['sms_response'] != NULL) { // $status = '<span class="right text-sm badge font-weight-normal badge-danger">Error: ' . $row['sms_response'] . '</span>'; $smsResponse = json_decode($row['sms_response'], true); if(!$smsResponse['Error'] && $smsResponse['Failed'] == 0 && $smsResponse['Accepted']==1 ) { $status = '<span class="right text-sm badge font-weight-normal badge-success">SMS Sent</span>'; } else { $status = '<span class="right text-sm badge font-weight-normal badge-danger">Error: ' . $row['sms_response'] . '</span> '; } } else if (!$row['sms_date'] && $row['sms_response'] == NULL) { $status = '<span class="right text-sm badge font-weight-normal badge-warning">Pending</span>'; } if ($row['vops_type'] == "orcr_plate") { $type = "ORCR & Plate"; } else if ($row['vops_type'] == "orcr") { $type = "ORCR"; } else if ($row['vops_type'] == "plate") { $type = "Plate"; } if ($row['pickup_date']) { $pickupdate = date('F d, Y', strtotime($row['pickup_date'])); } else { $pickupdate = '<span data-action-pickup class=" right text-sm badge font-weight-normal badge-primary">Pick up</span>'; } $response['rows'] = array_merge( $response['rows'], array(array( 'vops_id' => $row['vops_id'], 'date' => date('F d, Y', strtotime($row['date_added'])), 'customer' => $row['type'] == "1" ? $row['first_name'] . ' ' . $row['last_name'] : $row['corporation_name'], // 'released_date' => '', 'vehicle' => $row['model_variant'], 'conduction_sticker' => $row['conduction_sticker'], 'plate' => $row['plate_number'], 'mv_file' => $row['mv_file'], 'engine_number' => $row['engine_number'], 'chassis_number' => $row['chassis_number'], 'type' => $type, 'date_received' => date('F d, Y', strtotime($row['date_received'])), 'status' => $status, 'pickup_date' => $pickupdate, 'notes' => $row['notes'], 'company_dealer' => $row['company_code'] . ' - ' . $row['dealer_code'], )) ); } response()->json($response); } public function resendAll() { $not_sent = 0; $sent = 0; $sms_model = new \App\Models\Sms; $sms_module_id = 1; //orcr_plate if ($sms_model->getSmsModuleStatus($sms_module_id)) { $response = $this->lto->getAllError(); foreach ($response as $row) { $lto_dealer_contact = $this->lto->getLtoDealerContacts($row['dealer_id']); if (count($lto_dealer_contact) <= 0) { $not_sent++; continue; } if (empty($lto_dealer_contact[0]['contact_person']) \|\| empty($lto_dealer_contact[0]['contact_phone'])) { $not_sent++; continue; } $vehicle = new \App\Models\Vehicle; $vehicle_data = $vehicle->getVehicleDataByCS($row['conduction_sticker']); //get message template if ($row['type'] == "orcr_plate") { $sms_data['message'] = $sms_model->getSmsTemplate(3); } else if ($row['type'] == "orcr") { $sms_data['message'] = $sms_model->getSmsTemplate(1); } else if ($row['type'] == "plate") { $sms_data['message'] = $sms_model->getSmsTemplate(2); } $replace_parameter = array( '[plate]' => $vehicle_data[0]['plate_number'], '[cs]' => $vehicle_data[0]['conduction_sticker'], '[brand]' => $vehicle_data[0]['brand'], '[model]' => $vehicle_data[0]['model'], '[variant]' => $vehicle_data[0]['model_variant'], '[company]' => $vehicle_data[0]['company'], '[dealer]' => $vehicle_data[0]['dealer'], '[contact_person]' => $lto_dealer_contact[0]['contact_person'], '[contact_email]' => $lto_dealer_contact[0]['contact_email'], '[contact_phone]' => $lto_dealer_contact[0]['contact_phone'], ); $sms_data['message'] = strtr($sms_data['message'], $replace_parameter); $sms_data['mobile'] = $vehicle_data[0]['mobile_phone_1']; $array_data['record_id'] = $row["id"]; //send sms to customer $excluded_year_below = 2021; if (date('Y', strtotime($row['date_received'])) <= $excluded_year_below) { $array_data['sms_date'] = date("Y-m-d h:i:s"); $array_data['sms_response'] = $excluded_year_below; $not_sent++; } else { $sms_response = Sms::sendSms($sms_data); $array_data['sms_date'] = $sms_response == SMS_SUCCESS ? date("Y-m-d h:i:s") : NULL; $array_data['sms_response'] = $sms_response; if ($sms_response == SMS_SUCCESS) { $sent++; } else { $not_sent++; } } $this->lto->updateOrcrPlateSms($array_data); } } else { response()->json(array("status" => 0, "message" => "SMS API Disabled")); } response()->json(array("sent" => $sent, "not_sent" => $not_sent, "status" => 1, "message" => "Sent")); } public function orcrPlateCreate() { // echo (input('chk_send_sms')); // exit; // print_r(input()); $is_orcr = input('chk_orcr'); $is_plate = input('chk_plate'); $is_add_anyway = input('add_anyway'); $cs = strtoupper(input('txt_cs')); $plate = strtoupper(input('txt_plate')); $or = strtoupper(input('txt_or')); $cr = strtoupper(input('txt_cr')); $mv = strtoupper(input('txt_mv')); $date_received = strtoupper(input('txt_received_date')); $engine_no = strtoupper(input('txt_en')); $chassis_no = strtoupper(input('txt_cn')); $notes = strtoupper(input('txt_notes')); $vehicle = new \App\Models\Vehicle; //check if cs is exist $vehicle_data = $vehicle->getVehicleDataByCS($cs); if (count($vehicle_data) <= 0) { $response['message'] = "Conduction sticker is not exist."; $response['status'] = 0; response()->json($response); } //VALIDATE LTO CONTACT PERSON $lto_dealer_contact = $this->lto->getLtoDealerContacts($vehicle_data[0]['dealer_id']); if (count($lto_dealer_contact) <= 0) { $response['message'] = "No LTO dealer contact information. contact system admin."; $response['status'] = 0; response()->json($response); } if (empty($lto_dealer_contact[0]['contact_person']) \|\| empty($lto_dealer_contact[0]['contact_phone'])) { $response['message'] = "Incomplete LTO dealer contact information. contact system admin."; $response['status'] = 0; response()->json($response); } $array_data['vehicle_id'] = $vehicle_data[0]['id']; $array_data['user_id'] = Session::get('user')['id']; $array_data['plate'] = Utility::removeNotAlphaNumeric($plate); $array_data['or'] = Utility::removeNotAlphaNumeric($or); $array_data['cr'] = Utility::removeNotAlphaNumeric($cr); $array_data['mv'] = Utility::removeNotAlphaNumeric($mv); $array_data['engine_no'] = Utility::removeNotAlphaNumeric($engine_no); $array_data['chassis_no'] = Utility::removeNotAlphaNumeric($chassis_no); $array_data['notes'] = $notes; $array_data['date_received'] = date("Y-m-d", strtotime($date_received)); $array_data['status'] = "1"; if ($is_orcr && $is_plate) { $array_data['type'] = "orcr_plate"; } else if ($is_orcr) { $array_data['type'] = "orcr"; } else if ($is_plate) { $array_data['type'] = "plate"; } //check if data recently added if (!input('record_id')) { if ($is_add_anyway == '0') { $existing_data = $this->lto->checkorcrPlateExisting($array_data); if (count($existing_data) > 0) { $response['status'] = 2; response()->json($response); } } } //update vehicle or cr plate if ($plate) { //check plate exist in other vehicle $vehicle->updateVehiclePlate($array_data); } if ($or) { $vehicle->updateVehicleOr($array_data); } if ($cr) { $vehicle->updateVehicleCr($array_data); } if ($mv) { $vehicle->updateVehicleMv($array_data); } if ($engine_no) { $vehicle->updateVehicleEngineNo($array_data); } if ($chassis_no) { $vehicle->updateVehicleChassisNo($array_data); } if (!input('record_id') \|\| input('chk_send_sms')) { $sms_model = new \App\Models\Sms; //get message template if ($array_data['type'] == "orcr_plate") { $sms_data['message'] = $sms_model->getSmsTemplate(3); } else if ($array_data['type'] == "orcr") { $sms_data['message'] = $sms_model->getSmsTemplate(1); } else if ($array_data['type'] == "plate") { $sms_data['message'] = $sms_model->getSmsTemplate(2); } $replace_parameter = array( '[plate]' => $vehicle_data[0]['plate_number'], '[cs]' => $vehicle_data[0]['conduction_sticker'], '[brand]' => $vehicle_data[0]['brand'], '[model]' => $vehicle_data[0]['model'], '[variant]' => $vehicle_data[0]['model_variant'], '[company]' => $vehicle_data[0]['company'], '[dealer]' => $vehicle_data[0]['dealer'], '[contact_person]' => $lto_dealer_contact[0]['contact_person'], '[contact_email]' => $lto_dealer_contact[0]['contact_email'], '[contact_phone]' => $lto_dealer_contact[0]['contact_phone'], ); $sms_data['message'] = strtr($sms_data['message'], $replace_parameter); $sms_data['mobile'] = $vehicle_data[0]['mobile_phone_1']; // if ($sms_data['mobile'] == '+639399064816') { // $sms_data['mobile'] = "+639176331398"; //debug // } //check if sms module is enabled $sms_module_id = 1; //orcr_plate if ($sms_model->getSmsModuleStatus($sms_module_id)) { //send sms to customer $excluded_year_below = 2021; if (!input('record_id') && date('Y', strtotime($date_received)) <= $excluded_year_below) { $array_data['sms_date'] = date("Y-m-d h:i:s"); $array_data['sms_response'] = $excluded_year_below; } else { $sms_response = Sms::sendSms($sms_data); if (empty($sms_response)) { $sms_response = SMS_SUCCESS; } $array_data['sms_date'] = $sms_response == SMS_SUCCESS ? date("Y-m-d h:i:s") : NULL; $array_data['sms_response'] = $sms_response; } } else { $array_data['sms_date'] = NULL; $array_data['sms_response'] = NULL; } } //update data to database if (input('record_id')) { $array_data['record_id'] = input('record_id'); if (input('chk_send_sms')) { $this->lto->updateOrcrPlateSms($array_data); } $this->lto->updateOrcrPlate($array_data); } else { $this->lto->createOrcrPlateWithSMS($array_data); } //insert data to database $response['message'] = "Data successfully created."; $response['status'] = 1; response()->json($response); } public function orcrPlatePickup() { // echo (input('chk_send_sms')); // exit; // print_r(input()); $this->lto->updateOrcrPlatePickup(array(input('id'))); $response['message'] = "Data successfully saved."; $response['status'] = 1; response()->json($response); } function orcrImportFields() { $import = new \App\Models\Import; $result = $import->getImportFields(2); $response = array(); foreach ($result as $row) { $response[$row['id']] = $row; } response()->json($response); } public function orcrImport() { $disk_dir = APP_DISK . input('dir'); if (!file_exists($disk_dir)) { mkdir($disk_dir, 0777, true); } $log_dir = APP_DISK . input('log_dir'); if (!file_exists($log_dir)) { mkdir($log_dir, 0777, true); } $import = new \App\Models\Import; $import_fields = json_decode(input('import_fields'), true); foreach ($import_fields as $key => $value) { $import->updateImportFields(array( 'key' => $key, 'value' => $value, )); } // $destinationFilname = sprintf('%s.%s', uniqid(), $image->getExtension()); // $image->move(sprintf('/uploads/%s', $destinationFilename)); $object = input()->file('file', $defaultValue = null); if ($object->getSize() <= 0) { $response['message'] = "File is empty"; $response['status'] = 0; response()->json($response); } else { //check extension $valid_ext = array('xls', 'csv', 'xlsx'); if (!in_array($object->getExtension(), $valid_ext)) { $response['message'] = "Invalid file extension"; $response['status'] = 0; response()->json($response); } //gen filename $destinationFilename = sprintf('%s.%s', Uuid::long(), $object->getExtension()); //move file $full_dir = $disk_dir . '/' . $destinationFilename; $object->move($full_dir); // start import process $GLOBALS['total_data_count'] = 0; $GLOBALS['not_inserted_data_count'] = 0; $GLOBALS['inserted_data_count'] = 0; $GLOBALS['not_inserted_list_v2'] = array(); $GLOBALS['data_count_list_v2'] = array(); $file_type = \PhpOffice\PhpSpreadsheet\IOFactory::identify($full_dir); $reader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader($file_type); try { $spreadsheet = $reader->load($full_dir); //remove excel after store to phpspreadsheet unlink($full_dir); $data = $spreadsheet->getActiveSheet()->toArray(); $highestRow = $spreadsheet->getActiveSheet()->getHighestRow(); $highestColumn = $spreadsheet->getActiveSheet()->getHighestColumn(); $ColumnNumber = \PhpOffice\PhpSpreadsheet\Cell\Coordinate::columnIndexFromString($highestColumn); $data = array_map(array(new Utility(), 'upperCaseNestedArray'), $data); $header_column_found = false; foreach ($data as $row) { if (!empty(array_filter($row))) { // echo 'Not empty row'; } else { continue; } $row = array_filter($row); if (!$header_column_found) { // get matched field from database and excel globals $issue_summary_index = $import->getSummaryIndex('SUMMARY', $ColumnNumber, $row); $GLOBALS['conduction_sticker'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[11])); $GLOBALS['plate_number'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[12])); $GLOBALS['mv_file'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[13])); $GLOBALS['date'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[14])); $GLOBALS['notes'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[15])); $GLOBALS['engine_number'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[16])); $GLOBALS['chassis_number'] = $import->getFieldName($row, $ColumnNumber, array($import_fields[17])); // check required fields if ( !empty($GLOBALS['conduction_sticker']) && !empty($GLOBALS['plate_number']) && !empty($GLOBALS['mv_file']) && !empty($GLOBALS['date']) && !empty($GLOBALS['notes']) && !empty($GLOBALS['engine_number']) && !empty($GLOBALS['chassis_number']) ) { $header_column_found = true; $GLOBALS['row_headers'] = $row; continue; } } else { $GLOBALS['total_data_count']++; $data_conduction_sticker = $import->checkExist($row, $GLOBALS['conduction_sticker'], $GLOBALS['row_headers']); $data_plate_number = $import->checkExist($row, $GLOBALS['plate_number'], $GLOBALS['row_headers']); $data_plate_number = Utility::removeNotAlphaNumeric($data_plate_number); $data_mv_file = $import->checkExist($row, $GLOBALS['mv_file'], $GLOBALS['row_headers']); $data_mv_file = Utility::removeNotAlphaNumeric($data_mv_file); $data_date = $import->checkExist($row, $GLOBALS['date'], $GLOBALS['row_headers']); $data_date = date('Y-m-d', strtotime($data_date)); $data_notes = $import->checkExist($row, $GLOBALS['notes'], $GLOBALS['row_headers']); $data_engine_number = $import->checkExist($row, $GLOBALS['engine_number'], $GLOBALS['row_headers']); $data_engine_number = Utility::removeNotAlphaNumeric($data_engine_number); $data_chassis_number = $import->checkExist($row, $GLOBALS['chassis_number'], $GLOBALS['row_headers']); $data_chassis_number = Utility::removeNotAlphaNumeric($data_chassis_number); //Validations if (empty($data_conduction_sticker)) { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("NO CONDUCTION STICKER"), $row); $GLOBALS['not_inserted_data_count']++; continue; } if ($data_date == "1970-01-01") { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("NO DATE"), $row); $GLOBALS['not_inserted_data_count']++; continue; } if (strtotime($data_date) > strtotime(date('Y-m-d'))) { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("INVALID DATE"), $row); $GLOBALS['not_inserted_data_count']++; continue; } if ($data_date == "1970-01-01") { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("NO DATE"), $row); $GLOBALS['not_inserted_data_count']++; continue; } $vehicle = new \App\Models\Vehicle; $vehicle_data = $vehicle->getVehicleDataByCS($data_conduction_sticker); if (count($vehicle_data) <= 0) { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("VEHICLE DATA NOT EXIST IN SYSTEM"), $row); $GLOBALS['not_inserted_data_count']++; continue; } $lto_dealer_contact = $this->lto->getLtoDealerContacts($vehicle_data[0]['dealer_id']); if (count($lto_dealer_contact) <= 0) { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("NO LTO DEALER CONTACT INFO"), $row); $GLOBALS['not_inserted_data_count']++; continue; } if (empty($lto_dealer_contact[0]['contact_person']) \|\| empty($lto_dealer_contact[0]['contact_phone'])) { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("INCOMPLETE LTO DEALER CONTACT INFO"), $row); $GLOBALS['not_inserted_data_count']++; continue; } $array_data['vehicle_id'] = $vehicle_data[0]['id']; $array_data['user_id'] = Session::get('user')['id']; $array_data['plate'] = $data_plate_number; $array_data['mv'] = $data_mv_file; $array_data['date_received'] = $data_date; $array_data['notes'] = $data_notes; $array_data['engine_no'] = $data_engine_number; $array_data['chassis_no'] = $data_chassis_number; $array_data['status'] = "1"; //identify the type if ($data_mv_file && $data_plate_number) { $array_data['type'] = "orcr_plate"; $vehicle->updateVehiclePlate($array_data); $vehicle->updateVehicleMv($array_data); } else if ($data_mv_file) { $array_data['type'] = "orcr"; $vehicle->updateVehicleMv($array_data); } else if ($data_plate_number) { $array_data['type'] = "plate"; $vehicle->updateVehiclePlate($array_data); } else { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("NO MV FILE OR PLATE"), $row); $GLOBALS['not_inserted_data_count']++; continue; } $existing_data = $this->lto->checkorcrPlateExisting($array_data); if (count($existing_data) > 0) { $GLOBALS['not_inserted_list_v2'][] = array_merge(array("ALREADY UPLOADED IN SYSTEM"), $row); $GLOBALS['not_inserted_data_count']++; continue; } if ($data_engine_number) { $vehicle->updateVehicleEngineNo($array_data); } if ($data_chassis_number) { $vehicle->updateVehicleChassisNo($array_data); } $array_data['record_id'] = $this->lto->createOrcrPlate($array_data); //for 2021 records fill the sms $excluded_year_below = 2021; if (date('Y', strtotime($data_date)) <= $excluded_year_below) { $array_data['sms_date'] = date("Y-m-d h:i:s"); $array_data['sms_response'] = $excluded_year_below; $this->lto->updateOrcrPlateSms($array_data); } $GLOBALS['not_inserted_list_v2'][] = array_merge(array("SUCCESS IMPORT"), $row); $GLOBALS['inserted_data_count']++; } } if (!$header_column_found) { $return_arr["status"] = 2; $return_arr["message"] = " Header not found."; response()->json($return_arr); } else { $return_arr["status"] = 1; $return_arr["gen_file"] = $destinationFilename; $return_arr["orig_file"] = $object->getFilename(); $return_arr["total"] = $GLOBALS['total_data_count']; $return_arr["inserted"] = $GLOBALS['inserted_data_count']; $return_arr["not_inserted"] = $GLOBALS['not_inserted_data_count']; $return_arr["message"] = " File Uploaded."; ///START GEN LOG $spreadsheet = new \PhpOffice\PhpSpreadsheet\Spreadsheet(); $GLOBALS['data_count_list_v2'][] = array("Total Data", (string) ($GLOBALS['total_data_count'])); $GLOBALS['data_count_list_v2'][] = array("Inserted Data", (string) ($GLOBALS['inserted_data_count'])); $GLOBALS['data_count_list_v2'][] = array("Not Inserted Data", (string) ($GLOBALS['not_inserted_data_count'])); $GLOBALS['data_count_list_v2'][] = array("Import By", (string) Session::get('user')['first_name'] . ' ' . Session::get('user')['last_name']); $GLOBALS['data_count_list_v2'][] = array("Import Date", (string) date('F d, Y')); $data_count_list_v2_count = count($GLOBALS['data_count_list_v2']); $spreadsheet ->getActiveSheet() ->getStyle('B' . ($data_count_list_v2_count + 1) . ':' . (string) $highestColumn . ($data_count_list_v2_count + 1)) ->getFill() ->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID) ->getStartColor() ->setARGB('FFFF00'); $spreadsheet ->getActiveSheet() ->getStyle('A' . ($data_count_list_v2_count + 1) . '') ->getFill() ->setFillType(\PhpOffice\PhpSpreadsheet\Style\Fill::FILL_SOLID) ->getStartColor() ->setARGB('FF0000'); $spreadsheet->getActiveSheet()->getStyle('A' . ($data_count_list_v2_count + 1)) ->getFont()->getColor()->setARGB(\PhpOffice\PhpSpreadsheet\Style\Color::COLOR_WHITE); $sheet = $spreadsheet->getActiveSheet(); for ($i = 'A'; $i != $highestColumn; $i++) { $sheet->getColumnDimension($i)->setAutoSize(true); } foreach ($GLOBALS['not_inserted_list_v2'] as $key => $subArr) { unset($subArr[intval($issue_summary_index) + 1]); $GLOBALS['not_inserted_list_v2'][$key] = $subArr; } unset($GLOBALS['row_headers'][intval($issue_summary_index)]); usort($GLOBALS['not_inserted_list_v2'], function ($a, $b) { return $a[0] <=> $b[0]; }); $GLOBALS['not_inserted_list_v2'] = array_merge(array(array_map("strtoupper", array_merge(array('SUMMARY'), $GLOBALS['row_headers']))), $GLOBALS['not_inserted_list_v2']); if ($data_count_list_v2_count > 0) { $GLOBALS['not_inserted_list_v2'] = array_merge($GLOBALS['data_count_list_v2'], $GLOBALS['not_inserted_list_v2']); } $sheet->fromArray($GLOBALS['not_inserted_list_v2'], NULL, 'A1'); $writer = new \PhpOffice\PhpSpreadsheet\Writer\Xlsx($spreadsheet); $writer->save($log_dir . '/' . $destinationFilename); //END GEN LOG // echo json_encode($return_arr); response()->json($return_arr); } } catch (\Exception $e) { $response['message'] = "Error has occured " . $e; $response['status'] = 0; response()->json($response); } } } public function orcrImportSummaryDownload() { $log_dir = APP_DISK . "import/orcr_plate/logs/"; $file = $log_dir . input('file'); $fp = fopen($file, 'rb'); header("Content-Type: application/octet-stream"); header("Content-Disposition: attachment; filename=" . escape(input('name')) . ""); header("Content-Length: " . filesize($file)); fpassthru($fp); } public function orcrPlateSmsUpdateCron() { // curl -H "App-Dev-Id: 626ca81708a1f" https://localhost/cron/lto/orcr_plate/sms --insecure // curl -H "App-Dev-Id: 626ca81708a1f" https://connect.autohub.ph/cron/lto/orcr_plate/sms $headers = apache_request_headers(); if (!isset($headers['App-Dev-Id'])) { echo "Access Denied"; exit; } if ($headers['App-Dev-Id'] != "626ca81708a1f") { echo "Invalid Key"; exit; } $array_data['company_access'] = ""; $array_data['search'] = ""; $array_data['date_added'] = ""; $array_data['date_received'] = ""; $array_data['company_access'] = ""; $array_data['dealer_access'] = ""; $array_data['sort'] = ""; $array_data['sms_status'] = " AND (vops.sms_date IS NULL AND vops.sms_response IS NULL)"; $response = $this->lto->getNoSmsOrcrPlateList($array_data); $sms_model = new \App\Models\Sms; //get templates $template['orcr_plate'] = $sms_model->getSmsTemplate(3); $template['plate'] = $sms_model->getSmsTemplate(2); $template['orcr'] = $sms_model->getSmsTemplate(1); foreach ($response as $row) { if ($row['vops_type'] == "orcr_plate") { $sms_data['message'] = $template['orcr_plate']; } else if ($row['vops_type'] == "orcr") { $sms_data['message'] = $template['orcr']; } else if ($row['vops_type'] == "plate") { $sms_data['message'] = $template['plate']; } $array_data['record_id'] = $row['vops_id']; $replace_parameter = array( '[plate]' => $row['plate_number'], '[cs]' => $row['conduction_sticker'], '[brand]' => $row['brand'], '[model]' => $row['model'], '[variant]' => $row['model_variant'], '[company]' => $row['company'], '[dealer]' => $row['dealer'], '[contact_person]' => $row['contact_person'], '[contact_email]' => $row['contact_email'], '[contact_phone]' => $row['contact_phone'], ); $sms_data['message'] = strtr($sms_data['message'], $replace_parameter); $sms_data['mobile'] = $row['mobile_phone_1']; // $sms_data['mobile'] = "+639389592854"; //debug //check if sms module is enabled $sms_module_id = 1; //orcr_plate if ($sms_model->getSmsModuleStatus($sms_module_id)) { if (empty($row['contact_person']) \|\| empty($row['contact_phone'])) { $array_data['sms_date'] = NULL; $array_data['sms_response'] = "No LTO Dealer contact"; } else { //send sms to customer $sms_response = Sms::sendSms($sms_data); $array_data['sms_date'] = $sms_response == SMS_SUCCESS ? date("Y-m-d h:i:s") : NULL; $array_data['sms_response'] = $sms_response; } } else { $array_data['sms_date'] = NULL; $array_data['sms_response'] = NULL; } $this->lto->updateOrcrPlateSms($array_data); } } public function orcrStatusByCSMobile() { if (!input('mobile') && !input('cs') && !input('email')) { $response['message'] = "Insufficient parameters."; $response['status'] = 0; response()->json($response); } $array_data['mobile'] = \App\Utilities\MobileFormatter::format(Utility::removeNotAlphaNumeric(input('mobile'))); $array_data['cs'] = Utility::removeNotAlphaNumeric(input('cs')); $array_data['email'] = input('email'); // if (!empty($array_data['mobile']) && empty($array_data['cs'])) { // $array_data['search'] = " AND cc.mobile_phone_1 LIKE ? AND ?"; // $array_data['search_keyword'][0] = "%" . $array_data['mobile'] . "%"; // $array_data['search_keyword'][1] = "1"; // } else if (empty($array_data['mobile']) && !empty($array_data['cs'])) { // $array_data['search'] = " AND v.conduction_sticker = ? AND ? "; // $array_data['search_keyword'][0] = $array_data['cs']; // $array_data['search_keyword'][1] = "1"; // } else { // $array_data['search'] = " AND ( // cc.mobile_phone_1 LIKE ? // OR v.conduction_sticker = ? // ) // "; // $array_data['search_keyword'][0] = "%" . $array_data['mobile'] . "%"; // $array_data['search_keyword'][1] = $array_data['cs']; // } if (!empty($array_data['mobile']) && !empty($array_data['cs'])) { $array_data['search'] = " AND (REPLACE(cc.mobile_phone_1, '+63', '' ) = ? OR v.conduction_sticker = ?) "; $array_data['search_keyword'][0] = $array_data['mobile']; $array_data['search_keyword'][1] = $array_data['cs']; } else if (!empty($array_data['mobile'])) { $array_data['search'] = " AND REPLACE(cc.mobile_phone_1, '+63', '' ) = ? AND ?"; $array_data['search_keyword'][0] = $array_data['mobile']; $array_data['search_keyword'][1] = "1"; } else if (!empty($array_data['cs'])) { $array_data['search'] = " AND v.conduction_sticker = ? AND ? "; $array_data['search_keyword'][0] = $array_data['cs']; $array_data['search_keyword'][1] = "1"; } else if (!empty($array_data['email'])) { $array_data['search'] = " AND cc.email_1 = ? AND ? "; $array_data['search_keyword'][0] = $array_data['email']; $array_data['search_keyword'][1] = "1"; } $result = $this->lto->getOrcrPlateStatusList($array_data); $response['data'] = array(); foreach ($result as $row) { if ($row['sms_date'] && $row['sms_response'] != NULL) { $status = 'SMS Sent'; //'<span class="right text-sm badge font-weight-normal badge-success">SMS Sent</span>'; } else if (!$row['sms_date'] && $row['sms_response'] != NULL) { $status = 'Error'; //'<span class="right text-sm badge font-weight-normal badge-danger">Error: ' . $row['sms_response'] . '</span>'; } else if (!$row['sms_date'] && $row['sms_response'] == NULL) { $status = 'Pending'; //'<span class="right text-sm badge font-weight-normal badge-warning">Pending</span>'; } if ($row['vops_type'] == "orcr_plate") { $type = "ORCR & Plate"; } else if ($row['vops_type'] == "orcr") { $type = "ORCR"; } else if ($row['vops_type'] == "plate") { $type = "Plate"; } $response['data'] = array_merge( $response['data'], array(array( 'id' => $row['vehicle_id'], 'date_add' => date('F d, Y', strtotime($row['date_added'])), 'customer' => $row['type'] == "1" ? $row['first_name'] . ' ' . $row['last_name'] : $row['corporation_name'], 'firstname' => $row['type'] == "1" ? $row['first_name'] : '', 'lastname' => $row['type'] == "1" ? $row['last_name'] : '', 'mobile' => $row['mobile_phone_1'], 'brand' => $row['brand'], 'model' => $row['model'], // 'released_date' => '', 'vehicle' => $row['model_variant'], 'conduction_sticker' => $row['conduction_sticker'], 'plate' => $row['plate_number'], 'mv_file' => $row['mv_file'], 'engine_number' => $row['engine_number'], 'chassis_number' => $row['chassis_number'], 'type' => $type, 'date_received' => date('F d, Y', strtotime($row['date_received'])), 'date_pickup' => $row['pickup_date'] ? date('F d, Y', strtotime($row['pickup_date'])) : '', 'sms_status' => $status, 'plate_status' => $row['pickup_date'] ? 'Picked-up' : ($this->lto->getPlateStatus(array($row['vehicle_id'])) ? 'Available' : 'Not Available'), 'orcr_status' => $row['pickup_date'] ? 'Picked-up' : ($this->lto->getORCRStatus(array($row['vehicle_id'])) ? 'Available' : 'Not Available'), 'notes' => $row['notes'], 'company_dealer' => $row['company_code'] . ' - ' . $row['dealer_code'], 'sales_person' => $row['sales_person'], 'sc_id' => $row['asa_sales_person'], )) ); } $response['message'] = count($response['data']) ? 'Success' : 'No data fetched.'; $response['status'] = count($response['data']) ? 1 : 0; response()->json($response); } } ��Controllers/TestController.php��0000644��00000000443�15025010271�0012540 0��ustar�00��<?php namespace App\Controllers; class TestController { public function profile() { echo "FUNC"; } public function homeAction($id) { echo $id; exit; print_r($_REQUEST); echo "<br>"; print_r(get_defined_vars()); } } ��Controllers/UserController.php��0000644��00000000400�15025010271�0012530 0��ustar�00��<?php namespace App\Controllers; class UserController { public function profile() { echo "FUNC"; } public function homeAction() { print_r($_REQUEST); echo "<br>"; print_r(get_defined_vars()); } } ��Controllers/IndustryController.php��0000644��00000000651�15025010271�0013443 0��ustar�00��<?php namespace App\Controllers; use App\Core\Controller; use App\Core\Sms; use App\Utilities\Session; use App\Utilities\Uuid; use App\Utilities\Utility; class IndustryController extends Controller { private $industry; function __construct() { $this->industry = new \App\Models\Industry; } public function industryIndex() { include('resources/views/industry/industry.php'); } } ��Controllers/FileController.php��0000644��00000005006�15025010271�0012500 0��ustar�00��<?php namespace App\Controllers\Admin; use App\Core\View; use App\Core\Controller; use App\Utilities\Uuid; use Gumlet\ImageResize; use App\Utilities\Session; class FileController extends Controller { private $file; // Image files private $imageQuality = 80; //percent function __construct() { $this->file = new \App\Models\File; } public function upload() { $dir = input('dir'); $disk_dir = APP_DISK . '/' . $dir; if (!file_exists($disk_dir)) { mkdir($disk_dir, 0777, true); } $destinationFilename = ""; $object = input()->file('file', $defaultValue = null); // .pdf, .doc, .docx, .txt, .html, .htm, .ppt, .pptx, .xls, .csv, .xlsx, .png, .jpeg, .jpg, .mp4, .mkv, .mov, .avi, .wmv //check file if empty if ($object->getSize() <= 0) { $response['message'] = "File is empty"; $response['status'] = 0; } else { if ($object->getMime() === 'image/jpeg' \|\| $object->getMime() === 'image/png' \|\| $object->getMime() === 'image/gif') { //resize the file $image = new ImageResize($object->getTmpName()); $image->scale($this->imageQuality); //generate filename $destinationFilename = $dir . '/' . sprintf('%s.%s', Uuid::long(), $object->getExtension()); //save the file to disk $image->save(APP_DISK . '/' . $destinationFilename); } else { // echo "Modify me"; } //other file formats //insert file information to database $array_data['disk'] = APP_DISK; $array_data['user'] = Session::get('user')['id']; $array_data['filename'] = $object->getFilename(); $array_data['path'] = $destinationFilename; $array_data['mime'] = $object->getMime(); $array_data['extension'] = $object->getExtension(); $array_data['size'] = $object->getSize(); $file_id = $this->file->createFile($array_data); if ($file_id) { $response['id'] = $file_id; $response['path'] = $destinationFilename; $response['message'] = "Database upload successful"; $response['status'] = 1; } else { $response['message'] = "Database upload failed"; $response['status'] = 0; } } response()->json($response); } } ��Controllers/PageController05-06-24.php��0000644��00000012055�15025010271�0013312 0��ustar�00��<?php namespace App\Controllers; class PageController { public function error404() { echo "Error 404 file not found."; } public function error403() { echo "Error 403 forbidden."; } function activate() { include('resources/views/employees/activate.php'); } function auto_sms_service() { include('resources/views/sms_service/auto_sms_service.php'); } function car_club() { $page_title = "Car Clubs"; include('resources/views/car_club/list.php'); } function car_club_view($id) { $page_title = "Car Club Profile"; include('resources/views/car_club/view.php'); } function car_club_affiliation() { $page_title = "Car Clubs (Affiliation)"; include('resources/views/car_club_affiliation/list.php'); } function car_club_affiliation_view($id) { $page_title = "Car Club Profile"; include('resources/views/car_club_affiliation/view.php'); } function car_club_view1($id, $plate, $date) { include('resources/views/test1.php'); } function compliance() { include('resources/views/sc_compliance/compliance.php'); } function compliance_clients() { include('resources/views/sc_compliance/compliance_clients.php'); } function compliancestatus() { include('resources/views/sc_compliance/compliancestatus.php'); } function customer() { include('resources/views/customers/customer.php'); } function customer_view() { include('resources/views/customers/customer_view.php'); } //CUSTOMER UPDATE function customer_update_view() { include('resources/views/customer_update/customer_view.php'); } function customer_update_dealer_view() { include('resources/views/customer_update/assign_dealer_view.php'); } function customer_update() { include('resources/views/customer_update/customer_update.php'); } function dealer_assign() { include('resources/views/customer_update/dealer_assignment.php'); } function user_assignment() { include('resources/views/customer_update/dealer_assignment_user.php'); } function dealer_assinged_user() { include('resources/views/customer_update/dealer_assigned_user_list.php'); } function customer_update_assinged() { include('resources/views/customer_update/customer_update_assigned.php'); } function u_customer_update_assinged() { include('resources/views/customer_update/u_customer_update_assigned.php'); } function dashboard1() { include('resources/views/dashboard/dashboard.php'); } function employee() { include('resources/views/employees/employee.php'); } function finance_list() { include('resources/views/finance/financelist.php'); } function finance_information($plate_cs_number) { include('resources/views/finance/finance_information.php'); } function finance_dashboard() { include('resources/views/finance/financedashboard.php'); } function finance_pdc_information($pdc_plate_cs_number) { include('resources/views/finance_pdc/finance_pdc_information.php'); } function finance_pdc_list() { include('resources/views/finance_pdc/finance_pdc_list.php'); } function forgot() { include('resources/views/employees/forgot.php'); } function gen_key() { include('resources/views/misc/key.php'); } function home() { header('location:home.php'); } function menu() { include('resources/views/home/home.php'); } function profile() { include('resources/views/employees/profile.php'); } function profile_home() { include('resources/views/employees/profile_home.php'); } function recover() { include('resources/views/employees/recover.php'); } function sale() { include('resources/views/sales/sales.php'); } function sc_compliance() { include('resources/views/sc_compliance/sc_compliance.php'); } function sc_compliance_clients() { include('resources/views/sc_compliance/sc_compliance_clients.php'); } function sc_compliance_client() { include('resources/views/sc_compliance/sc_compliance_client.php'); } function service() { include('resources/views/services/service.php'); } function service_view() { include('resources/views/services/service_view.php'); } function signin() { include('resources/views/employees/signin.php'); } function signup() { include('resources/views/employees/signup.php'); } function vehicle() { include('resources/views/vehicles/vehicle.php'); } function vehicle_view() { include('resources/views/vehicles/vehicle_view.php'); } } ��Controllers/NatureOfBusinessController.php��0000644��00000017027�15025010271�0015066 0��ustar�00��<?php namespace App\Controllers; use App\Core\Controller; use App\Core\Sms; use App\Utilities\Session; use App\Utilities\Uuid; use App\Utilities\Utility; class NatureOfBusinessController extends Controller { private $nob; private $nob_perm = array(); function __construct() { $this->nob = new \App\Models\NatureOfBusiness; //access if (isset(Session::get('action_permissions')['5']['53']['25'])) { $this->nob_perm = Session::get('action_permissions')['5']['53']['25']; } if (isset(Session::get('action_permissions')['5']['53']['27'])) { $this->nob_perm = Session::get('action_permissions')['5']['53']['27']; } } public function topNatureOfBusinessIndex() { //access if (!in_array("1", $this->nob_perm)) { response()->redirect("/index.php"); } $page_title = "Top Nature of Business"; //get the attributes $attribute_list = $this->nob->getNatureOfBusinessCategories(); $nob_cat_options = ""; foreach ($attribute_list as $row) { $nob_cat_options .= '<option value="' . $row['id'] . '">' . $row['name'] . '</option>'; } include('resources/views/nature_of_business/top/list.php'); } public function summaryReport() { //access if (!in_array("1", $this->nob_perm)) { response()->redirect("/index.php"); } $page_title = "NoB Summary Report"; include('resources/views/nature_of_business/top/summary_report.php'); } public function topNatureOfBusinessList($cat_id) { if (!in_array("1", $this->nob_perm)) { response()->redirect("/index.php"); } $page_title = $this->nob->getNatureOfBusinessInfo($cat_id)[0]['name']; $attribute_list = $this->nob->getNatureOfBusinessCategories(); $nob_cat_options = ""; foreach ($attribute_list as $row) { if ($cat_id == $row['id']) { $nob_cat_options .= '<option value="' . $row['id'] . '" selected>' . $row['name'] . '</option>'; } else { $nob_cat_options .= '<option value="' . $row['id'] . '">' . $row['name'] . '</option>'; } } include('resources/views/nature_of_business/top/data.php'); } public function natureOfBusinessData(){ $array_data['offset'] = input('offset'); $array_data['limit'] = input('limit'); $array_data['offset_limit'] = " LIMIT " . $array_data['offset'] . "," . $array_data['limit'] . ""; $array_data['sort'] = empty(input('sort')) ? " ORDER BY date DESC" : " ORDER BY " . input('sort') . " " . input('order'); $array_data['category'] = !empty(input('nob_id')) ? " AND snob.id = " . input('nob_id') . "" : ""; // start date filter if (empty(input('start_sales_date'))) { $array_data['sales_date'] = ""; } else { $array_data['sales_date'] = " AND DATE_FORMAT(s.activity_date,'%Y-%m-%d') BETWEEN '" . input('start_sales_date') . "' AND '" . input('end_sales_date') . "' "; } $array_data['company_access'] = input('company_id') ? input('company_id') : implode(",", Session::get('company_permissions')); $array_data['dealer_access'] = input('dealer_id'); $array_data['company_access'] = " AND sc.id IN (" . $array_data['company_access'] . ")"; if ($array_data['dealer_access']) { $array_data['dealer_access'] = " AND sd.id IN (" . $array_data['dealer_access'] . ")"; } $result = $this->nob->getNatureOfBusinessData($array_data); $response['rows'] = array(); $response['total'] = $this->nob->getNatureOfBusinessDataCount($array_data); // $nob_perm = Session::get('action_permissions')['5']['53']['25']; foreach ($result AS $row) { $response['rows'] = array_merge( $response['rows'], array(array( 'id' => $row['id'], 'sales_id' => $row['sales_id'], 'date' => date('F d, Y', strtotime($row['date'])), 'customer' => $row['customer'], 'mobile' => (!in_array("2", $this->nob_perm)) ? Utility::maskString($row['mobile']) : "<a href='tel:" . $row['mobile'] . "'>" . $row['mobile'] . "</a>", 'mobile_var' => $row['mobile'], 'email' => (!in_array("3", $this->nob_perm)) ? Utility::maskEmail($row['email']) : "<a href='mailto:" . $row['email'] . "'>" . $row['email'] . "</a>", 'company' => $row['company'] . ' - ' . $row['dealer'], 'nob' => $row['nob'], 'sales_id' => $row['sales_id'], 'sms' => $row['sms'] != NULL ? '<span><i class="fas fa-check-circle" style="color: green;"></i></span>' : '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>', 'called' => $row['called'] != NULL ? '<span><i class="fas fa-check-circle" style="color: green;"></i></span>' : '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>', 'sms_var' => $row['sms'], 'called_var' => $row['called'] )) ); } response()->json($response); } public function natureOfBusinessCategoryCount() { $array_data['company_access'] = input('company_id') ? input('company_id') : implode(",", Session::get('company_permissions')); $array_data['dealer_access'] = input('dealer_id'); $array_data['category'] = input('category'); $array_data['company_access'] = " AND sc.id IN (" . $array_data['company_access'] . ")"; if ($array_data['dealer_access']) { $array_data['dealer_access'] = " AND sd.id IN (" . $array_data['dealer_access'] . ")"; } if ($array_data['category']) { $array_data['category'] = " AND snob.id IN (" . $array_data['category'] . ")"; } if (empty(input('start_sales_date'))) { $array_data['sales_date'] = ""; } else { $array_data['sales_date'] = " AND DATE_FORMAT(s.activity_date,'%Y-%m-%d') BETWEEN '" . input('start_sales_date') . "' AND '" . input('end_sales_date') . "' "; } $response = $this->nob->getNatureOfBusinessCategoryCount($array_data); response()->json($response); } public function tableListAction() { $array_data['offset'] = input('offset'); $array_data['limit'] = input('limit'); $array_data['offset_limit'] = " LIMIT " . $array_data['offset'] . "," . $array_data['limit'] . ""; $array_data['sales_id'] = input('sales_id'); $action_list = $this->nob->tableAction($array_data); response()->json($action_list); } public function makeSmsCall() { $array_data['type'] = input('type'); $array_data['sales_id'] = input('sales_id'); $array_data['phone'] = input('phone'); $sms_call = $this->nob->smsCall($array_data); response()->json($sms_call); } public function remarks() { $array_data['remarks'] = input('remarks'); $array_data['sales_id'] = input('sales_id'); $remarks = $this->nob->remarks($array_data); response()->json($remarks); } public function loadRemarks() { $array_data['sales_id'] = input('sales_id'); $remarks = $this->nob->loadRemarks($array_data); response()->json($remarks); } } ��Controllers/DashboardController.php��0000644��00000000362�15025010271�0013510 0��ustar�00��<?php namespace App\Controllers; class DashboardController { function test() { require_once(__DIR__ . '/../Classes/dashboard.class.php'); $dashboard_class = new Dashboard(); $dashboard_class->test(); } } ��Controllers/Customer_update.php��0000644��00000161373�15025010271�0012732 0��ustar�00��<?php namespace App\Controllers; use App\Core\Controller; use App\Core\Database; // use App\Core\Sms; // use App\Utilities\Session; // use App\Utilities\Uuid; use App\Utilities\Utility; // use App\Controllers\Customer; // include_once("Customer.php"); // include_once("../../api/controllers/customer.php"); // token =b0JCRy9CcUZEOFhrV1ErSE9CTW5IVmR2YkZZNDJaeS8xSU9jNkJjczJMWT0= // Utility::str_encrypt('28D4DE7C6AFD6'); // Utility::str_decrypt('b0JCRy9CcUZEOFhrV1ErSE9CTW5IVmR2YkZZNDJaeS8xSU9jNkJjczJMWT0='); define('API_TOKEN', 'b0JCRy9CcUZEOFhrV1ErSE9CTW5IVmR2YkZZNDJaeS8xSU9jNkJjczJMWT0='); // Check if token is provided and valid if (!isset($_REQUEST['token']) \|\| $_REQUEST['token'] !== API_TOKEN) { http_response_code(401); // Unauthorized echo json_encode(array("error" => "Unauthorized")); exit; } class Customer_update extends Controller { private $customer; public function test() { echo Utility::str_encrypt('autohubgroupAppDev0406224'); } function __construct() { // $this->lto = new \App\Models\Lto; // include_once(__DIR__ . '/Customer.php'); // $this->customer = new Customer; // $this->dealer = new \App\Models\Dealer; } public function cu_profile() { $customer_id = isset($_REQUEST['customer_id']) ? $_REQUEST['customer_id'] : '-1'; // $customer_profile = $this->customer->read_customer_profile_display($customer_id, $granted_company_ids, Database::connectDB()); // var_dump($customer_profile); $query_customer_info = "SELECT DATE_FORMAT(ci.date_modified, '%M %d, %Y - %h:%i:%s %p') AS date_modified, em.first_name AS emfname, em.middle_name AS emmname, em.last_name AS emlname, ci.id, ci.corporation_id,snob.name as profession ,sr.name as religion, ci.corporation_name,ci.first_name, ci.middle_name, ci.last_name, g.gender_name, DATE_FORMAT(ci.date_created, '%M %d, %Y') AS date_created, cc.email_1, cc.email_2, cc.email_3, cc.mobile_phone_1, cc.mobile_phone_2,cc.mobile_phone_3, cc.residential_phone, cc.fax_phone, cc.business_phone, cc.landline, sx.suffix_name AS suffix, ac.nationality, ci.no_of_children, ci.occupation, ams.name AS marital_status, DATE_FORMAT(ci.date_of_birth, '%M %d, %Y') AS birthdate,ci.contact_person, ci.time_created, cc.address_1, cc.address_2, acity1.citymunDesc AS address_1_city, sc.code AS source_company, sd.code AS source_dealer, sdms.name AS source_dms, acity2.citymunDesc AS address_2_city, cc.address_1_postal, cc.address_2_postal, ci.photo, ci.spouse_name, DATE_FORMAT(ci.date_uploaded, '%M %d, %Y - %h:%i:%s %p') AS date_uploaded, e.first_name AS efname, e.middle_name AS emname, e.last_name AS elname, TIMESTAMPDIFF(YEAR,ci.date_of_birth, CURDATE()) as age_number , ci.type, cc.viber, cc.facebook, cc.instagram, cc.whatsapp, cc.telegram, cc.website,snb.name as nature_of_business, ( IF( ci.category_id <> 0,ccat.name, IF( COUNT(se.id) > 0 && COUNT(s.id) < 1, 'SVO', IF( COUNT(se.id) < 1 && COUNT(s.id) > 0, 'SAO', IF( COUNT(v.id) = 1 && COUNT(se.id) > 0 && COUNT(s.id) > 0, 'LYL', IF( COUNT(v.id) > 1 && COUNT(v.id) < 4, 'SLY', IF( COUNT(v.id) > 3, 'VIP','None'/VVIP/ ) ) ) ) ) ) ) as customer_category, IF( (SELECT DATEDIFF(NOW(),se.start_date_of_service) <= 365) \|\| (SELECT DATEDIFF(NOW(),s.activity_date) <= 365) , '1','2' ) as isActive, smoc.name as mode_of_contact, sct.name as customer_type, ci.aha_status FROM inactive_customer ci LEFT OUTER JOIN customer_category ccat ON ci.category_id = ccat.id LEFT OUTER JOIN source_profession snob ON ci.profession_id=snob.id LEFT OUTER JOIN source_nature_of_business snb ON ci.nature_of_business_id=snb.id LEFT OUTER JOIN source_religion sr ON ci.religion_id = sr.id LEFT OUTER JOIN all_gender g ON ci.gender_id=g.id LEFT OUTER JOIN customer_contact cc ON ci.id=cc.customer_id LEFT OUTER JOIN all_suffix sx ON ci.suffix_id=sx.id LEFT OUTER JOIN all_countries ac ON ci.nationality_id=ac.num_code LEFT OUTER JOIN all_marital_status ams ON ci.marital_status_id=ams.id LEFT OUTER JOIN employee e ON ci.upload_by=e.id LEFT OUTER JOIN employee em ON ci.modified_by=em.id LEFT OUTER JOIN customer_dms cd ON ci.id=cd.customer_record_id LEFT OUTER JOIN source_company_dealer scd ON cd.company_dealer_id=scd.id LEFT OUTER JOIN source_company sc ON scd.company_id=sc.id LEFT OUTER JOIN source_dms sdms ON sc.dms_id=sdms.id LEFT OUTER JOIN source_dealer sd ON scd.dealer_id=sd.id LEFT OUTER JOIN all_city acity1 ON cc.address_1_city=acity1.id LEFT OUTER JOIN all_city acity2 ON cc.address_2_city=acity2.id LEFT OUTER JOIN source_customer_type sct ON ci.type=sct.id LEFT OUTER JOIN vehicle v ON ci.id = v.customer_record_id LEFT OUTER JOIN sales s ON v.id = s.vehicle_id LEFT OUTER JOIN service se ON v.id = se.vehicle_id LEFT OUTER JOIN source_mode_of_contact smoc ON cc.mode_of_contact_id = smoc.id WHERE ci.id='$customer_id' ORDER BY ci.id ASC LIMIT 1"; //echo $query_customer_info; return; $involvements = "SELECT sd.name AS dms, sc.code AS company, sdr.code AS dealer FROM `customer_dms` cd LEFT OUTER JOIN source_company_dealer scd ON cd.company_dealer_id = scd.id LEFT OUTER JOIN source_company sc ON sc.id = scd.company_id LEFT OUTER JOIN source_dms sd ON sc.`dms_id` = sd.id LEFT OUTER JOIN source_dealer sdr ON sdr.id = scd.dealer_id WHERE `customer_record_id` IN ('$customer_id')";//" AND sc.id IN (" . $granted_company_ids . ") "; // echo $query_customer_info; // return; $customer_info = Database::return_result($query_customer_info); $suffix = ""; $in = Database::return_result($involvements); //echo $involvements; return; $dms = array(); $company = array(); $dealer = array(); foreach ($in as $data1) { $dms = array_merge($dms, array($data1['dms'])); $company = array_merge($company, array($data1['company'])); $dealer = array_merge($dealer, array($data1['dealer'])); } $dms_new = array_unique($dms); $company_new = array_unique($company); $dealer_new = array_unique($dealer); $list_dms = implode(', ', $dms_new); $list_company = implode(', ', $company_new); $list_dealer = implode(', ', $dealer_new); foreach ($customer_info as $data) { if (intval($data['corporation_id']) <= 0) { $customer_corporation_name = ''; } else { $customer_corporation_name = Database::connectDB()->select("SELECT corporation_name FROM customer WHERE id = '" . $data['corporation_id'] . "' AND status = 1"); } if ($data['suffix'] == "None") { $suffix = ""; } else { $suffix = " " . $data['suffix']; } $get_image_query = "SELECT vi.name FROM vehicle v INNER JOIN vehicle_images vi ON v.id = vi.vehicle_id INNER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id WHERE 1 AND v.customer_record_id ='" . $data['id'] . "' AND scd.company_id IN (" . $granted_company_ids . ") AND vi.name <> 'default.png' AND vi.status <> 0 AND v.status <> 0 ORDER BY v.id DESC LIMIT 1"; // echo $get_image_query; $get_image_name = Database::select2($get_image_query); if ($get_image_name <> '') { $data['photo'] = $get_image_name; } $arr['photo'] = $data['photo']; if (intval($data['type']) === 1) { $arr['main_corporation_name'] = ''; $arr['full_name'] = $data['first_name'] . " " . $data['middle_name'] . " " . $data['last_name'] . " " . $suffix; $arr['main_first_name'] = $data['first_name']; $arr['main_middle_name'] = $data['middle_name']; $arr['main_last_name'] = $data['last_name']; $arr['suffix'] = $suffix; } else { $arr['main_corporation_name'] = $data['corporation_name']; $arr['full_name'] = ''; $arr['main_first_name'] = ''; $arr['main_middle_name'] = ''; $arr['main_last_name'] = ''; $arr['suffix'] = ''; } $arr['customer_record_id'] = $data['id']; $arr['main_email'] = $data['email_1']; $arr['main_customer_email_2'] = $data['email_2'] .(strlen($data['email_3'])>0 ? ', '.$data['email_3'] : ''); // $arr['main_customer_email_3'] = $data['email_3']; $arr['information_religion'] = $data['religion']; $arr['main_customer_mobile'] = $data['mobile_phone_1']; $arr['main_customer_landline'] = $data['landline']; $arr['main_customer_mobile_2'] = $data['mobile_phone_2'].(strlen($data['mobile_phone_3'])>0 ? ', '.$data['mobile_phone_3'] : ''); // $arr['main_customer_mobile_3'] = $data['mobile_phone_3']; $arr['main_customer_home_mobile'] = $data['residential_phone']; $arr['fax_phone'] = $data['fax_phone']; $arr['main_customer_business_mobile'] = $data['business_phone']; $arr['information_gender'] = $data['gender_name']; $arr['information_date_created'] = $data['date_created']; // $arr['information_dob'] = $data['birthdate']; // $arr['information_nationality'] = $data['nationality']; $arr['no_of_children'] = $data['no_of_children']; $arr['information_age'] = $data['age_number']; $arr['information_position'] = $data['occupation']; $arr['information_marital_status'] = $data['marital_status']; $arr['information_spouse'] = $data['spouse_name']; $arr['contact_person'] = $data['contact_person']; $arr['time_created'] = $data['time_created']; $arr['information_source_company'] = $data['source_company']; $arr['information_source_dealer'] = $data['source_dealer']; $arr['information_source_dms'] = $data['source_dms']; $arr['main_address_1'] = $data['address_1']; $arr['main_address_2'] = $data['address_2']; $arr['main_city_1'] = $data['address_1_city']; $arr['main_city_2'] = $data['address_2_city']; $arr['main_postal_1'] = $data['address_1_postal']; $arr['main_postal_2'] = $data['address_2_postal']; $arr['main_customer_address_1'] = $arr['main_address_1'] . ' ' . $arr['main_city_1'] . ' ' . $arr['main_postal_1']; $arr['main_customer_address_2'] = $arr['main_address_2'] . ' ' . $arr['main_city_2'] . ' ' . $arr['main_postal_2']; $arr['information_uploaded_by'] = $data['efname'] . " " . $data['elname']; $arr['information_date_uploaded'] = $data['date_uploaded']; $arr['information_modified_by'] = $data['emfname'] . " " . $data['emlname']; $arr['information_date_modified'] = $data['date_modified']; $arr['customer_type'] = (intval($data['type']) === 1) ? 'Individual' : 'Corporation'; $arr['main_customer_type'] = $data['customer_type']; $arr['customer_type_id'] = $data['type']; $arr['main_category'] = $data['customer_category']; $arr['main_customer_status'] = (intval($data['isActive']) == 1 ? 'Active' : 'Inactive'); $arr['main_customer_aha_status'] = (intval($data['aha_status']) == 1 ? 'Registered' : 'Not Registered'); $arr['main_customer_moc'] = $data['mode_of_contact']; $arr['main_facebook'] = $data['facebook']; $arr['main_instagram'] = $data['instagram']; $arr['main_viber'] = $data['viber']; $arr['main_telegram'] = $data['telegram']; $arr['main_whatsapp'] = $data['whatsapp']; $arr['main_website_link'] = $data['website']; $arr['information_business_company_name'] = $customer_corporation_name; $arr['information_profession'] = $data['profession']; $arr['information_nature_of_work_business'] = $data['nature_of_business']; } $get_image_query = "SELECT si.name FROM sales s INNER JOIN vehicle_images si ON s.id = si.sales_id INNER JOIN vehicle v ON s.vehicle_id = v.id INNER JOIN source_company_dealer scd ON s.company_dealer_id = scd.id WHERE 1 AND v.customer_record_id ='$customer_id' AND si.name <> 'default.png' AND vi.status <> 0 ORDER BY s.date_uploaded DESC LIMIT 1"; // echo $get_image_query; $get_image_name = Database::select2($get_image_query); if ($get_image_name <> '') { $arr['photo'] = $get_image_name; } $arr['information_dms_list'] = $list_dms; $arr['information_company_list'] = $list_company; $arr['information_dealer_list'] = $list_dealer; return response()->json($arr); } function isNotEmpty($data) { return preg_match('/\S/', $data); } public function index(){ $user_dealer_id = $_REQUEST['dealer_id']; $user_employee_id = $_REQUEST['employee_id']; $search = $_REQUEST['search']; $type = (isset($_REQUEST['type']) && $_REQUEST['type'] != '0') ? " AND t1.type = '".$_REQUEST['type']."' " : "" ; if($this->isNotEmpty($search)){ $filter_email = " OR cc.email_1 = '".$search."' "; }else{ $filter_email = ""; } $type =($this->isNotEmpty($search) ? " AND t1.type ='".$search."' " :''); $gender=''; // $dms=''; $age=''; $complete_data=''; $incomplete_data=''; $mobile_phone_1=''; $address_1=''; $date_of_birth=''; $company=''; $my_record =''; $group_by=''; $customer_actions = "" ; if(isset($_REQUEST['customer_actions']) && $_REQUEST['customer_actions'] != '0'){ switch($_REQUEST['customer_actions']){ case "all": $customer_actions = ""; break; case "new": $customer_actions = " AND t1.date_uploaded > DATE_SUB(NOW(), INTERVAL 1 WEEK) "; break; case "updated": $customer_actions = " AND t1.date_modified > DATE_SUB(NOW(), INTERVAL 1 WEEK) "; break; case "added": $customer_actions = " AND t1.date_uploaded > DATE_SUB(NOW(), INTERVAL 1 DAY) "; break; } } // $my_record =($this->isNotEmpty($search) ? " AND t1.type ='".$search."' " :'') $group_by =''; $offset_limit ='';//" LIMIT 100" $query = " SELECT DISTINCT %s FROM inactive_customer t1 /INNER JOIN cu_assign ON t1.id =cu_assign.customer_id INNER JOIN cu_dealer_users_assign cdua ON t1.id = cdua.customer_id / RIGHT JOIN cu_dealer_users_assign cdua ON t1.id = cdua.customer_id INNER JOIN customer_contact cc ON t1.id = cc.customer_id INNER JOIN customer_dms cd ON t1.id = cd.customer_record_id INNER JOIN source_company_dealer scd ON cd.company_dealer_id = scd.id INNER JOIN source_company sc ON scd.company_id = sc.id INNER JOIN source_dms sd ON sc.dms_id = sd.id LEFT OUTER JOIN all_suffix ass ON t1.suffix_id = ass.id LEFT OUTER JOIN vehicle v ON t1.id = v.customer_record_id LEFT OUTER JOIN sales s ON v.id = s.vehicle_id LEFT OUTER JOIN service se ON v.id = se.vehicle_id WHERE cdua.user_id='$user_employee_id' AND cdua.dealer_id ='$user_dealer_id' AND cdua.is_removed=0 AND ( (CONCAT('', CONCAT( t1.corporation_name, ' ', t1.first_name, ' ', t1.last_name , ' ', t1.first_name, ' ', t1.middle_name, ' ', t1.last_name ),' ', CONCAT('0',SUBSTRING(cc.mobile_phone_1, 4) ), ' ', cc.mobile_phone_1,' ',cd.customer_dms_id) LIKE '%%%s%%' /* 1 search / ) %s / email / %s / 3 gender / ) %s / 2 type / ORDER BY t1.id DESC "; // } $fields = " t1.id, t1.photo, IF(t1.type = 1, concat(t1.first_name,' ',t1.middle_name,' ',t1.last_name) ,t1.corporation_name ) as name, t1.gender_id, (SELECT gender_name FROM all_gender WHERE id=t1.gender_id) as gender_name, t1.date_of_birth, t1.date_uploaded, t1.date_created, TIMESTAMPDIFF(YEAR,t1.date_of_birth, CURDATE()) as age_number, cc.mobile_phone_1, cc.landline, cc.email_1, cc.address_1, CASE WHEN t1.type =1 THEN 'Corporation' WHEN t1.type =2 THEN 'Individual' END as type, t1.date_modified, t1.is_active, (SELECT DATEDIFF(NOW(),t1.date_modified)) as last_date_modified"; $count = " 1 "; $final_query = sprintf( $query, $fields, $search, $filter_email, $gender, $type, );//." $offset_limit"; $exec_query = Database::connect()->runBaseQuery($final_query);//Database::connect()->query($final_query); // echo $final_query;exit; // http_response_code(200); return response()->json($exec_query); } public function setStatus(){ $customer_id = $_REQUEST['customer_id']; $set_active_status = $_REQUEST['status']; // echo $customer_id.' '.$set_active_status;exit; $new_status = ($set_active_status == 1 ? 'Active' : 'Inactive'); $query_old = "SELECT is_active,first_name,middle_name,last_name FROM inactive_customer WHERE id=".$customer_id; $result = Database::connectDB()->query($query_old); // var_dump($result->num_rows); $full_name =''; if($result->num_rows == 1) { foreach($result as $row) { $is_active_status = $row['is_active']; $old_status = ($row['is_active'] == 0 ? 'Inactive' : 'Active'); $full_name = $row['first_name'].(strlen($row['middle_name'])>0 ? ' '.$row['middle_name'].' ' :' ').$row['last_name']; } unset($row); $log_set_active_customer = ($is_active_status == $set_active_status) ? '' : "[Customer status: " . $old_status . " to " . $new_status."]\n"; $log_desc = "Update customer: [ID:" . $customer_id . ", " . $full_name . "]".$log_set_active_customer."\n"; $id = $_SESSION['user']['id']; $code ='update_customer'; // echo $full_name;exit; try{ // ); Database::connectDB()->begin_transaction(); $update = Database::connectDB()->query("UPDATE inactive_customer SET is_active =".$set_active_status." WHERE id=".$customer_id); if(Database::connectDB()->query("INSERT INTO `all_activity_log`(`description`,`owner_id`,`target_id`,`code`) VALUES ('$log_desc',NULLIF('$id',''),'$customer_id','$code')") && $update){ Database::connectDB()->commit(); http_response_code(201); return response()->json(['msg'=>'Record successfully updated.','status'=>201]); // echo '{"msg" :"Record successfully updated.","status":1}'; }else{ // http_response_code(304); Database::connectDB()->rollback(); return response()->json(['msg'=>'Unable to create logs','status'=>304]); // echo '{"msg" :"Unable to create logs ","status":0}';exit; } }catch (\Throwable $e) { Database::connectDB()->rollback(); // http_response_code(304); return response()->json(['msg'=>'Unable to create logs'. $e ,'status'=>304]); // '{"msg" :"Unable to create logs "'.$e.',"status":0}';exit; } } } public function update() { if(isset($_REQUEST['customer_id']) && strlen($_REQUEST['customer_id'])>0) { $customer_id = $_REQUEST['customer_id']; $find_query = $this->read_customer_info_and_contact($customer_id); // var_dump($find_query);exit; // $find_query = $this->read_customer_profile_edit($customer_id); // $customer_info = json_decode($find_query,true); $customer_info =$find_query; // var_dump($customer_info);exit; $old_info_array=[]; $now = date('Y-m-d h:i:s'); if($customer_info->num_rows ===1) // if(is_array($customer_info) && count($customer_info)===1) { foreach ($customer_info as $old_info) { $old_info_array = $old_info; }unset($old_info); // echo'<pre>';print_r($old_info_array);echo'</pre>';exit; //customer info in customer and incative customer table $corporation_name = (isset($_REQUEST['corporation_name']) ? $_REQUEST['corporation_name'] : $old_info_array['corporation_name']); $first_name = (isset($_REQUEST['first_name']) ? $_REQUEST['first_name'] : $old_info_array['first_name']); $middle_name = (isset($_REQUEST['middle_name']) ? $_REQUEST['middle_name'] : $old_info_array['middle_name']); $last_name = (isset($_REQUEST['last_name']) ? $_REQUEST['last_name'] : $old_info_array['last_name']); $suffix_id = (isset($_REQUEST['suffix_id']) ? $_REQUEST['suffix_id'] : $old_info_array['suffix_id']); $gender_id = (isset($_REQUEST['gender_id']) ? $_REQUEST['gender_id'] : $old_info_array['gender_id']); $nationality_id = (isset($_REQUEST['nationality_id']) ? $_REQUEST['nationality_id'] : $old_info_array['nationality_id'] ); $date_of_birth = $_REQUEST['date_of_birth']; $marital_status_id = (isset($_REQUEST['marital_status_id']) ? $_REQUEST['marital_status_id'] : $old_info_array['marital_status_id']); $source_id = (isset($_REQUEST['source_id']) ? $_REQUEST['source_id'] : $old_info_array['source_id']); $mode_of_contact_id = (isset($_REQUEST['mode_of_contact_id']) ? $_REQUEST['mode_of_contact_id'] : $old_info_array['mode_of_contact_id']); $spouse_name = (isset($_REQUEST['spouse_name']) ? $_REQUEST['spouse_name'] : $old_info_array['spouse_name']); $no_of_children = (isset($_REQUEST['no_of_children']) ? $_REQUEST['no_of_children'] : $old_info_array['no_of_children']); $occupation = (isset($_REQUEST['occupation']) ? $_REQUEST['occupation'] : $old_info_array['occupation']); $contact_person = (isset($_REQUEST['contact_person']) ? $_REQUEST['contact_person'] : $old_info_array['contact_person']); $modified_by = (isset($_REQUEST['modified_by']) ? $_REQUEST['modified_by'] : $old_info_array['modified_by']); //employee id in employee id autoph_db $date_modified = $now; $customer_type = (isset($_REQUEST['type']) ? $_REQUEST['type'] : $old_info_array['type']); $category_id = (isset($_REQUEST['category_id']) ? $_REQUEST['category_id'] : $old_info_array['category_id']); $religion_id = (isset($_REQUEST['religion_id']) ? $_REQUEST['religion_id'] : $old_info_array['religion_id']); $corporation_id = (isset($_REQUEST['corporation_id']) ? $_REQUEST['corporation_id'] : $old_info_array['corporation_id']); $profession_id = (isset($_REQUEST['profession_id']) ? $_REQUEST['profession_id'] : $old_info_array['profession_id']); $nature_of_business_id = (isset($_REQUEST['nature_of_business_id']) ? $_REQUEST['nature_of_business_id'] : $old_info_array['nature_of_business_id']); $aha_status = (isset($_REQUEST['aha_status']) && $_REQUEST['aha_status']!=NULL && strlen($_REQUEST['aha_status'])>0 ? $_REQUEST['aha_status'] : $old_info_array['aha_status']); $status= (isset($_REQUEST['status']) ? $_REQUEST['status'] : $old_info_array['status']); //customer contact info $address_1 = (isset($_REQUEST['address_1']) ? $_REQUEST['address_1'] : $old_info_array['address_1']); $address_2 = (isset($_REQUEST['address_2']) ? $_REQUEST['address_2'] : $old_info_array['address_2']); $address_1_city= (isset($_REQUEST['address_1_city']) ? $_REQUEST['address_1_city'] : $old_info_array['address_1_city']); $address_2_city= (isset($_REQUEST['address_2_city']) ? $_REQUEST['address_2_city'] : $old_info_array['address_2_city']); $address_1_postal =(isset($_REQUEST['address_1_postal']) ? $_REQUEST['address_1_postal'] : $old_info_array['address_1_postal']) ; $address_2_postal = (isset($_REQUEST['address_2_postal']) ? $_REQUEST['address_2_postal'] : $old_info_array['address_2_postal']); $email_1 = (isset($_REQUEST['email_1']) ? $_REQUEST['email_1'] : $old_info_array['email_1']); $email_2 = (isset($_REQUEST['email_2']) ? $_REQUEST['email_2'] : $old_info_array['email_2']); $email_3 = (isset($_REQUEST['email_3']) ? $_REQUEST['email_3'] : $old_info_array['email_3']); $viber = (isset($_REQUEST['viber']) ? $_REQUEST['viber'] : $old_info_array['viber']); $facebook = (isset($_REQUEST['facebook']) ? $_REQUEST['facebook'] : $old_info_array['facebook']); $instagram = (isset($_REQUEST['instagram']) ? $_REQUEST['instagram'] : $old_info_array['instagram']); $telegram = (isset($_REQUEST['telegram']) ? $_REQUEST['telegram'] : $old_info_array['telegram']); $whatsapp = (isset($_REQUEST['whatsapp']) ? $_REQUEST['whatsapp'] : $old_info_array['whatsapp']); // $other_social = (isset($_REQUEST['other_social']) ? $_REQUEST['other_social'] : $old_info_array['other_social']); $business_phone = (isset($_REQUEST['business_phone']) ? $_REQUEST['business_phone'] : $old_info_array['business_phone']); $website = (isset($_REQUEST['website']) ? $_REQUEST['website'] : $old_info_array['website']); // $mobile_phone_1 = (isset($_REQUEST['mobile_phone_1']) ? $_REQUEST['mobile_phone_1'] : $old_info_array['mobile_phone_1']); $mobile_phone_2 =(isset($_REQUEST['mobile_phone_2']) && !empty($_REQUEST['mobile_phone_2']) ? $this->transform_mobile($_REQUEST['mobile_phone_2']) : $old_info_array['mobile_phone_2']); $mobile_phone_3 = (isset($_REQUEST['mobile_phone_3']) && !empty($_REQUEST['mobile_phone_2']) ? $this->transform_mobile($_REQUEST['mobile_phone_3']) : $old_info_array['mobile_phone_3']); $landline = (isset($_REQUEST['landline']) ? $_REQUEST['landline'] : $old_info_array['landline']); $residential_phone = (isset($_REQUEST['residential_phone']) ? $_REQUEST['residential_phone'] : $old_info_array['residential_phone']); // if(strlen($mobile_phone_2) ==11 && substr($mobile_phone_2, 0,1) ==0) // { // $ten_digits = substr($mobile_phone_2, 1,10); // $transform_zero = str_replace("0","+63",substr($mobile_phone_2, 0,1)); // $mobile_phone_2 = $transform_zero.$ten_digits; // } ///Customer interest //category id - customer_interest table //customer_interest_content sub table //customer_interest_list - main table $query_interest = "select id,interest_id from customer_interest_list where customer_id=".$customer_id; $categoryID =null; $customer_interest_list_id = null; $n=Database::connectDB()->query($query_interest); if($n->num_rows > 0) { foreach($n as $introw){ $customer_interest_list_id = $introw['id']; $interest_content = Database::connectDB()->query("SELECT id,interest_id,name FROM customer_interest_content WHERE id =".$introw['interest_id']); foreach($interest_content as $content) { $category_id = $content['interest_id']; $cu_interest = Database::connectDB()->query("SELECT id,name FROM customer_interest WHERE id=".$category_id); if($cu_interest->num_rows ===1) { foreach($cu_interest as $category) { $categoryID = $category['id']; } } } } } //CONTACT PERSON //customer_contact_person - main table $query_contact_info = "UPDATE `customer_contact` SET `customer_id`='$customer_id', `address_1`='$address_1', `address_2`='$address_2', `address_1_state`='$address_1_state', `address_2_state`='$address_2_state', `address_1_city`='$address_1_city', `address_2_city`='$address_2_city', `address_1_postal`='$address_1_postal', `address_2_postal`='$address_2_postal', -- `email_1`='$email_1', `email_2`='$email_2', `email_3`='$email_3', `viber`='$viber', `facebook`='$facebook', `instagram`='$instagram', `telegram`='$telegram', `whatsapp`='$whatsapp', -- `other_social`='$other_social', `website`='$website', `business_phone`='$business_phone', -- `fax_phone`='$fax_phone', -- `mobile_phone_1`='$mobile_phone_1', `mobile_phone_2`='$mobile_phone_2', `mobile_phone_3`='$mobile_phone_3', `landline`= '$landline', `residential_phone`='$residential_phone', `date_modified`='$now', `mode_of_contact_id`='$mode_of_contact_id' -- `status`='$status' WHERE `customer_id` = '$customer_id' "; $query_main = "UPDATE `customer` SET `corporation_name`='$corporation_name', `salutation_id`='$salutation_id', `first_name`='$first_name', `middle_name`='$middle_name', `last_name`='$last_name', `suffix_id`='$suffix_id', `gender_id`='$gender_id', `nationality_id`='$nationality_id', `date_of_birth`='$date_of_birth', `marital_status_id`='$marital_status_id', -- `source_id`='$source_id', `mode_of_contact_id`='$mode_of_contact_id', `spouse_name`='$spouse_name', `no_of_children`='', `occupation`='$occupation', `contact_person`='', `modified_by`='$modified_by', `date_modified`= '$now', `type`='$customer_type', `category_id`='$category_id', `religion_id`='$religion_id', `corporation_id`='$corporation_id', `profession_id`='$profession_id', `nature_of_business_id`='$nature_of_business_id', `aha_status` = '$aha_status', `status`='$status' WHERE id = '$customer_id' "; //CUSTOMER UPDATE- INACTIVE TABLE $query_cu = "UPDATE `inactive_customer` SET `id`='$customer_id', `corporation_name`='$corporation_name', `salutation_id`='$salutation_id', `first_name`='$first_name', `middle_name`='$middle_name', `last_name`='$last_name', `suffix_id`='$suffix_id', `gender_id`='$gender_id', `nationality_id`='$nationality_id', `date_of_birth`='$date_of_birth', `marital_status_id`='$marital_status_id', -- `source_id`='$source_id', `mode_of_contact_id`='$mode_of_contact_id', `spouse_name`='$spouse_name', `no_of_children`='', `occupation`='$occupation', `contact_person`='', `modified_by`='$modified_by', `date_modified`= NOW(), `type`='$customer_type', `category_id`='$category_id', `religion_id`='$religion_id', `corporation_id`='$corporation_id', `profession_id`='$profession_id', `nature_of_business_id`='$nature_of_business_id', `aha_status` = '$aha_status', `status`='$status' WHERE id = '$customer_id' "; // var_dump($mobile_phone_1); // $mobile_phone_1 = (($this->isNotEmpty($mobile_phone_1)) ? '+63'.$mobile_phone_1 : ''); // var_dump($mobile_phone_1); $mobile_phone_2 = (($this->isNotEmpty($mobile_phone_2)) ? '+63'.$mobile_phone_2 : ''); $mobile_phone_3 = (($this->isNotEmpty($mobile_phone_3)) ? '+63'.$mobile_phone_3 : ''); $mobile_info_array = [ $old_info_array['$mobile_phone_1'],$old_info_array['mobile_phone_2'], $old_info_array['$mobile_phone_3']]; $new_mobile_info_array[] =[$mobile_phone_1,$mobile_phone_2,$mobile_phone_3]; // echo'<pre>';print_r($new_mobile_info_array);echo'<pre>';return; if ($customer_type == 1) { // $old_info_array['mobile_phone_1'] <> $mobile_phone_1 // if(strlen($mobile_phone_1)>0) // { // if($old_info_array['mobile_phone_1'] <> $mobile_phone_1) // { // if ($this->read_customer_mobile_if_exist($mobile_phone_1) > 0) { // return response()->json(['msg'=>'Mobile already registered.' ,'status'=>304]); // } // } // } if(strlen($mobile_phone_2)>0) { if($old_info_array['mobile_phone_2'] <> $mobile_phone_2) { if ($this->read_customer_mobile_if_exist( $mobile_phone_2) > 0) { return response()->json(['msg'=>'Mobile already registered.' ,'status'=>304]); } } } if(strlen($mobile_phone_3)>0) { if($old_info_array['mobile_phone_3'] <> $mobile_phone_3) { if ($this->read_customer_mobile_if_exist($mobile_phone_3) > 0) { return response()->json(['msg'=>'Mobile already registered.' ,'status'=>304]); } } } // if (!in_array($mobile_phone_1,$mobile_info_array) && !in_array($mobile_phone_2,$mobile_info_array) && !in_array($mobile_phone_3,$mobile_info_array)) { // $i=0; // foreach($new_mobile_info_array as $mobile) // { // if ($this->read_customer_mobile_if_exist($new_customer_number) > 0) { // return response()->json(['msg'=>'Mobile already registered.' ,'status'=>304]); // } // } // } if ($this->isNotEmpty($email_1)) { if (strtolower($old_info_array['email_1']) <> strtolower($email_1)) { if ($this->read_customer_email_if_exist($email_1) > 0) { return response()->json(['msg'=>'Email already registered.' ,'status'=>304]); } } } if ($this->isNotEmpty($email_3)) { if (strtolower($old_info_array['email_3']) <> strtolower($email_1)) { if ($this->read_customer_email_if_exist($email_3) > 0) { return response()->json(['msg'=>'Email already registered.' ,'status'=>304]); } } } if ($this->isNotEmpty($email2)) { if (strtolower($old_info_array['email_2']) <> strtolower($email_1)) { if ($this->read_customer_email_if_exist($email_2) > 0) { return response()->json(['msg'=>'Email already registered.' ,'status'=>304]); } } } } if ($customer_type == 1) { $old_name = $old_info_array['first_name'] . ' ' . $old_info_array['middle_name'] . ' ' . $old_info_array['last_name']; $new_name = $first_name . ' ' . $middle_name. ' ' . $last_name; } else if ($customer_type == 2) { $old_name = $old_info_array['corporation_name']; $new_name = $corporation_name; } // echo'<pre>';print_r($old_info_array['first_name']);echo'</pre>'; // var_dump($old_name);var_dump($new_name);exit; $log_desc = "Update customer: "; //modify $log_customer_id ="[ID:" . $customer_id . ", " . $new_name . "]\n"; $log_name = ($old_name == $new_name) ? '' : "[Name: " . $old_name . " to " . $new_name . "]\n"; // $log_mobile = ($old_info_array["mobile_phone_1"] == $mobile_phone_1) ? '' : "[Mobile: " . $old_info_array["mobile_phone_1"] . " to " . $mobile_phone_1 . "]\n"; $log_mobile2 = ($old_info_array['mobile_phone_2'] == $mobile_phone_2 ? '' : '[Other Mobile 1 :'. $old_info_array['mobile_phone_2'].' to '.$mobile_phone_2.']\n'); $log_mobile3 =($old_info_array['mobile_phone_3'] == $mobile_phone_3 ? '' : '[Other Mobile 2 :'. $old_info_array['mobile_phone_3'].' to '.$mobile_phone_3.']\n'); $log_email = ($old_info_array["email_1"] == $email_1) ? '' : "[Email: " . $old_info_array["email_1"] . " to " . $email_1."]\n"; $log_email2 =(strlen($email_2) >0 ? ($old_info_array["email_2"] == $email_2) ? '' : "[Email: " . $old_info_array["email_2"] . " to " . $email_2 . "]\n" :''); $log_email3 =(strlen($email_3) > 0 ? ($old_info_array["email_3"] == $email_3) ? '' : "[Email: " . $old_info_array["email_3"] . " to " . $email_3 . "]\n" : ''); $log_address = ($old_info_array["address_1"] == $address_1) ? '' : "[Address: " . $old_info_array["address_1"] . " to " . $address_1. "]\n"; $log_address2 = ($old_info_array["address_2"] == $address_2) ? '' : "[Other address: " . $old_info_array["address_2"] . " to " . $address_2 . "]\n"; $log_bday = ($old_info_array["date_of_birth"] == date('Y-m-d',strtotime($date_of_birth))) ? '' : "[Birthday: " . $old_info_array["date_of_birth"] . " to " . date('Y-m-d',strtotime($date_of_birth)) . "]\n"; $log_gender = ($old_info_array["gender_id"] == $gender_id) ? '' : "[Gender: " . ($old_info_array["gender_id"]==1 ? 'Male' : 'Female') . " to " . ($gender_id==1 ? 'Male' : 'Female') . "]\n"; $query_log=''; if( strlen($log_name)>0 \|\| strlen($log_mobile)>0 \|\| strlen($log_mobile2)>0 \|\| strlen($log_mobile3)>0 \|\| strlen($log_email)>0 \|\| strlen($log_email2)>0 \|\| strlen($log_email3)>0 \|\| strlen($log_address)>0 \|\| strlen($log_address2)>0 \|\| strlen($log_bday)>0 \|\| strlen($log_gender)>0 ){ //create logs // $employee_id = $_SESSION['user']['id']; $employee_id = 1; $log_description = $log_desc. $log_name. $log_gender. $log_bday. $log_mobile. $log_mobile2. $log_mobile3. $log_email. $log_email2. $log_email3. $log_address. $log_address2; // $create_log =$this->createLog($employee_id,$log_description,$customer_id,'update_customer','api-customer-update'); $query_log ="INSERT INTO `all_activity_log`(`description`,`owner_id`,`target_id`,`code`) VALUES ('$log_description',NULLIF('$employee_id',''),'$customer_id','api-customer-update')"; } // echo $query_log;exit; try{ $this->dbTransaction($query_main,'customer'); $this->dbTransaction($query_cu,'inactive_customer'); $this->dbTransaction($query_contact_info,'customer_contact'); $this->dbTransaction($query_log,'all_activity_log'); // Database::connectDB()->begin_transaction(); // if( Database::connectDB()->query($query_main) && Database::connectDB()->query($query_cu) && Database::connectDB()->query($query_contact_info) && $create_log) // { Database::connectDB()->commit(); return response()->json(['msg'=>'Record successfully updated.' ,'status'=>201]); // } // else // { // Database::connectDB()->rollback(); // return response()->json(['msg'=>'Unable to update record. Please contact system administrator' ,'status'=>304]); // } } catch (\Throwable $e) { Database::connectDB()->rollback(); return response()->json(['msg'=>'Unable to update record. Please contacty system administrator' ,'status'=>304]); } } else { return response()->json(['msg' => 'No data found.','status'=>204]); } } else { // http_response_code(204); return response()->json(['msg' => 'No data found.','status'=>204]); } } private function read_customer_info_and_contact($id) { $customer_info =Database::connectDB()->query("SELECT FROM `customer` c INNER JOIN customer_contact cc ON c.`id` = cc.customer_id WHERE 1 AND c.id = $id LIMIT 1"); return $customer_info; } private function read_customer_mobile_if_exist($mobile) { $query = "SELECT 1 FROM `customer_contact` cc INNER JOIN customer c ON cc.customer_id = c.id WHERE 1 AND `mobile_phone_1` = '$mobile' OR `mobile_phone_2` = '$mobile' OR `mobile_phone_3` = '$mobile' AND c.type = 1 AND c.status = 1"; return Database::connectDB()->query($query)->num_rows; } private function read_customer_email_if_exist($email) { $query = "SELECT 1 FROM `customer_contact` cc INNER JOIN customer c ON cc.customer_id = c.id WHERE 1 AND cc.`email_1` = '$email' AND c.type = 1 AND c.status = 1"; return Database::connectDB()->query($query)->num_rows; } private function createLog($id,$description,$target_id,$code,$db){ Database::connectDB()->query("INSERT INTO `all_activity_log`(`description`,`owner_id`,`target_id`,`code`) VALUES ('$description',NULLIF('$id',''),'$target_id','$code')"); } private function dbTransaction($query,$table) { if(strlen($query)>0) { if(Database::connectDB()->query($query)) { Database::connectDB()->commit(); } else { return response()->json(['msg'=>'Unable to update record. Please contact system administrator' ,'source table'=>$table,'status'=>304]); Database::connectDB()->rollback(); } } } private function compareValues($value1, $value2) { // Convert both values to strings for comparison $stringValue1 = strval($value1); $stringValue2 = strval($value2); // Compare the string representations of the values if ($stringValue1 === $stringValue2) { return false; // Values are equal } else { return tue; } } private function read_customer_profile_edit($id) { $query_info= Database::connectDB()->query("SELECT c.,snob.name as nature_of_business_name,sp.name as profession_name FROM `customer` c LEFT OUTER JOIN source_nature_of_business snob ON c.nature_of_business_id = snob.id LEFT OUTER JOIN source_profession sp ON c.profession_id = sp.id WHERE c.`id` = '$id' "); // return $query_info;// json_encode($query); $data=[]; if($query_info->num_rows ===1) { foreach($query_info as $row) { $data[] = $row; } } return json_encode($data); } // private function transform_mobile($mobile_number) // { // // if(strlen($mobile_number) ==11 && substr($mobile_number, 0,1) ==0) // { // $ten_digits = substr($mobile_number, 1,10); // $transform_zero = str_replace("0","+63",substr($mobile_number, 0,1)); // $mobile_number = $transform_zero.$ten_digits; // return $mobile_number; // else // { // return response()->json(['msg'=>'Invalid mobile number.' ,'status'=>304]); // } // } //api collection dropdow public function customer_interest_list(){ $cu_interest = Database::connectDB()->query("SELECT id,name FROM customer_interest WHERE status =1"); $interest_category=[]; foreach($cu_interest as $row) { $interest_category[] = $row; } return response()->json($interest_category); } public function customer_interest_content(){ $cu_interest = Database::connectDB()->query("SELECT id,name FROM customer_interest_content WHERE status =1"); $interest_subcategory=[]; foreach($cu_interest as $row) { $interest_subcategory[] = $row; } return response()->json($interest_subcategory); } public function all_city(){ $all_city = Database::connectDB()->query("SELECT id,citymunDesc FROM all_city WHERE status =1"); $all_citys=[]; foreach($all_city as $row) { $all_citys[] = $row; } return response()->json($all_citys); } public function all_suffix(){ $all_suffix = Database::connectDB()->query("SELECT id,suffix_name FROM all_suffix WHERE 1"); $all_suffixs=[]; foreach($all_suffix as $row) { $all_suffixs[] = $row; } return response()->json($all_suffixs); } public function all_gender(){ $all_suffix = Database::connectDB()->query("SELECT id,gender_name FROM all_gender WHERE 1"); $all_suffixs=[]; foreach($all_suffix as $row) { $all_suffixs[] = $row; } return response()->json($all_suffixs); } public function all_marital_status(){ $all_marital = Database::connectDB()->query("SELECT id,name FROM all_marital_status WHERE 1"); $all_marital_status=[]; foreach($all_marital as $row) { $all_marital_status[] = $row; } return response()->json( $all_marital_status); } public function source_mode_contact(){ $moc = Database::connectDB()->query("SELECT id,name FROM source_mode_of_contact WHERE status =1"); $mocs=[]; foreach($moc as $row) { $mocs[] = $row; } return response()->json($mocs); } public function source_customer_type(){ $ctype = Database::connectDB()->query("SELECT id,name FROM source_customer_type WHERE 1"); $types=[]; foreach($ctype as $row) { $types[] = $row; } return response()->json($types); } public function customer_category(){ $cu_category = Database::connectDB()->query("SELECT id,name FROM customer_category WHERE status =1"); $customer_categories=[]; foreach($cu_category as $row) { $customer_categories[] = $row; } return response()->json($customer_categories); } public function source_religion(){ $religion = Database::connectDB()->query("SELECT id,name FROM source_religion WHERE status =1"); $religions=[]; foreach($religion as $row) { $religions[] = $row; } return response()->json($religions); } public function source_profession(){ $profession = Database::connectDB()->query("SELECT id,name FROM source_profession WHERE status =1"); $professions=[]; foreach($profession as $row) { $professions[] = $row; } return response()->json($professions); } public function source_nature_business(){ $nature_business = Database::connectDB()->query("SELECT id,name FROM source_nature_of_business WHERE status =1"); $nature_businesses=[]; foreach($nature_business as $row) { $nature_businesses[] = $row; } return response()->json($nature_businesses); } public function cu_affiliation_category(){ $affilications_category = Database::connectDB()->query("SELECT id,name FROM customer_affiliations_category WHERE status =1"); $category_affilications=[]; foreach( $affilications_category as $row) { $category_affilications[] = $row; } return response()->json($category_affilications); } public function cu_affiliation_content(){ $affilications_content = Database::connectDB()->query("SELECT id,name FROM customer_affiliations_content WHERE status =1"); $content_affilications=[]; foreach($affilications_content as $row) { $content_affilications[] = $row; } return response()->json($content_affilications); } public function corporation_name(){ $corporation = Database::connectDB()->query("SELECT id,corporation_name FROM customer WHERE corporation_name !=''"); $corporation_name=[]; foreach($corporation as $row) { $corporation_name[] = $row; } return response()->json( $corporation_name); } } ��Controllers/Customer/ActivityController.php��0000644��00000013121�15025010271�0015213 0��ustar�00��<?php namespace App\Controllers\Customer; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Utilities\Auth; use App\Utilities\Utility; class ActivityController { private $customerActivity; private $validator; function __construct() { $this->customerActivity = new \App\Models\Customer\Activity; // $this->validator = new \Rakit\Validation\Validator(); $this->validator = new \Rakit\Validation\Validator(); } public function storeValidate() { // make it $validation = $this->validator->make($_REQUEST, [ 'activity' => 'required', // 'source' => 'required_with:source_id', // 'source_id' => 'required_with:source', // 'user_id' => 'required_without:source,source_id', // 'password' => 'required\|min:6', // 'confirm_password' => 'required\|same:password', // 'postcode' => 'numeric', // 'avatar' => 'required\|uploaded_file:0,500K,png,jpeg', // 'skills' => 'array', // 'skills..id' => 'required\|numeric', // 'skills..percentage' => 'required\|numeric' ]); $validation->setAliases([ 'activity' => 'activity description', 'source' => 'source', 'source_id' => 'source_id', ]); // $validation->setMessages([ // 'required' => ':attribute is required', // 'email' => ':email is not valid', // // etc // ]); // then validate $validation->validate(); if ($validation->fails()) { // handling errors $errors = $validation->errors(); $response['message'] = implode("<br>", $errors->firstOfAll()); $response['status'] = 0; response()->json($response); } else { return true; } } public function store() { $_REQUEST = sanitize($_REQUEST); $this->storeValidate(); $id = $this->customerActivity->store(Utility::nullEmptyArray(array( $_REQUEST['id'], $_REQUEST['customer_id'], $_REQUEST['vehicle_id'], Auth::user()->id, $_REQUEST['activity'], 1, ))); $response['message'] = "Success."; $response['status'] = 1; $response['id'] = $id; response()->json($response); } public function storeInsuranceValidate() { // make it $validation = $this->validator->make($_REQUEST, [ 'insurance_company' => 'required', // 'source' => 'required_with:source_id', // 'source_id' => 'required_with:source', // 'user_id' => 'required_without:source,source_id', // 'password' => 'required\|min:6', // 'confirm_password' => 'required\|same:password', // 'postcode' => 'numeric', // 'avatar' => 'required\|uploaded_file:0,500K,png,jpeg', // 'skills' => 'array', // 'skills..id' => 'required\|numeric', // 'skills..percentage' => 'required\|numeric' ]); $validation->setAliases([ 'activity' => 'activity description', 'source' => 'source', 'source_id' => 'source_id', ]); // $validation->setMessages([ // 'required' => ':attribute is required', // 'email' => ':email is not valid', // // etc // ]); // then validate $validation->validate(); if ($validation->fails()) { // handling errors $errors = $validation->errors(); $response['message'] = implode("<br>", $errors->firstOfAll()); $response['status'] = 0; response()->json($response); } else { return true; } } public function storeInsurance() { $_REQUEST = sanitize($_REQUEST); $this->storeInsuranceValidate(); // print_r($_REQUEST); // exit; $id = $this->customerActivity->storeInsurance(Utility::nullEmptyArray(array( $_REQUEST['id'], $_REQUEST['customer_id'], Auth::user()->id, strtoupper(Utility::removeNotAlphaNumeric($_REQUEST['plate_number']) ?? ''), strtoupper(Utility::removeNotAlphaNumeric($_REQUEST['conduction_sticker']) ?? ''), $_REQUEST['insurance_company'], $_REQUEST['policy_number'], Utility::toSqlDate($_REQUEST['issue_date']), Utility::toSqlDate($_REQUEST['start_date']), Utility::toSqlDate($_REQUEST['end_date']), NULL, 1, ))); if (is_numeric($id)) { $response['message'] = "Success."; $response['status'] = 1; //update insurance $template = $this->customerActivity->template([1]); $id = $this->customerActivity->store(Utility::nullEmptyArray(array( $_REQUEST['id'], $_REQUEST['customer_id'], $_REQUEST['vehicle_id'], Auth::user()->id, $template['activity'], 1, ))); } else { $response['message'] = $id; $response['status'] = 0; } response()->json($response); } } ��Controllers/DealerController.php��0000644��00000000576�15025010271�0013024 0��ustar�00��<?php namespace App\Controllers; use App\Core\Controller; class DealerController extends Controller { private $dealer; function __construct() { $this->dealer = new \App\Models\Dealer; } public function companyDealers($company_id) { $response = $this->dealer->getCompanyDealers($company_id); response()->json($response); } } ��Controllers/CarClubController.php��0000644��00000000533�15025010271�0013134 0��ustar�00��<?php namespace App\Controllers; class CarClubController { public function error404() { echo "Error 404 file not found."; } function load() { $page_title = "Car Clubs"; include('resources/views/car_club/list.php'); } function view($id) { echo "Car Club Viewer ID:" . $id; } } ��Controllers/PageController.php��0000644��00000016227�15025010271�0012504 0��ustar�00��<?php namespace App\Controllers; class PageController { public function error404() { echo "Error 404 file not found."; } public function error403() { echo "Error 403 forbidden."; } function activate() { include('resources/views/employees/activate.php'); } function auto_sms_service() { include('resources/views/sms_service/auto_sms_service.php'); } function car_club() { $page_title = "Car Clubs"; include('resources/views/car_club/list.php'); } function car_club_view($id) { $page_title = "Car Club Profile"; include('resources/views/car_club/view.php'); } function car_club_affiliation() { $page_title = "Car Clubs (Affiliation)"; include('resources/views/car_club_affiliation/list.php'); } function car_club_affiliation_view($id) { $page_title = "Car Club Profile"; include('resources/views/car_club_affiliation/view.php'); } function car_club_view1($id, $plate, $date) { include('resources/views/test1.php'); } function compliance() { include('resources/views/sc_compliance/compliance.php'); } function compliance_clients() { include('resources/views/sc_compliance/compliance_clients.php'); } function compliancestatus() { include('resources/views/sc_compliance/compliancestatus.php'); } function customer() { include('resources/views/customers/customer.php'); } function customer_view() { include('resources/views/customers/customer_view.php'); } //CUSTOMER UPDATE function customer_update_view() { include('resources/views/customer_update/customer_view.php'); } function customer_update_dealer_view() { include('resources/views/customer_update/assign_dealer_view.php'); } function sm_dealer_view() { include('resources/views/customer_update/sm_assign_dealer_view.php'); } function customer_update() { include('resources/views/customer_update/customer_update.php'); } function dealer_assign() { include('resources/views/customer_update/dealer_assignment.php'); } function user_assignment() { include('resources/views/customer_update/dealer_assignment_user.php'); } function user_managment() { include('resources/views/customer_update/dealer_user_management.php'); } function dealer_assinged_user() { include('resources/views/customer_update/dealer_assigned_user_list.php'); } function customer_update_assinged() { include('resources/views/customer_update/customer_update_assigned.php'); } function assigned_customer_update() { include('resources/views/customer_update/assigned_customer_update.php'); } function u_customer_update_assinged() { include('resources/views/customer_update/u_customer_update_assigned.php'); } function user_manual() { if(isset($_REQUEST['user']) && base64_decode($_REQUEST['user']) ==='3695340036334700') { // $filePath = file_get_contents("public/storage/app/Customer Update Manual.pdf"); $filePath = realpath(__DIR__ . '/../../public/storage/app/Customer Update Manual.pdf'); $handle = fopen($filePath, 'rb'); if (!$handle) { header('HTTP/1.0 404 Not Found'); echo 'File not found'; exit; } // Set appropriate headers for streaming header('Content-Type: application/pdf'); header('Content-Disposition: inline; filename="' . basename($filePath) . '"'); header('Accept-Ranges: bytes'); header('Content-Length: ' . filesize($filePath)); // Read the file content in chunks and echo directly $chunkSize = 1024 1024; // 1 MB chunk size while (!feof($handle)) { echo fread($handle, $chunkSize); flush(); // Flush output to avoid buffering issues } fclose($handle); exit(); } } function assigned_cu_customer() { include('api/customer_update/assigned_cu_customer.php'); } function dashboard1() { include('resources/views/dashboard/dashboard.php'); } function employee() { include('resources/views/employees/employee.php'); } function finance_list() { include('resources/views/finance/financelist.php'); } function finance_information($plate_cs_number) { include('resources/views/finance/finance_information.php'); } function finance_dashboard() { include('resources/views/finance/financedashboard.php'); } function finance_pdc_information($pdc_plate_cs_number) { include('resources/views/finance_pdc/finance_pdc_information.php'); } function finance_pdc_list() { include('resources/views/finance_pdc/finance_pdc_list.php'); } function forgot() { include('resources/views/employees/forgot.php'); } function gen_key() { include('resources/views/misc/key.php'); } function home() { header('location:home.php'); } function menu() { include('resources/views/home/home.php'); } function profile() { include('resources/views/employees/profile.php'); } function profile_home() { include('resources/views/employees/profile_home.php'); } function recover() { include('resources/views/employees/recover.php'); } function sale() { include('resources/views/sales/sales.php'); } function sc_compliance() { include('resources/views/sc_compliance/sc_compliance.php'); } function sc_compliance_clients() { include('resources/views/sc_compliance/sc_compliance_clients.php'); } function sc_compliance_client() { include('resources/views/sc_compliance/sc_compliance_client.php'); } function service() { include('resources/views/services/service.php'); } function service_view() { include('resources/views/services/service_view.php'); } function signin() { include('resources/views/employees/signin.php'); } function signup() { include('resources/views/employees/signup.php'); } function vehicle() { include('resources/views/vehicles/vehicle.php'); } function vehicle_view() { include('resources/views/vehicles/vehicle_view.php'); } function ltms_upload() { include('resources/views/ltms/ltms_view.php'); } function asa_download() { include('resources/views/asa_v1/asav1download.php'); } } ��config/lto.php��0000644��00000000140�15025010271�0007304 0��ustar�00��<?php return [ "dealer_mapping" => [ "in" => "In", "out" => "Out" ], ]; ��Middlewares/NotAuth.php��0000644��00000001025�15025010271�0011066 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Models\User; use App\Utilities\Session; class NotAuth implements IMiddleware { public function handle(Request $request): void { if(!empty(Session::get('user')) \|\| !empty($_COOKIE['uid'])){ if(url()->contains('/admin')) { response()->redirect('/admin/signin'); }else{ response()->redirect('/'); } } } }��Middlewares/AdminNotAuth.php��0000644��00000000606�15025010271�0012043 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Models\User; use App\Utilities\Session; class AdminNotAuth implements IMiddleware { public function handle(Request $request): void { if(!empty(Session::get('user')) \|\| !empty($_COOKIE['uid'])){ response()->redirect(url('admin.index')); } } }��Middlewares/Auth.php��0000644��00000003766�15025010271�0010423 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Models\User; use App\Utilities\Session; use App\Utilities\Cookie; use App\Models\Permission; class Auth implements IMiddleware { public function handle(Request $request): void { $user = new User(); //check user status if (!isset(Session::get('user')['id'])) { response()->redirect("/signin.php"); } else { $user_id = Session::get('user')['id']; $user_info_arr = $user->userInfo($user_id); $user_info = $user_info_arr[0]; $user_permissions = $user->getUserPermissions($user_info['employee_role_id']); // print_r($user_permissions); foreach ($user_permissions as $user_permission) { if (isset($user_permission['action_permissions'])) { Session::set(['action_permissions' => json_decode($user_permission['action_permissions'], true)]); } else { Session::set(['action_permissions' => ""]); } if (isset($user_permission['company_permissions'])) { $company_permissions_arr = array_merge(array($user_info['company']), json_decode($user_permission['company_permissions'], true)); $company_permissions_arr = array_unique($company_permissions_arr); Session::set(['company_permissions' => $company_permissions_arr]); } else { Session::set(['company_permissions' => array($user_info['company'])]); } if (isset($user_permission['fields_permissions'])) { Session::set(['fields_permissions' => json_decode($user_permission['fields_permissions'], true)]); } else { Session::set(['fields_permissions' => ""]); } } // print_r(Session::get('user')); // exit; } } } ��Middlewares/Shop.php��0000644��00000000721�15025010271�0010417 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Models\User; use App\Utilities\Session; use App\Utilities\Cookie; use App\Models\Permission; class Shop implements IMiddleware { public function handle(Request $request): void { // ang purpose neto ay .... hmmmm // 1. kung may naka login ba na client // pag meron display header with account // pag wla } }��Middlewares/AdminAuth.php��0000644��00000003501�15025010271�0011357 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Models\User; use App\Utilities\Cookie; use App\Utilities\Session; use App\Models\Permission; class AdminAuth implements IMiddleware { public function handle(Request $request): void { $user = new User(); if (empty(Session::get('user')) && empty(Cookie::get('uid'))) { response()->redirect(url('admin.login') . '?ref=' . url()); } //login using cookie if (empty(Session::get('user')) && !empty(Cookie::get('uid'))) { $user_data = $user->authenticate(); if (empty($user_data)) { response()->redirect(url('admin.logout')); } Session::set(['user' => $user_data[0], 'agent' => $_SERVER['HTTP_USER_AGENT']]); } //check user status if (empty($user->userStatus(Session::get('user')['id']))) { response()->redirect(url('admin.logout')); } //get/refresh role and permissions Session::delete('permissions'); $roleId = $user->userRoleId(Session::get('user')['id']); $permissions_arr = array(); if (!empty($roleId)) { $permissions = Permission::rolePermissions($roleId); if (!empty($permissions)) { foreach ($permissions as $permission) { $permissions_arr[] = $permission['permissionId']; } } } $userAccessArr = $user->userAccess(Session::get('user')['id']); $permission_access = array_merge($permissions_arr, $userAccessArr[0]); Session::set(['permissions' => $permission_access]); //check if user is admin if (!Session::get('permissions')['admin']) { response()->redirect('/'); } } } ��Middlewares/CsrfVerifier.php��0000644��00000000346�15025010271�0012102 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\BaseCsrfVerifier; class CsrfVerifier extends BaseCsrfVerifier { /** * CSRF validation will be ignored on the following urls. / protected $except = ['/api/']; } ��Middlewares/ApiVerification.php��0000644��00000002025�15025010271�0012561 0��ustar�00��<?php namespace App\Middlewares; use Pecee\Http\Middleware\IMiddleware; use Pecee\Http\Request; use App\Models\Api; class ApiVerification implements IMiddleware { public function handle(Request $request): void { // Do authentication // $request->authenticated = false; if (!input('key')) { $response['message'] = "API Key is required."; $response['status'] = 0; response()->json($response); } $api = new Api(); $access_uris = $api->getApiKeyAccessUris(array("key" => input('key'))); $access_uris_arr = array(); foreach ($access_uris as $access_uri) { $access_uris_arr[] = $access_uri['uri']; } if (!count($access_uris_arr)) { $response['message'] = "API Key is invalid."; $response['status'] = 0; response()->json($response); } $url = strtok($_SERVER["REQUEST_URI"], '?'); $url = rtrim($url, '/\\'); if (!in_array($url, $access_uris_arr)) { $response['message'] = "You do not have permission to access this page."; $response['status'] = 0; response()->json($response); } } } ��Models/Lto.php��0000644��00000033160�15025010271�0007232 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Lto extends Model { public function checkorcrPlateExisting($array_data) { $query = "SELECT * FROM vehicle_orcr_plate_status WHERE 1 AND vehicle_id = ? AND type= ? AND date_received = ? AND status = 1"; $queryType = "iss"; $queryValue = array( $array_data['vehicle_id'], $array_data['type'], $array_data['date_received'], ); return Database::connect()->runQuery($query, $queryType, $queryValue); } public function updateOrcrPlatePickup($array_data) { $query = "UPDATE `vehicle_orcr_plate_status` SET pickup_date = NOW() WHERE 1 AND id = ?"; $paramType = "i"; return Database::connect()->update($query, $paramType, $array_data); } public function updateOrcrPlateSms($array_data) { $query = "UPDATE `vehicle_orcr_plate_status` SET sms_response = ? ,sms_date = ? WHERE 1 AND id = ?"; $paramType = "ssi"; $paramValue = array( $array_data['sms_response'], $array_data['sms_date'], $array_data['record_id'], ); return Database::connect()->update($query, $paramType, $paramValue); } public function updateOrcrPlate($array_data) { $query = "UPDATE `vehicle_orcr_plate_status` SET vehicle_id = ? , type = ?, status = ? , date_received = ?, notes = ? WHERE 1 AND id = ?"; $paramType = "isissi"; $paramValue = array( $array_data['vehicle_id'], $array_data['type'], $array_data['status'], $array_data['date_received'], $array_data['notes'], $array_data['record_id'], ); return Database::connect()->update($query, $paramType, $paramValue); } public function createOrcrPlate($array_data) { $query = "INSERT INTO `vehicle_orcr_plate_status` ( `vehicle_id`, `type`, `user_id`, `status`, `date_received`, `notes`, `date_added`) VALUES (?,?,?,?,?,?,NOW()); "; $paramType = "isiiss"; $paramValue = array( $array_data['vehicle_id'], $array_data['type'], $array_data['user_id'], $array_data['status'], $array_data['date_received'], $array_data['notes'], ); return Database::connect()->insert($query, $paramType, $paramValue); } public function createOrcrPlateWithSMS($array_data) { $query = "INSERT INTO `vehicle_orcr_plate_status` ( `vehicle_id`, `type`, `user_id`, `status`, `sms_response`, `sms_date`, `date_received`, `notes`, `date_added`) VALUES (?,?,?,?,?,?,?,?,NOW()); "; $paramType = "isiissss"; $paramValue = array( $array_data['vehicle_id'], $array_data['type'], $array_data['user_id'], $array_data['status'], $array_data['sms_response'], $array_data['sms_date'], $array_data['date_received'], $array_data['notes'], ); return Database::connect()->insert($query, $paramType, $paramValue); } public function orcrPlateQuery() { return "SELECT %s FROM vehicle_orcr_plate_status vops LEFT OUTER JOIN vehicle v ON vops.vehicle_id = v.id LEFT OUTER JOIN sales s ON v.id = s.vehicle_id LEFT OUTER JOIN sales_consultant scp ON s.sales_person = scp.id LEFT OUTER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id LEFT OUTER JOIN source_company sc ON scd.company_id = sc.id LEFT OUTER JOIN source_dealer sd ON scd.dealer_id = sd.id LEFT OUTER JOIN source_brand sb ON v.brand_id = sb.id LEFT OUTER JOIN source_car_model scm ON v.model_id = scm.id LEFT OUTER JOIN source_car_model_variant scmv ON v.model_variant_description = scmv.id LEFT OUTER JOIN customer c ON v.customer_record_id = c.id LEFT OUTER JOIN customer_contact cc ON c.id = cc.customer_id LEFT OUTER JOIN source_lto_dealer_contacts sldc ON sldc.id = (SELECT id FROM source_lto_dealer_contacts WHERE 1 AND dealer_id = sd.id AND status = 1 AND active = 1 LIMIT 1) WHERE 1 %s /search/ %s /date_added/ %s /date_received/ %s /sms_sttaus/ %s /company filter/ %s /dealer filter/ AND vops.status = 1 /AND vops.user_id = ?/ %s %s "; } public function orcrPlateQueryWS() { return "SELECT %s FROM vehicle v LEFT OUTER JOIN vehicle_orcr_plate_status vops ON v.id = vops.vehicle_id LEFT OUTER JOIN sales s ON v.id = s.vehicle_id LEFT OUTER JOIN sales_consultant scp ON s.sales_person = scp.id LEFT OUTER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id LEFT OUTER JOIN source_company sc ON scd.company_id = sc.id LEFT OUTER JOIN source_dealer sd ON scd.dealer_id = sd.id LEFT OUTER JOIN source_brand sb ON v.brand_id = sb.id LEFT OUTER JOIN source_car_model scm ON v.model_id = scm.id LEFT OUTER JOIN source_car_model_variant scmv ON v.model_variant_description = scmv.id LEFT OUTER JOIN customer c ON v.customer_record_id = c.id LEFT OUTER JOIN customer_contact cc ON c.id = cc.customer_id WHERE 1 %s /search/ %s /date_added/ %s /date_received/ %s /sms_sttaus/ %s /company filter/ %s /dealer filter/ /AND vops.user_id = ?/ GROUP BY v.id %s %s "; } public function getNoSmsOrcrPlateList($array_data) { $limit = ""; $fields = " c.first_name, c.last_name, c.corporation_name, c.type as customer_type, sc.name as company, sd.name as dealer, sb.name as brand, scm.name as model, scmv.name as model_variant, cc.mobile_phone_1, cc.email_1, v.id as vehicle_id, v.conduction_sticker, v.plate_number, v.mv_file, v.chassis_number, v.engine_number, vops.type as vops_type, vops.id as vops_id, vops.date_added, vops.sms_date, vops.date_received, vops.notes, vops.sms_response, sldc.contact_person, sldc.contact1 as contact_phone, sldc.email as contact_email "; $query = sprintf($this->orcrPlateQuery(), $fields, $array_data['search'], $array_data['date_added'], $array_data['date_received'], $array_data['sms_status'], $array_data['company_access'], $array_data['dealer_access'], $array_data['sort'], $limit); return Database::connect()->runBaseQuery($query); } public function getOrcrPlateList($array_data) { $array_data['company_access'] = " AND sc.id IN (" . $array_data['company_access'] . ")"; if ($array_data['dealer_access']) { $array_data['dealer_access'] = " AND sd.id IN (" . $array_data['dealer_access'] . ")"; } $limit = "LIMIT " . $array_data['offset'] . "," . $array_data['limit'] . ""; $fields = " c.first_name, c.last_name, c.corporation_name, c.type, sc.name as company, sc.code as company_code, sd.name as dealer, sd.code as dealer_code, sb.name as brand, scm.name as model, scmv.name as model_variant, cc.mobile_phone_1, cc.email_1, v.conduction_sticker, v.plate_number, v.mv_file, v.chassis_number, v.engine_number, vops.type as vops_type, vops.id as vops_id, vops.date_added, vops.sms_date, vops.pickup_date, vops.date_received, vops.notes, vops.sms_response"; $query = sprintf( $this->orcrPlateQuery(), $fields, $array_data['search'], $array_data['date_added'], $array_data['date_received'], $array_data['sms_status'], $array_data['company_access'], $array_data['dealer_access'], $array_data['sort'], $limit ); $paramType = "s"; $paramValue = array( $array_data['search_keyword'], ); return Database::connect()->runQuery($query, $paramType, $paramValue); } public function getOrcrPlateStatusList($array_data) { $fields = " c.first_name, c.last_name, c.corporation_name, c.type, sc.name as company, sc.code as company_code, sd.name as dealer, sd.code as dealer_code, sb.name as brand, scm.name as model, scmv.name as model_variant, cc.mobile_phone_1, cc.email_1, v.conduction_sticker, v.id as vehicle_id, v.plate_number, v.mv_file, v.chassis_number, v.engine_number, s.asa_sales_person, CONCAT(scp.first_name,' ',scp.last_name) as sales_person, vops.type as vops_type, vops.id as vops_id, vops.date_added, vops.sms_date, vops.date_received, vops.pickup_date, vops.notes, vops.sms_response"; $query = sprintf( $this->orcrPlateQueryWS(), $fields, $array_data['search'], '', '', '', '', '', '', '' ); // echo $query; // exit; $paramType = "ss"; $paramValue = array( $array_data['search_keyword'][0], $array_data['search_keyword'][1], ); return Database::connect()->runQuery($query, $paramType, $paramValue); } public function getLtoDealerContacts($dealer_id) { $query = "SELECT contact_person,contact1 as contact_phone,email as contact_email FROM source_lto_dealer_contacts WHERE 1 AND dealer_id = ? AND active = 1 AND status = 1 LIMIT 1 "; $queryType = "i"; $queryValue = array( $dealer_id, ); return Database::connect()->runQuery($query, $queryType, $queryValue); } public function getOrcrPlateListCount($array_data) { $array_data['company_access'] = " AND sc.id IN (" . $array_data['company_access'] . ")"; if ($array_data['dealer_access']) { $array_data['dealer_access'] = " AND sd.id IN (" . $array_data['dealer_access'] . ")"; } $limit = ""; $fields = " COUNT(1) "; $query = $this->orcrPlateQuery($fields); $query = sprintf($this->orcrPlateQuery(), $fields, $array_data['search'], $array_data['date_added'], $array_data['date_received'], $array_data['sms_status'], $array_data['company_access'], $array_data['dealer_access'], $array_data['sort'], $limit); $paramType = "s"; $paramValue = array( $array_data['search_keyword'], // $array_data['user_id'], ); return Database::connect()->select($query, $paramType, $paramValue); } public function getAllError() { $query = "SELECT s.,scd.dealer_id,v.conduction_sticker FROM `vehicle_orcr_plate_status` s INNER JOIN vehicle v ON s.`vehicle_id` = v.id INNER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id where s.`sms_date` is null AND s.`sms_response` != '' "; return Database::connect()->runBaseQuery($query); } public function getPlateStatus($array_data) { $query = "SELECT COUNT(1) FROM vehicle_orcr_plate_status WHERE (type='orcr_plate' OR type='plate') AND vehicle_id = ?"; $paramType = "i"; return Database::connect()->select($query, $paramType, $array_data); } public function getORCRStatus($array_data) { $query = "SELECT COUNT(1) FROM vehicle_orcr_plate_status WHERE (type='orcr_plate' OR type='orcr') AND vehicle_id = ?"; $paramType = "i"; return Database::connect()->select($query, $paramType, $array_data); } } ��Models/Vehicle.php��0000644��00000010454�15025010271�0010054 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Vehicle extends Model { public function getVehicleDataByCS($cs) { $query = "SELECT v., sc.name as company, sd.name as dealer, sb.name as brand, scm.name as model, scmv.name as model_variant , cc.mobile_phone_1, cc.email_1, sd.id as dealer_id FROM vehicle v LEFT OUTER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id LEFT OUTER JOIN source_company sc ON scd.company_id = sc.id LEFT OUTER JOIN source_dealer sd ON scd.dealer_id = sd.id LEFT OUTER JOIN source_brand sb ON v.brand_id = sb.id LEFT OUTER JOIN source_car_model scm ON v.model_id = scm.id LEFT OUTER JOIN source_car_model_variant scmv ON v.model_variant_description = scmv.id LEFT OUTER JOIN customer c ON v.customer_record_id = c.id LEFT OUTER JOIN customer_contact cc ON c.id = cc.customer_id WHERE 1 AND v.conduction_sticker = ? "; $paramType = "s"; $paramValue = array( $cs, ); return Database::connect()->runQuery($query, $paramType, $paramValue); } public function updateVehiclePlate($array_data) { $query = "UPDATE `vehicle` SET `plate_number` = ?, `modified_by` = ?, `date_modified` = NOW() WHERE `id` = ? "; $paramType = "sii"; $paramValue = array( $array_data['plate'], $array_data['user_id'], $array_data['vehicle_id'], ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function updateVehicleOr($array_data) { $query = "UPDATE `vehicle` SET `official_receipt` = ?, `modified_by` = ?, `date_modified` = NOW() WHERE `id` = ? "; $paramType = "sii"; $paramValue = array( $array_data['or'], $array_data['user_id'], $array_data['vehicle_id'], ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function updateVehicleCr($array_data) { $query = "UPDATE `vehicle` SET `certificate_of_registration` = ?, `modified_by` = ?, `date_modified` = NOW() WHERE `id` = ? "; $paramType = "sii"; $paramValue = array( $array_data['cr'], $array_data['user_id'], $array_data['vehicle_id'], ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function updateVehicleMv($array_data) { $query = "UPDATE `vehicle` SET `mv_file` = ?, `modified_by` = ?, `date_modified` = NOW() WHERE `id` = ? "; $paramType = "sii"; $paramValue = array( $array_data['mv'], $array_data['user_id'], $array_data['vehicle_id'], ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function updateVehicleEngineNo($array_data) { $query = "UPDATE `vehicle` SET `engine_number` = ?, `modified_by` = ?, `date_modified` = NOW() WHERE `id` = ? "; $paramType = "sii"; $paramValue = array( $array_data['engine_no'], $array_data['user_id'], $array_data['vehicle_id'], ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function updateVehicleChassisNo($array_data) { $query = "UPDATE `vehicle` SET `chassis_number` = ?, `modified_by` = ?, `date_modified` = NOW() WHERE `id` = ? "; $paramType = "sii"; $paramValue = array( $array_data['chassis_no'], $array_data['user_id'], $array_data['vehicle_id'], ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } } ��Models/Import.php��0000644��00000002767�15025010271�0007757 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Import extends Model { public function getImportFields($module_id) { $query = "SELECT * FROM import_module_fields WHERE 1 AND module_id = ?"; $queryType = "i"; $queryValue = array( $module_id, ); return Database::connect()->runQuery($query, $queryType, $queryValue); } public function updateImportFields($array_data) { $query = "UPDATE `import_module_fields` SET `field`=? WHERE 1 AND id = ?"; $queryType = "si"; $queryValue = array( strtoupper($array_data['value']), $array_data['key'], ); return Database::connect()->update($query, $queryType, $queryValue); } public function getSummaryIndex($str, $col_count, $array) { for ($i = 0; $i < $col_count; $i++) { if (in_array($str, $array, true)) { return $i; } } return -2; } function getFieldName($row, $col_count, $array_data) { for ($i = 0; $i < $col_count; $i++) { if (in_array(trim($row[$i]), $array_data, true)) { return $row[$i]; } } return ""; } function checkExist($row_arr, $field, $headers_arr) { if (empty($field)) { return ""; } $key = array_search($field, $headers_arr); return isset($row_arr[$key]) ? $row_arr[$key] : ''; } } ��Models/Dealer.php��0000644��00000001173�15025010271�0007667 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Dealer extends Model { public function getCompanyDealers($company_id) { $query = "SELECT sd.id, sd.code, sd.name FROM source_dealer sd LEFT OUTER JOIN source_company_dealer scd ON sd.id=scd.dealer_id WHERE 1 AND scd.company_id = ? AND sd.status = 1 and scd.status = 1 GROUP BY sd.id ORDER BY sd.code ASC"; $queryType = "i"; $queryValue = array( $company_id, ); return Database::connect()->runQuery($query, $queryType, $queryValue); } } ��Models/Company copy.php��0000644��00000001154�15025010271�0011033 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Company extends Model { public function getCompany($id) { $query = "SELECT * FROM autoph_db.source_company WHERE 1 AND id = ?"; $queryType = "i"; $queryValue = array( $id, ); return Database::connect()->runQuery($query, $queryType, $queryValue); } public function getUserAccessCompany($ids) { $query = "SELECT * FROM autoph_db.source_company WHERE 1 AND id IN (" . $ids . ") ORDER BY code"; return Database::connect()->runBaseQuery($query); } } ��Models/Industry.php��0000644��00000000160�15025010271�0010307 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Industry extends Model { } ��Models/NatureOfBusiness.php��0000644��00000043755�15025010271�0011746 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; use App\Core\Sms; class NatureOfBusiness extends Model { public function getNatureOfBusinessCategoryCount($array_data) { $query = " SELECT snob.id,snob.name,COUNT(1) as count FROM (SELECT snob.id, IF(snob.category_id = 0,snob.id,snob.category_id) AS category_id, snob.name, snob.is_parent FROM customer c INNER JOIN vehicle v ON c.id = v.customer_record_id INNER JOIN sales s ON v.id = s.vehicle_id LEFT OUTER JOIN source_nature_of_business snob ON c.nature_of_business_id = snob.id LEFT OUTER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id LEFT OUTER JOIN source_company sc ON scd.company_id = sc.id LEFT OUTER JOIN source_dealer sd ON scd.dealer_id = sd.id WHERE 1 /fix where statement/ AND s.activity_date != '' AND (snob.category_id != 0 OR snob.is_parent = 1) %s /company/ %s /dealer/ %s /snob/ %s /sales date/ GROUP BY c.id ORDER BY s.activity_date DESC) t1 INNER JOIN source_nature_of_business snob ON t1.category_id = snob.id WHERE snob.is_parent = 1 GROUP BY snob.id ORDER BY count DESC "; $result = Database::connect()->runBaseQuery(sprintf($query, $array_data['company_access'], $array_data['dealer_access'], $array_data['category'], $array_data['sales_date'])); return $result; } public function getNatureOfBusinessCategories() { $query = "SELECT * FROM source_nature_of_business WHERE 1 AND is_parent = 1 AND status = 1 ORDER BY name ASC"; $result = Database::connect()->runBaseQuery($query); return $result; } public function getNatureOfBusinessInfo($id) { $query = "SELECT * FROM source_nature_of_business WHERE 1 AND id = ?"; $queryType = "i"; $queryValue = array( $id, ); return Database::connect()->runQuery($query, $queryType, $queryValue); } public function getNatureOfBusinessDataQuery() { return "SELECT t1.* FROM ( SELECT c.id, IF( snob.category_id = 0, snob.id, snob.category_id ) AS category_id, IF( c.type = 1, CONCAT( c.last_name, ', ', c.first_name, ' ', c.middle_name ), c.corporation_name ) AS customer, c.type AS customer_type, cc.mobile_phone_1 AS mobile, cc.email_1 AS email, sc.code AS company, sd.code AS dealer, s.activity_date AS date, s.id AS sales_id, sfu.called, sfu.sms, snob.name AS nob FROM customer c INNER JOIN customer_contact cc ON c.id = cc.customer_id INNER JOIN vehicle v ON c.id = v.customer_record_id INNER JOIN sales s ON v.id = s.vehicle_id LEFT OUTER JOIN source_nature_of_business snob ON c.nature_of_business_id = snob.id LEFT OUTER JOIN source_company_dealer scd ON v.company_dealer_id = scd.id LEFT OUTER JOIN source_company sc ON scd.company_id = sc.id LEFT OUTER JOIN source_dealer sd ON scd.dealer_id = sd.id LEFT OUTER JOIN source_follow_ups sfu ON s.id = sfu.sales_id WHERE 1 /fix where statement/ AND s.activity_date != '' AND ( snob.category_id != 0 OR snob.is_parent = 1 ) %s /company/ %s /dealer/ %s /sales _date/ GROUP BY c.id %s /order/ ) t1 INNER JOIN source_nature_of_business snob ON t1.category_id = snob.id WHERE 1 %s %s /limit/ "; } public function getNatureOfBusinessDataCount($array_data) { $query_final = "SELECT COUNT(1) FROM (" . sprintf($this->getNatureOfBusinessDataQuery(), $array_data['company_access'], $array_data['dealer_access'], $array_data['sales_date'], $array_data['sort'], $array_data['category'], '') . ") t2"; $result = Database::connect()->selectBaseQuery($query_final); return $result; } public function getNatureOfBusinessData($array_data) { $query = sprintf($this->getNatureOfBusinessDataQuery(), $array_data['company_access'], $array_data['dealer_access'], $array_data['sales_date'], $array_data['sort'], $array_data['category'], $array_data['offset_limit']); // echo $query; exit; $result = Database::connect()->runBaseQuery($query); return $result; } public function tableAction($array_data) { $offset = $array_data['offset']; $limit = $array_data['limit']; $sales_id = $array_data['sales_id']; $fields = " sfu.`id`, DATE_FORMAT(sfu.`sms`, '%b %d, %Y / %h:%i:%s %p') AS sms, DATE_FORMAT(sfu.`called`, '%b %d, %Y / %h:%i:%s %p') AS called, concat(e1.`first_name`, ' ', e1.`last_name`) AS sms_done_by, concat(e2.`first_name`, ' ', e2.`last_name`) AS call_done_by, sfu.`remarks`, sfu.`status` "; $count = " COUNT(1) "; $json_arr['rows'] = array(); $action_list = "SELECT %s FROM `source_follow_ups` sfu INNER JOIN `employee` e1 ON e1.id = sfu.sms_done_by INNER JOIN `employee` e2 ON e2.id = sfu.call_done_by WHERE `sales_id` = '$sales_id'"; // echo sprintf($action_list, $fields); exit; $action_list_query = Database::connect()->runBaseQuery(sprintf($action_list, $fields)); $action_list_count = Database::connect()->selectBaseQuery(sprintf($action_list, $count)); $flag = 0; $count = 2; if(empty($action_list_query)){ while($count != 0){ if($flag == 0){ $json_arr['rows'] = array_merge($json_arr['rows'], array(array( 'action' => "SMS", 'data' => '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>', 'done_by' => '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>' ))); $flag = 1; } else { $json_arr['rows'] = array_merge($json_arr['rows'], array(array( 'id' => $row['id'], 'action' => "CALL", 'data' => '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>', 'done_by' => '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>' ))); $flag = 0; } $count--; } } else { foreach ($action_list_query AS $row) { while($count != 0){ if($flag == 0){ $json_arr['rows'] = array_merge($json_arr['rows'], array(array( 'id' => $row['id'], 'action' => "SMS", 'remarks' => $row['remarks'], 'data' => $row['sms'] == null ? '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>' : $row['sms'], 'done_by' => $row['sms'] == null ? '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>' : $row['sms_done_by'] ))); $flag = 1; } else { $json_arr['rows'] = array_merge($json_arr['rows'], array(array( 'id' => $row['id'], 'action' => "CALL", 'remarks' => $row['remarks'], 'data' => $row['called'] == null ? '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>' : $row['called'], 'done_by' => $row['called'] == null ? '<span><i class="fas fa-times-circle" style="color: #b22222;"></i></span>' : $row['call_done_by'] ))); $flag = 0; } $count--; } } } $json_arr['total'] = $action_list_count; return $json_arr; } public function smsCall($array_data) { $type = $array_data['type']; $sales_id = $array_data['sales_id']; $phone = $array_data['phone']; $json_arr = array(); $count = Database::connect()->selectBaseQuery("SELECT COUNT(1) FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if($count > 0){ // has record if($type == "sms"){ $is_done = Database::connect()->selectBaseQuery("SELECT `sms` FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if(!is_null($is_done)){ $json_arr['status'] = 3; // done } else { $sms_status = $this->sendMessage($phone); if($sms_status == 0){ // send sms success $current_datetime = Database::connect()->selectBaseQuery("SELECT NOW()"); $current_user = $_SESSION['user']['id']; $update_query = "UPDATE `source_follow_ups` SET `sms` = '$current_datetime', `sms_done_by` = '$current_user' WHERE `sales_id` = '$sales_id'"; // echo $update_query; exit; $update = Database::connect()->updateBaseQuery($update_query); if($update > 0){ $json_arr['status'] = 0; // success } else { $json_arr['status'] = 1; // database failed } } else { $json_arr['status'] = 2; // sms failed } } } else { // call $is_done = Database::connect()->selectBaseQuery("SELECT `called` FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if(!is_null($is_done)){ $json_arr['status'] = 3; // done } else { $current_datetime = Database::connect()->selectBaseQuery("SELECT NOW()"); $current_user = $_SESSION['user']['id']; $update_query = "UPDATE `source_follow_ups` SET `called` = '$current_datetime', `call_done_by` = '$current_user' WHERE `sales_id` = '$sales_id'"; $update = Database::connect()->updateBaseQuery($update_query); if($update > 0){ $json_arr['status'] = 0; // success } else { $json_arr['status'] = 1; // failed } } } } else { if($type == "sms"){ $is_done = Database::connect()->selectBaseQuery("SELECT `sms` FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if($is_done != ""){ $json_arr['status'] = 3; // done } else { $sms_status = $this->sendMessage($phone); if($sms_status == 0){ $current_datetime = Database::connect()->selectBaseQuery("SELECT NOW()"); $current_user = $_SESSION['user']['id']; $insert_query = "INSERT INTO `source_follow_ups`(`sales_id`, `sms`, `sms_done_by`) VALUES('$sales_id', '$current_datetime', '$current_user')"; $insert = Database::connect()->updateBaseQuery($insert_query); if($insert > 0){ $json_arr['status'] = 0; // success } else { $json_arr['status'] = 1; // database failed } } else { $json_arr['status'] = 2; // sms failed } } } else { // call // echo "SELECT `called` FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"; exit; $is_done = Database::connect()->selectBaseQuery("SELECT `called` FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if($is_done != ""){ $json_arr['status'] = 3; // done } else { $current_datetime = Database::connect()->selectBaseQuery("SELECT NOW()"); $current_user = $_SESSION['user']['id']; $insert_query = "INSERT INTO `source_follow_ups`(`sales_id`, `called`, `call_done_by`) VALUES('$sales_id', '$current_datetime', '$current_user')"; $insert = Database::connect()->updateBaseQuery($insert_query); if($insert > 0){ $json_arr['status'] = 0; // success } else { $json_arr['status'] = 1; // failed } } } } // print_r($json_arr); exit; return $json_arr; } public function remarks($array_data) { $sales_id = $array_data['sales_id']; $remarks = $array_data['remarks']; $json_arr = array(); $is_existing = Database::connect()->selectBaseQuery("SELECT COUNT(1) FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if($is_existing > 0){ $current_datetime = Database::connect()->selectBaseQuery("SELECT DATE_FORMAT((SELECT NOW()), '%b %d, %Y / %h:%i:%s %p')"); $current_user = $_SESSION['user']['first_name'] . " " . $_SESSION['user']['last_name'] . " [" . $_SESSION['user']['id'] . "] "; $remarks_last_update = $current_user . $current_datetime; $query = "UPDATE `source_follow_ups` SET `remarks` = '$remarks', `remarks_last_update` = '$remarks_last_update' WHERE `sales_id` = '$sales_id'"; $update = Database::connect()->updateBaseQuery($query); if($update > 0){ $json_arr['status'] = 0; // update success } else { $json_arr['status'] = 1; // update failed } } else { // not existing $current_datetime = Database::connect()->selectBaseQuery("SELECT DATE_FORMAT((SELECT NOW()), '%b %d, %Y / %h:%i:%s %p')"); $current_user = $_SESSION['user']['first_name'] . " " . $_SESSION['user']['last_name'] . " [" . $_SESSION['user']['id'] . "] "; $remarks_last_update = $current_user . $current_datetime; $query = "INSERT INTO `source_follow_ups`(`sales_id`, `remarks`, `remarks_last_update`, `status`) VALUES('$sales_id', '$remarks', '$remarks_last_update', 1)"; // echo $query; exit; $insert = Database::connect()->updateBaseQuery($query); if($insert > 0){ $json_arr['status'] = 0; // insert success } else { $json_arr['status'] = 1; // insert failed } } return $json_arr; } public function sendMessage($phone) { $query = "SELECT `message_header`, `message_body`, `message_footer` FROM `auto_txt_blast` WHERE `id` = 5"; $message_contents = Database::connect()->runBaseQuery($query); $header = ""; $body = ""; $footer = ""; foreach($message_contents AS $row){ $header = $row['message_header']; $body = $row['message_body']; $footer = $row['message_footer']; } $full_message = $header . "\n\n" . $body . "\n\n" . $footer; $sms_data['message'] = $full_message; $sms_data['mobile'] = $phone; $sms_response = Sms::sendSms($sms_data); $status = null; if($sms_response == 0){ // success $status = 0; } else { $status = 1; } return $status; } public function loadRemarks($array_data) { $sales_id = $array_data['sales_id']; $json_arr = array(); $is_existing = Database::connect()->selectBaseQuery("SELECT COUNT(1) FROM `source_follow_ups` WHERE `sales_id` = '$sales_id'"); if($is_existing > 0){ $query = "SELECT `remarks_last_update` FROM `source_follow_ups` WHERE `sales_id` = $sales_id"; $remarks_log = Database::connect()->selectBaseQuery($query); if(!is_null($remarks_log)){ $json_arr['status'] = 0; // goods $json_arr['remarks_log'] = $remarks_log; $json_arr['remarks'] = Database::connect()->selectBaseQuery("SELECT `remarks` FROM `source_follow_ups` WHERE `sales_id` = $sales_id"); } else { $json_arr['status'] = 1; // not good } } else { $json_arr['status'] = 1; // not good } return $json_arr; } } ��Models/User.php��0000644��00000040013�15025010271�0007405 0��ustar�00��<?php namespace App\Models; //Tips for impelementing codes use App\Core\Model; use App\Core\Database; class User extends Model { public function userInfo($user_id) { $query = "SELECT e.id, e.asa_id, e.`employee_id`, e.`first_name`, e.`middle_name`, e.`last_name`, concat(e.`first_name`, ' ', e.`last_name`) AS full_name, ext.suffix_name , e.`date_of_birth`, ag.gender_name, ag.id AS gender_id, e.`photo`, DATE_FORMAT(e.date_registered, '%M %d, %Y - %h:%i:%s %p') as date_registered, ea.username, ea.employee_role_id , ec.email_address, ec.email_address_2, ec.contact_number, ec.contact_number_2, ec.fax, ec.business, ec.residential, ec.landline, ec.address, st.provDesc, st.provCode as state_id, ac.citymunDesc, ac.id as city_id, ec.postal, ed.department_name, ed.id as department, ep.position_name, ep.id as position, sc.code as company_code, sc.name as company_name, sd.code as dealer_code, sd.name as dealer_name, sd.id as dealer, sc.id as company FROM `employee` e LEFT OUTER JOIN employee_account ea ON e.id = ea.user_id LEFT OUTER JOIN employee_contact ec ON e.id = ec.user_id LEFT OUTER JOIN all_suffix ext ON e.suffix_id = ext.id LEFT OUTER JOIN all_gender ag ON e.gender_id = ag.id LEFT OUTER JOIN source_company_dealer cdi ON e.company_dealer_id = cdi.id LEFT OUTER JOIN source_company sc ON cdi.company_id = sc.id LEFT OUTER JOIN source_dealer sd ON cdi.dealer_id = sd.id LEFT OUTER JOIN employee_department ed ON e.department_id = ed.id LEFT OUTER JOIN employee_position ep ON e.position_id = ep.id LEFT OUTER JOIN all_state st on ec.provCode = st.provCode LEFT OUTER JOIN all_city ac ON ec.city_id=ac.id where e.id = ?"; $paramType = "i"; $paramValue = array( $user_id, ); $result = Database::connect()->runQuery($query, $paramType, $paramValue); return $result; } public function getUserRole($user_id) { $query = "SELECT employee_role_id FROM employee_account WHERE 1 AND user_id = ?"; $paramType = "i"; $paramValue = array( $user_id, ); $result = Database::connect()->select($query, $paramType, $paramValue); return $result; } public function getUserPermissions($role_id) { $query = "SELECT action_permissions,company_permissions,fields_permissions FROM `employee_role_access` WHERE status = 1 AND employee_role_id = ? "; $paramType = "i"; $paramValue = array( $role_id, ); $result = Database::connect()->runQuery($query, $paramType, $paramValue); return $result; } public function userDataByEmail($email) { $query = "SELECT * FROM `user` WHERE 1 AND `email` = ?"; $paramType = "s"; $paramValue = array( $email, ); $result = Database::connect()->runQuery($query, $paramType, $paramValue); return $result; } public function createUserData($array_data) { $firstname = ucfirst($array_data['txt_fname']); $lastname = ucfirst($array_data['txt_lname']); $email = $array_data['txt_email']; $password = $array_data['txt_password']; $password_hash = password_hash($password, PASSWORD_DEFAULT); $query = "INSERT INTO `user`(`firstName`, `lastName`, `email`, `passwordHash`,`registeredAt`) VALUES (?,?,?,?,NOW())"; $paramType = "ssss"; $paramValue = array( $firstname, $lastname, $email, $password_hash ); $insertId = Database::connect()->insert($query, $paramType, $paramValue); return $insertId; } public function createUserEmailVerification($user_id, $token, $email) { $query = "INSERT INTO `user_email_verification`(`userId`, `token`, `email`,`createdAt`) VALUES (?,?,?,NOW())"; $paramType = "iss"; $paramValue = array( $user_id, $token, $email, ); $insertId = Database::connect()->insert($query, $paramType, $paramValue); return $insertId; } public function createLastLoginDate($user_id) { $query = "UPDATE user SET lastLogin = NOW() WHERE id = ?"; $paramType = "i"; $paramValue = array( $user_id, ); Database::connect()->update($query, $paramType, $paramValue); } public function createLoginToken($user_id, $token) { $query = "INSERT INTO `user_login_session`(`userId`, `token`, `createdAt`,`status`) VALUES (?,?,NOW(),1) ON DUPLICATE KEY UPDATE token = VALUES (token), createdAt = VALUES(createdAt), status = VALUES(status) "; $paramType = "is"; $paramValue = array( $user_id, $token, ); $insertId = Database::connect()->insert($query, $paramType, $paramValue); return $insertId; } public function emailTokenUserId($token) { $query = "SELECT userId FROM user_email_verification WHERE token = ? AND status IS NULL"; $paramType = "s"; $paramValue = array( $token ); $result = Database::connect()->select($query, $paramType, $paramValue); return $result; } public function disableEmailToken($token) { $query = "UPDATE user_email_verification SET status = 1 WHERE token = ? "; $paramType = "s"; $paramValue = array( $token ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function activateUser($user_id) { $query = "UPDATE user SET active = 1 WHERE id = ? "; $paramType = "i"; $paramValue = array( $user_id ); $result = Database::connect()->update($query, $paramType, $paramValue); return $result; } public function userIdByToken($token) { $query = "SELECT userId FROM user_login_session WHERE token = ? AND status = 1"; $paramType = "s"; $paramValue = array( $token ); $result = Database::connect()->select($query, $paramType, $paramValue); return $result; } public function authenticate() { $token = $_COOKIE['uid']; $userId = $this->userIdByToken($token); $query = "SELECT * FROM `user` WHERE 1 AND `id` = ?"; $paramType = "i"; $paramValue = array( $userId, ); $result = Database::connect()->runQuery($query, $paramType, $paramValue); return $result; } public function userStatus($userId) { $query = "SELECT * FROM `user` WHERE 1 AND `id` = ? AND status = 1 AND active = 1"; $paramType = "i"; $paramValue = array( $userId, ); $result = Database::connect()->runQuery($query, $paramType, $paramValue); return $result; } public function userAccess($userId) { $query = "SELECT admin,vendor FROM `user` WHERE 1 AND `id` = ? AND status = 1 AND active = 1"; $paramType = "i"; $paramValue = array( $userId, ); $result = Database::connect()->runQuery($query, $paramType, $paramValue); return $result; } public function userRoleId($userId) { $query = "SELECT u.roleId FROM `user` u INNER JOIN role r ON u.roleId = r.id WHERE 1 AND r.active = 1 AND u.id = ?"; $paramType = "i"; $paramValue = array( $userId, ); $result = Database::connect()->select($query, $paramType, $paramValue); return $result; } // user table settings public function tableUser($input_arr) { $type = $input_arr['type']; $search = $input_arr['search']; $offset = $input_arr['offset']; $limit = $input_arr['limit']; if ($type == 1) { // table list of brand $fields = " `id`, `profile`, concat(`firstName`, ' ', `lastName`) AS full_name, `roleId`, `status` "; $count = " COUNT(1) "; $json_arr['rows'] = array(); $user_list = "SELECT %s FROM `user` WHERE concat(`id`, `firstName`, `lastName`) LIKE '%%$search%%'"; // echo sprintf($user_list, $fields); exit; $user_list_query = Database::connect()->runBaseQuery(sprintf($user_list, $fields)); $user_list_count = Database::connect()->selectBaseQuery(sprintf($user_list, $count)); foreach ($user_list_query as $row) { $json_arr['rows'] = array_merge($json_arr['rows'], array(array( 'user_id' => $row['id'], 'profile' => $row['profile'], 'full_name' => $row['full_name'], 'role' => $row['roleId'], 'status' => $row['status'] == 0 ? "<span class='badge bg-danger'>INACTIVE</span>" : "<span class='badge bg-success'>ACTIVE</span>" ))); } $json_arr['total'] = $user_list_count; return $json_arr; } } public function loadUser($input_arr) { $user_id = $input_arr['user_id']; $sql = "SELECT u.id, u.roleId, u.profile, u.firstName, u.middleName, u.lastName, u.extName, u.mobile, u.email, u.profile, DATE_FORMAT(u.registeredAt, '%b %d, %Y') AS registered, u.status FROM user u WHERE u.id = '$user_id'"; // echo $sql; exit; $result = Database::connect()->runBaseQuery($sql); return $result; } public function extName() { $sql = "SELECT `id`, `name` FROM all_suffix WHERE `status` = 1"; $result = Database::connect()->runBaseQuery($sql); return $result; } public function updateUser($arr_data) { $user_id = $arr_data['user_id']; $update_first_name = strtoupper($arr_data['user_first_name']); $update_middle_name = strtoupper($arr_data['user_middle_name']); $update_last_name = strtoupper($arr_data['user_last_name']); $update_ext_name = $arr_data['user_ext_name']; $update_mobile_number = $arr_data['user_mobile_number']; $update_email = $arr_data['user_email']; $update_profile = $arr_data['image_filename']; $update_status = $arr_data['user_status']; $return_arr = array(); // $current_user = Session::get('user')['id']; $original_arr = array(); $select_sql = "SELECT `firstName`, `middleName`, `lastName`, `extName`, `mobile`, `email`, `profile`, `status` FROM `user` WHERE `id` = '$user_id'"; $original_user_list = Database::connect()->runBaseQuery($select_sql); foreach ($original_user_list as $row) { $original_arr[0] = $row['firstName']; $original_arr[1] = $row['middleName']; $original_arr[2] = $row['lastName']; $original_arr[3] = $row['extName']; $original_arr[4] = $row['mobile']; $original_arr[5] = $row['email']; $original_arr[6] = $row['status']; $original_arr[7] = $row['profile']; } if ( $original_arr[0] == $update_first_name && $original_arr[1] == $update_middle_name && $original_arr[2] == $update_last_name && $original_arr[3] == $update_ext_name && $original_arr[4] == $update_mobile_number && $original_arr[5] == $update_email && $original_arr[6] == $update_status && $update_profile == "Same" ) { return 10; // nothing changes } else { $duplicate_mobile = Database::connect()->selectBaseQuery("SELECT `mobile` FROM `user` WHERE `id` = '$user_id'"); $duplicate_email = Database::connect()->selectBaseQuery("SELECT `email` FROM `user` WHERE `id` = '$user_id'"); if ($duplicate_mobile == 1) { return 1; // duplicate mobile } else if ($duplicate_email == 1) { return 2; // duplicate email } else { $sql = ""; if ($update_profile == "Same") { $sql = "UPDATE `user` SET `firstName` = '$update_first_name', `middleName` = '$update_middle_name', `lastName` = '$update_last_name', `extName` = '$update_ext_name', `mobile` = '$update_mobile_number', `email` = '$update_email', `status` = '$update_status' WHERE `id` = '$user_id'"; } else { $file_name = $original_arr[7]; if ($file_name == "default.png") { // do nothing, not deleting the default photo } else { $file_name = "storage/users/" . $file_name; unlink($file_name); } $sql = "UPDATE `user` SET `firstName` = '$update_first_name', `middleName` = '$update_middle_name', `lastName` = '$update_last_name', `extName` = '$update_ext_name', `mobile` = '$update_mobile_number', `email` = '$update_email', `profile` = '$update_profile', `status` = '$update_status' WHERE `id` = '$user_id'"; // echo $sql; exit; } $update_sql = Database::connect()->updateBaseQuery($sql); if ($update_sql > 0) { return 0; // success } else { return 3; // update error } } } // $original_first_name = Database::connect()->selectBaseQuery("SELECT `name` FROM `brand` WHERE `id` = '$brand_id'"); // $original_description = Database::connect()->selectBaseQuery("SELECT `description` FROM `brand` WHERE `id` = '$brand_id'"); // $original_status = Database::connect()->selectBaseQuery("SELECT `status` FROM `brand` WHERE `id` = '$brand_id'"); // if($original_name == $update_brand_name && $original_description == $update_brand_description && $original_status == $update_brand_status && $update_logo_name == "Same"){ // return 10; // nothing changes // } // else { // $duplicate_name = Database::connect()->selectBaseQuery("SELECT COUNT(1) FROM `brand` WHERE `name` = '$update_brand_name' AND `id` != '$brand_id'"); // if($duplicate_name > 0){ // return 1; // duplicate found // } // else { // if($update_logo_name == "Same"){ // $sql = "UPDATE `brand` SET `name` = '$update_brand_name', `description` = '$update_brand_description', `status` = '$update_brand_status' WHERE `id` = '$brand_id'"; // echo $sql; exit; // } // else { // $file_name = Database::connect()->selectBaseQuery("SELECT `logo` FROM `brand` WHERE `id` = '$brand_id'"); // $file_name = "assets/img/logo/brands/" . $file_name; // unlink($file_name); // $sql = "UPDATE `brand` SET `name` = '$update_brand_name', `logo` = '$update_logo_name', `description` = '$update_brand_description', `status` = '$update_brand_status' WHERE `id` = '$brand_id'"; // echo $sql; exit; // } // $update_sql = Database::connect()->updateBaseQuery($sql); // if($update_sql > 0){ // return 0; // success // } // else { // return 2; // update failed // } // } // } } } ��Models/Customer/Activity.php��0000644��00000002352�15025010271�0012070 0��ustar�00��<?php namespace App\Models\Customer; use App\Core\Database; use App\Core\Model; class Activity { public function store($paramValue) { $query = "INSERT INTO `customer_activities`( `id`, `customer_id`, `vehicle_id`, `user_id`, `activity`, `status` ) VALUES (?,?,?,?,?,?)"; return Database::connect()->insert($query, "iiiisi", $paramValue); } public function storeInsurance($paramValue) { $query = "INSERT INTO `customer_activity_insurance_status`( `id`, `customer_id`, `user_id`, `plate_number`, `conduction_sticker`, `insurance_company`, `policy_number`, `issue_date`, `start_date`, `end_date`, `progress`, `status`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?)"; return Database::connect()->insert($query, "iiissssssssi", $paramValue); } public function template($paramValue) { $query = "SELECT * FROM `customer_activity_template` WHERE 1 AND id = ?"; return Database::connect()->selectQuery($query, "i", $paramValue); } } ��Models/Sms.php��0000644��00000001254�15025010271�0007235 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Sms extends Model { public function getSmsTemplate($id) { $query = "SELECT template FROM sms_module_templates WHERE 1 AND id = ?"; $queryType = "i"; $queryValue = array( $id, ); return Database::connect()->select($query, $queryType, $queryValue); } public function getSmsModuleStatus($id) { $query = "SELECT status FROM sms_modules WHERE 1 AND id = ?"; $queryType = "i"; $queryValue = array( $id, ); return Database::connect()->select($query, $queryType, $queryValue); } } ��Models/Api.php��0000644��00000001100�15025010271�0007172 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Api extends Model { public function getApiKeyAccessUris($array_data) { $query = "SELECT akau.uri FROM api_keys ak INNER JOIN api_key_access_uris akau ON ak.id = akau.api_key_id WHERE 1 AND ak.api_key = ? AND ak.status = 1 AND akau.status = 1"; $queryType = "s"; $queryValue = array( $array_data['key'], ); return Database::connect()->runQuery($query, $queryType, $queryValue); } } ��Models/Company.php��0000644��00000001154�15025010271�0010100 0��ustar�00��<?php namespace App\Models; use App\Core\Database; use App\Core\Model; class Company extends Model { public function getCompany($id) { $query = "SELECT * FROM autoph_db.source_company WHERE 1 AND id = ?"; $queryType = "i"; $queryValue = array( $id, ); return Database::connect()->runQuery($query, $queryType, $queryValue); } public function getUserAccessCompany($ids) { $query = "SELECT * FROM autoph_db.source_company WHERE 1 AND id IN (" . $ids . ") ORDER BY code"; return Database::connect()->runBaseQuery($query); } } ��Router.php��0000644��00000002737�15025010271�0006537 0��ustar�00��<?php /** * Custom router which handles default middlewares, default exceptions and things * that should be happen before and after the router is initialised. / namespace App; use Pecee\SimpleRouter\SimpleRouter; class Router extends SimpleRouter { /* * @throws \Exception * @throws \Pecee\Http\Middleware\Exceptions\TokenMismatchException * @throws \Pecee\SimpleRouter\Exceptions\HttpException * @throws \Pecee\SimpleRouter\Exceptions\NotFoundHttpException / // public static function start(): void // { // // Load our helpers // require_once 'helpers.php'; // // Load our custom routes // require_once 'routes/web.php'; // // Do initial stuff // parent::start(); // } public static function start(): void { // Load our helpers // require_once 'helpers.php'; move to index Router::csrfVerifier(new \App\Middlewares\CsrfVerifier()); Router::setDefaultNamespace('\App\Controllers'); // Router::group(['middleware' => \App\Middlewares\Maintenance::class], function () { Router::group(['exceptionHandler' => \App\Handlers\CustomExceptionHandler::class], function () { // API // Router::group(['prefix' => '/api', 'middleware' => \App\Middlewares\ApiVerification::class], function () { // Router::resource('/demo', 'ApiController'); // }); // Load our custom routes $gfg_folderpath = __DIR__ . "/../routes/"; \App\Utilities\Utility::includeFiles($gfg_folderpath); // }); }); // Do initial stuff parent::start(); } } ��EachPromise.php��0000644��00000017521�15025046355�0007467 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * Represents a promise that iterates over many promises and invokes * side-effect functions in the process. / class EachPromise implements PromisorInterface { private $pending = []; private $nextPendingIndex = 0; /* @var \Iterator\|null / private $iterable; /* @var callable\|int\|null / private $concurrency; /* @var callable\|null / private $onFulfilled; /* @var callable\|null / private $onRejected; /* @var Promise\|null / private $aggregate; /* @var bool\|null / private $mutex; /* * Configuration hash can include the following key value pairs: * * - fulfilled: (callable) Invoked when a promise fulfills. The function * is invoked with three arguments: the fulfillment value, the index * position from the iterable list of the promise, and the aggregate * promise that manages all of the promises. The aggregate promise may * be resolved from within the callback to short-circuit the promise. * - rejected: (callable) Invoked when a promise is rejected. The * function is invoked with three arguments: the rejection reason, the * index position from the iterable list of the promise, and the * aggregate promise that manages all of the promises. The aggregate * promise may be resolved from within the callback to short-circuit * the promise. * - concurrency: (integer) Pass this configuration option to limit the * allowed number of outstanding concurrently executing promises, * creating a capped pool of promises. There is no limit by default. * * @param mixed $iterable Promises or values to iterate. * @param array $config Configuration options / public function __construct($iterable, array $config = []) { $this->iterable = Create::iterFor($iterable); if (isset($config['concurrency'])) { $this->concurrency = $config['concurrency']; } if (isset($config['fulfilled'])) { $this->onFulfilled = $config['fulfilled']; } if (isset($config['rejected'])) { $this->onRejected = $config['rejected']; } } /* @psalm-suppress InvalidNullableReturnType / public function promise() { if ($this->aggregate) { return $this->aggregate; } try { $this->createPromise(); /* @psalm-assert Promise $this->aggregate / $this->iterable->rewind(); $this->refillPending(); } catch (\Throwable $e) { /* * @psalm-suppress NullReference * @phpstan-ignore-next-line / $this->aggregate->reject($e); } catch (\Exception $e) { /* * @psalm-suppress NullReference * @phpstan-ignore-next-line / $this->aggregate->reject($e); } /* * @psalm-suppress NullableReturnStatement * @phpstan-ignore-next-line / return $this->aggregate; } private function createPromise() { $this->mutex = false; $this->aggregate = new Promise(function () { if ($this->checkIfFinished()) { return; } reset($this->pending); // Consume a potentially fluctuating list of promises while // ensuring that indexes are maintained (precluding array_shift). while ($promise = current($this->pending)) { next($this->pending); $promise->wait(); if (Is::settled($this->aggregate)) { return; } } }); // Clear the references when the promise is resolved. $clearFn = function () { $this->iterable = $this->concurrency = $this->pending = null; $this->onFulfilled = $this->onRejected = null; $this->nextPendingIndex = 0; }; $this->aggregate->then($clearFn, $clearFn); } private function refillPending() { if (!$this->concurrency) { // Add all pending promises. while ($this->addPending() && $this->advanceIterator()); return; } // Add only up to N pending promises. $concurrency = is_callable($this->concurrency) ? call_user_func($this->concurrency, count($this->pending)) : $this->concurrency; $concurrency = max($concurrency - count($this->pending), 0); // Concurrency may be set to 0 to disallow new promises. if (!$concurrency) { return; } // Add the first pending promise. $this->addPending(); // Note this is special handling for concurrency=1 so that we do // not advance the iterator after adding the first promise. This // helps work around issues with generators that might not have the // next value to yield until promise callbacks are called. while (--$concurrency && $this->advanceIterator() && $this->addPending()); } private function addPending() { if (!$this->iterable \|\| !$this->iterable->valid()) { return false; } $promise = Create::promiseFor($this->iterable->current()); $key = $this->iterable->key(); // Iterable keys may not be unique, so we use a counter to // guarantee uniqueness $idx = $this->nextPendingIndex++; $this->pending[$idx] = $promise->then( function ($value) use ($idx, $key) { if ($this->onFulfilled) { call_user_func( $this->onFulfilled, $value, $key, $this->aggregate ); } $this->step($idx); }, function ($reason) use ($idx, $key) { if ($this->onRejected) { call_user_func( $this->onRejected, $reason, $key, $this->aggregate ); } $this->step($idx); } ); return true; } private function advanceIterator() { // Place a lock on the iterator so that we ensure to not recurse, // preventing fatal generator errors. if ($this->mutex) { return false; } $this->mutex = true; try { $this->iterable->next(); $this->mutex = false; return true; } catch (\Throwable $e) { $this->aggregate->reject($e); $this->mutex = false; return false; } catch (\Exception $e) { $this->aggregate->reject($e); $this->mutex = false; return false; } } private function step($idx) { // If the promise was already resolved, then ignore this step. if (Is::settled($this->aggregate)) { return; } unset($this->pending[$idx]); // Only refill pending promises if we are not locked, preventing the // EachPromise to recursively invoke the provided iterator, which // cause a fatal error: "Cannot resume an already running generator" if ($this->advanceIterator() && !$this->checkIfFinished()) { // Add more pending promises if possible. $this->refillPending(); } } private function checkIfFinished() { if (!$this->pending && !$this->iterable->valid()) { // Resolve the promise if there's nothing left to do. $this->aggregate->resolve(null); return true; } return false; } } ��Each.php��0000644��00000005507�15025046355�0006131 0��ustar�00��<?php namespace GuzzleHttp\Promise; final class Each { /* * Given an iterator that yields promises or values, returns a promise that * is fulfilled with a null value when the iterator has been consumed or * the aggregate promise has been fulfilled or rejected. * * $onFulfilled is a function that accepts the fulfilled value, iterator * index, and the aggregate promise. The callback can invoke any necessary * side effects and choose to resolve or reject the aggregate if needed. * * $onRejected is a function that accepts the rejection reason, iterator * index, and the aggregate promise. The callback can invoke any necessary * side effects and choose to resolve or reject the aggregate if needed. * * @param mixed $iterable Iterator or array to iterate over. * @param callable $onFulfilled * @param callable $onRejected * * @return PromiseInterface / public static function of( $iterable, callable $onFulfilled = null, callable $onRejected = null ) { return (new EachPromise($iterable, [ 'fulfilled' => $onFulfilled, 'rejected' => $onRejected ]))->promise(); } /* * Like of, but only allows a certain number of outstanding promises at any * given time. * * $concurrency may be an integer or a function that accepts the number of * pending promises and returns a numeric concurrency limit value to allow * for dynamic a concurrency size. * * @param mixed $iterable * @param int\|callable $concurrency * @param callable $onFulfilled * @param callable $onRejected * * @return PromiseInterface / public static function ofLimit( $iterable, $concurrency, callable $onFulfilled = null, callable $onRejected = null ) { return (new EachPromise($iterable, [ 'fulfilled' => $onFulfilled, 'rejected' => $onRejected, 'concurrency' => $concurrency ]))->promise(); } /* * Like limit, but ensures that no promise in the given $iterable argument * is rejected. If any promise is rejected, then the aggregate promise is * rejected with the encountered rejection. * * @param mixed $iterable * @param int\|callable $concurrency * @param callable $onFulfilled * * @return PromiseInterface / public static function ofLimitAll( $iterable, $concurrency, callable $onFulfilled = null ) { return each_limit( $iterable, $concurrency, $onFulfilled, function ($reason, $idx, PromiseInterface $aggregate) { $aggregate->reject($reason); } ); } } ��PromisorInterface.php��0000644��00000000364�15025046355�0010720 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * Interface used with classes that return a promise. / interface PromisorInterface { /* * Returns a promise. * * @return PromiseInterface / public function promise(); } ��AggregateException.php��0000644��00000000574�15025046355�0011035 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * Exception thrown when too many errors occur in the some() or any() methods. / class AggregateException extends RejectionException { public function __construct($msg, array $reasons) { parent::__construct( $reasons, sprintf('%s; %d rejected promises', $msg, count($reasons)) ); } } ��Create.php��0000644��00000004100�15025046355�0006460 0��ustar�00��<?php namespace GuzzleHttp\Promise; final class Create { /* * Creates a promise for a value if the value is not a promise. * * @param mixed $value Promise or value. * * @return PromiseInterface / public static function promiseFor($value) { if ($value instanceof PromiseInterface) { return $value; } // Return a Guzzle promise that shadows the given promise. if (is_object($value) && method_exists($value, 'then')) { $wfn = method_exists($value, 'wait') ? [$value, 'wait'] : null; $cfn = method_exists($value, 'cancel') ? [$value, 'cancel'] : null; $promise = new Promise($wfn, $cfn); $value->then([$promise, 'resolve'], [$promise, 'reject']); return $promise; } return new FulfilledPromise($value); } /* * Creates a rejected promise for a reason if the reason is not a promise. * If the provided reason is a promise, then it is returned as-is. * * @param mixed $reason Promise or reason. * * @return PromiseInterface / public static function rejectionFor($reason) { if ($reason instanceof PromiseInterface) { return $reason; } return new RejectedPromise($reason); } /* * Create an exception for a rejected promise value. * * @param mixed $reason * * @return \Exception\|\Throwable / public static function exceptionFor($reason) { if ($reason instanceof \Exception \|\| $reason instanceof \Throwable) { return $reason; } return new RejectionException($reason); } /* * Returns an iterator for the given value. * * @param mixed $value * * @return \Iterator / public static function iterFor($value) { if ($value instanceof \Iterator) { return $value; } if (is_array($value)) { return new \ArrayIterator($value); } return new \ArrayIterator([$value]); } } ��Utils.php��0000644��00000021000�15025046355�0006353 0��ustar�00��<?php namespace GuzzleHttp\Promise; final class Utils { /* * Get the global task queue used for promise resolution. * * This task queue MUST be run in an event loop in order for promises to be * settled asynchronously. It will be automatically run when synchronously * waiting on a promise. * * <code> * while ($eventLoop->isRunning()) { * GuzzleHttp\Promise\Utils::queue()->run(); * } * </code> * * @param TaskQueueInterface $assign Optionally specify a new queue instance. * * @return TaskQueueInterface / public static function queue(TaskQueueInterface $assign = null) { static $queue; if ($assign) { $queue = $assign; } elseif (!$queue) { $queue = new TaskQueue(); } return $queue; } /* * Adds a function to run in the task queue when it is next `run()` and * returns a promise that is fulfilled or rejected with the result. * * @param callable $task Task function to run. * * @return PromiseInterface / public static function task(callable $task) { $queue = self::queue(); $promise = new Promise([$queue, 'run']); $queue->add(function () use ($task, $promise) { try { if (Is::pending($promise)) { $promise->resolve($task()); } } catch (\Throwable $e) { $promise->reject($e); } catch (\Exception $e) { $promise->reject($e); } }); return $promise; } /* * Synchronously waits on a promise to resolve and returns an inspection * state array. * * Returns a state associative array containing a "state" key mapping to a * valid promise state. If the state of the promise is "fulfilled", the * array will contain a "value" key mapping to the fulfilled value of the * promise. If the promise is rejected, the array will contain a "reason" * key mapping to the rejection reason of the promise. * * @param PromiseInterface $promise Promise or value. * * @return array / public static function inspect(PromiseInterface $promise) { try { return [ 'state' => PromiseInterface::FULFILLED, 'value' => $promise->wait() ]; } catch (RejectionException $e) { return ['state' => PromiseInterface::REJECTED, 'reason' => $e->getReason()]; } catch (\Throwable $e) { return ['state' => PromiseInterface::REJECTED, 'reason' => $e]; } catch (\Exception $e) { return ['state' => PromiseInterface::REJECTED, 'reason' => $e]; } } /* * Waits on all of the provided promises, but does not unwrap rejected * promises as thrown exception. * * Returns an array of inspection state arrays. * * @see inspect for the inspection state array format. * * @param PromiseInterface[] $promises Traversable of promises to wait upon. * * @return array / public static function inspectAll($promises) { $results = []; foreach ($promises as $key => $promise) { $results[$key] = inspect($promise); } return $results; } /* * Waits on all of the provided promises and returns the fulfilled values. * * Returns an array that contains the value of each promise (in the same * order the promises were provided). An exception is thrown if any of the * promises are rejected. * * @param iterable<PromiseInterface> $promises Iterable of PromiseInterface objects to wait on. * * @return array * * @throws \Exception on error * @throws \Throwable on error in PHP >=7 / public static function unwrap($promises) { $results = []; foreach ($promises as $key => $promise) { $results[$key] = $promise->wait(); } return $results; } /* * Given an array of promises, return a promise that is fulfilled when all * the items in the array are fulfilled. * * The promise's fulfillment value is an array with fulfillment values at * respective positions to the original array. If any promise in the array * rejects, the returned promise is rejected with the rejection reason. * * @param mixed $promises Promises or values. * @param bool $recursive If true, resolves new promises that might have been added to the stack during its own resolution. * * @return PromiseInterface / public static function all($promises, $recursive = false) { $results = []; $promise = Each::of( $promises, function ($value, $idx) use (&$results) { $results[$idx] = $value; }, function ($reason, $idx, Promise $aggregate) { $aggregate->reject($reason); } )->then(function () use (&$results) { ksort($results); return $results; }); if (true === $recursive) { $promise = $promise->then(function ($results) use ($recursive, &$promises) { foreach ($promises as $promise) { if (Is::pending($promise)) { return self::all($promises, $recursive); } } return $results; }); } return $promise; } /* * Initiate a competitive race between multiple promises or values (values * will become immediately fulfilled promises). * * When count amount of promises have been fulfilled, the returned promise * is fulfilled with an array that contains the fulfillment values of the * winners in order of resolution. * * This promise is rejected with a {@see AggregateException} if the number * of fulfilled promises is less than the desired $count. * * @param int $count Total number of promises. * @param mixed $promises Promises or values. * * @return PromiseInterface / public static function some($count, $promises) { $results = []; $rejections = []; return Each::of( $promises, function ($value, $idx, PromiseInterface $p) use (&$results, $count) { if (Is::settled($p)) { return; } $results[$idx] = $value; if (count($results) >= $count) { $p->resolve(null); } }, function ($reason) use (&$rejections) { $rejections[] = $reason; } )->then( function () use (&$results, &$rejections, $count) { if (count($results) !== $count) { throw new AggregateException( 'Not enough promises to fulfill count', $rejections ); } ksort($results); return array_values($results); } ); } /* * Like some(), with 1 as count. However, if the promise fulfills, the * fulfillment value is not an array of 1 but the value directly. * * @param mixed $promises Promises or values. * * @return PromiseInterface / public static function any($promises) { return self::some(1, $promises)->then(function ($values) { return $values[0]; }); } /* * Returns a promise that is fulfilled when all of the provided promises have * been fulfilled or rejected. * * The returned promise is fulfilled with an array of inspection state arrays. * * @see inspect for the inspection state array format. * * @param mixed $promises Promises or values. * * @return PromiseInterface / public static function settle($promises) { $results = []; return Each::of( $promises, function ($value, $idx) use (&$results) { $results[$idx] = ['state' => PromiseInterface::FULFILLED, 'value' => $value]; }, function ($reason, $idx) use (&$results) { $results[$idx] = ['state' => PromiseInterface::REJECTED, 'reason' => $reason]; } )->then(function () use (&$results) { ksort($results); return $results; }); } } Promise.php��0000644��00000021360�15025046355�0006702 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * Promises/A+ implementation that avoids recursion when possible. * * @link https://promisesaplus.com/ / class Promise implements PromiseInterface { private $state = self::PENDING; private $result; private $cancelFn; private $waitFn; private $waitList; private $handlers = []; /* * @param callable $waitFn Fn that when invoked resolves the promise. * @param callable $cancelFn Fn that when invoked cancels the promise. / public function __construct( callable $waitFn = null, callable $cancelFn = null ) { $this->waitFn = $waitFn; $this->cancelFn = $cancelFn; } public function then( callable $onFulfilled = null, callable $onRejected = null ) { if ($this->state === self::PENDING) { $p = new Promise(null, [$this, 'cancel']); $this->handlers[] = [$p, $onFulfilled, $onRejected]; $p->waitList = $this->waitList; $p->waitList[] = $this; return $p; } // Return a fulfilled promise and immediately invoke any callbacks. if ($this->state === self::FULFILLED) { $promise = Create::promiseFor($this->result); return $onFulfilled ? $promise->then($onFulfilled) : $promise; } // It's either cancelled or rejected, so return a rejected promise // and immediately invoke any callbacks. $rejection = Create::rejectionFor($this->result); return $onRejected ? $rejection->then(null, $onRejected) : $rejection; } public function otherwise(callable $onRejected) { return $this->then(null, $onRejected); } public function wait($unwrap = true) { $this->waitIfPending(); if ($this->result instanceof PromiseInterface) { return $this->result->wait($unwrap); } if ($unwrap) { if ($this->state === self::FULFILLED) { return $this->result; } // It's rejected so "unwrap" and throw an exception. throw Create::exceptionFor($this->result); } } public function getState() { return $this->state; } public function cancel() { if ($this->state !== self::PENDING) { return; } $this->waitFn = $this->waitList = null; if ($this->cancelFn) { $fn = $this->cancelFn; $this->cancelFn = null; try { $fn(); } catch (\Throwable $e) { $this->reject($e); } catch (\Exception $e) { $this->reject($e); } } // Reject the promise only if it wasn't rejected in a then callback. /* @psalm-suppress RedundantCondition / if ($this->state === self::PENDING) { $this->reject(new CancellationException('Promise has been cancelled')); } } public function resolve($value) { $this->settle(self::FULFILLED, $value); } public function reject($reason) { $this->settle(self::REJECTED, $reason); } private function settle($state, $value) { if ($this->state !== self::PENDING) { // Ignore calls with the same resolution. if ($state === $this->state && $value === $this->result) { return; } throw $this->state === $state ? new \LogicException("The promise is already {$state}.") : new \LogicException("Cannot change a {$this->state} promise to {$state}"); } if ($value === $this) { throw new \LogicException('Cannot fulfill or reject a promise with itself'); } // Clear out the state of the promise but stash the handlers. $this->state = $state; $this->result = $value; $handlers = $this->handlers; $this->handlers = null; $this->waitList = $this->waitFn = null; $this->cancelFn = null; if (!$handlers) { return; } // If the value was not a settled promise or a thenable, then resolve // it in the task queue using the correct ID. if (!is_object($value) \|\| !method_exists($value, 'then')) { $id = $state === self::FULFILLED ? 1 : 2; // It's a success, so resolve the handlers in the queue. Utils::queue()->add(static function () use ($id, $value, $handlers) { foreach ($handlers as $handler) { self::callHandler($id, $value, $handler); } }); } elseif ($value instanceof Promise && Is::pending($value)) { // We can just merge our handlers onto the next promise. $value->handlers = array_merge($value->handlers, $handlers); } else { // Resolve the handlers when the forwarded promise is resolved. $value->then( static function ($value) use ($handlers) { foreach ($handlers as $handler) { self::callHandler(1, $value, $handler); } }, static function ($reason) use ($handlers) { foreach ($handlers as $handler) { self::callHandler(2, $reason, $handler); } } ); } } /* * Call a stack of handlers using a specific callback index and value. * * @param int $index 1 (resolve) or 2 (reject). * @param mixed $value Value to pass to the callback. * @param array $handler Array of handler data (promise and callbacks). / private static function callHandler($index, $value, array $handler) { /* @var PromiseInterface $promise / $promise = $handler[0]; // The promise may have been cancelled or resolved before placing // this thunk in the queue. if (Is::settled($promise)) { return; } try { if (isset($handler[$index])) { / * If $f throws an exception, then $handler will be in the exception * stack trace. Since $handler contains a reference to the callable * itself we get a circular reference. We clear the $handler * here to avoid that memory leak. / $f = $handler[$index]; unset($handler); $promise->resolve($f($value)); } elseif ($index === 1) { // Forward resolution values as-is. $promise->resolve($value); } else { // Forward rejections down the chain. $promise->reject($value); } } catch (\Throwable $reason) { $promise->reject($reason); } catch (\Exception $reason) { $promise->reject($reason); } } private function waitIfPending() { if ($this->state !== self::PENDING) { return; } elseif ($this->waitFn) { $this->invokeWaitFn(); } elseif ($this->waitList) { $this->invokeWaitList(); } else { // If there's no wait function, then reject the promise. $this->reject('Cannot wait on a promise that has ' . 'no internal wait function. You must provide a wait ' . 'function when constructing the promise to be able to ' . 'wait on a promise.'); } Utils::queue()->run(); /* @psalm-suppress RedundantCondition / if ($this->state === self::PENDING) { $this->reject('Invoking the wait callback did not resolve the promise'); } } private function invokeWaitFn() { try { $wfn = $this->waitFn; $this->waitFn = null; $wfn(true); } catch (\Exception $reason) { if ($this->state === self::PENDING) { // The promise has not been resolved yet, so reject the promise // with the exception. $this->reject($reason); } else { // The promise was already resolved, so there's a problem in // the application. throw $reason; } } } private function invokeWaitList() { $waitList = $this->waitList; $this->waitList = null; foreach ($waitList as $result) { do { $result->waitIfPending(); $result = $result->result; } while ($result instanceof Promise); if ($result instanceof PromiseInterface) { $result->wait(false); } } } } ��RejectedPromise.php��0000644��00000004354�15025046355�0010354 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * A promise that has been rejected. * * Thenning off of this promise will invoke the onRejected callback * immediately and ignore other callbacks. / class RejectedPromise implements PromiseInterface { private $reason; public function __construct($reason) { if (is_object($reason) && method_exists($reason, 'then')) { throw new \InvalidArgumentException( 'You cannot create a RejectedPromise with a promise.' ); } $this->reason = $reason; } public function then( callable $onFulfilled = null, callable $onRejected = null ) { // If there's no onRejected callback then just return self. if (!$onRejected) { return $this; } $queue = Utils::queue(); $reason = $this->reason; $p = new Promise([$queue, 'run']); $queue->add(static function () use ($p, $reason, $onRejected) { if (Is::pending($p)) { try { // Return a resolved promise if onRejected does not throw. $p->resolve($onRejected($reason)); } catch (\Throwable $e) { // onRejected threw, so return a rejected promise. $p->reject($e); } catch (\Exception $e) { // onRejected threw, so return a rejected promise. $p->reject($e); } } }); return $p; } public function otherwise(callable $onRejected) { return $this->then(null, $onRejected); } public function wait($unwrap = true, $defaultDelivery = null) { if ($unwrap) { throw Create::exceptionFor($this->reason); } return null; } public function getState() { return self::REJECTED; } public function resolve($value) { throw new \LogicException("Cannot resolve a rejected promise"); } public function reject($reason) { if ($reason !== $this->reason) { throw new \LogicException("Cannot reject a rejected promise"); } } public function cancel() { // pass } } ��PromiseInterface.php��0000644��00000005444�15025046355�0010530 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * A promise represents the eventual result of an asynchronous operation. * * The primary way of interacting with a promise is through its then method, * which registers callbacks to receive either a promise’s eventual value or * the reason why the promise cannot be fulfilled. * * @link https://promisesaplus.com/ / interface PromiseInterface { const PENDING = 'pending'; const FULFILLED = 'fulfilled'; const REJECTED = 'rejected'; /* * Appends fulfillment and rejection handlers to the promise, and returns * a new promise resolving to the return value of the called handler. * * @param callable $onFulfilled Invoked when the promise fulfills. * @param callable $onRejected Invoked when the promise is rejected. * * @return PromiseInterface / public function then( callable $onFulfilled = null, callable $onRejected = null ); /* * Appends a rejection handler callback to the promise, and returns a new * promise resolving to the return value of the callback if it is called, * or to its original fulfillment value if the promise is instead * fulfilled. * * @param callable $onRejected Invoked when the promise is rejected. * * @return PromiseInterface / public function otherwise(callable $onRejected); /* * Get the state of the promise ("pending", "rejected", or "fulfilled"). * * The three states can be checked against the constants defined on * PromiseInterface: PENDING, FULFILLED, and REJECTED. * * @return string / public function getState(); /* * Resolve the promise with the given value. * * @param mixed $value * * @throws \RuntimeException if the promise is already resolved. / public function resolve($value); /* * Reject the promise with the given reason. * * @param mixed $reason * * @throws \RuntimeException if the promise is already resolved. / public function reject($reason); /* * Cancels the promise if possible. * * @link https://github.com/promises-aplus/cancellation-spec/issues/7 / public function cancel(); /* * Waits until the promise completes if possible. * * Pass $unwrap as true to unwrap the result of the promise, either * returning the resolved value or throwing the rejected exception. * * If the promise cannot be waited on, then the promise will be rejected. * * @param bool $unwrap * * @return mixed * * @throws \LogicException if the promise has no wait function or if the * promise does not settle after waiting. / public function wait($unwrap = true); } ��FulfilledPromise.php��0000644��00000003707�15025046355�0010536 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * A promise that has been fulfilled. * * Thenning off of this promise will invoke the onFulfilled callback * immediately and ignore other callbacks. / class FulfilledPromise implements PromiseInterface { private $value; public function __construct($value) { if (is_object($value) && method_exists($value, 'then')) { throw new \InvalidArgumentException( 'You cannot create a FulfilledPromise with a promise.' ); } $this->value = $value; } public function then( callable $onFulfilled = null, callable $onRejected = null ) { // Return itself if there is no onFulfilled function. if (!$onFulfilled) { return $this; } $queue = Utils::queue(); $p = new Promise([$queue, 'run']); $value = $this->value; $queue->add(static function () use ($p, $value, $onFulfilled) { if (Is::pending($p)) { try { $p->resolve($onFulfilled($value)); } catch (\Throwable $e) { $p->reject($e); } catch (\Exception $e) { $p->reject($e); } } }); return $p; } public function otherwise(callable $onRejected) { return $this->then(null, $onRejected); } public function wait($unwrap = true, $defaultDelivery = null) { return $unwrap ? $this->value : null; } public function getState() { return self::FULFILLED; } public function resolve($value) { if ($value !== $this->value) { throw new \LogicException("Cannot resolve a fulfilled promise"); } } public function reject($reason) { throw new \LogicException("Cannot reject a fulfilled promise"); } public function cancel() { // pass } } ��Is.php��0000644��00000001747�15025046355�0005646 0��ustar�00��<?php namespace GuzzleHttp\Promise; final class Is { /* * Returns true if a promise is pending. * * @return bool / public static function pending(PromiseInterface $promise) { return $promise->getState() === PromiseInterface::PENDING; } /* * Returns true if a promise is fulfilled or rejected. * * @return bool / public static function settled(PromiseInterface $promise) { return $promise->getState() !== PromiseInterface::PENDING; } /* * Returns true if a promise is fulfilled. * * @return bool / public static function fulfilled(PromiseInterface $promise) { return $promise->getState() === PromiseInterface::FULFILLED; } /* * Returns true if a promise is rejected. * * @return bool / public static function rejected(PromiseInterface $promise) { return $promise->getState() === PromiseInterface::REJECTED; } } ��RejectionException.php��0000644��00000002302�15025046355�0011060 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * A special exception that is thrown when waiting on a rejected promise. * * The reason value is available via the getReason() method. / class RejectionException extends \RuntimeException { /* @var mixed Rejection reason. / private $reason; /* * @param mixed $reason Rejection reason. * @param string $description Optional description / public function __construct($reason, $description = null) { $this->reason = $reason; $message = 'The promise was rejected'; if ($description) { $message .= ' with reason: ' . $description; } elseif (is_string($reason) \|\| (is_object($reason) && method_exists($reason, '__toString')) ) { $message .= ' with reason: ' . $this->reason; } elseif ($reason instanceof \JsonSerializable) { $message .= ' with reason: ' . json_encode($this->reason, JSON_PRETTY_PRINT); } parent::__construct($message); } /* * Returns the rejection reason. * * @return mixed / public function getReason() { return $this->reason; } } ��Coroutine.php��0000644��00000010372�15025046355�0007234 0��ustar�00��<?php namespace GuzzleHttp\Promise; use Exception; use Generator; use Throwable; /* * Creates a promise that is resolved using a generator that yields values or * promises (somewhat similar to C#'s async keyword). * * When called, the Coroutine::of method will start an instance of the generator * and returns a promise that is fulfilled with its final yielded value. * * Control is returned back to the generator when the yielded promise settles. * This can lead to less verbose code when doing lots of sequential async calls * with minimal processing in between. * * use GuzzleHttp\Promise; * * function createPromise($value) { * return new Promise\FulfilledPromise($value); * } * * $promise = Promise\Coroutine::of(function () { * $value = (yield createPromise('a')); * try { * $value = (yield createPromise($value . 'b')); * } catch (\Exception $e) { * // The promise was rejected. * } * yield $value . 'c'; * }); * * // Outputs "abc" * $promise->then(function ($v) { echo $v; }); * * @param callable $generatorFn Generator function to wrap into a promise. * * @return Promise * * @link https://github.com/petkaantonov/bluebird/blob/master/API.md#generators inspiration / final class Coroutine implements PromiseInterface { /* * @var PromiseInterface\|null / private $currentPromise; /* * @var Generator / private $generator; /* * @var Promise / private $result; public function __construct(callable $generatorFn) { $this->generator = $generatorFn(); $this->result = new Promise(function () { while (isset($this->currentPromise)) { $this->currentPromise->wait(); } }); try { $this->nextCoroutine($this->generator->current()); } catch (\Exception $exception) { $this->result->reject($exception); } catch (Throwable $throwable) { $this->result->reject($throwable); } } /* * Create a new coroutine. * * @return self / public static function of(callable $generatorFn) { return new self($generatorFn); } public function then( callable $onFulfilled = null, callable $onRejected = null ) { return $this->result->then($onFulfilled, $onRejected); } public function otherwise(callable $onRejected) { return $this->result->otherwise($onRejected); } public function wait($unwrap = true) { return $this->result->wait($unwrap); } public function getState() { return $this->result->getState(); } public function resolve($value) { $this->result->resolve($value); } public function reject($reason) { $this->result->reject($reason); } public function cancel() { $this->currentPromise->cancel(); $this->result->cancel(); } private function nextCoroutine($yielded) { $this->currentPromise = Create::promiseFor($yielded) ->then([$this, '_handleSuccess'], [$this, '_handleFailure']); } /* * @internal / public function _handleSuccess($value) { unset($this->currentPromise); try { $next = $this->generator->send($value); if ($this->generator->valid()) { $this->nextCoroutine($next); } else { $this->result->resolve($value); } } catch (Exception $exception) { $this->result->reject($exception); } catch (Throwable $throwable) { $this->result->reject($throwable); } } /* * @internal / public function _handleFailure($reason) { unset($this->currentPromise); try { $nextYield = $this->generator->throw(Create::exceptionFor($reason)); // The throw was caught, so keep iterating on the coroutine $this->nextCoroutine($nextYield); } catch (Exception $exception) { $this->result->reject($exception); } catch (Throwable $throwable) { $this->result->reject($throwable); } } } ��TaskQueueInterface.php��0000644��00000000661�15025046355�0011015 0��ustar�00��<?php namespace GuzzleHttp\Promise; interface TaskQueueInterface { /* * Returns true if the queue is empty. * * @return bool / public function isEmpty(); /* * Adds a task to the queue that will be executed the next time run is * called. / public function add(callable $task); /* * Execute all of the pending task in the queue. / public function run(); } ��functions.php��0000644��00000023620�15025046355�0007275 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * Get the global task queue used for promise resolution. * * This task queue MUST be run in an event loop in order for promises to be * settled asynchronously. It will be automatically run when synchronously * waiting on a promise. * * <code> * while ($eventLoop->isRunning()) { * GuzzleHttp\Promise\queue()->run(); * } * </code> * * @param TaskQueueInterface $assign Optionally specify a new queue instance. * * @return TaskQueueInterface * * @deprecated queue will be removed in guzzlehttp/promises:2.0. Use Utils::queue instead. / function queue(TaskQueueInterface $assign = null) { return Utils::queue($assign); } /* * Adds a function to run in the task queue when it is next `run()` and returns * a promise that is fulfilled or rejected with the result. * * @param callable $task Task function to run. * * @return PromiseInterface * * @deprecated task will be removed in guzzlehttp/promises:2.0. Use Utils::task instead. / function task(callable $task) { return Utils::task($task); } /* * Creates a promise for a value if the value is not a promise. * * @param mixed $value Promise or value. * * @return PromiseInterface * * @deprecated promise_for will be removed in guzzlehttp/promises:2.0. Use Create::promiseFor instead. / function promise_for($value) { return Create::promiseFor($value); } /* * Creates a rejected promise for a reason if the reason is not a promise. If * the provided reason is a promise, then it is returned as-is. * * @param mixed $reason Promise or reason. * * @return PromiseInterface * * @deprecated rejection_for will be removed in guzzlehttp/promises:2.0. Use Create::rejectionFor instead. / function rejection_for($reason) { return Create::rejectionFor($reason); } /* * Create an exception for a rejected promise value. * * @param mixed $reason * * @return \Exception\|\Throwable * * @deprecated exception_for will be removed in guzzlehttp/promises:2.0. Use Create::exceptionFor instead. / function exception_for($reason) { return Create::exceptionFor($reason); } /* * Returns an iterator for the given value. * * @param mixed $value * * @return \Iterator * * @deprecated iter_for will be removed in guzzlehttp/promises:2.0. Use Create::iterFor instead. / function iter_for($value) { return Create::iterFor($value); } /* * Synchronously waits on a promise to resolve and returns an inspection state * array. * * Returns a state associative array containing a "state" key mapping to a * valid promise state. If the state of the promise is "fulfilled", the array * will contain a "value" key mapping to the fulfilled value of the promise. If * the promise is rejected, the array will contain a "reason" key mapping to * the rejection reason of the promise. * * @param PromiseInterface $promise Promise or value. * * @return array * * @deprecated inspect will be removed in guzzlehttp/promises:2.0. Use Utils::inspect instead. / function inspect(PromiseInterface $promise) { return Utils::inspect($promise); } /* * Waits on all of the provided promises, but does not unwrap rejected promises * as thrown exception. * * Returns an array of inspection state arrays. * * @see inspect for the inspection state array format. * * @param PromiseInterface[] $promises Traversable of promises to wait upon. * * @return array * * @deprecated inspect will be removed in guzzlehttp/promises:2.0. Use Utils::inspectAll instead. / function inspect_all($promises) { return Utils::inspectAll($promises); } /* * Waits on all of the provided promises and returns the fulfilled values. * * Returns an array that contains the value of each promise (in the same order * the promises were provided). An exception is thrown if any of the promises * are rejected. * * @param iterable<PromiseInterface> $promises Iterable of PromiseInterface objects to wait on. * * @return array * * @throws \Exception on error * @throws \Throwable on error in PHP >=7 * * @deprecated unwrap will be removed in guzzlehttp/promises:2.0. Use Utils::unwrap instead. / function unwrap($promises) { return Utils::unwrap($promises); } /* * Given an array of promises, return a promise that is fulfilled when all the * items in the array are fulfilled. * * The promise's fulfillment value is an array with fulfillment values at * respective positions to the original array. If any promise in the array * rejects, the returned promise is rejected with the rejection reason. * * @param mixed $promises Promises or values. * @param bool $recursive If true, resolves new promises that might have been added to the stack during its own resolution. * * @return PromiseInterface * * @deprecated all will be removed in guzzlehttp/promises:2.0. Use Utils::all instead. / function all($promises, $recursive = false) { return Utils::all($promises, $recursive); } /* * Initiate a competitive race between multiple promises or values (values will * become immediately fulfilled promises). * * When count amount of promises have been fulfilled, the returned promise is * fulfilled with an array that contains the fulfillment values of the winners * in order of resolution. * * This promise is rejected with a {@see AggregateException} if the number of * fulfilled promises is less than the desired $count. * * @param int $count Total number of promises. * @param mixed $promises Promises or values. * * @return PromiseInterface * * @deprecated some will be removed in guzzlehttp/promises:2.0. Use Utils::some instead. / function some($count, $promises) { return Utils::some($count, $promises); } /* * Like some(), with 1 as count. However, if the promise fulfills, the * fulfillment value is not an array of 1 but the value directly. * * @param mixed $promises Promises or values. * * @return PromiseInterface * * @deprecated any will be removed in guzzlehttp/promises:2.0. Use Utils::any instead. / function any($promises) { return Utils::any($promises); } /* * Returns a promise that is fulfilled when all of the provided promises have * been fulfilled or rejected. * * The returned promise is fulfilled with an array of inspection state arrays. * * @see inspect for the inspection state array format. * * @param mixed $promises Promises or values. * * @return PromiseInterface * * @deprecated settle will be removed in guzzlehttp/promises:2.0. Use Utils::settle instead. / function settle($promises) { return Utils::settle($promises); } /* * Given an iterator that yields promises or values, returns a promise that is * fulfilled with a null value when the iterator has been consumed or the * aggregate promise has been fulfilled or rejected. * * $onFulfilled is a function that accepts the fulfilled value, iterator index, * and the aggregate promise. The callback can invoke any necessary side * effects and choose to resolve or reject the aggregate if needed. * * $onRejected is a function that accepts the rejection reason, iterator index, * and the aggregate promise. The callback can invoke any necessary side * effects and choose to resolve or reject the aggregate if needed. * * @param mixed $iterable Iterator or array to iterate over. * @param callable $onFulfilled * @param callable $onRejected * * @return PromiseInterface * * @deprecated each will be removed in guzzlehttp/promises:2.0. Use Each::of instead. / function each( $iterable, callable $onFulfilled = null, callable $onRejected = null ) { return Each::of($iterable, $onFulfilled, $onRejected); } /* * Like each, but only allows a certain number of outstanding promises at any * given time. * * $concurrency may be an integer or a function that accepts the number of * pending promises and returns a numeric concurrency limit value to allow for * dynamic a concurrency size. * * @param mixed $iterable * @param int\|callable $concurrency * @param callable $onFulfilled * @param callable $onRejected * * @return PromiseInterface * * @deprecated each_limit will be removed in guzzlehttp/promises:2.0. Use Each::ofLimit instead. / function each_limit( $iterable, $concurrency, callable $onFulfilled = null, callable $onRejected = null ) { return Each::ofLimit($iterable, $concurrency, $onFulfilled, $onRejected); } /* * Like each_limit, but ensures that no promise in the given $iterable argument * is rejected. If any promise is rejected, then the aggregate promise is * rejected with the encountered rejection. * * @param mixed $iterable * @param int\|callable $concurrency * @param callable $onFulfilled * * @return PromiseInterface * * @deprecated each_limit_all will be removed in guzzlehttp/promises:2.0. Use Each::ofLimitAll instead. / function each_limit_all( $iterable, $concurrency, callable $onFulfilled = null ) { return Each::ofLimitAll($iterable, $concurrency, $onFulfilled); } /* * Returns true if a promise is fulfilled. * * @return bool * * @deprecated is_fulfilled will be removed in guzzlehttp/promises:2.0. Use Is::fulfilled instead. / function is_fulfilled(PromiseInterface $promise) { return Is::fulfilled($promise); } /* * Returns true if a promise is rejected. * * @return bool * * @deprecated is_rejected will be removed in guzzlehttp/promises:2.0. Use Is::rejected instead. / function is_rejected(PromiseInterface $promise) { return Is::rejected($promise); } /* * Returns true if a promise is fulfilled or rejected. * * @return bool * * @deprecated is_settled will be removed in guzzlehttp/promises:2.0. Use Is::settled instead. / function is_settled(PromiseInterface $promise) { return Is::settled($promise); } /* * Create a new coroutine. * * @see Coroutine * * @return PromiseInterface * * @deprecated coroutine will be removed in guzzlehttp/promises:2.0. Use Coroutine::of instead. / function coroutine(callable $generatorFn) { return Coroutine::of($generatorFn); } ��CancellationException.php��0000644��00000000267�15025046355�0011542 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * Exception that is set as the reason for a promise that has been cancelled. / class CancellationException extends RejectionException { } ��functions_include.php��0000644��00000000247�15025046355�0011000 0��ustar�00��<?php // Don't redefine the functions if included multiple times. if (!function_exists('GuzzleHttp\Promise\promise_for')) { require __DIR__ . '/functions.php'; } ��TaskQueue.php��0000644��00000003624�15025046355�0007176 0��ustar�00��<?php namespace GuzzleHttp\Promise; /* * A task queue that executes tasks in a FIFO order. * * This task queue class is used to settle promises asynchronously and * maintains a constant stack size. You can use the task queue asynchronously * by calling the `run()` function of the global task queue in an event loop. * * GuzzleHttp\Promise\Utils::queue()->run(); / class TaskQueue implements TaskQueueInterface { private $enableShutdown = true; private $queue = []; public function __construct($withShutdown = true) { if ($withShutdown) { register_shutdown_function(function () { if ($this->enableShutdown) { // Only run the tasks if an E_ERROR didn't occur. $err = error_get_last(); if (!$err \|\| ($err['type'] ^ E_ERROR)) { $this->run(); } } }); } } public function isEmpty() { return !$this->queue; } public function add(callable $task) { $this->queue[] = $task; } public function run() { while ($task = array_shift($this->queue)) { /* @var callable $task / $task(); } } /* * The task queue will be run and exhausted by default when the process * exits IFF the exit is not the result of a PHP E_ERROR error. * * You can disable running the automatic shutdown of the queue by calling * this function. If you disable the task queue shutdown process, then you * MUST either run the task queue (as a result of running your event loop * or manually using the run() method) or wait on each outstanding promise. * * Note: This shutdown will occur before any destructors are triggered. */ public function disableShutdown() { $this->enableShutdown = false; } } ��

| ver. 1.4 | . | PHP 7.3.33 | Generation time: 0.06 | proxy | phpinfo | Settings