package userrpc

import (
	"github.com/golang/protobuf/proto"
)

func GetUserByToken(dbname, token string, url ...string) (map[string]string, error) {

	var user_rpc_url string = "127.0.0.1:7976"
	if len(url) > 0 && url[0] != "" {
		user_rpc_url = url[0]
	}
	conn, _, err := DialUserService("tcp", user_rpc_url)
	if err != nil {
		return map[string]string{}, err
	}
	defer conn.Close()

	req := &UserRequest{proto.String(dbname), proto.String(token), nil}

	res := &UserResponse{}

	err = conn.GetByToken(req, res)

	if err != nil {
		return map[string]string{}, err
	}

	if res.GetUserId() != "" {
		return map[string]string{
			"UserId":     res.GetUserId(),
			"Username":   res.GetUsername(),
			"Nickname":   res.GetNickname(),
			"Mobile":     res.GetMobile(),
			"Email":      res.GetEmail(),
			"Status":     res.GetStatus(),
			"BusinessId": res.GetBusinessId(),
			"StoreId":    res.GetStoreId(),
			"FansTo":     res.GetFansTo(),
			"IsVip":      res.GetIsVip(),
			"Usercode":   res.GetUsercode(),
			"GroupId":    res.GetGroupId(),
			"Type":       res.GetType(),
		}, nil
	}

	return map[string]string{}, nil
}

/**
 * 使用用户名查询
 */
func GetUserByUsername(dbname, username string, url ...string) (*UserResponse, error) {

	var user_rpc_url string = "127.0.0.1:7976"
	if len(url) > 0 && url[0] != "" {
		user_rpc_url = url[0]
	}

	conn, _, err := DialUserService("tcp", user_rpc_url)
	if err != nil {
		return nil, err
	}
	defer conn.Close()

	req := &UserInfoByUsername{proto.String(dbname), proto.String(username), nil}

	res := &UserResponse{}

	err = conn.GetByUsername(req, res)

	if err != nil {
		return nil, err
	}

	return res, nil
}

/**
 * 使用编号查询
 */
func GetUserByUsercode(dbname, usercode string, url ...string) (*UserResponse, error) {

	var user_rpc_url string = "127.0.0.1:7976"
	if len(url) > 0 && url[0] != "" {
		user_rpc_url = url[0]
	}

	conn, _, err := DialUserService("tcp", user_rpc_url)
	if err != nil {
		return nil, err
	}
	defer conn.Close()

	req := &UserInfoByUsercode{proto.String(dbname), proto.String(usercode), nil}

	res := &UserResponse{}

	err = conn.GetByUsercode(req, res)

	if err != nil {
		return nil, err
	}

	return res, nil
}

func Login(dbname, account, password string, url ...string) (map[string]string, error) {

	var user_rpc_url string = "127.0.0.1:7976"
	if len(url) > 0 && url[0] != "" {
		user_rpc_url = url[0]
	}

	conn, _, err := DialUserService("tcp", user_rpc_url)
	if err != nil {
		return map[string]string{}, err
	}
	defer conn.Close()

	req := &LoginRequest{proto.String(dbname), proto.String(account), proto.String(password), nil}

	res := &LoginResponse{}

	err = conn.Login(req, res)

	if err != nil {
		return map[string]string{}, err
	}

	if res.GetUserId() != "" {
		return map[string]string{
			"UserId":     res.GetUserId(),
			"Username":   res.GetUsername(),
			"Nickname":   res.GetNickname(),
			"Mobile":     res.GetMobile(),
			"Email":      res.GetEmail(),
			"Status":     res.GetStatus(),
			"BusinessId": res.GetBusinessId(),
			"StoreId":    res.GetStoreId(),
			"FansTo":     res.GetFansTo(),
			"IsVip":      res.GetIsVip(),
			"Token":      res.GetToken(),
			"Usercode":   res.GetUsercode(),
			"GroupId":    res.GetGroupId(),
			"Type":       res.GetType(),
		}, nil
	}

	return map[string]string{}, nil
}