ESA2GJK1DH1K基础篇: APP使用SmartConfig绑定Wi-Fi 设备并通过MQTT控制设备(SimplePackage)

/**
* @brief   发送MQTT数据
* 把发送数据给网络模块的函数放在此处
* @param   buffer   发送的数据
* @param   length   数据长度
* @retval  None
* @warning None
* @example
**/
void mqtt_send_function(mqtt_t *mqtt)
{
    /*有缓存的数据需要发送;同时未启动超时检测*/
    if(mqtt->buff_manage_struct_t.SendLen !=0 && mqtt->timer_out_cnt<=0)//需要发送数据
    {
        if(mqtt_get_type(mqtt->send_buff) == MQTT_MSG_TYPE_SUBSCRIBE){//发送的消息是订阅
            mqtt->mqtt_message_id = mqtt_get_id(mqtt->send_buff, mqtt->buff_manage_struct_t.SendLen);//获取消息ID
            mqtt->mqtt_message_type = MQTT_MSG_TYPE_SUBSCRIBE;
            mqtt->timer_out_cnt = mqtt_timerout_default;//设置超时时间
        }
        else if(mqtt_get_type(mqtt->send_buff) == MQTT_MSG_TYPE_PUBLISH){//发送的消息是发布
            if(mqtt_get_qos(mqtt->send_buff) == 1 || mqtt_get_qos(mqtt->send_buff) == 2)//消息等级是1或者2
            {
                mqtt->mqtt_message_id = mqtt_get_id(mqtt->send_buff, mqtt->buff_manage_struct_t.SendLen);//获取消息ID,以便应答
                mqtt->mqtt_message_type = MQTT_MSG_TYPE_PUBLISH;
                mqtt->timer_out_cnt = mqtt_timerout_default;//设置超时时间
            }
        }
        //使用串口发送数据(发给网络模块):请替换自己的发送函数
        //mqtt->send_buff:发送的数据
        //mqtt->buff_manage_struct_t.SendLen:发送的数据长度
        //Send function
        UsartOutStrIT(mqtt->send_buff,mqtt->buff_manage_struct_t.SendLen);//请替换自己的发送函数
        mqtt->buff_manage_struct_t.SendLen=0;
    }
}


/**
* @brief   接收处理MQTT数据
*用户需要把网络模块接收到的MQTT数据传给此函数处理
* @param   buffer   接收的MQTT数据
* @param   length   数据长度
* @retval  None
* @warning None
* @example
**/
void mqtt_read_function(mqtt_t *mqtt,unsigned char* buffer, uint16_t length)
{
    uint8_t msg_type;
    uint8_t msg_qos;
    uint16_t msg_id;
    
    msg_type = mqtt_get_type(buffer);
    msg_qos = mqtt_get_qos(buffer);
    msg_id = mqtt_get_id(buffer, length);
    
    if(mqtt->mqtt_message_type == MQTT_MSG_TYPE_SUBSCRIBE){//上次发送的是订阅主题
        mqtt_keep_alive_init(mqtt);//初始化心跳包变量
        //上次发送的消息是订阅
        if(msg_type == MQTT_MSG_TYPE_SUBACK){//获取应答
            mqtt->timer_out_cnt = 0;//停止超时定时器
            
            if(msg_id == mqtt->mqtt_message_id && ( buffer[length-1]&0xff) != 0x80 )
            {
                mqtt->mqtt_message_type = MQTT_MSG_TYPE_SUBACK;
                if(mqtt->subscribedCb!=NULL){
                    mqtt->subscribedCb(mqtt->mqtt_message_id);
                }
            }
            else
            {
                mqtt->mqtt_message_type = 0;
                if(mqtt->failsubscribedCb!=NULL)mqtt->failsubscribedCb(mqtt->mqtt_message_id);
            }
        }
        else{
            mqtt->mqtt_message_type = 0;
            if(mqtt->failsubscribedCb!=NULL)mqtt->failsubscribedCb(mqtt->mqtt_message_id);
        }
    }
    
    switch (msg_type)
    {
        case MQTT_MSG_TYPE_PUBLISH://接收到消息
            mqtt_keep_alive_init(mqtt);//初始化心跳包变量
            if (msg_qos == 1){//消息等级是1,打包需要返回的PUBACK数据
                mqtt->mqtt_send_data_len = mqtt_msg_puback(msg_id,&mqtt->ptr,mqtt->mqtt_data_buff,mqtt_send_buff_len);
            }
            else if (msg_qos == 2){//消息等级是2,打包需要返回的PUBREC
                mqtt->mqtt_send_data_len = mqtt_msg_pubrec(msg_id,&mqtt->ptr,mqtt->mqtt_data_buff,mqtt_send_buff_len);
            }
            
            if (msg_qos == 1 || msg_qos == 2) {
                    if(mqtt->mqtt_send_data_len >0 ){                        
                        BufferManageWrite(&mqtt->buff_manage_struct_t,mqtt->ptr,mqtt->mqtt_send_data_len);/*把协议存入存入缓存*/
                }
            }
            
            //调用接收回调函数
            if(mqtt->recCb){
                mqtt->topic_length = length;
                mqtt->topic = mqtt_get_publish_topic(buffer, &mqtt->topic_length);
                mqtt->data_length = length;
                mqtt->data = mqtt_get_publish_data(buffer, &mqtt->data_length);
                
                mqtt->recCb(mqtt->topic,mqtt->topic_length,mqtt->data,mqtt->data_length);
            }
            break;
            
        case MQTT_MSG_TYPE_PUBACK://客户端上次发送了消息等级是1的消息,服务器返回PUBACK,说明消息已经送达
            if(mqtt->mqtt_message_type == MQTT_MSG_TYPE_PUBLISH && mqtt->mqtt_message_id == msg_id){
                mqtt->mqtt_message_type = 0;
                mqtt->timer_out_cnt = 0;//停止超时定时器
                if(mqtt->PublishedCb){
                    mqtt->PublishedCb();
                }
            }
            break;
        
        case MQTT_MSG_TYPE_PUBREC://客户端上次发送了消息等级是2的消息,服务器返回PUBREC,客户端需要返回PUBREL
            mqtt->mqtt_send_data_len = mqtt_msg_pubrel(msg_id,&mqtt->ptr,mqtt->mqtt_data_buff,mqtt_send_buff_len);
        
            //使用串口发送数据(发给网络模块):请替换自己的发送函数
            //mqtt->ptr:发送的数据
            //mqtt->mqtt_send_data_len:发送的数据长度
            //Send function
            UsartOutStrIT(mqtt->ptr,mqtt->mqtt_send_data_len);//请替换自己的发送函数
            break;
        case MQTT_MSG_TYPE_PUBCOMP://客户端上次发送了消息等级是2的消息,服务器返回PUBREC,客户端返回了PUBREL,服务器最后返回PUBCOMP,说明消息已经送达
            if (mqtt->mqtt_message_type == MQTT_MSG_TYPE_PUBLISH && mqtt->mqtt_message_id == msg_id) {
                mqtt->mqtt_message_type = 0;
                mqtt->timer_out_cnt = 0;//停止超时定时器
                if(mqtt->PublishedCb){
                    mqtt->PublishedCb();
                }
            }
            break;
        case MQTT_MSG_TYPE_PUBREL://客户端收到了消息等级为2的消息,同时回复了PUBREC,服务器返回PUBREL,客户端最后需要返回PUBCOMP
            mqtt->mqtt_send_data_len = mqtt_msg_pubcomp(msg_id,&mqtt->ptr,mqtt->mqtt_data_buff,mqtt_send_buff_len);
            
            BufferManageWrite(&mqtt->buff_manage_struct_t,mqtt->ptr,mqtt->mqtt_send_data_len);/*把协议存入存入缓存*/
            break;
        case MQTT_MSG_TYPE_PINGRESP://接收到心跳包数据
                mqtt_keep_alive_init(mqtt);//初始化心跳包变量
            break;
        
        default:
            break;
    }
}