<?php

namespace App\Services;

use App\Helper\AesEncrypt;
use App\Helper\CosHelper;
use App\Helper\ErrorCode;
use App\Helper\RedisClient;
use App\Helper\Response;
use App\Models\Legal\Contract;
use App\Models\Legal\FileMap;
use App\Models\Legal\PropertyFileType;
use App\Models\Legal\PropertyShare;
use App\Models\Legal\PropertyShareVerification;
use App\Models\Legal\PropertyTrack;
use App\Models\Legal\PropertyTrackFile;
use App\Models\Legal\PropertyTrackFileType;
use App\Models\Legal\StakeholderContract;
use App\Models\Legal\Treaty;
use App\Models\Legal\User;
use App\Models\Musician\AppCompany;
use App\Models\Musician\AppCompanyUser;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Qcloud\Cos\Client;

/**
 * Class PropertyTrackService
 * @package App\Services
 */
class PropertyTrackService extends Service
{

    /**
     * 歌曲文件列表
     * @return \Illuminate\Http\JsonResponse
     */
    public function list()
    {
        $res = PropertyTrack::query()->where(['create_admin'=>$this->request->get('identifier')->company_id, 'from'=>1])
                    ->when(filled($this->request->input('created_at')), function (Builder $builder){
                        list($start, $end) = explode(' - ', $this->request->input('created_at'));
                        $builder->whereBetween('created_at', [trim($start), trim($end)]);
                    })
                    ->when(filled($this->request->input('song_name')), function (Builder $builder){
                        $builder->where('song_name', 'like', "%{$this->request->input('song_name')}%");
                    })->when(filled($this->request->input('status')), function (Builder $builder){
                        $builder->where('status', $this->request->input('status'));
                    })
                    ->orderByDesc('id')->paginate($this->pageSize);

        return Response::success($res);
    }

    /**
     * 歌曲文件详情
     * @return \Illuminate\Http\JsonResponse
     */
    public function show()
    {
        $data = [];

        //详情
        if ($track = PropertyTrack::query()->with('project:id,name')->where(['id'=>$this->request->input('track_id'), 'from'=>1])->first()) {
            $user  = AppCompany::query()->where(['company_id'=>$track->create_admin])->first();
            $track->setAttribute('submit_name', $user ? $user->company_name : '');
            $data = $track;
        }

        return Response::success($data);
    }

    /**
     * 待上传数据
     * @return \Illuminate\Http\JsonResponse
     */
    public function pending()
    {
        //$count = PropertyTrack::query()->where(['create_admin'=>$this->request->get('identifier')->company_id])->whereNull('upload_time')->count();
        $count = PropertyTrack::query()->where(['create_admin'=>$this->request->get('identifier')->company_id])->where('status', 0)->count();
        return Response::success(['count'=>$count]);
    }

    /**
     * 歌曲上传文件列表
     * @return \Illuminate\Http\JsonResponse
     */
    public function file()
    {
        $trackFiles = PropertyTrackFile::query()->with('ptfTypes.type:id,type_name,remark')->where(['pt_id'=>$this->request->input('track_id')])
                        ->orderByDesc('id')->paginate($this->pageSize);

        $user_ids = [];
        foreach ($trackFiles as $item) {
            if ($item['from'] == 1) {
                $user_ids[] = $item->upload_user;
            }
        }

        if ($user_ids) {
            $user_ids = AppCompanyUser::query()->whereIn('id', array_unique($user_ids))->pluck('name','id')->toArray();
        }

        foreach ($trackFiles as &$item) {
            if ($item['from'] == 1) {
                $item->upload_user = $user_ids[$item->upload_user] ?? '';
            }
        }

        return Response::success($trackFiles);
    }

    /**
     * 资产歌曲-分享页面当前最新分享信息
     * @return \Illuminate\Http\JsonResponse
     */
    public function share()
    {
        $data = [
            'config'=>[
                'valid_day' =>  config('musician.property')['valid_day'], //有效期天数
            ],
            'phone'     =>  '',
            'share_url' =>  '',
            'expire_time'   =>  '',
        ];

        if ($share = PropertyShare::query()->where(['pf_id'=>$this->request->input('track_id')])->orderByDesc('id')->first()) {
            $data['phone']      = $share->phone;
            $data['share_url']  = $share->share_url;
            $data['expire_time']= $share->expire_time;
        }

        return Response::success($data);
    }

    /**
     * 生成链接
     * @return \Illuminate\Http\JsonResponse
     */
    public function shareCreate()
    {
        if (!PropertyTrack::query()->where(['from'=>$this->request->input('from'), 'id'=>$this->request->input('track_id')])->first()) {
            return Response::error(ErrorCode::SERVER_ERROR, '非法请求');
        }

        $propertyConfig = config('musician.property');
        $share = $propertyConfig['base_url'].uniqid();
        $share_url_hash = crc64($share);
        $expire_time    = time() + $propertyConfig['valid_day'] * 86400;

        //生成新链接-上一个失效
        try {

            //将上一条链接删除
            PropertyShare::query()->where(['pf_id'=>$this->request->input('track_id')])->orderByDesc('id')->limit(1)->delete();

            $expire_time = date('Y-m-d H:i:s', $expire_time);

            //生成新链接
            PropertyShare::query()->create([
                'pf_id'         =>  $this->request->input('track_id'),
                'phone'         =>  $this->request->input('phone'),
                'share_url'     =>  $share,
                'share_url_hash'=>  $share_url_hash,
                'expire_time'   =>  $expire_time,
                'from'          =>  $this->request->input('from'),
                'user_id'       =>  $this->request->input('from') ? $this->request->get('identifier')->company_id : $this->request->input('user_id'), //用户
            ]);

            return Response::success(['url'=>$share, 'expire_time'=>$expire_time]);
        } catch (\Throwable $throwable) {
            return Response::error();
        }
    }

    /**
     * @return \Illuminate\Http\JsonResponse|mixed
     */
    public function shareUser()
    {
        $share = PropertyShare::withTrashed()->where(['share_url_hash'=>crc64($this->request->input('share_url'))])->first();
        if (empty($share)) {return Response::error(ErrorCode::URL_FAIL);} //找不到此链接

        $data = ['from'=>$share->from, 'name'=>''];

        if ($share->from) {
            $record = AppCompany::query()->where(['company_id'=>$share->user_id])->select(['company_name as name'])->first();
        } else {
            $record = User::query()->where(['user_id'=>$share->user_id])->select(['name'])->first();
        }

        $record && $data['name'] = $record->name;

        return Response::success($data);
    }


    /**
     * 验证分享登录有效期
     * @return \Illuminate\Http\JsonResponse
     */
    public function shareCheck()
    {
        $url = $this->request->input('url');

        if (!$res = PropertyShare::withTrashed()->where(['share_url_hash'=>crc64($url)])->first()) {
            return Response::error(ErrorCode::URL_FAIL);
        }

        if ($this->now > $res->expire_time) {
            //过期
            return Response::error(ErrorCode::URL_EXPIRE);
        }

        if ($res->phone != $this->request->input('phone')) {
            return Response::error(ErrorCode::URL_CHECK_FAIL);
        }


        if (!is_null($res->deleted_at)) return Response::error(ErrorCode::URL_CHECK_FAIL);


        //验证成功 - 生成token
        $info = [
            'track_id'  =>  $res->pf_id,
            'id'        =>  $res->id,
        ];

        $token          =   getToken(mt_rand());
        $token_valid    =   config('musician.property')['token_valid'];
        $expire_time    =   time() + $token_valid;

        RedisClient::instance()->set($token, json_encode($info), 'EX', $token_valid);
        return Response::success(['token'=>$token, 'expire_time'=>$expire_time]);
    }


    /**
     * @return \Illuminate\Http\JsonResponse
     */
    public function shareShow()
    {
        $data = [];

        //详情
        if ($track = PropertyTrack::query()->with('project:id,name')->where(['id'=>$this->request->get('track_id')])->first()) {

            if ($track->from) {
                $record = AppCompany::query()->where(['company_id'=>$track->last_admin])->select(['company_name as name'])->first();
            } else {
                $record = User::query()->where(['user_id'=>$track->last_admin])->select(['name'])->first();
            }

            $track->setAttribute('submit_name', $record ? $record->name : '');
            $data = $track;
        }

        return Response::success($data);
    }

    /**
     * 歌曲上传文件列表
     * @return \Illuminate\Http\JsonResponse
     */
    public function shareFile()
    {
        $trackFiles = PropertyTrackFile::query()->with('ptfTypes.type:id,type_name,remark')->where(['pt_id'=>$this->request->get('track_id')])
                            ->orderByDesc('id')->paginate($this->pageSize);

        return Response::success($trackFiles);
    }

    /**
     * 歌曲上传文件列表
     * @return \Illuminate\Http\JsonResponse
     */
    public function shareFileType()
    {
        $res = PropertyFileType::query()->where(['type'=>'track', 'visible'=>1])->orderBy('id')->get();
        return Response::success($res);
    }

    /**
     * 歌曲文件存储 (分享页面)
     * @return \Illuminate\Http\JsonResponse|mixed
     */
    public function shareFileSave()
    {
        try {

            $fileTypes = $this->request->input('file_types');

            DB::transaction(function () use ($fileTypes){

                $upload_user = PropertyShare::query()->where(['id'=>$this->request->offsetGet('id')])->pluck('phone')->first();

                //property_track_files
                $res = PropertyTrackFile::query()->create([
                    'pt_id'         =>  $this->request->offsetGet('track_id'),
                    'name'          =>  $this->request->input('name'),
                    'size_byte'     =>  $this->request->input('size'),
                    'upload_user'   =>  $upload_user,
                    'upload_ip'     =>  $this->request->input('upload_ip'), //上传客户端ip
                    'from'          =>  $this->request->input('from'), // 0：版权 1：分贝登录用户 2：通过分享
                ]);

                $data = [];
                foreach ($fileTypes as $tpye_id) {
                    $data[] = [
                        'pt_id'     =>  $this->request->offsetGet('track_id'),
                        'p_file_id' =>  $res->id,
                        'p_type_id' =>  $tpye_id,
                        'created_at'=>  $this->now,
                    ];
                }

                //property_track_file_types
                PropertyTrackFileType::query()->insert($data);

                //file_maps
                FileMap::query()->create([
                    'user_id'       =>  $this->request->get('identifier') ? $this->request->get('identifier')->user_id : 0,
                    'company_id'    =>  $this->request->get('identifier') ? $this->request->get('identifier')->company_id : 0,
                    'name'          =>  $this->request->input('name'),
                    'path'          =>  $this->request->input('dir'),
                    'location'      =>  $this->request->input('location'),
                    'key'           =>  $this->request->input('url'),
                    'mime'          =>  $this->request->input('mime'),
                    'size'          =>  $this->request->input('size'),
                    'link'          =>  'property',
                    'link_id'       =>  $res->id,
                ]);

                //更新上传时间和状态
                PropertyTrack::query()->where(['id'=>$this->request->offsetGet('track_id')])->update([
                    'status'        =>  1,
                    'upload_time'   =>  $this->now,
                    'total_size'    =>  DB::raw("total_size + {$this->request->input('size')}"),
                ]);
            });

            return Response::success();
        } catch (\Throwable $throwable) {
            Log::info(__METHOD__, ['msg'=>$throwable->getMessage()]);
            return Response::error();
        }
    }

    /**
     * 歌曲文件存储
     * @return \Illuminate\Http\JsonResponse|mixed
     */
    public function fileSave()
    {
        try {

            $fileTypes = $this->request->input('file_types');

            DB::transaction(function () use ($fileTypes){

                $upload_user = $this->request->get('identifier') ? $this->request->get('identifier')->user_id : '';

                //property_track_files
                $res = PropertyTrackFile::query()->create([
                    'pt_id'         =>  $this->request->input('track_id'),
                    'name'          =>  $this->request->input('name'),
                    'size_byte'     =>  $this->request->input('size'),
                    'upload_user'   =>  $upload_user,
                    'upload_ip'     =>  $this->request->input('upload_ip'), //上传客户端ip
                    'from'          =>  $this->request->input('from'), // 0：版权 1：分贝登录用户 2：通过分享
                ]);

                $data = [];
                foreach ($fileTypes as $tpye_id) {
                    $data[] = [
                        'pt_id'     =>  $this->request->input('track_id'),
                        'p_file_id' =>  $res->id,
                        'p_type_id' =>  $tpye_id,
                        'created_at'=>  $this->now,
                    ];
                }

                //property_track_file_types
                PropertyTrackFileType::query()->insert($data);

                //file_maps
                FileMap::query()->create([
                    'user_id'       =>  $this->request->get('identifier')->user_id,
                    'company_id'    =>  $this->request->get('identifier')->company_id,
                    'name'          =>  $this->request->input('name'),
                    'path'          =>  $this->request->input('dir'),
                    'location'      =>  $this->request->input('location'),
                    'key'           =>  $this->request->input('url'),
                    'mime'          =>  $this->request->input('mime'),
                    'size'          =>  $this->request->input('size'),
                    'link'          =>  'property',
                    'link_id'       =>  $res->id,
                ]);


                //更新上传时间和状态
                PropertyTrack::query()->where(['id'=>$this->request->input('track_id')])->update([
                    'status'        =>  1,
                    'upload_time'   =>  $this->now,
                    'total_size'    =>  DB::raw("total_size + {$this->request->input('size')}"),
                ]);

            });

            return Response::success();
        } catch (\Throwable $throwable) {
            Log::info(__METHOD__, ['msg'=>$throwable->getMessage()]);
            return Response::error();
        }
    }

    /**
     * @return \Illuminate\Http\JsonResponse|mixed
     */
    public function getCosToken()
    {
        $client = new \GuzzleHttp\Client([
            'base_uri'  =>   env('resource_url'),
            'timeout'   =>   3.0,
        ]);

        try {

            $response   =   $client->post('/api/inside/getCosToken', [
                'json'  =>  ['data'=>$this->request->only(['dir', 'type'])],
            ]);
            $respArr    =   json_decode($response->getBody()->getContents(), true);

            $respArr['msg'] = $respArr['message'];
            unset($respArr['message']);

            return response()->json($respArr, 200);
        } catch (\Throwable $throwable) {
            return Response::error(ErrorCode::SERVER_ERROR, $throwable->getMessage());
        }
    }

}