<?php


namespace App\Logic;


use App\AccountLog;
use App\CoinTrade;
use App\CurrencyQuotation;
use App\Setting;
use App\UsersWallet;
use Illuminate\Support\Facades\DB;

class CoinTradeLogic
{
    public static function userSellCoin($userId,$sellCurrencyId,$wantCurrencyId,$amount,$price){
        //第一步  找出钱包
        $wallet = UsersWallet::where("user_id", $userId)
            ->where("currency", $sellCurrencyId)
            ->lockForUpdate()
            ->first();

        //锁钱包该币种数量
        //获取当前价格
        $qut = CurrencyQuotation::getInstance($wantCurrencyId,$sellCurrencyId);
        DB::beginTransaction();
        try{
//            $price = bc_mul($amount,$price,8);
            $result = change_wallet_balance($wallet,2, -$amount, AccountLog::COIN_TRADE_FROZEN, '币币交易下单，资金锁定');
            if ($result !== true) {
                throw new \Exception($result);
            }

            change_wallet_balance(
                $wallet,
                2,
                $amount,
                AccountLog::COIN_TRADE_FROZEN,
                '币币交易下单，锁定资金增加',
                true,
                0,
                0,
                serialize([])
            );
            //生成
            CoinTrade::newTrade($userId,CoinTrade::TRADE_TYPE_SELL,$sellCurrencyId,$wantCurrencyId,$amount,$qut->now_price,$price);
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            throw $e;
        }


    }

    public static function userBuyCoint($userId,$buyCurrencyId,$payCurrencyId,$amount,$price){
        //第一步  找出钱包
        $wallet = UsersWallet::where("user_id", $userId)
            ->where("currency", $payCurrencyId)
            ->lockForUpdate()
            ->first();
        //锁钱包该币种数量
        $qut = CurrencyQuotation::getInstance($payCurrencyId,$buyCurrencyId);
       // $costPrice = bc_mul($price,$amount);
        
         $costPrice = $amount;
        if($qut->now_price) $num = $amount / $qut->now_price;
        DB::beginTransaction();
        try{
//            $price = bc_mul($amount,$price,8);
            $result = change_wallet_balance($wallet,2, -$costPrice, AccountLog::COIN_TRADE_FROZEN, '币币交易下单，资金锁定');
            if ($result !== true) {
                throw new \Exception($result);
            }

            change_wallet_balance(
                $wallet,
                2,
                $costPrice,
                AccountLog::COIN_TRADE_FROZEN,
                '币币交易下单，锁定资金增加',
                true,
                0,
                0,
                serialize([])
            );
            //生成
            CoinTrade::newTrade($userId,CoinTrade::TRADE_TYPE_BUY,$buyCurrencyId,$payCurrencyId,$num,$qut->now_price,$price);//$amount
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            throw $e;
        }
        // 生成订单
    }

    public static function matchSellTrade($currencyId,$legalId,$nowPrice){
        
        if($currencyId==49) { 
        $tradeList = CoinTrade::where([
            'currency_id' => $currencyId,
            'legal_id' => $legalId,
            'status' => 1,
            'type' => 2
        ])->limit(1)->get();
        }else{
            
          $tradeList = CoinTrade::where([
            'currency_id' => $currencyId,
            'legal_id' => $legalId,
            'status' => 1,
            'type' => 2
        ])->where('target_price','<=',$nowPrice)->limit(1)->get();   
        }

        foreach($tradeList as $trade){
            DB::beginTransaction();
            try{

                $wallet = UsersWallet::where("user_id", $trade->u_id)
                    ->where("currency", $trade->legal_id)
                    ->lockForUpdate()
                    ->first();

                $targetWallet = UsersWallet::where("user_id", $trade->u_id)
                    ->where("currency", $trade->currency_id)
                    ->lockForUpdate()
                    ->first();
                if(!$wallet || !$targetWallet){
                    throw new \Exception(sprintf('订单%s找不到用户钱包',$trade->id));
                }

                $costPrice = bc_mul($trade->target_price,$trade->trade_amount,8);

                change_wallet_balance(
                    $targetWallet,
                    2,
                    -$trade->trade_amount,
                    AccountLog::COIN_TRADE_FROZEN,
                    '币币交易锁定减少',
                    true,
                    0,
                    0,
                    serialize([])
                );
                $chargeFee = $trade->charge_fee;
                $chargeFee = bc_sub(1,$chargeFee,8);
                //手续费
                $costPrice = bc_mul($costPrice,$chargeFee,8);
                change_wallet_balance($wallet,
                    2,
                    $costPrice,
                    AccountLog::COIN_TRADE,
                    '币币交易成功');
                $trade->status = 2;
                $trade->save();
                DB::commit();
            }catch (\Exception $e){
                DB::rollBack();
                echo $e->getMessage();
                continue;
            }
        }
    }

    public static function matchBuyTrade($currencyId,$legalId,$nowPrice){
        $tradeList = CoinTrade::where([
            'currency_id' => $currencyId,
            'legal_id' => $legalId,
            'status' => 1,
            'type' => 1
        ])->where('target_price','>=',$nowPrice)->limit(1)->get();

    // if($currencyId==49)file_put_contents('/www/wwwroot/crypto/public/tt1.txt',json_encode($tradeList));
        foreach($tradeList as $trade){

            DB::beginTransaction();
            try{
                //1 扣掉锁定资金
                $wallet = UsersWallet::where("user_id", $trade->u_id)
                    ->where("currency", $trade->legal_id)
                    ->lockForUpdate()
                    ->first();
                    
                  //  if($currencyId==49)file_put_contents('/www/wwwroot/crypto/public/tt1.txt',json_encode($wallet).PHP_EOL,FILE_APPEND);

                $targetWallet = UsersWallet::where("user_id", $trade->u_id)
                    ->where("currency", $trade->currency_id)
                    ->lockForUpdate()
                    ->first();
                    
                    
                    //  if($currencyId==49)file_put_contents('/www/wwwroot/crypto/public/tt1.txt',time()."--".json_encode($targetWallet).PHP_EOL,FILE_APPEND);
                if(!$wallet || !$targetWallet){
                    throw new \Exception(sprintf('订单%s找不到用户钱包',$trade->id));
                }
                $costPrice = bc_mul($trade->target_price,$trade->trade_amount,8);
                
                // if($currencyId==49)file_put_contents('/www/wwwroot/crypto/public/tt1.txt',$costPrice.PHP_EOL,FILE_APPEND);

                change_wallet_balance(
                    $wallet,
                    2,
                    -$costPrice,
                    AccountLog::COIN_TRADE_FROZEN,
                    '币币交易成功，锁定资金减少',
                    true,
                    0,
                    0,
                    serialize([])
                );

                //手续费
                $chargeFee = $trade->charge_fee;
                $chargeFee = bc_sub(1,$chargeFee,8);
                $amount = bc_mul($trade->trade_amount,$chargeFee,8);
                
              //   if($currencyId==49)file_put_contents('/www/wwwroot/crypto/public/tt1.txt',$amount.PHP_EOL,FILE_APPEND);
                change_wallet_balance($targetWallet,
                    2,
                    $amount,
                    AccountLog::COIN_TRADE,
                    '币币交易成功');
                $trade->status = 2;
 // if($currencyId==49)file_put_contents('/www/wwwroot/crypto/public/tt1.txt',$trade->status.PHP_EOL,FILE_APPEND);
                
                $trade->save();
                
                //解冻操作
                if($currencyId == 29 && $trade->trade_amount > 50){
                    // echo 'int33333333333';
                    $price = bc_mul($trade->trade_amount,0.25,8);
                    // var_dump([$trade->user_id,$currencyId,$price]);
                    //获取账号锁定金额
                    $lh_account = DB::table('lh_bank_account')->where('uid',$trade->u_id)->first();
                    if($lh_account && $lh_account->coin_lock_balance > 0){
                        if($lh_account->coin_lock_balance > $price){
                            $coin_lock_balance = bc_sub($lh_account->coin_lock_balance,$price,8);
                            $amount = $price;
                        }else{
                            $coin_lock_balance = 0;
                            $amount = $lh_account->coin_lock_balance;
                        }
                        DB::table('lh_bank_account')->where('uid',$trade->u_id)->update([
                                'coin_lock_balance' => $coin_lock_balance
                            ]);
                        DB::table('wallet_unlock_order')->insert([
                                'user_id' => $trade->u_id,
                                'wallet_id' => $targetWallet->id,
                                'currency_id' => $currencyId,
                                'amount' => $amount,
                                'created_at' => date("Y-m-d H:i:s"),
                                'handle_time' => date('Y-m-d H:i:s',strtotime('+1 day'))
                            ]);
                       
                    }
                    // $res = DB::table('wallet_unlock_order')->where('user_id',$trade->u_id)->where('currency_id',$currencyId)->where('status',1)->where('remain_amount','>',0)->orderBy('amount','desc')->first();
                    // if($res){
                    //     DB::table('wallet_unlock_order')->where('id',$res->id)->update([
                    //         'status' => 2,
                    //         'handle_time'=>date("Y-m-d H:i:s",strtotime('+1 day'))
                    //         ]);
                    //     // $res->status = 2;
                    //     // $res->handle_time = ;
                    //     // $res->save();
                    // }
                }
                DB::commit();
            }catch (\Exception $e){
                DB::rollBack();
                echo $e->getMessage().'333333333333333333'.PHP_EOL;
                continue;
            }
        }
    }


    public static function forceMatchTrade($tradeId){
        $trade = CoinTrade::find($tradeId);
        if($trade->status != 1){
            throw new \Exception('状态异常');
        }
        DB::beginTransaction();
        try{
            switch ($trade->type){
                case 1:
                    //1 扣掉锁定资金
                    $wallet = UsersWallet::where("user_id", $trade->u_id)
                        ->where("currency", $trade->legal_id)
                        ->lockForUpdate()
                        ->first();

                    $targetWallet = UsersWallet::where("user_id", $trade->u_id)
                        ->where("currency", $trade->currency_id)
                        ->lockForUpdate()
                        ->first();
                    if(!$wallet || !$targetWallet){
                        throw new \Exception(sprintf('订单%s找不到用户钱包',$trade->id));
                    }
                    $costPrice = bc_mul($trade->target_price,$trade->trade_amount,8);

                    change_wallet_balance(
                        $wallet,
                        2,
                        -$costPrice,
                        AccountLog::COIN_TRADE_FROZEN,
                        '币币交易成功，锁定资金减少',
                        true,
                        0,
                        0,
                        serialize([])
                    );

                    //手续费
                    $chargeFee = $trade->charge_fee;
                    $chargeFee = bc_sub(1,$chargeFee,8);
                    $amount = bc_mul($trade->trade_amount,$chargeFee,8);
                    change_wallet_balance($targetWallet,
                        2,
                        $amount,
                        AccountLog::COIN_TRADE,
                        '币币交易成功');
                    $trade->status = 2;
                    $trade->save();
                    break;
                case  2:

                    $wallet = UsersWallet::where("user_id", $trade->u_id)
                        ->where("currency", $trade->legal_id)
                        ->lockForUpdate()
                        ->first();

                    $targetWallet = UsersWallet::where("user_id", $trade->u_id)
                        ->where("currency", $trade->currency_id)
                        ->lockForUpdate()
                        ->first();
                    if(!$wallet || !$targetWallet){
                        throw new \Exception(sprintf('订单%s找不到用户钱包',$trade->id));
                    }

                    $costPrice = bc_mul($trade->target_price,$trade->trade_amount,8);

                    change_wallet_balance(
                        $targetWallet,
                        2,
                        -$trade->trade_amount,
                        AccountLog::COIN_TRADE_FROZEN,
                        '币币交易锁定减少',
                        true,
                        0,
                        0,
                        serialize([])
                    );
                    $chargeFee = $trade->charge_fee;
                    $chargeFee = bc_sub(1,$chargeFee,8);
                    //手续费
                    $costPrice = bc_mul($costPrice,$chargeFee,8);
                    change_wallet_balance($wallet,
                        2,
                        $costPrice,
                        AccountLog::COIN_TRADE,
                        '币币交易成功');
                    $trade->status = 2;
                    $trade->save();
                    break;
            }
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            throw $e;
        }

    }

    public static function cancelTrade($id){
        $trade = CoinTrade::find($id);
        if(!$trade)
            throw new \Exception('找不到订单');
        if($trade->status != 1)
            throw new \Exception('订单状态异常,请刷新列表。');
            
           
        switch ($trade->type){
            case 1:
                    DB::beginTransaction();
                    try{
                        //解除锁定  还钱
                        $wallet = UsersWallet::where("user_id", $trade->u_id)
                            ->where("currency", $trade->legal_id)
                            ->lockForUpdate()
                            ->first();
                        $costPrice = bc_mul($trade->target_price,$trade->trade_amount,8);
                        $result = change_wallet_balance($wallet,
                            2,
                            $costPrice,
                            AccountLog::COIN_TRADE_FROZEN,
                            '取消币币交易，资金返还');
                        if ($result !== true) {
                            throw new \Exception($result);
                        }
                        $result = change_wallet_balance(
                            $wallet,
                            2,
                            -$costPrice,
                            AccountLog::COIN_TRADE_FROZEN,
                            '取消币币交易，退换锁定资金',
                            true,
                            0,
                            0,
                            serialize([])
                        );
                        if ($result !== true) {
                            throw new \Exception($result);
                        }
                        $trade ->status = 3;
                        $trade->save();
                        DB::commit();
                    }catch (\Exception $e){
                        DB::rollBack();
                        throw $e;
                    }
                break;
            case 2:
                DB::beginTransaction();
                try{
                    //解除锁定  还钱
                    $wallet = UsersWallet::where("user_id", $trade->u_id)
                        ->where("currency", $trade->currency_id)
                        ->lockForUpdate()
                        ->first();
                    $result = change_wallet_balance($wallet,2, $trade->trade_amount, AccountLog::COIN_TRADE_FROZEN, '取消币币交易');
                    if ($result !== true) {
                        throw new \Exception($result);
                    }

                    $result = change_wallet_balance(
                        $wallet,
                        2,
                        -$trade->trade_amount,
                        AccountLog::COIN_TRADE_FROZEN,
                        '取消币币交易,退换锁定资金',
                        true,
                        0,
                        0,
                        serialize([])
                    );
                    if ($result !== true) {
                        throw new \Exception($result);
                    }
                    $trade ->status = 3;
                    $trade->save();
                    DB::commit();
                }catch (\Exception $e){
                    DB::rollBack();
                    throw $e;
                }
                break;
            default:
                throw new \Exception('类型有误');
        }
        return true;
    }
}