//информационный файл writeSyncer
 infoFileWriteSyncer := zapcore.AddSync(&lumberjack.Logger{
  Filename:   "./log/info.log", //бревно каталог хранения файлов, если папка не существует, то она будет создана автоматически
  MaxSize:    2,                //Ограничение размера файла, единица измерения МБ
  MaxBackups: 100,              //Максимальное количество сохраняемых файлов
  MaxAge:     30,               //Количество дней хранения файлов
  Compress:   false,            //Обрабатывается ли сжатие
 })
 infoFileCore := zapcore.NewCore(encoder, zapcore.NewMultiWriteSyncer(infoFileWriteSyncer, zapcore.AddSync(os.Stdout)), lowPriority) //Третий и последующие параметры — это уровень бревности записываемого файла. Режим ErrorLevel записывает только уровень бревности ошибки.
 //файл ошибки writeSyncer
 errorFileWriteSyncer := zapcore.AddSync(&lumberjack.Logger{
  Filename:   "./log/error.log", //кратковременный каталог хранения файлов
  MaxSize:    1,                 //Ограничение размера файла, единица измерения МБ
  MaxBackups: 5,                 //Максимальное количество сохраняемых файлов
  MaxAge:     30,                //Количество дней хранения файлов
  Compress:   false,             //Обрабатывается ли сжатие
 })

 errorFileWriteSyncer := zapcore.AddSync(&lumberjack.Logger{
  Filename:   "./log/error.log", //кратковременный каталог хранения файлов
  MaxSize:    1,                 //Ограничение размера файла, единица измерения МБ
  MaxBackups: 3,                 //Максимальное количество сохраняемых файлов
  MaxAge:     30,                //Количество дней хранения файлов
  Compress:   false,             //Обрабатывается ли сжатие
 })

 errorFileWriteSyncer := zapcore.AddSync(&lumberjack.Logger{
  Filename:   "./log/error.log", //кратковременный каталог хранения файлов
  MaxSize:    5,                 //Ограничение размера файла, единица измерения МБ
  MaxBackups: 10,                 //Максимальное количество сохраняемых файлов
  MaxAge:     30,                //Количество дней хранения файлов
  Compress:   false,             //Обрабатывается ли сжатие
 })

package main

import (
 "fmt"
 "io"
 "net/http"
 "time"

 rotatelogs "github.com/lestrrat-go/file-rotatelogs"
 "go.uber.org/zap"
 "go.uber.org/zap/zapcore"
)

// Используйте журналы ротации файлов для сегментации

var sugarLogger *zap.SugaredLogger

func main() {
 fmt.Println("подсказка Шуан: начать main")
 InitLogger()
 defer sugarLogger.Sync()

 for i := 0; i < 100000; i++ {
  simpleHttpGet("www.cnblogs.com")
  simpleHttpGet("https://www.baidu.com")
 }

}

// Пример: URL-адрес доступа HTTP, статус возврата
func simpleHttpGet(url string) {
 fmt.Println("begin simpleHttpGet:" + url)
 sugarLogger.Debugf("Trying to hit GET request for %s", url)
 resp, err := http.Get(url)
 if err != nil {
  sugarLogger.Errorf("Error fetching URL %s : Error = %s", url, err)
 } else {
  sugarLogger.Infof("Success! statusCode = %s for URL %s", resp.Status, url)
  resp.Body.Close()
 }
}

func InitLogger() {
 encoder := getEncoder()

 //Два интерфейса для определения уровня бревно
 //уровень предупреждения и ниже возвращаемся к информациибревно
 infoLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
  return lvl < zapcore.WarnLevel
 })
 //уровень предупреждения и выше принадлежат alertbrevno
 warnLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
  return lvl >= zapcore.WarnLevel
 })

 infoWriter := getLogWriter("/Users/fliter/zap-demo/demo2-log/info")
 warnWriter := getLogWriter("/Users/fliter/zap-demo/demo2-log/warn")

 //Создаем zap.Core,для logger
 core := zapcore.NewTee(
  zapcore.NewCore(encoder, infoWriter, infoLevel),
  zapcore.NewCore(encoder, warnWriter, warnLevel),
 )
 //Создать регистратор
 logger := zap.New(core, zap.AddCaller())
 sugarLogger = logger.Sugar()
}

// getEncoder
func getEncoder() zapcore.Encoder {
 encoderConfig := zap.NewProductionEncoderConfig()
 encoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
 encoderConfig.EncodeLevel = zapcore.CapitalLevelEncoder
 return zapcore.NewConsoleEncoder(encoderConfig)
}

// GetLogWriter
func getLogWriter(filePath string) zapcore.WriteSyncer {
 warnIoWriter := getWriter(filePath)
 return zapcore.AddSync(warnIoWriter)
}

// бревно напильник
func getWriter(filename string) io.Writer {

 //Сохраняем бревно на 30 дней, разделяем бревно каждую 1 минуту
 hook, err := rotatelogs.New(
  filename+"_%Y-%m-%d %H:%M:%S.log",
  // Создайте мягкую ссылку для последней версии бревно, указывающую на последний файл бревно.
  rotatelogs.WithLinkName(filename),

  // Условия уборки: Непосредственное удаление вырезанных бревно файлов в соответствии с условиями (количество или время)
  //--- MaxAge and RotationCount cannot be both set  Оба не могут быть установлены одновременно
  //--- RotationCount используется для установки максимального количества файлов, подлежащих вырезанию (любое превышение будет от старого к новому уборка)
  //--- MaxAge Максимальное время хранения перед настройкой очистки файла Минимальная единица минут
  //--- if both are 0, give maxAge a default 7 * 24 * time.Hour
  // Два параметра WithRotationCount и WithMaxAge не могут сосуществовать, и можно установить только один (оба параметра не будут вызывать ошибки при компиляции, но будут сообщать об ошибках во время выполнения. Это также необходимо для предотвращения влияния на логику обработки сегментации).
  //rotatelogs.WithRotationCount(10),       // Файлы, превышающие это число, будут удалены.
  rotatelogs.WithMaxAge(time.Hour*24*30), // Как долго хранить (установите максимальное время хранения перед очисткой файла) Минимальная единица минут)

  // Условия разделения (вырезать файл бревно; WithRotationTime and WithRotationSize ~~Он будет обрезан, если выполнено любое из условий~~)
  // После личного тестирования было обнаружено, что если бревно не продолжает увеличиваться и для WithRotationTime установлено небольшое значение (например, 10 с), файл не будет разделен в соответствии с частотой WithRotationTime. Когда бревно продолжает увеличиваться, оно будет разделено в соответствии с настройкой WithRotationTime (даже если настройка WithRotationTime очень мала)
  rotatelogs.WithRotationTime(time.Second*10),     // Делить каждые 10 секунд (установлен временной интервал резкой резки, по умолчанию). 24 * time.Hour)
  rotatelogs.WithRotationSize(int64(1*1024*1024*1024)), // Файл будет обрезан, когда достигнет максимального размера. bytes；
 )
 if err != nil {
  panic(err)
 }
 return hook
}

package main

import (
 "archive/zip"
 "fmt"
 "io"
 "net/http"
 "os"
 "path/filepath"
 "reflect"
 "time"

 "github.com/davecgh/go-spew/spew"
 rotatelogs "github.com/lestrrat-go/file-rotatelogs"
 "go.uber.org/zap"
 "go.uber.org/zap/zapcore"
)

// Используйте журналы ротации файлов для сегментации

var sugarLogger *zap.SugaredLogger

func main() {
 fmt.Println("подсказка Шуан: начать main")
 InitLogger()
 defer sugarLogger.Sync()

 for i := 0; i < 10000000; i++ {

  SugarLogger.Infof("Тест на сжатие занимает меньше места. Это текст заливки. Это текст заливки. Это текст заливки. Это текст заливки. Это текст заливки. Это текст заливки. Это текст-заполнитель Это текст-заполнитель Это текст-заполнитель Это текст-заполнитель Это текст-заполнитель Это текст-заполнитель Это текст-заполнитель текст, это текст-заполнитель, это текст-заполнитель, я is %d", i)

  //simpleHttpGet("www.cnblogs.com", i)
  //simpleHttpGet("https://www.baidu.com", i)
 }

 time.Sleep(10000e9)

}

// Пример: URL-адрес доступа HTTP, статус возврата
func simpleHttpGet(url string, i int) {
 //fmt.Println("begin simpleHttpGet:" + url)
 sugarLogger.Debugf("Trying to hit GET request for %s, i is %d", url, i)
 resp, err := http.Get(url)
 if err != nil {
  sugarLogger.Errorf("Error fetching URL %s : Error = %s, i is %d", url, err, i)
 } else {
  sugarLogger.Infof("Success! statusCode = %s for URL %s,i is %d", resp.Status, url, i)
  resp.Body.Close()
 }
}

func InitLogger() {
 encoder := getEncoder()

 //Два интерфейса для определения уровня бревно
 //уровень предупреждения и ниже возвращаемся к информациибревно
 infoLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
  return lvl < zapcore.WarnLevel
 })
 //уровень предупреждения и выше принадлежат alertbrevno
 warnLevel := zap.LevelEnablerFunc(func(lvl zapcore.Level) bool {
  return lvl >= zapcore.WarnLevel
 })

 infoWriter := getLogWriter("/Users/fliter/zap-demo/demo2-log/info")
 warnWriter := getLogWriter("/Users/fliter/zap-demo/demo2-log/warn")

 //Создаем zap.Core,для logger
 core := zapcore.NewTee(
  zapcore.NewCore(encoder, infoWriter, infoLevel),
  zapcore.NewCore(encoder, warnWriter, warnLevel),
 )
 //Создать регистратор
 logger := zap.New(core, zap.AddCaller())
 sugarLogger = logger.Sugar()
}

// getEncoder
func getEncoder() zapcore.Encoder {
 encoderConfig := zap.NewProductionEncoderConfig()
 encoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
 encoderConfig.EncodeLevel = zapcore.CapitalLevelEncoder
 return zapcore.NewConsoleEncoder(encoderConfig)
}

// GetLogWriter
func getLogWriter(filePath string) zapcore.WriteSyncer {
 warnIoWriter := getWriter(filePath)
 return zapcore.AddSync(warnIoWriter)
}

// бревно напильник
func getWriter(filename string) io.Writer {

 //Сохраняем бревно на 30 дней, разделяем бревно каждую 1 минуту
 hook, err := rotatelogs.New(
  filename+"_%Y-%m-%d %H:%M:%S.log",
  // Создайте мягкую ссылку для последней версии бревно, указывающую на последний файл бревно.
  rotatelogs.WithLinkName(filename),

  // Условия уборки: Непосредственное удаление вырезанных бревно файлов в соответствии с условиями (количество или время)
  //--- MaxAge and RotationCount cannot be both set  Оба не могут быть установлены одновременно
  //--- RotationCount используется для установки максимального количества файлов, подлежащих вырезанию (любое превышение будет от старого к новому уборка)
  //--- MaxAge Максимальное время хранения перед настройкой очистки файла Минимальная единица минут
  //--- if both are 0, give maxAge a default 7 * 24 * time.Hour
  // Два параметра WithRotationCount и WithMaxAge не могут сосуществовать, и можно установить только один (оба параметра не будут вызывать ошибки при компиляции, но будут сообщать об ошибках во время выполнения. Это также необходимо для предотвращения влияния на логику обработки сегментации).
  //rotatelogs.WithRotationCount(10),       // Файлы, превышающие это число, будут удалены.
  rotatelogs.WithMaxAge(time.Hour*24*30), // Как долго хранить (установите максимальное время хранения перед очисткой файла) Минимальная единица минут)

  // Условия разделения (вырезать файл бревно; WithRotationTime and WithRotationSize ~~Он будет обрезан, если выполнено любое из условий~~)
  // После личного тестирования было обнаружено, что если бревно не продолжает увеличиваться и для WithRotationTime установлено небольшое значение (например, 10 с), файл не будет разделен в соответствии с частотой WithRotationTime. Когда бревно продолжает увеличиваться, оно будет разделено в соответствии с настройкой WithRotationTime (даже если настройка WithRotationTime очень мала)
  rotatelogs.WithRotationTime(time.Second*10),           // Делить каждые 10 секунд (установлен временной интервал резкой резки, по умолчанию). 24 * time.Hour)
  rotatelogs.WithRotationSize(int64(1*1024*35000*1024)), // Файл будет обрезан, когда достигнет максимального размера. bytes；

  // Другие варианты Конфигурация
  //default: rotatelogs.Local ,you can set rotatelogs.UTC
  //rotatelogs.WithClock(rotatelogs.UTC),
  //rotatelogs.WithLocation(time.Local),
  //--- Когда файл, созданный Rotatelogs.New(), существует, принудительно создайте новый файл. Назовите его как имя исходного файла + серийный номер. Если файл .log существует, создайте его. a.log.1
  //rotatelogs.ForceNewFile(),

  rotatelogs.WithHandler(rotatelogs.Handler(rotatelogs.HandlerFunc(func(e rotatelogs.Event) {
   if e.Type() != rotatelogs.FileRotatedEventType {
    return
   }

   fmt.Println("Вырезка завершена, приступайте к операции упаковки")

   spew.Dump("e is:", e)

   prevFile := e.(*rotatelogs.FileRotatedEvent).PreviousFile()

   if prevFile != "" {
    // выполнять
    paths, fileName := filepath.Split(prevFile)
    //_ = paths
    //err := Zip("archive.zip", paths, prevFile)
    err := ZipFiles(paths+fileName+".zip", []string{prevFile})
    fmt.Println("err is", err)

    if err == nil {
     os.RemoveAll(prevFile)
    }

   }

   fmt.Println("Тип e:", reflect.TypeOf(e))

   fmt.Println("------------------")
   fmt.Println()
   fmt.Println()
   fmt.Println()

   //ctx := CleanContext{
   // Dir:         LogsConfig.LogOutputDir,
   // DirMaxSizeG: LogsConfig.LogDirMaxSizeG,
   // DirMaxCount: LogsConfig.LogDirMaxFileCount,
   //}
   //strategyOne := CleanStrategyOne{}
   //result, err := NewCleanStrategy(&ctx, &strategyOne).
   // Clean().
   // Result()
   //Warn("Выполнена первая политика удаления и очистки файлов; Результат:%v; Ошибка: %v", result, err)
  }))),
 )

 if err != nil {
  panic(err)
 }
 return hook
}

// ZipFiles compresses one or many files into a single zip archive file.
// Param 1: filename is the output zip file's name.
// Param 2: files is a list of files to add to the zip.
func ZipFiles(filename string, files []string) error {

 newZipFile, err := os.Create(filename)
 if err != nil {
  return err
 }
 defer newZipFile.Close()

 zipWriter := zip.NewWriter(newZipFile)
 defer zipWriter.Close()

 // Add files to zip
 for _, file := range files {
  if err = AddFileToZip(zipWriter, file); err != nil {
   return err
  }
 }
 return nil
}

func AddFileToZip(zipWriter *zip.Writer, filename string) error {

 fileToZip, err := os.Open(filename)
 if err != nil {
  return err
 }
 defer fileToZip.Close()

 // Get the file information
 info, err := fileToZip.Stat()
 if err != nil {
  return err
 }

 header, err := zip.FileInfoHeader(info)
 if err != nil {
  return err
 }

 // Using FileInfoHeader() above only uses the basename of the file. If we want
 // to preserve the folder structure we can overwrite this with the full path.
 header.Name = filename

 // Change to deflate to gain better compression
 // see http://golang.org/pkg/archive/zip/#pkg-constants
 header.Method = zip.Deflate

 writer, err := zipWriter.CreateHeader(header)
 if err != nil {
  return err
 }
 _, err = io.Copy(writer, fileToZip)
 return err
}

//
//// Zip compresses the specified files or dirs to zip archive.
//// If a path is a dir don't need to specify the trailing path separator.
//// For example calling Zip("archive.zip", "dir", "csv/baz.csv") will get archive.zip and the content of which is
//// baz.csv
//// dir
//// ├── bar.txt
//// └── foo.txt
//// Note that if a file is a symbolic link it will be skipped.
//
//// https://blog.csdn.net/K346K346/article/details/122441250
//func Zip(zipPath string, paths ...string) error {
// // Create zip file and it's parent dir.
// if err := os.MkdirAll(filepath.Dir(zipPath), os.ModePerm); err != nil {
//  return err
// }
// archive, err := os.Create(zipPath)
// if err != nil {
//  return err
// }
// defer archive.Close()
//
// // New zip writer.
// zipWriter := zip.NewWriter(archive)
// defer zipWriter.Close()
//
// // Traverse the file or directory.
// for _, rootPath := range paths {
//  // Remove the trailing path separator if path is a directory.
//  rootPath = strings.TrimSuffix(rootPath, string(os.PathSeparator))
//
//  // Visit all the files or directories in the tree.
//  err = filepath.Walk(rootPath, walkFunc(rootPath, zipWriter))
//  if err != nil {
//   return err
//  }
// }
// return nil
//}
//
//func walkFunc(rootPath string, zipWriter *zip.Writer) filepath.WalkFunc {
// return func(path string, info fs.FileInfo, err error) error {
//  if err != nil {
//   return err
//  }
//
//  // If a file is a symbolic link it will be skipped.
//  if info.Mode()&os.ModeSymlink != 0 {
//   return nil
//  }
//
//  // Create a local file header.
//  header, err := zip.FileInfoHeader(info)
//  if err != nil {
//   return err
//  }
//
//  // Set compression method.
//  header.Method = zip.Deflate
//
//  // Set relative path of a file as the header name.
//  header.Name, err = filepath.Rel(filepath.Dir(rootPath), path)
//  if err != nil {
//   return err
//  }
//  if info.IsDir() {
//   header.Name += string(os.PathSeparator)
//  }
//
//  // Create writer for the file header and save content of the file.
//  headerWriter, err := zipWriter.CreateHeader(header)
//  if err != nil {
//   return err
//  }
//  if info.IsDir() {
//   return nil
//  }
//  f, err := os.Open(path)
//  if err != nil {
//   return err
//  }
//  defer f.Close()
//  _, err = io.Copy(headerWriter, f)
//  return err
// }
//}