diff --git a/fs/local_adapter.go b/fs/local_adapter.go index 90296e1..dbef8af 100644 --- a/fs/local_adapter.go +++ b/fs/local_adapter.go @@ -51,7 +51,10 @@ func (l *LocalAdapter) GetFileList(ctx context.Context, dirPath string, relDt ti if err != nil { continue } - if startTime.Equal(stopTime) || stopTime.IsZero() { + if stopTime.IsZero() { + stopTime = startTime + } + if startTime.Equal(stopTime) { // 如果文件名没有时间戳,则认为该文件是未录制完成的 // 尝试读取一下视频信息 duration, err := util.GetVideoDuration(subCtx, path.Join(l.StorageConfig.Path, dirPath, file.Name())) diff --git a/fs/s3_adapter.go b/fs/s3_adapter.go index aac52ce..0281c1f 100644 --- a/fs/s3_adapter.go +++ b/fs/s3_adapter.go @@ -91,7 +91,10 @@ func (s *S3Adapter) GetFileList(ctx context.Context, dirPath string, relDt time. if err != nil { continue } - if startTime.Equal(stopTime) || stopTime.IsZero() { + if stopTime.IsZero() { + stopTime = startTime + } + if startTime.Equal(stopTime) { stopTime = stopTime.Add(time.Second * time.Duration(config.Config.Record.Duration)) } presignClient := s3.NewPresignClient(client)