<?php

/**
 * create by vscode
 * @author lion
 */
namespace App;


use Illuminate\Database\Eloquent\Model;
use App\Utils\RPC;

class TransactionIn extends Model
{
    protected $table = 'transaction_in';
    public $timestamps = false;
    protected $appends = ['account_number', 'currency_name', 'legal_name'];

    public function getAccountNumberAttribute()
    {
        return $this->hasOne('App\Users', 'id', 'user_id')->value('account_number');
    }

    public function getCreateTimeAttribute()
    {
        $value = $this->attributes['create_time'];
        return $value ? date("Y-m-d H:i:s", $value) : '';
    }

    /**
     * 匹配交易
     *
     * @param App\TransactionOut $out 卖出委托模型实例
     * @param float $num 匹配数量
     * @param App\Users $user 买入用户模型实例
     * @param integer $legal_id 法币币种id
     * @param integer $currency_id 交易币种id
     * @return void
     */
    public static function transaction($out, $num, $user, $legal_id, $currency_id)
    {
        if (empty($out) || empty($num) || empty($user)) {
            return false;
        }
        //买方法币
        $to_legal = UsersWallet::where("user_id", $user->id)
            ->where("currency", $legal_id)
            ->first();
        //卖方法币
        $out_legal = UsersWallet::where("user_id", $out->user_id)
            ->where("currency", $legal_id)
            ->first();
        //买方币
        $to_currency = UsersWallet::where("user_id", $user->id)
            ->where("currency", $currency_id)
            ->first();
        //卖方币
        $out_currency = UsersWallet::where("user_id", $out->user_id)   
            ->where("currency", $currency_id)
            ->first();
        $out_user = Users::find($out->user_id);

        if (empty($to_currency) || empty($out_currency) || empty($out_user) || empty($to_legal) || empty($out_legal)) {
            return false;
        }

        if (bc_comp($num, $out->number) > 0) {
            $num = $out->number;
        }

        $cny = bc_mul($num, $out->price, 5);
        $data_wallet1 = [
            'balance_type' => 1,
            'wallet_id' => $to_legal->id,
            'lock_type' => 0,
            'create_time' => time(),
            'before' => $to_legal->legal_balance,
            'change' => -$cny,
            'after' => bc_sub($to_legal->legal_balance, $cny, 5),
        ];
        //扣除买方的法币

        // $to_legal->legal_balance = bc_sub($to_legal->legal_balance, $cny, 5);
        // $to_legal->save();
        // AccountLog::insertLog([
        //     'user_id' => $user->id,
        //     'value' => -$cny,
        //     'info' => "买入扣除法币",
        //     'type' => AccountLog::TRANSACTIONIN_REDUCE,
        //     'currency_id' => $legal_id
        // ],$data_wallet1);


        $data_wallet2 = [
            'balance_type' => 1,
            'wallet_id' => $out_legal->id,
            'lock_type' => 0,
            'create_time' => time(),
            'before' => $out_legal->legal_balance,
            'change' => $cny,
            'after' => bc_add($out_legal->legal_balance, $cny, 5),
        ];
        //增加卖方法币
        // $out_legal->legal_balance = bc_add($out_legal->legal_balance, $cny, 5);
        // $out_legal->save();
        // AccountLog::insertLog([
        //     'user_id' => $out->user_id,
        //     'value' => $cny,
        //     'info' => "卖方增加法币",
        //     'type' => AccountLog::TRANSACTIONIN_SELLER_ADD,
        //     'currency' => $legal_id
        // ],$data_wallet2);

        $data_wallet3 = [
            'balance_type' => 2,
            'wallet_id' => $out_currency->id,
            'lock_type' => 1,
            'create_time' => time(),
            'before' => $out_currency->lock_change_balance,
            'change' => -$num,
            'after' => bc_sub($out_currency->lock_change_balance, $num, 5),
        ];
        //扣除卖方的币
        // if (bc_comp($out_currency->lock_change_balance, $num) < 0) {
        //     // abort(403, '匹配到的卖方委托存在异常,委托编号:' . $out->id);
        //     // return false;
        // }
        // $out_currency->lock_change_balance = bc_sub($out_currency->lock_change_balance, $num, 5);
        // $out_currency->save();
        // AccountLog::insertLog([
        //     'user_id' => $out->user_id,
        //     'value' => -$num,
        //     'info' => "扣除卖方",
        //     'type' => AccountLog::TRANSACTIONIN_SELLER,
        //     'currency' => $currency_id
        // ],$data_wallet3);


        $data_wallet4 = [
            'balance_type' =>  2,
            'wallet_id' => $to_currency->id,
            'lock_type' => 0,
            'create_time' => time(),
            'before' => $to_currency->change_balance,
            'change' => $num,
            'after' => bc_add($to_currency->change_balance, $num, 5),
        ];
        //增加买方的币
        // $to_currency->change_balance = bc_add($to_currency->change_balance, $num, 5);
        // $to_currency->save();

        // AccountLog::insertLog([
        //     'user_id' => $user->id,
        //     'value' => $num,
        //     'info' => "买方增加",
        //     'type' => AccountLog::TRANSACTIONIN_REDUCE_ADD,
        //     'currency' => $currency_id
        // ],$data_wallet4);

        if ($num >= $out->number) {
            $out->delete();
        } else {
            $out->number = bc_sub($out->number, $num, 5);
            $out->save();
        }

        //插入完成记录
        $complete = new TransactionComplete();
        $complete->way = 2;
        $complete->user_id = $user->id;
        $complete->from_user_id = $out->user_id;
        $complete->price = $out->price;
        $complete->number = $num;
        $complete->currency = $currency_id;
        $complete->legal = $legal_id;
        $complete->create_time = time();
        $complete->save();
        MarketHour::batchWriteMarketData($currency_id, $legal_id, $num, $out->price, 1);
    }

    public static function pushNews()
    {
        $data = self::orderBy('price', 'asc')->take(5)->get();
        $send = array("type" => "in", "data" => $data, "content" => "");
        return UserChat::sendChat($send);
    }

    /**
     * 币种
     *
     * @return void
     */
    public function currencycoin()
    {
        return $this->belongsTo('App\Currency', 'currency', 'id');
    }

    /**
     * 法币币种
     *
     * @return void
     */
    public function legalcoin()
    {
        return $this->belongsTo('App\Currency', 'legal', 'id');
    }

    public function getCurrencyNameAttribute()
    {
        return $this->currencycoin()->value('name');
    }

    public function getLegalNameAttribute()
    {
        return $this->legalcoin()->value('name');
    }
    
    //钱包的撮合交易 买入
    public static function walletTransaction($out, $num, $user, $legal_id, $currency_id)
    {
        if (empty($out) || empty($num) || empty($user)) {
            return false;
        }
        //买方法币
        $to_legal = UsersWallet::where("user_id", $user->id)
            ->where("currency", $legal_id)
            ->first();
        //卖方法币
        $out_legal = UsersWallet::where("user_id", $out->user_id)
            ->where("currency", $legal_id)
            ->first();
        //买方币
        $to_currency = UsersWallet::where("user_id", $user->id)
            ->where("currency", $currency_id)
            ->first();
        //卖方币
        $out_currency = UsersWallet::where("user_id", $out->user_id)   
            ->where("currency", $currency_id)
            ->first();
        $out_user = Users::find($out->user_id);

        if (empty($to_currency) || empty($out_currency) || empty($out_user) || empty($to_legal) || empty($out_legal)) {
            return false;
        }

        if (bc_comp($num, $out->number) > 0) {
            $num = $out->number;
        }

        $cny = bc_mul($num, $out->price, 5);
        $data_wallet1 = [
            'balance_type' => 1,
            'wallet_id' => $to_legal->id,
            'lock_type' => 0,
            'create_time' => time(),
            'before' => $to_legal->change_balance,
            'change' => -$cny,
            'after' => bc_sub($to_legal->change_balance, $cny, 5),
        ];
        //扣除买方的交易币

        $to_legal->change_balance = bc_sub($to_legal->change_balance, $cny, 5);
        $to_legal->save();
        AccountLog::insertLog([
            'user_id' => $user->id,
            'value' => -$cny,
            'info' => "买入扣除法币",
            'type' => AccountLog::TRANSACTIONIN_REDUCE,
            'currency' => $legal_id
        ],$data_wallet1);
        //扣除买方的法币的同事。扣除手续费
        
        // Transaction::changeRate($user->id,$cny,$legal_id,'in');

        $data_wallet2 = [
            'balance_type' => 1,
            'wallet_id' => $out_legal->id,
            'lock_type' => 0,
            'create_time' => time(),
            'before' => $out_legal->change_balance,
            'change' => $cny,
            'after' => bc_add($out_legal->change_balance, $cny, 5),
        ];
        //增加卖方法币
        $out_legal->change_balance = bc_add($out_legal->change_balance, $cny, 5);
        $out_legal->save();
        AccountLog::insertLog([
            'user_id' => $out->user_id,
            'value' => $cny,
            'info' => "卖方增加法币",
            'type' => AccountLog::TRANSACTIONIN_SELLER_ADD,
            'currency' => $legal_id
        ],$data_wallet2);
        //卖出的同事，扣除手续费
        // Transaction::changeRate($out->user_id,$cny,$legal_id,'out');
        $data_wallet3 = [
            'balance_type' => 2,
            'wallet_id' => $out_currency->id,
            'lock_type' => 1,
            'create_time' => time(),
            'before' => $out_currency->lock_change_balance,
            'change' => -$num,
            'after' => bc_sub($out_currency->lock_change_balance, $num, 5),
        ];
        //扣除卖方的币
        if (bc_comp($out_currency->lock_change_balance, $num) < 0) {
            abort(403, '匹配到的卖方委托存在异常,委托编号:' . $out->id);
            return false;
        }
        $out_currency->lock_change_balance = bc_sub($out_currency->lock_change_balance, $num, 5);
        $out_currency->save();
        AccountLog::insertLog([
            'user_id' => $out->user_id,
            'value' => -$num,
            'info' => "扣除卖方",
            'type' => AccountLog::TRANSACTIONIN_SELLER,
            'currency' => $currency_id
        ],$data_wallet3);


        $data_wallet4 = [
            'balance_type' =>  2,
            'wallet_id' => $to_currency->id,
            'lock_type' => 0,
            'create_time' => time(),
            'before' => $to_currency->change_balance,
            'change' => $num,
            'after' => bc_add($to_currency->change_balance, $num, 5),
        ];
        //增加买方的币
        $to_currency->change_balance = bc_add($to_currency->change_balance, $num, 5);
        $to_currency->save();

        AccountLog::insertLog([
            'user_id' => $user->id,
            'value' => $num,
            'info' => "买方增加",
            'type' => AccountLog::TRANSACTIONIN_REDUCE_ADD,
            'currency' => $currency_id
        ],$data_wallet4);

        if ($num >= $out->number) {
            $out->delete();
        } else {
            $out->number = bc_sub($out->number, $num, 5);
            $out->save();
        }

        //插入完成记录
        $complete = new TransactionComplete();
        $complete->way = 2;
        $complete->user_id = $user->id;
        $complete->from_user_id = $out->user_id;
        $complete->price = $out->price;
        $complete->number = $num;
        $complete->currency = $currency_id;
        $complete->legal = $legal_id;
        $complete->create_time = time();
        $complete->save();
        //插入交易行情数据表
        $total = TransactionComplete::where('currency', $currency_id)
                                ->where('legal', $legal_id)
                                ->where('create_time', '>=', strtotime(date('Y-m-d')))
                                ->sum('number');
        $data = [
            'legal_id' => $legal_id,
            'currency_id' => $currency_id,
            'volume' => $total,
            'now_price' => $out->price
        ];
        CurrencyQuotation::updateTodayPriceTable($data);//
        MarketHour::batchWriteMarketData($currency_id, $legal_id, $num, $out->price, 1);
    }
}