area-point-api/app/Http/Controllers/Api/Course/VideoController.php

<?php

namespace App\Http\Controllers\Api\Course;

use App\Http\Controllers\Controller;
use App\Repositories\Criteria\Course\VideoCriteria;
use App\Repositories\Enums\ModelStatusEnum;
use App\Repositories\Enums\ResponseCodeEnum;
use App\Repositories\Enums\VideoWatchEnum;
use App\Repositories\Models\Course\UserRecord;
use App\Repositories\Models\Course\Video;
use App\Repositories\Models\UserVideoWatchRecord;
use Carbon\Carbon;
use Illuminate\Http\Request;
use Illuminate\Support\Str;
use Jiannei\Response\Laravel\Support\Facades\Response;
use Prettus\Validator\Contracts\ValidatorInterface;
use App\Contracts\Repositories\Course\VideoRepository;
use App\Repositories\Validators\Course\VideoValidator;

/**
 * Class CourseVideosController.
 *
 * @package namespace App\Http\Controllers;
 */
class VideoController extends Controller
{
    /**
     * @var VideoRepository
     */
    protected $repository;

    /**
     * @var VideoValidator
     */
    protected $validator;

    /**
     * CourseVideosController constructor.
     *
     * @param VideoRepository $repository
     * @param VideoValidator $validator
     */
    public function __construct(VideoRepository $repository, VideoValidator $validator)
    {
        $this->repository = $repository;
        $this->validator = $validator;
    }

    /**
     * 列表
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource
     * Author: Mead
     */
    public function index()
    {
        $this->repository->pushCriteria(VideoCriteria::class);
        $courseVideos = $this->repository->paginate(request('per_page', self::PAGE_NUM));
        return Response::success($courseVideos);
    }

    /**
     * 创建
     * @param Request $request
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource|void
     * @throws \Illuminate\Validation\ValidationException
     * Author: Mead
     */
    public function store(Request $request)
    {
        $this->validate($request, $this->validator->getRules(ValidatorInterface::RULE_CREATE));
        try {
            $data = $request->only(array_keys($this->validator->getRules(ValidatorInterface::RULE_CREATE)));
            $data['user_id'] = login_user_id();
            $data['slug'] = Str::random();

            if (!in_array('published_at', $data) || empty($data['published_at'])) {
                $data['published_at'] = Carbon::now();
            }

            $courseVideo = $this->repository->create($data);
            return Response::success($courseVideo);
        } catch (\Exception $e) {
            return $this->errorStore($e);
        }
    }

    /**
     * 详情
     * @param $slug
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource
     * Author: Mead
     */
    public function show($slug)
    {
        $courseVideo = $this->repository->where('slug', $slug)->first();
        if (!$courseVideo) {
            return $this->error('找不到资源');
        }
        $courseVideo = $this->repository->parserResult($courseVideo);
        return Response::success($courseVideo);
    }

    /**
     * 更新
     * @param Request $request
     * @param $id
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource
     * @throws \Illuminate\Validation\ValidationException
     * Author: Mead
     */
    public function update(Request $request, $id)
    {
        $this->validate($request, $this->validator->getRules(ValidatorInterface::RULE_UPDATE));
        try {
            $data = $request->only(array_keys($this->validator->getRules(ValidatorInterface::RULE_UPDATE)));

            if (!in_array('published_at', $data) || empty($data['published_at'])) {
                $data['published_at'] = Carbon::now();
            }

            $courseVideo = $this->repository->update($data, $id);
            return Response::success($courseVideo);
        } catch (\Exception $e) {
            $this->errorStore($e);
        }
    }

    /**
     * 删除
     * @param $id
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource
     * Author: Mead
     */
    public function destroy($id)
    {
        try {
            $this->repository->delete($id);
            return Response::success(null, T('successfully delete.'));
        } catch (\Exception $exception) {
            return Response::fail(T('Delete failed.'), ResponseCodeEnum::SERVICE_UPDATE_DATA_ERROR);
        }
    }

    /**
     * 视频详情（用户）
     * @param $id
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\JsonResource
     * Author: Mead
     */
    public function detail($slug)
    {
        $video = $this->repository->where('status', ModelStatusEnum::OK)->where('published_at', '<', Carbon::now())->where('slug', $slug)->first();

        if (!$video) {
            return $this->error('找不到该资源');
        }

        $comments = $video->comments()->with(['user'])->limit(self::PAGE_NUM)->orderByDesc('id')->get();

        $attaches = $video->attaches()->with(['path_resource'])->where('status', ModelStatusEnum::OK)->get(['name', 'id', 'path', 'download_times']);

        $video->view_num++;
        $video->save();

//        $user_video_watch_record = UserVideoWatchRecord::query()->firstOrCreate([
//            'video_id' => $video->id,
//            'user_id' => login_user_id()
//        ], [
//            'course_id' => $video->course_id,
//            'watch_seconds' => 0,
//            'is_watched' => VideoWatchEnum::NO,
//            'progress' => 0
//        ]);

        $video = $this->repository->parserResult($video);

        return Response::success(compact('video', 'comments', 'attaches'));
    }

    /**
     * 记录观看进度
     * @param Request $request
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource
     * @throws \Illuminate\Validation\ValidationException
     * Author: Mead
     */
    public function lookRecord(Request $request)
    {
        $this->validate($request, [
            'course_id' => 'required',
            'video_id' => 'required',
            'watch_seconds' => 'required',
            'is_watched' => 'required',
        ]);

        $course_id = $request->get('course_id');
        $video_id = $request->get('video_id');
        $watch_seconds = $request->get('watch_seconds', 10);
        $is_watched = $request->get('is_watched', VideoWatchEnum::NO);

        $total_seconds = Video::query()->where('id', $video_id)->value('duration');

        $progress = 100;
        if ($total_seconds > 0) {
            $progress = bcdiv($watch_seconds, $total_seconds, 2) * 100;
        }

        if ($progress >= 98) {
            $is_watched = VideoWatchEnum::OK;
        }
        if ($progress > 100) {
            $progress = 100;
        }

        UserVideoWatchRecord::query()->updateOrCreate(['video_id' => $video_id, 'user_id' => login_user_id()], [
            'is_watched' => $is_watched,
            'course_id' => $course_id,
            'watch_seconds' => $watch_seconds,
            'watched_at' => Carbon::now(),
            'progress' => $progress
        ]);

        if ($is_watched == VideoWatchEnum::OK) {
            $video_over_nums = UserVideoWatchRecord::query()->where('course_id', $course_id)->where('is_watched', VideoWatchEnum::OK)->count();
            $video_total_nums = Video::query()->where('course_id', $course_id)->count();
            if ($video_total_nums > 0) {
                $course_progress = bcdiv($video_over_nums, $video_total_nums, 2) * 100;
            } else {
                $course_progress = 100;
            }

            $course_over_status = VideoWatchEnum::NO;
            if ($course_progress >= 98) {
                $course_over_status = VideoWatchEnum::OK;
            }
            UserRecord::query()->where('course_id', $course_id)->where('user_id', login_user_id())->update(['progress' => $course_progress, 'is_watched' => $course_over_status, 'watched_at' => Carbon::now()]);
        }

        return Response::success(null);
    }

    /**
     * 选项
     * @param Request $request
     * @return \Illuminate\Http\JsonResponse|\Illuminate\Http\Resources\Json\Resource
     * Author: Mead
     */
    public function selectOptions(Request $request)
    {
        $lists = $this->repository->select(['id', 'title'])->paginate($request->get('per_page', self::PAGE_NUM));
        return Response::success($lists);
    }

}