diff --git a/system/.htaccess b/system/.htaccess
new file mode 100644
index 0000000..44c2236
--- /dev/null
+++ b/system/.htaccess
@@ -0,0 +1,24 @@
+
');
+ } else {
+ $ui->assign("error_message", $e->getMessage() . '
' . $e->getTraceAsString() . ''); + } + $ui->display('router-error.tpl'); + die(); +} catch (Exception $e) { + $ui = new Smarty(); + $ui->setTemplateDir([ + 'custom' => File::pathFixer($UI_PATH . '/ui_custom/'), + 'default' => File::pathFixer($UI_PATH . '/ui/') + ]); + $ui->assign('_url', APP_URL . '/index.php?_route='); + $ui->setCompileDir(File::pathFixer($UI_PATH . '/compiled/')); + $ui->setConfigDir(File::pathFixer($UI_PATH . '/conf/')); + $ui->setCacheDir(File::pathFixer($UI_PATH . '/cache/')); + $ui->assign("error_title", "PHPNuxBill Crash"); + if (_auth()) { + $ui->assign("error_message", $e->getMessage() . '
' . $e->getTraceAsString() . ''); + } + $ui->display('router-error.tpl'); + die(); +} + +function _notify($msg, $type = 'e') +{ + $_SESSION['ntype'] = $type; + $_SESSION['notify'] = $msg; +} + +$ui = new Smarty(); +$ui->assign('_kolaps', $_COOKIE['kolaps']); +if (!empty($config['theme']) && $config['theme'] != 'default') { + $_theme = APP_URL . '/' . $UI_PATH . '/themes/' . $config['theme']; + $ui->setTemplateDir([ + 'custom' => File::pathFixer($UI_PATH . '/ui_custom/'), + 'theme' => File::pathFixer($UI_PATH . '/themes/' . $config['theme']), + 'default' => File::pathFixer($UI_PATH . '/ui/') + ]); +} else { + $_theme = APP_URL . '/' . $UI_PATH . '/ui'; + $ui->setTemplateDir([ + 'custom' => File::pathFixer($UI_PATH . '/ui_custom/'), + 'default' => File::pathFixer($UI_PATH . '/ui/') + ]); +} +$ui->assign('_theme', $_theme); +$ui->addTemplateDir($PAYMENTGATEWAY_PATH . File::pathFixer('/ui/'), 'pg'); +$ui->addTemplateDir($PLUGIN_PATH . File::pathFixer('/ui/'), 'plugin'); +$ui->setCompileDir(File::pathFixer($UI_PATH . '/compiled/')); +$ui->setConfigDir(File::pathFixer($UI_PATH . '/conf/')); +$ui->setCacheDir(File::pathFixer($UI_PATH . '/cache/')); +$ui->assign('app_url', APP_URL); +$ui->assign('_domain', str_replace('www.', '', parse_url(APP_URL, PHP_URL_HOST))); +$ui->assign('_url', APP_URL . '/index.php?_route='); +$ui->assign('_path', __DIR__); +$ui->assign('_c', $config); +$ui->assign('UPLOAD_PATH', str_replace($root_path, '', $UPLOAD_PATH)); +$ui->assign('CACHE_PATH', str_replace($root_path, '', $CACHE_PATH)); +$ui->assign('PAGES_PATH', str_replace($root_path, '', $PAGES_PATH)); +$ui->assign('_system_menu', 'dashboard'); + +function _msglog($type, $msg) +{ + $_SESSION['ntype'] = $type; + $_SESSION['notify'] = $msg; +} + +if (isset($_SESSION['notify'])) { + $notify = $_SESSION['notify']; + $ntype = $_SESSION['ntype']; + $ui->assign('notify', $notify); + $ui->assign('notify_t', $ntype); + unset($_SESSION['notify']); + unset($_SESSION['ntype']); +} + +// Routing Engine +$req = _get('_route'); +global $routes; +$routes = explode('/', $req); +$ui->assign('_routes', $routes); +$handler = $routes[0]; +if ($handler == '') { + $handler = 'default'; +} +$admin = Admin::_info(); +try { + $sys_render = $root_path . File::pathFixer('system/controllers/' . $handler . '.php'); + if (file_exists($sys_render)) { + $menus = array(); + // "name" => $name, + // "admin" => $admin, + // "position" => $position, + // "function" => $function + $ui->assign('_system_menu', $routes[0]); + foreach ($menu_registered as $menu) { + if ($menu['admin'] && _admin(false)) { + if (count($menu['auth']) == 0 || in_array($admin['user_type'], $menu['auth'])) { + $menus[$menu['position']] .= '
' . $e->getTraceAsString() . ''); + $ui->assign("error_title", "PHPNuxBill Crash"); + $ui->display('router-error.tpl'); + die(); +} catch (Exception $e) { + if (!Admin::getID()) { + r2(U . 'home', 'e', $e->getMessage()); + } + $ui->assign("error_message", $e->getMessage() . '
' . $e->getTraceAsString() . ''); + $ui->assign("error_title", "PHPNuxBill Crash"); + $ui->display('router-error.tpl'); + die(); +} diff --git a/system/composer.json b/system/composer.json new file mode 100644 index 0000000..9bded24 --- /dev/null +++ b/system/composer.json @@ -0,0 +1,6 @@ +{ + "require": { + "mpdf/mpdf": "^8.1", + "smarty/smarty": "^4.3" + } +} diff --git a/system/composer.lock b/system/composer.lock new file mode 100644 index 0000000..40d0cae --- /dev/null +++ b/system/composer.lock @@ -0,0 +1,490 @@ +{ + "_readme": [ + "This file locks the dependencies of your project to a known state", + "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies", + "This file is @generated automatically" + ], + "content-hash": "81c1d3c4b2673fdd2922ac32768d59f1", + "packages": [ + { + "name": "mpdf/mpdf", + "version": "v8.1.6", + "source": { + "type": "git", + "url": "https://github.com/mpdf/mpdf.git", + "reference": "146c7c1dfd21c826b9d5bbfe3c15e52fd933c90f" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/mpdf/mpdf/zipball/146c7c1dfd21c826b9d5bbfe3c15e52fd933c90f", + "reference": "146c7c1dfd21c826b9d5bbfe3c15e52fd933c90f", + "shasum": "" + }, + "require": { + "ext-gd": "*", + "ext-mbstring": "*", + "mpdf/psr-log-aware-trait": "^2.0 || ^3.0", + "myclabs/deep-copy": "^1.7", + "paragonie/random_compat": "^1.4|^2.0|^9.99.99", + "php": "^5.6 || ^7.0 || ~8.0.0 || ~8.1.0 || ~8.2.0", + "psr/http-message": "^1.0", + "psr/log": "^1.0 || ^2.0 || ^3.0", + "setasign/fpdi": "^2.1" + }, + "require-dev": { + "mockery/mockery": "^1.3.0", + "mpdf/qrcode": "^1.1.0", + "squizlabs/php_codesniffer": "^3.5.0", + "tracy/tracy": "~2.5", + "yoast/phpunit-polyfills": "^1.0" + }, + "suggest": { + "ext-bcmath": "Needed for generation of some types of barcodes", + "ext-xml": "Needed mainly for SVG manipulation", + "ext-zlib": "Needed for compression of embedded resources, such as fonts" + }, + "type": "library", + "autoload": { + "psr-4": { + "Mpdf\\": "src/" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "GPL-2.0-only" + ], + "authors": [ + { + "name": "Matěj Humpál", + "role": "Developer, maintainer" + }, + { + "name": "Ian Back", + "role": "Developer (retired)" + } + ], + "description": "PHP library generating PDF files from UTF-8 encoded HTML", + "homepage": "https://mpdf.github.io", + "keywords": [ + "pdf", + "php", + "utf-8" + ], + "support": { + "docs": "http://mpdf.github.io", + "issues": "https://github.com/mpdf/mpdf/issues", + "source": "https://github.com/mpdf/mpdf" + }, + "funding": [ + { + "url": "https://www.paypal.me/mpdf", + "type": "custom" + } + ], + "time": "2023-05-03T19:36:43+00:00" + }, + { + "name": "mpdf/psr-log-aware-trait", + "version": "v2.0.0", + "source": { + "type": "git", + "url": "https://github.com/mpdf/psr-log-aware-trait.git", + "reference": "7a077416e8f39eb626dee4246e0af99dd9ace275" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/mpdf/psr-log-aware-trait/zipball/7a077416e8f39eb626dee4246e0af99dd9ace275", + "reference": "7a077416e8f39eb626dee4246e0af99dd9ace275", + "shasum": "" + }, + "require": { + "psr/log": "^1.0 || ^2.0" + }, + "type": "library", + "autoload": { + "psr-4": { + "Mpdf\\PsrLogAwareTrait\\": "src/" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "authors": [ + { + "name": "Mark Dorison", + "email": "mark@chromatichq.com" + }, + { + "name": "Kristofer Widholm", + "email": "kristofer@chromatichq.com" + } + ], + "description": "Trait to allow support of different psr/log versions.", + "support": { + "issues": "https://github.com/mpdf/psr-log-aware-trait/issues", + "source": "https://github.com/mpdf/psr-log-aware-trait/tree/v2.0.0" + }, + "time": "2023-05-03T06:18:28+00:00" + }, + { + "name": "myclabs/deep-copy", + "version": "1.11.1", + "source": { + "type": "git", + "url": "https://github.com/myclabs/DeepCopy.git", + "reference": "7284c22080590fb39f2ffa3e9057f10a4ddd0e0c" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/myclabs/DeepCopy/zipball/7284c22080590fb39f2ffa3e9057f10a4ddd0e0c", + "reference": "7284c22080590fb39f2ffa3e9057f10a4ddd0e0c", + "shasum": "" + }, + "require": { + "php": "^7.1 || ^8.0" + }, + "conflict": { + "doctrine/collections": "<1.6.8", + "doctrine/common": "<2.13.3 || >=3,<3.2.2" + }, + "require-dev": { + "doctrine/collections": "^1.6.8", + "doctrine/common": "^2.13.3 || ^3.2.2", + "phpunit/phpunit": "^7.5.20 || ^8.5.23 || ^9.5.13" + }, + "type": "library", + "autoload": { + "files": [ + "src/DeepCopy/deep_copy.php" + ], + "psr-4": { + "DeepCopy\\": "src/DeepCopy/" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "description": "Create deep copies (clones) of your objects", + "keywords": [ + "clone", + "copy", + "duplicate", + "object", + "object graph" + ], + "support": { + "issues": "https://github.com/myclabs/DeepCopy/issues", + "source": "https://github.com/myclabs/DeepCopy/tree/1.11.1" + }, + "funding": [ + { + "url": "https://tidelift.com/funding/github/packagist/myclabs/deep-copy", + "type": "tidelift" + } + ], + "time": "2023-03-08T13:26:56+00:00" + }, + { + "name": "paragonie/random_compat", + "version": "v9.99.100", + "source": { + "type": "git", + "url": "https://github.com/paragonie/random_compat.git", + "reference": "996434e5492cb4c3edcb9168db6fbb1359ef965a" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/paragonie/random_compat/zipball/996434e5492cb4c3edcb9168db6fbb1359ef965a", + "reference": "996434e5492cb4c3edcb9168db6fbb1359ef965a", + "shasum": "" + }, + "require": { + "php": ">= 7" + }, + "require-dev": { + "phpunit/phpunit": "4.*|5.*", + "vimeo/psalm": "^1" + }, + "suggest": { + "ext-libsodium": "Provides a modern crypto API that can be used to generate random bytes." + }, + "type": "library", + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "authors": [ + { + "name": "Paragon Initiative Enterprises", + "email": "security@paragonie.com", + "homepage": "https://paragonie.com" + } + ], + "description": "PHP 5.x polyfill for random_bytes() and random_int() from PHP 7", + "keywords": [ + "csprng", + "polyfill", + "pseudorandom", + "random" + ], + "support": { + "email": "info@paragonie.com", + "issues": "https://github.com/paragonie/random_compat/issues", + "source": "https://github.com/paragonie/random_compat" + }, + "time": "2020-10-15T08:29:30+00:00" + }, + { + "name": "psr/http-message", + "version": "1.1", + "source": { + "type": "git", + "url": "https://github.com/php-fig/http-message.git", + "reference": "cb6ce4845ce34a8ad9e68117c10ee90a29919eba" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/php-fig/http-message/zipball/cb6ce4845ce34a8ad9e68117c10ee90a29919eba", + "reference": "cb6ce4845ce34a8ad9e68117c10ee90a29919eba", + "shasum": "" + }, + "require": { + "php": "^7.2 || ^8.0" + }, + "type": "library", + "extra": { + "branch-alias": { + "dev-master": "1.1.x-dev" + } + }, + "autoload": { + "psr-4": { + "Psr\\Http\\Message\\": "src/" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "authors": [ + { + "name": "PHP-FIG", + "homepage": "http://www.php-fig.org/" + } + ], + "description": "Common interface for HTTP messages", + "homepage": "https://github.com/php-fig/http-message", + "keywords": [ + "http", + "http-message", + "psr", + "psr-7", + "request", + "response" + ], + "support": { + "source": "https://github.com/php-fig/http-message/tree/1.1" + }, + "time": "2023-04-04T09:50:52+00:00" + }, + { + "name": "psr/log", + "version": "1.1.4", + "source": { + "type": "git", + "url": "https://github.com/php-fig/log.git", + "reference": "d49695b909c3b7628b6289db5479a1c204601f11" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/php-fig/log/zipball/d49695b909c3b7628b6289db5479a1c204601f11", + "reference": "d49695b909c3b7628b6289db5479a1c204601f11", + "shasum": "" + }, + "require": { + "php": ">=5.3.0" + }, + "type": "library", + "extra": { + "branch-alias": { + "dev-master": "1.1.x-dev" + } + }, + "autoload": { + "psr-4": { + "Psr\\Log\\": "Psr/Log/" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "authors": [ + { + "name": "PHP-FIG", + "homepage": "https://www.php-fig.org/" + } + ], + "description": "Common interface for logging libraries", + "homepage": "https://github.com/php-fig/log", + "keywords": [ + "log", + "psr", + "psr-3" + ], + "support": { + "source": "https://github.com/php-fig/log/tree/1.1.4" + }, + "time": "2021-05-03T11:20:27+00:00" + }, + { + "name": "setasign/fpdi", + "version": "v2.3.7", + "source": { + "type": "git", + "url": "https://github.com/Setasign/FPDI.git", + "reference": "bccc892d5fa1f48c43f8ba7db5ed4ba6f30c8c05" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/Setasign/FPDI/zipball/bccc892d5fa1f48c43f8ba7db5ed4ba6f30c8c05", + "reference": "bccc892d5fa1f48c43f8ba7db5ed4ba6f30c8c05", + "shasum": "" + }, + "require": { + "ext-zlib": "*", + "php": "^5.6 || ^7.0 || ^8.0" + }, + "conflict": { + "setasign/tfpdf": "<1.31" + }, + "require-dev": { + "phpunit/phpunit": "~5.7", + "setasign/fpdf": "~1.8", + "setasign/tfpdf": "1.31", + "squizlabs/php_codesniffer": "^3.5", + "tecnickcom/tcpdf": "~6.2" + }, + "suggest": { + "setasign/fpdf": "FPDI will extend this class but as it is also possible to use TCPDF or tFPDF as an alternative. There's no fixed dependency configured." + }, + "type": "library", + "autoload": { + "psr-4": { + "setasign\\Fpdi\\": "src/" + } + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "MIT" + ], + "authors": [ + { + "name": "Jan Slabon", + "email": "jan.slabon@setasign.com", + "homepage": "https://www.setasign.com" + }, + { + "name": "Maximilian Kresse", + "email": "maximilian.kresse@setasign.com", + "homepage": "https://www.setasign.com" + } + ], + "description": "FPDI is a collection of PHP classes facilitating developers to read pages from existing PDF documents and use them as templates in FPDF. Because it is also possible to use FPDI with TCPDF, there are no fixed dependencies defined. Please see suggestions for packages which evaluates the dependencies automatically.", + "homepage": "https://www.setasign.com/fpdi", + "keywords": [ + "fpdf", + "fpdi", + "pdf" + ], + "support": { + "issues": "https://github.com/Setasign/FPDI/issues", + "source": "https://github.com/Setasign/FPDI/tree/v2.3.7" + }, + "funding": [ + { + "url": "https://tidelift.com/funding/github/packagist/setasign/fpdi", + "type": "tidelift" + } + ], + "time": "2023-02-09T10:38:43+00:00" + }, + { + "name": "smarty/smarty", + "version": "v4.3.1", + "source": { + "type": "git", + "url": "https://github.com/smarty-php/smarty.git", + "reference": "e28cb0915b4e3749bf57d4ebae2984e25395cfe5" + }, + "dist": { + "type": "zip", + "url": "https://api.github.com/repos/smarty-php/smarty/zipball/e28cb0915b4e3749bf57d4ebae2984e25395cfe5", + "reference": "e28cb0915b4e3749bf57d4ebae2984e25395cfe5", + "shasum": "" + }, + "require": { + "php": "^7.1 || ^8.0" + }, + "require-dev": { + "phpunit/phpunit": "^8.5 || ^7.5", + "smarty/smarty-lexer": "^3.1" + }, + "type": "library", + "extra": { + "branch-alias": { + "dev-master": "4.0.x-dev" + } + }, + "autoload": { + "classmap": [ + "libs/" + ] + }, + "notification-url": "https://packagist.org/downloads/", + "license": [ + "LGPL-3.0" + ], + "authors": [ + { + "name": "Monte Ohrt", + "email": "monte@ohrt.com" + }, + { + "name": "Uwe Tews", + "email": "uwe.tews@googlemail.com" + }, + { + "name": "Rodney Rehm", + "email": "rodney.rehm@medialize.de" + }, + { + "name": "Simon Wisselink", + "homepage": "https://www.iwink.nl/" + } + ], + "description": "Smarty - the compiling PHP template engine", + "homepage": "https://smarty-php.github.io/smarty/", + "keywords": [ + "templating" + ], + "support": { + "forum": "https://github.com/smarty-php/smarty/discussions", + "issues": "https://github.com/smarty-php/smarty/issues", + "source": "https://github.com/smarty-php/smarty/tree/v4.3.1" + }, + "time": "2023-03-28T19:47:03+00:00" + } + ], + "packages-dev": [], + "aliases": [], + "minimum-stability": "stable", + "stability-flags": [], + "prefer-stable": false, + "prefer-lowest": false, + "platform": [], + "platform-dev": [], + "plugin-api-version": "2.3.0" +} diff --git a/system/create_cron_logs_table.sql b/system/create_cron_logs_table.sql new file mode 100644 index 0000000..7cb9f0e --- /dev/null +++ b/system/create_cron_logs_table.sql @@ -0,0 +1,21 @@ +-- Create cron logs table for tracking cron job execution +CREATE TABLE IF NOT EXISTS `tbl_cron_logs` ( + `id` int(11) NOT NULL AUTO_INCREMENT, + `cron_type` varchar(50) NOT NULL DEFAULT 'main' COMMENT 'Type of cron job (main, reminder, etc.)', + `started_at` datetime NOT NULL COMMENT 'When cron job started', + `finished_at` datetime DEFAULT NULL COMMENT 'When cron job finished', + `status` enum('running','completed','failed') NOT NULL DEFAULT 'running' COMMENT 'Cron job status', + `expired_users_found` int(11) NOT NULL DEFAULT 0 COMMENT 'Number of expired users found', + `expired_users_processed` int(11) NOT NULL DEFAULT 0 COMMENT 'Number of expired users processed', + `notifications_sent` int(11) NOT NULL DEFAULT 0 COMMENT 'Number of notifications sent', + `auto_renewals_attempted` int(11) NOT NULL DEFAULT 0 COMMENT 'Number of auto-renewals attempted', + `auto_renewals_successful` int(11) NOT NULL DEFAULT 0 COMMENT 'Number of successful auto-renewals', + `error_message` text DEFAULT NULL COMMENT 'Error message if cron failed', + `execution_time` decimal(10,3) DEFAULT NULL COMMENT 'Execution time in seconds', + `memory_usage` varchar(20) DEFAULT NULL COMMENT 'Memory usage at completion', + `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP, + PRIMARY KEY (`id`), + KEY `idx_cron_type` (`cron_type`), + KEY `idx_started_at` (`started_at`), + KEY `idx_status` (`status`) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='Cron job execution logs'; diff --git a/system/create_monitoring_table.sql b/system/create_monitoring_table.sql new file mode 100644 index 0000000..e8b1286 --- /dev/null +++ b/system/create_monitoring_table.sql @@ -0,0 +1,24 @@ +-- Create router monitoring table +CREATE TABLE IF NOT EXISTS `tbl_router_monitoring` ( + `id` int(11) NOT NULL AUTO_INCREMENT, + `router_id` int(11) NOT NULL, + `timestamp` datetime NOT NULL, + `ping_status` tinyint(1) NOT NULL DEFAULT 0, + `api_status` tinyint(1) NOT NULL DEFAULT 0, + `uptime` varchar(50) DEFAULT NULL, + `free_memory` bigint(20) DEFAULT NULL, + `total_memory` bigint(20) DEFAULT NULL, + `cpu_load` int(11) DEFAULT NULL, + `temperature` varchar(20) DEFAULT NULL, + `voltage` varchar(20) DEFAULT NULL, + `error` text DEFAULT NULL, + PRIMARY KEY (`id`), + KEY `router_id` (`router_id`), + KEY `timestamp` (`timestamp`), + KEY `router_timestamp` (`router_id`, `timestamp`) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4; + +-- Add monitoring columns to router table if they don't exist +ALTER TABLE `tbl_routers` +ADD COLUMN IF NOT EXISTS `last_error` text DEFAULT NULL, +ADD COLUMN IF NOT EXISTS `offline_since` datetime DEFAULT NULL; diff --git a/system/cron.php b/system/cron.php new file mode 100644 index 0000000..423c3f7 --- /dev/null +++ b/system/cron.php @@ -0,0 +1,268 @@ +"; +} + +// Start cron logging +$logId = CronLog::start('main'); +$expiredUsersFound = 0; +$expiredUsersProcessed = 0; +$notificationsSent = 0; +$autoRenewalsAttempted = 0; +$autoRenewalsSuccessful = 0; + +echo "PHP Time\t" . date('Y-m-d H:i:s') . "\n"; +$res = ORM::raw_execute('SELECT NOW() AS WAKTU;'); +$statement = ORM::get_last_statement(); +$rows = array(); +while ($row = $statement->fetch(PDO::FETCH_ASSOC)) { + echo "MYSQL Time\t" . $row['WAKTU'] . "\n"; +} + +$_c = $config; + +$textExpired = Lang::getNotifText('expired'); + +// Retrieve routers that are online +$onlineRouters = ORM::for_table('tbl_routers')->where('status', 'online')->find_many(); + +// Convert the ORM result set to a regular array +$onlineRoutersArray = $onlineRouters->as_array(); + +// Extract router names using array_map +$onlineRouterNames = array_map(function($router) { + return $router['name']; +}, $onlineRoutersArray); + +// If no online routers are found, skip processing user recharges +if (empty($onlineRouterNames)) { + echo "No online routers found. Skipping user recharge processing.\n"; + exit; // Skip further processing +} + +echo "Found " . count($onlineRouters) . " online routers.\n"; + +// First, handle suspended users that have reached their suspension time +$suspendedUsers = ORM::for_table('tbl_user_recharges')->where('status', 'suspended')->where_lte('expiration', date("Y-m-d")) + ->where_in('routers', $onlineRouterNames) + ->find_many(); + +echo "Found " . count($suspendedUsers) . " suspended user(s) to process.\n"; + +foreach ($suspendedUsers as $susUser) { + $date_now = strtotime(date("Y-m-d H:i:s")); + $expiration = strtotime($susUser['expiration'] . ' ' . $susUser['time']); + + if ($date_now >= $expiration) { + echo "Suspending user: " . (($isCli) ? $susUser['username'] : Lang::maskText($susUser['username'])) . "\n"; + + $u = ORM::for_table('tbl_user_recharges')->where('id', $susUser['id'])->find_one(); + $c = ORM::for_table('tbl_customers')->where('id', $susUser['customer_id'])->find_one(); + $m = ORM::for_table('tbl_routers')->where('name', $susUser['routers'])->find_one(); + $p = ORM::for_table('tbl_plans')->where('id', $u['plan_id'])->find_one(); + + if ($p['is_radius']) { + if (empty($p['pool_expired'])) { + print_r(Radius::customerDeactivate($c['username'])); + } else { + Radius::upsertCustomerAttr($c['username'], 'Framed-Pool', $p['pool_expired'], ':='); + print_r(Radius::disconnectCustomer($c['username'])); + } + } else { + $client = Mikrotik::getClient($m['ip_address'], $m['username'], $m['password']); + if ($susUser['type'] == 'Hotspot') { + if (!empty($p['pool_expired'])) { + Mikrotik::setHotspotUserPlan($client, $c['username'], 'EXPIRED NUXBILL ' . $p['pool_expired']); + } else { + Mikrotik::removeHotspotUser($client, $c['username']); + } + Mikrotik::removeHotspotActiveUser($client, $c['username']); + } else if ($susUser['type'] == 'PPPOE') { + if (!empty($p['pool_expired'])) { + Mikrotik::setPpoeUserPlan($client, $c['username'], 'EXPIRED NUXBILL ' . $p['pool_expired']); + } else { + Mikrotik::removePpoeUser($client, $c['username']); + } + Mikrotik::removePpoeActive($client, $c['username']); + } + } + + // Update status to 'off' (suspended) + $u->status = 'off'; + $u->save(); + + echo "User " . $susUser['username'] . " has been suspended.\n"; + } +} + +// Retrieve user recharges with status 'on' and expiration less than or equal to today +$d = ORM::for_table('tbl_user_recharges')->where('status', 'on')->where_lte('expiration', date("Y-m-d")) + ->where_in('routers', $onlineRouterNames) // Filter by routers that are online + ->find_many(); + +echo "Found " . count($d) . " user(s) on online routers.\n"; + +run_hook('cronjob'); #HOOK + +foreach ($d as $ds) { + if ($ds['type'] == 'Hotspot') { # HOTSPOT + $date_now = strtotime(date("Y-m-d H:i:s")); + $expiration = strtotime($ds['expiration'] . ' ' . $ds['time']); + echo $ds['expiration'] . " : " . (($isCli) ? $ds['username'] : Lang::maskText($ds['username'])); + if ($date_now >= $expiration) { + echo " : EXPIRED \r\n"; + $expiredUsersFound++; + $u = ORM::for_table('tbl_user_recharges')->where('id', $ds['id'])->find_one(); + $c = ORM::for_table('tbl_customers')->where('id', $ds['customer_id'])->find_one(); + $m = Mikrotik::info($ds['routers']); + + // Now no need to check the router status again because the query already filters offline routers + $p = ORM::for_table('tbl_plans')->where('id', $u['plan_id'])->find_one(); + if ($p['is_radius']) { + if (empty($p['pool_expired'])) { + print_r(Radius::customerDeactivate($c['username'])); + } else { + Radius::upsertCustomerAttr($c['username'], 'Framed-Pool', $p['pool_expired'], ':='); + print_r(Radius::disconnectCustomer($c['username'])); + } + } else { + $client = Mikrotik::getClient($m['ip_address'], $m['username'], $m['password']); + if (!empty($p['pool_expired'])) { + Mikrotik::setHotspotUserPackage($client, $c['username'], 'EXPIRED NUXBILL ' . $p['pool_expired']); + } else { + Mikrotik::removeHotspotUser($client, $c['username']); + } + Mikrotik::removeHotspotActiveUser($client, $c['username']); + } + echo Message::sendPackageNotification($c, $u['namebp'], $p['price'], 'expired', $config['user_notification_expired'], $p['type']) . "\n"; + $notificationsSent++; + + // Update database user with status off + $u->status = 'off'; + $u->save(); + $expiredUsersProcessed++; + + // Autoreneewal from deposit + if ($config['enable_balance'] == 'yes' && $c['auto_renewal']) { + $autoRenewalsAttempted++; + list($bills, $add_cost) = User::getBills($ds['customer_id']); + if ($add_cost > 0) { + if (!empty($add_cost)) { + $p['price'] += $add_cost; + } + } + if ($p && $p['enabled'] && $c['balance'] >= $p['price']) { + if (Package::rechargeUser($ds['customer_id'], $ds['routers'], $p['id'], 'Customer', 'Balance')) { + // if success, then get the balance + Balance::min($ds['customer_id'], $p['price']); + $autoRenewalsSuccessful++; + echo "plan enabled: $p[enabled] | User balance: $c[balance] | price $p[price]\n"; + echo "auto renewall Success\n"; + } else { + echo "plan enabled: $p[enabled] | User balance: $c[balance] | price $p[price]\n"; + echo "auto renewall Failed\n"; + Message::sendTelegram("FAILED RENEWAL #cron\n\n#u$c[username] #buy #Hotspot \n" . $p['name_plan'] . + "\nRouter: " . $p['routers'] . + "\nPrice: " . $p['price']); + } + } else { + echo "no renewall | plan enabled: $p[enabled] | User balance: $c[balance] | price $p[price]\n"; + } + } else { + echo "no renewall | balance $config[enable_balance] auto_renewal $c[auto_renewal]\n"; + } + } else + echo " : ACTIVE \r\n"; + } else { # PPPOE + $date_now = strtotime(date("Y-m-d H:i:s")); + $expiration = strtotime($ds['expiration'] . ' ' . $ds['time']); + echo $ds['expiration'] . " : " . (($isCli) ? $ds['username'] : Lang::maskText($ds['username'])); + if ($date_now >= $expiration) { + echo " : EXPIRED \r\n"; + $expiredUsersFound++; + $u = ORM::for_table('tbl_user_recharges')->where('id', $ds['id'])->find_one(); + $c = ORM::for_table('tbl_customers')->where('id', $ds['customer_id'])->find_one(); + $m = ORM::for_table('tbl_routers')->where('name', $ds['routers'])->find_one(); + + // No need to check router status here, as we've already filtered offline routers + $p = ORM::for_table('tbl_plans')->where('id', $u['plan_id'])->find_one(); + if ($p['is_radius']) { + if (empty($p['pool_expired'])) { + print_r(Radius::customerDeactivate($c['username'])); + } else { + Radius::upsertCustomerAttr($c['username'], 'Framed-Pool', $p['pool_expired'], ':='); + print_r(Radius::disconnectCustomer($c['username'])); + } + } else { + $client = Mikrotik::getClient($m['ip_address'], $m['username'], $m['password']); + if (!empty($p['pool_expired'])) { + Mikrotik::setPpoeUserPlan($client, $c['username'], 'EXPIRED NUXBILL ' . $p['pool_expired']); + } else { + Mikrotik::removePpoeUser($client, $c['username']); + } + Mikrotik::removePpoeActive($client, $c['username']); + } + echo Message::sendPackageNotification($c, $u['namebp'], $p['price'], 'expired', $config['user_notification_expired'], $p['type']) . "\n"; + $notificationsSent++; + + // Update database user with status off + $u->status = 'off'; + $u->save(); + $expiredUsersProcessed++; + + // Autoreneewal from deposit + if ($config['enable_balance'] == 'yes' && $c['auto_renewal']) { + $autoRenewalsAttempted++; + list($bills, $add_cost) = User::getBills($ds['customer_id']); + if ($add_cost > 0) { + if (!empty($add_cost)) { + $p['price'] += $add_cost; + } + } + if ($p && $p['enabled'] && $c['balance'] >= $p['price']) { + if (Package::rechargeUser($ds['customer_id'], $ds['routers'], $p['id'], 'Customer', 'Balance')) { + // if success, then get the balance + Balance::min($ds['customer_id'], $p['price']); + $autoRenewalsSuccessful++; + echo "plan enabled: $p[enabled] | User balance: $c[balance] | price $p[price]\n"; + echo "auto renewall Success\n"; + } else { + echo "plan enabled: $p[enabled] | User balance: $c[balance] | price $p[price]\n"; + echo "auto renewall Failed\n"; + Message::sendTelegram("FAILED RENEWAL #cron\n\n#u$c[username] #buy #PPPOE \n" . $p['name_plan'] . + "\nRouter: " . $p['routers'] . + "\nPrice: " . $p['price']); + } + } else { + echo "no renewall | plan enabled: $p[enabled] | User balance: $c[balance] | price $p[price]\n"; + } + } else { + echo "no renewall | balance $config[enable_balance] auto_renewal $c[auto_renewal]\n"; + } + } else + echo " : ACTIVE \r\n"; + } +} + +// Complete cron logging +echo "\n=== CRON JOB SUMMARY ===\n"; +echo "Expired users found: $expiredUsersFound\n"; +echo "Expired users processed: $expiredUsersProcessed\n"; +echo "Notifications sent: $notificationsSent\n"; +echo "Auto-renewals attempted: $autoRenewalsAttempted\n"; +echo "Auto-renewals successful: $autoRenewalsSuccessful\n"; + +// Update final statistics and complete logging +CronLog::complete([ + 'expired_users_found' => $expiredUsersFound, + 'expired_users_processed' => $expiredUsersProcessed, + 'notifications_sent' => $notificationsSent, + 'auto_renewals_attempted' => $autoRenewalsAttempted, + 'auto_renewals_successful' => $autoRenewalsSuccessful +]); + +echo "Cron job completed successfully!\n"; diff --git a/system/cron_reminder.php b/system/cron_reminder.php new file mode 100644 index 0000000..8e191e3 --- /dev/null +++ b/system/cron_reminder.php @@ -0,0 +1,77 @@ +"; +} + +$d = ORM::for_table('tbl_user_recharges')->where('status', 'on')->find_many(); + +run_hook('cronjob_reminder'); #HOOK + + +echo "PHP Time\t" . date('Y-m-d H:i:s') . "\n"; +$res = ORM::raw_execute('SELECT NOW() AS WAKTU;'); +$statement = ORM::get_last_statement(); +$rows = array(); +while ($row = $statement->fetch(PDO::FETCH_ASSOC)) { + echo "MYSQL Time\t" . $row['WAKTU'] . "\n"; +} + + +$day7 = date('Y-m-d', strtotime("+7 day")); +$day3 = date('Y-m-d', strtotime("+3 day")); +$day1 = date('Y-m-d', strtotime("+1 day")); +print_r([$day1, $day3, $day7]); +foreach ($d as $ds) { + if (in_array($ds['expiration'], [$day1, $day3, $day7])) { + $u = ORM::for_table('tbl_user_recharges')->where('id', $ds['id'])->find_one(); + $p = ORM::for_table('tbl_plans')->where('id', $u['plan_id'])->find_one(); + $c = ORM::for_table('tbl_customers')->where('id', $ds['customer_id'])->find_one(); + if ($p['validity_unit'] == 'Period') { + // Postpaid price from field + $add_inv = User::getAttribute("Invoice", $ds['customer_id']); + if (empty ($add_inv) or $add_inv == 0) { + $price = $p['price']; + } else { + $price = $add_inv; + } + } else { + $price = $p['price']; + } + if ($ds['expiration'] == $day7) { + echo Message::sendPackageNotification($c, $p['name_plan'], $price, Lang::getNotifText('reminder_7_day'), $config['user_notification_reminder'], $p['type']) . "\n"; + $remindersSent++; + } else if ($ds['expiration'] == $day3) { + echo Message::sendPackageNotification($c, $p['name_plan'], $price, Lang::getNotifText('reminder_3_day'), $config['user_notification_reminder'], $p['type']) . "\n"; + $remindersSent++; + } else if ($ds['expiration'] == $day1) { + echo Message::sendPackageNotification($c, $p['name_plan'], $price, Lang::getNotifText('reminder_1_day'), $config['user_notification_reminder'], $p['type']) . "\n"; + $remindersSent++; + } + } +} + +// Complete reminder cron logging +echo "\n=== REMINDER CRON SUMMARY ===\n"; +echo "Reminders sent: $remindersSent\n"; + +CronLog::complete([ + 'notifications_sent' => $remindersSent +]); + +echo "Reminder cron job completed successfully!\n"; \ No newline at end of file diff --git a/system/error_log b/system/error_log new file mode 100644 index 0000000..ac38513 --- /dev/null +++ b/system/error_log @@ -0,0 +1,166 @@ +[05-Jul-2024 03:20:03 UTC] Alloworigins called +[05-Jul-2024 03:20:03 UTC] Type parameter missing +[05-Jul-2024 03:25:02 UTC] Alloworigins called +[05-Jul-2024 03:25:02 UTC] Type parameter missing +[05-Jul-2024 11:36:03 Africa/Nairobi] PHP Fatal error: Uncaught PEAR2\Net\Transmitter\SocketException: stream_socket_client(): Unable to connect to tcp://us.labkom.us:6529 (Connection timed out) in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/Stream.php(145): PEAR2\Net\Transmitter\TcpClient->createException('stream_socket_c...', 0) +#1 [internal function]: PEAR2\Net\Transmitter\Stream->handleError(2, 'stream_socket_c...', '/home/codevibe/...', 159) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(159): stream_socket_client('tcp://us.labkom...', 0, '', '60', 4, Resource id #10) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#5 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#6 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#7 {main} + +Next PEAR2\Net\Transmitter\SocketException: Failed to connect with socket. in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(178): PEAR2\Net\Transmitter\TcpClient->createException('Failed to conne...', 8, Object(PEAR2\Net\Transmitter\SocketException)) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#5 {main} + +Next PEAR2\Net\RouterOS\SocketException: Error connecting to RouterOS in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php:169 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#3 {main} + thrown in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php on line 169 +[05-Jul-2024 11:40:04 Africa/Nairobi] PHP Fatal error: Uncaught PEAR2\Net\Transmitter\SocketException: stream_socket_client(): Unable to connect to tcp://us.labkom.us:6529 (Network is unreachable) in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/Stream.php(145): PEAR2\Net\Transmitter\TcpClient->createException('stream_socket_c...', 0) +#1 [internal function]: PEAR2\Net\Transmitter\Stream->handleError(2, 'stream_socket_c...', '/home/codevibe/...', 159) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(159): stream_socket_client('tcp://us.labkom...', 0, '', '60', 4, Resource id #10) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#5 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#6 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#7 {main} + +Next PEAR2\Net\Transmitter\SocketException: Failed to connect with socket. in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(178): PEAR2\Net\Transmitter\TcpClient->createException('Failed to conne...', 8, Object(PEAR2\Net\Transmitter\SocketException)) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#5 {main} + +Next PEAR2\Net\RouterOS\SocketException: Error connecting to RouterOS in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php:169 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#3 {main} + thrown in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php on line 169 +[05-Jul-2024 11:46:02 Africa/Nairobi] PHP Fatal error: Uncaught PEAR2\Net\Transmitter\SocketException: stream_socket_client(): Unable to connect to tcp://us.labkom.us:6529 (Connection timed out) in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/Stream.php(145): PEAR2\Net\Transmitter\TcpClient->createException('stream_socket_c...', 0) +#1 [internal function]: PEAR2\Net\Transmitter\Stream->handleError(2, 'stream_socket_c...', '/home/codevibe/...', 159) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(159): stream_socket_client('tcp://us.labkom...', 0, '', '60', 4, Resource id #10) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#5 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#6 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#7 {main} + +Next PEAR2\Net\Transmitter\SocketException: Failed to connect with socket. in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(178): PEAR2\Net\Transmitter\TcpClient->createException('Failed to conne...', 8, Object(PEAR2\Net\Transmitter\SocketException)) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#5 {main} + +Next PEAR2\Net\RouterOS\SocketException: Error connecting to RouterOS in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php:169 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#3 {main} + thrown in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php on line 169 +[05-Jul-2024 11:51:03 Africa/Nairobi] PHP Fatal error: Uncaught PEAR2\Net\Transmitter\SocketException: stream_socket_client(): Unable to connect to tcp://us.labkom.us:6529 (Connection timed out) in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/Stream.php(145): PEAR2\Net\Transmitter\TcpClient->createException('stream_socket_c...', 0) +#1 [internal function]: PEAR2\Net\Transmitter\Stream->handleError(2, 'stream_socket_c...', '/home/codevibe/...', 159) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(159): stream_socket_client('tcp://us.labkom...', 0, '', '60', 4, Resource id #10) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#5 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#6 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#7 {main} + +Next PEAR2\Net\Transmitter\SocketException: Failed to connect with socket. in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(178): PEAR2\Net\Transmitter\TcpClient->createException('Failed to conne...', 8, Object(PEAR2\Net\Transmitter\SocketException)) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#5 {main} + +Next PEAR2\Net\RouterOS\SocketException: Error connecting to RouterOS in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php:169 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#3 {main} + thrown in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php on line 169 +[06-Jul-2024 23:26:04 Africa/Nairobi] PHP Fatal error: Uncaught PEAR2\Net\Transmitter\SocketException: stream_socket_client(): Unable to connect to tcp://us.labkom.us:6529 (Connection timed out) in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/Stream.php(145): PEAR2\Net\Transmitter\TcpClient->createException('stream_socket_c...', 0) +#1 [internal function]: PEAR2\Net\Transmitter\Stream->handleError(2, 'stream_socket_c...', '/home/codevibe/...', 159) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(159): stream_socket_client('tcp://us.labkom...', 0, '', '60', 4, Resource id #10) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#5 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#6 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#7 {main} + +Next PEAR2\Net\Transmitter\SocketException: Failed to connect with socket. in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(178): PEAR2\Net\Transmitter\TcpClient->createException('Failed to conne...', 8, Object(PEAR2\Net\Transmitter\SocketException)) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#5 {main} + +Next PEAR2\Net\RouterOS\SocketException: Error connecting to RouterOS in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php:169 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#3 {main} + thrown in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php on line 169 +[06-Jul-2024 23:31:04 Africa/Nairobi] PHP Fatal error: Uncaught PEAR2\Net\Transmitter\SocketException: stream_socket_client(): Unable to connect to tcp://us.labkom.us:6529 (Connection timed out) in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/Stream.php(145): PEAR2\Net\Transmitter\TcpClient->createException('stream_socket_c...', 0) +#1 [internal function]: PEAR2\Net\Transmitter\Stream->handleError(2, 'stream_socket_c...', '/home/codevibe/...', 159) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(159): stream_socket_client('tcp://us.labkom...', 0, '', '60', 4, Resource id #10) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#5 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#6 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#7 {main} + +Next PEAR2\Net\Transmitter\SocketException: Failed to connect with socket. in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php:225 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/Transmitter/TcpClient.php(178): PEAR2\Net\Transmitter\TcpClient->createException('Failed to conne...', 8, Object(PEAR2\Net\Transmitter\SocketException)) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php(160): PEAR2\Net\Transmitter\TcpClient->__construct('us.labkom.us', '6529', false, '60', 'admin/11', '', Resource id #10) +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#3 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#4 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#5 {main} + +Next PEAR2\Net\RouterOS\SocketException: Error connecting to RouterOS in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php:169 +Stack trace: +#0 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Client.php(162): PEAR2\Net\RouterOS\Communicator->__construct('us.labkom.us', '6529', false, NULL, 'admin/11', '', NULL) +#1 /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/Mikrotik.php(24): PEAR2\Net\RouterOS\Client->__construct('us.labkom.us', 'admin', '11', '6529') +#2 /home/codevibe/kejos.codevibeisp.co.ke/system/cron.php(45): Mikrotik::getClient('us.labkom.us:65...', 'admin', '11') +#3 {main} + thrown in /home/codevibe/kejos.codevibeisp.co.ke/system/autoload/PEAR2/Net/RouterOS/Communicator.php on line 169 diff --git a/system/get_resources.php b/system/get_resources.php new file mode 100644 index 0000000..16f2dc2 --- /dev/null +++ b/system/get_resources.php @@ -0,0 +1,58 @@ +where('enabled', '1')->find_one($routerId); + + if (!$mikrotik) { + // Handle case where router is not found + return null; + } + + try { + $client = Mikrotik::getClient($mikrotik['ip_address'], $mikrotik['username'], $mikrotik['password']); + + $health = $client->sendSync(new RouterOS\Request('/system health print')); + $res = $client->sendSync(new RouterOS\Request('/system resource print')); + + $resourceData = $res->getAllOfType(RouterOS\Response::TYPE_DATA)[0]; + $uptime = $resourceData->getProperty('uptime'); + $freeMemory = $resourceData->getProperty('free-memory'); + $totalMemory = $resourceData->getProperty('total-memory'); + $cpuLoad = $resourceData->getProperty('cpu-load'); + + return [ + 'uptime' => $uptime, + 'freeMemory' => mikrotik_formatSize($freeMemory), + 'totalMemory' => mikrotik_formatSize($totalMemory), + 'cpuLoad' => $cpuLoad . '%' + ]; + } catch (Exception $e) { + // Handle exceptions, e.g., connection errors + return null; + } +} + +// Function to round the value and append the appropriate unit +function mikrotik_formatSize($size) +{ + $units = ['B', 'KB', 'MB', 'GB']; + $unitIndex = 0; + while ($size >= 1024 && $unitIndex < count($units) - 1) { + $size /= 1024; + $unitIndex++; + } + return round($size, 2) . ' ' . $units[$unitIndex]; +} + +if (isset($_GET['router_id'])) { + $routerId = $_GET['router_id']; + $resources = mikrotik_get_resources($routerId); + echo json_encode($resources); +} \ No newline at end of file diff --git a/system/index.html b/system/index.html new file mode 100644 index 0000000..9757970 --- /dev/null +++ b/system/index.html @@ -0,0 +1,8 @@ + + +
Directory access is forbidden.
+ + \ No newline at end of file diff --git a/system/install_cron_logs.php b/system/install_cron_logs.php new file mode 100644 index 0000000..0d5506b --- /dev/null +++ b/system/install_cron_logs.php @@ -0,0 +1,38 @@ +count(); + echo "✓ Table test successful - found $test records\n"; + + echo "\nCron logs system is now ready!\n"; + echo "You can view logs at: " . APP_URL . "/settings/cron-logs\n"; + +} catch (Exception $e) { + echo "✗ Error creating table: " . $e->getMessage() . "\n"; + exit(1); +} + +echo "\nInstallation completed successfully!\n"; diff --git a/system/migrate_notifications.php b/system/migrate_notifications.php new file mode 100644 index 0000000..cfa22f4 --- /dev/null +++ b/system/migrate_notifications.php @@ -0,0 +1,112 @@ + $existing_value, + 'pppoe' => $existing_value, + 'default' => $existing_value + ]; + } + } else { + // Use new default structure + echo "Using default template for '$key'\n"; + $migrated_notifications[$key] = $new_default[$key]; + } +} + +// Copy other notification types as-is +$other_keys = ['balance_send', 'balance_received', 'invoice_paid', 'invoice_balance', 'user_registration']; +foreach ($other_keys as $key) { + if (isset($existing_notifications[$key])) { + $migrated_notifications[$key] = $existing_notifications[$key]; + } else { + $migrated_notifications[$key] = $new_default[$key]; + } +} + +// Create backup of original file +if (file_exists($notifications_file)) { + $backup_file = $UPLOAD_PATH . DIRECTORY_SEPARATOR . 'notifications.backup.' . date('Y-m-d_H-i-s') . '.json'; + copy($notifications_file, $backup_file); + echo "Created backup: $backup_file\n"; +} + +// Save migrated notifications +$result = file_put_contents($notifications_file, json_encode($migrated_notifications, JSON_PRETTY_PRINT)); + +if ($result !== false) { + echo "Migration completed successfully!\n"; + echo "New notification structure saved to: $notifications_file\n"; + echo "\nMigration Summary:\n"; + echo "- Converted " . count($plan_specific_keys) . " plan-specific templates\n"; + echo "- Preserved " . count($other_keys) . " other notification types\n"; + echo "- Backup created for safety\n"; + echo "\nYou can now customize plan-type-specific templates in the admin panel.\n"; +} else { + echo "Error: Failed to save migrated notifications\n"; + exit(1); +} + +// Test the new structure +echo "\nTesting new notification structure...\n"; +$test_notifications = json_decode(file_get_contents($notifications_file), true); + +foreach ($plan_specific_keys as $key) { + if (isset($test_notifications[$key]) && is_array($test_notifications[$key])) { + echo "✓ Template '$key' is properly structured\n"; + } else { + echo "✗ Template '$key' has issues\n"; + } +} + +echo "\nMigration completed!\n"; diff --git a/system/orm.php b/system/orm.php new file mode 100644 index 0000000..46fee90 --- /dev/null +++ b/system/orm.php @@ -0,0 +1,2773 @@ + 'sqlite::memory:', + 'id_column' => 'id', + 'id_column_overrides' => array(), + 'error_mode' => PDO::ERRMODE_EXCEPTION, + 'username' => null, + 'password' => null, + 'driver_options' => null, + 'identifier_quote_character' => null, // if this is null, will be autodetected + 'limit_clause_style' => null, // if this is null, will be autodetected + 'logging' => false, + 'logger' => null, + 'caching' => false, + 'caching_auto_clear' => false, + 'return_result_sets' => false, + ); + + // Map of configuration settings + protected static $_config = array(); + + // Map of database connections, instances of the PDO class + protected static $_db = array(); + + // Last query run, only populated if logging is enabled + protected static $_last_query; + + // Log of all queries run, mapped by connection key, only populated if logging is enabled + protected static $_query_log = array(); + + // Query cache, only used if query caching is enabled + protected static $_query_cache = array(); + + // Reference to previously used PDOStatement object to enable low-level access, if needed + protected static $_last_statement = null; + + // --------------------------- // + // --- INSTANCE PROPERTIES --- // + // --------------------------- // + + // Key name of the connections in self::$_db used by this instance + protected $_connection_name; + + // The name of the table the current ORM instance is associated with + protected $_table_name; + + // Alias for the table to be used in SELECT queries + protected $_table_alias = null; + + // Values to be bound to the query + protected $_values = array(); + + // Columns to select in the result + protected $_result_columns = array('*'); + + // Are we using the default result column or have these been manually changed? + protected $_using_default_result_columns = true; + + // Join sources + protected $_join_sources = array(); + + // Should the query include a DISTINCT keyword? + protected $_distinct = false; + + // Is this a raw query? + protected $_is_raw_query = false; + + // The raw query + protected $_raw_query = ''; + + // The raw query parameters + protected $_raw_parameters = array(); + + // Array of WHERE clauses + protected $_where_conditions = array(); + + // LIMIT + protected $_limit = null; + + // OFFSET + protected $_offset = null; + + // ORDER BY + protected $_order_by = array(); + + // GROUP BY + protected $_group_by = array(); + + // HAVING + protected $_having_conditions = array(); + + // The data for a hydrated instance of the class + protected $_data = array(); + + // Fields that have been modified during the + // lifetime of the object + protected $_dirty_fields = array(); + + // Fields that are to be inserted in the DB raw + protected $_expr_fields = array(); + + // Is this a new object (has create() been called)? + protected $_is_new = false; + + // Name of the column to use as the primary key for + // this instance only. Overrides the config settings. + protected $_instance_id_column = null; + + // ---------------------- // + // --- STATIC METHODS --- // + // ---------------------- // + + /** + * Pass configuration settings to the class in the form of + * key/value pairs. As a shortcut, if the second argument + * is omitted and the key is a string, the setting is + * assumed to be the DSN string used by PDO to connect + * to the database (often, this will be the only configuration + * required to use Idiorm). If you have more than one setting + * you wish to configure, another shortcut is to pass an array + * of settings (and omit the second argument). + * @param string|array $key + * @param mixed $value + * @param string $connection_name Which connection to use + */ + public static function configure($key, $value = null, $connection_name = self::DEFAULT_CONNECTION) + { + self::_setup_db_config($connection_name); //ensures at least default config is set + + if (is_array($key)) { + // Shortcut: If only one array argument is passed, + // assume it's an array of configuration settings + foreach ($key as $conf_key => $conf_value) { + self::configure($conf_key, $conf_value, $connection_name); + } + } else { + if (is_null($value)) { + // Shortcut: If only one string argument is passed, + // assume it's a connection string + $value = $key; + $key = 'connection_string'; + } + self::$_config[$connection_name][$key] = $value; + } + } + + /** + * Retrieve configuration options by key, or as whole array. + * @param string $key + * @param string $connection_name Which connection to use + */ + public static function get_config($key = null, $connection_name = self::DEFAULT_CONNECTION) + { + if ($key) { + return self::$_config[$connection_name][$key]; + } else { + return self::$_config[$connection_name]; + } + } + + /** + * Delete all configs in _config array. + */ + public static function reset_config() + { + self::$_config = array(); + } + + /** + * Despite its slightly odd name, this is actually the factory + * method used to acquire instances of the class. It is named + * this way for the sake of a readable interface, ie + * ORM::for_table('table_name')->find_one()-> etc. As such, + * this will normally be the first method called in a chain. + * @param string $table_name + * @param string $connection_name Which connection to use + * @return ORM + */ + public static function for_table($table_name, $connection_name = self::DEFAULT_CONNECTION) + { + self::_setup_db($connection_name); + return new self($table_name, array(), $connection_name); + } + + /** + * Set up the database connection used by the class + * @param string $connection_name Which connection to use + */ + protected static function _setup_db($connection_name = self::DEFAULT_CONNECTION) + { + if ( + !array_key_exists($connection_name, self::$_db) || + !is_object(self::$_db[$connection_name]) + ) { + self::_setup_db_config($connection_name); + + $db = new PDO( + self::$_config[$connection_name]['connection_string'], + self::$_config[$connection_name]['username'], + self::$_config[$connection_name]['password'], + self::$_config[$connection_name]['driver_options'] + ); + + $db->setAttribute(PDO::ATTR_ERRMODE, self::$_config[$connection_name]['error_mode']); + self::set_db($db, $connection_name); + } + } + + /** + * Ensures configuration (multiple connections) is at least set to default. + * @param string $connection_name Which connection to use + */ + protected static function _setup_db_config($connection_name) + { + if (!array_key_exists($connection_name, self::$_config)) { + self::$_config[$connection_name] = self::$_default_config; + } + } + + /** + * Set the PDO object used by Idiorm to communicate with the database. + * This is public in case the ORM should use a ready-instantiated + * PDO object as its database connection. Accepts an optional string key + * to identify the connection if multiple connections are used. + * @param PDO $db + * @param string $connection_name Which connection to use + */ + public static function set_db($db, $connection_name = self::DEFAULT_CONNECTION) + { + self::_setup_db_config($connection_name); + self::$_db[$connection_name] = $db; + if (!is_null(self::$_db[$connection_name])) { + self::_setup_identifier_quote_character($connection_name); + self::_setup_limit_clause_style($connection_name); + } + } + + /** + * Close and delete all registered PDO objects in _db array. + */ + public static function reset_db() + { + self::$_db = null; + + self::$_db = array(); + } + + /** + * Detect and initialise the character used to quote identifiers + * (table names, column names etc). If this has been specified + * manually using ORM::configure('identifier_quote_character', 'some-char'), + * this will do nothing. + * @param string $connection_name Which connection to use + */ + protected static function _setup_identifier_quote_character($connection_name) + { + if (is_null(self::$_config[$connection_name]['identifier_quote_character'])) { + self::$_config[$connection_name]['identifier_quote_character'] = + self::_detect_identifier_quote_character($connection_name); + } + } + + /** + * Detect and initialise the limit clause style ("SELECT TOP 5" / + * "... LIMIT 5"). If this has been specified manually using + * ORM::configure('limit_clause_style', 'top'), this will do nothing. + * @param string $connection_name Which connection to use + */ + public static function _setup_limit_clause_style($connection_name) + { + if (is_null(self::$_config[$connection_name]['limit_clause_style'])) { + self::$_config[$connection_name]['limit_clause_style'] = + self::_detect_limit_clause_style($connection_name); + } + } + + /** + * Return the correct character used to quote identifiers (table + * names, column names etc) by looking at the driver being used by PDO. + * @param string $connection_name Which connection to use + * @return string + */ + protected static function _detect_identifier_quote_character($connection_name) + { + switch (self::get_db($connection_name)->getAttribute(PDO::ATTR_DRIVER_NAME)) { + case 'pgsql': + case 'sqlsrv': + case 'dblib': + case 'mssql': + case 'sybase': + case 'firebird': + return '"'; + case 'mysql': + case 'sqlite': + case 'sqlite2': + default: + return '`'; + } + } + + /** + * Returns a constant after determining the appropriate limit clause + * style + * @param string $connection_name Which connection to use + * @return string Limit clause style keyword/constant + */ + protected static function _detect_limit_clause_style($connection_name) + { + switch (self::get_db($connection_name)->getAttribute(PDO::ATTR_DRIVER_NAME)) { + case 'sqlsrv': + case 'dblib': + case 'mssql': + return ORM::LIMIT_STYLE_TOP_N; + default: + return ORM::LIMIT_STYLE_LIMIT; + } + } + + /** + * Returns the PDO instance used by the the ORM to communicate with + * the database. This can be called if any low-level DB access is + * required outside the class. If multiple connections are used, + * accepts an optional key name for the connection. + * @param string $connection_name Which connection to use + * @return PDO + */ + public static function get_db($connection_name = self::DEFAULT_CONNECTION) + { + self::_setup_db($connection_name); // required in case this is called before Idiorm is instantiated + return self::$_db[$connection_name]; + } + + /** + * Executes a raw query as a wrapper for PDOStatement::execute. + * Useful for queries that can't be accomplished through Idiorm, + * particularly those using engine-specific features. + * @example raw_execute('SELECT `name`, AVG(`order`) FROM `customer` GROUP BY `name` HAVING AVG(`order`) > 10') + * @example raw_execute('INSERT OR REPLACE INTO `widget` (`id`, `name`) SELECT `id`, `name` FROM `other_table`') + * @param string $query The raw SQL query + * @param array $parameters Optional bound parameters + * @param string $connection_name Which connection to use + * @return bool Success + */ + public static function raw_execute($query, $parameters = array(), $connection_name = self::DEFAULT_CONNECTION) + { + self::_setup_db($connection_name); + return self::_execute($query, $parameters, $connection_name); + } + + /** + * Returns the PDOStatement instance last used by any connection wrapped by the ORM. + * Useful for access to PDOStatement::rowCount() or error information + * @return PDOStatement + */ + public static function get_last_statement() + { + return self::$_last_statement; + } + + /** + * Internal helper method for executing statments. Logs queries, and + * stores statement object in ::_last_statment, accessible publicly + * through ::get_last_statement() + * @param string $query + * @param array $parameters An array of parameters to be bound in to the query + * @param string $connection_name Which connection to use + * @return bool Response of PDOStatement::execute() + */ + protected static function _execute($query, $parameters = array(), $connection_name = self::DEFAULT_CONNECTION) + { + $statement = self::get_db($connection_name)->prepare($query); + self::$_last_statement = $statement; + $time = microtime(true); + + foreach ($parameters as $key => &$param) { + if (is_null($param)) { + $type = PDO::PARAM_NULL; + } else if (is_bool($param)) { + $type = PDO::PARAM_BOOL; + } else if (is_int($param)) { + $type = PDO::PARAM_INT; + } else { + $type = PDO::PARAM_STR; + } + + $statement->bindParam(is_int($key) ? ++$key : $key, $param, $type); + } + + $q = $statement->execute(); + self::_log_query($query, $parameters, $connection_name, (microtime(true) - $time)); + + return $q; + } + + /** + * Add a query to the internal query log. Only works if the + * 'logging' config option is set to true. + * + * This works by manually binding the parameters to the query - the + * query isn't executed like this (PDO normally passes the query and + * parameters to the database which takes care of the binding) but + * doing it this way makes the logged queries more readable. + * @param string $query + * @param array $parameters An array of parameters to be bound in to the query + * @param string $connection_name Which connection to use + * @param float $query_time Query time + * @return bool + */ + protected static function _log_query($query, $parameters, $connection_name, $query_time) + { + // If logging is not enabled, do nothing + if (!self::$_config[$connection_name]['logging']) { + return false; + } + + if (!isset(self::$_query_log[$connection_name])) { + self::$_query_log[$connection_name] = array(); + } + + if (empty($parameters)) { + $bound_query = $query; + } else { + // Escape the parameters + $parameters = array_map(array(self::get_db($connection_name), 'quote'), $parameters); + + if (array_values($parameters) === $parameters) { + // ? placeholders + // Avoid %format collision for vsprintf + $query = str_replace("%", "%%", $query); + + // Replace placeholders in the query for vsprintf + if (false !== strpos($query, "'") || false !== strpos($query, '"')) { + $query = IdiormString::str_replace_outside_quotes("?", "%s", $query); + } else { + $query = str_replace("?", "%s", $query); + } + + // Replace the question marks in the query with the parameters + $bound_query = vsprintf($query, $parameters); + } else { + // named placeholders + foreach ($parameters as $key => $val) { + $query = str_replace($key, $val, $query); + } + $bound_query = $query; + } + } + + self::$_last_query = $bound_query; + self::$_query_log[$connection_name][] = $bound_query; + + + if (is_callable(self::$_config[$connection_name]['logger'])) { + $logger = self::$_config[$connection_name]['logger']; + $logger($bound_query, $query_time); + } + + return true; + } + + /** + * Get the last query executed. Only works if the + * 'logging' config option is set to true. Otherwise + * this will return null. Returns last query from all connections if + * no connection_name is specified + * @param null|string $connection_name Which connection to use + * @return string + */ + public static function get_last_query($connection_name = null) + { + if ($connection_name === null) { + return self::$_last_query; + } + if (!isset(self::$_query_log[$connection_name])) { + return ''; + } + + return end(self::$_query_log[$connection_name]); + } + + /** + * Get an array containing all the queries run on a + * specified connection up to now. + * Only works if the 'logging' config option is + * set to true. Otherwise, returned array will be empty. + * @param string $connection_name Which connection to use + */ + public static function get_query_log($connection_name = self::DEFAULT_CONNECTION) + { + if (isset(self::$_query_log[$connection_name])) { + return self::$_query_log[$connection_name]; + } + return array(); + } + + /** + * Get a list of the available connection names + * @return array + */ + public static function get_connection_names() + { + return array_keys(self::$_db); + } + + // ------------------------ // + // --- INSTANCE METHODS --- // + // ------------------------ // + + /** + * "Private" constructor; shouldn't be called directly. + * Use the ORM::for_table factory method instead. + */ + protected function __construct($table_name, $data = array(), $connection_name = self::DEFAULT_CONNECTION) + { + $this->_table_name = $table_name; + $this->_data = $data; + + $this->_connection_name = $connection_name; + self::_setup_db_config($connection_name); + } + + /** + * Create a new, empty instance of the class. Used + * to add a new row to your database. May optionally + * be passed an associative array of data to populate + * the instance. If so, all fields will be flagged as + * dirty so all will be saved to the database when + * save() is called. + */ + public function create($data = null) + { + $this->_is_new = true; + if (!is_null($data)) { + return $this->hydrate($data)->force_all_dirty(); + } + return $this; + } + + /** + * Specify the ID column to use for this instance or array of instances only. + * This overrides the id_column and id_column_overrides settings. + * + * This is mostly useful for libraries built on top of Idiorm, and will + * not normally be used in manually built queries. If you don't know why + * you would want to use this, you should probably just ignore it. + */ + public function use_id_column($id_column) + { + $this->_instance_id_column = $id_column; + return $this; + } + + /** + * Create an ORM instance from the given row (an associative + * array of data fetched from the database) + */ + protected function _create_instance_from_row($row) + { + $instance = self::for_table($this->_table_name, $this->_connection_name); + $instance->use_id_column($this->_instance_id_column); + $instance->hydrate($row); + return $instance; + } + + /** + * Tell the ORM that you are expecting a single result + * back from your query, and execute it. Will return + * a single instance of the ORM class, or false if no + * rows were returned. + * As a shortcut, you may supply an ID as a parameter + * to this method. This will perform a primary key + * lookup on the table. + */ + public function find_one($id = null) + { + if (!is_null($id)) { + $this->where_id_is($id); + } + $this->limit(1); + $rows = $this->_run(); + + if (empty($rows)) { + return false; + } + + return $this->_create_instance_from_row($rows[0]); + } + + /** + * Tell the ORM that you are expecting multiple results + * from your query, and execute it. Will return an array + * of instances of the ORM class, or an empty array if + * no rows were returned. + * @return array|\IdiormResultSet + */ + public function find_many() + { + if (self::$_config[$this->_connection_name]['return_result_sets']) { + return $this->find_result_set(); + } + return $this->_find_many(); + } + + /** + * Tell the ORM that you are expecting multiple results + * from your query, and execute it. Will return an array + * of instances of the ORM class, or an empty array if + * no rows were returned. + * @return array + */ + protected function _find_many() + { + $rows = $this->_run(); + return array_map(array($this, '_create_instance_from_row'), $rows); + } + + /** + * Tell the ORM that you are expecting multiple results + * from your query, and execute it. Will return a result set object + * containing instances of the ORM class. + * @return \IdiormResultSet + */ + public function find_result_set() + { + return new IdiormResultSet($this->_find_many()); + } + + /** + * Tell the ORM that you are expecting multiple results + * from your query, and execute it. Will return an array, + * or an empty array if no rows were returned. + * @return array + */ + public function find_array() + { + return $this->_run(); + } + + /** + * Tell the ORM that you wish to execute a COUNT query. + * Will return an integer representing the number of + * rows returned. + */ + public function count($column = '*') + { + return $this->_call_aggregate_db_function(__FUNCTION__, $column); + } + + /** + * Tell the ORM that you wish to execute a MAX query. + * Will return the max value of the choosen column. + */ + public function max($column) + { + return $this->_call_aggregate_db_function(__FUNCTION__, $column); + } + + /** + * Tell the ORM that you wish to execute a MIN query. + * Will return the min value of the choosen column. + */ + public function min($column) + { + return $this->_call_aggregate_db_function(__FUNCTION__, $column); + } + + /** + * Tell the ORM that you wish to execute a AVG query. + * Will return the average value of the choosen column. + */ + public function avg($column) + { + return $this->_call_aggregate_db_function(__FUNCTION__, $column); + } + + /** + * Tell the ORM that you wish to execute a SUM query. + * Will return the sum of the choosen column. + */ + public function sum($column) + { + return $this->_call_aggregate_db_function(__FUNCTION__, $column); + } + + /** + * Execute an aggregate query on the current connection. + * @param string $sql_function The aggregate function to call eg. MIN, COUNT, etc + * @param string $column The column to execute the aggregate query against + * @return int + */ + protected function _call_aggregate_db_function($sql_function, $column) + { + $alias = strtolower($sql_function); + $sql_function = strtoupper($sql_function); + if ('*' != $column) { + $column = $this->_quote_identifier($column); + } + $result_columns = $this->_result_columns; + $this->_result_columns = array(); + $this->select_expr("$sql_function($column)", $alias); + $result = $this->find_one(); + $this->_result_columns = $result_columns; + + $return_value = 0; + if ($result !== false && isset($result->$alias)) { + if (!is_numeric($result->$alias)) { + $return_value = $result->$alias; + } elseif ((int) $result->$alias == (float) $result->$alias) { + $return_value = (int) $result->$alias; + } else { + $return_value = (float) $result->$alias; + } + } + return $return_value; + } + + /** + * This method can be called to hydrate (populate) this + * instance of the class from an associative array of data. + * This will usually be called only from inside the class, + * but it's public in case you need to call it directly. + */ + public function hydrate($data = array()) + { + $this->_data = $data; + return $this; + } + + /** + * Force the ORM to flag all the fields in the $data array + * as "dirty" and therefore update them when save() is called. + */ + public function force_all_dirty() + { + $this->_dirty_fields = $this->_data; + return $this; + } + + /** + * Perform a raw query. The query can contain placeholders in + * either named or question mark style. If placeholders are + * used, the parameters should be an array of values which will + * be bound to the placeholders in the query. If this method + * is called, all other query building methods will be ignored. + */ + public function raw_query($query, $parameters = array()) + { + $this->_is_raw_query = true; + $this->_raw_query = $query; + $this->_raw_parameters = $parameters; + return $this; + } + + /** + * Add an alias for the main table to be used in SELECT queries + */ + public function table_alias($alias) + { + $this->_table_alias = $alias; + return $this; + } + + /** + * Internal method to add an unquoted expression to the set + * of columns returned by the SELECT query. The second optional + * argument is the alias to return the expression as. + */ + protected function _add_result_column($expr, $alias = null) + { + if (!is_null($alias)) { + $expr .= " AS " . $this->_quote_identifier($alias); + } + + if ($this->_using_default_result_columns) { + $this->_result_columns = array($expr); + $this->_using_default_result_columns = false; + } else { + $this->_result_columns[] = $expr; + } + return $this; + } + + /** + * Counts the number of columns that belong to the primary + * key and their value is null. + */ + public function count_null_id_columns() + { + if (is_array($this->_get_id_column_name())) { + return count(array_filter($this->id(), 'is_null')); + } else { + return is_null($this->id()) ? 1 : 0; + } + } + + /** + * Add a column to the list of columns returned by the SELECT + * query. This defaults to '*'. The second optional argument is + * the alias to return the column as. + */ + public function select($column, $alias = null) + { + $column = $this->_quote_identifier($column); + return $this->_add_result_column($column, $alias); + } + + ## ibnux add function + + /** + * Add a column to the list of columns returned by the SELECT + * query. This defaults to '*'. The second optional argument is + * the alias to return the column as. + * ['columnA', ['columnc', 'alias']] + */ + public function selects($columns = array()) + { + foreach ($columns as $column) { + if(is_array($column)) { + $column[0] = $this->_quote_identifier($column[0]); + $this->_add_result_column($column[0], $column[1]); + }else{ + $column = $this->_quote_identifier($column); + $this->_add_result_column($column, null); + } + } + return $this; + } + + public function getEnum($column){ + $result = $this->raw_query("SHOW COLUMNS FROM ".$this->_table_name." WHERE Field = '$column'")->findArray(); + preg_match("/^enum\(\'(.*)\'\)$/", $result[0]['Type'], $matches); + return explode("','", $matches[1]); + } + + ## END ibnux add function + + /** + * Add an unquoted expression to the list of columns returned + * by the SELECT query. The second optional argument is + * the alias to return the column as. + */ + public function select_expr($expr, $alias = null) + { + return $this->_add_result_column($expr, $alias); + } + + /** + * Add columns to the list of columns returned by the SELECT + * query. This defaults to '*'. Many columns can be supplied + * as either an array or as a list of parameters to the method. + * + * Note that the alias must not be numeric - if you want a + * numeric alias then prepend it with some alpha chars. eg. a1 + * + * @example select_many(array('alias' => 'column', 'column2', 'alias2' => 'column3'), 'column4', 'column5'); + * @example select_many('column', 'column2', 'column3'); + * @example select_many(array('column', 'column2', 'column3'), 'column4', 'column5'); + * + * @return \ORM + */ + public function select_many() + { + $columns = func_get_args(); + if (!empty($columns)) { + $columns = $this->_normalise_select_many_columns($columns); + foreach ($columns as $alias => $column) { + if (is_numeric($alias)) { + $alias = null; + } + $this->select($column, $alias); + } + } + return $this; + } + + /** + * Add an unquoted expression to the list of columns returned + * by the SELECT query. Many columns can be supplied as either + * an array or as a list of parameters to the method. + * + * Note that the alias must not be numeric - if you want a + * numeric alias then prepend it with some alpha chars. eg. a1 + * + * @example select_many_expr(array('alias' => 'column', 'column2', 'alias2' => 'column3'), 'column4', 'column5') + * @example select_many_expr('column', 'column2', 'column3') + * @example select_many_expr(array('column', 'column2', 'column3'), 'column4', 'column5') + * + * @return \ORM + */ + public function select_many_expr() + { + $columns = func_get_args(); + if (!empty($columns)) { + $columns = $this->_normalise_select_many_columns($columns); + foreach ($columns as $alias => $column) { + if (is_numeric($alias)) { + $alias = null; + } + $this->select_expr($column, $alias); + } + } + return $this; + } + + /** + * Take a column specification for the select many methods and convert it + * into a normalised array of columns and aliases. + * + * It is designed to turn the following styles into a normalised array: + * + * array(array('alias' => 'column', 'column2', 'alias2' => 'column3'), 'column4', 'column5')) + * + * @param array $columns + * @return array + */ + protected function _normalise_select_many_columns($columns) + { + $return = array(); + foreach ($columns as $column) { + if (is_array($column)) { + foreach ($column as $key => $value) { + if (!is_numeric($key)) { + $return[$key] = $value; + } else { + $return[] = $value; + } + } + } else { + $return[] = $column; + } + } + return $return; + } + + /** + * Add a DISTINCT keyword before the list of columns in the SELECT query + */ + public function distinct() + { + $this->_distinct = true; + return $this; + } + + /** + * Internal method to add a JOIN source to the query. + * + * The join_operator should be one of INNER, LEFT OUTER, CROSS etc - this + * will be prepended to JOIN. + * + * The table should be the name of the table to join to. + * + * The constraint may be either a string or an array with three elements. If it + * is a string, it will be compiled into the query as-is, with no escaping. The + * recommended way to supply the constraint is as an array with three elements: + * + * first_column, operator, second_column + * + * Example: array('user.id', '=', 'profile.user_id') + * + * will compile to + * + * ON `user`.`id` = `profile`.`user_id` + * + * The final (optional) argument specifies an alias for the joined table. + */ + protected function _add_join_source($join_operator, $table, $constraint, $table_alias = null) + { + + $join_operator = trim("{$join_operator} JOIN"); + + $table = $this->_quote_identifier($table); + + // Add table alias if present + if (!is_null($table_alias)) { + $table_alias = $this->_quote_identifier($table_alias); + $table .= " {$table_alias}"; + } + + // Build the constraint + if (is_array($constraint)) { + list($first_column, $operator, $second_column) = $constraint; + $first_column = $this->_quote_identifier($first_column); + $second_column = $this->_quote_identifier($second_column); + $constraint = "{$first_column} {$operator} {$second_column}"; + } + + $this->_join_sources[] = "{$join_operator} {$table} ON {$constraint}"; + return $this; + } + + /** + * Add a RAW JOIN source to the query + */ + public function raw_join($table, $constraint, $table_alias, $parameters = array()) + { + // Add table alias if present + if (!is_null($table_alias)) { + $table_alias = $this->_quote_identifier($table_alias); + $table .= " {$table_alias}"; + } + + $this->_values = array_merge($this->_values, $parameters); + + // Build the constraint + if (is_array($constraint)) { + list($first_column, $operator, $second_column) = $constraint; + $first_column = $this->_quote_identifier($first_column); + $second_column = $this->_quote_identifier($second_column); + $constraint = "{$first_column} {$operator} {$second_column}"; + } + + $this->_join_sources[] = "{$table} ON {$constraint}"; + return $this; + } + + /** + * Add a simple JOIN source to the query + */ + public function join($table, $constraint, $table_alias = null) + { + return $this->_add_join_source("", $table, $constraint, $table_alias); + } + + /** + * Add an INNER JOIN souce to the query + */ + public function inner_join($table, $constraint, $table_alias = null) + { + return $this->_add_join_source("INNER", $table, $constraint, $table_alias); + } + + /** + * Add a LEFT OUTER JOIN souce to the query + */ + public function left_outer_join($table, $constraint, $table_alias = null) + { + return $this->_add_join_source("LEFT OUTER", $table, $constraint, $table_alias); + } + + /** + * Add an RIGHT OUTER JOIN souce to the query + */ + public function right_outer_join($table, $constraint, $table_alias = null) + { + return $this->_add_join_source("RIGHT OUTER", $table, $constraint, $table_alias); + } + + /** + * Add an FULL OUTER JOIN souce to the query + */ + public function full_outer_join($table, $constraint, $table_alias = null) + { + return $this->_add_join_source("FULL OUTER", $table, $constraint, $table_alias); + } + + /** + * Internal method to add a HAVING condition to the query + */ + protected function _add_having($fragment, $values = array()) + { + return $this->_add_condition('having', $fragment, $values); + } + + /** + * Internal method to add a HAVING condition to the query + */ + protected function _add_simple_having($column_name, $separator, $value) + { + return $this->_add_simple_condition('having', $column_name, $separator, $value); + } + + /** + * Internal method to add a HAVING clause with multiple values (like IN and NOT IN) + */ + public function _add_having_placeholder($column_name, $separator, $values) + { + if (!is_array($column_name)) { + $data = array($column_name => $values); + } else { + $data = $column_name; + } + $result = $this; + foreach ($data as $key => $val) { + $column = $result->_quote_identifier($key); + $placeholders = $result->_create_placeholders($val); + $result = $result->_add_having("{$column} {$separator} ({$placeholders})", $val); + } + return $result; + } + + /** + * Internal method to add a HAVING clause with no parameters(like IS NULL and IS NOT NULL) + */ + public function _add_having_no_value($column_name, $operator) + { + $conditions = (is_array($column_name)) ? $column_name : array($column_name); + $result = $this; + foreach ($conditions as $column) { + $column = $this->_quote_identifier($column); + $result = $result->_add_having("{$column} {$operator}"); + } + return $result; + } + + /** + * Internal method to add a WHERE condition to the query + */ + protected function _add_where($fragment, $values = array()) + { + return $this->_add_condition('where', $fragment, $values); + } + + /** + * Internal method to add a WHERE condition to the query + */ + protected function _add_simple_where($column_name, $separator, $value) + { + return $this->_add_simple_condition('where', $column_name, $separator, $value); + } + + /** + * Add a WHERE clause with multiple values (like IN and NOT IN) + */ + public function _add_where_placeholder($column_name, $separator, $values) + { + if (!is_array($column_name)) { + $data = array($column_name => $values); + } else { + $data = $column_name; + } + $result = $this; + foreach ($data as $key => $val) { + $column = $result->_quote_identifier($key); + $placeholders = $result->_create_placeholders($val); + $result = $result->_add_where("{$column} {$separator} ({$placeholders})", $val); + } + return $result; + } + + /** + * Add a WHERE clause with no parameters(like IS NULL and IS NOT NULL) + */ + public function _add_where_no_value($column_name, $operator) + { + $conditions = (is_array($column_name)) ? $column_name : array($column_name); + $result = $this; + foreach ($conditions as $column) { + $column = $this->_quote_identifier($column); + $result = $result->_add_where("{$column} {$operator}"); + } + return $result; + } + + /** + * Internal method to add a HAVING or WHERE condition to the query + */ + protected function _add_condition($type, $fragment, $values = array()) + { + $conditions_class_property_name = "_{$type}_conditions"; + if (!is_array($values)) { + $values = array($values); + } + array_push($this->$conditions_class_property_name, array( + self::CONDITION_FRAGMENT => $fragment, + self::CONDITION_VALUES => $values, + )); + return $this; + } + + /** + * Helper method to compile a simple COLUMN SEPARATOR VALUE + * style HAVING or WHERE condition into a string and value ready to + * be passed to the _add_condition method. Avoids duplication + * of the call to _quote_identifier + * + * If column_name is an associative array, it will add a condition for each column + */ + protected function _add_simple_condition($type, $column_name, $separator, $value) + { + $multiple = is_array($column_name) ? $column_name : array($column_name => $value); + $result = $this; + + foreach ($multiple as $key => $val) { + // Add the table name in case of ambiguous columns + if (count($result->_join_sources) > 0 && strpos($key, '.') === false) { + $table = $result->_table_name; + if (!is_null($result->_table_alias)) { + $table = $result->_table_alias; + } + + $key = "{$table}.{$key}"; + } + $key = $result->_quote_identifier($key); + $result = $result->_add_condition($type, "{$key} {$separator} ?", $val); + } + return $result; + } + + /** + * Return a string containing the given number of question marks, + * separated by commas. Eg "?, ?, ?" + */ + protected function _create_placeholders($fields) + { + if (!empty($fields)) { + $db_fields = array(); + foreach ($fields as $key => $value) { + // Process expression fields directly into the query + if (array_key_exists($key, $this->_expr_fields)) { + $db_fields[] = $value; + } else { + $db_fields[] = '?'; + } + } + return implode(', ', $db_fields); + } + } + + /** + * Helper method that filters a column/value array returning only those + * columns that belong to a compound primary key. + * + * If the key contains a column that does not exist in the given array, + * a null value will be returned for it. + */ + protected function _get_compound_id_column_values($value) + { + $filtered = array(); + foreach ($this->_get_id_column_name() as $key) { + $filtered[$key] = isset($value[$key]) ? $value[$key] : null; + } + return $filtered; + } + + /** + * Helper method that filters an array containing compound column/value + * arrays. + */ + protected function _get_compound_id_column_values_array($values) + { + $filtered = array(); + foreach ($values as $value) { + $filtered[] = $this->_get_compound_id_column_values($value); + } + return $filtered; + } + + /** + * Add a WHERE column = value clause to your query. Each time + * this is called in the chain, an additional WHERE will be + * added, and these will be ANDed together when the final query + * is built. + * + * If you use an array in $column_name, a new clause will be + * added for each element. In this case, $value is ignored. + */ + public function where($column_name, $value = null) + { + return $this->where_equal($column_name, $value); + } + + /** + * More explicitly named version of for the where() method. + * Can be used if preferred. + */ + public function where_equal($column_name, $value = null) + { + return $this->_add_simple_where($column_name, '=', $value); + } + + /** + * Add a WHERE column != value clause to your query. + */ + public function where_not_equal($column_name, $value = null) + { + return $this->_add_simple_where($column_name, '!=', $value); + } + + /** + * Special method to query the table by its primary key + * + * If primary key is compound, only the columns that + * belong to they key will be used for the query + */ + public function where_id_is($id) + { + return (is_array($this->_get_id_column_name())) ? + $this->where($this->_get_compound_id_column_values($id), null) : + $this->where($this->_get_id_column_name(), $id); + } + + /** + * Allows adding a WHERE clause that matches any of the conditions + * specified in the array. Each element in the associative array will + * be a different condition, where the key will be the column name. + * + * By default, an equal operator will be used against all columns, but + * it can be overriden for any or every column using the second parameter. + * + * Each condition will be ORed together when added to the final query. + */ + public function where_any_is($values, $operator = '=') + { + $data = array(); + $query = array("(("); + $first = true; + foreach ($values as $value) { + if ($first) { + $first = false; + } else { + $query[] = ") OR ("; + } + $firstsub = true; + foreach ($value as $key => $item) { + $op = is_string($operator) ? $operator : (isset($operator[$key]) ? $operator[$key] : '='); + if ($firstsub) { + $firstsub = false; + } else { + $query[] = "AND"; + } + $query[] = $this->_quote_identifier($key); + $data[] = $item; + $query[] = $op . " ?"; + } + } + $query[] = "))"; + return $this->where_raw(join(' ', $query), $data); + } + + /** + * Similar to where_id_is() but allowing multiple primary keys. + * + * If primary key is compound, only the columns that + * belong to they key will be used for the query + */ + public function where_id_in($ids) + { + return (is_array($this->_get_id_column_name())) ? + $this->where_any_is($this->_get_compound_id_column_values_array($ids)) : + $this->where_in($this->_get_id_column_name(), $ids); + } + + /** + * Add a WHERE ... LIKE clause to your query. + */ + public function where_like($column_name, $value = null) + { + return $this->_add_simple_where($column_name, 'LIKE', $value); + } + + /** + * Add where WHERE ... NOT LIKE clause to your query. + */ + public function where_not_like($column_name, $value = null) + { + return $this->_add_simple_where($column_name, 'NOT LIKE', $value); + } + + /** + * Add a WHERE ... > clause to your query + */ + public function where_gt($column_name, $value = null) + { + return $this->_add_simple_where($column_name, '>', $value); + } + + /** + * Add a WHERE ... < clause to your query + */ + public function where_lt($column_name, $value = null) + { + return $this->_add_simple_where($column_name, '<', $value); + } + + /** + * Add a WHERE ... >= clause to your query + */ + public function where_gte($column_name, $value = null) + { + return $this->_add_simple_where($column_name, '>=', $value); + } + + /** + * Add a WHERE ... <= clause to your query + */ + public function where_lte($column_name, $value = null) + { + return $this->_add_simple_where($column_name, '<=', $value); + } + + /** + * Add a WHERE ... IN clause to your query + */ + public function where_in($column_name, $values) + { + return $this->_add_where_placeholder($column_name, 'IN', $values); + } + + /** + * Add a WHERE ... NOT IN clause to your query + */ + public function where_not_in($column_name, $values) + { + return $this->_add_where_placeholder($column_name, 'NOT IN', $values); + } + + /** + * Add a WHERE column IS NULL clause to your query + */ + public function where_null($column_name) + { + return $this->_add_where_no_value($column_name, "IS NULL"); + } + + /** + * Add a WHERE column IS NOT NULL clause to your query + */ + public function where_not_null($column_name) + { + return $this->_add_where_no_value($column_name, "IS NOT NULL"); + } + + /** + * Add a raw WHERE clause to the query. The clause should + * contain question mark placeholders, which will be bound + * to the parameters supplied in the second argument. + */ + public function where_raw($clause, $parameters = array()) + { + return $this->_add_where($clause, $parameters); + } + + /** + * Add a LIMIT to the query + */ + public function limit($limit) + { + $this->_limit = $limit; + return $this; + } + + /** + * Add an OFFSET to the query + */ + public function offset($offset) + { + $this->_offset = $offset; + return $this; + } + + /** + * Add an ORDER BY clause to the query + */ + protected function _add_order_by($column_name, $ordering) + { + $column_name = $this->_quote_identifier($column_name); + $this->_order_by[] = "{$column_name} {$ordering}"; + return $this; + } + + /** + * Add an ORDER BY column DESC clause + */ + public function order_by_desc($column_name) + { + return $this->_add_order_by($column_name, 'DESC'); + } + + /** + * Add an ORDER BY column ASC clause + */ + public function order_by_asc($column_name) + { + return $this->_add_order_by($column_name, 'ASC'); + } + + /** + * Add an unquoted expression as an ORDER BY clause + */ + public function order_by_expr($clause) + { + $this->_order_by[] = $clause; + return $this; + } + + /** + * Add a column to the list of columns to GROUP BY + */ + public function group_by($column_name) + { + $column_name = $this->_quote_identifier($column_name); + $this->_group_by[] = $column_name; + return $this; + } + + /** + * Add an unquoted expression to the list of columns to GROUP BY + */ + public function group_by_expr($expr) + { + $this->_group_by[] = $expr; + return $this; + } + + /** + * Add a HAVING column = value clause to your query. Each time + * this is called in the chain, an additional HAVING will be + * added, and these will be ANDed together when the final query + * is built. + * + * If you use an array in $column_name, a new clause will be + * added for each element. In this case, $value is ignored. + */ + public function having($column_name, $value = null) + { + return $this->having_equal($column_name, $value); + } + + /** + * More explicitly named version of for the having() method. + * Can be used if preferred. + */ + public function having_equal($column_name, $value = null) + { + return $this->_add_simple_having($column_name, '=', $value); + } + + /** + * Add a HAVING column != value clause to your query. + */ + public function having_not_equal($column_name, $value = null) + { + return $this->_add_simple_having($column_name, '!=', $value); + } + + /** + * Special method to query the table by its primary key. + * + * If primary key is compound, only the columns that + * belong to they key will be used for the query + */ + public function having_id_is($id) + { + return (is_array($this->_get_id_column_name())) ? + $this->having($this->_get_compound_id_column_values($id), null) : + $this->having($this->_get_id_column_name(), $id); + } + + /** + * Add a HAVING ... LIKE clause to your query. + */ + public function having_like($column_name, $value = null) + { + return $this->_add_simple_having($column_name, 'LIKE', $value); + } + + /** + * Add where HAVING ... NOT LIKE clause to your query. + */ + public function having_not_like($column_name, $value = null) + { + return $this->_add_simple_having($column_name, 'NOT LIKE', $value); + } + + /** + * Add a HAVING ... > clause to your query + */ + public function having_gt($column_name, $value = null) + { + return $this->_add_simple_having($column_name, '>', $value); + } + + /** + * Add a HAVING ... < clause to your query + */ + public function having_lt($column_name, $value = null) + { + return $this->_add_simple_having($column_name, '<', $value); + } + + /** + * Add a HAVING ... >= clause to your query + */ + public function having_gte($column_name, $value = null) + { + return $this->_add_simple_having($column_name, '>=', $value); + } + + /** + * Add a HAVING ... <= clause to your query + */ + public function having_lte($column_name, $value = null) + { + return $this->_add_simple_having($column_name, '<=', $value); + } + + /** + * Add a HAVING ... IN clause to your query + */ + public function having_in($column_name, $values = null) + { + return $this->_add_having_placeholder($column_name, 'IN', $values); + } + + /** + * Add a HAVING ... NOT IN clause to your query + */ + public function having_not_in($column_name, $values = null) + { + return $this->_add_having_placeholder($column_name, 'NOT IN', $values); + } + + /** + * Add a HAVING column IS NULL clause to your query + */ + public function having_null($column_name) + { + return $this->_add_having_no_value($column_name, 'IS NULL'); + } + + /** + * Add a HAVING column IS NOT NULL clause to your query + */ + public function having_not_null($column_name) + { + return $this->_add_having_no_value($column_name, 'IS NOT NULL'); + } + + /** + * Add a raw HAVING clause to the query. The clause should + * contain question mark placeholders, which will be bound + * to the parameters supplied in the second argument. + */ + public function having_raw($clause, $parameters = array()) + { + return $this->_add_having($clause, $parameters); + } + + /** + * Build a SELECT statement based on the clauses that have + * been passed to this instance by chaining method calls. + */ + protected function _build_select() + { + // If the query is raw, just set the $this->_values to be + // the raw query parameters and return the raw query + if ($this->_is_raw_query) { + $this->_values = $this->_raw_parameters; + return $this->_raw_query; + } + + // Build and return the full SELECT statement by concatenating + // the results of calling each separate builder method. + return $this->_join_if_not_empty(" ", array( + $this->_build_select_start(), + $this->_build_join(), + $this->_build_where(), + $this->_build_group_by(), + $this->_build_having(), + $this->_build_order_by(), + $this->_build_limit(), + $this->_build_offset(), + )); + } + + /** + * Build the start of the SELECT statement + */ + protected function _build_select_start() + { + $fragment = 'SELECT '; + $result_columns = join(', ', $this->_result_columns); + + if ( + !is_null($this->_limit) && + self::$_config[$this->_connection_name]['limit_clause_style'] === ORM::LIMIT_STYLE_TOP_N + ) { + $fragment .= "TOP {$this->_limit} "; + } + + if ($this->_distinct) { + $result_columns = 'DISTINCT ' . $result_columns; + } + + $fragment .= "{$result_columns} FROM " . $this->_quote_identifier($this->_table_name); + + if (!is_null($this->_table_alias)) { + $fragment .= " " . $this->_quote_identifier($this->_table_alias); + } + return $fragment; + } + + /** + * Build the JOIN sources + */ + protected function _build_join() + { + if (count($this->_join_sources) === 0) { + return ''; + } + + return join(" ", $this->_join_sources); + } + + /** + * Build the WHERE clause(s) + */ + protected function _build_where() + { + return $this->_build_conditions('where'); + } + + /** + * Build the HAVING clause(s) + */ + protected function _build_having() + { + return $this->_build_conditions('having'); + } + + /** + * Build GROUP BY + */ + protected function _build_group_by() + { + if (count($this->_group_by) === 0) { + return ''; + } + return "GROUP BY " . join(", ", $this->_group_by); + } + + /** + * Build a WHERE or HAVING clause + * @param string $type + * @return string + */ + protected function _build_conditions($type) + { + $conditions_class_property_name = "_{$type}_conditions"; + // If there are no clauses, return empty string + if (count($this->$conditions_class_property_name) === 0) { + return ''; + } + + $conditions = array(); + foreach ($this->$conditions_class_property_name as $condition) { + $conditions[] = $condition[self::CONDITION_FRAGMENT]; + $this->_values = array_merge($this->_values, $condition[self::CONDITION_VALUES]); + } + + return strtoupper($type) . " " . join(" AND ", $conditions); + } + + /** + * Build ORDER BY + */ + protected function _build_order_by() + { + if (count($this->_order_by) === 0) { + return ''; + } + return "ORDER BY " . join(", ", $this->_order_by); + } + + /** + * Build LIMIT + */ + protected function _build_limit() + { + $fragment = ''; + if ( + !is_null($this->_limit) && + self::$_config[$this->_connection_name]['limit_clause_style'] == ORM::LIMIT_STYLE_LIMIT + ) { + if (self::get_db($this->_connection_name)->getAttribute(PDO::ATTR_DRIVER_NAME) == 'firebird') { + $fragment = 'ROWS'; + } else { + $fragment = 'LIMIT'; + } + $fragment .= " {$this->_limit}"; + } + return $fragment; + } + + /** + * Build OFFSET + */ + protected function _build_offset() + { + if (!is_null($this->_offset)) { + $clause = 'OFFSET'; + if (self::get_db($this->_connection_name)->getAttribute(PDO::ATTR_DRIVER_NAME) == 'firebird') { + $clause = 'TO'; + } + return "$clause " . $this->_offset; + } + return ''; + } + + /** + * Wrapper around PHP's join function which + * only adds the pieces if they are not empty. + */ + protected function _join_if_not_empty($glue, $pieces) + { + $filtered_pieces = array(); + foreach ($pieces as $piece) { + if (is_string($piece)) { + $piece = trim($piece); + } + if (!empty($piece)) { + $filtered_pieces[] = $piece; + } + } + return join($glue, $filtered_pieces); + } + + /** + * Quote a string that is used as an identifier + * (table names, column names etc). This method can + * also deal with dot-separated identifiers eg table.column + */ + protected function _quote_one_identifier($identifier) + { + $parts = explode('.', $identifier); + $parts = array_map(array($this, '_quote_identifier_part'), $parts); + return join('.', $parts); + } + + /** + * Quote a string that is used as an identifier + * (table names, column names etc) or an array containing + * multiple identifiers. This method can also deal with + * dot-separated identifiers eg table.column + */ + protected function _quote_identifier($identifier) + { + if (is_array($identifier)) { + $result = array_map(array($this, '_quote_one_identifier'), $identifier); + return join(', ', $result); + } else { + return $this->_quote_one_identifier($identifier); + } + } + + /** + * This method performs the actual quoting of a single + * part of an identifier, using the identifier quote + * character specified in the config (or autodetected). + */ + protected function _quote_identifier_part($part) + { + if ($part === '*') { + return $part; + } + + $quote_character = self::$_config[$this->_connection_name]['identifier_quote_character']; + // double up any identifier quotes to escape them + return $quote_character . + str_replace( + $quote_character, + $quote_character . $quote_character, + $part + ) . $quote_character; + } + + /** + * Create a cache key for the given query and parameters. + */ + protected static function _create_cache_key($query, $parameters, $table_name = null, $connection_name = self::DEFAULT_CONNECTION) + { + if (isset(self::$_config[$connection_name]['create_cache_key']) and is_callable(self::$_config[$connection_name]['create_cache_key'])) { + return call_user_func_array(self::$_config[$connection_name]['create_cache_key'], array($query, $parameters, $table_name, $connection_name)); + } + $parameter_string = join(',', $parameters); + $key = $query . ':' . $parameter_string; + return sha1($key); + } + + /** + * Check the query cache for the given cache key. If a value + * is cached for the key, return the value. Otherwise, return false. + */ + protected static function _check_query_cache($cache_key, $table_name = null, $connection_name = self::DEFAULT_CONNECTION) + { + if (isset(self::$_config[$connection_name]['check_query_cache']) and is_callable(self::$_config[$connection_name]['check_query_cache'])) { + return call_user_func_array(self::$_config[$connection_name]['check_query_cache'], array($cache_key, $table_name, $connection_name)); + } elseif (isset(self::$_query_cache[$connection_name][$cache_key])) { + return self::$_query_cache[$connection_name][$cache_key]; + } + return false; + } + + /** + * Clear the query cache + */ + public static function clear_cache($table_name = null, $connection_name = self::DEFAULT_CONNECTION) + { + self::$_query_cache = array(); + if (isset(self::$_config[$connection_name]['clear_cache']) and is_callable(self::$_config[$connection_name]['clear_cache'])) { + return call_user_func_array(self::$_config[$connection_name]['clear_cache'], array($table_name, $connection_name)); + } + } + + /** + * Add the given value to the query cache. + */ + protected static function _cache_query_result($cache_key, $value, $table_name = null, $connection_name = self::DEFAULT_CONNECTION) + { + if (isset(self::$_config[$connection_name]['cache_query_result']) and is_callable(self::$_config[$connection_name]['cache_query_result'])) { + return call_user_func_array(self::$_config[$connection_name]['cache_query_result'], array($cache_key, $value, $table_name, $connection_name)); + } elseif (!isset(self::$_query_cache[$connection_name])) { + self::$_query_cache[$connection_name] = array(); + } + self::$_query_cache[$connection_name][$cache_key] = $value; + } + + /** + * Execute the SELECT query that has been built up by chaining methods + * on this class. Return an array of rows as associative arrays. + */ + protected function _run() + { + $query = $this->_build_select(); + $caching_enabled = self::$_config[$this->_connection_name]['caching']; + + if ($caching_enabled) { + $cache_key = self::_create_cache_key($query, $this->_values, $this->_table_name, $this->_connection_name); + $cached_result = self::_check_query_cache($cache_key, $this->_table_name, $this->_connection_name); + + if ($cached_result !== false) { + $this->_reset_idiorm_state(); + return $cached_result; + } + } + + self::_execute($query, $this->_values, $this->_connection_name); + $statement = self::get_last_statement(); + + $rows = array(); + while ($row = $statement->fetch(PDO::FETCH_ASSOC)) { + $rows[] = $row; + } + + if ($caching_enabled) { + self::_cache_query_result($cache_key, $rows, $this->_table_name, $this->_connection_name); + } + + $this->_reset_idiorm_state(); + return $rows; + } + + /** + * Reset the Idiorm instance state + */ + private function _reset_idiorm_state() + { + $this->_values = array(); + $this->_result_columns = array('*'); + $this->_using_default_result_columns = true; + } + + /** + * Return the raw data wrapped by this ORM + * instance as an associative array. Column + * names may optionally be supplied as arguments, + * if so, only those keys will be returned. + */ + public function as_array() + { + if (func_num_args() === 0) { + return $this->_data; + } + $args = func_get_args(); + return array_intersect_key($this->_data, array_flip($args)); + } + + /** + * Return the value of a property of this object (database row) + * or null if not present. + * + * If a column-names array is passed, it will return a associative array + * with the value of each column or null if it is not present. + */ + public function get($key) + { + if (is_array($key)) { + $result = array(); + foreach ($key as $column) { + $result[$column] = isset($this->_data[$column]) ? $this->_data[$column] : null; + } + return $result; + } else { + return isset($this->_data[$key]) ? $this->_data[$key] : null; + } + } + + /** + * Return the name of the column in the database table which contains + * the primary key ID of the row. + */ + protected function _get_id_column_name() + { + if (!is_null($this->_instance_id_column)) { + return $this->_instance_id_column; + } + if (isset(self::$_config[$this->_connection_name]['id_column_overrides'][$this->_table_name])) { + return self::$_config[$this->_connection_name]['id_column_overrides'][$this->_table_name]; + } + return self::$_config[$this->_connection_name]['id_column']; + } + + /** + * Get the primary key ID of this object. + */ + public function id($disallow_null = false) + { + $id = $this->get($this->_get_id_column_name()); + + if ($disallow_null) { + if (is_array($id)) { + foreach ($id as $id_part) { + if ($id_part === null) { + throw new Exception('Primary key ID contains null value(s)'); + } + } + } else if ($id === null) { + throw new Exception('Primary key ID missing from row or is null'); + } + } + + return $id; + } + + /** + * Set a property to a particular value on this object. + * To set multiple properties at once, pass an associative array + * as the first parameter and leave out the second parameter. + * Flags the properties as 'dirty' so they will be saved to the + * database when save() is called. + */ + public function set($key, $value = null) + { + return $this->_set_orm_property($key, $value); + } + + /** + * Set a property to a particular value on this object. + * To set multiple properties at once, pass an associative array + * as the first parameter and leave out the second parameter. + * Flags the properties as 'dirty' so they will be saved to the + * database when save() is called. + * @param string|array $key + * @param string|null $value + */ + public function set_expr($key, $value = null) + { + return $this->_set_orm_property($key, $value, true); + } + + /** + * Set a property on the ORM object. + * @param string|array $key + * @param string|null $value + * @param bool $raw Whether this value should be treated as raw or not + */ + protected function _set_orm_property($key, $value = null, $expr = false) + { + if (!is_array($key)) { + $key = array($key => $value); + } + foreach ($key as $field => $value) { + $this->_data[$field] = $value; + $this->_dirty_fields[$field] = $value; + if (false === $expr and isset($this->_expr_fields[$field])) { + unset($this->_expr_fields[$field]); + } else if (true === $expr) { + $this->_expr_fields[$field] = true; + } + } + return $this; + } + + /** + * Check whether the given field has been changed since this + * object was saved. + */ + public function is_dirty($key) + { + return array_key_exists($key, $this->_dirty_fields); + } + + /** + * Check whether the model was the result of a call to create() or not + * @return bool + */ + public function is_new() + { + return $this->_is_new; + } + + /** + * Save any fields which have been modified on this object + * to the database. + */ + public function save() + { + $query = array(); + + // remove any expression fields as they are already baked into the query + $values = array_values(array_diff_key($this->_dirty_fields, $this->_expr_fields)); + + if (!$this->_is_new) { // UPDATE + // If there are no dirty values, do nothing + if (empty($values) && empty($this->_expr_fields)) { + return true; + } + $query = $this->_build_update(); + $id = $this->id(true); + if (is_array($id)) { + $values = array_merge($values, array_values($id)); + } else { + $values[] = $id; + } + } else { // INSERT + $query = $this->_build_insert(); + } + + $success = self::_execute($query, $values, $this->_connection_name); + $caching_auto_clear_enabled = self::$_config[$this->_connection_name]['caching_auto_clear']; + if ($caching_auto_clear_enabled) { + self::clear_cache($this->_table_name, $this->_connection_name); + } + // If we've just inserted a new record, set the ID of this object + if ($this->_is_new) { + $this->_is_new = false; + if ($this->count_null_id_columns() != 0) { + $db = self::get_db($this->_connection_name); + if ($db->getAttribute(PDO::ATTR_DRIVER_NAME) == 'pgsql') { + // it may return several columns if a compound primary + // key is used + $row = self::get_last_statement()->fetch(PDO::FETCH_ASSOC); + foreach ($row as $key => $value) { + $this->_data[$key] = $value; + } + } else { + $column = $this->_get_id_column_name(); + // if the primary key is compound, assign the last inserted id + // to the first column + if (is_array($column)) { + $column = reset($column); + } + $this->_data[$column] = $db->lastInsertId(); + } + } + } + + $this->_dirty_fields = $this->_expr_fields = array(); + return $success; + } + + /** + * Add a WHERE clause for every column that belongs to the primary key + */ + public function _add_id_column_conditions(&$query) + { + $query[] = "WHERE"; + $keys = is_array($this->_get_id_column_name()) ? $this->_get_id_column_name() : array($this->_get_id_column_name()); + $first = true; + foreach ($keys as $key) { + if ($first) { + $first = false; + } else { + $query[] = "AND"; + } + $query[] = $this->_quote_identifier($key); + $query[] = "= ?"; + } + } + + /** + * Build an UPDATE query + */ + protected function _build_update() + { + $query = array(); + $query[] = "UPDATE {$this->_quote_identifier($this->_table_name)} SET"; + + $field_list = array(); + foreach ($this->_dirty_fields as $key => $value) { + if (!array_key_exists($key, $this->_expr_fields)) { + $value = '?'; + } + $field_list[] = "{$this->_quote_identifier($key)} = $value"; + } + $query[] = join(", ", $field_list); + $this->_add_id_column_conditions($query); + return join(" ", $query); + } + + /** + * Build an INSERT query + */ + protected function _build_insert() + { + $query[] = "INSERT INTO"; + $query[] = $this->_quote_identifier($this->_table_name); + $field_list = array_map(array($this, '_quote_identifier'), array_keys($this->_dirty_fields)); + $query[] = "(" . join(", ", $field_list) . ")"; + $query[] = "VALUES"; + + $placeholders = $this->_create_placeholders($this->_dirty_fields); + $query[] = "({$placeholders})"; + + if (self::get_db($this->_connection_name)->getAttribute(PDO::ATTR_DRIVER_NAME) == 'pgsql') { + $query[] = 'RETURNING ' . $this->_quote_identifier($this->_get_id_column_name()); + } + + return join(" ", $query); + } + + /** + * Delete this record from the database + */ + public function delete() + { + $query = array( + "DELETE FROM", + $this->_quote_identifier($this->_table_name) + ); + $this->_add_id_column_conditions($query); + return self::_execute(join(" ", $query), is_array($this->id(true)) ? array_values($this->id(true)) : array($this->id(true)), $this->_connection_name); + } + + /** + * Delete many records from the database + */ + public function delete_many() + { + // Build and return the full DELETE statement by concatenating + // the results of calling each separate builder method. + $query = $this->_join_if_not_empty(" ", array( + "DELETE FROM", + $this->_quote_identifier($this->_table_name), + $this->_build_where(), + )); + + return self::_execute($query, $this->_values, $this->_connection_name); + } + + // --------------------- // + // --- ArrayAccess --- // + // --------------------- // + + #[\ReturnTypeWillChange] + public function offsetExists($key) + { + return array_key_exists($key, $this->_data); + } + + #[\ReturnTypeWillChange] + public function offsetGet($key) + { + return $this->get($key); + } + + #[\ReturnTypeWillChange] + public function offsetSet($key, $value) + { + if (is_null($key)) { + throw new InvalidArgumentException('You must specify a key/array index.'); + } + $this->set($key, $value); + } + + #[\ReturnTypeWillChange] + public function offsetUnset($key) + { + unset($this->_data[$key]); + unset($this->_dirty_fields[$key]); + } + + // --------------------- // + // --- MAGIC METHODS --- // + // --------------------- // + public function __get($key) + { + return $this->offsetGet($key); + } + + public function __set($key, $value) + { + $this->offsetSet($key, $value); + } + + public function __unset($key) + { + $this->offsetUnset($key); + } + + + public function __isset($key) + { + return $this->offsetExists($key); + } + + /** + * Magic method to capture calls to undefined class methods. + * In this case we are attempting to convert camel case formatted + * methods into underscore formatted methods. + * + * This allows us to call ORM methods using camel case and remain + * backwards compatible. + * + * @param string $name + * @param array $arguments + * @return ORM + */ + public function __call($name, $arguments) + { + $method = strtolower(preg_replace('/([a-z])([A-Z])/', '$1_$2', $name)); + + if (method_exists($this, $method)) { + return call_user_func_array(array($this, $method), $arguments); + } else { + throw new IdiormMethodMissingException("Method $name() does not exist in class " . get_class($this)); + } + } + + /** + * Magic method to capture calls to undefined static class methods. + * In this case we are attempting to convert camel case formatted + * methods into underscore formatted methods. + * + * This allows us to call ORM methods using camel case and remain + * backwards compatible. + * + * @param string $name + * @param array $arguments + * @return ORM + */ + public static function __callStatic($name, $arguments) + { + $method = strtolower(preg_replace('/([a-z])([A-Z])/', '$1_$2', $name)); + + return call_user_func_array(array('ORM', $method), $arguments); + } +} + +/** + * A class to handle str_replace operations that involve quoted strings + * @example IdiormString::str_replace_outside_quotes('?', '%s', 'columnA = "Hello?" AND columnB = ?'); + * @example IdiormString::value('columnA = "Hello?" AND columnB = ?')->replace_outside_quotes('?', '%s'); + * @author Jeff Roberson