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

‘liusuyi’

2024-02-01 b587ba125adcee0631bc816540779cca56f9099b

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

 src/main/java/com/ard/alarm/radar/domain/ArdEquipRadar.java

@@ -71,5 +71,6 @@
    /** ip */
    private String ip;


    /** 连接状态 */

    private String state;

}

 src/main/java/com/ard/alarm/radar/service/IArdEquipRadarService.java

@@ -19,4 +19,11 @@
     */
    public List<ArdEquipRadar> selectArdEquipRadarList(ArdEquipRadar ardEquipRadar);
    public ArdEquipRadar selectArdEquipRadarById(String radarId);
    /**

     * 更新雷达

     *

     * @param ardEquipRadar radar

     * @return radar集合

     */

    public int updateArdEquipRadar(ArdEquipRadar ardEquipRadar);

}

 src/main/java/com/ard/alarm/radar/service/impl/ArdEquipRadarServiceImpl.java

@@ -10,6 +10,8 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;



/**
 * radarService业务层处理
 *
@@ -18,7 +20,7 @@
 */
@Service
public class ArdEquipRadarServiceImpl implements IArdEquipRadarService {
    @Autowired
    @Resource

    private ArdEquipRadarMapper ardEquipRadarMapper;


@@ -38,4 +40,14 @@
    public ArdEquipRadar selectArdEquipRadarById(String radarId) {
        return ardEquipRadarMapper.selectById(radarId);
    }
    /**

     * 更新雷达

     *

     * @param ardEquipRadar radar

     * @return radar

     */

    @Override

    public int updateArdEquipRadar(ArdEquipRadar ardEquipRadar) {

        return ardEquipRadarMapper.updateById(ardEquipRadar);

    }

}

 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);

                }

            }

        });

    }

}

 src/main/resources/application-dev.yml

@@ -66,7 +66,7 @@
logging:

  level:

    hikSdk: info

    mqtt: debug

    mqtt: info

    netty: debug

    external: info

    camera: info


 src/main/resources/application-prod.yml

@@ -14,7 +14,7 @@
      stat-view-servlet:
        enabled: true
      driver-class-name: org.postgresql.Driver
      url: jdbc:postgresql://192.168.2.15:5432/ry-vue
      url: jdbc:postgresql://192.168.1.14:5432/ry-vue?stringtype=unspecified

      username: postgres
      password: postgres
      #最大连接数
@@ -36,12 +36,18 @@
    enabled: true
  tcp:
    enabled: true
# minio配置

minio:

  endpoint: http://127.0.0.1:9001

  accessKey: admin

  secretKey: xzx12345

# mqtt配置
mqtt:
  host: tcp://192.168.2.15:1883
  clientId: client-2272
  host: tcp://192.168.1.14:1883

  clientId: alarm14

  username: admin
  password: admin
  password: xzx12345

  topic: tube

  timeout: 100
  keepalive: 60
  enabled: true
@@ -53,11 +59,7 @@
# 三场数字化
digitization3:
  enabled: false
# minio配置
minio:
  endpoint: http://192.168.2.15:9001
  accessKey: admin
  secretKey: xzx12345


# mybatis-plus配置
mybatis-plus:
  type-aliases-package: com.ard.alarm.**.domain
@@ -66,7 +68,7 @@
logging:
  level:
    hikSdk: info
    mqtt: debug
    mqtt: info

    netty: info
    external: info
    camera: info

 src/main/resources/application.yml

 src/main/resources/logback-spring.xml