QT 实时分析文件内容，解析内容字段；文件一有改变可以实时监测出来，并进行按行分析；把分析出来的有用信息保存下来

#include "analysisvehifno.h" //#include "baseinfo.h" #include "commonunits.h" #include <QJsonDocument> #include <QDebug> #include <QFile> #include <QJsonObject> #include <QJsonArray> #include <QJsonArray> #include <QVariant> #include <QTextCodec> AnalysisVehInfo::AnalysisVehInfo(QObject *parent) : QObject(parent) { loadVehConfig(); m_nIndex = 1; m_nLocation = 0; m_nPosErrCount = 0; m_pCheckTimer = new QTimer(this); connect(m_pCheckTimer, SIGNAL(timeout()), this, SLOT(onTimeout())); connect(this, SIGNAL(recvLog(QString)), this, SLOT(recvLineLog(QString))); m_bFirst = true; sLastLaspTime = QDateTime::currentDateTime().toString("yyyyMMdd"); m_pCheckLaspTimer = new QTimer(this); connect(m_pCheckLaspTimer, SIGNAL(timeout()), this, SLOT(onLaspTimeout())); m_pCheckLaspTimer->start(10*1000); } void AnalysisVehInfo::loadVehConfig() { QFile file("./conf/VehConfig.json"); if (!file.open(QFile::ReadOnly)) { //LOGMAIN->error(QString("Load [./conf/VehConfig.json] Err -- %1.").arg(file.errorString())); return; } QByteArray ba = file.readAll(); QVariantMap map = QJsonDocument::fromJson(ba).object().toVariantMap(); for (auto iter = map.constBegin(); iter != map.constEnd(); ++iter) { if (iter.key() != "analyse") { QList<VehConfig> configList; QList<QVariant> array = iter.value().toList(); if (!array.isEmpty()) { for (int i = 0; i < array.count(); ++i) { VehConfig config; QVariantMap tmpMap = array.at(i).toMap(); config.regExp = tmpMap.value("regexp").toString(); config.nMaxLen = tmpMap.value("maxlen").toInt(); config.nMinLen = tmpMap.value("minlen").toInt(); QString sLine = tmpMap.value("reginfo").toString(); if (sLine.size()) { QStringList strList = sLine.trimmed().split(","); for (int i = 0; i < strList.size(); ++i) { QStringList sTmpList = strList.at(i).split("|"); if (sTmpList.size() > 1) config.valueList.append(QPair<int, QString>(sTmpList.at(0).toInt(), sTmpList.at(1))); } } else { continue; } configList.append(config); } m_VehCofingHash.insert(iter.key(), configList); } } else { QVariantMap tmp = iter.value().toMap(); for (auto i = tmp.constBegin(); i != tmp.constEnd(); ++i) { QList<QVariant> array = i.value().toList(); QList<InfoAnalyze> list; for (int j = 0; j < array.count(); ++j) { InfoAnalyze info; QVariantMap tmpMap = array.at(j).toMap(); info.nBegin = tmpMap.value("begin").toInt(); info.nEnd = tmpMap.value("end").toInt(); info.sDealType = tmpMap.value("dealType").toString().split("|"); info.sName = tmpMap.value("name").toString(); list.append(info); } m_InfoAnalyzeHash.insert(i.key(), list); } } } #ifdef OUTCONFIG for (auto iter = m_VehCofingHash.constBegin(); iter != m_VehCofingHash.constEnd(); ++iter) { qDebug() << "Name" << iter.key(); for (int i = 0; i < iter.value().size(); ++i) { qDebug() << QString("regExp : %1, maxLen %2, minLen : %3").arg(iter.value().at(i).regExp).arg(iter.value().at(i).nMaxLen).arg(iter.value().at(i).nMinLen); qDebug() << iter.value().at(i).valueList; } } #endif } QHash<QString, QString> AnalysisVehInfo::checkInfo(QString sLine, QString sKey) { //LOGMAIN->info(QString("checkInfo:sLine:%1;sKey:%2").arg(sLine).arg(sKey)); QHash<QString, QString> rt; QList<VehConfig> baseConfig = m_VehCofingHash.value(sKey); foreach (VehConfig config, baseConfig) { if (config.nMaxLen > 0 && sLine.size() > config.nMaxLen) continue; if (config.nMinLen > 0 && sLine.size() < config.nMinLen) continue; QRegExp reg(config.regExp); if (-1 < reg.indexIn(sLine)) { for (int i = 0; i < config.valueList.size(); ++i) { if (0 == config.valueList.at(i).first) { rt.insert(config.valueList.at(i).second, reg.cap(i + 1)); } else if (1 == config.valueList.at(i).first) { //递归 QHash<QString, QString> rt1 = checkInfo(reg.cap(i + 1), config.valueList.at(i).second); for (auto iter = rt1.constBegin(); iter != rt1.constEnd(); ++iter) rt.insert(iter.key(), iter.value()); } else { QString sInfo = reg.cap(i + 1); QList<InfoAnalyze> list = m_InfoAnalyzeHash.value(config.valueList.at(i).second); foreach (auto value, list) { QString sTmp = sInfo.mid(value.nBegin, value.nEnd - value.nBegin); QByteArray baTmp = sTmp.toUtf8(); foreach (auto d, value.sDealType) { int nType = d.toInt(); switch (nType) { case 1: // Hex 2 Raw baTmp = QByteArray::fromHex(baTmp); break; case 2: // Raw 2 Hex baTmp = baTmp.toHex(); break; case 3: // GBK 2 Un { static QTextCodec *pCodec = QTextCodec::codecForName("GB2312"); baTmp = pCodec->toUnicode(baTmp).toUtf8(); break; default: break; } } } //LOGMAIN->info(QString("checkInfo:value.sName:%1;baTmp:%2").arg(value.sName).arg(QString::fromUtf8(baTmp))); rt.insert(value.sName, QString::fromUtf8(baTmp)); } } } break; } } return rt; } void AnalysisVehInfo::readFile(const QString &sName, int nType) { //LOGMAIN->info(QString("readFile:%1;nType:%2").arg(sName).arg(nType)); static QTextCodec *pCodec = QTextCodec::codecForName("GB2312"); if (2 == nType) { QString sOldName = sName; sOldName.replace(".log", "_bak01.log"); //LOGMAIN->info(QString("readFile:sOldName:%1").arg(sOldName)); readFile(sOldName, 0); m_nLocation = 0; } else { QFile file(sName); //LOGMAIN->info(QString("readFile:sName:%1").arg(sName)); if (file.exists()) { if (!file.open(QFile::ReadOnly)) return; if (file.size() > m_nLocation) { m_nPosErrCount = 0; file.seek(m_nLocation); while (!file.atEnd()) { QString str; if (pCodec) {