strprfcrm/app/Http/Controllers/ScheduleController.php

<?php

namespace App\Http\Controllers;

use App\Helpers\DateHelper;
use App\Http\Requests\CreateScheduleFromOrderRequest;
use App\Http\Requests\CreateScheduleFromReclamationRequest;
use App\Http\Requests\ExportScheduleRequest;
use App\Http\Requests\UpdateScheduleRequest;
use App\Jobs\ExportScheduleJob;
use App\Models\Dictionary\Area;
use App\Models\Dictionary\District;
use App\Models\Order;
use App\Models\ProductSKU;
use App\Models\Reclamation;
use App\Models\ReclamationStatus;
use App\Models\Role;
use App\Models\Schedule;
use App\Models\User;
use App\Services\NotificationService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Collection;
use Illuminate\Http\Request;
use Illuminate\Support\Carbon;

class ScheduleController extends Controller
{
    protected array $data = [
        'active'    => 'schedule',
        'title'     => 'График монтажей',
        'id'        => 'schedule',
    ];

    public function index(Request $request)
    {
        $this->data['districts'] = District::query()->get()->pluck('name', 'id');
        $this->data['areas'] = Area::query()->get()->pluck('name', 'id');
        $this->data['brigadiers'] = User::query()
            ->where('role', Role::BRIGADIER)
            ->when(hasRole(Role::BRIGADIER), fn (Builder $query) => $query->whereKey(auth()->id()))
            ->get()
            ->pluck('name', 'id');

        $this->data['scheduleYear'] = (int)$request->get('year', date('Y'));
        if ($this->data['scheduleYear'] < 2000 || $this->data['scheduleYear'] > 2100) {
            $this->data['scheduleYear'] = (int)date('Y');
        }

        $tab = $request->get('tab', 'week');
        $this->data['activeTab'] = in_array($tab, ['week', 'month'], true) ? $tab : 'week';

        $this->data['weekNumber'] = $request->get('week' ,date('W'));
        $weekDates = [
            'mon' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber']),
            'tue' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber'], 2),
            'wed' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber'], 3),
            'thu' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber'], 4),
            'fri' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber'], 5),
            'sat' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber'], 6),
            'sun' => DateHelper::getDateOfWeek($this->data['scheduleYear'], $this->data['weekNumber'], 7),
        ];
        $this->data['weekDates'] = $weekDates;


        $schedules = [];
        foreach ($weekDates as $date) {
            $schedules[$date] = null;
        }
        $result = Schedule::query()
            ->whereBetween('installation_date', [$weekDates['mon'], $weekDates['sun']])
            ->when(hasRole(Role::BRIGADIER), fn (Builder $query) => $query->where('brigadier_id', auth()->id()))
            ->with(['brigadier', 'district', 'area'])
            ->get();
        $result = $this->filterSchedulesForCurrentUser($result);
        $this->data['scheduleStatusMap'] = $this->buildScheduleStatusMap($result);

        foreach ($result as $schedule) {
            $schedules[$schedule->installation_date][] = $schedule;
        }

        $this->data['schedules'] = $schedules;

        $monthParam = $request->get('month');
        $monthNumber = (int)date('m');
        if (is_string($monthParam)) {
            if (preg_match('/^(0[1-9]|1[0-2])$/', $monthParam)) {
                $monthNumber = (int)$monthParam;
            } elseif (preg_match('/^(\\d{4})-(0[1-9]|1[0-2])$/', $monthParam, $matches)) {
                $this->data['scheduleYear'] = (int)$matches[1];
                $monthNumber = (int)$matches[2];
            }
        }

        $monthStart = Carbon::createFromDate($this->data['scheduleYear'], $monthNumber, 1)->startOfMonth();
        $monthEnd = $monthStart->copy()->endOfMonth();

        $gridStart = $monthStart->copy()->startOfWeek(Carbon::MONDAY);
        $gridEnd = $monthEnd->copy()->endOfWeek(Carbon::SUNDAY);
        $cursor = $gridStart->copy();
        $monthDays = [];
        while ($cursor->lte($gridEnd)) {
            $monthDays[] = [
                'date' => $cursor->toDateString(),
                'day' => (int)$cursor->format('j'),
                'week' => (int)$cursor->isoWeek(),
                'weekYear' => (int)$cursor->isoWeekYear(),
                'inMonth' => $cursor->month === $monthStart->month,
                'isToday' => $cursor->isToday(),
            ];
            $cursor->addDay();
        }

        $monthSchedules = Schedule::query()
            ->whereBetween('installation_date', [$monthStart->toDateString(), $monthEnd->toDateString()])
            ->when(hasRole(Role::BRIGADIER), fn (Builder $query) => $query->where('brigadier_id', auth()->id()))
            ->with(['brigadier'])
            ->get();
        $monthSchedules = $this->filterSchedulesForCurrentUser($monthSchedules);

        $monthScheduleColors = [];
        $monthBrigadierLegend = [];
        foreach ($monthSchedules as $schedule) {
            $date = $schedule->installation_date;
            $brigadierId = $schedule->brigadier_id ?? 0;
            if (!isset($monthScheduleColors[$date])) {
                $monthScheduleColors[$date] = [];
            }
            if (!isset($monthScheduleColors[$date][$brigadierId])) {
                $monthScheduleColors[$date][$brigadierId] = [
                    'color' => $schedule->brigadier?->color ?? '#cccccc',
                    'name' => $schedule->brigadier?->name ?? '',
                ];
            }
            if (!isset($monthBrigadierLegend[$brigadierId])) {
                $monthBrigadierLegend[$brigadierId] = [
                    'color' => $schedule->brigadier?->color ?? '#cccccc',
                    'name' => $schedule->brigadier?->name ?? '',
                ];
            }
        }
        foreach ($monthScheduleColors as $date => $colors) {
            $monthScheduleColors[$date] = array_values($colors);
        }

        $this->data['monthGrid'] = array_chunk($monthDays, 7);
        $this->data['monthLabel'] = $monthStart->isoFormat('MMMM YYYY');
        $this->data['monthNumber'] = $monthNumber;
        $this->data['monthPrev'] = $monthStart->copy()->subMonth()->format('Y-m');
        $this->data['monthNext'] = $monthStart->copy()->addMonth()->format('Y-m');
        $this->data['monthValue'] = $monthStart->format('Y-m');
        $this->data['monthScheduleColors'] = $monthScheduleColors;
        $this->data['monthBrigadierLegend'] = array_values($monthBrigadierLegend);

        return view('schedule.index', $this->data);
    }

    public function createFromOrder(CreateScheduleFromOrderRequest $request, NotificationService $notificationService)
    {
        $validated = $request->validated();

        // delete all auto schedules for this order
        if(isset($validated['delete_old_records'])) {
            Schedule::query()
                ->where('order_id', $validated['order_id'])
                ->where('source', 'Площадки')
                ->where('manual', false)
                ->delete();
        }

        // create all records in schedule
        $order = Order::query()
            ->where('id', $validated['order_id'])
            ->first();

        $errors = [];
        if(!$order->brigadier_id) $errors[] = 'Не указан бригадир!';
        if(!$order->installation_date) $errors[] = 'Не указана дата монтажа!';
        if(!$order->install_days) $errors[] = 'Не указан срок монтажа!';

        if($errors) {
            return redirect()->route('order.show', $order->id)->with(['danger' => $errors]);
        }

        if(empty($validated['skus'])) {
            foreach ($order->products_sku as $psku)
                $validated['skus'][] = $psku->id;
        }

        $mafs = [];
        foreach ($validated['skus'] as $skuId) {
            $sku = ProductSKU::query()->where('id', $skuId)->first();
            if(!isset($mafs[$sku->product->article])) {
                $mafs[$sku->product->article] = 1;
            } else {
                $mafs[$sku->product->article] += 1;
            }
        }
        $mafsText = '';
        $mafsCount = 0;
        foreach ($mafs as $article => $count) {
            $mafsText .= $article . ' - ' . $count . "\r\n";
            $mafsCount += $count;
        }
        $first = true;
        for ($iDays = 1; $iDays < $order->install_days + 1; $iDays++) {

            $instDate = date('Y-m-d', strtotime('+' . $iDays - 1 . ' days', strtotime($order->installation_date)));
            $schedule = Schedule::query()
                ->create([
                    'order_id' => $validated['order_id'],
                    'address_code' => $validated['order_id'],
                    'source'    => 'Площадки',
                    'installation_date' => $instDate,
                    'manual' => false,
                    'district_id' => $order->district_id,
                    'area_id' => $order->area_id,
                    'object_address' => $order->object_address,
                    'object_type' => $order->objectType->name,
                    'mafs' => $mafsText,
                    'mafs_count' => $mafsCount,
                    'brigadier_id' => $order->brigadier_id,
                    'comment'   => $validated['comment'],
                ]);
            if($first && isset($validated['send_notifications'])) {
                $first = false;
                $notificationService->notifyScheduleAdded($schedule->fresh(['brigadier']), auth()->user());
            }
        }
        return redirect()->route('schedule.index');

    }

    public function createFromReclamation(CreateScheduleFromReclamationRequest $request, NotificationService $notificationService)
    {
        $validated = $request->validated();

        // delete all auto schedules for this order
        if(isset($validated['delete_old_records'])) {
            Schedule::query()
                ->where('address_code', 'РЕКЛ-' . $validated['reclamation_id'])
                ->where('source', 'Рекламации')
                ->where('manual', false)
                ->delete();
        }

        $reclamation = Reclamation::query()
            ->where('id', $validated['reclamation_id'])
            ->first();

        $order = $reclamation->order;
        $scheduleComment = $this->buildScheduleCommentFromReclamation($reclamation);

        $mafs = [];
        if(empty($validated['skus'])) {
            foreach ($reclamation->skus as $sku)
                if(!isset($mafs[$sku->product->article])) {
                    $mafs[$sku->product->article] = 1;
                } else {
                    $mafs[$sku->product->article] += 1;
                }
        }

        $mafsCount = 0;
        $mafsText = '';

        foreach ($mafs as $article => $count) {
            $mafsCount += $count;
            $mafsText .= $article . ' - ' . $count . "\r\n";
        }

        $first = true;
        for ($iDays = 1; $iDays < $reclamation->work_days + 1; $iDays++) {
            $instDate = date('Y-m-d', strtotime('+' . $iDays - 1 . ' days', strtotime($reclamation->start_work_date)));
            $schedule = Schedule::query()
                ->create([
                    'order_id' => $order->id,
                    'address_code' => 'РЕКЛ-' . $validated['reclamation_id'],
                    'source'    => 'Рекламации',
                    'installation_date' => $instDate,
                    'manual' => false,
                    'district_id' => $order->district_id,
                    'area_id' => $order->area_id,
                    'object_address' => $order->object_address,
                    'object_type' => $reclamation->reason,
                    'mafs' => $mafsText,
                    'mafs_count' => $mafsCount,
                    'brigadier_id' => $reclamation->brigadier_id,
                    'comment'   => $scheduleComment,
                ]);
            if($first && isset($validated['send_notifications'])) {
                $first = false;
                $notificationService->notifyScheduleAdded($schedule->fresh(['brigadier']), auth()->user());
            }
        }
        return redirect()->route('schedule.index');

    }

    private function buildScheduleCommentFromReclamation(Reclamation $reclamation): string
    {
        $guarantee = trim((string) $reclamation->guarantee);

        $parts = $reclamation->sparePartReservations()
            ->whereIn('status', ['active', 'issued'])
            ->with(['sparePart:id,article', 'sparePartOrder:id,order_number'])
            ->orderBy('created_at')
            ->get()
            ->map(static function ($reservation): ?string {
                $article = trim((string) $reservation->sparePart?->article);

                if ($article === '') {
                    return null;
                }

                $orderNumber = $reservation->sparePartOrder?->display_order_number ?? '-';

                return $article . ' - ' . $orderNumber;
            })
            ->filter()
            ->values();

        $lines = array_filter([
            $guarantee !== '' ? $guarantee : null,
            $parts->isNotEmpty()
                ? 'Используемые детали: ' . $parts->implode(', ') . '.'
                : null,
        ]);

        return implode(PHP_EOL, $lines);
    }


    public function update(UpdateScheduleRequest $request, NotificationService $notificationService)
    {
        $validated = $request->validated();

        if(isset($validated['id'])) {
             Schedule::query()
                ->where('id', $validated['id'])
                ->update($validated);
             $schedule = Schedule::query()->find($validated['id']);
        } else {
            $schedule = Schedule::query()
                ->create([
                    'address_code' => $validated['address_code'] ?? '-',
                    'installation_date' => $validated['installation_date'],
                    'manual' => true,
                    'district_id' => $validated['district_id'],
                    'area_id' => $validated['area_id'],
                    'object_address' => $validated['object_address'],
                    'object_type' => $validated['object_type'],
                    'mafs' => $validated['mafs'],
                    'mafs_count' => $validated['mafs_count'],
                    'brigadier_id' => $validated['brigadier_id'],
                    'comment'   => $validated['comment'],
                    'transport' => $validated['transport'] ?? null,
                    'admin_comment' => $validated['admin_comment'] ?? null,
                ]);
            $notificationService->notifyScheduleAdded($schedule->fresh(['brigadier']), auth()->user());
        }

        return redirect()->back();
    }

    public function delete(Schedule $schedule)
    {
        $schedule->delete();
        return redirect()->back();
    }

    public function export(ExportScheduleRequest $request)
    {
        $startDate = $request->validated()['start_date'];
        $endDate   = $request->validated()['end_date'];

        $schedules = Schedule::query()
            ->where('installation_date', '>=', $startDate)
            ->where('installation_date', '<=', $endDate)
            ->orderBy('installation_date')
            ->orderBy('brigadier_id')
            ->get();

        ExportScheduleJob::dispatch($schedules, $request->user()->id);
        return redirect()->route('schedule.index', [
            'week' => (int) $request->validated()['week'],
            'year' => (int) $request->input('year', date('Y')),
        ])
            ->with(['success' => 'Задача генерации графика создана!']);

    }

    private function filterSchedulesForCurrentUser(Collection $schedules): Collection
    {
        if (!hasRole(Role::BRIGADIER)) {
            return $schedules;
        }

        $brigadierSchedules = $schedules
            ->where('brigadier_id', auth()->id())
            ->values();

        if ($brigadierSchedules->isEmpty()) {
            return $brigadierSchedules;
        }

        $visibleOrderIds = Order::query()
            ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
            ->whereIn('id', $brigadierSchedules->pluck('order_id')->filter()->unique()->all())
            ->where('brigadier_id', auth()->id())
            ->whereIn('order_status_id', Order::visibleStatusIdsForBrigadier())
            ->pluck('id')
            ->all();

        $reclamationIds = $brigadierSchedules
            ->filter(fn (Schedule $schedule) => $schedule->source === 'Рекламации')
            ->map(fn (Schedule $schedule) => $this->extractReclamationId((string)$schedule->address_code))
            ->filter()
            ->unique()
            ->values();

        $visibleReclamationIds = Reclamation::query()
            ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
            ->whereIn('id', $reclamationIds->all())
            ->where('brigadier_id', auth()->id())
            ->whereIn('status_id', Reclamation::visibleStatusIdsForBrigadier())
            ->pluck('id')
            ->all();

        return $brigadierSchedules
            ->filter(function (Schedule $schedule) use ($visibleOrderIds, $visibleReclamationIds) {
                if ($schedule->source === 'Площадки') {
                    return in_array((int)$schedule->order_id, $visibleOrderIds, true);
                }

                if ($schedule->source === 'Рекламации') {
                    return in_array($this->extractReclamationId((string)$schedule->address_code), $visibleReclamationIds, true);
                }

                return true;
            })
            ->values();
    }

    private function buildScheduleStatusMap($schedules): array
    {
        $statusMap = [];
        $orderIds = [];
        $reclamationScheduleIds = [];

        foreach ($schedules as $schedule) {
            $statusMap[$schedule->id] = [
                'name' => '-',
                'color' => 'secondary',
            ];

            if ($schedule->source === 'Площадки' && $schedule->order_id) {
                $orderIds[] = (int)$schedule->order_id;
                continue;
            }

            if ($schedule->source === 'Рекламации') {
                $reclamationId = $this->extractReclamationId((string)$schedule->address_code);
                if ($reclamationId) {
                    $reclamationScheduleIds[$reclamationId][] = $schedule->id;
                }
            }
        }

        if ($orderIds) {
            $orderStatuses = Order::query()
                ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                ->whereIn('id', array_unique($orderIds))
                ->pluck('order_status_id', 'id')
                ->all();

            foreach ($schedules as $schedule) {
                if ($schedule->source !== 'Площадки' || !$schedule->order_id) {
                    continue;
                }

                $statusId = $orderStatuses[(int)$schedule->order_id] ?? null;
                if ($statusId) {
                    $statusMap[$schedule->id] = [
                        'name' => Order::STATUS_NAMES[$statusId] ?? '-',
                        'color' => Order::STATUS_COLOR[$statusId] ?: 'secondary',
                    ];
                }
            }
        }

        if ($reclamationScheduleIds) {
            $reclamationStatuses = Reclamation::query()
                ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                ->whereIn('id', array_keys($reclamationScheduleIds))
                ->pluck('status_id', 'id')
                ->all();

            foreach ($reclamationScheduleIds as $reclamationId => $scheduleIds) {
                $statusId = $reclamationStatuses[$reclamationId] ?? null;
                $statusName = $statusId ? (Reclamation::STATUS_NAMES[$statusId] ?? '-') : '-';
                $statusColor = $statusId ? (ReclamationStatus::STATUS_COLOR[$statusId] ?? 'secondary') : 'secondary';

                foreach ($scheduleIds as $scheduleId) {
                    $statusMap[$scheduleId] = [
                        'name' => $statusName,
                        'color' => $statusColor,
                    ];
                }
            }
        }

        return $statusMap;
    }

    private function extractReclamationId(string $addressCode): ?int
    {
        if (preg_match('/^РЕКЛ-(\d+)$/u', $addressCode, $matches)) {
            return (int)$matches[1];
        }

        return null;
    }
}