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

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

发布于 2019-10-31 21:47:28 浏览：1051 订阅该版

**0、前言**

本周主要使用了邮箱和事件集，做完这个部分初步感觉像是在通过操作系统编程序了，下面介绍一下这个部分功能的实现。首先附上main.c部分代码，main函数在创建完初始化后，被系统自动回收了，论坛字数有限，删减部分代码。
main.c
```int main(void)
{

led_init();
    key_init();
	pm25_init();
	mylog_init();

return RT_EOK;
}
```

**1、任务一 mylog的实现**
    这部分主要是在初始化时创建,然后可以通过调用mylog(char* tag,rt_uint32_t data)这个函数，实现异步打印各种参数的名称和数值。
mylog.c
```#include "mylog.h"

/* 私有类型定义 --------------------------------------------------------------*/
struct msg	/* 创建消息类型结构体 */
{
  char *tag;
  rt_uint32_t dat;
};
/* 私有变量 ------------------------------------------------------------------*/
/* 邮箱控制块 */
struct rt_mailbox mb;
/* 用于放邮件的内存池 */
char mb_pool[128];
/* 私有函数原型 --------------------------------------------------------------*/
static void mylog_entry(void *parameter);
/**
  * 函数功能: mylog打印函数以及信箱初始化
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
int mylog_init(void)
{
    rt_thread_t mylog_thread;

/* 创建mylog异步日志打印线程 */
    mylog_thread = rt_thread_create("mylog_print",
                                    mylog_entry,
                                    RT_NULL,
                                    1024,
                                    RT_THREAD_PRIORITY_MAX / 2,
                                    20);
    /* 创建成功启动线程 */
    if (mylog_thread != RT_NULL)
    {
        rt_thread_startup(mylog_thread);
    }

rt_err_t result;

/* 初始化一个 mailbox */
    result = rt_mb_init(&mb,
                        "mbt",                      /* 名称是 mbt */
                        &mb_pool[0],                /* 邮箱用到的内存池是 mb_pool */
                        sizeof(mb_pool) / 4,        /* 邮箱中的邮件数目，因为一封邮件占 4 字节 */
                        RT_IPC_FLAG_FIFO);          /* 采用 FIFO 方式进行线程等待 */
    if (result != RT_EOK)
    {
        rt_kprintf("init mailbox failed.<br>");
        return -1;
    }

return RT_EOK;
}

/**
  * 函数功能: mylog打印函数初始化
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
static void mylog_entry(void *parameter)
{
    struct msg *msg_ptr;
	
	while(1)
	{
		if (rt_mb_recv(&mb, (rt_ubase_t *)&msg_ptr, RT_WAITING_FOREVER) == RT_EOK)
		{
			rt_kprintf("[%s] data is:%d <br>",msg_ptr -> tag, msg_ptr -> dat);  /* 发送日志数据 */
		}
		rt_thread_delay(100);
	} 
}

/**
  * 函数功能: 按照格式打印异步日志
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
int mylog(char* tag,rt_uint32_t data)
{
    struct msg *amsg;

amsg = (struct msg *)rt_malloc(sizeof(struct msg));
    amsg->tag = tag;
    amsg->dat = data;
    rt_mb_send(&mb, (rt_uint32_t)amsg);
	
    return RT_EOK;
}

/***************************** END OF FILE *********************************/```mylog.h
```/* 扩展变量 ------------------------------------------------------------------*/
extern struct rt_mailbox mb;

/* 函数声明 ------------------------------------------------------------------*/
int mylog_init(void);
int mylog(char* tag,rt_uint32_t data);

#endif /* __MYLOG_H__ */```

**2、任务二 温湿度报警的实现**
（1）、首先做了按键的检测函数，按键每按下一次后改变状态，用于控制检测的使能还是失能。
key.c
```uint8_t KeyState = 0;/* 按压状态 */

void key_cb(void *args)
{
    if(rt_pin_read(KEY1_PIN_NUM))
    {
		KeyState = 1 - KeyState;				/* 更改按键状态 */
    }
}

/**
  * 函数功能: 按键初始化函数
  * 输入参数: 无
  * 返 回 值: 无
  * 说    明：无
  */
void key_init(void)
{
    /* 按键0引脚为输入模式 */
    rt_pin_mode(KEY1_PIN_NUM, PIN_MODE_INPUT_PULLUP);
    /* 绑定中断，边沿触发模式，回调函数名为key_cb */
    rt_pin_attach_irq(KEY1_PIN_NUM, PIN_IRQ_MODE_RISING_FALLING, key_cb, RT_NULL);
    /* 使能中断 */
    rt_pin_irq_enable(KEY1_PIN_NUM, PIN_IRQ_ENABLE);
}

/***************************** END OF FILE *********************************/```key.h
```/* 扩展变量 ------------------------------------------------------------------*/
extern uint8_t KeyState;/* 按压状态 */

/* 函数声明 ------------------------------------------------------------------*/
void key_init(void);

#endif /* __KEY_H__ */
```(2)、然后，是LED报警线程，检测按键状态，在报警使能的情况下，线程上收到报警会进入常亮状态，否则会进入闪烁状态，失能状态下保持熄灭。
"led_alert.c
```#include "led_alert.h"
#include "key.h"

/* 私有变量 ------------------------------------------------------------------*/
struct rt_event event;  /* 事件控制块 */```"led_alert.h
```#define EVENT_FLAG1 (1 << 1)
#define EVENT_FLAG2 (1 << 2)

/* 扩展变量 ------------------------------------------------------------------*/
extern struct rt_event event;  /* 事件控制块 */

#endif /* __LED_ALERT_H__ */
```（3）、论坛限制10000字，只能写到这里了，就贴了温湿度检测和报警的这部分。以下是报警打印的核心部分代码{:2_29:}
```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
				mylog("temp",temp);	/* 执行日志打印 */
				mylog("humi",humi);
				if(temp>25)
				{
					rt_event_send(&event, EVENT_FLAG1);/* 发送事件 */
				}
				if(humi>80)
				{
					rt_event_send(&event, EVENT_FLAG2);/* 发送事件 */
				}	
            }
        }

rt_thread_delay(1000);
    }
}```

**3、运行结果**

![QQ截图20191031211651.png](/uploads/201910/31/212815kk0kchv0hm602xkk.png)