PropertyTrackService.php 6.76 KB
<?php

namespace App\Services;

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\PropertyShare;
use App\Models\Legal\PropertyShareVerification;
use App\Models\Legal\PropertyTrack;
use App\Models\Legal\PropertyTrackFile;
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 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('upload_time')), function (Builder $builder){
                        list($start, $end) = explode(' - ', $this->request->input('upload_time'));
                        $builder->whereBetween('upload_time', [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();
        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')])
                        ->paginate($this->pageSize);

        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['token_valid'];

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

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

            //生成新链接
            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'   =>  date('Y-m-d H:i:s', $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]);
        } 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::query()->where(['share_url_hash'=>crc64($url), 'from'=>$this->request->input('from')])->where('expire_time', '<=', $this->now)->first()) {
            return Response::error(ErrorCode::URL_CHECK_FAIL);
        }

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

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