package logic

import (
	"context"
	"fmt"

	"lone-services/pkg/modelbase"
	"lone-services/pkg/utils"
	"lone-services/pkg/validate"
	user "lone-services/rpc/user/pb"
	"lone-services/services/user/internal/dao"
	"lone-services/services/user/internal/model"
	"lone-services/services/user/internal/svc"
	"lone-services/services/user/validator"

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

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

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

func (l *UserItemsLogic) UserItems(in *user.UserItemsReq) (*user.Response, error) {
	var v validator.UserItemsValidator
	if msg := validate.ValidateFromProto(in, &v); msg != utils.StringEmpty {
		return outResponse(utils.ErrorParams, msg), nil
	}

	adminInfo := utils.GetUserFromCtx(l.ctx)
	if adminInfo.ID < utils.NumberOne {
		return failResponse(utils.ErrorNoLoginInfo), nil
	}

	page := int(v.Page)
	size := int(v.Size)
	if page < modelbase.DefaultPage {
		page = modelbase.DefaultPage
	}
	if size < utils.NumberOne {
		size = modelbase.DefaultSize
	}

	prefix := modelbase.Prefix()
	existsSQL := fmt.Sprintf(`EXISTS (
		SELECT 1 FROM %suser_client uc
		INNER JOIN %sclient c ON c.code = uc.client_code
		WHERE uc.user_id = %susers.id
		  AND uc.status = %d
		  AND c.status = %d
		  AND c.subject_type = ?
	)`, prefix, prefix, prefix, dao.StatusEnabled, dao.StatusEnabled)

	params := modelbase.Params{
		Order: "id DESC",
		Page:  page,
		Size:  size,
		Other: map[string]string{
			existsSQL: dao.SubjectTypeUser,
		},
	}
	if v.Mobile != utils.StringEmpty {
		phone := utils.GetSearchPhone(v.Mobile)
		if len(phone) > utils.NumberZero {
			params.Like = map[string]string{
				"mobile LIKE ? ": "%%" + phone + "%%",
			}
		}
	}

	var list []dao.UserRow
	userModel := model.UserModel{}.Init()
	result, err := userModel.Page(params, &list)
	if err != nil {
		l.Errorf("user items: %v", err)
		return failResponse(utils.Fail), nil
	}

	items := make([]dao.UserListItem, 0, len(list))
	for _, row := range list {
		mobile := row.Mobile
		if len(row.Mobile) >= 72 {
			if plain, dErr := utils.DecryptPhone(row.Mobile); dErr == nil {
				mobile = utils.DecryptPhoneReplace(plain)
			}
		}
		items = append(items, dao.UserListItem{
			Id:           row.Id,
			Name:         row.Name,
			Avatar:       row.Avatar,
			Mobile:       mobile,
			OriginMobile: row.Mobile,
			Gender:       row.Gender,
			Birthday:     row.Birthday.DateString(),
			Status:       row.Status,
			CreatedAt:    row.CreatedAt,
			UpdatedAt:    row.UpdatedAt,
		})
	}

	return okResponse(dao.UserItemsData{
		Count: result.Count,
		Items: items,
	}), nil
}