📄 dbproc.c.bak
字号:
#include <console.h>
#include <database.h>
#include "dbproc.h"
#define SYS_VERSION 1020
unsigned char cDateTimeBuf[10];
extern unsigned char gcPSAMNo[4];
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;
unsigned long lOldTradeCounter = 0;
int i;
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 )
{
getSysRunTime(&srt);
if(srt.sSysVersion == SYS_VERSION)
return 0;
if(abs(SYS_VERSION - srt.sSysVersion)<100)
lOldTradeCounter = srt.lTradeCounter;
}
}
clr_scr();
move_cursor(0,0);
puts("正在初始化数据库");
move_cursor(0,2);
puts("请稍等...");
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;
srt.cLastSendFromDb = TD_DB_INDEX1;
srt.lLastSendFrom = 0;
srt.cLastSendToDb = TD_DB_INDEX1;
srt.lLastSendTo = 0;
srt.lWorkerNo = 0;
memcpy(srt.cPassword, "12345678", 8);
getBCDDateTime(srt.cLastGatherDateTime);
getBCDDateTime(srt.cLastBLDateTime);
memcpy(srt.SMSCenterNo, "+8613800755500", 14);
memcpy(srt.CenterNo, "06800", 5);
srt.lTradeCounter = lOldTradeCounter;
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) );
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -