query("SHOW TABLES LIKE '$table'");
return $stmt->rowCount() > 0;
} catch (PDOException $e) {
return false;
}
}
}
if (!function_exists('getProductRatingSafe')) {
function getProductRatingSafe($product_id) {
global $pdo;
if (!tableExistsSafe('product_reviews')) {
return ['avg' => 0, 'total' => 0];
}
try {
$stmt = $pdo->prepare("SELECT AVG(rating) as avg, COUNT(*) as total FROM product_reviews WHERE product_id = ? AND status = 'approved'");
$stmt->execute([$product_id]);
$row = $stmt->fetch(PDO::FETCH_ASSOC);
$avg = isset($row['avg']) ? (float)$row['avg'] : 0;
return ['avg' => round($avg, 1), 'total' => (int)($row['total'] ?? 0)];
} catch (PDOException $e) {
return ['avg' => 0, 'total' => 0];
}
}
}
if (!function_exists('inWishlistSafe')) {
function inWishlistSafe($user_id, $product_id) {
global $pdo;
if (!$user_id || !tableExistsSafe('wishlist')) return false;
try {
$stmt = $pdo->prepare("SELECT 1 FROM wishlist WHERE user_id = ? AND product_id = ?");
$stmt->execute([$user_id, $product_id]);
return (bool) $stmt->fetchColumn();
} catch (PDOException $e) {
return false;
}
}
}
if (!function_exists('fetchSectionSafe')) {
function fetchSectionSafe($sql, $params = []) {
global $pdo;
if (!tableExistsSafe('plumbing_products')) return [];
try {
$stmt = $pdo->prepare($sql);
$stmt->execute($params);
return $stmt->fetchAll(PDO::FETCH_ASSOC);
} catch (PDOException $e) {
return [];
}
}
}
// ============================================================
// Fixed subcategory for this page
// ============================================================
$fixed_subcategory = 'pvc_pipes';
// ============================================================
// Filters and sorting
// ============================================================
$subcategory = isset($_GET['subcategory']) ? trim($_GET['subcategory']) : '';
$min_price = isset($_GET['min_price']) ? (float)$_GET['min_price'] : 0;
$max_price = isset($_GET['max_price']) ? (float)$_GET['max_price'] : 0;
$search = isset($_GET['search']) ? trim($_GET['search']) : '';
$sort = isset($_GET['sort']) ? $_GET['sort'] : 'featured';
$page = isset($_GET['page']) ? max(1, (int)$_GET['page']) : 1;
$per_page = 12;
// ============================================================
// Build query
// ============================================================
$where = "subcategory = ?";
$params = [$fixed_subcategory];
if (!empty($subcategory) && $subcategory !== $fixed_subcategory) {
$where .= " AND subcategory = ?";
$params[] = $subcategory;
}
if ($min_price > 0) {
$where .= " AND price >= ?";
$params[] = $min_price;
}
if ($max_price > 0) {
$where .= " AND price <= ?";
$params[] = $max_price;
}
if (!empty($search)) {
$where .= " AND (name LIKE ? OR description LIKE ?)";
$search_term = '%' . $search . '%';
$params[] = $search_term;
$params[] = $search_term;
}
// ============================================================
// Count total
// ============================================================
$total_products = 0;
$total_pages = 0;
try {
if (tableExistsSafe('plumbing_products')) {
$count_sql = "SELECT COUNT(*) FROM plumbing_products WHERE $where";
$stmt = $pdo->prepare($count_sql);
$stmt->execute($params);
$total_products = $stmt->fetchColumn();
$total_pages = ceil($total_products / $per_page);
}
} catch (PDOException $e) {
// ignore
}
// ============================================================
// Build ORDER BY
// ============================================================
switch ($sort) {
case 'price_low': $order = "price ASC"; break;
case 'price_high': $order = "price DESC"; break;
case 'popular': $order = "sales DESC"; break;
case 'newest': $order = "created_at DESC"; break;
case 'featured':
default: $order = "created_at DESC"; break;
}
// ============================================================
// Fetch products
// ============================================================
$products = [];
try {
if (tableExistsSafe('plumbing_products')) {
$offset = ($page - 1) * $per_page;
$sql = "SELECT * FROM plumbing_products WHERE $where ORDER BY $order LIMIT ? OFFSET ?";
$params[] = $per_page;
$params[] = $offset;
$stmt = $pdo->prepare($sql);
$stmt->execute($params);
$products = $stmt->fetchAll(PDO::FETCH_ASSOC);
}
} catch (PDOException $e) {
$products = [];
}
// ============================================================
// Fetch all subcategories for dropdown
// ============================================================
$all_subcategories = [];
try {
if (tableExistsSafe('plumbing_products')) {
$stmt = $pdo->query("SELECT DISTINCT subcategory FROM plumbing_products ORDER BY subcategory");
$all_subcategories = $stmt->fetchAll(PDO::FETCH_COLUMN);
}
} catch (PDOException $e) {
// ignore
}
// ============================================================
// Fetch sections
// ============================================================
$featured = fetchSectionSafe("SELECT * FROM plumbing_products WHERE subcategory = ? ORDER BY RAND() LIMIT 8", [$fixed_subcategory]);
$best_sellers = fetchSectionSafe("SELECT * FROM plumbing_products WHERE subcategory = ? ORDER BY sales DESC LIMIT 8", [$fixed_subcategory]);
$new_arrivals = fetchSectionSafe("SELECT * FROM plumbing_products WHERE subcategory = ? ORDER BY created_at DESC LIMIT 8", [$fixed_subcategory]);
$special_offers = fetchSectionSafe("SELECT * FROM plumbing_products WHERE subcategory = ? AND price < (SELECT AVG(price) FROM plumbing_products WHERE subcategory = ?) * 0.8 LIMIT 8", [$fixed_subcategory, $fixed_subcategory]);
// ============================================================
// Recently viewed
// ============================================================
$recently_viewed = [];
if (isset($_SESSION['recently_viewed']) && tableExistsSafe('plumbing_products')) {
$ids = array_slice(array_reverse($_SESSION['recently_viewed']), 0, 6);
if (!empty($ids)) {
try {
$placeholders = implode(',', array_fill(0, count($ids), '?'));
$stmt = $pdo->prepare("SELECT * FROM plumbing_products WHERE id IN ($placeholders) AND subcategory = ? ORDER BY FIELD(id, " . implode(',', array_fill(0, count($ids), '?')) . ")");
$stmt->execute(array_merge($ids, [$fixed_subcategory], $ids));
$recently_viewed = $stmt->fetchAll(PDO::FETCH_ASSOC);
} catch (PDOException $e) {}
}
}
// ============================================================
// Get rating for each product
// ============================================================
$ratings = [];
foreach ($products as $p) {
$ratings[$p['id']] = getProductRatingSafe($p['id']);
}
// ============================================================
// Map subcategory to display name
// ============================================================
$subcategory_labels = [
'pvc_pipes' => 'PVC Pipes',
'water_tanks' => 'Water Tanks',
'taps' => 'Taps',
'fittings' => 'Fittings'
];
?>
PVC Pipes – Building Materials Uganda
PVC Pipes
Durable PVC pipes for plumbing, electrical conduit, and drainage applications.
Browse PVC Pipes
