From a53f8f8a5a105a73a231e032be67ddbb45438576 Mon Sep 17 00:00:00 2001
From: suyiiyii <suyiiyii@gmail.com>
Date: Mon, 20 Jan 2025 13:04:55 +0800
Subject: [PATCH] =?UTF-8?q?feat(user):=20=E5=88=9D=E5=A7=8B=E5=8C=96?=
 =?UTF-8?q?=E7=94=A8=E6=88=B7=E6=9C=8D=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增用户登录和注册功能
- 实现基本的用户信息验证
- 集成数据库连接和查询
---
 app/user/biz/service/login.go    | 1 +
 app/user/biz/service/register.go | 6 ++++++
 app/user/main.go                 | 5 +++++
 3 files changed, 12 insertions(+)

diff --git a/app/user/biz/service/login.go b/app/user/biz/service/login.go
index 2b3af1f..d9f58b0 100644
--- a/app/user/biz/service/login.go
+++ b/app/user/biz/service/login.go
@@ -16,5 +16,6 @@ func NewLoginService(ctx context.Context) *LoginService {
 func (s *LoginService) Run(req *user.LoginReq) (resp *user.LoginResp, err error) {
 	// Finish your business logic.
 
+	resp = &user.LoginResp{UserId: 111}
 	return
 }
diff --git a/app/user/biz/service/register.go b/app/user/biz/service/register.go
index 86444b6..4bb7b90 100644
--- a/app/user/biz/service/register.go
+++ b/app/user/biz/service/register.go
@@ -2,6 +2,8 @@ package service
 
 import (
 	"context"
+	"errors"
+	"github.com/suyiiyii/hertz101/app/user/biz/dal/query"
 	user "github.com/suyiiyii/hertz101/rpc_gen/kitex_gen/user"
 )
 
@@ -15,6 +17,10 @@ func NewRegisterService(ctx context.Context) *RegisterService {
 // Run create note info
 func (s *RegisterService) Run(req *user.RegisterReq) (resp *user.RegisterResp, err error) {
 	// Finish your business logic.
+	if req.Password == "" || req.Email == "" {
+		return nil, errors.New("password or email is empty")
+	}
+	query.Q.User
 
 	return
 }
diff --git a/app/user/main.go b/app/user/main.go
index 0b3ab70..3cba03a 100644
--- a/app/user/main.go
+++ b/app/user/main.go
@@ -1,6 +1,9 @@
 package main
 
 import (
+	"github.com/suyiiyii/hertz101/app/user/biz/dal"
+	"github.com/suyiiyii/hertz101/app/user/biz/dal/mysql"
+	"github.com/suyiiyii/hertz101/app/user/biz/dal/query"
 	"net"
 	"time"
 
@@ -21,6 +24,8 @@ func main() {
 	if err != nil {
 		klog.Error(err.Error())
 	}
+	dal.Init()
+	query.Use(mysql.DB)
 	opts := kitexInit()
 
 	svr := userservice.NewServer(new(UserServiceImpl), opts...)