<?php

namespace App\Http\Controllers;

use App\Components\AsyncResponse;
use App\DischargeProvider;
use App\DischargeTask;
use App\Filters\DischargeTaskFilters;
use App\Services\common\ExportService;
use App\Services\OwnerService;
use Illuminate\Http\Request;

class DischargeTaskController extends Controller
{
    use AsyncResponse;
    public function index(Request  $request,DischargeTaskFilters  $filters)
    {
        // 权限 ***

        $dischargeTasks = DischargeTask::query()->with(['dischargeProvider','owner'])->filter($filters)->orderByDesc('id')->paginate($request['paginate'] ?? 50);
        $owners = app(OwnerService::class)->getAuthorizedOwners();
        $dischargeProviders = DischargeProvider::query()->select('name','id')->get();
        return view('transport.discharge.task.index',compact('dischargeTasks','owners','dischargeProviders'));
    }

    // 结算报表
    public function statementIndex(Request $request,DischargeTaskFilters $filters)
    {
        // 权限 ***
        $dischargeStatements  = DischargeTask::query()->with('dischargeProvider')->filter($filters)->orderBy('id')->paginate($request['paginate'] ?? 50);
        $owners = app(OwnerService::class)->getAuthorizedOwners();
        $providers = DischargeProvider::query()->select('name','id')->get();
        return view('transport.discharge.statement.index',compact('dischargeStatements','owners','providers'));
    }


    public function create()
    {

    }


    public function store(Request $request)
    {
    }

    // async 创建
    public function storeApi(Request $request)
    {
        // 权限 ***
        $result = app('DischargeTaskService')->createTask($request->all());
        if($result['success'])$this->success($result['data']);
        $this->error('任务创建异常，刷新当前页面重试');
    }

    public function show(DischargeTask $dischargeTask)
    {
        //
    }


    public function edit(DischargeTask $dischargeTask)
    {
        //
    }

    public function update(Request $request, DischargeTask $dischargeTask)
    {
        //
    }

    // async 编辑
    public function updateApi(Request $request)
    {
        $dischargeTask = DischargeTask::query()->where('id',$request['id'])->first();
        $result = app('DischargeTaskService')->updateDischargeTask($dischargeTask,$request->all());
        if($result['success'])$this->success($result['data']);
        else $this->error($request['message'] ?? '操作异常，请刷新页面重试');
    }

    // 修改任务服务商
    public function updateTaskProviderApi(Request $request)
    {
        // 权限 ***
        $dischargeTask = DischargeTask::query()->where('id',$request['id'])->first();
        $result = app('DischargeTaskService')->updateTaskProvider($dischargeTask,$request->all());
        if($result['success'])$this->success($result['data']);
        else $this->error($result['message'] ?? '操作异常，请刷新页面重试');
    }

    public function destroy(DischargeTask $dischargeTask)
    {

    }

    //  async 删除
    public function destroyApi(Request $request)
    {
        // 权限 ***
        /** @var DischargeTask $dischargeTask */
        $dischargeTask = DischargeTask::query()->where('id',$request['id'])->first();
        $result = app('DischargeTaskService')->deleteDischargeTask($dischargeTask);
        if($result['success'])$this->success();
        else $this->error($result['message']);
    }


    // 执行任务
    public function executingTaskApi(Request $request)
    {
        $dischargeTask = DischargeTask::query()->where('id',$request['id'])->first();
        $result = app('DischargeTaskService')->updateTaskProvider($dischargeTask,$request->all());
        if($result['success'])$this->success($result['data']);
        $this->error($result['message'] ?? '操作异常，请刷新页面重试');
    }


    // 卸货任务文件下载
    public function export(Request $request,DischargeTaskFilters $filters)
    {
        $dischargeTasks = DischargeTask::query()->with(['dischargeProvider','owner'])->filter($filters)->orderByDesc('id')->get();
        $row = ['日期','客户名称','作业名称','入库单号','数量','单位','单价','收费','状态','备注'];
        $json =  app('DischargeTaskService')->getJson($dischargeTasks);
        return app(ExportService::class)->json($row,$json,"卸货任务");
    }

    // 结算报表下载
    public function exportStatements(Request $request,DischargeTaskFilters $filters)
    {
        $dischargeTasks = DischargeTask::query()->with(['dischargeProvider','owner'])->filter($filters)->orderByDesc('id')->get();
        $row = ['日期','客户名称','作业名称','入库单号','数量','单位','收入单价','收入合计','服务商','数量','单位','支出单价','支出合计','状态','收入备注','支出备注'];
        $json =  app('DischargeTaskService')->getStatementsJson($dischargeTasks);
        return app(ExportService::class)->json($row,$json,"卸货结算报表");
    }

}