|
@@ -226,7 +226,7 @@ void HttpSocket::init()
|
|
static __int64 itimeto = 0;
|
|
static __int64 itimeto = 0;
|
|
static __int32 ipage = 0;
|
|
static __int32 ipage = 0;
|
|
|
|
|
|
- getsynctime(itimefrom, itimeto, ipage, bAllPageDone);
|
|
|
|
|
|
+ loaddbsynctime(itimefrom, itimeto, ipage, bAllPageDone);
|
|
while (true)
|
|
while (true)
|
|
{
|
|
{
|
|
static __int64 inowtime = funclib::gettimestamp();
|
|
static __int64 inowtime = funclib::gettimestamp();
|
|
@@ -386,7 +386,7 @@ void HttpSocket::getgamehistory(__int64 itimefrom, __int64 itimeto, __int32 ifir
|
|
if((ipage + 1) * ipagesize >= itotalsize)
|
|
if((ipage + 1) * ipagesize >= itotalsize)
|
|
bAllPageDone = true;
|
|
bAllPageDone = true;
|
|
|
|
|
|
- setsynctime(itimefrom, itimeto, ipage + 1, bAllPageDone);
|
|
|
|
|
|
+ setdbsynctime(itimefrom, itimeto, ipage + 1, bAllPageDone);
|
|
|
|
|
|
if(!bAllPageDone)
|
|
if(!bAllPageDone)
|
|
getgamehistory(itimefrom, itimeto, ipage + 1);
|
|
getgamehistory(itimefrom, itimeto, ipage + 1);
|
|
@@ -417,7 +417,7 @@ void HttpSocket::sendreelmsg(string stronly, string strtarget, string strjson, f
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
-void HttpSocket::getsynctime(__int64& itimefrom, __int64& itimeto, __int32& ipage, bool& bdone)
|
|
|
|
|
|
+void HttpSocket::loaddbsynctime(__int64& itimefrom, __int64& itimeto, __int32& ipage, bool& bdone)
|
|
{
|
|
{
|
|
itimefrom = 0;
|
|
itimefrom = 0;
|
|
itimeto = 0;
|
|
itimeto = 0;
|
|
@@ -434,7 +434,7 @@ void HttpSocket::getsynctime(__int64& itimefrom, __int64& itimeto, __int32& ipag
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
-void HttpSocket::setsynctime(__int64 itimefrom, __int64 itimeto, __int32 ipage, bool bdone)
|
|
|
|
|
|
+void HttpSocket::setdbsynctime(__int64 itimefrom, __int64 itimeto, __int32 ipage, bool bdone)
|
|
{
|
|
{
|
|
m_pthirddeveloper->find_one_and_update(make_document(kvp("id", 2)),
|
|
m_pthirddeveloper->find_one_and_update(make_document(kvp("id", 2)),
|
|
make_document(kvp("$set" , make_document(kvp("logtimefrom", itimefrom), kvp("logtimeto", itimeto), kvp("logpage", ipage), kvp("logdone", bdone)))));
|
|
make_document(kvp("$set" , make_document(kvp("logtimefrom", itimefrom), kvp("logtimeto", itimeto), kvp("logpage", ipage), kvp("logdone", bdone)))));
|