shikeying
2024-05-08 19ab3a8c760fa5e7e6cfab1b2ff97c187589efae
去掉加密文件验证
2个文件已删除
8个文件已修改
103 ■■■■■ 已修改文件
deploy-jar-template/src/main/resources/wk_sn_lic.bin 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
deploy-jar-template/src/test/java/com/walker/TestGenerator.java 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pom.xml 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-di-support-univocity/src/main/java/com/walker/di/excel/DefaultDataListener.java 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-infrastructure/pom.xml 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-infrastructure/src/main/java/com/walker/infrastructure/arguments/AbstractArgumentsManager.java 64 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-jdbc/src/main/java/com/walker/jdbc/JdbcInspector.java 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-pay-support-payunk/src/test/java/com/walker/pay/payunk/TestPayUnkEngine.java 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-tcp/src/main/java/com/walker/tcp/support/AbstractConnectionManager.java 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
walker-tcp/src/main/java/com/walker/tcp/support/AbstractTcpLongEngine.java 2 ●●●●● 补丁 | 查看 | 原始文档 | 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){