ultimatepos/Modules/Maintenance/Http/Controllers/WorkOrderController.php

<?php

namespace Modules\Maintenance\Http\Controllers;

use Illuminate\Http\Request;
use Illuminate\Routing\Controller;
use Modules\Maintenance\Http\Controllers\Concerns\AuthorizesMaintenance;
use Modules\Maintenance\Models\WorkOrder;
use Modules\Maintenance\Services\MaintenanceAccountingService;
use Modules\Maintenance\Services\MaintenanceActivityService;
use Modules\Maintenance\Services\MaintenanceCrmSyncService;
use Modules\Maintenance\Services\FieldMissionService;
use Modules\Maintenance\Services\MaterialListService;
use Modules\Maintenance\Services\SparePartService;
use Modules\Maintenance\Services\WorkOrderService;
use Modules\Maintenance\Traits\AppliesMaintenanceScope;
use Modules\Maintenance\Utils\MaintenanceUtil;
use Yajra\DataTables\Facades\DataTables;

class WorkOrderController extends Controller
{
    use AuthorizesMaintenance, AppliesMaintenanceScope;

    public function __construct(
        protected MaintenanceUtil $maintenanceUtil,
        protected WorkOrderService $workOrderService,
        protected MaintenanceAccountingService $accountingService,
        protected MaintenanceCrmSyncService $crmSyncService,
        protected SparePartService $sparePartService,
        protected MaterialListService $materialListService,
        protected FieldMissionService $missionService
    ) {}

    public function index(Request $request)
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.view');

        $business_id = $this->maintenanceUtil->getBusinessId();

        if ($request->ajax()) {
            $query = WorkOrder::where('business_id', $business_id)
                ->with(['equipment:id,name,code', 'project:id,name', 'assignedTechnician:id,first_name,last_name'])
                ->orderByDesc('created_at');

            $this->applyMaintenanceScopeFilters($query, $request);

            if ($status = $request->get('status')) {
                $query->where('status', $status);
            }
            if ($equipment_id = $request->get('equipment_id')) {
                $query->where('equipment_id', $equipment_id);
            }

            return DataTables::of($query)
                ->addColumn('equipment_name', fn ($row) => $row->equipment?->name ?? '—')
                ->addColumn('technician_name', function ($row) {
                    if (! $row->assignedTechnician) {
                        return '—';
                    }

                    return trim($row->assignedTechnician->first_name.' '.($row->assignedTechnician->last_name ?? ''));
                })
                ->addColumn('status_label', fn ($row) => $this->maintenanceUtil->statusLabel($row->status))
                ->addColumn('priority_label', fn ($row) => $this->maintenanceUtil->priorityLabel($row->priority))
                ->addColumn('action', function ($row) {
                    $html = '<a href="'.action([self::class, 'show'], [$row->id]).'" class="btn btn-xs btn-info"><i class="fa fa-eye"></i></a>';
                    if (auth()->user()->can('maintenance.work_orders.update')) {
                        $html .= ' <a href="'.action([self::class, 'edit'], [$row->id]).'" class="btn btn-xs btn-primary"><i class="glyphicon glyphicon-edit"></i></a>';
                    }

                    return $html;
                })
                ->editColumn('scheduled_at', fn ($row) => $this->maintenanceUtil->formatDateTime($row->scheduled_at))
                ->editColumn('cost', fn ($row) => $this->maintenanceUtil->formatMoney($row->cost))
                ->rawColumns(['action'])
                ->make(true);
        }

        return view('maintenance::work_orders.index', [
            'equipment' => $this->maintenanceUtil->getEquipmentDropdown($business_id),
            'projects' => $this->maintenanceUtil->getProjectsDropdown($business_id),
            'statuses' => $this->maintenanceUtil->statusLabels(),
            'priorities' => $this->maintenanceUtil->priorityLabels(),
        ]);
    }

    public function create()
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.create');

        $business_id = $this->maintenanceUtil->getBusinessId();

        return view('maintenance::work_orders.create', [
            'equipment' => $this->maintenanceUtil->getEquipmentDropdown($business_id),
            'projects' => $this->maintenanceUtil->getProjectsDropdown($business_id),
            'production_lines' => $this->maintenanceUtil->getProductionLinesDropdown($business_id),
            'users' => $this->maintenanceUtil->getUsersDropdown($business_id),
            'statuses' => $this->maintenanceUtil->statusLabels(),
            'priorities' => $this->maintenanceUtil->priorityLabels(),
        ]);
    }

    public function store(Request $request)
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.create');

        $business = $this->maintenanceUtil->getBusiness();
        $business_id = $business->id;

        $data = $request->validate(array_merge([
            'description' => 'nullable|string',
            'priority' => 'sometimes|in:low,medium,high,urgent',
            'assigned_technician_id' => 'nullable|exists:users,id',
            'preventive_schedule_id' => 'nullable|exists:maintenance_preventive_schedules,id',
            'overhaul_id' => 'nullable|exists:maintenance_overhauls,id',
            'rebuild_id' => 'nullable|exists:maintenance_rebuild_projects,id',
            'scheduled_at' => 'nullable|string',
            'status' => 'sometimes|in:draft,open,in_progress,on_hold,completed,cancelled',
            'equipment_id' => 'required_without:equipment_ids|exists:maintenance_equipment,id',
            'equipment_ids' => 'nullable|array|min:1',
            'equipment_ids.*' => 'integer|exists:maintenance_equipment,id',
        ], $this->scopeValidationRules()));

        $equipmentIds = $this->resolveEquipmentIds($data);
        if (empty($equipmentIds)) {
            return $this->maintenanceUtil->jsonOrRedirect($request, false, 'حداقل یک تجهیز انتخاب کنید.');
        }

        unset($data['equipment_id'], $data['equipment_ids']);

        try {
            $data = $this->syncScopeFromLine($data);
        } catch (\InvalidArgumentException $e) {
            return $this->maintenanceUtil->jsonOrRedirect($request, false, $e->getMessage());
        }

        if (! empty($data['scheduled_at'])) {
            $data['scheduled_at'] = $this->maintenanceUtil->parseInputDateTime($data['scheduled_at']);
        }

        $created = [];
        foreach ($equipmentIds as $equipmentId) {
            $workOrder = WorkOrder::create(array_merge($data, [
                'business_id' => $business_id,
                'equipment_id' => $equipmentId,
                'work_order_number' => $this->workOrderService->generateNumber($business),
                'requester_id' => auth()->id(),
                'status' => $data['status'] ?? 'open',
            ]));

            MaintenanceActivityService::log(
                $business, 'created', 'work_order', $workOrder->id,
                "دستور کار {$workOrder->work_order_number} ایجاد شد.", auth()->user()
            );

            $created[] = $workOrder;
        }

        $redirect = count($created) === 1
            ? action([self::class, 'show'], [$created[0]->id])
            : action([self::class, 'index']);

        return $this->maintenanceUtil->jsonOrRedirect(
            $request,
            true,
            count($created) > 1 ? count($created).' دستور کار ایجاد شد.' : 'دستور کار ایجاد شد.',
            $redirect
        );
    }

    public function show($id)
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.view');

        $business_id = $this->maintenanceUtil->getBusinessId();
        $business = $this->maintenanceUtil->getBusiness();
        $work_order = WorkOrder::where('business_id', $business_id)
            ->with(['equipment', 'project', 'productionLine', 'assignedTechnician', 'requester', 'parts.sparePart'])
            ->findOrFail($id);

        $spare_parts = $this->maintenanceUtil->getSparePartsDropdown($business_id);

        $materialPanel = auth()->user()->can('maintenance.materials.view')
            ? array_merge(
                $this->materialListService->getPanelData($business, 'work_order', (int) $id, auth()->user()),
                [
                    'spare_parts' => $spare_parts,
                    'can_manage' => auth()->user()->can('maintenance.materials.manage'),
                    'can_procure' => auth()->user()->can('maintenance.materials.procure'),
                ]
            )
            : null;

        $missionPanel = auth()->user()->can('maintenance.mission.view')
            ? array_merge(
                $this->missionService->getPanelData($business, 'work_order', (int) $id),
                [
                    'spare_parts' => $spare_parts,
                    'tools' => \Modules\Maintenance\Models\MaintenanceTool::where('business_id', $business_id)->where('status', 'available')->orderBy('name')->pluck('name', 'id'),
                    'users' => $this->maintenanceUtil->getUsersDropdown($business_id),
                    'can_manage' => auth()->user()->can('maintenance.mission.manage'),
                    'can_issue' => auth()->user()->can('maintenance.mission.issue'),
                    'can_expense' => auth()->user()->can('maintenance.mission.expense'),
                ]
            )
            : null;

        return view('maintenance::work_orders.show', compact('work_order', 'spare_parts', 'materialPanel', 'missionPanel'));
    }

    public function edit($id)
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.update');

        $business_id = $this->maintenanceUtil->getBusinessId();
        $work_order = WorkOrder::where('business_id', $business_id)->findOrFail($id);

        return view('maintenance::work_orders.edit', [
            'work_order' => $work_order,
            'equipment' => $this->maintenanceUtil->getEquipmentDropdown($business_id),
            'projects' => $this->maintenanceUtil->getProjectsDropdown($business_id),
            'production_lines' => $this->maintenanceUtil->getProductionLinesDropdown($business_id, $work_order->project_id),
            'users' => $this->maintenanceUtil->getUsersDropdown($business_id),
            'statuses' => $this->maintenanceUtil->statusLabels(),
            'priorities' => $this->maintenanceUtil->priorityLabels(),
        ]);
    }

    public function update(Request $request, $id)
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.update');

        $business_id = $this->maintenanceUtil->getBusinessId();
        $work_order = WorkOrder::where('business_id', $business_id)->findOrFail($id);

        $data = $request->validate(array_merge([
            'description' => 'nullable|string',
            'priority' => 'sometimes|in:low,medium,high,urgent',
            'assigned_technician_id' => 'nullable|exists:users,id',
            'status' => 'sometimes|in:draft,open,in_progress,on_hold,completed,cancelled',
            'labor_hours' => 'nullable|numeric',
            'completion_report' => 'nullable|string',
            'scheduled_at' => 'nullable|string',
            'cost' => 'nullable|integer|min:0',
        ], $this->scopeValidationRules()));

        try {
            $data = $this->syncScopeFromLine(array_merge([
                'project_id' => $work_order->project_id,
                'production_line_id' => $work_order->production_line_id,
            ], $data));
        } catch (\InvalidArgumentException $e) {
            return $this->maintenanceUtil->jsonOrRedirect($request, false, $e->getMessage());
        }

        if (array_key_exists('scheduled_at', $data)) {
            $data['scheduled_at'] = $this->maintenanceUtil->parseInputDateTime($data['scheduled_at']);
        }

        if (($data['status'] ?? null) === 'completed' && ! $work_order->completed_at) {
            $data['completed_at'] = now();
        }

        $work_order->update($data);

        if ($work_order->status === 'completed') {
            $fresh = $work_order->fresh();
            $this->accountingService->postWorkOrderIfCompleted(
                $fresh,
                $business_id,
                (int) auth()->id()
            );
            $this->crmSyncService->notifyCrmOnWorkOrderCompleted($fresh, auth()->user());
        }

        return $this->maintenanceUtil->jsonOrRedirect(
            $request,
            true,
            'دستور کار به‌روزرسانی شد.',
            action([self::class, 'show'], [$work_order->id])
        );
    }

    public function consumePart(Request $request, $id)
    {
        $this->authorizeMaintenanceAccess('maintenance.work_orders.update');

        $business = $this->maintenanceUtil->getBusiness();
        $work_order = WorkOrder::where('business_id', $business->id)->findOrFail($id);

        $data = $request->validate([
            'spare_part_id' => ['required', 'exists:maintenance_spare_parts,id'],
            'quantity' => ['required', 'numeric', 'min:0.001'],
        ]);

        try {
            $this->sparePartService->consumeForWorkOrder(
                $business,
                $work_order,
                (int) $data['spare_part_id'],
                (float) $data['quantity'],
                auth()->user()
            );
        } catch (\InvalidArgumentException $e) {
            return $this->maintenanceUtil->jsonOrRedirect($request, false, $e->getMessage());
        }

        return $this->maintenanceUtil->jsonOrRedirect(
            $request,
            true,
            'قطعه مصرف شد.',
            action([self::class, 'show'], [$work_order->id])
        );
    }
}