RT-Thread-[第3期空气质量分析仪]第二周作业RT-Thread问答社区

[第3期空气质量分析仪]第二周作业

发布于 2019-10-25 20:23:39 浏览：1066 订阅该版

经过上周的学习完成，对RTT有了初步的了解。对于这周的作业，分析下需要做的事情：
温湿度应用，即编写应用模块；PM2.5使用分为驱动编写，应用模块编写；甲醛和PM2.5是一样的。
这样分析主要要做两件事情：应用模块和驱动编写。
应用模块 
创建线程，将在线程中独立完成模块的使用。
任务一
按照《第二周》中的提示创建文件、函数，参考文档中心线程管理，可以很快的编写好void temp_humi_entry()、void temp_humi_init(void)函数。只需要在main函数中初始化temp_humi_init即可。具体代码如下：
```#define TEMP_HUMI_THREAD_STACK_SIZE	1000	
#define TEMP_HUMI_PRIORITY			4

static rt_thread_t temp_huim_thread = RT_NULL;

//线程入口
void temp_humi_entry(void * paramter)
{
	rt_thread_mdelay(1000);
	while(1)
	{
		dht11_read_temp();
		dht11_read_humi();
		rt_thread_mdelay(500);
	}
	
}

//创建温湿度传感器线程
void temp_humi_init(void)
{
	dht11_hw_init();
	//创建动态线程
	temp_huim_thread = rt_thread_create("temp_humi",temp_humi_entry,RT_NULL,
										RT_MAIN_THREAD_STACK_SIZE,RT_MAIN_THREAD_PRIORITY,40);
	if(temp_huim_thread != RT_NULL)
	{
		//启动线程
		rt_thread_startup(temp_huim_thread);
	}
}```

任务二、PM2.5
我使用的传感器是以为朋友提供的，其型号为PM2008MS。这个传感器的原理和推荐的传感器是一样的，只是自带MCU。因此，AD采集和数据处理都已经在传感器内部执行，需要做的是去读取数据便可能到准确的颗粒物质量浓度。
驱动编写：
这个传感器使用的通信方式是串口通信，波特率：9600 校验位：无 停止位：一位
协议总长度：32字节
设置DMA接收模式
```struct serial_configure config = RT_SERIAL_CONFIG_DEFAULT;  /* 初始化配置参数 */
//static struct rt_semaphore rx_sem;    /* 用于接收消息的信号量 */
rt_size_t res_pm25;
rt_uint8_t Buffer[32] = {0};

/* 串口接收消息结构*/
struct rx_msg
{
    rt_device_t dev;
    rt_size_t size;
};
static struct rt_messagequeue rx_mq;
static rt_device_t serial;                /* 串口设备句柄 */

/* 接收数据回调函数 */
static rt_err_t uart_input(rt_device_t dev, rt_size_t size)
{
	static rt_uint8_t cnt = 0;
 rt_err_t result;
	struct rx_msg msg;
	msg.dev = dev;
 msg.size = size;
	cnt = rt_device_read(dev, -1, Buffer, size);
//	if(cnt != 32)
//	{
//		 rt_kprintf("find %s data number failed! ", SAMPLE_UART_NAME);
//		 return RT_ERROR;
//	}
	result = rt_mq_send(&rx_mq, &msg, sizeof(msg));

return result;
}

//初始化传感器使用到的串口
rt_uint8_t sensor_uart_init(void * parameter)
{
	/* step1：查找串口设备 */
	serial = rt_device_find(SAMPLE_UART_NAME);
 if (!serial)
 {
 rt_kprintf("find %s failed! ", SAMPLE_UART_NAME);
 return RT_ERROR;
 }
	/* step2：打开串口设备。以中断接收及轮询发送模式打开串口设备 */
	rt_device_open(serial, RT_DEVICE_FLAG_DMA_RX);

//	rt_sem_init(&rx_sem, "rx_sem", 0, RT_IPC_FLAG_FIFO);	//初始化信号量
	
	
	/* step3：修改串口配置参数 */
	config.baud_rate = BAUD_RATE_9600;        //9600波特率
	config.data_bits = DATA_BITS_8;           //数据位 8
	config.stop_bits = STOP_BITS_1;           //停止位 1
	config.parity = PARITY_NONE;              //无奇偶校验位

/* 以 DMA 接收及轮询发送方式打开串口设备 */
	rt_device_control(serial, RT_DEVICE_CTRL_CONFIG, &config);
		
	if(rt_device_set_rx_indicate(serial, uart_input) == RT_EOK)
		rt_kprintf("pm2.5 sensor init succeed! ");
	
	return RT_EOK;
}

rt_uint8_t PM2008_hw_init(void * parameter)
{
	static char msg_pool[128];
	
	
	/* 初始化消息队列 */
    rt_mq_init(&rx_mq, "rx_mq",
               msg_pool,                 /* 存放消息的缓冲区 */
               sizeof(struct rx_msg),    /* 一条消息的最大长度 */
               sizeof(msg_pool),         /* 存放消息的缓冲区大小 */
               RT_IPC_FLAG_FIFO);        /* 如果有多个线程等待，按照先来先得到的方法分配消息 */

sensor_uart_init(RT_NULL);
			   
	return RT_EOK;
}

void PM2008_hw_read(void)
{
	struct rx_msg msg;
    rt_err_t result;
//    rt_uint32_t rx_length;
//    static char rx_buffer[RT_SERIAL_RB_BUFSZ + 1];

{
 rt_memset(&msg, 0, sizeof(msg));		//将msg数据设置为0
 /* 从消息队列中读取消息*/
 result = rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER);
//		rt_kprintf("recv = %d ",result);
 if (result == RT_EOK)
 {
 rt_kprintf("PM2.5浓度：%d ",Buffer[6]*256 + Buffer[7]);
 }
 }

}
```按照文档中心编写了程序，经过调试能够正常的打印出传感器的数据。
串口打印数据现象：
[attach]11764[/attach]

添加线程，实现线程调用：
```#include <rtthread.h>
#include <rtdevice.h>
#include "pm2.5.h"
#include "pm2.5_th.h"

#define PM_25_THREAD_STACK_SIZE	1000	
#define PM_25_PRIORITY			4

static rt_thread_t pm_25_thread = RT_NULL;
void pm25_entry(void * paramter)
{
	rt_thread_mdelay(1000);
	while(1)
	{
		PM2008_hw_read();
		rt_thread_mdelay(100);
	}
}

//创建PM2.5传感器线程
void pm25_init(void)
{
	PM2008_hw_init(RT_NULL); 			//如 gp2y_hw_init()
	
	pm_25_thread = rt_thread_create("pm_25",pm25_entry,RT_NULL,
					PM_25_THREAD_STACK_SIZE,PM_25_PRIORITY,40);
	if(pm_25_thread != RT_NULL)
	{
		//启动线程
		rt_thread_startup(pm_25_thread);
	}
}```串口打印数据：
![mmexport1572006149292.png](/uploads/201910/25/202314a3vj9tdmnnevi34n.png)