kge_newlavarel/app/Jobs/GiftJob.php

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

use Illuminate\Support\Facades\DB;
use Redis;
use Illuminate\Support\Facades\Log;

class GiftJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $msgid;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($msgid)
    {
        //
        $this->msgid = $msgid;
        Log::info(date('Y-m-d H:i:d').':'.$msgid);

    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $result = $this->goaaa();


        if($result === false){
            //防止失败
            $key = 'kgelavarel_giftjob_'.$this->msgid;

            $limit_rs = $this->apiLimit(2,3600000,$key);//一小时最多另执行2次

            if($limit_rs === true){
                //echo 123;
                dispatch((new GiftJob($this->msgid))->delay(60));//加入队列
            }else{
                //echo 345;
            }
        }
    }

    public function apiLimit($apiLimit = 1, $apiLimitTime = 1000, $key = '')
    {
        $redisconfig = [
            // 主机
            'host'     => 'r-uf6s12w1bbuff46572.redis.rds.aliyuncs.com',
            'host'     => 'r-uf6s12w1bbuff46572pd.redis.rds.aliyuncs.com',//外网
            // 端口
            'port'      => 6379,
            'redis_pwd' => 'tA2sXnCJcKdwzxi6',
            'redis_selectdb' => 0,
        ];

        $redis = new Redis();
        $redis->connect($redisconfig["host"], $redisconfig["port"]);
        if ($redisconfig['redis_pwd']) {
            $redis->auth($redisconfig['redis_pwd']);
        }
        if($redisconfig['redis_selectdb'] > 0){
            $redis->select($redisconfig['redis_selectdb']);
        }

        //
        //指定键值新增+1 并获取
        $count = $redis->incr($key);
        if ($count > $apiLimit) {
            return false;
        }

        //设置过期时间
        if ($count == 1) {
            $redis->pExpire($key, $apiLimitTime);
        }

        return true;
    }

    public function goaaa(){
        
        //
        $data = DB::table('hx_gift_user_party')->where('id',$this->msgid)->first();

        DB::beginTransaction();

        //用户信息
        $authuser_info = DB::table('hx_user')->where('id',$data->user_id)->value('nickname');
        $partyInfo     = DB::table('hx_party')->where('id',$data->party_id)->first();


        $money_to_jewel = 10000;
        $user_id = $data->user_to_id;
        // 添加获赠用户余额
        if($data->getvalue > 0){
            $getMoney = bcdiv($data->getvalue,$money_to_jewel,2);
            if($getMoney > 0){
                $rs_wallet = $this->lockChangeAccountRemain($user_id,$getMoney,'+',0,"{$authuser_info}送你{$data->gift_name}x{$data->number}",101,'money');
                if($rs_wallet['status'] == false){
                    Db::rollback();
                    return false;
                }
            }
        }

        // 增加房主抽成
        if ($partyInfo) {
            $guilderMoney = $data->guildermoney;
            if($guilderMoney > 0){
                $touserInfo    = DB::table('hx_user')->where('id',$user_id)->value('nickname');
                $rs_wallet = $this->lockChangeAccountRemain($partyInfo->user_id,$guilderMoney,'+',0,"{$authuser_info}送礼物{$data->gift_name}x{$data->number}给{$touserInfo},房间礼物抽成",102,'money');
                if($rs_wallet['status'] == false){
                    Db::rollback();
                    return false;
                }
            }
        }

        Db::commit();
        return true;
    }


    /**
     *
     * @param floatval $number 金额（正数进账，负数出账）
     * @param $accountType 货币类型，money,score
     * @param $logtype 日志的类型
     * @param $remark  备注
     * @param $user_id  用户id
     * @param $table  来源表
     * @param $data_id  表id
     * @param $isAdmin 是否是管理员处理
     * @return array
     * @return array[status]
     * @return array[msg]
     * @return array[log_table]
     * @return array[log_id]
     */
    public function lockChangeAccountRemain($user_id,$money,$mode,$before = 0,$remark='',$logtype,$accountType='money',$extend = [])
    {
        //初始化
        $result = array(
            'status'=>false,
            'code' => 0, //报错时候采用
            'msg'=>'',
            'log_table' => '',
            'log_id' => '',
        );

        //获取小数点
        $point = $accountType == 'money' ? 2 : 0;
        bcscale($point);

        //钱包名称
        $wallet_name = '余额';

        //数字纠正
        $money = abs($money);
        if($mode == '-'){
            $number = -$money;
        }else{
            $number = $money;
        }

        //检测
        $number = floatval( $number );
        if( $number == 0 )
        {
            $result['msg'] = '交易金额:0';
            return $result;
        }
        if(0 === bccomp($number, 0)){
            $result['msg'] = '交易金额:0';
            return $result;
        }


        //检测
        $wallet = DB::table('hx_user_wallet')->where('user_id',$user_id)->lockForUpdate()->first();
        if(empty($wallet))
        {
            $result['msg'] = '不存在的用户';
            return $result;
        }

        if(bccomp(bcadd($wallet->$accountType, $number), 0) === -1)
        {
            $result['code'] = 10;
            $result['msg'] = $wallet_name.'余额不足!';
            return $result;
        }

        if(0 !== bccomp($number, 0))
        {

            //钱币记录
            $data = array();
            $data['user_id'] = $user_id;
            $data['value'] = $money;
            $data['mode'] = $mode;
            $data['before'] = $wallet->$accountType;
            $data['balance'] = bcadd($wallet->$accountType, $number);
            $data['detail'] = $remark;
            $data['createtime'] = time();
            $data['type'] = $logtype;
            if ($accountType == 'jewel') {
                $data['cityname'] = isset($extend['cityname']) ? $extend['cityname'] : '';
            }
            //新的方式
            $rs1 = DB::table('hx_user_wallet')->where('user_id',$user_id)->update([$accountType => $data['balance']]);

            /////////////
            $log_table = 'hx_user_'.$accountType.'_log';

            $rs2_id = DB::table($log_table)->insertGetId($data);

            if($rs1 === false || $rs2_id === false){
                $result['msg'] = '更新财务记录失败!';
                return $result;
            }


            if( $rs1 !== false && $rs2_id !== false )
            {
                $result['status'] = true;
                $result['msg'] = '账户余额已更新!';
                $result['log_table'] = $accountType.'_log';
                $result['log_id'] = $rs2_id;

                return $result;
            }
            else
            {
                $result['msg'] = '更新财务记录失败!';
                return $result;
            }
        } else {
            $result['msg'] = '金额不足0.01';
            return $result;
        }

    }

}