Create PHP MVC app. Create pagination
Today I am fulfil request from one of my subscribers, who asked me to make pagination. For this purpose we need to use SQL query with LIMIT. Process is described in details in video.
Code lesson (Utils.php)
<?php
/**
* 1-ая - 5 продуктов
* 2-ая - с 6 по 10 продукт
* 3-я - с 11 по 15 продукт
* 5*(2-1)+1 = 6
* 5*(3-1)+1 = 11
* 5*(4-1)+1 = 16
* LIMIT $perPage*($page-1)+1, $itemsCount
* 15 -> 3
* 1 - 0-5
* 2 - 6- 10
* 3 - 11- 15
*/
class Utils {
public function drawPager($totalItems, $perPage) {
$pages = ceil($totalItems / $perPage);
if(!isset($_GET['page']) || intval($_GET['page']) == 0) {
$page = 1;
} else if (intval($_GET['page']) > $totalItems) {
$page = $pages;
} else {
$page = intval($_GET['page']);
}
$pager = "<nav aria-label='Page navigation'>";
$pager .= "<ul class='pagination'>";
$pager .= "<li><a href='/products?page=1' aria-label='Previous'><span aria-hidden='true'>«</span> Начало</a></li>";
for($i=2; $i<=$pages-1; $i++) {
$pager .= "<li><a href='/products?page=". $i."'>" . $i ."</a></li>";
}
$pager .= "<li><a href='/products?page=". $pages ."' aria-label='Next'>Конец <span aria-hidden='true'>»</span></a></li>";
$pager .= "</ul>";
return $pager;
}
}Code lesson (config.php)
<?php
session_start();
$_SERVER['DOCUMENT_ROOT'] = "/var/www/u0016495/data/www/cabinet.kamil-abzalov.ru";
define("ROOT", $_SERVER['DOCUMENT_ROOT']);
define("CONTROLLER_PATH", ROOT. "/controllers/");
define("MODEL_PATH", ROOT. "/models/");
define("VIEW_PATH", ROOT. "/views/");
define("UPLOAD_DIR", ROOT. "/uploads/");
define("UTILS", ROOT. "/utils/");
require_once("db.php");
require_once("route.php");
require_once UTILS . "Utils.php";
require_once MODEL_PATH. 'Model.php';
require_once VIEW_PATH. 'View.php';
require_once CONTROLLER_PATH. 'Controller.php';
Routing::buildRoute();Code lesson (ProductsController.php)
<?php
class ProductsController extends Controller {
private $pageTpl = "/views/products.tpl.php";
private $productsPerPage = 5;
public function __construct() {
$this->model = new ProductsModel();
$this->view = new View();
$this->utils = new Utils();
}
public function index() {
if(!$_SESSION['user']) {
header("Location: /");
}
$allProducts = count($this->model->getAllProducts());
$totalPages = ceil($allProducts / $this->productsPerPage);
$this->makeProductPager($allProducts, $totalPages);
$pagination = $this->utils->drawPager($allProducts, $this->productsPerPage);
$this->pageData['pagination'] = $pagination;
$this->pageData['title'] = "Товары";
// $this->pageData['productsOnPage'] = $this->model->getAllProducts();
$this->view->render($this->pageTpl, $this->pageData);
if($_FILES) {
if($_FILES['csv']['type'] != 'text/csv' || $_FILES['csv']['type'] == '') {
$this->pageData['errors'] = "Ошибка! Возможно данный файл имеет некорректный формат";
} else {
if(move_uploaded_file($_FILES['csv']['tmp_name'],UPLOAD_FOLDER.$_FILES['csv']['name'])) {
$file = fopen(UPLOAD_FOLDER.$_FILES['csv']['name'], "r");
$row = 1;
while($data = fgetcsv($file, 200, ";")) {
if($row == 1) {
$row++;
continue;
} else {
$this->model->addFromCSV($data);
}
}
fclose($file);
$this->model->getAllProducts();
}
}
}
}
public function getProduct() {
if(!$_SESSION['user']) {
header("Location: /");
return;
}
if(!isset($_GET['id'])) {
echo json_encode(array("success" => false));
} else {
$productId = $_GET['id'];
$productInfo = json_encode($this->model->getProductById($productId));
echo $productInfo;
}
}
public function saveProduct() {
if(!$_SESSION['user']) {
header("Location: /");
return;
}
if(!isset($_POST['id']) || trim($_POST['name']) == '' || trim($_POST['price']) == '') {
echo json_encode(array("success" => false, "text" => "Ошибка обновления данных"));
} else {
$productId = $_POST['id'];
$productName = strip_tags(trim($_POST['name']));
$productPrice = strip_tags(trim($_POST['price']));
echo json_encode(array("success" => true, "text" => "Информация о товаре обновлена"));
}
}
public function addProduct() {
if(!$_SESSION['user']) {
header("Location: /");
return;
}
if(empty($_POST) || trim($_POST['productName']) == '' || trim($_POST['productPrice']) == '') {
echo json_encode(array("success" => false, "text" => "Не удалось добавить товар"));
} else {
$productName = strip_tags(trim($_POST['productName']));
$productPrice = strip_tags(trim($_POST['productPrice']));
$this->model->addProduct($productName, $productPrice);
echo json_encode(array("success" => true, "text" => "Новый товар добавлен"));
}
}
public function deleteProduct() {
if(!$_SESSION['user']) {
header("Location: /");
return;
}
if(empty($_POST) || !isset($_POST['id'])) {
echo json_encode(array("success" => false));
} else {
$productId = $_POST['id'];
if($this->model->deleteProduct($productId)) {
echo json_encode(array("success" => true, "text" => "Товар удален"));
} else {
echo json_encode(array("success" => false, "text" => "Ошибка удаления товара"));
}
}
}
public function makeProductPager($allProducts, $totalPages) {
if(!isset($_GET['page']) || intval($_GET['page']) == 0 || intval($_GET['page']) == 1 || intval($_GET['page']) < 0) {
$pageNumber = 1;
$leftLimit = 0;
$rightLimit = $this->productsPerPage; // 0-5
} elseif (intval($_GET['page']) > $totalPages || intval($_GET['page']) == $totalPages) {
$pageNumber = $totalPages; // 2
$leftLimit = $this->productsPerPage * ($pageNumber - 1); // 5 * (2-1) = 6
$rightLimit = $allProducts; // 8
} else {
$pageNumber = intval($_GET['page']);
$leftLimit = $this->productsPerPage * ($pageNumber-1); // 5* (2-1) = 6
$rightLimit = $this->productsPerPage; // 5 -> (6,7,8,9,10)
}
$this->pageData['productsOnPage'] = $this->model->getLimitProducts($leftLimit, $rightLimit);
}
}
?>
Code lesson (ProductsModel.php)
<?php
class ProductsModel extends Model {
public function getAllProducts() {
$result = array();
$sql = "SELECT * FROM products";
$stmt = $this->db->prepare($sql);
$stmt->execute();
while($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
$result[$row['id']] = $row;
}
return $result;
}
public function getLimitProducts($leftLimit, $rightLimit) {
$result = array();
$sql = "SELECT * FROM products LIMIT :leftLimit, :rightLimit";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(":leftLimit", $leftLimit, PDO::PARAM_INT);
$stmt->bindValue(":rightLimit", $rightLimit, PDO::PARAM_INT);
$stmt->execute();
while($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
$result[$row['id']] = $row;
}
return $result;
}
public function addFromCSV($data) {
$sql = "INSERT INTO products(name, price) VALUES(:name, :price)";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(":name", $data[0], PDO::PARAM_STR);
$stmt->bindValue(":price", $data[1], PDO::PARAM_INT);
$stmt->execute();
}
public function getProductById($id) {
$result = array();
$sql = "SELECT * FROM products WHERE id = :id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(":id", $id, PDO::PARAM_INT);
$stmt->execute();
$result = $stmt->fetch(PDO::FETCH_ASSOC);
return $result;
}
public function saveProductInfo($id, $name, $price) {
$sql = "UPDATE products
SET price = :price, name = :name
WHERE id = :id
";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(":price", $price, PDO::PARAM_INT);
$stmt->bindValue(":name", $name, PDO::PARAM_STR);
$stmt->bindValue(":id", $id, PDO::PARAM_INT);
$stmt->execute();
return true;
}
public function addProduct($productName, $productPrice) {
$sql = "INSERT INTO products(name, price)
VALUES(:productName, :productPrice)
";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(":productName", $productName, PDO::PARAM_STR);
$stmt->bindValue(":productPrice", $productPrice, PDO::PARAM_INT);
$stmt->execute();
return true;
}
public function deleteProduct($id) {
$sql = "DELETE FROM products WHERE id = :id";
$stmt = $this->db->prepare($sql);
$stmt->bindValue(":id", $id, PDO::PARAM_INT);
$stmt->execute();
$count = $stmt->rowCount();
if($count > 0) {
return true;
} else {
return false;
}
}
}
?>
0 Comments