package orderrpcv2

import (
	"encoding/json"
	"errors"
	"strconv"
)

func GetUserBuyNum(site_id, dbname string, product_id string, user_id string, url ...string) (int64, error) {

	if dbname == "" || product_id == "" || user_id == "" {
		return 0, errors.New("参数错误")
	}

	conn, err := rpc_server_conn(url...)
	if err != nil {
		return 0, err
	}
	defer conn.Close()

	var data map[string]string = make(map[string]string)

	data["dbname"] = dbname
	data["site_id"] = site_id
	data["product_id"] = product_id
	data["user_id"] = user_id

	req, err := SetReqData(data)

	if err != nil {
		return 0, err
	}

	res := &Response{}

	err = conn.GetUserBuyNum(req, res)

	if err != nil {
		return 0, err
	}

	res_data_de, err := GetResData(res)

	if err != nil {
		return 0, err
	}

	if res_data_de == "" {
		return 0, errors.New("no data")
	}

	var res_arr map[string]string

	err = json.Unmarshal([]byte(res_data_de), &res_arr)

	if err != nil {
		return 0, err
	}

	if _, ok := res_arr["Quantity"]; ok {
		return strconv.ParseInt(res_arr["Quantity"], 10, 64)
	}
	return 0, errors.New("failed")
}

func GetUserBuyTotal(site_id, dbname string, product_id string, user_id string, url ...string) (int64, error) {

	if dbname == "" || product_id == "" || user_id == "" {
		return 0, errors.New("参数错误")
	}

	conn, err := rpc_server_conn(url...)
	if err != nil {
		return 0, err
	}
	defer conn.Close()

	var data map[string]string = make(map[string]string)

	data["dbname"] = dbname
	data["site_id"] = site_id
	data["product_id"] = product_id
	data["user_id"] = user_id

	req, err := SetReqData(data)

	if err != nil {
		return 0, err
	}

	res := &Response{}

	err = conn.GetUserBuyTotal(req, res)

	if err != nil {
		return 0, err
	}

	res_data_de, err := GetResData(res)

	if err != nil {
		return 0, err
	}

	if res_data_de == "" {
		return 0, errors.New("no data")
	}

	var res_arr map[string]string

	err = json.Unmarshal([]byte(res_data_de), &res_arr)

	if err != nil {
		return 0, err
	}

	if _, ok := res_arr["Total"]; ok {
		return strconv.ParseInt(res_arr["Total"], 10, 64)
	}
	return 0, errors.New("failed")
}