<?php

namespace App\Http\Controllers\Api;

use Illuminate\Http\{Request, Response};
use Illuminate\Database\Eloquent\Relations\Relation;
use App\Http\Resources\{ReimbursementResource, WorkflowLogResource, EmployeeSignRepairResource, HolidayApplyResource, OvertimeApplyResource, AgreementResource};
use App\Enums\CheckStatus;
use App\Models\{WorkflowLog, WorkflowCheck};
use Illuminate\Support\Facades\DB;
use Illuminate\Validation\Rule;
use App\Admin\Services\WorkFlowService;
use App\Exceptions\RuntimeException;

class WorkflowController extends Controller
{
    public function index(Request $request)
    {
        $request->validate([
            'subject_type' => 'required',
        ]);
        $subjectType = $request->input('subject_type');
        $model = Relation::getMorphedModel($subjectType);
        $resource = $this->mapResource($subjectType);

        $user = $request->user();

        $include = ['workflow'];
        if ($request->input('include')) {
            $explodes = explode(',', $request->input('include'));
            $include = array_merge($include, $explodes);
        }

        $query = $model::query()->with($include)
            ->whereHas('workflow', fn($q) => $q->where('check_status', CheckStatus::Processing))
            ->whereHas('workflow.logs', fn($q) => $q->own($user))
            ->orderBy('created_at', 'desc');

        $list = $query->paginate($request->input('per_page'));

        return $resource::collection($list);
    }

    public function show($id, Request $request)
    {
        $request->validate([
            'subject_type' => 'required',
        ]);
        $subjectType = $request->input('subject_type');
        $model = Relation::getMorphedModel($subjectType);
        $resource = $this->mapResource($subjectType);

        $include = ['workflow'];
        if ($request->input('include')) {
            $explodes = explode(',', $request->input('include'));
            $include = array_merge($include, $explodes);
        }
        $info = $model::query()->with($include)->findOrFail($id);

        return $resource::make($info);
    }

    public function logs($id, Request $request)
    {
        $request->validate([
            'subject_type' => 'required',
        ]);
        $check = WorkflowCheck::where('subject_type', $request->input('subject_type'))->where('subject_id', $id)->firstOrFail();
        $logs = $check->logs()->sort()->get();

        return WorkflowLogResource::collection($logs);
    }

    public function cancel($id, Request $request, WorkFlowService $workFlowService)
    {
        $request->validate([
            'subject_type' => 'required',
        ]);
        $check = WorkflowCheck::where('subject_type', $request->input('subject_type'))->where('subject_id', $id)->firstOrFail();
        try {
            DB::beginTransaction();
            if (!$workFlowService->cancel($check)) {
                throw new RuntimeException($workFlowService->getError());
            }

            DB::commit();
            return response('', Response::HTTP_OK);
        } catch (\Exception $e) {
            DB::rollBack();
            throw new RuntimeException($e->getMessage());
        }
    }

    public function check($id, Request $request, WorkFlowService $workFlowService)
    {
        $request->validate([
            'subject_type' => 'required',
            'status' => ['required'],
            'remarks' => [Rule::requiredIf(fn() => !$request->input('status'))]
        ], [
            'remarks.required_if' => '未通过原因必填',
        ]);
        $check = WorkflowCheck::where('subject_type', $request->input('subject_type'))->where('subject_id', $id)->firstOrFail();
        $user = $request->user();
        try {
            DB::beginTransaction();
            $log = $check->logs()->where('check_status', CheckStatus::Processing)->first();
            if (!$log) {
                throw new RuntimeException('审核已经完成');
            }
            if (!$workFlowService->check($user, $log, !!$request->input('status'), ['remarks' => $request->input('remarks')])) {
                throw new RuntimeException($workFlowService->getError());
            }

            DB::commit();
            return response('', Response::HTTP_OK);
        } catch (\Exception $e) {
            DB::rollBack();
            throw new RuntimeException($e->getMessage());
        }
    }

    protected function mapResource($key)
    {
        $map = [
            'reimbursements' => ReimbursementResource::class,
            'employee_sign_repairs' => EmployeeSignRepairResource::class,
            'holiday_applies' => HolidayApplyResource::class,
            'overtime_applies' => OvertimeApplyResource::class,
            'agreements' => AgreementResource::class,
        ];
        return data_get($map, $key);
    }
}