joylink/xian-ncc-da-server
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of https://git.code.tencent.com/xian-ncc-da/xian-ncc-da-server

Browse Source
This commit is contained in:
weizhihong 2023-07-19 13:41:57 +08:00
commit 56456614af
20 changed files with 1167 additions and 335 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/club/joylink/xiannccda/alert/AlertDetail.java
View File

@ -4,6 +4,8 @@ import java.time.LocalDateTime;
public interface AlertDetail {
AlertType getAlertType();
LocalDateTime getAlertTime();
Integer getAlertTipId();

30
src/main/java/club/joylink/xiannccda/alert/xian3/Xian3TrainDelayAlert.java → src/main/java/club/joylink/xiannccda/alert/AlertDetailImpl.java
View File

@ -1,19 +1,27 @@
package club.joylink.xiannccda.alert.xian3;
package club.joylink.xiannccda.alert;
import club.joylink.xiannccda.alert.AlertDetail;
import club.joylink.xiannccda.alert.AlertType;
import java.time.LocalDateTime;
import lombok.Builder;
import lombok.AllArgsConstructor;
import lombok.Data;
/**
* 西安三号线报警
*/
@Builder
public class Xian3TrainDelayAlert implements AlertDetail {
@Data
@AllArgsConstructor
public class AlertDetailImpl implements AlertDetail {
private AlertType alertType;
private LocalDateTime alertTime;
private String info;
private Integer alertTipId;
private String info;
private String deviceInfo;
private String reason;
@Override
public AlertType getAlertType() {
return alertType;
}
@Override
public LocalDateTime getAlertTime() {
@ -27,20 +35,16 @@ public class Xian3TrainDelayAlert implements AlertDetail {
@Override
public String getDeviceInfo() {
return "道岔P0110";
return deviceInfo;
}
@Override
public String getReason() {
return "道岔P0110失表";
return reason;
}
@Override
public Integer getAlertTipId() {
return alertTipId;
}
public AlertType getAlertType() {
return AlertType.XIAN3_TRAIN_DELAY;
}
}

35
src/main/java/club/joylink/xiannccda/alert/AlertEmitJob.java Normal file
View File

@ -0,0 +1,35 @@
package club.joylink.xiannccda.alert;
import club.joylink.xiannccda.alert.core.AlertManager;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
@Order(1)
@Component
public class AlertEmitJob implements ApplicationRunner {
private TrainDelayAlertMonitoringTask trainDelayAlertMonitoringTask;
private BlueDisplayAlertMonitoringTask blueDisplayAlertMonitoringTask;
private PlatformDoorAlertMonitoringTask platformDoorAlertMonitoringTask;
public AlertEmitJob(
TrainDelayAlertMonitoringTask trainDelayAlertMonitoringTask,
BlueDisplayAlertMonitoringTask blueDisplayAlertMonitoringTask,
PlatformDoorAlertMonitoringTask platformDoorAlertMonitoringTask) {
this.trainDelayAlertMonitoringTask = trainDelayAlertMonitoringTask;
this.blueDisplayAlertMonitoringTask = blueDisplayAlertMonitoringTask;
this.platformDoorAlertMonitoringTask = platformDoorAlertMonitoringTask;
}
@Override
public void run(ApplicationArguments args) throws Exception {
AlertManager alertManager = AlertManager.getInstance();
//报警源
alertManager.addTask(trainDelayAlertMonitoringTask);
alertManager.addTask(blueDisplayAlertMonitoringTask);
alertManager.addTask(platformDoorAlertMonitoringTask);
}
}

11
src/main/java/club/joylink/xiannccda/alert/AlertJob.java → src/main/java/club/joylink/xiannccda/alert/AlertListenerJob.java
View File

@ -13,10 +13,10 @@ import org.springframework.stereotype.Component;
@Order
@Component
public class AlertJob implements ApplicationRunner {
public class AlertListenerJob implements ApplicationRunner {
private final WsMessageServerManager wsMessageServerManager;
public AlertJob(WsMessageServerManager wsMessageServerManager) {
public AlertListenerJob(WsMessageServerManager wsMessageServerManager) {
this.wsMessageServerManager = wsMessageServerManager;
}
@ -27,7 +27,7 @@ public class AlertJob implements ApplicationRunner {
//添加报警事件监听器
addAlertListeners();
//注册西安NCC的报警ws消息发送服务
wsMessageServerManager.registerMessageServer(NccAlertMessageServer.getInstance());
wsMessageServerManager.registerMessageServer(NccAlertMessageServer.getDefault());
//启动报警源事件监测任务
AlertManager.getInstance().taskStart();
}
@ -49,14 +49,15 @@ public class AlertJob implements ApplicationRunner {
}
private void addAlertListeners() {
NccAlertMessageServer nccAlertMessageServer = NccAlertMessageServer.getInstance();
NccAlertMessageServer nccAlertMessageServer = NccAlertMessageServer.getDefault();
AlertManager alertManager = AlertManager.getInstance();
//报警监听
//添加消息
alertManager.on(new Listener<NccAlertInfo>() {
@Override
public void accept(NccAlertInfo event) {
nccAlertMessageServer.addMsg(event);
}
});
}
}

14
src/main/java/club/joylink/xiannccda/alert/AlertType.java
View File

@ -2,11 +2,17 @@ package club.joylink.xiannccda.alert;
public enum AlertType {
/**
* 西安三蓝显
* 蓝显
*/
XIAN3_BLUE_DISPLAY,
BLUE_DISPLAY,
/**
* 西安三列车延误
* 列车延误
*/
XIAN3_TRAIN_DELAY,
TRAIN_DELAY,
/**
* 站台门无关闭锁紧信号
*/
PLATFORM_DOOR_WITHOUT_LOCKED_SIGNAL,
PLATFORM_DOOR_CANNOT_OPEN,
PLATFORM_DOOR_CANNOT_CLOSE,
}

51
src/main/java/club/joylink/xiannccda/alert/BlueDisplayAlertMonitoringTask.java Normal file
View File

@ -0,0 +1,51 @@
package club.joylink.xiannccda.alert;
import club.joylink.xiannccda.alert.core.AlertManager;
import club.joylink.xiannccda.alert.core.AlertMonitoringTask;
import club.joylink.xiannccda.entity.AlertTip;
import club.joylink.xiannccda.repository.IAlertTipRepository;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.time.LocalDateTime;
import org.springframework.stereotype.Component;
@Component
public class BlueDisplayAlertMonitoringTask implements AlertMonitoringTask {
private IAlertTipRepository alertTipRepository;
private boolean alertTriggered;
public BlueDisplayAlertMonitoringTask(IAlertTipRepository alertTipRepository) {
this.alertTipRepository = alertTipRepository;
}
@Override
public String getName() {
return "blue_display";
}
@Override
public void run() {
LocalDateTime now = LocalDateTime.now();
if (alertTriggered) {
if (now.getSecond() % 30 != 0) {
alertTriggered = false;
}
} else {
if (now.getSecond() % 30 == 0) {
AlertType alertType = AlertType.BLUE_DISPLAY;
LambdaQueryWrapper<AlertTip> queryWrapper = Wrappers.lambdaQuery(AlertTip.class);
queryWrapper.eq(AlertTip::getAlertType, alertType)
.eq(AlertTip::getLocationType, AlertTipLocationType.QX);
AlertTip alertTip = alertTipRepository.getOne(queryWrapper);
Integer alertTipId = alertTip == null ? null : alertTip.getId();
AlertManager alertManager = AlertManager.getInstance();
AlertDetailImpl alert = new AlertDetailImpl(alertType, now, alertTipId, "[3号线]全线蓝显",
"轨旁设备", "轨旁设备故障");
alertManager.emit(alert);
alertTriggered = true;
}
}
}
}

85
src/main/java/club/joylink/xiannccda/alert/PlatformDoorAlertMonitoringTask.java Normal file
View File

@ -0,0 +1,85 @@
package club.joylink.xiannccda.alert;
import club.joylink.xiannccda.alert.core.AlertManager;
import club.joylink.xiannccda.alert.core.AlertMonitoringTask;
import club.joylink.xiannccda.entity.AlertTip;
import club.joylink.xiannccda.repository.IAlertTipRepository;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.time.LocalDateTime;
import org.springframework.stereotype.Component;
@Component
public class PlatformDoorAlertMonitoringTask implements AlertMonitoringTask {
private IAlertTipRepository alertTipRepository;
private boolean alertTriggered;
public PlatformDoorAlertMonitoringTask(IAlertTipRepository alertTipRepository) {
this.alertTipRepository = alertTipRepository;
}
@Override
public String getName() {
return "platform_door";
}
@Override
public void run() {
LocalDateTime now = LocalDateTime.now();
if (alertTriggered) {
if (now.getSecond() % 30 != 0) {
alertTriggered = false;
}
} else {
if (now.getSecond() % 30 == 0) {
emitPlatformDoorWithoutLockedSignalAlert(now, alertTipRepository);
emitPlatformDoorCannotOpenAlert(now, alertTipRepository);
emitPlatformDoorCannotCloseAlert(now, alertTipRepository);
alertTriggered = true;
}
}
}
public void emitPlatformDoorWithoutLockedSignalAlert(LocalDateTime now,
IAlertTipRepository alertTipRepository) {
AlertType alertType = AlertType.PLATFORM_DOOR_WITHOUT_LOCKED_SIGNAL;
LambdaQueryWrapper<AlertTip> queryWrapper = Wrappers.lambdaQuery(AlertTip.class);
queryWrapper.eq(AlertTip::getAlertType, alertType);
AlertTip alertTip = alertTipRepository.getOne(queryWrapper);
Integer alertTipId = alertTip == null ? null : alertTip.getId();
AlertManager alertManager = AlertManager.getInstance();
AlertDetailImpl alert = new AlertDetailImpl(alertType, now, alertTipId,
"[3号线]站台门无关闭锁紧信号", "鱼化寨下行站台", "鱼化寨下行站台无关闭锁紧信号");
alertManager.emit(alert);
}
public void emitPlatformDoorCannotOpenAlert(LocalDateTime now,
IAlertTipRepository alertTipRepository) {
AlertType alertType = AlertType.PLATFORM_DOOR_CANNOT_OPEN;
LambdaQueryWrapper<AlertTip> queryWrapper = Wrappers.lambdaQuery(AlertTip.class);
queryWrapper.eq(AlertTip::getAlertType, alertType);
AlertTip alertTip = alertTipRepository.getOne(queryWrapper);
Integer alertTipId = alertTip == null ? null : alertTip.getId();
AlertManager alertManager = AlertManager.getInstance();
AlertDetailImpl alert = new AlertDetailImpl(alertType, now, alertTipId,
"[3号线]站台门整侧站台门无法打开", "鱼化寨下行站台", "鱼化寨下行站台整侧站台门无法打开");
alertManager.emit(alert);
}
public void emitPlatformDoorCannotCloseAlert(LocalDateTime now,
IAlertTipRepository alertTipRepository) {
AlertType alertType = AlertType.PLATFORM_DOOR_CANNOT_CLOSE;
LambdaQueryWrapper<AlertTip> queryWrapper = Wrappers.lambdaQuery(AlertTip.class);
queryWrapper.eq(AlertTip::getAlertType, alertType);
AlertTip alertTip = alertTipRepository.getOne(queryWrapper);
Integer alertTipId = alertTip == null ? null : alertTip.getId();
AlertManager alertManager = AlertManager.getInstance();
AlertDetailImpl alert = new AlertDetailImpl(alertType, now, alertTipId,
"[3号线]站台门整侧站台门无法关闭", "鱼化寨下行站台", "鱼化寨下行站台整侧站台门无法关闭");
alertManager.emit(alert);
}
}

52
src/main/java/club/joylink/xiannccda/alert/TrainDelayAlertMonitoringTask.java Normal file
View File

@ -0,0 +1,52 @@
package club.joylink.xiannccda.alert;
import club.joylink.xiannccda.alert.core.AlertManager;
import club.joylink.xiannccda.alert.core.AlertMonitoringTask;
import club.joylink.xiannccda.entity.AlertTip;
import club.joylink.xiannccda.repository.IAlertTipRepository;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.time.LocalDateTime;
import org.springframework.stereotype.Component;
@Component
public class TrainDelayAlertMonitoringTask implements AlertMonitoringTask {
private IAlertTipRepository alertTipRepository;
private boolean alertTriggered;
public TrainDelayAlertMonitoringTask(IAlertTipRepository alertTipRepository) {
this.alertTipRepository = alertTipRepository;
}
@Override
public String getName() {
return "Train_Delay";
}
@Override
public void run() {
LocalDateTime now = LocalDateTime.now();
if (alertTriggered) {
if (now.getSecond() % 30 != 0) {
alertTriggered = false;
}
} else {
if (now.getSecond() % 30 == 0) {
AlertType alertType = AlertType.PLATFORM_DOOR_CANNOT_OPEN;
LambdaQueryWrapper<AlertTip> queryWrapper = Wrappers.lambdaQuery(AlertTip.class);
queryWrapper.eq(AlertTip::getAlertType, alertType)
.eq(AlertTip::getTimeType, AlertTipTimeType.CLOCK_7_9_AND_19_21);
AlertTip alertTip = alertTipRepository.getOne(queryWrapper);
Integer alertTipId = alertTip == null ? null : alertTip.getId();
AlertManager alertManager = AlertManager.getInstance();
AlertDetailImpl alert = new AlertDetailImpl(alertType, now, alertTipId,
String.format("[3号线]列车[01-1001]按计划应于%s抵达[%s]，现因[%s]晚点%s分钟",
now.minusMinutes(2), "鱼化寨", "道岔P0110失表", "2"), "道岔[P0110]", "道岔[P0110]失表");
alertManager.emit(alert);
alertTriggered = true;
}
}
}
}

26
src/main/java/club/joylink/xiannccda/alert/xian3/Xian3AlertJob.java
View File

@ -1,26 +0,0 @@
package club.joylink.xiannccda.alert.xian3;
import club.joylink.xiannccda.alert.core.AlertManager;
import club.joylink.xiannccda.repository.IAlertTipRepository;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
@Order(1)
@Component
public class Xian3AlertJob implements ApplicationRunner {
private final IAlertTipRepository alertTipRepository;
public Xian3AlertJob(IAlertTipRepository alertTipRepository) {
this.alertTipRepository = alertTipRepository;
}
@Override
public void run(ApplicationArguments args) throws Exception {
AlertManager alertManager = AlertManager.getInstance();
//报警源
alertManager.addTask(new Xian3TrainDelayAlertMonitoringTask());
}
}

33
src/main/java/club/joylink/xiannccda/alert/xian3/Xian3BlueDisplayAlert.java
View File

@ -1,33 +0,0 @@
package club.joylink.xiannccda.alert.xian3;
import club.joylink.xiannccda.alert.core.AlertInfo;
import java.time.LocalDateTime;
import lombok.Data;
/**
* 西安3蓝显
*/
@Data
public class Xian3BlueDisplayAlert implements AlertInfo {
private String id;
@Override
public String getId() {
return id;
}
@Override
public String getLevel() {
return null;
}
@Override
public LocalDateTime getAlertTime() {
return null;
}
@Override
public String getInfo() {
return null;
}
}

32
src/main/java/club/joylink/xiannccda/alert/xian3/Xian3SupplyShortageAlert.java
View File

@ -1,32 +0,0 @@
package club.joylink.xiannccda.alert.xian3;
import club.joylink.xiannccda.alert.core.AlertInfo;
import java.time.LocalDateTime;
public class Xian3SupplyShortageAlert implements AlertInfo {
private String id;
public Xian3SupplyShortageAlert(String id) {
this.id = id;
}
@Override
public String getId() {
return id;
}
@Override
public String getLevel() {
return null;
}
@Override
public LocalDateTime getAlertTime() {
return null;
}
@Override
public String getInfo() {
return null;
}
}

43
src/main/java/club/joylink/xiannccda/alert/xian3/Xian3TrainDelayAlertMonitoringTask.java
View File

@ -1,43 +0,0 @@
package club.joylink.xiannccda.alert.xian3;
import club.joylink.xiannccda.alert.core.AlertManager;
import club.joylink.xiannccda.alert.core.AlertMonitoringTask;
import java.time.LocalDateTime;
import java.util.concurrent.atomic.AtomicInteger;
public class Xian3TrainDelayAlertMonitoringTask implements AlertMonitoringTask {
private final AtomicInteger id = new AtomicInteger(1);
private boolean alertTriggered;
public Xian3TrainDelayAlertMonitoringTask() {
}
@Override
public String getName() {
return "Xian3_Train_Delay";
}
@Override
public void run() {
LocalDateTime now = LocalDateTime.now();
if (alertTriggered) {
if (now.getSecond() % 10 != 0) {
alertTriggered = false;
}
} else {
if (now.getSecond() % 10 == 0) {
AlertManager alertManager = AlertManager.getInstance();
Xian3TrainDelayAlert alert = Xian3TrainDelayAlert.builder()
.alertTime(now)
.info(String.format("[3号线]列车[01-1001]按计划应于%s抵达[%s]，现因[%s]晚点%s分钟",
now.minusMinutes(2), "鱼化寨", "道岔P0110失表", "2"))
.alertTipId(1)
.build();
alertManager.emit(alert);
alertTriggered = true;
}
}
}
}

6
src/main/java/club/joylink/xiannccda/ats/message/line3/changer/SignalChanger.java
View File

@ -7,6 +7,9 @@ import org.apache.commons.lang3.StringUtils;
public class SignalChanger {
/**
* X10301 /XR
*/
public static class Signal1Changer implements NameChangerFilter {
@Override
@ -31,6 +34,9 @@ public class SignalChanger {
}
}
/**
* X1506_L2
*/
public static class Signal2Changer implements NameChangerFilter {
@Override

4
src/main/java/club/joylink/xiannccda/ats/message/line3/changer/SwitchChanger.java
View File

@ -4,9 +4,11 @@ import club.joylink.xiannccda.ats.message.line3.device.DeviceType;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/**
* P09301
*/
public class SwitchChanger implements NameChangerFilter {
@Override
public DeviceType deviceType() {
return DeviceType.DEVICE_TYPE_SWITCH;

14
src/main/java/club/joylink/xiannccda/ats/message/line3/changer/TrackChanger.java
View File

@ -6,6 +6,9 @@ import java.util.regex.Pattern;
public class TrackChanger {
/**
* 处理 3号线 区段位 T06301A 这样类似的格式
*/
public static class Track1Changer implements NameChangerFilter {
@Override
@ -15,7 +18,7 @@ public class TrackChanger {
@Override
public String changeDeviceName(String sourceName) {
Pattern regex = Pattern.compile("^([A-Za-z]{1,2})([\\d]{1,2})3?(.*?)([A-Z])$");
Pattern regex = Pattern.compile("^([A-Za-z]{1,2})([\\d]{1,2})3(.*?)([A-Z])$");
// Pattern regex = Pattern.compile("^([A-Za-z]{1,2})([\\d]{2})3(.*?)([A-Z])$");
Matcher matcher = regex.matcher(sourceName);
if (matcher.find()) {
@ -28,6 +31,9 @@ public class TrackChanger {
}
}
/**
* 处理区段 T11301 这样类似的格式
*/
public static class Track4Changer implements NameChangerFilter {
@Override
@ -53,6 +59,9 @@ public class TrackChanger {
}
}
/**
* 处理区段 TP_D33G 这样类似的格式
*/
public static class Track2Changer implements NameChangerFilter {
@Override
@ -71,6 +80,9 @@ public class TrackChanger {
}
}
/**
* 处理区段 T150406 这样类似的格式
*/
public static class Track3Changer implements NameChangerFilter {
@Override

1050
src/main/java/club/joylink/xiannccda/dto/protos/DeviceStatusProto.java
View File

File diff suppressed because it is too large Load Diff

2
src/main/java/club/joylink/xiannccda/ws/NccAlertMessageServer.java
View File

@ -66,7 +66,7 @@ public class NccAlertMessageServer implements IMessageServer {
this.id = id;
}
public static NccAlertMessageServer getInstance() {
public static NccAlertMessageServer getDefault() {
return getInstance("default");
}

2
src/main/resources/application.yml
View File

@ -2,7 +2,7 @@ server:
port: 9081
spring:
profiles:
active: local
active: dev
banner:
location: classpath:banner.txt
datasource:

8
src/test/java/club/joylink/xiannccda/alert/AlertManagerTest.java
View File

@ -3,8 +3,6 @@ package club.joylink.xiannccda.alert;
import club.joylink.xiannccda.alert.core.AlertManager;
import club.joylink.xiannccda.alert.core.AlertMonitoringTask;
import club.joylink.xiannccda.alert.core.AlertSourceEvent;
import club.joylink.xiannccda.alert.xian3.Xian3SupplyShortageAlert;
import club.joylink.xiannccda.alert.xian3.Xian3TrainDelayAlert;
import club.joylink.xiannccda.event.Listener;
import java.util.ArrayList;
import java.util.List;
@ -23,8 +21,7 @@ public class AlertManagerTest {
//可能报警事件监听器
manager.on(new SuppliesRemainInsufficientListener(sid));
//报警事件监听器
manager.on((Listener<Xian3TrainDelayAlert>) event -> System.out.println("列车延误报警"));
manager.on((Listener<Xian3SupplyShortageAlert>) event -> System.out.println("物资紧缺报警"));
manager.on((Listener<AlertDetailImpl>) event -> System.out.println("列车延误报警"));
manager.taskStart();
manager.emit(new SuppliesCountUpdatedEvent(this, 2));
@ -78,9 +75,6 @@ public class AlertManagerTest {
@Override
public void accept(SuppliesCountUpdatedEvent event) {
if (event.getRemain() <= SuppliesAlertMin) {
AlertManager.getInstance(sId).emit(new Xian3SupplyShortageAlert("2"));
}
}
}

2
xian-ncc-da-message

@ -1 +1 @@
Subproject commit 90b6f4600e531c496d849163653acb80c6e933ea
Subproject commit eb0ad6e4305642b6619f5e97d1498ad5dc5a6d42