| | |
|---|
| | | code = k.split("-")[-1] |
|---|
| | | val = RedisUtils.get(__redis, k) |
|---|
| | | val = json.loads(val) |
|---|
| | | if val: |
|---|
| | | val = set(val) |
|---|
| | | else: |
|---|
| | | val = set() |
|---|
| | | CodeDataCacheUtil.set_cache(cls.__cancel_watch_indexs_cache, code, val) |
|---|
| | | |
|---|
| | | keys = RedisUtils.keys(__redis, "h_cancel_transaction_index-*") |
|---|
| | |
|---|
| | | cache_result = CodeDataCacheUtil.get_cache(self.__cancel_watch_indexs_cache, code) |
|---|
| | | if cache_result[0]: |
|---|
| | | return cache_result[1] |
|---|
| | | return None, -1, False |
|---|
| | | return set() |
|---|
| | | |
|---|
| | | def __save_transaction_index(self, code, index): |
|---|
| | | CodeDataCacheUtil.set_cache(self.__transaction_progress_index_dict, code, index) |
|---|
