296 lines
8.1 KiB
Go
296 lines
8.1 KiB
Go
|
package handlers
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"net/http"
|
|||
|
|
"strconv"
|
|||
|
|
|
|||
|
|
"github.com/gin-gonic/gin"
|
|||
|
|
"github.com/go-playground/validator/v10"
|
|||
|
|
|
|||
|
|
"github.com/Nanqipro/YunQue-Tech-Projects/ai_english_learning/serve/internal/common"
|
|||
|
|
"github.com/Nanqipro/YunQue-Tech-Projects/ai_english_learning/serve/internal/services"
|
|||
|
|
"github.com/Nanqipro/YunQue-Tech-Projects/ai_english_learning/serve/internal/utils"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
// UserHandler 用户处理器
|
|||
|
|
type UserHandler struct {
|
|||
|
|
userService *services.UserService
|
|||
|
|
validator *validator.Validate
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// NewUserHandler 创建用户处理器实例
|
|||
|
|
func NewUserHandler(userService *services.UserService) *UserHandler {
|
|||
|
|
return &UserHandler{
|
|||
|
|
userService: userService,
|
|||
|
|
validator: validator.New(),
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// UpdateUserRequest 更新用户信息请求结构
|
|||
|
|
type UpdateUserRequest struct {
|
|||
|
|
Username string `json:"username" validate:"omitempty,min=3,max=20"`
|
|||
|
|
Email string `json:"email" validate:"omitempty,email"`
|
|||
|
|
Nickname string `json:"nickname" validate:"omitempty,min=1,max=50"`
|
|||
|
|
Avatar string `json:"avatar" validate:"omitempty,url"`
|
|||
|
|
Timezone string `json:"timezone" validate:"omitempty"`
|
|||
|
|
Language string `json:"language" validate:"omitempty"`
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// UpdateUserPreferencesRequest 更新用户偏好设置请求结构
|
|||
|
|
type UpdateUserPreferencesRequest struct {
|
|||
|
|
DailyGoal int `json:"daily_goal" validate:"omitempty,min=1,max=1000"`
|
|||
|
|
WeeklyGoal int `json:"weekly_goal" validate:"omitempty,min=1,max=7000"`
|
|||
|
|
ReminderEnabled bool `json:"reminder_enabled"`
|
|||
|
|
DifficultyLevel string `json:"difficulty_level" validate:"omitempty,oneof=beginner intermediate advanced"`
|
|||
|
|
LearningMode string `json:"learning_mode" validate:"omitempty,oneof=casual intensive exam"`
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// UserStatsResponse 用户学习统计响应结构
|
|||
|
|
type UserStatsResponse struct {
|
|||
|
|
TotalWords int `json:"total_words"`
|
|||
|
|
LearnedWords int `json:"learned_words"`
|
|||
|
|
MasteredWords int `json:"mastered_words"`
|
|||
|
|
StudyDays int `json:"study_days"`
|
|||
|
|
ConsecutiveDays int `json:"consecutive_days"`
|
|||
|
|
TotalStudyTime int `json:"total_study_time"` // 分钟
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// GetUserProfile 获取用户信息
|
|||
|
|
func (h *UserHandler) GetUserProfile(c *gin.Context) {
|
|||
|
|
userID, exists := utils.GetUserIDFromContext(c)
|
|||
|
|
if !exists {
|
|||
|
|
common.BadRequestResponse(c, "请先登录")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
user, err := h.userService.GetUserByID(userID)
|
|||
|
|
if err != nil {
|
|||
|
|
if businessErr, ok := err.(*common.BusinessError); ok {
|
|||
|
|
common.ErrorResponse(c, http.StatusBadRequest, businessErr.Message)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
common.InternalServerErrorResponse(c, "获取用户信息失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 获取用户偏好设置
|
|||
|
|
preferences, err := h.userService.GetUserPreferences(userID)
|
|||
|
|
if err != nil {
|
|||
|
|
// 偏好设置获取失败不影响用户信息返回，记录日志即可
|
|||
|
|
preferences = nil
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 构造响应数据
|
|||
|
|
response := map[string]interface{}{
|
|||
|
|
"id": user.ID,
|
|||
|
|
"username": user.Username,
|
|||
|
|
"email": user.Email,
|
|||
|
|
"nickname": user.Nickname,
|
|||
|
|
"avatar": user.Avatar,
|
|||
|
|
"timezone": user.Timezone,
|
|||
|
|
"language": user.Language,
|
|||
|
|
"status": user.Status,
|
|||
|
|
"created_at": user.CreatedAt,
|
|||
|
|
"updated_at": user.UpdatedAt,
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if preferences != nil {
|
|||
|
|
response["preferences"] = map[string]interface{}{
|
|||
|
|
"daily_goal": preferences.DailyGoal,
|
|||
|
|
"weekly_goal": preferences.WeeklyGoal,
|
|||
|
|
"reminder_enabled": preferences.ReminderEnabled,
|
|||
|
|
"difficulty_level": preferences.DifficultyLevel,
|
|||
|
|
"learning_mode": preferences.LearningMode,
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
common.SuccessResponse(c, response)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// UpdateUserProfile 更新用户信息
|
|||
|
|
func (h *UserHandler) UpdateUserProfile(c *gin.Context) {
|
|||
|
|
userID, exists := utils.GetUserIDFromContext(c)
|
|||
|
|
if !exists {
|
|||
|
|
common.BadRequestResponse(c, "请先登录")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var req UpdateUserRequest
|
|||
|
|
if err := c.ShouldBindJSON(&req); err != nil {
|
|||
|
|
common.ValidationErrorResponse(c, err)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 验证请求参数
|
|||
|
|
if err := h.validator.Struct(&req); err != nil {
|
|||
|
|
common.ValidationErrorResponse(c, err)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 构造更新数据
|
|||
|
|
updates := make(map[string]interface{})
|
|||
|
|
if req.Username != "" {
|
|||
|
|
updates["username"] = req.Username
|
|||
|
|
}
|
|||
|
|
if req.Email != "" {
|
|||
|
|
updates["email"] = req.Email
|
|||
|
|
}
|
|||
|
|
if req.Nickname != "" {
|
|||
|
|
updates["nickname"] = req.Nickname
|
|||
|
|
}
|
|||
|
|
if req.Avatar != "" {
|
|||
|
|
updates["avatar"] = req.Avatar
|
|||
|
|
}
|
|||
|
|
if req.Timezone != "" {
|
|||
|
|
updates["timezone"] = req.Timezone
|
|||
|
|
}
|
|||
|
|
if req.Language != "" {
|
|||
|
|
updates["language"] = req.Language
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if len(updates) == 0 {
|
|||
|
|
common.BadRequestResponse(c, "没有需要更新的字段")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 更新用户信息
|
|||
|
|
user, err := h.userService.UpdateUser(userID, updates)
|
|||
|
|
if err != nil {
|
|||
|
|
if businessErr, ok := err.(*common.BusinessError); ok {
|
|||
|
|
common.ErrorResponse(c, http.StatusBadRequest, businessErr.Message)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
common.InternalServerErrorResponse(c, "更新用户信息失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
common.SuccessResponse(c, user)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// UpdateUserPreferences 更新用户偏好设置
|
|||
|
|
func (h *UserHandler) UpdateUserPreferences(c *gin.Context) {
|
|||
|
|
userID, exists := utils.GetUserIDFromContext(c)
|
|||
|
|
if !exists {
|
|||
|
|
common.BadRequestResponse(c, "请先登录")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var req UpdateUserPreferencesRequest
|
|||
|
|
if err := c.ShouldBindJSON(&req); err != nil {
|
|||
|
|
common.ValidationErrorResponse(c, err)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 验证请求参数
|
|||
|
|
if err := h.validator.Struct(&req); err != nil {
|
|||
|
|
common.ValidationErrorResponse(c, err)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 构造更新数据
|
|||
|
|
updates := make(map[string]interface{})
|
|||
|
|
if req.DailyGoal > 0 {
|
|||
|
|
updates["daily_goal"] = req.DailyGoal
|
|||
|
|
}
|
|||
|
|
if req.WeeklyGoal > 0 {
|
|||
|
|
updates["weekly_goal"] = req.WeeklyGoal
|
|||
|
|
}
|
|||
|
|
updates["reminder_enabled"] = req.ReminderEnabled
|
|||
|
|
if req.DifficultyLevel != "" {
|
|||
|
|
updates["difficulty_level"] = req.DifficultyLevel
|
|||
|
|
}
|
|||
|
|
if req.LearningMode != "" {
|
|||
|
|
updates["learning_mode"] = req.LearningMode
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 更新用户偏好设置
|
|||
|
|
preferences, err := h.userService.UpdateUserPreferences(userID, updates)
|
|||
|
|
if err != nil {
|
|||
|
|
if businessErr, ok := err.(*common.BusinessError); ok {
|
|||
|
|
common.ErrorResponse(c, http.StatusBadRequest, businessErr.Message)
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
common.InternalServerErrorResponse(c, "更新偏好设置失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
common.SuccessResponse(c, preferences)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// GetUserStats 获取用户学习统计
|
|||
|
|
func (h *UserHandler) GetUserStats(c *gin.Context) {
|
|||
|
|
userID, exists := utils.GetUserIDFromContext(c)
|
|||
|
|
if !exists {
|
|||
|
|
common.BadRequestResponse(c, "请先登录")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 获取时间范围参数
|
|||
|
|
timeRange := c.DefaultQuery("time_range", "all") // all, week, month, year
|
|||
|
|
|
|||
|
|
// 这里需要实现具体的统计逻辑，暂时返回模拟数据
|
|||
|
|
// TODO: 实现真实的统计查询，使用userID和timeRange参数
|
|||
|
|
_ = userID // 避免未使用变量错误
|
|||
|
|
_ = timeRange // 避免未使用变量错误
|
|||
|
|
stats := &UserStatsResponse{
|
|||
|
|
TotalWords: 1000,
|
|||
|
|
LearnedWords: 750,
|
|||
|
|
MasteredWords: 500,
|
|||
|
|
StudyDays: 30,
|
|||
|
|
ConsecutiveDays: 7,
|
|||
|
|
TotalStudyTime: 1800, // 30小时
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
common.SuccessResponse(c, stats)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// GetUserLearningProgress 获取用户学习进度
|
|||
|
|
func (h *UserHandler) GetUserLearningProgress(c *gin.Context) {
|
|||
|
|
userID, exists := utils.GetUserIDFromContext(c)
|
|||
|
|
if !exists {
|
|||
|
|
common.BadRequestResponse(c, "请先登录")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 获取分页参数
|
|||
|
|
page, _ := strconv.Atoi(c.DefaultQuery("page", "1"))
|
|||
|
|
limit, _ := strconv.Atoi(c.DefaultQuery("limit", "20"))
|
|||
|
|
if page < 1 {
|
|||
|
|
page = 1
|
|||
|
|
}
|
|||
|
|
if limit < 1 || limit > 100 {
|
|||
|
|
limit = 20
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 获取过滤参数
|
|||
|
|
masteryLevel := c.Query("mastery_level")
|
|||
|
|
categoryID := c.Query("category_id")
|
|||
|
|
|
|||
|
|
// 调用词汇服务获取用户的学习进度
|
|||
|
|
progressList, total, err := h.userService.GetUserLearningProgress(utils.Int64ToString(userID), page, limit)
|
|||
|
|
if err != nil {
|
|||
|
|
common.InternalServerErrorResponse(c, "获取学习进度失败")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
totalPages := int64(0)
|
|||
|
|
if limit > 0 {
|
|||
|
|
totalPages = (total + int64(limit) - 1) / int64(limit)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
response := map[string]interface{}{
|
|||
|
|
"progress": progressList,
|
|||
|
|
"pagination": map[string]interface{}{
|
|||
|
|
"page": page,
|
|||
|
|
"limit": limit,
|
|||
|
|
"total": total,
|
|||
|
|
"total_page": totalPages,
|
|||
|
|
},
|
|||
|
|
"filters": map[string]interface{}{
|
|||
|
|
"mastery_level": masteryLevel,
|
|||
|
|
"category_id": categoryID,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
common.SuccessResponse(c, response)
|
|||
|
|
}
|