| | |
|---|
| | | |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price_as_num(code) |
|---|
| | | |
|---|
| | | if len(fdatas) > 100: |
|---|
| | | if False and len(fdatas) > 100: |
|---|
| | | # 并行处理买单与卖单 |
|---|
| | | # 超过100条数据才需要并行处理 |
|---|
| | | f1 = dask.delayed(statistic_big_buy_data)() |
|---|
| | |
|---|
| | | _start_time = time.time() |
|---|
| | | |
|---|
| | | try: |
|---|
| | | last_data = fdatas[-1] |
|---|
| | | # 统计上板时间 |
|---|
| | | try: |
|---|
| | | for d in fdatas: |
|---|
| | | if d[1]: |
|---|
| | | # 主动买 |
|---|
| | | if d[2]: |
|---|
| | | # 涨停 |
|---|
| | | current_price_process_manager.set_latest_not_limit_up_time(code, d[5]) |
|---|
| | | else: |
|---|
| | | # 主动卖（板上） |
|---|
| | | if d[2]: |
|---|
| | | L2LimitUpSellDataManager.clear_data(code) |
|---|
| | | break |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | if last_data[1] and last_data[2]: |
|---|
| | | current_price_process_manager.set_latest_not_limit_up_time(code, last_data[5]) |
|---|
| | | if not last_data[1] and last_data[2]: |
|---|
| | | L2LimitUpSellDataManager.clear_data(code) |
|---|
| | | big_sell_order_info = None |
|---|
| | | # 统计卖单 |
|---|
| | | big_sell_order_info = HuaXinSellOrderStatisticManager.statistic_continue_limit_up_sell_transaction_datas( |
|---|
