joylink/rts-sim-module
6
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

iscs bas 大系统

Browse Source
This commit is contained in:
xzb 2023-12-29 17:00:26 +08:00
parent 8a938a451c
commit 5c169edfbc
13 changed files with 405 additions and 119 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
component/iscs_bas_pipe.go
View File

@ -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-反转
On bool //true-输出流体驱动力；false-未输出流体驱动力
}
var (

2
entity/iscs_bas.go
View File

@ -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
}

2
entity/iscs_load.go
View File

@ -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())
}
//风机

4
proto/src/model.proto
View File

@ -353,8 +353,8 @@ enum DeviceType {
DeviceType_CombinationAirConditioner = 390;
//ISCS 净化装置
DeviceType_AirPurificationDevice = 391;
//ISCS 气体环境(正常空气+有害烟雾)
DeviceType_GasEnvironment = 392;
//ISCS 环境(正常空气、有害烟雾、温度、湿度等)
DeviceType_Environment = 392;
}

117
repository/iscs_bas_dxt.go
View File

@ -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 阀门端口
//
@ -81,11 +91,9 @@ func (p *ValvePort) Device() PortedDevice {
// 有四个端口，ABC三个端口为输入口，D端口为输出口
type GasMixingChamber struct {
Identity
Code string
PortA DevicePort //A端口连接的设备
PortB DevicePort //B端口连接的设备
PortC DevicePort //C端口连接的设备
PortD DevicePort //D端口连接的设备
Code string
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
}

32
repository/iscs_pscada_yc.go
View File

@ -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")
}
}
///////////////////////////////////////////////////

38
repository/model/proto/model.pb.go
View File

@ -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 (

10
repository/repository.go
View File

@ -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)
}

20
repository/repository_iscs.go
View File

@ -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})

5
sys/iscs_sys/iscs_bas_air_conditioner.go
View File

@ -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
})
}

1
sys/iscs_sys/iscs_bas_fan.go
View File

@ -50,6 +50,5 @@ func (s *FanSystem) Update(w ecs.World) {
}
//
fluidDriver.On = fan.Speed > 0
fluidDriver.Forward = fan.Forward
})
}

276
sys/iscs_sys/iscs_bas_fluid.go
View File

@ -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
}
case proto.DeviceType_DeviceType_AirPavilion: //风亭，其中送风亭为动力源
}
}
})
}
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:
// 计算流体在管线中的流动参数
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()
}
}

1
sys/iscs_sys/iscs_bas_valve.go
View File

@ -19,6 +19,7 @@ func NewValveSystem() *ValveSystem {
query: ecs.NewQuery(filter.Contains(component.UidType, component.ValveType, component.ValveControllerType, component.TwoPositionTransformType)),
}
}
func (s *ValveSystem) Update(w ecs.World) {
wd := entity.GetWorldData(w)
s.query.Each(w, func(entry *ecs.Entry) {