当前位置： 首页 > news >正文

【智能家居入门1之环境信息监测】（STM32、ONENET云平台、微信小程序、HTTP协议）

news 来源：原创 2024/5/14 15:19:47

作为入门本篇只实现微信小程序接收下位机上传的数据，之后会持续发布如下项目：①可以实现微信小程序控制下位机动作，真正意义上的智能家居；②将网络通讯协议换成MQTT协议再实现上述功能，此时的服务器也不再是ONENET，可以是公用的MQTT服务器也可以自己搭建或者租

    • 最终效果
    • 一、下位机模块测试与分析
      • 1、MQ系列传感器
      • 2、DHT11温湿度传感器
      • 3、Esp8266-01s
      • 4、oled液晶屏
    • 二、微信小程序
    • 三、项目获取

这个项目参考的是b站up主：彼岸有光我们有船

最终效果

实物图：
主控是STM32F103C8T6，这里arduino开发板我只是拿来给几个模块供电的，有面包板的话也可以用面包板，用到的模块有：MQ-4天然气传感器、MQ-9可燃气体传感器、0.96寸oled液晶屏、DHT11温湿度传感器、Esp8266-01s、J-Link下载器。
在这里插入图片描述
ONENET云平台：
在这里插入图片描述
微信小程序：
在这里插入图片描述

一、下位机模块测试与分析

1、MQ系列传感器

MQ气体传感器使用的气敏材料是在清洁空气中电导率较低的二氧化锡。当传感器所处环境中存在可燃气体时，传感器的电导率随空气中可燃气体浓度的增加而增大。使用简单的电路即可将电导率的变化转换为与该气体浓度相对应的输出信号。MQ气体传感器对甲烷的灵敏度高,对丙烷、丁烷也有较好的灵敏度。这种传感器可检测多种可燃性气体，特别是天然气。
在这里插入图片描述
关于这个传感器的详细资料可以下载阅读：我用夸克网盘分享了「MQ-2-135-3-7-9烟雾空气敏酒精氢一氧化碳可燃液化传感器模块探头.rar」，点击链接即可保存。打开「夸克APP」，无需下载在线播放视频，畅享原画5倍速，支持电视投屏。
链接：https://pan.quark.cn/s/22c08247dd8a
提取码：xLRC

在这个项目中只需要接三个引脚：VCC、GND、AO。AO输出接开发板的IO口，通过ADC将传感器的模拟输出转换成数字量。这里用到了开发板上ADC1的通道2、3，对应GPIOA-2、GPIOA-3。 关于 ADC的使用可以直接看视频：
https://www.bilibili.com/video/BV1th411z7sn/?p=21&spm_id_from=pageDriver&vd_source=2a10d30b8351190ea06d85c5d0bfcb2a
下面是多通道ADC源码，如果想再加的话只需要在初始化gpio的时候加上需要的io口即可，但是需要对应io口与adc通道的对应关系：
在这里插入图片描述

#include "stm32f10x.h"                  // Device headervoid AD_Init(void)
{GPIO_InitTypeDef GPIO_InitStructure;ADC_InitTypeDef ADC_InitStructure;						//定义结构体变量/*开启时钟*/RCC_APB2PeriphClockCmd(RCC_APB2Periph_ADC1, ENABLE);	//开启ADC1的时钟RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA, ENABLE);	//开启GPIOA的时钟/*设置ADC时钟*/RCC_ADCCLKConfig(RCC_PCLK2_Div6);						//选择时钟6分频，ADCCLK = 72MHz / 6 = 12MHz/*GPIO初始化*/GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AIN;GPIO_InitStructure.GPIO_Pin = GPIO_Pin_2 | GPIO_Pin_3;GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;GPIO_Init(GPIOA, &GPIO_InitStructure);					//将PA0、PA1、PA2和PA3引脚初始化为模拟输入/*不在此处配置规则组序列，而是在每次AD转换前配置，这样可以灵活更改AD转换的通道*//*ADC初始化*/ADC_InitStructure.ADC_Mode = ADC_Mode_Independent;		//模式，选择独立模式，即单独使用ADC1ADC_InitStructure.ADC_DataAlign = ADC_DataAlign_Right;	//数据对齐，选择右对齐ADC_InitStructure.ADC_ExternalTrigConv = ADC_ExternalTrigConv_None;	//外部触发，使用软件触发，不需要外部触发ADC_InitStructure.ADC_ContinuousConvMode = DISABLE;		//连续转换，失能，每转换一次规则组序列后停止ADC_InitStructure.ADC_ScanConvMode = DISABLE;			//扫描模式，失能，只转换规则组的序列1这一个位置ADC_InitStructure.ADC_NbrOfChannel = 1;					//通道数，为1，仅在扫描模式下，才需要指定大于1的数，在非扫描模式下，只能是1ADC_Init(ADC1, &ADC_InitStructure);						//将结构体变量交给ADC_Init，配置ADC1/*ADC使能*/ADC_Cmd(ADC1, ENABLE);									//使能ADC1，ADC开始运行/*ADC校准*/ADC_ResetCalibration(ADC1);								//固定流程，内部有电路会自动执行校准while (ADC_GetResetCalibrationStatus(ADC1) == SET);ADC_StartCalibration(ADC1);while (ADC_GetCalibrationStatus(ADC1) == SET);
}/*** 函    数：获取AD转换的值* 参    数：ADC_Channel 指定AD转换的通道，范围：ADC_Channel_x，其中x可以是0/1/2/3* 返 回 值：AD转换的值，范围：0~4095*/
uint16_t AD_GetValue(uint8_t ADC_Channel)
{ADC_RegularChannelConfig(ADC1, ADC_Channel, 1, ADC_SampleTime_55Cycles5);	//在每次转换前，根据函数形参灵活更改规则组的通道1ADC_SoftwareStartConvCmd(ADC1, ENABLE);					//软件触发AD转换一次while (ADC_GetFlagStatus(ADC1, ADC_FLAG_EOC) == RESET);	//等待EOC标志位，即等待AD转换结束return ADC_GetConversionValue(ADC1);					//读数据寄存器，得到AD转换的结果
}

2、DHT11温湿度传感器

1、DHT11 采用单总线协议与单片机通信，概括起来是两个大过程：配对和数据传输，下面对两个过程进行分析：
①配对过程
（1）Data引脚在默认状态时处于高电平；
（2）在开始通信时，MCU将Data引脚拉低并保持18ms，然后再将Data引脚拉高20-40us；
（3）当DHT11收到命令后，它会主动拉低Data引脚，持续80us；
（4）DHT11再次拉高DATA引脚，80us后开始发送数据给MCU。
在这里插入图片描述
②数据传输
（1）在每次发送数据之前，DHT11会把Data引脚先拉低50us，这表示单片机要继续发送下一位数据；
（2）DHT11拉高Data引脚，如果拉高持续时间是26-28us，表示发送0；如果拉高的持续时间是116-118us，表示发送1。

在这里插入图片描述
2、驱动代码：
①c文件：

#include "dht11.h"
#include "delay.h"//复位DHT11
void DHT11_Rst(void)	   
{                 DHT11_IO_OUT(); 	//SET OUTPUTDHT11_DQ_OUT=0; 	//拉低DQdelay_ms(20);    	//拉低至少18msDHT11_DQ_OUT=1; 	//DQ=1 delay_us(30);     	//主机拉高20~40us
}
//等待DHT11的回应
//返回1:未检测到DHT11的存在
//返回0:存在
u8 DHT11_Check(void) 	   
{   u8 retry=0;DHT11_IO_IN();//SET INPUT	 while (DHT11_DQ_IN&&retry<100)//DHT11会拉低40~80us{retry++;delay_us(1);};	 if(retry>=100)return 1;else retry=0;while (!DHT11_DQ_IN&&retry<100)//DHT11拉低后会再次拉高40~80us{retry++;delay_us(1);};if(retry>=100)return 1;	    return 0;
}
//从DHT11读取一个位
//返回值：1/0
u8 DHT11_Read_Bit(void) 			 
{u8 retry=0;while(DHT11_DQ_IN&&retry<100)//等待变为低电平{retry++;delay_us(1);}retry=0;while(!DHT11_DQ_IN&&retry<100)//等待变高电平{retry++;delay_us(1);}delay_us(40);//等待40usif(DHT11_DQ_IN)return 1;else return 0;		   
}
//从DHT11读取一个字节
//返回值：读到的数据
u8 DHT11_Read_Byte(void)    
{        u8 i,dat;dat=0;for (i=0;i<8;i++) {dat<<=1; dat|=DHT11_Read_Bit();}						    return dat;
}
//从DHT11读取一次数据
//temp:温度值(范围:0~50°)
//humi:湿度值(范围:20%~90%)
//返回值：0,正常;1,读取失败
u8 DHT11_Read_Data(u8 *temp,u8 *humi)    
{        u8 buf[5];u8 i;DHT11_Rst();if(DHT11_Check()==0){for(i=0;i<5;i++)//读取40位数据{buf[i]=DHT11_Read_Byte();}if((buf[0]+buf[1]+buf[2]+buf[3])==buf[4]){*humi=buf[0];*temp=buf[2];}}else return 1;return 0;	    
}
//初始化DHT11的IO口 DQ 同时检测DHT11的存在
//返回1:不存在
//返回0:存在    	 
u8 DHT11_Init(void)
{	 GPIO_InitTypeDef  GPIO_InitStructure;RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA, ENABLE);	 //使能PA端口时钟GPIO_InitStructure.GPIO_Pin = GPIO_Pin_8;				 //PA0端口配置GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; 		 //推挽输出GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;GPIO_Init(GPIOA, &GPIO_InitStructure);				 //初始化IO口GPIO_SetBits(GPIOA,GPIO_Pin_8);						 //PA0 输出高DHT11_Rst();  //复位DHT11return DHT11_Check();//等待DHT11的回应
}

②头文件：

#ifndef __DHT11_H
#define __DHT11_H 
#include "sys.h"   //IO方向设置
#define DHT11_IO_IN()  {GPIOA->CRH&=0XFFFFFFF0;GPIOA->CRH|=8;}
#define DHT11_IO_OUT() {GPIOA->CRH&=0XFFFFFFF0;GPIOA->CRH|=3;}
IO操作函数											   
#define	DHT11_DQ_OUT PAout(8) //数据端口	PA0出方向 
#define	DHT11_DQ_IN  PAin(8)  //数据端口	PA0入方向u8 DHT11_Init(void);//初始化DHT11
u8 DHT11_Read_Data(u8 *temp,u8 *humi);//读取温湿度
u8 DHT11_Read_Byte(void);//读出一个字节
u8 DHT11_Read_Bit(void);//读出一个位
u8 DHT11_Check(void);//检测是否存在DHT11
void DHT11_Rst(void);//复位DHT11    
#endif

主函数中直接调用DHT11_Read_Data，定义两个变量接收即可。

3、Esp8266-01s

在使用单片机连接此模块前最好先进行测试，测试可以参考之前的一篇博客（这篇博客还有如何在ONENET云平台创建产品和设备）：https://blog.csdn.net/m0_71523511/article/details/135887108
驱动代码：

#include "esp8266.h"char *str[4] = {"POST /devices/1038xxxxxxxx/datapoints HTTP/1.1","api-key:wfsF4bCGtQIQmW=xxxxxxxx","Host:api.heclouds.com",""};
char strValue[8] = {0};// 向onenet发送数据
u8 *esp8266_str_data(char *key, char *value)
{u8 i;u8 *back;char temp[512];char temp3[64];		// 长度char temp5[128];		// 发送值// 拼接post报文strcpy(temp5, "{\"datastreams\":[{\"id\":\"");strcat(temp5, key);strcat(temp5, "\",\"datapoints\":[{\"value\":");strcat(temp5, value);strcat(temp5, "}]}]}");strcpy(temp3, "Content-Length:");sprintf(temp, "%d", strlen(temp5) + 1);strcat(temp3, temp);strcpy(temp, "");for (i = 0; i < 3; i++){strcat(temp, str[i]);strcat(temp, "\r\n");}strcat(temp, temp3);strcat(temp, "\r\n\r\n");strcat(temp, temp5);strcat(temp, "\r\n");back = esp8266_send_data((u8 *)temp, 50);// printf("server:%s\r\n", back);if (strstr((char *)back, "ERROR"))		//发送失败, 重新初始化,发送{esp8266_send_cmd("AT+RST", "OK", 50);esp8266_send_cmd("AT+CIPCLOSE", "OK", 50);esp8266_send_cmd("AT+CWMODE=1", "OK", 50);esp8266_send_cmd("AT+CWDHCP=1", "OK", 50);//esp8266_send_cmd("AT+CIPMUX=0", "OK", 50);while (esp8266_send_cmd("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80", "CONNECT", 100));//esp8266_send_cmd("AT+CIPMODE=1", "OK", 50);//esp8266_send_cmd("AT+CIPSEND", "OK", 20);return esp8266_send_data((u8 *)temp, 50);}return back;
}// 向esp8266请求数据
u16 esp8266_get_data(char *vStr)
{u8 i;u16 value = 0;char *back;char temp[160] = "GET /devices/1038269453/datastreams/";// 拼接请求报文strcat(temp, vStr);strcat(temp, " HTTP/1.1\r\n");for (i = 1; i < 4; i++){strcat(temp, str[i]);strcat(temp, "\r\n");}// 发送报文, 获取返回字符串back = (char *)esp8266_send_data((u8 *)temp, 50);// 在回送报文中截取出数值back = strchr(strstr(back, "\"current_value\":"), ':') + 1;while (*back != '}'){if(*back == '\"'){back++;continue;}value = value * 10 + (*back - '0');back++;}return value;
}//ESP8266模块和PC进入透传模式
void esp8266_start_trans(void)
{//让Wifi模块重启的命令esp8266_send_cmd("AT+RST", "OK", 50);esp8266_send_cmd("AT+CIPCLOSE", "OK", 50);esp8266_send_cmd("AT+CWMODE=1", "OK", 50);esp8266_send_cmd("AT+CWDHCP=1", "OK", 50);delay_ms(1000); //延时2S等待重启成功delay_ms(1000);//让模块连接上自己的路由WIFI GOT IPwhile (esp8266_send_cmd("AT+CWJAP=\"WZQ\",\"1234567890\"", "WIFI GOT IP", 500)){delay_ms(1);};//建立TCP连接  这四项分别代表了 要连接的ID号0~4   连接类型  远程服务器IP地址   远程服务器端口号while (esp8266_send_cmd("AT+CIPSTART=\"TCP\",\"183.230.40.33\",80", "CONNECT", 200)){delay_ms(1);};
}//ESP8266退出透传模式   返回值:0,退出成功;1,退出失败
//配置wifi模块，通过想wifi模块连续发送3个+（每个+号之间 超过10ms,这样认为是连续三次发送+）
u8 esp8266_quit_trans(void)
{u8 result = 1;u3_printf("+++");delay_ms(1000);							   //等待500ms太少 要1000ms才可以退出result = esp8266_send_cmd("AT", "OK", 20); //退出透传判断.if (result)printf("quit_trans failed!");elseprintf("quit_trans success!");return result;
}//向ESP8266发送命令
//cmd:发送的命令字符串;ack:期待的应答结果,如果为空,则表示不需要等待应答;waittime:等待时间(单位:10ms)
//返回值:0,发送成功(得到了期待的应答结果);1,发送失败
u8 esp8266_send_cmd(u8 *cmd, u8 *ack, u16 waittime)
{u8 res = 0;USART3_RX_STA = 0;u3_printf("%s\r\n", cmd); //发送命令delay_ms(1);if (ack && waittime)	  //需要等待应答{while (--waittime) //等待倒计时{delay_ms(10);if (USART3_RX_STA&0X8000) //接收到期待的应答结果{if (esp8266_check_cmd(ack)){printf("%s\r\n", (u8 *)USART3_RX_BUF);break; //得到有效数据}USART3_RX_STA = 0;//strcpy((char *)USART3_RX_BUF, "");		// 清空接收缓存区}}if (waittime == 0) res = 1;}return res;
}//ESP8266发送命令后,检测接收到的应答
//str:期待的应答结果
//返回值:0,没有得到期待的应答结果;其他,期待应答结果的位置(str的位置)
u8 *esp8266_check_cmd(u8 *str)
{char *strx = 0;if (USART3_RX_STA & 0X8000) //接收到一次数据了{USART3_RX_BUF[USART3_RX_STA & 0X7FFF] = 0; //添加结束符strx = strstr((const char *)USART3_RX_BUF, (const char *)str);}return (u8 *)strx;
}//向ESP8266发送数据
//cmd:发送的命令字符串;waittime:等待时间(单位:10ms)
//返回值:发送数据后，服务器的返回验证码
u8 *esp8266_send_data(u8 *cmd, u16 waittime)
{char temp[1024];char *ack = temp;USART3_RX_STA = 0;u3_printf("%s", cmd); //发送命令delay_ms(1);if (waittime)		  //需要等待应答{while (--waittime) //等待倒计时{delay_ms(10);if (USART3_RX_STA & 0X8000) //接收到期待的应答结果{USART3_RX_BUF[USART3_RX_STA & 0X7FFF] = 0; //添加结束符ack = (char *)USART3_RX_BUF;USART3_RX_STA = 0;break; //得到有效数据}}}return (u8 *)ack;
}// 将数字转为字符串
void numToString(u16 value)
{int k = 0, j = 0;int num = (int)value;char tem[10];if (value == 0){strValue[0] = '0';strValue[1] = '\0';return;}while (num){tem[k++] = num % 10 + '0'; //将数字加字符0就变成相应字符num /= 10;				   //此时的字符串为逆序}tem[k] = '\0';k = k - 1;while (k >= 0){strValue[j++] = tem[k--]; //将逆序的字符串转为正序}strValue[j] = '\0'; //字符串结束标志
}

需要注意的是这段代码有两个地方需要修改：
在这里插入图片描述
分别换成自己云平台的设备ID和master-keyapi。

4、oled液晶屏

这是调试程序的好帮手，用的好可以很快找出程序是哪里出问题了。这个驱动代码网上都有很多封装好的，这里就不贴出来了。本项目用的是四引脚oled，使用IIC通信协议，IIC协议的原理可以看此视频：https://www.bilibili.com/video/BV1th411z7sn/?p=31&spm_id_from=pageDriver&vd_source=2a10d30b8351190ea06d85c5d0bfcb2a
想连接oled的详细代码可以看此视频：
https://www.bilibili.com/video/BV1EN41177Pc/?spm_id_from=333.337.search-card.all.click&vd_source=2a10d30b8351190ea06d85c5d0bfcb2a

二、微信小程序

微信小程序最关键的地方就是与云平台的数据交互，其他比如界面、功能都是在这个的基础上才有用。对微信小程序开发感兴趣的可以学一下javascript，比较简单。
下载文章末尾的开源项目压缩包，解压之后可以看到里面有一个文件夹叫：基于STM32的环境信息采集_微信小程序，打开微信开发者工具，选择导入，选择此小程序文件夹打开即可。
在这里插入图片描述
在这里插入图片描述
进入工程之后修改设备ID和master-keyapi：
在这里插入图片描述
index.js代码：

Page({data: {temp:0},// 事件处理函数getinfo(){var that = thiswx.request({url: "https://api.heclouds.com/devices/1038269453/datapoints",   //将请求行中的数字换成自己的设备IDheader: {"api-key": "wfsF4bCGtQIQmW=3wTsPnrdjuFA=" //自己的api-key},method: "GET",success: function (e) {console.log("获取成功",e)that.setData({temp:e.data.data.datastreams[2].datapoints[0].value,humi:e.data.data.datastreams[7].datapoints[0].value,gas_ch4:e.data.data.datastreams[0].datapoints[0].value,ranqi:e.data.data.datastreams[4].datapoints[0].value})console.log("temp==",that.data.temp),console.log("humi==",that.data.humi),console.log("gas==",that.data.gas_ch4),console.log("ranqi==",that.data.ranqi)}});},onLoad() {var that = thissetInterval(function(){that.getinfo()},5000)}})

三、项目获取

我用夸克网盘分享了「基于STM32的环境信息采集（ONENET+HTTP）.rar」，点击链接即可保存。打开「夸克APP」，无需下载在线播放视频，畅享原画5倍速，支持电视投屏。
链接：https://pan.quark.cn/s/23b7bdc7b54b
提取码：pR55

相关文章：

  • 141 Linux 系统编程18，线程，ps –Lf 进程 查看LWP，线程间共享数据，优缺点，编译加-lpthread，
  • docker学习入门篇
  • 【java数据结构】HashMap和HashSet
  • 详解开关电源
  • 理论学习：nn.CrossEntropyLoss
  • linux中git暂存，提交，上传到github
  • 深入学习默认成员函数——c++指南
  • 学习数据节构和算法的第15天
  • 什么是jwt
  • 【Spring Boot 3】动态注入和移除Bean
  • git - 笔记
  • 在 Python 中从键盘读取用户输入
  • Promise图解，Pass
  • 【Web】浅聊Java反序列化之C3P0——JNDI注入利用
  • 【Qt】四种绘图设备详细使用
  • C++类的相互关联
  • ES6--对象的扩展
  • ES6核心特性
  • ES6简单总结（搭配简单的讲解和小案例）
  • ESLint简单操作
  • EventListener原理
  • Java小白进阶笔记(3)-初级面向对象
  • Mac 鼠须管 Rime 输入法 安装五笔输入法 教程
  • miaov-React 最佳入门
  • Redash本地开发环境搭建
  • Spring Boot MyBatis配置多种数据库
  • Tornado学习笔记（1）
  • webpack+react项目初体验——记录我的webpack环境配置
  • 翻译--Thinking in React
  • 给自己的博客网站加上酷炫的初音未来音乐游戏？
  • 开源地图数据可视化库——mapnik
  • 前端之Sass/Scss实战笔记
  • 数组的操作
  • 新手搭建网站的主要流程
  • 一个6年java程序员的工作感悟，写给还在迷茫的你
  • Java数据解析之JSON
  • # 手柄编程_北通阿修罗3动手评：一款兼具功能、操控性的电竞手柄
  • ###C语言程序设计-----C语言学习（6）#
  • #include
  • #我与Java虚拟机的故事#连载11： JVM学习之路
  • （1）(1.8) MSP(MultiWii 串行协议)(4.1 版)
  • （DenseNet）Densely Connected Convolutional Networks--Gao Huang
  • (二十五)admin-boot项目之集成消息队列Rabbitmq
  • （附源码）基于ssm的模具配件账单管理系统 毕业设计 081848
  • (附源码)计算机毕业设计SSM疫情社区管理系统
  • （附源码）小程序儿童艺术培训机构教育管理小程序 毕业设计 201740
  • （黑马C++）L06 重载与继承
  • （三）Hyperledger Fabric 1.1安装部署-chaincode测试
  • （五）大数据实战——使用模板虚拟机实现hadoop集群虚拟机克隆及网络相关配置
  • (原創) 物件導向與老子思想 (OO)
  • （转）jdk与jre的区别
  • .locked1、locked勒索病毒解密方法|勒索病毒解决|勒索病毒恢复|数据库修复
  • .net core 客户端缓存、服务器端响应缓存、服务器内存缓存
  • .NET Core使用NPOI导出复杂，美观的Excel详解
  • .NET 设计模式初探