sub_db_sybase_cfg.c

电信硬件的信息数据采集程序

				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmsvrlogerrmsg.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmsvrlogerrmsg.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
	
			sprintf(tempFile,"%s/KPIErrlog.tmp",TEMP_FILE_PATH);
			memset(shellCommandStr,'\0',sizeof(shellCommandStr));
			sprintf(shellCommandStr,"%s/sub_db_sybase_getcmsvrlogerrmsg.sh %s",GET_DB_SHELL_PATH,EachDBEntityCfg);
			getShellValueFromFile(shellCommandStr,pKPIValues,tempFile);
			/* put KPI Value to Queue */
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvrlogerrmsg End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif

	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getfmdbloguseradio								|
| Description	: for KPI FM-00-03-01-04 :get database log use radio           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getfmdbloguseradio()
{
	char FuncName[128] = {"sub_db_sybase_getfmdbloguseradio"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmdbloguseradio Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmdbloguseradio.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmdbloguseradio.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getfmdbloguseradio(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmdbloguseradio End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getfmdbloguse									|
| Description	: for KPI FM-00-03-01-05 :get database log use radio           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getfmdbloguse()
{
	char FuncName[128] = {"sub_db_sybase_getfmdbloguse"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmdbloguse Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmdbloguse.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmdbloguse.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getfmdbloguse(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmdbloguse End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getpmwaitlocks									|
| Description	: for KPI PM-00-03-01-07:										|
|				  get the number of wait locks									|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getpmwaitlocks()
{
	char FuncName[128] = {"sub_db_sybase_getpmwaitlocks"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getpmwaitlocks Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getpmwaitlocks.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getpmwaitlocks.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getpmwaitlocks(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);	
		}
	}

#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getpmwaitlocks End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbspacefreeradio							|
| Description	: for KPI PM-00-03-01-08:										|
|				  get database free space radio									|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbspacefreeradio()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbspacefreeradio"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbspacefreeradio Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {
			continue;
		} else {
			fp = fopen(EachDBEntityCfg,"r");
			if(fp == NULL) {
#ifdef ERROR_OUT
				sprintf(DebugMsg,"file %s not exists!\n",EachDBEntityCfg);
				writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
				continue;
			}
			fclose(fp);
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbspacefreeradio.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbspacefreeradio.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getcmdbspacefreeradio(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbspacefreeradio End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif

	return;
}


/*******************************************************************************\
| Name			: sub_db_sybase_gettempdbspcfreeradio							|
| Description	: for KPI PM-00-03-01-09:										|
|				  get tempdb free space radio									|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_gettempdbspcfreeradio()
{
	char FuncName[128] = {"sub_db_sybase_gettempdbspcfreeradio"};
	struct KPIValue *pKPIValues = NULL;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	long lDBEntityNum=0;
	int i=0;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_gettempdbspcfreeradio Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	pKPIValues = malloc(sizeof(struct KPIValue));
	if(!pKPIValues) {
#ifdef ERROR_OUT
		sprintf(DebugMsg,"malloc memory failed\n");
		writeLog(FuncName,DebugMsg,ERROR_MSG);
#endif
		return;
	}
	memset(pKPIValues,'\0',sizeof(struct KPIValue));
	memset(tempValue,'\0',sizeof(tempValue));
	getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,(char *)DB_ENTITY_NUM_ITEM);
	lDBEntityNum = atol(tempValue);
	for(i=0;i<lDBEntityNum;++i) {
		char dbEntityCfgItem[64];
		memset(dbEntityCfgItem,'\0',sizeof(dbEntityCfgItem));
		memset(tempValue,'\0',sizeof(tempValue));
		memset(EachDBEntityCfg,'\0',sizeof(EachDBEntityCfg));

		sprintf(dbEntityCfgItem,"%s_%ld",DB_ENTITY_CFG_PREFIX,i+1);		
		getParameter(tempValue,(char *)SUB_DB_CONFIG_FILE,dbEntityCfgItem);
		sprintf(EachDBEntityCfg,"%s",tempValue);
		if(strlen(StrTrim(EachDBEntityCfg)) == 0) {