|
@@ -44,7 +44,7 @@ outLoop:
|
|
// 1 获取即将处理的窗口
|
|
// 1 获取即将处理的窗口
|
|
currentTimeWindow := entity.TimeWindowConsumerQueue[0]
|
|
currentTimeWindow := entity.TimeWindowConsumerQueue[0]
|
|
entity.RemoveHeadOfTimeWindowConsumerQueue()
|
|
entity.RemoveHeadOfTimeWindowConsumerQueue()
|
|
- c_log.GlobalLogger.Infof("开始处理窗口,【Lable】=%v,【TriggerIds】=%v,【FaultTime】=%v,【Length】=%v", currentTimeWindow.Labels, currentTimeWindow.TriggerIds, currentTimeWindow.FaultTime, currentTimeWindow.Length)
|
|
|
|
|
|
+ c_log.GlobalLogger.Infof("开始处理窗口,【Lable】=%v,【FaultTime】=%v,【Length】=%v", currentTimeWindow.Labels, currentTimeWindow.FaultTime, currentTimeWindow.Length)
|
|
// 2 获取目录
|
|
// 2 获取目录
|
|
dir := domain.GetCopyDir(commonConfig.CloudConfig.BagCopyDir, currentTimeWindow.FaultTime)
|
|
dir := domain.GetCopyDir(commonConfig.CloudConfig.BagCopyDir, currentTimeWindow.FaultTime)
|
|
bags, _ := util.ListAbsolutePathWithSuffixAndSort(dir, ".bag")
|
|
bags, _ := util.ListAbsolutePathWithSuffixAndSort(dir, ".bag")
|
|
@@ -143,7 +143,7 @@ outLoop:
|
|
}
|
|
}
|
|
|
|
|
|
// 删除本地所有已上传的bag文件
|
|
// 删除本地所有已上传的bag文件
|
|
- c_log.GlobalLogger.Infof("结束处理窗口,【Lable】=%v,【TriggerIds】=%v,【FaultTime】=%v,【Length】=%v", currentTimeWindow.Labels, currentTimeWindow.TriggerIds, currentTimeWindow.FaultTime, currentTimeWindow.Length)
|
|
|
|
|
|
+ c_log.GlobalLogger.Infof("结束处理窗口,【Lable】=%v,,【FaultTime】=%v,【Length】=%v", currentTimeWindow.Labels, currentTimeWindow.FaultTime, currentTimeWindow.Length)
|
|
if err = util.RemoveDir(dir); err != nil {
|
|
if err = util.RemoveDir(dir); err != nil {
|
|
continue outLoop
|
|
continue outLoop
|
|
}
|
|
}
|