浏览代码

烟感语音通话功能

james 2 年之前
父节点
当前提交
0b90ccf6e3
共有 2 个文件被更改,包括 5 次插入1 次删除
  1. 4 0
      DataProcessService/ytTBSN101Process/tbcore.cpp
  2. 1 1
      DataProcessService/ytTBSN101Process/tbcore.h

+ 4 - 0
DataProcessService/ytTBSN101Process/tbcore.cpp

@@ -25,14 +25,17 @@ TBCore::TBCore(QObject *parent) :
     for(quint16 i=0;i<16;i++){
         wxThreads[0][i] = new WechartThreads(this,i,"47.98.201.73","/jdxf/wxapp2.php/Home/Waterwarn/bj");
         wxThreads[1][i] = new WechartThreads(this,i,"47.98.201.73","/jdxf/wxapp2.php/Home/Geomagnetismwarn/index");
+        wxThreads[2][i] = new WechartThreads(this,i,"47.98.201.73","/jdxf/wxapp2.php/Home/GeneralPush/voice_alarm");
         connect(wxThreads[0][i],&WechartThreads::wxchart,this,&TBCore::wxchart);
         connect(wxThreads[1][i],&WechartThreads::wxchart,this,&TBCore::wxchart);
+        connect(wxThreads[2][i],&WechartThreads::wxchart,this,&TBCore::wxchart);
         tbThread[i] = new ttsThreads(this,i,"47.98.201.73","/report",55125);
         connect(tbThread[i],&ttsThreads::ttslog,this,&TBCore::wxchart);
         repThread[i] = new ttsThreads(this,i,"127.0.0.1","/report",55335);
         connect(repThread[i],&ttsThreads::ttslog,this,&TBCore::wxchart);
         wxThreads[0][i]->start();
         wxThreads[1][i]->start();
+        wxThreads[2][i]->start();
         tbThread[i]->start();
         repThread[i]->start();
     }
@@ -222,6 +225,7 @@ void TBCore::AlarmReport(QString subtype, quint64 addr, quint64 insertid, QStrin
                         .replace(",","%2C").replace(":","%3A").replace(" ","+");
                 logThread->appendData(data);
                 wxThreads[0][wxcur&0x0f]->appendData(data);
+                wxThreads[2][wxcur&0x0f]->appendData(data);
                 wxcur++;
                 wxcur &= 0x0f;
             }

+ 1 - 1
DataProcessService/ytTBSN101Process/tbcore.h

@@ -57,7 +57,7 @@ private:
     LogThread *logThread;
     DatabaseThread *dbThread;
     quint8 wxcur,repcur;
-    WechartThreads *wxThreads[2][16];
+    WechartThreads *wxThreads[3][16];
 //    WechartThreads *wxThreads[16];
     ttsThreads *repThread[16];
     ttsThreads *tbThread[16];