智慧机房 V2.0

\mainpage OneNetPostӦ??

\section note1 ????˵??

 ??Ӧ??ʵ?֣?

 - ????????ɼ?ԭʼ???ݼ??????????ϴ?onenet?ƶ???ƽ̨

 - ????????OneNetƽ̨ע???豸??

 - Http?????????ϴ?

\section note2 ????ģ??

??Ӧ?û???Ϊ????ģ?飺

  - Ӧ?ÿ??ģ??

  - ??Ȩ??? 

  - ????豸ע??״̬ 

  - ע???豸

  - ?????ϴ?

\section note3 ?޸???־

\page pageLog ?޸???־

\section log2 20170508

  ???? 20170508

\section log1 20170508 

\page pageApp Ӧ?ÿ??ģ??

\section app1-1 ????????

  ????豸???ã???Ȩ??????ע???豸

\section app1-2 ???

  - ͨ???ϴ????ݻ???-??Ӧ??ʵ????

  - ???ù??????? ??ȡini?ļ???ʽ??????ʱ??չ?޸ġ?

  - ?????߳?

  - ??Ϣ???? ֧????Ϣ??Ӧ

  - ?ػ????? ??ʱ????Ϣ???ػ????̣??쳣?ж????????˳??????ػ??????Զ?????

  - ??־??¼ ֧????־??¼??ͨ??global.h?ļ?ȫ?ֱ?????/?رջ???־ģʽ

\section app1-3 ????

\page post OneNeT??Ȩģ??

\section accredit1-1 ????????

  ????????

  - ʵ?ֶ??豸????Ȩ????

\section accredit1-2 ???

  - ??ȡ?豸??Ȩ?룬???豸??Ȩ??????Ȩ

\section accredit1-3 ????

   (1) ??ȡ?豸??Ȩ??Ϣ

   (2) ?Ƿ???Ȩ????????(3)????????(5)

   (3) ??????, ???ڣ????˳?????????(4)

   (4) ??ʼ??ִ?г??򣬲ɼ?????

   (5) ??Ȩ?ѹ??ڣ????˳?????????(4)

\section accredit1-4 ע??

  ע?????

  - ??ʱ?ж??豸??Ȩ?Ƿ????

\section accredit1-5 ʾ??

  ʾ???ο? 

\page post OneNeT???ע??ģ??

\section accredit1-1 ????????

  ????????

  - ʵ?ֶ??豸ע?????Ƿ?ע???ж?

\section accredit1-2 ???

  - ????˶??豸ע?????

  - ???豸???б??

\section accredit1-3 ????

   (1) ?????豸

   (2) ?????豸????

   (3) ?ж??豸?Ƿ?ע?ᣬ??????(6),??????(4)

   (4) ?ж??豸??Ϣ?Ƿ???£???????(5),??ת(2)

   (5) OneNet?豸????http????????(7)

   (6) ??OneNetע???豸

   (7) ?жϱ????豸?Ƿ???ɣ????˳?????????(2)

\section accredit1-4 ע??

  ע?????

  - ???豸ע?????Ψһ?Ժ˲?

\section accredit1-5 ʾ??

<pre>

  int COneNetPost::OneNet_CheckDeviceRegist(void)

	{

		std::map<int, TPostMsgItem>::iterator itPostItem = m_PostItem.begin();

		std::map<int, TPostMsgItem>::iterator it;

		for (; itPostItem != m_PostItem.end(); itPostItem++)

		{		

			it = m_PostDevice.find(iSid);

			if (it == m_PostDevice.end())//?豸δע??

			{

				OneNet_RegistDevice(itPostItem->second);

			}

		}

		return m_PostDevice.size();

	}

</pre>

\page postReg OneNETע??ģ??

\section reg1-1 ????????

  ????????

  - ʹ??POST??????OneNetƽ̨ע???豸??

  - ?豸ע??ɹ????Զ????????в???ע????豸??Ϣ???Ա????´?????ʱ???õؼ???豸ע???????

\section reg1-2 ???

  - ??????õĴ??????Ƿ?????OneNetƽ̨ע?ᣬ??û??ע??????ƽ̨ע???豸

  - ?Ѿ?ע????OneNetƽ̨?????豸??Ϣ

  - û??ע?ᣬ??OneNetƽ̨ע??ע???豸

  - ?ο? OneNET devices

\section reg1-3 ????

   (1) ?????豸

   (2) ????ע???豸????

   (3) ??ƽ̨????ɾ???豸

   (4) ɾ???????豸ע????Ϣ

   (5) ?豸??????ɣ?????ת??(2),??ת??(6)

   (6) ????豸ע??״̬

   (7) ?˳?

\section reg1-4 ע??

  ע?????

  - ע??ǰ?ȼ???豸?Ƿ??Ѿ?ע??

  - ?豸?и???Ҫ??ʱ???????ݿ?

\section reg1-5 ʾ??

  ʾ???ο? 

 //??ƽ̨ע??ע???豸

 <pre>

int COneNetPost::OneNet_RegistDevice(TPostMsgItem& item)

{

    char postdata[_BUF1K];	//Post???????뻺????????????ƽ̨????Post????

    char outdata[_BUF2K];	//Post??????????????????ڴ洢ƽ̨???ص?????

	long outlen = 0;			//Post???????ݳ??ȣ????ڼ?¼ƽ̨???ص????ݴ?С

	int iSid = item.Sid;

	int iKind = item.Kind;

	int iDevId = 0;

	std::string sDevApiKey;

	std::string sUrl;

	std::string sUrlHeader;

    cJSON *nd = NULL;

    cJSON *json = NULL;

    cJSON *child = NULL;

	//ע???豸

	sUrl = Format("http://%s:%d/register_de?register_code=%s", m_sPostHost.c_str(), m_iPostPort, m_PostRegCode[item.SubSys].c_str());//URL

	sUrlHeader=Format("");//Httpͷ

	if (iSid > 0)

		sprintf(postdata, "{\"sn\": \"%s-%d\"}", m_sMacID.c_str(), iSid);

	else

		sprintf(postdata, "{\"sn\": \"%s\"}", m_sMacID.c_str());

	if (DoHttpRequest(sUrl.c_str(), sUrlHeader.c_str(), postdata, outdata, &outlen) <= 0)

	{

		return 0;

	}

	//????????????

	json = cJSON_Parse((const char*)outdata);

	nd = cJSON_GetObjectItem(json, "error");

	int res = 0;

	if (strcmp(nd->valuestring, "succ") != 0)

	{

		cJSON_Delete(json);

		return 0;

	}

	child = cJSON_GetObjectItem(json, "data");

	nd = cJSON_GetObjectItem(child, "device_id");//ȡ???豸ID

	iDevId = atol(nd->valuestring);

	nd = cJSON_GetObjectItem(child, "key");//ȡ???豸ApiKey

	sDevApiKey = nd->valuestring;

	strcpy(item.ApiKey, nd->valuestring);

	item.DevID = iDevId;

	m_PostDevice[iSid] = item;

	sprintf(postdata, "insert into tbRegDevDef(DevID, SID, Kind, Type, SubSys, Name, Note, ApiKey, Mask, Ext0, Ext1) \

						values(%d, %d, %d, %d, %d, '%s', '%s', '%s', 0, 0, 0)",

						item.DevID, item.Sid, item.Kind, item.Type, item.SubSys, item.Name, item.ANote, item.ApiKey);

	m_dbCfg->execDML(postdata);

	cJSON_Delete(json);

	//?????豸??Ϣ

	OneNet_UpdateDeviceInfo(item);

	return 1;

}

</pre>

\page postOneNet OneNeT?ϴ?ģ??

\section post1-1 ????????

  ????????

  - ???????????ϴ?

  - ?????????ϴ?

\section post1-2 ???

  - ???????

  - ??ѯ????

  - ?ϴ?????

  - ?ο? OneNeT datapoints

\section post1-3 ????

  (1) ??ȡ?豸?б?

  (2) ?????豸???ݼ?¼

  (3) ????????Ƿ???£?????ת(2),??ת(4)

  (4) ?????ݸ???http?????????ϴ?

  (5) ?ж??Ƿ??????ɣ?????ת??(6),??ת(2)

  (6) ????

\section post1-4 ע??

  ע??????

  - ???????Ƿ????

  - ????????Ƿ????

  - ?????ϴ??Ƿ?ɹ?

\section post1-5 ʾ??

  ʾ???ο? 

  //?ϴ???????????

   <pre>

	std::map<int, TPostMsgItem>::iterator itPostItem = m_PostItem.begin();

	std::map<int, std::string>::iterator itDateUpd;

	for (; itPostItem != m_PostItem.end(); itPostItem++)//????

	{

		itDateUpd = m_PostDateUpd.find(itPostItem->second.Sid); //???ݸ???ʱ??

		if (itDateUpd == m_PostDateUpd.end())//û????ظ??¼?¼

			continue;

		sTable = m_PostDbTabName[iType];

		if (m_dbDat->tableExists(sTable.c_str()))//???ݱ?????

		{

			ssql = Format(_T("select * from %s where SID=%d"),sTable.c_str(),iSid);

			iqry = m_dbDat->qryExec(ssql.data());

			if (!m_dbDat->qryEof(iqry))

			{

				sDateUpd = m_dbDat->qryFieldStr(iqry, _T("DateUpd"));//???ݸ???ʱ??

				if (sDateUpd != itDateUpd->second)//?????и???

				{

					itDateUpd->second = sDateUpd;

					//TODO: ??????ݿ??Ƿ???ڲ?ȡ????Ӧ?????ݣ?Ȼ??????Post????֡

					iFieldCount = m_dbDat->qryFieldCount(iqry);

					sprintf(postdata,"{");

					for(int k=1; k<iFieldCount; k++)

					{						

						sprintf(abuf,"\"%s\":%d,",m_dbDat->qryFieldName(iqry,k), m_dbDat->qryFieldInt(iqry, _T(m_dbDat->qryFieldName(iqry, k))));

						strcat(postdata, abuf);										

					}

					strcat(postdata,"}");

					sUrl = Format("http://%s:%d/devices/%ld/%s", m_sPostHost.c_str(), m_iPostPort, m_PostDevice[iSid].DevID, m_sPostPath.c_str());

					sUrlHeader=Format("api-key:%s", m_PostApiKey[itPostItem->second.SubSys].c_str());

					if (DoHttpRequest(sUrl.c_str(), sUrlHeader.c_str(), postdata, outdata, &outlen) <= 0)

					{

					   ;

					}

				}

			}

			m_dbDat->qryFinalize(iqry);

		}

		_sleep(1);

	}

	 </pre>