From 965948f9781ebc33239748fc175f635e33d5edb8 Mon Sep 17 00:00:00 2001
From: admin <admin@8346c931-da38-4b9b-9d4c-e48b93cbd075>
Date: Thu, 4 Jun 2015 08:14:15 +0000
Subject: [PATCH] git-svn-id: svn://192.168.0.12/source@144
 8346c931-da38-4b9b-9d4c-e48b93cbd075

---
 FilterProcess/sfilterprocess.cpp | 39 +++++++++++++++++++++++++++++---
 1 file changed, 36 insertions(+), 3 deletions(-)

diff --git a/FilterProcess/sfilterprocess.cpp b/FilterProcess/sfilterprocess.cpp
index e4b71b0..131998c 100644
--- a/FilterProcess/sfilterprocess.cpp
+++ b/FilterProcess/sfilterprocess.cpp
@@ -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");
 }