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-dev3.zhipuzi.com/pos";
		m_canyin_yewu_url = "https://cyapi-dev3.zhipuzi.com/pos";
		m_lingshou_yewu_url = "https://lsapi-dev3.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_http_proxy.ip = CSetting::GetInstance()->GetParam("http_proxy_ip");
	m_http_proxy.port = CSetting::GetInstance()->GetParam("http_proxy_port");
	m_http_proxy.username = CSetting::GetInstance()->GetParam("http_proxy_username");
	m_http_proxy.password = CSetting::GetInstance()->GetParam("http_proxy_password");
}

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

	m_http_proxy.ip = CSetting::GetInstance()->GetParam("http_proxy_ip");
	m_http_proxy.port = CSetting::GetInstance()->GetParam("http_proxy_port");
	m_http_proxy.username = CSetting::GetInstance()->GetParam("http_proxy_username");
	m_http_proxy.password = CSetting::GetInstance()->GetParam("http_proxy_password");
}

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

std::string CZhipuziHttpClient::GetUsername()
{
	return m_username;
}

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

    std::string response;
    bool ret = RequestPingtaiNew("/login/login", 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_version_type = v_version_type.GetString();

	if (m_version_type == "1")
	{
		m_yewu_url = m_canyin_yewu_url;
	}
	else
	{
		m_yewu_url = m_lingshou_yewu_url;
	}

	lwm_sess_token = v_data["lwm_sess_token"].GetString();

	m_shop_id = v_data["shop_id"].GetString();
	if (atoi(m_shop_id.c_str()) == 0)
	{
		LOG_INFO("login failed! shop_id is 0");
		errmsg = CLewaimaiString::UnicodeToUTF8(L"当前账号未关联店铺，请登录智铺子商家app关联店铺");

		return false;
	}

	//保存店铺信息
	CShopinfo::GetInstance()->InitShopinfoByLogin(v_data);

    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_username;
	params["nonce"] = nonce;
	params["timestamp"] = timestamp;
	params["url"] = m_yewu_url + url;
	params["shop_id"] = m_shop_id;

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

	int timeout = 5;
	
	if (url == "/goods/getallgoods")
	{
		//初始化所有商品，把超时时间延长一点
		timeout = 30;
	}

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

	//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"] = m_username;
	params["password"] = md5(m_password);
	params["lwm_appid"] = lwm_appid;
	params["nonce"] = nonce;
	params["timestamp"] = timestamp;
	params["lwm_sess_token"] = lwm_sess_token;
	params["shop_id"] = m_shop_id;

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

	//用于计算签名的临时变量
	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 + "=" + 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_yewu_url + url, postString, response, NULL, m_http_proxy);

	//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_username;
	params["nonce"] = nonce;
	params["timestamp"] = timestamp;
	params["url"] = 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_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_pingtai_url + url, postString, response, NULL, m_http_proxy);

	//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_username);
	params["password"] = md5(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_pingtai_url + url, postString, response, NULL, m_http_proxy);

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

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

	return false;
}