admin/bl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

```

Browse Source 
refactor(cool): 修复Logger变量名拼写错误

将全局Logger变量从Loger修正为Logger，统一日志实例命名规范，
确保所有模块中日志记录的一致性。

BREAKING CHANGE: 全局日志实例变量名从Loger改为Logger
```
This commit is contained in:
昔念
2025-12-25 12:14:04 +08:00
parent ff199e339f
commit 164e70519f
30 changed files with 85 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
common/cool/cool.go
View File

@@ -33,7 +33,7 @@ func init() {
ctx = gctx.GetInitCtx()
redisConfig = &gredis.Config{}
)
Loger.Debug(ctx, "module cool init start ...", gtime.Now())
Logger.Debug(ctx, "module cool init start ...", gtime.Now())
buildData := gbuild.Data()
if _, ok := buildData["mode"]; ok {
RunMode = buildData["mode"].(string)
@@ -43,7 +43,7 @@ func init() {
}
redisVar, err := g.Cfg().Get(ctx, "redis.cool")
if err != nil {
Loger.Error(ctx, "初始化缓存失败,请检查配置文件")
Logger.Error(ctx, "初始化缓存失败,请检查配置文件")
panic(err)
}
if !redisVar.IsEmpty() {
@@ -57,9 +57,9 @@ func init() {
g.DB().GetCache().SetAdapter(gcache.NewAdapterRedis(redis)) //设置数据库
}
//Logerebug(ctx, "当前运行模式", RunMode)
Loger.Debug(ctx, "当前实例ID:", ProcessFlag)
Loger.Debug(ctx, "是否缓存模式:", IsRedisMode)
Loger.Debug(ctx, "module cool init finished ...")
Logger.Debug(ctx, "当前实例ID:", ProcessFlag)
Logger.Debug(ctx, "是否缓存模式:", IsRedisMode)
Logger.Debug(ctx, "module cool init finished ...")
}

2
common/cool/ctx.go
View File

@@ -31,7 +31,7 @@ func GetAdmin(ctx context.Context) *Admin {
admin := &Admin{}
err := gjson.New(r.GetCtxVar("admin").String()).Scan(admin)
if err != nil {
Loger.Error(ctx, err)
Logger.Error(ctx, err)
}
return admin
}

8
common/cool/func.go
View File

@@ -41,7 +41,7 @@ func RunFunc(ctx g.Ctx, funcstring string) (err error) {
if !FuncMap[funcName].IsAllWorker() {
// 检查当前是否为主进程, 如果不是主进程, 则不执行
if ProcessFlag != CacheManager.MustGetOrSet(ctx, "cool:masterflag", ProcessFlag, 60*time.Second).String() {
Loger.Debug(ctx, "当前进程不是主进程, 不执行单例函数", funcName)
Logger.Debug(ctx, "当前进程不是主进程, 不执行单例函数", funcName)
return
}
}
@@ -79,7 +79,7 @@ func ListenFunc(ctx g.Ctx) {
for {
data, err := conn.Receive(ctx)
if err != nil {
Loger.Error(ctx, err)
Logger.Error(ctx, err)
time.Sleep(10 * time.Second)
continue
}
@@ -89,10 +89,10 @@ func ListenFunc(ctx g.Ctx) {
continue
}
if dataMap["Channel"] == "cool:func" {
Loger.Debug(ctx, "执行函数", dataMap["Payload"])
Logger.Debug(ctx, "执行函数", dataMap["Payload"])
err := RunFunc(ctx, dataMap["Payload"])
if err != nil {
Loger.Error(ctx, "执行函数失败", err)
Logger.Error(ctx, "执行函数失败", err)
}
}
}

8
common/cool/global.go
View File

@@ -28,8 +28,8 @@ type Cmd struct {
var (
CmdCache = &utils.SyncMap[uint32, Cmd]{} //命令缓存
Loger = glog.New()
Cron = cronex.New() //时间轮
Logger = glog.New()
Cron = cronex.New() //时间轮
)
var Filter *sensitive.Manager
@@ -37,8 +37,8 @@ var DefaultGenerator = utils.NewGen(time.Date(2025, 1, 1, 0, 0, 0, 0, time.UTC),
func init() {
// 创建 IdGeneratorOptions 对象，可在构造函数中输入 WorkerId：
Loger.SetFlags(glog.F_TIME_STD | glog.F_FILE_LONG | glog.F_ASYNC) //设置flag
Loger.Print(ctx, "初始化日志")
Logger.SetFlags(glog.F_TIME_STD | glog.F_FILE_LONG | glog.F_ASYNC) //设置flag
Logger.Print(ctx, "初始化日志")
// for i := 0; i < 600; i++ {
// glog.Debug(context.Background(), i, "初始化雪花算法", DefaultGenerator.Get())
// }

12
common/cool/initdb.go
View File

@@ -66,30 +66,30 @@ func FillInitData(ctx g.Ctx, moduleName string, model IModel, ismod *bool) (bool
mInit := g.DB("default").Model("base_sys_init")
n, err := mInit.Clone().Where("group", model.GroupName()).Where("table", model.TableName()).Count()
if err != nil {
Loger.Error(ctx, "读取表 base_sys_init 失败 ", err.Error())
Logger.Error(ctx, "读取表 base_sys_init 失败 ", err.Error())
return false, err
}
if n > 0 {
Loger.Debug(ctx, "分组", model.GroupName(), "中的表", model.TableName(), "已经初始化过,跳过本次初始化.")
Logger.Debug(ctx, "分组", model.GroupName(), "中的表", model.TableName(), "已经初始化过,跳过本次初始化.")
return false, err
}
m := g.DB(model.GroupName()).Model(model.TableName())
jsonData, _ := gjson.LoadContent(gres.GetContent("modules/" + moduleName + "/resource/initjson/" + model.TableName() + ".json"))
if jsonData.Var().Clone().IsEmpty() {
Loger.Debug(ctx, "分组", model.GroupName(), "中的表", model.TableName(), "无可用的初始化数据,跳过本次初始化.")
Logger.Debug(ctx, "分组", model.GroupName(), "中的表", model.TableName(), "无可用的初始化数据,跳过本次初始化.")
return false, err
}
_, err = m.Data(jsonData).Insert()
if err != nil {
Loger.Error(ctx, err.Error())
Logger.Error(ctx, err.Error())
return false, err
}
_, err = mInit.Insert(g.Map{"group": model.GroupName(), "table": model.TableName()})
if err != nil {
Loger.Error(ctx, err.Error())
Logger.Error(ctx, err.Error())
return false, err
}
Loger.Info(ctx, "分组", model.GroupName(), "中的表", model.TableName(), "初始化完成.")
Logger.Info(ctx, "分组", model.GroupName(), "中的表", model.TableName(), "初始化完成.")
if ismod != nil {
*ismod = true
}

2
common/cool/service.go
View File

@@ -243,7 +243,7 @@ func (s *Service) ServiceList(ctx context.Context, req *ListReq) (data interface
result, err := m.All()
if err != nil {
Loger.Error(ctx, "ServiceList error:", err)
Logger.Error(ctx, "ServiceList error:", err)
}
if result == nil {
data = garray.New()

2
common/rpc/client.go
View File

@@ -35,7 +35,7 @@ func GetServerInfoList() []ServerInfo {
t, ok := cool.GetClient(v.Port)
if ok {
cool.Loger.Info(context.TODO(), "服务器假踢人")
cool.Logger.Info(context.TODO(), "服务器假踢人")
err := t.KickPerson(0) //实现指定服务器踢人
if err == nil {

8
common/rpc/rpc.go
View File

@@ -24,7 +24,7 @@ type ServerHandler struct{}
// 实现踢人
func (h *ServerHandler) Kick(ctx context.Context, userid uint32) error {
cool.Loger.Info(context.TODO(), "服务器收到踢人")
cool.Logger.Info(context.TODO(), "服务器收到踢人")
useid1, err := share.ShareManager.GetUserOnline(userid)
if err != nil {
@@ -43,7 +43,7 @@ func (h *ServerHandler) Kick(ctx context.Context, userid uint32) error {
// 注册logic服务器
func (h *ServerHandler) RegisterLogic(ctx context.Context, id, port uint16) error {
cool.Loger.Debug(context.Background(), "注册logic服务器", id, port)
cool.Logger.Debug(context.Background(), "注册logic服务器", id, port)
//TODO 待修复滚动更新可能导致的玩家可以同时在旧服务器和新服务器同时在线的bug
revClient, ok := jsonrpc.ExtractReverseClient[cool.ClientHandler](ctx)
@@ -67,13 +67,13 @@ func StartServer() {
rpcServer := jsonrpc.NewServer(jsonrpc.WithReverseClient[cool.ClientHandler](""))
rpcServer.Register("", &ServerHandler{})
cool.Loger.Debug(context.Background(), "jsonrpc server start", rpcport)
cool.Logger.Debug(context.Background(), "jsonrpc server start", rpcport)
// go time.AfterFunc(3000, func() {
// testjsonrpc()
// })
err := http.ListenAndServe("0.0.0.0:"+rpcport, rpcServer)
cool.Loger.Debug(context.Background(), "jsonrpc server fail", err)
cool.Logger.Debug(context.Background(), "jsonrpc server fail", err)
}
var closer jsonrpc.ClientCloser

6
common/socket/ServerEvent.go
View File

@@ -44,7 +44,7 @@ func (s *Server) OnClose(c gnet.Conn, err error) (action gnet.Action) {
if err := recover(); err != nil { // 恢复 panic，err 为 panic 错误值
// 1. 打印错误信息
cool.Loger.Error(context.TODO(), "panic 错误：", err)
cool.Logger.Error(context.TODO(), "panic 错误：", err)
}
}()
@@ -111,7 +111,7 @@ func (s *Server) OnTraffic(c gnet.Conn) (action gnet.Action) {
if err := recover(); err != nil { // 恢复 panic，err 为 panic 错误值
// 1. 打印错误信息
cool.Loger.Error(context.TODO(), "panic 错误：", err)
cool.Logger.Error(context.TODO(), "panic 错误：", err)
}
}()
@@ -187,7 +187,7 @@ func (s *Server) handleTcp(conn gnet.Conn) (action gnet.Action) {
if conn.InboundBuffered() > 0 {
if err := conn.Wake(nil); err != nil { // wake up the connection manually to avoid missing the leftover data
cool.Loger.Errorf(context.Background(), "failed to wake up the connection, %v", err)
cool.Logger.Errorf(context.Background(), "failed to wake up the connection, %v", err)
return gnet.Close
}
}

4
common/socket/kick.go
View File

@@ -12,7 +12,7 @@ type Broadcast struct {
}
func (h *Server) Broadcast(t string) int {
cool.Loger.Info(context.TODO(), "全服广播", t)
cool.Logger.Info(context.TODO(), "全服广播", t)
var count int
player.Mainplayer.Range(func(key uint32, value *player.Player) bool {
count++
@@ -25,7 +25,7 @@ func (h *Server) Broadcast(t string) int {
return count
}
func (h *Server) KickPerson(a int) error {
cool.Loger.Info(context.TODO(), "检测到踢人请求", a)
cool.Logger.Info(context.TODO(), "检测到踢人请求", a)
if a == 0 {
return nil
}