+编译linux配置
This commit is contained in:
parent
70fdea9832
commit
130b8db17a
@ -126,7 +126,7 @@ var additionalPoints = []RoutePoint{
|
|||||||
|
|
||||||
// MQTT相关和全局变量
|
// MQTT相关和全局变量
|
||||||
var (
|
var (
|
||||||
mqttBroker = "tcp://192.168.3.110:1883"
|
mqttBroker = "tcp://123.6.102.119:1883"
|
||||||
mqttTopic = "vehicle/sim/data"
|
mqttTopic = "vehicle/sim/data"
|
||||||
eventMQTTTopic = "vehicle/sim/event"
|
eventMQTTTopic = "vehicle/sim/event"
|
||||||
alarmMQTTTopic = "vehicle/sim/alarm"
|
alarmMQTTTopic = "vehicle/sim/alarm"
|
||||||
@ -249,8 +249,8 @@ func init() {
|
|||||||
concurrentSemaphore = make(chan struct{}, maxConcurrentTrucks)
|
concurrentSemaphore = make(chan struct{}, maxConcurrentTrucks)
|
||||||
|
|
||||||
// 设置路线文件路径
|
// 设置路线文件路径
|
||||||
routeFile1 = `C:\Users\29620\tms-simulate\routes\routeG7干线.json`
|
routeFile1 = `./data/route_G7MainLine.json`
|
||||||
routeFile2 = `C:\Users\29620\tms-simulate\routes\route煤矿到陆港3.json`
|
routeFile2 = `./data/route_CoalMineToPort3.json`
|
||||||
|
|
||||||
// 检查路线文件是否存在
|
// 检查路线文件是否存在
|
||||||
if _, err := os.Stat(routeFile1); os.IsNotExist(err) {
|
if _, err := os.Stat(routeFile1); os.IsNotExist(err) {
|
||||||
@ -263,7 +263,7 @@ func init() {
|
|||||||
route1StartChan = make(chan struct{})
|
route1StartChan = make(chan struct{})
|
||||||
|
|
||||||
// 加载所有事件
|
// 加载所有事件
|
||||||
eventsFilePathRoute1 := `D:\worker\tms-simulate\tmsTemplateroute1.json` // 请根据实际路径调整
|
eventsFilePathRoute1 := `./data/tmsTemplateroute1.json` // 请根据实际路径调整
|
||||||
loadedEventsRoute1, err := loadAllEvents(eventsFilePathRoute1)
|
loadedEventsRoute1, err := loadAllEvents(eventsFilePathRoute1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("加载 route1 事件失败: %v", err)
|
log.Fatalf("加载 route1 事件失败: %v", err)
|
||||||
@ -271,7 +271,7 @@ func init() {
|
|||||||
allEventsRoute1 = loadedEventsRoute1
|
allEventsRoute1 = loadedEventsRoute1
|
||||||
log.Printf("Route1 事件类型数量: %d", len(allEventsRoute1))
|
log.Printf("Route1 事件类型数量: %d", len(allEventsRoute1))
|
||||||
|
|
||||||
eventsFilePathRoute2 := `D:\worker\tms-simulate\tmsTemplateroute2.json` // 请根据实际路径调整
|
eventsFilePathRoute2 := `./data/tmsTemplateroute2.json` // 请根据实际路径调整
|
||||||
loadedEventsRoute2, err := loadAllEvents(eventsFilePathRoute2)
|
loadedEventsRoute2, err := loadAllEvents(eventsFilePathRoute2)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("加载 route2 事件失败: %v", err)
|
log.Fatalf("加载 route2 事件失败: %v", err)
|
||||||
@ -280,7 +280,7 @@ func init() {
|
|||||||
log.Printf("Route2 事件类型数量: %d", len(allEventsRoute2))
|
log.Printf("Route2 事件类型数量: %d", len(allEventsRoute2))
|
||||||
|
|
||||||
// 加载报警事件
|
// 加载报警事件
|
||||||
eventsFilePathAlarm := `D:\worker\tms-simulate\tmsTemplateAlarm.json` // 请根据实际路径调整
|
eventsFilePathAlarm := `./data/tmsTemplateAlarm.json` // 请根据实际路径调整
|
||||||
allEventsAlarm, err = loadAllEvents(eventsFilePathAlarm)
|
allEventsAlarm, err = loadAllEvents(eventsFilePathAlarm)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("加载报警事件失败: %v", err)
|
log.Fatalf("加载报警事件失败: %v", err)
|
||||||
@ -1092,11 +1092,11 @@ func startRoute(stopChan chan struct{}, mqttClient mqtt.Client, route []RoutePoi
|
|||||||
Waybill: "", // 将在 runSimulation 中生成
|
Waybill: "", // 将在 runSimulation 中生成
|
||||||
DriverName: driverName, // 分配司机姓名
|
DriverName: driverName, // 分配司机姓名
|
||||||
PhoneNumber: "18940028888", // 分配固定电话号码
|
PhoneNumber: "18940028888", // 分配固定电话号码
|
||||||
CarPlate: "蒙K123ER", // 新增字段,固定或动态分配
|
CarPlate: "蒙K123ER", // 新增字段,固定或动态分配
|
||||||
Mileage: 100.0, // 新增字段,示例值,实际应动态获取
|
Mileage: 100.0, // 新增字段,示例值,实际应动态获取
|
||||||
Speed: 60.0, // 新增字段,示例值,实际应动态获取
|
Speed: 60.0, // 新增字段,示例值,实际应动态获取
|
||||||
Location: "北京", // 新增字段,示例值,实际应动态获取
|
Location: "北京", // 新增字段,示例值,实际应动态获取
|
||||||
VehicleStatus: "ACC正常", // 新增字段,示例值,实际应动态获取
|
VehicleStatus: "ACC正常", // 新增字段,示例值,实际应动态获取
|
||||||
eventsSent: make(map[int]bool),
|
eventsSent: make(map[int]bool),
|
||||||
}
|
}
|
||||||
simulationWaitGroup.Add(1)
|
simulationWaitGroup.Add(1)
|
||||||
|
Binary file not shown.
Loading…
x
Reference in New Issue
Block a user