|
@@ -1,6 +1,7 @@
|
|
package service
|
|
package service
|
|
|
|
|
|
import (
|
|
import (
|
|
|
|
+ "cicv-data-closedloop/aarch64/pjisuv/common/config"
|
|
commonConfig "cicv-data-closedloop/aarch64/pjisuv/common/config"
|
|
commonConfig "cicv-data-closedloop/aarch64/pjisuv/common/config"
|
|
"cicv-data-closedloop/common/config/c_log"
|
|
"cicv-data-closedloop/common/config/c_log"
|
|
"cicv-data-closedloop/common/util"
|
|
"cicv-data-closedloop/common/util"
|
|
@@ -16,6 +17,7 @@ import (
|
|
var (
|
|
var (
|
|
dir = "/userdata/competition/"
|
|
dir = "/userdata/competition/"
|
|
dirBak = "/userdata/competition-bak/"
|
|
dirBak = "/userdata/competition-bak/"
|
|
|
|
+ ossPrefix = "competition/"
|
|
commandArgs = []string{"record", "--split", "--duration=1", "/pji_gps", "/data_read"}
|
|
commandArgs = []string{"record", "--split", "--duration=1", "/pji_gps", "/data_read"}
|
|
topic = "/team_name"
|
|
topic = "/team_name"
|
|
urlExamTick = "http://36.110.106.142:12341/web_server/exam/tick"
|
|
urlExamTick = "http://36.110.106.142:12341/web_server/exam/tick"
|
|
@@ -64,7 +66,7 @@ func dataCollection() {
|
|
c_log.GlobalLogger.Debug("上传实车算法比赛全量数据包", files[i])
|
|
c_log.GlobalLogger.Debug("上传实车算法比赛全量数据包", files[i])
|
|
bagSlice := strings.Split(files[i], "/")
|
|
bagSlice := strings.Split(files[i], "/")
|
|
commonConfig.OssMutex.Lock()
|
|
commonConfig.OssMutex.Lock()
|
|
- _ = commonConfig.OssBucket.PutObjectFromFile("competition/"+bagSlice[len(bagSlice)-1], files[i])
|
|
|
|
|
|
+ _ = commonConfig.OssBucket.PutObjectFromFile(ossPrefix+config.LocalConfig.EquipmentNo+"/"+bagSlice[len(bagSlice)-1], files[i])
|
|
commonConfig.OssMutex.Unlock()
|
|
commonConfig.OssMutex.Unlock()
|
|
_ = util.DeleteFile(files[i])
|
|
_ = util.DeleteFile(files[i])
|
|
}
|
|
}
|