From 0032c293fdcf83cf399a4898e5965815455a4f22 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 08 十二月 2020 14:27:11 +0800
Subject: [PATCH] 本地代码暂存
---
service-order/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java | 35 +++++++++++++++++++++++++++++++++++
1 files changed, 35 insertions(+), 0 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
index 0fb1fef..669d877 100644
--- 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
@@ -61,6 +61,9 @@
//5.0 鍒锋柊鍩虹鏉冮檺
flushPrivilege(dataQuery);
+ //鍒锋柊databus
+ doFlushDatabus(dataQuery);
+
dataQuery.setResponseInfo(DataTransactionFactory.createBusinessResponseJson(ResponseConstant.RESULT_CODE_SUCCESS, "鍒锋柊鎴愬姛"));
}
@@ -83,6 +86,8 @@
//5.0 鍒锋柊鍩虹鏉冮檺
flushPrivilege(headers);
+
+ flushDatabus(headers);
}
/**
@@ -104,6 +109,7 @@
doFlushPrivilege();
+ //鍒锋柊databus
doFlushDatabus();
}
@@ -230,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());
@@ -243,6 +263,21 @@
}
/**
+ * 鍒锋柊 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();
+ }
+
+ /**
* 鍒锋柊 Mapping 鏁版嵁
*/
private void flushMapping(Map<String, String> headers) {
--
Gitblit v1.8.0