| | |
| | | from l2.l2_transaction_data_manager import HuaXinSellOrderStatisticManager |
| | | from l2 import l2_data_util |
| | | from log_module import log_export, async_log_util |
| | | from utils import tool |
| | | |
| | |
| | | |
| | | |
| | | def test_sell_order_info(): |
| | | code = "603967" |
| | | code = "600506" |
| | | l2_data_util.load_l2_data(code, force=True) |
| | | date = tool.get_now_date_str() |
| | | data_map = log_export.load_huaxin_transaction_map(date=date) |
| | | datas = data_map.get(code) |
| | | start_print = False |
| | | for i in range(len(datas)): |
| | | d = datas[i] |
| | | if d[0][7] == 11181370: |
| | | start_print = True |
| | | if start_print: |
| | | print(d) |
| | | if i == 1653: |
| | | print("调试") |
| | | big_sell_order_info = HuaXinSellOrderStatisticManager.add_transaction_datas(code, d) |
| | | if big_sell_order_info[0] < 50 * 10000: |
| | | continue |
| | | # print(big_sell_order_info) |
| | | print(i, sum([ x[1]*x[2] for x in big_sell_order_info[1]]), big_sell_order_info) |
| | | |
| | | |
| | | if __name__ == '__main__': |