From 65bcf58c4e11a09b095bb60a639af8cadd025cba Mon Sep 17 00:00:00 2001
From: chengf <cgf12138@163.com>
Date: 星期三, 22 十月 2025 18:26:52 +0800
Subject: [PATCH] 部门/岗位添加部门代码
---
service-dev/src/main/java/com/java110/dev/smo/impl/DevServiceCacheSMOImpl.java | 64 +++++++++++++++++++++++++++-----
1 files changed, 54 insertions(+), 10 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..1fcaf8b 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
@@ -3,14 +3,11 @@
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.DataTransactionFactory;
import com.java110.db.dao.IQueryServiceDAO;
-import com.java110.dev.smo.IDevServiceCacheSMO;
-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;
-import com.java110.entity.service.ServiceSql;
import com.java110.dev.dao.IDevServiceDAO;
+import com.java110.dev.smo.IDevServiceCacheSMO;
+import com.java110.dto.privilege.BasePrivilegeDto;
+import com.java110.dto.system.*;
+import com.java110.dto.mapping.Mapping;
import com.java110.service.context.DataQuery;
import com.java110.utils.cache.*;
import com.java110.utils.constant.CommonConstant;
@@ -18,7 +15,7 @@
import com.java110.utils.exception.SMOException;
import com.java110.utils.util.Assert;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -62,7 +59,10 @@
flushPrivilege(dataQuery);
//鍒锋柊databus
- doFlushDatabus(dataQuery);
+ flushDatabus(dataQuery);
+
+//鍒锋柊BusinessTableHis
+ flushBusinessTableHis(dataQuery);
dataQuery.setResponseInfo(DataTransactionFactory.createBusinessResponseJson(ResponseConstant.RESULT_CODE_SUCCESS, "鍒锋柊鎴愬姛"));
}
@@ -88,6 +88,8 @@
flushPrivilege(headers);
flushDatabus(headers);
+
+ flushBusinessTableHis(headers);
}
/**
@@ -111,6 +113,9 @@
//鍒锋柊databus
doFlushDatabus();
+
+ //鍒锋柊BusinessTableHis
+ doFlushBusinessTableHis();
}
@@ -236,7 +241,7 @@
/**
* 鍒锋柊 Mapping 鏁版嵁
*/
- private void doFlushDatabus(DataQuery dataQuery) {
+ private void flushDatabus(DataQuery dataQuery) {
JSONObject params = dataQuery.getRequestParams();
@@ -246,6 +251,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 +295,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 +370,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