QT系统集成组

#pragma once

#include "ZJ_cctv.h"

#include "ZJ_cctvClient.h"

#include "iostream"

#include "fstream"

#ifdef WIN32

#include <direct.h>

#include <io.h>

#else

#include <sys/stat.h>

#include <sys/io.h>

#include <stdio.h>

#include <unistd.h>

#include <sys/types.h>

#endif

#ifndef WIN32

#include <iconv.h>

#endif

#define far

typedef void far  *LPVOID;

unsigned long long GetTimeStamp()

{

	unsigned long long stampNow = 0;

	time_t timer;

	timer = time(NULL);

	stampNow = timer;

	return stampNow;

}

unsigned int rxprocess(LPVOID rxptr)

{

	ZJ_CCTV* rtxpPara = NULL;

	rtxpPara = (ZJ_CCTV*)rxptr;

	sint32 rtuno = rtxpPara->Get_rtuno();

	while (rtxpPara->rxflag)

	{

		//rtxpPara->getallResources();

//		rtxpPara->realplay("api/tvwall/1/device/1/floatwnd/16846849/subwnd/3","e3c1c32b86154dcea0e9fb2dc701a015");

//		rtxpPara->getToken();//wyf test 20230517

		SeSleep(10000);

	}

	return 0;

}

unsigned int txprocess(LPVOID txptr)

{

	ZJ_CCTV* rtxpPara = NULL;

	rtxpPara = (ZJ_CCTV*)txptr;

	sint32 rtuno = rtxpPara->Get_rtuno();

	while (rtxpPara->txflag)

	{

		S_RAWCMD rawcmd;

		while (rtxpPara->Get_CmdNum() > 0)

		{

			if (rtxpPara->Get_ACmd(rtuno, &rawcmd) == 0)

				break;

			rtxpPara->PrintLog(LOG_INFORMATION, "?յ?%d???ն? ????:%d ", rtuno, rawcmd.type);

			uint8 len = 0;

			ST_TRACK_ADDR 	m_cmdaddr;     //?????ⲿ???ͨ???˱????????ⲿ?????ַ??Ϣ

			m_cmdaddr = rawcmd.src;

			switch (rawcmd.type)

			{

				case DC_K_CMD_AOOPER:

				{

					S_AO_CTL* aoinfo;

					aoinfo = (S_AO_CTL*)(&rawcmd.data);

					int i;

					switch (aoinfo->funcCode)

					{

						case DC_K_CTL_AOSEL://ѡ??

							//ֱ?ӷ?У

							rawcmd.type = DC_K_CMDRET_AOOPER;

							rawcmd.len = sizeof(aoinfo);

							rawcmd.src = m_cmdaddr;

							aoinfo->retCode = 1;

							rtxpPara->Rpt_AResult(rtuno, rawcmd);

							break;

						case DC_K_CTL_AOEXE://ִ??

						{

							sint32 ytvalue = (sint32)(aoinfo->ptVal);

							uint16 ptno = aoinfo->ptAddr;

							rtxpPara->PrintLog(1, "<<<<<< YT no=%d   val=%d  ", ptno, ytvalue);

							int wid = ytvalue / 100;

							ytvalue = ytvalue - wid * 100;

							if (ptno >= 1 && ptno <= 4 &&rtxpPara->Cameramap.count(ytvalue)>0 && rtxpPara->Wndmap.count(ptno * 100)>0)

							{

								rtxpPara->getToken();

								rtxpPara->realplay(rtxpPara->Wndmap[ptno * 100], rtxpPara->Cameramap[ytvalue]);								

								rtxpPara->PrintLog(1, "??????????ͷ%d??%s ??Ƶ??ǽ??%d x100??%s", ytvalue,rtxpPara->Cameramap[ytvalue].c_str(),ptno,rtxpPara->Wndmap[ptno * 100].c_str());

							}

							else

							{

								rtxpPara->PrintLog(3, "δ?????¿?ֵ %d ??Ӧ?ļ?ص??? ???? ???ںţ??¿??ƴ???", ytvalue);

							}

						}

							break;

						case DC_K_CTL_AODEL://????

							break;

						default:

							break;

					}

				}

					break;

				default: //?????????·????????		

					break;

			}

			rtxpPara->Del_ACmd(rtuno);

		}

		SeSleep(500);

	}

	return 0;

}

sint32 ZJ_CCTV::Get_rtuno()

{

	return (pLink->GetRtuNo());

}

sint32 ZJ_CCTV::Get_CmdNum()

{

	sint32 rtuno = pLink->GetRtuNo();

	return (pCmdMem->GetCmdNum(rtuno));

}

sint32 ZJ_CCTV::Get_ACmd(sint32 rtuno, S_RAWCMD* cmd)

{

	return pCmdMem->GetACmd(rtuno, cmd);

}

sint32 ZJ_CCTV::Del_ACmd(sint32 rtuno)

{

	return pCmdMem->DelACmd(rtuno);

}

sint32 ZJ_CCTV::Rpt_AResult(sint32 rtuno, S_RAWCMD cmd)

{

	return pCmdMem->RptAResult(rtuno, cmd);

}

void ZJ_CCTV::Init(S_PROTOCOLCFG* pcfg)

{

	PRawCtrl = pcfg->PRawCtrl;

	pCmdMem = pcfg->pCmdMem;

	pRtu = pcfg->pRtu;

	pLink = pcfg->pLink;

	rxflag = true;

	txflag = true;

	ReadIni();

	if (rxflag)

	{

		sint32 rxthread = SE_CreateThread((PTHREAD_FUNC_DEF)rxprocess, this, 100);

	}

	PrintLog(LOG_INFORMATION, "????rx?߳? !");

	if (txflag)

	{

		sint32 txthread = SE_CreateThread((PTHREAD_FUNC_DEF)txprocess, this, 100);

	}

	PrintLog(LOG_INFORMATION, "????tx?߳? !");

}

int ZJ_CCTV::getallResources()

{

	int status = 0;

	sint32 rtuno = Get_rtuno();

	string url = logininfo.urlheader + "/artemis/api/tvms/v1/public/all";

	string header = "Content-Type:application/json\r\n";

	//header = header + logininfo.appkey + "\r\nx-ca-signature-headers:x-ca-key\r\nx-ca-signature:" + Signaturemap["getallResources"];

	string body;

	string callback;

	Json::Value bodysender;

	bodysender;

	Json::FastWriter bodywrite;

	body = bodywrite.write(bodysender);

	status = Fclient::Sendreq(url, header, body, callback, 1);

	if (callback.size() <= 0)

	{

		PrintLog(LOG_ERROR, "getallResources callback is NULL!   ");

		return 0;

	}

	Json::Reader reader(Json::Features::strictMode());

	Json::Value data;

	if (reader.parse(callback, data))

	{

		string state = data["code"].asString();

		if (!(state.compare("0")))

		{

			int size = data["data"]["tvwall_list"][0]["dlp_list"][0]["floatwmd_list"][0]["wnd_list"].size();

			for (int i = 0; i < size; i++)

			{

				/*WndInfo wnd;

				wnd.wnd_uri = data["data"]["tvwall_list"][0]["dlp_list"][0]["floatwmd_list"][0]["wnd_list"][i]["wnd_uri"].asString();

				wnd.status = data["data"]["tvwall_list"][0]["dlp_list"][0]["floatwmd_list"][0]["wnd_list"][i]["status"].asInt();

				wnd.decode_channel = data["data"]["tvwall_list"][0]["dlp_list"][0]["floatwmd_list"][0]["wnd_list"][i]["decode_channel"].asInt();

				int id = data["data"]["tvwall_list"][0]["dlp_list"][0]["floatwmd_list"][0]["wnd_list"][i]["wnd_id"].asInt();

				Wndmap[id] = wnd;*/

			}

		}

		else

		{

			PrintLog(LOG_ERROR, "??ȡ????ǽ??????Ϣ???ش????? :%s   ",state.c_str());

		}

	}

	return 1;

}

int ZJ_CCTV::getToken()

{//{"access_token":"CBI2JCUP8cZvQFwPZJZTEs0EZkC9ridr","expires_in":43199}

	int ret=-1;

	int status = 0;

	sint32 rtuno = Get_rtuno();

	m_seq=rand();

	string seq_tmp=to_string(m_seq);

//seq_tmp="192051860833485581719661";

	string url = logininfo.urlheader + "/artemis/oauth/token";

//	string header = "Content-Type:application/json\r\n";

	string header = "Content-Type: multipart/form-data; boundary=--------------------------"+seq_tmp+"\r\n";//492051860833485581719660\r\n";

//	header = header +"User-Agent: PostmanRuntime/7.28.4\r\nAccept: */*\r\n";

//	header = header +"Postman-Token: b90f3dd3-2c85-49f6-844e-e2f838f8d380\r\n";

//	header = header +"Accept-Encoding: gzip, deflate, br\r\n";

	string body="----------------------------" + seq_tmp + "\r\n";//492051860833485581719660\r\n";

body = body +"Content-Disposition: form-data; name=\"client_id\"\r\n\r\n"+logininfo.appkey;

body = body +"\r\n----------------------------" + seq_tmp + "\r\n";//492051860833485581719660\r\n";	

body = body +"Content-Disposition: form-data; name=\"client_secret\"\r\n\r\n"+logininfo.secret;

body = body +"\r\n----------------------------" + seq_tmp + "--\r\n";//492051860833485581719660--\r\n";	

	string callback;

	Json::Value bodysender;

//	bodysender["client_id"] = logininfo.appkey;

//	bodysender["client_secret"] = logininfo.secret;

//	Json::FastWriter bodywrite;

//	body = bodywrite.write(bodysender);

	status = Fclient::Sendreq(url, header, body, callback, 1);

//callback="{\"access_token\":\"CBI2JCUP8cZvQFwPZJZTEs0EZkC9ridr\",\"expires_in\":43199}";//wyf test

	if (callback.size() <= 0)

	{

		PrintLog(LOG_ERROR, "getToken callback is NULL!status=%d   ",status);

		return 0;

	}

	Json::Reader reader(Json::Features::strictMode());

	Json::Value data;

	if (reader.parse(callback, data))

	{

		m_token="";

		m_token = data["access_token"].asString();

		if (0!=m_token.compare(""))

		{

			ret=1;

			PrintLog(1, "access_token=%s  ",m_token.c_str());

		}

		else

		{

			ret=-1;

			PrintLog(LOG_ERROR, "access_token??ȡʧ??");

		}

	}

	return ret;

}

int ZJ_CCTV::realplay(string wnd,string camera)

{

	int status = 0;

	sint32 rtuno = Get_rtuno();

	string url = logininfo.urlheader + "/artemis/api/tvms/v1/public/tvwall/wnds/realplay/addition";

//	string header = "Content-Type:application/json\r\nx-ca-key:23013291\r\n";

	string header = "Content-Type:application/json\r\naccess_token:" + m_token + "\r\n";

	string body;

	string callback;

	Json::Value bodysender;

	bodysender["realplay_list"][0]["wnd_uri"] = wnd;

	bodysender["realplay_list"][0]["camera_indexcode"] = camera;

	bodysender["realplay_list"][0]["stream_type"] = 0;

	Json::FastWriter bodywrite;

	body = bodywrite.write(bodysender);

	status = Fclient::Sendreq(url, header, body, callback, 1);

	if (callback.size() <= 0)

	{

		PrintLog(LOG_ERROR, "realplay callback is NULL!   ");

		return 0;

	}

	Json::Reader reader(Json::Features::strictMode());

	Json::Value data;

	if (reader.parse(callback, data))

	{

		string state = data["code"].asString();

		if (!(state.compare("0")))

		{

			PrintLog(1, "????ǽ??ǽ?????ɹ???   ");

		}

		else

		{

			PrintLog(LOG_ERROR, "????ǽ??ǽ???ش????? :%d   ", state);

		}

	}

	return 1;

}

int ZJ_CCTV::ReadIni()

{

	char *home = getenv("SEROOT");

	if (NULL == home)

	{

		PrintLog(LOG_ERROR, "????????SEROOTδ????");

		return 0;

	}

	char filename[256] = { 0 };

#if defined(__unix)

	sprintf(filename, "%s%s", home, "/cfg/ZJ_CCTV.ini");

#else

	sprintf(filename, "%s%s", home, "\\cfg\\ZJ_CCTV.ini");

#endif

	CReadConf readconf;

	char http_tmp[128]={0};

	char appkey_tmp[128]={0};

	char secret_tmp[128]={0};

	char ip_tmp[128]={0};

	readconf.ReadString("LoginInfo", "http_type", http_tmp, filename, "http");

	string head_tmp = http_tmp;//"https://";

	readconf.ReadString("LoginInfo", "server_ip", ip_tmp, filename, "10.151.1.80:443");

	readconf.ReadString("LoginInfo", "appkey", appkey_tmp, filename, "23013291");

	readconf.ReadString("LoginInfo", "secret", secret_tmp, filename, "N63QsR6vnHHu73laueHH");

	logininfo.appkey = appkey_tmp;

	logininfo.secret = secret_tmp;

//	logininfo.urlheader = head_tmp + ip_tmp;

	logininfo.urlheader = head_tmp + "://" + ip_tmp;

	int wndnum = 0;

	wndnum = readconf.ReadLong("Wnd_uri", "winNum", filename, "0");

	int i;

	char sSection[20];

	char wnd_tmp[128];

	for (i = 0; i < wndnum; i++)

	{

		memset(sSection, 0, sizeof(char)* 10);

		sprintf(sSection, "win_%d", i + 1);

		readconf.ReadString("Wnd_uri", sSection, wnd_tmp, filename, "0");

		Wndmap[(i + 1) * 100] = wnd_tmp;

	}

	int cameranum = 0;

	cameranum = readconf.ReadLong("Camera", "cameraNum", filename, "0");

	char cam_tmp[128];

	for (i = 0; i < cameranum; i++)

	{

		memset(sSection, 0, sizeof(char)* 10);

		sprintf(sSection, "camera_%d", i + 1);

		readconf.ReadString("Camera", sSection, cam_tmp, filename, "0");

		Cameramap[i + 1] = cam_tmp;

	}

	return 1;

}

sint32 ZJ_CCTV::TxProc()

{

	return 1;

}

sint32 ZJ_CCTV::RxProc()

{

	return 1;

}

#if defined(WIN32)

extern "C" __declspec(dllexport)

#else 

extern "C"

#endif

CProtocol	*CreateProtocol(char *defpara)

{

	return (CProtocol*)(new ZJ_CCTV());

}

/*

#ifdef __unix

extern "C" CProtocol* CreateProtocol(char *defpara)

#else

extern "C" __declspec(dllexport)  CProtocol* CreateProtocol(char *defpara)

#endif

{

CProtocol *pEpv = new ZJ_CCTV;

return pEpv;

}

*/