From 8496ad2c954f6caaf3c9155f58f81ca04d5d5451 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期一, 09 九月 2024 20:52:30 +0800
Subject: [PATCH] 1、住户不再降级 2、住户地址随时间边长定位越来越准确 3、住户分析的服务人员归类到访客
---
main.go | 50 ++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 46 insertions(+), 4 deletions(-)
diff --git a/main.go b/main.go
index b03808f..86e9d3a 100644
--- a/main.go
+++ b/main.go
@@ -1,7 +1,16 @@
package main
import (
+ "basic.com/CloudAI/protomsg.git/analysis"
+ "google.golang.org/grpc"
+ "net"
+ "ruleModelEngine/api/analysisApi"
+ "ruleModelEngine/cache"
"ruleModelEngine/config"
+ "ruleModelEngine/db"
+
+ //"ruleModelEngine/task"
+
//"annotation_service/db"
"basic.com/valib/logger.git"
"flag"
@@ -9,14 +18,40 @@
"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()
+ if dbErr != nil {
+ logger.Error("鏁版嵁搴撹繛鎺ュけ璐�", dbErr)
+ return
+ }
+ logger.Info("ConnectDB success !")
+ cacheErr := cache.DeviceCacheInit()
+ if cacheErr != nil {
+ logger.Error("璁惧琛ㄧ紦瀛樺け璐�", cacheErr)
+ return
+ }
+ logger.Info("cache device success !")
+}
+func initApiServer() {
+ ln, err := net.Listen("tcp", config.Api.Host+":"+config.Api.Port)
+ if err != nil {
+ logger.Fatal("grpc server init error: %v", err.Error())
+ //panic(fmt.Sprintf("grpc server init error: %v", err.Error()))
+ }
+ s := grpc.NewServer()
+ analysis.RegisterAnalysisServiceServer(s, &analysisApi.Server{})
+ err = s.Serve(ln)
+ if err != nil {
+ logger.Fatal("grpc server init error: %v", err.Error())
+ //panic(fmt.Sprintf("grpc server init error: %v", err.Error()))
+ }
}
func main() {
@@ -28,11 +63,18 @@
logger.Info("Executing immediately...")
rule.ExecuteTask()
}
-
+ //r, _ := db.QueryByDays(3)
+ //for _, id := range r {
+ // task.TaskAnalysisService(id)
+ //}
+ //fmt.Println("ids: ", len(r))
+ //return
+ //task.TaskAnalysisService("3407b20e-6343-4832-88fa-a8e986552532")
+ go initApiServer()
+ //return
now := time.Now()
next := time.Date(now.Year(), now.Month(), now.Day()+1, 1, 0, 0, 0, now.Location())
duration := next.Sub(now)
-
timer := time.NewTimer(duration)
logger.Info("The program has started and will execute at one o'clock in the early morning every night.")
for {
--
Gitblit v1.8.0