查看:2149|回复:0
编了几个用于OneNet上传数据和获取数据的函数,贡献出来
个人感觉使用官方的库比较占内存,太多的功能和函数其实用不上,所以就自己编了几个实用的函数,贡献出来
欢迎大家积极实用OneNet。
- void setup() {
- // put your setup code here, to run once:
- #define WiFi_Port Serial3
- #define Debug_Port Serial
- }
- void loop() {
- // put your main code here, to run repeatedly:
- }
-
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于向OneNet发送数据,根据你的需要可以随意发送同一个设备下的n个数据流的数据点。本函数无返回值。 //
-
//***********************************************************************************************************************//
-
//本函数需要调用函数:String build_Post_HTTP_Header(unsigned long Device, String Host, String Key) //
- //他用来构造 HTTP头字符串 //
- //其中 Device 为OneNet上的设备,为无符号长整数型; //
- //Host 为OneNet的HTTP主机"api.heclouds点com",可以定义为一个字符串再引,也可直接使用; //
- //Key 为 OneNet上对应设备的Apikey,或用户的Masterkey,为字符串型 //
-
//***********************************************************************************************************************//
- //本函数还调用函数 Make_Post_Json(),这是用于构造相应Json字符串的函数; //
-
//***********************************************************************************************************************//
- //本函数还调用函数 returnmsg_ok_conWiFi();这个函数是判断是否完成了TCP连接; //
-
//***********************************************************************************************************************//
- //本函数还调用函数 returnmsgWiFi();主要是为了查看WiFi模块是否正确接受了发送的数据以及回显情,如不需要可用//来注销; //
-
//***********************************************************************************************************************//
-
//本函数还调用函数 returnmsg_ok_finishWiFi();主要是用来判断OneNet是否返回了正确信息 //
-
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- void Post_Data()
- {
-
String Send_info = build_Post_HTTP_Header(131278, "api.heclouds点com", "b6724PQP4FEVVI3sqMb3QIHh6boA" );
-
int len = Send_info.length() + Make_Post_Json().length() + 4; //计算总长度,如用透传则不需要,+4是加的 WiFi_Port.print("\r\n\r\n"); 两个换行和两个回车;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
- delay(500);
-
WiFi_Port.print("AT+CIPSEND=");
- returnmsgWiFi();
- WiFi_Port.println(len);
- returnmsgWiFi();
- delay(500);
-
WiFi_Port.print(Send_info);
- returnmsgWiFi();
-
WiFi_Port.print(Make_Post_Json());
- returnmsgWiFi();
-
WiFi_Port.print("\r\n\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于构造一个Json数据串 //
- //本函数需要调用函数:String Build_Json (String ID, long Value) //
- //其中ID 为OneNet上的设备中”数据流“ID,为字符串型; //
- //Value 为对应的数,为长整数型; //
- //他的返回值为构造好的,包含一数据流的数据点Json数据串; //
-
//***************************************************************************************************************//
- //本函数还调用函数 String ADD_Post_JsonPar(String Json, String ID, long Value) //
- //他是用来给已构造好的Json数据串增加一个数据流数据点; //
- //Json 为前面已构造好的一个完整Json数据,ID为需要增加的数据流的ID, Value为对用的数据; //
- //他的返回值为构造好的含有多个数据流数值的Json串 //
-
//***************************************************************************************************************//
- //如需增加多个数据流的数据,只需多次调用函数 String ADD_Post_JsonPar(String Json, String ID, long Value) //
-
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- String Make_Post_Json()
- {
- String _Json = Build_Post_Json("A01", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A02", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A03", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A04", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A05", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A06", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A07", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A08", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A09", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A10", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A11", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A12", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A13", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A14", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A15", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A16", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A17", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A18", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A19", random(1000));
- _Json = ADD_Post_JsonPar(_Json, "A20", random(1000));
- return _Json;
- }
-
///////////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于构造一个只包含一个数据流数据点的基本Json数据串 //
- //其中ID 为OneNet上的设备中”数据流“ID,为字符串型; //
- //Value 为对应的数,为长整数型; //
- //他的返回值为构造好,包含一数据流的数据点数; //
-
//形成Json数据串如此例:{"datastreams":[{"id":"TEMP","datapoints":[{"value":12345 }]}]} // //
-
///////////////////////////////////////////////////////////////////////////////////////////////////////////////
- String Build_Post_Json (String ID, long Value)
- {
- String _Value = Value + String("");
-
String _Json = "{\"datastreams\":[{\"id\":\"";
- _Json += ID;
- _Json += "\",\"datapoints\":";
- _Json += "[{\"value\":";
- _Json += _Value;
- _Json += "}]}]}";
- return _Json;
- }
-
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用来给已构造好的Json数据串增加一个数据流数据点; //
- //Json 为前面已构造好的一个完整Json数据,ID为需要增加的数据流的ID, Value为对用的数据; //
- //他的返回值为构造好的含有多个数据流数值的Json串 //
-
//*************************************************************************************************************************************//
- //如需增加多个数据流的数据,只需多次调用函数 String ADD_Post_JsonPar(String Json, String ID, long Value) //
-
//形成Json数据串如此例:{"datastreams":[{"id":"TEMP","datapoints":[{"value":45 }]},{"id":"HUMI","datapoints":[{"value":32 }]}]} // //
-
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- String ADD_Post_JsonPar(String Json, String ID, long Value)
- {
- int LENS = Json.length();
- String _Json = Json.substring(0, LENS - 2); //-2是先去掉最后两个字符“]}",然后追加”,"以及需要增加的ID的对应Json字符串,并加回"]}",够造成一个完整的Json数据串
- _Json += +",{\"id\":\"";
- _Json += ID;
- _Json += "\",\"datapoints\":";
- _Json += "[{\"value\":";
- String _Value = Value + String("");
- _Json += _Value;
- _Json += "}]}]}";
- return _Json;
- }
-
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于构造POST HTTP头字符串 //
- //其中 Device 为OneNet上的设备,为无符号长整数型; //
- //Host 为OneNet的HTTP主机"api.heclouds点com",可以定义为一个字符串再引,也可直接使用; //
- //Key为 OneNet上对应设备的Apikey,或用户的Masterkey,为字符串型 //
-
//**************************************************************************************************************//
- //形成的HTTP头字符串如下: //
-
//POST http://api.heclouds点com/devices/77654/datapoints HTTP/1.1\r\n “\r\n”代表一个回车一个换行,两个字符 //
- //Host: api.heclouds点com\r\n //
-
//api-key: asdjoiSKFMdmcdslk1398247\r\n //
- //Connection: close\r\n //
- //Content-Length: 68\r\n\r\n 这里要两次回车换行 //
-
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-
String build_Post_HTTP_Header(unsigned long Device, String Host, String Key)
- {
- String _Device = String("") + Device;
-
int Lens = Make_Post_Json().length();
- String _lens = Lens + String("");
- String HTTP_Header = "POST http://api.heclouds点com/devices/" + _Device + "/datapoints HTTP/1.1\r\n";
- HTTP_Header = HTTP_Header + "Host: " + Host + "\r\n";
- HTTP_Header = HTTP_Header + "api-key: " + Key + "\r\n" ;
- HTTP_Header = HTTP_Header + "Connection: close" + "\r\n" ;
- HTTP_Header = HTTP_Header + "Content-Length: " + _lens + "\r\n\r\n";
- return HTTP_Header;
- }
-
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于向OneNet获取(GET)一个或n个数据流的当前数据点,返回值为返回的Json字符串。 //
-
//*********************************************************************************************************************//
-
//本函数需要调用函数:String build_Post_HTTP_Header(unsigned long Device, String Host, String Key) //
- //他用来构造 HTTP头字符串 //
- //其中 Device 为OneNet上的设备,为无符号长整数型; //
- //Host 为OneNet的HTTP主机"api.heclouds点com",可以定义为一个字符串再引,也可直接使用; //
- //Key 为 OneNet上对应设备的Apikey,或用户的Masterkey,为字符串型 //
-
//*********************************************************************************************************************//
- //本函数还调用函数 Make_GET_Json(),这是用于构造相应Json字符串的函数; //
-
//*********************************************************************************************************************//
- //本函数还调用函数 returnmsg_ok_conWiFi();这个函数是判断是否完成了TCP连接; //
-
//*********************************************************************************************************************//
- //本函数还调用函数 returnmsgWiFi();主要是为了查看WiFi模块是否正确接受了发送的数据以及回显情,如不需要可用//来注销; //
-
//*********************************************************************************************************************//
- //本函数还调用函数 returnmsg_GET_S_WiFi();主要是用来生成返回值字符 //
- //他的返回值就是包含相应数据流当前数据点值的Json数据串 //
-
//*********************************************************************************************************************//
-
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
- String GET_Datapoints()
- {
-
int len = Make_GET_Json().length() + 4; //计算总长度,如用透传则不需要,+4是加的 WiFi_Port.print("\r\n\r\n"); 两个换行和两个回车;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
- delay(1000);
-
WiFi_Port.print("AT+CIPSEND=");
- returnmsgWiFi();
- WiFi_Port.println(len);
- returnmsgWiFi();
- delay(1000);
-
WiFi_Port.print(Make_GET_Json());
- returnmsgWiFi();
-
WiFi_Port.print("\r\n\r\n");
- String _ResulT = returnmsg_GET_S_WiFi();
-
WiFi_Port.println("AT+CIPCLOSE");
- return _ResulT;
- }
-
///////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于分析String GET_Datapoints()取回的数据流的数据点 //
- //_Result为String GET_Datapoints()函数取回的结果; //
- //_Stream为想要分析的数据 //
- //返回值为对应的数据流的相应数值 //
- //如需分析多个数据,调用多次即可 //
-
///////////////////////////////////////////////////////////////////////////////////////////////////
- int Analyze_GET_Result(String _Result, String _Stream)
- {
- int _No1 = _Result.indexOf(_Stream);
- String _SubS1 = _Result.substring(_No1 - 22, _No1 - 3);
- int _No2 = _SubS1.indexOf(":");
- int _No3 = _SubS1.indexOf("}");
- String _SubS2 = _SubS1.substring(_No2 + 2, _No3 - 1);
- int _n = atoi(_SubS2.c_str());
- return _n;
- }
-
//////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于构造一个包含一个或多个数据流数据点的GETJson数据串 //
- //本函数需要调用函数:String Build_GET_HTTP (String ID, String Key, long Device, String Host) //
- //其中ID 为OneNet上的设备中”数据流“ID,为字符串型; //
- //其中 Device 为OneNet上的设备,为无符号长整数型; //
- //Host 为OneNet的HTTP主机"api.heclouds点com",可以定义为一个字符串再引,也可直接使用; //
- //Key 为 OneNet上对应设备的Apikey,或用户的Masterkey,为字符串型 //
- //他的返回值为构造好的,包含相应数据流的数据点Json数据串; //
-
//******************************************************************************************************//
- //本函数还调用函数 String ADD_GET_HTTP_Par(String Json, String ID) //
- //他是用来给已构造好的Json数据串增加一个数据流数据点; //
- //Json 为前面已构造好的一个完整Json数据,ID为需要增加的数据流的ID; //
- //他的返回值为构造好的含有多个数据流数值的Json串 //
-
//******************************************************************************************************//
- //如需GET多个数据流的数据点,只需多次调用函数 String ADD_GET_HTTP_Par(String Json, String ID) //
-
//******************************************************************************************************//
-
//////////////////////////////////////////////////////////////////////////////////////////////////////////
- String Make_GET_Json()
- {
-
String _GET_HTTP= Build_GET_HTTP ("T001", "ankjsdvndfrehvngjoitre13290", 46788, "api.heclouds点com");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T002");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T003");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T004");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T005");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T006");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T006");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T007");
-
_GET_HTTP = ADD_GET_HTTP_Par(_GET_HTTP, "T008");
- return _GET_HTTP;
- }
-
///////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于构造 GET 数据流数据点的Json字符串 //
- //其中 Device 为OneNet上的设备,为无符号长整数型; //
- //Host 为OneNet的HTTP主机"api.heclouds点com",可以定义为一个字符串再引,也可直接使用; //
- //Key为 OneNet上对应设备的Apikey,或用户的Masterkey,为字符串型 //
- //ID为需要获取数据点的数据流的ID //
- //返回值为构造好的GET HTTP头和Json的组合。 //
-
//*******************************************************************************************//
- //他的返回Json数据串如下: //
-
// GET /devices/54365/datapoints?datastream_id=K1 HTTP/1.1\r\n //
- //Host: api.heclouds点com\r\n //
-
//api-key: asdjoiSKFMdmcdslk1398247\r\n //
-
///////////////////////////////////////////////////////////////////////////////////////////////
- String Build_GET_HTTP (String ID, String Key, long Device, String Host)
- {
- String _Device = Device + String("");
-
String _HTTP = "GET /devices/" + _Device + "/datapoints?datastream_id=" + ID + " HTTP/1.1\r\n";
- _HTTP = _HTTP + "Host: " + Host + "\r\n";
- _HTTP = _HTTP + "api-key:" + Key + "\r\n";
- return _HTTP;
- }
-
////////////////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于对构造好的包含一个数据流数据点的GET HTTP头和Json字符串组合,增加一个需要读取的数据流 //
- //Json 为前面已构造好的一个完整Json数据,ID为需要增加的数据流的ID ; //
- //返回值为增加一个数据流后的GET HTTP头和Json字符串组合 //
-
//****************************************************************************************************//
- //如需增加多个数据流的数据,只需多次调用函数 String ADD_HTTPPar(String Json, String ID) //
-
//****************************************************************************************************//
- //他的返回Json数据串如下: //
-
// GET /devices/54365/datapoints?datastream_id=K1,K2 HTTP/1.1\r\n //
- //Host: api.heclouds点com\r\n //
-
//api-key: asdjoiSKFMdmcdslk1398247\r\n //
-
////////////////////////////////////////////////////////////////////////////////////////////////////////
- String ADD_GET_HTTP_Par(String Json, String ID)
- {
- int _Lens = Json.length();
- int _Point1 = Json.indexOf(" HTTP/1.1");
- String SubString1 = Json.substring(0, _Point1);
- String SubString2 = Json.substring(_Point1, _Lens);
- String _HTTP = Json.substring(0, _Point1);
- _HTTP += ",";
- _HTTP += ID;
- _HTTP += Json.substring(_Point1, _Lens);
- return _HTTP;
- }
-
///////////////////////////////////////////////////////////////////////////////////////////////
- //本函数生成GET命令返回的信息字符串用于后续的分析 //
- //如大于3分钟未返回结束信息则认为超时失败,执行AT+CIPCLOSE,强行关闭TCP连接 //
- //判断是否结束的关键字是"\"error\":\"succ\"}" //
- //返回值为系统返回的Json 数据串 //
-
///////////////////////////////////////////////////////////////////////////////////////////////
- String returnmsg_GET_S_WiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 180000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
- return "false";
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
-
// Debug_Port.println(TEMPdata);
- delayMicroseconds(500);
- }
-
if (_TEMPdata.indexOf("\"error\":\"succ\"}") > 3)
- {
-
Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- return _TEMPdata;
- }
- }
- }
-
//********************************************************** OneNet WiFi send Data *******************************************************************************************************
-
/////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为整数类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid 对应数据流的ID,thisData 对应数据流的数值 //
-
/////////////////////////////////////////////////////////////////////////////////////////////
- //
- void sendDataWiFi(String APIkey, int thisData, unsigned long deviceid ,String Host, String sensorid)
- {
- int l = getLength(thisData);
- int D = getLength(deviceid);
- int S = sensorid.length();
- int lenss = 53 + S + l;
- int lll = getLength(lenss);
- int lens = 214 + D + S + l + lll;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n"); returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.print("{\"datastreams\":[{\"id\":\"");
-
WiFi_Port.print(sensorid);
- returnmsgWiFi();
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- returnmsgWiFi();
-
WiFi_Port.print(thisData);
- WiFi_Port.print("}]}]}");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send 2 Data *******************************************************************************************************
-
/////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为整数类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid1 对应数据流1的ID,Data1 对应数据流1的数值 //
- // sensorid2 对应数据流2的ID,Data2 对应数据流2的数值 //
-
/////////////////////////////////////////////////////////////////////////////////////////////
- void send2DataWiFi(String APIkey, int Data1, int Data2, unsigned long deviceid,String Host, String sensorid1 , String sensorid2)
- {
- int l1 = getLength(Data1);
- int l2 = getLength(Data2);
- int D = getLength(deviceid);
- int S1 = sensorid1.length();
- int S2 = sensorid2.length();
- int lenss = 53 + 36 + S1 + l1 + S2 + l2; //增加一个数据流Lenss固定长度需要增加36;
- int l3 = getLength(lenss);
- int lens = 214 + 36 + D + S1 + l1 + S2 + l2 + l3; //增加一个数据流Lens固定长度需要增加36;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
////////////////////////////////////////////////////////////////////sensor data
-
WiFi_Port.print("{\"datastreams\":[");
-
///////////////////////////////////////////////////////////////////sensor1
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid1);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data1);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid2);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data2);
- WiFi_Port.print("}]}");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor end
- WiFi_Port.print("]}");
-
////////////////////////////////////////////////////sensor data end
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send 3 Data *******************************************************************************************************
-
/////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为整数类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid1 对应数据流1的ID,Data1 对应数据流1的数值 //
- // sensorid2 对应数据流2的ID,Data2 对应数据流2的数值 //
- // sensorid3 对应数据流3的ID,Data3 对应数据流3的数值 //
-
/////////////////////////////////////////////////////////////////////////////////////////////
- void send3DataWiFi(String APIkey, int Data1, int Data2, int Data3, unsigned long deviceid,String Host, String sensorid1, String sensorid2, String sensorid3)
- {
- int l1 = getLength(Data1);
- int l2 = getLength(Data2);
- int l3 = getLength(Data3);
- int D = getLength(deviceid);
- int S1 = sensorid1.length();
- int S2 = sensorid2.length();
- int S3 = sensorid3.length();
- int lenss = 53 + 36 + 36 + S1 + l1 + S2 + l2 + S3 + l3; //增加一个数据流Lenss固定长度需要增加36,增加2个数据流需要增加2次36;
- int lll = getLength(lenss);
- int lens = 214 + 36 + 36 + D + lll + S1 + l1 + S2 + l2 + S3 + l3; //增加一个数据流Lens固定长度需要增加36,增加2个数据流需要增加2次36;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- delay(00);
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: "); returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: "); returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
////////////////////////////////////////////////////////////////////sensor data
-
WiFi_Port.print("{\"datastreams\":[");
-
///////////////////////////////////////////////////////////////////sensor1
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid1);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data1);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid2);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data2);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid3);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data3);
- WiFi_Port.print("}]}");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor end
- WiFi_Port.print("]}");
-
////////////////////////////////////////////////////sensor data end
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send 4 Data *******************************************************************************************************
-
/////////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为整数类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid1 对应数据流1的ID,Data1 对应数据流1的数值 //
- // sensorid2 对应数据流2的ID,Data2 对应数据流2的数值 //
- // sensorid3 对应数据流3的ID,Data3 对应数据流3的数值 //
- // sensorid4 对应数据流4的ID,Data4 对应数据流4的数值 //
-
/////////////////////////////////////////////////////////////////////////////////////////////
- void send4DataWiFi(String APIkey, int Data1, int Data2, int Data3, int Data4, unsigned long deviceid,String Host, String sensorid1, String sensorid2, String sensorid3, String sensorid4)
- {
- int l1 = getLength(Data1);
- int l2 = getLength(Data2);
- int l3 = getLength(Data3);
- int l4 = getLength(Data4);
- int D = getLength(deviceid);
- int S1 = sensorid1.length();
- int S2 = sensorid2.length();
- int S3 = sensorid3.length();
- int S4 = sensorid4.length();
- int lenss = 53 + 36 + 36 + 36 + S1 + l1 + S2 + l2 + S3 + l3 + S4 + l4; //增加一个数据流Lenss固定长度需要增加36,增加3个数据流需要增加3次36;
- int lll = getLength(lenss);
- int lens = 214 + 36 + 36 + 36 + D + lll + S1 + l1 + S2 + l2 + S3 + l3 + S4 + l4; //增加一个数据流Lens固定长度需要增加36,增加3个数据流需要增加3次36;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- delay(00);
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
////////////////////////////////////////////////////////////////////sensor data
-
WiFi_Port.print("{\"datastreams\":[");
-
///////////////////////////////////////////////////////////////////sensor1
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid1);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data1);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid2);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data2);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor3
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid3);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data3);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor4
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid4);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data4);
- WiFi_Port.print("}]}");
- returnmsgWiFi();
-
//////////////////////////////////////////////////////////////sensor end
- WiFi_Port.print("]}");
-
////////////////////////////////////////////////////sensor data end
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send Data *******************************************************************************************************
-
/////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送一个数据流的数据点,数值为字符数组类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid 对应数据流1的ID,thisData对应数据流1的数值 //
-
/////////////////////////////////////////////////////////////////////////////////////////
- void sendDataWiFiC(String APIkey, char *thisData, unsigned long deviceid,String Host, String sensorid )
- {
- int l = strlen(thisData);
- int D = getLength(deviceid);
- int S = sensorid.length();
- int lenss = 53 + S + l;
- int lll = getLength(lenss);
- int lens = 214 + D + S + l + lll;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.print("{\"datastreams\":[{\"id\":\"");
-
WiFi_Port.print(sensorid);
- returnmsgWiFi();
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- returnmsgWiFi();
-
WiFi_Port.print(thisData);
- WiFi_Port.print("}]}]}");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send 2 Data *******************************************************************************************************
-
//////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为字符串类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid1 对应数据流1的ID,Data1 对应数据流1的数值 //
- // sensorid2 对应数据流2的ID,Data2 对应数据流2的数值 //
-
//////////////////////////////////////////////////////////////////////////////////////////
- void send2DataWiFiC(String APIkey, char * Data1, char * Data2, unsigned long deviceid,String Host, String sensorid1 , String sensorid2)
- {
- int l1 = strlen(Data1);
- int l2 = strlen(Data2);
- int D = getLength(deviceid);
- int S1 = sensorid1.length();
- int S2 = sensorid2.length();
- int lenss = 53 + 36 + S1 + l1 + S2 + l2; //增加一个数据流Lenss固定长度需要增加36,增加1个数据流需要增加1次36;
- int l3 = getLength(lenss);
- int lens = 214 + 36 + D + S1 + l1 + S2 + l2 + l3; //增加一个数据流Lens固定长度需要增加36,增加1个数据流需要增加1次36;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- delay(00);
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
////////////////////////////////////////////////////////////////////sensor data
-
WiFi_Port.print("{\"datastreams\":[");
-
///////////////////////////////////////////////////////////////////sensor1
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid1);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data1);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid2);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data2);
- WiFi_Port.print("}]}");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor end
- WiFi_Port.print("]}");
-
////////////////////////////////////////////////////sensor data end
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send 3 Data *******************************************************************************************************
-
//////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为字符串类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid1 对应数据流1的ID,Data1 对应数据流1的数值 //
- // sensorid2 对应数据流2的ID,Data2 对应数据流2的数值 //
- // sensorid3 对应数据流3的ID,Data3 对应数据流3的数值 //
-
//////////////////////////////////////////////////////////////////////////////////////////
- void send3DataWiFiC(String APIkey, char * Data1, char * Data2, char * Data3, unsigned long deviceid,String Host, String sensorid1, String sensorid2, String sensorid3)
- {
- int l1 = strlen(Data1);
- int l2 = strlen(Data2);
- int l3 = strlen(Data3);
- int D = getLength(deviceid);
- int S1 = sensorid1.length();
- int S2 = sensorid2.length();
- int S3 = sensorid3.length();
- int lenss = 53 + 36 + 36 + S1 + l1 + S2 + l2 + S3 + l3; //增加一个数据流Lens固定长度需要增加36,增加2个数据流需要增加2次36;
- int lll = getLength(lenss);
- int lens = 214 + 36 + 36 + D + lll + S1 + l1 + S2 + l2 + S3 + l3; //增加一个数据流Lens固定长度需要增加36,增加2个数据流需要增加2次36;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- delay(00);
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
////////////////////////////////////////////////////////////////////sensor data
-
WiFi_Port.print("{\"datastreams\":[");
-
///////////////////////////////////////////////////////////////////sensor1
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid1);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data1);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid2);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data2);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid3);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data3);
- WiFi_Port.print("}]}");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor end
- WiFi_Port.print("]}");
-
////////////////////////////////////////////////////sensor data end
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send 4 Data *******************************************************************************************************
-
//////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送四个数据流的数据点,数值为字符串类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid1 对应数据流1的ID,Data1 对应数据流1的数值 //
- // sensorid2 对应数据流2的ID,Data2 对应数据流2的数值 //
- // sensorid3 对应数据流3的ID,Data3 对应数据流3的数值 //
- // sensorid4 对应数据流4的ID,Data4 对应数据流4的数值 //
-
//////////////////////////////////////////////////////////////////////////////////////////
- void send4DataWiFiC(String APIkey, char * Data1, char * Data2, char * Data3, char * Data4, unsigned long deviceid,String Host, String sensorid1, String sensorid2, String sensorid3, String sensorid4)
- {
- int l1 = strlen(Data1);
- int l2 = strlen(Data2);
- int l3 = strlen(Data3);
- int l4 = strlen(Data4);
- int D = getLength(deviceid);
- int S1 = sensorid1.length();
- int S2 = sensorid2.length();
- int S3 = sensorid3.length();
- int S4 = sensorid4.length();
- int lenss = 53 + 36 + 36 + 36 + S1 + l1 + S2 + l2 + S3 + l3 + S4 + l4; //增加一个数据流Lens固定长度需要增加36,增加3个数据流需要增加3次36;
- int lll = getLength(lenss);
- int lens = 214 + 36 + 36 + 36 + D + lll + S1 + l1 + S2 + l2 + S3 + l3 + S4 + l4; //增加一个数据流Lens固定长度需要增加36,增加3个数据流需要增加3次36;
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- delay(00);
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
////////////////////////////////////////////////////////////////////sensor data
-
WiFi_Port.print("{\"datastreams\":[");
-
///////////////////////////////////////////////////////////////////sensor1
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid1);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data1);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor2
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid2);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data2);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor3
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid3);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data3);
- WiFi_Port.print("}]},");
- returnmsgWiFi();
-
///////////////////////////////////////////////////////////////////sensor4
-
WiFi_Port.print("{\"id\":\"");
-
WiFi_Port.print(sensorid4);
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":");
- WiFi_Port.print(Data4);
- WiFi_Port.print("}]}");
- returnmsgWiFi();
-
//////////////////////////////////////////////////////////////sensor end
- WiFi_Port.print("]}");
-
////////////////////////////////////////////////////sensor data end
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
//********************************************************** OneNet WiFi send GPS Data *******************************************************************************************************
-
////////////////////////////////////////////////////////////////////////////////////
- //本函数用于发送GPS数据流的数据点,数值为整数类型 //
- // APIkey OneNet对应设备的MasterKey或Apikey //
- // deviceid 对应设备的ID //
- // Host HTTP服务器名称 //
- // sensorid 对应GPS数据流的ID //
- // LON 对应经度的数值 //
- // LAT 对应纬度数值 //
- // HEIGH 对应海拔高度数值; //
-
////////////////////////////////////////////////////////////////////////////////////
- void sendGPSDataWiFi(char* HEIGH, unsigned long deviceid, String sensorid,String Host, char* LON, char* LAT, String APIkey )
- {
- int l = strlen(HEIGH);
- int D = getLength(deviceid);
- int S = sensorid.length();
- int Lonlen = strlen(LON);
- int Latlen = strlen(LAT);
- int lenss = 53 + 28 + S + l + Lonlen + Latlen;
- int l2 = getLength(lenss);
- int lens = 214 + 28 + D + S + l + Lonlen + Latlen + l2;
- WiFi_Port.println(lens);
-
WiFi_Port.println("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80");
- returnmsg_ok_conWiFi();
-
Debug_Port.println("connecting...");
-
WiFi_Port.print("AT+CIPSEND=");
- returnmsgWiFi();
- WiFi_Port.println(lens);
- returnmsg_ok_1WiFi();
- WiFi_Port.print("POST http://api.heclouds点com/devices/");
- returnmsgWiFi();
-
WiFi_Port.print(deviceid);
- returnmsgWiFi();
-
WiFi_Port.print("/datapoints HTTP/1.1");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("Host: ");
- returnmsgWiFi();
- WiFi_Port.print(Host);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("api-key: ");
- returnmsgWiFi();
- WiFi_Port.print(APIkey);
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.println("Connection: close");
- returnmsgWiFi();
-
WiFi_Port.print("Content-Length: ");
- returnmsgWiFi();
- WiFi_Port.print(lenss);
- returnmsgWiFi(); WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
-
WiFi_Port.print("{\"datastreams\":[{\"id\":\"");
- returnmsgWiFi();
-
WiFi_Port.print(sensorid);
- returnmsgWiFi();
-
WiFi_Port.print("\",\"datapoints\":[{\"value\":{\"lon\":\"");
- returnmsgWiFi();
- WiFi_Port.print(LON);
- returnmsgWiFi();
-
WiFi_Port.print("\",\"lat\":\"");
- returnmsgWiFi();
- WiFi_Port.print(LAT);
- returnmsgWiFi();
-
WiFi_Port.print("\",\"ele\":\"");
- returnmsgWiFi();
- WiFi_Port.print(HEIGH);
- returnmsgWiFi();
-
WiFi_Port.print("\"}}]}]}");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- returnmsgWiFi();
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
- WiFi_Port.print("\r\n");
-
returnmsg_ok_finishWiFi();
- }
-
///////////////////////////////////////////////////////////////////////////////
- //本函数用于判断串口发挥至是否有关键字“OK” //
- //如60秒内无正确返回,强制执行AT+CIPCLOSE,强行关闭TCP连接 //
-
///////////////////////////////////////////////////////////////////////////////
- void returnmsg_okWiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 60000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
- return ;
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
-
//Debug_Port.println(_TEMPdata);
- delay(2);
- }
- if (_TEMPdata.indexOf("OK") > 0)
- {
-
// Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break;
- }
- else
- {
- delay(1);
- }
- }
- return;
- }
-
///////////////////////////////////////////////////////////////////
- //本函数用于打印WiFi的串口返回信息,用于Debug,无实际作用 //
-
///////////////////////////////////////////////////////////////////
- void returnmsgWiFi()
- {
- String _TEMPdata = "";
- while (!WiFi_Port.available())
- {
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
- delay(1);
- }
-
Debug_Port.print(_TEMPdata);
- _TEMPdata = "";
- return;
- }
-
///////////////////////////////////////////////////////////////////////////////
- //本函数用于判断串口发挥至是否有关键字“OK”和“ready” //
- //如60秒内无正确返回,强制执行AT+CIPCLOSE,强行关闭TCP连接 //
-
///////////////////////////////////////////////////////////////////////////////
- void returnmsg_ok_readyWiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 60000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
-
- return ;
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
-
//DebugDebug_Port.println(_TEMPdata);
- delayMicroseconds(800);
- }
-
if ((_TEMPdata.indexOf("OK") > 0)&& (_TEMPdata.indexOf("ready") > 0))
- {
-
// Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break;
- }
- }
- return;
- }
-
///////////////////////////////////////////////////////////////////////////////
- //本函数用于判断是否正确的完成了TCP连接; //
- //判断标志为返回了“OK”以及"CONNECT" //
- //如超过20秒还没收到以上两个关键字,则主动执行一次关闭连接操作并退出 //
-
///////////////////////////////////////////////////////////////////////////////
- void returnmsg_ok_conWiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 20000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
- returnmsgWiFi();
- return ;
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
- delay(1);
- }
-
if ((_TEMPdata.indexOf("OK") > 3)&& (_TEMPdata.indexOf("CONNECT") > 0))
- {
-
Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break;
- }
- }
- return;
- }
-
////////////////////////////////////////////////////////////////////////////////////
- //本函数用于判断服务器收到相应的命令后是否正确的执行并返回了相应的信息。 //
- //判断标志为返回了“OK”以及"CLOSED" //
- //如超过20秒还没收到以上两个关键字,则主动执行一次关闭连接操作并退出。 //
-
////////////////////////////////////////////////////////////////////////////////////
- void returnmsg_ok_finishWiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 20000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
- returnmsgWiFi();
- return ;
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
-
// Debug_Port.println(_TEMPdata);
- delayMicroseconds(700);
- }
-
if ((_TEMPdata.indexOf("CLOSED") > 3)&& (_TEMPdata.indexOf("OK") > 0))
- {
-
Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break;
- }
- else
- {
- ;
- }
- }
- return;
- }
-
/////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于判断CIPSEND后是否返回了“OK”或“close” //
- //收到任何一个都退出。 //
-
/////////////////////////////////////////////////////////////////////////////////////////
- void returnmsg_ok_errWiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- while ( WiFi_Port.available())
- {
- _TEMPdata += char( WiFi_Port.read());
-
//Debug_Port.println(_TEMPdata);
- delay(2);
- }
-
if ((_TEMPdata.indexOf("OK") > 1) || (_TEMPdata.indexOf("ERROR") > 1))
- {
-
Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break ;
- }
- }
- return ;
- }
-
/////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于判断CIPSEND后是否返回了“OK”和“close” //
- //如超过20秒没有还没收到以上两个关键字,则主动执行一次关闭连接操作并退出。 //
-
/////////////////////////////////////////////////////////////////////////////////////////
- void returnmsg_ok_closeWiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 20000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
-
- return ;
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
-
// DebugDebug_Port.println(_TEMPdata);
- delayMicroseconds(700);
- }
-
if ((_TEMPdata.indexOf("close") > 3)&& (_TEMPdata.indexOf("OK") > 0))
- {
-
Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break;
- }
- else
- {
- ;
- }
- }
- return;
- }
-
/////////////////////////////////////////////////////////////////////////////////////////
- //本函数用于判断CIPSEND后是否返回了“>” //
- //如超过20秒没有还没收到以上关键字,则主动执行一次关闭连接操作并退出。 //
-
/////////////////////////////////////////////////////////////////////////////////////////
- void returnmsg_ok_1WiFi()
- {
- String _TEMPdata = "";
- unsigned long _PT0 = 0;
- unsigned long _PT1 = 0;
- _PT0 = millis();
- _TEMPdata = "";
- while (1)
- {
- _PT1 = millis();
- if (_PT1 - _PT0 > 20000)
- {
- Debug_Port.println(" ");
-
Debug_Port.println("Get error..................");
-
WiFi_Port.println("AT+CIPCLOSE");
-
- return ;
- }
- while (WiFi_Port.available())
- {
- _TEMPdata += char(WiFi_Port.read());
-
// DebugDebug_Port.println(_TEMPdata);
- delay(2);
- }
- if (_TEMPdata.indexOf(">") > 0)
- {
-
Debug_Port.println(_TEMPdata);
- Debug_Port.println("");
- _TEMPdata = "";
- break;
- }
- else
- {
- delay(1);
- }
- }
- return;
- }
-
///////////////////////////////////////////////////////////////////
- //本函数用于计算一个长整型数值的长度 //
- //返回值为int类型数值 //
-
///////////////////////////////////////////////////////////////////
- int getLength(unsigned long someValue)
- {
- int digits = 1;
- int dividend = someValue / 10;
- while (dividend > 0) {
- dividend = dividend / 10;
- digits++;
- }
- return digits;
- }
-
5.66 KB, 下载次数: 8, 下载积分: 黑币 -5