| | |
|---|
| | | /**
|
|---|
| | | * 监测雷达连接状态
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0/5 * * * * ?")
|
|---|
| | | @Scheduled(cron = "0/3 * * * * ?")
|
|---|
| | | public void monitorConnectStatus() {
|
|---|
| | | log.debug("定时监测雷达连接状态");
|
|---|
| | | List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());
|
|---|
| | | ardEquipRadars.stream().forEach(ardEquipRadar -> {
|
|---|
| | | if (ardEquipRadar.getState() == null || (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("0"))) {
|
|---|
| | | ardEquipRadar.setState("0");
|
|---|
| | | ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
|
|---|
| | | }
|
|---|
| | | else
|
|---|
| | | {
|
|---|
| | | if (trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort())) {
|
|---|
| | | if (!ardEquipRadar.getState().equals("1")) {
|
|---|
| | |
|
|---|
| | | boolean online = trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort());
|
|---|
| | | if (online) {
|
|---|
| | | if (ardEquipRadar.getState() == null || !ardEquipRadar.getState().equals("1")) {
|
|---|
| | | ardEquipRadar.setState("1");
|
|---|
| | | ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
|
|---|
| | | }
|
|---|
| | | } else {
|
|---|
| | | if (ardEquipRadar.getState() == null || !ardEquipRadar.getState().equals("0")) {
|
|---|
| | | ardEquipRadar.setState("0");
|
|---|
| | | ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | });
|
|---|
