Changeset 2022 in ntrip

Timestamp:

Nov 25, 2009, 6:02:00 PM (15 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bncpppthread.cpp (modified) (4 diffs)
• bncpppthread.h (modified) (2 diffs)

trunk/BNC/bncpppthread.cpp

@@ -43 +43 @@
 #include "bncpppthread.h"
 
+extern "C" {
+#include "clock_orbit_rtcm.h"
+}
+
 using namespace std;
 
@@ -50 +54 @@
   _staID         = staID;
   _isToBeDeleted = false;
-  cout << "PPP Client " << _staID.data() << " constructor\n";
 }
 
@@ -103 +106 @@
     t_obsInternal* obs = &(pp->_o);
     QString staID = QString(obs->StatID); 
-    cout << obs->GPSWeek << " " << obs->GPSWeeks << " " 
-         << staID.toAscii().data() << " " << obs->satSys << obs->satNum << endl;
+    cout << "DATA " << obs->GPSWeek << " " << obs->GPSWeeks << " " 
+         << staID.toAscii().data() << " " 
+         << obs->satSys << obs->satNum << endl;
   }
 }
@@ -129 +133 @@
 void bncPPPthread::slotNewCorrections(QList<QString> corrList) {
   QMutexLocker locker(&_mutex);
-  cout << "PPP Client: new corrections " << corrList.size() << endl;
+  QListIterator<QString> it(corrList);
+  while (it.hasNext()) {
+    QTextStream in(it.next().toAscii());
+    int     messageType;
+    int     updateInterval;
+    int     GPSweek;
+    double  GPSweeks;
+    QString prn;
+    in >> messageType >> updateInterval >> GPSweek >> GPSweeks >> prn;
+    if ( messageType == COTYPE_GPSCOMBINED     || 
+         messageType == COTYPE_GLONASSCOMBINED ) {
+      t_corr* cc = 0;
+      if (_corr.contains(prn)) {
+        cc = _corr.value(prn); 
+      }
+      else {
+        cc = new t_corr();
+        _corr[prn] = cc;
+      }
+      in >> cc->iod >> cc->dClk >> cc->rao[0] >> cc->rao[1] >> cc->rao[2];
+    }
+  }
 }

trunk/BNC/bncpppthread.h

@@ -32 +32 @@
 #include "RTCM3/ephemeris.h"
 
+struct t_corr {
+  int    iod;
+  double dClk;
+  double rao[3];
+};
+
 class bncPPPthread : public QThread {
  Q_OBJECT
@@ -57 +63 @@
 
  private:
-  QByteArray            _staID;
-  bool                  _isToBeDeleted;
-  QMutex                _mutex;
-  QMap<QString, t_eph*> _eph;
+  QByteArray             _staID;
+  bool                   _isToBeDeleted;
+  QMutex                 _mutex;
+  QMap<QString, t_eph*>  _eph;
+  QMap<QString, t_corr*> _corr;
 };