手把手教你基于MM32与BC26搭建OneNET云平台应用

void BC26_InitBuffer(void)

{

    BC26_Length = 0;

    memset(BC26_Buffer, 0, sizeof(BC26_Buffer));

}



void BC26_SendData(uint8_t Data)

{

    UART_SendData(UART1, Data);

    while(UART_GetFlagStatus(UART1, UART_IT_TXIEN) == RESET);

}



void BC26_SendString(char *str)

{

    while(*str)

    {

        BC26_SendData(*str++);

    }

}



uint8_t BC26_AT_WaitForReply(char *Keyword)

{

    while(QUEUE_EMPTY(UART1_RX_IDX) == 0)

    {

        BC26_Buffer[BC26_Length++] = QUEUE_READ(UART1_RX_IDX);



        if(strstr((char *)BC26_Buffer, Keyword) != NULL)

        {

            return 1;

        }

    }



    return 0;

}



void BC26_AT_DisplayReply(void)

{

    OLED_Clear(0x00);  OLED_Display((char *)BC26_Buffer);  SysTick_DelayMS(999);

}



uint32_t BC26_AT_SendCommand(char *Command, char *Response, uint32_t Timeout)

{

    if(Command != NULL)

    {

        QUEUE_INIT(UART1_RX_IDX);



        BC26_SendString(Command);

        BC26_SendString("\r\n" );

    }



    if(Timeout != 0)

    {

        BC26_InitBuffer();



        while(Timeout--)

        {

            if(BC26_AT_WaitForReply(Response) != 0)

            {

                BC26_AT_DisplayReply();   return 1;

            }



            SysTick_DelayMS(1);

        }



        return 0;

    }



    return 1;

}



void BC26_InitUART(void)

{

    GPIO_InitTypeDef GPIO_InitStructure;

    NVIC_InitTypeDef NVIC_InitStructure;

    UART_InitTypeDef UART_InitStructure;



    RCC_APB2PeriphClockCmd(RCC_APB2Periph_UART1, ENABLE);



    UART_StructInit(&UART_InitStructure);

    UART_InitStructure.UART_BaudRate            = 9600;

    UART_InitStructure.UART_WordLength          = UART_WordLength_8b;

    UART_InitStructure.UART_StopBits            = UART_StopBits_1;

    UART_InitStructure.UART_Parity              = UART_Parity_No;

    UART_InitStructure.UART_HardwareFlowControl = UART_HardwareFlowControl_None;

    UART_InitStructure.UART_Mode                = UART_Mode_Rx | UART_Mode_Tx;

    UART_Init(UART1, &UART_InitStructure);



    NVIC_InitStructure.NVIC_IRQChannel = UART1_IRQn;

    NVIC_InitStructure.NVIC_IRQChannelPriority = 3;

    NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE;

    NVIC_Init(&NVIC_InitStructure);



    UART_ITConfig(UART1, UART_IT_RXIEN, ENABLE);

    UART_Cmd(UART1, ENABLE);



    RCC_AHBPeriphClockCmd(RCC_AHBPeriph_GPIOA, ENABLE);



    GPIO_PinAFConfig(GPIOA, GPIO_PinSource9,  GPIO_AF_1);

    GPIO_PinAFConfig(GPIOA, GPIO_PinSource10, GPIO_AF_1);



    GPIO_StructInit(&GPIO_InitStructure);

    GPIO_InitStructure.GPIO_Pin   = GPIO_Pin_9;

    GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;

    GPIO_InitStructure.GPIO_Mode  = GPIO_Mode_AF_PP;

    GPIO_Init(GPIOA, &GPIO_InitStructure);



    GPIO_InitStructure.GPIO_Pin   = GPIO_Pin_10;

    GPIO_InitStructure.GPIO_Mode  = GPIO_Mode_IN_FLOATING;

    GPIO_Init(GPIOA, &GPIO_InitStructure);

}



void UART1_IRQHandler(void)

{

    if(UART_GetITStatus(UART1, UART_IT_RXIEN) != RESET)

    {

        QUEUE_WRITE(UART1_RX_IDX, UART_ReceiveData(UART1));

        UART_ClearITPendingBit(UART1, UART_IT_RXIEN);

    }

}



void BC26_StartProcess(void)

{

    BC26_AT_SendCommand("AT",           "OK", 500);



    BC26_AT_SendCommand("AT+CPIN?",     "OK", 500);



    BC26_AT_SendCommand("AT+CSQ",       "OK", 500);



    BC26_AT_SendCommand("AT+CEREG?",    "OK", 500);



    BC26_AT_SendCommand("AT+CGPADDR?",  "OK", 500);



    /* 设置MQTT协议版本 */

    BC26_AT_SendCommand("AT+QMTCFG=\"version\",0,1", "OK", 500);



    /* 打开MQTT客户端网络 */

    BC26_AT_SendCommand("AT+QMTOPEN=0,\"studio-mqtt.heclouds.com\",1883", "+QMTOPEN: 0,0", 5000);



    /* 连接客户端至MQTT服务器 */

    BC26_AT_SendCommand("AT+QMTCONN=0,\"BC26_001\",\"OV9DtD7QIm\",\"version=2018-10-31&res=products%2FOV9DtD7QIm%2Fdevices%2FBC26_001&et=1672502399&method=md5&sign=QMYMEAx06v6zgoXB%2Fh5zgA%3D%3D\"", "+QMTCONN: 0,0,0", 5000);



    /* 订阅主题：设备属性上报的响应 */

    BC26_AT_SendCommand("AT+QMTSUB=0,1,\"$sys/OV9DtD7QIm/BC26_001/thing/property/post/reply\",0", "OK", 5000);

}



void BC26_Init(void)

{

    BC26_InitUART();



    BC26_StartProcess();



    TASK_Append(TASK_ID_BC26, BC26_Handler, 10000);

}



void BC26_Handler(void)

{

    static uint8_t Control = 0;

    uint8_t Result = 0;



    if(Control == 0)

    {

        Control = 1;

        Result = BC26_AT_SendCommand("AT+QMTPUB=0,0,0,0,\"$sys/OV9DtD7QIm/BC26_001/thing/property/post\",72,\"{\"id\":\"12345\",\"version\":\"1.0\",\"params\":{\"Lock_control\":{\"value\":true}}}}\"",  "OK", 5000);

    }

    else

    {

        Control = 0;

        Result = BC26_AT_SendCommand("AT+QMTPUB=0,0,0,0,\"$sys/OV9DtD7QIm/BC26_001/thing/property/post\",73,\"{\"id\":\"12345\",\"version\":\"1.0\",\"params\":{\"Lock_control\":{\"value\":false}}}}\"", "OK", 5000);

    }



    if(Result != 0)

    {

        OLED_Display("Control Publish OK");

    }

    else

    {

        OLED_Display("Control Publish Error");

    }

}



void BC26_KEY_Handler(uint8_t Flag)

{

    uint8_t Result = 0;



    /* 发布消息：设备属性上报 */

    if(Flag)

    {

        Result = BC26_AT_SendCommand("AT+QMTPUB=0,0,0,0,\"$sys/OV9DtD7QIm/BC26_001/thing/property/post\",71,\"{\"id\":\"12345\",\"version\":\"1.0\",\"params\":{\"Lock_status\":{\"value\":true}}}}\"",  "OK", 5000);

    }

    else

    {

        Result = BC26_AT_SendCommand("AT+QMTPUB=0,0,0,0,\"$sys/OV9DtD7QIm/BC26_001/thing/property/post\",72,\"{\"id\":\"12345\",\"version\":\"1.0\",\"params\":{\"Lock_status\":{\"value\":false}}}}\"", "OK", 5000);

    }



    if(Result != 0)

    {

        OLED_Display("Status Publish OK");

    }

    else

    {

        OLED_Display("Status Publish Error");

    }

}