【野火】瑞萨RA MCU创意氛围赛+无线环境检测小车

wuboy19

【野火】瑞萨RA MCU创意氛围赛+无线环境检测小车
一、项目简介    
本项目旨在基于启明6M5开发板设计一个无线环境监测小车系统，用于监测实验室环境，用户能够通过蓝牙对小车进行控制，并通过onenet云平台进行查看当前环境数据以及历史数据，具体实现功能如下：

• 利用启明6M5开发板完成对温湿度DHT11的温湿度读取。
  
• 利用启明6M5开发板完成对板载esp8266与onenet云平台的数据传输。
  
• 利用启明6M5开发板完成对麦克拉姆轮小车的控制以及蓝牙控制。
  
• 完成onenet云平台的mqtt协议接入。并可视化显示进行部署，实时显示小车温湿度数据。
  

二、项目系统组成整个系统框图：


2.1硬件介绍 启明6M5开发板

• 采用 Arm Cortex-M33 内核的瑞萨 RA 系列 32 位 MCU；
  
• 主芯片为的R7FA6M5BH3CFC，主高达200MHz，2MB的代码闪存，8KB数据闪存，以及512KB的带奇偶校验/ECC的SRAM；
  
• LQFP封装，IO口128个，底板引出未使用的IO口47个。
  

板子实物图如下：

本次项目中使用到了外设如下：

• GPT2、GPT4、GPT6、GPT8用于输出思路PWM输出用于控制麦克拉姆轮的四个轮子的使能端；
  
• SCI4、SCI9用于蓝牙通讯和板载esp8266的通信；
  
• P400用于LED指示程序运行；
  
• GPIO用到的如下表格：
  

小车GPIO以及GPT绑定的引脚使用



l298n



麦克拉姆轮运动可以参考：https://blog.csdn.net/weixin_42108484/article/details/122090548?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522169260570916800188577262%2522%252C%2522scm%2522%253A%252220140713.130102334..%2522%257D&request_id=169260570916800188577262&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~baidu_landing_v2~default-1-122090548-null-null.142%5Ev93%5EchatgptT3_2&utm_term=%E9%BA%A6%E5%85%8B%E6%8B%89%E5%A7%86%E8%BD%AE&spm=1018.2226.3001.4187

RA smart 配置如下：




onenet配置
可以参考链接1：https://blog.csdn.net/m0_37738838/article/details/85012065?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522169260830116800222878194%2522%252C%2522scm%2522%253A%252220140713.130102334..%2522%257D&request_id=169260830116800222878194&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~sobaiduend~default-1-85012065-null-null.142%5Ev93%5EchatgptT3_2&utm_term=onenet%20esp8266%20arduino&spm=1018.2226.3001.4187
可以参考链接2：https://blog.csdn.net/weixin_51651698/article/details/131262456?utm_medium=distribute.pc_relevant.none-task-blog-2~default~baidujs_utm_term~default-4-131262456-blog-85012065.235%5Ev38%5Epc_relevant_anti_vip_base&spm=1001.2101.3001.4242.3&utm_relevant_index=7

DHT11模块    
DHT11 数字温湿度传感器是一款含有已校准数字信号输出的温湿度复合传感器，内部由一个 8 位单片机控制一个电阻式感湿元件和一个 NTC 测温元件。DHT11 虽然也是采用单总线协议，但是该协议与 DS18B20 的单总线协议稍微有些不同之处。
   相比于 DS18B20 只能测量温度，DHT11 既能检测温度又能检测湿度，不过 DHT11 的精度和测量范围都要低于 DS18B20，其温度测量范围为 0~50℃，误差在±2℃；湿度的测量范围为 20%~90%RH（Relative Humidity 相对湿度—指空气中水汽压与饱和水汽压的百分比），误差在±5%RH。DHT11 电路很简单，只需要将 DATA 引脚连接单片机的一个 I/O 即可，不过该引脚需要上拉一个 5K 的电阻，DHT11 的供电电压为 3~5.5V。

6M5接线DHT11


三、项目系统实现

(1)PWM产生
小车需要四路PWM信号，来控制L298N的使能端，来控制电机转速。PWM的频率配置成20Khz是默认电机的频率，然后通过控制占空比来达到控制电机转速/

PWM的核心代码

1. #include "bsp_gpt_pwm_output.h"
   
2. 
   
3. 
   
4. /*  当前选用PWM输出引脚 GTIOC6B P600 */
   
5. 
   
6. 
   
7. /* GPT初始化函数 */
   
8. void GPT6_PWM_Init(void)
   
9. {
   
10.     /* 初始化 GPT 模块 */
    
11.     R_GPT_Open(&g_timer_gpt6_ctrl, &g_timer_gpt6_cfg);
    
12.    
    
13.     /* 启动 GPT 定时器 */
    
14.     R_GPT_Start(&g_timer_gpt6_ctrl);
    
15.    
    
16.     /* 重新设置占空比为 80% */
    
17. //    GPT_PWM_SetDuty(80);
    
18. }
    
19. 
    
20. 
    
21. void GPT4_PWM_Init(void)
    
22. {
    
23.     /* 初始化 GPT 模块 */
    
24.     R_GPT_Open(&g_timer_gpt4_ctrl, &g_timer_gpt4_cfg);
    
25.    
    
26.     /* 启动 GPT 定时器 */
    
27.     R_GPT_Start(&g_timer_gpt4_ctrl);
    
28.    
    
29.     /* 重新设置占空比为 80% */
    
30. //    GPT_PWM_SetDuty(80);
    
31. }
    
32. 
    
33. void GPT8_PWM_Init(void)
    
34. {
    
35.     /* 初始化 GPT 模块 */
    
36.     R_GPT_Open(&g_timer_gpt8_ctrl, &g_timer_gpt8_cfg);
    
37.    
    
38.     /* 启动 GPT 定时器 */
    
39.     R_GPT_Start(&g_timer_gpt8_ctrl);
    
40.    
    
41.     /* 重新设置占空比为 80% */
    
42. //    GPT_PWM_SetDuty(80);
    
43. }
    
44. 
    
45. void GPT2_PWM_Init(void)
    
46. {
    
47.     /* 初始化 GPT 模块 */
    
48.     R_GPT_Open(&g_timer_gpt2_ctrl, &g_timer_gpt2_cfg);
    
49.    
    
50.     /* 启动 GPT 定时器 */
    
51.     R_GPT_Start(&g_timer_gpt2_ctrl);
    
52.    
    
53.     /* 重新设置占空比为 80% */
    
54. //    GPT_PWM_SetDuty(80);
    
55. }
    
56. 
    
57. /** 自定义函数：设置PWM占空比
    
58.     @param duty 占空比范围：0~100 %
    
59. */
    
60. void GPT6_PWM_SetDuty(uint8_t duty)
    
61. {
    
62.     timer_info_t info;
    
63.     uint32_t current_period_counts;
    
64.     uint32_t duty_cycle_counts;
    
65. 
    
66.     if (duty > 100)
    
67.         duty = 100; //限制占空比范围：0~100
    
68. 
    
69.     /* 获得GPT的信息 */
    
70.     R_GPT_InfoGet(&g_timer_gpt6_ctrl, &info);
    
71.    
    
72.     /* 获得计时器一个周期需要的计数次数 */
    
73.     current_period_counts = info.period_counts;
    
74.    
    
75.     /* 根据占空比和一个周期的计数次数计算GTCCR寄存器的值 */
    
76.     duty_cycle_counts = (uint32_t)(((uint64_t) current_period_counts * duty) / 100);
    
77. 
    
78.     /* 最后调用FSP库函数设置占空比 */
    
79.     R_GPT_DutyCycleSet(&g_timer_gpt6_ctrl, duty_cycle_counts, GPT_IO_PIN_GTIOCB);
    
80. }
    
81. 
    
82. void GPT4_PWM_SetDuty(uint8_t duty)
    
83. {
    
84.     timer_info_t info;
    
85.     uint32_t current_period_counts;
    
86.     uint32_t duty_cycle_counts;
    
87. 
    
88.     if (duty > 100)
    
89.         duty = 100; //限制占空比范围：0~100
    
90. 
    
91.     /* 获得GPT的信息 */
    
92.     R_GPT_InfoGet(&g_timer_gpt4_ctrl, &info);
    
93.    
    
94.     /* 获得计时器一个周期需要的计数次数 */
    
95.     current_period_counts = info.period_counts;
    
96.    
    
97.     /* 根据占空比和一个周期的计数次数计算GTCCR寄存器的值 */
    
98.     duty_cycle_counts = (uint32_t)(((uint64_t) current_period_counts * duty) / 100);
    
99. 
    
100.     /* 最后调用FSP库函数设置占空比 */
     
101.     R_GPT_DutyCycleSet(&g_timer_gpt4_ctrl, duty_cycle_counts, GPT_IO_PIN_GTIOCB);
     
102. }
     
103. 
     
104. void GPT8_PWM_SetDuty(uint8_t duty)
     
105. {
     
106.     timer_info_t info;
     
107.     uint32_t current_period_counts;
     
108.     uint32_t duty_cycle_counts;
     
109. 
     
110.     if (duty > 100)
     
111.         duty = 100; //限制占空比范围：0~100
     
112. 
     
113.     /* 获得GPT的信息 */
     
114.     R_GPT_InfoGet(&g_timer_gpt8_ctrl, &info);
     
115.    
     
116.     /* 获得计时器一个周期需要的计数次数 */
     
117.     current_period_counts = info.period_counts;
     
118.    
     
119.     /* 根据占空比和一个周期的计数次数计算GTCCR寄存器的值 */
     
120.     duty_cycle_counts = (uint32_t)(((uint64_t) current_period_counts * duty) / 100);
     
121. 
     
122.     /* 最后调用FSP库函数设置占空比 */
     
123.     R_GPT_DutyCycleSet(&g_timer_gpt8_ctrl, duty_cycle_counts, GPT_IO_PIN_GTIOCB);
     
124. }
     
125. void GPT2_PWM_SetDuty(uint8_t duty)
     
126. {
     
127.     timer_info_t info;
     
128.     uint32_t current_period_counts;
     
129.     uint32_t duty_cycle_counts;
     
130. 
     
131.     if (duty > 100)
     
132.         duty = 100; //限制占空比范围：0~100
     
133. 
     
134.     /* 获得GPT的信息 */
     
135.     R_GPT_InfoGet(&g_timer_gpt2_ctrl, &info);
     
136.    
     
137.     /* 获得计时器一个周期需要的计数次数 */
     
138.     current_period_counts = info.period_counts;
     
139.    
     
140.     /* 根据占空比和一个周期的计数次数计算GTCCR寄存器的值 */
     
141.     duty_cycle_counts = (uint32_t)(((uint64_t) current_period_counts * duty) / 100);
     
142. 
     
143.     /* 最后调用FSP库函数设置占空比 */
     
144.     R_GPT_DutyCycleSet(&g_timer_gpt2_ctrl, duty_cycle_counts, GPT_IO_PIN_GTIOCA);
     
145. }
     

复制代码

（2）串口收发（本作者将stm32的sendstring函数进行一直，实现发送任意长度字符串）
蓝牙串口：该串口核心就是接收蓝牙发送的数据，产生接收中断后对其接收到的字符进行判断。

1. #include "bsp_debug_uart.h"
   
2. #include "string.h"
   
3. #include "stdlib.h"
   
4. #include "led/bsp_led.h"
   
5. #include "gpt/bsp_gpt_pwm_output.h"
   
6. /* 调试串口 UART4 初始化 */
   
7. void Debug_UART4_Init(void)
   
8. {
   
9.     fsp_err_t err = FSP_SUCCESS;
   
10.    
    
11.     err = R_SCI_UART_Open (&g_uart4_ctrl, &g_uart4_cfg);
    
12.     assert(FSP_SUCCESS == err);
    
13. }
    
14. 
    
15. 
    
16. 
    
17. /* 发送完成标志 */
    
18. volatile bool uart_send_complete_flag = false;
    
19. //qianmian
    
20.         //6 4
    
21.         //8 2
    
22. /* 串口中断回调 */
    
23. //void GPT6_FRONT();
    
24. //void GPT6_BEHIND();
    
25. //void GPT6_STOP();
    
26. void debug_uart4_callback (uart_callback_args_t * p_args)
    
27. {
    
28.     switch (p_args->event)
    
29.     {
    
30.         case UART_EVENT_RX_CHAR:
    
31.         {
    
32.             switch (p_args->data)
    
33.             {
    
34.                 case '3':
    
35.                                                                         //前进
    
36.                                                                                 GPT6_FRONT();
    
37.                                                                                 GPT4_FRONT();
    
38.                                                                                 GPT8_FRONT();
    
39.                                                                                 GPT2_FRONT();
    
40.                     break;
    
41.                 case '4':
    
42.                     //后退
    
43.                                                                                 GPT6_BEHIND();
    
44.                                                                                 GPT4_BEHIND();
    
45.                                                                                 GPT8_BEHIND();
    
46.                                                                                 GPT2_BEHIND();
    
47.                     break;
    
48.                 case '5':
    
49.                                                                         //停止
    
50.                     GPT6_STOP();
    
51.                                                                                 GPT4_STOP();
    
52.                                                                                 GPT8_STOP();
    
53.                                                                                 GPT2_STOP();
    
54.                     break;
    
55.                                                                 case '6':
    
56.                                                                         //左旋
    
57.                     GPT6_BEHIND();
    
58.                                                                                 GPT4_FRONT();
    
59.                                                                                 GPT8_FRONT();
    
60.                                                                                 GPT2_BEHIND();
    
61.                     break;
    
62.                                                                
    
63.                                                                 case '7':
    
64.                                                                         //右旋
    
65.                     GPT6_FRONT();
    
66.                                                                                 GPT4_BEHIND();
    
67.                                                                                 GPT8_BEHIND();
    
68.                                                                                 GPT2_FRONT();
    
69.                     break;
    
70.                 default:
    
71.                     break;
    
72.             }
    
73.             break;
    
74.         }
    
75.         case UART_EVENT_TX_COMPLETE:
    
76.         {
    
77.             uart_send_complete_flag = true;
    
78.             break;
    
79.         }
    
80.         default:
    
81.             break;
    
82.     }
    
83. }
    
84. 
    
85. void zero_str(char *str,uint16_t index)
    
86. {
    
87.         int i;
    
88.         for(i=0;i<index;i++)
    
89.         {
    
90.                 *(str+index)='\0';
    
91.         }
    
92. }
    
93. 
    
94. /* 重定向 printf 输出 */
    
95. #if defined __GNUC__ && !defined __clang__
    
96. int _write(int fd, char *pBuffer, int size); //防止编译警告
    
97. int _write(int fd, char *pBuffer, int size)
    
98. {
    
99.     (void)fd;
    
100.     R_SCI_UART_Write(&g_uart4_ctrl, (uint8_t *)pBuffer, (uint32_t)size);
     
101.     while(uart_send_complete_flag == false);
     
102.     uart_send_complete_flag = false;
     
103. 
     
104.     return size;
     
105. }
     
106. #else
     
107. int fputc(int ch, FILE *f)
     
108. {
     
109.     (void)f;
     
110.     R_SCI_UART_Write(&g_uart4_ctrl, (uint8_t *)&ch, 1);
     
111.     while(uart_send_complete_flag == false);
     
112.     uart_send_complete_flag = false;
     
113. 
     
114.     return ch;
     
115. }
     
116. #endif
     
117. 
     
118. 
     
119. 
     
120. 
     
121. 
     
122. 
     

复制代码

onenet串口：该串口在蓝牙串口基础上增加发送字符串函数，由于开始时候为了方便测试。默认printf给蓝牙串口，也就是本机串口使用，所以自行编写串口发送，两者不要同时调用会有bug，虽然配置了优先级。

1. #include "bsp_onenet.h"
   
2. 
   
3. 
   
4. /* 调试串口 UART9 初始化 */
   
5. void onenet_UART9_Init(void)
   
6. {
   
7.     fsp_err_t err = FSP_SUCCESS;
   
8.    
   
9.     err = R_SCI_UART_Open (&g_uart9_ctrl, &g_uart9_cfg);
   
10.     assert(FSP_SUCCESS == err);
    
11. }
    
12. 
    
13. 
    
14. 
    
15. /* 发送完成标志 */
    
16. volatile bool onenet_uart_send_complete_flag = false;
    
17. 
    
18. 
    
19. /* 串口中断回调 */
    
20. void onenet_uart9_callback (uart_callback_args_t * p_args)
    
21. {
    
22.     switch (p_args->event)
    
23.     {
    
24.         case UART_EVENT_RX_CHAR:
    
25.         {
    
26.             /* 把串口接收到的数据发送回去 */
    
27.             R_SCI_UART_Write(&g_uart9_ctrl, (uint8_t *)&(p_args->data), 1);
    
28.             break;
    
29.         }
    
30.         case UART_EVENT_TX_COMPLETE:
    
31.         {
    
32.             onenet_uart_send_complete_flag = true;
    
33.             break;
    
34.         }
    
35.         default:
    
36.             break;
    
37.     }
    
38. }
    
39. 
    
40. void Usart_SendByte( uart_ctrl_t * const pUSARTx, uint8_t ch)
    
41. {
    
42.         /* 发送一个字节数据到USART */
    
43.         R_SCI_UART_Write(pUSARTx, (uint8_t *)&ch, 1);
    
44.                
    
45.         /* 等待发送数据寄存器为空 */
    
46.         while(onenet_uart_send_complete_flag == false)
    
47.         {
    
48.         }
    
49.   onenet_uart_send_complete_flag = false;
    
50. }
    
51. 
    
52. /*****************  发送字符串 **********************/
    
53. void Usart_SendString( uart_ctrl_t * const pUSARTx, char *str)
    
54. {
    
55.         
    
56.         unsigned int k=0;
    
57.   do
    
58.   {
    
59.       Usart_SendByte( pUSARTx, *(str + k) );
    
60.       k++;
    
61.   } while(*(str + k)!='\0');
    
62.   
    
63.   /* 等待发送完成 */
    
64. 
    
65. }
    

复制代码

DHT11读取温湿度：DHT11就是单总线读取，读取后通过格式化字符串写入。

1. #include "bsp_dht11.h"             // Device header
   
2. #include <string.h>
   
3. #include <stdlib.h>
   
4. #include <stdio.h>
   
5. #include "debug_uart/bsp_debug_uart.h"
   
6. DHT11_Data_TypeDef DHT11_Data_my;
   
7. float temperature;
   
8. float hum;
   
9. char T_Data[10]={0};
   
10. char H_Data[10]={0};
    
11. char dis_str[30]={0};
    
12. /* DHT11初始化函数 */
    
13. void DHT11_Init(void)
    
14. {
    
15.     /* 初始化配置引脚（这里重复初始化了，可以注释掉） */
    
16.     R_IOPORT_Open (&g_ioport_ctrl, g_ioport.p_cfg);
    
17. }
    
18. 
    
19. void DHT11_DELAY_US(uint32_t delay)
    
20. {
    
21.     R_BSP_SoftwareDelay(delay, BSP_DELAY_UNITS_MICROSECONDS);
    
22. }
    
23. 
    
24. void DHT11_DELAY_MS(uint32_t delay)
    
25. {
    
26.     R_BSP_SoftwareDelay(delay, BSP_DELAY_UNITS_MILLISECONDS);
    
27. }
    
28. 
    
29. //主机发送开始信号
    
30. void DHT11_Start(void)
    
31. {
    
32. 
    
33.     DHT_HIGH; //先拉高
    
34.     DHT11_DELAY_US(30);
    
35. 
    
36.     DHT_LOW; //拉低电平至少18us
    
37.     DHT11_DELAY_MS(20);
    
38. 
    
39.     DHT_HIGH; //拉高电平20~40us
    
40.     DHT11_DELAY_US(30);
    
41. 
    
42. 
    
43. }
    
44. 
    
45. 
    
46. /*
    
47. * 从DHT11读取一个字节，MSB先行
    
48. */
    
49. static uint8_t Read_Byte(void)
    
50. {
    
51.     uint8_t i, temp=0;
    
52. 
    
53.     for(i=0;i<8;i++)
    
54.     {
    
55.         /*每bit以50us低电平标置开始，轮询直到从机发出 的50us 低电平 结束*/
    
56.         while(Read_Data == Bit_RESET);
    
57. 
    
58.         /*DHT11 以26~28us的高电平表示“0”，以70us高电平表示“1”，
    
59.          *通过检测 x us后的电平即可区别这两个状 ，x 即下面的延时
    
60.          */
    
61.         DHT11_DELAY_US(40); //延时x us 这个延时需要大于数据0持续的时间即可
    
62. 
    
63.         if(Read_Data == Bit_SET)/* x us后仍为高电平表示数据“1” */
    
64.         {
    
65.             /* 等待数据1的高电平结束 */
    
66.             while( Read_Data ==Bit_SET);
    
67. 
    
68.             temp|=(uint8_t)(0x01<<(7-i));  //把第7-i位置1，MSB先行
    
69.         }
    
70.         else     // x us后为低电平表示数据“0”
    
71.         {
    
72.             temp&=(uint8_t)~(0x01<<(7-i)); //把第7-i位置0，MSB先行
    
73.         }
    
74.     }
    
75.     return temp;
    
76. }
    
77. 
    
78. 
    
79. /*
    
80. * 一次完整的数据传输为40bit，高位先出
    
81. * 8bit 湿度整数 + 8bit 湿度小数 + 8bit 温度整数 + 8bit 温度小数 + 8bit 校验和
    
82. */
    
83. uint8_t Read_DHT11(DHT11_Data_TypeDef *DHT11_Data)
    
84. {
    
85.     uint16_t count;
    
86.     DHT11_Start();
    
87.     DHT_HIGH; //拉高电平
    
88. 
    
89.     /*判断从机是否有低电平响应信号 如不响应则跳出，响应则向下运行*/
    
90.     if( Read_Data == Bit_RESET)
    
91.     {
    
92.     count=0;
    
93.         /*轮询直到从机发出 的80us 低电平 响应信号结束*/
    
94.         while( Read_Data ==Bit_RESET)
    
95.         {
    
96.             count++;
    
97.             if(count>1000)
    
98.                     return 0;
    
99.             DHT11_DELAY_US(10);
    
100.         }
     
101. 
     
102.     count=0;
     
103.         /*轮询直到从机发出的 80us 高电平 标置信号结束*/
     
104.         while( Read_Data==Bit_SET)
     
105.         {
     
106.                 count++;
     
107.                 if(count>1000)
     
108.                     return 0;
     
109.                 DHT11_DELAY_US(10);
     
110.         }
     
111.         /*开始接收数据*/
     
112.         DHT11_Data->humi_int= Read_Byte();
     
113. 
     
114.         DHT11_Data->humi_deci= Read_Byte();
     
115. 
     
116.         DHT11_Data->temp_int= Read_Byte();
     
117. 
     
118.         DHT11_Data->temp_deci= Read_Byte();
     
119. 
     
120.         DHT11_Data->check_sum= Read_Byte();
     
121. 
     
122.         DHT_LOW;
     
123.         DHT11_DELAY_US(55);
     
124.         DHT_HIGH;
     
125. 
     
126.         /*检查读取的数据是否正确*/
     
127.         if(DHT11_Data->check_sum == DHT11_Data->humi_int + DHT11_Data->humi_deci + DHT11_Data->temp_int+ DHT11_Data->temp_deci)
     
128.             return 1;
     
129.         else
     
130.             return 0;
     
131.     }
     
132.     else
     
133.     {
     
134.         return 0;
     
135.     }
     
136. }
     
137. void Read_ALL(void)
     
138. {
     
139.         if( Read_DHT11 ( & DHT11_Data_my ) == 1)
     
140.         {
     
141.         
     
142.                 sprintf(T_Data,"%d.%d",DHT11_Data_my.temp_int,DHT11_Data_my.temp_deci);
     
143.                 sprintf(H_Data,"%d.%d",DHT11_Data_my.humi_int,DHT11_Data_my.humi_deci);
     
144.                 temperature=atof(T_Data);
     
145.                 hum=atof(H_Data);
     
146. //                printf("T:%s  H:%s\n",T_Data,H_Data);
     
147. //                delay_ms(50);
     
148. //                printf("i:%d\n",DHT11_Data.temp_int);
     
149. //                printf("d:%d\n",DHT11_Data.temp_deci);
     
150.         }
     
151. }
     
152. 
     

复制代码

esp8266连接onenet：连接onenet主要是通过多协议接入的方法，通过mqtt协议对数据进行传输，然后通过onenet平台的可视化进行对数据显示。

1. #include <ArduinoJson.h>
   
2. #include <ESP8266WiFi.h>
   
3. #include <PubSubClient.h>
   
4. #include <Wire.h>
   
5. String rx_data;
   
6. /********************修改***************************/
   
7. #define wifi_ssid "project_my"          //wifi名称
   
8. #define wifi_password "12345678"    //wifi密码
   
9. /********************不修改***************************/
   
10. #define mqtt_server "183.230.40.39"/*OneNet-MQTT IP不修改*/
    
11. #define mqtt_port 6002/*OneNet-MQTT port不修改*/
    
12. /********************修改***************************/
    
13. #define mqtt_devid ""/*OneNet-MQTT DeviceID设备ID*/
    
14. #define mqtt_pubid ""/*OneNet-MQTT ProductID产品ID*/
    
15. #define mqtt_password ""/*OneNet-MQTT APIkey  master apikey*/
    
16. /********************不修改***************************/
    
17. WiFiClient espClient;
    
18. PubSubClient client(espClient);
    
19. long last_time = 0;
    
20. unsigned short json_len = 0;
    
21. 
    
22. /********************修改***************************/
    
23. char dataDHT11[] = "{"temp":%.2f, "hum":%.2f, "pressure":%d}";//dataDHT11位输出的名称  temp、hump为onenet上数据流名称 %0.2f为数据类型
    
24. char msgJson[100];//根据数据总名称+数据长度而定，长的话可以改
    
25. char msg_buf[200];//根据数据总名称+数据长度而定，长的话可以改
    
26. 
    
27. float temperature;//传感器数据，这里使用假数据，视自己情况而定
    
28. float hum;
    
29. int pressure;
    
30. /********************不修改***************************/
    
31. String getstringfromdata(String source_str,String str_start,String str_end)//字符串提取函数
    
32. {
    
33.     String getstring_temp="";
    
34.     if(source_str.equals(""))
    
35.     {
    
36.       return "";
    
37.     }
    
38.     else
    
39.     {
    
40.         getstring_temp=source_str.substring(source_str.indexOf(str_start)+1,source_str.indexOf(str_end));
    
41.         return getstring_temp;
    
42.     }
    
43. }
    
44. void setup()
    
45. {
    
46.   Serial.begin(115200);
    
47.   client.setServer(mqtt_server, mqtt_port);
    
48.   client.setCallback(mqtt_callback);
    
49. }
    
50. 
    
51. void setup_wifi()
    
52. {
    
53.   Serial.println();
    
54.   Serial.print("Connecting to ");
    
55.   Serial.println(wifi_ssid);
    
56.   WiFi.begin(wifi_ssid, wifi_password);
    
57.   Serial.println("--WiFi connected");
    
58.   Serial.println("IP address: ");
    
59.   Serial.println(WiFi.localIP());
    
60. }
    
61. 
    
62. void mqtt_callback(char* topic, byte* payload, unsigned int length)//
    
63. {
    
64.   Serial.print("Message arrived [");
    
65.   Serial.print(topic);
    
66.   Serial.print("] ");
    
67.   for (int i = 0; i < length; i++)
    
68.   {
    
69.     Serial.print((char)payload[i]);
    
70.   }
    
71.   Serial.println();
    
72. 
    
73.   DynamicJsonDocument doc(1024);
    
74.   deserializeJson(doc, payload);
    
75.   JsonObject obj = doc.as<JsonObject>();
    
76. }
    
77. 
    
78. void reconnect()
    
79. {
    
80.   while (!client.connected())
    
81.   {
    
82.     Serial.print("Attempting MQTT connection...");
    
83.     if (client.connect(mqtt_devid, mqtt_pubid, mqtt_password))//连接MQTT服务器
    
84.     {
    
85.       Serial.println("connected");
    
86.     }
    
87.     else
    
88.     {
    
89.       Serial.print("failed, rc=");
    
90.       Serial.print(client.state());
    
91.       Serial.println(" try again in 2s");
    
92.       delay(2000);
    
93.     }
    
94.   }
    
95. }
    
96. 
    
97. void loop()
    
98. {
    
99.   /********************修改***************************/
    
100.   
     
101. 
     
102.   delay(200);
     
103. /********************不修改***************************/
     
104.   if(WiFi.status() != WL_CONNECTED)
     
105.   {
     
106.     setup_wifi();
     
107.   }
     
108.   
     
109.   if (!client.connected())
     
110.   {
     
111.     reconnect();
     
112.   }
     
113.   client.loop();
     
114. 
     
115.   long now = millis();
     
116.   if (now - last_time > 3000)
     
117.   {
     
118.     last_time = now;
     
119.       /********************修改***************************/
     
120.       // dataDHT11为setup()之前设置的要上传的数组，temperature, humidity,press,ax为%0.2f替换的内容  100为数组最大长度，如果数据多，就改大一点
     
121.     snprintf(msgJson, 100, dataDHT11, temperature, hum,pressure);
     
122.       /********************不修改***************************/
     
123.     Serial.print(msgJson);
     
124.      
     
125.     memset(msg_buf, 0, 200);
     
126.     json_len = strlen(msgJson);                     //packet length count the end char '\0'
     
127.     msg_buf[0] = char(0x03);                        //palyLoad packet byte 1, one_net mqtt Publish packet payload byte 1, type3 , json type2
     
128.     msg_buf[1] = char(json_len >> 8);               //high 8 bits of json_len (16bits as short int type)
     
129.     msg_buf[2] = char(json_len & 0xff);             //low 8 bits of json_len (16bits as short int type)
     
130. 
     
131.     memcpy(msg_buf + 3, msgJson, strlen(msgJson));
     
132. 
     
133.     Serial.print("Lngth of published message: ");
     
134.     client.publish("$dp", (uint8_t*)msg_buf, 3 + strlen(msgJson));  //   msg_buf as payload length which may have a "0x00"byte
     
135.     Serial.println(strlen(msgJson));
     
136.   }
     
137. }
     
138. //串口中断入口
     
139. void serialEvent()
     
140. {
     
141.   rx_data="";
     
142.   while (Serial.available())
     
143.   {
     
144.     rx_data += char(Serial.read());
     
145.     delay(2); //这里不能去掉，要给串口处理数据的时间
     
146.   }
     
147.   Serial.println(rx_data);
     
148.   temperature=(getstringfromdata(rx_data,"a","b")).toFloat();
     
149.   hum=(getstringfromdata(rx_data,"b","c")).toFloat();
     
150.   pressure=(getstringfromdata(rx_data,"c","d")).toInt();
     
151. }
     

复制代码

四、项目成果展示

（1）开始时候是使用灯来看四路PWM是否输出，以及对应IN1和IN2是否输出。（确认无误后将其和电机对应使能和IN脚相接）

（2）onenet实时显示温湿度数据


（3）蓝牙助手界面


（4）整体实物以及运动视频

视频链接：https://www.bilibili.com/video/BV13u4y1i7zj/
mycode.zip (1.26 MB, 下载次数: 11)

2023-8-22 18:22 上传

点击文件名下载附件
代码