LIBAdmin.class.phpcheckKey($_SESSION['auth_key']);}else {return false;}}/** * Авторизоваться * @param type $login * @param type $pass * @return boolean * @throws Excetion */public static function authorize($login, $pass) {// ищем пользователя по логину$user_id = Database::value("select id from users where login='%s' and status=1;", array($login));if(!$user_id)thrownewExcetion('Пользователь не найден');// если находим - создаем объект и вызываем функцию авторизации$user = new Users($user_id);$auth_key = $user->auth($pass);// если успешено - пишем в сессию ключ авторизацииif($auth_key) {$_SESSION['user_id'] = $user->id;$_SESSION['auth_key'] = $auth_key;return true;}elsethrownewExcetion('Пользовательненайден');}/** * проверить сущетвование модуля * @paramstring $mod* @return bool|string */public static function modExists($mod) {$modfile = self::MOD_PATH.$mod.".php";if (in_array($mod, self::$MODULES) && file_exists($modfile))return $modfile;elsereturn false;}public static function username() {if(!empty($_SESSION['user_id'])) {$user = new Users($_SESSION['user_id']);return $user->name;}return false;}public static function userId() {if(!empty($_SESSION['user_id'])) {return intval($_SESSION['user_id']);}return false;}}Buyer.class.phpinput = $input;}}Database.class.phpconnection = new mysqli('localhost', 'user16468_test', '250288', 'user16468_test');$this->connection->query("SET NAMES 'utf8'");if ($this->connection->connect_errno) {throw new Exception($this->connection->connect_error, $this->connection->connect_errno);}}/** * получить соединение * @return mysqli */private static function getInstance() {if(!self::$instance)self::$instance = new Database();return self::$instance->connection;}/** * выполнить запрос * @param string $sql * @param array $placeholders агрументы длоя форматирования vprintf * @return array * @throws Exception */public static function query($sql, $placeholders = array()) {$connection = self::getInstance();if(!empty($placeholders)) {foreach($placeholders as &$ph) {$ph = $connection->real_escape_string($ph);}$sql = vsprintf($sql, $placeholders);}$result = $connection->query($sql);if(!$result) {throw new Exception($connection->error."\n\nQuery:\n".$sql, $connection->errono);} // не-select запросы if(is_bool($result))return $result;$res = array();while($row = $result->fetch_assoc()) {$res[] = $row;}return (empty($res)) ? false : $res;}/** * получить едиственный ряд * @paramstring $sql * @paramarray $placeholders агрументы длоя форматирования vprintf* @return mixed */public static function singleRow($sql, $placeholders=array()) {if($rows = self::query($sql, $placeholders)) {return $rows[0];}else {return false;}}/** * получить едиственный ряд * @paramstring $sql * @paramarray $placeholders агрументы длоя форматирования vprintf* @return mixed */public static function value($sql, $placeholders = array()) {if($rows = self::query($sql, $placeholders)) {$cnt = count($rows[0]);if($cnt == 1)return current($rows[0]);elseif($cnt>1)thrownewException("Более одного значения возвращено");elsethrownewException("Не возвращено ни одного значения");}else {returnfalse;}}/** * простой update записи по id с очисткой параметров * @paramstring $table - таблица для обновления * @paramarray $fields - ассоциативный массив с полями для обновлния * @paramint $id - id записи для обновления*/public static function simpleUpdate($table, $fields, $id) {$connection = self::getInstance();$id = intval($id);$update_str = "";// обходим массив с полями и экранируем данные, за одно и собираем строку запроса// используем замыкание для доступа к $connection и $update_str// ключи экранировать особого смысла нет, так как это не пользовательские данныеarray_walk($fields, function($f, $k) use($connection, &$update_str){$update_str .= $k." = '".$connection->real_escape_string($f)."',";});// обрежем лишнюю запятую в конце$update_str = trim($update_str,',');$sql = "update {$table} set {$update_str} where id={$id}";// выполняем запрос$q = self::query($sql);// если были измененные записи - все хорошоreturn ($q && $connection->affected_rows) ? true : false;} public static function simpleDelete($table, $id) {$connection = self::getInstance();$id = intval($id);$sql = "delete from {$table} where id = $id";// выполняем запрос$q = self::query($sql);// если были измененные записи - все хорошоreturn ($q && $connection->affected_rows) ? true : false;}public static function insert($table, $fields) {$connection = self::getInstance();// обходим массив с полями и экранируем данные// используем замыкание для доступа к $connection// ключи экранировать особого смысла нет, так как это не пользовательские данныеarray_walk($fields, function(&$f) use($connection){$f = $connection->real_escape_string($f);if($f==null) $f = 'null';else $f = "'{$f}'";});$sql = "insert into {$table} (".implode(',',array_keys($fields)).") values (".implode(',',array_values($fields)).")";$q = self::query($sql);// если были вставленные записи - все хорошоreturn ($q && $connection->affected_rows) ? $connection->insert_id : false;}}Order.class.phpid;foreach(Database::query($sql) as $good) {$goods[] = new OrderGood($good['id']);}return $goods;}/** * получить стоимость заказа * @parambool $delivery учитывать доставку* @return int */public function getCost($delivery=true) {$sql = "select (price * qty) as summ from order_goods where order_id=".$this->id;$cost = Database::value($sql);if($delivery) $cost += $this->delivery_cost;return $cost;}/** * Подтведрить заказ * @return bool */public function confirm() {$this->status = 5;return $this->save();}/** * Выполнить заказ * @return bool */public function complete() {$this->status = 10;return $this->save();}/** * Отменить заказ * @return bool*/publicfunctioncancel() {// при отмене заказа нужнео увеличить кол-во доступного к заказу товараforeach($this->getGoods() as $good) {$prod = new Product($good->prod_id);$prod->stock += $good->qty;$prod->save();}$this->status = 20;return $this->save();}/** * Перекрыть обновление * @return bool */public function update() {if($this->status != $this->data_db['status'])$this->date_status = date('Y-m-d H:i:s');return parent::update();}}OrderGood.class.phpprod_id);if($this->qty > $p->stock)throw new Exception("Невозможно заказать {$this->qty} шт. товара {$p->name}. Доступно {$p->stock} шт.");$p->stock -= $this->qty;$p->save();returnparent::create();}/** * При удалении позиции заказа увеличить кол-во доступного товара* @return bool */public function delete() {$p = new Product($this->prod_id);$p->stock += $this->qty;$p->save();return parent::delete();}protected function update() {// если изменилось кол-во в заказеif($this->qty != $this->data_db['qty']) {$p = new Product($this->prod_id);$delta = $this->qty - $this->data_db['qty'];// если кол-во увеличилост - нужно проверить хватит ли товара ещеif($delta > 0 && $delta > $p->stock) {throw new Exception("Невозможно заказать еще {$delta} шт. товара {$p->name}. Доступно {$p->stock} шт.");}// обновить кол-во доступного товара$p->stock -= $delta;$p->save();}return parent::update();}}OrdersController.class.phpinput['status']) || empty($this->input['delivery_cost']) || empty($this->input['delivery_address']) )thrownewException("Заполните все поля");if(empty($this->input['id']))throw new Exception('Не передан ID');$post = new Order(intval($this->input['id']));$post->status = $this->input['status'];$post->delivery_cost = intval($this->input['delivery_cost']);$post->delivery_address = $this->input['delivery_address'];$post->save();}}Posts.class.phpinput['title']) || empty($this->input['title']) || empty($this->input['status']) )thrownewException("Заполните все поля");$post = new Posts();$post->title = $this->input['title'];$post->text = $this->input['text'];$post->status = $this->input['status'];$post->user_id = Admin::userId();$post->save();}public function edit() {if(empty($this->input['title']) || empty($this->input['title']) || empty($this->input['status']) )thrownewException("Заполните все поля");if(empty($this->input['id']))throw new Exception('Не передан ID');$post = new Posts(intval($this->input['id']));$post->title = $this->input['title'];$post->text = $this->input['text'];$post->status = $this->input['status'];$post->save();}public function del() {if(empty($this->input['id']))throw new Exception('Не передан ID');$post = new Posts(intval($this->input['id']));$post->delete();}}Product.class.phpstatus = 0;return $this->update();}}ProductsController.class.phpinput[$mf]))thrownewException("Заполните все поля");}$post = new Product();$post->name = $this->input['name'];$post->description = $this->input['description'];$post->status = intval($this->input['status']);$post->price = (empty($this->input['price'])) ? 0 : intval($this->input['price']);$post->stock = (empty($this->input['stock'])) ? 0 : intval($this->input['stock']);$post->image_url = (empty($this->input['image_url'])) ? null : $this->input['image_url'];$post->save();}public function edit() {if(empty($this->input['id']))throw new Exception('Не передан ID');$mandatory = array('name','description','status'); foreach($mandatory as $mf) {if(empty($this->input[$mf]))thrownewException("Заполните все поля");}$post = new Product(intval($this->input['id']));$post->name = $this->input['name'];$post->description = $this->input['description'];$post->status = intval($this->input['status']);$post->price = (empty($this->input['price'])) ? 0 : intval($this->input['price']);$post->stock = (empty($this->input['stock'])) ? 0 : intval($this->input['stock']);$post->image_url = (empty($this->input['image_url'])) ? null : $this->input['image_url'];$post->save();}public function del() {if(empty($this->input['id']))throw new Exception('Не передан ID');$post = new Products(intval($this->input['id']));$post->delete();}}Record.class.phptable_fields))throw new Exception("[".get_called_class()."] поле $name не существует");return $this->data[$name];}/** * сеттерполейсущности * @param string $name * @param mixed $value */public function __set($name, $value) {if(!in_array($name, $this->table_fields))$this->name = $value;else$this->data[$name] = $value;}/** * конструктор * @paraminteger|null $id - id записи или null для создания новой*/public function __construct($id = null) {if($id) {$this->load($id);}else {$this->createEmpty();}}/** * сохранить изменения * @return bool */public function save() {if($this->id) return $this->update();elsereturn $this->create();}/** * удалить запись * @return boolean * @throws Exception */public function delete() {if(!Database::simpleDelete($this->table, $this->id)) {throw new Exception("[".get_called_class()."] ошибка удадения записи id ".$this->id);}$this->id = null;$this->data = $this->data_db = array();returntrue;}/** * загрузить данные из БД* @param integer $id * @return boolean * @throws Exception */protected function load($id) {//поля для загрузки из БД$fields = implode(',',$this->table_fields);$id = intval($id);// запрос на выборку записи$sql = "select id, {$fields} from {$this->table} where id=%d";$row = Database::singleRow($sql, array($id));//если запись не найденаif(!$row)throw new Exception("[".get_called_class()."] запись с id={$id} не найдена");// id пишем в публичное свойство$this->id = intval($row['id']);unset($row['id']);// а остальное - в массив данных для доступа через магические методы и облегчения работы с БД$this->data = $this->data_db = $row;returntrue;}/** * создать пустой объект * @returnboolean*/protected function createEmpty() {// заполняем все поля null'ами$this->data = array();$this->data_db = array_fill_keys($this->table_fields, null);returntrue;}/** * записать в БД обновления* @return boolean * @throws Exception */protected function update() {// пишем в базу только изменившиеся данные$affected = array();foreach($this->data as $k => $v) {if(isset($this->data_db[$k]) && $v != $this->data_db[$k]) {$affected[$k] = $v;}}// если ничего не изменилось - просто выходимif(empty($affected)) {return false;}if(!Database::simpleUpdate($this->table, $affected, $this->id)) {throw new Exception("[".get_called_class()."] ошибка обновления записи id ".$this->id);}array_merge($this->data_db, $this->data);returntrue;}/** * создать новую запись * @returnboolean* @throws Exception */protected function create() {if(empty($this->data)) {throw new Exception("[".get_called_class()."] пустой массив для создания записи");}if(!($id = Database::insert($this->table, $this->data))) {throw new Exception("[".get_called_class()."] ошибка добавления записи");}$this->id = intval($id);array_merge($this->data_db, $this->data);return $id;}}Users.class.phpsalt);}/** * сгенерировать ключ авторизации * @returnstring */private function authKey() {return sha1($this->password.$this->salt.date('d.m.Y H:i:s'));}/** * Установить новый пароль * @paramstring $new_pass* @throws Exception */public function changePassword($new_pass) {if(mb_strlen($new_pass) < 6)thrownewException("Пароль слишком короткий");// сделаем новую соль$new_salt = md5($new_pass);$this->salt = $new_salt;$this->password = $this->passPhrase($new_pass);}public function create() {$this->changePassword($this->password);parent::create();}/** * запрещаем удалять пользователей, делая их неактивными*/public function delete() {$this->status = 0;return $this->update();}/** * запрещаем деактивитваровть себя */public function update() {if($this->id==Admin::userId() && $this->status == 0)thrownewException("Нельзя отключить самого себя");parent::update();}/** * авторизовать по паролю * @paramtype $pass*/public function auth($pass) {$pass = $this->passPhrase($pass);if($pass == $this->password) {$key = $this->authKey();$this->auth_key = $key;$this->update();return $key;}elsereturn false;}/** * проверить ключ авторизации * @paramtype $key* @return type */public function checkKey($key) {return ($this->auth_key == $key); }}UsersController.class.phpinput['id']))throw new Exception('Не передан ID');$user = new Users(intval($this->input['id']));if(!empty($this->input['login']))$user->login = $this->input['login'];if(!empty($this->input['name']))$user->name = $this->input['name'];if(!empty($this->input['status']))$user->status = intval($this->input['status']);if(!empty($this->input['password']))$user->changePassword($this->input['password']);$user->save();}public function add() {$mandatory = array('name','login','password'); foreach($mandatory as $mf) {if(empty($this->input[$mf]))thrownewException("Заполните все поля");}$user = new Users();$user->name = $this->input['name'];$user->login = $this->input['login'];$user->password = $this->input['password'];$user->status = intval($this->input['status']);$user->save();}public function del() {if(empty($this->input['id']))throw new Exception('Не передан ID');$user = new Users(intval($this->input['id']));$user->delete();}}ADMINindex.php <link href="../lib_js/bootstrap/css/bootstrap.min.css" rel="stylesheet"><script src="../lib_js/jquery-2.2.3.min.js"></script><script src="../lib_js/bootstrap/js/bootstrap.min.js"></script><script src="../lib_js/jqgrid/js/grid.locale-ru.js" type="text/javascript"></script><script src="../lib_js/jqgrid/js/jquery.jqGrid.min.js" type="text/javascript"></script><link href="../lib_js/jqgrid/css/ui.jqgrid-bootstrap.css" rel="stylesheet"> login.phpgetMessage();}}?> <link href="../lib_js/bootstrap/css/bootstrap.min.css" rel="stylesheet"> ';}?> Логин Пароль Вход