STM32+NB-IoT（M5311）模组对接OneNET教程-HAL库

原理图

了解NB-iot程序流程

1、PWRKEY引脚至少拉低两秒（相当于使能）

2、通过 AT+MQTTCFG 指令进行MQTT内容设置，下面是OneNet举例（其他平台可能会有区别）

u1_printf("AT+MQTTCFG=183.230.40.39,6002,%s,120,%s,%s,1,0\r\n", \

DEVID, PROID, APIKEY); //设置MQTT信息

3、等待模块返回IP地址数据（数据模块检测到物联网卡，且已经连接了网络），返回数据以+IP:开头

4、确认模块连接网络后通过 AT+MQTTOPEN=1,1,0 指令进行MQTT连接，并确认连接是否连接成功，成功返回+MQTTOPEN: OK

5、接下来就可以通过 AT+MQTTPUB 发送数据指令进行发送，下面是OneNet举例

/* 发送指令，并设置发送长度 */
	u1_printf("AT+MQTTPUB=$dp,0,1,0,%d,03%.2X%.2X", Send_Len+3, Send_Len/256, Send_Len%256);
	for(i=0; i<Send_Len; i++) //数据发送--HEX形式发送
	u1_printf("%.2X", NB_Send_Buf[i]);
	u1_printf("\r\n");

发送时需要将数据转换成HEX格式

获取相关信息

如何创建OneNET产品设备，大家可以参考一下文章

创建产品设备，点击前往

完成后需要获取以下信息

#define DEVID "857640***"      //设备ID
#define PROID "472**0"         //产品ID
#define APIKEY "=0jEeHtkkvt0pF0=O***********"  //产品APIkey

上面信息获取之后，我们就需要创建属于我们的程序了

程序创建

打开STM32cubeMX,没有下载的，点击前往

程序相对来说比较乱，有兴趣的朋友可以自己整理。

创建完成工程之后

设置定时器为1ms进入中断

定时器设置完成之后，设置串口，串口信息如下图所示，记住：需要开启中断！

程序编写

//包含基础库
#include "stdio.h"
#include "string.h"

//重定义串口
#define PWRKEY(a) (a?HAL_GPIO_WritePin(PWRKEY_GPIO_Port, PWRKEY_Pin, GPIO_PIN_SET):HAL_GPIO_WritePin(PWRKEY_GPIO_Port, PWRKEY_Pin, GPIO_PIN_RESET))

uint8_t USART1_TX_BUF[300];
#define u1_printf(...)  HAL_UART_Transmit(&huart1,USART1_TX_BUF,sprintf((char *)USART1_TX_BUF,__VA_ARGS__),0xffff)

uint8_t USART2_TX_BUF[200];
#define u2_printf(...)  HAL_UART_Transmit(&huart2,USART2_TX_BUF,sprintf((char *)USART2_TX_BUF,__VA_ARGS__),0xffff)

//重定义服务器信息
#define DEVID "85764***"      //设备ID
#define PROID "4720**"         //产品ID
#define APIKEY "=0jEeHtkkvt0pF0=OXNQDl******"  //产品APIkey

//变量定义
uint8_t uart1_value;
uint16_t time_1ms,time_500ms;
uint8_t uart1_buf[36],uart1_time,uart1_num;
uint8_t uart1_rx__flag;

uint8_t NB_Flag; //NB标志位
uint16_t NB_Time; //NB模块计时变量
uint8_t NB_Send; //NB模块发送函数
uint8_t NB_Send_Buf[300]; //发送缓存数组
uint16_t Send_Len; //发送长度变量

//初始化定时器串口
	HAL_TIM_Base_Start_IT(&htim1);
	HAL_UART_Receive_IT(&huart1, &uart1_value, 1);
//初始化NB-iot模块
	PWRKEY(0);
	HAL_Delay(2000);
	PWRKEY(1);

通过MQTT协议连接OneNET，以及处理下发的数据

if(uart1_rx__flag == 1) //串口接收到一帧数据
		{
			uart1_rx__flag = 0;

			if(NB_Flag == 0) //判断是否接收到信号
			{
				if(strstr((char *)uart1_buf, "+IP") != NULL) //NB模块检测到物联网卡信号
				{
					NB_Flag = 1;
					u1_printf("AT+MQTTOPEN=1,1,0\r\n"); //发送连接指令
					NB_Flag = 2;
				}
			}
			else if(NB_Flag == 2) //判断MQTT是否连接成功
			{
				if(strstr((char *)uart1_buf, "+MQTTOPEN: OK") != NULL) //MQTT连接成功
				{
					NB_Flag = 3;
				}
			}
			else                 	//处理云下发数据
			{
				STAT = strstr((char *)uart1_buf, "STAT");
				if(STAT != NULL)
				{
					STAT += 4;
					if((*STAT-'0')&&(flag_stat == 0))
					{
						flag_stat = 1;
						Motor_Foreward();
					}
					else if(((*STAT-'0')==0)&&(flag_stat == 1))
					{
						flag_stat = 0;
						Motor_Reversal();
					}
				}
				MODE = strstr((char *)uart1_buf, "MODE");
				if(MODE != NULL)
				{
					MODE += 4;
					flag_mode=*MODE-0x30;
				}
			}
		}

上报数据到服务器

		uint16_t i;
		if(NB_Send == 1)
		{
			NB_Send = 0;
			if(NB_Flag == 3)
			{
				/* 发送数据整合 */
				sprintf((char *)NB_Send_Buf, \
								"{\"pos\":{\"lon\":%f,\"lat\":%f},\"Temp\":%.1f,\"Humi\":%.1f,\"MQ3\":%d}", \
								34.12, 34.12, 34.12, 34.12, 12);
				Send_Len = strlen((char *)NB_Send_Buf);
				/* 发送指令，并设置发送长度 */
				u1_printf("AT+MQTTPUB=$dp,0,1,0,%d,03%.2X%.2X", Send_Len+3, Send_Len/256, Send_Len%256);

				for(i=0; i<Send_Len; i++) //数据发送--HEX形式发送
					u1_printf("%.2X", NB_Send_Buf[i]);
				u1_printf("\r\n");
			}
			else
			{
				u1_printf("AT+MQTTCFG=183.230.40.39,6002,%s,120,%s,%s,1,0\r\n", DEVID, PROID, APIKEY); //设置MQTT信息
			}
		}

定时器中断回调函数

void HAL_TIM_PeriodElapsedCallback(TIM_HandleTypeDef *htim)
{
	if(htim->Instance == htim1.Instance)		//定时器1触发中断
	{
		time_1ms++;
		if(time_1ms>= 500)
		{
			time_1ms= 0;
			time_500ms = 1;
		}
		NB_Time++;
		if(NB_Time >= 3000) //每3S向发送一次数据
		{
			NB_Time = 0;
			NB_Send = 1;
		}

		if(uart1_num != 0)
		{
			uart1_time++;
			if(uart1_time >= 10)			//一帧数据接受完成
			{
				uart1_time = 0;
				uart1_num = 0;
				uart1_rx__flag = 1;
			}
		}

	}
}

串口中断回调函数

void HAL_UART_RxCpltCallback(UART_HandleTypeDef *huart)
{
	if(huart->Instance == huart1.Instance)//串口1触发中断
	{
		HAL_UART_Receive_IT(&huart1, &uart1_value, 1);
		uart1_buf[uart1_num++] = uart1_value;
		uart1_time = 0;
	}
}