rts-sim-module/component/physical_section.go

package component

import (
	"fmt"
	"joylink.club/ecs"
)

//计轴设备，管理联锁集中站内的所有计轴区段
//计轴直接复位：计轴的轮对计数清零，区段转换为空闲状态
//计轴预复位：将计轴的轮对计数清零，但是区段不会立即变成空闲区段，而是处于一种“占用”状态，在压道车通过之后确认区段空闲且计轴正常后，区段转换为空闲状态
//
//当CI系统给计轴设备发送计轴直接复零/预复零命令时，连续发送一定时间（具体发送时间调试后确定）的复零/预复零命令。
//当RAC，RJO，RJT任意一个不为0时，终止发送复零/预复零命令。

// PhysicalSectionState 物理区段
type PhysicalSectionState struct {
	//true-占用，false-出清
	Occ bool
}

// AxlePhysicalSection 计轴物理区段
type AxlePhysicalSection struct {
	//计轴区段内车轴数
	Count int
	//记录Count变化波形
	countPulse uint8
}
type AxleDeviceRuntime struct {
	//true-计轴复位反馈,表示计轴设备已收到CI系统发送的直接复零/预复零命令。
	Rac bool
	//true-运营原因拒绝计轴复位,如区段空闲时下发复位命令；或车轮压住传感器时收到复位命令。
	Rjo bool
	//true-技术原因拒绝计轴复位,主要指计轴相关设备故障时收到复位命令，如车轮传感器的导线断开、AEB之间的通信故障等
	Rjt bool
	//true-计轴直接复位
	//计轴的轮对计数清零，区段转换为空闲状态
	Drst bool
	//true-计轴预复位
	//将计轴的轮对计数清零，但是区段不会立即变成空闲区段，而是处于一种“占用”状态，在压道车通过之后确认区段空闲且计轴正常后，区段转换为空闲状态
	Pdrst bool
	//true-计轴系统正在执行直接预复位操作
	DoingPdrst bool
}

func NewAxleDeviceRuntime() *AxleDeviceRuntime {
	return &AxleDeviceRuntime{}
}

// AxleManageDevice 计轴管理设备
type AxleManageDevice struct {
	CentralizedStation string                        //所属集中站
	Adrs               map[string]*AxleDeviceRuntime //key-sectionId
}

func (d *AxleManageDevice) FindAdr(sectionId string) *AxleDeviceRuntime {
	return d.Adrs[sectionId]
}
func NewAxleManageDevice(centralizedStation string) *AxleManageDevice {
	return &AxleManageDevice{CentralizedStation: centralizedStation, Adrs: make(map[string]*AxleDeviceRuntime)}
}

var (
	PhysicalSectionStateType = ecs.NewComponentType[PhysicalSectionState]()
	AxlePhysicalSectionType  = ecs.NewComponentType[AxlePhysicalSection]()
	AxleSectionFaultTag      = ecs.NewTag()
	AxleManageDeviceType     = ecs.NewComponentType[AxleManageDevice]()
)

/////////////////////////////AxlePhysicalSection/////////////////////////////////

func NewAxlePhysicalSection() *AxlePhysicalSection {
	return &AxlePhysicalSection{Count: 0, countPulse: 0}
}
func (c *AxlePhysicalSection) UpdateCount(count int) {
	cp := to1(c.Count)
	np := to1(count)
	//
	if cp != np {
		c.countPulse <<= 1
		if np > 0 {
			c.countPulse |= np
		}
	}
	c.Count = count
}
func (c *AxlePhysicalSection) ResetCountPulse() {
	c.countPulse = 0x00
}
func (c *AxlePhysicalSection) ShowCountWave() string {
	return fmt.Sprintf("%08b", c.countPulse)
}

// IsCount010Pulse true-车进入计轴区段后出清计轴区段
func (c *AxlePhysicalSection) IsCount010Pulse() bool {
	return c.countPulse&0x01 == 0 && c.countPulse&0x02 > 0 && c.countPulse&0x04 == 0
}

// 归1
func to1(c int) uint8 {
	if c > 0 {
		return 0x01
	} else {
		return 0x00
	}
}