From 573d22f534116ed01056869f2299f37d04b8ddb6 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期日, 13 五月 2018 23:58:55 +0800
Subject: [PATCH] 完成控制服务前台操作配置数据功能
---
CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java | 31 ++++++++++++++++++++++++++++++-
1 files changed, 30 insertions(+), 1 deletions(-)
diff --git a/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java b/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java
index 69fba40..8e9791e 100644
--- a/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java
+++ b/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java
@@ -53,6 +53,21 @@
dataQuery.setResponseInfo(DataTransactionFactory.createBusinessResponseJson(ResponseConstant.RESULT_CODE_SUCCESS,"鍒锋柊鎴愬姛"));
}
+ /**
+ * 鐢ㄦ潵绯荤粺鍚姩鍒锋柊
+ */
+ @Override
+ public void startFlush() {
+ //1.0 灏佽 AppRoute
+ doFlushAppRoute();
+
+ //2.0 鍒嗚 Mapping
+ doFlushMapping();
+
+ //3.0 鍒嗚 ServiceSql
+ doFlushServiceSql();
+ }
+
private void checkCacheParam(DataQuery dataQuery) throws SMOException{
JSONObject params = dataQuery.getRequestParams();
if(params == null || !params.containsKey(CommonConstant.CACHE_PARAM_NAME)){
@@ -68,6 +83,11 @@
if(!CommonConstant.CACHE_SERVICE_SQL.equals(params.getString(CommonConstant.CACHE_PARAM_NAME))){
return ;
}
+ // 鍒锋柊
+ doFlushServiceSql();
+ }
+
+ private void doFlushServiceSql() {
List<ServiceSql> serviceSqls = queryServiceDAOImpl.qureyServiceSqlAll();
if(serviceSqls == null || serviceSqls.size() == 0){
@@ -77,6 +97,7 @@
ServiceSqlCache.setServiceSql(serviceSql);
}
}
+
/**
* 鍒锋柊 Mapping 鏁版嵁
@@ -89,6 +110,10 @@
return ;
}
+ doFlushMapping();
+ }
+
+ private void doFlushMapping() {
List<Mapping> mappings = centerServiceDAOImpl.getMappingInfoAll();
for(Mapping mapping : mappings){
@@ -123,6 +148,11 @@
if(!CommonConstant.CACHE_APP_ROUTE_SERVICE.equals(params.getString(CommonConstant.CACHE_PARAM_NAME))){
return ;
}
+ doFlushAppRoute();
+
+ }
+
+ private void doFlushAppRoute() {
List<Map> appInfos = centerServiceDAOImpl.getAppRouteAndServiceInfoAll();
Map<String,List<AppRoute>> appRoustsMap = new HashMap<String,List<AppRoute>>();
List<AppRoute> appRoutes = null;
@@ -140,7 +170,6 @@
for (String appId : appRoustsMap.keySet()) {
AppRouteCache.setAppRoute(appRoustsMap.get(appId));
}
-
}
public ICenterServiceDAO getCenterServiceDAOImpl() {
--
Gitblit v1.8.0