优化监控雷达连接状态定时任务

‘liusuyi’

2024-03-08 9325629ccbf07c02ae6d2686836cfbe57a6c0b31

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

@@ -139,19 +139,18 @@
    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);

                }

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

            if (ardEquipRadar.getState() == null || (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("0"))) {

                ardEquipRadar.setState("0");

                ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

            }

            else

            {

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

                    ardEquipRadar.setState("0");

                    ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

                if (trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort())) {

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

                        ardEquipRadar.setState("1");

                        ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);

                    }

                }

            }

        });