feat:bn监听

@@ -106,7 +106,7 @@ class CmBroker
     {
     {
         $this->msg("binance 推送", $data);
         $this->msg("binance 推送", $data);
         if (isset($data['e']) && $data['e'] == 'ORDER_TRADE_UPDATE') {
         if (isset($data['e']) && $data['e'] == 'ORDER_TRADE_UPDATE') {
-            if ($data['x'] == 'TRADE') {
+            if ($data['o']['x'] == 'TRADE') {
                 $wsDataTrade = WsDataTrade::TransferBinanceTrade($data, $this->symbolInfos, function ($symbol) {
                 $wsDataTrade = WsDataTrade::TransferBinanceTrade($data, $this->symbolInfos, function ($symbol) {
                     return $this->getSymbolSt($symbol);
                     return $this->getSymbolSt($symbol);
                 });
                 });

@@ -63,7 +63,6 @@ class ExBroker
         $this->wsKline->connect(
         $this->wsKline->connect(
             $onOpen = function () use ($symbol, $interval) {
             $onOpen = function () use ($symbol, $interval) {
                 $subData = json_encode(['method' => 'SUBSCRIBE', 'params' => [strtolower($symbol) . '@kline_' . $interval], 'id' => 1]);
                 $subData = json_encode(['method' => 'SUBSCRIBE', 'params' => [strtolower($symbol) . '@kline_' . $interval], 'id' => 1]);
-                var_dump($subData);
                 $this->wsKline->push($subData);
                 $this->wsKline->push($subData);
             },
             },
             $onMessage = function ($data) use ($onData) {
             $onMessage = function ($data) use ($onData) {