【RTOS】RT-Thread创新设计大赛——面向物联网的智能台灯设计

//重映串口控制台到rt_kprintf

void rt_hw_console_output(const char *str)

{

   rt_enter_critical();

        while(*str!= '\0')

        {

           if(*str == '\n')

                 {

                         UartSendByte(UART0, '\r');

                          

                 }

                  UartSendByte(UART0, *str++);

        }

        rt_exit_critical();

}

#define   RT_USING_FINSH      //打开finsh功能

#define   RTE_USING_DEVICE    //打开DEVICE

#define   RTE_FINSH_USING_MSH

char rt_hw_console_getchar(void)

{

    int ch = -1;

    if(READ_BIT(UART0->SR,UART_SR_RFNE_MSK) != RESET)

    {

        ch =  UART0->RBR & 0xff;

    }

    return ch;

}

while(onenet_mqtt_init())

{

 rt_kprintf("onenet_mqtt_init error!\r\n");

}

// onenet 上传数据线程

void task2(void *parameter)

{

  unsigned int i;

  while(onenet_mqtt_init());

        while(1)

        {

                i++;

                if(i>=100)i=1;

          onenet_mqtt_upload_digit("temperature",i);

                rt_thread_mdelay(1000);

          rt_kprintf("\r\n upload_temp thread is OK!\r\n");

        }

}

/****************************************************************************/

struct rt_thread Task2_thread;

rt_uint8_t rt_task2_thread_stack[1024];

rt_thread_init(&Task2_thread,"task2",

                       task2,RT_NULL,&rt_task2_thread_stack[0],

                       sizeof(rt_task2_thread_stack),4,50);

rt_thread_startup(&Task2_thread);        

static void mqtt_callback(MQTTClient *c, MessageData *msg_data)

{

    size_t res_len = 0;

    uint8_t *response_buf = RT_NULL;

    char topicname[45] = { "$crsp/" };



    RT_ASSERT(c);

    RT_ASSERT(msg_data);



    LOG_D("topic %.*s receive a message", msg_data->topicName->lenstring.len, msg_data->topicName->lenstring.data);



        LOG_D("message length is %d", msg_data->message->payloadlen);

                LOG_D("recv data is %s\n", msg_data->message->payload);

/*******************本人添加测试代码部***************************************/

                uint8_t *recv_data = msg_data->message->payload;    //获取按钮数据

                rt_pin_mode(LED1_PIN, PIN_MODE_OUTPUT);        //配置LED

                if(*recv_data == '1')

                {

                   //led on

                        rt_pin_write(LED1_PIN, PIN_LOW);                  

                }

                else if((*recv_data == '0'))

                {

                 rt_pin_write(LED1_PIN, PIN_HIGH);

                }                        

/****************************************************************************/

    if (onenet_mqtt.cmd_rsp_cb != RT_NULL)

    {

        onenet_mqtt.cmd_rsp_cb((uint8_t *) msg_data->message->payload, msg_data->message->payloadlen, &response_buf,

                &res_len);



        if (response_buf != RT_NULL || res_len != 0)

        {

            strncat(topicname, &(msg_data->topicName->lenstring.data[6]), msg_data->topicName->lenstring.len - 6);



            onenet_mqtt_publish(topicname, response_buf, strlen((const char *)response_buf));



            ONENET_FREE(response_buf);

        }

    }

}

/***************************************************************************/

#include "bsp_dht11.h"

/* 可以在下面的宏定义中把后面的延时函数替换换SysTick的延时函数，就是想用那个就换成那个的 */

#define  delay_us(us)   rt_hw_us_delay(us)

#define  delay_ms(ms)   rt_thread_mdelay(ms)



#define  DH_PIN  43



void DHT11_Rst(void)           

{                 

          DHT11_IO_OUT();         //SET OUTPUT

          DHT11_Dout_0;            //拉低DQ

    delay_ms(20);     //拉低至少18ms

    DHT11_Dout_1;                  //DQ=1

          delay_us(30);     //主机拉高20~40us

}



//等待DHT11的回应

//返回1:未检测到DHT11的存在

//返回0:存在

unsigned char DHT11_Check(void)            

{   

        unsigned char retry=0;

        DHT11_IO_IN();//SET INPUT         

    while (DHT11_Dout_IN()&&retry<100)//DHT11会拉低40~80us

        {

                retry++;

                delay_us(1);

        };         

        if(retry>=100)return 1;

        else retry=0;

    while (!DHT11_Dout_IN()&&retry<100)//DHT11拉低后会再次拉高40~80us

        {

                retry++;

                delay_us(1);

        };

        if(retry>=100)return 1;            

        return 0;

}



//从DHT11读取一个位

//返回值：1/0

unsigned char DHT11_Read_Bit(void)                          

{

         unsigned char retry=0;

        while(DHT11_Dout_IN()&&retry<100)//等待变为低电平

        {

                retry++;

                delay_us(1);

        }

        retry=0;

        while(!DHT11_Dout_IN()&&retry<100)//等待变高电平

        {

                retry++;

                delay_us(1);

        }

        delay_us(40);//等待40us

        if(DHT11_Dout_IN())return 1;

        else return 0;                   

}

//从DHT11读取一个字节

//返回值：读到的数据

unsigned char DHT11_Read_Byte(void)    

{        

    unsigned char i,dat;

    dat=0;

        for (i=0;i<8;i++) 

        {

                   dat<<=1; 

            dat|=DHT11_Read_Bit();

    }                                                    

    return dat;

}

//从DHT11读取一次数据

//temp:温度值(范围:0~50°)

//humi:湿度值(范围:20%~90%)

//返回值：0,正常;1,读取失败

unsigned char DHT11_Read_Data(unsigned char *temp,unsigned char *humi)    

{        

         unsigned char buf[5];

        unsigned char i;

        DHT11_Rst();

        if(DHT11_Check()==0)

        {

                for(i=0;i<5;i++)//读取40位数据

                {

                        buf[i]=DHT11_Read_Byte();

                }

                if((buf[0]+buf[1]+buf[2]+buf[3])==buf[4])

                {

                        *humi=buf[0];

                        *temp=buf[2];

                }

        }else return 1;

        return 0;            

}

//初始化DHT11的IO口 DQ 同时检测DHT11的存在

//返回1:不存在

//返回0:存在             

unsigned char DHT11_Init(void)

{         

    gpio_init_t  x;

                 /* Initialize PC9 pin */

    x.mode = GPIO_MODE_OUTPUT;

    x.pupd = GPIO_PUSH_UP;

    x.odos = GPIO_PUSH_PULL;

    x.odrv = GPIO_OUT_DRIVE_NORMAL;

    x.flt  = GPIO_FILTER_DISABLE;

    x.type = GPIO_TYPE_CMOS;

    x.func = GPIO_FUNC_1;

        

   gpio_init(DHT11_GPIO_PORT, DHT11_PIN, &x); 

                            

        DHT11_Rst();  //复位DHT11

        return DHT11_Check();//等待DHT11的回应

} 

/***************************************************************************/

#ifndef __DHT11_H

#define        __DHT11_H

#include <es32f065x.h>

#include "ald_gpio.h"

#include <rtthread.h>

#include "pin.h"

#include "board.h"



#define      DHT11_GPIO_PORT                 GPIOA

#define      DHT11_PIN                       GPIO_PIN_10



//IO方向设置

#define DHT11_IO_IN()   rt_pin_mode(DH_PIN, PIN_MODE_INPUT_PULLUP)        

#define DHT11_IO_OUT()  rt_pin_mode(DH_PIN,PIN_MODE_OUTPUT)



////IO操作函数                                                                                           

#define DHT11_Dout_0              gpio_write_pin(DHT11_GPIO_PORT, DHT11_PIN,0)

#define DHT11_Dout_1              gpio_write_pin(DHT11_GPIO_PORT,DHT11_PIN,1)



#define DHT11_Dout_IN()            gpio_read_pin(DHT11_GPIO_PORT,DHT11_PIN )





unsigned char DHT11_Init(void);

unsigned char DHT11_Read_Data(unsigned char *temp,unsigned char *humi);

#endif /* __DHT11_H */

/***************************************************************************/