2675 lines
100 KiB
C
2675 lines
100 KiB
C
#include "sock_api/sock_api.h"
|
||
#include "lwip.h"
|
||
#include <string.h>
|
||
#include "stdlib.h"
|
||
#include "time.h"
|
||
#include "json_c/json_object.h"
|
||
#include "json_c/json_tokener.h"
|
||
#include "server/ai_server.h"
|
||
#include "system/includes.h"
|
||
#include "asm/crc16.h"
|
||
#include "common/base64.h"
|
||
#include "common/aes.h"
|
||
#include "fs/fs.h"
|
||
#include "asm/sfc_norflash_api.h"
|
||
|
||
#ifdef TELECOM_MC_SDK_VERSION
|
||
MODULE_VERSION_EXPORT(telecom_mc_sdk, TELECOM_MC_SDK_VERSION);
|
||
#endif
|
||
|
||
#if 1
|
||
#define log_info(x, ...) printf("\n>>>>>>[mc_device]\n" x " ", ## __VA_ARGS__)
|
||
#else
|
||
#define log_info(...)
|
||
#endif
|
||
|
||
#define DEV_CTEI_LOGIN_ENABLE
|
||
|
||
#define CT_LOGIN_HOST "smarthome.ctdevice.ott4china.com:9012"
|
||
#define CT_DEVICE_VERSION "11111.222.333.444"
|
||
#define CT_PARENT_DEV_MAC "000000000000"
|
||
#define CT_VERSION "000.000.000.001"
|
||
#define CT_SUB_DEVICE_ID "123123123123112312"
|
||
#define CT_SUB_DEVICE_CTEI "123123123312312312"
|
||
#define CT_SUB_DEVICE_MAC "123312312312312"
|
||
|
||
#define FLASH_BUF_LEN 1024
|
||
#define FLASH_BUF_START 12 * 1024
|
||
|
||
//定时器ID
|
||
static int heartbeat_timeout_id;
|
||
static int heartbeat_id;
|
||
static int device_status_id;
|
||
//线程PID
|
||
static int server_func_id;
|
||
static int dev_login_pid;
|
||
|
||
static int recv_sequence_num; //接收随机数
|
||
static u8 report_all; //发送完整状态成功标志位
|
||
static u8 CT_connect_flag; //SDK可连接标志位
|
||
static u8 heart_send; //心跳已发送标志,处理了心跳包发送但先收到非心跳包的情况
|
||
|
||
static int tcp_device_init(char *tcp_host);
|
||
static void tcp_send_function(int code);
|
||
static void tcp_recv_handler(void *priv);
|
||
static void device_status_init();
|
||
static void info_init();
|
||
static void timeout_func(void *priv);
|
||
static void device_status_func(void *priv);
|
||
static void heartbeat_ctl_func(void *priv);
|
||
static void status_set_func(int serial, char *name, char *param);
|
||
|
||
enum SEVER_TO_DEVICE_EVENT {
|
||
RECV_MSG,
|
||
CONNECT_CLOSE,
|
||
};
|
||
|
||
struct CT_Mc_device_info {
|
||
struct sockaddr_in local;
|
||
struct sockaddr_in dest;
|
||
void *tcp_sock;
|
||
void *udp_sock;
|
||
|
||
char ipaddr[20];
|
||
|
||
char tcpHost[64];
|
||
char tcp_port[10];
|
||
|
||
char udpHost[64];
|
||
char udp_port[10];
|
||
|
||
u16 serial_num;
|
||
char deviceId[50];
|
||
char sessionKey[20];
|
||
char pin[20];
|
||
char iv[20];
|
||
char mac[20];
|
||
char ctei[20];
|
||
char model[20];
|
||
|
||
char token[40];
|
||
|
||
int heartBeat;
|
||
int authInterval;
|
||
|
||
u8 login_flag;
|
||
};
|
||
static struct CT_Mc_device_info device = {0};
|
||
|
||
const struct ai_sdk_api CT_MC_api;
|
||
|
||
/************************************************/
|
||
//statusSerials
|
||
struct extraStatusParam {
|
||
int test; //#测试使用
|
||
};
|
||
|
||
struct dev_status {
|
||
struct list_head entry;
|
||
char statusName[20];
|
||
int statusValue;
|
||
|
||
u8 total; //共有同类型设备数量
|
||
u8 id_num; //设备单/多路序号
|
||
u8 upload_flag; //设备状态上报标志
|
||
|
||
u8 param_vaild; //是否有扩展项
|
||
struct extraStatusParam param;
|
||
};
|
||
static struct dev_status status_head;
|
||
|
||
/***********************************************/
|
||
//resourceSerials
|
||
struct resourceInfoParam {
|
||
int consum_ID;
|
||
int remain_life;
|
||
char consum_name[20];
|
||
};
|
||
|
||
struct dev_res {
|
||
struct list_head entry;
|
||
struct resourceInfoParam param;
|
||
char resourceName[20];
|
||
|
||
u8 total; //共有同类型设备数量
|
||
u8 id_num; //设备单/多路序号
|
||
u8 upload_flag; //设备状态上报标志
|
||
};
|
||
static struct dev_res res_head;
|
||
|
||
/************************************************/
|
||
//event //#没测试到
|
||
struct eventInfoParam {
|
||
char ID_name[20];
|
||
int ID_value;
|
||
char TYPE_name[20];
|
||
int TYPE_value;
|
||
};
|
||
|
||
struct device_eventInfo {
|
||
struct list_head entry;
|
||
char eventName[20];
|
||
struct eventInfoParam param;
|
||
};
|
||
static struct device_eventInfo event_head;
|
||
/************************************************/
|
||
|
||
|
||
static struct dev_status *get_alarm_info()
|
||
{
|
||
return NULL;
|
||
}
|
||
|
||
#define PROFILE_PATH "mnt/sdfile/EXT_RESERVED/telecom"
|
||
|
||
//设备信息读取
|
||
static int device_read_flash()
|
||
{
|
||
printf("%s", __func__);
|
||
int ret = -1;
|
||
|
||
struct list_head *pos = NULL;
|
||
struct dev_status *status_info = NULL;
|
||
struct dev_res *res_info = NULL;
|
||
|
||
u8 *device_data = (u8 *)calloc(1, FLASH_BUF_LEN);
|
||
if (!device_data) {
|
||
return ret;
|
||
}
|
||
|
||
u32 profile_addr;
|
||
FILE *profile_fp = fopen(PROFILE_PATH, "r");
|
||
if (profile_fp == NULL) {
|
||
free(device_data);
|
||
return ret;
|
||
}
|
||
|
||
struct vfs_attr file_attr;
|
||
fget_attrs(profile_fp, &file_attr);
|
||
profile_addr = file_attr.sclust;
|
||
fclose(profile_fp);
|
||
|
||
sdfile_reserve_zone_read(device_data, profile_addr, FLASH_BUF_LEN, 0);
|
||
|
||
u16 *device_crc = (u16 *)&device_data[0];
|
||
u16 *device_len = (u16 *)&device_data[2];
|
||
if (*device_len > FLASH_BUF_LEN) {
|
||
printf("------%s------%d, no data ,device_len = %d\r\n", __func__, __LINE__, *device_len);
|
||
goto read_exit;
|
||
}
|
||
|
||
//CRC校验比较
|
||
if (*device_crc != CRC16((const void *)&device_data[4], (u32)*device_len)) {
|
||
printf("-----%s--------%d, CRC16 failed\r\n", __func__, __LINE__);
|
||
goto read_exit;
|
||
}
|
||
|
||
u16 *status_num = (u16 *)&device_data[4];
|
||
u16 *resource_num = (u16 *)&device_data[6];
|
||
u8 *device_buffer = &device_data[8];
|
||
|
||
for (int i = 0; i < (u32)*status_num; i++) {
|
||
status_info = (struct dev_status *)calloc(1, sizeof(struct dev_status));
|
||
if (status_info == NULL) {
|
||
goto read_exit;
|
||
}
|
||
memcpy(status_info, device_buffer, sizeof(struct dev_status));
|
||
device_buffer += sizeof(struct dev_status);
|
||
list_add_tail(&status_info->entry, &status_head.entry);
|
||
}
|
||
|
||
for (int i = 0; i < (u32)*resource_num; i++) {
|
||
res_info = (struct dev_res *)calloc(1, sizeof(struct dev_res));
|
||
if (res_info == NULL) {
|
||
goto read_exit;
|
||
}
|
||
memcpy(res_info, device_buffer, sizeof(struct dev_res));
|
||
device_buffer += sizeof(struct dev_res);
|
||
list_add_tail(&res_info->entry, &res_head.entry);
|
||
}
|
||
|
||
ret = 0;
|
||
|
||
read_exit:
|
||
//关闭flash
|
||
free(device_data);
|
||
device_data = NULL;
|
||
return ret;
|
||
}
|
||
|
||
//擦除flash函数,测试使用
|
||
void device_erase_flash()
|
||
{
|
||
printf("%s", __func__);
|
||
|
||
u32 profile_addr;
|
||
FILE *profile_fp = fopen(PROFILE_PATH, "r");
|
||
if (profile_fp == NULL) {
|
||
return;
|
||
}
|
||
|
||
struct vfs_attr file_attr;
|
||
fget_attrs(profile_fp, &file_attr);
|
||
profile_addr = file_attr.sclust;
|
||
fclose(profile_fp);
|
||
|
||
sdfile_reserve_zone_erase(profile_addr, SDFILE_SECTOR_SIZE, 0);
|
||
}
|
||
|
||
//设备信息存储
|
||
void device_write_flash()
|
||
{
|
||
printf("%s", __func__);
|
||
|
||
struct list_head *pos = NULL;
|
||
struct dev_status *status_info = NULL;
|
||
struct dev_res *res_info = NULL;
|
||
|
||
u8 *device_data = (u8 *)calloc(1, FLASH_BUF_LEN);
|
||
if (!device_data) {
|
||
return;
|
||
}
|
||
|
||
u32 profile_addr;
|
||
FILE *profile_fp = fopen(PROFILE_PATH, "r");
|
||
if (profile_fp == NULL) {
|
||
free(device_data);
|
||
return;
|
||
}
|
||
|
||
struct vfs_attr file_attr;
|
||
fget_attrs(profile_fp, &file_attr);
|
||
profile_addr = file_attr.sclust;
|
||
fclose(profile_fp);
|
||
|
||
u16 *device_crc = (u16 *)&device_data[0];
|
||
u16 *device_len = (u16 *)&device_data[2];
|
||
u16 *status_num = (u16 *)&device_data[4];
|
||
u16 *resource_num = (u16 *)&device_data[6];
|
||
|
||
list_for_each(pos, &status_head.entry) {
|
||
(*status_num)++;
|
||
}
|
||
list_for_each(pos, &res_head.entry) {
|
||
(*resource_num)++;
|
||
}
|
||
|
||
u8 *device_buffer = &device_data[8];
|
||
*device_len = 4;
|
||
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
memcpy(device_buffer, status_info, sizeof(struct dev_status));
|
||
device_buffer += sizeof(struct dev_status);
|
||
*device_len += sizeof(struct dev_status);
|
||
}
|
||
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
memcpy(device_buffer, res_info, sizeof(struct dev_res));
|
||
device_buffer += sizeof(struct dev_res);
|
||
*device_len += sizeof(struct dev_res);
|
||
}
|
||
|
||
*device_crc = CRC16((const void *)&device_data[4], (u32) * device_len);
|
||
|
||
sdfile_reserve_zone_erase(profile_addr, SDFILE_SECTOR_SIZE, 0);
|
||
sdfile_reserve_zone_write(device_data, profile_addr, *device_len + 4, 0);
|
||
free(device_data);
|
||
device_data = NULL;
|
||
}
|
||
|
||
//设备信息初始化
|
||
static void device_status_init()
|
||
{
|
||
struct list_head *pos = NULL;
|
||
int total = 0;
|
||
char tmp_buf[32];
|
||
struct dev_status *status_info = NULL;
|
||
struct dev_res *res_info = NULL;
|
||
|
||
//-----------------------设备状态初始化-------------------------------//
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "POWER");
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
if (!strcmp(status_info->statusName, tmp_buf)) {
|
||
status_info->total += 1;
|
||
|
||
if (status_info->id_num == 0) {
|
||
status_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
//获取同类别设备状态总数
|
||
if (status_info != NULL) {
|
||
total = status_info->total;
|
||
} else {
|
||
total = 0;
|
||
}
|
||
|
||
status_info = (struct dev_status *)calloc(1, sizeof(struct dev_status));
|
||
if (status_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(status_info->statusName, tmp_buf);
|
||
status_info->statusValue = 0;
|
||
|
||
status_info->total = (total == 0) ? 1 : total;
|
||
status_info->id_num = (total == 0) ? 0 : total;
|
||
status_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&status_info->entry, &status_head.entry);
|
||
status_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "LIGHT_TEMP");
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
if (!strcmp(status_info->statusName, tmp_buf)) {
|
||
status_info->total += 1;
|
||
total = status_info->total;
|
||
|
||
if (status_info->id_num == 0) {
|
||
status_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
status_info = (struct dev_status *)calloc(1, sizeof(struct dev_status));
|
||
if (status_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(status_info->statusName, tmp_buf);
|
||
status_info->statusValue = 12000;
|
||
|
||
status_info->total = (total == 0) ? 1 : total;
|
||
status_info->id_num = (total == 0) ? 0 : total;
|
||
status_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&status_info->entry, &status_head.entry);
|
||
status_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "LIGHTNESS");
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
if (!strcmp(status_info->statusName, tmp_buf)) {
|
||
status_info->total += 1;
|
||
total = status_info->total;
|
||
|
||
if (status_info->id_num == 0) {
|
||
status_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
status_info = (struct dev_status *)calloc(1, sizeof(struct dev_status));
|
||
if (status_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(status_info->statusName, tmp_buf);
|
||
status_info->statusValue = 100;
|
||
|
||
status_info->total = (total == 0) ? 1 : total;
|
||
status_info->id_num = (total == 0) ? 0 : total;
|
||
status_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&status_info->entry, &status_head.entry);
|
||
status_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "LIGHTNESS");
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
if (!strcmp(status_info->statusName, tmp_buf)) {
|
||
status_info->total += 1;
|
||
total = status_info->total;
|
||
|
||
if (status_info->id_num == 0) {
|
||
status_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
status_info = (struct dev_status *)calloc(1, sizeof(struct dev_status));
|
||
if (status_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(status_info->statusName, tmp_buf);
|
||
status_info->statusValue = 50;
|
||
|
||
status_info->total = (total == 0) ? 1 : total;
|
||
status_info->id_num = (total == 0) ? 0 : total;
|
||
status_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&status_info->entry, &status_head.entry);
|
||
status_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
|
||
//-----------------------资源状态初始化-------------------------------//
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "Electricity");
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
if (!strcmp(res_info->resourceName, tmp_buf)) {
|
||
res_info->total += 1;
|
||
total = res_info->total;
|
||
|
||
if (res_info->id_num == 0) {
|
||
res_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
res_info = (struct dev_res *)calloc(1, sizeof(struct dev_res));
|
||
if (res_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(res_info->resourceName, tmp_buf);
|
||
res_info->param.consum_ID = 123456;
|
||
strcpy(res_info->param.consum_name, "temperature");
|
||
res_info->param.remain_life = 30;
|
||
|
||
res_info->total = (total == 0) ? 1 : total;
|
||
res_info->id_num = (total == 0) ? 0 : total;
|
||
res_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&res_info->entry, &res_head.entry);
|
||
res_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
|
||
|
||
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "Electricity");
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
if (!strcmp(res_info->resourceName, tmp_buf)) {
|
||
res_info->total += 1;
|
||
total = res_info->total;
|
||
|
||
if (res_info->id_num == 0) {
|
||
res_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
res_info = (struct dev_res *)calloc(1, sizeof(struct dev_res));
|
||
if (res_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(res_info->resourceName, tmp_buf);
|
||
res_info->param.consum_ID = 123456;
|
||
strcpy(res_info->param.consum_name, "temperature");
|
||
res_info->param.remain_life = 20;
|
||
|
||
res_info->total = (total == 0) ? 1 : total;
|
||
res_info->id_num = (total == 0) ? 0 : total;
|
||
res_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&res_info->entry, &res_head.entry);
|
||
res_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
|
||
/************************************/
|
||
memset(tmp_buf, 0, sizeof(tmp_buf));
|
||
strcpy(tmp_buf, "Water");
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
if (!strcmp(res_info->resourceName, tmp_buf)) {
|
||
res_info->total += 1;
|
||
total = res_info->total;
|
||
|
||
if (res_info->id_num == 0) {
|
||
res_info->id_num = 1;
|
||
}
|
||
}
|
||
}
|
||
|
||
res_info = (struct dev_res *)calloc(1, sizeof(struct dev_res));
|
||
if (res_info == NULL) {
|
||
printf("%s---%dcalloc failed \r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
|
||
strcpy(res_info->resourceName, tmp_buf);
|
||
res_info->param.consum_ID = 1122;
|
||
strcpy(res_info->param.consum_name, "LEVEL");
|
||
res_info->param.remain_life = 10;
|
||
|
||
res_info->total = (total == 0) ? 1 : total;
|
||
res_info->id_num = (total == 0) ? 0 : total;
|
||
res_info->upload_flag = 1; //创建时默认要上传给服务器端
|
||
list_add_tail(&res_info->entry, &res_head.entry);
|
||
res_info = NULL;
|
||
total = 0;
|
||
/************************************/
|
||
}
|
||
|
||
//错误信息处理
|
||
static void CT_error_fun(int error)
|
||
{
|
||
switch (error) {
|
||
case 1001:
|
||
log_info("Token invalid...");
|
||
break;
|
||
case 1002:
|
||
log_info("Request parameter error...");
|
||
break;
|
||
case 1003:
|
||
log_info("Device does not exist...");
|
||
case 9999:
|
||
log_info("Failed, System abnormality...");
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
|
||
//初始化上报信息标志位
|
||
static void init_upload_flag()
|
||
{
|
||
struct dev_status *status_info = NULL;
|
||
struct dev_res *res_info = NULL;
|
||
struct list_head *pos = NULL;
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
status_info->upload_flag = 1;
|
||
}
|
||
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
res_info->upload_flag = 1;
|
||
}
|
||
|
||
}
|
||
|
||
//deviceID登录请求
|
||
static char *CT_dev_login_ID_request(void)
|
||
{
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node = NULL;
|
||
first_node = json_object_new_object();
|
||
device.serial_num = rand32();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(++device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "devMac", json_object_new_string(device.mac));
|
||
json_object_object_add(first_node, "devCTEI", json_object_new_string(device.ctei));
|
||
json_object_object_add(first_node, "devVersion", json_object_new_string(CT_DEVICE_VERSION));
|
||
#if 0 //存在父设备开启
|
||
|
||
json_object_object_add(first_node, "parentDevMac", json_object_new_string(CT_PARENT_DEV_MAC));
|
||
|
||
#endif
|
||
if (device.ipaddr[0] != '\0') {
|
||
json_object_object_add(first_node, "ip", json_object_new_string(device.ipaddr));
|
||
}
|
||
json_object_object_add(first_node, "version", json_object_new_string(CT_VERSION));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
|
||
//encrypt
|
||
char *encrypt_buf = NULL, *encode_buf = NULL;
|
||
int encrypt_len;
|
||
encrypt_buf = (char *)calloc(1, strlen(json_object_get_string(first_node)) + 16);
|
||
if (!encrypt_buf) {
|
||
json_object_put(first_node);
|
||
return NULL;
|
||
}
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.pin, 16, device.iv, 16, encrypt_buf, &encrypt_len);
|
||
|
||
encode_buf = base64_encode(encrypt_buf, encrypt_len, NULL);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(1002));
|
||
json_object_object_add(root_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encode_buf));
|
||
|
||
char *send_buf = (char *)calloc(1, strlen(json_object_get_string(root_node)) + 4);
|
||
strcpy(send_buf, "CTS");
|
||
strcat(send_buf, json_object_to_json_string_ext(root_node, JSON_C_TO_STRING_NOSLASHESCAPE));
|
||
strcat(send_buf, "\r\n");
|
||
|
||
if (encrypt_buf) {
|
||
free(encrypt_buf);
|
||
}
|
||
if (encode_buf) {
|
||
free(encode_buf);
|
||
}
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
|
||
return send_buf;
|
||
}
|
||
|
||
//CTEI登录请求
|
||
static char *CT_dev_login_CTEI_request(void)
|
||
{
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
device.serial_num = rand32();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(++device.serial_num));
|
||
json_object_object_add(first_node, "devCTEI", json_object_new_string(device.ctei));
|
||
json_object_object_add(first_node, "devMac", json_object_new_string(device.mac));
|
||
json_object_object_add(first_node, "devVersion", json_object_new_string(CT_DEVICE_VERSION));
|
||
#if 0 //存在父设备开启
|
||
|
||
json_object_object_add(first_node, "parentDevMac", json_object_new_string(CT_PARENT_DEV_MAC));
|
||
|
||
#endif
|
||
if (*device.ipaddr) {
|
||
json_object_object_add(first_node, "ip", json_object_new_string(device.ipaddr));
|
||
}
|
||
json_object_object_add(first_node, "version", json_object_new_string(CT_VERSION));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
char *encrypt_buf = NULL, *encode_buf = NULL;
|
||
int encrypt_len;
|
||
encrypt_buf = (char *)calloc(1, strlen(json_object_get_string(first_node)) + 16);
|
||
if (!encrypt_buf) {
|
||
printf("encrypt_buf malloc failed ----%s-----%d\r\n", __func__, __LINE__);
|
||
json_object_put(first_node);
|
||
return NULL;
|
||
}
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.pin, 16, device.iv, 16, encrypt_buf, &encrypt_len);
|
||
|
||
encode_buf = base64_encode(encrypt_buf, encrypt_len, NULL);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(1102));
|
||
json_object_object_add(root_node, "devCTEI", json_object_new_string(device.ctei));
|
||
|
||
json_object_object_add(root_node, "data", json_object_new_string(encode_buf));
|
||
|
||
char *send_buf = (char *)calloc(1, strlen(json_object_get_string(root_node)) + 4);
|
||
strcpy(send_buf, "CTS");
|
||
strcat(send_buf, json_object_to_json_string_ext(root_node, JSON_C_TO_STRING_NOSLASHESCAPE));
|
||
strcat(send_buf, "\r\n");
|
||
|
||
if (encrypt_buf) {
|
||
free(encrypt_buf);
|
||
}
|
||
if (encode_buf) {
|
||
free(encode_buf);
|
||
}
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
|
||
return send_buf;
|
||
}
|
||
|
||
//业务服务器连接请求
|
||
static char *CT_dev_connect_request(void)
|
||
{
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(++device.serial_num));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(first_node, "devVersion", json_object_new_string(CT_DEVICE_VERSION));
|
||
json_object_object_add(first_node, "model", json_object_new_string(device.model));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
char *encrypt_buf = NULL, *encode_buf = NULL;
|
||
int encrypt_len;
|
||
encrypt_buf = (char *)calloc(1, strlen(json_object_get_string(first_node)) + 16);
|
||
if (!encrypt_buf) {
|
||
printf("encrypt_buf malloc failed ----%s-----%d\r\n", __func__, __LINE__);
|
||
json_object_put(first_node);
|
||
return NULL;
|
||
}
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, 16, device.sessionKey, 16, encrypt_buf, &encrypt_len);
|
||
|
||
encode_buf = base64_encode(encrypt_buf, encrypt_len, NULL);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(1004));
|
||
json_object_object_add(root_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encode_buf));
|
||
|
||
|
||
char *send_buf = (char *)calloc(1, strlen(json_object_get_string(root_node)) + 4);
|
||
strcpy(send_buf, "CTS");
|
||
strcat(send_buf, json_object_to_json_string_ext(root_node, JSON_C_TO_STRING_NOSLASHESCAPE));
|
||
strcat(send_buf, "\r\n");
|
||
|
||
if (encrypt_buf) {
|
||
free(encrypt_buf);
|
||
}
|
||
if (encode_buf) {
|
||
free(encode_buf);
|
||
}
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
|
||
return send_buf;
|
||
}
|
||
|
||
//心跳请求
|
||
static char *CT_dev_heartbeat_request(void)
|
||
{
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(++device.serial_num));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
heart_send = 1; //心跳包创建发送
|
||
|
||
//encrypt
|
||
char *encrypt_buf = NULL, *encode_buf = NULL;
|
||
int encrypt_len;
|
||
encrypt_buf = (char *)calloc(1, strlen(json_object_get_string(first_node)) + 16);
|
||
if (!encrypt_buf) {
|
||
printf("encrypt_buf malloc failed ----%s-----%d\r\n", __func__, __LINE__);
|
||
json_object_put(first_node);
|
||
return NULL;
|
||
}
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, 16, device.sessionKey, 16, encrypt_buf, &encrypt_len);
|
||
|
||
encode_buf = base64_encode(encrypt_buf, encrypt_len, NULL);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(1000));
|
||
json_object_object_add(root_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encode_buf));
|
||
|
||
char *send_buf = (char *)calloc(1, strlen(json_object_get_string(root_node)) + 4);
|
||
strcpy(send_buf, "CTS");
|
||
strcat(send_buf, json_object_to_json_string_ext(root_node, JSON_C_TO_STRING_NOSLASHESCAPE));
|
||
strcat(send_buf, "\r\n");
|
||
|
||
if (encrypt_buf) {
|
||
free(encrypt_buf);
|
||
}
|
||
if (encode_buf) {
|
||
free(encode_buf);
|
||
}
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
|
||
return send_buf;
|
||
}
|
||
|
||
//设备控制回复
|
||
static char *CT_dev_control_reply(void) //device->server
|
||
{
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "result", json_object_new_int(0));
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(recv_sequence_num));
|
||
json_object_object_add(first_node, "dscp", json_object_new_string("操作成功"));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
char *encrypt_buf = NULL, *encode_buf = NULL;
|
||
int encrypt_len;
|
||
encrypt_buf = (char *)calloc(1, strlen(json_object_get_string(first_node)) + 16);
|
||
if (!encrypt_buf) {
|
||
printf("encrypt_buf malloc failed ----%s-----%d\r\n", __func__, __LINE__);
|
||
json_object_put(first_node);
|
||
return NULL;
|
||
}
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, 16, device.sessionKey, 16, encrypt_buf, &encrypt_len);
|
||
|
||
encode_buf = base64_encode(encrypt_buf, encrypt_len, NULL);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2004));
|
||
json_object_object_add(root_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encode_buf));
|
||
|
||
char *send_buf = (char *)calloc(1, strlen(json_object_get_string(root_node)) + 4);
|
||
strcpy(send_buf, "CTS");
|
||
strcat(send_buf, json_object_to_json_string_ext(root_node, JSON_C_TO_STRING_NOSLASHESCAPE));
|
||
strcat(send_buf, "\r\n");
|
||
|
||
if (encrypt_buf) {
|
||
free(encrypt_buf);
|
||
}
|
||
if (encode_buf) {
|
||
free(encode_buf);
|
||
}
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
|
||
return send_buf;
|
||
}
|
||
|
||
//设备信息上报
|
||
static char *CT_dev_report_request(void)
|
||
{
|
||
int status_serialId_num = 0, resource_serialId_num = 0;
|
||
int total ;
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[6] = {0}, *third_node[6] = {0};
|
||
struct list_head *pos = NULL;
|
||
struct dev_status *status_info = NULL;
|
||
struct dev_res *res_info = NULL;
|
||
|
||
if (!report_all) {
|
||
init_upload_flag();
|
||
}
|
||
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(++device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
//statusSerials
|
||
status_info = list_first_entry(&status_head.entry, struct dev_status, entry);
|
||
if (*(status_info->statusName)) {
|
||
second_node[0] = json_object_new_array();
|
||
total = 1;
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
//先统计要上报的状态总数
|
||
if (status_info->upload_flag == 1) {
|
||
total = status_info->total > total ? status_info->total + 1 : total;
|
||
}
|
||
}
|
||
for (int i = 0; i < total; i++) {
|
||
second_node[3] = NULL;
|
||
second_node[1] = json_object_new_object();
|
||
second_node[2] = json_object_new_array();
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
if (status_info->id_num == i && status_info->upload_flag == 1) {
|
||
status_info->upload_flag = 0;
|
||
second_node[3] = json_object_new_object();
|
||
json_object_object_add(second_node[3], "statusName", json_object_new_string(status_info->statusName));
|
||
json_object_object_add(second_node[3], "curStatusValue", json_object_new_int(status_info->statusValue));
|
||
if (status_info->param_vaild) {
|
||
printf("%s into param\r\n", status_info->statusName);
|
||
second_node[4] = json_object_new_array();
|
||
|
||
//if multple , use list_head -- 1
|
||
second_node[5] = json_object_new_object();
|
||
json_object_object_add(second_node[5], "param1", json_object_new_string("123"));
|
||
json_object_object_add(second_node[5], "param2", json_object_new_string("456"));
|
||
|
||
json_object_array_add(second_node[4], second_node[5]);
|
||
//if multple , use list_head--end -- 1
|
||
json_object_object_add(second_node[3], "extraStatusParam", second_node[4]);
|
||
}
|
||
json_object_array_add(second_node[2], second_node[3]);
|
||
}
|
||
}
|
||
if (!second_node[3]) {
|
||
json_object_put(second_node[1]);
|
||
second_node[1] = NULL;
|
||
json_object_put(second_node[2]);
|
||
second_node[2] = NULL;
|
||
} else {
|
||
json_object_object_add(second_node[1], "serialId", json_object_new_int(i));
|
||
json_object_object_add(second_node[1], "statusSerial", second_node[2]);
|
||
json_object_array_add(second_node[0], second_node[1]);
|
||
}
|
||
}
|
||
if (!second_node[3]) {
|
||
json_object_put(second_node[0]);
|
||
second_node[0] = NULL;
|
||
} else {
|
||
json_object_object_add(first_node, "statusSerials", second_node[0]);
|
||
}
|
||
}
|
||
|
||
//resourceSerials
|
||
res_info = list_first_entry(&res_head.entry, struct dev_res, entry);
|
||
if (*(res_info->resourceName)) {
|
||
third_node[0] = json_object_new_array();
|
||
total = 1;
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
//先统计要上报的资源总数
|
||
if (res_info->upload_flag == 1) {
|
||
total = res_info->total > total ? res_info->total + 1 : total;
|
||
}
|
||
}
|
||
for (int i = 0; i < total; i++) {
|
||
third_node[3] = NULL;
|
||
third_node[1] = json_object_new_object();
|
||
third_node[2] = json_object_new_array();
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
if (res_info->id_num == i && res_info->upload_flag == 1) {
|
||
res_info->upload_flag = 0;
|
||
third_node[3] = json_object_new_object();
|
||
json_object_object_add(third_node[3], "resourceName", json_object_new_string(res_info->resourceName));
|
||
third_node[4] = json_object_new_array();
|
||
|
||
//if multple , use list_head -- 2
|
||
third_node[5] = json_object_new_object();
|
||
json_object_object_add(third_node[5], "CONSUM_ID", json_object_new_int(res_info->param.consum_ID));
|
||
json_object_object_add(third_node[5], "CONSUM_NAME", json_object_new_string(res_info->param.consum_name));
|
||
json_object_object_add(third_node[5], "REMAIN_LIFE", json_object_new_int(res_info->param.remain_life));
|
||
json_object_array_add(third_node[4], third_node[5]);
|
||
//if multple , use list_head --end -- 2
|
||
|
||
json_object_object_add(third_node[3], "resourceInfo", third_node[4]);
|
||
json_object_array_add(third_node[2], third_node[3]);
|
||
}
|
||
}
|
||
if (!third_node[3]) {
|
||
json_object_put(third_node[1]);
|
||
third_node[1] = NULL;
|
||
json_object_put(third_node[2]);
|
||
third_node[2] = NULL;
|
||
} else {
|
||
json_object_object_add(third_node[1], "serialId", json_object_new_int(i));
|
||
json_object_object_add(third_node[1], "resourceSerial", third_node[2]);
|
||
json_object_array_add(third_node[0], third_node[1]);
|
||
}
|
||
|
||
}
|
||
if (!third_node[3]) {
|
||
json_object_put(third_node[0]);
|
||
third_node[0] = NULL;
|
||
} else {
|
||
json_object_object_add(first_node, "resourceSerials", third_node[0]);
|
||
}
|
||
}
|
||
//time
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
char *encrypt_buf = NULL, *encode_buf = NULL;
|
||
int encrypt_len;
|
||
encrypt_buf = (char *)calloc(1, strlen(json_object_get_string(first_node)) + 16);
|
||
if (!encrypt_buf) {
|
||
printf("encrypt_buf malloc failed ----%s-----%d\r\n", __func__, __LINE__);
|
||
json_object_put(first_node);
|
||
return NULL;
|
||
}
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, 16, device.sessionKey, 16, encrypt_buf, &encrypt_len);
|
||
|
||
encode_buf = base64_encode(encrypt_buf, encrypt_len, NULL);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2006));
|
||
json_object_object_add(root_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encode_buf));
|
||
char *send_buf = (char *)calloc(1, strlen(json_object_get_string(root_node)) + 4);
|
||
strcpy(send_buf, "CTS");
|
||
strcat(send_buf, json_object_to_json_string_ext(root_node, JSON_C_TO_STRING_NOSLASHESCAPE));
|
||
strcat(send_buf, "\r\n");
|
||
|
||
/* printf("\nlen = %d\nbuf = %s\r\n", strlen(json_object_get_string(first_node)), json_object_get_string(first_node)); */
|
||
|
||
if (encrypt_buf) {
|
||
free(encrypt_buf);
|
||
}
|
||
if (encode_buf) {
|
||
free(encode_buf);
|
||
}
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
|
||
return send_buf;
|
||
}
|
||
|
||
#if 0 //#没测试到，待修改
|
||
|
||
static void CT_dev_status_reply(void) //device->server
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "result", json_object_new_int(0));
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2002));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
return;
|
||
}
|
||
|
||
static void CT_dev_manage_reply(void) //device->server
|
||
{
|
||
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "result", json_object_new_int(0));
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2030));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
static void CT_dev_resource_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
int resource_serialId_num = 0;
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5], *third_node[5];
|
||
struct list_head *pos = NULL;
|
||
struct dev_res *res_info = NULL;
|
||
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
//resourceSerials
|
||
res_info = list_first_entry(&res_head.entry, struct dev_res, entry);
|
||
if (res_info != &res_head) {
|
||
third_node[0] = json_object_new_array();
|
||
if (list_first_entry(&res_info->entry, struct dev_res, entry) != &res_head) {
|
||
resource_serialId_num = 1;
|
||
} else {
|
||
resource_serialId_num = 0;
|
||
}
|
||
list_for_each(pos, &res_head.entry) {
|
||
res_info = list_entry(pos, struct dev_res, entry);
|
||
third_node[1] = json_object_new_object();
|
||
json_object_object_add(third_node[1], "serialId", json_object_new_int(resource_serialId_num++));
|
||
third_node[2] = json_object_new_array();
|
||
|
||
//if multple , use list_head -- 1
|
||
third_node[3] = json_object_new_object();
|
||
json_object_object_add(second_node[3], "resourceName", json_object_new_string(res_info->resourceName));
|
||
third_node[4] = json_object_new_array();
|
||
|
||
|
||
//if multple , use list_head -- 2
|
||
third_node[5] = json_object_new_object();
|
||
json_object_object_add(third_node[5], "CONSUM_ID", json_object_new_int(res_info->param.consum_ID));
|
||
json_object_object_add(third_node[5], "CONSUM_NAME", json_object_new_string(res_info->param.consum_name));
|
||
json_object_object_add(third_node[5], "REMAIN_LIFE", json_object_new_int(res_info->param.remain_life));
|
||
json_object_array_add(third_node[4], third_node[5]);
|
||
//if multple , use list_head --end -- 2
|
||
|
||
json_object_object_add(third_node[3], "resourceInfo", third_node[4]);
|
||
json_object_array_add(third_node[2], third_node[3]);
|
||
//if multple , use list_head --end -- 1
|
||
|
||
json_object_object_add(third_node[1], "resourceSerial", third_node[2]);
|
||
json_object_array_add(third_node[0], third_node[1]);
|
||
}
|
||
json_object_object_add(first_node, "resourceSerials", third_node[0]);
|
||
}
|
||
//time
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
printf("%s %d\r\n", device.sessionKey, strlen(device.sessionKey));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2028));
|
||
json_object_object_add(root_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(first_node));
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
printf("***********************\r\n");
|
||
|
||
free(encode_buf);
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
}
|
||
|
||
void CT_dev_message_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
int event_num = 0, event_serialId_num = 0;
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5], *third_node[5];
|
||
struct list_head *pos = NULL;
|
||
struct device_eventInfo *event_info = NULL;
|
||
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
//event
|
||
second_node[0] = json_object_new_array();
|
||
list_for_each(pos, &event_head.entry) {
|
||
event_info = list_entry(pos, struct device_eventInfo, entry);
|
||
second_node[1] = json_object_new_object();
|
||
json_object_object_add(second_node[1], "eventId", json_object_new_int(event_num++));
|
||
json_object_object_add(second_node[1], "serialId", json_object_new_int(event_serialId_num++));
|
||
json_object_object_add(second_node[1], "eventNmame", json_object_new_string(event_info->eventName));
|
||
second_node[2] = json_object_new_array();
|
||
|
||
//if multple , use list_head -- 1
|
||
second_node[3] = json_object_new_object();
|
||
json_object_object_add(second_node[3], event_info->param.ID_name, json_object_new_int(event_info->param.ID_value));
|
||
json_object_object_add(second_node[3], event_info->param.TYPE_name, json_object_new_int(event_info->param.TYPE_value));
|
||
json_object_object_add(second_node[3], "TIME", json_object_new_int(time(NULL)));
|
||
|
||
|
||
json_object_array_add(second_node[2], second_node[3]);
|
||
//if multple , use list_head --end -- 1
|
||
|
||
json_object_object_add(second_node[1], "eventInfo", second_node[2]);
|
||
json_object_array_add(second_node[0], second_node[1]);
|
||
}
|
||
json_object_object_add(first_node, "event", second_node[0]);
|
||
|
||
//time
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2032));
|
||
json_object_object_add(root_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(first_node));
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
printf("***********************\r\n");
|
||
|
||
free(encode_buf);
|
||
json_object_put(root_node);
|
||
json_object_put(first_node);
|
||
}
|
||
|
||
void CT_dev_alarm_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
int alarm_serialId_num = 0;
|
||
struct dev_status *alarm_info = NULL;
|
||
alarm_info = get_alarm_info();
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
//alarm
|
||
second_node[0] = json_object_new_object();
|
||
json_object_object_add(second_node[0], "serialId", json_object_new_int(alarm_serialId_num++));
|
||
json_object_object_add(second_node[0], "statusName", json_object_new_string(alarm_info->statusName));
|
||
json_object_object_add(second_node[0], "curStatusValue", json_object_new_int(alarm_info->statusValue));
|
||
json_object_object_add(second_node[0], "dscp", json_object_new_string("qwasdsadasdas"));
|
||
json_object_object_add(second_node[0], "alarmtime", json_object_new_int(time(NULL)));
|
||
|
||
json_object_object_add(first_node, "alarm", second_node[0]);
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2008));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_dev_fault_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
int error_serialId_num = 0;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
//error
|
||
second_node[0] = json_object_new_object();
|
||
json_object_object_add(second_node[0], "serialId", json_object_new_int(error_serialId_num++));
|
||
json_object_object_add(second_node[0], "errorCode", json_object_new_int(100001));
|
||
json_object_object_add(second_node[0], "errorInfo", json_object_new_string("qwasdsadasdas"));
|
||
json_object_object_add(second_node[0], "errortime", json_object_new_int(time(NULL)));
|
||
|
||
json_object_object_add(first_node, "error", second_node[0]);
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2010));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_sub_dev_ID_auth_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "subDeviceId", json_object_new_string(CT_SUB_DEVICE_ID));
|
||
json_object_object_add(first_node, "pin", json_object_new_string(device.pin));
|
||
#if (defined CT_SUB_DEVICE_MAC)
|
||
json_object_object_add(first_node, "subDevMac", json_object_new_string(CT_SUB_DEVICE_MAC));
|
||
#endif
|
||
|
||
#if (defined CT_SUB_DEVICE_CTEI)
|
||
json_object_object_add(first_node, "subDevCTEI", json_object_new_string(CT_SUB_DEVICE_CTEI));
|
||
#endif
|
||
|
||
#if (defined CT_PARENT_DEV_MAC)
|
||
json_object_object_add(first_node, "parentDevMac", json_object_new_string(CT_PARENT_DEV_MAC));
|
||
#endif
|
||
|
||
#if (defined CT_SUB_DEVICE_IP)
|
||
json_object_object_add(first_node, "subDevIp", json_object_new_string(CT_SUB_DEVICE_IP));
|
||
#endif
|
||
|
||
#if (defined CT_SUB_DEVICE_VERSION)
|
||
json_object_object_add(first_node, "subVersion", json_object_new_string(CT_SUB_DEVICE_VERSION));
|
||
#endif
|
||
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2012));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_sub_dev_CTEI_auth_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
#if (defined CT_SUB_DEVICE_MAC)
|
||
json_object_object_add(first_node, "subDevMac", json_object_new_string(CT_SUB_DEVICE_MAC));
|
||
#endif
|
||
#if (defined CT_SUB_DEVICE_VERSION)
|
||
json_object_object_add(first_node, "subVersion", json_object_new_string(CT_SUB_DEVICE_VERSION));
|
||
#endif
|
||
json_object_object_add(first_node, "pin", json_object_new_string(device.pin));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2112));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_sub_dev_unbind_reply(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "result", json_object_new_int(0));
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "subDeviceId", json_object_new_string(CT_SUB_DEVICE_ID));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2014));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_sub_dev_bind_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "subDeviceId", json_object_new_string(CT_SUB_DEVICE_ID));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2016));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_sub_dev_unbind_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "subDeviceId", json_object_new_string(CT_SUB_DEVICE_ID));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2018));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_sub_dev_online_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "subDeviceId", json_object_new_string(CT_SUB_DEVICE_ID));
|
||
json_object_object_add(first_node, "onLine", json_object_new_int(1));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2020));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_dev_version_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "model", json_object_new_string(device.model));
|
||
|
||
second_node[0] = json_object_new_object();
|
||
json_object_object_add(second_node[0], "version", json_object_new_string(CT_DEVICE_VERSION));
|
||
json_object_object_add(first_node, "device", second_node[0]);
|
||
|
||
if (0) { //have modules
|
||
second_node[1] = json_object_new_array();
|
||
|
||
//if multple , use list_head
|
||
second_node[2] = json_object_new_object();
|
||
json_object_object_add(second_node[2], "name", json_object_new_string("123"));
|
||
json_object_object_add(second_node[2], "version", json_object_new_string("1.2.3"));
|
||
json_object_array_add(second_node[1], second_node[2]);
|
||
//if multple , use list_head --end
|
||
json_object_object_add(first_node, "modules", second_node[1]);
|
||
|
||
}
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2022));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_dev_upgrade_reply(void) //device->server
|
||
{
|
||
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL;
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "result", json_object_new_int(0));
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2024));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_dev_upgrade_result_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
int type = 0, upgrade_status = 0;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "type", json_object_new_int(type));
|
||
if (type == 1) {
|
||
json_object_object_add(first_node, "moduleName", json_object_new_string("1asdas"));
|
||
}
|
||
json_object_object_add(first_node, "status", json_object_new_int(upgrade_status));
|
||
json_object_object_add(first_node, "version", json_object_new_string(CT_DEVICE_VERSION));
|
||
json_object_object_add(first_node, "percent", json_object_new_string("20\%"));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(2026));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_voice_control_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
int extensions = 0;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
//需要配合sn，islast判断是否加1
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
second_node[0] = json_object_new_object();
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "format", json_object_new_string("amr"));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "rate", json_object_new_int(8000));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "channel", json_object_new_int(1));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "vocieId", json_object_new_string("12312321"));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "sn", json_object_new_int(1));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "isLast", json_object_new_int(0));
|
||
}
|
||
json_object_object_add(second_node[0], "audioData", json_object_new_string(" "));
|
||
if (extensions == 1) {
|
||
second_node[1] = json_object_new_array();
|
||
//if multple , use list_head
|
||
second_node[2] = json_object_new_object();
|
||
json_object_object_add(second_node[2], "key", json_object_new_string("213"));
|
||
json_object_object_add(second_node[2], "value", json_object_new_int(1));
|
||
json_object_array_add(second_node[1], second_node[2]);
|
||
//if multple , use list_head --end
|
||
|
||
json_object_object_add(second_node[0], "extensions", second_node[1]);
|
||
}
|
||
json_object_object_add(first_node, "CtrlParam", second_node[0]);
|
||
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(3002));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_speech_synthesis_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
int extensions = 0;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
|
||
second_node[0] = json_object_new_object();
|
||
json_object_object_add(second_node[0], "content", json_object_new_string("已经为你打开空调!"));
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "anchor", json_object_new_string("xiaoyan"));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "speed", json_object_new_int(123));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "volume", json_object_new_int(123));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "pitch", json_object_new_int(123));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "format", json_object_new_string("amr"));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "rate", json_object_new_int(8000));
|
||
}
|
||
if (1) {
|
||
json_object_object_add(second_node[0], "channel", json_object_new_int(1));
|
||
}
|
||
json_object_object_add(first_node, "ttsParam", second_node[0]);
|
||
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(3000));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_dev_data_download_reply(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
int error_serialId_num = 0;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "result", json_object_new_int(0));
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
json_object_object_add(first_node, "downDataResp", json_object_new_string("1232132131"));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(9000));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
void CT_dev_data_upload_request(void)
|
||
{
|
||
char encrypt_buf[512];
|
||
char *encode_buf;
|
||
unsigned int encode_len;
|
||
int encrypt_len;
|
||
|
||
int error_serialId_num = 0;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node[5];
|
||
first_node = json_object_new_object();
|
||
json_object_object_add(first_node, "sequence", json_object_new_int(device.serial_num++));
|
||
json_object_object_add(first_node, "deviceId", json_object_new_string(device.deviceId));
|
||
json_object_object_add(first_node, "time", json_object_new_int(time(NULL)));
|
||
json_object_object_add(first_node, "upData", json_object_new_string("1232132131"));
|
||
|
||
//encrypt
|
||
CT_AES_CBC_Encrypt((u8 *)json_object_get_string(first_node), strlen(json_object_get_string(first_node)), device.sessionKey, strlen(device.sessionKey), device.iv, strlen(device.iv), encrypt_buf, &encrypt_len);
|
||
|
||
root_node = json_object_new_object();
|
||
json_object_object_add(root_node, "code", json_object_new_int(9002));
|
||
json_object_object_add(first_node, "token", json_object_new_string(device.token));
|
||
json_object_object_add(root_node, "data", json_object_new_string(encrypt_buf));
|
||
|
||
printf("***********************\r\n");
|
||
printf("*********%s**************\r\n", __func__);
|
||
printf("%s\r\n", json_object_get_string(root_node));
|
||
|
||
encode_buf = base64_encode(json_object_get_string(root_node), strlen(json_object_get_string(root_node)), &encode_len);
|
||
|
||
printf("%s\r\n", encode_buf);
|
||
|
||
free(encode_buf);
|
||
}
|
||
|
||
#endif
|
||
|
||
static void CT_server_to_device_fun(void *priv)
|
||
{
|
||
u8 connecting = 1;
|
||
char cmdName[32] = {0}, cmdParam[128] = {0}, parse_buf[64] = {0};
|
||
unsigned int decrypt_len;
|
||
int parse_len, decode_len, code, msg[32], err, serial_num;
|
||
char *decode_buf = NULL, *decrypt_buf = NULL;
|
||
|
||
json_object *root_node = NULL, *first_node = NULL, *second_node = NULL;
|
||
|
||
while (connecting) {
|
||
err = os_taskq_pend("taskq", msg, ARRAY_SIZE(msg));
|
||
if (err != OS_TASKQ || msg[0] != Q_USER) {
|
||
continue;
|
||
}
|
||
|
||
switch (msg[1]) {
|
||
case RECV_MSG:
|
||
|
||
root_node = json_tokener_parse(strstr((char *)msg[2], "{"));
|
||
if (!root_node) {
|
||
log_info("%d buf1 root_node error", __LINE__);
|
||
goto exit;
|
||
}
|
||
free((char *)msg[2]);
|
||
|
||
code = json_object_get_int(json_object_object_get(root_node, "code"));
|
||
|
||
if (!json_object_object_get_ex(root_node, "data", &first_node)) {
|
||
goto exit;
|
||
}
|
||
json_object_get(first_node);
|
||
json_object_put(root_node);
|
||
root_node = NULL;
|
||
|
||
decode_buf = base64_decode(json_object_get_string(first_node), strlen(json_object_get_string(first_node)), &decode_len);
|
||
decrypt_buf = (char *)calloc(1, decode_len + 1);
|
||
if (!decrypt_buf) {
|
||
log_info("------%s-----------%d------malloc failed", __func__, __LINE__);
|
||
goto exit;
|
||
}
|
||
if ((code == 1003) || (code == 1103)) {
|
||
CT_AES_CBC_Decrypt(decode_buf, decode_len, device.pin, 16, device.iv, 16, decrypt_buf, &decrypt_len);
|
||
} else {
|
||
CT_AES_CBC_Decrypt(decode_buf, decode_len, device.sessionKey, 16, device.sessionKey, 16, decrypt_buf, &decrypt_len);
|
||
}
|
||
|
||
log_info("code = %d\nbuf = %s", code, decrypt_buf);
|
||
//json
|
||
root_node = json_tokener_parse(decrypt_buf);
|
||
if (!root_node) {
|
||
log_info("%d root_node NULL", __LINE__);
|
||
goto exit;
|
||
}
|
||
if (decode_buf) {
|
||
free(decode_buf);
|
||
decode_buf = NULL;
|
||
}
|
||
if (decrypt_buf) {
|
||
free(decrypt_buf);
|
||
decrypt_buf = NULL;
|
||
}
|
||
|
||
if (code == 2003 || code == 2005 || code == 2031 || code == 2015 || code == 2025 || code == 9001) {
|
||
recv_sequence_num = json_object_get_int(json_object_object_get(root_node, "sequence"));
|
||
} else {
|
||
if (0 != json_object_get_int(json_object_object_get(root_node, "result"))) {
|
||
log_info("%s------%d result not 0", __func__, __LINE__);
|
||
if (code == 2007) {
|
||
init_upload_flag();
|
||
}
|
||
CT_error_fun(json_object_get_int(json_object_object_get(root_node, "result")));
|
||
goto exit;
|
||
}
|
||
|
||
serial_num = json_object_get_int(json_object_object_get(root_node, "sequence"));
|
||
if (code == 1001) {
|
||
heart_send = 0;
|
||
}
|
||
if ((device.serial_num - heart_send) != serial_num) {
|
||
log_info("%d serial_num not match\n\n\n", __LINE__);
|
||
goto exit;
|
||
}
|
||
}
|
||
|
||
switch (code) {
|
||
//-----------设备通道层接口
|
||
case 1003: //设备ID登录响应
|
||
if (*json_object_get_string(json_object_object_get(root_node, "sessionKey"))) {
|
||
strcpy(device.sessionKey, json_object_get_string(json_object_object_get(root_node, "sessionKey")));
|
||
}
|
||
|
||
|
||
if (*json_object_get_string(json_object_object_get(root_node, "tcpHost"))) {
|
||
strcpy(parse_buf, json_object_get_string(json_object_object_get(root_node, "tcpHost")));
|
||
parse_len = strchr(parse_buf, ':') - parse_buf + 1;
|
||
strncpy(device.tcpHost, parse_buf, parse_len - 1);
|
||
strcpy(device.tcp_port, parse_buf + parse_len);
|
||
memset(parse_buf, 0, sizeof(parse_buf));
|
||
}
|
||
|
||
if (*json_object_get_string(json_object_object_get(root_node, "udpHost"))) {
|
||
strcpy(parse_buf, json_object_get_string(json_object_object_get(root_node, "udpHost")));
|
||
parse_len = strchr(parse_buf, ':') - parse_buf + 1;
|
||
strncpy(device.udpHost, parse_buf, parse_len - 1);
|
||
strcpy(device.udp_port, parse_buf + parse_len);
|
||
memset(parse_buf, 0, sizeof(parse_buf));
|
||
}
|
||
|
||
if (*json_object_get_string(json_object_object_get(root_node, "token"))) {
|
||
strcpy(device.token, json_object_get_string(json_object_object_get(root_node, "token")));
|
||
}
|
||
|
||
log_info("sessionkey = %s, tcpHost = %s, tcp_port = %s,udpHost = %s,udp_port = %s, token = %s\r\n", device.sessionKey, device.tcpHost, device.tcp_port, device.udpHost, device.udp_port, device.token);
|
||
|
||
for (int i = 0; i < 3; i++) {
|
||
if (0 == tcp_device_init(NULL)) { //连接业务服务器
|
||
thread_fork("msg_recv_handler", 8, 2048, 0, NULL, tcp_recv_handler, NULL);
|
||
//发送信息
|
||
tcp_send_function(1004);
|
||
break;
|
||
} else {
|
||
printf("------%s-----%d connect server failed ,i = %d\r\n", __func__, __LINE__, i);
|
||
}
|
||
}
|
||
break;
|
||
|
||
case 1005: //设备连接响应
|
||
device.login_flag = 1; //设备登录标志位置1
|
||
//heatBeat
|
||
if (*json_object_get_string(json_object_object_get(root_node, "heartBeat"))) {
|
||
device.heartBeat = json_object_get_int(json_object_object_get(root_node, "heartBeat"));
|
||
} else {
|
||
device.heartBeat = 30;
|
||
}
|
||
|
||
//authInterval 如果不设置就默认为0， 前3次60s 后续600s
|
||
if (*json_object_get_string(json_object_object_get(root_node, "authInterval"))) {
|
||
device.authInterval = json_object_get_int(json_object_object_get(root_node, "authInterval"));
|
||
}
|
||
//上报设备状态跟资源信息 code:2006
|
||
tcp_send_function(2006);
|
||
if (!heartbeat_id) {
|
||
heartbeat_id = sys_timer_add_to_task("app_core", NULL, heartbeat_ctl_func, device.heartBeat * 1000);
|
||
}
|
||
|
||
if (heartbeat_timeout_id) {
|
||
sys_timer_modify(heartbeat_timeout_id, (device.heartBeat * 3 + 10) * 1000);
|
||
} else {
|
||
heartbeat_timeout_id = sys_timeout_add_to_task("app_core", NULL, timeout_func, (device.heartBeat * 3 + 10) * 1000);
|
||
}
|
||
|
||
break;
|
||
|
||
case 1001: //设备心跳响应
|
||
//将心跳计数标志位清零 重新计数超时
|
||
if (heartbeat_timeout_id) {
|
||
sys_timer_re_run(heartbeat_timeout_id);
|
||
}
|
||
|
||
break;
|
||
|
||
case 1103: //设备ctei登录响应
|
||
if (*json_object_get_string(json_object_object_get(root_node, "sessionKey"))) {
|
||
strcpy(device.sessionKey, json_object_get_string(json_object_object_get(root_node, "sessionKey")));
|
||
}
|
||
|
||
if (*json_object_get_string(json_object_object_get(root_node, "tcpHost"))) {
|
||
strcpy(parse_buf, json_object_get_string(json_object_object_get(root_node, "tcpHost")));
|
||
parse_len = strchr(parse_buf, ':') - parse_buf + 1;
|
||
strncpy(device.tcpHost, parse_buf, parse_len - 1);
|
||
strcpy(device.tcp_port, parse_buf + parse_len);
|
||
memset(parse_buf, 0, sizeof(parse_buf));
|
||
}
|
||
|
||
if (*json_object_get_string(json_object_object_get(root_node, "udpHost"))) {
|
||
strcpy(parse_buf, json_object_get_string(json_object_object_get(root_node, "udpHost")));
|
||
parse_len = strchr(parse_buf, ':') - parse_buf + 1;
|
||
strncpy(device.udpHost, parse_buf, parse_len - 1);
|
||
strcpy(device.udp_port, parse_buf + parse_len);
|
||
memset(parse_buf, 0, sizeof(parse_buf));
|
||
}
|
||
if (*json_object_get_string(json_object_object_get(root_node, "deviceId"))) {
|
||
strcpy(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")));
|
||
}
|
||
|
||
if (*json_object_get_string(json_object_object_get(root_node, "token"))) {
|
||
strcpy(device.token, json_object_get_string(json_object_object_get(root_node, "token")));
|
||
}
|
||
|
||
log_info("sessionkey = %s, tcpHost = %s, tcp_port = %s,udpHost = %s,udp_port = %s,deviceId = %s token = %s\r\n", device.sessionKey, device.tcpHost, device.tcp_port, device.udpHost, device.udp_port, device.deviceId, device.token);
|
||
|
||
for (int i = 0; i < 3; i++) {
|
||
if (0 == tcp_device_init(NULL)) { //连接业务服务器
|
||
thread_fork("msg_recv_handler", 8, 2048, 0, NULL, tcp_recv_handler, NULL);
|
||
//发送信息
|
||
tcp_send_function(1004);
|
||
break;
|
||
} else {
|
||
printf(" %d connect server failed\r\n", i);
|
||
}
|
||
}
|
||
break;
|
||
|
||
//------------设备业务层接口
|
||
case 2003: //设备状态查询请求 #
|
||
if (device.deviceId == json_object_get_string(json_object_object_get(root_node, "deviceId"))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2005: //设备状态控制请求 #
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
log_info("into deviceid\r\n");
|
||
|
||
int tmp_serial = json_object_get_int(json_object_object_get(root_node, "serialId"));
|
||
|
||
for (int i = 0;; i++) {
|
||
second_node = json_object_array_get_idx(json_object_object_get(root_node, "cmd"), i);
|
||
if (second_node == NULL) {
|
||
break;
|
||
}
|
||
strcpy(cmdName, json_object_get_string(json_object_object_get(second_node, "cmdName")));
|
||
strcpy(cmdParam, json_object_get_string(json_object_object_get(second_node, "cmdParam")));
|
||
status_set_func(tmp_serial, cmdName, cmdParam);
|
||
memset(cmdName, 0, sizeof(cmdName));
|
||
memset(cmdParam, 0, sizeof(cmdParam));
|
||
|
||
}
|
||
|
||
tcp_send_function(2004);
|
||
if (device_status_id) {
|
||
sys_timer_re_run(device_status_id);
|
||
} else {
|
||
//延迟5S后汇报
|
||
device_status_id = sys_timeout_add(NULL, device_status_func, 5000);
|
||
}
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2007: //设备状态/资源上报响应
|
||
report_all = 1;
|
||
//可选择性的在此处进行flash更新
|
||
thread_fork("write_flash", 20, 1024, 0, NULL, device_write_flash, NULL);
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来响应对应的子设备
|
||
}
|
||
break;
|
||
#if 0 //#没测试到，待修改
|
||
case 2031: //设备资源管理请求 #
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2029: //设备资源变化上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2033: //设备信息上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2009: //设备状态告警响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2011: //设备故障反馈响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//服务器是查找本设备，10s内上报设备最新状态
|
||
} else {
|
||
//查询设备绑定的子设备是否存在ID与deviceId相同，若存在则将该命令转换来查询对应的子设备
|
||
}
|
||
break;
|
||
|
||
case 2013: //子设备ID鉴权响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//看对应子设备ID authResult 为0 则鉴权成功
|
||
}
|
||
|
||
break;
|
||
|
||
case 2015: //子设备解绑请求 #
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//看对应子设备ID 进行下线解绑操作
|
||
}
|
||
break;
|
||
|
||
case 2017: //子设备绑定上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//看对应子设备ID
|
||
}
|
||
|
||
break;
|
||
|
||
case 2019: //子设备解绑上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//看对应子设备ID
|
||
}
|
||
|
||
break;
|
||
|
||
case 2021: //子设备在线状态上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//看对应子设备ID
|
||
}
|
||
|
||
break;
|
||
|
||
case 2023: //设备版本上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//
|
||
}
|
||
|
||
break;
|
||
|
||
case 2025: //设备版本升级通知请求 #
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//
|
||
}
|
||
|
||
break;
|
||
|
||
case 2027: //设备版本升级结果上报响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//
|
||
}
|
||
|
||
break;
|
||
|
||
case 3003: //语音控制响应
|
||
if ((400002 || 0) != atoi(json_object_get_string(json_object_object_get(root_node, "result")))) {
|
||
log_info("%d result not 0", __LINE__);
|
||
CT_error_fun(atoi(json_object_get_string(json_object_object_get(root_node, "result"))));
|
||
break;
|
||
}
|
||
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//
|
||
}
|
||
if (json_object_object_get_ex(root_node, "ctrlResult", &first_node)) {
|
||
char ctrl_buf[512] = {0};
|
||
strcpy(ctrl_buf, json_object_get_string(first_node));
|
||
//进行后续操作
|
||
}
|
||
|
||
break;
|
||
|
||
case 3001: //语音合成响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//
|
||
}
|
||
if (json_object_object_get_ex(root_node, "ttsResult", &first_node)) {
|
||
char tts_buf[512] = {0};
|
||
strcpy(tts_buf, json_object_get_string(first_node));
|
||
//进行后续操作
|
||
}
|
||
|
||
break;
|
||
|
||
case 2113: //子设备ctei鉴权
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
//看对应子设备ID authResult 为0 则鉴权成功
|
||
}
|
||
|
||
break;
|
||
|
||
case 9001: //设备数据下行请求 #
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
|
||
}
|
||
|
||
//downData
|
||
|
||
break;
|
||
|
||
case 9003: //设备数据上行响应
|
||
if (!strcmp(device.deviceId, json_object_get_string(json_object_object_get(root_node, "deviceId")))) {
|
||
|
||
}
|
||
|
||
//upData
|
||
|
||
break;
|
||
#endif
|
||
|
||
deault:
|
||
break;
|
||
|
||
}
|
||
exit:
|
||
json_object_put(second_node);
|
||
second_node = NULL;
|
||
json_object_put(first_node);
|
||
first_node = NULL;
|
||
json_object_put(root_node);
|
||
root_node = NULL;
|
||
if (decode_buf) {
|
||
free(decode_buf);
|
||
decode_buf = NULL;
|
||
}
|
||
if (decrypt_buf) {
|
||
free(decrypt_buf);
|
||
decrypt_buf = NULL;
|
||
}
|
||
break;
|
||
|
||
case CONNECT_CLOSE:
|
||
connecting = 0;
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
//recv
|
||
static void tcp_recv_handler(void *priv)
|
||
{
|
||
int recv_len = 0;
|
||
char *ptr;
|
||
char recv_buf[1024] = {0};
|
||
|
||
for (;;) {
|
||
recv_len = sock_recvfrom(device.tcp_sock, recv_buf + recv_len, sizeof(recv_buf), 0, NULL, NULL);
|
||
if (recv_len > 0) {
|
||
ptr = strstr(recv_buf, "\r\n");
|
||
|
||
if (ptr != NULL) {
|
||
printf("recv completed!\r\n");
|
||
char *tmp_buf = (char *)calloc(1, strlen(recv_buf) + 1);
|
||
strcpy(tmp_buf, recv_buf);
|
||
os_taskq_post("server_to_device", 2, RECV_MSG, (int *)tmp_buf);
|
||
recv_len = 0;
|
||
memset(recv_buf, 0, sizeof(recv_buf));
|
||
}
|
||
} else {
|
||
printf("tcp recv len = %d\r\n", recv_len);
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
static int tcp_device_init(char *tcp_host)
|
||
{
|
||
char ipaddr[20];
|
||
if (device.tcp_sock) {
|
||
sock_unreg(device.tcp_sock);
|
||
device.tcp_sock = NULL;
|
||
}
|
||
|
||
if (tcp_host != NULL) {
|
||
memset(&device.dest, 0, sizeof(device.dest));
|
||
struct hostent *hent = NULL;
|
||
int cnt = 0;
|
||
char tmp_host[50] = {0}, *pA = NULL;
|
||
strcpy(tmp_host, tcp_host);
|
||
pA = strpbrk(tmp_host, ":/");
|
||
if (NULL == pA) {
|
||
cnt = strlen(tmp_host);
|
||
} else {
|
||
cnt = pA - tmp_host;
|
||
}
|
||
tmp_host[cnt] = '\0';
|
||
pA = strstr(tcp_host, tmp_host) + strlen(tmp_host);
|
||
if (':' == *pA) {
|
||
pA++;
|
||
device.dest.sin_port = htons(atoi(pA));
|
||
} else {
|
||
device.dest.sin_port = htons(80);
|
||
}
|
||
hent = gethostbyname(tmp_host);
|
||
if (hent == NULL) {
|
||
printf("hent NULL\r\n");
|
||
return -1;
|
||
}
|
||
memcpy(&device.dest.sin_addr, hent->h_addr, sizeof(struct in_addr));
|
||
} else {
|
||
memset(&device.dest, 0, sizeof(device.dest));
|
||
device.dest.sin_addr.s_addr = inet_addr(device.tcpHost);
|
||
device.dest.sin_port = htons(atoi(device.tcp_port));
|
||
}
|
||
|
||
device.tcp_sock = sock_reg(AF_INET, SOCK_STREAM, 0, NULL, NULL);
|
||
if (device.tcp_sock == NULL) {
|
||
log_info("%s tcp: sock_reg fail\n", __func__);
|
||
return -1;
|
||
}
|
||
if (0 != sock_set_reuseaddr(device.tcp_sock)) {
|
||
sock_unreg(device.tcp_sock);
|
||
return -1;
|
||
}
|
||
sock_set_connect_to(device.tcp_sock, 10000);
|
||
/* sock_set_recv_timeout(device.tcp_sock, 40000); */
|
||
sock_set_send_timeout(device.tcp_sock, 10000);
|
||
|
||
device.local.sin_addr.s_addr = htonl(INADDR_ANY);
|
||
device.local.sin_port = htons(0);
|
||
device.local.sin_family = AF_INET;
|
||
if (0 != sock_bind(device.tcp_sock, (struct sockaddr *)&device.local, sizeof(struct sockaddr_in))) {
|
||
sock_unreg(device.tcp_sock);
|
||
log_info("%s sock_bind fail\n", __func__);
|
||
return -1;
|
||
}
|
||
|
||
|
||
device.dest.sin_family = AF_INET;
|
||
if (0 != sock_connect(device.tcp_sock, (struct sockaddr *)&device.dest, sizeof(struct sockaddr_in))) {
|
||
log_info("sock_connect fail.\n");
|
||
printf("ip addr = 0x%x,port = 0x%x\r\n", device.dest.sin_addr.s_addr, device.dest.sin_port);
|
||
sock_unreg(device.tcp_sock);
|
||
return -1;
|
||
}
|
||
|
||
|
||
return 0;
|
||
}
|
||
|
||
static void device_login_func(void *priv)
|
||
{
|
||
u8 i = 0;
|
||
while (1) {
|
||
if (!CT_connect_flag) {
|
||
printf("-------%s-------%d\r\n", __func__, __LINE__);
|
||
return;
|
||
}
|
||
for (int cnt = 0; cnt < 3; cnt++) {
|
||
if (!tcp_device_init(CT_LOGIN_HOST)) {
|
||
goto _login;
|
||
}
|
||
}
|
||
if (device.authInterval) {
|
||
os_time_dly(device.authInterval * 100);
|
||
} else {
|
||
if (i < 3) {
|
||
os_time_dly(60 * 100);
|
||
i++;
|
||
} else {
|
||
os_time_dly(600 * 100);
|
||
}
|
||
}
|
||
}
|
||
_login:
|
||
//创建线程，用于接收tcp_server的数据
|
||
thread_fork("login_recv_handler", 8, 2048, 20, NULL, tcp_recv_handler, NULL);
|
||
|
||
if (!server_func_id) {
|
||
thread_fork("server_to_device", 8, 8192, 20, &server_func_id, CT_server_to_device_fun, NULL);
|
||
}
|
||
|
||
tcp_send_function(1102);
|
||
|
||
if (!heartbeat_timeout_id) {
|
||
heartbeat_timeout_id = sys_timeout_add_to_task("app_core", NULL, timeout_func, 20 * 1000);
|
||
}
|
||
return ;
|
||
|
||
}
|
||
|
||
static void timeout_func(void *priv)
|
||
{
|
||
printf("into timeout\r\n");
|
||
device.login_flag = 0;
|
||
report_all = 0;
|
||
heart_send = 0;
|
||
if (device.tcp_sock) {
|
||
sock_set_quit(device.tcp_sock);
|
||
sock_unreg(device.tcp_sock); //断开服务器socket
|
||
device.tcp_sock = NULL;
|
||
}
|
||
|
||
if (heartbeat_id) {
|
||
sys_timer_del(heartbeat_id);
|
||
heartbeat_id = 0;
|
||
}
|
||
|
||
if (heartbeat_timeout_id) {
|
||
sys_timer_del(heartbeat_timeout_id);
|
||
heartbeat_timeout_id = 0;
|
||
}
|
||
|
||
if (!dev_login_pid) {
|
||
thread_fork("device_login", 8, 4096, 0, &dev_login_pid, device_login_func, NULL);
|
||
}
|
||
}
|
||
|
||
static void device_status_func(void *priv)
|
||
{
|
||
tcp_send_function(2006);
|
||
}
|
||
static void heartbeat_ctl_func(void *priv)
|
||
{
|
||
tcp_send_function(1000);
|
||
}
|
||
|
||
static void status_set_func(int serial, char *name, char *param)
|
||
{
|
||
int type = 0, power_status = 0;
|
||
struct dev_status *status_info = NULL;
|
||
struct list_head *pos = NULL;
|
||
if (!strcmp(name, "SET_POWER")) {
|
||
type = 1;
|
||
} else if (!strcmp(name, "SET_LIGHT_TEMP")) {
|
||
type = 2;
|
||
} else if (!strcmp(name, "SET_LIGHTNESS")) {
|
||
type = 3;
|
||
} else if (!strcmp(name, "SET_SOUND")) {
|
||
type = 4;
|
||
}
|
||
|
||
list_for_each(pos, &status_head.entry) {
|
||
status_info = list_entry(pos, struct dev_status, entry);
|
||
if (type == 1) {
|
||
if (!strcmp(status_info->statusName, "POWER") && status_info->id_num == serial) {
|
||
printf("into power\r\n");
|
||
power_status = atoi(param);
|
||
if (power_status == 2) {
|
||
power_status = status_info->statusValue ? 0 : 1;
|
||
}
|
||
status_info->statusValue = power_status;
|
||
status_info->upload_flag = 1;
|
||
break;
|
||
}
|
||
} else if (type == 2) {
|
||
if (!strcmp(status_info->statusName, "LIGHT_TEMP") && status_info->id_num == serial) {
|
||
printf("into light temp\r\n");
|
||
status_info->statusValue = atoi(param);
|
||
status_info->upload_flag = 1;
|
||
break;
|
||
}
|
||
} else if (type == 3) {
|
||
if (!strcmp(status_info->statusName, "LIGHTNESS") && status_info->id_num == serial) {
|
||
printf("into lightness\r\n");
|
||
status_info->statusValue = atoi(param);
|
||
status_info->upload_flag = 1;
|
||
break;
|
||
}
|
||
} else if (type == 4) {
|
||
if (!strcmp(status_info->statusName, "SOUND") && status_info->id_num == serial) {
|
||
printf("into sound\r\n");
|
||
status_info->statusValue = 0; //待解决
|
||
status_info->upload_flag = 1;
|
||
printf("sound = %s\r\n", param);
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
static void tcp_send_function(int code)
|
||
{
|
||
int len = 0, s_len = 0;
|
||
char *data = NULL;
|
||
printf("code = %d\r\n", code);
|
||
switch (code) {
|
||
case 1004:
|
||
data = CT_dev_connect_request();
|
||
break;
|
||
case 1102:
|
||
data = CT_dev_login_CTEI_request();
|
||
break;
|
||
case 2006:
|
||
data = CT_dev_report_request();
|
||
break;
|
||
case 1000:
|
||
data = CT_dev_heartbeat_request();
|
||
break;
|
||
case 2004:
|
||
data = CT_dev_control_reply();
|
||
break;
|
||
default:
|
||
break;
|
||
|
||
}
|
||
|
||
int ret = sock_send(device.tcp_sock, data, strlen(data), 0);
|
||
|
||
if (data) {
|
||
free(data);
|
||
}
|
||
}
|
||
|
||
static int CT_state_check(void)
|
||
{
|
||
if (device.login_flag) {
|
||
return AI_STAT_CONNECTED;
|
||
}
|
||
return AI_STAT_DISCONNECTED;
|
||
|
||
}
|
||
|
||
static int CT_connect(void)
|
||
{
|
||
CT_connect_flag = 1;
|
||
if (!status_head.entry.next) {
|
||
info_init();
|
||
}
|
||
if (list_empty(&status_head.entry)) {
|
||
if (device_read_flash()) {
|
||
printf("no flash save,goto init------%s-----%d\r\n", __func__, __LINE__);
|
||
device_status_init();
|
||
}
|
||
}
|
||
device.login_flag = 0;
|
||
if (!dev_login_pid) {
|
||
thread_fork("device_login", 8, 2048, 0, &dev_login_pid, device_login_func, NULL);
|
||
}
|
||
return 0;
|
||
}
|
||
|
||
static int CT_do_event(int event, int arg)
|
||
{
|
||
log_info("do_event : %d", event);
|
||
return 0;
|
||
}
|
||
|
||
static int CT_disconnect(void)
|
||
{
|
||
CT_connect_flag = 0;
|
||
report_all = 0;
|
||
device.login_flag = 0;
|
||
sock_unreg(device.tcp_sock);
|
||
device.tcp_sock = NULL;
|
||
if (heartbeat_id) {
|
||
sys_timer_del(heartbeat_id);
|
||
heartbeat_id = 0;
|
||
}
|
||
if (heartbeat_timeout_id) {
|
||
sys_timeout_del(heartbeat_timeout_id);
|
||
heartbeat_timeout_id = 0;
|
||
}
|
||
os_taskq_post("server_to_device", 1, CONNECT_CLOSE);
|
||
return 0;
|
||
}
|
||
|
||
static void info_init()
|
||
{
|
||
INIT_LIST_HEAD(&status_head.entry); //初始化状态节点头
|
||
INIT_LIST_HEAD(&res_head.entry); //初始化资源节点头
|
||
/* INIT_LIST_HEAD(&event_head.entry); //初始化事件节点头 */
|
||
|
||
//设备信息请向电信方获取
|
||
char pin_iv[] = "G8NT7SQWC5JT67IJ4LW62S0YUCVD6YR3";
|
||
strcpy(device.model, "ZD18");
|
||
strncpy(device.pin, pin_iv, 16);
|
||
strncpy(device.iv, pin_iv + 16, 16);
|
||
printf("pin = %s \niv = %s\r\n", device.pin, device.iv);
|
||
strcpy(device.mac, "38C3DEFE1AA8"); //12
|
||
strcpy(device.ctei, "184579850000003"); //15
|
||
strcpy(device.deviceId, "00A1140101080210037376982606879673"); //34
|
||
|
||
}
|
||
|
||
REGISTER_AI_SDK(CT_MC_api) = {
|
||
.name = "China_Telecom_Mc",
|
||
.connect = CT_connect,
|
||
.state_check = CT_state_check,
|
||
.do_event = CT_do_event,
|
||
.disconnect = CT_disconnect,
|
||
};
|