<?php

namespace trader;

require_once __DIR__ . '/struct/ApiInfo.php';
require_once __DIR__ . '/exchange/okx/ExBroker.php';
require_once __DIR__ . '/exchange/binance/ExBroker.php';
require_once __DIR__ . '/exchange/bybit/ExBroker.php';
require_once __DIR__ . '/exchange/bitget/ExBroker.php';
require_once __DIR__ . '/struct/Kline.php';
require_once __DIR__ . '/struct/Order.php';
require_once __DIR__ . '/struct/WsData.php';
require_once __DIR__ . '/struct/WsDataTrade.php';
require_once __DIR__ . '/struct/WsDataPos.php';
require_once __DIR__ . '/struct/SymbolInfo.php';
require_once __DIR__ . '/struct/WsDataOrder.php';
require_once __DIR__ . '/struct/WsDataAccount.php';
require_once __DIR__ . '/struct/Pos.php';
require_once __DIR__ . '/struct/Premium.php';
require_once __DIR__ . '/struct/IndexTicker.php';
require_once __DIR__ . '/../jytools/func.php';
require_once __DIR__ . '/../jytools/Websocket.php';


use trader\struct\ApiInfo;
use trader\exchange\okx\ExBroker as OkxBroker;
use trader\exchange\binance\ExBroker as BinanceBroker;
use trader\exchange\bybit\ExBroker as BybitBroker;
use trader\exchange\bitget\ExBroker as BitgetBroker;
use trader\struct\Kline;
use trader\struct\Order;
use trader\struct\WsData;
use trader\struct\WsDataTrade;
use trader\struct\WsDataPos;
use trader\struct\SymbolInfo;
use trader\struct\WsDataOrder;
use trader\struct\WsDataAccount;
use trader\struct\Pos;
use trader\struct\Premium;
use trader\struct\IndexTicker;
use \Exception;
use function jytools\timeFormat;
use function jytools\getMicrotime;

class CmBroker
{
    const PLAT_OKX = 'okx';
    const PLAT_BINANCE = 'binance';
    const PLAT_BYBIT = 'bybit';
    const PLAT_BITGET = 'bitget';
    const BN_FEE_KEY = "x-tdk3UjFd";
    const OK_FEE_KEY = "059de09b75e8BCDE";
    const MODE_TWO_SIDE = 'TWO_SIDE';
    const MODE_ONE_SIDE = 'ONE_SIDE';
    /**
     * @var string 当前使用的交易平台
     * @see PLAT_OKX
     * @see PLAT_BINANCE
     * @see PLAT_BYBIT 
     * @see PLAT_BITGET
     */
    public $plat;
    private OkxBroker|BinanceBroker|BybitBroker|BitgetBroker $exBroker;
    /** @var SymbolInfo[] $symbolInfos */
    public $symbolInfos = [];
    /** @var Pos[] $positions */
    public $positions = [];
    public $name = '';
    public $levers = [];
    public $uid;
    public $posMode = '';
    public ?ApiInfo $apiInfo;
    private $wsHost;
    private $restHost;

    public function __construct($plat, ?ApiInfo $apiInfo, $wsHost = null, $restHost = null)
    {
        $this->plat = $plat;
        $this->apiInfo = $apiInfo;
        $exBroker = null;
        if ($plat == self::PLAT_OKX) {
            $exBroker = new OkxBroker($apiInfo);
        }
        if ($plat == self::PLAT_BINANCE) {
            $exBroker = new BinanceBroker($apiInfo);
        }
        if ($plat == self::PLAT_BYBIT) {
            $exBroker = new BybitBroker($apiInfo);
        }
        if ($plat == self::PLAT_BITGET) {
            $exBroker = new BitgetBroker($apiInfo);
        }
        $this->wsHost = $wsHost;
        $this->restHost = $restHost;
        $this->exBroker = $exBroker;
        if ($wsHost && $wsHost != "") {
            $this->exBroker->setWsHost($wsHost);
        }
        if ($restHost && $restHost != "") {
            $this->exBroker->setRestHost($restHost);
        }
        $this->init();
    }
    //复制一个新的实例
    public function copy()
    {
        $apiInfo = null;
        if ($this->apiInfo) {
            $apiInfo = new ApiInfo($this->apiInfo->key, $this->apiInfo->secret, $this->apiInfo->passphrase);
        }
        $cmBroker = new CmBroker($this->plat, $apiInfo, $this->wsHost, $this->restHost);
        $cmBroker->symbolInfos = $this->symbolInfos;
        $cmBroker->positions = $this->positions;
        $cmBroker->name = $this->name;
        $cmBroker->levers = $this->levers;
        $cmBroker->uid = $this->uid;
        $cmBroker->posMode = $this->posMode;
        return $cmBroker;
    }
    public function setName($name)
    {
        $this->name = $name;
    }
    public function setUid($uid)
    {
        $this->uid = $uid;
    }
    public function init()
    {
        $this->initSymbolInfos();
        if ($this->plat == self::PLAT_OKX && $this->apiInfo && $this->apiInfo->key != '') {
            $this->initPosMode();
            $this->initPositions();
        }
    }
    public function accListen(callable $onData)
    {
        $this->exBroker->accListen(function ($data) use ($onData) {
            // output("ws 有效数据", $data);
            if ($this->plat == self::PLAT_BINANCE) {
                $this->binanceAccDataHandle($data, $onData);
            }
            if ($this->plat == self::PLAT_OKX) {
                $this->okxAccDataHandle($data, $onData);
            }
            if ($this->plat == self::PLAT_BYBIT) {
                $this->bybitAccDataHandle($data, $onData);
            }
            if ($this->plat == self::PLAT_BITGET) {
                $this->bitgetAccDataHandle($data, $onData);
            }
        });
    }
    //处理币安相关账户数据监听
    private function binanceAccDataHandle($data, $onData)
    {
        if (isset($data['e']) && $data['e'] == 'ORDER_TRADE_UPDATE') {
            if ($data['o']['x'] == 'TRADE') {
                $wsDataTrade = WsDataTrade::TransferBinanceTrade($data, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataTrade != null) {
                    $wsDataTrade->cliOrdId = str_replace(self::BN_FEE_KEY, '', $wsDataTrade->cliOrdId);
                    $wsData = new WsData($this->plat, 'trade', $trade = $wsDataTrade);
                    $onData($wsData);
                }
            }
            $wsDataOrder = WsDataOrder::TransferBinanceOrder($data, $this->symbolInfos, function ($symbol) {
                return $this->getSymbolSt($symbol);
            });
            if ($wsDataOrder != null) {
                $wsDataOrder->cliOrdId = str_replace(self::BN_FEE_KEY, '', $wsDataOrder->cliOrdId);
                $wsData = new WsData($this->plat, 'order', $trade = null, $pos = null, $order = $wsDataOrder);
                $onData($wsData);
            }
        }
        if (isset($data['e']) && $data['e'] == 'ACCOUNT_UPDATE') {
            if (isset($data['a']) && isset($data['a']['P'])) {
                $positions = $data['a']['P'];
                foreach ($positions as $key => $value) {
                    $wsDataPos = WsDataPos::TransferBinancePos($value, $this->symbolInfos, function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $this->positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $wsDataPos;
                    $wsData = new WsData($this->plat, 'pos', $trade = null, $pos = $wsDataPos);
                    $onData($wsData);
                }
                foreach ($this->positions as $key => $value) {
                    if ($value->qty == 0) {
                        unset($this->positions[$key]);
                    }
                }
            }
        }
    }
    //处理欧意账户相关数据监听
    private function okxAccDataHandle($data, $onData)
    {
        if (isset($data['arg']) && $data['arg']['channel'] == 'orders') {
            foreach ($data['data'] as $key => $value) {
                $wsDataTrade = WsDataTrade::TransferOkxOrder($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataTrade != null) {
                    $wsData = new WsData($this->plat, 'trade', $trade = $wsDataTrade);
                    $onData($wsData);
                }
                $wsDataOrd = WsDataOrder::TransferOkxOrder($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataOrd != null) {
                    $wsData = new WsData($this->plat, 'order', $trade = null, $pos = null, $order = $wsDataOrd);
                    $onData($wsData);
                }
            }
            return;
        }
        if (isset($data['arg']) && $data['arg']['channel'] == 'positions') {
            $positions = [];
            $eventType = $data['eventType'];
            foreach ($data['data'] as $key => $value) {
                $wsDataPos = WsDataPos::TransferOkxPos($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataPos) {
                    $pos = Pos::transferWsDataPos($wsDataPos);
                    if ($this->posMode != self::MODE_ONE_SIDE) {
                        $pos->qty = abs($pos->qty); // 统一为正
                        $pos->lot = abs($pos->lot); // 统一为正
                    }
                    $positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $pos;
                    $wsData = new WsData($this->plat, 'pos', $trade = null, $pos = $wsDataPos);
                    $onData($wsData);
                    if ($eventType == 'event_update') {
                        $this->positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $pos;
                    }
                }
            }
            if ($eventType == 'snapshot') {
                $this->positions = $positions;
            }
            return;
        }
        if (isset($data['arg']) && $data['arg']['channel'] == 'account') {
            $wsDataAccount = WsDataAccount::TransferOkxAccount($data['data']);
            $wsData = new WsData($this->plat, 'account', $trade = null, $pos = null, $order = null, $account = $wsDataAccount);
            $onData($wsData);
            return;
        }
        $this->msg("okx 无处理ws数据实现", $data);
    }
    //处理bybit账户相关数据监听
    private function bybitAccDataHandle($data, $onData)
    {
        if (isset($data['topic']) && $data['topic'] == 'order') {
            foreach ($data['data'] as $key => $value) {
                $wsDataOrd = WsDataOrder::TransferBybitOrder($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataOrd != null) {
                    $wsData = new WsData($this->plat, 'order', $trade = null, $pos = null, $order = $wsDataOrd);
                    $onData($wsData);
                }
            }
            return;
        }
        if (isset($data['topic']) && $data['topic'] == 'execution') {
            foreach ($data['data'] as $key => $value) {
                $wsDataTrade = WsDataTrade::TransferBybitTrade($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataTrade != null) {
                    $wsData = new WsData($this->plat, 'trade', $trade = $wsDataTrade);
                    $onData($wsData);
                }
            }
            return;
        }
        if (isset($data['topic']) && $data['topic'] == 'position') {
            foreach ($data['data'] as $key => $value) {
                $wsDataPos = WsDataPos::TransferBybitPos($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataPos != null) {
                    $pos = Pos::transferWsDataPos($wsDataPos);
                    $this->positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $pos;
                    $wsData = new WsData($this->plat, 'pos', $trade = null, $pos = $wsDataPos);
                    $onData($wsData);
                }
            }
            return;
        }
    }
    //处理bitget账户相关数据监听
    private function bitgetAccDataHandle($data, $onData)
    {
        // 处理订单和成交数据
        if (isset($data['arg']) && $data['arg']['channel'] == 'orders') {
            foreach ($data['data'] as $value) {
                // 处理订单数据
                $wsDataOrder = WsDataOrder::TransferBitgetOrder($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataOrder) {
                    $wsData = new WsData($this->plat, 'order', null, null, $wsDataOrder);
                    $onData($wsData);
                }
            }
            return;
        }
        //处理成交数据
        if (isset($data['arg']) && $data['arg']['channel'] == 'fill') {
            foreach ($data['data'] as $value) {
                $wsDataTrade = WsDataTrade::TransferBitgetOrder($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataTrade) {
                    $wsData = new WsData($this->plat, 'trade', $wsDataTrade);
                    $onData($wsData);
                }
            }
        }

        // 处理持仓数据
        if (isset($data['arg']) && $data['arg']['channel'] == 'positions') {
            foreach ($data['data'] as $pos) {
                $wsDataPos = WsDataPos::TransferBitgetPos($pos, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($wsDataPos) {
                    $this->positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $wsDataPos;
                    $wsData = new WsData($this->plat, 'pos', null, $wsDataPos);
                    $onData($wsData);
                }
            }
            return;
        }
    }
    public function klineListen($symbol, $peroid, $onData)
    {
        if ($this->plat == self::PLAT_BINANCE && $peroid == '1s') {
            $this->msg("币安不支持1sk线", $symbol, $peroid);
            return;
        }
        $symbol = $this->getSymbolOri($symbol, $this->plat);
        $periodOri = $this->getPeriodOri($this->plat, $peroid);
        $this->exBroker->klineListen($symbol, $periodOri, function ($data) use ($onData) {
            if ($this->plat == self::PLAT_BINANCE) {
                $kline = Kline::transferBinance($data);
            }
            if ($this->plat == self::PLAT_OKX) {
                $kline = Kline::transferOkx($data);
            }
            if ($this->plat == self::PLAT_BYBIT) {
                $kline = Kline::transferBybit($data);
            }
            if ($this->plat == self::PLAT_BITGET) {
                $kline = Kline::transferBitget($data);
            }
            $onData($kline);
        });
    }
    //转换为标准交易对
    public function getSymbolSt($symbol)
    {
        $symbol = str_replace('-USDT-SWAP', 'USDT',  $symbol);
        $symbol = str_replace('-USDC-SWAP', 'USDC',  $symbol);
        if (preg_match('/^[A-Z0-9]+USD[CT]$/', $symbol)) {
            if ($this->plat == self::PLAT_BINANCE || $this->plat == self::PLAT_BYBIT) {
                $num = SymbolInfo::extractNumber($symbol);
                $symbol = str_replace($num, '', $symbol);
                return $symbol;
            }
            return $symbol;
        } else {
            throw new Exception('转换标准交易对错误' . $symbol . ' to ', $symbol);
        }
    }
    //转换为原始周期
    public function getPeriodOri($platTarget, $period)
    {
        if ($platTarget == self::PLAT_BINANCE) {
            return $period;
        }
        if ($platTarget == self::PLAT_OKX) {
            $arr = [
                '1s' => '1s',
                '1m' => '1m',
                '3m' => '3m',
                '5m' => '5m',
                '15m' => '15m',
                '30m' => '30m',
                '1h' => '1H',
                '2h' => '2H',
                '4h' => '4H',
                '6h' => '6H',
                '12h' => '12H',
                '1d' => '1D',
                '1w' => '1W',
            ];
            if (!isset($arr[$period])) {
                throw new Exception('周期错误,' . $this->plat . '不支持的周期' . $period);
            }
            return $arr[$period];
        }
        if ($platTarget == self::PLAT_BYBIT) {
            $arr = [
                '1m' => '1',
                '3m' => '3',
                '5m' => '5',
                '15m' => '15',
                '30m' => '30',
                '1h' => '60',
                '2h' => '120',
                '4h' => '240',
                '6h' => '360',
                '12h' => '720',
                '1d' => 'D',
                '1w' => 'W',
                '1M' => 'M',
            ];
            if (!isset($arr[$period])) {
                throw new Exception('周期错误,' . $this->plat . '不支持的周期' . $period);
            }
            return $arr[$period];
        }
        if ($platTarget == self::PLAT_BITGET) {
            $arr = [
                '1m' => 'candle1m',
                '5m' => 'candle5m',
                '15m' => 'candle15m',
                '30m' => 'candle30m',
                '1h' => 'candle1H',
                '4h' => 'candle4H',
                '12h' => 'candle12H',
                '1d' => 'candle1D',
            ];
            if (!isset($arr[$period])) {
                throw new Exception('周期错误,' . $this->plat . '不支持的周期' . $period);
            }
            return $arr[$period];
        }
        throw new Exception('平台错误' . $platTarget);
    }

    //转换为原始交易对
    public function getSymbolOri($symbol): string
    {
        /** @var SymbolInfo $symbolInfo */
        $symbolInfo = $this->symbolInfos[$symbol] ?? false;
        if ($symbolInfo) {
            return $symbolInfo->symbolOri;
        }
        return "";
    }

    public function placeOrder(Order $order)
    {
        /** @var SymbolInfo $symbolInfo */
        $symbolInfo = $this->symbolInfos[$order->symbol];
        if ($this->plat == self::PLAT_OKX) {
            $orderOri = $order->toOkxOrder($this->symbolInfos, function ($symbol) {
                return $this->getSymbolOri($symbol);
            });
            if (!isset($orderOri['tag'])) {
                $orderOri['tag'] = self::OK_FEE_KEY;
            }
            $this->msg("下单", $orderOri);
            if ($orderOri['sz'] == 0) {
                $msg = "当前下单数量为{$order->qty},最小下单数量为{$symbolInfo->minQty}，不下单";
                $this->msg($msg, $orderOri);
                return ["code" => 2, "msg" => $msg];
            }
            $res = $this->exBroker->placeOrder($orderOri);
            $this->msg("下单结果", $res);
            return $res;
        }
        if ($this->plat == self::PLAT_BINANCE) {
            $orderOri = $order->toBinanceOrder($this->symbolInfos, function ($symbol) {
                return $this->getSymbolOri($symbol, $this->plat);
            });
            if (isset($orderOri['newClientOrderId'])) {
                $orderOri['newClientOrderId'] = self::BN_FEE_KEY . $orderOri['newClientOrderId'];
            } else {
                $orderOri['newClientOrderId'] = self::BN_FEE_KEY . getMicrotime();
            }
            $this->msg("下单", $orderOri);
            if ($orderOri['quantity'] == 0) {
                $msg = "当前下单数量为{$order->qty},最小下单数量为{$symbolInfo->minQty}，不下单";
                $this->msg($msg, $orderOri);
                return ["code" => 2, "msg" => $msg];
            }
            $res = $this->exBroker->placeOrder($orderOri);
            $this->msg("下单结果", $res);
            if ($res && isset($res['clientOrderId'])) {
                $res['clientOrderId'] = str_replace(self::BN_FEE_KEY, '', $res['clientOrderId']);
            }
            return $res;
        }
        if ($this->plat == self::PLAT_BYBIT) {
            $orderOri = $order->toBybitOrder($this->symbolInfos, function ($symbol) {
                return $this->getSymbolOri($symbol, $this->plat);
            });
            $this->msg("下单", $orderOri);
            if ($orderOri['qty'] == 0) {
                $msg = "当前下单数量为{$order->qty},最小下单数量为{$symbolInfo->minQty}，不下单";
                $this->msg($msg, $orderOri);
                return ["code" => 2, "msg" => $msg];
            }
            $res = $this->exBroker->placeOrder($orderOri);
            $this->msg("下单结果", $res);
            return $res;
        }
        if ($this->plat == self::PLAT_BITGET) {
            $orderOri = $order->toBitgetOrder($this->symbolInfos, function ($symbol) {
                return $this->getSymbolOri($symbol, $this->plat);
            });
            $this->msg("下单", $orderOri);
            if ($orderOri['size'] == 0) {
                $msg = "当前下单数量为{$order->qty},最小下单数量为{$symbolInfo->minQty}，不下单";
                $this->msg($msg, $orderOri);
                return ["code" => 2, "msg" => $msg];
            }
            $res = $this->exBroker->placeOrder($orderOri);
            $this->msg("下单结果", $res);
            return $res;
        }
    }

    public function msg()
    {
        $args = func_get_args();
        $outStr = '[' . timeFormat('ms') . ']：' . $this->name . ": ";
        foreach ($args as $key => $value) {
            $value = is_array($value) ? json_encode($value) : $value;
            if (is_bool($value)) {
                $value = $value ? 'bool:true' : 'bool:false';
            }
            $outStr .= count($args) - $key > 1 ? $value . '  ' : $value;
        }
        echo $outStr . PHP_EOL;
    }
    public function getPosQty($symbol, $posSide)
    {
        $key = $symbol . "_" . $posSide;
        if (!isset($this->positions[$key])) {
            return 0;
        }
        /** @var Pos $pos */
        $pos = $this->positions[$key];
        return $pos->qty;
    }
    private function initSymbolInfos($count = 1)
    {
        if ($count > 3) {
            throw new Exception("broker初始化交易对信息失败");
        }
        if ($this->plat == self::PLAT_OKX) {
            //获取所有USDT SWAP 交易对
            $res = $this->exBroker->getSymbolInfos();
            $infos = [];
            foreach ($res as $key => $value) {
                if (($value["settleCcy"] == "USDT" || $value["settleCcy"] == "USDC") && $value["state"] == "live") {
                    $info = SymbolInfo::transferOkx($value, function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $infos[$info->symbol] = $info;
                }
            }
            $this->symbolInfos = $infos;
        }
        if ($this->plat == self::PLAT_BINANCE) {
            $res = $this->exBroker->getSymbolInfos();
            $infos = [];
            foreach ($res as $key => $value) {
                if (($value["quoteAsset"] == "USDT" || $value["quoteAsset"] == "USDC") && $value["status"] == "TRADING" && $value["contractType"] == "PERPETUAL") {
                    $info = SymbolInfo::transferBinance($value, function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $infos[$info->symbol] = $info;
                }
            }
            $this->symbolInfos = $infos;
        }
        if ($this->plat == self::PLAT_BYBIT) {
            $res = $this->exBroker->getSymbolInfos();
            $infos = [];
            foreach ($res as $key => $value) {
                if (($value['quoteCoin'] == 'USDT') && $value['status'] == 'Trading' && $value['contractType'] == 'LinearPerpetual') {
                    $info = SymbolInfo::transferBybit($value, function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $infos[$info->symbol] = $info;
                }
            }
            $this->symbolInfos = $infos;
        }
        if ($this->plat == self::PLAT_BITGET) {
            $res = $this->exBroker->getSymbolInfos();
            $infos = [];
            foreach ($res as $value) {
                if (($value['quoteCoin'] == 'USDT' || $value['quoteCoin'] == 'USDC') && $value['symbolStatus'] == 'normal') {
                    $info = SymbolInfo::transferBitget($value, function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $infos[$info->symbol] = $info;
                }
            }
            $this->symbolInfos = $infos;
        }
        if (count($this->symbolInfos) == 0) {
            $this->initSymbolInfos($count + 1);
            return;
        }
        //定时10m刷新
        swoole_timer_after(1000 * 60 * 10, function () {
            $this->initSymbolInfos();
        });
    }
    public function stopListen()
    {
        $this->exBroker->stopListen();
    }
    public function closeAllPos()
    {
        $this->exBroker->closeAllPos();
    }
    //设置允许合约
    public function setAllowFutures($isAllowFutures)
    {
        $this->exBroker->setAllowFutures($isAllowFutures);
    }
    //设置双向持仓模式
    public function setLongShortMode($isLongShort)
    {
        $this->exBroker->setLongShortMode($isLongShort);
    }
    //获取全部品种的杠杆
    public function getLevers()
    {
        $levers = $this->exBroker->getAllLevers();
        if ($this->plat == self::PLAT_OKX) {
            $resNew = [];
            foreach ($levers as $key => $value) {
                $symbol = $this->getSymbolSt($key); //转换为标准交易对
                $resNew[$symbol] = $value;
            }
            $levers = $resNew;
        }
        if ($this->plat == self::PLAT_BINANCE) {
            $resNew = [];
            foreach ($levers as $key => $value) {
                if (!str_ends_with($key, 'USDT')) {
                    continue;
                }
                $symbol = $this->getSymbolSt($key); //转换为标准交易对
                $resNew[$symbol] = $value;
            }
            $levers = $resNew;
        }
        $this->levers = $levers; //缓存levers
        return $levers;
    }
    //设置杠杆
    public function setLever($symbol, $lever)
    {
        $symbol = $this->getSymbolOri($symbol);
        $res = $this->exBroker->setLever($symbol, $lever);
        if ($res) {
            $this->levers[$symbol] = $lever;
        }
    }
    //查询获取全部持仓
    public function getAllPos(): array
    {
        $positions = $this->exBroker->getAllPos();
        $newPositions = [];
        foreach ($positions as $key => $value) {
            if ($this->plat == self::PLAT_OKX) {
                $item = Pos::transferOkxPos($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($this->posMode != self::MODE_ONE_SIDE) {
                    $item->qty = abs($item->qty);
                    $item->lot = abs($item->lot);
                }
                $newPositions[$item->symbol . "_" . $item->posSide] = $item;
            }
            if ($this->plat == self::PLAT_BINANCE) {
                $item = Pos::transferBinancePos($value, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($this->posMode != self::MODE_ONE_SIDE) {
                    $item->qty = abs($item->qty);
                    $item->lot = abs($item->lot);
                }
                $newPositions[$item->symbol . "_" . $item->posSide] = $item;
            }
        }
        return $newPositions;
    }
    //获取某个品种的某个方向仓位
    public function getPos($symbol, $posSide)
    {
        $symbolOri = $this->getSymbolOri($symbol);
        if ($this->plat == self::PLAT_OKX) {
            $posSide = strtolower($posSide);
            $symbolInfo = $this->symbolInfos[$symbol];
            $lot = $this->exBroker->getPos($symbolOri, $posSide);
            $qty = round($lot * $symbolInfo->ctVal, $symbolInfo->qtyPrec);
            if ($this->posMode != self::MODE_ONE_SIDE) {
                $qty = abs($qty);
                $lot = abs($lot);
            }
            return $qty;
        }
        return -1;
    }
    /**
     * 获取k线数据
     * @param string $symbol 交易对
     * @param string $peroid 周期
     * @param int $limit 限制数量
     * @return Kline[] 返回K线数组
     */
    public function getKlines($symbol, $peroid, $limit = 100)
    {
        $symbolOri = $this->getSymbolOri($symbol);
        $peroidOri = $this->getPeriodOri($this->plat, $peroid);
        if ($this->plat == self::PLAT_OKX) {
            $res = $this->exBroker->getKlines($symbolOri, $peroidOri, $limit);
            if ($res['code'] != '0') {
                return [];
            }
            $newKlines = [];
            foreach ($res['data'] as $key => $value) {
                $kline = Kline::transferOkx($value);
                $newKlines[] = $kline;
            }
            //把 $newKlines 倒序
            $newKlines = array_reverse($newKlines);
            return $newKlines;
        }
        if ($this->plat == self::PLAT_BINANCE) {
            $res = $this->exBroker->getKlines($symbolOri, $peroidOri, $limit);
            if (count($res) == 0) {
                return [];
            }
            $newKlines = [];
            foreach ($res as $key => $value) {
                $kline = Kline::transferBinanceRest($value);
                $newKlines[] = $kline;
            }
            //把 $newKlines 倒序
            $newKlines = array_reverse($newKlines);
            return $newKlines;
        }
        return [];
    }
    public function initPositions()
    {
        $this->positions = $this->getAllPos();
    }
    //----------公告数据接口--------
    //获取所有品种资金费率，返回数据为 Premium[]
    public function getPremiumAll(): array
    {
        $data = [];
        if ($this->plat == self::PLAT_OKX) {
            foreach ($this->symbolInfos as $key => $value) {
                $res = $this->exBroker->getPremium($value->symbolOri);
                if (isset($res['data'])) {
                    $prem = Premium::transferOkx($res['data'][0], function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $data[$prem->symbol] = $prem;
                }
            }
        } else if ($this->plat == self::PLAT_BINANCE) {
            $res = $this->exBroker->getPremiumAll();
            foreach ($res as $key => $value) {
                $prem = Premium::transferBinance($value, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
                if ($prem) {
                    $data[$prem->symbol] = $prem;
                }
            }
        } else {
            throw new Exception("获取资金费 该交易所未实现，请先实现代码");
        }
        return $data;
    }
    private function initPosMode()
    {
        if ($this->plat == self::PLAT_OKX && $this->apiInfo && $this->apiInfo->key != '') {
            $res = $this->exBroker->getAccountConfig();
            $config = $res['data'][0];
            $this->posMode = $config['posMode'] == 'long_short_mode' ? self::MODE_TWO_SIDE : self::MODE_ONE_SIDE;
        }
    }
    public function cancelOrder($symbol, $cliOrdId = "", $orderId = "")
    {
        $symbolOri = $this->getSymbolOri($symbol);
        if ($this->plat == self::PLAT_OKX) {
            return $this->exBroker->cancelOrder($symbolOri, $cliOrdId, $orderId);
        }
    }
    public function getOrder($symbol, $cliOrdId = "", $orderId = ""): ?WsDataOrder
    {
        $symbolOri = $this->getSymbolOri($symbol);
        if ($this->plat == self::PLAT_OKX) {
            $res = $this->exBroker->getOrder($symbolOri, $cliOrdId, $orderId);
            if (isset($res['data']) && isset($res['data'][0])) {
                $data = $res['data'][0];
                return WsDataOrder::TransferOkxOrder($data, $this->symbolInfos, function ($symbol) {
                    return $this->getSymbolSt($symbol);
                });
            }
        }
        return null;
    }
    public function getOrderPending($symbol): array
    {
        if ($this->plat == self::PLAT_OKX) {
            $symbolOri = $this->getSymbolOri($symbol);
            $res = $this->exBroker->getOrderPending($symbolOri);
            if (isset($res['data']) && isset($res['data'][0])) {
                $orders = [];
                foreach ($res['data'] as $key => $value) {
                    $order = WsDataOrder::TransferOkxOrder($value, $this->symbolInfos, function ($symbol) {
                        return $this->getSymbolSt($symbol);
                    });
                    $orders[] = $order;
                }
                return $orders;
            }
        } else {
            new Exception("getOrderPending 该交易所未实现，请先实现代码");
        }
        return [];
    }
    public function subDepth($symbol, callable $onData)
    {
        $this->exBroker->subDepth($symbol, $onData);
    }
    public function getIndexTickers()
    {
        $res = $this->exBroker->getIndexTickers();
        if ($res && $res['code'] == '0') {
            return IndexTicker::transferOkxData($res['data']);
        }
        return [];
    }
}