deploy-jar-template/src/main/resources/wk_sn_lic.bin | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
deploy-jar-template/src/test/java/com/walker/TestGenerator.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
pom.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-di-support-univocity/src/main/java/com/walker/di/excel/DefaultDataListener.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-infrastructure/pom.xml | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-jdbc/src/main/java/com/walker/jdbc/JdbcInspector.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-pay-support-payunk/src/test/java/com/walker/pay/payunk/TestPayUnkEngine.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-tcp/src/main/java/com/walker/tcp/support/AbstractConnectionManager.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
walker-tcp/src/main/java/com/walker/tcp/support/AbstractTcpLongEngine.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
deploy-jar-template/src/main/resources/wk_sn_lic.bin
File was deleted deploy-jar-template/src/test/java/com/walker/TestGenerator.java
File was deleted pom.xml
@@ -65,7 +65,7 @@ <spring-cloud-dependencies.version>2021.0.4</spring-cloud-dependencies.version> <spring.cloud.alibaba.version>2021.0.4.0</spring.cloud.alibaba.version> <walker-tools.version>1.0.0-SNAPSHOT</walker-tools.version> <!-- <walker-tools.version>1.0.0-SNAPSHOT</walker-tools.version>--> <walker-dependencies.version>2.7.18</walker-dependencies.version> <!-- <walker-infrastructure.version>2.3.0-SNAPSHOT</walker-infrastructure.version>--> @@ -158,15 +158,6 @@ <groupId>org.springframework.boot</groupId> <artifactId>spring-boot</artifactId> <!-- <scope>compile</scope>--> </dependency> <!-- 把安全模块放到工具项目工程中,2022/09-27 --> <dependency> <groupId>com.walkersoft</groupId> <artifactId>walker-tools</artifactId> <type>pom</type> <scope>import</scope> <version>${walker-tools.version}</version> </dependency> <!-- ================================================= walker-di-support-univocity/src/main/java/com/walker/di/excel/DefaultDataListener.java
@@ -4,7 +4,6 @@ import com.alibaba.excel.event.AnalysisEventListener; import com.walker.infrastructure.ApplicationRuntimeException; import com.walker.infrastructure.utils.StringUtils; import com.walker.security.SystemLogMan; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -37,7 +36,6 @@ // throw new IllegalArgumentException("LoadListener is required!"); // } this.loadListener = loadListener; SystemLogMan.getInstance().checkMan(); } @Override walker-infrastructure/pom.xml
@@ -121,12 +121,6 @@ <artifactId>jaxen</artifactId> </dependency> <!-- 授权访问:2022/10/08 --> <dependency> <groupId>com.walkersoft</groupId> <artifactId>walker-security</artifactId> </dependency> </dependencies> <!--<build> 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映射关系:key=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){ walker-jdbc/src/main/java/com/walker/jdbc/JdbcInspector.java
@@ -1,7 +1,6 @@ package com.walker.jdbc; import com.walker.db.DatabaseType; import com.walker.security.SystemLogMan; /** * 存储系统数据库相关的关键信息,方便业务查看并使用。 @@ -19,7 +18,6 @@ private JdbcInspector(){} public static JdbcInspector getInstance(){ SystemLogMan.getInstance().checkMan(); if(instance == null){ instance = new JdbcInspector(); } walker-pay-support-payunk/src/test/java/com/walker/pay/payunk/TestPayUnkEngine.java
@@ -30,7 +30,7 @@ System.out.println(MoneyUtils.scaleYuan2Accuracy(1)); } @Test // @Test public void payAliAnDf(){ RestTemplate restTemplate = this.getRestTemplate(); PayEngineProvider payEngineProvider = new PayUnkEngineProvider(restTemplate); @@ -70,8 +70,6 @@ configuration.put(Constants.CONFIG_KEY_APPID, new DefaultVariable(VariableType.String, "APP202310209174137956073295", null).setId(Constants.CONFIG_KEY_APPID)); // 支付宝A版代付到户编号:3635 configuration.put(Constants.CONFIG_KEY_USER_ACCOUNT_ID, new DefaultVariable(VariableType.String, "3635", null).setId(Constants.CONFIG_KEY_USER_ACCOUNT_ID)); // configuration.put(Constants.CONFIG_KEY_ALIPAY_IDENTITY, new DefaultVariable(VariableType.String, "2088820986081574", null).setId(Constants.CONFIG_KEY_ALIPAY_IDENTITY)); // configuration.put(Constants.CONFIG_KEY_ALIPAY_AGREEMENT_NO, new DefaultVariable(VariableType.String, "20235824012463444332", null).setId(Constants.CONFIG_KEY_ALIPAY_AGREEMENT_NO)); configuration.put(Constants.CONFIG_KEY_ALIPAY_IDENTITY, new DefaultVariable(VariableType.String, "identity", null).setId(Constants.CONFIG_KEY_ALIPAY_IDENTITY)); configuration.put(Constants.CONFIG_KEY_ALIPAY_AGREEMENT_NO, new DefaultVariable(VariableType.String, "agreement", null).setId(Constants.CONFIG_KEY_ALIPAY_AGREEMENT_NO)); return configuration; walker-tcp/src/main/java/com/walker/tcp/support/AbstractConnectionManager.java
@@ -2,7 +2,6 @@ import com.walker.db.page.GenericPager; import com.walker.infrastructure.utils.StringUtils; import com.walker.security.SystemLogMan; import com.walker.tcp.Connection; import com.walker.tcp.ConnectionCache; import com.walker.tcp.ConnectionManager; @@ -43,7 +42,6 @@ if(connectionTypes != null){ this.connectionTypeCache = connectionTypes; } SystemLogMan.getInstance().checkMan(); } public void setMultipleEngine(boolean multipleEngine) { walker-tcp/src/main/java/com/walker/tcp/support/AbstractTcpLongEngine.java
@@ -1,7 +1,6 @@ package com.walker.tcp.support; import com.walker.infrastructure.utils.StringUtils; import com.walker.security.SystemLogMan; import com.walker.tcp.Connection; import com.walker.tcp.ConnectionCallback; import com.walker.tcp.ConnectionManager; @@ -97,7 +96,6 @@ // throw new IllegalArgumentException(ProtocolResolver.ERR_NOFOUND); // } try{ SystemLogMan.getInstance().checkMan(); this.onStart(); startTime = System.currentTimeMillis(); if(openHeartBeat){