| | |
| | | "time" |
| | | ) |
| | | |
| | | var env = flag.String("app", "app", "read database info") |
| | | var env = flag.String("rulemodelengine", "rulemodelengine", "read database info") |
| | | |
| | | func init() { |
| | | config.Init(*env) |
| | | var logFile = config.LogConf.Path + "annotation_service.log" |
| | | var logFile = config.LogConf.Path + "rule_model_engine.log" |
| | | logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge) |
| | | logger.Info("loginit success !") |
| | | dbErr := db.ConnectDB() |
| | |
| | | logger.Error("设备表缓存失败", cacheErr) |
| | | return |
| | | } |
| | | logger.Info("cache device success !") |
| | | cacheErr = cache.PublicHouseCacheInit() |
| | | if cacheErr != nil { |
| | | logger.Error("公租房数据缓存失败", cacheErr) |
| | | return |
| | | } |
| | | logger.Info("cache init success !") |
| | | } |
| | | |
| | | func initApiServer() { |
| | |
| | | |
| | | func main() { |
| | | //db.UpdatePersonStatusByIds() |
| | | immediate := flag.Bool("immediate", false, "whether to execute immediately") |
| | | immediate := flag.Bool("immediate", true, "whether to execute immediately") |
| | | flag.Parse() |
| | | |
| | | if *immediate { |