|
@@ -2599,7 +2599,7 @@ char* setThresholdToCh(_AlarmRequestInfo* _alarm_request_info,int nChID)
|
|
|
char buff[100] ={0};
|
|
char buff[100] ={0};
|
|
|
get_time(buff);
|
|
get_time(buff);
|
|
|
#if IS_IP
|
|
#if IS_IP
|
|
|
- ret = dev_insert_alarm_info(__globalDeviceManage.db,product_id, ALARM_TYPE_OPRATION,buff,"power threshold update !!");
|
|
|
|
|
|
|
+ ret = dev_insert_alarm_info(__globalDeviceManage.db,product_id, ALARM_TYPE_OPRATION,buff,"power threshold update !");
|
|
|
#else
|
|
#else
|
|
|
ret = dev_insert_alarm_info(__globalDeviceManage.db, __globalDeviceManage._globalDevInfo.product_id,
|
|
ret = dev_insert_alarm_info(__globalDeviceManage.db, __globalDeviceManage._globalDevInfo.product_id,
|
|
|
ALARM_TYPE_OPRATION,buff,"power threshold update!!");
|
|
ALARM_TYPE_OPRATION,buff,"power threshold update!!");
|
|
@@ -2639,23 +2639,16 @@ static void alarmProtect(void *conn)
|
|
|
|
|
|
|
|
GlobalPowerManger *_globalPowerMangerTemp = NULL;
|
|
GlobalPowerManger *_globalPowerMangerTemp = NULL;
|
|
|
//int ret = -1;
|
|
//int ret = -1;
|
|
|
- int number = 0;
|
|
|
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
|
- list_for_each_entry(_globalPowerMangerTemp, &__globalDeviceManage._globalPowerManger.list, list)
|
|
|
|
|
- {
|
|
|
|
|
-
|
|
|
|
|
- ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
|
|
|
- _globalPowerMangerTemp->product_id,
|
|
|
|
|
- ALARM_TYPE_POWER ,1,10,
|
|
|
|
|
- &_alarm_ack_info,&nAlarmNumber);
|
|
|
|
|
- number += nAlarmNumber;
|
|
|
|
|
|
|
+ ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
|
|
|
+ ALARM_TYPE_POWER, 1, 10,
|
|
|
|
|
+ &_alarm_ack_info, &nAlarmNumber);
|
|
|
|
|
|
|
|
- }
|
|
|
|
|
- if(number==0) {
|
|
|
|
|
|
|
+ if(ret!=0) {
|
|
|
log_e("get power alarm error.");
|
|
log_e("get power alarm error.");
|
|
|
}
|
|
}
|
|
|
else {
|
|
else {
|
|
|
- ack_str = alarm_info_to_json(&_alarm_ack_info,number);
|
|
|
|
|
|
|
+ ack_str = alarm_info_to_json(&_alarm_ack_info,nAlarmNumber);
|
|
|
|
|
|
|
|
//释放资源
|
|
//释放资源
|
|
|
_AlarmAckInfo* node;
|
|
_AlarmAckInfo* node;
|
|
@@ -2702,21 +2695,17 @@ static void alarmProtect(void *conn)
|
|
|
#if IS_IP
|
|
#if IS_IP
|
|
|
GlobalPowerManger *_globalPowerMangerTemp = NULL;
|
|
GlobalPowerManger *_globalPowerMangerTemp = NULL;
|
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
|
- int number = 0;
|
|
|
|
|
- list_for_each_entry(_globalPowerMangerTemp, &__globalDeviceManage._globalPowerManger.list, list)
|
|
|
|
|
- {
|
|
|
|
|
- nAlarmNumber = 0;
|
|
|
|
|
-
|
|
|
|
|
- ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
|
|
|
- _globalPowerMangerTemp->product_id,
|
|
|
|
|
- ALARM_TYPE_POWER,_alarm_request_info.pagenum,_alarm_request_info.pagesize,
|
|
|
|
|
- &_alarm_ack_info,&nAlarmNumber);
|
|
|
|
|
- number +=nAlarmNumber;
|
|
|
|
|
- }
|
|
|
|
|
- if(number == 0) {
|
|
|
|
|
|
|
+
|
|
|
|
|
+ nAlarmNumber = 0;
|
|
|
|
|
+
|
|
|
|
|
+ ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
|
|
|
+ ALARM_TYPE_POWER, _alarm_request_info.pagenum, _alarm_request_info.pagesize,
|
|
|
|
|
+ &_alarm_ack_info, &nAlarmNumber);
|
|
|
|
|
+
|
|
|
|
|
+ if(ret!=0) {
|
|
|
log_e("get power alarm error.");
|
|
log_e("get power alarm error.");
|
|
|
} else {
|
|
} else {
|
|
|
- ack_str = alarm_info_to_json(&_alarm_ack_info,number);
|
|
|
|
|
|
|
+ ack_str = alarm_info_to_json(&_alarm_ack_info,nAlarmNumber);
|
|
|
|
|
|
|
|
//释放资源
|
|
//释放资源
|
|
|
_AlarmAckInfo* node;
|
|
_AlarmAckInfo* node;
|
|
@@ -2757,7 +2746,6 @@ static void alarmProtect(void *conn)
|
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
|
//查询数据库
|
|
//查询数据库
|
|
|
ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
|
- __globalDeviceManage._globalDevInfo.product_id,
|
|
|
|
|
ALARM_TYPE_SENSOR,_alarm_request_info.pagenum,_alarm_request_info.pagesize,
|
|
ALARM_TYPE_SENSOR,_alarm_request_info.pagenum,_alarm_request_info.pagesize,
|
|
|
&_alarm_ack_info,&nAlarmNumber);
|
|
&_alarm_ack_info,&nAlarmNumber);
|
|
|
if(ret!=0) {
|
|
if(ret!=0) {
|
|
@@ -2782,7 +2770,6 @@ static void alarmProtect(void *conn)
|
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
INIT_LIST_HEAD(&_alarm_ack_info.list);
|
|
|
|
|
|
|
|
ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
ret = dev_serarch_all_alarm(__globalDeviceManage.db,
|
|
|
- __globalDeviceManage._globalDevInfo.product_id,
|
|
|
|
|
ALARM_TYPE_NETWORK,_alarm_request_info.pagenum,_alarm_request_info.pagesize,
|
|
ALARM_TYPE_NETWORK,_alarm_request_info.pagenum,_alarm_request_info.pagesize,
|
|
|
&_alarm_ack_info,&nAlarmNumber);
|
|
&_alarm_ack_info,&nAlarmNumber);
|
|
|
if(ret!=0) {
|
|
if(ret!=0) {
|
|
@@ -4311,7 +4298,21 @@ static void systemManagent(void *conn)
|
|
|
ack_str = service_userRole_ack_to_json(nName,&User_list, &Role_list);
|
|
ack_str = service_userRole_ack_to_json(nName,&User_list, &Role_list);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+ UserInfo *node;
|
|
|
|
|
+ UserInfo *next;
|
|
|
|
|
+ list_for_each_entry_safe(node, next, &User_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node->list);
|
|
|
|
|
+ free(node);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ RoleInfo *node1;
|
|
|
|
|
+ RoleInfo *next1;
|
|
|
|
|
+ list_for_each_entry_safe(node1, next1, &Role_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node1->list);
|
|
|
|
|
+ free(node1);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
//查询用户列表
|
|
//查询用户列表
|
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"listUserQuery")==0)
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"listUserQuery")==0)
|
|
@@ -4330,9 +4331,24 @@ static void systemManagent(void *conn)
|
|
|
char *nName = getUserNamebyToken(_UserRoleManageRequestInfo.user_token);
|
|
char *nName = getUserNamebyToken(_UserRoleManageRequestInfo.user_token);
|
|
|
if (nName != NULL)
|
|
if (nName != NULL)
|
|
|
{
|
|
{
|
|
|
- ack_str = service_userQuery_ack_to_json(nName, &User_list, &Role_list);
|
|
|
|
|
|
|
+ ack_str = service_userQuery_ack_to_json(nName, &User_list, &Role_list,_UserRoleManageRequestInfo.userName,_UserRoleManageRequestInfo.pagenum,_UserRoleManageRequestInfo.pagesize);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ UserInfo *node;
|
|
|
|
|
+ UserInfo *next;
|
|
|
|
|
+ list_for_each_entry_safe(node, next, &User_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node->list);
|
|
|
|
|
+ free(node);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ RoleInfo *node1;
|
|
|
|
|
+ RoleInfo *next1;
|
|
|
|
|
+ list_for_each_entry_safe(node1, next1, &Role_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node1->list);
|
|
|
|
|
+ free(node1);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
//删除用户
|
|
//删除用户
|
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"deleteUser")==0)
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"deleteUser")==0)
|
|
@@ -4360,6 +4376,13 @@ static void systemManagent(void *conn)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ UserInfo *node;
|
|
|
|
|
+ UserInfo *next;
|
|
|
|
|
+ list_for_each_entry_safe(node, next, &User_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node->list);
|
|
|
|
|
+ free(node);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
if (!CurUserFlag)
|
|
if (!CurUserFlag)
|
|
|
{
|
|
{
|
|
@@ -4387,13 +4410,14 @@ static void systemManagent(void *conn)
|
|
|
//添加用户
|
|
//添加用户
|
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"addUser")==0)
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"addUser")==0)
|
|
|
{
|
|
{
|
|
|
- //未析构
|
|
|
|
|
|
|
+ //未析构
|
|
|
UserInfo *new_user = (UserInfo *)malloc(sizeof(UserInfo));
|
|
UserInfo *new_user = (UserInfo *)malloc(sizeof(UserInfo));
|
|
|
memset(new_user,0,sizeof(UserInfo));
|
|
memset(new_user,0,sizeof(UserInfo));
|
|
|
|
|
|
|
|
new_user->product_id = __globalDeviceManage._globalDevInfo.product_id;
|
|
new_user->product_id = __globalDeviceManage._globalDevInfo.product_id;
|
|
|
|
|
|
|
|
int nMaxUserNum=1;
|
|
int nMaxUserNum=1;
|
|
|
|
|
+ bool existFlag=false;
|
|
|
UserInfo User_list;
|
|
UserInfo User_list;
|
|
|
INIT_LIST_HEAD(&User_list.list);
|
|
INIT_LIST_HEAD(&User_list.list);
|
|
|
// 查询角色信息
|
|
// 查询角色信息
|
|
@@ -4413,34 +4437,69 @@ static void systemManagent(void *conn)
|
|
|
{
|
|
{
|
|
|
nMaxUserNum=_UserInfoTemp->userID;
|
|
nMaxUserNum=_UserInfoTemp->userID;
|
|
|
}
|
|
}
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- new_user->userID = nMaxUserNum+1;
|
|
|
|
|
|
|
|
|
|
- new_user->userName = malloc(256);
|
|
|
|
|
- strcpy(new_user->userName, _UserRoleManageRequestInfo.userName);
|
|
|
|
|
- new_user->userPW = malloc(256);
|
|
|
|
|
- strcpy(new_user->userPW, _UserRoleManageRequestInfo.password);
|
|
|
|
|
- new_user->nickName = malloc(256);
|
|
|
|
|
- strcpy(new_user->nickName, _UserRoleManageRequestInfo.nickName);
|
|
|
|
|
- new_user->roleID = _UserRoleManageRequestInfo.roleId;//GetRoleIDByName(_UserRoleManageRequestInfo.roleName,&Role_list);
|
|
|
|
|
-
|
|
|
|
|
- new_user->createTime = malloc(64);
|
|
|
|
|
- struct tm *t;
|
|
|
|
|
- struct timeval tv;
|
|
|
|
|
- gettimeofday(&tv, NULL);
|
|
|
|
|
- t = localtime(&tv.tv_sec);
|
|
|
|
|
- sprintf(new_user->createTime, "%04d-%02d-%02d %02d:%02d:%02d", t->tm_year + 1900, t->tm_mon + 1, t->tm_mday, t->tm_hour, t->tm_min, t->tm_sec);
|
|
|
|
|
|
|
+ if (strcmp(_UserInfoTemp->userName, _UserRoleManageRequestInfo.userName) == 0)
|
|
|
|
|
+ {
|
|
|
|
|
+ existFlag = true;
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- dev_insert_user_info(__globalDeviceManage.db, new_user);
|
|
|
|
|
|
|
+ if (existFlag)
|
|
|
|
|
+ {
|
|
|
|
|
+ ack_str = ctrl_breaker_err_ack_to_json("User already exists!");
|
|
|
|
|
+ }
|
|
|
|
|
+ else
|
|
|
|
|
+ {
|
|
|
|
|
+ new_user->userID = nMaxUserNum + 1;
|
|
|
|
|
+
|
|
|
|
|
+ new_user->userName = malloc(256);
|
|
|
|
|
+ strcpy(new_user->userName, _UserRoleManageRequestInfo.userName);
|
|
|
|
|
+ new_user->userPW = malloc(256);
|
|
|
|
|
+ strcpy(new_user->userPW, _UserRoleManageRequestInfo.password);
|
|
|
|
|
+ new_user->nickName = malloc(256);
|
|
|
|
|
+ strcpy(new_user->nickName, _UserRoleManageRequestInfo.nickName);
|
|
|
|
|
+ new_user->roleID = _UserRoleManageRequestInfo.roleId; // GetRoleIDByName(_UserRoleManageRequestInfo.roleName,&Role_list);
|
|
|
|
|
+
|
|
|
|
|
+ new_user->createTime = malloc(64);
|
|
|
|
|
+ struct tm *t;
|
|
|
|
|
+ struct timeval tv;
|
|
|
|
|
+ gettimeofday(&tv, NULL);
|
|
|
|
|
+ t = localtime(&tv.tv_sec);
|
|
|
|
|
+ sprintf(new_user->createTime, "%04d-%02d-%02d %02d:%02d:%02d", t->tm_year + 1900, t->tm_mon + 1, t->tm_mday, t->tm_hour, t->tm_min, t->tm_sec);
|
|
|
|
|
+
|
|
|
|
|
+ dev_insert_user_info(__globalDeviceManage.db, new_user);
|
|
|
|
|
+
|
|
|
|
|
+ free(new_user->userName);
|
|
|
|
|
+ free(new_user->userPW);
|
|
|
|
|
+ free(new_user->nickName);
|
|
|
|
|
+ free(new_user->createTime);
|
|
|
|
|
+
|
|
|
|
|
+ char temp[100];
|
|
|
|
|
+ // sprintf(temp, "$添加$|$用户$|%s", _UserRoleManageRequestInfo.userName);
|
|
|
|
|
+ sprintf(temp, "Add user %s", _UserRoleManageRequestInfo.userName);
|
|
|
|
|
+ dev_insert_alarm_ctrl(__globalDeviceManage.db, __globalDeviceManage._globalDevInfo.product_id, ALARM_TYPE_OPRATION, temp);
|
|
|
|
|
+
|
|
|
|
|
+ ack_str=ctrl_sts_ack_to_json();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ free(new_user);
|
|
|
|
|
+ UserInfo *node;
|
|
|
|
|
+ UserInfo *next;
|
|
|
|
|
+ list_for_each_entry_safe(node, next, &User_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node->list);
|
|
|
|
|
+ free(node);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- char temp[100];
|
|
|
|
|
- //sprintf(temp, "$添加$|$用户$|%s", _UserRoleManageRequestInfo.userName);
|
|
|
|
|
- sprintf(temp, "Add user %s", _UserRoleManageRequestInfo.userName);
|
|
|
|
|
- dev_insert_alarm_ctrl(__globalDeviceManage.db, __globalDeviceManage._globalDevInfo.product_id, 3, temp);
|
|
|
|
|
-
|
|
|
|
|
- ack_str=ctrl_sts_ack_to_json();
|
|
|
|
|
|
|
+ RoleInfo *node1;
|
|
|
|
|
+ RoleInfo *next1;
|
|
|
|
|
+ list_for_each_entry_safe(node1, next1, &Role_list.list, list)
|
|
|
|
|
+ {
|
|
|
|
|
+ list_del(&node1->list);
|
|
|
|
|
+ free(node1);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
//更新用户信息
|
|
//更新用户信息
|
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"updateUser")==0)
|
|
else if(strcmp(_UserRoleManageRequestInfo.type,"updateUser")==0)
|
|
@@ -4458,11 +4517,16 @@ static void systemManagent(void *conn)
|
|
|
new_user->nickName = malloc(256);
|
|
new_user->nickName = malloc(256);
|
|
|
strcpy(new_user->nickName , _UserRoleManageRequestInfo.nickName);
|
|
strcpy(new_user->nickName , _UserRoleManageRequestInfo.nickName);
|
|
|
new_user->roleID = _UserRoleManageRequestInfo.roleId;
|
|
new_user->roleID = _UserRoleManageRequestInfo.roleId;
|
|
|
- // new_user->createTime = malloc(64);
|
|
|
|
|
- // strcpy(new_user->createTime , _UserRoleManageRequestInfo.createTime);
|
|
|
|
|
|
|
+ new_user->createTime = malloc(64);
|
|
|
|
|
+ strcpy(new_user->createTime , _UserRoleManageRequestInfo.createTime);
|
|
|
|
|
|
|
|
dev_update_user_info(__globalDeviceManage.db, new_user);
|
|
dev_update_user_info(__globalDeviceManage.db, new_user);
|
|
|
|
|
|
|
|
|
|
+ free(new_user->userName);
|
|
|
|
|
+ free(new_user->userPW);
|
|
|
|
|
+ free(new_user->nickName);
|
|
|
|
|
+ free(new_user->createTime);
|
|
|
|
|
+ free(new_user);
|
|
|
char temp[100];
|
|
char temp[100];
|
|
|
//sprintf(temp, "$修改$|$用户$|%s", _UserRoleManageRequestInfo.userName);
|
|
//sprintf(temp, "$修改$|$用户$|%s", _UserRoleManageRequestInfo.userName);
|
|
|
sprintf(temp, "Update user %s", _UserRoleManageRequestInfo.userName);
|
|
sprintf(temp, "Update user %s", _UserRoleManageRequestInfo.userName);
|