增加定时监测更新雷达连接状态

‘liusuyi’

2024-02-01 b587ba125adcee0631bc816540779cca56f9099b

 src/main/java/com/ard/utils/netty/tcp/ClientInitialize.java

@@ -12,6 +12,7 @@
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.core.annotation.Order;
import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

import javax.annotation.Resource;
@@ -130,4 +131,29 @@
            connectServer(ardEquipRadar);//连接每一个雷达服务
        }
    }


    /**

     * 监测雷达连接状态

     */

    @Scheduled(cron = "0/5 * * * * ?")

    public void monitorConnectStatus() {

        log.debug("定时监测雷达连接状态");

        List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());

        ardEquipRadars.stream().forEach(ardEquipRadar ->{

            if(trueConnectMap.contains(ardEquipRadar.getIp()+"_"+ardEquipRadar.getPort()))

            {

                if(!ardEquipRadar.getState().equals("1")) {

                    ardEquipRadar.setState("1");

                    ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

                }

            }

            else

            {

                if(!ardEquipRadar.getState().equals("0")) {

                    ardEquipRadar.setState("0");

                    ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

                }

            }

        });

    }

}