From c3fd4effdef0cc5955f89b5df279b14841e857f5 Mon Sep 17 00:00:00 2001
From: qixiaoning <jony.kee@outlook.com>
Date: 星期二, 11 十一月 2025 11:21:36 +0800
Subject: [PATCH] 修改权限,修复删除rag记录问题
---
api-gateway/main.go | 70 ++++++++++++++++++++++++++++++-----
1 files changed, 60 insertions(+), 10 deletions(-)
diff --git a/api-gateway/main.go b/api-gateway/main.go
index 332b684..6da26ea 100644
--- a/api-gateway/main.go
+++ b/api-gateway/main.go
@@ -1,14 +1,17 @@
package main
import (
+ "context"
+ "encoding/json"
+ "flag"
+
"basic.com/valib/logc.git"
"basic.com/valib/logger.git"
- "basic.com/valib/version.git"
- "context"
- "flag"
+ vaversion "basic.com/valib/version.git"
"github.com/gin-gonic/gin"
-// "net/http"
-// _ "net/http/pprof"
+
+ // "net/http"
+ // _ "net/http/pprof"
"os"
"os/signal"
"syscall"
@@ -19,21 +22,26 @@
"vamicro/api-gateway/traces"
"vamicro/config"
"vamicro/extend/util"
+
+ bh "basic.com/valib/c_bhomebus.git/api/bhsgo"
+ bhmsg "basic.com/valib/c_bhomebus.git/proto/source/bhome_msg"
)
var (
- procName = service.ProcName
- env = flag.String("e", "pro", "")
+ procName = service.ProcName
+ env = flag.String("e", "pro", "")
+ VaSystemLogTopic = "VaSystemLogSaveTopic"
)
-//func init() {
+// func init() {
func sinit() {
flag.Parse()
+ //鎺у埗鍙版墦鍗扮増鏈�
vaversion.Usage()
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 !")
}
@@ -44,11 +52,22 @@
// logger.Info(http.ListenAndServe("0.0.0.0:6077", nil))
//}()
- sinit()
+ sinit()
models.Init()
defer models.CloseDB()
ctx, cancel := context.WithCancel(context.Background())
+
+ defer func() {
+ logInfo2 := logc.VaSystemLog{
+ HostName: "localhost",
+ ProcName: "smartai",
+ ProcID: os.Getpid(),
+ Level: logc.LevelInfo,
+ Info: "smartai鍋滄",
+ }
+ LogDecoderInfo(ctx, logInfo2)
+ }()
q := make(chan os.Signal, 1)
signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)
@@ -62,6 +81,18 @@
})
auth.Oauth2Init()
util.AuthCheck(ctx) //鎺堟潈妫�鏌�
+
+ //璁板綍鏃ュ織
+ logInfo := logc.VaSystemLog{
+ HostName: "localhost",
+ ProcName: "smartai",
+ ProcID: os.Getpid(),
+ Level: logc.LevelInfo,
+ Info: "smartai鍚姩",
+ }
+
+ LogDecoderInfo(ctx, logInfo)
+
go func() {
r := gin.Default()
r.Use(auth.AuthHandler())
@@ -81,3 +112,22 @@
logger.Debug("client is nil")
}
}
+
+// 淇濆瓨绯荤粺鏃ュ織
+func LogDecoderInfo(ctx context.Context, logInfo logc.VaSystemLog) {
+
+ logger.Debug("start LogDecoderInfo")
+
+ go func() {
+
+ logData, _ := json.Marshal(logInfo)
+ pub := bhmsg.MsgPublish{
+ Topic: []byte(VaSystemLogTopic),
+ Data: logData,
+ }
+ if !bh.Publish(&pub, 1000) {
+ logger.Error("LogDecoderInfo %s failed\n", VaSystemLogTopic)
+ }
+
+ }()
+}
--
Gitblit v1.8.0