sub_db_sybase_cfg.c

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

#include "sub_db_sybase_cfg.h"

/*******************************************************************************\
| Name			: sub_db_sybase_getcmsvradd										|
| Description	: for KPI CM-00-03-01-01 :get server IP address					|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmsvradd()
{
	char FuncName[128] = {"sub_db_sybase_getcmsvradd"};
	char shellCommandStr[MAX_STRING_LENGTH];
	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_getcmsvradd 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,"getcmsvradd.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmsvradd.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;

			memset(shellCommandStr,'\0',sizeof(shellCommandStr));
			sprintf(shellCommandStr,"%s/sub_db_sybase_getcmsvradd.sh %s",GET_DB_SHELL_PATH,EachDBEntityCfg);
			getSingleValueFromShell(shellCommandStr,pKPIValues);
			/* put KPI Value to Queue */
			putKPIValueQueue(pKPIValues);
		}
	}
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvradd End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmsvrname									|
| Description	: for KPI CM-00-03-01-02 :get server name						|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmsvrname()
{
	char FuncName[128] = {"sub_db_sybase_getcmsvrname"};
	char shellCommandStr[MAX_STRING_LENGTH];
	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_getcmsvrname Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	memset(temp,'\0',sizeof(temp));
	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,"getcmsvrname.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmsvrname.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;

			memset(shellCommandStr,'\0',sizeof(shellCommandStr));
			sprintf(shellCommandStr,"%s/sub_db_sybase_getcmsvrname.sh %s",GET_DB_SHELL_PATH,EachDBEntityCfg);
			getSingleValueFromShell(shellCommandStr,pKPIValues);
			/* put KPI Value to Queue */
			putKPIValueQueue(pKPIValues);
		}
	}
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvrname End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmsvrport									|
| Description	: for KPI CM-00-03-01-03 :get server IP port					|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmsvrport()
{
	char FuncName[128] = {"sub_db_sybase_getcmsvrport"};
	char shellCommandStr[MAX_STRING_LENGTH];
	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_getcmsvrport Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	memset(temp,'\0',sizeof(temp));
	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,"getcmsvrport.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmsvrport.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;

			memset(shellCommandStr,'\0',sizeof(shellCommandStr));
			sprintf(shellCommandStr,"%s/sub_db_sybase_getcmsvrport.sh %s",GET_DB_SHELL_PATH,EachDBEntityCfg);
			getSingleValueFromShell(shellCommandStr,pKPIValues);
			/* put KPI Value to Queue */
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvrport End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmsvrlogpath									|
| Description	: for KPI CM-00-03-01-04 :get server log path					|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmsvrlogpath()
{
	char FuncName[128] = {"sub_db_sybase_getcmsvrlogpath"};
	char shellCommandStr[MAX_STRING_LENGTH];
	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_getcmsvrlogpath Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	memset(temp,'\0',sizeof(temp));
	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,"getcmsvrlogpath.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmsvrlogpath.KPIID");
			sprintf(pKPIValues->KPIID,temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;

			memset(shellCommandStr,'\0',sizeof(shellCommandStr));
			sprintf(shellCommandStr,"%s/sub_db_sybase_getcmsvrlogpath.sh %s",GET_DB_SHELL_PATH,EachDBEntityCfg);
			getSingleValueFromShell(shellCommandStr,pKPIValues);
			/* put KPI Value to Queue */
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvrlogpath End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmsvrshmsize									|
| Description	: for KPI CM-00-03-01-05: get server share memory size			|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.20.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmsvrshmsize()
{
	char FuncName[128] = {"sub_db_sybase_getcmsvrshmsize"};
	long lDBEntityNum=0;
	int i=0;
	char temp[VALUE_STRING_LENGTH];
	char tempValue[128];
	char EachDBEntityCfg[256];
	struct KPIValue *pKPIValues = NULL;
	FILE *fp = NULL;
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmsvrshmsize 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,"getcmsvrshmsize.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));	
			getParameter(temp,EachDBEntityCfg,"getcmsvrshmsize.KPIID");
			sprintf(pKPIValues->KPIID,temp);