Commit 471e3b48 authored by 陈伟灿's avatar 陈伟灿

Merge branch 'cwc' into 'master'

【修改内容】1,上传最新的网关程序;2,版本号更新为1.4.6

See merge request chenweican/k-sdk!206
parents 429ec1be 65c4d534
1.4.5 1.4.6
\ No newline at end of file \ No newline at end of file
...@@ -238,7 +238,6 @@ static char * kk_create_register_info() ...@@ -238,7 +238,6 @@ static char * kk_create_register_info()
cJSON *root; cJSON *root;
char *out = NULL; char *out = NULL;
char *signSource,*base64Out = NULL; char *signSource,*base64Out = NULL;
char mac[16] = {0};
char ramdonId[16] = {0}; char ramdonId[16] = {0};
unsigned char sign_hex[32] = {0}; unsigned char sign_hex[32] = {0};
char sign_hex_str[65] = {0}; char sign_hex_str[65] = {0};
...@@ -248,7 +247,6 @@ static char * kk_create_register_info() ...@@ -248,7 +247,6 @@ static char * kk_create_register_info()
int productSecret_len = 0; int productSecret_len = 0;
char keyTmp[64] = {0}; char keyTmp[64] = {0};
root=cJSON_CreateObject(); root=cJSON_CreateObject();
HAL_Get_mac(mac);
HAL_GetTime_s(ramdonId); HAL_GetTime_s(ramdonId);
KK_Get_ccuid(ccuid); KK_Get_ccuid(ccuid);
kk_cloud_get_pid(pid); kk_cloud_get_pid(pid);
......
...@@ -254,7 +254,6 @@ MQTTAsync KK_MQTT_Connect(void) ...@@ -254,7 +254,6 @@ MQTTAsync KK_MQTT_Connect(void)
MQTTAsync_willOptions will_opts = MQTTAsync_willOptions_initializer; MQTTAsync_willOptions will_opts = MQTTAsync_willOptions_initializer;
MQTTAsync_setTraceCallback(mqttTraceCallback); MQTTAsync_setTraceCallback(mqttTraceCallback);
opts.MQTTVersion = MQTTVERSION_3_1_1; opts.MQTTVersion = MQTTVERSION_3_1_1;
char mac[16]={0};
char token[512] = {0}; char token[512] = {0};
char usrname[128] = {0}; char usrname[128] = {0};
fp = fopen(KK_TOKEN_PATH, "r"); fp = fopen(KK_TOKEN_PATH, "r");
...@@ -262,7 +261,6 @@ MQTTAsync KK_MQTT_Connect(void) ...@@ -262,7 +261,6 @@ MQTTAsync KK_MQTT_Connect(void)
fread(token,1,sizeof(token),fp); fread(token,1,sizeof(token),fp);
fclose(fp); fclose(fp);
} }
HAL_Get_mac(mac);
char ccuid[32] = {0}; char ccuid[32] = {0};
char pid[32] = {0}; char pid[32] = {0};
KK_Get_ccuid(ccuid); KK_Get_ccuid(ccuid);
......
...@@ -1033,11 +1033,12 @@ void KK_Data_FromMid(void* str,int len, char* chalMark) ...@@ -1033,11 +1033,12 @@ void KK_Data_FromMid(void* str,int len, char* chalMark)
INFO_PRINT("offline handle!!!"); INFO_PRINT("offline handle!!!");
kk_device_onoffline_handle(payload,0); kk_device_onoffline_handle(payload,0);
}else if(strstr(msgtype->valuestring,"/thing/service/addDeviceToRoom_reply")!= NULL){ }else if(strstr(msgtype->valuestring,"/thing/service/addDeviceToRoom_reply")!= NULL){
sleep(3);
INFO_PRINT("addDeviceToRoom_reply handle!!!"); INFO_PRINT("addDeviceToRoom_reply handle!!!");
device_add_sync(payload); kk_handle_sync_push_info();
kk_handle_sync_info();
}else if(strstr(msgtype->valuestring,"/thing/service/removeDeviceFromRoom_reply")!= NULL){ }else if(strstr(msgtype->valuestring,"/thing/service/removeDeviceFromRoom_reply")!= NULL){
kk_handle_sync_push_info(); kk_handle_sync_push_info();
kk_handle_sync_info();
}else if(strstr(msgtype->valuestring,"/thing/event/alarmNotify")!= NULL){ }else if(strstr(msgtype->valuestring,"/thing/event/alarmNotify")!= NULL){
INFO_PRINT("alarmNotify handle!!!"); INFO_PRINT("alarmNotify handle!!!");
cJSON * msgId = cJSON_GetObjectItem(payload, "msgId"); cJSON * msgId = cJSON_GetObjectItem(payload, "msgId");
......
...@@ -11,6 +11,5 @@ void KK_Data_FromMid(void* str,int len, char* chalMark); ...@@ -11,6 +11,5 @@ void KK_Data_FromMid(void* str,int len, char* chalMark);
int kk_lan_property_syn_deal(const char *deviceCode,cJSON *properties); int kk_lan_property_syn_deal(const char *deviceCode,cJSON *properties);
int send_msg_to_module(cJSON *root); int send_msg_to_module(cJSON *root);
void device_add_sync(cJSON *payload);
void kk_handle_sync_push_info(void); void kk_handle_sync_push_info(void);
#endif #endif
\ No newline at end of file
...@@ -281,14 +281,11 @@ int main(int argc, char* argv[]) ...@@ -281,14 +281,11 @@ int main(int argc, char* argv[])
if(g_sync_flag&SYNC_INFO_FLAG){ if(g_sync_flag&SYNC_INFO_FLAG){
DEBUG_PRINT("[SYNC INFO].\n"); DEBUG_PRINT("[SYNC INFO].\n");
send_data = _kk_data_create(SYNC_MSG_TYPE,s_pid,s_ccuid,"*"); send_data = _kk_data_create(SYNC_MSG_TYPE,s_pid,s_ccuid,"*");
g_sync_flag&=~SYNC_INFO_FLAG; g_sync_flag&=~SYNC_INFO_FLAG;
}else if(g_sync_flag&SYNC_INFO_PUSH_FLAG){ }else if(g_sync_flag&SYNC_INFO_PUSH_FLAG){
DEBUG_PRINT("[SYNC INFO PUSH].\n"); DEBUG_PRINT("[SYNC INFO PUSH].\n");
send_data = _kk_data_create(SYNCPUSH_MSG_TYPE,s_pid,s_ccuid,"*"); send_data = _kk_data_create(SYNCPUSH_MSG_TYPE,s_pid,s_ccuid,"*");
kk_handle_sync_push_info();
g_sync_flag&=~SYNC_INFO_PUSH_FLAG; g_sync_flag&=~SYNC_INFO_PUSH_FLAG;
}else{ }else{
g_sync_flag = 0; g_sync_flag = 0;
......
...@@ -168,32 +168,34 @@ int kk_sync_actions(cJSON *actions,SYN_SCENE_ACTION **act) ...@@ -168,32 +168,34 @@ int kk_sync_actions(cJSON *actions,SYN_SCENE_ACTION **act)
int i,num = cJSON_GetArraySize(actions); int i,num = cJSON_GetArraySize(actions);
int node = -1; int node = -1;
int get_flag = 0; int get_flag = 0;
*act = (SYN_SCENE_ACTION *)malloc(sizeof(SYN_SCENE_ACTION)*num); *act = (SYN_SCENE_ACTION *)malloc(sizeof(SYN_SCENE_ACTION)*num);
memset(*act,0,sizeof(SYN_SCENE_ACTION)*num); memset(*act,0,sizeof(SYN_SCENE_ACTION)*num);
SYN_SCENE_ACTION *ptr=*act; SYN_SCENE_ACTION *ptr=*act;
for(i=0;i<num;i++,ptr++){ for(i=0;i<num;i++,ptr++){
cJSON *item; cJSON *item;
item = cJSON_GetArrayItem(actions,i); item = cJSON_GetArrayItem(actions,i);
deviceCode = cJSON_GetObjectItem(item,"deviceCode"); deviceCode = cJSON_GetObjectItem(item,"deviceCode");
if(deviceCode == NULL){
continue;
}
delay = cJSON_GetObjectItem(item,"delay"); delay = cJSON_GetObjectItem(item,"delay");
if(delay == NULL){
continue;
}
epNum = cJSON_GetObjectItem(item,"epNum"); epNum = cJSON_GetObjectItem(item,"epNum");
if(epNum == NULL){
continue;
}
propertyName= cJSON_GetObjectItem(item,"propertyName"); propertyName= cJSON_GetObjectItem(item,"propertyName");
type= cJSON_GetObjectItem(item,"type"); type= cJSON_GetObjectItem(item,"type");
propertyValue= cJSON_GetObjectItem(item,"propertyValue"); propertyValue= cJSON_GetObjectItem(item,"propertyValue");
ptr->ui_area = NULL; ptr->ui_area = NULL;
ptr->ui_name = NULL; ptr->ui_name = NULL;
ptr->ui_room_id = NULL; ptr->ui_room_id = NULL;
ptr->delay = delay->valuestring; ptr->delay = delay->valuestring;
ptr->nodeid = kk_lan_db_node_get(deviceCode->valuestring,epNum->valueint); ptr->nodeid = kk_lan_db_node_get(deviceCode->valuestring,epNum->valueint);
ptr->operate_type ="*";//type->valuestring;//根据实际设备调整 ptr->operate_type ="*";//type->valuestring;//根据实际设备调整
ptr->operation = "*";//propertyValue->valuestring;// ptr->operation = "*";//propertyValue->valuestring;//
} }
......
...@@ -460,6 +460,7 @@ void kk_lan_add_scene_notify(const char* scene_id) ...@@ -460,6 +460,7 @@ void kk_lan_add_scene_notify(const char* scene_id)
debug_log(LOG_CRIT_LEVEL,"[notify] add scene(%s).\n",scene_id); debug_log(LOG_CRIT_LEVEL,"[notify] add scene(%s).\n",scene_id);
kk_handle_sync_push_info(); kk_handle_sync_push_info();
kk_handle_sync_info();
} }
//删除场景通知 //删除场景通知
...@@ -472,6 +473,7 @@ void kk_lan_delete_scene_notify(const char* scene_id) ...@@ -472,6 +473,7 @@ void kk_lan_delete_scene_notify(const char* scene_id)
cJSON_Delete(msg); cJSON_Delete(msg);
kk_handle_sync_push_info(); kk_handle_sync_push_info();
kk_handle_sync_info();
} }
//布防撤防状态通知(0-离家布防、1-撤防、2-在家布防、3-区域布防) //布防撤防状态通知(0-离家布防、1-撤防、2-在家布防、3-区域布防)
...@@ -546,6 +548,7 @@ static int _kk_lan_delete_device(const char *deviceCode) ...@@ -546,6 +548,7 @@ static int _kk_lan_delete_device(const char *deviceCode)
if(num){ if(num){
kk_handle_sync_push_info(); kk_handle_sync_push_info();
kk_handle_sync_info();
} }
return 0; return 0;
} }
...@@ -573,10 +576,4 @@ int kk_lan_device_delete_notify(cJSON *payload) ...@@ -573,10 +576,4 @@ int kk_lan_device_delete_notify(cJSON *payload)
return 0; return 0;
} }
void device_add_sync(cJSON *payload)
{
//NEW_DEVICES
printf("[%s][%d]\n",__FUNCTION__,__LINE__);
kk_handle_sync_push_info();
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment