rts-sim-testing-service/third_party/train_pc_sim/train_pc_receive_handler.go

package train_pc_sim

import (
	"joylink.club/bj-rtsts-server/dto/state_proto"
	"joylink.club/bj-rtsts-server/third_party/message"
	"joylink.club/bj-rtsts-server/third_party/tcp"
	"joylink.club/bj-rtsts-server/third_party/tpapi"
	"log/slog"
)

type TrainPcReciverData struct {
	tpapi.ThirdPartyApiService
	clientKey   string
	tcpClient   *tcp.TcpClient
	pcSimManage TrainPcSimManage
	trainInit   bool
	state       tpapi.ThirdPartyApiServiceState
	speedPlace  *message.TrainSpeedPlaceReportMsg
	train       *state_proto.TrainState
}

func (rd *TrainPcReciverData) Name() string {
	return Name
}

// 服务状态
func (rd *TrainPcReciverData) State() tpapi.ThirdPartyApiServiceState {
	return rd.state
}

func (d *TrainPcReciverData) updateState(state tpapi.ThirdPartyApiServiceState) {
	d.state = state
}
func (d *TrainPcReciverData) readError(err error) {
	slog.Error("连接车载pc仿真tcp服务断开", err)
	d.updateState(tpapi.ThirdPartyState_Broken)
	d.tcpClient = nil

}
func (d *TrainPcReciverData) ServiceDesc() string {
	return d.clientKey
}
func (rd *TrainPcReciverData) receiverDataHandle(n int, data []byte) {

	receiveData := data[:n]

	trainPcMsgs := message.TrainPcSimDecode(receiveData)
	train := rd.train
	if train == nil {
		slog.Error("车载输出数字量，未找到连接车载pc仿真的列车")
		return
	}
	if !train.ConnState.Conn {
		slog.Error("车载输出数字量，,列车未连接车载pc仿真")
		return
	}
	//hexSourceData := hex.EncodeToString(receiveData)
	//slog.Info(fmt.Sprintf("接受列车激活端:%v pc仿真接收数据：%v", rd.clientKey, hexSourceData))
	for _, baseMsg := range trainPcMsgs {
		//slog.Info(fmt.Sprintf("pc仿真接收数据：%v,类型:%X", hexSourceData, baseMsg.Type))
		switch baseMsg.Type {
		//case RECIVE_TRAIN_CREATE_REMOVE:
		//	pc.trainPcSimManage.TrainPcSimConnOrRemoveHandle(baseMsg.Data[0])
		case message.RECIVE_TRAIN_INTERFACE_CABINET_OUTR:
			initResult := rd.pcSimManage.TrainPcSimDigitalOutInfoHandle(train, rd.trainInit, baseMsg.Data)
			rd.trainInit = initResult
		case message.RECIVE_TRAIN_INTERFACE_CABINET_OUTR_BACK:
			rd.pcSimManage.TrainPcSimDigitalReportHandle(train, baseMsg.Data)
		case message.RECIVE_TRAIN_QUERY_STATUS:
			rd.pcSimManage.TrainBtmQuery(train, baseMsg.Data)
		case message.RECIVE_TRAIN_MOCK_DATA:
			rd.pcSimManage.TrainPcSimMockInfo(train, baseMsg.Data)

			//case RECIVE_TRAIN_DOOR_MODE:
			//	pc.trainPcSimManage.TrainDoorModeHandle(baseMsg.Data[0])
		}
	}

}