phonehdb.c

一个操作系统源代码 用于嵌入式设备 在Vc++环境下仿真 成功移植到多款处理器上

/*************************************************************************
*
* Copyright  2002 National ASIC Center, All rights Reserved
*
* FILE NAME:			phoneHdb.c
* PROGRAMMER:			xuanhui
* Date of Creation:		2002/09/7
* 
* DESCRIPTION: 			Database operations for the application "phone history".
*
* NOTE:			 		 
*						 
*
* FUNCTIONS LIST:
* -------------------------------------------------------------------------
*InitPhoneHDB,
*LinkPhoneHDB,
*DetachPhoneHDB,
*PhoneHDBReadRecord,
*PhoneHDBModifyRecord,
*PhoneHDBAddRecord,
*PhoneHDBDelRecord,
*PhoneHDBFindRecord,
*PhoneHDBSearchRecord,
*
* GLOBAL VARS LIST:
* 
*
**************************************************************************
*
* MODIFICATION HISTORY
*
*
* 2002/09/7	by xuanhui		Create the file
*								
*************************************************************************/
#include <string.h>
#include <sys\lmalloc.h>

//#include "phonehdb.h"
#include <database\phonehdb.h>
#include <database\common.h>

// 字段索引
FIELDINDEX	PHTimeField_I[12];					// 时间一级索引表
FIELDINDEX	PHNameField_I[27];					// 姓名一级索引表
FIELDINDEX	PHPhoneField_I[100];					// 电话一级索引表
FIELDINDEX	PHCallTimeField[4];					// 通话时间索引表
FIELDINDEX	PHTypeField[3];						// 历史纪录类型一级索引表

//FIELDINDEXLIST	PhoneHDBFList[ PH_INDEX_FIELD_NUM ] = 
FIELDINDEXLIST	PhoneHDBFList[ PH_FIELD_NUM ] = 
	{
		{	PH_TIME_FIELD,		SINGLE_VALUE_FIELD,	12,		PHTimeField_I,   II_LEVEL },		// 时间索引表
		{	PH_NAME_FIELD,		SINGLE_VALUE_FIELD,	27,		PHNameField_I,   II_LEVEL },		// 姓名索引表
		{	PH_PHONE_FIELD,		SINGLE_VALUE_FIELD,	100,	PHPhoneField_I,  II_LEVEL },		// 电话索引表
		{	PH_CALL_TIME_FIELD,	SINGLE_VALUE_FIELD,	4,		PHCallTimeField, I_LEVEL  },		// 通话时间索引表
		{	PH_TYPE_FIELD,		SINGLE_VALUE_FIELD,	4,		PHTypeField,     I_LEVEL  }			// 历史纪录类型索引表
	};

//-------------------- Local Functions List --------------------------------------------//
//初始化一级索引表
static void InitIndexList( void );
// 将字段值加入到字段索引表
static DWORD Add2FieldIndexTbl( DBGACB *gacb, BYTE field, BYTE *value, DWORD id );

//创建新的二级索引表
static FIELDINDEX *CreateIIIndexList( FIELDINDEX *I_index_list, BYTE field );
//获取手机号码字段值的一二级索引
static void GetPhoneFieldIandIIIndex( BYTE *field_value, WORD *field_I_index, WORD *field_II_index );

/**********************************************************************/
DBGACB* InitPhoneHDB( DBGACB *gacb )
{
	DWORD	id = gacb->PLInfo->info.usedBlockHead;
	BYTE	i;

	InitIndexList();	// 初始化一级字段索引表

	gacb->IFNum = PH_INDEX_FIELD_NUM;
	gacb->FList = PhoneHDBFList;
	gacb->fieldNum = PH_FIELD_NUM;

	for( i = 0; i < RECORD_FIELD_LIST_LEN; i++)
		gacb->RFList[i] = 0;

	// 构建物理模式信息
	gacb->PLInfo->info.usedBlockTail = 0;
	gacb->PLInfo->info.freeBlockHead = 0;
	gacb->PLInfo->info.usedBlockNum = 0;
	gacb->PLInfo->info.freeBlockNum = 0;

	if( id != 0 )	// 判断记录是否为空
	{
		// 记录不为空
		DBRECORDHEAD	*head_info = NULL;
		BYTE	*record = NULL, *data, *field_value;
#ifdef SIM_ON_PC
		WORD	*field;
#else
		WORD	field;
#endif
		BYTE	i;
		WORD	record_size = 0;
		DWORD	record_num = 0;
		DWORD	rv = DB_OK;

		// 逐条读取记录，建立字段索引表和记录字段表
		do
		{
			rv = GlobalReadRecord( gacb->PLInfo, id, &record );
			if( rv == DB_FREE_RECORD )	//空闲记录
				record = NULL;
			if( ( rv == DB_NO_MEM ) || ( rv == DB_ERROR ) )		
				return NULL;

			if( record == NULL )//空闲记录块
			{
				if( ( head_info = (DBRECORDHEAD *)SysLmalloc(sizeof(DBRECORDHEAD)) ) == NULL )
					return NULL;
				gacb->PLInfo->info.freeBlockHead = id;
				//初始化空闲块数目
				fseek( gacb->PLInfo->fp, id+ADDRESS_BYTE_NUM, SEEK_SET );
				fread( &record_size, SIZE_BYTE_NUM, 1, gacb->PLInfo->fp );
				record_num = (DWORD)( ( record_size + BLOCK_DATA_SIZE - 1 ) / BLOCK_DATA_SIZE );
				gacb->PLInfo->info.freeBlockNum += record_num;
				//初始化尾记录地址
				fseek( gacb->PLInfo->fp, id+ADDRESS_BYTE_NUM+SIZE_BYTE_NUM+FLAG_BYTE_NUM+NEXT_BYTE_NUM, SEEK_SET );
				fread( &head_info->prev, PREV_BYTE_NUM, 1, gacb->PLInfo->fp );
				gacb->PLInfo->info.usedBlockTail = head_info->prev;
				SysLfree(head_info);
				break;
			}else{	//有效记录块
				head_info = (DBRECORDHEAD *)record;

				record_size = head_info->size;
				record_num = (DWORD)( ( record_size + BLOCK_DATA_SIZE - 1 ) / BLOCK_DATA_SIZE );

				gacb->PLInfo->info.usedBlockTail = id;//初始化尾记录地址
				gacb->PLInfo->info.usedBlockNum += record_num;

				data = (BYTE *)(&head_info->data);
#ifdef SIM_ON_PC
				field = (WORD *)data;
#endif

				for( i = 0; i < gacb->IFNum; i++ )
				{
#ifdef SIM_ON_PC
					if( field[i] != 0 )	// 字段有字段值
					{
						field_value = data + field[i];
#else
					Bytes2Word( &field, data+(i*sizeof(WORD)) );
					if( field != 0 )	// 字段有字段值
					{
						field_value = data + field;
#endif
						Add2FieldIndexTbl( gacb, i, field_value, id );// 将字段值加入到字段索引表	
					}
				}
				id = head_info->next;
				SysLfree(record);
			}
		}while( id != 0 );

	}
	return gacb;
}
/**********************************************************************/
DBLACB* LinkPhoneHDB( DBGACB *gacb )
{
	return LinkDB( gacb );
}

/**********************************************************************/

void DetachPhoneHDB( DBLACB *lacb )
{
	RECORDDATA		*prev_record_data, *next_record_data;
//	BYTE			*data;

	next_record_data = lacb->head->head;
	while( ( next_record_data != NULL ) && ( lacb->head->num != 0 ) )
	{
		prev_record_data = next_record_data;
		next_record_data++;
		if( prev_record_data->data != NULL )
		{
//			data = prev_record_data->data - ( SIZE_BYTE_NUM + FLAG_BYTE_NUM + NEXT_BYTE_NUM + PREV_BYTE_NUM );
			SysLfree( prev_record_data->data );
		}
		lacb->head->num--;
//		Lfree( prev_record_data );
	}

	SysLfree( lacb->head->head );
	SysLfree( lacb->head );
	return;
}
/**********************************************************************/
BYTE* PhoneHDBReadRecord( DBLACB *lacb, DWORD id )
{
	return ReadDBRecord( lacb, id );
}

/**********************************************************************/
DWORD PhoneHDBModifyRecord( DBLACB *lacb, DWORD id, BYTE *data, WORD dataLen )
{	
	BYTE			i;
	BYTE			*field_value, *record;
#ifdef SIM_ON_PC
	WORD			*field;
#else
	WORD			field;
#endif
	DWORD			rv = DB_OK;

	//读出修改前的数据
	rv = GlobalReadRecord( lacb->gacb->PLInfo, id, &record );
	if( rv != DB_OK )
		return DB_ERROR;

	DelRecordIndexTbl( lacb, id );

	//填充修改后的数据
	id = AddModifiedRecordData( lacb->gacb->PLInfo, id, data, dataLen, record );
	if( id == DB_ERROR )
		return DB_ERROR;

	//把修改后的记录添加大字段索引表和记录字段索引表中
#ifdef SIM_ON_PC
	field = (WORD *)data;
#endif
			
	for( i = 0; i < PH_INDEX_FIELD_NUM; i++ )
	{
#ifdef SIM_ON_PC
		if( field[i] != 0 )	// 字段有字段值
		{
			field_value = data + field[i];
#else
		Bytes2Word( &field, data+(i*sizeof(WORD)) );
		if( field != 0 )	// 字段有字段值
		{
			field_value = data + field;
#endif
			// 将字段值加入到字段索引表				
			Add2FieldIndexTbl( lacb->gacb, i, field_value, id );
		}
	}
	return id;
}

/**********************************************************************/
DWORD PhoneHDBAddRecord( DBLACB *lacb, BYTE *data, WORD dataLen )
{
	BYTE			i;
	BYTE			*field_value;
#ifdef SIM_ON_PC
	WORD			*field;
#else
	WORD			field;
#endif
	DWORD			id = 0;

	//填充新添加的数据
	id = AddNewRecordData( lacb->gacb->PLInfo, data, dataLen );
	if( id == DB_ERROR )
		return DB_ERROR;

	//把修改后的记录添加大字段索引表和记录字段索引表中
#ifdef SIM_ON_PC
	field = (WORD *)data;
#endif
	
	for( i = 0; i < lacb->gacb->IFNum; i++ )
	{
#ifdef SIM_ON_PC
		if( field[i] != 0 )	// 字段有字段值
		{
			field_value = data + field[i];
#else
		Bytes2Word( &field, data+(i*sizeof(WORD)) );
		if( field != 0 )	// 字段有字段值
		{
			field_value = data + field;
#endif
			Add2FieldIndexTbl( lacb->gacb, i, field_value, id );// 将字段值加入到字段索引表		
		}
	}
	return id;
}

/**********************************************************************/

DWORD PhoneHDBDelRecord( DBLACB *lacb, DWORD id )
{
	id = GlobalDelRecord( lacb->gacb->PLInfo, id );			//在数据库中删除指定的记录
	if( ( id == DB_ERROR ) || ( id == DB_FREE_RECORD ) )
		return DB_ERROR;

	DelRecordIndexTbl( lacb, id );
	
	return id;
}
/**********************************************************************/
//在指定数据库中查找与指定字段匹配(完全匹配/部分匹配)的记录(精确查找)
LOCALSEARCHLIST* PhoneHDBFindRecord( DBLACB *lacb, BYTE field, BYTE *data, BYTE mode )
{	
	WORD				i, j, k = 0;
	FIELDINDEXLIST		*list;		//字段索引表	
	FIELDINDEX			*I_index_list, *II_index_list;	//一、二级索引表
	WORD				field_I_index[PY_MAX_NUM], field_II_index[PY_MAX_NUM];//字段一二级索引值
	RECORDINDEX			*next_record_index; 
	RECORDINDEX			*local_search_list = NULL;
	BYTE				PY_num = 0;
	RECORDDATA			*record_data_head;
	WORD				hour, minute, second;
	DWORD				read_rv = DB_OK;

	//验证字段的有效性
	if( field < 0 || field > ( PH_INDEX_FIELD_NUM - 1) )
		return NULL;
	
	//验证查找模式的有效性
	if( ( mode != PRECISE_FULL_MATCH ) && ( mode != PRECISE_PART_MATCH ) && ( mode != GLOBAL_SEARCH ) )
		return NULL;

	list = lacb->gacb->FList;
	I_index_list = list[field].head;//找到相符的一级字段索引表

	//申请局部查找表
	if( ( lacb->head = SysLmalloc( sizeof(LOCALSEARCHLIST) ) ) == NULL )	
		return NULL;
	lacb->head->num = 0;
	lacb->head->head = NULL;
	
	if( ( mode == GLOBAL_SEARCH ) && ( data == NULL ) )			//所有记录按主索引排列(名片:姓名,电话和短信历史纪录:时间)
	{
		for( i = 0; i < list[field].num; i++ )
		{
			II_index_list = I_index_list->sub;
			for( j = 0; j < I_index_list->num; j++ )
			{
				next_record_index = II_index_list->next;
				for( k = 0; k < II_index_list->num; k++ )
				{
					GetLocalSearchList( &local_search_list, next_record_index->index );
					next_record_index = next_record_index->next;
				}
				lacb->head->num = (WORD)( lacb->head->num + II_index_list->num );
				II_index_list++;
			}
			I_index_list++; 
		}
		if( lacb->head->num != 0 )
		{
//			lacb->head = ObtainSearchList( lacb->head, lacb->gacb->PLInfo, local_search_list, lacb->head->num );
//			lacb->head = ObtainSearchList( lacb->head, lacb->gacb->PLInfo, local_search_list, lacb->head->num, PH_TIME_FIELD );
			lacb->head->head = ObtainSearchList( lacb->gacb->PLInfo, local_search_list, lacb->head->num );
			PhoneHDBSortList( lacb, lacb->head, PH_TIME_FIELD, 0 );
			FreeRecordList( local_search_list );
		}
		goto endrv;
	}

	//验证字段值的有效性
	if( data == NULL )
		return NULL;

	switch( field )	//获取关键字的一二级索引
	{
		case PH_NAME_FIELD:	// 姓名字段
			GetNameFieldIandIIIndex( data, field_I_index, field_II_index, &PY_num);	//将关键字转化为索引
			I_index_list += ( *field_I_index - 'a' );
			if( I_index_list->num == 0 )
			{
				goto endrv;
			}else{
				II_index_list = I_index_list->sub;
				II_index_list += ( *field_II_index );//确定二级索引表
			}
			break;
		case PH_PHONE_FIELD: // 手机号码字段
			GetPhoneFieldIandIIIndex( data, field_I_index, field_II_index );
			I_index_list += ( *field_I_index );//确定一级索引表
			if( I_index_list->num == 0 )
			{
				goto endrv;
			}else{
				II_index_list = I_index_list->sub;
				II_index_list += ( *field_II_index );//确定二级索引表
			}
			break;
		case PH_CALL_TIME_FIELD:
			hour = (WORD)( ( *data & 0x0f ) * 10 + ( *( data + 1 ) & 0x0f ) );
			minute = (WORD)( ( *( data + 2 ) & 0x0f ) * 10 + ( *( data + 3 ) & 0x0f ) );
			second = (WORD)( ( *( data + 4 ) & 0x0f ) * 10 + ( *( data + 5 ) & 0x0f ) );
			
			if( ( hour > 1 ) || ( hour == 1 &&  ( minute >= 0 || second >= 0 ) ) )