zhengshilong/IUQT
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

用户模块

Browse Source
This commit is contained in:
郑诗龙
2025-07-11 18:03:48 +08:00
parent aad7c9e24f
commit 9a46c0fdf4
11 changed files with 3106 additions and 335 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
acquaintances/biz/handler/user/user_relations_service.go Normal file
View File

@@ -0,0 +1,71 @@
// Code generated by hertz generator.
package user
import (
"acquaintances/biz/dal/mysql"
"context"
user "acquaintances/biz/model/user"
"github.com/cloudwego/hertz/pkg/app"
"github.com/cloudwego/hertz/pkg/protocol/consts"
)
// DeleteUserRelations .
// @router /v1/user/relation/ [DELETE]
func DeleteUserRelations(ctx context.Context, c *app.RequestContext) {
var err error
var req user.DeleteUserRelationsReq
err = c.BindAndValidate(&req)
if err != nil {
c.JSON(consts.StatusBadRequest, err.Error())
return
}
if err = mysql.DeleteUserRelations(req); err != nil {
c.JSON(consts.StatusInternalServerError, err.Error())
return
}
resp := new(user.DeleteUserRelationsReq)
c.JSON(consts.StatusOK, resp)
}
// CreateUserRelations .
// @router /v1/user/relation/ [POST]
func CreateUserRelations(ctx context.Context, c *app.RequestContext) {
var err error
var req user.CreateUserRelationsReq
err = c.BindAndValidate(&req)
if err != nil {
c.JSON(consts.StatusBadRequest, err.Error())
return
}
if err = mysql.CreateUserRelations(req); err != nil {
c.JSON(consts.StatusInternalServerError, err.Error())
return
}
resp := new(user.CreateUserRelationsReq)
c.JSON(consts.StatusOK, resp)
}
// ListUserRelations .
// @router /v1/user/relation/ [GET]
func ListUserRelations(ctx context.Context, c *app.RequestContext) {
var err error
var req user.ListUserRelationsReq
err = c.BindAndValidate(&req)
if err != nil {
c.JSON(consts.StatusBadRequest, err.Error())
return
}
resp := new(user.ListUserRelationsResponse)
resp, err = mysql.GetUserListRelations(req)
if err != nil {
c.JSON(consts.StatusInternalServerError, err.Error())
return
}
c.JSON(consts.StatusOK, resp)
}

39
acquaintances/biz/handler/user/user_service.go
View File

@@ -9,54 +9,67 @@ import (
"acquaintances/biz/utils"
"context"
"github.com/cloudwego/hertz/pkg/app"
"github.com/cloudwego/hertz/pkg/common/hlog"
"github.com/cloudwego/hertz/pkg/protocol/consts"
"strconv"
)
// UpdateUser .
// @router /v1/user/update/:user_id [POST]
// @router /v1/user/update/ [PUT]
func UpdateUser(ctx context.Context, c *app.RequestContext) {
var err error
var req user.UpdateUserRequest
err = c.BindAndValidate(&req)
if err != nil {
c.String(consts.StatusBadRequest, err.Error())
c.JSON(consts.StatusBadRequest, err.Error())
return
}
if err = mysql.UpdatesUser(&req); err != nil {
hlog.Error(err.Error())
c.JSON(consts.StatusInternalServerError, &user.CreateUserResponse{Code: user.Code_DBErr, Msg: err.Error()})
return
}
resp := new(user.UpdateUserResponse)
c.JSON(consts.StatusOK, resp)
}
// DeleteUser .
// @router /v1/user/delete/:user_id [POST]
// @router /v1/user/delete/ [delete]
func DeleteUser(ctx context.Context, c *app.RequestContext) {
var err error
var req user.DeleteUserRequest
err = c.BindAndValidate(&req)
if err != nil {
c.String(consts.StatusBadRequest, err.Error())
c.JSON(consts.StatusBadRequest, err.Error())
return
}
if err = mysql.DeleteUser(req.UserID); err != nil {
c.JSON(consts.StatusInternalServerError, err.Error())
return
}
resp := new(user.DeleteUserResponse)
c.JSON(consts.StatusOK, resp)
}
// QueryUser .
// @router /v1/user/query/ [POST]
func QueryUser(ctx context.Context, c *app.RequestContext) {
// @router /v1/user/info/ [GET]
func InfoUser(ctx context.Context, c *app.RequestContext) {
var err error
var req user.QueryUserRequest
var req user.InfoUserRequest
err = c.BindAndValidate(&req)
if err != nil {
c.String(consts.StatusBadRequest, err.Error())
c.JSON(consts.StatusBadRequest, err.Error())
return
}
data, err := mysql.InfoUser(req.UserID)
if err != nil {
c.JSON(consts.StatusInternalServerError, err.Error())
return
}
resp := new(user.QueryUserResponse)
resp.UserInfo = data
c.JSON(consts.StatusOK, resp)
}
@@ -68,12 +81,12 @@ func CreateUser(ctx context.Context, c *app.RequestContext) {
var req user.CreateUserRequest
err = c.BindAndValidate(&req)
if err != nil {
c.String(consts.StatusBadRequest, err.Error())
c.JSON(consts.StatusBadRequest, err.Error())
return
}
userId, err := utils.GetID()
if err != nil {
c.String(consts.StatusInternalServerError, err.Error())
c.JSON(consts.StatusInternalServerError, err.Error())
return
}
if err = mysql.CreateUser([]*model.User{