admin_api/app/Http/Controllers/Game/RechargeController.php

<?php


namespace App\Http\Controllers\Game;

use App\dao\Pay\AccountPayInfo;
use App\Facade\TableName;
use App\Http\helper\NumConfig;
use App\Http\logic\api\CashPayLogic;
use App\Http\logic\api\RechargeLogic;
use App\Models\AccountsInfo;
use App\Models\Order;
use App\Models\Platform\MonthCard;
use App\Services\ApkService;
use App\Util;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;
use function GuzzleHttp\Psr7\rewind_body;

class RechargeController
{
    protected $JumpOut = [2, 4, 9, 13, 12, 14];
    protected $Sdk = [];

    // 返回支付档位
    public function gear(Request $request)
    {


        $list = DB::table('agent.dbo.recharge_gear')
            ->select('id','money','favorable_price','give','recommend','gear')
            ->orderBy('money', 'asc')->where('status', 1)->get();

        return apiReturnSuc(['list'=>$list,'bonus_show'=>false]);
    }


    // 根据支付档位获取渠道
    public function getPayChannel(Request $request)
    {
        $id = $request->id ?: '';
        $ChannelNumber = $request->ChannelNumber ?: '';
        if (empty($id)) {
            return apiReturnFail(['web.payment.payment_error','PayMent Error']);
        }


        $key="get_channel_{$id}_{$ChannelNumber}";

//        if(Redis::exists($key)) {
//            $result=json_decode(Redis::get($key));
//        }else {
            $first = DB::table('agent.dbo.recharge_gear')
                ->where('status', 1)
                ->where('id', $id)
                ->first();

            if (empty($first)) {
                return apiReturnFail(['web.payment.payment_error','PayMent Error']);
            }

            $first->favorable_price = $first->favorable_price + $first->give;


            $UserID=$request->UserID;

            if(env('MULTI_COUNTRY',0)==1){


                $names = DB::table('agent.dbo.admin_configs')
                    ->where('type', 'pay_method')
                    ->where('status', '1')
                    ->where('country',$request->Country??AccountsInfo::select('BindCountry')->where('UserID',$UserID)->first()->BindCountry)
                    ->select('id', 'name', 'new_pay_type')
                    ->orderByDesc('sort')->get()
                    ->map(function ($value) {
                        return (array)$value;
                    })->toArray();
            }else{
                $names = DB::table('agent.dbo.admin_configs')
                    ->where('type', 'pay_method')
                    ->where('status', '1')
                    ->select('id', 'name', 'new_pay_type')
                    ->orderByDesc('sort')->get()
                    ->map(function ($value) {
                        return (array)$value;
                    })->toArray();
            }



            // 渠道
            if ($ChannelNumber != '') {
                $switch = Redis::get("recharge_config_switch_{$ChannelNumber}");
                if ($switch) {
                    $list = DB::connection('write')->table('QPPlatformDB.dbo.ChannelOpenRecharge as go')
                        ->join('agent.dbo.admin_configs as cf', 'go.ConfigID', '=', 'cf.id')
                        ->where('go.Channel', $ChannelNumber)
                        ->where('go.Status', 1)
                        ->where('cf.type', 'pay_method')
                        ->orderByDesc('go.Sort')
                        ->select('go.Sort', 'ConfigID')
                        ->pluck('Sort', 'ConfigID')->toArray();
                }
            }

            if (!isset($list) || count($list) < 1) {  // 默认配置
                $list = DB::connection('write')->table('agent.dbo.admin_configs')
                    ->where('type', 'pay_method')
                    ->where('status', 1)
                    ->select('sort as Sort', 'id as ConfigID')
                    ->pluck('Sort', 'ConfigID')->toArray();
            }

            $data = [];

            foreach ($names as $k => $va) {
                if (isset($list[$va['id']])) {
                    $type = $va['new_pay_type'] == 1 ? 3 : 2;

                    if ($va['new_pay_type'] == 4) {
                        $type = 0;
                    }
                    // type = 1 sdk跳转 type=2 外跳链接  type=0  默认 type=3 复制信息到APP支付
                    $data[] = ['id' => $va['id'],
                        'name' => $va['name'], 'status' => 1, 'type' => $type, 'sort' => $list[$va['id']]];
                }
            }

//        $first->cpf_first=0;
//        if($ChannelNumber==103)$first->cpf_first=1;

            $gear = array_values($data);
            $gear = collect($gear)->sortByDesc('sort')->toArray();
            $first->kefu_switch = 1;
            $gear = array_values($gear);
            $first->gear = \GuzzleHttp\json_encode($gear);
            $result = apiReturnSuc($first);
//            Redis::set($key,json_encode($result));
//            Redis::expire($key,60);
//        }
//        $dir = $path = app()->basePath() . DIRECTORY_SEPARATOR . 'public' . DIRECTORY_SEPARATOR . 'cache';
//        if (!file_exists($dir)) {
//            mkdir($dir, 0777);
//        }
//        $path = $dir . DIRECTORY_SEPARATOR . "get_channel_{$id}_{$ChannelNumber}.json";
//        file_put_contents($path, json_encode($result));
        return $result;
    }

    // 返回支付渠道
    public function payChannel()
    {
        $list = DB::table('agent.dbo.admin_configs')->where('type', 'pay_method')
            ->where('status', 1)
            ->select('id', 'name', 'status')
            ->orderByDesc('sort')->get();

        foreach ($list as &$value) {
            if (in_array($value->id, $this->Sdk)) {
                $value->type = 0;
            } elseif (in_array($value->id, $this->JumpOut)) {
                $value->type = 2;
            } else {
                $value->type = 0;
            }
        }
        unset($value);
        return apiReturnSuc("$list");
    }

    // 首充可选择渠道
    public function firstPayfirstPayConfig(Request $request)
    {
        $origin = $_SERVER['HTTP_ORIGIN'] ??$_SERVER['HTTP_REFERER']?? '*';
        if (strstr($origin, "52256") ) {
            return apiReturnSuc(null);
        }
        $user=$request->user();
        if($user){
            $firstPayExists = DB::table(TableName::QPAccountsDB().'UserRechargeActive')->where('UserID',$user->UserID)->first();
            if($firstPayExists){
                return apiReturnSuc(null);
            }
        }
        // 推荐充值档位
        $recomendar_recharge = DB::table(TableName::QPAccountsDB() . 'SystemStatusInfo')
            ->where('StatusName', 'RecomendarRecharge')
            ->value('StatusValue');
        $first_pay = DB::table('agent.dbo.recharge_gear')->where('status', 1)
            ->where('first_pay', 1)->first();
        if (!$first_pay) {
            return apiReturnSuc(compact('first_pay', 'recomendar_recharge'));
        }
        $names = DB::table('agent.dbo.admin_configs')
            ->where('type', 'pay_method')
            ->where('status', 1)
            ->select('id', 'name', 'new_pay_type')->orderByDesc('sort')->get()->toArray();


        $first_pay->favorable_price = $first_pay->favorable_price + $first_pay->give;

        $data = [];

        foreach ($names as $k => $va) {
            $type = $va->new_pay_type == 1 ? 3 : 2;
            if($va->new_pay_type == 4){
                $type = 0;
            }
            // type = 1 sdk跳转 type=2 外跳链接  type=0  默认 type=3 复制信息到APP支付
            $data[] = ['id' => $va->id, 'name' => $va->name, 'status' => 1, 'type' => $type];
        }
        $gear = array_values($data);
        $first_pay->gear = \GuzzleHttp\json_encode($gear);

        $ChannelNumber = $request->ChannelNumber ?: '';
//        $first_pay->cpf_first=0;
//        if($ChannelNumber==103)$first_pay->cpf_first=1;

        return apiReturnSuc(compact('first_pay', 'recomendar_recharge'));
    }

    // 引导付费
    public function guidePayment(Request $request)
    {
        $UserID = (int)$request->globalUser->UserID;//$request->input('UserID');

        // 引导付费标识
//        $guide_payment_exists = DB::table(TableName::agent() . 'guide_payment')->where('UserID', $UserID)->first();
        $flag = false;

        // 查看用户有没有充值过【只要充值过，引导付费就不能充值】
        $user_recharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
            ->where('UserID', $UserID)
            ->value('Recharge') ?: 0;

        if ($user_recharge > 0) {
            $flag = true;
        }

        // 引导付费礼包列表
        $guidePayment = (new RechargeLogic())->guidePayment($this->JumpOut);
        // 日期 -- 倒计时【小时】
        $countdown = 24;
        return apiReturnSuc(['is_pay' => $flag, 'countdown' => $countdown, 'guidePayment' => $guidePayment]);
    }

    // 充值Vip等级
    public function vipConfig(Request $request)
    {
        $res = DB::table('QPAccountsDB.dbo.ProtectLevel')
            ->orderBy('Recharge')->get();
        $list = [];
        foreach ($res as $v) {
            $list[] = [
                'id' => $v->ID,
                'money' => $v->Recharge,
                'num' => $v->ID - 1,
                'relief_money' => $v->GrantNum/100,
                'vip' => $v->ID - 1,
            ];
        }
        // 充值礼包
        $monthCards = MonthCard::query()
            ->select('CardID', 'CardName', 'Price', 'FirstReward', 'DayReward', 'gear', 'CardState')
            ->where(['CardType' => 1,])
            ->get();
        // 充值渠道过滤
        $UserID = (int)$request->globalUser->UserID;//$request->input('UserID');
        $accountInfo = AccountsInfo::query()->where('UserID', $UserID)->first();
        $channel = $accountInfo->Channel ?? 0;
        $switch = Redis::get("recharge_config_switch_{$channel}");
        if ($channel && $switch) {
            $channels = DB::connection('write')->table('QPPlatformDB.dbo.ChannelOpenRecharge as go')
                ->join('agent.dbo.admin_configs as cf', 'go.ConfigID', '=', 'cf.id')
                ->where('go.Channel', $channel)
                ->where('go.Status', 1)
                ->where('cf.type', 'pay_method')
                ->orderByDesc('go.Sort')
                ->select(
                    DB::raw('cf.id as id'),
                    'name',
                    'config_value',
                    'new_pay_type',
                    DB::raw('go.Sort as sort')
                )
                ->get()
                ->toArray();
        }

        if (empty($channels)) {
            $channels = DB::table('agent.dbo.admin_configs')
                ->select('id', 'name', 'config_value', 'new_pay_type', 'sort')
                ->where([
                    'type' => 'pay_method',
                    'status' => 1
                ])
                ->orderByDesc('sort')
                ->get()->toArray();
        }

        foreach ($monthCards as $k => $v) {
            $monthCards[$k]['CardID'] = $monthCards[$k]['CardID'] + 100;
            $monthCards[$k]['FirstReward'] = $v['FirstReward']/100;
            $monthCards[$k]['DayReward'] = $v['DayReward']/100;
            $cardChannels = [];
            foreach ($channels as $channel) {
                $channel->type = $channel->new_pay_type == 4?0: ($channel->new_pay_type == 1 ? 3 : 2);
                $cardChannels[] = [
                    'id' => $channel->id,
                    'name' => $channel->name,
                    'pic' => $channel->config_value,
                    'status' => 1,
                    'type' => $channel->new_pay_type == 4?0: ($channel->new_pay_type == 1 ? 3 : 2),
                    'new_pay_type' => $channel->new_pay_type,
                    'sort' => $channel->sort
                ];
            }
            usort($cardChannels, function ($a, $b) {
                return $a['sort'] > $b['sort'] ? -1 : 1;
            });
            $monthCards[$k]['gear'] = json_encode($cardChannels);
        }
        return apiReturnSuc(compact('list', 'monthCards'));
    }

    // 用户总充值
    public function userTotalRecharge(Request $request)
    {
        $UserID = (int)$request->globalUser->UserID;//$request->input('UserID');
//        Util::WriteLog('login_header',$request->header());

        try{

            $userInfo = DB::table(TableName::QPAccountsDB() . 'AccountsInfo')
                ->where('UserID', $UserID)
                ->first();
            if(isset($userInfo)) {
                //记录版本号
                $v = (int)$request->get('v');
                $cv = Util::getClientVer();

//                $CustomID = $v * 1000 + $cv;
//                DB::table(TableName::QPAccountsDB() . 'AccountsInfo')
//                    ->where('UserID', $UserID)
//                    ->update(['CustomID' => $CustomID]);


                $list = DB::connection('read')->table('QPTreasureDB.dbo.GameScoreInfo')
                    ->where('UserID', '=', $UserID)
                    ->first();

                if ($list) {
                    //下线的包
                    if ($list->WinCount == 0 && $list->LostCount == 0 && in_array($userInfo->Channel, [103, 104, 101, 105, 123, 109, 121, 106])) {
//                        ApkService::ControlOldUser($UserID);
                    }
                    if ($list->WinCount == 0 && $list->LostCount == 0 && strtotime($list->RegisterDate) < time() - 86400 * 2) {

                        if ($userInfo->Channel == 100 || $userInfo->Channel == 103 || $userInfo->Channel == 104) {
//                            ApkService::ControlOldUser($UserID);
                        }

                    }
                }

            }
        }catch (\Exception $exception){
            Util::WriteLog('control_old_user',$exception);
        }



        $user_total_recharge = DB::table(TableName::QPAccountsDB() . 'YN_VIPAccount')
            ->where('UserID', $UserID)
            ->value('Recharge') ?: 0;


        // 引导付费标识
//        $guide_payment_exists = DB::table(TableName::agent() . 'guide_payment')->where('UserID', $UserID)->first();
        $flag = false;

        // 查看用户有没有充值过【只要充值过，引导付费就不能充值】

        if ($user_total_recharge > 0) {
            $flag = true;
        }

        // 引导付费礼包列表
//        $guidePayment = (new RechargeLogic())->guidePayment($this->JumpOut);
        // 日期 -- 倒计时【小时】
        $countdown = 24;
        return apiReturnSuc(['user_total_recharge'=>$user_total_recharge,'is_pay' => $flag, 'countdown' => $countdown, 'guidePayment' => []]);
//        $AccountWithDrawInfo = DB::table(TableName::QPAccountsDB() . 'AccountWithDrawInfo')
//            ->lock('WITH(NOLOCK)')
//            ->where('UserID', $UserID)
//            ->first();
//
//
//        if (!$AccountWithDrawInfo) {
//            $cpf = $this->_getNewCpf($UserID);
//            if($cpf){
//                $dao = new AccountPayInfo();
//                $data = [
//                    'PixType' => 1,
//                    'BankUserName' => $dao->randUserName(0),
//                    'PixNum' => $cpf,
//                    'UserID' => $UserID,
//                    'Achieves' => 0,
//                    'HistoryWithDraw' => 0
//                ];
//
//                try {
//                    DB::table(TableName::QPAccountsDB() . 'AccountWithDrawInfo')
//                        ->where('UserID', $UserID)
//                        ->insert($data);
//
//                    try {
//                        DB::table(TableName::QPRecordDB() . 'RecordBankCardBind')
//                            ->insert([
//                                'UserID' => $UserID,
//                                'BankCard' => $cpf,
//                                'BindDate' => now()
//                            ]);
//                        Util::WriteLog('update_pix',[
//                            'UserID' => $UserID,
//                            'BankCard' => $cpf,
//                            'BindDate' => now()
//                        ]);
//                    } catch (\Exception $e) {
//                        Log::error('insert RecordBankCardBind failed', ['data' => $data]);
//                    }
//
//                } catch (\Exception $e) {
//                    Log::error('insert AccountWithDrawInfo failed', ['data' => $data]);
//                }
//            }
//
//        } else {
//            if(!$AccountWithDrawInfo->BankUserName || !$AccountWithDrawInfo->PixNum){
//
//                $cpf = $this->_getNewCpf($UserID);
//
//                if($cpf){
//                    $dao = new AccountPayInfo();
//                    $data = [
//                        'PixType' => 1,
//                        'BankUserName' => $dao->randUserName(0),
//                        'PixNum' => $cpf,
//                        'UserID' => $UserID,
//                        'Achieves' => 0,
//                        'HistoryWithDraw' => 0
//                    ];
//
//                    DB::table(TableName::QPAccountsDB() . 'AccountWithDrawInfo')
//                        ->where('UserID', $UserID)
//                        ->update($data);
//                }
//
//
//            }
//        }

    }

    private function _getNewCpf($UserID){
        return 0;
        $where[] = ['payment_code', 'cashPay'];
        $where[] = ['pay_status', 1];
        $where[] = ['UserID', $UserID];

        $build_sql = DB::connection('write')->table('order')
            ->where($where)
            ->first();
        if($build_sql){
            $cashPay = new CashPayLogic();
            return $cashPay->search($build_sql->order_sn);
        }
        return 0;

    }
}