| | |
|---|
| | | return temp_data |
|---|
| | | |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price_as_num(code) |
|---|
| | | |
|---|
| | | if len(fdatas) > 100: |
|---|
| | | # 并行处理买单与卖单 |
|---|
| | | f1 = statistic_big_buy_data() |
|---|
| | | f2 = statistic_big_sell_data() |
|---|
| | | dask_result = statistic_big_data(f1, f2) |
|---|
| | | # 超过100条数据才需要并行处理 |
|---|
| | | f1 = dask.delayed(statistic_big_buy_data)() |
|---|
| | | f2 = dask.delayed(statistic_big_sell_data)() |
|---|
| | | dask_result = dask.delayed(statistic_big_data)(f1, f2) |
|---|
| | | buy_datas, sell_datas = dask_result.compute() |
|---|
| | | else: |
|---|
| | | buy_datas = statistic_big_buy_data() |
|---|
| | | sell_datas = statistic_big_sell_data() |
|---|
| | | # L撤的比例与买卖大单无直接关系了 |
|---|
| | | # if buy_datas or sell_datas: |
|---|
| | | # buy_money = BigOrderDealManager().get_total_buy_money(code) |
|---|
