| | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 计算时间的区间 |
|---|
| | | def __compute_time_space_as_second(cancel_time, cancel_time_unit): |
|---|
| | | def compute_time_space_as_second(cancel_time, cancel_time_unit): |
|---|
| | | __time = int(cancel_time) |
|---|
| | | if int(cancel_time) == 0: |
|---|
| | | return 0, 0 |
|---|
| | |
|---|
| | | # 根据买撤数据(与今日总的数据)计算买入数据 |
|---|
| | | def get_buy_data_with_cancel_data(cancel_data, local_today_num_operate_map): |
|---|
| | | # 计算时间区间 |
|---|
| | | min_space, max_space = __compute_time_space_as_second(cancel_data["val"]["cancelTime"], |
|---|
| | | min_space, max_space = compute_time_space_as_second(cancel_data["val"]["cancelTime"], |
|---|
| | | cancel_data["val"]["cancelTimeUnit"]) |
|---|
| | | max_time = __sub_time(cancel_data["val"]["time"], min_space) |
|---|
| | | min_time = __sub_time(cancel_data["val"]["time"], max_space) |
|---|
| | |
|---|
| | | |
|---|
| | | @async_call |
|---|
| | | def save_big_data(code, same_time_nums, datas): |
|---|
| | | return None |
|---|
| | | latest_datas = __last_big_data.get(code) |
|---|
| | | d1 = json.dumps(datas) |
|---|
| | | d2 = json.dumps(latest_datas) |
|---|
