📄 dbproc.c.bak
字号:
#include <console.h>
#include <database.h>
#include "dbproc.h"
#define SYS_VERSION 1000
unsigned char cDateTimeBuf[10];
extern unsigned char gcSAMNo[8];
extern unsigned long glChargeMoney;
extern unsigned long glTradeCounter;
extern unsigned char gcChargeType;
/*
* 数字转换为压缩BCD码
* in:unsigned short value, unsigned short base
* base:10^N表示低N位
* return:
*/
unsigned char *toBCD(unsigned short value, unsigned short base)
{
unsigned char i=0;
value %= base;
base /= 10;
while( base > 0 )
{
cDateTimeBuf[i>>1] &= 0xF0; //低四位清零
while( value >= base )//用减法得到该位的值
{
value -= base;
cDateTimeBuf[i>>1] ++;
}
if( !(i&0x01) ) //如果i为偶数，压缩BCD码
cDateTimeBuf[i>>1] <<= 4;
i++;
base /= 10;
}
return cDateTimeBuf;
}
/*
* 得到日期时间的BCD码，格式为：yyyymmddhhmmss 占7个byte
*/
void getBCDDateTime(unsigned char *dt)
{
typ_RTC_time_rec t;
typ_RTC_date_rec d;
t.l_word = RTC_read_time();
d.l_word = RTC_read_date();
memcpy( (void *)(dt+0), (void *)toBCD(d.fields.year,10000), 2);
memcpy( (void *)(dt+2), (void *)toBCD(d.fields.month,100), 1);
memcpy( (void *)(dt+3), (void *)toBCD(d.fields.day,100), 1);
memcpy( (void *)(dt+4), (void *)toBCD(t.fields.hour,100), 1);
memcpy( (void *)(dt+5), (void *)toBCD(t.fields.minute,100), 1);
memcpy( (void *)(dt+6), (void *)toBCD(t.fields.second,100), 1);
}
/*
* 从BCD码日期时间字符窜得到日期
* in: const unsigned char *dt as format "yyyymmddhhmmss"
* return: date's long
*/
unsigned long getDateFromBCD(const unsigned char *dt)
{
typ_RTC_date_rec date;
date.fields.year = (dt[0]>>4)*1000 + (dt[0]&0x0f)*100 +
(dt[1]>>4)*10 + (dt[1]&0x0f);
date.fields.month = (dt[2]>>4)*10 + (dt[2]&0x0f);
date.fields.day = (dt[3]>>4)*10 + (dt[3]&0x0f);
return date.l_word;
}
/*
* 从BCD码日期时间字符窜得到时间
* in: const unsigned char *dt as format "yyyymmddhhmmss"
* return: time's long
*/
unsigned long getTimeFromBCD(const unsigned char *dt)
{
typ_RTC_time_rec time;
time.fields.hour = (dt[4]>>4)*10 + (dt[4]&0x0f);
time.fields.minute = (dt[5]>>4)*10 + (dt[5]&0x0f);
time.fields.second = (dt[6]>>4)*10 + (dt[5]&0x0f);
return time.l_word;
}
/*
* 异或校验
*/
unsigned char XOR_calc(unsigned char *buf, int len)
{
unsigned char result=0;
int i=0;
for(;i<len;i++)
{
result |= buf[i];
}
return result;
}
// CRC Caculator
// Parameters:
// pData: Data need to caculate CRC
// uLen: Data Length
// Return: CRC
// Download from http://www.mcu51.com/index.asp?page=2&typeid=2&txtitle=
//
unsigned int uCalCrc(unsigned char *pData, unsigned int uLen)
{
unsigned int crc;
unsigned char da;
unsigned int crc_ta[256]={ /* CRC余式表 */
0x0000, 0x1021, 0x2042, 0x3063, 0x4084, 0x50a5, 0x60c6, 0x70e7,
0x8108, 0x9129, 0xa14a, 0xb16b, 0xc18c, 0xd1ad, 0xe1ce, 0xf1ef,
0x1231, 0x0210, 0x3273, 0x2252, 0x52b5, 0x4294, 0x72f7, 0x62d6,
0x9339, 0x8318, 0xb37b, 0xa35a, 0xd3bd, 0xc39c, 0xf3ff, 0xe3de,
0x2462, 0x3443, 0x0420, 0x1401, 0x64e6, 0x74c7, 0x44a4, 0x5485,
0xa56a, 0xb54b, 0x8528, 0x9509, 0xe5ee, 0xf5cf, 0xc5ac, 0xd58d,
0x3653, 0x2672, 0x1611, 0x0630, 0x76d7, 0x66f6, 0x5695, 0x46b4,
0xb75b, 0xa77a, 0x9719, 0x8738, 0xf7df, 0xe7fe, 0xd79d, 0xc7bc,
0x48c4, 0x58e5, 0x6886, 0x78a7, 0x0840, 0x1861, 0x2802, 0x3823,
0xc9cc, 0xd9ed, 0xe98e, 0xf9af, 0x8948, 0x9969, 0xa90a, 0xb92b,
0x5af5, 0x4ad4, 0x7ab7, 0x6a96, 0x1a71, 0x0a50, 0x3a33, 0x2a12,
0xdbfd, 0xcbdc, 0xfbbf, 0xeb9e, 0x9b79, 0x8b58, 0xbb3b, 0xab1a,
0x6ca6, 0x7c87, 0x4ce4, 0x5cc5, 0x2c22, 0x3c03, 0x0c60, 0x1c41,
0xedae, 0xfd8f, 0xcdec, 0xddcd, 0xad2a, 0xbd0b, 0x8d68, 0x9d49,
0x7e97, 0x6eb6, 0x5ed5, 0x4ef4, 0x3e13, 0x2e32, 0x1e51, 0x0e70,
0xff9f, 0xefbe, 0xdfdd, 0xcffc, 0xbf1b, 0xaf3a, 0x9f59, 0x8f78,
0x9188, 0x81a9, 0xb1ca, 0xa1eb, 0xd10c, 0xc12d, 0xf14e, 0xe16f,
0x1080, 0x00a1, 0x30c2, 0x20e3, 0x5004, 0x4025, 0x7046, 0x6067,
0x83b9, 0x9398, 0xa3fb, 0xb3da, 0xc33d, 0xd31c, 0xe37f, 0xf35e,
0x02b1, 0x1290, 0x22f3, 0x32d2, 0x4235, 0x5214, 0x6277, 0x7256,
0xb5ea, 0xa5cb, 0x95a8, 0x8589, 0xf56e, 0xe54f, 0xd52c, 0xc50d,
0x34e2, 0x24c3, 0x14a0, 0x0481, 0x7466, 0x6447, 0x5424, 0x4405,
0xa7db, 0xb7fa, 0x8799, 0x97b8, 0xe75f, 0xf77e, 0xc71d, 0xd73c,
0x26d3, 0x36f2, 0x0691, 0x16b0, 0x6657, 0x7676, 0x4615, 0x5634,
0xd94c, 0xc96d, 0xf90e, 0xe92f, 0x99c8, 0x89e9, 0xb98a, 0xa9ab,
0x5844, 0x4865, 0x7806, 0x6827, 0x18c0, 0x08e1, 0x3882, 0x28a3,
0xcb7d, 0xdb5c, 0xeb3f, 0xfb1e, 0x8bf9, 0x9bd8, 0xabbb, 0xbb9a,
0x4a75, 0x5a54, 0x6a37, 0x7a16, 0x0af1, 0x1ad0, 0x2ab3, 0x3a92,
0xfd2e, 0xed0f, 0xdd6c, 0xcd4d, 0xbdaa, 0xad8b, 0x9de8, 0x8dc9,
0x7c26, 0x6c07, 0x5c64, 0x4c45, 0x3ca2, 0x2c83, 0x1ce0, 0x0cc1,
0xef1f, 0xff3e, 0xcf5d, 0xdf7c, 0xaf9b, 0xbfba, 0x8fd9, 0x9ff8,
0x6e17, 0x7e36, 0x4e55, 0x5e74, 0x2e93, 0x3eb2, 0x0ed1, 0x1ef0
};
crc=0;
while(uLen--!=0) {
da=(unsigned char) (crc/256); /* 以8位二进制数的形式暂存CRC的高8位 */
crc<<=8; /* 左移8位，相当于CRC的低8位乘以 */
crc^=crc_ta[da^*pData]; /* 高8位和当前字节相加后再查表求CRC ，再加上以前的CRC */
pData++;
}
return(crc);
}
/*
* 初始化数据库，在剩余的flash空间中创建编号为1，10，100的三块空间
* 分别用来存放系统状态信息、黑名单（要求>5000条）、交易记录（要求>5000条）
* （这里每块flash是64kBytes），对于1M的FLASH，要求手持机程序代码<256k
* return: 0 successed
* other fail
*/
short initDb()
{
sttSysRunTime srt;
get_db_sys_param(&dsp);
/* if(dsp.blocks < 9) //不够最小size (9*64K)
return 1;
if( (file_sys_cnt = DB_check_db(filesys)) == 5 )
{
if( filesys[0].db_id == 1 && filesys[0].block_cnt == 0 &&
filesys[1].db_id == 10 && filesys[1].block_cnt == 1 &&
filesys[2].db_id == 100 && filesys[2].block_cnt == 1 &&
filesys[3].db_id == 1000 && filesys[3].block_cnt == 1 &&
filesys[4].db_id == 10000 && filesys[4].block_cnt == 1 )
return 0;
}
*/
erase_db_sys();
DB_format_db(1, 1, 200); //系统状态信息数据库，占64K，每个200个byte
DB_format_db(10, 2, 8); //黑名单数据库，占128K，每个黑名单8个byte
DB_format_db(100, 2, sizeof(sttChargeRecord) ); //交易记录数据库1，占128K，每条交易纪录40个byte
DB_format_db(1000, 2, sizeof(sttChargeRecord) ); //交易记录数据库2，占128K，每条交易纪录40个byte
DB_format_db(10000, 2, sizeof(sttChargeRecord) ); //交易记录数据库3，占128K，每条交易纪录40个byte
file_sys_cnt = DB_check_db(filesys);
memset( (void *)&srt, 0, sizeof(srt) );
srt.sSysVersion = SYS_VERSION; //版本号
srt.cLastTradeHandleDb = TD_DB_INDEX1;
srt.lLastTradeHandle = 0;
srt.cLastGatherFromDb = TD_DB_INDEX1;
srt.lLastGatherFrom = 0;
srt.cLastGatherToDb = TD_DB_INDEX1;
srt.lLastGatherTo = 0;
getBCDDateTime(srt.cLastGatherDateTime);
getBCDDateTime(srt.cLastBLDateTime);
srt.lTradeCounter = 0;
DB_add_record(RT_DB_INDEX, (void *)&srt);
return 0;
}
/*
* 得到系统运行时参数
* out: sttSysRunTime *srt
* return: 0 successed
* other fail
*/
short getSysRunTime(sttSysRunTime *srt)
{
char flag;
void *p;
memset( (void *)srt, 0, sizeof(sttSysRunTime) );
p = DB_jump_to_record(RT_DB_INDEX, DB_count_records(RT_DB_INDEX) - 1, &flag);
if (p)
{
memcpy( (void *)srt, p, sizeof(sttSysRunTime) );
return 0;
}
return 1;
}
/*
* 更新系统运行时参数
* in: sttSysRunTime *srt
* return: 0 successed
* other fail
*/
short updateSysRunTime(sttSysRunTime *srt)
{
if (DB_add_record(RT_DB_INDEX, (void *)srt) == 0)
{
if( DB_erase_filesys(RT_DB_INDEX) != 0 )
return 1;
DB_add_record(RT_DB_INDEX, (void *)srt);
}
return 0;
}
/*
* 更新黑名单
* 输入参数: 从服务器下来的黑名单数据包
* 返回 : 0 成功
* -1 失败
*/
short updateBlackList(unsigned char * blPacket)
{
sttBlackListHead blHead;
sttSysRunTime srt;
unsigned char *p;
short count=0;
unsigned short serialNo;
unsigned long blackNum;
if( getSysRunTime(&srt) == 0 )
{
memcpy( (void *)&blHead, (void *)blPacket, sizeof(blHead) );
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, lTradeCounter;
buf = inBuf + sizeof(sttPacketHead);
if( getSysRunTime(pSrt) == 0 )
{
//有交易数据
if( haveTradeRecord(pSrt) )
{
oldDb = pSrt->cLastGatherToDb;
oldTo = pSrt->lLastGatherTo;
curDbCapacity = DB_capacity(pSrt->cLastGatherToDb);
lTradeCounter = pSrt->lTradeCounter;
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);
memcpy((void *)(buf+wrapNum*sizeof(sttChargeRecord)), p, sizeof(sttChargeRecord));
if(((*((char*)p+33)&0xf0)==0x10)||((*((char*)p+33)&0xf0)==0x20))
lTradeCounter ++;
wrapNum ++;
if(wrapNum == 20)
break;
pSrt->lLastGatherTo ++;
}
if( wrapNum > 0)
{
pSrt->cLastGatherFromDb = oldDb;
pSrt->lLastGatherFrom = oldTo;
getBCDDateTime((unsigned char *)pSrt->cLastGatherDateTime);
}
else
{
glTradeCounter = 0;
if(!ReadRecord(0x15, 1, 4, tmpbuf)) return 1;
OverTurnString(&glTradeCounter, tmpbuf, 4);
lTradeCounter = glTradeCounter;
}
}
memcpy((void *)pHead.cBuildDateTime,(void *)pSrt->cLastGatherDateTime,7);
memcpy((void *)pHead.cSAMNo,gcSAMNo,8);//SAM卡卡号，应该是全局的
pHead.cSerial[0] = serialNo >> 8;//
pHead.cSerial[1] = serialNo & 0x00FF;
pHead.cTradeSerialNo[0] = (pSrt->lTradeCounter >> 24)&0x000000FF;
pHead.cTradeSerialNo[1] = (pSrt->lTradeCounter >> 16)&0x000000FF;
pHead.cTradeSerialNo[2] = (pSrt->lTradeCounter >> 8 )&0x000000FF;
pHead.cTradeSerialNo[3] = (pSrt->lTradeCounter )&0x000000FF;
pHead.cRecordNumber[0] = wrapNum >> 8;
pHead.cRecordNumber[1] = wrapNum & 0x00FF;
pHead.cBcc = XOR_calc( (unsigned char *)&pHead, sizeof(pHead)-1 );
pSrt->lTradeCounter = lTradeCounter;
memcpy( (void *)inBuf,(void *)&pHead, sizeof(pHead) ); //加上包头
}
return wrapNum;
}
/*
* 在交易记录数据库中加入一条交易记录
* 输入参数: 交易记录
* 返回 : 0 成功
* other 失败
*/
short appendTradeRecord(sttChargeRecord *cr)
{
sttSysRunTime srt;
unsigned char tmpbuf[10];
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;
}
// srt.iTradeTimes ++;
// srt.lTradeMoney += glChargeMoney;
glTradeCounter = 0;
if(!ReadRecord(0x15, 1, 4, tmpbuf)) return 5;
OverTurnString(&glTradeCounter, tmpbuf, 4);
if(srt.lTradeCounter==0)
{
srt.lTradeCounter = glTradeCounter;
}
if(((gcChargeType&0xf0)==0x10)||((gcChargeType&0xf0)==0x20))
{
glTradeCounter ++;
OverTurnString(tmpbuf, &glTradeCounter, 4);
if(!AppendRecord(0x15, 4, tmpbuf))
return 5;
}
// move_cursor(0,0);
// printf("%ld %ld", srt.lTradeCounter, glTradeCounter);
if (updateSysRunTime(&srt) != 0) //update sysruntime param
return 4;
return 0;
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -