QT系统集成组

#pragma once

//#include "mongoose.h"

#include "Axiomclient.h"

unsigned long GetTimetmp() {

	unsigned long stampNow = 0;

	time_t timer;

	timer = time(NULL);

	stampNow = timer;

	return stampNow;

}

static void event_handle(struct mg_connection* connection, int event_type, void* event_data, void* pUser) {

	struct http_message* hm = (struct http_message*)event_data;

	int connect_status;

	switch (event_type) {

	case MG_EV_CONNECT:

	{

						  connect_status = *(int*)event_data;

						  if (connect_status != 0) {

							  char char_tmp[64] = { 0 };

							  sprintf(char_tmp, "{\"connect failed, error code: %u\":%u}", connect_status);

							  string* str_tmp = (string*)pUser;

							  *str_tmp = char_tmp;

						  }

	}

		break;

	case MG_EV_HTTP_REPLY:

	{

//							 connection->flags |= MG_F_SEND_AND_CLOSE;

							 string* str_tmp = (string*)pUser;

							 *str_tmp = string(hm->body.p, hm->body.len);

	}

		break;

	case MG_EV_CLOSE:

		break;

	case MG_EV_HTTP_CHUNK:

		break;

	default:

		break;

	}

}

static void event_handlelong(struct mg_connection* connection, int event_type, void* event_data, void* pUser) {

	struct http_message* hm = (struct http_message*)event_data;

	int connect_status;

//	if (string(hm->body.p, hm->body.len).find(":[]")) {sleep(1000000);}

	switch (event_type) {

	case MG_EV_CONNECT:

	{

						  connect_status = *(int*)event_data;

						  if (connect_status != 0) {

							  char char_tmp[64] = { 0 };

							  sprintf(char_tmp, "{abcdefg, error code}");

							  string* str_tmp = (string*)pUser;

							  *str_tmp = char_tmp;

						  }

	}

		break;

	case MG_EV_HTTP_REPLY:

	{

//							 connection->flags |= MG_F_SEND_AND_CLOSE;

							 string* str_tmp = (string*)pUser;

							 *str_tmp = string(hm->body.p, hm->body.len);

//							 *str_tmp = string(connection->recv_mbuf.buf, connection->recv_mbuf.len);

	}

		break;

	case MG_EV_CLOSE:

	{

						char char_tmp[64] = { 0 };

						sprintf(char_tmp, "{abcdefg, error code}");

						string* str_tmp = (string*)pUser;

						*str_tmp = char_tmp;

	}

		break;

	case MG_EV_HTTP_CHUNK:

		break;

	default:

		break;

	}

}

int Fclient::Sendreq(string& sendUrl, string& sendHeader, string& reqData, string& req_callback, int type) {

	int flag = 0;			//????-1????ͨ??ʧ?ܣ? 0??ʾ??ʱ?? 1????????????????

	string str_url = sendUrl;

	struct mg_mgr mgr = { 0 };

	struct mg_connection* nc = NULL;

	mg_mgr_init(&mgr, NULL);

	switch (type)   //type 1??post or get  2??delete  3??put  4??post

	{

	case 1:

		nc = mg_connect_http(&mgr, event_handle, &req_callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	case 2:

		nc = mg_connect_http(&mgr, event_handle, &req_callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	case 3:

		nc = mg_connect_httpPUT(&mgr, event_handle, &req_callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	case 4:

		nc = mg_connect_httpPOST(&mgr, event_handle, &req_callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	default:

		nc = mg_connect_http(&mgr, event_handle, &req_callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	}

	mg_set_protocol_http_websocket(nc);

	unsigned long preTime = 0, nowTime = 0;

	preTime = GetTimetmp();

	int findResult = -1;

	while (1) {

		if (req_callback.length() > 0) {

			findResult = -1;

			findResult = req_callback.find("connect failed, error code");

			if (findResult < 0)

				flag = 1;//Rx ok ret=1

			else

				return -1;// -1 = Socket Error

			break;

		}

		mg_mgr_poll(&mgr, 1000);

		nowTime = GetTimetmp();

		if (nowTime - preTime >= 15) {

			flag = 0;

			break;

		}

	}

	mg_mgr_free(&mgr);

//	if (type == 2) sleep(10000000);

	return flag;

}

void Fclient::init_mg() {

	this->mgr_long = { 0 };

	this->nc_long = NULL;

	mg_mgr_init(&this->mgr_long, NULL);

}

void Fclient::free_mg() {

	mg_mgr_free(&this->mgr_long);

}

int Fclient::SendreqLong(string& sendUrl, string& sendHeader, string& reqData, int type, bool& flag1, string path, string host) {

	int flag = 0;			//????-1????ͨ??ʧ?ܣ? 0??ʾ??ʱ?? 1????????????????

	string str_url = sendUrl;

	string callback;

	switch (type)   //type 1??post or get  2??delete  3??put  4??post

	{

	case 1:

		if (flag1) {

			nc_long = mg_connect_http(&mgr_long, event_handlelong, &callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

//			nc_long = mg_connect_ws(&mgr_long, host.c_str(), event_handlelong, &call_back);

			flag1 = false;

		} else {

//			sleep(1000000);

			mg_printf(nc_long, "%s %s HTTP/1.1\r\nHost: %s\r\nContent-Length: %" SIZE_T_FMT

				"\r\n%s\r\n%s",

				(reqData[0] == '\0' ? "GET" : "POST"), path.c_str(),

				host.c_str(), reqData.length(), sendHeader.c_str(), reqData.c_str());

//			sleep(100000000);

			nc_long->mgr = &mgr_long;

		}

		break;

	case 2:{

			   mg_printf(mgr_long.active_connections, "%s %s HTTP/1.1\r\nHost: %s\r\nContent-Length: %" SIZE_T_FMT

				   "\r\n%s\r\n%s",

				   (reqData[0] == '\0' ? "GET" : "POST"), path.c_str(),

				   host.c_str(), reqData.length(), sendHeader.c_str(), reqData.c_str());

			   break;

	}

	case 3:

		nc_long = mg_connect_httpPUT(&mgr_long, event_handle, &callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	case 4:

		nc_long = mg_connect_httpPOST(&mgr_long, event_handle, &callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	default:

		nc_long = mg_connect_http(&mgr_long, event_handle, &callback, str_url.c_str(), sendHeader.c_str(), reqData.c_str());

		break;

	}

//	mg_set_protocol_http_websocket(mgr_long.active_connections);

	unsigned long preTime = 0, nowTime = 0;

	preTime = GetTimetmp();

	int findResult = -1;

//	int aaaaaaa = 0;

	while (1) {

		if (callback.length() > 0) {

			findResult = -1;

			findResult = callback.find("abcdefg");

			if (findResult < 0)

				flag = 1;//Rx ok ret=1

			else

				return -1;// -1 = Socket Error

			break;

		}

//		aaaaaaa++;

		mg_mgr_poll(nc_long->mgr, 1000);

//		if (type == 2 && aaaaaaa == 2) {sleep(1000000);}

//		if (!flag1) { sleep(1000000); }

//		if (iii == 555) { sleep(10000000); }

		nowTime = GetTimetmp();

		if (nowTime - preTime >= 15) {

			flag = 0;

			break;

		}

	}

//	mg_mgr_free(&mgr_long);

	call_back = callback;

	return flag;

}