feat:k线监听

@@ -62,15 +62,17 @@ class ExBroker
         $this->wsKline = new Websocket($this->host . $this->path);
         $this->wsKline = new Websocket($this->host . $this->path);
         $this->wsKline->connect(
         $this->wsKline->connect(
             $onOpen = function () use ($symbol, $interval) {
             $onOpen = function () use ($symbol, $interval) {
-                $subData = json_encode(['method' => 'SUBSCRIBE', 'params' => [$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) {
+                var_dump($data);
                 $data = json_decode($data, true);
                 $data = json_decode($data, true);
-                if (!$data) {
+                if (!$data || !isset($data['data'])) {
                     return;
                     return;
                 }
                 }
-                $onData($data);
+                $onData($data['data']);
             },
             },
             $onClose = null,
             $onClose = null,
         );
         );