@@ -20,3 +20,75 @@ async def get_monitor_cache_info(request: Request):
2020 except Exception as e :
2121 logger .exception (e )
2222 return response_500 (data = "" , message = str (e ))
23+
24+
25+ @cacheController .post ("/getNames" , response_model = List [CacheInfoModel ], dependencies = [Depends (CheckUserInterfaceAuth ('monitor:cache:list' ))])
26+ async def get_monitor_cache_name (request : Request ):
27+ try :
28+ # 获取全量数据
29+ cache_name_list_result = CacheService .get_cache_monitor_cache_name_services ()
30+ logger .info ('获取成功' )
31+ return response_200 (data = cache_name_list_result , message = "获取成功" )
32+ except Exception as e :
33+ logger .exception (e )
34+ return response_500 (data = "" , message = str (e ))
35+
36+
37+ @cacheController .post ("/getKeys/{cache_name}" , response_model = List [str ], dependencies = [Depends (CheckUserInterfaceAuth ('monitor:cache:list' ))])
38+ async def get_monitor_cache_key (request : Request , cache_name : str ):
39+ try :
40+ # 获取全量数据
41+ cache_key_list_result = await CacheService .get_cache_monitor_cache_key_services (request , cache_name )
42+ logger .info ('获取成功' )
43+ return response_200 (data = cache_key_list_result , message = "获取成功" )
44+ except Exception as e :
45+ logger .exception (e )
46+ return response_500 (data = "" , message = str (e ))
47+
48+
49+ @cacheController .post ("/getValue/{cache_name}/{cache_key}" , response_model = CacheInfoModel , dependencies = [Depends (CheckUserInterfaceAuth ('monitor:cache:list' ))])
50+ async def get_monitor_cache_value (request : Request , cache_name : str , cache_key : str ):
51+ try :
52+ # 获取全量数据
53+ cache_value_list_result = await CacheService .get_cache_monitor_cache_value_services (request , cache_name , cache_key )
54+ logger .info ('获取成功' )
55+ return response_200 (data = cache_value_list_result , message = "获取成功" )
56+ except Exception as e :
57+ logger .exception (e )
58+ return response_500 (data = "" , message = str (e ))
59+
60+
61+ @cacheController .post ("/clearCacheName/{cache_name}" , response_model = CrudCacheResponse , dependencies = [Depends (CheckUserInterfaceAuth ('monitor:cache:list' ))])
62+ async def clear_monitor_cache_name (request : Request , cache_name : str ):
63+ try :
64+ clear_cache_name_result = await CacheService .clear_cache_monitor_cache_name_services (request , cache_name )
65+ if clear_cache_name_result .is_success :
66+ logger .info (clear_cache_name_result .message )
67+ return response_200 (data = clear_cache_name_result , message = clear_cache_name_result .message )
68+ except Exception as e :
69+ logger .exception (e )
70+ return response_500 (data = "" , message = str (e ))
71+
72+
73+ @cacheController .post ("/clearCacheKey/{cache_name}/{cache_key}" , response_model = CrudCacheResponse , dependencies = [Depends (CheckUserInterfaceAuth ('monitor:cache:list' ))])
74+ async def clear_monitor_cache_key (request : Request , cache_name : str , cache_key : str ):
75+ try :
76+ clear_cache_key_result = await CacheService .clear_cache_monitor_cache_key_services (request , cache_name , cache_key )
77+ if clear_cache_key_result .is_success :
78+ logger .info (clear_cache_key_result .message )
79+ return response_200 (data = clear_cache_key_result , message = clear_cache_key_result .message )
80+ except Exception as e :
81+ logger .exception (e )
82+ return response_500 (data = "" , message = str (e ))
83+
84+
85+ @cacheController .post ("/clearCacheAll" , response_model = CrudCacheResponse , dependencies = [Depends (CheckUserInterfaceAuth ('monitor:cache:list' ))])
86+ async def clear_monitor_cache_all (request : Request ):
87+ try :
88+ clear_cache_all_result = await CacheService .clear_cache_monitor_all_services (request )
89+ if clear_cache_all_result .is_success :
90+ logger .info (clear_cache_all_result .message )
91+ return response_200 (data = clear_cache_all_result , message = clear_cache_all_result .message )
92+ except Exception as e :
93+ logger .exception (e )
94+ return response_500 (data = "" , message = str (e ))
0 commit comments