?? dbsvr.cpp
字號:
}
//4.發送操作結果flag:int + ret:int+sizeofrecord:int + record0+ record1
*(int *)sendbuf=PMDB_UDPHEADID;
*((int *)sendbuf +1)=nret;
if(pRetResultStruct !=NULL)
{
*((int *)sendbuf +2)=pRetResultStruct->nSize;
}else
*((int *)sendbuf +2)=0;
nsend=send(*(SOCKET*)msg.wParam,sendbuf,sizeof(int)*3,0);
if(nsend == SOCKET_ERROR)
{
// writebuginfo(L"DbSvr err 104\r\n");
goto DBACTION_ERR;
}
pCur=pRetResultStruct;
npacket=0;
while(pCur !=NULL)
{
pNext=pCur->pNext;
nsend=send(*(SOCKET*)msg.wParam,(char *)pCur->pBuf,pCur->nSize,0);
if(nsend == SOCKET_ERROR)
{
FreeResult(&pRetResultStruct);
swprintf(cwTemp,L"Send packet %d,Err=%d",npacket,WSAGetLastError());
// writebuginfo(cwTemp);
goto DBACTION_ERR;
}
pCur=pNext;npacket++;
if(npacket%100 ==0)
Sleep(20);
}
FreeResult(&pRetResultStruct);
closesocket(*(SOCKET*)msg.wParam);
delete (SOCKET*)msg.wParam;
break;
DBACTION_ERR:
// ASSERT(0);
closesocket(*(SOCKET*)msg.wParam);
delete (SOCKET*)msg.wParam;
break;
}
break;
default:
break;
}
}
return 0;
}
bool WaitForDataRecv(SOCKET skClient, int nSec)
{
int nRet;
fd_set RSet,WSet;
struct timeval tv;
tv.tv_sec = nSec;
tv.tv_usec = 0;
FD_ZERO(&RSet);
FD_SET(skClient, &RSet);
FD_ZERO(&WSet);
FD_SET(skClient, &WSet);
nRet=select(skClient,&RSet,NULL, NULL, &tv);
// nRet=select(skClient,&RSet,&WSet, NULL, &tv);
if( nRet== 0)
{//timeout
return false;
}else if( nRet ==SOCKET_ERROR)
{
int nErr=WSAGetLastError();
// WCHAR cwTemp[100];
// swprintf(cwTemp,L" nErr=%d \r\n",nErr);
if(nErr ==WSAEINTR)
{
// swprintf(cwTemp,L"socket has closed! \r\n");
}
// writebuginfo(cwTemp);
return false;
}else
return true;
}
bool IsSocketClose(SOCKET skClient)
{
WSAEVENT hEvent;
hEvent=WSACreateEvent();
if(hEvent ==NULL)
return true;
int nRet=WSAEventSelect(skClient,hEvent,FD_CLOSE);
if(nRet ==SOCKET_ERROR)
{
WSACloseEvent(hEvent);
return true;
}
if( WaitForSingleObject(hEvent,0)==WAIT_OBJECT_0)
{//已經關閉
WSACloseEvent(hEvent);
return true;
}
WSACloseEvent(hEvent);
return FALSE;
}
UINT DbSocketServerThread( LPVOID pParam )
{
SOCKET socket1=*(SOCKET *)pParam;
while (bSockeRun)
{
SOCKET skClient = accept(socket1,NULL, NULL);
if(skClient ==INVALID_SOCKET )
{
MessageBox(NULL,L"Accept Failure！",L"DbSvr!",MB_OK);
break;
}
SOCKET *pSocket=new SOCKET;
*pSocket=skClient;
// MessageBox(NULL,L"Accept Ok！",L"post thread message!",MB_OK);
PostThreadMessage(pThreadDb->m_nThreadID,MSG_DBACTION,((WPARAM )pSocket),0);
// Sleep(500);
}
// writebuginfo(L"exit socket thread\r\n");
return 0;
}
void CALLBACK TimerFunDay( HWND hwnd, UINT uMsg, UINT idEvent, DWORD dwTime )
{
//同步處理
// writebuginfo(L"enter database record delete");
writebuginfo("file:%s,line:%d*****database record delete\r\n",__FILE__,__LINE__);
//數據維護計劃
CTime tm=CTime::GetCurrentTime();
CTime tm1y,tm6m,tm3m,tm1m;
tm1y=CTime(tm.GetYear()-1,tm.GetMonth(),1,0,0,0);
if(tm.GetMonth()>6)
tm6m=CTime(tm.GetYear(),tm.GetMonth()-6,1,0,0,0);
else
tm6m=CTime(tm.GetYear()-1,tm.GetMonth()+6,1,0,0,0);
if(tm.GetMonth()>3)
tm3m=CTime(tm.GetYear(),tm.GetMonth()-3,1,0,0,0);
else
tm3m=CTime(tm.GetYear()-1,tm.GetMonth()+9,1,0,0,0);
if(tm.GetMonth()>1)
tm1m=CTime(tm.GetYear(),tm.GetMonth()-1,1,0,0,0);
else
tm1m=CTime(tm.GetYear()-1,tm.GetMonth()+11,1,0,0,0);
time_t t1y,t6m,t3m,t1m;
t1y=tm1y.GetTime();
t6m=tm6m.GetTime();
t3m=tm3m.GetTime();
t1m=tm1m.GetTime();
KillTimer(NULL,g_TimerFunDayID);
g_TimerFunDayID=SetTimer(NULL,101,24*60*60*1000,TimerFunDay);
static WCHAR SqlIst[10][150];
int index=0;
//1 進出記錄 3mon
swprintf(SqlIst[index++],L"Delete from PassRecord where Time<%d",t3m);
//3 報警通知記錄 3mon
swprintf(SqlIst[index++],L"Delete from AlarmNotifyHisTable where AlarmSpingID in (select Idx from AlarmSpringTable where Time<%d )",t3m);
//2 報警記錄 3mon
swprintf(SqlIst[index++],L"Delete from AlarmSpringTable where Time<%d",t3m);
//4 開支明細 1year
// OutgoingRecordTable
swprintf(SqlIst[index++],L"Delete from OutgoingRecordTable where RecordTime<%d",t1y);
//5 備忘錄 6mon
swprintf(SqlIst[index++],L"Delete from TicklerTable where Time<%d",t6m);
//6 可視對講記錄 記錄保存1mon，圖片本地保存10次，其余保存在服務器
swprintf(SqlIst[index++],L"Delete from InterPhoneRecordTable where Time<%d",t1m);
//7 可視電話記錄 記錄保存1mon，圖片本地保存10次，其余保存在服務器
swprintf(SqlIst[index++],L"Delete from TelVideoRecordTable where Time<%d",t1m);
//8 語音留言 記錄保存3mon，圖片本地保存10次，其余保存在服務器
swprintf(SqlIst[index++],L"Delete from VoiceMsgTable where Time<%d",t3m);
//9 短信 保存1mon
swprintf(SqlIst[index++],L"Delete from ShortMsgTable where Time<%d",t1m);
::EnterCriticalSection(&g_DbCritialSection);
if(!g_DataBase.OpenData())
{
// writebuginfo(L"can‘t open database");
writebuginfo("file:%s,line:%d,can‘t open database\r\n",__FILE__,__LINE__);
::LeaveCriticalSection(&g_DbCritialSection);
return ;
}
NodeSql *pFirst,*pNode=NULL,*pNext=NULL;
for(int i=0;i<9;i++)
{
pNext=new NodeSql;
memset(pNext,0,sizeof(NodeSql));
pNext->pSql = SqlIst[i];
if(pNode==NULL)
{
pNode=pNext;
pFirst=pNext;
}else
{
pNode->pNext=pNext;
pNode=pNext;
}
}
BOOL bDel=g_DataBase.ExecuteSql(pFirst);
if(bDel)
{
// writebuginfo(L"OK! database record delete");
}else
{
// writebuginfo(L"failure! database record delete");
}
//刪除
while(pFirst)
{
pNode=pFirst;
pFirst=pFirst->pNext;
delete pNode;
}
g_DataBase.CloseData();
::LeaveCriticalSection(&g_DbCritialSection);
// writebuginfo(L"exit database record delete");
writebuginfo("file:%s,line:%d*****exit database record delete=%d\r\n",__FILE__,__LINE__,bDel);
}
/*
功能：定時器函數，執行數據庫文件的本地備份
參數：標準，略
返回：無
編寫人：呂黃梁
時間：2005-06-16
*/
void CALLBACK TimerFunBackUp( HWND hwnd, UINT uMsg, UINT idEvent, DWORD dwTime )
{
// DWORD t1,t2;
// t1=::GetTickCount();
// writebuginfo(L"enter database Backup");
writebuginfo("file:%s,line:%d,enter database Backup\r\n",__FILE__,__LINE__);
::EnterCriticalSection(&g_DbCritialSection);
// writebuginfo(L"begin database Backup");
g_DataBase.CloseData();
// writebuginfo(L"begin database Backup01");
if(!g_DataBase.OpenData())//保證備份前數據庫是好的
{
writebuginfo("file:%s,line:%derror database Backup\r\n",__FILE__,__LINE__);
// writebuginfo(L"");
::LeaveCriticalSection(&g_DbCritialSection);
return ;
}
// writebuginfo(L"begin database Backup01");
g_DataBase.CloseData();
// writebuginfo(L"begin database copying");
CopyFile(DATABASE_PMDB,DATABASE_PMDB_BACKUP,FALSE);
// t2=::GetTickCount();
// WCHAR cwTemp[100];
// swprintf(cwTemp,L"tm=%d s",(t2-t1)/1000);
// writebuginfo(cwTemp);
::LeaveCriticalSection(&g_DbCritialSection);
// writebuginfo(L"exit database Backup");
writebuginfo("file:%s,line:%d,database Backup ok\r\n",__FILE__,__LINE__);
}
/*
功能：數據庫文件的本地恢復
參數：無
返回：
0 －成功
－1 －失敗
編寫人：呂黃梁
時間：2005-06-16
*/
int DbRecove()
{
writebuginfo("enter database recove\n");
int nret=0;
CDataBase db;
::EnterCriticalSection(&g_DbCritialSection);
g_DataBase.CloseData();
if(!db.OpenData(DATABASE_PMDB_BACKUP))
{
writebuginfo("can't open the backup database \n");
::LeaveCriticalSection(&g_DbCritialSection);
return -1;
}
db.CloseData();
if(CopyFile(DATABASE_PMDB_BACKUP,DATABASE_PMDB,FALSE))
{
writebuginfo("exit database recove success\n");
nret= 0;
}
else
{
nret= -1;
writebuginfo("exit database recove failure，errid=%d\n",GetLastError());
}
::LeaveCriticalSection(&g_DbCritialSection);
return nret;
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -