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

调整

Browse Source
This commit is contained in:
tiger_zhou 2024-01-12 11:25:44 +08:00
parent 3cfde83eef
commit 60f1725f8a
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/club/joylink/xiannccda/ats/message/OccTcpClientConnection.java
View File

@ -107,7 +107,7 @@ public class OccTcpClientConnection {
this.lastReceiveMessageTime = System.currentTimeMillis(); this.lastReceiveMessageTime = System.currentTimeMillis();
this.channel = channelFuture.channel(); this.channel = channelFuture.channel();
this.connected = true; this.connected = true;
this.client.requestBaseData(); // this.client.requestBaseData();
SystemContext.publishEvent(new SystemWarnConnStateEvent(this.client.getLineId(), this)); SystemContext.publishEvent(new SystemWarnConnStateEvent(this.client.getLineId(), this));
} }
}); });

1
src/main/java/club/joylink/xiannccda/ats/message/XianOccMessagingClient.java
View File

@ -75,6 +75,7 @@ public class XianOccMessagingClient {
} }
} }
//获取列车运行图
public void requestBaseData() { public void requestBaseData() {
if (this.rtConnection.connected && this.nrtConnection.connected && this.requestBaseDataFlag.compareAndSet(false, true)) { if (this.rtConnection.connected && this.nrtConnection.connected && this.requestBaseDataFlag.compareAndSet(false, true)) {
log.info("发送计划运行图请求 lineId[{}] host[{}] 实时接口[{}]", this.lineId, this.host, false); log.info("发送计划运行图请求 lineId[{}] host[{}] 实时接口[{}]", this.lineId, this.host, false);