<?php

namespace App\Http\Controllers;

use App\Models\Place;
use App\Models\Service;
use App\Models\User;
use Illuminate\Http\Request;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\Http;
use App\Utils\Logger;

class ServiceController extends Controller
{
    /**
     * Display a listing of the resource.
     */
    public function index(Request $request)
    {
        if(!$request->user()->hasPermission("services-read")) abort(401);
        User::where('id', $request->user()->id)->update(['last_access' => now()]);

        $query = Service::join('users', 'users.id', '=', 'chief_id')
            ->join('services_types', 'services_types.id', '=', 'type_id')
            ->select('services.*', 'users.name as chief', 'services_types.name as type')
            ->with('drivers:name')
            ->with('crew:name')
            ->with('place')
            ->orderBy('start', 'desc');
        if($request->has('from')) {
            try {
                $from = Carbon::parse($request->input('from'));
                $query->whereDate('start', '>=', $from->toDateString());
            } catch (\Carbon\Exceptions\InvalidFormatException $e) { }
        }
        if($request->has('to')) {
            try {
                $to = Carbon::parse($request->input('to'));
                $query->whereDate('start', '<=', $to->toDateString());
            } catch (\Carbon\Exceptions\InvalidFormatException $e) { }
        }
        return response()->json(
            $query->get()
        );
    }

    /**
     * Get single Service
     */
    public function show(Request $request, $id)
    {
        if(!$request->user()->hasPermission("services-read")) abort(401);
        User::where('id', $request->user()->id)->update(['last_access' => now()]);

        return response()->json(
            Service::join('users', 'users.id', '=', 'chief_id')
                ->join('services_types', 'services_types.id', '=', 'type_id')
                ->select('services.*', 'users.name as chief', 'services_types.name as type')
                ->with('drivers:name')
                ->with('crew:name')
                ->with('place')
                ->find($id)
        );
    }

    private function extractServiceUsers($service)
    {
        $usersList = [$service->chief_id];
        foreach($service->drivers as $driver) {
            $usersList[] = $driver->id;
        }
        foreach($service->crew as $crew) {
            $usersList[] = $crew->id;
        }
        return array_unique($usersList);
    }

    /**
     * Add or update Service.
     */
    public function createOrUpdate(Request $request)
    {
        $adding = !isset($request->id) || is_null($request->id);

        if(!$adding && !$request->user()->hasPermission("services-update")) abort(401);
        if($adding && !$request->user()->hasPermission("services-create")) abort(401);

        $service = $adding ? new Service() : Service::where("id",$request->id)->with('drivers')->with('crew')->first();

        if(is_null($service)) abort(404);

        if(!$adding) {
            $usersToDecrement = $this->extractServiceUsers($service);
            User::whereIn('id', $usersToDecrement)->decrement('services');

            $service->drivers()->detach();
            $service->crew()->detach();
            $service->save();
        }

        //Find Place by lat lon
        $place = Place::where('lat', $request->lat)->where('lon', $request->lon)->first();
        if(!$place) {
            $place = new Place();
            $place->lat = $request->lat;
            $place->lon = $request->lon;

            $response = Http::withUrlParameters([
                'lat' => $request->lat,
                'lon' => $request->lon,
            ])->get('https://nominatim.openstreetmap.org/reverse?format=json&lat={lat}&lon={lon}');
            if(!$response->ok()) abort(500);

            $place->place_id = isset($response["place_id"]) ? $response["place_id"] : null;
            $place->osm_id = isset($response["osm_id"]) ? $response["osm_id"] : null;
            $place->osm_type = isset($response["osm_type"]) ? $response["osm_type"] : null;
            $place->licence = isset($response["licence"]) ? $response["licence"] : null;
            $place->addresstype = isset($response["addresstype"]) ? $response["addresstype"] : null;
            $place->country = isset($response["address"]["country"]) ? $response["address"]["country"] : null;
            $place->country_code = isset($response["address"]["country_code"]) ? $response["address"]["country_code"] : null;
            $place->name = isset($response["name"]) ? $response["name"] : null;
            $place->display_name = isset($response["display_name"]) ? $response["display_name"] : null;
            $place->road = isset($response["address"]["road"]) ? $response["address"]["road"] : null;
            $place->house_number = isset($response["address"]["house_number"]) ? $response["address"]["house_number"] : null;
            $place->postcode = isset($response["address"]["postcode"]) ? $response["address"]["postcode"] : null;
            $place->state = isset($response["address"]["state"]) ? $response["address"]["state"] : null;
            $place->village = isset($response["address"]["village"]) ? $response["address"]["village"] : null;
            $place->suburb = isset($response["address"]["suburb"]) ? $response["address"]["suburb"] : null;
            $place->city = isset($response["address"]["city"]) ? $response["address"]["city"] : null;
            $place->municipality = isset($response["address"]["municipality"]) ? $response["address"]["municipality"] : null;

            $place->save();
        }

        $service->code = $request->code;
        $service->chief()->associate($request->chief);
        $service->type()->associate($request->type);
        $service->notes = $request->notes;
        $service->start = $request->start/1000;
        $service->end = $request->end/1000;
        $service->place()->associate($place);
        $service->addedBy()->associate($request->user());
        $service->updatedBy()->associate($request->user());
        $service->save();

        $service->drivers()->attach(array_unique($request->drivers));
        $service->crew()->attach(array_unique($request->crew));
        $service->save();

        $usersToIncrement = array_unique(array_merge(
            [$request->chief],
            $request->drivers,
            $request->crew
        ));
        User::whereIn('id', $usersToIncrement)->increment('services');

        Logger::log($adding ? "Intervento aggiunto" : "Intervento modificato");
    }

    /**
     * Remove the specified resource from storage.
     */
    public function destroy(Request $request, $id)
    {
        if(!$request->user()->hasPermission("services-delete")) abort(401);
        $service = Service::find($id);
        $usersToDecrement = $this->extractServiceUsers($service);
        User::whereIn('id', $usersToDecrement)->decrement('services');
        $service->delete();
        Logger::log("Intervento eliminato");
    }
}