【开发者成长激励计划-基于TencentOS Tiny 云控制转CAN通信控制电机】

void application_entry(void *arg)
{
    tos_sem_create(&canrx, 0);
    tos_sem_create(&cjson_hdl, 0);
    tos_task_create(&lcddisp, "lcddisp", lcddisp_entry, NULL, 7, lcddisp_stk, LCDDISP_STK_SIZE, 0); // Create task1
    tos_task_create(&can_tx, "can_tx", cantx_entry, NULL, 4, can_tx_stk, CAN_TX_STK_SIZE, 0);// Create task2
    tos_task_create(&can_rx, "can_rx", canrx_entry, NULL, 5, can_rx_stk, CAN_RX_STK_SIZE, 0);// Create task3
    tos_task_create(&mqtt_task, "mqtt_task", mqtt_task_entry, NULL, 6, mqtt_task_stk, MQTT_TASK_STK_SIZE, 0);// Create task4
}

void default_message_handler(mqtt_message_t* msg)   //\\\"brightness\\\":%d\\,
{
    cJSON *root;
    cJSON *params;
//    cJSON *token;
    cJSON *method;
    cJSON *power_switch;
//    cJSON *brightness_level;

    printf("callback:\r\n");
    printf("---------------------------------------------------------\r\n");
    printf("\ttopic:%s\r\n", msg->topic);
    printf("\tpayload:%s\r\n", msg->payload);
    printf("---------------------------------------------------------\r\n");

    // 1. 解析从云端收到的控制信息，示例控制信息为
    //payload:"{"method":"control","clientToken":"clientToken-4902Qhq74","params":{"switch_1":1}}"
    root = cJSON_Parse(msg->payload +1);
    if (!root){
        printf("Invalid json root\r\n");
        return;
    }

    // 2. 解析出method
    method = cJSON_GetObjectItem(root, "method");
    if (!method){
        printf("Invalid json method\r\n");
        cJSON_Delete(root);
        return;
    }

    // 3. 仅处理云端下发的 control 数据，report_reply暂不处理
    if (0 != strncmp(method->valuestring, "control", sizeof("control") - 1)){
        cJSON_Delete(root);
        return;
    }

    // 4. 解析出params
    params = cJSON_GetObjectItem(root, "params");
    if (!params){
        printf("Invalid json params\r\n");
        cJSON_Delete(root);
        return;
    }
    // 1. 解析出 power_switch
    power_switch = cJSON_GetObjectItem(params, "switch_1");
    // 2. 根据 power_switch 控制实际硬件开关
    if (power_switch){
        iot_explorer_handle_power_switch(power_switch->valueint);
    }

    cJSON_Delete(root);
}

char payload[256] = {0};
static char report_topic_name[TOPIC_NAME_MAX_SIZE] = {0};
static char report_reply_topic_name[TOPIC_NAME_MAX_SIZE] = {0};

void mqtt_demo_task(void)
{
    int ret = 0;
    int size = 0;
    //int lightness = 0;
    //int color=0;
    //float voltage = 0.0;
    mqtt_state_t state;

    char *product_id = PRODUCT_ID;
    char *device_name = DEVICE_NAME;
    char *key = DEVICE_KEY;

    device_info_t dev_info;
    memset(&dev_info, 0, sizeof(device_info_t));

    /**
     * Please Choose your AT Port first, default is HAL_UART_2(USART2)
    */
    ret = esp8266_tencent_firmware_sal_init(HAL_UART_PORT_2);

    if (ret < 0) {
        printf("esp8266 tencent firmware sal init fail, ret is %d\r\n", ret);
    }

    //esp8266_tencent_firmware_join_ap("TP-LINK_0F58", "hhyf1bhhyf1b");
    esp8266_tencent_firmware_join_ap("CU_VSVC", "iya8j5tt");

    strncpy(dev_info.product_id, product_id, PRODUCT_ID_MAX_SIZE);
    strncpy(dev_info.device_name, device_name, DEVICE_NAME_MAX_SIZE);
    strncpy(dev_info.device_serc, key, DEVICE_SERC_MAX_SIZE);
    tos_tf_module_info_set(&dev_info, TLS_MODE_PSK);

    mqtt_param_t init_params = DEFAULT_MQTT_PARAMS;
    if (tos_tf_module_mqtt_conn(init_params) != 0) {
        printf("module mqtt conn fail\n");
    } else {
        printf("module mqtt conn success\n");
    }

    if (tos_tf_module_mqtt_state_get(&state) != -1) {
        printf("MQTT: %s\n", state == MQTT_STATE_CONNECTED ? "CONNECTED" : "DISCONNECTED");
    }

    size = snprintf(report_reply_topic_name, TOPIC_NAME_MAX_SIZE, "$thing/down/property/%s/%s", product_id, device_name);

    if (size < 0 || size > sizeof(report_reply_topic_name) - 1) {
        printf("sub topic content length not enough! content size:%d  buf size:%d", size, (int)sizeof(report_reply_topic_name));
    }
    if (tos_tf_module_mqtt_sub(report_reply_topic_name, QOS0, default_message_handler) != 0) {
        printf("module mqtt sub fail\n");
    } else {
        printf("module mqtt sub success\n");
    }

    memset(report_topic_name, 0, sizeof(report_topic_name));
    size = snprintf(report_topic_name, TOPIC_NAME_MAX_SIZE, "$thing/up/property/%s/%s", product_id, device_name);

    if (size < 0 || size > sizeof(report_topic_name) - 1) {
        printf("pub topic content length not enough! content size:%d  buf size:%d", size, (int)sizeof(report_topic_name));
    }
}