Merge branch 'master' of https://git.code.tencent.com/jl-framework/rtss_simulation
This commit is contained in:
commit
80585dbf7a
168
component/cbtc_atp_ground.go
Normal file
168
component/cbtc_atp_ground.go
Normal file
@ -0,0 +1,168 @@
|
||||
package component
|
||||
|
||||
import (
|
||||
"time"
|
||||
|
||||
"joylink.club/ecs"
|
||||
)
|
||||
|
||||
// 控制模式
|
||||
type ControlMode uint8
|
||||
|
||||
const (
|
||||
ControlMode_None ControlMode = iota // 交出未被接收
|
||||
ControlMode_Center // 中控
|
||||
ControlMode_Local // 站控/自律站控
|
||||
ControlMode_Emergency // 紧急站控
|
||||
ControlMode_Interlock // 联锁控/非常站控
|
||||
)
|
||||
|
||||
// 控制模式
|
||||
type ControlState struct {
|
||||
Model ControlMode // 当前控制模式
|
||||
}
|
||||
|
||||
var ControlStateType = ecs.NewComponentType[ControlState]() // 控制模式
|
||||
|
||||
// 限速组件
|
||||
type SpeedLimit struct {
|
||||
Val float32 // 限速值
|
||||
}
|
||||
|
||||
var SpeedLimitType = ecs.NewComponentType[SpeedLimit]() // 限速组件
|
||||
|
||||
// 占用类型
|
||||
type OccupiedType uint8
|
||||
|
||||
const (
|
||||
Occupied_Ct OccupiedType = iota // 通信车占用
|
||||
Occupied_Nct // 非通信车占用
|
||||
Occupied_Fault // 故障占用
|
||||
)
|
||||
|
||||
// 占用状态
|
||||
type OccupiedStatus struct {
|
||||
Type OccupiedType
|
||||
}
|
||||
|
||||
var OccupiedStatusType = ecs.NewComponentType[OccupiedStatus]() // 占用状态组件
|
||||
|
||||
// 进路锁闭状态
|
||||
type RouteLock struct {
|
||||
Route *ecs.Entry
|
||||
}
|
||||
|
||||
var RouteLockType = ecs.NewComponentType[RouteLock]()
|
||||
|
||||
// 故障锁闭状态
|
||||
type FaultLock struct {
|
||||
Fault any // 故障信息
|
||||
}
|
||||
|
||||
var FaultLockType = ecs.NewComponentType[FaultLock]() // 故障锁闭状态组件
|
||||
|
||||
// 封锁状态
|
||||
type BlockadeStatus struct {
|
||||
}
|
||||
|
||||
var BlockadeStatusType = ecs.NewComponentType[BlockadeStatus]() // 封锁状态组件
|
||||
|
||||
// 解锁状态
|
||||
type UnLockStatus struct {
|
||||
Delay bool // 延迟状态
|
||||
DelayTime time.Duration // 延迟解锁时间
|
||||
TriggerDevice *ecs.Entry // 触发解锁设备
|
||||
}
|
||||
|
||||
var UnLockStatusType = ecs.NewComponentType[UnLockStatus]() // 解锁状态组件
|
||||
|
||||
// 关闭状态
|
||||
type ClosedStatus struct {
|
||||
}
|
||||
|
||||
var ClosedStatusType = ecs.NewComponentType[ClosedStatus]() // 关闭状态组件
|
||||
|
||||
// 站台跳停状态
|
||||
type PlatformSkipStatus struct {
|
||||
AllSkip bool // 全部跳停
|
||||
Trains []*ecs.Entry // 跳停列车
|
||||
}
|
||||
|
||||
var PlatformSkipStatusType = ecs.NewComponentType[PlatformSkipStatus]() // 站台跳停状态
|
||||
|
||||
// 站台停靠发车状态
|
||||
type PlatformParkStatus struct {
|
||||
Park bool // 列车停靠状态
|
||||
ParkTime time.Duration // 停靠时间
|
||||
Depart bool // 列车发车状态
|
||||
}
|
||||
|
||||
var PlatformParkStatusType = ecs.NewComponentType[PlatformParkStatus]() // 站台停靠发车状态
|
||||
|
||||
// 扣车状态
|
||||
type PlatformHoldStatus struct {
|
||||
}
|
||||
|
||||
var PlatformHoldStatusType = ecs.NewComponentType[PlatformHoldStatus]() // 扣车状态组件
|
||||
|
||||
// 信号机状态
|
||||
type SignalStatus struct {
|
||||
ApproachLock bool // 接近锁闭
|
||||
OverlapLock bool // 延续保护锁闭
|
||||
}
|
||||
|
||||
var SignalStatusType = ecs.NewComponentType[SignalStatus]() // 信号机状态组件
|
||||
|
||||
// 进路状态
|
||||
type RouteStatus struct {
|
||||
AtsControl bool // ats自动控制
|
||||
Setting bool // 进路是否排列中
|
||||
Lock bool // 已锁闭
|
||||
}
|
||||
|
||||
var RouteStatusType = ecs.NewComponentType[RouteStatus]() // 进路状态组件
|
||||
|
||||
// 列车运行级别
|
||||
type TrainRunLevel uint8
|
||||
|
||||
const (
|
||||
TrainRunLevel_CBTC TrainRunLevel = iota // cbtc级别
|
||||
TrainRunLevel_ITC // 点式通信
|
||||
TrainRunLevel_IL // 联锁级
|
||||
)
|
||||
|
||||
// 列车运行模式
|
||||
type DriveMode uint8
|
||||
|
||||
const (
|
||||
DriveMode_AM DriveMode = iota // 列车自动驾驶模式
|
||||
DriveMode_CM // ATP防护下的人工驾驶模式
|
||||
DriveMode_RM // 限制人工驾驶模式
|
||||
DriveMode_NRM // 无限制人工驾驶模式
|
||||
)
|
||||
|
||||
// 位置：目标位置、占用位置
|
||||
type DevicePosition struct {
|
||||
Device *ecs.Entry // 设备
|
||||
Offset int64 // 在设备上的相对a位置偏移
|
||||
Direction bool // 从a到b为true;从b到a为false
|
||||
}
|
||||
|
||||
var DevicePositionType = ecs.NewComponentType[DevicePosition]()
|
||||
|
||||
// 列车运行状态
|
||||
type TrainRunStatus struct {
|
||||
RunLevel TrainRunLevel // 列车运行级别
|
||||
DriveMode DriveMode // 驾驶模式
|
||||
Speed float32 // 运行速度
|
||||
SpeedMax float32 // 最大速度
|
||||
HeadPosition *DevicePosition // 车头位置
|
||||
TailPosition *DevicePosition // 车尾位置
|
||||
Hold bool // 扣车
|
||||
}
|
||||
|
||||
var TrainRunStatusType = ecs.NewComponentType[TrainRunStatus]() // 列车位置状态组件
|
||||
|
||||
var (
|
||||
TrainSpeedMax float32 = 80 / 3.6
|
||||
)
|
||||
@ -3,16 +3,22 @@ package component
|
||||
import "joylink.club/ecs"
|
||||
|
||||
// FluidPipe 流体管线
|
||||
//
|
||||
// 管线内流体流动条件：1、管线内有流体；2、管线两端有压差；3、管线畅通
|
||||
type FluidPipe struct {
|
||||
FlowVelocity int32 //流速，大于零从管线A端向B端流动，小于零从管线B端向A端流动，等于零没有流动
|
||||
Direction PipeFlowDirection //流动方向
|
||||
}
|
||||
|
||||
// PipeFlowDirection 管线内流体流动方向定义
|
||||
type PipeFlowDirection int8
|
||||
|
||||
const (
|
||||
PipeFlowNon PipeFlowDirection = iota //流体未流动
|
||||
PipeFlowAb //流体从管线的A->B
|
||||
PipeFlowBa //流体从管线的B->A
|
||||
)
|
||||
|
||||
// FluidDriver 流体驱动器
|
||||
type FluidDriver struct {
|
||||
On bool //true-输出流体驱动力；false-未输出流体驱动力
|
||||
Forward bool //true-正转；false-反转
|
||||
}
|
||||
|
||||
var (
|
||||
|
||||
@ -101,7 +101,7 @@ func newAirConditioningEntity(w ecs.World, id string, tag *ecs.ComponentType[str
|
||||
wd := GetWorldData(w)
|
||||
e, ok := wd.EntityMap[id]
|
||||
if !ok {
|
||||
e = w.Entry(w.Create(component.UidType, component.MotorType, component.AirConditioningType, component.FluidDriverType, component.DeviceExceptionType, tag))
|
||||
e = w.Entry(w.Create(component.UidType, component.MotorType, component.AirConditioningType, component.DeviceExceptionType, tag))
|
||||
component.UidType.SetValue(e, component.Uid{Id: id})
|
||||
wd.EntityMap[id] = e
|
||||
}
|
||||
|
||||
@ -84,7 +84,7 @@ func LoadIscs(w ecs.World) error {
|
||||
NewAirCurtainEntity(w, ac.Id())
|
||||
}
|
||||
//气体环境
|
||||
for _, gasEnv := range data.Repo.GasEnvironmentMap {
|
||||
for _, gasEnv := range data.Repo.EnvironmentMap {
|
||||
NewGasEnvironmentEntity(w, gasEnv.Id())
|
||||
}
|
||||
//风机
|
||||
|
||||
@ -27,6 +27,7 @@ message Repository {
|
||||
string mainCoordinateSystem = 20;
|
||||
repeated Key Keys = 21;
|
||||
repeated CentralizedStationRef CentralizedStationRefs = 22;
|
||||
repeated Route routes = 23;
|
||||
//ISCS 编号[300,500]
|
||||
//ISCS管线
|
||||
repeated Pipe pipes = 300;
|
||||
@ -353,8 +354,8 @@ enum DeviceType {
|
||||
DeviceType_CombinationAirConditioner = 390;
|
||||
//ISCS 净化装置
|
||||
DeviceType_AirPurificationDevice = 391;
|
||||
//ISCS 气体环境(正常空气+有害烟雾)
|
||||
DeviceType_GasEnvironment = 392;
|
||||
//ISCS 环境(正常空气、有害烟雾、温度、湿度等)
|
||||
DeviceType_Environment = 392;
|
||||
}
|
||||
|
||||
|
||||
@ -501,10 +502,16 @@ message Mkx {
|
||||
}
|
||||
//站台
|
||||
message Platform {
|
||||
enum PlatformDirection {
|
||||
Unknown = 0;
|
||||
Up = 1; // 上行
|
||||
Down = 2; // 下行
|
||||
}
|
||||
string id = 1;
|
||||
string code = 2;
|
||||
string stationId = 3;
|
||||
string physicalSectionId = 4;
|
||||
PlatformDirection direction = 5;
|
||||
}
|
||||
|
||||
// 报警器
|
||||
@ -558,6 +565,29 @@ message CiSectionCodePoint{
|
||||
string sectionId = 2;//物理区段id
|
||||
}
|
||||
|
||||
// 进路信息
|
||||
message Route {
|
||||
enum RouteType {
|
||||
RECEIVING = 0;
|
||||
DEPARTURE = 1;
|
||||
SHUNTING = 2;
|
||||
PASS = 3;
|
||||
LONG_SHUNTING = 4;
|
||||
}
|
||||
string id = 1;
|
||||
string name = 2;
|
||||
// 开始信号机
|
||||
string startId = 3;
|
||||
// 目的信号机
|
||||
string destinationId = 4;
|
||||
// 关联设备ID
|
||||
repeated string deviceIds = 5;
|
||||
// 敌对进路ID
|
||||
repeated string conflictingRouteIds = 6;
|
||||
// 进路类型
|
||||
RouteType routeType = 7;
|
||||
}
|
||||
|
||||
//////////////////////////ISCS///////////////////////////////////
|
||||
|
||||
|
||||
@ -737,3 +767,4 @@ message GasEnvironment{
|
||||
string id = 1;
|
||||
string code = 2;
|
||||
}
|
||||
|
||||
|
||||
@ -45,8 +45,8 @@ type Valve struct {
|
||||
Identity
|
||||
Code string
|
||||
ValveType proto.Valve_Type //阀门子类型
|
||||
PortA DevicePort //阀门A端口连接的设备
|
||||
PortB DevicePort //阀门B端口连接的设备
|
||||
PortA *PipePort //阀门A端口连接的设备
|
||||
PortB *PipePort //阀门B端口连接的设备
|
||||
}
|
||||
|
||||
func NewValve(id string, code string, valveType proto.Valve_Type) *Valve {
|
||||
@ -59,6 +59,16 @@ func NewValve(id string, code string, valveType proto.Valve_Type) *Valve {
|
||||
func (p *Valve) PortNum() int {
|
||||
return 2
|
||||
}
|
||||
func (p *Valve) Ports() []*PipePort {
|
||||
var ports []*PipePort
|
||||
if p.PortA != nil {
|
||||
ports = append(ports, p.PortA)
|
||||
}
|
||||
if p.PortB != nil {
|
||||
ports = append(ports, p.PortB)
|
||||
}
|
||||
return ports
|
||||
}
|
||||
|
||||
// ValvePort 阀门端口
|
||||
//
|
||||
@ -82,10 +92,8 @@ func (p *ValvePort) Device() PortedDevice {
|
||||
type GasMixingChamber struct {
|
||||
Identity
|
||||
Code string
|
||||
PortA DevicePort //A端口连接的设备
|
||||
PortB DevicePort //B端口连接的设备
|
||||
PortC DevicePort //C端口连接的设备
|
||||
PortD DevicePort //D端口连接的设备
|
||||
PortsA []*PipePort //A端多个输入口
|
||||
PortsB []*PipePort //B端多个输出口
|
||||
}
|
||||
|
||||
func NewGasMixingChamber(id string, code string) *GasMixingChamber {
|
||||
@ -97,6 +105,14 @@ func NewGasMixingChamber(id string, code string) *GasMixingChamber {
|
||||
func (p *GasMixingChamber) PortNum() int {
|
||||
return 4
|
||||
}
|
||||
func (p *GasMixingChamber) IsInput(pipeId string) bool {
|
||||
for _, portA := range p.PortsA {
|
||||
if pipeId == portA.pipe.Id() {
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
// GasMixingChamberPort 混合室静压箱端口
|
||||
//
|
||||
@ -121,10 +137,10 @@ func (p *GasMixingChamberPort) Device() PortedDevice {
|
||||
type CombinationAirConditioner struct {
|
||||
Identity
|
||||
Code string
|
||||
PortA DevicePort //新风输入A端口连接的设备
|
||||
PortB DevicePort //工作风输出B端口连接的设备
|
||||
PortC DevicePort //C端口连接的设备
|
||||
PortD DevicePort //D端口连接的设备
|
||||
PortA *PipePort //新风输入A端口连接的设备
|
||||
PortB *PipePort //工作风输出B端口连接的设备
|
||||
PortC *PipePort //C端口连接的设备
|
||||
PortD *PipePort //D端口连接的设备
|
||||
}
|
||||
|
||||
func NewCombinationAirConditioner(id string, code string) *CombinationAirConditioner {
|
||||
@ -136,25 +152,21 @@ func NewCombinationAirConditioner(id string, code string) *CombinationAirConditi
|
||||
func (p *CombinationAirConditioner) PortNum() int {
|
||||
return 4
|
||||
}
|
||||
func (p *CombinationAirConditioner) Outputs() []DevicePort {
|
||||
var out []DevicePort
|
||||
func (p *CombinationAirConditioner) Ports() []*PipePort {
|
||||
var ports []*PipePort
|
||||
if p.PortA != nil {
|
||||
ports = append(ports, p.PortA)
|
||||
}
|
||||
if p.PortB != nil {
|
||||
out = append(out, p.PortB)
|
||||
ports = append(ports, p.PortB)
|
||||
}
|
||||
if p.PortC != nil {
|
||||
out = append(out, p.PortC)
|
||||
}
|
||||
return out
|
||||
}
|
||||
func (p *CombinationAirConditioner) Inputs() []DevicePort {
|
||||
var in []DevicePort
|
||||
if p.PortA != nil {
|
||||
in = append(in, p.PortA)
|
||||
ports = append(ports, p.PortC)
|
||||
}
|
||||
if p.PortD != nil {
|
||||
in = append(in, p.PortD)
|
||||
ports = append(ports, p.PortD)
|
||||
}
|
||||
return in
|
||||
return ports
|
||||
}
|
||||
|
||||
// CombinationAirConditionerPort 组合式空调端口
|
||||
@ -179,8 +191,8 @@ func (p *CombinationAirConditionerPort) Device() PortedDevice {
|
||||
type AirPurificationDevice struct {
|
||||
Identity
|
||||
Code string
|
||||
PortA DevicePort //A端口连接的设备
|
||||
PortB DevicePort //B端口连接的设备
|
||||
PortA *PipePort //A端口连接的设备
|
||||
PortB *PipePort //B端口连接的设备
|
||||
}
|
||||
|
||||
func NewAirPurificationDevice(id string, code string) *AirPurificationDevice {
|
||||
@ -192,6 +204,16 @@ func NewAirPurificationDevice(id string, code string) *AirPurificationDevice {
|
||||
func (p *AirPurificationDevice) PortNum() int {
|
||||
return 2
|
||||
}
|
||||
func (p *AirPurificationDevice) Ports() []*PipePort {
|
||||
var ports []*PipePort
|
||||
if p.PortA != nil {
|
||||
ports = append(ports, p.PortA)
|
||||
}
|
||||
if p.PortB != nil {
|
||||
ports = append(ports, p.PortB)
|
||||
}
|
||||
return ports
|
||||
}
|
||||
|
||||
// AirPurificationDevicePort 净化装置端口
|
||||
//
|
||||
@ -231,8 +253,8 @@ type Fan struct {
|
||||
Code string
|
||||
FanType proto.Fan_Type
|
||||
*fanRunningModel
|
||||
PortA DevicePort //A端口连接的设备，风机出风口即排风口,输出端口
|
||||
PortB DevicePort //B端口连接的设备，风机进风口，输入端口
|
||||
PortA *PipePort //A端口连接的设备，风机出风口即排风口,输出端口
|
||||
PortB *PipePort //B端口连接的设备，风机进风口，输入端口
|
||||
}
|
||||
|
||||
func NewFan(id string, code string, fanType proto.Fan_Type) *Fan {
|
||||
@ -246,18 +268,6 @@ func NewFan(id string, code string, fanType proto.Fan_Type) *Fan {
|
||||
func (p *Fan) PortNum() int {
|
||||
return 2
|
||||
}
|
||||
func (p *Fan) Outputs() []DevicePort {
|
||||
if p.PortA == nil {
|
||||
return nil
|
||||
}
|
||||
return []DevicePort{p.PortA}
|
||||
}
|
||||
func (p *Fan) Inputs() []DevicePort {
|
||||
if p.PortB == nil {
|
||||
return nil
|
||||
}
|
||||
return []DevicePort{p.PortB}
|
||||
}
|
||||
|
||||
// FanPort 风机端口
|
||||
//
|
||||
@ -302,38 +312,37 @@ func newFanRunningModel(fanType proto.Fan_Type) *fanRunningModel {
|
||||
|
||||
////////////////////////////////////////////////
|
||||
|
||||
// GasEnvironment 气体环境(正常空气+有害烟雾)
|
||||
// 有多个输入口，统一为端口A，用来为环境补充新鲜空气；
|
||||
// 有多个输出口，统一为端口B，用户将环境的混浊气体排除；
|
||||
// 排出气体动力源为该环境。
|
||||
type GasEnvironment struct {
|
||||
// Environment 环境
|
||||
// 有多个输入口，统一为端口A
|
||||
// 有多个输出口，统一为端口B
|
||||
type Environment struct {
|
||||
Identity
|
||||
Code string
|
||||
PortsA []DevicePort // 有多个输入口，统一为端口A，用来为环境补充新鲜空气；
|
||||
PortsB []DevicePort // 有多个输出口，统一为端口B，用户将环境的混浊气体排除；
|
||||
}
|
||||
|
||||
func NewGasEnvironment(id string, code string) *GasEnvironment {
|
||||
return &GasEnvironment{
|
||||
Identity: &identity{id: id, deviceType: proto.DeviceType_DeviceType_GasEnvironment},
|
||||
func NewEnvironment(id string, code string) *Environment {
|
||||
return &Environment{
|
||||
Identity: &identity{id: id, deviceType: proto.DeviceType_DeviceType_Environment},
|
||||
Code: code,
|
||||
}
|
||||
}
|
||||
func (p *GasEnvironment) PortNum() int {
|
||||
func (p *Environment) PortNum() int {
|
||||
return len(p.PortsA) + len(p.PortsB)
|
||||
}
|
||||
|
||||
// GasEnvironmentPort 气体环境端口
|
||||
// EnvironmentPort 气体环境端口
|
||||
//
|
||||
// implement DevicePort
|
||||
type GasEnvironmentPort struct {
|
||||
type EnvironmentPort struct {
|
||||
port proto.Port
|
||||
device *GasEnvironment
|
||||
device *Environment
|
||||
}
|
||||
|
||||
func (p *GasEnvironmentPort) Port() proto.Port {
|
||||
func (p *EnvironmentPort) Port() proto.Port {
|
||||
return p.port
|
||||
}
|
||||
func (p *GasEnvironmentPort) Device() PortedDevice {
|
||||
func (p *EnvironmentPort) Device() PortedDevice {
|
||||
return p.device
|
||||
}
|
||||
|
||||
@ -1,6 +1,9 @@
|
||||
package repository
|
||||
|
||||
import "joylink.club/rtsssimulation/repository/model/proto"
|
||||
import (
|
||||
"fmt"
|
||||
"joylink.club/rtsssimulation/repository/model/proto"
|
||||
)
|
||||
|
||||
//电力监控系统车站一次图中相关设备模型
|
||||
|
||||
@ -20,6 +23,18 @@ func (p *Pipe) PortNum() int {
|
||||
return 2
|
||||
}
|
||||
|
||||
// PortDevice 获取管线对应端口连接的设备
|
||||
func (p *Pipe) PortDevice(port proto.Port) DevicePort {
|
||||
switch port {
|
||||
case proto.Port_A:
|
||||
return p.PortA
|
||||
case proto.Port_B:
|
||||
return p.PortB
|
||||
default:
|
||||
panic("管线端口只有A或B")
|
||||
}
|
||||
}
|
||||
|
||||
// PipePort 管线端口
|
||||
//
|
||||
// implement DevicePort
|
||||
@ -34,6 +49,21 @@ func (p *PipePort) Port() proto.Port {
|
||||
func (p *PipePort) Device() PortedDevice {
|
||||
return p.pipe
|
||||
}
|
||||
func (p *PipePort) PipePortId() string {
|
||||
return fmt.Sprintf("%s-%d", p.pipe.Id(), p.port)
|
||||
}
|
||||
|
||||
// ToOtherPort 获取当前管线端口所在管线的另一端
|
||||
func (p *PipePort) ToOtherPort() PipePort {
|
||||
switch p.port {
|
||||
case proto.Port_A:
|
||||
return PipePort{port: proto.Port_B, pipe: p.pipe}
|
||||
case proto.Port_B:
|
||||
return PipePort{port: proto.Port_A, pipe: p.pipe}
|
||||
default:
|
||||
panic("管线的端口只能为A或B")
|
||||
}
|
||||
}
|
||||
|
||||
///////////////////////////////////////////////////
|
||||
|
||||
|
||||
@ -185,8 +185,8 @@ const (
|
||||
DeviceType_DeviceType_CombinationAirConditioner DeviceType = 390
|
||||
// ISCS 净化装置
|
||||
DeviceType_DeviceType_AirPurificationDevice DeviceType = 391
|
||||
// ISCS 气体环境(正常空气+有害烟雾)
|
||||
DeviceType_DeviceType_GasEnvironment DeviceType = 392
|
||||
// ISCS 环境(正常空气、有害烟雾、温度、湿度等)
|
||||
DeviceType_DeviceType_Environment DeviceType = 392
|
||||
)
|
||||
|
||||
// Enum value maps for DeviceType.
|
||||
@ -283,7 +283,7 @@ var (
|
||||
389: "DeviceType_GasMixingChamber",
|
||||
390: "DeviceType_CombinationAirConditioner",
|
||||
391: "DeviceType_AirPurificationDevice",
|
||||
392: "DeviceType_GasEnvironment",
|
||||
392: "DeviceType_Environment",
|
||||
}
|
||||
DeviceType_value = map[string]int32{
|
||||
"DeviceType_Unknown": 0,
|
||||
@ -377,7 +377,7 @@ var (
|
||||
"DeviceType_GasMixingChamber": 389,
|
||||
"DeviceType_CombinationAirConditioner": 390,
|
||||
"DeviceType_AirPurificationDevice": 391,
|
||||
"DeviceType_GasEnvironment": 392,
|
||||
"DeviceType_Environment": 392,
|
||||
}
|
||||
)
|
||||
|
||||
@ -5570,7 +5570,7 @@ var file_model_proto_rawDesc = []byte{
|
||||
0x0a, 0x0e, 0x47, 0x61, 0x73, 0x45, 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65, 0x6e, 0x74,
|
||||
0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64,
|
||||
0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
|
||||
0x63, 0x6f, 0x64, 0x65, 0x2a, 0xee, 0x15, 0x0a, 0x0a, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x54,
|
||||
0x63, 0x6f, 0x64, 0x65, 0x2a, 0xeb, 0x15, 0x0a, 0x0a, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x54,
|
||||
0x79, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x12, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x54, 0x79, 0x70,
|
||||
0x65, 0x5f, 0x55, 0x6e, 0x6b, 0x6e, 0x6f, 0x77, 0x6e, 0x10, 0x00, 0x12, 0x1e, 0x0a, 0x1a, 0x44,
|
||||
0x65, 0x76, 0x69, 0x63, 0x65, 0x54, 0x79, 0x70, 0x65, 0x5f, 0x50, 0x68, 0x79, 0x73, 0x69, 0x63,
|
||||
@ -5743,20 +5743,20 @@ var file_model_proto_rawDesc = []byte{
|
||||
0x43, 0x6f, 0x6e, 0x64, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x65, 0x72, 0x10, 0x86, 0x03, 0x12, 0x25,
|
||||
0x0a, 0x20, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x54, 0x79, 0x70, 0x65, 0x5f, 0x41, 0x69, 0x72,
|
||||
0x50, 0x75, 0x72, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x76, 0x69,
|
||||
0x63, 0x65, 0x10, 0x87, 0x03, 0x12, 0x1e, 0x0a, 0x19, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x54,
|
||||
0x79, 0x70, 0x65, 0x5f, 0x47, 0x61, 0x73, 0x45, 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65,
|
||||
0x6e, 0x74, 0x10, 0x88, 0x03, 0x2a, 0x2c, 0x0a, 0x04, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x08, 0x0a,
|
||||
0x04, 0x4e, 0x6f, 0x6e, 0x65, 0x10, 0x00, 0x12, 0x05, 0x0a, 0x01, 0x41, 0x10, 0x01, 0x12, 0x05,
|
||||
0x0a, 0x01, 0x42, 0x10, 0x02, 0x12, 0x05, 0x0a, 0x01, 0x43, 0x10, 0x03, 0x12, 0x05, 0x0a, 0x01,
|
||||
0x44, 0x10, 0x04, 0x2a, 0x20, 0x0a, 0x09, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
|
||||
0x12, 0x08, 0x0a, 0x04, 0x4c, 0x45, 0x46, 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x52, 0x49,
|
||||
0x47, 0x48, 0x54, 0x10, 0x01, 0x2a, 0x43, 0x0a, 0x0e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x50, 0x6f,
|
||||
0x69, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x6f, 0x75, 0x6e, 0x64,
|
||||
0x61, 0x72, 0x79, 0x10, 0x00, 0x12, 0x0f, 0x0a, 0x0b, 0x41, 0x78, 0x6c, 0x65, 0x43, 0x6f, 0x75,
|
||||
0x6e, 0x74, 0x65, 0x72, 0x10, 0x01, 0x12, 0x12, 0x0a, 0x0e, 0x49, 0x6e, 0x73, 0x75, 0x6c, 0x61,
|
||||
0x74, 0x65, 0x64, 0x4a, 0x6f, 0x69, 0x6e, 0x74, 0x10, 0x02, 0x42, 0x1a, 0x5a, 0x18, 0x2e, 0x2f,
|
||||
0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x2f, 0x6d, 0x6f, 0x64, 0x65, 0x6c,
|
||||
0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
|
||||
0x63, 0x65, 0x10, 0x87, 0x03, 0x12, 0x1b, 0x0a, 0x16, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x54,
|
||||
0x79, 0x70, 0x65, 0x5f, 0x45, 0x6e, 0x76, 0x69, 0x72, 0x6f, 0x6e, 0x6d, 0x65, 0x6e, 0x74, 0x10,
|
||||
0x88, 0x03, 0x2a, 0x2c, 0x0a, 0x04, 0x50, 0x6f, 0x72, 0x74, 0x12, 0x08, 0x0a, 0x04, 0x4e, 0x6f,
|
||||
0x6e, 0x65, 0x10, 0x00, 0x12, 0x05, 0x0a, 0x01, 0x41, 0x10, 0x01, 0x12, 0x05, 0x0a, 0x01, 0x42,
|
||||
0x10, 0x02, 0x12, 0x05, 0x0a, 0x01, 0x43, 0x10, 0x03, 0x12, 0x05, 0x0a, 0x01, 0x44, 0x10, 0x04,
|
||||
0x2a, 0x20, 0x0a, 0x09, 0x44, 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x08, 0x0a,
|
||||
0x04, 0x4c, 0x45, 0x46, 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x52, 0x49, 0x47, 0x48, 0x54,
|
||||
0x10, 0x01, 0x2a, 0x43, 0x0a, 0x0e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x50, 0x6f, 0x69, 0x6e, 0x74,
|
||||
0x54, 0x79, 0x70, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x6f, 0x75, 0x6e, 0x64, 0x61, 0x72, 0x79,
|
||||
0x10, 0x00, 0x12, 0x0f, 0x0a, 0x0b, 0x41, 0x78, 0x6c, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x65,
|
||||
0x72, 0x10, 0x01, 0x12, 0x12, 0x0a, 0x0e, 0x49, 0x6e, 0x73, 0x75, 0x6c, 0x61, 0x74, 0x65, 0x64,
|
||||
0x4a, 0x6f, 0x69, 0x6e, 0x74, 0x10, 0x02, 0x42, 0x1a, 0x5a, 0x18, 0x2e, 0x2f, 0x72, 0x65, 0x70,
|
||||
0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x2f, 0x6d, 0x6f, 0x64, 0x65, 0x6c, 0x2f, 0x70, 0x72,
|
||||
0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
|
||||
}
|
||||
|
||||
var (
|
||||
|
||||
@ -51,7 +51,7 @@ type Repository struct {
|
||||
AirPurificationDeviceMap map[string]*AirPurificationDevice //ISCS净化装置
|
||||
AirCurtainMap map[string]*AirCurtain //ISCS空气幕
|
||||
FanMap map[string]*Fan //ISCS风机
|
||||
GasEnvironmentMap map[string]*GasEnvironment //ISCS气体环境
|
||||
EnvironmentMap map[string]*Environment //ISCS气体环境
|
||||
}
|
||||
|
||||
func newRepository(id string, version string) *Repository {
|
||||
@ -98,7 +98,7 @@ func newRepository(id string, version string) *Repository {
|
||||
AirPurificationDeviceMap: make(map[string]*AirPurificationDevice), //ISCS净化装置
|
||||
AirCurtainMap: make(map[string]*AirCurtain), //ISCS空气幕
|
||||
FanMap: make(map[string]*Fan), //ISCS风机
|
||||
GasEnvironmentMap: make(map[string]*GasEnvironment), //ISCS气体环境
|
||||
EnvironmentMap: make(map[string]*Environment), //ISCS气体环境
|
||||
}
|
||||
}
|
||||
|
||||
@ -189,7 +189,7 @@ func (repo *Repository) FindById(id string) Identity {
|
||||
if md, ok := repo.FanMap[id]; ok {
|
||||
return md
|
||||
}
|
||||
if md, ok := repo.GasEnvironmentMap[id]; ok {
|
||||
if md, ok := repo.EnvironmentMap[id]; ok {
|
||||
return md
|
||||
}
|
||||
//ISCS-end
|
||||
@ -385,8 +385,8 @@ func (repo *Repository) FindModel(deviceId string, deviceType proto.DeviceType)
|
||||
return repo.AirCurtainMap[deviceId], nil
|
||||
case proto.DeviceType_DeviceType_Fan:
|
||||
return repo.FanMap[deviceId], nil
|
||||
case proto.DeviceType_DeviceType_GasEnvironment:
|
||||
return repo.GasEnvironmentMap[deviceId], nil
|
||||
case proto.DeviceType_DeviceType_Environment:
|
||||
return repo.EnvironmentMap[deviceId], nil
|
||||
default:
|
||||
return nil, fmt.Errorf("仓库中不存在[%s]类型的模型", deviceType)
|
||||
}
|
||||
|
||||
@ -104,10 +104,10 @@ func buildIscsModels(source *proto.Repository, repository *Repository) error {
|
||||
m := NewFan(protoData.Id, protoData.Code, protoData.FanType)
|
||||
repository.FanMap[m.Id()] = m
|
||||
}
|
||||
//ISCS气体环境
|
||||
//ISCS环境
|
||||
for _, protoData := range source.GasEnvironments {
|
||||
m := NewGasEnvironment(protoData.Id, protoData.Code)
|
||||
repository.GasEnvironmentMap[m.Id()] = m
|
||||
m := NewEnvironment(protoData.Id, protoData.Code)
|
||||
repository.EnvironmentMap[m.Id()] = m
|
||||
}
|
||||
//
|
||||
return nil
|
||||
@ -160,13 +160,9 @@ func buildIscsPipeModelRelationship(source *proto.Repository, repository *Reposi
|
||||
pipePortRelatedDevice = &GasMixingChamberPort{port: portRelatedDevice.Port, device: gasMixingChamber}
|
||||
switch portRelatedDevice.Port {
|
||||
case proto.Port_A:
|
||||
gasMixingChamber.PortA = &PipePort{port: pipePort, pipe: pipeModel}
|
||||
gasMixingChamber.PortsA = append(gasMixingChamber.PortsA, &PipePort{port: pipePort, pipe: pipeModel})
|
||||
case proto.Port_B:
|
||||
gasMixingChamber.PortB = &PipePort{port: pipePort, pipe: pipeModel}
|
||||
case proto.Port_C:
|
||||
gasMixingChamber.PortC = &PipePort{port: pipePort, pipe: pipeModel}
|
||||
case proto.Port_D:
|
||||
gasMixingChamber.PortD = &PipePort{port: pipePort, pipe: pipeModel}
|
||||
gasMixingChamber.PortsB = append(gasMixingChamber.PortsB, &PipePort{port: pipePort, pipe: pipeModel})
|
||||
}
|
||||
}
|
||||
case proto.DeviceType_DeviceType_CombinationAirConditioner:
|
||||
@ -206,10 +202,10 @@ func buildIscsPipeModelRelationship(source *proto.Repository, repository *Reposi
|
||||
fan.PortB = &PipePort{port: pipePort, pipe: pipeModel}
|
||||
}
|
||||
}
|
||||
case proto.DeviceType_DeviceType_GasEnvironment:
|
||||
case proto.DeviceType_DeviceType_Environment:
|
||||
{
|
||||
gasEnvironment := relatedDevice.(*GasEnvironment)
|
||||
pipePortRelatedDevice = &GasEnvironmentPort{port: portRelatedDevice.Port, device: gasEnvironment}
|
||||
gasEnvironment := relatedDevice.(*Environment)
|
||||
pipePortRelatedDevice = &EnvironmentPort{port: portRelatedDevice.Port, device: gasEnvironment}
|
||||
switch portRelatedDevice.Port {
|
||||
case proto.Port_A:
|
||||
gasEnvironment.PortsA = append(gasEnvironment.PortsA, &PipePort{port: pipePort, pipe: pipeModel})
|
||||
|
||||
33
sys/cbtc_sys/train_run_control.go
Normal file
33
sys/cbtc_sys/train_run_control.go
Normal file
@ -0,0 +1,33 @@
|
||||
package cbtc_sys
|
||||
|
||||
import (
|
||||
"github.com/yohamta/donburi"
|
||||
"joylink.club/ecs"
|
||||
"joylink.club/ecs/filter"
|
||||
"joylink.club/rtsssimulation/component"
|
||||
)
|
||||
|
||||
// 列车运行控制组件，给列车增加限制组件
|
||||
type TrainRunControlSys struct {
|
||||
trainQuery *ecs.Query
|
||||
}
|
||||
|
||||
func NewTrainRunControlSys() *TrainRunControlSys {
|
||||
return &TrainRunControlSys{
|
||||
trainQuery: ecs.NewQuery(filter.Contains(component.TrainRunStatusType)),
|
||||
}
|
||||
}
|
||||
|
||||
func (sls *TrainRunControlSys) Update(w ecs.World) {
|
||||
sls.trainQuery.Each(w, func(e *donburi.Entry) {
|
||||
runStatus := component.TrainRunStatusType.Get(e)
|
||||
headDevice := runStatus.HeadPosition.Device
|
||||
// 限速赋值
|
||||
if headDevice.HasComponent(component.SpeedLimitType) { // 车头所在设备有限速组件
|
||||
speedLimit := component.SpeedLimitType.Get(headDevice)
|
||||
runStatus.SpeedMax = speedLimit.Val
|
||||
} else {
|
||||
runStatus.SpeedMax = component.TrainSpeedMax
|
||||
}
|
||||
})
|
||||
}
|
||||
@ -13,17 +13,14 @@ type AirConditionerSystem struct {
|
||||
|
||||
func NewAirConditionerSystem() *AirConditionerSystem {
|
||||
return &AirConditionerSystem{
|
||||
query: ecs.NewQuery(filter.Contains(component.UidType, component.MotorType, component.AirConditioningType, component.FluidDriverType)),
|
||||
query: ecs.NewQuery(filter.Contains(component.UidType, component.MotorType, component.AirConditioningType)),
|
||||
}
|
||||
}
|
||||
func (s *AirConditionerSystem) Update(w ecs.World) {
|
||||
s.query.Each(w, func(entry *ecs.Entry) {
|
||||
motor := component.MotorType.Get(entry)
|
||||
fluidDriver := component.FluidDriverType.Get(entry)
|
||||
air := component.AirConditioningType.Get(entry)
|
||||
//
|
||||
air.Running = motor.Speed > 0
|
||||
fluidDriver.On = air.Running
|
||||
fluidDriver.Forward = motor.Forward
|
||||
})
|
||||
}
|
||||
|
||||
@ -50,6 +50,5 @@ func (s *FanSystem) Update(w ecs.World) {
|
||||
}
|
||||
//
|
||||
fluidDriver.On = fan.Speed > 0
|
||||
fluidDriver.Forward = fan.Forward
|
||||
})
|
||||
}
|
||||
|
||||
@ -8,12 +8,15 @@ import (
|
||||
"joylink.club/rtsssimulation/entity"
|
||||
"joylink.club/rtsssimulation/repository"
|
||||
"joylink.club/rtsssimulation/repository/model/proto"
|
||||
"log/slog"
|
||||
)
|
||||
|
||||
// FluidDriverSystem 流体驱动系统
|
||||
// 实现流体在设备、管线中流动
|
||||
// 流体驱动源(风机、送风亭、泵)
|
||||
type FluidDriverSystem struct {
|
||||
query *ecs.Query
|
||||
query *ecs.Query //流体驱动源
|
||||
drivePathMap map[string][]*SearchedPath //key pipePortId,value 驱动源驱动流体的路径
|
||||
}
|
||||
|
||||
func NewFluidDriverSystem() *FluidDriverSystem {
|
||||
@ -22,30 +25,275 @@ func NewFluidDriverSystem() *FluidDriverSystem {
|
||||
}
|
||||
}
|
||||
|
||||
// 流体驱动系统依赖的数据
|
||||
type fluidDriverModel interface {
|
||||
Outputs() []repository.DevicePort
|
||||
Inputs() []repository.DevicePort
|
||||
// 获取流体流动路径
|
||||
func (s *FluidDriverSystem) findFluidPath(fromDevice repository.Identity, fromDevicePortPipe repository.PipePort, fromIsStart bool) []*SearchedPath {
|
||||
pipePortId := fromDevicePortPipe.PipePortId()
|
||||
sp, ok := s.drivePathMap[pipePortId]
|
||||
if !ok {
|
||||
sp = newFluidDriverPathSearcher(fromDevice, fromDevicePortPipe, fromIsStart).search()
|
||||
s.drivePathMap[pipePortId] = sp
|
||||
}
|
||||
return sp
|
||||
}
|
||||
|
||||
func (s *FluidDriverSystem) Update(w ecs.World) {
|
||||
wd := entity.GetWorldData(w)
|
||||
s.query.Each(w, func(entry *ecs.Entry) {
|
||||
fdId := component.UidType.Get(entry).Id
|
||||
fd := component.FluidDriverType.Get(entry)
|
||||
fdModel, fdModelOk := wd.Repo.FindById(fdId).(fluidDriverModel)
|
||||
if !fdModelOk {
|
||||
fmt.Printf("==>>FluidDriverSystem.Update FluidDriver[%s]未实现接口fluidDriverModel\n", fdId)
|
||||
fluidDriverOn := fd.On
|
||||
fdModel := wd.Repo.FindById(fdId)
|
||||
if fdModel == nil {
|
||||
fmt.Printf("==>>FluidDriver[%s]模型不存在\n", fdId)
|
||||
} else {
|
||||
s.fluidDrive(entry, fd, fdModel)
|
||||
switch fdModel.Type() {
|
||||
case proto.DeviceType_DeviceType_Fan: //风机
|
||||
{
|
||||
fanModel := fdModel.(*repository.Fan)
|
||||
fanOutPort := *fanModel.PortA
|
||||
fanInPort := *fanModel.PortB
|
||||
fanOutPath := s.findFluidPath(fanModel, fanOutPort, true)
|
||||
fanInPath := s.findFluidPath(fanModel, fanInPort, false)
|
||||
//
|
||||
_ = fanOutPath
|
||||
_ = fanInPath
|
||||
_ = fluidDriverOn
|
||||
}
|
||||
})
|
||||
}
|
||||
func (s *FluidDriverSystem) fluidDrive(entry *ecs.Entry, fd *component.FluidDriver, fdModel fluidDriverModel) {
|
||||
for _, out := range fdModel.Outputs() {
|
||||
switch out.Device().Type() {
|
||||
case proto.DeviceType_DeviceType_Pipe:
|
||||
case proto.DeviceType_DeviceType_AirPavilion: //风亭，其中送风亭为动力源
|
||||
|
||||
}
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
// 计算流体在管线中的流动参数
|
||||
func (s *FluidDriverSystem) calculateFluid(fluidDriverOn bool, outPath []*SearchedPath, inPath []*SearchedPath) {
|
||||
|
||||
}
|
||||
|
||||
// 判断路径是否畅通
|
||||
func (s *FluidDriverSystem) isFluidPathUnblocked(fp *SearchedPath, w ecs.World) bool {
|
||||
for i := 0; i < len(fp.ViaPipes); i++ {
|
||||
viaPipe := fp.ViaPipes[i]
|
||||
viaDevice := viaPipe.Device().(*repository.Pipe).PortDevice(viaPipe.Port())
|
||||
switch viaDevice.Device().Type() {
|
||||
case proto.DeviceType_DeviceType_Environment: //默认畅通
|
||||
case proto.DeviceType_DeviceType_PipeFitting: //默认畅通
|
||||
case proto.DeviceType_DeviceType_AirPurificationDevice: //默认畅通
|
||||
case proto.DeviceType_DeviceType_GasMixingChamber: //默认畅通
|
||||
case proto.DeviceType_DeviceType_Valve:
|
||||
if s.getValveOpenRate(w, viaDevice.Device().Id()) <= 0 { //阀门未开，路径阻塞
|
||||
return false
|
||||
}
|
||||
case proto.DeviceType_DeviceType_CombinationAirConditioner:
|
||||
if !s.isCombinationAirConditionerRunning(w, viaDevice.Device().Id()) { //组合式空调未开，路径阻塞
|
||||
return false
|
||||
}
|
||||
}
|
||||
}
|
||||
return true
|
||||
}
|
||||
|
||||
// 组合式空调是否在运行
|
||||
func (s *FluidDriverSystem) isCombinationAirConditionerRunning(w ecs.World, id string) bool {
|
||||
wd := entity.GetWorldData(w)
|
||||
entry, ok := wd.EntityMap[id]
|
||||
if ok {
|
||||
air := component.AirConditioningType.Get(entry)
|
||||
return air.Running
|
||||
} else {
|
||||
slog.Warn(fmt.Sprintf("World中未找到组合式空调[%s]的实体", id))
|
||||
}
|
||||
|
||||
return false
|
||||
}
|
||||
|
||||
// 获取阀门开度
|
||||
func (s *FluidDriverSystem) getValveOpenRate(w ecs.World, valveId string) uint8 {
|
||||
wd := entity.GetWorldData(w)
|
||||
entry, ok := wd.EntityMap[valveId]
|
||||
if ok {
|
||||
return component.ValveType.Get(entry).OpenRate
|
||||
} else {
|
||||
slog.Warn(fmt.Sprintf("World中未找到阀门[%s]的实体", valveId))
|
||||
}
|
||||
return 0
|
||||
}
|
||||
|
||||
//////////////////////////流体路径相关/////////////////////////////
|
||||
|
||||
type SearchedPath struct {
|
||||
ViaPipes []repository.PipePort //路径所经过的有向管线
|
||||
}
|
||||
type fluidDriverPathSearcher struct {
|
||||
fromDevice repository.Identity //起点设备
|
||||
fromDevicePortPipe repository.PipePort //从起点设备的某个端口连接的管线的某个端口开始
|
||||
fromIsStart bool //true-以设备输出口为起点；false-以设备输入口为起点
|
||||
searchedPaths []*fluidPath //搜索到的路径
|
||||
excludePipeIds []string //排除经过这些管线的路径
|
||||
}
|
||||
|
||||
func newFluidDriverPathSearcher(fromDevice repository.Identity, fromDevicePortPipe repository.PipePort, fromIsStart bool) *fluidDriverPathSearcher {
|
||||
return &fluidDriverPathSearcher{fromDevice: fromDevice, fromDevicePortPipe: fromDevicePortPipe, fromIsStart: fromIsStart}
|
||||
}
|
||||
|
||||
func (s *fluidDriverPathSearcher) search() []*SearchedPath {
|
||||
var rt []*SearchedPath
|
||||
if !s.exclude(s.fromDevicePortPipe.Device().Id()) {
|
||||
searchContext := &fluidPath{}
|
||||
searchContext.addPipe(s.fromDevicePortPipe)
|
||||
s.doSearch(searchContext)
|
||||
} else {
|
||||
return rt
|
||||
}
|
||||
//
|
||||
for _, fp := range s.searchedPaths {
|
||||
fpLen := len(fp.viaPipes)
|
||||
path := &SearchedPath{}
|
||||
if !s.fromIsStart { //以输入口为起点，须反转搜索结果
|
||||
for i := fpLen - 1; i >= 0; i-- {
|
||||
viaPipe := fp.viaPipes[i]
|
||||
path.ViaPipes = append(path.ViaPipes, viaPipe.ToOtherPort())
|
||||
}
|
||||
} else {
|
||||
for _, viaPipe := range fp.viaPipes {
|
||||
path.ViaPipes = append(path.ViaPipes, viaPipe)
|
||||
}
|
||||
}
|
||||
rt = append(rt, path)
|
||||
}
|
||||
|
||||
//
|
||||
return rt
|
||||
}
|
||||
|
||||
func (s *fluidDriverPathSearcher) exclude(pipeId string) bool {
|
||||
for _, excludePipeId := range s.excludePipeIds {
|
||||
if excludePipeId == pipeId {
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
func (s *fluidDriverPathSearcher) addSearchedPath(searchContext *fluidPath) {
|
||||
s.searchedPaths = append(s.searchedPaths, searchContext)
|
||||
}
|
||||
|
||||
// 递归搜索
|
||||
func (s *fluidDriverPathSearcher) doSearch(searchContext *fluidPath) {
|
||||
nextViaPipes := searchContext.nextViaPathPipes()
|
||||
lenNextPipes := len(nextViaPipes)
|
||||
if lenNextPipes == 0 {
|
||||
s.addSearchedPath(searchContext)
|
||||
} else if lenNextPipes == 1 {
|
||||
if !searchContext.viaPipe(nextViaPipes[0].Device().Id()) && !s.exclude(nextViaPipes[0].Device().Id()) {
|
||||
searchContext.addPipe(nextViaPipes[0])
|
||||
s.doSearch(searchContext)
|
||||
}
|
||||
} else {
|
||||
for _, nextViaPipe := range nextViaPipes {
|
||||
if searchContext.viaPipe(nextViaPipe.Device().Id()) { //舍弃回头路径
|
||||
continue
|
||||
}
|
||||
if s.exclude(nextViaPipe.Device().Id()) { //舍弃排除路径
|
||||
continue
|
||||
}
|
||||
//
|
||||
cp := searchContext.clone()
|
||||
cp.addPipe(nextViaPipe)
|
||||
s.doSearch(cp)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (p *fluidPath) nextViaPathPipes() []repository.PipePort {
|
||||
nextDevice := p.nextDevice()
|
||||
switch nextDevice.Type() {
|
||||
case proto.DeviceType_DeviceType_PipeFitting:
|
||||
return p.nextDeviceViaPipes(nextDevice.(*repository.PipeFitting).Ports(), p.curPipe)
|
||||
case proto.DeviceType_DeviceType_Valve:
|
||||
return p.nextDeviceViaPipes(nextDevice.(*repository.Valve).Ports(), p.curPipe)
|
||||
case proto.DeviceType_DeviceType_GasMixingChamber:
|
||||
return p.nextGasMixingChamberViaPipes(nextDevice.(*repository.GasMixingChamber), p.curPipe)
|
||||
case proto.DeviceType_DeviceType_CombinationAirConditioner:
|
||||
return p.nextCombinationAirConditionerViaPipes(nextDevice.(*repository.CombinationAirConditioner), p.curPipe)
|
||||
case proto.DeviceType_DeviceType_AirPurificationDevice:
|
||||
return p.nextDeviceViaPipes(nextDevice.(*repository.AirPurificationDevice).Ports(), p.curPipe)
|
||||
default:
|
||||
slog.Warn("管线路径中的设备[%d]无法处理", nextDevice.Type())
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
///////////////////////////////////////////////////////////////////////////////////////////
|
||||
|
||||
func (p *fluidPath) nextDeviceViaPipes(deviceAllPipePorts []*repository.PipePort, preViaPipe repository.PipePort) []repository.PipePort {
|
||||
var rt []repository.PipePort
|
||||
findPreViaPipe := false
|
||||
for _, pfPort := range deviceAllPipePorts {
|
||||
if preViaPipe.Device().Id() != pfPort.Device().Id() {
|
||||
rt = append(rt, *pfPort)
|
||||
} else {
|
||||
findPreViaPipe = true
|
||||
}
|
||||
}
|
||||
if !findPreViaPipe { //校验数据
|
||||
panic("preViaPipe没有与设备连接")
|
||||
}
|
||||
return rt
|
||||
}
|
||||
|
||||
// 组合式空调
|
||||
func (p *fluidPath) nextCombinationAirConditionerViaPipes(nextDevice *repository.CombinationAirConditioner, preViaPipe repository.PipePort) []repository.PipePort {
|
||||
var rt []repository.PipePort
|
||||
if preViaPipe.Device().Id() == nextDevice.PortA.Device().Id() { //从组合式空调的A口进入
|
||||
rt = append(rt, *nextDevice.PortB)
|
||||
if nextDevice.PortC != nil {
|
||||
rt = append(rt, *nextDevice.PortC)
|
||||
}
|
||||
return rt
|
||||
} else if preViaPipe.Device().Id() == nextDevice.PortD.Device().Id() { //从组合式空调的D口进入
|
||||
return rt
|
||||
}
|
||||
return rt
|
||||
}
|
||||
|
||||
// 静压箱
|
||||
func (p *fluidPath) nextGasMixingChamberViaPipes(nextDevice *repository.GasMixingChamber, preViaPipe repository.PipePort) []repository.PipePort {
|
||||
var rt []repository.PipePort
|
||||
if nextDevice.IsInput(preViaPipe.Device().Id()) {
|
||||
for _, out := range nextDevice.PortsB {
|
||||
rt = append(rt, *out)
|
||||
}
|
||||
}
|
||||
return rt
|
||||
}
|
||||
|
||||
type fluidPath struct {
|
||||
curPipe repository.PipePort //路径中当前有向管线
|
||||
viaPipes []repository.PipePort //路径所经过的有向管线
|
||||
}
|
||||
|
||||
func (p *fluidPath) addPipe(viaPipe repository.PipePort) {
|
||||
p.viaPipes = append(p.viaPipes, viaPipe)
|
||||
p.curPipe = viaPipe
|
||||
}
|
||||
func (p *fluidPath) viaPipe(pipeId string) bool {
|
||||
for _, vp := range p.viaPipes {
|
||||
if vp.Device().Id() == pipeId {
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
func (p *fluidPath) clone() *fluidPath {
|
||||
cp := &fluidPath{viaPipes: make([]repository.PipePort, 0, len(p.viaPipes)), curPipe: p.curPipe}
|
||||
copy(cp.viaPipes, p.viaPipes)
|
||||
return cp
|
||||
}
|
||||
func (p *fluidPath) nextDevice() repository.Identity {
|
||||
if p.curPipe.Port() == proto.Port_A {
|
||||
return p.curPipe.Device().(*repository.Pipe).PortB.Device()
|
||||
} else {
|
||||
return p.curPipe.Device().(*repository.Pipe).PortA.Device()
|
||||
}
|
||||
}
|
||||
|
||||
@ -20,6 +20,7 @@ func NewValveSystem() *ValveSystem {
|
||||
query: ecs.NewQuery(filter.Contains(component.UidType, component.ValveType, component.ValveControllerType, component.FixedPositionTransformType)),
|
||||
}
|
||||
}
|
||||
|
||||
func (s *ValveSystem) Update(w ecs.World) {
|
||||
wd := entity.GetWorldData(w)
|
||||
s.query.Each(w, func(entry *ecs.Entry) {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user