开发板使用的是中科蓝讯的AB32，本系统分为3个部分。

OLED显示部分，显示温湿度采集的值。

土壤湿度采集部分，采集土壤的湿度，对数据做出判断，发出控制指令。

继电器控制部分，开发板发出信号，控制继电器打开水泵浇水，并且蜂鸣器会发出警告。

开发平台使用的是RT_studio,它讲很多模块都集成，界面看着也很舒服。

运用了RT_Thre，事件发送，线程。

主函数程序部分：

#include

先初始化OLED屏幕，然后调用温湿度传感器线程初始化，oled屏幕线程初始化，adc线程初始化，蜂鸣器和继电器线程初始化。

ADC程序部分：

static void adc_thread_entry(void *parameter)
{
  (void)parameter;
  while(1)
  {
      rt_thread_mdelay(1000);
    if(adc_vol_sample()>800){
    rt_event_send(adc_event, 1);                       
    rt_thread_mdelay(100);                           
    }else {
        rt_event_send(adc_event, 2);                       
        rt_thread_mdelay(100);                           
    }
  }
}

int adc_thread_init(void)
{
    adc_event = rt_event_create("adc",                            // 事件名称
                                RT_IPC_FLAG_FIFO);                // 先进先出模式
    if(adc_event == RT_NULL)
      return -1;

    adc_thread = rt_thread_create("adc",                          // 线程名称
                                  adc_thread_entry,               // 线程入口函数
                                  RT_NULL,                        // 入口函数入口参数
                                  512,                            // 线程堆栈大小
                                  8,                              // 线程优先级
                                  20);                            // 时间片
    if(adc_thread == RT_NULL)
      return -1;
    return rt_thread_startup(adc_thread);                         // 启动线程
}

采集土壤湿度，当土壤湿度大于800的时候发送adc事件1，当小于800的时候发送事件2.

继电器控制部分程序：

static void buzz_thread_entry()
{
  rt_err_t result = RT_EOK;
  rt_uint32_t eventVal = 0;
  buzz_init();                                               // LED引脚初始化
  while(1)
  {
      result = rt_event_recv(adc_event,
                                 1|2,// 接收4个按键事件
                                 RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,// 任意一个事件发生，完成后清除事件标志
                                 500,                  // 等待时间
                                 &eventVal);                          // 事件值
      if(result == RT_EOK)
      {
          if(eventVal==1)
          {
              Buzz(1);
          }
          if(eventVal==2)
          {
              Buzz(0);
          }
      }
  }
}

int buzz_thread_init(void)
{
  buzz_thread = rt_thread_create("buzz",             // 线程名称
                                buzz_thread_entry,           // 线程入口函数
                                RT_NULL,                      // 入口函数传入参数
                                256,                            // 线程堆栈大小
                                10,                             // 线程优先级
                                20);                          // 线程时间片

  if(buzz_thread == RT_NULL) return -1;

  return rt_thread_startup(buzz_thread);
}

接收adc发送来的事件进行判断。

温湿度传感器部分程序：

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;
}


static 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!\n");
        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\n", res);
            rt_device_close(dev);
            return;
        }
        else
        {
            if (sensor_data.data.temp >= 0)
            {
               temp = (sensor_data.data.temp & 0xffff) >> 0;      // get temp
               humi = (sensor_data.data.temp & 0xffff0000) >> 16; // get humi
               //rt_kprintf("temp:%d, humi:%d\n" ,temp, humi);
            }
        }

        rt_thread_delay(1000);
    }
}


void 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);
    }
}

使用的是 DHT11的软件包对温湿度进行采集，将温度以及湿度保存。

oled屏幕部分程序：

static void oled_display_entry(void *parameter)
{
    char text[200];
    while(1)
    {
        rt_memset(text, 0, sizeof(text));
        rt_sprintf(text, "%d", temp);
        ssd1306_SetCursor(60, 6);//添加代码，设置显示光标位置
        ssd1306_WriteString(text, Font_11x18, White);//添加代码，设置显示内容
       // ssd1306_UpdateScreen();////添加代码，更新显示屏信息

       rt_memset(text, 0, sizeof(text));
       rt_sprintf(text, "%d", humi);
       ssd1306_SetCursor(60, 40);//添加代码，设置显示光标位置
       ssd1306_WriteString(text, Font_11x18, White);//添加代码，设置显示内容
       ssd1306_UpdateScreen();////添加代码，更新显示屏信息
       rt_thread_mdelay(100);
    }

}

void oled_display_thread_create()
{
    rt_thread_t oled_display_thread;
    oled_display_thread = rt_thread_create("oled_display",
                                      oled_display_entry,
                                      RT_NULL,
                                      1024,
                                      20,
                                      40);
    if (oled_display_thread != RT_NULL)
    {
        rt_thread_startup(oled_display_thread);
    }

}

将采集的温湿度数据显示在屏幕中，使用的是ssd1306 软件包。

项目地址：谭周强/AB32项目 - Gitee.com

第一次用rt_thread做的小项目_哔哩哔哩_bilibili