dtu/Core/Src/database.c

#include "database.h"
#include "usart.h"
#include "tt808.h"

uint16_t PDA_pushArr[1024];

extern TipsFlag tipsflag;	
extern Menu_table menu;	


DatabaseLoc dbloc;
DatabaseEvent dbeve;
DatabaseLoc *dblocptr = &dbloc;
DatabaseEvent *dbeveptr = &dbeve;

bool MiddleObj =false;

/**
  * @breaf 数据库初始化
  * @Explanation 向各头部写入关键信息
  */
void Database_init(uint16_t pushsize_loc, uint16_t pullsize_loc,uint16_t pushsize_eve, uint16_t pullsize_eve)
{
	Flash_ReadBytes((uint16_t*)&(dblocptr->temppush.loc_pushIndex),LocDbHeadStart,4);//读取loc头部是否发生写入
	if(dblocptr->temppush.loc_pullIndex == 0xFFFF && dblocptr->temppush.loc_pushIndex==0xFFFF)//未写入
	{
		dblocptr->headinfo.loc_pushIndex = 0;
		dblocptr->headinfo.loc_pullIndex = 0;
		dblocptr->headinfo.loc_pushSize = pushsize_loc;
		dblocptr->headinfo.loc_pullSize = pullsize_loc;
		Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);
	}
	else
	{
		//*高地址字节在前
		dblocptr->headinfo.loc_pushIndex = dblocptr->temppush.loc_pushIndex;
		dblocptr->headinfo.loc_pullIndex = dblocptr->temppush.loc_pushIndex;
		dblocptr->headinfo.loc_pushSize =  dblocptr->temppush.loc_pushSize;
		dblocptr->headinfo.loc_pullSize =  dblocptr->temppush.loc_pullSize;
	}

	
	
	
	Flash_ReadBytes((uint16_t*)&(dbeveptr->temppush),EveDbHeadStart,4);//读取loc头部是否发生写入
	if(dbeveptr->temppush.eve_pushIndex == 0xFFFF && dbeveptr->temppush.eve_pullIndex ==0xFFFF)//未写入
	{
		dbeveptr->headinfo.eve_pushIndex = 0;
		dbeveptr->headinfo.eve_pullIndex = 0;
		dbeveptr->headinfo.eve_pushSize = pushsize_loc;
		dbeveptr->headinfo.eve_pullSize = pullsize_loc;
		Flash_WriteBytes((uint16_t*)&(dbeveptr->headinfo),EveDbHeadStart,4);
	}
	else
	{
		//*高地址字节在前
		dbeveptr->headinfo.eve_pushIndex = dbeveptr->temppush.eve_pushIndex;
		dbeveptr->headinfo.eve_pullIndex = dbeveptr->temppush.eve_pullIndex;
		dbeveptr->headinfo.eve_pushSize =  dbeveptr->temppush.eve_pushSize;
		dbeveptr->headinfo.eve_pullSize =  dbeveptr->temppush.eve_pullSize;
	}

}

HAL_StatusTypeDef PushSta;
//***************定位信息入库
void Database_Push(uint8_t object)
{
	if(object==0)//位置信息写入
	{
		if(dblocptr->headinfo.loc_pushIndex!=0)
		{
			if(dblocptr->temppush.latitude != dblocptr->location.latitude && dblocptr->temppush.longitude != dblocptr->location.longitude)//相同纬度参数(包含未获取定位为0)
			{
				Flash_WriteBytes((uint16_t*)&(dblocptr->location.alarmFlag),LocDbBodyStart + (dblocptr->headinfo.loc_pushIndex*34),17);
				Flash_ReadBytes((uint16_t*)&(dblocptr->temppush.alarmFlag),LocDbBodyStart + ((dblocptr->headinfo.loc_pushIndex-1)*34),17);//读取body信息
				printf("入库操作,当前索引%d\r\n",dblocptr->headinfo.loc_pushIndex);
				TestPrintStruct(dblocptr,1);//读取Temp
				dblocptr->headinfo.loc_pushIndex+=1;
				Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
			}

		}

		else if(dblocptr->location.latitude!=0 && dblocptr->headinfo.loc_pushIndex==0)//判断定位是否正常工作
		{		
			Flash_WriteBytes((uint16_t*)&(dblocptr->location.alarmFlag),LocDbBodyStart,17);//34
			dblocptr->headinfo.loc_pushIndex+=1;
			Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
		}
	}

						
	TestPrintStruct(dblocptr,0);//读取Work
	Flash_ReadBytes((uint16_t*)&(dblocptr->temppush.loc_pushIndex),LocDbHeadStart,4);//读取loc头部写入信息
	if(dblocptr->temppush.loc_pushIndex == dblocptr->headinfo.loc_pushSize)//入库结束(返回
	{
		printf("入库操作,当前索引%d,达边界值返回覆写\r\n",dblocptr->headinfo.loc_pushIndex);
		dblocptr->headinfo.loc_pushIndex=0;
		Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
	}
	
}

void Database_Pull(uint8_t object)
{
	if(object==0)//位置信息出库
	{
		Flash_ReadBytes((uint16_t*)&(dblocptr->headinfo.loc_pushIndex),LocDbHeadStart,4);//读取loc头部写入信息
		printf("出库操作,共出库%d当前索引%d\r\n",dblocptr->headinfo.loc_pushIndex,dblocptr->headinfo.loc_pushIndex);
		
		if(dblocptr->headinfo.loc_pushIndex!=0 || dblocptr->temppull.alarmFlag!=0xFFFFFFFF)//库内有数据
		{
			Flash_ReadBytes((uint16_t*)&(dblocptr->temppull.alarmFlag),LocDbBodyStart,17);//读取出库body信息
			dblocptr->headinfo.loc_pullIndex+=1;
			Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
			Retrans = true;
		}
		if(dblocptr->temppull.alarmFlag==0xFFFFFFFF)
		{
			dblocptr->headinfo.loc_pullIndex=0;
			dblocptr->headinfo.loc_pushIndex=0;
			Flash_WriteBytes((uint16_t*)&(dblocptr->headinfo),LocDbHeadStart,4);//更新刻度
			Retrans = false;
		}
		MiddleObj = true;
	}
}



void TestPrintStruct(DatabaseLoc *ptr,uint8_t temppush)
{
	if(temppush)
	{
		printf("temp:%08X%08X%08X%08X%04X%04X%04X%d%d%d%d%d%d%02X%02X%02X%02X%02X%02X\r\n", \
		ptr->temppush.alarmFlag, \
		ptr->temppush.statusFlag, \
		ptr->temppush.latitude, \
		ptr->temppush.longitude, \
		ptr->temppush.height, \
		ptr->temppush.speed, \
		ptr->temppush.direction, \
		ptr->temppush.timeBCD[0], \
		ptr->temppush.timeBCD[1], \
		ptr->temppush.timeBCD[2], \
		ptr->temppush.timeBCD[3], \
		ptr->temppush.timeBCD[4], \
		ptr->temppush.timeBCD[5], \
		ptr->temppush.signalCmd, \
		ptr->temppush.signalCmd_len, \
		ptr->temppush.CSQ, \
		ptr->temppush.atellitesCmd, \
		ptr->temppush.atellitesCmd_len, \
		ptr->temppush.satellitesNum);
	}
	else
	{
		printf("now :%08X%08X%08X%08X%04X%04X%04X%d%d%d%d%d%d%02X%02X%02X%02X%02X%02X\r\n", \
		ptr->location.alarmFlag, \
		ptr->location.statusFlag, \
		ptr->location.latitude, \
		ptr->location.longitude, \
		ptr->location.height, \
		ptr->location.speed, \
		ptr->location.direction, \
		ptr->location.timeBCD[0], \
		ptr->location.timeBCD[1], \
		ptr->location.timeBCD[2], \
		ptr->location.timeBCD[3], \
		ptr->location.timeBCD[4], \
		ptr->location.timeBCD[5], \
		ptr->location.signalCmd, \
		ptr->location.signalCmd_len, \
		ptr->location.CSQ, \
		ptr->location.atellitesCmd, \
		ptr->location.atellitesCmd_len, \
		ptr->location.satellitesNum);
	}
}