diff --git a/route煤矿到陆港3.json b/data/route_CoalMineToPort3.json similarity index 100% rename from route煤矿到陆港3.json rename to data/route_CoalMineToPort3.json diff --git a/routeG7干线.json b/data/route_G7MainLine.json similarity index 100% rename from routeG7干线.json rename to data/route_G7MainLine.json diff --git a/tmsTemplateAlarm.json b/data/tmsTemplateAlarm.json similarity index 100% rename from tmsTemplateAlarm.json rename to data/tmsTemplateAlarm.json diff --git a/tmsTemplateroute1.json b/data/tmsTemplateroute1.json similarity index 100% rename from tmsTemplateroute1.json rename to data/tmsTemplateroute1.json diff --git a/tmsTemplateroute2.json b/data/tmsTemplateroute2.json similarity index 100% rename from tmsTemplateroute2.json rename to data/tmsTemplateroute2.json diff --git a/main/golang/antesv/tms/core/service/SimTruckService.go b/main/golang/antesv/tms/core/service/SimTruckService.go index 4dad8b3..7ee667a 100644 --- a/main/golang/antesv/tms/core/service/SimTruckService.go +++ b/main/golang/antesv/tms/core/service/SimTruckService.go @@ -126,7 +126,7 @@ var additionalPoints = []RoutePoint{ // MQTT相关和全局变量 var ( - mqttBroker = "tcp://192.168.3.110:1883" + mqttBroker = "tcp://123.6.102.119:1883" mqttTopic = "vehicle/sim/data" eventMQTTTopic = "vehicle/sim/event" alarmMQTTTopic = "vehicle/sim/alarm" @@ -249,8 +249,8 @@ func init() { concurrentSemaphore = make(chan struct{}, maxConcurrentTrucks) // 设置路线文件路径 - routeFile1 = `C:\Users\29620\tms-simulate\routes\routeG7干线.json` - routeFile2 = `C:\Users\29620\tms-simulate\routes\route煤矿到陆港3.json` + routeFile1 = `./data/route_G7MainLine.json` + routeFile2 = `./data/route_CoalMineToPort3.json` // 检查路线文件是否存在 if _, err := os.Stat(routeFile1); os.IsNotExist(err) { @@ -263,7 +263,7 @@ func init() { route1StartChan = make(chan struct{}) // 加载所有事件 - eventsFilePathRoute1 := `D:\worker\tms-simulate\tmsTemplateroute1.json` // 请根据实际路径调整 + eventsFilePathRoute1 := `./data/tmsTemplateroute1.json` // 请根据实际路径调整 loadedEventsRoute1, err := loadAllEvents(eventsFilePathRoute1) if err != nil { log.Fatalf("加载 route1 事件失败: %v", err) @@ -271,7 +271,7 @@ func init() { allEventsRoute1 = loadedEventsRoute1 log.Printf("Route1 事件类型数量: %d", len(allEventsRoute1)) - eventsFilePathRoute2 := `D:\worker\tms-simulate\tmsTemplateroute2.json` // 请根据实际路径调整 + eventsFilePathRoute2 := `./data/tmsTemplateroute2.json` // 请根据实际路径调整 loadedEventsRoute2, err := loadAllEvents(eventsFilePathRoute2) if err != nil { log.Fatalf("加载 route2 事件失败: %v", err) @@ -280,7 +280,7 @@ func init() { log.Printf("Route2 事件类型数量: %d", len(allEventsRoute2)) // 加载报警事件 - eventsFilePathAlarm := `D:\worker\tms-simulate\tmsTemplateAlarm.json` // 请根据实际路径调整 + eventsFilePathAlarm := `./data/tmsTemplateAlarm.json` // 请根据实际路径调整 allEventsAlarm, err = loadAllEvents(eventsFilePathAlarm) if err != nil { log.Fatalf("加载报警事件失败: %v", err) @@ -1092,11 +1092,11 @@ func startRoute(stopChan chan struct{}, mqttClient mqtt.Client, route []RoutePoi Waybill: "", // 将在 runSimulation 中生成 DriverName: driverName, // 分配司机姓名 PhoneNumber: "18940028888", // 分配固定电话号码 - CarPlate: "蒙K123ER", // 新增字段,固定或动态分配 + CarPlate: "蒙K123ER", // 新增字段,固定或动态分配 Mileage: 100.0, // 新增字段,示例值,实际应动态获取 Speed: 60.0, // 新增字段,示例值,实际应动态获取 - Location: "北京", // 新增字段,示例值,实际应动态获取 - VehicleStatus: "ACC正常", // 新增字段,示例值,实际应动态获取 + Location: "北京", // 新增字段,示例值,实际应动态获取 + VehicleStatus: "ACC正常", // 新增字段,示例值,实际应动态获取 eventsSent: make(map[int]bool), } simulationWaitGroup.Add(1) diff --git a/target/tms_simulate.sh b/target/tms_simulate.sh index 099ead4..c495a6c 100644 Binary files a/target/tms_simulate.sh and b/target/tms_simulate.sh differ