|
@@ -15,6 +15,7 @@ Description : Generate context info from mysql to context conf file
|
|
|
#include <assert.h>
|
|
|
#include <time.h>
|
|
|
#include <ctype.h>
|
|
|
+#include <cjson/cJSON.h>
|
|
|
|
|
|
#include <mysql/mysql.h>
|
|
|
|
|
@@ -216,20 +217,144 @@ if (executesql("set names utf8")) // 如果失败
|
|
|
return 0; // 返回成功
|
|
|
}
|
|
|
|
|
|
-//mysql> desc t_paging_groups;
|
|
|
-//+-----------+--------------+------+-----+---------+----------------+
|
|
|
-//| Field | Type | Null | Key | Default | Extra |
|
|
|
-//+-----------+--------------+------+-----+---------+----------------+
|
|
|
-//| id | bigint(11) | NO | PRI | NULL | auto_increment |
|
|
|
-//| name | varchar(128) | NO | UNI | NULL | |
|
|
|
-//| exten | varchar(16) | NO | UNI | NULL | |
|
|
|
-//| remark | varchar(256) | YES | | NULL | |
|
|
|
-//| createdAt | datetime | NO | | NULL | |
|
|
|
-//| updatedAt | datetime | NO | | NULL | |
|
|
|
-//+-----------+--------------+------+-----+---------+----------------+
|
|
|
+//对比license文件 by dingyu
|
|
|
+static int check_license(void)
|
|
|
+{
|
|
|
+ char g_host_name[64];
|
|
|
+ char g_user_name[64] = "root";
|
|
|
+ char g_password[64];
|
|
|
+ char g_db_name[64] = "init_db";
|
|
|
+ char sql[256];
|
|
|
+ const unsigned int g_db_port = 3306;
|
|
|
+ MYSQL *g_conn;
|
|
|
+ MYSQL_RES *g_res;
|
|
|
+ MYSQL_ROW g_row;
|
|
|
+ cJSON *pJson;
|
|
|
+ FILE *fp; //文件1指针
|
|
|
+ FILE *fp2; //文件2指针
|
|
|
+ int line=0;
|
|
|
+ int i;
|
|
|
+ struct MD5Context md5;
|
|
|
+ unsigned char sum[16];
|
|
|
+ char file_str[1024];
|
|
|
+ char file_str2[1024];
|
|
|
+ char file_str3[1024];
|
|
|
+ char sumbuf[128];
|
|
|
+
|
|
|
+ memset(limited_datetime,'\0', sizeof(limited_datetime));
|
|
|
+ memset(serveruuid,'\0',sizeof(serveruuid));
|
|
|
+ strcpy(g_host_name,getenv("MYSQL"));
|
|
|
+ strcpy(g_password,getenv("MYSQL_ROOT_PASSWORD"));
|
|
|
+
|
|
|
+ g_conn = mysql_init(NULL);
|
|
|
+ if(mysql_real_connect(g_conn, g_host_name, g_user_name, g_password, g_db_name, g_db_port, NULL, 0))
|
|
|
+ {
|
|
|
+ /*query the database according the sql*/
|
|
|
+ mysql_query(g_conn, "set names utf8");
|
|
|
+ memset(sql,'\0', sizeof(sql));
|
|
|
+ sprintf(sql, "select * from D_T_S_Z_L where prop_key='SYSTEM_UUID'");
|
|
|
+ if (mysql_real_query(g_conn, sql, strlen(sql)) != 0){
|
|
|
+ mysql_close(g_conn); // 关闭链接
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ g_res = mysql_store_result(g_conn);
|
|
|
+ if(mysql_num_rows(g_res) == 0){
|
|
|
+ mysql_free_result(g_res); //释放结果
|
|
|
+ mysql_close(g_conn); // 关闭链接
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ g_row=mysql_fetch_row(g_res);
|
|
|
+
|
|
|
+ if(g_row[2] == NULL){
|
|
|
+ mysql_free_result(g_res); //释放结果
|
|
|
+ mysql_close(g_conn); // 关闭链接
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ strcpy(serveruuid,g_row[2]);
|
|
|
+ memset(sql,'\0', sizeof(sql));
|
|
|
+ sprintf(sql, "select * from D_T_S_Z_L where prop_key='LIMITED_DATETIME'");
|
|
|
+ if (mysql_real_query(g_conn, sql, strlen(sql)) != 0){
|
|
|
+ mysql_close(g_conn); // 关闭链接
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ g_res = mysql_store_result(g_conn);
|
|
|
+ if(mysql_num_rows(g_res) == 0){
|
|
|
+ mysql_free_result(g_res); //释放结果
|
|
|
+ mysql_close(g_conn); // 关闭链接
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ g_row=mysql_fetch_row(g_res);
|
|
|
+
|
|
|
+ if(g_row[2] == NULL){
|
|
|
+ mysql_free_result(g_res); //释放结果
|
|
|
+ mysql_close(g_conn); // 关闭链接
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ strcpy(limited_datetime,g_row[2]);
|
|
|
+ mysql_free_result(g_res);
|
|
|
+ mysql_close(g_conn);
|
|
|
+ fp=fopen("/music/license","r");//创建的文件
|
|
|
+ if(fp==NULL)
|
|
|
+ {
|
|
|
+ printf("open error\n");
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ memset(file_str3,'\0',sizeof(file_str3));
|
|
|
+ if(fgets(file_str3,sizeof(file_str3),fp)){
|
|
|
+ if (file_str3[strlen(file_str3) - 1] == '\n')
|
|
|
+ {
|
|
|
+ file_str3[strlen(file_str3) - 1] = '\0';
|
|
|
+ }
|
|
|
+ pJson = cJSON_Parse(file_str3);
|
|
|
+ if ( !pJson ) {
|
|
|
+ printf( "parse failed!\n");
|
|
|
+ fclose(fp);
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ maxclients = cJSON_GetObjectItem(pJson, "number")->valueint;
|
|
|
+ cJSON_Delete(pJson);
|
|
|
+
|
|
|
+ memset(file_str,'\0',sizeof(file_str));
|
|
|
+ sprintf(file_str,"%s+%d+8675309-Zycoo-nwcavertingoureyes@Coocenter.com",serveruuid,maxclients);
|
|
|
+ MD5Init(&md5);
|
|
|
+ MD5Update(&md5, (unsigned char *) file_str, strlen(file_str));
|
|
|
+ MD5Final(sum, &md5);
|
|
|
+ char tmp[16];
|
|
|
+ memset(sumbuf,0,sizeof(sumbuf));
|
|
|
+ memset(file_str2,0,sizeof(file_str2));
|
|
|
+ for(i=0;i<16;i++)
|
|
|
+ {
|
|
|
+ memset(tmp,0,sizeof(tmp));
|
|
|
+ sprintf(tmp,"%02x",sum[i]);
|
|
|
+ strcat(sumbuf,tmp);
|
|
|
+ }
|
|
|
+ fp2=fopen("/init/sql/.limited","r");//创建的文件
|
|
|
+ if(fp2==NULL)
|
|
|
+ {
|
|
|
+ printf("open error\n");
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ while(fgets(file_str2,sizeof(file_str2),fp2))//逐行循环读取文件,直到文件结束
|
|
|
+ {
|
|
|
+ line++;
|
|
|
+ if(strstr(file_str2,sumbuf)) //检查字符串是否在该行中,如果在,则输出该行
|
|
|
+ {
|
|
|
+ fclose(fp2);
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ fclose(fp2);//关闭文件,结束
|
|
|
+ }
|
|
|
+ fclose(fp);//关闭文件,结束
|
|
|
+ }
|
|
|
+ return 0;
|
|
|
+}
|
|
|
|
|
|
|
|
|
int main(int argc, char **argv) {
|
|
|
+ if(!check_license()){
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
/*
|
|
|
memset(g_host_name, 0, sizeof(g_host_name));
|
|
|
memset(g_user_name, 0, sizeof(g_user_name));
|
|
@@ -315,6 +440,7 @@ mytime()\
|
|
|
}
|
|
|
int setout = 1;
|
|
|
fprintf(conf_fp, "[DialRule_%s]\n",g_row[1]);
|
|
|
+ fprintf(conf_fp, "include => cdr-action\n");
|
|
|
fprintf(conf_fp, "include => call-trigger\n");
|
|
|
memset(sql_tmp,0,sizeof(sql_tmp));
|
|
|
//获取对讲终端所在队列的号码
|
|
@@ -383,8 +509,24 @@ mytime()\
|
|
|
}
|
|
|
int setout = 1;
|
|
|
fprintf(conf_fp, "[DialRule_%s]\n",g_row[1]);
|
|
|
- fprintf(conf_fp, "include => call-trigger\n");
|
|
|
+ fprintf(conf_fp, "include => cdr-action\n");
|
|
|
fprintf(conf_fp, "include => featurecodes\n");
|
|
|
+
|
|
|
+ //获取对讲终端所在队列的号码
|
|
|
+ memset(sql_tmp,0,sizeof(sql_tmp));
|
|
|
+ sprintf(sql_tmp,"select exten from t_paging_deviceGroups JOIN t_paging_groups on t_paging_groups.id = t_paging_deviceGroups.GroupId where DeviceId = %s",g_row[0]);
|
|
|
+ if (executesql(sql_tmp)){
|
|
|
+ print_mysql_error(NULL);
|
|
|
+ exit(1);
|
|
|
+ }
|
|
|
+ d_res = mysql_store_result(g_conn); // 从服务器传送结果集至本地,mysql_use_result直接使用服务器上的记录集
|
|
|
+ while ((d_row=mysql_fetch_row(d_res))){ // 打印结果集
|
|
|
+ if (d_row[0] == NULL){
|
|
|
+ printf("some feild is empty!\n");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ fprintf(conf_fp, "include => phones-group-%s\n", d_row[0]);
|
|
|
+ }
|
|
|
if(g_row[2]){
|
|
|
memset(sql_tmp,0,sizeof(sql_tmp));
|
|
|
sprintf(sql_tmp,"select t_paging_users.id,t_paging_users.level from t_paging_users join t_paging_devices on t_paging_users.id = t_paging_devices.user_id\
|
|
@@ -408,7 +550,7 @@ mytime()\
|
|
|
sprintf(sql_tmp,"select exten,t_paging_userServices.tPagingServiceId as service_id from t_paging_groups\
|
|
|
JOIN t_paging_userGroups on t_paging_groups.id = t_paging_userGroups.GroupId\
|
|
|
JOIN t_paging_userServices on t_paging_userServices.UserId = t_paging_userGroups.UserId\
|
|
|
- where t_paging_userServices.tPagingServiceId in(1,4,9) and t_paging_userGroups.UserId\
|
|
|
+ where t_paging_userServices.tPagingServiceId in(1,4,7,9) and t_paging_userGroups.UserId\
|
|
|
in(select t_paging_users.id from t_paging_users join t_paging_devices on t_paging_users.id = t_paging_devices.user_id\
|
|
|
where t_paging_devices.exten=%s) order by t_paging_userServices.tPagingServiceId",g_row[1]); //查询分机所属管理员的权限以及所管理的组
|
|
|
if (executesql(sql_tmp)){
|
|
@@ -429,6 +571,9 @@ mytime()\
|
|
|
case 4:
|
|
|
fprintf(conf_fp, "include => extens-group-%s\n", d_row[0]);
|
|
|
break;
|
|
|
+ case 7:
|
|
|
+ fprintf(conf_fp, "include => call-trigger\n");
|
|
|
+ break;
|
|
|
case 9:
|
|
|
if(setout){
|
|
|
fprintf(conf_fp, "include => CallingRule_OutCall\n");
|
|
@@ -438,20 +583,6 @@ mytime()\
|
|
|
}
|
|
|
}
|
|
|
}else{
|
|
|
- //获取对讲终端所在队列的号码
|
|
|
- sprintf(sql_tmp,"select exten from t_paging_deviceGroups JOIN t_paging_groups on t_paging_groups.id = t_paging_deviceGroups.GroupId where DeviceId = %s",g_row[0]);
|
|
|
- if (executesql(sql_tmp)){
|
|
|
- print_mysql_error(NULL);
|
|
|
- exit(1);
|
|
|
- }
|
|
|
- d_res = mysql_store_result(g_conn); // 从服务器传送结果集至本地,mysql_use_result直接使用服务器上的记录集
|
|
|
- while ((d_row=mysql_fetch_row(d_res))){ // 打印结果集
|
|
|
- if (d_row[0] == NULL){
|
|
|
- printf("some feild is empty!\n");
|
|
|
- continue;
|
|
|
- }
|
|
|
- fprintf(conf_fp, "include => phones-group-%s\n", d_row[0]);
|
|
|
- }
|
|
|
memset(sql_tmp,0,sizeof(sql_tmp));
|
|
|
sprintf(sql_tmp,"select UserId from t_paging_deviceGroups JOIN t_paging_userGroups on t_paging_deviceGroups.GroupId = t_paging_userGroups.GroupId where DeviceId = %s group by UserId",g_row[0]);
|
|
|
if (executesql(sql_tmp)){
|