物模型通信


static void on_report_property_result_cb(char *property_id, void *user_data,
                                         data_model_report_result_t result_code);
static void on_receive_property_changed_cb(char *property_id,
                                           tc_iot_data_model_property_t *data_model_property);
static void on_report_event_result_cb(char *event_id, void *user_data,
                                      data_model_report_result_t result_code);
static int  on_receive_new_action_cb(char *action_id,
                                      tc_iot_data_model_action_t *data_model_action);


tc_iot_data_model_callback_t callback;
memset(&callback, 0, sizeof(callback));
callback.on_report_property_result_cb   = on_report_property_result_cb;
callback.on_receive_property_changed_cb = on_receive_property_changed_cb;
callback.on_report_event_result_cb      = on_report_event_result_cb;
callback.on_receive_new_action_cb       = on_receive_new_action_cb;


tc_iot_error_e dm_rc = tc_iot_data_model_init(callback);
if (dm_rc != TC_IOT_ERR_SUCCESS) {
    printf("tc_iot_data_model_init failed: %d\\n", dm_rc);
}

#include "tc_iot_data_model.h"

tc_iot_data_model_property_t property[1];
memset(property, 0, sizeof(property));

char power_switch_id[] = "power_switch";
property[0].property.data_id = power_switch_id;
property[0].property.data_type = DATA_MODEL_DATA_TYPE_BOOL;
property[0].property.data_value.value_bool = true;

rc = tc_iot_data_model_report_property(property, 1, NULL);
if (rc != TC_IOT_ERR_SUCCESS) {
    printf("tc_iot_data_model_report_property failed: %d\\n", rc);
}

tc_iot_data_model_property_t property[4];
memset(property, 0, sizeof(property));

char id_power[]  = "power_switch";
char id_bright[] = "brightness";
char id_color[]  = "color";
char id_name[]   = "device_name";

property[0].property.data_id   = id_power;
property[0].property.data_type = DATA_MODEL_DATA_TYPE_BOOL;
property[0].property.data_value.value_bool = true;

property[1].property.data_id   = id_bright;
property[1].property.data_type = DATA_MODEL_DATA_TYPE_INT;
property[1].property.data_value.value_int = 80;

property[2].property.data_id   = id_color;
property[2].property.data_type = DATA_MODEL_DATA_TYPE_ENUM;
property[2].property.data_value.value_enum = 2;

property[3].property.data_id   = id_name;
property[3].property.data_type = DATA_MODEL_DATA_TYPE_STRING;
property[3].property.data_value.value_string = "test_device_001";

rc = tc_iot_data_model_report_property(property, 4, NULL);
if (rc != TC_IOT_ERR_SUCCESS) {
    printf("tc_iot_data_model_report_property failed: %d\\n", rc);
}

#include "tc_iot_data_model.h"

tc_iot_data_model_event_t event[1];
memset(event, 0, sizeof(event));

char event_id[] = "temperature_alert";
event[0].event_id = event_id;
event[0].event_type = DATA_MODEL_EVENT_TYPE_ALERT;

data_model_data_item_t event_data[1];
memset(event_data, 0, sizeof(event_data));

char temp_id[] = "temperature";
event_data[0].data_id = temp_id;
event_data[0].data_type = DATA_MODEL_DATA_TYPE_INT;
event_data[0].data_value.value_int = 85;

event[0].event_data_list = event_data;
event[0].event_data_num  = 1;

rc = tc_iot_data_model_report_event(event, 1, NULL);
if (rc != TC_IOT_ERR_SUCCESS) {
    printf("tc_iot_data_model_report_event failed: %d\\n", rc);
}

tc_iot_data_model_event_t fault[1];
memset(fault, 0, sizeof(fault));

fault[0].event_id = "device_error";
fault[0].event_type = DATA_MODEL_EVENT_TYPE_FAULT;
fault[0].event_data_num = 0;
fault[0].event_data_list = NULL;

rc = tc_iot_data_model_report_event(fault, 1, NULL);
if (rc != TC_IOT_ERR_SUCCESS) {
    printf("tc_iot_data_model_report_event failed: %d\\n", rc);
}

static void on_receive_property_changed_cb(char *property_id,
                                            tc_iot_data_model_property_t *data_model_property) {
    if (property_id == NULL || data_model_property == NULL) {
        return;
    }

    data_model_data_item_t *item = &data_model_property->property;
    printf("[demo] property changed: id=%s, type=%d\\n", item->data_id, (int)item->data_type);

    switch (item->data_type) {
        case DATA_MODEL_DATA_TYPE_BOOL:
            // 根据 item->data_value.value_bool 调整设备状态
            break;
        case DATA_MODEL_DATA_TYPE_INT:
            // 根据 item->data_value.value_int 调整设备状态
            break;
        case DATA_MODEL_DATA_TYPE_FLOAT:
            // 根据 item->data_value.value_float 调整设备状态
            break;
        case DATA_MODEL_DATA_TYPE_STRING:
            // 根据 item->data_value.value_string 调整设备状态
            break;
        case DATA_MODEL_DATA_TYPE_ENUM:
            // 根据 item->data_value.value_enum 调整设备状态
            break;
        case DATA_MODEL_DATA_TYPE_TIME:
            // 根据 item->data_value.value_time 调整设备状态
            break;
        default:
            break;
    }
}


static int on_receive_new_action_cb(char *action_id, tc_iot_data_model_action_t *data_model_action) {
    if (action_id == NULL || data_model_action == NULL) {
        return -1;
    }

    printf("[demo] receive new action: id=%s, token=%s, timestamp=%u, input_num=%d\\n",
           action_id,
           data_model_action->token ? data_model_action->token : "",
           (unsigned)data_model_action->timestamp,
           data_model_action->action_input_data_num);

    // 1. 解析输入参数
    for (int i = 0; i < data_model_action->action_input_data_num; i++) {
        data_model_data_item_t *input = &data_model_action->action_input_data_list[i];
        printf("    input[%d]: id=%s, type=%d\\n", i, input->data_id, (int)input->data_type);
        // 根据业务需要读取 input->data_value ...
    }

    // 2. 执行行为逻辑（同步执行，避免在回调里做长时间阻塞）

    // 3. 填充输出参数（按云端定义的输出参数顺序和类型）
    int output_num = data_model_action->action_input_data_num;  // 示例：与输入参数个数保持一致
    data_model_action->action_output_data_num = output_num;
    data_model_action->action_output_data_list = NULL;
    if (output_num > 0) {
        data_model_action->action_output_data_list =
            (data_model_data_item_t *)calloc(output_num, sizeof(data_model_data_item_t));
        if (data_model_action->action_output_data_list == NULL) {
            return -2;  // 内存不足，回复云端失败
        }
        for (int i = 0; i < output_num; i++) {
            data_model_data_item_t *input  = &data_model_action->action_input_data_list[i];
            data_model_data_item_t *output = &data_model_action->action_output_data_list[i];

            output->data_id = input->data_id;       // 与云端约定好的输出参数标识
            output->data_type = input->data_type;   // 与云端约定好的输出参数类型
            if (input->data_type == DATA_MODEL_DATA_TYPE_INT) {
                output->data_value.value_int = input->data_value.value_int + 1;
            } else {
                output->data_value = input->data_value;
            }
        }
    }

    // 4. 返回 0：执行成功；返回非 0：执行失败，云端会收到对应错误码
    return 0;
}