1、完善代码和application.yml配置文件，去掉不用的引入文件； 2、init-config.xml配置中增加属性 enable,相应解析类...

liurunyu

2024-08-22 c70b92da60c0d00625da5fc2369b475e69e0b88e

1、完善代码和application.yml配置文件，去掉不用的引入文件；
2、init-config.xml配置中增加属性 enable,相应解析类也增加了解析与判断；
3、凡是有Server的应用，加载资源方式改为用springboot的工具类加载；
4、通信协议相关的扫描注解功能实现改为采用reflections-0.10.2，以实现可以在jar包情况下能够扫描类（.class）注解。

 pipIrr-platform/pipIrr-common/pom.xml

@@ -148,6 +148,13 @@
            <artifactId>jna-platform</artifactId>
            <version>5.12.1</version>
        </dependency>
        <!-- ç±»åå°„ -->
        <dependency>
            <groupId>org.reflections</groupId>
            <artifactId>reflections</artifactId>
            <version>0.10.2</version>
        </dependency>


        <!-- Hutool是一个小而全的Java工具类库(https://github.com/dromara/hutool)  -->
        <dependency>

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/AnnotationScan.java

@@ -1,13 +1,13 @@
package com.dy.common.mw.protocol;

import java.net.URI;
import java.net.URL;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Set;

import com.dy.common.util.ClassScan;
import com.dy.common.util.NumUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.reflections.Reflections;

/**
 * æ‰«æï¼š
@@ -20,7 +20,9 @@
@SuppressWarnings("unused")
public class AnnotationScan {
    
    private static String scanRootPackage = "com.dy.common.mw.protocol." ;
    private static final Logger log = LogManager.getLogger(AnnotationScan.class);

    private static String scanRootPackage = "com.dy.common.mw.protocol" ;

    private static AnnotationScan instance ;
    
@@ -47,19 +49,9 @@
     * @throws Exception å¼‚常
     */
    private void scanEndpointAnnotations() throws Exception{
        ClassLoader load = this.getClass().getClassLoader() ;
		
        if(!scanRootPackage.endsWith(".")){
            scanRootPackage += "." ;
        }
        URL url = AnnotationScan.class.getResource("/" + scanRootPackage.replace('.', '/'));
        if(url != null){
            String urlStr = url.toString() ;
            if(urlStr != null){
                URI uri = new URI(url.toString());

                List<String> classNames = new ClassScan().searchClassFromUrl(new URI[]{uri}, scanRootPackage) ;
                if(classNames != null && classNames.size() > 0){
        Reflections reflections = new Reflections(scanRootPackage); // æŒ‡å®šåŒ…名
        Set<Class<?>> driverClasses = reflections.getTypesAnnotatedWith(AnnotationDriver.class);
        if (driverClasses != null && driverClasses.size() > 0) {
                    String protocolName ;
                    int priority;
                    int onLineDataMinLength;
@@ -69,17 +61,14 @@
                    HashMap<String, AnnotationPrefixedDataAvailableVo> prefixedDataAvailableMap = ProtocolCache.getPrefixedDataAvailableMap() ;
                    HashMap<String, AnnotationOnLineVo> onLineMap = ProtocolCache.getOnLineMap() ;

                    for(String cName : classNames){
                        String className = cName.substring(0,  cName.lastIndexOf('.')) ;
                        Class<?> clazz = load.loadClass(className) ;
                        if(clazz.isAnnotationPresent(AnnotationDriver.class)){
            for (Class<?> clazz : driverClasses) {
                            AnnotationDriver ann = clazz.getAnnotation(AnnotationDriver.class) ;
                            if(ann != null){
                                if(ann.enable()){
                                    protocolName = ann.name() ;
                                    if(!(protocolName.trim().equals(""))){
                                        if(driverMap.containsKey(protocolName)){
                                            throw new Exception("严重错误，协议驱动名称" + protocolName + "出现了重复注解！") ;
                                throw new Exception("严重错误，协议驱动(名称)" + protocolName + "出现了重复注解！");
                                        }
                                        driverMap.put(protocolName, new AnnotationDriverVo(clazz)) ;
                                    }else{
@@ -89,8 +78,8 @@
                            }
                        }


                        if(clazz.isAnnotationPresent(AnnotationPrefixedDataAvailable.class)){
            Set<Class<?>> prefixedClass = reflections.getTypesAnnotatedWith(AnnotationPrefixedDataAvailable.class);
            for (Class<?> clazz : prefixedClass) {
                            AnnotationPrefixedDataAvailable ann = clazz.getAnnotation(AnnotationPrefixedDataAvailable.class) ;
                            if(ann != null){
                                if(ann.enable()){
@@ -128,7 +117,8 @@
                            }
                        }

                        if(clazz.isAnnotationPresent(AnnotationOnLine.class)){
            Set<Class<?>> onLineClass = reflections.getTypesAnnotatedWith(AnnotationOnLine.class);
            for (Class<?> clazz : onLineClass) {
                            AnnotationOnLine ann = clazz.getAnnotation(AnnotationOnLine.class) ;
                            if(ann != null){
                                if(ann.enable()){
@@ -153,8 +143,8 @@
                                }
                            }
                        }
                    }

            //进行验证
                    String error = this.hasErrorInDriver(driverMap) ;
                    if(error != null){
                        throw new Exception(error) ;
@@ -173,8 +163,7 @@
                    throw new Exception("严重错误， æ‰«æåè®®ç›¸å…³æ³¨è§£æ‰€å¾—到类型集合为空，扫描根路径是" + scanRootPackage) ;
                }
            }
        }
    }

    /**
     * æ£€æŸ¥ä¼˜å…ˆçº§é‡å¤
     * @param priority ä¼˜å…ˆçº§

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/Driver.java

@@ -1,10 +1,9 @@
package com.dy.common.mw.protocol;

import java.net.URI;
import java.util.HashMap;
import java.util.List;
import java.util.Set;

import com.dy.common.util.ClassScan;
import org.reflections.Reflections;


public abstract class Driver {
@@ -21,7 +20,6 @@
     * @throws Exception å¼‚常
     */
    public abstract void scanAnnotationCode() throws Exception ;
	
    /**
     * æ‰«æè¯†åˆ«åŠŸèƒ½ç æ³¨è§£ç±»
     * @param driver é©±åŠ¨
@@ -31,17 +29,15 @@
     * @throws Exception å¼‚常
     */
    @SuppressWarnings("unchecked")
    protected void doScanAnnotationCode(Driver driver, String protocolName, URI uri, String scanRootPackage) throws Exception{
        ClassLoader load = driver.getClass().getClassLoader() ;
        List<String> classNames = new ClassScan().searchClassFromUrl(new URI[]{uri}, scanRootPackage) ;
        if(classNames != null && classNames.size() > 0){
    protected void doScanAnnotationCode(Driver driver, String protocolName, String scanRootPackage) throws Exception{
        Reflections reflections = new Reflections(scanRootPackage); // æŒ‡å®šåŒ…名
            String code ;
            String[] codes ;
            for(String cName : classNames){
                String className = cName.substring(0,  cName.lastIndexOf('.')) ;
                Class<?> clazz = load.loadClass(className) ;
                Class<CodeParse> codeParseClazz ;
                if(clazz.isAnnotationPresent(AnnotationCodeUp.class)){

        Set<Class<?>> codeUpClasses = reflections.getTypesAnnotatedWith(AnnotationCodeUp.class);
        if (codeUpClasses != null && codeUpClasses.size() > 0) {
            for (Class<?> clazz : codeUpClasses) {
                    AnnotationCodeUp ann = clazz.getAnnotation(AnnotationCodeUp.class) ;
                    if(ann != null){
                        codeParseClazz = (Class<CodeParse>)clazz ;
@@ -67,8 +63,11 @@
                        }
                    }
                }
        }
                
                if(clazz.isAnnotationPresent(AnnotationCodeDown.class)){
        Set<Class<?>> codeDownClasses = reflections.getTypesAnnotatedWith(AnnotationCodeDown.class);
        if (codeDownClasses != null && codeDownClasses.size() > 0) {
            for (Class<?> clazz : codeDownClasses) {
                    AnnotationCodeDown ann = clazz.getAnnotation(AnnotationCodeDown.class) ;
                    if(ann != null){
                        codeParseClazz = (Class<CodeParse>)clazz ;
@@ -96,7 +95,7 @@
                }
            }
        }
    }

    /**
     * å•çº¿ç¨‹å•ä¾‹Driver模式下运行
     * å¾—到上行数据功能码处理类CodeParse对象

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V1_0_0/DriverV1_0_1.java

@@ -9,7 +9,7 @@
@AnnotationDriver(enable = true, name= ProtocolConstantV206V1_0_0.protocolName)
public class DriverV1_0_1 extends Driver {
    
    private static String scanRootPackage = "com.dy.common.mw.protocol.p206V1_0_0." ;
    private static String scanRootPackage = "com.dy.common.mw.protocol.p206V1_0_0" ;
    
    //在Driver中是单例，随Driver的单例对象在单线程中运行
    private ParseParamsForUpV1_0_1 upCpParams ;
@@ -29,12 +29,7 @@
     */
    @Override
    public void scanAnnotationCode() throws Exception{
        if(!scanRootPackage.endsWith(".")){
            scanRootPackage += "." ;
        }
        URL url = this.getClass().getResource("/" + scanRootPackage.replace('.', '/'));
        URI uri = new URI(url.toString());  
        super.doScanAnnotationCode(this, ProtocolConstantV206V1_0_0.protocolName, uri, scanRootPackage) ;
        super.doScanAnnotationCode(this, ProtocolConstantV206V1_0_0.protocolName, scanRootPackage) ;
    }

    /**

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/protocol/p206V202404/DriverV202404.java

@@ -1,6 +1,7 @@
package com.dy.common.mw.protocol.p206V202404;

import com.dy.common.mw.protocol.*;
import com.dy.common.mw.protocol.p206V1_0_0.ProtocolConstantV206V1_0_0;
import com.dy.common.util.DateTime;

import java.net.URI;
@@ -9,7 +10,7 @@
@AnnotationDriver(name= ProtocolConstantV206V202404.protocolName)
public class DriverV202404 extends Driver {
    
    private static String scanRootPackage = "com.dy.common.mw.protocol.p206V202404." ;
    private static String scanRootPackage = "com.dy.common.mw.protocol.p206V202404" ;
    
    //在Driver中是单例，随Driver的单例对象在单线程中运行
    private ParseParamsForUpV202404 upCpParams ;
@@ -29,12 +30,7 @@
     */
    @Override
    public void scanAnnotationCode() throws Exception{
        if(!scanRootPackage.endsWith(".")){
            scanRootPackage += "." ;
        }
        URL url = this.getClass().getResource("/" + scanRootPackage.replace('.', '/'));
        URI uri = new URI(url.toString());  
        super.doScanAnnotationCode(this, ProtocolConstantV206V202404.protocolName, uri, scanRootPackage) ;
        super.doScanAnnotationCode(this, ProtocolConstantV206V1_0_0.protocolName, scanRootPackage) ;
    }

    /**

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ClassScan.java

File was deleted

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ConfigXml.java

@@ -1,42 +1,21 @@
package com.dy.common.util;

import java.io.FileWriter;
import java.net.URL;
import java.util.List;

import org.jdom2.Document;
import org.jdom2.Element;
import org.jdom2.input.SAXBuilder;
import org.jdom2.output.Format;
import org.jdom2.output.XMLOutputter;

@SuppressWarnings("unused")
public class ConfigXml {

import java.io.FileWriter;
import java.net.URL;
import java.util.List;

    /**
     * åˆ›å»ºDocument对象
     * @param clazz å‚考类
     * @param filePath é…ç½®æ–‡ä»¶è·¯å¾„
     * @return è¿”回结果  è¿”回结果返回 doc对象
     * @throws Exception  æŠ›å‡ºå¼‚常 æŠ›å‡ºå¼‚常
 * @Author: liurunyu
 * @Date: 2024/8/21 15:27
 * @Description
     */
    public Document createDom(Class<?> clazz, String filePath) throws Exception {
        if(clazz == null){
            throw new Exception("class对象为空!");
        }
        if(filePath == null || filePath.equals("")){
            throw new Exception("配置文件路径名称为空!");
        }
        if(!filePath.startsWith("/")){
            filePath = "/" + filePath ;
        }
        URL configFileURL = clazz.getResource(filePath);
        if (configFileURL == null) {
            throw new Exception("没有得到" + filePath + "配置!");
        }
        return this.createDom(configFileURL) ;
    }
public class ConfigXml {
    
    /**
     * åˆ›å»ºDocument对象
@@ -44,7 +23,7 @@
     * @return è¿”回结果  è¿”回结果返回 doc对象
     * @throws Exception  æŠ›å‡ºå¼‚常 æŠ›å‡ºå¼‚常
     */
    public Document createDom(URL configFileURL) throws Exception {
    protected Document doCreateDom(URL configFileURL) throws Exception {
        if (configFileURL == null) {
            throw new Exception("没有得到配置文件!", null);
        }

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ConfigXml4Springboot.java

New file
@@ -0,0 +1,36 @@
package com.dy.common.util;

import java.net.URL;
import org.jdom2.Document;
import org.springframework.core.io.Resource;
import org.springframework.core.io.ResourceLoader;

@SuppressWarnings("unused")
public class ConfigXml4Springboot extends ConfigXml {

    /**
     * åœ¨SpringBoot环境中应用
     * @param resourceLoader
     * @param fileName
     * @return
     * @throws Exception
     */
    public Document createDom(ResourceLoader resourceLoader, String fileName) throws Exception {
        if(resourceLoader == null){
            throw new Exception("resourceLoader对象为空!");
        }
        if(fileName == null || fileName.equals("")){
            throw new Exception("配置文件路径名称为空!");
        }
        while(fileName.startsWith("/") || fileName.startsWith("\\")){
            fileName = fileName.substring(1) ;
        }
        Resource resource = resourceLoader.getResource("classpath:" + fileName);
        URL configFileURL = resource.getURL() ;
        if (configFileURL == null) {
            throw new Exception("没有得到" + fileName + "配置!");
        }
        return super.doCreateDom(configFileURL) ;
    }

}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/util/ConfigXmlNoSpringboot.java

New file
@@ -0,0 +1,33 @@
package com.dy.common.util;

import java.net.URL;
import org.jdom2.Document;

@SuppressWarnings("unused")
public class ConfigXmlNoSpringboot extends ConfigXml {
    /**
     * åœ¨éžSpringBoot环境中应用
     * åˆ›å»ºDocument对象
     * @param clazz å‚考类
     * @param filePath é…ç½®æ–‡ä»¶è·¯å¾„
     * @return è¿”回结果  è¿”回结果返回 doc对象
     * @throws Exception  æŠ›å‡ºå¼‚常 æŠ›å‡ºå¼‚常
     */
    public Document createDom(Class<?> clazz, String filePath) throws Exception {
        if(clazz == null){
            throw new Exception("class对象为空!");
        }
        if(filePath == null || filePath.equals("")){
            throw new Exception("配置文件路径名称为空!");
        }
        if(!filePath.startsWith("/")){
            filePath = "/" + filePath ;
        }
        URL configFileURL = clazz.getResource(filePath);
        if (configFileURL == null) {
            throw new Exception("没有得到" + filePath + "配置!");
        }
        return super.doCreateDom(configFileURL) ;
    }

}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/util/OrgListenerSupport.java

@@ -1,10 +1,8 @@
package com.dy.pipIrrGlobal.util;

import com.dy.common.util.ConfigXml;
import com.dy.common.util.ConfigXml4Springboot;
import org.jdom2.Document;
import org.springframework.boot.context.event.ApplicationReadyEvent;

import java.net.URL;
import org.springframework.core.io.ResourceLoader;

/**
 * @Author: liurunyu
@@ -17,18 +15,17 @@
     * å®žå§‹åŒ–
     */
    @SuppressWarnings("unused ")
    protected void init() {
        this.init(null);
    protected void init(ResourceLoader resourceLoader) {
        this.doInit(resourceLoader);
    }
    /**
     * å®žå§‹åŒ–
     */
    @SuppressWarnings("unused ")
    protected void init(ApplicationReadyEvent event) {
    protected void doInit(ResourceLoader resourceLoader) {
        try {
            URL configFileURL = OrgListenerSupport.class.getResource("/init-config.xml");
            ConfigXml configXml = new ConfigXml();
            Document doc = configXml.createDom(configFileURL);
            ConfigXml4Springboot configXml = new ConfigXml4Springboot() ;
            Document doc = configXml.createDom(resourceLoader, "init-config.xml") ;
            this.doInit(configXml, doc);
        } catch (Exception e) {
            System.out.println("系统启动时，初始化配置出错 !");
@@ -36,16 +33,19 @@
            e.printStackTrace();
        }
    }
    private void doInit(ConfigXml configXml, Document doc) throws Exception {
    private void doInit(ConfigXml4Springboot configXml, Document doc) throws Exception {
        if (configXml != null && doc != null) {
            for (int num = 1; num <= 10000; num++) {
                if (configXml.existElement(doc, "config.orgs.org" + num)) {
                    String orgTag = configXml.getSetAttrTxt(doc, "config.orgs.org" + num, "tag", null, false, null);
                    String orgName = configXml.getSetAttrTxt(doc, "config.orgs.org" + num, "name", null, false, null);
                    Boolean enable = configXml.getSetAttrBoolean(doc, "config.orgs.org" + num, "enable", null, null);
                    if(enable != null && enable.booleanValue()){
                    Org.OrgVo vo = new Org().new OrgVo() ;
                    vo.tag = orgTag ;
                    vo.name = orgName ;
                    Org.OrgList.add(vo) ;
                    }
                }else{
                    break ;
                }

 pipIrr-platform/pipIrr-global/src/main/resources/init-config.xml

@@ -1,8 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<config>
    <orgs>
        <!-- å¤šä¸ªç»„织，用编号区分，编号从1开始 -->
        <org1 tag="ym" name="元谋">
        <!-- å¤šä¸ªç»„织，用编号区分，编号从1开始，enable表示是否启用 -->
        <org1 tag="ym" name="元谋" enable="true">
            <districts>
                <province name="云南省" num="53" level="0">
                    <city name="楚雄彝族自治州" num="23" level="1">
@@ -29,7 +29,7 @@
                <item5 typeName="绿化用水"/>
            </waterTypes>
        </org1>
        <org2 tag="pj" name="片角">
        <org2 tag="pj" name="片角" enable="false">
            <districts>
                <province name="云南省" num="53" level="0">
                    <city name="丽江市" num="23" level="1">

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/pom.xml

@@ -159,6 +159,14 @@
            <artifactId>jna-platform</artifactId>
            <version>5.12.1</version>
        </dependency>
        <!-- ç±»åå°„ -->
        <dependency>
            <groupId>org.reflections</groupId>
            <artifactId>reflections</artifactId>
            <version>0.10.2</version>
        </dependency>


        <!-- æµ‹è¯• -->
        <dependency>
            <groupId>org.springframework.boot</groupId>

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/Server.java

@@ -22,17 +22,19 @@
import com.dy.rtuMw.resource.ResourceUnit;
import com.dy.rtuMw.resource.ResourceUnitConfigVo;
import com.dy.common.springUtil.SpringContextUtil;
import com.dy.common.util.ConfigXml;
import com.dy.common.util.ConfigXml4Springboot;
import com.dy.common.util.IDLongGenerator;

import org.jdom2.Document;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Component;

@Component
public class Server {

    private ConfigXml conf = null ;
    private ConfigXml4Springboot conf = null ;
    private Document doc = null ;
    private boolean showStartInfo = false ;
    
@@ -42,6 +44,9 @@
    private String HttpSvPort ;
    @Value("${server.servlet.context-path}")
    private String HttpSvPath ;

    @Autowired
    protected ResourceLoader resourceLoader ;

    private List<UnitInterface> units = new ArrayList<UnitInterface>() ;

@@ -78,8 +83,8 @@
        try {
            //ConfigProperties.init(this.getClass().getResourceAsStream("/config/config.properties"), false);
            
            this.conf = new ConfigXml() ;
            this.doc = this.conf.createDom(this.getClass(), "config.xml") ;
            this.conf = new ConfigXml4Springboot() ;
            this.doc = this.conf.createDom(this.resourceLoader, "config.xml") ;
            ////////////////
            //服务 é…ç½®
            this.showStartInfo = this.conf.getSetAttrBoolean(this.doc, "config.server", "showStartInfo", null, null) ;
@@ -325,6 +330,7 @@
            /////////////////
            //RTU上行数据处理模块
            RtuDataUnitConfigVo rducVo = new RtuDataUnitConfigVo();
            rducVo.resourceLoader = this.resourceLoader ;
            AdapterImp_RtuDataUnit rducAdap = new AdapterImp_RtuDataUnit();
            rducAdap.setConfig(rducVo);
            RtuDataUnit rducUnit = RtuDataUnit.getInstance();

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/RtuDataUnit.java

@@ -34,7 +34,7 @@
     */
    @Override
    public void start(UnitStartedCallbackInterface callback) throws Exception {
        TaskPool.setTaskTreeCofig(new TreeParse().parseConfig());
        TaskPool.setTaskTreeCofig(new TreeParse().parseConfig(confVo.resourceLoader));
        callback.call(null) ;
        System.out.println("RTU数据处理模块成功启动");
    }

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/RtuDataUnitConfigVo.java

@@ -1,5 +1,7 @@
package com.dy.rtuMw.server.rtuData;

public class RtuDataUnitConfigVo {
import org.springframework.core.io.ResourceLoader;

public class RtuDataUnitConfigVo {
    public ResourceLoader resourceLoader ;
}

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/TreeParse.java

@@ -7,7 +7,8 @@
import org.jdom2.Document;
import org.jdom2.Element;
import org.jdom2.input.SAXBuilder;

import org.springframework.core.io.Resource;
import org.springframework.core.io.ResourceLoader;

public class TreeParse {
    public List<String> ids ;
@@ -26,7 +27,6 @@
    /**
     * è§£æžå¤„理器配置
     * @return
     */
    protected TreeConfig parseConfig() {
        try {
            ClassLoader classLoader = ClassLoader.getSystemClassLoader();
@@ -39,6 +39,24 @@
            return null;
        }
    }
     */

    /**
     * è§£æžå¤„理器配置
     * @return
     */
    protected TreeConfig parseConfig(ResourceLoader resourceLoader) {
        try {
            Resource resource = resourceLoader.getResource("classpath:RtuDataDealTree.xml");
            URL configFileURL = resource.getURL() ;
            return this.parse(this.createDom(configFileURL)) ;
        } catch (Exception e) {
            System.out.println("系统启动时，初始上行数据处理任务配置出错 !");
            System.out.println(e.getMessage());
            e.printStackTrace();
            return null;
        }
    }
    
    /**
     * 

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/resources/config.xml

@@ -41,6 +41,7 @@
        />
        
        <!-- 
        2024-08-22 æš‚时不用
        centerAddr: ä¸­å¿ƒåœ°å€ï¼Œå½“前，centerAddr未用到
        synchroRtuClock: æ˜¯å¦å¯¹RTU校时
        synchroRtuClockTimepieces：当RTU与服务器时钟相差一定毫秒（配置文件是秒钟）后，进行校时
@@ -108,6 +109,7 @@
        
            
        <!-- 
        2024-08-22 æš‚时不用
        port：rmi服务端口号
        context：rmi服务上下文
         -->

 pipIrr-platform/pipIrr-mw/pipIrr-mwTest-client/src/main/java/com/dy/testClient/Server.java

@@ -11,10 +11,11 @@
import com.dy.common.mw.UnitInterface;
import com.dy.common.mw.support.SupportUnit;
import com.dy.common.mw.support.SupportUnitConfigVo;
import com.dy.common.util.ConfigXml;
import com.dy.common.util.ConfigXmlNoSpringboot;

public class Server {

    private ConfigXml conf = null ;
    private ConfigXmlNoSpringboot conf = null ;
    private Document doc = null ;
    private boolean showStartInfo = false ;

@@ -27,7 +28,7 @@
        Server sv = new Server();
        Long start = System.currentTimeMillis() ;
        try {
            sv.conf = new ConfigXml() ;
            sv.conf = new ConfigXmlNoSpringboot() ;
            sv.doc = sv.conf.createDom(sv.getClass(), "/config.xml") ;
            ////////////////
            //服务 é…ç½®

 pipIrr-platform/pipIrr-mw/pipIrr-mwTest-client/˵Ã÷.txt

New file
@@ -0,0 +1 @@
本模块是批量压力测试的客户端，模拟多个测控器上报数据，受服务端（pipIrr-mwTest-server）控制。

 pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/src/main/java/com/dy/testServer/Server.java

@@ -12,12 +12,12 @@
import com.dy.common.mw.UnitStartedCallbackInterface;
import com.dy.common.mw.channel.rmi.RmiConfigVo;
import com.dy.common.mw.channel.rmi.RmiUnit;
import com.dy.common.util.ConfigXml;
import com.dy.common.util.NumUtil;
import com.dy.common.util.ConfigXmlNoSpringboot;

public class Server{

    private ConfigXml conf = null ;
    private ConfigXmlNoSpringboot conf = null ;
    private Document doc = null ;
    private boolean showStartInfo = false ;
    
@@ -39,7 +39,7 @@
        Server sv = new Server();
        long start = System.currentTimeMillis() ;
        try {
            sv.conf = new ConfigXml() ;
            sv.conf = new ConfigXmlNoSpringboot() ;
            sv.doc = sv.conf.createDom(sv.getClass(), "config.xml") ;
            ////////////////
            //服务 é…ç½®

 pipIrr-platform/pipIrr-mw/pipIrr-mwTest-server/˵Ã÷.txt

New file
@@ -0,0 +1 @@
本模块是批量压力测试的服务端，为客户端（pipIrr-mwTest-client）分配测控器（RTU）数量及测控器（RTU）地址，并控制客户启动，接收客户端数据。

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-rtu/src/main/java/com/dy/pipIrrMwTestRtu/Server.java

@@ -1,10 +1,12 @@
package com.dy.pipIrrMwTestRtu;

import com.dy.common.mw.UnitInterface;
import com.dy.common.util.ConfigXml;
import com.dy.common.util.ConfigXml4Springboot;
import com.dy.pipIrrMwTestRtu.tcpClient.TcpClUnit;
import com.dy.pipIrrMwTestRtu.tcpClient.TcpClUnitConfigVo;
import org.jdom2.Document;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
@@ -18,8 +20,10 @@

@Component
public class Server {
    @Autowired
    protected ResourceLoader resourceLoader ;

    private ConfigXml conf = null ;
    private ConfigXml4Springboot conf = null ;
    private Document doc = null ;
    private boolean showStartInfo = false ;

@@ -41,8 +45,8 @@
        try {
            //ConfigProperties.init(this.getClass().getResourceAsStream("/config/config.properties"), false);

            this.conf = new ConfigXml() ;
            this.doc = this.conf.createDom(this.getClass(), "config.xml") ;
            this.conf = new ConfigXml4Springboot() ;
            this.doc = this.conf.createDom(resourceLoader, "config.xml") ;
            ////////////////
            //服务 é…ç½®
            this.showStartInfo = this.conf.getSetAttrBoolean(this.doc, "config.server", "showStartInfo", null, null) ;

 pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
    profiles:
        include: global, database, database-ym, database-pj, database-sp
        include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java

@@ -3,7 +3,7 @@
import com.dy.common.multiDataSource.DataSourceContext;
import com.dy.common.mybatis.envm.Deleted;
import com.dy.common.mybatis.envm.Disabled;
import com.dy.common.util.ConfigXml;
import com.dy.common.util.ConfigXml4Springboot;
import com.dy.common.util.MD5;
import com.dy.pipIrrGlobal.daoBa.BaDistrictMapper;
import com.dy.pipIrrGlobal.daoBa.BaSettingsMapper;
@@ -20,10 +20,9 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.core.io.ResourceLoader;
import org.springframework.lang.NonNull;
import org.springframework.stereotype.Component;

import java.net.URL;

/**
 * ç›‘听器，实现功能：在系统启动时初始化，向数据库中插入数据
@@ -34,11 +33,18 @@
@Component
public class InitListener implements ApplicationListener<ApplicationReadyEvent> {

    protected ResourceLoader resourceLoader ;

    private BaDistrictMapper distriDao ;
    private BaUserMapper userDao ;
    private SePaymentMethodMapper paymentMethodDao ;
    private BaSettingsMapper settingsDao ;
    private SeWaterTypeMapper waterTypeDao ;

    @Autowired
    public void setResourceLoader(ResourceLoader resourceLoader){
        this.resourceLoader = resourceLoader ;
    }

    @Autowired
    public void setDistriDao(BaDistrictMapper distriDao){
@@ -88,9 +94,8 @@
    @SuppressWarnings("unused ")
    private void init(ApplicationReadyEvent event){
        try {
            URL configFileURL = InitListener.class.getResource("/init-config.xml" );
            ConfigXml configXml = new ConfigXml() ;
            Document doc = configXml.createDom(configFileURL) ;
            ConfigXml4Springboot configXml = new ConfigXml4Springboot() ;
            Document doc = configXml.createDom(this.resourceLoader, "init-config.xml") ;
            this.doInit(configXml, doc);
        } catch (Exception e) {
            System.out.println("系统启动时，初始化配置出错 !");
@@ -98,11 +103,13 @@
            e.printStackTrace();
        }
    }
    private void doInit(ConfigXml configXml, Document doc) throws Exception{
    private void doInit(ConfigXml4Springboot configXml, Document doc) throws Exception{
        if(configXml != null && doc != null){
            for(int num = 1; num <= 10000; num++){
                if(configXml.existElement(doc, "config.orgs.org" + num)){
                    String orgTag = configXml.getSetAttrTxt(doc, "config.orgs.org" + num,"tag", null, false, null) ;
                    Boolean enable = configXml.getSetAttrBoolean(doc, "config.orgs.org" + num, "enable", null, null);
                    if(enable != null && enable.booleanValue()){
                    //设置数据源
                    DataSourceContext.set(orgTag);
                    if(!this.existDistricts()){
@@ -172,6 +179,7 @@
                            }
                        }
                    }
                    }
                }else{
                    break ;
                }

 pipIrr-platform/pipIrr-web/pipIrr-web-irrigate/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
  profiles:
    include: global, database, database-ym, database-pj, database-sp
    include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-operation/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
    profiles:
        include: global, database, database-ym, database-pj, database-sp
        include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
  profiles:
    include: global, database, database-ym, database-pj, database-sp
    include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
    profiles:
        include: global, database, database-ym, database-pj, database-sp
        include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
  profiles:
    include: global, database, database-ym, database-pj, database-sp
    include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/util/SsoListener.java

@@ -1,12 +1,17 @@
package com.dy.sso.util;

import com.dy.pipIrrGlobal.util.OrgListenerSupport;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Component;

@Component
public class SsoListener extends OrgListenerSupport implements ApplicationListener<ApplicationReadyEvent> {

    @Autowired
    protected ResourceLoader resourceLoader ;


    @Override
@@ -18,7 +23,7 @@
            e.printStackTrace();
        } finally {
            //初始化机构
            super.init();
            super.init(resourceLoader);
        }
    }


 pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
    profiles:
        include: global, database, database-ym, database-pj, database-sp
        include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/util/OrgListener.java

@@ -1,12 +1,17 @@
package com.dy.pipIrrStatistics.util;

import com.dy.pipIrrGlobal.util.OrgListenerSupport;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Component;

@Component
public class OrgListener extends OrgListenerSupport implements ApplicationListener<ApplicationReadyEvent> {

    @Autowired
    protected ResourceLoader resourceLoader ;

    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
@@ -16,7 +21,7 @@
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            super.init();
            super.init(resourceLoader);
        }
    }
}

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
    profiles:
        include: global, database, database-ym, database-pj, database-sp
        include: global, database, database-ym, database-pj

#actutor的web端口
management:

 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/resources/application.yml

@@ -1,6 +1,6 @@
spring:
    profiles:
        include: global, database, database-ym, database-pj, database-sp
        include: global, database, database-ym, database-pj

#actutor的web端口
management: