MokoSuiteField/source/packages/com_mokosuitefield/api/src/Controller/FieldEquipmentController.php

<?php
namespace Moko\Component\MokoSuiteField\Api\Controller;

defined('_JEXEC') or die;

use Joomla\CMS\Factory;
use Joomla\CMS\MVC\Controller\BaseController;
use Joomla\Database\DatabaseInterface;

/**
 * Equipment + Vehicles + Service Agreements API.
 *
 * GET    /equipment               — List equipment
 * GET    /equipment/{id}          — Equipment detail with service history
 * GET    /vehicles                — List vehicles (fleet)
 * GET    /vehicles/{id}/stock     — Truck stock for a vehicle
 * GET    /agreements              — List service agreements
 * GET    /agreements/{id}         — Agreement detail with WO history
 */
class FieldEquipmentController extends BaseController
{
	private function requireAuth(string $action = 'core.manage'): void
	{
		$user = Factory::getApplication()->getIdentity();
		if (!$user || $user->guest || (!$user->authorise('core.admin') && !$user->authorise($action, 'com_mokosuitefield'))) {
			http_response_code(403);
			echo json_encode(['error' => 'Access denied.']);
			Factory::getApplication()->close();
		}
	}

	public function listEquipment(): void
	{
		$this->requireAuth('core.manage');
		$db = Factory::getContainer()->get(DatabaseInterface::class);
		$input = Factory::getApplication()->getInput();

		$query = $db->getQuery(true)
			->select('eq.*, loc.name AS location_name, loc.address')
			->select('cd.name AS customer_name')
			->from($db->quoteName('#__mokosuitefield_equipment', 'eq'))
			->join('LEFT', $db->quoteName('#__mokosuitefield_locations', 'loc') . ' ON loc.id = eq.location_id')
			->join('LEFT', $db->quoteName('#__contact_details', 'cd') . ' ON cd.id = eq.contact_id')
			->order('eq.name ASC');

		$type = $input->getString('type', '');
		if ($type) $query->where($db->quoteName('eq.type') . ' = ' . $db->quote($type));

		$status = $input->getString('status', '');
		if ($status) $query->where($db->quoteName('eq.status') . ' = ' . $db->quote($status));

		$locationId = $input->getInt('location_id', 0);
		if ($locationId) $query->where('eq.location_id = ' . $locationId);

		$db->setQuery($query, 0, 100);
		$this->sendJson($db->loadObjectList() ?: []);
	}

	public function getEquipment(): void
	{
		$this->requireAuth('core.manage');
		$db = Factory::getContainer()->get(DatabaseInterface::class);
		$id = Factory::getApplication()->getInput()->getInt('id', 0);

		$db->setQuery($db->getQuery(true)
			->select('eq.*, loc.name AS location_name, loc.address, cd.name AS customer_name')
			->from($db->quoteName('#__mokosuitefield_equipment', 'eq'))
			->join('LEFT', $db->quoteName('#__mokosuitefield_locations', 'loc') . ' ON loc.id = eq.location_id')
			->join('LEFT', $db->quoteName('#__contact_details', 'cd') . ' ON cd.id = eq.contact_id')
			->where('eq.id = ' . $id));
		$equipment = $db->loadObject();

		if (!$equipment) {
			http_response_code(404);
			$this->sendJson(['error' => 'Equipment not found']);
			return;
		}

		// Service history
		$db->setQuery($db->getQuery(true)
			->select('wo.id, wo.wo_number, wo.description, wo.status, wo.completed_at, wo.trade')
			->from($db->quoteName('#__mokosuitefield_work_orders', 'wo'))
			->where('wo.equipment_id = ' . $id)
			->order('wo.scheduled_date DESC'), 0, 20);
		$equipment->service_history = $db->loadObjectList() ?: [];

		$this->sendJson($equipment);
	}

	public function listVehicles(): void
	{
		$this->requireAuth('core.manage');
		$db = Factory::getContainer()->get(DatabaseInterface::class);

		$db->setQuery($db->getQuery(true)
			->select('v.*, t_cd.name AS tech_name')
			->from($db->quoteName('#__mokosuitefield_vehicles', 'v'))
			->join('LEFT', $db->quoteName('#__mokosuitefield_technicians', 't') . ' ON t.id = v.technician_id')
			->join('LEFT', $db->quoteName('#__contact_details', 't_cd') . ' ON t_cd.id = t.contact_id')
			->order('v.vehicle_name ASC'));

		$this->sendJson($db->loadObjectList() ?: []);
	}

	public function truckStock(): void
	{
		$this->requireAuth('core.manage');
		$db = Factory::getContainer()->get(DatabaseInterface::class);
		$vehicleId = Factory::getApplication()->getInput()->getInt('id', 0);

		$db->setQuery($db->getQuery(true)
			->select('ts.*, p.title AS product_name')
			->from($db->quoteName('#__mokosuitefield_truck_stock', 'ts'))
			->join('LEFT', $db->quoteName('#__mokosuite_crm_products', 'p') . ' ON p.id = ts.product_id')
			->where('ts.vehicle_id = ' . $vehicleId)
			->order('p.title ASC'));

		$this->sendJson($db->loadObjectList() ?: []);
	}

	public function listAgreements(): void
	{
		$this->requireAuth('core.manage');
		$db = Factory::getContainer()->get(DatabaseInterface::class);
		$input = Factory::getApplication()->getInput();

		$query = $db->getQuery(true)
			->select('sa.*, cd.name AS customer_name, loc.address')
			->from($db->quoteName('#__mokosuitefield_service_agreements', 'sa'))
			->join('LEFT', $db->quoteName('#__contact_details', 'cd') . ' ON cd.id = sa.contact_id')
			->join('LEFT', $db->quoteName('#__mokosuitefield_locations', 'loc') . ' ON loc.id = sa.location_id')
			->order('sa.end_date ASC');

		$status = $input->getString('status', '');
		if ($status) $query->where($db->quoteName('sa.status') . ' = ' . $db->quote($status));

		$db->setQuery($query, 0, 100);
		$this->sendJson($db->loadObjectList() ?: []);
	}

	public function getAgreement(): void
	{
		$this->requireAuth('core.manage');
		$db = Factory::getContainer()->get(DatabaseInterface::class);
		$id = Factory::getApplication()->getInput()->getInt('id', 0);

		$db->setQuery($db->getQuery(true)
			->select('sa.*, cd.name AS customer_name, loc.name AS location_name, loc.address')
			->from($db->quoteName('#__mokosuitefield_service_agreements', 'sa'))
			->join('LEFT', $db->quoteName('#__contact_details', 'cd') . ' ON cd.id = sa.contact_id')
			->join('LEFT', $db->quoteName('#__mokosuitefield_locations', 'loc') . ' ON loc.id = sa.location_id')
			->where('sa.id = ' . $id));
		$agreement = $db->loadObject();

		if (!$agreement) {
			http_response_code(404);
			$this->sendJson(['error' => 'Agreement not found']);
			return;
		}

		// Work orders under this agreement
		$db->setQuery($db->getQuery(true)
			->select('wo.id, wo.wo_number, wo.description, wo.status, wo.scheduled_date, wo.trade')
			->from($db->quoteName('#__mokosuitefield_work_orders', 'wo'))
			->where('wo.agreement_id = ' . $id)
			->order('wo.scheduled_date DESC'), 0, 30);
		$agreement->work_orders = $db->loadObjectList() ?: [];

		$this->sendJson($agreement);
	}

	private function sendJson(mixed $data): void
	{
		header('Content-Type: application/json; charset=utf-8');
		echo json_encode($data, JSON_THROW_ON_ERROR | JSON_UNESCAPED_UNICODE);
		Factory::getApplication()->close();
	}
}