dbproc.c.bak

用于小商品消费的SMS消费机程序

		
		serialNo = ((int)blHead.cSerial[0]<<8) + blHead.cSerial[1];
		blackNum = ((int)blHead.cBlackNumber[0]<<8) + blHead.cBlackNumber[1];
		if( (serialNo == 0) && (blackNum > 0) ) //如果是第一个黑名单包，而且有数据
			DB_erase_filesys(BL_DB_INDEX);
		
		p = blPacket + sizeof(blHead);

		for( ; count<blackNum; count++ )
		{
			DB_add_record(BL_DB_INDEX, (void *)( p + count*8 ) );
		}
	}
	else
	{
		count = -1;
	}
	return count;
}

/*
 * 比较两个8byte的卡号
 * in:     unisgned char *card1
 *         unsigned char *card2
 * return: 0    card1=card2
 *         1    card1>card2
 *         -1   card1<card2
 */
short cmpCardNo(const unsigned char *card1, const unsigned char *card2)
{
	int i=0;

	for(;i<8;i++)
	{
		if(card1[i] > card2[i])	
		{
			return 1;
		}
		else if(card1[i] < card2[i])
		{
			return -1;
		}
	}
	
	return 0;	
}
/*
 * 在黑名单数据库中查找指定的黑名单，采用折半查找，要求黑名单一定是升序的
 * 输入参数: 卡号
 * 返回    : 0      成功，在黑名单中
 *           other  失败，不在黑名单中
 */
short findBlackList(unsigned char * cardNo)
{
	int low=0, heigh, mid, i=0; 
	unsigned char *p;
	char flag;
	
	heigh = DB_count_records(BL_DB_INDEX)-1;

	while( low <= heigh )
	{
		mid = (low + heigh) >> 2;
		
		p = (unsigned char *)DB_jump_to_record(BL_DB_INDEX, mid, &flag);
		i = cmpCardNo(cardNo, p);
		if( i == 0 )
		{
			return 0;
		}
		else if( i > 0 )
		{
			low = mid + 1;
		}
		else 
		{
			heigh = mid + 1;
		}
	}
	return 1;
} 

inline short haveTradeRecord(const sttSysRunTime *srt)
{
	if  ( (srt->cLastTradeHandleDb != srt->cLastGatherToDb) || (srt->lLastGatherTo < srt->lLastTradeHandle) ) 
		return 1;
	return 0;	
}

/*
 * 打包交易记录（建议一个packet包最多20条交易记录）
 * 输入参数: 
 * 返回    : 打包条数,如果<0，代表打包不成功
 */
short wrapTradeRecord(unsigned char *inBuf, int serialNo, sttSysRunTime *pSrt)
{
	sttPacketHead pHead;
	void *p;
	unsigned char *buf;
	unsigned char tmpbuf[10];

	char flag;
	unsigned short wrapNum=0;
	
	unsigned char oldDb;
	unsigned long oldTo;
	unsigned long curDbCapacity;
	
	buf = inBuf + sizeof(sttPacketHead);
	
	if( getSysRunTime(pSrt) == 0 )
	{
		//有交易数据
		if( haveTradeRecord(pSrt))  
		{
			oldDb = pSrt->cLastGatherToDb;
			oldTo = pSrt->lLastGatherTo;
			curDbCapacity = DB_capacity(pSrt->cLastGatherToDb);			
			
			while( haveTradeRecord(pSrt) )
			{
				if( pSrt->lLastGatherTo == curDbCapacity )
				{
					pSrt->lLastGatherTo = 0;	
					if(pSrt->cLastGatherToDb == TD_DB_INDEX3)
						pSrt->cLastGatherToDb = TD_DB_INDEX1;
					else 
						pSrt->cLastGatherToDb ++;
					curDbCapacity = DB_capacity(pSrt->cLastGatherToDb);
				}
				p = DB_jump_to_record(pSrt->cLastGatherToDb, pSrt->lLastGatherTo, &flag); 	
//				if(((*((char*)p+37)&0xf0)==0x10)||((*((char*)p+37)&0xf0)==0x20))
//				{
					memcpy((void *)(buf+wrapNum*(sizeof(sttChargeRecord)-1)), p, sizeof(sttChargeRecord)-1);
					wrapNum ++;
//				}
				
				pSrt->lLastGatherTo ++;
				if(wrapNum == 10)
					break;
				
			}	
//			if( wrapNum > 0)
			{
				pSrt->cLastGatherFromDb = oldDb;
				pSrt->lLastGatherFrom = oldTo;
				getBCDDateTime((unsigned char *)pSrt->cLastGatherDateTime);
			}
		}
		
		memcpy((void *)pHead.cBuildDateTime,(void *)pSrt->cLastGatherDateTime,7);
		memset((void *)pHead.cSAMNo,0,4);
		memcpy((void *)pHead.cSAMNo+4,gcPSAMNo,4);//SAM卡卡号，应该是全局的
		pHead.cSerial[0] = serialNo & 0x00FF;//
		pHead.cSerial[1] = serialNo >> 8;
		pHead.cTradeSerialNo[0] = 0;
		pHead.cTradeSerialNo[1] = 0;
		pHead.cTradeSerialNo[2] = 0;
		pHead.cTradeSerialNo[3] = 0;
		pHead.cRecordNumber[0] = wrapNum & 0x00FF;
		pHead.cRecordNumber[1] = wrapNum >> 8;
		pHead.cBcc = XOR_calc( (unsigned char *)&pHead, sizeof(pHead)-1 );   
		memcpy( (void *)inBuf,(void *)&pHead, sizeof(pHead) ); //加上包头
	}
	
	return wrapNum;
}

/*
 * 在交易记录数据库中加入一条交易记录
 * 输入参数: 交易记录
 * 返回    : 0         成功
 *           other     失败
 */
short appendTradeRecord(sttChargeRecord *cr)
{
	sttSysRunTime srt;
	unsigned char tmpbuf[10];

	move_cursor(0,0);
	puts("appendRecord");
	
	if(getSysRunTime(&srt) != 0 )                                //得到运行时参数出错
	{
		return 1;
	}
		
	if(DB_add_record(srt.cLastTradeHandleDb, (void *)cr) == 0 )  //加入当前数据库中
	{
		
		if(srt.cLastTradeHandleDb == TD_DB_INDEX3)
			srt.cLastTradeHandleDb = TD_DB_INDEX1;
		else
			srt.cLastTradeHandleDb ++;
		if(srt.cLastGatherFromDb == srt.cLastTradeHandleDb )  //加入位置所在db到了最后采集的开始位置所在的db,不能加入
			return 2;
		DB_erase_filesys(srt.cLastTradeHandleDb);	//删除数据库
		if( DB_add_record(srt.cLastTradeHandleDb, (void *)cr) != 0 )//加入新的数据库中
		{
			srt.lLastTradeHandle = 1;       //交易位置指针=1;
		}
		else 
			return 3;
	}
	else
	{
		srt.lLastTradeHandle ++;  //交易位置指针+1;	
	}
	
	if(gcChargeType!=0x30)
	{
		glTradeCounter ++;
	}
	srt.lTradeCounter = glTradeCounter;
	
	if (updateSysRunTime(&srt) != 0)	//update sysruntime param
		return 4;
	
	return 0;
}


inline short haveSendRecord(const sttSysRunTime *srt)
{
	if  ( (srt->cLastTradeHandleDb != srt->cLastSendToDb) || (srt->lLastSendTo < srt->lLastTradeHandle) ) 
		return 1;
	return 0;	
}

/*
 * 打包交易记录（建议一个packet包最多20条交易记录）
 * 输入参数: 
 * 返回    : 打包条数,如果<0，代表打包不成功
 */
short wrapSMSRecord(unsigned char *inBuf, sttSysRunTime *pSrt)
{
	sttPacketHead pHead;
	void *p;
	unsigned char *buf;
	unsigned char tmpbuf[10];

	char flag;
	unsigned short wrapNum=0;
	
	unsigned char oldDb;
	unsigned long oldTo;
	unsigned long curDbCapacity, lTradeCounter;
	
	buf = inBuf + 8;
	
	if( getSysRunTime(pSrt) == 0 )
	{
		//有交易数据
		if( haveSendRecord(pSrt))  
		{
			oldDb = pSrt->cLastSendToDb;
			oldTo = pSrt->lLastSendTo;
			curDbCapacity = DB_capacity(pSrt->cLastSendToDb);			
			
			while(haveSendRecord(pSrt))
			{
				if( pSrt->lLastSendTo == curDbCapacity )
				{
					pSrt->lLastSendTo = 0;	
					if(pSrt->cLastSendToDb == TD_DB_INDEX3)
						pSrt->cLastSendToDb = TD_DB_INDEX1;
					else 
						pSrt->cLastSendToDb ++;
					curDbCapacity = DB_capacity(pSrt->cLastSendToDb);
				}
				p = DB_jump_to_record(pSrt->cLastSendToDb, pSrt->lLastSendTo, &flag);
				memcpy((void *)(buf+wrapNum*(sizeof(sttChargeRecord)-1)), p, sizeof(sttChargeRecord)-1);
				
				wrapNum ++;
				pSrt->lLastSendTo ++;				
				if(wrapNum == MAX_SEND_RECORD)
					break;
			}	
			if( wrapNum > 0)
			{
				pSrt->cLastSendFromDb = oldDb;
				pSrt->lLastSendFrom = oldTo;				
				memcpy(inBuf, "EKT", 3);
				inBuf[3] = wrapNum;
				memcpy(inBuf+4, gcPSAMNo, 4);		
//				memcpy(inBuf, "EKTEKT", 6);
//				inBuf[6] = wrapNum;
//				memcpy(inBuf+7, gcPSAMNo, 4);		
			}
		}		
	}	
	return wrapNum;
}