emaildb.c

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

	{
		case EMAIL_SUBIECT_FIELD:	// 主题字段
		case EMAIL_ADDRESSER_FIELD:	// 发件人字段
		case EMAIL_ADDRESSEE_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 EMAIL_TYPE_FIELD:	// 类型字段
		case EMAIL_BOX_FIELD:	// 邮件所在箱型字段(收件箱、发件箱、草稿箱、垃圾箱)
			*field_I_index = (WORD)(*data & 0x0f);
			I_index_list += ( *field_I_index );//确定一级索引表
			break;
		default:
			break;
	}
			
	switch( field )	//得到查找的链表
	{
		case EMAIL_TIME_FIELD:	// 邮件时间字段
			lacb->head = SearchTimeRange( lacb, data, I_index_list, EMAIL_TIME_FIELD );
			break;
		case EMAIL_SUBIECT_FIELD:	// 主题字段
		case EMAIL_ADDRESSER_FIELD: // 发件人字段
		case EMAIL_ADDRESSEE_FIELD:	// 收件人字段
			if( II_index_list->num == 0 )	
				goto	endrv;
			
			read_rv = SearchPreciseRecord( II_index_list, lacb, field, data, mode );
			if( read_rv != DB_OK )
			{
				SysLfree( lacb->head );
				return NULL;
			}
			if( lacb->head->num != 0 )
			{
				if( ( record_data_head = (RECORDDATA *)SysLmalloc( sizeof(RECORDDATA) * lacb->head->num ) ) == NULL ) 
				{
					SysLfree( lacb->head );
					return NULL;
				}
				memcpy( record_data_head, lacb->head->head, ( sizeof(RECORDDATA) * lacb->head->num ) );
				SysLfree( lacb->head->head );
				lacb->head->head = record_data_head;
			}
			break;
		case EMAIL_TYPE_FIELD:	// 关系字段
		case EMAIL_BOX_FIELD:	// 邮件所在箱型字段(收件箱、发件箱、草稿箱、垃圾箱)
			lacb->head->num = I_index_list->num;
			if( I_index_list->num != 0 )
				lacb->head->head = ObtainSearchList( lacb->gacb->PLInfo, I_index_list->next, lacb->head->num );
			break;
		default:
			break;
	}

	EmailDBSortList( lacb, lacb->head, EMAIL_TIME_FIELD, 0 );
endrv:
	return ( lacb->head );
}

/**********************************************************************/
//在指定数据库中查找与指定字段索引匹配（完全匹配/部分匹配）的记录（模糊查找）
 LOCALSEARCHLIST* EmailDBSortRecord( DBLACB *lacb, BYTE field, BYTE *data, BYTE reserved )
{
	return NULL;
}

/**********************************************************************/
//对指定列表进行排序
LOCALSEARCHLIST* EmailDBSortList( DBLACB *lacb, LOCALSEARCHLIST *searchlist, BYTE field, BYTE reserved )
{
	WORD				i, count;
	CHAR				rv = 0;			//字段值比较结果
	DBRECORDHEAD		*head_info, *tmp_head_info;
	BYTE				*record_data, *field_value, *tmp_data, *tmp_field_value;
#ifdef SIM_ON_PC
	WORD				*field_head, *tmp_field_head;
#else
	WORD				field_head, tmp_field_head;
#endif
	RECORDDATA			*next_record_data;

	//验证字段的有效性
	if( ( field != EMAIL_TIME_FIELD ) && ( field != EMAIL_SUBIECT_FIELD) && ( field != EMAIL_ADDRESSER_FIELD) )
		return NULL;
	
	if(  searchlist->num != 0 )
	{
		count = searchlist->num;
		if( ( next_record_data = (RECORDDATA *)SysLmalloc(sizeof(RECORDDATA)) ) == NULL )
			return NULL;
		while( count != 1 )	//冒泡算法
		{
			for( i = 0; i < (WORD)( count - 1 ) ; i++ )
			{
				head_info = (DBRECORDHEAD *)( searchlist->head[i].data );
				record_data = (BYTE *)(&head_info->data);
#ifdef SIM_ON_PC
				field_head = (WORD *)record_data;
				if( field_head[field] != 0 )
					field_value = record_data + field_head[field];
#else
				Bytes2Word( &field_head, record_data+(field*sizeof(WORD)) );
				if( field_head != 0 )
					field_value = record_data + field_head;
#endif

				tmp_head_info = (DBRECORDHEAD *)( searchlist->head[i+1].data );
				tmp_data = (BYTE *)(&tmp_head_info->data);
#ifdef SIM_ON_PC
				tmp_field_head = (WORD *)tmp_data;
				if( tmp_field_head[field] != 0 )
					tmp_field_value = tmp_data + tmp_field_head[field];
#else
				Bytes2Word( &tmp_field_head, tmp_data+(field*sizeof(WORD)) );
				if( tmp_field_head != 0 )
					tmp_field_value = tmp_data + tmp_field_head;
#endif

				switch( field )
				{
					case EMAIL_TIME_FIELD:
						rv = strcmp( field_value, tmp_field_value );
						break;
					case EMAIL_SUBIECT_FIELD:
					case EMAIL_ADDRESSER_FIELD:
						rv = CompareChar( field_value, tmp_field_value );
						break;
				}
				if( ( ( rv > 0 ) && ( field == EMAIL_SUBIECT_FIELD || field == EMAIL_ADDRESSER_FIELD ) )	//名字按拼音和长度排列(大的放后面),交换;时间按新的放在后面
				  || ( ( rv < 0 ) && ( field == EMAIL_TIME_FIELD ) ) )	//新时间排在前面
				{
					//暂存前一个数据
					next_record_data->index = searchlist->head[i].index;
					next_record_data->data = searchlist->head[i].data;
					next_record_data->datalen = searchlist->head[i].datalen;

					//重新写入前一个数据
					searchlist->head[i].index = searchlist->head[i+1].index;
					searchlist->head[i].data = searchlist->head[i+1].data;
					searchlist->head[i].datalen = searchlist->head[i+1].datalen;

					//重新写入后一个数据
					searchlist->head[i+1].index = next_record_data->index;
					searchlist->head[i+1].data = next_record_data->data;
					searchlist->head[i+1].datalen = next_record_data->datalen;
				}
			}
			count--;
		}
		SysLfree(next_record_data);
	}
	return searchlist;
}

/*************** Local Functions ********************/
//初始化一级索引表
void InitIndexList( void )
{
	BYTE i;

	// 时间一级索引表
	for( i = 0; i < 12; i++ )
	{
		EmailTimeField_I[i].next = NULL;
		EmailTimeField_I[i].prev = NULL;
		EmailTimeField_I[i].sub = NULL;
		EmailTimeField_I[i].index = i;		// 0 to 11
		EmailTimeField_I[i].num = 0;
	}

	// 主题一级索引表   //	for( i = 0; i < 26; i++ )
	for( i = 0; i < 27; i++ )
	{
		EmailSubjectField_I[i].next = NULL;
		EmailSubjectField_I[i].prev = NULL;
		EmailSubjectField_I[i].sub = NULL;
		EmailSubjectField_I[i].index = (WORD)(97+i);	// 'a' to 'z'
		EmailSubjectField_I[i].num = 0;
	}

	// 发件人一级索引表
	for( i = 0; i < 27; i++ )
	{
		EmailAddresserField_I[i].next = NULL;
		EmailAddresserField_I[i].prev = NULL;
		EmailAddresserField_I[i].sub = NULL;
		EmailAddresserField_I[i].index = (WORD)(97+i);	// 'a' to 'z'
		EmailAddresserField_I[i].num = 0;
	}

	// 收件人一级索引表
	for( i = 0; i < 27; i++ )
	{
		EmailAddresseeField_I[i].next = NULL;
		EmailAddresseeField_I[i].prev = NULL;
		EmailAddresseeField_I[i].sub = NULL;
		EmailAddresseeField_I[i].index = (WORD)(97+i);	// 'a' to 'z'
		EmailAddresseeField_I[i].num = 0;
	}


	// 邮件类型索引表
	for( i = 0; i < 4; i++ )
	{
		EmailTypeField[i].next = NULL;
		EmailTypeField[i].prev = NULL;
		EmailTypeField[i].sub = NULL;
		EmailTypeField[i].index = i;		// 0 to 3
		EmailTypeField[i].num = 0;
	}

	// 邮件所在箱型字段(收件箱、发件箱、垃圾箱)索引表
	for( i = 0; i < 4; i++ )
	{
		EmailBoxField[i].next = NULL;
		EmailBoxField[i].prev = NULL;
		EmailBoxField[i].sub = NULL;
		EmailBoxField[i].index = i;		// 0 to 2
		EmailBoxField[i].num = 0;
	}
}

/**********************************************************************/
// 将字段值加入到字段索引表	
DWORD Add2FieldIndexTbl( DBGACB *gacb, BYTE field, BYTE *value, DWORD id )
{
	FIELDINDEXLIST		*list;
	FIELDINDEX			*I_index_list, *II_index_list;	//一、二级索引表
	RECORDINDEX			*new_record_head;				//新纪录的地址
	BYTE				*temp;							//指向字段的暂存指针
	WORD				field_I_index[PY_MAX_NUM], field_II_index[PY_MAX_NUM];//字段一二级索引值
	BYTE				i;
	BYTE				PY_num = 0;						//存放汉字的多音字的个数

	if( value == NULL )
		return DB_ERROR;

	temp = value;
	list = gacb->FList;
	I_index_list = list[field].head;//链接一级索引表

	switch( field )
	{
		case EMAIL_SUBIECT_FIELD:	// 姓名字段
		case EMAIL_ADDRESSER_FIELD:	// 发件人字段 
		case EMAIL_ADDRESSEE_FIELD:	// 收件人字段
			GetNameFieldIandIIIndex( temp, field_I_index, field_II_index, &PY_num);	//将字段值转化为索引
			for( i = 0; i <= PY_num; i++ )			//把单音字/多音字逐个添加到字段索引表中
			{
				I_index_list += ( field_I_index[i] - 'a' );
				II_index_list = CreateIIIndexList( I_index_list, field );// 新建姓名二级索引表
				II_index_list += ( field_II_index[i] );//确定二级索引表
				
				new_record_head = Add2RecordIndexTbl( II_index_list, id );//添加记录在二级索引的记录表中
				Add2RecordIndex( gacb->RFList, id, new_record_head );// 将字段索引加入到记录字段表
					 
				I_index_list = list[field].head;
//				field_I_index++;
//				field_II_index++;
			}
//			field_I_index -= (PY_num+1);
//			field_II_index -= (PY_num+1);
			break;
		case EMAIL_TIME_FIELD:	// 时间字段
			GetTimeFieldIandIIIndex( temp, field_I_index, field_II_index );
			I_index_list += ( *field_I_index );//确定一级索引表
			II_index_list = CreateIIIndexList( I_index_list, field );// 新建二级索引表
			II_index_list += ( *field_II_index );//确定二级索引表
			
			new_record_head = Add2RecordIndexTbl( II_index_list, id );//添加记录在二级索引的记录表中
			Add2RecordIndex( gacb->RFList, id, new_record_head );// 将字段索引加入到记录字段表
			break;
		case EMAIL_TYPE_FIELD:	// 关系字段
		case EMAIL_BOX_FIELD:	// 邮件所在箱型字段(收件箱、发件箱、垃圾箱)

			*field_I_index = (WORD)( *value & 0x0f );
			
			I_index_list += ( *field_I_index );//确定一级索引表
			
			new_record_head = Add2RecordIndexTbl( I_index_list, id );//添加记录在二级索引的记录表中
			Add2RecordIndex( gacb->RFList, id, new_record_head );// 将字段索引加入到记录字段表
			break;
		default:
			break;
	}

	return DB_OK;
}

/**********************************************************************/
//创建新的二级索引表
FIELDINDEX *CreateIIIndexList( FIELDINDEX *I_index_list, BYTE field )
{
	BYTE			k;
	FIELDINDEX		*II_index_list;

	II_index_list = I_index_list->sub;		//链接二级索引表
	if( II_index_list == NULL )	 //二级索引表为空,则动态申请二级索引表
	{
								
		switch( field )
		{		
			case EMAIL_TIME_FIELD:		// 邮件时间字段
				I_index_list->num = 31;		//更新一级索引表的索引数
				break;
			case EMAIL_SUBIECT_FIELD:	// 主题字段
			case EMAIL_ADDRESSER_FIELD:	// 发件人字段
			case EMAIL_ADDRESSEE_FIELD:	// 收件人字段
				I_index_list->num = 54;		//更新一级索引表的索引数
				break;
			default:
				return NULL;
		}

		if( ( II_index_list = (FIELDINDEX *)SysLmalloc( sizeof(FIELDINDEX) * ( I_index_list->num ) ) ) == NULL )
			return NULL;
		I_index_list->sub = II_index_list;	//链接二级索引表
		
		// 新建二级索引表
		for( k = 0; k < I_index_list->num; k++ )
		{
			II_index_list[k].next = NULL;		
			II_index_list[k].prev = NULL;
			II_index_list[k].sub = NULL;
			II_index_list[k].index = k;	
			II_index_list[k].num = 0;
		}
	}
	return ( II_index_list );
}