From e9be8d15ab3ee20685793e16071c56485b32e33a Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期五, 23 四月 2021 10:10:24 +0800
Subject: [PATCH] 优化代码
---
service-order/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java | 50 ++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 48 insertions(+), 2 deletions(-)
diff --git a/service-order/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java b/service-order/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java
old mode 100644
new mode 100755
index 8c3d9d9..669d877
--- a/service-order/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java
+++ b/service-order/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java
@@ -4,6 +4,7 @@
import com.java110.core.factory.DataTransactionFactory;
import com.java110.db.dao.IQueryServiceDAO;
import com.java110.dto.basePrivilege.BasePrivilegeDto;
+import com.java110.dto.businessDatabus.BusinessDatabusDto;
import com.java110.entity.center.AppRoute;
import com.java110.entity.mapping.Mapping;
import com.java110.entity.order.ServiceBusiness;
@@ -60,6 +61,9 @@
//5.0 鍒锋柊鍩虹鏉冮檺
flushPrivilege(dataQuery);
+ //鍒锋柊databus
+ doFlushDatabus(dataQuery);
+
dataQuery.setResponseInfo(DataTransactionFactory.createBusinessResponseJson(ResponseConstant.RESULT_CODE_SUCCESS, "鍒锋柊鎴愬姛"));
}
@@ -82,6 +86,8 @@
//5.0 鍒锋柊鍩虹鏉冮檺
flushPrivilege(headers);
+
+ flushDatabus(headers);
}
/**
@@ -97,11 +103,14 @@
//3.0 鍒嗚 ServiceSql
doFlushServiceSql();
-
+ //5.0 鍒锋柊鍏ㄦ柊
doFlushServiceBusiness();
- //5.0 鍒锋柊鍏ㄦ柊
+
doFlushPrivilege();
+
+ //鍒锋柊databus
+ doFlushDatabus();
}
@@ -227,6 +236,20 @@
/**
* 鍒锋柊 Mapping 鏁版嵁
*/
+ private void doFlushDatabus(DataQuery dataQuery) {
+
+ JSONObject params = dataQuery.getRequestParams();
+
+ if (!CommonConstant.CACHE_DATABUS.equals(params.getString(CommonConstant.CACHE_PARAM_NAME))) {
+ return;
+ }
+
+ doFlushDatabus();
+ }
+
+ /**
+ * 鍒锋柊 Mapping 鏁版嵁
+ */
private void flushPrivilege(Map<String, String> headers) {
Assert.hasKey(headers, CommonConstant.CACHE_PARAM, "鏈寘鍚玞ache鍙傛暟" + headers.toString());
@@ -237,6 +260,21 @@
}
doFlushPrivilege();
+ }
+
+ /**
+ * 鍒锋柊 databus 鏁版嵁
+ */
+ private void flushDatabus(Map<String, String> headers) {
+
+ Assert.hasKey(headers, CommonConstant.CACHE_PARAM, "鏈寘鍚玞ache鍙傛暟" + headers.toString());
+
+ if (!CommonConstant.CACHE_DATABUS.equals(headers.get(CommonConstant.CACHE_PARAM))
+ && !CommonConstant.CACHE_ALL.equals(headers.get(CommonConstant.CACHE_PARAM))) {
+ return;
+ }
+
+ doFlushDatabus();
}
/**
@@ -289,6 +327,14 @@
PrivilegeCache.setValue(basePrivilegeDtos);
}
+ private void doFlushDatabus() {
+ logger.debug("寮�濮嬪埛鏂� Mapping鏁版嵁鍒皉edis鏁版嵁搴撲腑");
+ List<BusinessDatabusDto> businessDatabusDtos = centerServiceDAOImpl.getDatabusAll();
+ //鍒犻櫎鍘熷鏁版嵁
+ DatabusCache.removeData(DatabusCache.DEFAULT_DATABUS);
+ DatabusCache.setValue(businessDatabusDtos);
+ }
+
/**
* 鍒锋柊AppRoute鏁版嵁
*/
--
Gitblit v1.8.0