|
@@ -153,16 +153,16 @@ outLoop:
|
|
c_log.GlobalLogger.Info("【callBackJson】=", callBackJson)
|
|
c_log.GlobalLogger.Info("【callBackJson】=", callBackJson)
|
|
|
|
|
|
{
|
|
{
|
|
- //commonConfig.OssMutex.Lock()
|
|
|
|
- //err := commonConfig.OssBucket.PutObject(objectKey3+"callback.json", strings.NewReader(callBackJson))
|
|
|
|
- //commonConfig.OssMutex.Unlock()
|
|
|
|
- //if err != nil {
|
|
|
|
- // c_log.GlobalLogger.Error("上传 callback.json", callBackJson, "失败:", err)
|
|
|
|
- //}
|
|
|
|
- // 删除本地所有已上传的bag文件
|
|
|
|
- //if err := commonUtil.RemoveDir(dir); err != nil {
|
|
|
|
- // continue outLoop
|
|
|
|
- //}
|
|
|
|
|
|
+ commonConfig.OssMutex.Lock()
|
|
|
|
+ err := commonConfig.OssBucket.PutObject(objectKey3+"callback.json", strings.NewReader(callBackJson))
|
|
|
|
+ commonConfig.OssMutex.Unlock()
|
|
|
|
+ if err != nil {
|
|
|
|
+ c_log.GlobalLogger.Error("上传 callback.json", callBackJson, "失败:", err)
|
|
|
|
+ }
|
|
|
|
+ //删除本地所有已上传的bag文件
|
|
|
|
+ if err := commonUtil.RemoveDir(dir); err != nil {
|
|
|
|
+ continue outLoop
|
|
|
|
+ }
|
|
commonUtil.WriteStringToFile(callBackJson, dir+"callback.json")
|
|
commonUtil.WriteStringToFile(callBackJson, dir+"callback.json")
|
|
}
|
|
}
|
|
}
|
|
}
|