20 lines
585 B
Go
20 lines
585 B
Go
|
package message_server
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"joylink.club/bj-rtsts-server/message_server/ms_api"
|
||
|
|
"joylink.club/bj-rtsts-server/mqtt"
|
||
|
|
"joylink.club/bj-rtsts-server/third_party"
|
||
|
|
"joylink.club/bj-rtsts-server/ts/simulation/wayside/memory"
|
||
|
|
)
|
||
|
|
|
||
|
|
func NewTpapiServiceMs(vs *memory.VerifySimulation) ms_api.MsgTask {
|
||
|
|
return ms_api.NewScheduleTask(fmt.Sprintf("仿真第三方API服务[%s]状态", vs.SimulationId), func() error {
|
||
|
|
rss := third_party.GetRunningServiceStates()
|
||
|
|
mqtt.GetMsgClient().PubTpapiServiceState(vs.SimulationId, rss)
|
||
|
|
return nil
|
||
|
|
}, 1000*time.Millisecond)
|
||
|
|
}
|