package user

import (
	"context"
	"encoding/json"

	authHelper "perms-system-server/internal/logic/auth"
	"perms-system-server/internal/middleware"
	"perms-system-server/internal/response"
	"perms-system-server/internal/svc"
	"perms-system-server/internal/types"

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

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

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

func (l *FetchUserCredentialsLogic) FetchUserCredentials(req *types.FetchUserCredentialsReq) (resp *types.FetchUserCredentialsResp, err error) {
	productCode := middleware.GetProductCode(l.ctx)
	if err := authHelper.RequireProductAdminFor(l.ctx, productCode); err != nil {
		return nil, err
	}

	if req.Ticket == "" {
		return nil, response.ErrBadRequest("ticket 不能为空")
	}

	key := userCredentialsKeyPrefix + req.Ticket
	val, err := l.svcCtx.Redis.GetDelCtx(l.ctx, key)
	if err != nil {
		logx.WithContext(l.ctx).Errorf("FetchUserCredentials: redis getdel failed: %v", err)
		return nil, response.NewCodeError(503, "凭证服务暂时不可用，请稍后重试")
	}
	if val == "" {
		return nil, response.ErrBadRequest("凭证票据无效或已过期")
	}

	var payload userCredentialsPayload
	if err := json.Unmarshal([]byte(val), &payload); err != nil {
		logx.WithContext(l.ctx).Errorf("FetchUserCredentials: unmarshal payload failed: %v", err)
		return nil, response.NewCodeError(500, "凭证数据异常，请联系管理员")
	}

	return &types.FetchUserCredentialsResp{
		Username: payload.Username,
		Password: payload.Password,
	}, nil
}