1、common模块优化代码，Command命令中增加RTU命令结果返回webRul; 2、通信中间件增加了接收http下发RTU命令和内部命令的Co...

liurunyu

2023-12-21 7d885c1d4c86f40927af50e6e7bfa13aac0c2180

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

@@ -39,18 +39,24 @@

    @Override
    public void execute() throws Exception {
        if(session != null){
            if(sendTimes <= ServerProperties.sendTimes){
                log.info("RTU" + rtuAddr + "开始任务");
                log.info("RTU" + rtuAddr + "将要执行" + ServerProperties.sendTimes + "轮次任务，当前轮次是" + sendTimes);
                sendDataOfP206V1_0_0() ;
            }else{
                log.info("RTU" + rtuAddr + "等待一会，以接收通信中间件下行数据");
                if(overStart == 0){
                    overStart = System.currentTimeMillis() ;
        if(!this.isOver){
            if(session != null){
                if(sendTimes <= ServerProperties.sendTimes){
                    log.info("RTU" + rtuAddr + "开始任务");
                    log.info("RTU" + rtuAddr + "将要执行" + ServerProperties.sendTimes + "轮次任务，当前轮次是" + sendTimes);
                    sendDataOfP206V1_0_0() ;
                }else{
                    long now = System.currentTimeMillis() ;
                    if(now - overStart >= 30 * 1000){
                    if(ServerProperties.sendOverThenCloseConnect == 1){
                        log.info("RTU" + rtuAddr + "等待一会，以接收通信中间件下行数据");
                        if(overStart == 0){
                            overStart = System.currentTimeMillis() ;
                        }else{
                            long now = System.currentTimeMillis() ;
                            if(now - overStart >= 30 * 1000){
                                this.jobOver() ;
                            }
                        }
                    }else{
                        this.jobOver() ;
                    }
                }
@@ -95,7 +101,9 @@
    }

    private void jobOver(){
        session.closeOnFlush() ;
        if(ServerProperties.sendOverThenCloseConnect == 1){
            session.closeOnFlush() ;
        }
        this.isOver = true ;
        TcpClUnit.clientOver() ;
    }