RT-Thread-[第3期空气质量分析仪]第二周作业。提交学习营每周的作业~RT-Thread问答社区

[第3期空气质量分析仪]第二周作业。提交学习营每周的作业~

发布于 2019-10-24 23:54:18 浏览：953 订阅该版

0、写在前面的话：
    最近公司项目真是太忙了，每周真是抽时间外的时间，在搞这个项目，可能有很多地方并不是按照RT-Thread的思维在做开发，但是，也算初步完成了吧，做完后再细细雕琢吧，附上一张工程截图。
![1.png](/uploads/201910/24/234038t8jj8asdic9jmcyj.png)

1、任务一 温湿度
这个任务是上星期的，借用了RT-Thread的软件包。
temp_humi_th.c
```/*
 * Copyright (c) 2006-2018, RT-Thread Development Team
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * Change Logs:
 * Date           Author         Notes
 * 2019-08-01     LuoGong         the first version.
 * 2019-08-15     MurphyZhao      add lock and modify code style
 */

#include <rtthread.h>
#include <rtdevice.h>
#include "sensor.h"
#include "sensor_dallas_dht11.h"
#include "drv_gpio.h"

/* Modify this pin according to the actual wiring situation */
#define DHT11_DATA_PIN    GET_PIN(A, 8)

void read_temp_entry(void *parameter)
{
    rt_device_t dev = RT_NULL;
    struct rt_sensor_data sensor_data;
    rt_size_t res;
    rt_uint8_t get_data_freq = 1; /* 1Hz */

dev = rt_device_find("temp_dht11");
    if (dev == RT_NULL)
    {
        return;
    }

if (rt_device_open(dev, RT_DEVICE_FLAG_RDWR) != RT_EOK)
    {
        rt_kprintf("open device failed!<br>");
        return;
    }

rt_device_control(dev, RT_SENSOR_CTRL_SET_ODR, (void *)(&get_data_freq));

while (1)
    {
        res = rt_device_read(dev, 0, &sensor_data, 1);

if (res != 1)
        {
            rt_kprintf("read data failed! result is %d<br>", res);
            rt_device_close(dev);
            return;
        }
        else
        {
            if (sensor_data.data.temp >= 0)
            {
                uint8_t temp = (sensor_data.data.temp & 0xffff) >> 0;      // get temp
                uint8_t humi = (sensor_data.data.temp & 0xffff0000) >> 16; // get humi
                rt_kprintf("temp:%d, humi:%d<br>" ,temp, humi);
            }
        }

rt_thread_delay(1000);
    }
}

int dht11_read_temp_sample(void)
{
    rt_thread_t dht11_thread;

dht11_thread = rt_thread_create("dht_tem",
                                     read_temp_entry,
                                     RT_NULL,
                                     1024,
                                     RT_THREAD_PRIORITY_MAX / 2,
                                     20);
    if (dht11_thread != RT_NULL)
    {
        rt_thread_startup(dht11_thread);
    }

return RT_EOK;
}
INIT_APP_EXPORT(dht11_read_temp_sample);

int rt_hw_dht11_port(void)
{
    struct rt_sensor_config cfg;
    
    cfg.intf.user_data = (void *)DHT11_DATA_PIN;
    rt_hw_dht11_init("dht11", &cfg);

return RT_EOK;
}
INIT_COMPONENT_EXPORT(rt_hw_dht11_port);
```

2、任务二 PM2.5检测
    这个模块因为硬件电路的问题，完成的比较曲折，程序中基本包含：PWM输出、ADC检测、以及线程的注册,和线程接口的写入。代码如下
pm25_th.c
```/* 包含头文件 ----------------------------------------------------------------*/
#include "pm25_th.h"
#include <rtthread.h>
#include <rtdevice.h>
#include <board.h>
#include "stm32f1xx_hal.h"

/* 私有类型定义 --------------------------------------------------------------*/
/* 私有宏定义 ----------------------------------------------------------------*/
/* 私有变量 ------------------------------------------------------------------*/
/* 扩展变量 ------------------------------------------------------------------*/
/* 私有函数原型 --------------------------------------------------------------*/
/* 函数体 --------------------------------------------------------------------*/

ADC_HandleTypeDef hadc1;

TIM_HandleTypeDef htim3;

#define ADC_DEV_NAME        "adc1"  /* ADC 设备名称 */
#define ADC_DEV_CHANNEL     14      /* ADC 通道 */

rt_adc_device_t adc_dev;            /* ADC 设备句柄 */

/**
  * 函数功能: ADC初始化函数
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
static void ADC_Init(void)
{
    ADC_ChannelConfTypeDef sConfig = {0};

/** Common config
    */
    hadc1.Instance = ADC1;
    hadc1.Init.ScanConvMode = ADC_SCAN_DISABLE;
    hadc1.Init.ContinuousConvMode = DISABLE;
    hadc1.Init.DiscontinuousConvMode = DISABLE;
    hadc1.Init.ExternalTrigConv = ADC_SOFTWARE_START;
    hadc1.Init.DataAlign = ADC_DATAALIGN_RIGHT;
    hadc1.Init.NbrOfConversion = 1;
    if (HAL_ADC_Init(&hadc1) != HAL_OK)
    {
        Error_Handler();
    }
    /** Configure Regular Channel
    */
    sConfig.Channel = ADC_CHANNEL_14;
    sConfig.Rank = ADC_REGULAR_RANK_1;
    sConfig.SamplingTime = ADC_SAMPLETIME_1CYCLE_5;
    if (HAL_ADC_ConfigChannel(&hadc1, &sConfig) != HAL_OK)
    {
        Error_Handler();
    }
}

/**
  * 函数功能: PWM 定时器3初始化函数
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
static void MX_TIM3_Init(void)
{
    /* 定时器初句柄声明 */
    TIM_ClockConfigTypeDef sClockSourceConfig = {0};
    TIM_MasterConfigTypeDef sMasterConfig = {0};
    TIM_OC_InitTypeDef sConfigOC = {0};

/* 配置相关寄存器 */
    htim3.Instance = TIM3;
    htim3.Init.Prescaler = 72-1;
    htim3.Init.CounterMode = TIM_COUNTERMODE_UP;
    htim3.Init.Period = 1000-1;
    htim3.Init.ClockDivision = TIM_CLOCKDIVISION_DIV1;
    htim3.Init.AutoReloadPreload = TIM_AUTORELOAD_PRELOAD_DISABLE;
    if (HAL_TIM_Base_Init(&htim3) != HAL_OK)
    {
        Error_Handler();
    }
    sClockSourceConfig.ClockSource = TIM_CLOCKSOURCE_INTERNAL;
    if (HAL_TIM_ConfigClockSource(&htim3, &sClockSourceConfig) != HAL_OK)
    {
        Error_Handler();
    }
    if (HAL_TIM_PWM_Init(&htim3) != HAL_OK)
    {
        Error_Handler();
    }
    sMasterConfig.MasterOutputTrigger = TIM_TRGO_RESET;
    sMasterConfig.MasterSlaveMode = TIM_MASTERSLAVEMODE_DISABLE;
    if (HAL_TIMEx_MasterConfigSynchronization(&htim3, &sMasterConfig) != HAL_OK)
    {
        Error_Handler();
    }
    sConfigOC.OCMode = TIM_OCMODE_PWM1;
    sConfigOC.Pulse = 0;
    sConfigOC.OCPolarity = TIM_OCPOLARITY_HIGH;
    sConfigOC.OCFastMode = TIM_OCFAST_DISABLE;
    if (HAL_TIM_PWM_ConfigChannel(&htim3, &sConfigOC, TIM_CHANNEL_1) != HAL_OK)
    {
        Error_Handler();
    }

HAL_TIM_MspPostInit(&htim3);
}

/**
  * 函数功能: ADC读取函数
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
static uint16_t ADC_Read(void)
{
    uint16_t value;

HAL_ADC_Start(&hadc1);
    HAL_ADC_PollForConversion(&hadc1, 10);    /* 等待转换完成，第二个参数表示超时时间，单位ms */

if(HAL_IS_BIT_SET(HAL_ADC_GetState(&hadc1), HAL_ADC_STATE_REG_EOC))
    {
        value=HAL_ADC_GetValue(&hadc1);
    }

return value;
}

/**
  * 函数功能: ADC读取函数
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
void read_pm25_entry(void *parameter)
{
    uint16_t Val;
    float pm2_5;
	uint16_t pm2_5_h,pm2_5_l;
	
	while(1)
	{
		/* 读取ADC值 */
		Val = ADC_Read();

/* 换算PM2.5数值 */
		pm2_5 = ((((float)Val * 3.3f /4096)*0.17)-0.1f)*1000;
		
		pm2_5_h=(uint16_t)pm2_5;
		
		/* 输出PM2.5值 */
		rt_kprintf("pm25 : %d<br>" ,pm2_5_h);
		
		rt_thread_delay(1000);
	} 
}

int pm25_init(void)
{
    rt_thread_t pm25_thread;

/* 初始化ADC外设 */
    ADC_Init();

/* 初始化PWM输出外设 */
    MX_TIM3_Init();

/* 启动TIM3定时器输出 */
    HAL_TIM_PWM_Start(&htim3,TIM_CHANNEL_1);
	
	/* 装载脉冲宽度值 */
	TIM1->CCR1 = 320;

/* 创建PM2.5读取线程 */
    pm25_thread = rt_thread_create("gp2y_pm25",
                                   read_pm25_entry,
                                   RT_NULL,
                                   1024,
                                   RT_THREAD_PRIORITY_MAX / 2,
                                   20);
    if (pm25_thread != RT_NULL)
    {
        rt_thread_startup(pm25_thread);
    }

return RT_EOK;
}

/***************************** END OF FILE *********************************/
```pm25_th.h
```#ifndef __BSP_PM25_TH_H__
#define __BSP_PM25_TH_H__

/* 包含头文件 ----------------------------------------------------------------*/
#include "main.h"

/* 类型定义 ------------------------------------------------------------------*/
/* 宏定义 --------------------------------------------------------------------*/
/* 扩展变量 ------------------------------------------------------------------*/
/* 函数声明 ------------------------------------------------------------------*/
int pm25_init(void);

#endif  /* __BSP_PM25_TH_H__ */
```3、运行截图
![3.png](/uploads/201910/24/235403uxwo8yxowmyk1bz6.png)