作者 karlet

feat:下单数量报错,ping pong过滤

@@ -164,10 +164,13 @@ class CmBroker @@ -164,10 +164,13 @@ class CmBroker
164 $orderOri = $order->toOkxOrder($this->symbolInfos, function ($symbol) { 164 $orderOri = $order->toOkxOrder($this->symbolInfos, function ($symbol) {
165 return $this->getSymbolOri($symbol, $this->plat); 165 return $this->getSymbolOri($symbol, $this->plat);
166 }); 166 });
  167 + /** @var SymbolInfo $symbolInfo */
  168 + $symbolInfo = $this->symbolInfos[$order->symbol];
167 $this->msg("下单", $orderOri); 169 $this->msg("下单", $orderOri);
168 if ($orderOri['sz'] == 0) { 170 if ($orderOri['sz'] == 0) {
169 - $this->msg("下单数量为0,不下单", $orderOri);  
170 - return ["code" => 1, "msg" => "下单数量为0,不下单"]; 171 + $msg = "当前下单数量为{$order->qty},最小下单数量为{$symbolInfo->minQty},不下单";
  172 + $this->msg($msg, $orderOri);
  173 + return ["code" => 2, "msg" => $msg];
171 } 174 }
172 $res = $this->exBroker->placeOrder($orderOri); 175 $res = $this->exBroker->placeOrder($orderOri);
173 $this->msg("下单结果", $res); 176 $this->msg("下单结果", $res);
@@ -135,6 +135,9 @@ class ExBroker @@ -135,6 +135,9 @@ class ExBroker
135 // ws 消息预处理 135 // ws 消息预处理
136 private function onWsDataPre($data, callable $onWsData) 136 private function onWsDataPre($data, callable $onWsData)
137 { 137 {
  138 + if ($data == "ping" || $data == "pong") {
  139 + return;
  140 + }
138 $data = json_decode($data, true); 141 $data = json_decode($data, true);
139 if (isset($data['event'])) { 142 if (isset($data['event'])) {
140 if ($data['event'] == 'login' && $data['code'] == '0') { 143 if ($data['event'] == 'login' && $data['code'] == '0') {