zhangsiye/server/app/Http/Controllers/V1/User/EpisodeController.php

<?php
namespace App\Http\Controllers\V1\User;

use App\Http\Controllers\V1\Controller;
use App\Models\Episode;
use App\Models\EpisodesList;
use App\Models\UserConsumeRecord;
use App\Models\UserEpisodesRecord;
use App\Models\UserInfo;
use Illuminate\Database\QueryException;

class EpisodeController extends Controller
{
    public function buyRecord($episode)
    {
        $lists = UserEpisodesRecord::filterUser()
            ->select(['episodes_id','list_id'])
            ->where('episodes_id',$episode)
            ->get()
            ->pluck('list_id');

        return $this->success($lists);
    }

    public function buy($episode,$list)
    {
        try {
            \DB::beginTransaction();

            $episode = Episode::find($episode);
            $list = EpisodesList::find($list);
            $user = UserInfo::find(\user()->id);


            $count = UserEpisodesRecord::filterUser()->where('list_id',$list->id)->count();
            if($count){
                return $this->error('请勿重复购买');
            }

            if($user->integral < $list->sale_price){
                return $this->success([
                    'overage' => 0
                ],0,'余额不足');
            }

            // 购买记录
            $record = new UserEpisodesRecord();
            $record->user_id =\user()->id;
            $record->episodes_id = $episode->id;
            $record->list_id = $list->id;
            $record->price = $list->sale_price;
            $record->status = 1;
            $record->save();

            // 记录日志
            app(UserConsumeRecord::class)->record(
                \user()->id,
                UserConsumeRecord::TYPE_CONSUME,
                -$list->sale_price,
                "购买短剧 {$episode->name} 第{$list->sort}集"
            );
            // 扣除金币
            $user->integral = $user->integral - $list->sale_price;
            $user->save();

            \DB::commit();
            return $this->success(['episode_id' => $episode, 'list_id' => $list]);
        }catch (QueryException $e){
            \DB::rollBack();
            return $this->error('购买失败');
        }catch (\Exception $ex){
            \DB::rollBack();
            return $this->error('购买失败');
        }
    }
}