| | |
|---|
| | | log.debug("定时监测雷达连接状态");
|
|---|
| | | List<ArdEquipRadar> ardEquipRadars = ardEquipRadarService.selectArdEquipRadarList(new ArdEquipRadar());
|
|---|
| | | ardEquipRadars.stream().forEach(ardEquipRadar -> {
|
|---|
| | | if (trueConnectMap.containsKey(ardEquipRadar.getIp() + ":" + ardEquipRadar.getPort())) {
|
|---|
| | | if (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("1")) {
|
|---|
| | | ardEquipRadar.setState("1");
|
|---|
| | | ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
|
|---|
| | | }
|
|---|
| | | } else {
|
|---|
| | | if (ardEquipRadar.getState() == null || (ardEquipRadar.getState() != null && !ardEquipRadar.getState().equals("0"))) {
|
|---|
| | | ardEquipRadar.setState("0");
|
|---|
| | | ardEquipRadarService.updateArdEquipRadar(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")) {
|
|---|
| | | ardEquipRadar.setState("1");
|
|---|
| | | ardEquipRadarService.updateArdEquipRadar(ardEquipRadar);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | });
|
|---|
