From 19ab3a8c760fa5e7e6cfab1b2ff97c187589efae Mon Sep 17 00:00:00 2001
From: shikeying <pxzsky@163.com>
Date: 星期三, 08 五月 2024 11:57:22 +0800
Subject: [PATCH] 去掉加密文件验证
---
walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java | 64 +++++++++++++++----------------
1 files changed, 31 insertions(+), 33 deletions(-)
diff --git a/walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java b/walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java
index 7c6e963..580bea8 100644
--- a/walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java
+++ b/walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java
@@ -2,7 +2,6 @@
import com.walker.infrastructure.arguments.support.DefaultVariable;
import com.walker.infrastructure.utils.StringUtils;
-import com.walker.security.SystemLogMan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -22,42 +21,41 @@
public abstract class AbstractArgumentsManager implements ArgumentsManager {
protected Logger logger = LoggerFactory.getLogger(getClass());
-
+
private Object source;
-
+
/* 鍒嗙粍闆嗗悎 */
private Map<String, Group> groupMap = new TreeMap<String, Group>();
-
+
/* 鍙橀噺闆嗗悎涓庣粍ID鏄犲皠鍏崇郴锛歬ey=groupId, value=variable ID set */
private ConcurrentHashMap<String, List<String>> variableMap = new ConcurrentHashMap<String, List<String>>(8);
-
+
private ConcurrentHashMap<String, Variable> allVars = new ConcurrentHashMap<String, Variable>(32);
-
+
private Object lock = new Object();
-
+
@Override
public void setSource(Object source){
assert (source != null);
this.source = source;
}
-
+
@Override
public void afterPropertiesSet() throws Exception{
- SystemLogMan.getInstance().checkMan();
// if(this.source == null){
// throw new ArgumentsException("parameter: source is not found!");
// }
-
+
List<Group> groupList = null;
-
+
try{
groupList = load(source);
} catch(Exception ex){
throw new ArgumentsException("涓氬姟鍔犺浇閰嶇疆鍙傛暟澶辫触:" + ex.getMessage(), ex);
}
-
+
initGroup(groupList);
-
+
if(logger.isDebugEnabled()){
logger.debug("~~~~~~~~~~~~~~~~~ 绯荤粺鍔犺浇鎵�鏈夐厤缃弬鏁�-start ~~~~~~~~~~~~~~~~~");
for(Variable v : allVars.values()){
@@ -66,7 +64,7 @@
logger.debug("~~~~~~~~~~~~~~~~~ 绯荤粺鍔犺浇鎵�鏈夐厤缃弬鏁�-end ~~~~~~~~~~~~~~~~~");
}
}
-
+
private void initGroup(List<Group> groupList){
if(groupList != null){
Collections.sort(groupList);
@@ -76,7 +74,7 @@
}
}
}
-
+
private void initVariableInGroup(Group group){
List<Variable> varList = group.getChildren();
if(varList != null && varList.size() > 0){
@@ -89,7 +87,7 @@
} else
variableMap.put(group.getId(), null);
}
-
+
/**
* 鍔犺浇鍏蜂綋鐨勫弬鏁版暟鎹紝骞惰繑鍥炲垎缁勯泦鍚堜俊鎭紝鍒嗙粍涓寘鍚簡鍙彉鍙傛暟鏁版嵁銆�</p>
* 瀛愮被瀹炵幇鍏蜂綋鍔犺浇杩囩▼銆�
@@ -97,15 +95,15 @@
* @return
*/
protected abstract List<Group> load(Object source) throws Exception;
-
+
/**
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
- *
+ *
* 浠ヤ笅涓虹郴缁熸彁渚涚殑鏍囧噯API
- *
+ *
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
-
+
@Override
public Variable getVariable(String id) {
assert (StringUtils.isNotEmpty(id));
@@ -127,19 +125,19 @@
public void persist(String groupId, String variableId, Object value) {
assert (StringUtils.isNotEmpty(groupId));
assert (value != null);
-
+
/* 鏇存柊瀹炰綋涓殑鏁版嵁 */
try {
saveVariable(groupId, variableId, value);
} catch (Exception e) {
throw new ArgumentsException("鏇存柊鍙彉鍙傛暟鍒颁笟鍔′腑鍑虹幇閿欒: " + e.getMessage(), e);
}
-
+
synchronized (lock) {
updateCache(groupId, variableId, value);
}
}
-
+
private void updateCache(String groupId, String variableId, Object value){
if(groupMap.get(groupId) == null)
throw new IllegalArgumentException("not found group id: " + groupId);
@@ -153,7 +151,7 @@
} else
throw new ElementNotFoundException("var id: " + variableId);
}
-
+
@Override
public void persist(List<Object[]> changedList){
if(changedList == null) return;
@@ -167,21 +165,21 @@
if(arr[2] == null)
throw new IllegalArgumentException("绗笁涓弬鏁�:value涓嶅瓨鍦ㄦ垨鑰呮槸绌哄��");
}
-
+
/* 鏇存柊瀹炰綋涓殑鏁版嵁 */
try {
saveVariables(changedList);
} catch (Exception e) {
throw new ArgumentsException("鏇存柊鍙彉鍙傛暟鍒颁笟鍔′腑鍑虹幇閿欒: " + e.getMessage(), e);
}
-
+
synchronized (lock){
for(Object[] args : changedList){
updateCache(args[0].toString(), args[1].toString(), args[2]);
}
}
}
-
+
@Override
public void insert(List<Object[]> insertList) {
if(insertList == null) return;
@@ -199,14 +197,14 @@
} catch (Exception e) {
throw new ArgumentsException("鏂板缓鍙彉鍙傛暟鍑虹幇閿欒: " + e.getMessage(), e);
}
-
+
synchronized (lock){
for(Object[] args : insertList){
insertCache((Group)args[0], (Variable)args[1]);
}
}
}
-
+
/**
* 鐢卞瓙绫绘潵瀹炵幇鍏蜂綋鐨勬洿鏂颁粙璐ㄤ腑鐨勫弬鏁帮紝濡傦細鏁版嵁搴撱�侀厤缃枃浠剁瓑銆�
* @param groupId 鍒嗙粍ID
@@ -216,7 +214,7 @@
*/
protected abstract void saveVariable(String groupId
, String variableId, Object value) throws Exception;
-
+
/**
* 瀛愮被瀹炵幇鎸佷箙鍖栨洿鏂板弬鏁颁俊鎭埌浠嬭川涓紝濡傦細鏁版嵁搴撱�侀厤缃枃浠剁瓑銆�</p>
* 鎵归噺鏇存柊鏂规硶锛岄泦鍚堜腑鏄暟缁勫璞★紝Object[]{groupId, variableId, value}</br>
@@ -225,7 +223,7 @@
* @throws Exception
*/
protected abstract void saveVariables(List<Object[]> changedList) throws Exception;
-
+
/**
* 鍔犲叆鏂扮殑鍙傛暟闆嗗悎锛岄泦鍚堜腑鏄暟缁勫璞★紝Object[]{group, variable}
* 濡傛灉宸茬粡瀛樺湪璇ュ弬鏁帮紝鍒欎笉鍐嶅垱寤恒��
@@ -251,7 +249,7 @@
varList.add(variable.getId());
}
}
-
+
@Override
public List<Group> getGroupList() {
if(groupMap.size() == 0) return null;
@@ -272,7 +270,7 @@
List<String> varIds = variableMap.get(groupId);
if(varIds == null)
return null;
-
+
List<Variable> result = new ArrayList<Variable>(8);
Variable var = null;
for(String vid : varIds){
--
Gitblit v1.9.1