liurunyu
2024-09-07 9ad6b0179be4d351105f1507779d4f41a3a41953
pipIrr-platform/pipIrr-web/pipIrr-mwTest-rtu/src/main/java/com/dy/pipIrrMwTestRtu/tcpClient/TcpClUnit.java
@@ -2,7 +2,7 @@
import com.dy.common.mw.UnitAdapterInterface;
import com.dy.common.mw.UnitInterface;
import com.dy.common.mw.UnitStartedCallbackInterface;
import com.dy.common.mw.UnitCallbackInterface;
import com.dy.common.util.Callback;
import com.dy.pipIrrMwTestRtu.ServerProperties;
import com.dy.pipIrrMwTestRtu.tcpClient.upData.UpData;
@@ -42,14 +42,14 @@
    }
    @Override
    public void start(UnitStartedCallbackInterface callback) throws Exception {
    public void start(UnitCallbackInterface callback) throws Exception {
        System.out.println("Tcp Client模块成功启动");
        this.doStart();
        callback.call(null) ;
    }
    @Override
    public void stop(UnitStartedCallbackInterface callback) throws Exception {
    public void stop(UnitCallbackInterface callback) throws Exception {
        callback.call(null);
    }
@@ -108,13 +108,22 @@
        new Thread(new Runnable(){
            @Override
            public void run() {
                while(true){
                if(ServerProperties.onlyOneHeartBeat){
                    try {
                        UpHeartBeat.upCd02Data(ServerProperties.rtuAddr);
                        Thread.sleep(30000L);
                        //Thread.sleep(30000000L);
                    }catch (Exception e){
                        continue;
                    }
                }else{
                    while(true){
                        try {
                            UpHeartBeat.upCd02Data(ServerProperties.rtuAddr);
                            Thread.sleep(30000L);
                            //Thread.sleep(30000000L);
                        }catch (Exception e){
                            continue;
                        }
                    }
                }
            }