|
|
@@ -33,9 +33,6 @@ func RunTimeWindowProducerQueue() {
|
|
|
// 处理
|
|
|
time.Sleep(time.Duration(1) * time.Second)
|
|
|
if len(entity.TimeWindowProducerQueue) > 0 {
|
|
|
- // 如果有可处理的，先把record命令杀掉
|
|
|
- c_log.GlobalLogger.Info("采集数据，发送record命令进程关闭信号。")
|
|
|
- commonService.ChannelKillRosRecord <- 3
|
|
|
// 处理
|
|
|
bags, _ := util.ListAbsolutePathWithSuffixAndSort(commonConfig.CloudConfig.BagDataDir, ".bag")
|
|
|
currentTimeWindow := entity.TimeWindowProducerQueue[0]
|
|
|
@@ -60,6 +57,9 @@ func RunTimeWindowProducerQueue() {
|
|
|
}
|
|
|
// 如果没有包可以供当前窗口移动，且已经生成了更新的包，则当前窗口已经可以上传
|
|
|
if !move && bigger {
|
|
|
+ time.Sleep(time.Duration(2) * time.Second)
|
|
|
+ c_log.GlobalLogger.Info("采集数据，发送record命令进程关闭信号。")
|
|
|
+ commonService.ChannelKillRosRecord <- 3
|
|
|
domain.SupplyCopyBags(commonConfig.CloudConfig.BagDataDir, commonConfig.CloudConfig.BagCopyDir, currentTimeWindow)
|
|
|
// 将时间窗口移出准备队列
|
|
|
entity.RemoveHeadOfTimeWindowProducerQueue()
|
