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

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

发布于 2019-09-11 01:10:16 浏览：803 订阅该版

终于弄完了，直接上代码吧。```void key_cb_dht11(void *args)
{
    static uint32_t key_cnt = 0;
    key_cnt++;
    if(key_cnt%2 == 0)
    {
        dht11_switch = 0;
        led_off(LED_PIN_DHT11);
    }
    else
    {
        dht11_switch = 1;
    }

}

void key_cb_pm25(void *args)
{
    static uint32_t key_cnt = 0;
    key_cnt++;
    if(key_cnt%2 == 0)
    {
        pm25_switch = 0;        
        led_off(LED_PIN_PM25);
    }
    else
    {
        pm25_switch = 1;
    }

void key_cb_sgp30(void *args)
{
    if(PIN_LOW == rt_pin_read(KEY_PIN_SGP30))  
    {
       led_on(LED_PIN_SGP30);
    }
    else
    {
        led_off(LED_PIN_SGP30);
    }
}

void Key_Init(void)
{
     /* 按键引脚为输入模式 */
    rt_pin_mode(KEY_PIN_DHT11, PIN_MODE_INPUT_PULLUP);
    /* 绑定中断，下降沿模式，回调函数名为led_blink */
    rt_pin_attach_irq(KEY_PIN_DHT11, PIN_IRQ_MODE_RISING_FALLING, key_cb_dht11, RT_NULL);
    rt_pin_irq_enable(KEY_PIN_DHT11, PIN_IRQ_ENABLE);

/* 按键引脚为输入模式 */
    rt_pin_mode(KEY_PIN_PM25, PIN_MODE_INPUT_PULLUP);
    /* 绑定中断，下降沿模式，回调函数名为led_blink */   
    rt_pin_attach_irq(KEY_PIN_PM25, PIN_IRQ_MODE_RISING_FALLING, key_cb_pm25, RT_NULL);
    rt_pin_irq_enable(KEY_PIN_PM25, PIN_IRQ_ENABLE);   
    
     /* 按键引脚为输入模式 */
    rt_pin_mode(KEY_PIN_SGP30, PIN_MODE_INPUT_PULLUP);
    /* 绑定中断，下降沿模式，回调函数名为led_blink */
    rt_pin_attach_irq(KEY_PIN_SGP30, PIN_IRQ_MODE_RISING_FALLING, key_cb_sgp30,RT_NULL);
    rt_pin_irq_enable(KEY_PIN_SGP30, PIN_IRQ_ENABLE);

}

``````
static void led_entry(void *param)
{
    char *str;
    rt_uint32_t e;

while (1)
    {
       
           if (rt_event_recv(&event, (EVENT_TEMP_HUMI| EVENT_PM25|TEMP_HUMI_OK|PM25_OK),
                             RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
                             RT_WAITING_FOREVER, &e) == RT_EOK)
            {
                if((e&EVENT_TEMP_HUMI) == EVENT_TEMP_HUMI)
                {
                    led_on(LED_PIN_DHT11);
                }
                
                if((e&EVENT_PM25) == EVENT_PM25)
                {
                    led_on(LED_PIN_PM25);
                }

if((e&TEMP_HUMI_OK) == TEMP_HUMI_OK)
                {
                    led_blink(LED_PIN_DHT11);
                }
                if((e&PM25_OK) == PM25_OK)
                {
                    led_blink(LED_PIN_PM25);
                }

}
    }
}

``````

static void temp_humi_entry(void *param)
{
    int32_t Temp = 0;
    uint8_t wendu,shidu;
    rt_uint32_t e;
    while (1)
    {
            if(dht11_switch == 1)
            {
                Temp = Dht11_read_data(DHT11_PIN);
                wendu = Temp&0xff;                
                if(wendu > 36)
                {
                    rt_event_send(&event, EVENT_TEMP_HUMI);
                }
                else
                {
                   rt_event_send(&event, TEMP_HUMI_OK); 
                }
                shidu = Temp>>16;
                st_mylog->data_type_ptr = temp_str;
                st_mylog->data_value = wendu;
                mylog(st_mylog);
                st_mylog->data_type_ptr = huimi_str;
                st_mylog->data_value = shidu;
                mylog(st_mylog);                
            }
            else if(dht11_switch == 0)
            {
                led_off(LED_PIN_DHT11);
            }                      
            rt_thread_mdelay(1000);

}
}

``````
static void pm25_entry(void *param)
{
    float pm25_value_f;
    int32_t   pm25_value_i;
    rt_uint32_t e;
    while (1)
    {
            if(pm25_switch == 1)
            {
                pm25_value_f = gp2y_read_pm25();
                pm25_value_i = (int32_t)(pm25_value_f);
                
                if(pm25_value_i > 100)
                {
                    rt_event_send(&event, EVENT_PM25);
                }
                else
                {
                   rt_event_send(&event, PM25_OK); 
                }
                st_mylog->data_type_ptr = pm25_str;
                st_mylog->data_value = pm25_value_i;
                mylog(st_mylog);        
            }
            else if(pm25_switch == 0)
            {
                led_off(LED_PIN_PM25);
            }
            rt_thread_mdelay(1000);
            
}
}

``````

static void mylog_entry(void *param)
{
    char *str;

while (1)
    {
       MSG_MYLOG_STRU* msg_ptr;
       
       /* 从邮箱中收取邮件 */
       if (rt_mb_recv(mb_mylog, (rt_uint32_t*)&msg_ptr, RT_WAITING_FOREVER) == RT_EOK)
       {
           rt_kprintf("[%s] data is:%d<br>",msg_ptr->data_type_ptr, msg_ptr->data_value);
       }
    }
}

static void Rt_thread_create(void)
{
        /* 创建线程 1，名称是 thread1，入口是 thread1_entry*/
    tid_mylog = rt_thread_create("rt_mylog",
                            mylog_entry, RT_NULL,
                            THREAD_STACK_SIZE,
                            5, 100);

/* 如果获得线程控制块，启动这个线程 */
    if (tid_mylog != RT_NULL)
    rt_thread_startup(tid_mylog);

}
static int Rt_mb_create(void)
{
    rt_err_t result;

/* 创建一个邮箱 */
     mb_mylog= rt_mb_create("mb_mylog", 20,RT_IPC_FLAG_FIFO);
     
     if(mb_mylog == RT_NULL)
     {
          rt_kprintf("init mb_mylog mailbox failed.<br>");
     }
}

void mylog_init(void)
{
    st_mylog = (MSG_MYLOG_STRU*)rt_malloc(sizeof(MSG_MYLOG_STRU));    
    Rt_mb_create();
    Rt_thread_create();
}

void mylog(MSG_MYLOG_STRU *st_msg)
{
        
    rt_mb_send(mb_mylog, (rt_uint32_t)st_msg);

}

```