sub_db_sybase_cfg.c

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

			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbshmsize.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbshmsize.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI value */
			getcmdbshmsize(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbshmsize End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbdevname									|
| Description	: for KPI CM-00-03-01-11 :get database device name	           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbdevname()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbdevname"};
	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_getcmdbdevname 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,"getcmdbdevname.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbdevname.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;

			/* get KPI values */	
			getcmdbdevname(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbdevname End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbdevpath									|
| Description	: for KPI CM-00-03-01-12 :get database device path	           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbdevpath()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbdevpath"};
	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_getcmdbdevpath 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,"getcmdbdevpath.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbdevpath.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
	
			/* get KPI values */	
			getcmdbdevpath(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbdevpath End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}


/*******************************************************************************\
| Name			: sub_db_sybase_getcmdbdevsize									|
| Description	: for KPI CM-00-03-01-13 :get database device size	           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmdbdevsize()
{
	char FuncName[128] = {"sub_db_sybase_getcmdbdevsize"};
	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_getcmdbdevsize 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,"getcmdbdevsize.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getcmdbdevsize.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getcmdbdevsize(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getcmdbdevsize End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getfmsrvstatus									|
| Description	: for KPI FM-00-03-01-01 :get database server status           	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getfmsrvstatus()
{
	char FuncName[128] = {"sub_db_sybase_getfmsrvstatus"};
	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_getfmsrvstatus 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,"getfmsrvstatus.EntityID");
			sprintf(pKPIValues->EntityID,"%s",temp);
			sprintf(pKPIValues->CollTime,"%s",getDatetime());
			memset(temp,'\0',sizeof(temp));
			getParameter(temp,EachDBEntityCfg,"getfmsrvstatus.KPIID");
			sprintf(pKPIValues->KPIID,"%s",temp);
			sprintf(pKPIValues->KPIValue,"");
			pKPIValues->next = NULL;
			/* get KPI values */	
			getfmsrvstatus(pKPIValues,EachDBEntityCfg);
			putKPIValueQueue(pKPIValues);
		}
	}
	
#ifdef DEBUG_OUT
	sprintf(DebugMsg,"sub_db_sybase_getfmsrvstatus End\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif

	return;
}

/*******************************************************************************\
| Name			: sub_db_sybase_getcmsvrlogerrmsg								|
| Description	: for KPI FM-00-03-01-02 :get error log message             	|
| Input Param	: 																|
| Output Param	:																|
| Author		: yangyong														|
| History		: Aug.21.2003		yangyong		create						|
|																				|
|*******************************************************************************/
void sub_db_sybase_getcmsvrlogerrmsg()
{
	char FuncName[128] = {"sub_db_sybase_getcmsvrlogerrmsg"};
	char shellCommandStr[MAX_STRING_LENGTH];
	char tempFile[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_getcmsvrlogerrmsg Begin\n");
	writeLog(FuncName,DebugMsg,DEBUG_MSG);
#endif
	memset(temp,'\0',sizeof(temp));
	memset(tempFile,'\0',sizeof(tempFile));
	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