diff --git a/.gitignore b/.gitignore index 32b6bae..33559bf 100644 --- a/.gitignore +++ b/.gitignore @@ -1 +1,3 @@ -.lock \ No newline at end of file +.lock +logs/ +RawData/ diff --git a/iniDataForLinux b/iniDataForLinux index 3f6b8d6..e00c3c1 100755 Binary files a/iniDataForLinux and b/iniDataForLinux differ diff --git a/iniDataForMacOs b/iniDataForMacOs index 6784c81..e84968b 100755 Binary files a/iniDataForMacOs and b/iniDataForMacOs differ diff --git a/main.go b/main.go index 867a2d8..4237f50 100644 --- a/main.go +++ b/main.go @@ -113,13 +113,6 @@ func init() { log.Fatal("failed to get executable path: ", err) } executableDir = filepath.Dir(executablePath) - //判断目录是否存在,不存在则创建 - err = os.MkdirAll(filepath.Join(executableDir, zipPath), 0755) - err = os.MkdirAll(filepath.Join(executableDir, txtPath), 0755) - err = os.MkdirAll(filepath.Join(executableDir, logPath), 0755) - if err != nil { - log.Fatal(err) - } flag.StringVar(&env, "env", "dev", "运行模式") flag.Parse() @@ -170,6 +163,14 @@ func init() { panic(fmt.Errorf("无效的运行模式: %s", env)) } + //判断目录是否存在,不存在则创建 + err = os.MkdirAll(filepath.Join(executableDir, zipPath), 0755) + err = os.MkdirAll(filepath.Join(executableDir, txtPath), 0755) + err = os.MkdirAll(filepath.Join(executableDir, logPath, time.Now().Format("2006_01")), 0755) + if err != nil { + log.Fatal(err) + } + redisClient = redis.NewClient(&redis.Options{ Addr: redisAddress, Password: redisPassword, @@ -192,13 +193,13 @@ func main() { os.Exit(1) } applogger = logrus.New() - logPath := filepath.Join(executableDir, "logs") + logPath := filepath.Join(executableDir, "logs", time.Now().Format("2006_01")) logFileName := "sms_processing_" + time.Now().Format("2006_01_02") + ".log" logFileHook := &lumberjack.Logger{ Filename: filepath.Join(logPath, logFileName), } applogger.SetOutput(logFileHook) - + applogger.Info("程序启动....") go downloadDecompression() // 启动立即执行一次 ticker := time.NewTicker(time.Duration(taskTime) * time.Minute) // 创建一个定时器,每隔一分钟触发一次任务函数