rts-sim-testing-service/third_party/interlock/beijing11/interlock.go

// Package beijing11 北京11号线联锁通信
package beijing11

import (
	"encoding/json"
	"fmt"
	"joylink.club/bj-rtsts-server/config"
	"joylink.club/bj-rtsts-server/third_party/udp"
	"log/slog"
	"sync"
)

var (
	initMutex = sync.Mutex{}
	logTag    = "[北京11号线联锁通信]"
	running   = false
	server    udp.UdpServer
)

func Start(interlockConfig *config.InterlockConfig) {
	if interlockConfig == nil || interlockConfig.Ip == "" || !interlockConfig.Open {
		return
	}
	if running {
		return
	}
	initMutex.Lock()
	defer initMutex.Unlock()
	if running {
		return
	}
	//UDP通信设施
	server = udp.NewServer(fmt.Sprintf(":%d", interlockConfig.LocalPort), func(b []byte) {
		slog.Info(fmt.Sprintf("%s收到消息：%x", logTag, b))
		frame := &FromInterlockFrame{}
		err := frame.Decode(b)
		if err != nil {
			slog.Error(fmt.Sprintf("%s解析数据出错：%s", logTag, err))
		} else {
			marshal, err := json.Marshal(frame)
			if err != nil {
				slog.Error(fmt.Sprintf("%s解析为json出错：%s", logTag, err))
			} else {
				slog.Info(fmt.Sprintf("%s解析为json：%s", logTag, string(marshal)))
			}
		}
	})
	err := server.Listen()
	if err != nil {
		panic(fmt.Sprintf("%s启动UDP服务失败：%s", logTag, err))
	}
	running = true
}

func Stop() {
	initMutex.Lock()
	defer initMutex.Unlock()
	running = false
	if server != nil {
		server.Close()
		server = nil
	}
}