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

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

发布于 2019-09-08 16:27:31 浏览：1197 订阅该版

* 本帖最后由 ZMQK_3560 于 2019-9-8 16:40 编辑 *

转眼已经到最后一周了，随着学习更多的官方资料，对rt_thread慢慢熟悉了，后来的任务完成的都挺顺利。不像刚开始的时候，一点概念没有，云里雾里的，只能照葫芦画瓢。还是要多看多学，很有帮助。
    一直有个疑问，一个c文件内两个函数的数据交换需不需要用IPC，两个函数是不同线程调用的，一直比较纠结。用吧 感觉挺麻烦的，不用吧 又感觉不符合rtos的风格。

第三周的任务是：
任务一：实现异步日志 mylog的传感器信息打印
任务二：系统的相关部件按照逻辑联系运行起来

任务一：
mylog.c
```#define THREAD_MYLOG_STACK_SIZE   256
static rt_thread_t mylog_printf = RT_NULL;
static rt_mailbox_t mylog_mb;

/* 邮箱及线程初始化 */
void mylog_init (void)
{
		/* 创建一个邮箱 */
		mylog_mb= rt_mb_create("mylog_mb", 5,RT_IPC_FLAG_FIFO);
		
		if(mylog_mb == RT_NULL)
		{
				rt_kprintf("init mylog mailbox failed. ");
		}
		
		/* 创建线程 */
		mylog_printf = rt_thread_create("mylog_thread",
																		mylog_thread_entry, RT_NULL,
																		THREAD_MYLOG_STACK_SIZE,
																		30, 20
																		);
		
		if(mylog_printf != RT_NULL)
		{
				/* 启动线程 */
				rt_thread_startup(mylog_printf);
				
		}
		else rt_kprintf("thread_mylog create failed ");
		
		
}

/* 邮箱邮件打印入口函数 */
void mylog_thread_entry (void *param)
{
		static struct mylog_msg *msg;/* 接收邮箱数据结构体 */
		
		while(1)
		{
				if(rt_mb_recv (mylog_mb, (rt_ubase_t*)&msg, 
												RT_WAITING_FOREVER) == RT_EOK)/* 尝试接收邮件 */
				{
					rt_kprintf("[%s] data is: %d ", msg->data_ptr, 
																					 msg->data);
				}
			
		}
		
		
}

/* 邮箱发送数据 */
void mylog (struct mylog_msg *msg)
{
		if(msg != RT_NULL)
			if(rt_mb_send (mylog_mb, (rt_ubase_t)msg) != RT_EOK)/* 邮箱发送邮件 */
					rt_kprintf("mylog_mb sent failed ");
		
		
}```![微信截图_20190907224157.png](/uploads/201909/08/154843viiitrri91irs60l.png)

任务二:
led_alert.c
```#define THREAD_LED_STACK_SIZE   			256
#define THREAD_LED_EVENT_STACK_SIZE		256

static rt_thread_t tid1,tid2;

rt_event_t led_event;

/* led初始化 */
void led_init(void)
{
		/* set LED0 pin mode to output */
		rt_pin_mode(LED0_PIN, PIN_MODE_OUTPUT);
		/* set LED1 pin mode to output */
		rt_pin_mode(LED1_PIN, PIN_MODE_OUTPUT);
	
  	/* 初始化位高电平，不亮*/
		rt_pin_write(LED0_PIN, PIN_HIGH);
		rt_pin_write(LED1_PIN, PIN_HIGH);

led_event_init();
	
}

/* led0亮 */
void led_on(LED_list value)
{
	switch(value)
	{
		case LED0:
			rt_pin_write(LED0_PIN, PIN_LOW);
			break;
		case LED1:
			rt_pin_write(LED1_PIN, PIN_LOW);
			break;
		
		default:
			
			break;
		
		
	}

}

/* led0灭 */
void led_off(LED_list value)
{
	switch(value)
	{
		case LED0:
			rt_pin_write(LED0_PIN, PIN_HIGH);
			break;
		case LED1:
			rt_pin_write(LED1_PIN, PIN_HIGH);
			break;
		
		default:
			
			break;
		
		
	}

}

/* led0闪烁 */
void led0_blink(rt_uint16_t time)
{
		led_on(LED0);
		rt_thread_mdelay(time);
		led_off(LED0);
		rt_thread_mdelay(time);
	
}

/* led1闪烁 */
void led1_blink(void)
{
		led_on(LED1);
		rt_thread_mdelay(100);
		led_off(LED1);
		rt_thread_mdelay(100);
	
}

/* led0闪烁入口函数 */
void thread_led0_blink_entry(void *parameter)
{
		rt_uint8_t i;

for(i = 0; i<2; i++)
		{
				led_on(LED0);
				rt_thread_mdelay(100);
				led_off(LED0);
				rt_thread_mdelay(100);
		}
	
}

/* led闪烁入口函数 */
void thread_led1_blink_entry(void *parameter)
{
		rt_uint8_t i;

for(i = 0; i<2; i++)
		{
				led_on(LED1);
				rt_thread_mdelay(100);
				led_off(LED1);
				rt_thread_mdelay(50);
		}
	
}

void led_blink(void)
{
		tid1 = rt_thread_create("thread1_led0",
														thread_led0_blink_entry, RT_NULL,
														THREAD_LED_STACK_SIZE,
														18, 10
														);
	
		if(tid1 != RT_NULL)
				rt_kprintf("thread1_led0 created ");
		
		tid2 = rt_thread_create("thread1_led1",
														thread_led1_blink_entry, RT_NULL,
														THREAD_LED_STACK_SIZE,
														17, 10
														);
	
		if(tid2 != RT_NULL)
				rt_kprintf("thread1_led1 created ");

}

/* LED事件初始化*/
void led_event_init(void)
{
	
		static rt_thread_t event = RT_NULL;
	
		led_event = rt_event_create("sensor_event", RT_IPC_FLAG_FIFO);
		if(led_event == RT_NULL)
			rt_kprintf("led event create fail");
		
		event = rt_thread_create("led_event_thread",
														led_entry, RT_NULL,
														THREAD_LED_EVENT_STACK_SIZE,
														16, 10
														);
		if(event != RT_NULL)
				rt_thread_startup(event);
		else		rt_kprintf("led event thread create fail");
	
		led_blink();
		rt_thread_startup(tid1);
		rt_thread_startup(tid2);
}

void led_send_event(rt_uint32_t event)
{
	rt_event_send(led_event, event);
	
}

/* LED灯事件集判断 */
void led_entry(void *parameter)
{
	
		rt_uint32_t e;
	
		while(1)
		{
				if(rt_event_recv(led_event, EVENT_FLAG1 | EVENT_FLAG2 | EVENT_FLAG3, 
								RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR , RT_WAITING_FOREVER, &e) == RT_EOK)
				{
					if(e & EVENT_FLAG1)
						thread_led0_blink_entry(RT_NULL);
			
					if(e & EVENT_FLAG2)
							thread_led1_blink_entry(RT_NULL);
					
					if(e & EVENT_FLAG3)
							;

}
	}
	
}```temp_humi_th.c
```#define TEMP_HUMI_THREAD_SIZE				512

struct temp_humi
{
	rt_uint8_t  temp;
	rt_uint8_t  humi;
} temp_humi_data = {0,0};

static rt_thread_t dht11_thread;
static rt_device_t dev = RT_NULL;

static rt_uint8_t TUMP_HUMI_ON_OFF;

static rt_uint8_t temp[] = "TEMP";
static rt_uint8_t humi[] = "HUMI";
static struct mylog_msg 	Temp_MSG = {temp,0};
static struct mylog_msg 	Humi_MSG = {humi,0};

/* 温湿度读取线程入口 */
void temp_humi_entry (void *parameter)
{
    //rt_device_t dev = RT_NULL;
    struct rt_sensor_data sensor_data;
    rt_size_t res;

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

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

rt_thread_delay(2000);
    }	
	
}

/* 温湿度初始化, 初始化线程 */
void temp_humi_init (void)
{
		dht11_hw_init();
		temp_humi_thread_start();
	
	
}

/* 温湿度初始化, 初始化线程 */
rt_uint8_t temp_humi_thread_start (void)
{

dht11_thread = rt_thread_create("temp_humi",
                                     temp_humi_entry,
                                     RT_NULL,
                                     TEMP_HUMI_THREAD_SIZE,
                                     RT_THREAD_PRIORITY_MAX / 2,
                                     20);
    if (dht11_thread != RT_NULL)
    {
        rt_thread_startup(dht11_thread);
    }

return RT_EOK;	
	
	
}

/* dht11初始化 */
rt_uint8_t dht11_hw_init (void)
{
    struct rt_sensor_config cfg;
	
    
    rt_uint8_t get_data_freq = 1; /* 1Hz */
    
    cfg.intf.user_data = (void *)DHT11_DATA_PIN;
    rt_hw_dht11_init("dht11", &cfg);

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

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

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

return RT_EOK;
	
}

/* dht11读取温湿度数据 */
void dht11_read_temp_humi (void)
{
		//rt_kprintf("temp:%d " ,temp_humi_data.temp);
		//rt_kprintf("humi:%d " ,temp_humi_data.humi);
		Temp_MSG.data = temp_humi_data.temp;
		Humi_MSG.data = temp_humi_data.humi;
		if(Temp_MSG.data < 34 && Temp_MSG.data > 10 && Humi_MSG.data < 70)
				led_send_event(EVENT_FLAG1);
		else 	led_on(LED0);
		mylog(&Temp_MSG);										/* mylog打印 */

mylog(&Humi_MSG);										/* mylog打印 */

}

/* 温湿度采集控制  按键中断调用函数  不能有可能导致挂起的函数  */
void key0_TH_contr(rt_uint8_t value)
{
		TUMP_HUMI_ON_OFF = value;
		if(!TUMP_HUMI_ON_OFF)
			led_off(LED0);

}```未完，见下篇...
pm25_th.c
key.c

![QQ截图20190908155051.png](https://oss-club.rt-thread.org/uploads/201909/08/155430fh4lciiczrxnonqw.png)

![微信截图_20190907224157.png](https://oss-club.rt-thread.org/uploads/201909/08/163640golrj7ydon4pd4r4.png)