| | |
| | | if not cache_result[0] or cache_result[1] is None: |
| | | global_util.limit_up_time[code] = time |
| | | tool.CodeDataCacheUtil.set_cache(self.__limit_up_time_cache, code, time) |
| | | RedisUtils.setex_async( |
| | | self.__db, "limit_up_time-{}".format(code), tool.get_expire(), time) |
| | | # TODO 测试 |
| | | # RedisUtils.setex_async( |
| | | # self.__db, "limit_up_time-{}".format(code), tool.get_expire(), time) |
| | | |
| | | def get_limit_up_time(self, code): |
| | | time = global_util.limit_up_time.get(code) |
| | |
| | | # 删除买撤点数据 |
| | | def delete_buy_cancel_point(self, code): |
| | | tool.CodeDataCacheUtil.clear_cache(self.__buy_cancel_single_pos_cache, code) |
| | | RedisUtils.delete_async(self.__db, "buy_cancel_single_pos-{}".format(code)) |
| | | # TODO 测试 |
| | | # RedisUtils.delete_async(self.__db, "buy_cancel_single_pos-{}".format(code)) |
| | | |
| | | |
| | | # 清除l2数据 |