From c5aac73ec29f74904b544a722037b39bbb85ab3e Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 07 二月 2019 21:35:35 +0800
Subject: [PATCH] 去serviceCode 改为businessTypeCd 完成
---
OrderService/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java | 54 +++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 51 insertions(+), 3 deletions(-)
diff --git a/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java b/OrderService/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java
similarity index 82%
rename from CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java
rename to OrderService/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java
index ab4edfa..e34438c 100644
--- a/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceCacheSMOImpl.java
+++ b/OrderService/src/main/java/com/java110/order/smo/impl/CenterServiceCacheSMOImpl.java
@@ -1,8 +1,10 @@
-package com.java110.center.smo.impl;
+package com.java110.order.smo.impl;
import com.alibaba.fastjson.JSONObject;
-import com.java110.center.dao.ICenterServiceDAO;
-import com.java110.center.smo.ICenterServiceCacheSMO;
+import com.java110.common.cache.ServiceBusinessCache;
+import com.java110.entity.order.ServiceBusiness;
+import com.java110.order.dao.ICenterServiceDAO;
+import com.java110.order.smo.ICenterServiceCacheSMO;
import com.java110.common.cache.AppRouteCache;
import com.java110.common.cache.MappingCache;
import com.java110.common.cache.ServiceSqlCache;
@@ -55,6 +57,9 @@
//3.0 鍒嗚 ServiceSql
flushServiceSql(dataQuery);
+ //4.0 鍒锋柊涓氬姟淇℃伅
+ flushServiceBusiness(dataQuery);
+
dataQuery.setResponseInfo(DataTransactionFactory.createBusinessResponseJson(ResponseConstant.RESULT_CODE_SUCCESS,"鍒锋柊鎴愬姛"));
}
@@ -70,6 +75,9 @@
//3.0 鍒嗚 ServiceSql
flushServiceSql(headers);
+
+ //4.0 鍒锋柊涓氬姟淇℃伅
+ flushServiceBusiness(headers);
}
/**
@@ -85,6 +93,8 @@
//3.0 鍒嗚 ServiceSql
doFlushServiceSql();
+
+ doFlushServiceBusiness();
}
private void checkCacheParam(DataQuery dataQuery) throws SMOException{
@@ -106,6 +116,16 @@
doFlushServiceSql();
}
+ private void flushServiceBusiness(DataQuery dataQuery) {
+
+ JSONObject params = dataQuery.getRequestParams();
+ if(!CommonConstant.CACHE_SERVICE_BUSINESS.equals(params.getString(CommonConstant.CACHE_PARAM_NAME))){
+ return ;
+ }
+ // 鍒锋柊
+ doFlushServiceBusiness();
+ }
+
/**
* 3.0 鍒嗚 ServiceSql
*/
@@ -118,6 +138,20 @@
}
// 鍒锋柊
doFlushServiceSql();
+ }
+
+ /**
+ * 3.0 鍒嗚 ServiceSql
+ */
+ private void flushServiceBusiness(Map<String,String> headers) {
+
+ Assert.hasKey(headers,CommonConstant.CACHE_PARAM,"鏈寘鍚玞ache鍙傛暟"+headers.toString());
+ if(!CommonConstant.CACHE_SERVICE_BUSINESS.equals(headers.get(CommonConstant.CACHE_PARAM))
+ && !CommonConstant.CACHE_ALL.equals(headers.get(CommonConstant.CACHE_PARAM))){
+ return ;
+ }
+ // 鍒锋柊
+ doFlushServiceBusiness();
}
private void doFlushServiceSql() {
@@ -137,6 +171,20 @@
}
}
+ private void doFlushServiceBusiness(){
+ logger.debug("寮�濮嬪埛鏂� ServiceBusiness鏁版嵁鍒皉edis鏁版嵁搴撲腑");
+ List<ServiceBusiness> serviceBusinesses = queryServiceDAOImpl.qureyServiceBusiness();
+
+ if(serviceBusinesses == null || serviceBusinesses.size() == 0){
+ return;
+ }
+ //鍒犻櫎鍘熷鏁版嵁
+ ServiceSqlCache.removeData(ServiceBusinessCache._KEY_SERVICE_BUSINESS);
+
+ //璁剧疆缂撳瓨
+ ServiceBusinessCache.setServiceBusiness(serviceBusinesses);
+ }
+
/**
* 鍒锋柊 Mapping 鏁版嵁
--
Gitblit v1.8.0