物联网后端个人第十二周总结

news2024/11/18 2:57:21

学习工作进度

物联网方面

1.模拟设备通过规则引擎将数据通过mqtt进行转发

在物联网平台上实现模拟设备通过规则引擎将数据通过mqtt进行转发已经全部完成了，所使用的物联网平台在这方面有不少的问题和bug，也可能是没有按照开发者的想法对平台进行使用才导致出现了问题，也能给我们进行一个提醒，在日后开发我们自己的平台时一定要把使用文档写明白

2.网关二次开发
网关二次开发的工作终于圆满结束了上周因为向网关上传的程序有问题，导致网关宕机，与客服交流过之后解决了网关无法工作的问题，并且也解决了c程序编译的问题

本周首先通过网关技术客服给的调试程序获取到了网关每次对传感器轮询得到的原始数据。得到原始数据之后还要对原始数据进行处理

以下是对数据的处理过程

经过一系列的进制转换，拼接之后将数据封装成JSON格式的，通过网关配置软件中指定的ip地址和端口将数据发送到mqtt-broker上，mqtt-broker再根据配置的topic将消息进行转发

以下为网关二次开发的程序

#include "user_code.h"

static void get_mb_cmd_info(unsigned char item,int length,char** res)
{
	struct zq_mbpoll_info info;	
	int i;
	char** arr=malloc(length*sizeof(char*));
	char *token;
	char a[50];
	int num;
	double result;

	memset(a,0X00,50*sizeof(char));
	memset(&info,0x00,sizeof(info));
	zq_get_mbpoll_item_cmd_info(item,&info);
	strcpy(a,info.val);
	dbg_user_printf("%s",info.val);
	
    for(i=0; i<length; i++){
        if (i==0){
            token=strtok(a, ",");
        }else{
            token=strtok(NULL, ",");
        }
        num=atoi(token);
        arr[i]=malloc(5*sizeof(char));
        sprintf(arr[i],"%x",num);
    }
	
    for(i=0; i<length; i=i+2){
        res[i/2]=malloc(7*sizeof(char));
        strcpy(res[i/2],arr[i]);
        strcat(res[i/2],arr[i+1]);
        free(arr[i]);
        free(arr[i+1]);
        num=strtol(res[i/2],NULL,16);
		result=num/10.0;
        sprintf(res[i/2],"%.1f",result);
		dbg_user_printf("%s",res[i/2]);
    }
}

int mymb_poll_loop_query_end(void){
	char* res[5];
	int i;
	get_mb_cmd_info(0,10,res);
	char* result;
	cJSON *root;
	
	root=cJSON_CreateObject();
	cJSON_AddItemToObject(root,"temperature",cJSON_CreateString(res[0]));
	cJSON_AddItemToObject(root,"humidity",cJSON_CreateString(res[1]));
	cJSON_AddItemToObject(root,"pressure",cJSON_CreateString(res[2]));
	cJSON_AddItemToObject(root,"illumination",cJSON_CreateString(res[3]));
	cJSON_AddItemToObject(root,"CO2",cJSON_CreateString(res[4]));
	dbg_user_printf("%s",cJSON_Print(root));
	result=cJSON_Print(root);
	
	zq_tcp_send(2,result,strlen(result)*sizeof(char),0,0);
	dbg_user_printf("end");

	free(result);
	cJSON_Delete(root);
	for(i=0;i<5;i++){
        free(res[i]);
    }
    return 0;
}

int app_main(void * pParameter){
	zq_set_version(24);
	struct zq_recv_cb cb;
	memset(&cb,0x00,sizeof(cb));
	cb.mb_poll_loop_query_end =  mymb_poll_loop_query_end;	 
	zq_set_recv_cb(cb); 
}
APP_INIT app_init = app_main;