• Home
Name Date Size #Lines LOC

..--

include/12-May-2024-10758

src/12-May-2024-540368

BUILD.gnD12-May-20241.4 KiB4035

README.mdD12-May-202411.3 KiB343251

iot_cloud_oc_sample.cD12-May-202410.2 KiB384311

README.md

1# BearPi-HM_Nano开发板智慧农业案例开发
2本示例将演示如何在BearPi-HM_Nano开发板上使用MQTT协议连接华为IoT平台,使用的是E53_IA1 智慧农业扩展板与 BearPi-HM_Nano 开发板,设备安装如下图所示。
3
4![](../../docs/figures/D11_iot_cloud_oc_agriculture/E53_IA1_Install.png "E53_IA1安装")
5
6## 软件设计
7
8
9### 连接平台
10在连接华为IoT平台前需要设置 CONFIG_APP_DEVICEID、CONFIG_APP_DEVICEPWD、CONFIG_APP_SERVERIP、CONFIG_APP_SERVERPORT,通过oc_mqtt_profile_connect()函数连接平台。
11```c
12    WifiConnect(CONFIG_WIFI_SSID, CONFIG_WIFI_PWD);
13    dtls_al_init();
14    mqtt_al_init();
15    oc_mqtt_init();
16
17    g_app_cb.app_msg = queue_create("queue_rcvmsg",10,1);
18    if(g_app_cb.app_msg == NULL){
19        printf("Create receive msg queue failed");
20
21    }
22    oc_mqtt_profile_connect_t  connect_para;
23    (void) memset( &connect_para, 0, sizeof(connect_para));
24
25    connect_para.boostrap =      0;
26    connect_para.device_id =     CONFIG_APP_DEVICEID;
27    connect_para.device_passwd = CONFIG_APP_DEVICEPWD;
28    connect_para.server_addr =   CONFIG_APP_SERVERIP;
29    connect_para.server_port =   CONFIG_APP_SERVERPORT;
30    connect_para.life_time =     CONFIG_APP_LIFETIME;
31    connect_para.rcvfunc =       msg_rcv_callback;
32    connect_para.security.type = EN_DTLS_AL_SECURITY_TYPE_NONE;
33    //连接平台
34    ret = oc_mqtt_profile_connect(&connect_para);
35    if((ret == (int)en_oc_mqtt_err_ok)){
36        g_app_cb.connected = 1;
37        printf("oc_mqtt_profile_connect succeed!\r\n");
38    }
39    else
40    {
41        printf("oc_mqtt_profile_connect failed!\r\n");
42    }
43```
44
45### 推送数据
46
47当需要上传数据时,需要先拼装数据,然后通过oc_mqtt_profile_propertyreport上报数据。代码示例如下:
48
49```c
50static void deal_report_msg(report_t *report)
51{
52    oc_mqtt_profile_service_t    service;
53    oc_mqtt_profile_kv_t         temperature;
54    oc_mqtt_profile_kv_t         humidity;
55    oc_mqtt_profile_kv_t         luminance;
56    oc_mqtt_profile_kv_t         led;
57    oc_mqtt_profile_kv_t         motor;
58
59    if (g_app_cb.connected != 1) {
60        return;
61    }
62
63    service.event_time = NULL;
64    service.service_id = "Agriculture";
65    service.service_property = &temperature;
66    service.nxt = NULL;
67
68    temperature.key = "Temperature";
69    temperature.value = &report->temp;
70    temperature.type = EN_OC_MQTT_PROFILE_VALUE_INT;
71    temperature.nxt = &humidity;
72
73    humidity.key = "Humidity";
74    humidity.value = &report->hum;
75    humidity.type = EN_OC_MQTT_PROFILE_VALUE_INT;
76    humidity.nxt = &luminance;
77
78    luminance.key = "Luminance";
79    luminance.value = &report->lum;
80    luminance.type = EN_OC_MQTT_PROFILE_VALUE_INT;
81    luminance.nxt = &led;
82
83    led.key = "LightStatus";
84    led.value = g_app_cb.led?"ON":"OFF";
85    led.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
86    led.nxt = &motor;
87
88    motor.key = "MotorStatus";
89    motor.value = g_app_cb.motor?"ON":"OFF";
90    motor.type = EN_OC_MQTT_PROFILE_VALUE_STRING;
91    motor.nxt = NULL;
92    //发送数据
93    oc_mqtt_profile_propertyreport(NULL,&service);
94    return;
95}
96```
97
98
99### 命令接收
100
101华为IoT平台支持下发命令,命令是用户自定义的。接收到命令后会将命令数据发送到队列中,task_main_entry函数中读取队列数据并调用deal_cmd_msg函数进行处理,代码示例如下:
102
103```c
104static int msg_rcv_callback(oc_mqtt_profile_msgrcv_t *msg)
105{
106    int ret = 0;
107    char *buf;
108    int buf_len;
109    app_msg_t *app_msg;
110
111    if ((msg == NULL) || (msg->request_id == NULL) || (msg->type != EN_OC_MQTT_PROFILE_MSG_TYPE_DOWN_COMMANDS)) {
112        return ret;
113    }
114
115    buf_len = sizeof(app_msg_t) + strlen(msg->request_id) + 1 + msg->msg_len + 1;
116    buf = malloc(buf_len);
117    if (buf == NULL) {
118        return ret;
119    }
120    app_msg = (app_msg_t *)buf;
121    buf += sizeof(app_msg_t);
122
123    app_msg->msg_type = en_msg_cmd;
124    app_msg->msg.cmd.request_id = buf;
125    buf_len = strlen(msg->request_id);
126    buf += buf_len + 1;
127    memcpy_s(app_msg->msg.cmd.request_id, buf_len, msg->request_id, buf_len);
128    app_msg->msg.cmd.request_id[buf_len] = '\0';
129
130    buf_len = msg->msg_len;
131    app_msg->msg.cmd.payload = buf;
132    memcpy_s(app_msg->msg.cmd.payload, buf_len, msg->msg, buf_len);
133    app_msg->msg.cmd.payload[buf_len] = '\0';
134
135    ret = osMessageQueuePut(g_app_cb.app_msg, &app_msg, 0U, CONFIG_QUEUE_TIMEOUT);
136    if (ret != 0) {
137        free(app_msg);
138    }
139
140    return ret;
141}
142
143static void oc_cmdresp(cmd_t *cmd, int cmdret)
144{
145    oc_mqtt_profile_cmdresp_t cmdresp;
146    ///< do the response
147    cmdresp.paras = NULL;
148    cmdresp.request_id = cmd->request_id;
149    cmdresp.ret_code = cmdret;
150    cmdresp.ret_name = NULL;
151    (void)oc_mqtt_profile_cmdresp(NULL, &cmdresp);
152}
153
154///< COMMAND DEAL
155#include <cJSON.h>
156static void deal_light_cmd(cmd_t *cmd, cJSON *obj_root)
157{
158    cJSON *obj_paras;
159    cJSON *obj_para;
160    int cmdret;
161
162    obj_paras = cJSON_GetObjectItem(obj_root, "paras");
163    if (obj_paras == NULL) {
164        cJSON_Delete(obj_root);
165    }
166    obj_para = cJSON_GetObjectItem(obj_paras, "Light");
167    if (obj_paras == NULL) {
168        cJSON_Delete(obj_root);
169    }
170    ///< operate the LED here
171    if (strcmp(cJSON_GetStringValue(obj_para), "ON") == 0) {
172        g_app_cb.led = 1;
173        LightStatusSet(ON);
174        printf("Light On!\r\n");
175    } else {
176        g_app_cb.led = 0;
177        LightStatusSet(OFF);
178        printf("Light Off!\r\n");
179    }
180    cmdret = 0;
181    oc_cmdresp(cmd, cmdret);
182
183    cJSON_Delete(obj_root);
184    return;
185}
186
187static void deal_motor_cmd(cmd_t *cmd, cJSON *obj_root)
188{
189    cJSON *obj_paras;
190    cJSON *obj_para;
191    int cmdret;
192
193    obj_paras = cJSON_GetObjectItem(obj_root, "Paras");
194    if (obj_paras == NULL) {
195        cJSON_Delete(obj_root);
196    }
197    obj_para = cJSON_GetObjectItem(obj_paras, "Motor");
198    if (obj_para == NULL) {
199        cJSON_Delete(obj_root);
200    }
201    ///< operate the Motor here
202    if (strcmp(cJSON_GetStringValue(obj_para), "ON") == 0) {
203        g_app_cb.motor = 1;
204        MotorStatusSet(ON);
205        printf("Motor On!\r\n");
206    } else {
207        g_app_cb.motor = 0;
208        MotorStatusSet(OFF);
209        printf("Motor Off!\r\n");
210    }
211    cmdret = 0;
212    oc_cmdresp(cmd, cmdret);
213
214    cJSON_Delete(obj_root);
215    return;
216}
217```
218
219
220## 编译调试
221
222
223### 登录
224
225设备接入华为云平台之前,需要在平台注册用户账号,华为云地址:<https://www.huaweicloud.com/>
226
227在华为云首页单击产品,找到IoT物联网,单击设备接入IoTDA 并单击立即使用,如下图所示。
228
229![](../../docs/figures/D11_iot_cloud_oc_agriculture/platformlogin01.png "登录平台")
230
231![](../../docs/figures/D11_iot_cloud_oc_agriculture/platformlogin02.png "登录平台")
232
233### 创建产品
234
235在设备接入页面可看到总览界面,展示了华为云平台接入的协议与域名信息,根据需要选取MQTT通讯必要的信息备用,如下图所示。
236
237接入协议(端口号):MQTT 1883
238
239域名:iot-mqtts.cn-north-4.myhuaweicloud.com
240![](../../docs/figures/D10_iot_cloud_oc_infrared/viewplatform.png "查看平台信息")
241
242选中侧边栏产品页,单击右上角“创建产品”,如下图所示。
243
244![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct01.png "创建产品")
245
246在页面中选中所属资源空间,并且按要求填写产品名称,选中MQTT协议,数据格式为JSON,并填写厂商名称,在下方模型定义栏中选择所属行业以及添加设备类型,并单击右下角“立即创建”,如下图所示。
247
248![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct02.png "创建产品")
249
250创建完成后,在产品页会自动生成刚刚创建的产品,单击“查看”可查看创建的具体信息,如下图所示。
251
252![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct03.png "创建产品")
253
254
255单击产品详情页的自定义模型,在弹出页面中新增服务,如下图所示。
256
257服务ID:`Agriculture`(必须一致)
258
259服务类型:`Sensor`(可自定义)
260![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct04.png "创建产品")
261
262在“Agriculture”的下拉菜单下点击“添加属性”填写相关信息“Temperature”,
263“Humidity”,“Luminance”,“LightStatus”,“MotorStatus”,如下图所示。
264
265
266![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct05.png "创建产品")
267
268![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct06.png "创建产品")
269
270![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct07.png "创建产品")
271
272![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct08.png "创建产品")
273
274![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct09.png "创建产品")
275
276在“Agriculture”的下拉菜单下点击“添加命令”填写相关信息。
277
278命令名称:`Agriculture_Control_light`
279
280参数名称:`Light`
281
282数据类型:`string`
283
284长度:`3`
285
286枚举值:`ON,OFF`
287
288![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct10.png "创建产品")
289
290命令名称:`Agriculture_Control_Motor`
291
292参数名称:`Motor`
293
294数据类型:`string`
295
296长度:`3`
297
298枚举值:`ON,OFF`
299
300![](../../docs/figures/D11_iot_cloud_oc_agriculture/createproduct11.png "创建产品")
301
302#### 注册设备
303
304在侧边栏中单击“设备”,进入设备页面,单击右上角“注册设备”,勾选对应所属资源空间并选中刚刚创建的产品,注意设备认证类型选择“秘钥”,按要求填写秘钥,如下图所示。
305
306![](../../docs/figures/D11_iot_cloud_oc_agriculture/registerdevice01.png "注册设备")
307
308记录下设备ID和设备密钥,如下图所示。
309![](../../docs/figures/D11_iot_cloud_oc_agriculture/registerdevice02.png "注册设备")
310
311注册完成后,在设备页面单击“所有设备”,即可看到新建的设备,同时设备处于未激活状态,如下图所示。
312
313![](../../docs/figures/D11_iot_cloud_oc_agriculture/registerdevice03.png "注册设备")
314
315
316### 修改代码中设备信息
317修改`iot_cloud_oc_sample.c`中第31行附近的wifi的ssid和pwd,以及设备的DEVICEID和DEVICEPWD(这两个参数是在平台注册设备时产生的),如下图所示。
318
319![](../../docs/figures/D11_iot_cloud_oc_agriculture/modifydevicemsg.png "修改设备信息")
320### 修改 BUILD.gn 文件
321
322修改 `device\board\bearpi\bearpi_hm_nano\app`路径下 BUILD.gn 文件,指定 `cloud_oc_agriculture` 参与编译。
323
324```r
325#"D7_iot_cloud_oc_smoke:cloud_oc_smoke",
326#"D8_iot_cloud_oc_light:cloud_oc_light",
327#"D9_iot_cloud_oc_manhole_cover:cloud_oc_manhole_cover",
328#"D10_iot_cloud_oc_infrared:cloud_oc_infrared",
329"D11_iot_cloud_oc_agriculture:cloud_oc_agriculture",
330#"D12_iot_cloud_oc_gps:cloud_oc_gps",
331```
332### 测试
333示例代码编译烧录后,按下开发板的RESET按键,通过串口助手查看日志,会打印温湿度及光照强度信息,平台上的设备显示为在线状态,如下图所示。
334
335![](../../docs/figures/D11_iot_cloud_oc_agriculture/deviceOnline.png "设备在线")
336
337点击设备右侧的“查看”,进入设备详情页面,可看到上报的数据,如下图所示。
338
339![](../../docs/figures/D11_iot_cloud_oc_agriculture/viewdevicemsg.png "查看设备信息")
340
341在华为云平台设备详情页,单击“命令”,选择同步命令下发,选中创建的命令属性,单击“确定”,即可发送下发命令控制设备,如下图所示。
342![](../../docs/figures/D11_iot_cloud_oc_agriculture/sendcommand.png "命令下发")
343