|
...
|
...
|
@@ -57,11 +57,12 @@ class ExBroker |
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function klineListen($symbol, $interval, callable $onData) {
|
|
|
|
$this->wsKline = new Websocket($this->host. $this->path);
|
|
|
|
public function klineListen($symbol, $interval, callable $onData)
|
|
|
|
{
|
|
|
|
$this->wsKline = new Websocket($this->host . $this->path);
|
|
|
|
$this->wsKline->connect(
|
|
|
|
$onOpen = function () use ($symbol, $interval) {
|
|
|
|
$subData = json_encode(['method' => 'SUBSCRIBE', 'params' => [$symbol. '@kline_'. $interval], 'id' => 1]);
|
|
|
|
$subData = json_encode(['method' => 'SUBSCRIBE', 'params' => [$symbol . '@kline_' . $interval], 'id' => 1]);
|
|
|
|
$this->wsKline->push($subData);
|
|
|
|
},
|
|
|
|
$onMessage = function ($data) use ($onData) {
|
|
...
|
...
|
@@ -85,4 +86,14 @@ class ExBroker |
|
|
|
{
|
|
|
|
$res = $this->api->getPremiumIndex([]);
|
|
|
|
}
|
|
|
|
//设置双向持仓模式
|
|
|
|
public function setLongShortMode($isLongShortMode)
|
|
|
|
{
|
|
|
|
if ($isLongShortMode) {
|
|
|
|
$res = $this->api->setPositionMode(['dualSidePosition' => 'true']);
|
|
|
|
} else {
|
|
|
|
$res = $this->api->setPositionMode(['dualSidePosition' => 'false']);
|
|
|
|
}
|
|
|
|
return $res;
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|