RT-Thread-AB32VG1之信息采集系统RT-Thread问答社区

AB32VG1之信息采集系统

发布于 2021-05-11 14:27:01 浏览：1024 订阅该版

[tocm]

# 1、信息采集系统介绍
   该系统可实现温度的实时监测(DS18B20)、电压采集(ADC)、温度存储(EEPROM)、温度查询(UART)、信息输出
串口助手使用的是XCOM(自动添加回车和换行)，串口参数为：波特率9600、停止位1、数据位8、无校验。信息查询指令为what's the temp
# 2、硬件
存储设备：AT24C04 引脚15(PB2-SDA)、16(PB1-SCL)
温度监测：DS18B20 引脚PF0
电压采集: ADC0
查询输出：串口通讯 UART1
![PHOTO_20210511_111947562.jpg](https://oss-club.rt-thread.org/uploads/20210511/cb9b3c332b5920d740472a35bf0c1221.jpg)
#3、软件模块
##3.1、各模块基础内容
[AB32VG1测评【ADC外设】](https://club.rt-thread.org/ask/article/2628.html)
[AB32VG1之模拟IIC](https://club.rt-thread.org/ask/article/2755.html)
[AB32VG1之DS18B20的使用](https://club.rt-thread.org/ask/article/2756.html)
[AB32VG1之UART通讯](https://club.rt-thread.org/ask/article/2758.html)
##3.2、电压采集功能
  通过ADC采集ADC0电压AD值，打印实际读取到的转换的原始数据和经过计算后的实际电压值。
  ```
/* 定义线程控制块 */
static rt_thread_t AdcDemo_thread  = RT_NULL;
rt_uint32_t  ADC_VoltageVal = 0;

static int AdcDemo_thread_entry(void* parameter);
static int AdcDemo_thread_entry(void* parameter)
{
    rt_adc_device_t adc_dev;
    rt_uint32_t value, vol;
    rt_err_t ret = RT_EOK;

/* 查找设备 */
    adc_dev = (rt_adc_device_t)rt_device_find(ADC_DEV_NAME);
    if (adc_dev == RT_NULL)
    {
      rt_kprintf("adc sample run failed! can't find %s device!\n", ADC_DEV_NAME);
      return RT_ERROR;
    }
    /* 使能设备 */
    ret = rt_adc_enable(adc_dev, ADC_DEV_CHANNEL);
    while(1)
    {
      /* 读取采样值 */
      value = rt_adc_read(adc_dev, ADC_DEV_CHANNEL);
      rt_kprintf("the value is :%d \n", value);
      /* 转换为对应电压值 */
      vol = value * REFER_VOLTAGE / CONVERT_BITS;
      ADC_VoltageVal = vol;
      rt_kprintf("the voltage is :%d.%02d \n", vol / 100, vol % 100);
      rt_thread_mdelay(1000);
    }
    return ret;
}

void AdcDemo_ThreadInit(void)
{
    AdcDemo_thread =                     /* 线程控制块指针     */
    rt_thread_create( "AdcDemo",         /* 线程名字                */
            AdcDemo_thread_entry,        /* 线程入口函数        */
            RT_NULL,                     /* 线程入口函数参数 */
            1024,                        /* 线程栈大小     */
            3,                           /* 线程的优先级   */
            20);                         /* 线程时间片     */

/* 启动线程，开启调度 */
   if (AdcDemo_thread != RT_NULL)
   {
     rt_thread_startup(AdcDemo_thread);
   }
}
INIT_APP_EXPORT(AdcDemo_ThreadInit);
MSH_CMD_EXPORT(AdcDemo_ThreadInit,AdcDemo);
```
##3.2、温度采集功能
实现采集DS18B20实时温度，在温度值滤波函数中添加每出现一次温度改变超过2℃就写一次EE，并且在打印终端实时温度数据，代码如下：。
```
rt_int32_t DS18B20_Temp = 0;
/* 限幅滤波法（又称程序判断滤波法）
 *  A值可根据实际情况调整
  *  value为有效值，new_value为当前采样值
    滤波程序返回有效的实际值  */
#define A 20  //两度一更新
#define B 100  //两次相差10度认为读取错误
at24cxx_device_t EE_DEV = RT_NULL;

static rt_int32_t filter(rt_int32_t new_value)
{
   static rt_int32_t value    = 0;
   static rt_bool_t  FirstGet = 0;
   static rt_int32_t Count    = 0;
   unsigned char buf[4];
   if(FirstGet != 0)
   {
       if ((abs(new_value - value)> A)&&((abs(new_value - value)< B)))
       {
           buf[0] = (unsigned char)(new_value & 0xFF);
           buf[1] = (unsigned char)((new_value>>8) & 0xFF);
           buf[2] = (unsigned char)((new_value>>16) & 0xFF);
           buf[3] = (unsigned char)((new_value>>24) & 0xFF);
           rt_kprintf("temp:%3d.%dC,write count :%d\n",
                       new_value / 10,
                       new_value % 10,
                       Count++);
           value = new_value;
           at24cxx_write(EE_DEV, 0x01, buf, 4);
           return value;
       }
   }
   else
   {
       buf[0] = (unsigned char)(new_value & 0xFF);
       buf[1] = (unsigned char)((new_value>>8) & 0xFF);
       buf[2] = (unsigned char)((new_value>>16) & 0xFF);
       buf[3] = (unsigned char)((new_value>>24) & 0xFF);
       rt_kprintf("temp:%3d.%dC,write count :%d\n",
                                  new_value / 10,
                                  new_value % 10,
                                  Count++);
       FirstGet = 1;
       value = new_value;
   }
   return new_value;
}

static void read_temp_entry(void *parameter)
{
    rt_device_t dev = RT_NULL;
    struct rt_sensor_data sensor_data;
    rt_size_t res;

dev = rt_device_find(parameter);
    if (dev == RT_NULL)
    {
        rt_kprintf("Can't find device:%s\n", parameter);
        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 *)100);

while (1)
    {
        res = rt_device_read(dev, 0, &sensor_data, 1);
        if (res != 1)
        {
            rt_kprintf("read data failed!size is %d\n", res);
            rt_device_close(dev);
            return;
        }
        else
        {
            DS18B20_Temp  = filter(sensor_data.data.temp);
        }
        rt_thread_mdelay(100);
    }
}
static int ds18b20_read_temp_sample(void)
{
    rt_thread_t ds18b20_thread;

ds18b20_thread = rt_thread_create("18b20tem",
                                      read_temp_entry,
                                      "temp_ds18b20",
                                      1024,
                                      RT_THREAD_PRIORITY_MAX / 2,
                                      20);
    if (ds18b20_thread != RT_NULL)
    {
        rt_thread_startup(ds18b20_thread);
    }

return RT_EOK;
}
INIT_APP_EXPORT(ds18b20_read_temp_sample);
```
##3.3、数据存储功能
  通过添加AT24CXX 软件包，实现每出现一次温度改变超过2℃就调用at24cxx_write(EE_DEV, 0x01, buf, 4);写一次EEPROM。
##3.4、数据打印功能  
  通过添加串口例程，这里添加的是官网UART设备中的第二个例程，既接收到特定内容进行答复，
  程序里实现的是：接收到what's the temp指令，则打印当前采集数据信息，收到其它指令则回复Please check your CMD!。代码如下：
```
#define GET_TEMP_CMD          "what's the temp"
#define SAMPLE_UART_NAME      "uart1"
#define DATA_CMD_END          '\r'       /* 结束位设置为 \r，即回车符 */
#define ONE_DATA_MAXLEN        20        /* 不定长数据的最大长度          */
/* 数据解析线程 */
static void serial_thread_entry(void *parameter)
{
    int8_t ch;
    int8_t data[ONE_DATA_MAXLEN];
    static int8_t i = 0;
    int8_t buf[6];
    int8_t Hundred = 0 ,Dacade = 0,Unit = 0;
    while (1)
    {
        ch = uart_sample_get_char();

if(ch == DATA_CMD_END)
        {
            data[i++] = '\0';
            rt_kprintf("data=%s\r\n",data);
            if(0 == strcmp(data,GET_TEMP_CMD))
            {

if(DS18B20_Temp > 0)//温度为零上
                {
                    //先打印温度
                    rt_kprintf("The current temperature is:%3d.%dC\n",
                                                DS18B20_Temp / 10,
                                                DS18B20_Temp % 10);
                    //串口输出温度
                    Hundred = (int8_t)(DS18B20_Temp / 100);//百位
                    Dacade  = (int8_t)((DS18B20_Temp - Hundred*100) / 10);//十位
                    Unit    = (int8_t)(((DS18B20_Temp - Hundred*100) - Dacade*10));//个位
                    buf[0] = Int2Char(Hundred);
                    buf[1] = Int2Char(Dacade);
                    buf[2] = '.';
                    buf[3] = Int2Char(Unit);
                    buf[4] = '\n';
                    buf[5] = Int2Char(ADC_VoltageVal/100);
                    buf[6] = Int2Char((ADC_VoltageVal%100)/10);
                    buf[7] = '\r';
                    buf[8] = '\n';
                    rt_device_write(serial, 0, buf, 9);
                }
                else
                {
                    //先打印温度
                    rt_kprintf("The current temperature is:-%2d.%dC\n",
                                                -DS18B20_Temp / 10,
                                                -DS18B20_Temp % 10);
                    //串口输出温度
                    Hundred = (int8_t)(-DS18B20_Temp / 100);//百位
                    Dacade  = (int8_t)((-DS18B20_Temp - Hundred*100) / 10);//十位
                    Unit    = (int8_t)(((-DS18B20_Temp - Hundred*100) - Dacade*10));//个位
                    buf[0]  = '-';
                    buf[1]  = Int2Char(Hundred);
                    buf[2]  = Int2Char(Dacade);
                    buf[3]  = '.';
                    buf[4]  = Int2Char(Unit);
                    buf[5] = Int2Char(ADC_VoltageVal/100);
                    buf[6] = Int2Char((ADC_VoltageVal%100)/10);
                    buf[7]  = '\r';
                    buf[8] = '\n';
                    rt_device_write(serial, 0, buf, 9);
                }
            }
            i = 0;
            continue;
        }
        i = (i >= ONE_DATA_MAXLEN-1) ? ONE_DATA_MAXLEN-1 : i;
        data[i++] = ch;
    }
}
/**
  * @brief  thread_serial
  * @param  None
  * @retval ret
  */
int thread_serial(void)
{
    rt_err_t ret = RT_EOK;
    char uart_name[RT_NAME_MAX];
    char str[] = "hello RT-Thread!\r\n";

rt_strncpy(uart_name, SAMPLE_UART_NAME, RT_NAME_MAX);

/* 查找系统中的串口设备 */
    serial = rt_device_find(uart_name);
    if (!serial)
    {
        rt_kprintf("find %s failed!\n", uart_name);
        return RT_ERROR;
    }
    /* 修改串口配置参数 */
    config.baud_rate = BAUD_RATE_9600;        //修改波特率为 9600
    config.data_bits = DATA_BITS_8;           //数据位 8
    config.stop_bits = STOP_BITS_1;           //停止位 1
    config.bufsz     = 64;                   //修改缓冲区 buff size 为 128
    config.parity    = PARITY_NONE;           //无奇偶校验位

/* 控制串口设备。通过控制接口传入命令控制字，与控制参数 */
    rt_device_control(serial, RT_DEVICE_CTRL_CONFIG, &config);

/* 初始化信号量 */
    rt_sem_init(&rx_sem, "rx_sem", 0, RT_IPC_FLAG_FIFO);
    /* 以中断接收及轮询发送模式打开串口设备 */
    rt_device_open(serial, RT_DEVICE_FLAG_INT_RX);
    /* 设置接收回调函数 */
    rt_device_set_rx_indicate(serial, uart_input);
    /* 发送字符串 */
    rt_device_write(serial, 0, str, (sizeof(str) - 1));

/* 创建 serial 线程 */
    rt_thread_t thread = rt_thread_create("serial", serial_thread_entry, RT_NULL, 1024, 25, 10);
    /* 创建成功则启动线程 */
    if (thread != RT_NULL)
    {
        rt_thread_startup(thread);
    }
    else
    {
        ret = RT_ERROR;
    }

return ret;
}
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(thread_serial, uart device sample);
INIT_APP_EXPORT(thread_serial);
```
#4、效果展示
![20210511141359179.png](https://oss-club.rt-thread.org/uploads/20210511/2603ffd0cd68c0241f4b7667660a7f3c.png)

![20210511141413846.png](https://oss-club.rt-thread.org/uploads/20210511/9030af879368b3552760a401152db333.png)
#5、代码
gitee ->[孙继国 / 中科蓝讯 AB32VG1 RISC-V开发板](https://gitee.com/sunjiguo/AB32VG1)
#6、视频展示
[B站](https://m.bilibili.com/video/BV1aU4y1t7un?p=1&share_medium=iphone&share_plat=ios&share_source=WEIXIN&share_tag=s_i×tamp=1620781903&unique_k=WL18aS)
#7、心得体会
   该系统从想法到实现，最主要耗费时间的地方在us级定时器以及串口的回调函数缺失问题的排查，其它的底层程序基本上没有自己动手去编写，仅仅是通过官方例程或者上一批测评代码进行的修改重组，足以说明RT-Thread Studio搭配蓝讯AB32VG1开发板进行小项目的开发是十分便捷的。目前RT-Thread官方论坛日益完善，蓝讯AB32VG1开发板前期测评资料，使得上手更容易，更进一步的学习，需沉心静气深入研究，因本人水平有限，文章内容及代码中可能会出现错误，还请谅解。
   最后祝RT-Thread蒸蒸日上，蓝讯越来越牛！