commit

common/domain/d_service.go

@@ -16,6 +16,7 @@ func MoveFromDataToCopy(faultTime string, bagDataDir string, sourceBag string, b
 	copyCommand = append(copyCommand, sourceBag)
 	copyCommand = append(copyCommand, targetBag)
 	_, _, _ = util.Execute("mv", copyCommand...)
+	c_log.GlobalLogger.Infof("移动bag包 【%v】->【%v】", sourceBag, targetBag)
 }
 
 func GetCopyDir(bagDataDir string, faultTime string) string {

kinglong/master/pkg/svc/produce_window.go

@@ -31,7 +31,6 @@ var (
 // PrepareTimeWindowProducerQueue 负责监听所有主题并修改时间窗口
 func PrepareTimeWindowProducerQueue() {
 	log.GlobalLogger.Info("订阅者 goroutine，启动。")
-
 	//创建订阅者0订阅主题 nodefault_info
 	log.GlobalLogger.Info("创建订阅者0订阅话题 ", masterConfig.TopicOfNodeFaultInfo)
 	subscriber0, err := goroslib.NewSubscriber(goroslib.SubscriberConf{