Merge branch 'master' of https://git.code.tencent.com/jl-framework/rtss_simulation
This commit is contained in:
xzb
commit
d9a9349cb7
@ -2,34 +2,35 @@ syntax = "proto3";
|
||||
|
||||
package message;
|
||||
|
||||
option go_package = "./repository/message_proto";
|
||||
|
||||
message Simulation {
|
||||
enum Type {
|
||||
// 城市轨道交通
|
||||
CG = 0;
|
||||
// 国铁
|
||||
GT = 1;
|
||||
}
|
||||
}
|
||||
option go_package = "./repo/dto";
|
||||
|
||||
message Repo {
|
||||
// 仿真类型
|
||||
Simulation.Type simType = 1;
|
||||
string id = 1;
|
||||
oneof data {
|
||||
CG cg = 2;
|
||||
GT gt = 3;
|
||||
CGData cgData = 2;
|
||||
GTData gtData = 3;
|
||||
}
|
||||
}
|
||||
|
||||
// 国铁数据
|
||||
message GT {
|
||||
message GTData {
|
||||
|
||||
}
|
||||
|
||||
// 列车运行方向(Train Running Direction)
|
||||
enum TRD {
|
||||
// 上行
|
||||
Upward = 0;
|
||||
// 下行
|
||||
Downward = 1;
|
||||
}
|
||||
|
||||
// 城轨数据
|
||||
message CG {
|
||||
message CGData {
|
||||
// 线路数据
|
||||
repeated Line lines = 1;
|
||||
// 监控盘(IBP/PSL/MKX等)数据,线路相关数据会引用这里
|
||||
repeated JKP jkps = 2;
|
||||
}
|
||||
|
||||
// 城轨线路数据
|
||||
@ -37,62 +38,90 @@ message Line {
|
||||
// 所在城市
|
||||
string city = 1;
|
||||
// 线路编号
|
||||
int32 lineId = 2;
|
||||
string lineId = 2;
|
||||
// 信号布置
|
||||
XHBZ xhbz = 3;
|
||||
// 继电器柜布置
|
||||
repeated CiJDQBZ jdqbz = 4;
|
||||
}
|
||||
// 信号布置数据
|
||||
message XHBZ {
|
||||
// 数据id
|
||||
string gid = 1;
|
||||
string id = 1;
|
||||
// 车站
|
||||
repeated Station stations = 2;
|
||||
// 站台
|
||||
repeated Platform platforms = 3;
|
||||
// 屏蔽门
|
||||
repeated Psd psds = 4;
|
||||
// 物理区段
|
||||
repeated PhysicalSection physicalSections = 5;
|
||||
// 区段
|
||||
repeated Section sections = 5;
|
||||
// 道岔
|
||||
repeated Turnout turnouts = 6;
|
||||
// 检测点
|
||||
repeated DevidingPoint devidingPoints = 7;
|
||||
// 信号机
|
||||
repeated Signal signals = 7;
|
||||
// 应答器
|
||||
repeated Balise balises = 8;
|
||||
repeated Signal signals = 8;
|
||||
// 应答器(欧标)
|
||||
repeated Balise balises = 9;
|
||||
// 停车点
|
||||
repeated ParkingSpot parkingSpots = 9;
|
||||
repeated ParkingSpot parkingSpots = 10;
|
||||
// 坡度
|
||||
repeated Pd pds = 10;
|
||||
repeated Pd pds = 11;
|
||||
// 曲度
|
||||
repeated Qd qds = 11;
|
||||
// 紧急关闭/停车按钮
|
||||
repeated EMP emps = 12;
|
||||
// 发车计时器
|
||||
repeated TDT tdts = 13;
|
||||
repeated Qd qds = 12;
|
||||
// 紧急关闭(停车)按钮
|
||||
repeated EMP emps = 13;
|
||||
// 发车计时器(Train Depart Timer,TDT 或 Depart Time Indicator,DTI)
|
||||
repeated TDT tdts = 14;
|
||||
// 门控箱
|
||||
repeated Mkx mkxs = 14;
|
||||
repeated Mkx mkxs = 15;
|
||||
// 就地控制盘
|
||||
repeated PSL psls = 15;
|
||||
repeated PSL psls = 16;
|
||||
// 人员防护开关
|
||||
repeated SPKS spks = 16;
|
||||
repeated SPKS spks = 17;
|
||||
// 设备电子元件组合
|
||||
repeated DeviceEcc deviceEccs = 18;
|
||||
}
|
||||
// 人员防护开关
|
||||
message SPKS {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 关联站台id
|
||||
uint32 platformId = 3;
|
||||
}
|
||||
// 就地控制盘
|
||||
message PSL {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 关联屏蔽门id
|
||||
uint32 psdId = 3;
|
||||
}
|
||||
// 门控箱
|
||||
message Mkx {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 关联屏蔽门id
|
||||
uint32 psdId = 3;
|
||||
}
|
||||
// 发车计时器
|
||||
message TDT {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 关联站台id
|
||||
uint32 platformId = 3;
|
||||
}
|
||||
// 紧急关闭/停车按钮
|
||||
message EMP {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 关联站台id
|
||||
uint32 platformId = 3;
|
||||
}
|
||||
// 曲度
|
||||
message Qd {
|
||||
@ -105,37 +134,63 @@ message Pd {
|
||||
// 停车点
|
||||
message ParkingSpot {
|
||||
uint32 id = 1;
|
||||
// 列车编组数量
|
||||
uint32 tgn = 2;
|
||||
// 公里标
|
||||
GLB glb = 3;
|
||||
}
|
||||
// 应答器
|
||||
message Balise {
|
||||
uint32 id = 1;
|
||||
}
|
||||
//区段检测点
|
||||
message CheckPoint{
|
||||
// 检测点类型
|
||||
// 应答器类型
|
||||
enum Type {
|
||||
Boundary = 0; //区段边界
|
||||
JZ = 1; //计轴器
|
||||
JYJ = 2; //绝缘节
|
||||
// 无源应答器
|
||||
FB = 0;
|
||||
// 有源应答器
|
||||
TB = 1;
|
||||
}
|
||||
uint32 id = 1;
|
||||
// 检测点类型
|
||||
// 应答器类型
|
||||
Type type = 2;
|
||||
// 应答器编号
|
||||
string code = 3;
|
||||
// 所属设备集中站id
|
||||
uint32 ecsId = 4;
|
||||
}
|
||||
//区段分界点
|
||||
message DevidingPoint {
|
||||
// 区段分界点类型
|
||||
enum Type {
|
||||
//区段边界
|
||||
Boundary = 0;
|
||||
//计轴器
|
||||
JZ = 1;
|
||||
//绝缘节
|
||||
JYJ = 2;
|
||||
}
|
||||
uint32 id = 1;
|
||||
// 区段分界点类型
|
||||
Type type = 2;
|
||||
// 区段分界点编号
|
||||
string code = 3;
|
||||
// 公里标
|
||||
GLB glb = 3;
|
||||
// 关联的物理区段/道岔端口
|
||||
repeated DevicePort devicePorts = 4;
|
||||
GLB glb = 4;
|
||||
// 关联的物理区段/道岔端点
|
||||
repeated SectionPort sectionPorts = 5;
|
||||
// 所属设备集中站id
|
||||
repeated uint32 ecsIds = 6;
|
||||
}
|
||||
// 设备
|
||||
message Device {
|
||||
// 设备类型
|
||||
enum Type {
|
||||
// 错误未知类型
|
||||
Unknown = 0;
|
||||
// 区段
|
||||
Section = 0;
|
||||
Section = 1;
|
||||
// 道岔
|
||||
Turnout = 1;
|
||||
Turnout = 2;
|
||||
// 信号机
|
||||
Signal = 2;
|
||||
Signal = 3;
|
||||
}
|
||||
// 设备端点(区段、道岔)
|
||||
enum Port {
|
||||
@ -149,35 +204,128 @@ message Device {
|
||||
Type type = 2;
|
||||
}
|
||||
|
||||
// 设备端点
|
||||
message DevicePort {
|
||||
// 设备id
|
||||
uint32 id = 1;
|
||||
// 设备类型
|
||||
Device.Type type = 2;
|
||||
// 设备端
|
||||
Device.Port port = 3;
|
||||
// 区段端点
|
||||
message SectionPort {
|
||||
// 区段类型
|
||||
enum SectionType {
|
||||
// 区段
|
||||
Section = 0;
|
||||
// 道岔
|
||||
Turnout = 1;
|
||||
}
|
||||
// 端点类型
|
||||
enum PortType {
|
||||
A = 0;
|
||||
B = 1;
|
||||
C = 2;
|
||||
}
|
||||
// 类型
|
||||
SectionType type = 1;
|
||||
// 区段/道岔 id
|
||||
uint32 id = 2;
|
||||
// 端点
|
||||
PortType port = 3;
|
||||
}
|
||||
// 信号机
|
||||
message Signal {
|
||||
// 信号机模型型号
|
||||
enum Model {
|
||||
HLU = 0;
|
||||
// 红绿黄三显示信号机
|
||||
// 红绿黄三显示引导为红黄
|
||||
// 红绿黄三显示,不封,有单黄,有引导
|
||||
HLU_0_1_1 = 0;
|
||||
// 红绿黄三显示,不封,无单黄,有引导
|
||||
HLU_0_0_1 = 1;
|
||||
// 红绿黄三显示,不封,有单黄,无引导
|
||||
HLU_0_1_0 = 2;
|
||||
// 红绿黄三显示,封黄,无单黄,有引导
|
||||
HLU_U_0_0 = 3;
|
||||
// 红绿黄三显示,封绿,有单黄,有引导
|
||||
HLU_L_1_1 = 4;
|
||||
// 红绿黄三显示,封绿,有单黄,无引导
|
||||
HLU_L_1_0 = 5;
|
||||
// 红绿黄三显示,全封
|
||||
HLU_LU_0_0 = 6;
|
||||
// 红绿二显示信号机
|
||||
// 红绿二显示,不封
|
||||
HL_0 = 7;
|
||||
// 红绿二显示,封绿
|
||||
HL_L = 8;
|
||||
// 红黄二显示,不封
|
||||
HU_0 = 9;
|
||||
// 红黄二显示,封黄
|
||||
HU_U = 10;
|
||||
// 单红显示信号机
|
||||
H = 11;
|
||||
// 蓝白二显示信号机
|
||||
AB = 12;
|
||||
// 红白黄三显示信号机
|
||||
// 红白黄三显示,不封,有单黄,无引导
|
||||
HBU_0_1_0 = 13;
|
||||
// 红白黄三显示,封黄,无单黄,无引导
|
||||
HBU_U_0_0 = 14;
|
||||
}
|
||||
uint32 id = 1;
|
||||
// 信号机编号
|
||||
string code = 2;
|
||||
// 信号机模型型号
|
||||
Model model = 3;
|
||||
// 所属设备集中站id
|
||||
uint32 ecsId = 4;
|
||||
}
|
||||
// 道岔
|
||||
message Turnout {
|
||||
// 道岔模型型号
|
||||
enum Model {
|
||||
// ZDJ9单机牵引
|
||||
ZDJ9_1 = 0;
|
||||
// ZDJ9双机牵引
|
||||
ZDJ9_2 = 1;
|
||||
}
|
||||
uint32 id = 1;
|
||||
// 道岔编号
|
||||
string code = 2;
|
||||
// 道岔模型型号
|
||||
Model model = 3;
|
||||
// 道岔A端关联的区段/道岔端点
|
||||
SectionPort asp = 4;
|
||||
// 道岔B端关联的区段/道岔端点
|
||||
SectionPort bsp = 5;
|
||||
// 道岔C端关联的区段/道岔端点
|
||||
SectionPort csp = 6;
|
||||
// 所属设备集中站id
|
||||
uint32 ecsId = 7;
|
||||
}
|
||||
// 物理区段
|
||||
message PhysicalSection {
|
||||
message Section {
|
||||
// 物理区段类型
|
||||
enum Type {
|
||||
// 一般物理区段
|
||||
Physical = 0;
|
||||
// 道岔物理区段
|
||||
TurnoutPhysical = 1;
|
||||
// 逻辑区段
|
||||
Logical = 2;
|
||||
}
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 物理区段类型
|
||||
Type type = 3;
|
||||
// 物理区段A端关联的区段/道岔端点
|
||||
SectionPort asp = 4;
|
||||
// 物理区段B端关联的区段/道岔端点
|
||||
SectionPort bsp = 5;
|
||||
// 所属设备集中站id
|
||||
uint32 ecsId = 6;
|
||||
}
|
||||
// 屏蔽门
|
||||
message Psd {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 关联的站台
|
||||
uint32 platformId = 3;
|
||||
}
|
||||
//站台
|
||||
message Platform {
|
||||
@ -196,8 +344,14 @@ message Station {
|
||||
string name = 2;
|
||||
// 车站站名
|
||||
string zname = 3;
|
||||
// 车站公里标(站台中心点)
|
||||
// 车站公里标
|
||||
GLB glb = 4;
|
||||
// 是否设备集中站(Equipment centralized station)
|
||||
bool isEcs = 5;
|
||||
// 是否停车场/车辆段
|
||||
bool isCd = 6;
|
||||
// 集中站关联下属车站
|
||||
repeated uint32 ecsStationIds = 7;
|
||||
}
|
||||
//公里标
|
||||
message GLB {
|
||||
@ -211,21 +365,21 @@ message GLB {
|
||||
|
||||
|
||||
// 联锁设备布置数据
|
||||
message CiSBBZ {
|
||||
message CiJDQBZ {
|
||||
// 设备集中站uid
|
||||
string ecsId = 1;
|
||||
string ecsName = 1;
|
||||
// 继电器
|
||||
repeated Relay relays = 2;
|
||||
// 断相保护器
|
||||
repeated PFP pfps = 3;
|
||||
// 设备电气组合组
|
||||
repeated DeviceEcc deviceEcgs = 4;
|
||||
repeated DeviceEcc deviceEcgDatas = 4;
|
||||
// 联锁采集码表
|
||||
repeated CiCjTable cjt = 5;
|
||||
// 联锁驱动码表
|
||||
repeated CiQdTable qdt = 6;
|
||||
// 联锁区段码位表
|
||||
repeated string sectionIds = 7;
|
||||
repeated uint32 sectionIds = 7;
|
||||
}
|
||||
// 联锁区段码位表
|
||||
message CiSectionTable {
|
||||
@ -234,17 +388,18 @@ message CiSectionTable {
|
||||
}
|
||||
// 联锁驱动码表
|
||||
message CiQdTable {
|
||||
// 继电器id
|
||||
repeated uint32 relayIds = 1;
|
||||
// 继电器id(按位顺序排列)
|
||||
repeated string relayIds = 1;
|
||||
}
|
||||
// 联锁采集码表
|
||||
message CiCjTable {
|
||||
// 采集继电器接点(按位顺序排列)
|
||||
repeated CiCjItem items = 1;
|
||||
}
|
||||
// 联锁采集项
|
||||
message CiCjItem {
|
||||
// 继电器id
|
||||
uint32 relayId = 1;
|
||||
string uint32 = 1;
|
||||
// 采集继电器前后接点(前接点为吸起/定位),true-前接点,false-后接点
|
||||
bool q = 2;
|
||||
}
|
||||
@ -275,21 +430,27 @@ message Relay {
|
||||
}
|
||||
// 按钮、灯等监控盘(IBP/门控箱/PSL等)
|
||||
message JKP {
|
||||
// 监控盘类型
|
||||
enum Type {
|
||||
// IBP盘(综合后备盘)
|
||||
IBP = 0;
|
||||
// 屏蔽门就地控制盘
|
||||
PSL = 1;
|
||||
// 门控箱
|
||||
MKX = 2;
|
||||
}
|
||||
// 数据id
|
||||
uint32 gid = 1;
|
||||
string gid = 1;
|
||||
// 数据类型
|
||||
Type type = 2;
|
||||
// 开关
|
||||
repeated KaiGuan kgs = 2;
|
||||
repeated KaiGuan kgs = 3;
|
||||
// 灯
|
||||
repeated Lamp lamps = 3;
|
||||
repeated Lamp lamps = 4;
|
||||
// 警铃
|
||||
repeated Alarm alarms = 4;
|
||||
repeated Alarm alarms = 5;
|
||||
// 设备电子元件组合
|
||||
repeated DeviceEcc deviceEccs = 5;
|
||||
repeated DeviceEcc deviceEccs = 6;
|
||||
}
|
||||
// 警铃/蜂鸣器
|
||||
message Alarm {
|
||||
@ -302,8 +463,10 @@ message KaiGuan {
|
||||
uint32 id = 1;
|
||||
// 编号
|
||||
string code = 2;
|
||||
// 是否自复位
|
||||
bool zfw = 3;
|
||||
// 是否有背光灯
|
||||
bool lamp = 3;
|
||||
bool lamp = 4;
|
||||
}
|
||||
// 灯
|
||||
message Lamp {
|
||||
@ -314,10 +477,10 @@ message Lamp {
|
||||
|
||||
// 设备电子元件组合
|
||||
message DeviceEcc {
|
||||
// 设备编号
|
||||
string deviceCode = 1;
|
||||
// 设备类型
|
||||
Device.Type deviceType = 2;
|
||||
Device.Type deviceType = 1;
|
||||
// 设备编号
|
||||
string deviceCode = 2;
|
||||
// 电子元件组合
|
||||
repeated Ecc ecc = 3;
|
||||
}
|
||||
@ -325,6 +488,6 @@ message DeviceEcc {
|
||||
message Ecc {
|
||||
// 组合名称
|
||||
string code = 1;
|
||||
// 关联的电子元件id
|
||||
// 关联的电子元件(包括但不限于继电器、断相保护器、按钮、灯等)id
|
||||
repeated uint32 ids = 2;
|
||||
}
|
||||
17
repo/api.go
Normal file
17
repo/api.go
Normal file
@ -0,0 +1,17 @@
|
||||
package repo
|
||||
|
||||
import "joylink.club/rtsssimulation/repo/model"
|
||||
|
||||
type Repo interface {
|
||||
// 模型仓库id
|
||||
Id() string
|
||||
// 通过uid查询模型对象
|
||||
FindByUid(uid string) model.Model
|
||||
}
|
||||
|
||||
type IdMap interface {
|
||||
// 获取数据元素id
|
||||
DeId() string
|
||||
// 获取uid
|
||||
Uid() string
|
||||
}
|
||||
23
repo/check_test.go
Normal file
23
repo/check_test.go
Normal file
@ -0,0 +1,23 @@
|
||||
package repo
|
||||
|
||||
import "testing"
|
||||
|
||||
func TestIsFieldEmpty(t *testing.T) {
|
||||
tests := []struct {
|
||||
give any
|
||||
want bool
|
||||
}{
|
||||
{give: nil, want: true},
|
||||
{give: "", want: true},
|
||||
{give: 0, want: true},
|
||||
{give: []string{}, want: true},
|
||||
{give: map[string]string{}, want: true},
|
||||
{give: []int{}, want: true},
|
||||
}
|
||||
|
||||
for _, tt := range tests {
|
||||
if got := isFieldEmpty(tt.give); got != tt.want {
|
||||
t.Errorf("IsFieldEmpty(%v) = %v, want = %v", tt.give, got, tt.want)
|
||||
}
|
||||
}
|
||||
}
|
||||
4239
repo/dto/repo.pb.go
Normal file
4239
repo/dto/repo.pb.go
Normal file
File diff suppressed because it is too large
Load Diff
25
repo/error_record.go
Normal file
25
repo/error_record.go
Normal file
@ -0,0 +1,25 @@
|
||||
package repo
|
||||
|
||||
// 构建错误记录
|
||||
type ErrorRecord struct {
|
||||
// 告警信息
|
||||
Warns []string
|
||||
// 错误信息
|
||||
Errs []string
|
||||
}
|
||||
|
||||
func NewErrorRecord() *ErrorRecord {
|
||||
return &ErrorRecord{}
|
||||
}
|
||||
|
||||
func (r *ErrorRecord) AddError(err string) {
|
||||
r.Errs = append(r.Errs, err)
|
||||
}
|
||||
|
||||
func (r *ErrorRecord) HasError() bool {
|
||||
return len(r.Errs) > 0
|
||||
}
|
||||
|
||||
func (r *ErrorRecord) AddWarn(warn string) {
|
||||
r.Warns = append(r.Warns, warn)
|
||||
}
|
||||
484
repo/idmapping_build.go
Normal file
484
repo/idmapping_build.go
Normal file
@ -0,0 +1,484 @@
|
||||
package repo
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"reflect"
|
||||
"strconv"
|
||||
"strings"
|
||||
|
||||
"joylink.club/rtsssimulation/repo/dto"
|
||||
"joylink.club/rtsssimulation/repo/model"
|
||||
)
|
||||
|
||||
// 城轨uid
|
||||
type CgUid struct {
|
||||
// 城市
|
||||
city string
|
||||
// 线路
|
||||
line string
|
||||
// 设备编号
|
||||
codes []string
|
||||
// codestr
|
||||
codestr string
|
||||
// uid
|
||||
idstr string
|
||||
}
|
||||
|
||||
func NewCgUid(city string, line string, codes ...string) *CgUid {
|
||||
if city == "" || line == "" {
|
||||
panic(fmt.Errorf("创建城轨uid错误: 城市、线路、车站不能为空 city=%s, line=%s", city, line))
|
||||
}
|
||||
l := len(codes)
|
||||
if l == 0 {
|
||||
panic(fmt.Errorf("创建城轨uid错误: codes不能为空"))
|
||||
}
|
||||
codestr := strings.Join(codes, "_")
|
||||
elems := []string{city, line, codestr}
|
||||
uid := strings.Join(elems, "_")
|
||||
return &CgUid{
|
||||
city: city,
|
||||
line: line,
|
||||
codes: codes,
|
||||
codestr: codestr,
|
||||
idstr: uid,
|
||||
}
|
||||
}
|
||||
|
||||
func (u *CgUid) Id() string {
|
||||
return u.idstr
|
||||
}
|
||||
|
||||
func (u *CgUid) Code() string {
|
||||
return u.codestr
|
||||
}
|
||||
|
||||
type idMap struct {
|
||||
// 数据id
|
||||
Did string
|
||||
// 元素id
|
||||
Eid uint32
|
||||
// 唯一id
|
||||
Uid model.Uid
|
||||
}
|
||||
|
||||
func NewIdMap(did string, eid uint32, uid model.Uid) *idMap {
|
||||
return &idMap{
|
||||
Did: did,
|
||||
Eid: eid,
|
||||
Uid: uid,
|
||||
}
|
||||
}
|
||||
|
||||
func (m *idMap) DeId() string {
|
||||
return DeID(m.Did, m.Eid)
|
||||
}
|
||||
func (m *idMap) Debug() string {
|
||||
return fmt.Sprintf("{数据id=%s, 元素id=%v, uid=%s}", m.Did, m.Eid, m.Uid.Id())
|
||||
}
|
||||
|
||||
// 数据元素id key生成
|
||||
// did - 数据id
|
||||
// eid - 元素id
|
||||
func DeID(did string, eid uint32) string {
|
||||
return fmt.Sprintf("%s_%v", did, eid)
|
||||
}
|
||||
|
||||
// id映射表
|
||||
type IdMapping struct {
|
||||
// 数据元素id映射
|
||||
deidMap map[string]*idMap
|
||||
// uid映射(只存储最初的idMap,实际中一个uid可能对应多个数据元素id)
|
||||
uidMap map[string]*idMap
|
||||
}
|
||||
|
||||
func (m *IdMapping) queryByDeId(deid string) *idMap {
|
||||
return m.deidMap[deid]
|
||||
}
|
||||
|
||||
func (m *IdMapping) queryByDidAndEid(did string, eid uint32) *idMap {
|
||||
id := DeID(did, eid)
|
||||
return m.deidMap[id]
|
||||
}
|
||||
|
||||
func (m *IdMapping) add(idmap *idMap) {
|
||||
if idmap == nil {
|
||||
panic(fmt.Errorf("添加id映射表错误: idmap不能为空"))
|
||||
}
|
||||
m.deidMap[idmap.DeId()] = idmap
|
||||
}
|
||||
|
||||
func (m *IdMapping) checkUidAndAdd(idmap *idMap) (existed *idMap, uidExisted bool) {
|
||||
if idmap == nil {
|
||||
panic(fmt.Errorf("添加id映射表错误: idmap不能为空"))
|
||||
}
|
||||
m.deidMap[idmap.DeId()] = idmap
|
||||
existed, ok := m.uidMap[idmap.Uid.Id()]
|
||||
if ok {
|
||||
uidExisted = true
|
||||
} else {
|
||||
m.uidMap[idmap.Uid.Id()] = idmap
|
||||
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 构建id映射
|
||||
func BuildIdMapping(msgs *dto.Repo, errRecord *ErrorRecord) *IdMapping {
|
||||
if cg := msgs.GetCgData(); cg != nil {
|
||||
return BuildCgIdMapping(cg, errRecord)
|
||||
} else if gt := msgs.GetGtData(); gt != nil {
|
||||
return BuildGtIdMapping(gt)
|
||||
}
|
||||
errRecord.AddError("构建id映射表错误: 没有数据")
|
||||
return nil
|
||||
}
|
||||
|
||||
// 构建城轨id映射
|
||||
func BuildCgIdMapping(cg *dto.CGData, errRecord *ErrorRecord) *IdMapping {
|
||||
if cg == nil {
|
||||
errRecord.AddError("构建城轨id映射表错误: 未关联任何数据")
|
||||
return nil
|
||||
}
|
||||
idMapping := &IdMapping{
|
||||
deidMap: make(map[string]*idMap),
|
||||
uidMap: make(map[string]*idMap),
|
||||
}
|
||||
lineSet := make(map[string]struct{})
|
||||
for _, l := range cg.Lines {
|
||||
if _, ok := lineSet[l.City+l.LineId]; ok {
|
||||
errRecord.AddError(fmt.Sprintf("构建城轨id映射表错误: 线路重复:%s_%s", l.City, l.LineId))
|
||||
return nil
|
||||
}
|
||||
lineSet[l.City+l.LineId] = struct{}{}
|
||||
}
|
||||
for _, line := range cg.Lines {
|
||||
buildXhbz(idMapping, line, errRecord)
|
||||
if errRecord.HasError() {
|
||||
return nil
|
||||
}
|
||||
}
|
||||
return idMapping
|
||||
}
|
||||
|
||||
// 构建信号布置数据id映射
|
||||
func buildXhbz(idMapping *IdMapping, line *dto.Line, errRecord *ErrorRecord) {
|
||||
xhbz := line.Xhbz
|
||||
if xhbz == nil {
|
||||
errRecord.AddError("构建城轨id映射表错误: 信号布置数据为空")
|
||||
return
|
||||
}
|
||||
city := line.City // 城市
|
||||
lineId := line.LineId // 线路id
|
||||
did := xhbz.Id // 数据id
|
||||
errPrefix := "信号布置数据错误"
|
||||
// 车站uid
|
||||
for _, station := range xhbz.Stations {
|
||||
eid := station.Id
|
||||
if checkFieldEmpty(did, eid, station.Name, errPrefix, "车站名称", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, station.Name))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 车站站台uid
|
||||
for _, p := range xhbz.Platforms {
|
||||
eid := p.Id
|
||||
if checkFieldEmpty(did, eid, p.Code, errPrefix, "站台编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, p.StationId, errPrefix, "站台关联车站", errRecord) {
|
||||
continue
|
||||
}
|
||||
stationIdm := idMapping.queryByDidAndEid(did, p.StationId)
|
||||
if checkRelationNil(did, eid, p.StationId, stationIdm, errPrefix, "站台关联车站", errRecord) {
|
||||
continue
|
||||
}
|
||||
// 站台code: 车站名称_站台编号
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, stationIdm.Uid.Code(), p.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 屏蔽门uid
|
||||
for _, p := range xhbz.Psds {
|
||||
eid := p.Id
|
||||
if checkFieldEmpty(did, eid, p.Code, errPrefix, "屏蔽门编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, p.PlatformId, errPrefix, "屏蔽门关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, p.PlatformId)
|
||||
if checkRelationNil(did, eid, p.PlatformId, relIdMap, errPrefix, "屏蔽门关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
// 屏蔽门code: 站台编号_屏蔽门编号
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), p.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 物理区段
|
||||
for _, ps := range xhbz.PhysicalSections {
|
||||
eid := ps.Id
|
||||
if checkFieldEmpty(did, eid, ps.Code, errPrefix, "物理区段编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, ps.EcsId, errPrefix, "物理区段关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, ps.EcsId)
|
||||
if checkRelationNil(did, eid, ps.EcsId, relIdMap, errPrefix, "物理区段关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
// 物理区段code: 集中站名称_物理区段编号
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), ps.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 道岔uid
|
||||
for _, t := range xhbz.Turnouts {
|
||||
eid := t.Id
|
||||
if checkFieldEmpty(did, eid, t.Code, errPrefix, "道岔编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, t.EcsId, errPrefix, "道岔关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, t.EcsId)
|
||||
if checkRelationNil(did, eid, t.EcsId, relIdMap, errPrefix, "道岔关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
// 道岔code: 集中站名称_道岔编号
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), t.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 区段分界点uid
|
||||
for _, c := range xhbz.DevidingPoints {
|
||||
eid := c.Id
|
||||
if checkFieldEmpty(did, eid, c.Code, errPrefix, "区段分界点编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, c.EcsIds, errPrefix, "区段分界点关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
ecsErr := false
|
||||
for _, v := range c.EcsIds {
|
||||
relIdMap := idMapping.queryByDidAndEid(did, v)
|
||||
if checkRelationNil(did, eid, v, relIdMap, errPrefix, "区段分界点关联集中站", errRecord) {
|
||||
ecsErr = true
|
||||
continue
|
||||
}
|
||||
}
|
||||
if ecsErr {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, c.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 信号机uid
|
||||
for _, s := range xhbz.Signals {
|
||||
eid := s.Id
|
||||
if checkFieldEmpty(did, eid, s.Code, errPrefix, "信号机编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, s.EcsId, errPrefix, "信号机关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, s.EcsId)
|
||||
if checkRelationNil(did, eid, s.EcsId, relIdMap, errPrefix, "信号机关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), s.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 应答器uid
|
||||
for _, b := range xhbz.Balises {
|
||||
eid := b.Id
|
||||
if checkFieldEmpty(did, eid, b.Code, errPrefix, "应答器编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, b.EcsId, errPrefix, "应答器关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, b.EcsId)
|
||||
if checkRelationNil(did, eid, b.EcsId, relIdMap, errPrefix, "应答器关联集中站", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), b.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 停车点
|
||||
for _, ps := range xhbz.ParkingSpots {
|
||||
idmap := NewIdMap(did, ps.Id, NewCgUid(city, lineId, did, strconv.Itoa(int(ps.Id))))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 坡度
|
||||
for _, v := range xhbz.Pds {
|
||||
idmap := NewIdMap(did, v.Id, NewCgUid(city, lineId, did, strconv.Itoa(int(v.Id))))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 曲度
|
||||
for _, v := range xhbz.Qds {
|
||||
idmap := NewIdMap(did, v.Id, NewCgUid(city, lineId, did, strconv.Itoa(int(v.Id))))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 紧急停车按钮
|
||||
for _, v := range xhbz.Emps {
|
||||
eid := v.Id
|
||||
if checkFieldEmpty(did, eid, v.Code, errPrefix, "紧急停车按钮编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, v.PlatformId, errPrefix, "紧急停车按钮关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, v.PlatformId)
|
||||
if checkRelationNil(did, eid, v.PlatformId, relIdMap, errPrefix, "紧急停车按钮关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), v.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 停车倒计时器
|
||||
for _, v := range xhbz.Tdts {
|
||||
eid := v.Id
|
||||
if checkFieldEmpty(did, eid, v.Code, errPrefix, "停车倒计时器编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, v.PlatformId, errPrefix, "停车倒计时器关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, v.PlatformId)
|
||||
if checkRelationNil(did, eid, v.PlatformId, relIdMap, errPrefix, "停车倒计时器关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), v.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// 门控箱
|
||||
for _, v := range xhbz.Mkxs {
|
||||
eid := v.Id
|
||||
if checkFieldEmpty(did, eid, v.Code, errPrefix, "门控箱编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, v.PsdId, errPrefix, "门控箱关联屏蔽门", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, v.PsdId)
|
||||
if checkRelationNil(did, eid, v.PsdId, relIdMap, errPrefix, "门控箱关联屏蔽门", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), v.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// PSL
|
||||
for _, v := range xhbz.Psls {
|
||||
eid := v.Id
|
||||
if checkFieldEmpty(did, eid, v.Code, errPrefix, "PSL编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, v.PsdId, errPrefix, "PSL关联屏蔽门", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, v.PsdId)
|
||||
if checkRelationNil(did, eid, v.PsdId, relIdMap, errPrefix, "PSL关联屏蔽门", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), v.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
// SPKS
|
||||
for _, v := range xhbz.Spks {
|
||||
eid := v.Id
|
||||
if checkFieldEmpty(did, eid, v.Code, errPrefix, "SPKS编号", errRecord) {
|
||||
continue
|
||||
}
|
||||
if checkFieldEmpty(did, eid, v.PlatformId, errPrefix, "SPKS关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
relIdMap := idMapping.queryByDidAndEid(did, v.PlatformId)
|
||||
if checkRelationNil(did, eid, v.PlatformId, relIdMap, errPrefix, "SPKS关联站台", errRecord) {
|
||||
continue
|
||||
}
|
||||
idmap := NewIdMap(did, eid, NewCgUid(city, lineId, relIdMap.Uid.Code(), v.Code))
|
||||
if checkRepeatOrAddIdMap(idmap, idMapping, errPrefix, errRecord) {
|
||||
continue
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func checkRelationNil(did string, eid uint32, relId uint32, relIdMap *idMap, prefix string, relTip string, errRecord *ErrorRecord) bool {
|
||||
if relIdMap == nil {
|
||||
errRecord.AddError(fmt.Sprintf("%s: %s不存在, 数据id=%s 数据元素id=%v 关联id=%v", prefix, relTip, did, eid, relId))
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
// 检查字段是否为空
|
||||
func checkFieldEmpty(did string, eid uint32, field any, prefix string, tip string, errRecord *ErrorRecord) bool {
|
||||
if isFieldEmpty(field) {
|
||||
errRecord.AddError(fmt.Sprintf("%s: %s不能为空, 数据id=%s 数据元素id=%v ", prefix, tip, did, eid))
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
func isFieldEmpty(field any) bool {
|
||||
if field == nil {
|
||||
return true
|
||||
}
|
||||
vf := reflect.ValueOf(field)
|
||||
switch vf.Kind() {
|
||||
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64,
|
||||
reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64,
|
||||
reflect.Float32, reflect.Float64:
|
||||
return field == 0
|
||||
case reflect.String:
|
||||
return field == ""
|
||||
case reflect.Slice, reflect.Map:
|
||||
return vf.Len() == 0
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
// 数据uid/deid重复检查
|
||||
func checkRepeatOrAddIdMap(idm *idMap, idMapping *IdMapping, prefix string, errRecord *ErrorRecord) (repeated bool) {
|
||||
if old := idMapping.queryByDeId(idm.DeId()); old != nil {
|
||||
errRecord.AddError(fmt.Sprintf("%s,数据元素重复: 数据1=%s 数据2=%s,", prefix, old.Debug(), idm.Debug()))
|
||||
repeated = true
|
||||
} else if old, _ := idMapping.checkUidAndAdd(idm); old != nil {
|
||||
errRecord.AddError(fmt.Sprintf("%s,数据重复: 数据1=%s 数据2=%s,", prefix, old.Debug(), idm.Debug()))
|
||||
repeated = true
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func BuildGtIdMapping(gt *dto.GTData) *IdMapping {
|
||||
panic("未实现")
|
||||
}
|
||||
39
repo/manage.go
Normal file
39
repo/manage.go
Normal file
@ -0,0 +1,39 @@
|
||||
package repo
|
||||
|
||||
import (
|
||||
"sync"
|
||||
|
||||
"joylink.club/rtsssimulation/repo/dto"
|
||||
)
|
||||
|
||||
type repoManager struct {
|
||||
repoMap map[string]Repo
|
||||
lock sync.Mutex
|
||||
}
|
||||
|
||||
var defaultManager = &repoManager{
|
||||
repoMap: make(map[string]Repo),
|
||||
}
|
||||
|
||||
// 获取或构建模型仓库
|
||||
func GetOrBuildRepo(id string, dc func(errRecord *ErrorRecord) *dto.Repo) (Repo, *ErrorRecord) {
|
||||
manager := defaultManager
|
||||
manager.lock.Lock()
|
||||
defer manager.lock.Unlock()
|
||||
r, ok := manager.repoMap[id]
|
||||
errRecord := NewErrorRecord()
|
||||
if !ok {
|
||||
// 所需protobuf数据转换
|
||||
msgs := dc(errRecord)
|
||||
// 数据转换出错直接返回
|
||||
if errRecord.HasError() {
|
||||
return nil, errRecord
|
||||
}
|
||||
// 构建模型Repo
|
||||
r, errRecord = BuildFrom(msgs)
|
||||
if r != nil {
|
||||
manager.repoMap[id] = r
|
||||
}
|
||||
}
|
||||
return r, errRecord
|
||||
}
|
||||
57
repo/model/api.go
Normal file
57
repo/model/api.go
Normal file
@ -0,0 +1,57 @@
|
||||
package model
|
||||
|
||||
type ModelType string
|
||||
|
||||
const (
|
||||
// 车站
|
||||
MT_Station ModelType = "Station"
|
||||
// 站台
|
||||
MT_Stand ModelType = "Stand"
|
||||
// 屏蔽门
|
||||
MT_PSD ModelType = "PSD"
|
||||
// Link
|
||||
MT_Link ModelType = "Link"
|
||||
// 区段
|
||||
MT_Section ModelType = "Section"
|
||||
// 道岔
|
||||
MT_Turnout ModelType = "Turnout"
|
||||
// 信号机
|
||||
MT_Signal ModelType = "Signal"
|
||||
// 应答器
|
||||
MT_Balise ModelType = "Balise"
|
||||
)
|
||||
|
||||
type Uid interface {
|
||||
Id() string
|
||||
// 设备原始编号
|
||||
Code() string
|
||||
}
|
||||
|
||||
// 模型接口
|
||||
type Model interface {
|
||||
// Unique id,唯一id
|
||||
Uid() Uid
|
||||
// 模型类型
|
||||
Type() ModelType
|
||||
}
|
||||
|
||||
// Link
|
||||
type Link interface {
|
||||
Model
|
||||
}
|
||||
|
||||
// 物理区段(实际检测区段,一般区段两端点,道岔区段为3-4个端点)
|
||||
type PhysicalSection interface {
|
||||
Model
|
||||
Code() string
|
||||
}
|
||||
|
||||
// 道岔
|
||||
type Turnout interface {
|
||||
Model
|
||||
}
|
||||
|
||||
// 关联的端口关系
|
||||
type AssociatedPort interface {
|
||||
Port() string
|
||||
}
|
||||
52
repo/model/impl/link.go
Normal file
52
repo/model/impl/link.go
Normal file
@ -0,0 +1,52 @@
|
||||
package impl
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"sync/atomic"
|
||||
|
||||
"joylink.club/rtsssimulation/repo/dto"
|
||||
"joylink.club/rtsssimulation/repo/model"
|
||||
)
|
||||
|
||||
// link生成uid基础值
|
||||
var link_uid_base = atomic.Uint32{}
|
||||
|
||||
// 轨道链路
|
||||
type Link struct {
|
||||
uid string
|
||||
|
||||
apTurnout *Turnout // A端关联道岔,可能为nil
|
||||
bpTurnout *Turnout // B端关联道岔,可能为nil
|
||||
apGlb dto.GLB // A端公里标
|
||||
bpGlb dto.GLB // B端公里标
|
||||
length int64 // 长度
|
||||
models []model.Model // 关联的模型,从A到B排序
|
||||
physicalSections []*PhysicalSection // 关联的物理区段(包含道岔物理区段),从A到B排序
|
||||
}
|
||||
|
||||
func NewLink() *Link {
|
||||
return &Link{
|
||||
uid: fmt.Sprintf("%d", link_uid_base.Add(1)),
|
||||
}
|
||||
}
|
||||
|
||||
func (l *Link) Uid() string {
|
||||
return l.uid
|
||||
}
|
||||
|
||||
func (l *Link) Type() model.ModelType {
|
||||
return model.MT_Link
|
||||
}
|
||||
|
||||
// link偏移
|
||||
type LinkOffset struct {
|
||||
link *Link
|
||||
offset int64
|
||||
}
|
||||
|
||||
// link偏移范围
|
||||
type LinkRange struct {
|
||||
link *Link
|
||||
start int64
|
||||
end int64
|
||||
}
|
||||
33
repo/model/impl/physical_section.go
Normal file
33
repo/model/impl/physical_section.go
Normal file
@ -0,0 +1,33 @@
|
||||
package impl
|
||||
|
||||
import (
|
||||
"joylink.club/rtsssimulation/repo/model"
|
||||
)
|
||||
|
||||
type PhysicalSection struct {
|
||||
uid string
|
||||
code string
|
||||
|
||||
apSection model.Model // A端关联区段/道岔
|
||||
bpSection model.Model // B端关联区段/道岔
|
||||
linkRanges []*LinkRange // 所属link范围(道岔物理区段为多个)
|
||||
}
|
||||
|
||||
func NewPhysicalSection(uid string, code string) *PhysicalSection {
|
||||
return &PhysicalSection{
|
||||
uid: uid,
|
||||
code: code,
|
||||
}
|
||||
}
|
||||
|
||||
func (s *PhysicalSection) Uid() string {
|
||||
return s.uid
|
||||
}
|
||||
|
||||
func (s *PhysicalSection) Type() model.ModelType {
|
||||
return model.MT_Section
|
||||
}
|
||||
|
||||
func (s *PhysicalSection) Code() string {
|
||||
return s.code
|
||||
}
|
||||
6
repo/model/impl/section_check_device.go
Normal file
6
repo/model/impl/section_check_device.go
Normal file
@ -0,0 +1,6 @@
|
||||
package impl
|
||||
|
||||
// 区段分段设备(计轴/绝缘节)
|
||||
type SectionDividedDevice struct {
|
||||
uid string
|
||||
}
|
||||
29
repo/model/impl/turnout.go
Normal file
29
repo/model/impl/turnout.go
Normal file
@ -0,0 +1,29 @@
|
||||
package impl
|
||||
|
||||
import "joylink.club/rtsssimulation/repo/model"
|
||||
|
||||
type Turnout struct {
|
||||
uid string
|
||||
code string
|
||||
|
||||
// A端关联区段/道岔
|
||||
apSection model.Model
|
||||
// B端关联区段/道岔
|
||||
bpSection model.Model
|
||||
// C端关联区段/道岔
|
||||
cpSection model.Model
|
||||
|
||||
// A方向Link
|
||||
adLink *Link
|
||||
// B方向Link
|
||||
bdLink *Link
|
||||
// C方向Link
|
||||
cdLink *Link
|
||||
}
|
||||
|
||||
func NewTurnout(uid string, code string) *Turnout {
|
||||
return &Turnout{
|
||||
uid: uid,
|
||||
code: code,
|
||||
}
|
||||
}
|
||||
44
repo/repo.go
Normal file
44
repo/repo.go
Normal file
@ -0,0 +1,44 @@
|
||||
package repo
|
||||
|
||||
import (
|
||||
"joylink.club/rtsssimulation/repo/dto"
|
||||
"joylink.club/rtsssimulation/repo/model"
|
||||
"joylink.club/rtsssimulation/repo/model/impl"
|
||||
)
|
||||
|
||||
type repo struct {
|
||||
id string
|
||||
idMapping *IdMapping // id映射
|
||||
modelMap map[string]model.Model // 模型map,key为uid
|
||||
linkMap map[string]*impl.Link // 链路map,key为uid
|
||||
physicalSectionMap map[string]*impl.PhysicalSection // 物理区段map,key为uid
|
||||
turnoutMap map[string]*impl.Turnout // 道岔map,key为uid
|
||||
}
|
||||
|
||||
func BuildFrom(msgs *dto.Repo) (Repo, *ErrorRecord) {
|
||||
errRecord := NewErrorRecord()
|
||||
idMapping := BuildIdMapping(msgs, errRecord)
|
||||
if errRecord.HasError() {
|
||||
return nil, errRecord
|
||||
}
|
||||
repo := &repo{
|
||||
id: msgs.Id,
|
||||
idMapping: idMapping,
|
||||
modelMap: make(map[string]model.Model, 1024),
|
||||
linkMap: make(map[string]*impl.Link, 256),
|
||||
physicalSectionMap: make(map[string]*impl.PhysicalSection, 256),
|
||||
turnoutMap: make(map[string]*impl.Turnout, 128),
|
||||
}
|
||||
|
||||
return repo, errRecord
|
||||
}
|
||||
|
||||
// 模型仓库id
|
||||
func (r *repo) Id() string {
|
||||
return r.id
|
||||
}
|
||||
|
||||
// 通过uid查询模型对象
|
||||
func (r *repo) FindByUid(uid string) model.Model {
|
||||
return nil
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user