feat: 完成用户管理接口核心CRUD功能

- 实现完整的用户创建逻辑,包含唯一性验证和密码加密
- 实现用户详情查询,安全过滤密码字段
- 实现用户信息更新,支持部分字段更新和唯一性验证
- 实现用户删除功能,包含存在性检查和日志记录
- 创建完整的API测试用例,覆盖正常和错误场景
- 更新任务进度文档,标记第10个任务为已完成
- 提升项目整体完成率至35%,中优先级任务完成率至25%
This commit is contained in:
xujiang
2025-07-11 13:01:50 +08:00
parent 494d98bee5
commit d47e55d5fb
6 changed files with 413 additions and 18 deletions

View File

@ -2,11 +2,15 @@ package user
import (
"context"
"strings"
"time"
"photography-backend/internal/svc"
"photography-backend/internal/types"
"photography-backend/pkg/errorx"
"github.com/zeromicro/go-zero/core/logx"
"github.com/zeromicro/go-zero/core/stores/sqlx"
)
type UpdateUserLogic struct {
@ -25,7 +29,92 @@ func NewUpdateUserLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Update
}
func (l *UpdateUserLogic) UpdateUser(req *types.UpdateUserRequest) (resp *types.UpdateUserResponse, err error) {
// todo: add your logic here and delete this line
// 检查用户是否存在
user, err := l.svcCtx.UserModel.FindOne(l.ctx, req.Id)
if err != nil {
if err == sqlx.ErrNotFound {
return &types.UpdateUserResponse{
BaseResponse: types.BaseResponse{
Code: errorx.UserNotFound,
Message: "用户不存在",
},
}, nil
}
logx.WithContext(l.ctx).Error("查询用户失败: ", err)
return &types.UpdateUserResponse{
BaseResponse: types.BaseResponse{
Code: errorx.ServerError,
Message: "查询用户失败",
},
}, nil
}
return
// 检查用户名唯一性(如果要更新用户名)
if req.Username != "" && strings.TrimSpace(req.Username) != user.Username {
existingUser, err := l.svcCtx.UserModel.FindOneByUsername(l.ctx, req.Username)
if err == nil && existingUser != nil {
return &types.UpdateUserResponse{
BaseResponse: types.BaseResponse{
Code: errorx.UserExists,
Message: "用户名已存在",
},
}, nil
}
user.Username = strings.TrimSpace(req.Username)
}
// 检查邮箱唯一性(如果要更新邮箱)
if req.Email != "" && strings.TrimSpace(req.Email) != user.Email {
existingUser, err := l.svcCtx.UserModel.FindOneByEmail(l.ctx, req.Email)
if err == nil && existingUser != nil {
return &types.UpdateUserResponse{
BaseResponse: types.BaseResponse{
Code: errorx.UserExists,
Message: "邮箱已存在",
},
}, nil
}
user.Email = strings.TrimSpace(req.Email)
}
// 更新其他字段
if req.Avatar != "" {
user.Avatar = req.Avatar
}
if req.Status >= 0 {
user.Status = int64(req.Status)
}
// 更新时间
user.UpdatedAt = time.Now()
// 执行更新
err = l.svcCtx.UserModel.Update(l.ctx, user)
if err != nil {
logx.WithContext(l.ctx).Error("更新用户失败: ", err)
return &types.UpdateUserResponse{
BaseResponse: types.BaseResponse{
Code: errorx.ServerError,
Message: "更新用户失败",
},
}, nil
}
// 返回更新后的用户信息(不包含密码)
return &types.UpdateUserResponse{
BaseResponse: types.BaseResponse{
Code: errorx.Success,
Message: "更新用户成功",
},
Data: types.User{
Id: user.Id,
Username: user.Username,
Email: user.Email,
Avatar: user.Avatar,
Status: int(user.Status),
CreatedAt: user.CreatedAt.Unix(),
UpdatedAt: user.UpdatedAt.Unix(),
},
}, nil
}