| | |
|---|
| | | """ |
|---|
| | | # 涨停价成交的大单(策略进程尚未统计到的) |
|---|
| | | total_deal_money = 0 |
|---|
| | | total_deal_money_info_list = [] |
|---|
| | | limit_up_price_money_list = [] |
|---|
| | | deal_order_ids = BigOrderDealManager().get_total_buy_order_ids(code) |
|---|
| | | for info in money_list: |
|---|
| | |
|---|
| | | if info[2] in deal_order_ids: |
|---|
| | | continue |
|---|
| | | total_deal_money += info[0] |
|---|
| | | total_deal_money_info_list.append(info) |
|---|
| | | if limit_up_price_money_list: |
|---|
| | | average_money = sum(limit_up_price_money_list) // len(limit_up_price_money_list) |
|---|
| | | self.set_big_order_threshold(code, average_money) |
|---|
| | | self.__already_total_deal_big_order_money[code] = total_deal_money |
|---|
| | | async_log_util.info(logger_l2_radical_buy_data, f"之前的大单：{code}-{total_deal_money_info_list}") |
|---|
| | | |
|---|
| | | def get_big_order_threshold(self, code): |
|---|
| | | """ |
|---|
