package auth

import (
	"context"
	"errors"

	"perms-system-server/internal/loaders"
	"perms-system-server/internal/middleware"
	userModel "perms-system-server/internal/model/user"
	"perms-system-server/internal/response"
	"perms-system-server/internal/svc"
	"perms-system-server/internal/types"

	"github.com/zeromicro/go-zero/core/logx"
)

type UpdateSelfInfoLogic struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewUpdateSelfInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateSelfInfoLogic {
	return &UpdateSelfInfoLogic{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

func (l *UpdateSelfInfoLogic) UpdateSelfInfo(req *types.UpdateSelfInfoReq) error {
	caller := middleware.GetUserDetails(l.ctx)
	if caller == nil {
		return response.ErrUnauthorized("未登录")
	}

	if req.Nickname == nil && req.Avatar == nil && req.Email == nil && req.Phone == nil {
		return response.ErrBadRequest("至少需要修改一个字段")
	}

	if req.Nickname != nil && len(*req.Nickname) > 64 {
		return response.ErrBadRequest("昵称长度不能超过64个字符")
	}
	if req.Avatar != nil && len(*req.Avatar) > 255 {
		return response.ErrBadRequest("头像地址长度不能超过255个字符")
	}
	if req.Email != nil && len(*req.Email) > 64 {
		return response.ErrBadRequest("邮箱长度不能超过64个字符")
	}
	if req.Phone != nil && len(*req.Phone) > 32 {
		return response.ErrBadRequest("手机号长度不能超过32个字符")
	}

	user, err := l.svcCtx.SysUserModel.FindOne(l.ctx, caller.UserId)
	if err != nil {
		return response.ErrNotFound("用户不存在")
	}

	nickname := user.Nickname
	avatar := user.Avatar.String
	email := user.Email
	phone := user.Phone

	if req.Nickname != nil {
		nickname = *req.Nickname
	}
	if req.Avatar != nil {
		avatar = *req.Avatar
	}
	if req.Email != nil {
		email = *req.Email
	}
	if req.Phone != nil {
		phone = *req.Phone
	}

	if err := l.svcCtx.SysUserModel.UpdateSelfInfo(l.ctx, user.Id, user.Username, nickname, avatar, email, phone, user.UpdateTime); err != nil {
		if errors.Is(err, userModel.ErrUpdateConflict) {
			return response.ErrConflict("信息已被其他会话修改，请刷新后重试")
		}
		return err
	}

	cleanCtx, cancel := loaders.DetachCacheCleanCtx(l.ctx)
	defer cancel()
	l.svcCtx.UserDetailsLoader.Clean(cleanCtx, caller.UserId)

	return nil
}