正在显示
1 个修改的文件
包含
6 行增加
和
0 行删除
| @@ -102,6 +102,7 @@ class CmBroker | @@ -102,6 +102,7 @@ class CmBroker | ||
| 102 | } | 102 | } |
| 103 | if (isset($data['arg']) && $data['arg']['channel'] == 'positions') { | 103 | if (isset($data['arg']) && $data['arg']['channel'] == 'positions') { |
| 104 | $positions = []; | 104 | $positions = []; |
| 105 | + $eventType = $data['eventType']; | ||
| 105 | foreach ($data['data'] as $key => $value) { | 106 | foreach ($data['data'] as $key => $value) { |
| 106 | $wsDataPos = WsDataPos::TransferOkxPos($value, $this->symbolInfos, function ($symbol) { | 107 | $wsDataPos = WsDataPos::TransferOkxPos($value, $this->symbolInfos, function ($symbol) { |
| 107 | return $this->getSymbolSt($symbol); | 108 | return $this->getSymbolSt($symbol); |
| @@ -111,9 +112,14 @@ class CmBroker | @@ -111,9 +112,14 @@ class CmBroker | ||
| 111 | $positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $pos; | 112 | $positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $pos; |
| 112 | $wsData = new WsData($this->plat, 'pos', $trade = null, $pos = $wsDataPos); | 113 | $wsData = new WsData($this->plat, 'pos', $trade = null, $pos = $wsDataPos); |
| 113 | $onData($wsData); | 114 | $onData($wsData); |
| 115 | + if ($eventType == 'event_update') { | ||
| 116 | + $this->positions[$wsDataPos->symbol . "_" . $wsDataPos->posSide] = $pos; | ||
| 114 | } | 117 | } |
| 115 | } | 118 | } |
| 119 | + } | ||
| 120 | + if ($eventType == 'snapshot') { | ||
| 116 | $this->positions = $positions; | 121 | $this->positions = $positions; |
| 122 | + } | ||
| 117 | return; | 123 | return; |
| 118 | } | 124 | } |
| 119 | if (isset($data['arg']) && $data['arg']['channel'] == 'account') { | 125 | if (isset($data['arg']) && $data['arg']['channel'] == 'account') { |
-
请 注册 或 登录 后发表评论