| | |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | |
|---|
| | | @dask.delayed |
|---|
| | | def statistic_big_buy_data(): |
|---|
| | | buy_datas, bigger_buy_datas = HuaXinBuyOrderManager.statistic_big_buy_data(code, fdatas, limit_up_price) |
|---|
| | | if buy_datas: |
|---|
| | |
|---|
| | | logger_debug.exception(e) |
|---|
| | | return buy_datas |
|---|
| | | |
|---|
| | | @dask.delayed |
|---|
| | | def statistic_big_sell_data(): |
|---|
| | | sell_datas = HuaXinSellOrderStatisticManager.statistic_big_sell_data(code, fdatas) |
|---|
| | | if sell_datas: |
|---|
| | | BigOrderDealManager().add_sell_datas(code, sell_datas) |
|---|
| | | return sell_datas |
|---|
| | | |
|---|
| | | @dask.delayed |
|---|
| | | def statistic_big_data(f1_, f2_): |
|---|
| | | temp_data = f1_, f2_ |
|---|
| | | return temp_data |
|---|
