From b2e0ee0c4ad5d3422208081772bc2faeadc8b7ea Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期二, 14 九月 2021 12:59:33 +0800
Subject: [PATCH] 优化代码
---
service-dev/src/main/java/com/java110/dev/smo/impl/DevServiceCacheSMOImpl.java | 55 ++++++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 52 insertions(+), 3 deletions(-)
diff --git a/service-dev/src/main/java/com/java110/dev/smo/impl/DevServiceCacheSMOImpl.java b/service-dev/src/main/java/com/java110/dev/smo/impl/DevServiceCacheSMOImpl.java
index 65ef6cc..bcc7b74 100644
--- a/service-dev/src/main/java/com/java110/dev/smo/impl/DevServiceCacheSMOImpl.java
+++ b/service-dev/src/main/java/com/java110/dev/smo/impl/DevServiceCacheSMOImpl.java
@@ -1,16 +1,18 @@
package com.java110.dev.smo.impl;
import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Transactional;
import com.java110.core.factory.DataTransactionFactory;
import com.java110.db.dao.IQueryServiceDAO;
+import com.java110.dev.dao.IDevServiceDAO;
import com.java110.dev.smo.IDevServiceCacheSMO;
import com.java110.dto.basePrivilege.BasePrivilegeDto;
import com.java110.dto.businessDatabus.BusinessDatabusDto;
+import com.java110.dto.businessTableHis.BusinessTableHisDto;
import com.java110.entity.center.AppRoute;
import com.java110.entity.mapping.Mapping;
import com.java110.entity.order.ServiceBusiness;
import com.java110.entity.service.ServiceSql;
-import com.java110.dev.dao.IDevServiceDAO;
import com.java110.service.context.DataQuery;
import com.java110.utils.cache.*;
import com.java110.utils.constant.CommonConstant;
@@ -62,7 +64,10 @@
flushPrivilege(dataQuery);
//鍒锋柊databus
- doFlushDatabus(dataQuery);
+ flushDatabus(dataQuery);
+
+//鍒锋柊BusinessTableHis
+ flushBusinessTableHis(dataQuery);
dataQuery.setResponseInfo(DataTransactionFactory.createBusinessResponseJson(ResponseConstant.RESULT_CODE_SUCCESS, "鍒锋柊鎴愬姛"));
}
@@ -88,6 +93,8 @@
flushPrivilege(headers);
flushDatabus(headers);
+
+ flushBusinessTableHis(headers);
}
/**
@@ -111,6 +118,9 @@
//鍒锋柊databus
doFlushDatabus();
+
+ //鍒锋柊BusinessTableHis
+ doFlushBusinessTableHis();
}
@@ -236,7 +246,7 @@
/**
* 鍒锋柊 Mapping 鏁版嵁
*/
- private void doFlushDatabus(DataQuery dataQuery) {
+ private void flushDatabus(DataQuery dataQuery) {
JSONObject params = dataQuery.getRequestParams();
@@ -246,6 +256,21 @@
doFlushDatabus();
}
+
+ /**
+ * 鍒锋柊 doFlushBusinessTableHis 鏁版嵁
+ */
+ private void flushBusinessTableHis(DataQuery dataQuery) {
+
+ JSONObject params = dataQuery.getRequestParams();
+
+ if (!CommonConstant.CACHE_BUSINESS_TABLE_HIS.equals(params.getString(CommonConstant.CACHE_PARAM_NAME))) {
+ return;
+ }
+
+ doFlushBusinessTableHis();
+ }
+
/**
* 鍒锋柊 Mapping 鏁版嵁
@@ -275,6 +300,21 @@
}
doFlushDatabus();
+ }
+
+ /**
+ * 鍒锋柊 databus 鏁版嵁
+ */
+ private void flushBusinessTableHis(Map<String, String> headers) {
+
+ Assert.hasKey(headers, CommonConstant.CACHE_PARAM, "鏈寘鍚玞ache鍙傛暟" + headers.toString());
+
+ if (!CommonConstant.CACHE_BUSINESS_TABLE_HIS.equals(headers.get(CommonConstant.CACHE_PARAM))
+ && !CommonConstant.CACHE_ALL.equals(headers.get(CommonConstant.CACHE_PARAM))) {
+ return;
+ }
+
+ doFlushBusinessTableHis();
}
/**
@@ -335,6 +375,15 @@
DatabusCache.setValue(businessDatabusDtos);
}
+ private void doFlushBusinessTableHis() {
+ logger.debug("寮�濮嬪埛鏂� BusinessTableHis鏁版嵁鍒皉edis鏁版嵁搴撲腑");
+ List<BusinessTableHisDto> businessTableHisDtos = devServiceDAOImpl.getBusinessTableHisAll();
+ //鍒犻櫎鍘熷鏁版嵁
+ BusinessTableHisCache.removeData(BusinessTableHisCache.DEFAULT_BUSINESS_TABLE_HIS);
+ BusinessTableHisCache.setValue(businessTableHisDtos);
+ }
+
+
/**
* 鍒锋柊AppRoute鏁版嵁
*/
--
Gitblit v1.8.0