zhipuzi_pos_windows/zhipuzi_pos_windows/network/CZhipuziHttpClient.cpp

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

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

CZhipuziHttpClient CZhipuziHttpClient::m_client;

CZhipuziHttpClient::CZhipuziHttpClient()
{
    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("/login/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)
        {
            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_ur = "https://cyapi.zhipuzi.com/pos";
	}
	else
	{
		m_client.m_yewu_ur = "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_ur + 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_ur + 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;
	}

	return false;
}