From fd31206bcb8b084720291a53c986db771d8f5975 Mon Sep 17 00:00:00 2001
From: qixiaoning <jony.kee@outlook.com>
Date: 星期四, 18 九月 2025 13:58:16 +0800
Subject: [PATCH] 抓拍预警记录查询修改，备份还原接口问题修复，应用安装接口调试
---
appcenter-service/main.go | 40 +++++++++++++++++++++-------------------
1 files changed, 21 insertions(+), 19 deletions(-)
diff --git a/appcenter-service/main.go b/appcenter-service/main.go
index 2cf2c2d..9c99824 100644
--- a/appcenter-service/main.go
+++ b/appcenter-service/main.go
@@ -1,10 +1,6 @@
package main
import (
- "basic.com/valib/bhomeclient.git"
- "basic.com/valib/bhomedbapi.git"
- "basic.com/valib/logger.git"
- "basic.com/valib/version.git"
"context"
"flag"
"net/http"
@@ -17,14 +13,19 @@
"vamicro/appcenter-service/service"
"vamicro/config"
versionControlS "vamicro/version-control/service"
+
+ "basic.com/valib/bhomeclient.git"
+ "basic.com/valib/bhomedbapi.git"
+ "basic.com/valib/logger.git"
+ vaversion "basic.com/valib/version.git"
)
var (
procName = service.ProcName
- proc = &bhomeclient.ProcInfo{
+ proc = &bhomeclient.ProcInfo{
Name: procName, //杩涚▼鍚嶇О
- ID: procName, //杩涚▼id
- Info: "", //杩涚▼鐨勬弿杩颁俊鎭紝鐢ㄤ簬鍖哄垎鍚屼竴杩涚▼鍚嶇О涓嬪涓繘绋�
+ ID: procName, //杩涚▼id
+ Info: "", //杩涚▼鐨勬弿杩颁俊鎭紝鐢ㄤ簬鍖哄垎鍚屼竴杩涚▼鍚嶇О涓嬪涓繘绋�
}
env = flag.String("e", "pro", "")
)
@@ -35,29 +36,29 @@
config.Init(*env)
// 鏃ュ織鍒濆鍖�
- var logFile = config.LogConf.Path + "vamicro-"+procName+".log"
+ var logFile = config.LogConf.Path + "vamicro-" + procName + ".log"
logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
logger.Info("log init success !")
}
-func main(){
+func main() {
models.Init()
defer models.CloseDB()
ctx, cancel := context.WithCancel(context.Background())
- fm,pubTopics := initFuncMap()
- var reg = &bhomeclient.RegisterInfo {
- Proc: *proc,
- Channel: nil,
+ fm, pubTopics := initFuncMap()
+ var reg = &bhomeclient.RegisterInfo{
+ Proc: *proc,
+ Channel: nil,
PubTopic: pubTopics,
- SubTopic: []string{versionControlS.SysUpdateConfigTopic},
+ SubTopic: []string{versionControlS.SysUpdateConfigTopic},
}
q := make(chan os.Signal, 1)
signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)
ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, logger.Debug)
- if err !=nil {
+ if err != nil {
return
}
@@ -67,7 +68,7 @@
go ms.StartServer(fm)
go handleSubMsg(ctx, ms)
go service.SelfUpdateStart(ctx) //鑷姩鏇存柊
- go service.NoticeTick(ctx)//鏇存柊鎻愰啋
+ go service.NoticeTick(ctx) //鏇存柊鎻愰啋
// pprof 鐢ㄤ簬鍒嗘瀽鎬ц兘
go func() {
logger.Info(http.ListenAndServe("0.0.0.0:7073", nil))
@@ -80,7 +81,8 @@
}
const urlPrefix = "/data/api-v"
-func initFuncMap() (map[string]bhomeclient.MicroFunc,[]string) {
+
+func initFuncMap() (map[string]bhomeclient.MicroFunc, []string) {
funcMap := make(map[string]bhomeclient.MicroFunc)
sc := new(controllers.SdkController)
sa := new(controllers.SdkArgController)
@@ -113,7 +115,7 @@
funcMap[urlPrefix+"/app/upgrade/notice/delay"] = ac.DelayNotice
var pubTopics []string
- for key,_ := range funcMap {
+ for key, _ := range funcMap {
pubTopics = append(pubTopics, key)
}
return funcMap, pubTopics
@@ -129,4 +131,4 @@
service.PersistentWrapper(string(msg.Topic), msg.Data)
}
}
-}
\ No newline at end of file
+}
--
Gitblit v1.8.0