| | |
|---|
| | | |
|---|
| | | def get_sell_deal_big_order_money(self, code, threshold_money): |
|---|
| | | if code in self.__already_total_sell_deal_big_order_money: |
|---|
| | | return sum([x[0] if x[0] >= threshold_money else 0 for x in |
|---|
| | | self.__already_total_sell_deal_big_order_money[code][1]]) |
|---|
| | | sellno_map = l2_data_util_new.local_today_sellno_map.get(code) |
|---|
| | | total_sell_money = 0 |
|---|
| | | for x in self.__already_total_sell_deal_big_order_money[code][1]: |
|---|
| | | if x[0] < threshold_money: |
|---|
| | | continue |
|---|
| | | if f"{x[2]}" in sellno_map: |
|---|
| | | continue |
|---|
| | | total_sell_money += x[0] |
|---|
| | | return total_sell_money |
|---|
| | | return 0 |
|---|
| | | |
|---|
| | | def get_deal_big_order_money_list(self, code): |
|---|
| | |
|---|
| | | response_data = json.loads(r_str) |
|---|
| | | if response_data["code"] == 0: |
|---|
| | | datas = response_data["data"] |
|---|
| | | async_log_util.info(logger_debug, f"拉取订阅之前的数据：{code_}-{datas}") |
|---|
| | | if datas: |
|---|
| | | buy_datas = datas["buy"] |
|---|
| | | sell_datas = datas["sell"] |
|---|
