| | |
| | | tool.CodeDataCacheUtil.set_cache(self.__max_price_info_cache, code, price_info) |
| | | RedisUtils.setex_async( |
| | | self.__db, "max_price_info-{}".format(code), tool.get_expire(), json.dumps(price_info)) |
| | | async_log_util.info(logger_debug, f"最大现价-{price_info}") |
| | | async_log_util.info(logger_debug, f"最大现价:{code}-{price_info}") |
| | | |
| | | def get_price_info_cache(self, code): |
| | | return self.__max_price_info_cache.get(code) |
| | |
| | | # 09:25之后才开始记录 |
| | | if datas and tool.get_now_time_str() > '09:25:00': |
| | | for d in datas: |
| | | MaxPriceInfoManager().set_price_info(d[0], price=d[1], time=l2_huaxin_util.convert_time(d[9])) |
| | | MaxPriceInfoManager().set_price_info(d[0], price=d[1], time=d[9]) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | |
| | |
| | | |
| | | if __name__ == "__main__": |
| | | result = get_limit_up_list() |
| | | print(len(result["list"])) |
| | | result_list = result["list"] |
| | | print(len(result_list)) |