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

버그 수정

Browse Source 
git-svn-id: svn://192.168.0.12/source@82 8346c931-da38-4b9b-9d4c-e48b93cbd075
This commit is contained in:
admin
2015-04-24 05:53:34 +00:00
parent 67bcea8c27
commit 2a31575a00
5 changed files with 2 additions and 184 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
Filter/sgetthread.cpp
View File

@@ -1,58 +0,0 @@
#include "sgetthread.h"
#include <QObject>
#include <QSqlDatabase>
#include <QSqlQuery>
#include <QSqlError>
#include <QDebug>
SGetThread::SGetThread()
{
}
SGetThread::~SGetThread()
{
}
void SGetThread::run()
{
QString strSelect;
strSelect = "select ";
strSelect += "CONVERT(body_articleid USING utf8),";
strSelect += "CONVERT(body_nickname USING utf8),";
strSelect += "CONVERT(body_date USING utf8),";
strSelect += "CONVERT(body_articletitle USING utf8),";
strSelect += "CONVERT(body_data USING utf8),";
strSelect += "CONVERT(body_platformid USING utf8),";
strSelect += "CONVERT(body_platformtitle USING utf8),";
strSelect += "CONVERT(url USING utf8),";
strSelect += "CONVERT(reply_nickname USING utf8),";
strSelect += "CONVERT(reply_parent USING utf8),";
strSelect += "CONVERT(reply_date USING utf8),";
strSelect += "CONVERT(reply_data USING utf8),";
strSelect += "CONVERT(reply_urlreply USING utf8),";
strSelect += "CONVERT(keyword_id USING utf8),";
strSelect += "CONVERT(platformname USING utf8),";
strSelect += "CONVERT(platformform USING utf8),";
strSelect += "CONVERT(articleform USING utf8),";
strSelect += "CONVERT(reply_rownum USING utf8)";
strSelect += " from ";
strSelect += m_strTable;
strSelect += " Order by body_date";
QSqlQuery query(strSelect);
while(query.next())
{
QStringList strList;
for(int i = 0; i < 18; i++)
strList << query.value(i).toString();
m_pData->append(strList);
}
}
void SGetThread::SetData(QString _strTable,QVector <QStringList> *_pData)
{
m_strTable = _strTable;
m_pData = _pData;
}

18
Filter/sgetthread.h
View File

@@ -1,18 +0,0 @@
#ifndef SGETTHREAD_H
#define SGETTHREAD_H
#include <QThread>
class SGetThread : public QThread
{
public:
SGetThread();
~SGetThread();
void SetData(QString _strTable,QVector <QStringList> *_pData);
private:
QVector <QStringList> *m_pData;
QString m_strTable;
protected:
void run();
};
#endif // SGETTHREAD_H

82
Filter/sputthread.cpp
View File

@@ -1,82 +0,0 @@
#include "sputthread.h"
#include <QObject>
#include <QSqlQuery>
#include <QSqlError>
#include <QDebug>
#include <QFile>
SPutThread::SPutThread()
{
}
SPutThread::~SPutThread()
{
}
void SPutThread::SetData(QString _strTable,QVector<QStringList> *_pData,int _nStart,int _nEnd)
{
m_nStart = _nStart;
m_nEnd = _nEnd;
m_strTable = _strTable;
m_pData = _pData;
}
QString SPutThread::SqlString(QString _str)
{
_str.replace("\\","\\\\");
_str.replace("'","");
_str.replace(",","\\,");
return _str;
}
void SPutThread::Debug(QString _strFilename,QString _strData)
{
QFile file(_strFilename);
if (!file.open(QIODevice::WriteOnly | QIODevice::Text | QIODevice::Append))
return;
QTextStream out(&file);
out << _strData;
file.close();
}
void SPutThread::run()
{
QString strInsert = "insert into " + m_strTable + " ( company_name , category_name , platform_name , platform_form , platform_title ,"
"article_num , article_rownum , article_form , article_title , article_url , article_id , article_nickname , "
"article_date , article_body , article_reply ) value (";
for (int i = m_nStart ; i < m_nEnd ; i++)
{
QString query = strInsert;
query += "'',"; //company_name
query += "'',"; //category_name
query += "'" + m_pData->at(i).at(14) + "',"; //platform_name
query += "'" + m_pData->at(i).at(15) + "',"; //platform_form
query += "'" + SqlString(m_pData->at(i).at(6)) + "',"; //platform_title
query += "'0',"; //article_num
query += "'" + m_pData->at(i).at(17) + "',"; //article_rownum
query += "'" + m_pData->at(i).at(16) + "',"; //article_type
query += "'" + SqlString(m_pData->at(i).at(3)) + "',"; //article_title
query += "'" + m_pData->at(i).at(7) + "',"; //article_url
query += "'" + m_pData->at(i).at(0) + "',"; //article_id
QString str = m_pData->at(i).at(1);
str.replace("var isInitial","");
str.replace(";","");
query += "'" + SqlString(str.trimmed()) + "',"; //article_nickname
if (m_pData->at(i).at(16) == "reply")
query += "'" + m_pData->at(i).at(10) + "',"; //article_date
else
query += "'" + m_pData->at(i).at(2) + "',"; //article_date
query += "'" + SqlString(m_pData->at(i).at(4)) + "',"; //article_body
query += "'" + SqlString(m_pData->at(i).at(11)) + "')"; //article_reply
QSqlQuery sql;
if (sql.exec(query.toUtf8())==false)
{
Debug("error.txt",query);
Debug("error.txt",sql.lastError().text());
}
}
}

24
Filter/sputthread.h
View File

@@ -1,24 +0,0 @@
#ifndef SPUTTHREAD_H
#define SPUTTHREAD_H
#include <QObject>
#include <QThread>
class SPutThread : public QThread
{
Q_OBJECT
public:
SPutThread();
~SPutThread();
void SetData(QString _strTable,QVector <QStringList> *_pData,int _nStart,int _nEnd);
QString SqlString(QString _str);
void Debug(QString _strFilename,QString _strData);
private:
QVector<QStringList>*m_pData;
QString m_strTable;
int m_nStart,m_nEnd;
protected:
void run();
};
#endif // SPUTTHREAD_H

4
Filter/widget.cpp
View File

@@ -1875,7 +1875,7 @@ void Widget::DataPut(QString _strCompanyNum)
query.bindValue(":DATA",SqlString(stReply.m_strlist[m_anData[E_DATA_article_data]].trimmed()).toUtf8());
query.bindValue(":DATE",stReply.m_strlist[m_anData[E_DATA_article_date]].trimmed().toUtf8());
query.bindValue(":BODY_NUM",m_mapData[strUrl].m_nNum);
query.bindValue(":REALBYCATEGORYNUM",GetVectorToString(stReply.m_vecCategory,""));
query.bindValue(":REALBYCATEGORYNUM",GetVectorToString(stReply.m_vecCategory," ").trimmed());
if (query.exec()==false){
InsertLog(query.lastError().text());db.close();return;
}
@@ -1928,7 +1928,7 @@ void Widget::DataPut(QString _strCompanyNum)
else
query.bindValue(":LASTUPDATE",strDate);
query.bindValue(":REALBYCATEGORYNUM",GetVectorToString(m_mapData[strUrl].m_vecCategory,""));
query.bindValue(":REALBYCATEGORYNUM",GetVectorToString(m_mapData[strUrl].m_vecCategory," ").trimmed());
if (query.exec()==false) {
InsertLog(query.lastError().text());db.close();return;
}