zhipuzi_pay_plugin/zhipuzi_pay_plugin/network/CZhipuziHttpClient.cpp

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

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

#include <curl/curl.h>

CZhipuziHttpClient::CZhipuziHttpClient()
{
	//初始化curl
	curl_global_init(CURL_GLOBAL_ALL);

	//初始化htttp代理相关参数
	std::string http_is_proxy = CSetting::GetParam("http_is_proxy");
	if (http_is_proxy == "1")
	{
		m_is_http_proxy = true;
	}
	else
	{
		m_is_http_proxy = false;
	}
	
	m_http_proxy_ip = CSetting::GetParam("http_proxy_ip");
	m_http_proxy_port = CSetting::GetParam("http_proxy_port");

	if (m_env == DEV)
	{
		m_pingtai_url = "https://pf-api-dev3.zhipuzi.com/seller";
	}
	else if (m_env == TEST)
	{
		m_pingtai_url = "https://pf-api-test.zhipuzi.com/seller";
	}
	else if (m_env == RELEASE)
	{
		m_pingtai_url = "https://pf-api.zhipuzi.com/seller";
	}
}

/*
 *修改了htttp代理设置之后，这里修改状态
 **/
void CZhipuziHttpClient::UpdateProxy()
{
	std::string http_is_proxy = CSetting::GetParam("http_is_proxy");
	if (http_is_proxy == "1")
	{
		m_client.m_is_http_proxy = true;
	}
	else
	{
		m_client.m_is_http_proxy = false;
	}

	m_client.m_http_proxy_ip = CSetting::GetParam("http_proxy_ip");
	m_client.m_http_proxy_port = CSetting::GetParam("http_proxy_port");
}

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.RequestPingtaiNew("/login/login", params, response);

    if(!ret)
    {
        //网络请求出错
        LOG_INFO("network failed!");
        errmsg = CLewaimaiString::UnicodeToUTF8(L"请求服务器失败，请检查网络设置！");;
        return false;
    }

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

    rapidjson::Document document;
    document.Parse(response.c_str());
    if(!document.IsObject())
    {
        LOG_INFO("message 非法！");
        errmsg = CLewaimaiString::UnicodeToUTF8(L"服务器错误");
        return false;
    }

    if(document.HasMember("errcode"))
    {
        rapidjson::Value& v_errcode = document["errcode"];
        int errcode = v_errcode.GetInt();
        if(errcode != 0)
        {
            LOG_INFO("login failed! message:" << document["errmsg"].GetString());
            errmsg = std::string(document["errmsg"].GetString());
			
			if (errcode == 10003)
			{
				errmsg = CLewaimaiString::UnicodeToUTF8(L"密码错误");
			}

            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());

			if (errcode == 10003)
			{
				errmsg = CLewaimaiString::UnicodeToUTF8(L"密码错误");
			}

            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")
	{
		if (m_client.m_env == RELEASE)
		{
			m_client.m_yewu_url = "https://cyapi.zhipuzi.com/seller";
		}
		else if (m_client.m_env == TEST)
		{
			m_client.m_yewu_url = "https://cyapi-test.zhipuzi.com/seller";
		}
		else if (m_client.m_env == DEV)
		{
			m_client.m_yewu_url = "https://cyapi-dev3.zhipuzi.com/seller";
		}
	}
	else
	{
		m_client.m_yewu_url = "https://lsapi.zhipuzi.com/seller";
	}

	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, m_client.m_is_http_proxy, m_client.m_http_proxy_ip, m_client.m_http_proxy_port);

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

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

    return false;
}

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

	std::string lwm_appid = "kJnkkHODnoloay197k97G129J";
	std::string open_secret = "kMDNjjid91ydo#!9DH1";

	//先添加默认参数，用于计算签名
	params["username"] = CLewaimaiString::UrlEncode(m_client.m_username);
	params["password"] = md5(m_client.m_password);
	params["lwm_appid"] = lwm_appid;
	params["nonce"] = nonce;
	params["timestamp"] = timestamp;

	//计算签名
	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());

	//用于计算签名的临时变量
	string tmp = md5(postString);
	tmp += open_secret;

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

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

	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());

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

	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, m_client.m_is_http_proxy, m_client.m_http_proxy_ip, m_client.m_http_proxy_port);

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

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

	return false;
}

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

	std::string lwm_appid = "84b19199fd221a78c491cd553cbb4ab7";
	std::string open_secret = "#repast!@#AfAS#@!";

	//先添加默认参数，用于计算签名
	params["username"] = CLewaimaiString::UrlEncode(m_client.m_username);
	params["password"] = md5(m_client.m_password);
	params["lwm_appid"] = lwm_appid;
	params["nonce"] = nonce;
	params["timestamp"] = timestamp;

	//计算签名
	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());

	//用于计算签名的临时变量
	string tmp = md5(postString);
	tmp += open_secret;

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

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

	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());

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

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

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

	return false;
}