| | |
|---|
| | | |
|---|
| | | |
|---|
| | | def re_set_price_pres(codes, force=False): |
|---|
| | | # 通过历史数据缓存获取 |
|---|
| | | result = HistoryKDatasUtils.get_gp_latest_info(codes) |
|---|
| | | for item in result: |
|---|
| | | symbol = item['symbol'] |
|---|
| | |
|---|
| | | # 获取最近一次涨停/涨停下一个交易日的最大值 |
|---|
| | | def get_volumns_by_code(code, count=60) -> object: |
|---|
| | | datas = HistoryKDatasUtils.get_history_tick_n(code, count, "open,high,low,close,volume,pre_close,bob,amount") |
|---|
| | | if not datas: |
|---|
| | | return None |
|---|
| | | # 计算 |
|---|
| | | datas.sort(key=lambda x: x["bob"], reverse=True) |
|---|
| | | return datas |
|---|
| | | |
|---|
| | | |
|---|
| | | def parse_max_volume(code, datas, is_new_or_near_top=False): |
|---|
| | | def parse_max_volume(code, datas, is_new_or_near_top=False): |
|---|
| | | result = __parse_max_volume(code, datas, is_new_or_near_top) |
|---|
| | | refer_index = result[3] |
|---|
| | | # 计算最低价 |
|---|
