Bigiot.net
BIGIOT.net
Home
Home
Public dev
Mobile
Document
Talk
Login
Register
请问一下多数据上传的代码怎么修改,我想上传6种数据
作者:
a386554965
| 更新时间:2018-06-11 | 浏览量:1411
首页
讨论
Arduino
这是一个不错的想法...
评论:共1条
Blue moon
评论于:2018-08-08 15:37:43
/*
这个是两种数据的,以DHT11温度和湿度为例
注意 :Arduino IDE版本请使用1.6.5-1.8.2
*/
#include <aJSON.h>
#include <Wire.h>
int temp;//温度
int humi;//湿度
int j;
unsigned int loopCnt;
int chr[40] = {0};//创建数字数组,用来存放40个bit
unsigned long time;
#define pin 3
//============= 此处必须修改============
String DEVICEID = "XXXX"; // 你的设备ID=======
String APIKEY = "XXXXXf"; // 设备密码==
String INPUTID1 = "XXXX"; //接口ID==============
String INPUTID2 = "XXXX"; //接口ID==============
//=======================================
unsigned long lastCheckInTime = 0; //记录上次报到时间
unsigned long lastUpdateTime = 0;//记录上次上传数据时间
const unsigned long postingInterval = 40000; // 每隔40秒向服务器报到一次
const unsigned long updateInterval = 5000; // 数据上传间隔时间5秒
String inputString = "";//串口读取到的内容
boolean stringComplete = false;//串口是否读取完毕
boolean CONNECT = true; //连接状态
boolean isCheckIn = false; //是否已经登录服务器
char* parseJson(char *jsonString);//定义aJson字符串
void setup() {
Serial.begin(115200);
delay(10000);
}
void loop() {
//温湿度部分
bgn:
delay(2000);
//设置3号接口模式为:输出
//输出低电平20ms(>18ms)
//输出高电平40μs
pinMode(pin, OUTPUT);
digitalWrite(pin, LOW);
delay(20);
digitalWrite(pin, HIGH);
delayMicroseconds(40);
digitalWrite(pin, LOW);
//设置2号接口模式:输入
pinMode(pin, INPUT);
//高电平响应信号
loopCnt = 10000;
while (digitalRead(pin) != HIGH)
{
if (loopCnt-- == 0)
{
//如果长时间不返回高电平,输出个提示,重头开始。
Serial.println("HIGH");
goto bgn;
}
}
//低电平响应信号
loopCnt = 30000;
while (digitalRead(pin) != LOW)
{
if (loopCnt-- == 0)
{
//如果长时间不返回低电平,输出个提示,重头开始。
Serial.println("LOW");
goto bgn;
}
}
//开始读取bit1-40的数值
for (int i = 0; i < 40; i++)
{
while (digitalRead(pin) == LOW)
{}
//当出现高电平时,记下时间“time”
time = micros();
while (digitalRead(pin) == HIGH)
{}
//当出现低电平,记下时间,再减去刚才储存的time
//得出的值若大于50μs,则为‘1’,否则为‘0’
//并储存到数组里去
if (micros() - time > 50)
{
chr[i] = 1;
} else {
chr[i] = 0;
}
}
//湿度,8位的bit,转换为数值
humi = chr[0] * 128 + chr[1] * 64 + chr[2] * 32 + chr[3] * 16 + chr[4] * 8 + chr[5] * 4 + chr[6] * 2 + chr[7];
//温度,8位的bit,转换为数值
temp = chr[16] * 128 + chr[17] * 64 + chr[18] * 32 + chr[19] * 16 + chr[20] * 8 + chr[21] * 4 + chr[22] * 2 + chr[23];
//贝壳物联源码里的部分,给的源码是一种数据的,往看注释改哪里
if (millis() - lastCheckInTime > postingInterval || lastCheckInTime == 0) {
checkIn();
}
if (millis() - lastUpdateTime > updateInterval) {
//注意这里调用了update2,注意括号里的内容,去找update2函数,如果想传更多的数据跟update2函数有关,末尾配写法
update2(DEVICEID, INPUTID1, temp, INPUTID2, humi);
}
serialEvent();
if (stringComplete) {
inputString.trim();
//Serial.println(inputString);
if (inputString == "CLOSED") {
Serial.println("connect closed!");
CONNECT = false;
isCheckIn = false;
} else {
int len = inputString.length() + 1;
if (inputString.startsWith("{") && inputString.endsWith("}")) {
char jsonString[len];
inputString.toCharArray(jsonString, len);
aJsonObject *msg = aJson.parse(jsonString);
processMessage(msg);//处理接收到的Json数据
aJson.deleteItem(msg);
}
}
inputString = "";
stringComplete = false;
}
}
void checkIn() {
if (!CONNECT) {
Serial.print("+++");
delay(500);
Serial.print("\r\n");
delay(1000);
Serial.print("AT+RST\r\n");
delay(6000);
CONNECT = true;
lastCheckInTime == 0;
}
else {
Serial.print("{\"M\":\"checkin\",\"ID\":\"");
Serial.print(DEVICEID);
Serial.print("\",\"K\":\"");
Serial.print(APIKEY);
Serial.print("\"}\r\n");
lastCheckInTime = millis();
}
}
void processMessage(aJsonObject *msg) {
aJsonObject* method = aJson.getObjectItem(msg, "M");
aJsonObject* content = aJson.getObjectItem(msg, "C");
aJsonObject* client_id = aJson.getObjectItem(msg, "ID");
//char* st = aJson.print(msg);
if (!method) {
return;
}
//Serial.println(st);
//free(st);
String M = method->valuestring;
if (M == "checkinok") {
isCheckIn = true;
}
}
void serialEvent() {
while (Serial.available()) {
char inChar = (char)Serial.read();
inputString += inChar;
if (inChar == '\n') {
stringComplete = true;
}
}
}
//void update1(String did, String inputid, float value) {
// Serial.print("{\"M\":\"update\",\"ID\":\"");
// Serial.print(did);
// Serial.print("\",\"V\":{\"");
// Serial.print(inputid);
// Serial.print("\":\"");
// Serial.print(value);
// Serial.println("\"}}");
// lastCheckInTime = millis();
// lastUpdateTime = millis();
//}
//同时上传两个接口数据调用此函数
void update2(String did, String inputid1, float value1, String inputid2, float value2){
Serial.print("{\"M\":\"update\",\"ID\":\"");
Serial.print(did);
Serial.print("\",\"V\":{\"");
Serial.print(inputid1);
Serial.print("\":\"");
Serial.print(value1);
Serial.print("\",\"");
Serial.print(inputid2);
Serial.print("\":\"");
Serial.print(value2);
Serial.println("\"}}");
lastCheckInTime = millis();
lastUpdateTime= millis();
}
这个参考了贝壳物联讨论一位朋友的答案,感谢这位朋友
关于数据上传这里给大家分享一个函数格式供大家参考
void update1(int did, int inputid1, int inputid2,int inputid3,float value1 ,float value2,float value3) // 定义一次传递3个参数的函数
{
String str1="{\"M\":\"update\",\"ID\":\"";
str1+=did;
str1+="\",\"V\":{\"";
str1+=inputid1;
str1+="\":\"";
str1+=value1;
str1+="\",\"" ;
str1+=inputid2;
str1+="\":\"";
str1+=value2;
str1+="\",\"" ;
str1+=inputid3;
str1+="\":\"";
str1+=value3;
str1+="\"" ;
str1+="}}\n";
client.print(str1);
//下面是串口打印 传递到服务器的信息,以便调试
Serial.print("update:");
Serial.print(inputid1);
Serial.print("->");
Serial.println(value1);
Serial.print("update:");
Serial.print(inputid2);
Serial.print("->");
Serial.println(value2);
Serial.print("update:");
Serial.print(inputid3);
Serial.print("->");
Serial.println(value3);
}
返回顶部