UserExchangesController.php

<?php


namespace App\Http\Controllers;


use App\Http\Filters\UserExchangeFilter;
use App\Models\ExchangeSetting;
use App\Models\UserExchange;
use App\Models\UserIntegral;
use Common\Model\RedisModel;
use Hhxsv5\LaravelS\Swoole\Task\Task;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

/**
 * 用户红包兑换管理
 * Class UserExchangesController
 * @package App\Http\Controllers
 */
class UserExchangesController extends Controller
{
    /**
     * @param Request $request
     * @return array
     */
    public function show(Request $request)
    {
        $id = $request->id;
        $userExchange = UserExchange::with('exchange_setting')->where('id', $id)->first()->toArray();

        return $this->Export(0, 'ok', ['data' => $userExchange]);
    }

    /**
     * 用户兑换红包列表
     * @param Request $request
     * @param UserExchange $userExchange
     * @param UserExchangeFilter $filter
     * @return array
     */
    public function index(Request $request, UserExchange $userExchange, UserExchangeFilter $filter)
    {
        $page = $request->has('page') ? $request->page : self::DEFAULT_PAGE;
        $pageSize = $request->has('page_size') ? $request->page_size : self::DEFAULT_PAGE_SIZE;

        $res = $userExchange->getUserExchangeList($page, $pageSize, $filter);

        return $this->Export(0, 'ok', $res);
    }


    /**
     * 审核用户的兑换
     * @param Request $request
     * @param UserExchange $userExchange
     * @return array
     */
    public function audit(Request $request, UserExchange $userExchange)
    {
        $data = [
            'audit_reason' => $request->get('audit_reason'),
            'audit_time'   => time(),
            'update_time'  => time(),
            'audit_id'     => $request->get('audit_id'),
            'user_id'      => $request->get('user_id'),
            'audit_email'  => $request->get('audit_email'),
            'status'       => $request->get('status'),
        ];
        $res = $userExchange->auditUserExchange($request->id, $request->exchange_amount, $data);
        if ($res) {
            return $this->Export(0, 'ok');
        } else {
            return $this->Export(16, '审核用户兑换失败');
        }
    }

    /**
     * 批量审核
     * @param Request $request
     * @param UserExchange $userExchange
     * @return array
     */
    public function batchAuditReject(Request $request, UserExchange $userExchange)
    {
        $ids = $request->ids;
        if (!is_array($ids)) {
            return Log::Info('批量修改参数不是数组');
        }

        $data = [
            'status'       => (int)$request->status,
            'audit_reason' => $request->audit_reason,
            'audit_id'     => $request->audit_id,
            'audit_email'  => $request->audit_email,
            'update_time'  => time(),
        ];
        $res = $userExchange->batchAuditRejectUserExchange($ids, $data);
        if ($res) {
            return $this->Export(0, 'ok');
        } else {
            return $this->Export(17, '审核批量拒绝兑换失败');
        }
    }

    //用于抢兑换名额
    public function create(Request $request)
    {
        $Field = ['user_id', 'exchange_id'];
        $collert = $request->only($Field);

        $Redis = new RedisModel();

        //先判断客户今天是否抢到名额
        $time = date('Ymd');
        $Pre = 'ic_exchanges_quota_' . $time;
        $Record = $Redis->hget($Pre, $collert['user_id']);

        if ($Record) {
            return $this->Export(ErrorCode(100, 1), '今天已经兑换过来，请明天再来吧');
        }

        //获取用户红包
        $UserInfo = $Redis->hget('ic_user', $collert['user_id']);

        $UserInfo = json_decode($UserInfo, true);
        if (empty($UserInfo['integral'])) {
            return $this->Export(ErrorCode(102, 1), '红包余额不足');
        }

        //获取红包配置
        $ic_exchange_settings = json_decode($Redis->hget('ic_exchange_settings', $collert['exchange_id']), true);

        //判断红包提现设置是否可用
        if (!$ic_exchange_settings || $ic_exchange_settings['status'] != 1) {
            return $this->Export(ErrorCode(103, 1), '当前提现不可用');
        }

        //判断用余额
        if ($ic_exchange_settings['amount'] > $UserInfo['integral']) {
            return $this->Export(ErrorCode(102, 1), '红包余额不足');
        }

        //消费名额
        $Cahce = $Redis->rpop('ic_exchange_settings_' . $collert['exchange_id']);
        if (!$Cahce) {
            return $this->Export(ErrorCode(101, 1), '名额被抢光了');
        }
        $Cahce = json_decode($Cahce, true);

        //记录当前消费的名额，自动过期
        $Redis->hset($Pre, $collert['user_id'], $collert['exchange_id']);
        $Redis->expire($Pre, 60 * 60 * 24);

        try {
            DB::beginTransaction();

            //扣减用户金额
            $UserIntrgralModel = new UserIntegral();
            $result = $UserIntrgralModel->Deduction($collert['user_id'], $ic_exchange_settings['amount']);

            if (!$result) {
                ErrorLog(ErrorCode(1, 9), '扣减用户红包失败,用户ID:' . $collert['user_id']);
                throw new \Exception('扣减用户红包失败,用户ID:' . $collert['user_id']);
            }

            //添加红包记录
            $UserExchangeModel = new UserExchange();
            $data = [
                'user_id'     => $collert['user_id'],
                'type'        => $ic_exchange_settings['type'],
                'exchange_id' => $ic_exchange_settings['id'],
                'amount'      => $ic_exchange_settings['amount'],
            ];

            $result = $UserExchangeModel->addRecord($data);
            if (!$result) {
                $Errinfo = '红包提现记录添加失败' . $collert['user_id'];
                ErrorLog(ErrorCode(1, 9), $Errinfo);
                throw new \Exception($Errinfo);
            }

            //提前提交事务
            DB::commit();

            //扣减缓存里面的红包金额
            $UserInfo['integral'] = $UserInfo['integral'] - $ic_exchange_settings['amount'];
            $Redis->hset('ic_user', $UserInfo['user_id'], json_encode($UserInfo));

            //金额小于20元时，推送一个异步任务（用来提现或者充值），延时10秒，防止主从同步不及时
            if ($data['amount'] < 20) {
                $Task = new ExchangesTask($data, $ic_exchange_settings);
                $Task->delay(10);
                $result = Task::deliver($Task);
                if (!$result) {
                    ErrorLog(ErrorCode(1, 9), '提现任务推送失败，提现ID:' . $data['id']);
                }
            }

            return $this->Export(0, 'ok', ['data' => $data['id']]);

        } catch (\Exception $e) {
            DB::rollBack();
            SendErrMsg($e);

            return $this->Export(ErrorCode(100, 5), '提现失败');
        }
    }
}