zhipuzi_pos_windows/zhipuzi_pos_windows/network/CZhipuziHttpClient.cpp

#include "../pch/pch.h"
#include "CZhipuziHttpClient.h"

#include "../helper/MD5.h"

#include <curl/curl.h>

CZhipuziHttpClient::CZhipuziHttpClient()
{
#ifdef _DEBUG
	m_env = DEV;
#else
	m_env = RELEASE;
#endif	

	if (m_env == DEV)
	{
		m_pingtai_url = "https://pf-api-dev.zhipuzi.com/pos";
		m_canyin_yewu_url = "https://cyapi-dev.zhipuzi.com/pos";
		m_lingshou_yewu_url = "https://lsapi-dev.zhipuzi.com/pos";
	}
	else if (m_env == TEST)
	{
		m_pingtai_url = "https://pf-api-test.zhipuzi.com/pos";
		m_canyin_yewu_url = "https://cyapi-test.zhipuzi.com/pos";
		m_lingshou_yewu_url = "https://lsapi-test.zhipuzi.com/pos";
	}
	else if (m_env == RELEASE)
	{
		m_pingtai_url = "https://pf-api.zhipuzi.com/pos";
		m_canyin_yewu_url = "https://cyapi.zhipuzi.com/pos";
		m_lingshou_yewu_url = "https://lsapi.zhipuzi.com/pos";
	}

	//初始化curl
	curl_global_init(CURL_GLOBAL_ALL);

	m_username = CSetting::getUsername();
	m_password = CSetting::getPassword();
}


CZhipuziHttpClient::~CZhipuziHttpClient()
{
}

void CZhipuziHttpClient::Init(std::string username, std::string password)
{
	m_client.m_username = username;
	m_client.m_password = password;
}

bool CZhipuziHttpClient::Login(std::string& errmsg)
{
	std::map<string, string> params;

    std::string response;
    bool ret = m_client.RequestPingtai("/userlogin/userlogin", params, response);

	if (!ret)
	{
		//网络请求出错
		LOG_INFO("network failed!");
		errmsg = "network failed!";
		return false;
	}

	//LOG_INFO("response:" << response.c_str());

    rapidjson::Document document;
    document.Parse(response.c_str());
    if(!document.IsObject())
    {
        LOG_INFO("message 非法！");
        errmsg = "message 非法！";
        return false;
    }

    if(document.HasMember("errcode"))
    {
        rapidjson::Value& v_errcode = document["errcode"];
        int errcode = v_errcode.GetInt();
        if(errcode == -1 || errcode < 0)
        {
            LOG_INFO("login failed! message:" << document["errmsg"].GetString());
            errmsg = std::string(document["errmsg"].GetString());
            return false;
        }
    }
    else if(document.HasMember("error_code"))
    {
        rapidjson::Value& v_errcode = document["error_code"];
        int errcode = v_errcode.GetInt();
        if(errcode < 0)
        {
            LOG_INFO("login failed! message:" << document["error_msg"].GetString());
            errmsg = std::string(document["error_msg"].GetString());
            return false;
        }
    }

	rapidjson::Value& v_data = document["data"]; 

	rapidjson::Value& v_version_type = v_data["version_type"];
	m_client.m_version_type = v_version_type.GetString();

	if (m_client.m_version_type == "1")
	{
		m_client.m_yewu_url = "https://cyapi.zhipuzi.com/pos";
	}
	else
	{
		m_client.m_yewu_url = "https://lsapi.zhipuzi.com/pos";
	}

	rapidjson::Value& v_lwm_sess_token = v_data["lwm_sess_token"];
	m_client.lwm_sess_token = v_lwm_sess_token.GetString();

    LOG_INFO("login success!");

    return true;
}

bool CZhipuziHttpClient::Request(std::string url, std::map<string, string> params, std::string& response)
{
    std::string timestamp = to_string(time(NULL));
    std::string nonce = "123456";

    //先添加默认参数，用于计算签名
    params["username"] = m_client.m_username;
    params["nonce"] = nonce;
    params["timestamp"] = timestamp;
    params["url"] = m_client.m_yewu_url + url;

    //计算签名
    std::string postString;
    for(std::map<string, string>::iterator it = params.begin(); it != params.end();)
    {
        postString += it->first + "=" + it->second;

        it++;

        if(it != params.end())
        {
            postString += "&";
        }
    }

    LOG_INFO("postString:" << postString.c_str());

    //用于计算签名的临时变量
    std::string password = md5(m_client.m_password);
    transform(password.begin(), password.end(), password.begin(), ::toupper);

    string tmp = postString + password;

    std::string sign = md5(tmp);
    transform(sign.begin(), sign.end(), sign.begin(), ::toupper);
    LOG_INFO("sign:" << sign.c_str());

    //加上签名，去掉url，计算post
    params["sign"] = sign;
    params.erase("url");

    //未签名之前，不能进行urlencode，签名完成之后可以（params的value必须为utf8格式）
    postString = "";
    for(std::map<string, string>::iterator it = params.begin(); it != params.end();)
    {
        postString += it->first + "=" + CLewaimaiString::UrlEncode(it->second);

        it++;

        if(it != params.end())
        {
            postString += "&";
        }
    }

    LOG_INFO("postString:" << postString.c_str());

    CHttpClient m_httpClient;
    int ret = m_httpClient.Posts(m_client.m_yewu_url + url, postString, response, NULL);

    LOG_INFO("response:" << response.c_str());

    if(ret == 0)
    {
        //ret为0表示没有出错
        return true;
    }

    return false;
}

bool CZhipuziHttpClient::RequestPingtai(std::string url, std::map<string, string> params, std::string& response)
{
	std::string timestamp = to_string(time(NULL));
	std::string nonce = "123456";

	//先添加默认参数，用于计算签名
	params["username"] = m_client.m_username;
	params["nonce"] = nonce;
	params["timestamp"] = timestamp;
	params["url"] = m_client.m_pingtai_url + url;

	//计算签名
	std::string postString;
	for (std::map<string, string>::iterator it = params.begin(); it != params.end(); )
	{
		postString += it->first + "=" + it->second;

		it++;

		if (it != params.end())
		{
			postString += "&";
		}
	}

	LOG_INFO("postString:" << postString.c_str());

	//用于计算签名的临时变量
	std::string password = md5(m_client.m_password);
	transform(password.begin(), password.end(), password.begin(), ::toupper);

	string tmp = postString + password;

	std::string sign = md5(tmp);
	transform(sign.begin(), sign.end(), sign.begin(), ::toupper);
	LOG_INFO("sign:" << sign.c_str());

	//加上签名，去掉url，计算post
	params["sign"] = sign;
	params.erase("url");

	//未签名之前，不能进行urlencode，签名完成之后可以（params的value必须为utf8格式）
	postString = "";
	for (std::map<string, string>::iterator it = params.begin(); it != params.end();)
	{
		postString += it->first + "=" + CLewaimaiString::UrlEncode(it->second);

		it++;

		if (it != params.end())
		{
			postString += "&";
		}
	}

	LOG_INFO("postString:" << postString.c_str());

	CHttpClient m_httpClient;
	int ret = m_httpClient.Posts(m_client.m_pingtai_url + url, postString, response, NULL);

	LOG_INFO("response:" << response.c_str());

	if (ret == 0)
	{
		//ret为0表示没有出错
		return true;
	}
	else
	{
		//返回值说明 https://blog.csdn.net/u011857683/article/details/53069268
		LOG_INFO("request error, ret value:" << ret);
	}

	return false;
}

std::string CZhipuziHttpClient::getShopId()
{
	return m_client.m_shop_id;
}