joylink
/
rts-sim-testing-service
6
0
Fork 0
Code Issues 8 Pull Requests Actions Packages Projects Releases Wiki Activity

计轴rssp 集成

This commit is contained in:
xzb 2023-11-09 14:04:37 +08:00
parent d4a2cf2f80
commit d8b5e2d89c
2 changed files with 38 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
config/config.go
View File

@ -82,10 +82,15 @@ type InterlockConfig struct {
// RsspAxleConfig 计轴区段与联锁安全通信配置 // RsspAxleConfig 计轴区段与联锁安全通信配置
type RsspAxleConfig struct { type RsspAxleConfig struct {
City string `json:"City" description:"所属城市"` City string `json:"city" description:"所属城市"`
LineId string `json:"LineId" description:"所属线路"` LineId string `json:"lineId" description:"所属线路"`
CentralizedStation string `json:"centralizedStation" description:"所属集中站"` CentralizedStation string `json:"centralizedStation" description:"所属集中站"`
RsspCfgs []RsspConfig `json:"rsspCfgs" description:"主备安全通道配置"` RsspCfgs []RsspConfig `json:"rsspCfgs" description:"主备安全通道配置"`
SendingPeriod uint32 `json:"sendingPeriod" description:"发送周期值"` //接收方每个安全通信会话对应的发送周期值,单位ms
SsrRsspTimeout uint32 `json:"ssrRsspTimeout" description:"等待SSR回应的定时器超时值"` //等待SSR回应的定时器超时值,为RsspTimer时间,1=SendingPeriod
Mtv uint32 `json:"mtv" description:"最大时序偏差"` //每个安全通信会话可容忍的最大时序偏差,即当前接收的RSD的序列号与上一次RSD的序列号最大允许差值
Udl uint32 `json:"udl" description:"RSD应用数据长度配置值"` //每个安全通信会话RSD应用数据长度发送和接收的配置值（支持固定长度和可变长度）;0-可变长度，大于0即固定长度
DeviceA bool `json:"deviceA" description:"true-A机；false-B机"` //true-A机；false-B机
} }
// RsspConfig CI系统与计轴设备的安全通信协议配置参数 // RsspConfig CI系统与计轴设备的安全通信协议配置参数
@ -99,12 +104,12 @@ type RsspConfig struct {
SID2 uint32 `json:"sID2" description:"通道2源标识"` //通道2源标识 SID2 uint32 `json:"sID2" description:"通道2源标识"` //通道2源标识
SINIT1 uint32 `json:"sINIT1" description:"通道1序列初始"` //通道1序列初始 SINIT1 uint32 `json:"sINIT1" description:"通道1序列初始"` //通道1序列初始
SINIT2 uint32 `json:"sINIT2" description:"通道2序列初始"` //通道2序列初始 SINIT2 uint32 `json:"sINIT2" description:"通道2序列初始"` //通道2序列初始
SendingPeriod uint32 `json:"sendingPeriod" description:"发送周期值"` //接收方每个安全通信会话对应的发送周期值,单位ms SendingPeriod uint32 //接收方每个安全通信会话对应的发送周期值,单位ms
SsrRsspTimeout uint32 `json:"ssrRsspTimeout" description:"等待SSR回应的定时器超时值"` //等待SSR回应的定时器超时值,为RsspTimer时间,1=SendingPeriod SsrRsspTimeout uint32 //等待SSR回应的定时器超时值,为RsspTimer时间,1=SendingPeriod
Mtv uint32 `json:"mtv" description:"最大时序偏差"` //每个安全通信会话可容忍的最大时序偏差,即当前接收的RSD的序列号与上一次RSD的序列号最大允许差值 Mtv uint32 //每个安全通信会话可容忍的最大时序偏差,即当前接收的RSD的序列号与上一次RSD的序列号最大允许差值
Udl uint32 `json:"udl" description:"RSD应用数据长度配置值"` //每个安全通信会话RSD应用数据长度发送和接收的配置值（支持固定长度和可变长度）;0-可变长度，大于0即固定长度 Udl uint32 //每个安全通信会话RSD应用数据长度发送和接收的配置值（支持固定长度和可变长度）;0-可变长度，大于0即固定长度
DeviceA bool //true-A机；false-B机
PicType byte `json:"picType" description:"协议交互类别"` //协议交互类别，message.PicType PicType byte `json:"picType" description:"协议交互类别"` //协议交互类别，message.PicType
DeviceA bool `json:"deviceA" description:"true-A机；false-B机"` //true-A机；false-B机
RemoteIp string `json:"remoteIp" description:"远程服务器ip"` //远程服务器ip RemoteIp string `json:"remoteIp" description:"远程服务器ip"` //远程服务器ip
RemoteUdpPort int `json:"remoteUdpPort" description:"远程服务器端口"` //远程服务器端口 RemoteUdpPort int `json:"remoteUdpPort" description:"远程服务器端口"` //远程服务器端口
LocalUdpPort int `json:"localUdpPort" description:"本地服务器端口"` //本地服务器端口 LocalUdpPort int `json:"localUdpPort" description:"本地服务器端口"` //本地服务器端口

15
third_party/axle_device/rssp_axle.go vendored
View File

@ -26,6 +26,8 @@ type rsspAxle struct {
lineId string lineId string
//所属集中站 //所属集中站
centralizedStation string centralizedStation string
//接收方每个安全通信会话对应的发送周期值,单位ms
sendingPeriod uint32
//主安全通道 //主安全通道
masterRssp *RsspChannel masterRssp *RsspChannel
//备安全通道 //备安全通道
@ -42,14 +44,25 @@ func InitRsspAxle(cfg *config.RsspAxleConfig) RsspAxle {
ra.city = cfg.City ra.city = cfg.City
ra.lineId = cfg.LineId ra.lineId = cfg.LineId
ra.centralizedStation = cfg.CentralizedStation ra.centralizedStation = cfg.CentralizedStation
ra.sendingPeriod = cfg.SendingPeriod
// //
cfgLen := len(cfg.RsspCfgs) cfgLen := len(cfg.RsspCfgs)
var masterConfig, slaveConfig *config.RsspConfig var masterConfig, slaveConfig *config.RsspConfig
if cfgLen >= 1 { if cfgLen >= 1 {
masterConfig = &cfg.RsspCfgs[0] masterConfig = &cfg.RsspCfgs[0]
masterConfig.SendingPeriod = cfg.SendingPeriod
masterConfig.SsrRsspTimeout = cfg.SsrRsspTimeout
masterConfig.Mtv = cfg.Mtv
masterConfig.Udl = cfg.Udl
masterConfig.DeviceA = cfg.DeviceA
} }
if cfgLen >= 2 { if cfgLen >= 2 {
slaveConfig = &cfg.RsspCfgs[1] slaveConfig = &cfg.RsspCfgs[1]
slaveConfig.SendingPeriod = cfg.SendingPeriod
slaveConfig.SsrRsspTimeout = cfg.SsrRsspTimeout
slaveConfig.Mtv = cfg.Mtv
slaveConfig.Udl = cfg.Udl
slaveConfig.DeviceA = cfg.DeviceA
} }
if masterConfig != nil { if masterConfig != nil {
mrc := &RsspChannel{} mrc := &RsspChannel{}
@ -133,7 +146,7 @@ func (s *rsspAxle) doTaskSendStatus(sendContext context.Context) {
slog.Debug(e.Error()) slog.Debug(e.Error())
} }
//todo //todo
time.Sleep(300 * time.Millisecond) time.Sleep(time.Duration(s.sendingPeriod) * time.Millisecond)
} }
} }