0
点赞
收藏
分享

微信扫一扫

HarmonyOS系统中内核实现智慧烟感控制的方法

愚鱼看书说故事 2022-10-31 阅读 38
harmonyos华为鸿蒙系统上传jsonLinux系统/运维


      大家好，今天主要和大家聊一聊，如何利用鸿蒙系统实现智慧烟感方法

HarmonyOS系统中内核实现智慧烟感控制的方法_上传

 

目录

​​第一：鸿蒙系统智慧烟感基本简介​​

​​第二：华为IOT平台API ​​

​​数据上传​​

​​设备消息上报​​

​​设备上报属性数据​​

​​网关批量上报属性数据​​

​​属性设置的响应结果​​

​​属性查询响应结果​​

​​将命令的执行结果返回给平台​​

​​第三：软件设计​​

​​连接平台​​

​​推送数据​​

​​命令接收​​

​​第四：编译调试​​

​​登录​​

​​创建产品​​

​​第五：修改代码中设备信息​​

​​第六：修改 BUILD.gn 文件​​

​​第七：编译调试​​

第一：鸿蒙系统智慧烟感基本简介

    在鸿蒙开发板上使用MQTT协议连接华为IOT平台，使用智慧烟感和开发板进行通信的实例。

    华为云是华为的云服务品牌，用在线的方式将华为30多年在ICT基础设施领域的技术积累和产品解决方案开放给客户，致力于提供稳定可靠、安全可信、可持续创新的云服务，做智能世界的”黑土地”，推进实现 “用得起、用得好、用得放心”的普惠Al。华为云作为底座,为华为全栈全场景AI战略提供强大的算力平台和更易用的开发平台。

第二：华为IOT平台API 

数据上传

设备消息上报

int oc_mqtt_profile_msgup(char *deviceid,oc_mqtt_profile_msgup_t *payload);

是指设备无法按照产品模型中定义的属性格式进行数据上报时，可调用此接口将设备的自定义数据上报给平台，平台将设备上报的消息转发给应用服务器或华为云其他云服务上进行存储和处理。

参数

描述

deviceid

设备id

payload

要上传的消息

返回

描述

0

上传成功

1

上传失败

设备上报属性数据

int oc_mqtt_profile_propertyreport(char *deviceid,oc_mqtt_profile_service_t *payload);

用于设备按产品模型中定义的格式将属性数据上报给平台。

参数

描述

deviceid

设备id

payload

要上传的消息

返回

描述

0

上传成功

1

上传失败

属性上报和消息上报的区别，请查看​​消息通信说明​​

网关批量上报属性数据

int oc_mqtt_profile_gwpropertyreport(char *deviceid,oc_mqtt_profile_device_t *payload);

用于批量设备上报属性数据给平台。网关设备可以用此接口同时上报多个子设备的属性数据。

参数

描述

deviceid

设备id

payload

要上传的消息

返回

描述

0

上传成功

1

上传失败

属性设置的响应结果

int oc_mqtt_profile_propertysetresp(char *deviceid,oc_mqtt_profile_propertysetresp_t *payload);

参数

描述

deviceid

设备id

payload

消息

返回

描述

0

上传成功

1

上传失败

属性查询响应结果

int oc_mqtt_profile_propertygetresp(char *deviceid,oc_mqtt_profile_propertygetresp_t *payload);

参数

描述

deviceid

设备id

payload

消息

返回

描述

0

上传成功

1

上传失败

将命令的执行结果返回给平台

int oc_mqtt_profile_cmdresp(char *deviceid,oc_mqtt_profile_cmdresp_t *payload); 平台下发命令后，需要设备及时将命令的执行结果返回给平台，如果设备没回响应，平台会认为命令执行超时。

参数

描述

deviceid

设备id

payload

要上传的消息

返回

描述

0

上传成功

1

上传失败

第三：软件设计

连接平台

在连接平台前需要设置获取CONFIG_APP_DEVICEID、CONFIG_APP_DEVICEPWD、CONFIG_APP_SERVERIP、CONFIG_APP_SERVERPORT，通过oc_mqtt_profile_connect()函数连接平台。

WifiConnect(CONFIG_WIFI_SSID, CONFIG_WIFI_PWD);
    dtls_al_init();
    mqtt_al_init();
    oc_mqtt_init();
    
    g_app_cb.app_msg = queue_create("queue_rcvmsg",10,1);
    if(NULL ==  g_app_cb.app_msg){
        printf("Create receive msg queue failed");
        
    }
    oc_mqtt_profile_connect_t  connect_para;
    (void) memset( &connect_para, 0, sizeof(connect_para));

    connect_para.boostrap =      0;
    connect_para.device_id =     CONFIG_APP_DEVICEID;
    connect_para.device_passwd = CONFIG_APP_DEVICEPWD;
    connect_para.server_addr =   CONFIG_APP_SERVERIP;
    connect_para.server_port =   CONFIG_APP_SERVERPORT;
    connect_para.life_time =     CONFIG_APP_LIFETIME;
    connect_para.rcvfunc =       msg_rcv_callback;
    connect_para.security.type = EN_DTLS_AL_SECURITY_TYPE_NONE;
    ret = oc_mqtt_profile_connect(&connect_para);
    if((ret == (int)en_oc_mqtt_err_ok)){
        g_app_cb.connected = 1;
        printf("oc_mqtt_profile_connect succed!\r\n");
    }
    else
    {
        printf("oc_mqtt_profile_connect faild!\r\n");
    }

推送数据

当需要上传数据时，需要先拼装数据，让后通过oc_mqtt_profile_propertyreport上报数据。代码示例如下：

static void deal_report_msg(report_t *report)
{
    oc_mqtt_profile_service_t service;
    oc_mqtt_profile_kv_t smoke_value;
    oc_mqtt_profile_kv_t beep;

    service.event_time = NULL;
    service.service_id = "Smoke";
    service.service_property = &smoke_value;
    service.nxt = NULL;

    smoke_value.key = "Smoke_Value";
    smoke_value.value = &report->smokevalue;
    smoke_value.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
    smoke_value.nxt = &beep;

    beep.key = "BeepStatus";
    beep.value = g_app_cb.beep ? "ON" : "OFF";
    beep.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
    beep.nxt = NULL;

    oc_mqtt_profile_propertyreport(USERNAME, &service);
    return;
}

命令接收

华为IoT平台支持下发命令，命令是用户自定义的。接收到命令后会将命令数据发送到队列中，task_main_entry函数中读取队列数据并调用deal_cmd_msg函数进行处理，代码示例如下：

void oc_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size)
{
    app_msg_t *app_msg;

    int    ret = 0;
    app_msg = malloc(sizeof(app_msg_t));
    app_msg->msg_type = en_msg_cmd;
    app_msg->msg.cmd.payload = (char *)recv_data;

    printf("recv data is %.*s\n", recv_size, recv_data);
    ret = osMessageQueuePut(mid_MsgQueue,&app_msg,0U, 0U);
    if(ret != 0){
        free(recv_data);
    }
    *resp_data = NULL;
    *resp_size = 0;
}
static int task_main_entry( void )
{
    app_msg_t *app_msg;

    WifiConnect("TP-LINK_65A8","0987654321");
    device_info_init(CLIENT_ID,USERNAME,PASSWORD);
    oc_mqtt_init();
    oc_set_cmd_rsp_cb(oc_cmd_rsp_cb);

    while(1){
        app_msg = NULL;
        (void)osMessageQueueGet(mid_MsgQueue,(void **)&app_msg,NULL, 0U);
        if(NULL != app_msg){
            switch(app_msg->msg_type){
                case en_msg_cmd:
                    deal_cmd_msg(&app_msg->msg.cmd);
                    break;
                case en_msg_report:
                    deal_report_msg(&app_msg->msg.report);
                    break;
                default:
                    break;
            }
            free(app_msg);
        }
    }
    return 0;
}
static void deal_cmd_msg(cmd_t *cmd)
{
    cJSON *obj_root;
    cJSON *obj_cmdname;
    cJSON *obj_paras;
    cJSON *obj_para;

    int cmdret = 1;
    oc_mqtt_profile_cmdresp_t cmdresp;
    obj_root = cJSON_Parse(cmd->payload);
    if (NULL == obj_root)
    {
        goto EXIT_JSONPARSE;
    }

    obj_cmdname = cJSON_GetObjectItem(obj_root, "command_name");
    if (NULL == obj_cmdname)
    {
        goto EXIT_CMDOBJ;
    }
    if (0 == strcmp(cJSON_GetStringValue(obj_cmdname), "Smoke_Control_Beep"))
    {
        obj_paras = cJSON_GetObjectItem(obj_root, "paras");
        if (NULL == obj_paras)
        {
            goto EXIT_OBJPARAS;
        }
        obj_para = cJSON_GetObjectItem(obj_paras, "Beep");
        if (NULL == obj_para)
        {
            goto EXIT_OBJPARA;
        }
        ///< operate the LED here
        if (0 == strcmp(cJSON_GetStringValue(obj_para), "ON"))
        {
            g_app_cb.beep = 1;
            Beep_StatusSet(ON);
            printf("Beep On!");
            goto EXIT_JSONPARSE;
        }
        else
        {
            g_app_cb.beep = 0;
            Beep_StatusSet(OFF);
            printf("Beep Off!");
            goto EXIT_JSONPARSE;
        }
        cmdret = 0;
    }
    

EXIT_OBJPARA:
EXIT_OBJPARAS:
EXIT_CMDOBJ:
    cJSON_Delete(obj_root);
EXIT_JSONPARSE:
    ///< do the response
    cmdresp.paras = NULL;
    cmdresp.request_id = cmd->request_id;
    cmdresp.ret_code = cmdret;
    cmdresp.ret_name = NULL;
    (void)oc_mqtt_profile_cmdresp(NULL, &cmdresp);
    return;
}

第四：编译调试

登录

设备接入华为云平台之前，需要在平台注册用户账号，华为云地址：​​https://www.huaweicloud.com/​​

在华为云首页单击产品，找到IoT物联网，单击设备接入IoTDA 并单击立即使用。

HarmonyOS系统中内核实现智慧烟感控制的方法_华为_02

 

HarmonyOS系统中内核实现智慧烟感控制的方法_json_03

创建产品

在设备接入页面可看到总览界面，展示了华为云平台接入的协议与域名信息，根据需要选取MQTT通讯必要的信息备用。

接入协议（端口号）：MQTT 1883

域名：iot-mqtts.cn-north-4.myhuaweicloud.com

HarmonyOS系统中内核实现智慧烟感控制的方法_上传_04

 选中侧边栏产品页，单击右上角“创建产品”，在页面中选中所属资源空间，并且按要求填写产品名称，选中MQTT协议，数据格式为JSON，并填写厂商名称，在下方模型定义栏中选择所属行业以及添加设备类型，并单击右下角“确定”如图：

HarmonyOS系统中内核实现智慧烟感控制的方法_华为_05

创建完成后，在产品页会自动生成刚刚创建的产品，单击“查看”可查看创建的具体信息。

HarmonyOS系统中内核实现智慧烟感控制的方法_上传_06

 

单击产品详情页的自定义模型，在弹出页面中新增服务

服务ID：​​Smoke​​(必须一致)

服务类型：​​Senser​​(可自定义)

HarmonyOS系统中内核实现智慧烟感控制的方法_鸿蒙系统_07

 在“Smoke”的下拉菜单下点击“添加属性”填写相关信息“Smoke_Value”，“BeepStatus”。

 

HarmonyOS系统中内核实现智慧烟感控制的方法_harmonyos_08

HarmonyOS系统中内核实现智慧烟感控制的方法_华为_09

在“Smoke”的下拉菜单下点击“添加命令”填写相关信息。

命令名称：​​Smoke_Control_Beep​​

参数名称：​​Beep​​

数据类型：​​string​​

长度：​​3​​

枚举值：​​ON,OFF​​

HarmonyOS系统中内核实现智慧烟感控制的方法_华为_10

 

注册设备

在侧边栏中单击“设备”，进入设备页面，单击右上角“注册设备”，勾选对应所属资源空间并选中刚刚创建的产品，注意设备认证类型选择“秘钥”，按要求填写秘钥。

HarmonyOS系统中内核实现智慧烟感控制的方法_上传_11

HarmonyOS系统中内核实现智慧烟感控制的方法_华为_12

 记录下设备ID和设备密钥

 注册完成后，在设备页面单击“所有设备”，即可看到新建的设备，同时设备处于未激活状态

HarmonyOS系统中内核实现智慧烟感控制的方法_harmonyos_13

第五：修改代码中设备信息

修改​​iot_cloud_oc_sample.c​​中第31行附近的wifi的ssid和pwd，以及设备的DEVICEID和DEVICEPWD（这两个参数是在平台注册设备时产生的），

HarmonyOS系统中内核实现智慧烟感控制的方法_上传_14

 

第六：修改 BUILD.gn 文件

修改 ​​applications\sample\BearPi\BearPi-HM_Nano​​​路径下 BUILD.gn 文件，指定 ​​cloud_oc_smoke​​ 参与编译。

"D8_iot_cloud_oc_smoke:cloud_oc_smoke"
#"D9_iot_cloud_oc_light:cloud_oc_light"
#"D10_iot_cloud_oc_manhole_cover:cloud_oc_manhole_cover"
#"D11_iot_cloud_oc_infrared:cloud_oc_infrared"
#"D12_iot_cloud_oc_agriculture:cloud_oc_agriculture"

第七：编译调试

示例代码编译烧录代码后，按下开发板的RESET按键，通过串口助手查看日志，平台上的设备显示为在线状态。

HarmonyOS系统中内核实现智慧烟感控制的方法_鸿蒙系统_15

 

点击设备右侧的“查看”，进入设备详情页面，可看到上报的数据

在华为云平台设备详情页，单击“命令”，选择同步命令下发，选中创建的命令属性，单击“确定”，即可发送下发命令控制设备

举报

相关推荐

HarmonyOS系统中内核实现智慧物流控制的方法

harmonyos鸿蒙系统鸿蒙华为上传PPTOffice办公

HarmonyOS系统中内核实现ADC采样的方法

harmonyos鸿蒙鸿蒙系统函数分析硬件设计Storm大数据

HarmonyOS系统中内核实现MQTT连接华为云的方法

harmonyos鸿蒙系统华为鸿蒙华为云虚拟化云计算

HarmonyOS系统中内核实现温湿度采集方法

harmonyos华为鸿蒙系统鸿蒙初始化虚拟化云计算

HarmonyOS系统中内核实现三轴加速度检测方法

harmonyos华为鸿蒙系统加速度传感器开发板虚拟化云计算

HarmonyOS系统内核中GPIO控制方法

harmonyos华为鸿蒙系统ios引脚虚拟化云计算

HarmonyOS系统内核中消息队列的实现

harmonyos华为消息队列初始化软件设计虚拟化云计算

netfilter内核实现概述

网络netfilteriptables

Netlink 内核实现分析 1

套接字初始化组播编程语言

Netlink 内核实现分析 2

套接字组播系统调用编程语言
0 条评论