etc/clients
1
0
Fork 0
Code Issues Pull Requests Releases Activity

git-svn-id: svn://192.168.0.12/source@144 8346c931-da38-4b9b-9d4c-e48b93cbd075

Browse Source
This commit is contained in:
admin
2015-06-04 08:14:15 +00:00
parent bcbb37ed3c
commit 965948f978
1 changed files with 36 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
FilterProcess/sfilterprocess.cpp
View File

@@ -249,7 +249,7 @@ void SFilterProcess::run(QString _strFindID,QString _strFilterGroupName)
InsertLog(m_db.lastError().text());
return;
}
strQuery = QString("UPDATE company SET lastupdate = sysdate() WHERE num = ") + strCompany;
strQuery = QString("UPDATE dbinfo SET lastupdate = sysdate() WHERE company_num = ") + strCompany;
m_db.exec(strQuery.toUtf8());
m_db.close();
InsertLog("<Finish>");
@@ -1052,7 +1052,12 @@ void SFilterProcess::DataInfluenceCount(QString _strFilter,QString _strCompanyNu
strQuery = MakeInfluencerrankQuery(stIn,nCount,"replycount",strCompanyNum);
if(query.exec(strQuery.toUtf8()) == false) {InsertLog(query.lastError().text());return;}
}
m_db.close();
//
strQuery = "update dbinfo set "
"influencercount = " + QString::number(list.size()) + " "
"where company_num = " + strCompanyNum;
if(query.exec(strQuery.toUtf8()) == false) {InsertLog(query.lastError().text());return;}
m_db.close();
InsertLog("Influence Rank Count Send End");
}
}
@@ -1245,6 +1250,13 @@ void SFilterProcess::DataSpammersCount(QString _strFilter,QString _strCompanyNum
}
nCount++;
}
//influencercount
strQuery = "update dbinfo set "
"spammercount = " + QString::number(list.size()) + " "
"where company_num = " + strCompanyNum;
if(query.exec(strQuery.toUtf8()) == false) {InsertLog(query.lastError().text());return;}
m_db.close();
InsertLog("Spamer Rank Count Send End ");
}
@@ -1440,6 +1452,12 @@ void SFilterProcess::DataPowerCafeCount(QString _strFilter,QString _strCompanyNu
InsertLog(query.lastError().text());
return;}
}
//influencercount,spammercount
strQuery = "update dbinfo set "
"powercafecount = " + QString::number(listAll.size()) + " "
"where company_num = " + strCompanyNum;
if(query.exec(strQuery.toUtf8()) == false) {InsertLog(query.lastError().text());return;}
m_db.close();
InsertLog("Power Cafe Rank Send End");
}
@@ -1683,7 +1701,9 @@ void SFilterProcess::DataPut(QString _strCompanyNum)
}
}
int nReplyCount = 0;
int nReplyCount = 0,nBodyCount = 0;
QDateTime dtMin = QDateTime::currentDateTime().addYears(50);
QDateTime dtMax = QDateTime::currentDateTime().addYears(-50);
foreach(QString strUrl , m_strlistOrder )
{
int nReplyStart = nReplyCount;
@@ -1732,6 +1752,10 @@ void SFilterProcess::DataPut(QString _strCompanyNum)
else
query.bindValue(":VIEW",m_mapData[strUrl].m_strlist[m_anData[E_DATA_article_hit]]);
query.bindValue(":DATE",m_mapData[strUrl].m_strlist[m_anData[E_DATA_article_date]].trimmed());
QDateTime dtData = QDateTime::fromString(m_mapData[strUrl].m_strlist[m_anData[E_DATA_article_date]].trimmed(),"yyyy-MM-dd HH:mm:ss");
if (dtData < dtMin && dtData > QDateTime::currentDateTime().addYears(-20)) dtMin = dtData;
if (dtData > dtMax) dtMax = dtData;
if (m_mapData[strUrl].m_vecReply.size() == 0)
{
query.bindValue(":REPLY_STARTNUM",-1);
@@ -1751,6 +1775,7 @@ void SFilterProcess::DataPut(QString _strCompanyNum)
query.bindValue(":REALBYCATEGORYNUM",GetVectorToString(m_mapData[strUrl].m_vecCategory," ").trimmed());
if (query.exec()==false) {InsertLog(query.lastError().text());m_db.close();return;}
nBodyCount++;
}
query.prepare(strMapQuery);
@@ -1815,6 +1840,14 @@ void SFilterProcess::DataPut(QString _strCompanyNum)
RenameTable("id_" + _strCompanyNum,"id_" + _strCompanyNum + "_update","id_" + _strCompanyNum + "_temp");
RenameTable("nickname_" + _strCompanyNum,"nickname_" + _strCompanyNum + "_update","nickname_" + _strCompanyNum + "_temp");
RenameTable("community_" + _strCompanyNum,"community_" + _strCompanyNum + "_update","community_" + _strCompanyNum + "_temp");
//influencercount,spammercount,powercafecount,
strQuery = "update dbinfo set "
"bodycount = " + QString::number(nBodyCount) + " , "
"replycount = " + QString::number(nReplyCount)+" , "
"mindate = '" + dtMin.toString("yyyy-MM-dd HH:mm:ss") + "' , "
"maxdate = '" + dtMax.toString("yyyy-MM-dd HH:mm:ss") + "' "
"where company_num = " + _strCompanyNum;
if(query.exec(strQuery.toUtf8()) == false) {InsertLog(query.lastError().text());return;}
m_db.close();
InsertLog("Data Put End");
}