From 636008b97d9c5a913bab262ef4b01743e21a34ad Mon Sep 17 00:00:00 2001
From: "DESKTOP-V763RJ7\\Administrator" <835606593@qq.com>
Date: Wed, 14 Jan 2026 18:15:36 +0800
Subject: [PATCH] =?UTF-8?q?feat=20=E5=8E=86=E5=8F=B2=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/grpc.go                                   |  4 ++--
 config/config.dev.yaml                        |  3 ++-
 config/config.go                              |  5 ++--
 config/config.prod.yaml                       |  3 ++-
 go.mod                                        |  2 +-
 go.sum                                        |  2 --
 internal/global/global.go                     |  8 -------
 internal/grpc_server/{server => }/server.go   |  2 +-
 .../grpc_server/{server => }/server_init.go   |  2 +-
 internal/handler/http_handler/login.go        | 14 +++++------
 internal/handler/http_handler/login_test.go   | 20 ++++++++--------
 .../ws_handler/client/client_handler.go       | 10 ++++----
 internal/handler/ws_handler/login/login.go    |  4 ++--
 internal/net/http_gateway/middleward.go       | 24 ++++++++-----------
 internal/net/http_gateway/router.go           | 16 +++++++------
 internal/testutil/suite.go                    |  5 ++--
 16 files changed, 58 insertions(+), 66 deletions(-)
 rename internal/grpc_server/{server => }/server.go (98%)
 rename internal/grpc_server/{server => }/server_init.go (97%)

diff --git a/app/grpc.go b/app/grpc.go
index 77ed571..e6640f8 100644
--- a/app/grpc.go
+++ b/app/grpc.go
@@ -3,7 +3,7 @@ package app
 import (
 	"git.hlsq.asia/mmorpg/service-common/net/grpc/service"
 	"git.hlsq.asia/mmorpg/service-gateway/config"
-	"git.hlsq.asia/mmorpg/service-gateway/internal/grpc_server/server"
+	"git.hlsq.asia/mmorpg/service-gateway/internal/grpc_server"
 )
 
 // ModuleGrpcServer Grpc服务模块
@@ -16,7 +16,7 @@ func (m *ModuleGrpcServer) init() error {
 }
 
 func (m *ModuleGrpcServer) start() error {
-	m.server = server.NewServer(config.Get().Serve.Grpc.TTL)
+	m.server = grpc_server.NewServer(config.Get().Serve.Grpc.TTL)
 	m.server.Init(config.Get().Serve.Grpc.Address, config.Get().Serve.Grpc.Port)
 	return nil
 }
diff --git a/config/config.dev.yaml b/config/config.dev.yaml
index 804ae4c..31fd0bb 100644
--- a/config/config.dev.yaml
+++ b/config/config.dev.yaml
@@ -39,4 +39,5 @@ serve:
 
 auth:
   secret: "bMa3mU4oCsX2KBex5o7GzwSnACpumFq3SdlDXYZgVTU="
-  expire: 259200
+  shortExpire: 60
+  longExpire: 10080
diff --git a/config/config.go b/config/config.go
index efd145d..f18de65 100644
--- a/config/config.go
+++ b/config/config.go
@@ -14,8 +14,9 @@ type Config struct {
 }
 
 type AuthConfig struct {
-	Secret string `yaml:"secret"`
-	Expire int64  `yaml:"expire"`
+	Secret      string `yaml:"secret"`
+	ShortExpire int64  `yaml:"shortExpire"`
+	LongExpire  int64  `yaml:"longExpire"`
 }
 
 var cfg *Config
diff --git a/config/config.prod.yaml b/config/config.prod.yaml
index a944c9e..41499f2 100644
--- a/config/config.prod.yaml
+++ b/config/config.prod.yaml
@@ -39,4 +39,5 @@ serve:
 
 auth:
   secret: "bMa3mU4oCsX2KBex5o7GzwSnACpumFq3SdlDXYZgVTU="
-  expire: 259200
\ No newline at end of file
+  shortExpire: 15
+  longExpire: 10080
\ No newline at end of file
diff --git a/go.mod b/go.mod
index b39c35f..ff1c4ff 100644
--- a/go.mod
+++ b/go.mod
@@ -4,7 +4,7 @@ go 1.23.1
 
 require (
 	bou.ke/monkey v1.0.2
-	git.hlsq.asia/mmorpg/service-common v0.0.0-20260113095415-34b2e45e3d50
+	git.hlsq.asia/mmorpg/service-common v0.0.0-20260114100922-695f5e7b0497
 	github.com/alicebob/miniredis/v2 v2.35.0
 	github.com/gin-contrib/cors v1.7.6
 	github.com/gin-gonic/gin v1.11.0
diff --git a/go.sum b/go.sum
index f15789d..f0883d3 100644
--- a/go.sum
+++ b/go.sum
@@ -2,8 +2,6 @@ bou.ke/monkey v1.0.2 h1:kWcnsrCNUatbxncxR/ThdYqbytgOIArtYWqcQLQzKLI=
 bou.ke/monkey v1.0.2/go.mod h1:OqickVX3tNx6t33n1xvtTtu85YN5s6cKwVug+oHMaIA=
 filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
-git.hlsq.asia/mmorpg/service-common v0.0.0-20260113095415-34b2e45e3d50 h1:T0JZl2N+HMYRgyifEGFXD2y1MZOuoAS1xjnIg/JLGwM=
-git.hlsq.asia/mmorpg/service-common v0.0.0-20260113095415-34b2e45e3d50/go.mod h1:xv6m1I2jUA6mudKVznygpnzMoshBQarthHD1QnkW4qc=
 github.com/BurntSushi/toml v1.2.0 h1:Rt8g24XnyGTyglgET/PRUNlrUeu9F5L+7FilkXfZgs0=
 github.com/BurntSushi/toml v1.2.0/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
 github.com/alicebob/miniredis/v2 v2.35.0 h1:QwLphYqCEAo1eu1TqPRN2jgVMPBweeQcR21jeqDCONI=
diff --git a/internal/global/global.go b/internal/global/global.go
index e214366..91ed60f 100644
--- a/internal/global/global.go
+++ b/internal/global/global.go
@@ -15,14 +15,6 @@ const (
 	MaxQueueUpSize = 100 // 最大排队人数
 )
 
-// PublicPaths 不需要鉴权的接口，硬编码注册
-var PublicPaths = []string{
-	"/user/info",
-	"/qgdzs/get_question",
-	"/qgdzs/answer_question",
-	"/qgdzs/get_all_category",
-}
-
 var (
 	OnlineUsersGauge prometheus.Gauge
 )
diff --git a/internal/grpc_server/server/server.go b/internal/grpc_server/server.go
similarity index 98%
rename from internal/grpc_server/server/server.go
rename to internal/grpc_server/server.go
index 425a76a..6d6dfd3 100644
--- a/internal/grpc_server/server/server.go
+++ b/internal/grpc_server/server.go
@@ -1,4 +1,4 @@
-package server
+package grpc_server
 
 import (
 	"context"
diff --git a/internal/grpc_server/server/server_init.go b/internal/grpc_server/server_init.go
similarity index 97%
rename from internal/grpc_server/server/server_init.go
rename to internal/grpc_server/server_init.go
index 8cfde4d..4fb2b88 100644
--- a/internal/grpc_server/server/server_init.go
+++ b/internal/grpc_server/server_init.go
@@ -1,4 +1,4 @@
-package server
+package grpc_server
 
 import (
 	"git.hlsq.asia/mmorpg/service-common/discover/common"
diff --git a/internal/handler/http_handler/login.go b/internal/handler/http_handler/login.go
index 52828c3..4d9900d 100644
--- a/internal/handler/http_handler/login.go
+++ b/internal/handler/http_handler/login.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"git.hlsq.asia/mmorpg/service-common/db/redis"
 	"git.hlsq.asia/mmorpg/service-common/log"
-	"git.hlsq.asia/mmorpg/service-common/net/grpc/service"
+	"git.hlsq.asia/mmorpg/service-common/net/grpc/grpc_client"
 	"git.hlsq.asia/mmorpg/service-common/net/http/http_resp"
 	"git.hlsq.asia/mmorpg/service-common/proto/rs/grpc_pb"
 	"git.hlsq.asia/mmorpg/service-common/utils"
@@ -36,7 +36,7 @@ func Login(c *gin.Context) {
 		http_resp.JsonBadRequest(c)
 		return
 	}
-	client, err := service.UserNewClientLB()
+	client, err := grpc_client.UserNewClientLB()
 	if err != nil {
 		log.Errorf("Login UserNewClientLB error: %v", err)
 		http_resp.JsonOK(c, http_resp.Error(http_resp.Failed))
@@ -97,11 +97,11 @@ func RefreshToken(c *gin.Context) {
 	}
 	claims, err := utils.ParseToken(req.RefreshToken, config.Get().Auth.Secret)
 	if err != nil {
-		http_resp.JsonOK(c, http_resp.Error(http_resp.TokenInvalid))
+		http_resp.JsonUnauthorized(c)
 		return
 	}
 	if redis.GetClient().Get(c, fmt.Sprintf(global.KeyGatewayRefreshToken, claims.USN)).Val() != req.RefreshToken {
-		http_resp.JsonOK(c, http_resp.Error(http_resp.TokenInvalid))
+		http_resp.JsonUnauthorized(c)
 		return
 	}
 	at, rt, err := genToken(c, claims.USN)
@@ -118,11 +118,11 @@ func RefreshToken(c *gin.Context) {
 }
 
 func genToken(ctx context.Context, usn string) (string, string, error) {
-	at, err := genTokenOne(ctx, global.KeyGatewayAccessToken, usn, 2*time.Hour)
+	at, err := genTokenOne(ctx, global.KeyGatewayAccessToken, usn, time.Duration(config.Get().Auth.ShortExpire)*time.Minute)
 	if err != nil {
 		return "", "", err
 	}
-	rt, err := genTokenOne(ctx, global.KeyGatewayRefreshToken, usn, 3*24*time.Hour)
+	rt, err := genTokenOne(ctx, global.KeyGatewayRefreshToken, usn, time.Duration(config.Get().Auth.LongExpire)*time.Minute)
 	if err != nil {
 		return "", "", err
 	}
@@ -130,7 +130,7 @@ func genToken(ctx context.Context, usn string) (string, string, error) {
 }
 
 func genTokenOne(ctx context.Context, key string, usn string, ttl time.Duration) (string, error) {
-	token, err := utils.GenToken(usn, config.Get().Auth.Secret, time.Duration(config.Get().Auth.Expire)*time.Second)
+	token, err := utils.GenToken(usn, config.Get().Auth.Secret, ttl)
 	if err != nil {
 		return "", err
 	}
diff --git a/internal/handler/http_handler/login_test.go b/internal/handler/http_handler/login_test.go
index 402cc85..65ce79b 100644
--- a/internal/handler/http_handler/login_test.go
+++ b/internal/handler/http_handler/login_test.go
@@ -5,7 +5,7 @@ import (
 	"context"
 	"fmt"
 	"git.hlsq.asia/mmorpg/service-common/db/redis"
-	"git.hlsq.asia/mmorpg/service-common/net/grpc/service"
+	"git.hlsq.asia/mmorpg/service-common/net/grpc/grpc_client"
 	"git.hlsq.asia/mmorpg/service-common/net/http/http_resp"
 	"git.hlsq.asia/mmorpg/service-common/proto/rs/grpc_pb"
 	"git.hlsq.asia/mmorpg/service-common/proto/rs/grpc_pb/mocks"
@@ -50,10 +50,10 @@ func (ts *LoginTestSuite) TestLogin() {
 	})
 
 	ts.Run("UserNewClientLB Failed", func() {
-		monkey.Patch(service.UserNewClientLB, func() (grpc_pb.UserClient, error) {
+		monkey.Patch(grpc_client.UserNewClientLB, func() (grpc_pb.UserClient, error) {
 			return nil, assert.AnError
 		})
-		defer monkey.Unpatch(service.UserNewClientLB)
+		defer monkey.Unpatch(grpc_client.UserNewClientLB)
 
 		w, c := utils.CreateTestContext("POST", "/", &LoginReq{
 			Phone: "13800000000",
@@ -68,13 +68,13 @@ func (ts *LoginTestSuite) TestLogin() {
 		defer ctrl.Finish()
 		client := mocks.NewMockUserClient(ctrl)
 		client.EXPECT().
-			Login(gomock.Any(), gomock.Any()).
+			PhoneLogin(gomock.Any(), gomock.Any()).
 			Return(nil, fmt.Errorf("gRPC failed"))
 
-		monkey.Patch(service.UserNewClientLB, func() (grpc_pb.UserClient, error) {
+		monkey.Patch(grpc_client.UserNewClientLB, func() (grpc_pb.UserClient, error) {
 			return client, nil
 		})
-		defer monkey.Unpatch(service.UserNewClientLB)
+		defer monkey.Unpatch(grpc_client.UserNewClientLB)
 
 		w, c := utils.CreateTestContext("POST", "/", &LoginReq{
 			Phone: "13800000000",
@@ -89,13 +89,13 @@ func (ts *LoginTestSuite) TestLogin() {
 		defer ctrl.Finish()
 		client := mocks.NewMockUserClient(ctrl)
 		client.EXPECT().
-			Login(gomock.Any(), gomock.Any()).
-			Return(&grpc_pb.LoginResp{USN: "1", Name: "hh"}, nil)
+			PhoneLogin(gomock.Any(), gomock.Any()).
+			Return(&grpc_pb.PhoneLoginResp{USN: "1", Name: "hh"}, nil)
 
-		monkey.Patch(service.UserNewClientLB, func() (grpc_pb.UserClient, error) {
+		monkey.Patch(grpc_client.UserNewClientLB, func() (grpc_pb.UserClient, error) {
 			return client, nil
 		})
-		defer monkey.Unpatch(service.UserNewClientLB)
+		defer monkey.Unpatch(grpc_client.UserNewClientLB)
 
 		w, c := utils.CreateTestContext("POST", "/", &LoginReq{
 			Phone: "13800000000",
diff --git a/internal/handler/ws_handler/client/client_handler.go b/internal/handler/ws_handler/client/client_handler.go
index 77c41e5..2b8fd2e 100644
--- a/internal/handler/ws_handler/client/client_handler.go
+++ b/internal/handler/ws_handler/client/client_handler.go
@@ -4,8 +4,7 @@ import (
 	"context"
 	"fmt"
 	"git.hlsq.asia/mmorpg/service-common/db/redis"
-	"git.hlsq.asia/mmorpg/service-common/net/grpc/service"
-	"git.hlsq.asia/mmorpg/service-common/net/grpc/stream_client"
+	"git.hlsq.asia/mmorpg/service-common/net/grpc/grpc_client"
 	"git.hlsq.asia/mmorpg/service-common/proto/rs/grpc_pb"
 	"git.hlsq.asia/mmorpg/service-common/proto/ss/ss_pb"
 	"git.hlsq.asia/mmorpg/service-gateway/internal/global"
@@ -55,7 +54,7 @@ func (c *Client) handle(event Event) {
 }
 
 func (c *Client) onEnter(msg *ss_pb.C2S_EnterInstance) {
-	client, err := service.SceneNewClientLB()
+	client, err := grpc_client.SceneNewClientLB()
 	if err != nil {
 		c.logger.Errorf("SceneNewClient err: %v", err)
 		return
@@ -79,7 +78,7 @@ func (c *Client) onLeave() {
 	if c.SceneSID == "" {
 		return
 	}
-	client, err := service.SceneNewClient(c.SceneSID)
+	client, err := grpc_client.SceneNewClient(c.SceneSID)
 	if err != nil {
 		c.logger.Errorf("SceneNewClient err: %v", err)
 		return
@@ -98,7 +97,7 @@ func (c *Client) onAction(msg *ss_pb.C2S_Action) {
 	if c.SceneSID == "" {
 		return
 	}
-	if err := stream_client.SendMessageToScene(c.SceneSID, stream_client.FunAction, &grpc_pb.ActionReq{
+	if err := grpc_client.SendMessageToScene(c.SceneSID, grpc_client.FunAction, &grpc_pb.ActionReq{
 		UniqueNo: c.UniqueNo,
 		USN:      c.USN,
 		Action:   int32(msg.Action),
@@ -107,5 +106,6 @@ func (c *Client) onAction(msg *ss_pb.C2S_Action) {
 		SkillID:  msg.SkillID,
 	}); err != nil {
 		c.logger.Errorf("send action err: %v", err)
+		return
 	}
 }
diff --git a/internal/handler/ws_handler/login/login.go b/internal/handler/ws_handler/login/login.go
index e2ad47b..466f338 100644
--- a/internal/handler/ws_handler/login/login.go
+++ b/internal/handler/ws_handler/login/login.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"git.hlsq.asia/mmorpg/service-common/db/redis"
 	"git.hlsq.asia/mmorpg/service-common/log"
-	"git.hlsq.asia/mmorpg/service-common/net/grpc/service"
+	"git.hlsq.asia/mmorpg/service-common/net/grpc/grpc_client"
 	"git.hlsq.asia/mmorpg/service-common/proto/rs/grpc_pb"
 	"git.hlsq.asia/mmorpg/service-common/proto/ss/ss_pb"
 	"git.hlsq.asia/mmorpg/service-gateway/internal/global"
@@ -162,7 +162,7 @@ func (l *Login) CheckOnline(user *User) string {
 
 // KickUser 把玩家踢下线
 func (l *Login) KickUser(gatewaySID string, usn string) bool {
-	gc, err := service.GatewayNewClient(gatewaySID)
+	gc, err := grpc_client.GatewayNewClient(gatewaySID)
 	if err != nil {
 		log.Errorf("KickUser cannot find gateway client: %v, sid: %v", err, gatewaySID)
 		return false
diff --git a/internal/net/http_gateway/middleward.go b/internal/net/http_gateway/middleward.go
index cbc3d64..f7f2016 100644
--- a/internal/net/http_gateway/middleward.go
+++ b/internal/net/http_gateway/middleward.go
@@ -5,7 +5,6 @@ import (
 	"git.hlsq.asia/mmorpg/service-common/net/http/http_resp"
 	"git.hlsq.asia/mmorpg/service-common/utils"
 	"git.hlsq.asia/mmorpg/service-gateway/config"
-	"git.hlsq.asia/mmorpg/service-gateway/internal/global"
 	"github.com/gin-contrib/cors"
 	"github.com/gin-gonic/gin"
 	"go.uber.org/zap"
@@ -43,14 +42,13 @@ func ginLogger(logger *zap.SugaredLogger) gin.HandlerFunc {
 
 func authJwt() gin.HandlerFunc {
 	return func(c *gin.Context) {
-		// 如果是Public接口，有Token就读，没有就算了
-		public := false
-		for _, path := range global.PublicPaths {
-			if strings.HasPrefix(c.Request.URL.Path, path) {
-				public = true
-				break
-			}
+		pList := strings.SplitN(c.Request.URL.Path, "/", 4)
+		if len(pList) < 4 || pList[2] == "" {
+			http_resp.JsonNotFound(c)
+			return
 		}
+		// 如果是Public接口，有Token就读，没有就算了
+		public := pList[2] == "open"
 
 		token := strings.TrimPrefix(c.GetHeader("Authorization"), "Bearer ")
 		if token == "" {
@@ -58,16 +56,14 @@ func authJwt() gin.HandlerFunc {
 				c.Next()
 				return
 			}
-			http_resp.AbortUnauthorized(c)
+			http_resp.JsonUnauthorized(c)
+			c.Abort()
 			return
 		}
 		claims, err := utils.ParseToken(token, config.Get().Auth.Secret)
 		if err != nil {
-			if public {
-				c.Next()
-				return
-			}
-			http_resp.AbortUnauthorized(c)
+			http_resp.JsonUnauthorized(c)
+			c.Abort()
 			return
 		}
 
diff --git a/internal/net/http_gateway/router.go b/internal/net/http_gateway/router.go
index db22577..304cd48 100644
--- a/internal/net/http_gateway/router.go
+++ b/internal/net/http_gateway/router.go
@@ -3,7 +3,7 @@ package http_gateway
 import (
 	"context"
 	"git.hlsq.asia/mmorpg/service-common/log"
-	"git.hlsq.asia/mmorpg/service-common/net/grpc/service"
+	"git.hlsq.asia/mmorpg/service-common/net/grpc/grpc_client"
 	"git.hlsq.asia/mmorpg/service-common/net/http/http_resp"
 	"git.hlsq.asia/mmorpg/service-common/proto/rs/grpc_pb"
 	"git.hlsq.asia/mmorpg/service-gateway/internal/handler/http_handler"
@@ -52,16 +52,18 @@ func InitRouter() *gin.Engine {
 	r.HandleMethodNotAllowed = true
 	r.NoMethod(func(c *gin.Context) {
 		http_resp.JsonMethodNotAllowed(c)
+		c.Abort()
 	})
 	r.NoRoute(func(c *gin.Context) {
 		http_resp.JsonNotFound(c)
+		c.Abort()
 	})
 
-	initBaseRoute(r.Group("/"))
-
 	auth := r.Group("/")
 	auth.Use(authJwt())
 
+	// 网关
+	initBaseRoute(auth)
 	// 用户中心
 	initUserPath(auth)
 	// 奇怪的知识-服务端
@@ -72,13 +74,13 @@ func InitRouter() *gin.Engine {
 
 func initBaseRoute(r *gin.RouterGroup) {
 	g := r.Group("/gw")
-	g.POST("/login", http_handler.Login)
-	g.POST("/refresh_token", http_handler.RefreshToken)
+	g.POST("/open/login", http_handler.Login)
+	g.POST("/open/refresh_token", http_handler.RefreshToken)
 }
 
 func initUserPath(r *gin.RouterGroup) {
 	g := r.Group("/user")
-	client, err := service.UserNewClientLB()
+	client, err := grpc_client.UserNewClientLB()
 	if err != nil {
 		log.Errorf("get user conn failed: %v", err)
 		return
@@ -95,7 +97,7 @@ func initUserPath(r *gin.RouterGroup) {
 
 func initQgdzsPath(r *gin.RouterGroup) {
 	g := r.Group("/qgdzs")
-	client, err := service.QgdzsNewClientLB()
+	client, err := grpc_client.QgdzsNewClientLB()
 	if err != nil {
 		log.Errorf("get qgdzs conn failed: %v", err)
 		return
diff --git a/internal/testutil/suite.go b/internal/testutil/suite.go
index 8d0f132..4fb8a6d 100644
--- a/internal/testutil/suite.go
+++ b/internal/testutil/suite.go
@@ -28,8 +28,9 @@ func (ts *TestSuite) SetupSuite() {
 			},
 		},
 		Auth: &config.AuthConfig{
-			Secret: "test",
-			Expire: 259200,
+			Secret:      "test",
+			ShortExpire: 15,
+			LongExpire:  10080,
 		},
 	})