#include "RealTimeAlarm.h"
#include "ui_RealTimeAlarm.h"
#include <QPushButton>
#include "QMyTableViewBtnDelegate.h"
#include "AlarmDetails.h"
#include "sqlitedb.h"
#include <QTimeZone>
#include "ftpclient.h"


CRealTimeAlarm::CRealTimeAlarm(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::CRealTimeAlarm)
{
    ui->setupUi(this);
    ui->widget_alarm->setProperty("flag", "Button");
    headerStr = QObject::tr("序号,级别,报警内容,报警时间,报警详情");

    model = new QStandardItemModel(ui->tableView);
    ui->tableView->setSelectionBehavior(QAbstractItemView::SelectRows); //选中行
    QStringList headerList = headerStr.split(",");
    model->setHorizontalHeaderLabels(headerList);
    model->setColumnCount(headerList.size());
    ui->tableView->setModel(model);
    ui->tableView->setColumnWidth(0, 50);
    ui->tableView->setColumnWidth(1, 50);
    ui->tableView->setColumnWidth(2, 370);
    ui->tableView->setColumnWidth(3, 200);
    ui->tableView->setAlternatingRowColors(true);

    ui->tableView->horizontalHeader()->setSectionResizeMode(QHeaderView::Interactive);
    //ui->tableView->horizontalHeader()->setSectionResizeMode(0,QHeaderView::ResizeToContents);
    //ui->tableView->horizontalHeader()->setSectionResizeMode(4,QHeaderView::ResizeToContents);

    // 必须要设置此项，否则样式表的hover无法生效
    ui->tableView->setMouseTracking(true);
    m_strFileName = "";
    ui->tableView->setEditTriggers(QAbstractItemView::NoEditTriggers);
    initTable();

}

CRealTimeAlarm::~CRealTimeAlarm()
{
    QVector<GroupData>().swap(m_vecGroupdata);
    QVector<WAVE_INFO>().swap(m_vecWaveInfo);
    QVector<WAVE_ALLDATA>().swap(m_vecAllData);
    QMap<QString,QVector<WAVE_DATA>>::Iterator iter1 = mapWaveData.begin();
    for(iter1 = mapWaveData.begin();iter1 != mapWaveData.end();iter1++){
        QVector<WAVE_DATA>().swap(iter1.value());
        mapWaveData.erase(iter1);
    }
    delete ui;
}

void CRealTimeAlarm::createRowItem(int Row,QVariantList RowItem)
{
    model->setRowCount(Row+1);
    for (int  j = 0;  j < RowItem.size(); ++j)
    {
        model->setData(model->index(Row,j,QModelIndex()),RowItem.at(j));
    }
}
void CRealTimeAlarm::initTable()
{
    qDebug() << "initTable1" << endl;
    model->setRowCount(0);
    qDebug() << "initTable2" << endl;
    QString strTableName = "t_AlarmStatusInfo",strSql;
    strSql = QString("  timestamp <> '' order by timestamp DESC limit 0,100");
    m_vecTriggerAlarmStatusInfo = g_SqliteDB->GetTriggerAlarmStatusInfo(strTableName,strSql);

    if(m_vecTriggerAlarmStatusInfo.size() > 0){
        for (int i = 0; i < m_vecTriggerAlarmStatusInfo.size(); i++) {
             QVariantList strRowItem ;
             QDateTime dateTime = QDateTime::fromSecsSinceEpoch(m_vecTriggerAlarmStatusInfo[i].timestamp);
             QTimeZone timeZone("Asia/Shanghai");
             dateTime = dateTime.toTimeZone(timeZone);
             QString TStr = dateTime.toString("yyyy-MM-dd hh:mm:ss");
             QString triggerLevel = "",triggerEventName = "";
             if(m_vecTriggerAlarmStatusInfo[i].triggerLevel == "1"){
                triggerLevel = "警报";
             }else if(m_vecTriggerAlarmStatusInfo[i].triggerLevel == "2"){
                triggerLevel = "危险";
             }
             QString strFeatureName = "";
             if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("MinValues"))
                strFeatureName = "最小值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("MaxValues"))
                strFeatureName = "最大值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("DCValues"))
                strFeatureName = "偏置电压/Gap";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("RMSValues"))
                strFeatureName = "有效值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("DiagnosisPk2Pk"))
                strFeatureName = "诊断峰峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("IntegratRMS"))
                strFeatureName =  "有效值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("IntegratPk2Pk"))
                strFeatureName = "积分峰峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("SpeedProfileSpeed"))
                strFeatureName = "转速";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("IntegratPk2Pk/2"))
                strFeatureName = "峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("DiagnosisPeak"))
                strFeatureName = "峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("MonitorPk2Pk"))
                strFeatureName = "监测保护峰峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("InvertDanger") )
                strFeatureName = "反时限危险值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("InvertAlarm"))
                strFeatureName = "反时限警报值";
             if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("Over")){
                 triggerEventName = m_vecTriggerAlarmStatusInfo[i].channelName + "-" + strFeatureName+ "-" + "高于" + triggerLevel + "值";
             }else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("Under")){
                 triggerEventName = m_vecTriggerAlarmStatusInfo[i].channelName + "-" + strFeatureName+ "-" + "低于" + triggerLevel + "值";
             }
             strRowItem << i + 1 << triggerLevel << triggerEventName << TStr;

             createRowItem(i,strRowItem);
        }
        QMyTableViewBtnDelegate *m_btnDelegate = new QMyTableViewBtnDelegate(QStringList()<<"详情", this);
        ui->tableView->setItemDelegateForColumn(4, m_btnDelegate);
        connect(m_btnDelegate, SIGNAL(editData(const QModelIndex &)), this,SLOT(Details(const QModelIndex &)));

    }else{
        QMessageBox::information(this, "提示", QString("未查询到数据！"));
    }
}


void CRealTimeAlarm::OpenDatFile(QString& strFileName)
{
    QProgressDialog *progressDialog = new QProgressDialog(this);
    progressDialog->setWindowFlags(Qt::CustomizeWindowHint | Qt::FramelessWindowHint);
    progressDialog->setWindowModality(Qt::WindowModal);
    progressDialog->setWindowTitle(tr("Please Wait"));
    progressDialog->setLabelText(tr("读取中..."));
    progressDialog->setCancelButton(0);
    progressDialog->show();


    QTime startTime = QTime::currentTime();
    m_vecGroupdata.clear();
    m_vecWaveInfo.clear();
    QVector<GroupData>().swap(m_vecGroupdata);
    QVector<WAVE_INFO>().swap(m_vecWaveInfo);
    QVector<WAVE_ALLDATA>().swap(m_vecAllData);
    QMap<QString,QVector<WAVE_DATA>>::Iterator iter1 = mapWaveData.begin();
    for(iter1 = mapWaveData.begin();iter1 != mapWaveData.end();iter1++){
        QVector<WAVE_DATA>().swap(iter1.value());
        mapWaveData.erase(iter1);
    }

    int channelwork[64];
    int channelEnabled[64];
    int theSize = 0;    //通道数
    //读12字节头文件
    int iJsonSize, iChannelsize;
    char equipNo[12];     //设备No 12字节
    char time[10];        //数据起始时间 10字节
    QFile file(strFileName);
    if (!file.open(QIODevice::ReadOnly))
    {
        qDebug() << "::MainWidget::ReadDatData()  cannot open file for read";
        return;
    }
    file.read((char*)&iChannelsize, sizeof(iChannelsize));

    qDebug() << "::MainWidget::ReadDatData()  Channelsize:" << iChannelsize;
    int iCount;          //存储dat文件原始数据秒数
    file.read((char*)&iCount, sizeof(iCount));
    qDebug() << "::MainWidget::ReadDatData()  iCount:" << iCount;

    file.read(equipNo, sizeof(equipNo));
    QString sEquipNo(equipNo);

    file.read(time, sizeof(time));
    QString CollectTime(time);

    file.read((char *)&iJsonSize, sizeof(iJsonSize));
    qDebug() << "::MainWidget::ReadDatData()  iJsonSize:" << iJsonSize;

    //读json串
    char *buf0 = (char *)malloc(sizeof(char) *iJsonSize);
    file.read(buf0,iJsonSize);
    QJsonParseError parseJsonErr;
    QJsonDocument document = QJsonDocument::fromJson(buf0,&parseJsonErr);
    if(!(parseJsonErr.error == QJsonParseError::NoError))
    {
           qDebug()<<tr("解析json文件错误！");
           delete progressDialog;
           file.close();
           return;
    }
    int channels = 0;
    QJsonObject jsonObject = document.object();
    QString strType  = jsonObject["DeviceType"].toString();
    if(jsonObject.contains(QStringLiteral("ChannelSettings"))){
        QJsonValue arrayValue = jsonObject.value(QStringLiteral("ChannelSettings"));
        if(arrayValue.isArray()){
            QJsonArray array = arrayValue.toArray();
            theSize = array.size();
            for(int i = 0; i<array.size();i++){
                WAVE_INFO waveInfo;
                channelEnabled[i] = array.at(i)["isEnable"].toInt();
                channelwork[i] = array.at(i)["isWork"].toInt();
                QString strchannelType = array.at(i)["sensorType"].toString();
                if(channelEnabled[i] && channelwork[i] && strchannelType != "DO" && strchannelType != "DI"){
                    waveInfo.channelId = array.at(i)["channelId"].toString();
                    waveInfo.channelType = array.at(i)["sensorType"].toString();
                    waveInfo.channelName = array.at(i)["channelName"].toString();
                    waveInfo.sensorType = array.at(i)["sensorType"].toString();
                    waveInfo.channelSamleRate = array.at(i)["samplingRate"].toInt();
                    waveInfo.pairChannelID = array.at(i)["pairChannelId"].toString();
                    waveInfo.equipmentName = array.at(i)["equipmentName"].toString();
                    waveInfo.sensorEngineeringUnit = array.at(i)["sensorEngineeringUnit"].toString();
                    waveInfo.speedRefChannelId = array.at(i)["speedRefChannelId"].toString();
                    waveInfo.tachAutoTach = array.at(i)["tachAutoTach"].toBool();
                    waveInfo.sensorGapVoltage = array.at(i)["sensorGapVoltage"].toDouble();
                    waveInfo.sensorSensitivity = array.at(i)["sensorSensitivity"].toDouble();
                    QString strtachTriggerEdge = array.at(i)["tachTriggerEdge"].toString();
                    if(strtachTriggerEdge == "rising"){
                        waveInfo.iTrigger = 0;
                    }else if(strtachTriggerEdge == "falling"){
                        waveInfo.iTrigger = 1;
                    }
                    waveInfo.iTrigger = 0;
                    waveInfo.iKeyCount = array.at(i)["tachTriggerPerRev"].toInt();
                    waveInfo.iTriggerValue = array.at(i)["tachTriggerVoltageLevel"].toDouble();
                    waveInfo.iHysteresis = array.at(i)["tachTriggerHysteresis"].toDouble();
                    qDebug() <<waveInfo.channelId<< "iKeyCount" << waveInfo.iKeyCount << "iTriggerValue" << waveInfo.iTriggerValue << "iHysteresis" << waveInfo.iHysteresis << endl;
                    m_vecWaveInfo.push_back(waveInfo);
                    channels ++ ;
                    qDebug() << waveInfo.sensorGapVoltage <<  waveInfo.sensorSensitivity  << endl;
                    qDebug() << waveInfo.channelId << waveInfo.channelType <<waveInfo.channelName << waveInfo.pairChannelID << waveInfo.sensorEngineeringUnit << waveInfo.speedRefChannelId << waveInfo.iTriggerValue<<endl;
                }
            }
        }
    }if(jsonObject.contains(QStringLiteral("groups"))){
        QJsonValue arrayValue = jsonObject.value(QStringLiteral("groups"));
        if(arrayValue.isArray()){
            QJsonArray array1 = arrayValue.toArray();
            theSize = array1.size();
            for(int i = 0; i<array1.size();i++){
                QString strChannelType = array1.at(i)["ChannelType"].toString();
                QString strChannelID = array1.at(i)["name"].toString();
                //if(strChannelType == "TACHOMETER")
                {
                    for(int ii = 0; ii < m_vecWaveInfo.size();ii++){
                        if(strChannelID == m_vecWaveInfo[ii].channelId){
                            QJsonValue arrayValue = array1.at(i)["channels"];
                            QJsonArray array2 = arrayValue.toArray();
                            for(int j = 0; j<array2.size();j++){
                                if("SpeedProfileSpeed" == array2.at(j)["name"].toString()){
                                    QJsonArray arrayValue = array2.at(j)["data"].toArray();
                                    for(int jj = 0; jj < arrayValue.size();jj++){
                                        m_vecWaveInfo[ii].SpeedProfileSpeed.push_back(arrayValue[jj].toDouble());
                                    }
                                }
                                if("RMSValues" == array2.at(j)["name"].toString()){
                                    QJsonArray arrayValue = array2.at(j)["data"].toArray();
                                    for(int jj = 0; jj < arrayValue.size();jj++){
                                        m_vecWaveInfo[ii].RMSValue.push_back(arrayValue[jj].toDouble());
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
    }

    qDebug()<<"channels" <<channels<<endl;
    //循环读出原始数据内容
    WAVE_CHNDATA m_WaveChnData[15000];
    int  Count, waveSize,bufferSiz;
    if(strType == "3500")
        bufferSiz = 16;
    else
        bufferSiz = 15;
    char buf[bufferSiz];
    m_vecAllData.clear();
    //QVector<WAVE_DATA> pData;
    int j = 0;
    int temCount = 0;
    int flag = -1;
    progressDialog->setRange(0, iCount * channels-1);

    while (!file.atEnd()) {
        file.read((char *)&Count, sizeof(Count));
        //qDebug()<<"Count" << Count << "temCount" <<temCount<< endl;
        if(Count > temCount && flag == 0)//过滤超出的秒数的数据
            break;
        if(Count == temCount  && flag == 0)
            flag = 1;
        if(Count < temCount || flag == 1){//过滤原始数据中转速多余数据
            file.read(buf, sizeof(buf));
            file.read((char *)&waveSize, sizeof(waveSize));
            float f = 0.0;
            QVector<double> vecSpeed;
            qDebug()<<"waveSize1" <<waveSize<<endl;
            for (int i = 0; i < waveSize; i++) {
                file.read((char *)&f, sizeof(f));
                vecSpeed.push_back(f);
            }
            for(int ii = 0; ii < 2000;ii++){
                if(m_WaveChnData[ii].Second == Count){
                    m_WaveChnData[ii].TimeStamp = vecSpeed;
                }
            }
            flag = 0;
            qDebug()<<"::MainWidget::ReadDatData()11  wave.channelId" << buf <<" wave.count"<<Count<<" wave.wavedata"<<m_WaveChnData[j].waveData.size()<<"waveSize"<<waveSize << "j"<<j<<endl;;
        }else {
            file.read(buf, sizeof(buf));
            file.read((char *)&waveSize, sizeof(waveSize));
            float f = 0.0;
            WAVE_ALLDATA waveAll;
            if(waveSize < 0 || waveSize > 131072){
                qDebug() << "waveSize2" << waveSize << endl;
                delete progressDialog;
                file.close();
                return;
            }
            for (int i = 0; i < waveSize; i++) {
                file.read((char *)&f, sizeof(f));
                m_WaveChnData[j].channelId = buf;
                m_WaveChnData[j].waveData.push_back((double)f);
                m_WaveChnData[j].Second = Count;
            }

            temCount = Count;
            //qDebug()<<"::MainWidget::ReadDatData()  wave.channelId" << m_WaveChnData[j].channelId<<" wave.count"<<Count<<" wave.wavedata"<<m_WaveChnData[j].waveData.size()<<"waveSize"<<waveSize << "j"<<j<<endl;;
        }
        progressDialog->setValue(j);
        if (progressDialog->wasCanceled())
        {

            delete progressDialog;
            file.close();
            return ;
        }
        j++;
    }

    /*if(temCount != iCount){
        MyMsgBox(QMessageBox::Warning,"警告","Dat文件采集秒数与实际读取秒数不一致");
        iCount = temCount;
    }*/

    qDebug()<<m_vecAllData.size()<<m_vecAllData.capacity() << "iCount" <<iCount << "m_vecWaveInfo" << m_vecWaveInfo.size() <<endl;
    QVector<WAVE_INFO>::iterator iter = m_vecWaveInfo.begin();
    int linecolor = 0;

    for (;iter != m_vecWaveInfo.end() ; iter++ ) {
        WAVE_DATA wave;
        int ii = 0;
        QVector<WAVE_DATA> m_vecPushData1;
        for(int i = 0; i < j; i++){
            //qDebug() << "i" << iter->channelId.left(bufferSiz)  << "j " << m_WaveChnData[i].channelId.left(bufferSiz) <<endl;
            if(iter->channelId.left(bufferSiz) == m_WaveChnData[i].channelId.left(bufferSiz)){

                wave.waveData = m_WaveChnData[i].waveData;
                double sum = 0.0;
                if(iter->sensorType == "ACCELEROMETER" || iter->sensorType == "MICROPHONE"  ||
                        iter->sensorType == "PROXIMETER"  || iter->sensorType == "VELOCITY" ||
                        iter->sensorType == "TACHOMETER" || iter->sensorType == "THRUST" ||
                        iter->sensorType == "FAST_VOLTAGE"){
                    sum = std::accumulate(std::begin(wave.waveData), std::end(wave.waveData), 0.0);
                    double size = m_WaveChnData[i].waveData.size();
                    wave.mean = sum/size;

                }else{
                    sum = 0.0;
                }
                if(iter->sensorType == "TACHOMETER"){
                    wave.TimeStamp = m_WaveChnData[i].TimeStamp;
                    //qDebug()<< "iCount" <<iCount<<endl;
                    ii ++;
                }

                wave.SpeedProfileSpeed = iter->SpeedProfileSpeed;
                wave.wavesize = wave.waveData.size();
                wave.SamleRate = iter->channelSamleRate;
                wave.sensorType = iter->sensorType;
                wave.channelId = iter->channelId;
                wave.channelNo = theSize;
                wave.Time = iCount;
                wave.channelName = iter->channelName;
                wave.pairChannelID = iter->pairChannelID;
                wave.sensorEngineeringUnit = iter->sensorEngineeringUnit;
                wave.speedRefChannelId = iter->speedRefChannelId;
                wave.RMSValue = iter->RMSValue;

                wave.iTrigger = iter->iTrigger;
                wave.iKeyCount = iter->iKeyCount;
                wave.iTriggerValue = iter->iTriggerValue;
                wave.iHysteresis = iter->iHysteresis;
                wave.tachAutoTach = iter->tachAutoTach;
                wave.sensorGapVoltage = iter->sensorGapVoltage;
                wave.sensorSensitivity = iter->sensorSensitivity;
                switch(linecolor){
                    case 0:
                        wave.linColor = Qt::green ;
                    break;
                    case 1:
                        wave.linColor = QColor(30,144,255) ;
                    break;
                    case 2:
                        wave.linColor = QColor(255,182,193) ;
                    break;
                    case 3:
                        wave.linColor = Qt::cyan ;
                    break;
                    case 4:
                        wave.linColor = Qt::magenta ;
                    break;
                    case 5:
                        wave.linColor = Qt::yellow ;
                    break;
                    case 6:
                        wave.linColor = QColor(255,69,0) ;
                    break;
                    case 7:
                        wave.linColor = QColor(0, 255, 127) ;
                    break;
                    case 8:
                        wave.linColor = QColor(255,140,0) ;
                    break;
                    case 9:
                        wave.linColor = QColor(0, 191, 255) ;
                    break;
                    case 10:
                        wave.linColor = Qt::darkMagenta ;
                    break;
                    case 11:
                        wave.linColor = Qt::lightGray ;
                    break;
                    case 12:
                        wave.linColor = Qt::darkYellow ;
                    break;
                    case 13:
                        wave.linColor = QColor(153,	51,	250);
                    break;
                    case 14:
                        wave.linColor = QColor(255, 218, 185) ;
                    break;
                    case 15:
                        wave.linColor = QColor(0,199,140) ;
                    break;
                    default:
                    break;
                }
                m_vecPushData1.push_back(wave);
            }
        }
        linecolor++;
        if(linecolor > 15){
            linecolor = 0;
        }
        qDebug() << "channelId"<<iter->channelId << endl;
        mapWaveData.insert(iter->channelId,m_vecPushData1);
        m_iRealCount = m_vecPushData1.size();
        qDebug() << "m_iRealCount"<<m_iRealCount << endl;
        qDebug()<<"mapWaveData size"<<mapWaveData.size()<<endl;

    }
    file.close();
    free(buf0);
    //qDebug() << "=====waveSpeedData time=====" <<mapWaveData[strChannelID].at(0).Time <<mapWaveData[speedChannelID].at(0).Time << endl;
    qDebug() << "m_iRealCount" << m_iRealCount << endl;
    //设置播放进度条
    m_iCount = 0;
    m_iCount = m_iRealCount;


    QTime stopTime = QTime::currentTime();
    qDebug() << "Time: " << startTime.msecsTo(stopTime) << "ms" <<endl;

    if(m_iRealCount < 1){
        QMessageBox::information(this, "提示", QString("未读取到数据！"));
        return;
    }

    delete progressDialog;
    DateViewdialog = new CDataGraphView();
    connect(DateViewdialog, SIGNAL(ItemCheckStateSignal(QString, bool)), this, SLOT(ItemCheckStateSlot(QString, bool)));
    DateViewdialog->setWindowModality(Qt::ApplicationModal);
    DateViewdialog->setAttribute(Qt::WA_DeleteOnClose);
    DateViewdialog->show();
    QStringList strIDList,strChannleType,strChannleNameList;
    QMap<QString,QVector<WAVE_DATA>>::Iterator iter2 = mapWaveData.begin();
    for (; iter2 != mapWaveData.end(); iter2 ++)
    {
        if(!strIDList.contains(iter2.key()))
        strIDList.push_back(iter2.key());
        strChannleType.push_back(iter2.value()[0].sensorType);
        strChannleNameList.push_back(iter2.value()[0].channelName);
    }
    DateViewdialog->SetDataIDs(strIDList, tr("Data Watch "),strChannleType,strChannleNameList);
}
void CRealTimeAlarm::DownloadStatus_Slot()
{
    OpenDatFile(g_LocalFile);
    disconnect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64)));
    disconnect(g_FtpClient,SIGNAL(sigDownloadStatus()),this,SLOT(DownloadStatus_Slot()));
}
void CRealTimeAlarm::downloadProcess_Slot(qint64 byteSend, qint64 byteTotal)
{
    downloadProgressDialog->setRange(0, byteTotal);
    downloadProgressDialog->setValue(byteSend);
    if(byteSend == byteTotal){
         disconnect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64)));
         OpenDatFile(g_LocalFile);
    }
}

void CRealTimeAlarm::Details(const QModelIndex &index)
{

    int row = index.row();
    QString strCol = "triggeredFileName";
    QString strTimeStamp = QString("%1").arg(m_vecTriggerAlarmStatusInfo[row].timestamp);
    QString strTableName = QString("t_TriggerEvent ORDER BY  ABS(triggeredTime  - %1) LIMIT 1").arg(m_vecTriggerAlarmStatusInfo[row].timestamp);
    QString strFileName = g_SqliteDB->GetSingelLine(strTableName,strCol);
    strFileName = strFileName.left(strFileName.size()-1);
    QStringList strList = strFileName.split("/");

#ifdef Q_OS_WIN32
    QString strPath = QCoreApplication::applicationDirPath() + "\\dat\\" + strList[5];
#endif
#ifdef Q_OS_LINUX
    QString strPath = QCoreApplication::applicationDirPath() + "/dat/" + strList[5];
#endif

    QFile file(strPath);
    customLogMessageHandler(QtDebugMsg, "RealTimeAlarm:" + strPath);
    g_LocalFile = strPath;
    if(file.exists()){
        qDebug() << "file1" << endl;
        OpenDatFile(strPath);
    }else{
        downloadProgressDialog = new QProgressDialog(this);
        downloadProgressDialog->setWindowFlags(Qt::CustomizeWindowHint | Qt::FramelessWindowHint);
        downloadProgressDialog->setWindowModality(Qt::WindowModal);
        downloadProgressDialog->setWindowTitle(tr("Please Wait"));
        downloadProgressDialog->setLabelText(tr("下载中..."));
        //downloadProgressDialog->setCancelButton(0);
        downloadProgressDialog->show();
        qDebug() << "file2" << endl;
        connect(g_FtpClient,SIGNAL(sigDownloadProcess(qint64 , qint64 )),this,SLOT(downloadProcess_Slot(qint64 , qint64)));
        //connect(g_FtpClient,SIGNAL(sigDownloadStatus()),this,SLOT(DownloadStatus_Slot()));
        QString str = QString("ftp://%1/").arg(IP);
        g_FtpClient->SetServerInfo(str);
        g_FtpClient->SetUserInfo("root","@#cidw!@123456");
        g_FtpClient->DownLoad(strFileName,strPath);
    }
}

void CRealTimeAlarm::ItemCheckStateSlot(QString strID, bool bChecked)
{
    DateViewdialog->ViewData(strID,mapWaveData[strID]);
}

void CRealTimeAlarm::on_pushButton_refresh_clicked()
{
    model->setRowCount(0);
    qDebug() << "initTable2" << endl;
    QString strTableName = "t_AlarmStatusInfo",strSql;
    strSql = QString("  timestamp <> '' order by timestamp DESC limit 0,100");
    m_vecTriggerAlarmStatusInfo = g_SqliteDB->GetTriggerAlarmStatusInfo(strTableName,strSql);

    if(m_vecTriggerAlarmStatusInfo.size() > 0){
        for (int i = 0; i < m_vecTriggerAlarmStatusInfo.size(); i++) {
             QVariantList strRowItem ;
             QDateTime dateTime = QDateTime::fromSecsSinceEpoch(m_vecTriggerAlarmStatusInfo[i].timestamp);
             QTimeZone timeZone("Asia/Shanghai");
             dateTime = dateTime.toTimeZone(timeZone);
             QString TStr = dateTime.toString("yyyy-MM-dd hh:mm:ss");
             QString triggerLevel = "",triggerEventName = "";
             if(m_vecTriggerAlarmStatusInfo[i].triggerLevel == "1"){
                triggerLevel = "警报";
             }else if(m_vecTriggerAlarmStatusInfo[i].triggerLevel == "2"){
                triggerLevel = "危险";
             }
             QString strFeatureName = "";
             if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("MinValues"))
                strFeatureName = "最小值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("MaxValues"))
                strFeatureName = "最大值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("DCValues"))
                strFeatureName = "偏置电压/Gap";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("RMSValues"))
                strFeatureName = "有效值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("DiagnosisPk2Pk"))
                strFeatureName = "诊断峰峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("IntegratRMS"))
                strFeatureName =  "有效值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("IntegratPk2Pk"))
                strFeatureName = "积分峰峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("SpeedProfileSpeed"))
                strFeatureName = "转速";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("IntegratPk2Pk/2"))
                strFeatureName = "峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("DiagnosisPeak"))
                strFeatureName = "峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("MonitorPk2Pk"))
                strFeatureName = "监测保护峰峰值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("InvertDanger") )
                strFeatureName = "反时限危险值";
             else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("InvertAlarm"))
                strFeatureName = "反时限警报值";
             if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("Over")){
                 triggerEventName = m_vecTriggerAlarmStatusInfo[i].channelName + "-" + strFeatureName+ "-" + "高于" + triggerLevel + "值";
             }else if(m_vecTriggerAlarmStatusInfo[i].triggerEventName.contains("Under")){
                 triggerEventName = m_vecTriggerAlarmStatusInfo[i].channelName + "-" + strFeatureName+ "-" + "低于" + triggerLevel + "值";
             }
             strRowItem << i + 1 << triggerLevel << triggerEventName << TStr;

             createRowItem(i,strRowItem);
        }
        QMyTableViewBtnDelegate *m_btnDelegate = new QMyTableViewBtnDelegate(QStringList()<<"详情", this);
        ui->tableView->setItemDelegateForColumn(4, m_btnDelegate);
        connect(m_btnDelegate, SIGNAL(editData(const QModelIndex &)), this,SLOT(Details(const QModelIndex &)));

    }else{
        QMessageBox::information(this, "提示", QString("未查询到数据！"));
    }
}