| | |
|---|
| | | @param big_orders: [(代码, 买/卖, [订单号,量,金额,最后时间戳,最后价格, 初始时间戳, 初始价格])] 如：[ ('002741', 0, [475820, 91600, 1610328, 92500000, 17.58, 92500000, 17.58])] |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | codes = [] |
|---|
| | | for d in big_orders: |
|---|
| | | code = d[0] |
|---|
| | | if d[1] == 0: |
|---|
| | |
|---|
| | | if code not in self.big_order_sell: |
|---|
| | | self.big_order_sell[code] = [] |
|---|
| | | self.big_order_sell[code].append(d[2]) |
|---|
| | | if code not in codes: |
|---|
| | | codes.append(code) |
|---|
| | | # 驱动下单 |
|---|
| | | for code in codes: |
|---|
| | | self.__run(code, self.stock_variables_dict.get(code)) |
|---|
| | | |
|---|
| | | def add_ticks(self, ticks): |
|---|
| | | """ |
|---|
| | |
|---|
| | | self.current_block_in_datas = _block_in_datas |
|---|
| | | |
|---|
| | | def __run(self, code, sv: StockVariables): |
|---|
| | | if not sv: |
|---|
| | | return |
|---|
| | | # 运行代码 |
|---|
| | | # 注入大单 |
|---|
| | | sv.今日大单数据 = self.big_order_buy.get(code) |
|---|
