admin_api/app/Services/PayMentService.php

<?php


namespace App\Services;

use App\Http\Controllers\Api\AegPayController;
use App\Http\Controllers\Api\ApcopayController;
use App\Http\Controllers\Api\AppleStorePayController;
use App\Http\Controllers\Api\BetCatPayController;
use App\Http\Controllers\Api\BPayController;
use App\Http\Controllers\Api\CashPayController;
use App\Http\Controllers\Api\ClickPayController;
use App\Http\Controllers\Api\CryptoController;
use App\Http\Controllers\Api\FastPayController;
use App\Http\Controllers\Api\GooglePayController;
use App\Http\Controllers\Api\GoopagoController;
use App\Http\Controllers\Api\HHPayColController;
use App\Http\Controllers\Api\KaroPayController;
use App\Http\Controllers\Api\LQPayController;
use App\Http\Controllers\Api\NicePayController;
use App\Http\Controllers\Api\PagsmileNewPayController;
use App\Http\Controllers\Api\PagsmilePayController;
use App\Http\Controllers\Api\PPayController;
use App\Http\Controllers\Api\RussiaPayController;
use App\Http\Controllers\Api\SitoBankController;
use App\Http\Controllers\Api\SmartFastColController;
use App\Http\Controllers\Api\SmartFastPayController;
use App\Http\Controllers\Api\SmartFastPeruController;
use App\Http\Controllers\Api\StanPayController;
use App\Http\Controllers\Api\StarpagoBDController;
use App\Http\Controllers\Api\TopPayController;
use App\Http\Controllers\Api\WWPayColController;
use App\Http\Controllers\Api\DoPayController;
use App\Http\Controllers\Api\StarpagoController;
use App\Http\Controllers\Api\PKpayController;
use App\Http\Controllers\Api\ALL2payController;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;

class PayMentService
{
    public static function pay_order($transport = null)
    {
        switch ($transport) {

//            case 'pay4':
//                return new PagsmilePayController();
//                break;
//
//            case 'pay44':
//                return new PagsmileNewPayController();
//                break;

            case 'ClickPay':
                return new ClickPayController();

            case 'TopPay':
                return new TopPayController();

            case 'DoPay_EP':
                return new DoPayController('EASYPAISA');

            case 'DoPay_JC':
                return new DoPayController('JAZZCASH');

            case 'Starpago_BK':
                return new StarpagoBDController('BKASH');

            case 'Starpago_NG':
                return new StarpagoBDController('NAGAD');

            case 'Starpago_EP':
                return new StarpagoController('EASYPAISA');

            case 'Starpago_JC':
                return new StarpagoController('JAZZCASH');

            case 'PKpay_EP':
                return new PKpayController('EASY');

            case 'PKpay_JC':
                return new PKpayController('JAZZ');

            case 'ALL2pay_EP':
                return new ALL2payController('EASYPAISA');

            case 'ALL2pay_JC':
                return new ALL2payController('JAZZCASH');
            case 'KaroPay_EP':
                return new KaroPayController('EASYPAISA');

            case 'KaroPay_JC':
                return new KaroPayController('JAZZCASH');

            case 'CashPay':
                return new CashPayController();

            case 'SitoBank':
                return new SitoBankController();

//            case 'FastPay':
//                return new FastPayController();

//            case 'NicePay':
//                return new NicePayController();

            case 'AegPay':
                return new AegPayController();

            case 'russiaPay':
                return new RussiaPayController();

            case 'StanPay':
                return new StanPayController();

            case 'SmartFastPay':
                return new SmartFastPayController();

            case 'LQPay':
                return new LQPayController();

            case 'PPay':
                return new PPayController();

            case 'SFP_Ecuador_Wallet':
                return new SmartFastPeruController("wallet",'EC');
            case 'SFP_Ecuador_Bank':
                return new SmartFastPeruController("bank_transfer",'EC');
            case 'SFP_Ecuador_MobileMoney':
                return new SmartFastPeruController("mobile_money",'EC');


            case 'SFP_Chile_Wallet':
                return new SmartFastPeruController("wallet",'CL');
            case 'SFP_Chile_Bank':
                return new SmartFastPeruController("bank_transfer",'CL');
            case 'SFP_Chile_CreditCard':
                return new SmartFastPeruController("credit_card",'CL');


            case 'SFP_PeruPay_Wallet':
                return new SmartFastPeruController("wallet",'PE');
            case 'SFP_PeruPay_Bank':
                return new SmartFastPeruController("bank_transfer",'PE');
            case 'SFP_PeruPay_CreditCard':
                return new SmartFastPeruController("credit_card",'PE');
            case 'SFP_PeruPay_CIP':
                return new SmartFastPeruController("cip",'PE');


            case 'SFP_ColPay_Bank':
                return new SmartFastPeruController("bancolombia",'CO');
            case 'SFP_ColPay_Efecty':
                return new SmartFastPeruController("efecty",'CO');

            case 'SFP_ColPay_Nequi':
                return new SmartFastColController('nequi');

            case 'SFP_ColPay_Transfiya':
                return new SmartFastColController('transfiya');

            case 'SFP_ColPay_PSE':
                return new SmartFastColController('pse');

            case 'DCP_Crypto':
                return new CryptoController();

            case 'HHPay':
                return new HHPayColController();

            case 'WWPay':
                return new WWPayColController();

            case 'Apcopay':
                return new ApcopayController();

            case 'apple':
                return new AppleStorePayController();
            case 'google':
                return new GooglePayController();

            default:
                throw new \Exception('unknown pay channel:'.$transport);
        }
    }

    /**
     * 根据支付方式随机获取充值渠道
     * @param $method
     * @param $channel
     * @return bool|mixed
     */
    /*public static function getServiceByPayMethod3($method, $channel)
    {
//        $switch = Redis::get("recharge_config_switch_{$channel}");
//        if ($channel && $switch) {
//            $services = DB::connection('write')
//                ->table('QPPlatformDB.dbo.ChannelOpenRecharge')
//                ->join(
//                    'agent.dbo.admin_configs',
//                    'admin_configs.id',
//                    '=',
//                    'ChannelOpenRecharge.ConfigID'
//                )
//                ->where('admin_configs.new_pay_type', $method)
//                ->where('admin_configs.type', 'pay')
//                ->where('admin_configs.status', 1)
//                ->where('ChannelOpenRecharge.Status', 1)
//                ->where('ChannelOpenRecharge.Channel', $channel)
//                ->where('ChannelOpenRecharge.Sort', '>', 0)
//                ->selectRaw('admin_configs.config_key, ChannelOpenRecharge.Sort as sort')
//                ->get();
//        }
        $services = DB::table('agent.dbo.admin_configs')->where([
            'new_pay_type' => $method,
            'type' => 'pay',
            'status' => 1,
        ])->get();
        if (!$services->count()) {
            Log::error('支付渠道配置异常', [
                'method' => $method,
            ]);
            return false;
        }
        $matrix = [];
        foreach ($services as $v) {
            for ($i = 0; $i < $v->sort; $i++) {
                $matrix[] = $v->config_key;
            }
        }
        $res = $matrix[mt_rand(0, count($matrix)-1)];
        return $res;
    }*/

    /**
     * 根据支付方式随机获取充值渠道
     * @param $method
     * @param $channel
     * @return bool|mixed
     */
    public static function getServiceByPayMethod($method, $channel,$except_channelName="")
    {
        $except_configKeys=[$except_channelName];
        $switch = Redis::get("recharge_config_switch_{$channel}");
        if ($channel && $switch) {
            $services = DB::connection('write')
                          ->table('QPPlatformDB.dbo.ChannelOpenRecharge')
                          ->join(
                              'agent.dbo.admin_configs',
                              'admin_configs.id',
                              '=',
                              'ChannelOpenRecharge.ConfigID'
                          )
                          ->where('admin_configs.new_pay_type', $method)
                          ->whereNotIn('admin_configs.config_key',$except_configKeys)
                          ->where('admin_configs.type', 'pay')
                          ->where('admin_configs.status', 1)
                          ->where('ChannelOpenRecharge.Status', 1)
                          ->where('ChannelOpenRecharge.Channel', $channel)
                          ->where('ChannelOpenRecharge.Sort', '>', 0)
                          ->selectRaw('admin_configs.config_key, ChannelOpenRecharge.Sort as sort')
                          ->get();
        }
        if (!isset($services) || !$services->count()) {
            $services = DB::table('agent.dbo.admin_configs')->where([
                                                                        'new_pay_type' => $method,
                                                                        'type' => 'pay',
                                                                        'status' => 1,
                                                                    ])->get();
            if (!$services->count()) {
                Log::error('支付渠道配置异常', [
                    'method' => $method,
                ]);
                return false;
            }
        }
        $matrix = [];
        foreach ($services as $v) {
            for ($i = 0; $i < $v->sort; $i++) {
                if(Redis::exists("PayErro_".$v->config_key)) continue;
                $matrix[] = $v->config_key;
            }
        }
        if(count($matrix)==0) {
            foreach ($services as $v) {
                for ($i = 0; $i < $v->sort; $i++) {
                    $matrix[] = $v->config_key;
                }
            }
        }
        $res = $matrix[mt_rand(0, count($matrix)-1)];
        return $res;
    }
    /**
     * 根据支付方式随机获取充值渠道
     * @param $method
     * @param $channel
     * @return bool|mixed
     */
    public static function getServiceByPayCountry($method, $channel,$country,$except_channelName="")
    {
        $except_configKeys=[$except_channelName];
        $switch = Redis::get("recharge_config_switch_{$channel}");
        if ($channel && $switch) {
            $services = DB::connection('write')
                          ->table('QPPlatformDB.dbo.ChannelOpenRecharge')
                          ->join(
                              'agent.dbo.admin_configs',
                              'admin_configs.id',
                              '=',
                              'ChannelOpenRecharge.ConfigID'
                          )
                          ->where('admin_configs.new_pay_type', $method)
                          ->whereNotIn('admin_configs.config_key',$except_configKeys)
                          ->where('admin_configs.country', $country)
                          ->where('admin_configs.type', 'pay')
                          ->where('admin_configs.status', 1)
                          ->where('ChannelOpenRecharge.Status', 1)
                          ->where('ChannelOpenRecharge.Channel', $channel)
                          ->where('ChannelOpenRecharge.Sort', '>', 0)
                          ->selectRaw('admin_configs.config_key, ChannelOpenRecharge.Sort as sort')
                          ->get();
        }
        if (!isset($services) || !$services->count()) {
            $services = DB::table('agent.dbo.admin_configs')->where([
                                                                        'new_pay_type' => $method,
                                                                        'type' => 'pay',
                                                                        'status' => 1,
                                                                        'country' => $country,
                                                                    ])->get();
            if (!$services->count()) {
                Log::error('支付渠道配置异常', [
                    'method' => $method,
                ]);
                return false;
            }
        }
        $matrix = [];
        foreach ($services as $v) {
            for ($i = 0; $i < $v->sort; $i++) {
                if(Redis::exists("PayErro_".$v->config_key)) continue;
                $matrix[] = $v->config_key;
            }
        }
        if(count($matrix)==0) {
            foreach ($services as $v) {
                for ($i = 0; $i < $v->sort; $i++) {
                    $matrix[] = $v->config_key;
                }
            }
        }
        $res = $matrix[mt_rand(0, count($matrix)-1)];
        return $res;
    }
}