添加gorm的model结构一个表名的入口

server/home-user-auth/internal/handler/usergoogleloginhandler.go

@@ -2,7 +2,6 @@ package handler
 
 import (
 	"errors"
-	"log"
 	"net/http"
 
 	"github.com/zeromicro/go-zero/core/logx"
@@ -54,7 +53,6 @@ func UserGoogleLoginHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 			userinfo = &auth.UserInfo{UserId: 0, GuestId: 0}
 		}
 
-		log.Println(r.URL.String(), r.URL.Query())
 		var req types.RequestGoogleLogin
 		// 如果端点有请求结构体，则使用httpx.Parse方法从HTTP请求体中解析请求数据
 		if err := httpx.Parse(r, &req); err != nil {
@@ -65,12 +63,18 @@ func UserGoogleLoginHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 			logx.Info(err)
 			return
 		}
+
 		// 创建一个业务逻辑层实例
 		l := logic.NewUserGoogleLoginLogic(r.Context(), svcCtx)
 		resp := l.UserGoogleLogin(&req, userinfo)
+
 		// 如果响应不为nil，则使用httpx.OkJsonCtx方法返回JSON响应;
 		if resp != nil {
-			httpx.OkJsonCtx(r.Context(), w, resp)
+			if resp.IsRewriteHandler() {
+				resp.RewriteHandler(w, r)
+			} else {
+				httpx.OkJsonCtx(r.Context(), w, resp)
+			}
 		} else {
 			err := errors.New("server logic is error, resp must not be nil")
 			httpx.ErrorCtx(r.Context(), w, err)

server/home-user-auth/internal/logic/usergoogleloginlogic.go

@@ -5,6 +5,8 @@ import (
 	"fusenapi/utils/basic"
 	"log"
 	"net/http"
+	"net/url"
+	"time"
 
 	"context"
 
@@ -16,6 +18,7 @@ import (
 	"golang.org/x/net/proxy"
 	"golang.org/x/oauth2"
 	"golang.org/x/oauth2/google"
+	"gorm.io/gorm"
 )
 
 type UserGoogleLoginLogic struct {
@@ -67,9 +70,36 @@ func (l *UserGoogleLoginLogic) UserGoogleLogin(req *types.RequestGoogleLogin, us
 
 	r, err := ses.Get("https://www.googleapis.com/oauth2/v2/userinfo?access_token=" + token.AccessToken).Execute()
 	if err != nil {
-		panic(err)
+		logx.Error(err)
+		return resp.SetStatus(basic.CodeOAuthGoogleApiErr)
 	}
+
 	log.Println(r.Json())
 
+	googleId := r.Json().Get("id").Int()
+	user, err := l.svcCtx.AllModels.FsUser.FindUserByGoogleId(context.TODO(), googleId)
+	log.Println(user)
+	if err != nil {
+		if err != gorm.ErrRecordNotFound {
+			logx.Error(err)
+			return resp.SetStatus(basic.CodeDbSqlErr)
+		}
+
+		// 如果密码匹配，则生成 JWT Token。
+		nowSec := time.Now().Unix()
+		jwtToken, err := auth.GenerateJwtToken(&l.svcCtx.Config.Auth.AccessSecret, l.svcCtx.Config.Auth.AccessExpire, nowSec, 0, 0)
+
+		// 如果生成 JWT Token 失败，则抛出错误并返回未认证的状态码。
+		if err != nil {
+			logx.Error(err)
+			return resp.SetStatus(basic.CodeServiceErr)
+		}
+
+		return resp.SetRewriteHandler(func(w http.ResponseWriter, r *http.Request) {
+			http.Redirect(w, r, "http://localhost:9900?token="+url.QueryEscape(jwtToken), http.StatusFound)
+		})
+
+	}
+
 	return resp.SetStatus(basic.CodeOK)
 }