rts-sim-module/examples/signal_2xh1/main.go

package main

import (
	"joylink.club/ecs"
	rtss_simulation "joylink.club/rtsssimulation"
	"joylink.club/rtsssimulation/consts"
	"joylink.club/rtsssimulation/entity"
	"joylink.club/rtsssimulation/examples/signal_2xh1/sigSys"
	"joylink.club/rtsssimulation/fi"
	"joylink.club/rtsssimulation/repository"
	"joylink.club/rtsssimulation/repository/model/proto"
	"log"
	"log/slog"
	"os"
	"time"
)

const (
	IdSignal2XH1 = "signal_2xh1-1"
)

// 信号机测试
func main() {
	//
	logConfig := &slog.HandlerOptions{AddSource: false, Level: slog.LevelDebug}
	slog.SetDefault(slog.New(slog.NewTextHandler(os.Stderr, logConfig)))
	//
	proto := &proto.Repository{}
	proto.Id = "test-for-signal"
	proto.Version = "v1.0"
	addProtoSignal2XH1(proto)
	repo := repository.BuildRepositoryForSignalTest(proto)
	sim := rtss_simulation.NewSimulation(repo)
	loadEntities(sim, repo)
	sim.SetSpeed(0.1)
	sim.AddSystem(sigSys.NewSignalDebugSystem())
	sim.StartUp()
	//
	time.Sleep(1 * time.Second)
	slog.Debug("灭灯 .....")
	fi.DriveSignal2XH1Dd(sim, IdSignal2XH1, false) //灭灯
	time.Sleep(2 * time.Second)
	slog.Debug("亮灯 .....")
	fi.DriveSignal2XH1Dd(sim, IdSignal2XH1, true) //亮灯
	time.Sleep(2 * time.Second)
	slog.Debug("开通列车信号 .....")
	fi.DriveSignal2XH1Lx(sim, IdSignal2XH1) //开通列车信号
	time.Sleep(3 * time.Second)
	slog.Debug("开通禁止信号 .....")
	fi.DriveSignal2XH1Non(sim, IdSignal2XH1) //开通禁止信号
	//
	time.Sleep(3 * time.Second)
	sim.Close()
}
func worldLog(w ecs.World, logInfo string) {
	ecs.Request(w, func() any {
		log.Println(logInfo)
		return nil
	})
}
func addProtoSignal2XH1(r *proto.Repository) {
	//相关继电器
	r.Relays = append(r.Relays, &proto.Relay{Id: "2xh1-ddj", Code: consts.SIGNAL_DDJ, Model: proto.Relay_JWXC_1700})
	r.Relays = append(r.Relays, &proto.Relay{Id: "2xh1-dj", Code: consts.SIGNAL_DJ, Model: proto.Relay_JZXC_H18})
	r.Relays = append(r.Relays, &proto.Relay{Id: "2xh1-lxj", Code: consts.SIGNAL_LXJ, Model: proto.Relay_JWXC_1700})
	//
	signal := &proto.Signal{}
	signal.Id = IdSignal2XH1
	signal.Km = &proto.Kilometer{}
	//
	group := &proto.ElectronicComponentGroup{Code: consts.SIGNAL_2XH1, ComponentIds: []string{"2xh1-ddj", "2xh1-dj", "2xh1-lxj"}}
	//
	signal.ElectronicComponentGroups = append(signal.ElectronicComponentGroups, group)
	r.Signals = append(r.Signals, signal)
}
func loadEntities(w ecs.World, repo *repository.Repository) {
	// 初始化世界数据单例组件
	entity.LoadWorldData(w, repo)
	//
	if le := entity.LoadSignals(w); le != nil {
		slog.Error(le.Error())
	}
}