DER2021102201/app/api/model/plus/live/Gift.php

<?php

namespace app\api\model\plus\live;

use app\common\enum\user\GiftLogSceneEnum;
use app\common\model\plus\live\Gift as GiftModel;
use app\api\model\user\User as UserModel;
use app\common\model\plus\live\RoomGift as RoomGiftModel;
use app\common\model\user\GiftLog as GiftLogModel;
use app\common\model\plus\live\Room as RoomModel;
use app\common\model\plus\live\UserGift as UserGiftModel;
use app\api\model\supplier\Supplier as SupplierModel;
/**
 * 礼物模型
 */
class Gift extends GiftModel
{

    /**
     * 获取礼物列表
     */
    public function getList()
    {
        return $this->with(['image'])
            ->where('is_delete', '=', 0)
            ->order(['sort' => 'asc', 'create_time' => 'asc'])
            ->select();
    }

    public function sendGift($user, $room_id, $gift_id){
        $gift = self::detail($gift_id);
        $room = RoomModel::detail($room_id);
        if(!$gift || $gift['is_delete'] == 1){
            $this->error = '礼物不存在';
            return false;
        }
        if($user['gift_money'] < $gift['price']){
            $this->error = '余额不足';
            return false;
        }
        $this->startTrans();
        try {
            // 扣除
            (new UserModel())->where('user_id', '=', $user['user_id'])
                ->dec('gift_money', $gift['price'])
                ->update();
            // 主播增加
            (new SupplierModel())->where('shop_supplier_id', '=', $room['shop_supplier_id'])
                ->inc('total_gift', $gift['price'])
                ->inc('gift_money', $gift['price'])
                ->update();
            // 房间增加
            (new RoomModel())->where('room_id', '=', $room_id)
                ->inc('gift_num', $gift['price'])
                ->update();
            // 房间用户礼物数增加
            $user_gift_model = UserGiftModel::detail($room_id, $user['user_id']);
            $user_gift_model->where('room_id', '=', $room_id)->where('user_id', '=', $user['user_id'])
                ->inc('gift_num', $gift['price'])->update();
            // 保存记录
            (new RoomGiftModel())->save([
                'room_id' => $room_id,
                'user_id' => $user['user_id'],
                'shop_supplier_id' => $room['shop_supplier_id'],
                'price' => $gift['price'],
                'gift_name' =>  $gift['gift_name'],
                'app_id' => self::$app_id
            ]);
            GiftLogModel::add(GiftLogSceneEnum::CONSUME, [
                'user_id' => $user['user_id'],
                'money' => -$gift['price'],
            ], ['gift_name' => $gift['gift_name']]);
            $this->commit();
            return true;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
            return false;
        }
    }
}