source: ntrip/trunk/BNS/bns.cpp@ 2419

Last change on this file since 2419 was 2419, checked in by mervart, 14 years ago

* empty log message *

File size: 22.3 KB
RevLine 
[756]1/* -------------------------------------------------------------------------
2 * BKG NTRIP Server
3 * -------------------------------------------------------------------------
4 *
5 * Class: bns
6 *
7 * Purpose: This class implements the main application behaviour
8 *
9 * Author: L. Mervart
10 *
11 * Created: 29-Mar-2008
12 *
13 * Changes:
14 *
15 * -----------------------------------------------------------------------*/
16
[858]17#include <math.h>
[756]18#include <iostream>
[800]19#include <newmatio.h>
[756]20
21#include "bns.h"
[799]22#include "bnsutils.h"
[847]23#include "bnsrinex.h"
[848]24#include "bnssp3.h"
[1668]25#include "bnssettings.h"
[1838]26extern "C" {
27#include "RTCM/rtcm3torinex.h"
28}
[756]29
30using namespace std;
31
[1838]32// Error Handling
33////////////////////////////////////////////////////////////////////////////
34void RTCM3Error(const char*, ...) {
35}
36
[756]37// Constructor
38////////////////////////////////////////////////////////////////////////////
[757]39t_bns::t_bns(QObject* parent) : QThread(parent) {
[760]40
[764]41 this->setTerminationEnabled(true);
[828]42
[836]43 connect(this, SIGNAL(moveSocket(QThread*)),
44 this, SLOT(slotMoveSocket(QThread*)));
45
[1668]46 bnsSettings settings;
[979]47
48 // Set Proxy (application-wide)
49 // ----------------------------
50 QString proxyHost = settings.value("proxyHost").toString();
51 int proxyPort = settings.value("proxyPort").toInt();
[980]52
53 QNetworkProxy proxy;
54 if (proxyHost.isEmpty()) {
55 proxy.setType(QNetworkProxy::NoProxy);
56 }
57 else {
[979]58 proxy.setType(QNetworkProxy::Socks5Proxy);
59 proxy.setHostName(proxyHost);
60 proxy.setPort(proxyPort);
61 }
[980]62 QNetworkProxy::setApplicationProxy(proxy);
[979]63
[828]64 // Thread that handles broadcast ephemeris
65 // ---------------------------------------
66 _bnseph = new t_bnseph(parent);
[827]67
[1059]68 connect(_bnseph, SIGNAL(newEph(t_eph*, int)),
[1058]69 this, SLOT(slotNewEph(t_eph*, int)));
[828]70 connect(_bnseph, SIGNAL(newMessage(QByteArray)),
71 this, SLOT(slotMessage(const QByteArray)));
72 connect(_bnseph, SIGNAL(error(QByteArray)),
73 this, SLOT(slotError(const QByteArray)));
[760]74
[827]75 // Server listening for rtnet results
76 // ----------------------------------
[828]77 _clkSocket = 0;
[827]78 _clkServer = new QTcpServer;
79 _clkServer->listen(QHostAddress::Any, settings.value("clkPort").toInt());
[828]80 connect(_clkServer, SIGNAL(newConnection()),this, SLOT(slotNewConnection()));
[827]81
[828]82 // Socket and file for outputting the results
83 // -------------------------------------------
[2349]84 for (int ic = 1; ic <= 10; ic++) {
[1069]85 QString mountpoint = settings.value(QString("mountpoint_%1").arg(ic)).toString();
[1123]86 QString outFileName = settings.value(QString("outFile_%1").arg(ic)).toString();
87 if (!mountpoint.isEmpty() || !outFileName.isEmpty()) {
[1698]88 _caster.push_back(new t_bnscaster(mountpoint, outFileName, ic));
[1068]89 connect(_caster.back(), SIGNAL(error(const QByteArray)),
90 this, SLOT(slotError(const QByteArray)));
91 connect(_caster.back(), SIGNAL(newMessage(const QByteArray)),
92 this, SLOT(slotMessage(const QByteArray)));
93 }
[1067]94 }
95
[1796]96 // Socket for outputting the Ephemerides
97 // -------------------------------------
98 QString mountpoint = settings.value("mountpoint_Eph").toString();
99 if (mountpoint.isEmpty()) {
100 _casterEph = 0;
101 }
102 else {
103 _casterEph = new t_bnscaster(mountpoint);
[1800]104 connect(_casterEph, SIGNAL(error(const QByteArray)),
[1796]105 this, SLOT(slotError(const QByteArray)));
[1800]106 connect(_casterEph, SIGNAL(newMessage(const QByteArray)),
[1796]107 this, SLOT(slotMessage(const QByteArray)));
108 }
109
[1065]110 // Log File
111 // --------
[983]112 QIODevice::OpenMode oMode;
113 if (Qt::CheckState(settings.value("fileAppend").toInt()) == Qt::Checked) {
114 oMode = QIODevice::WriteOnly | QIODevice::Unbuffered | QIODevice::Append;
115 }
116 else {
117 oMode = QIODevice::WriteOnly | QIODevice::Unbuffered;
118 }
119
[816]120 QString logFileName = settings.value("logFile").toString();
121 if (logFileName.isEmpty()) {
[947]122 _logFile = 0;
123 _logStream = 0;
[812]124 }
[816]125 else {
126 _logFile = new QFile(logFileName);
[983]127 if (_logFile->open(oMode)) {
[816]128 _logStream = new QTextStream(_logFile);
129 }
[948]130 else {
131 _logStream = 0;
132 }
[816]133 }
[847]134
[1072]135 // Echo input from RTNet into a file
136 // ---------------------------------
137 QString echoFileName = settings.value("inpEcho").toString();
138 if (echoFileName.isEmpty()) {
139 _echoFile = 0;
140 _echoStream = 0;
141 }
142 else {
143 _echoFile = new QFile(echoFileName);
144 if (_echoFile->open(oMode)) {
145 _echoStream = new QTextStream(_echoFile);
146 }
147 else {
148 _echoStream = 0;
149 }
150 }
151
[847]152 // RINEX writer
153 // ------------
154 if ( settings.value("rnxPath").toString().isEmpty() ) {
155 _rnx = 0;
156 }
157 else {
[850]158 QString prep = "BNS";
[857]159 QString ext = ".clk";
[850]160 QString path = settings.value("rnxPath").toString();
161 QString intr = settings.value("rnxIntr").toString();
162 int sampl = settings.value("rnxSampl").toInt();
163 _rnx = new bnsRinex(prep, ext, path, intr, sampl);
[847]164 }
[848]165
166 // SP3 writer
167 // ----------
168 if ( settings.value("sp3Path").toString().isEmpty() ) {
169 _sp3 = 0;
170 }
171 else {
[850]172 QString prep = "BNS";
[857]173 QString ext = ".sp3";
[850]174 QString path = settings.value("sp3Path").toString();
175 QString intr = settings.value("sp3Intr").toString();
176 int sampl = settings.value("sp3Sampl").toInt();
177 _sp3 = new bnsSP3(prep, ext, path, intr, sampl);
[848]178 }
[756]179}
180
181// Destructor
182////////////////////////////////////////////////////////////////////////////
[757]183t_bns::~t_bns() {
[763]184 deleteBnsEph();
[769]185 delete _clkServer;
[837]186 delete _clkSocket;
[1066]187 for (int ic = 0; ic < _caster.size(); ic++) {
188 delete _caster.at(ic);
189 }
[1796]190 delete _casterEph;
[816]191 delete _logStream;
[812]192 delete _logFile;
[1072]193 delete _echoStream;
194 delete _echoFile;
[779]195 QMapIterator<QString, t_ephPair*> it(_ephList);
196 while (it.hasNext()) {
197 it.next();
198 delete it.value();
199 }
[849]200 delete _rnx;
201 delete _sp3;
[756]202}
203
[763]204// Delete bns thread
205////////////////////////////////////////////////////////////////////////////
206void t_bns::deleteBnsEph() {
207 if (_bnseph) {
208 _bnseph->terminate();
[764]209 _bnseph->wait(100);
[763]210 delete _bnseph;
211 _bnseph = 0;
212 }
213}
214
[756]215// Write a Program Message
216////////////////////////////////////////////////////////////////////////////
[758]217void t_bns::slotMessage(const QByteArray msg) {
[816]218 if (_logStream) {
[1217]219 QString txt = QDateTime::currentDateTime().toUTC().toString("yy-MM-dd hh:mm:ss ");
220 *_logStream << txt << msg << endl;
[818]221 _logStream->flush();
[812]222 }
[757]223 emit(newMessage(msg));
[756]224}
225
[760]226// Write a Program Message
227////////////////////////////////////////////////////////////////////////////
228void t_bns::slotError(const QByteArray msg) {
[816]229 if (_logStream) {
230 *_logStream << msg << endl;
[818]231 _logStream->flush();
[812]232 }
[763]233 deleteBnsEph();
[760]234 emit(error(msg));
235}
236
[769]237// New Connection
238////////////////////////////////////////////////////////////////////////////
239void t_bns::slotNewConnection() {
[1208]240//slotMessage("t_bns::slotNewConnection");
241 slotMessage("Clocks & orbits port: Waiting for client to connect"); // weber
[787]242 delete _clkSocket;
[769]243 _clkSocket = _clkServer->nextPendingConnection();
244}
245
[784]246//
247////////////////////////////////////////////////////////////////////////////
[1058]248void t_bns::slotNewEph(t_eph* ep, int nBytes) {
[784]249
250 QMutexLocker locker(&_mutex);
251
[1058]252 emit(newEphBytes(nBytes));
253
[1801]254 // Output Ephemerides as they are
255 // ------------------------------
256 if (_casterEph) {
[1802]257 _casterEph->open();
[1867]258 unsigned char Array[67];
259 int size = ep->RTCM3(Array);
260 if (size > 0) {
261 _casterEph->write((char*) Array, size);
262 emit(newOutEphBytes(size));
[1803]263 }
[1867]264 //// QByteArray buffer = "New Ephemeris " + ep->prn().toAscii() + "\n";
265 //// _casterEph->write(buffer.data(), buffer.length());
266 //// int len = buffer.length();
267 //// if (len > 0) {
268 //// emit(newOutEphBytes(len));
269 //// }
[1801]270 }
271
[784]272 t_ephPair* pair;
[884]273 if ( !_ephList.contains(ep->prn()) ) {
[784]274 pair = new t_ephPair();
[884]275 _ephList.insert(ep->prn(), pair);
[784]276 }
277 else {
[884]278 pair = _ephList[ep->prn()];
[784]279 }
280
281 if (pair->eph == 0) {
282 pair->eph = ep;
283 }
284 else {
[884]285 if (ep->isNewerThan(pair->eph)) {
[784]286 delete pair->oldEph;
287 pair->oldEph = pair->eph;
288 pair->eph = ep;
289 }
290 else {
291 delete ep;
292 }
293 }
294}
295
[756]296// Start
297////////////////////////////////////////////////////////////////////////////
[757]298void t_bns::run() {
[769]299
[758]300 slotMessage("============ Start BNS ============");
[770]301
[828]302 // Start Thread that retrieves broadcast Ephemeris
303 // -----------------------------------------------
[758]304 _bnseph->start();
[769]305
[770]306 // Endless loop
307 // ------------
[769]308 while (true) {
[836]309
310 if (_clkSocket && _clkSocket->thread() != currentThread()) {
311 emit(moveSocket(currentThread()));
312 }
313
[796]314 if (_clkSocket && _clkSocket->state() == QAbstractSocket::ConnectedState) {
315 if ( _clkSocket->canReadLine()) {
316 readEpoch();
317 }
[809]318 else {
319 _clkSocket->waitForReadyRead(10);
320 }
[769]321 }
322 else {
[794]323 msleep(10);
[769]324 }
325 }
[756]326}
327
[778]328//
329////////////////////////////////////////////////////////////////////////////
[784]330void t_bns::readEpoch() {
[778]331
[1670]332 bnsSettings settings;
333
[1197]334 // Read the first line (if not already read)
335 // -----------------------------------------
336 if (_clkLine.indexOf('*') == -1) {
337 _clkLine = _clkSocket->readLine();
338 if (_echoStream) {
339 *_echoStream << _clkLine;
340 _echoStream->flush();
341 }
342 emit(newClkBytes(_clkLine.length()));
[1072]343 }
344
[1197]345 if (_clkLine.indexOf('*') == -1) {
[784]346 return;
[778]347 }
348
[1197]349 QTextStream in(_clkLine);
[784]350
351 QString hlp;
[1197]352 int year, month, day, hour, min;
353 double sec;
354 in >> hlp >> year >> month >> day >> hour >> min >> sec;
355
356 int GPSweek;
[798]357 double GPSweeks;
[784]358
[1197]359 GPSweekFromYMDhms(year, month, day, hour, min, sec, GPSweek, GPSweeks);
[784]360
[1197]361 QStringList prns;
[874]362
[1197]363 // Loop over all satellites
364 // ------------------------
365 QStringList lines;
366 for (;;) {
367 if (!_clkSocket->canReadLine()) {
[1198]368 break;
[1197]369 }
370 _clkLine = _clkSocket->readLine();
371 if (_echoStream) {
372 *_echoStream << _clkLine;
373 _echoStream->flush();
374 }
375 if (_clkLine[0] == '*') {
376 return;
377 }
378 if (_clkLine[0] == 'P') {
379 _clkLine.remove(0,1);
380 lines.push_back(_clkLine);
381 }
382 }
383
384 if (lines.size() > 0) {
385
[922]386 QStringList prns;
387
[1066]388 for (int ic = 0; ic < _caster.size(); ic++) {
389 _caster.at(ic)->open();
[927]390
[1066]391 for (int oldEph = 0; oldEph <= 0; oldEph++) { // TODO: handle old ephemeris
392
393 struct ClockOrbit co;
394 memset(&co, 0, sizeof(co));
395 co.GPSEpochTime = (int)GPSweeks;
[1838]396 co.GLONASSEpochTime = (int)fmod(GPSweeks, 86400.0)
397 + 3 * 3600 - gnumleap(year, month, day);
[1066]398 co.ClockDataSupplied = 1;
399 co.OrbitDataSupplied = 1;
400 co.SatRefDatum = DATUM_ITRF;
401
[2291]402 struct Bias bias;
403 memset(&bias, 0, sizeof(bias));
404 bias.GPSEpochTime = (int)GPSweeks;
405 bias.GLONASSEpochTime = (int)fmod(GPSweeks, 86400.0)
406 + 3 * 3600 - gnumleap(year, month, day);
407
[1197]408 for (int ii = 0; ii < lines.size(); ii++) {
409
[1066]410 QString prn;
[2294]411 ColumnVector xx(14); xx = 0.0;
[1066]412 t_eph* ep = 0;
413
[1075]414 if (oldEph == 0 && ic == 0) {
[1197]415 QTextStream in(lines[ii].toAscii());
[1066]416 in >> prn;
417 prns << prn;
418 if ( _ephList.contains(prn) ) {
[2046]419 in >> xx(1) >> xx(2) >> xx(3) >> xx(4) >> xx(5)
[2294]420 >> xx(6) >> xx(7) >> xx(8) >> xx(9) >> xx(10)
421 >> xx(11) >> xx(12) >> xx(13) >> xx(14);
[2046]422 xx(1) *= 1e3; // x-crd
423 xx(2) *= 1e3; // y-crd
424 xx(3) *= 1e3; // z-crd
425 xx(4) *= 1e-6; // clk
426 xx(5) *= 1e-6; // rel. corr.
427 // xx(6), xx(7), xx(8) ... PhaseCent - CoM
[2294]428 // xx(9) .. P1-C1 DCB, xx(10) ... P1-P2 DCB
429 // xx(11) ... dT
430 xx(12) *= 1e3; // x-crd at time + dT
431 xx(13) *= 1e3; // y-crd at time + dT
432 xx(14) *= 1e3; // z-crd at time + dT
[1670]433
[1066]434 t_ephPair* pair = _ephList[prn];
435 pair->xx = xx;
436 ep = pair->eph;
437 }
[872]438 }
[1066]439 else {
[1197]440 prn = prns[ii];
[1066]441 if ( _ephList.contains(prn) ) {
442 t_ephPair* pair = _ephList[prn];
443 prn = pair->eph->prn();
444 xx = pair->xx;
[1076]445 if (oldEph) {
446 ep = pair->oldEph;
447 }
448 else {
449 ep = pair->eph;
450 }
[1066]451 }
[873]452 }
[1066]453
454 if (ep != 0) {
455 struct ClockOrbit::SatData* sd = 0;
456 if (prn[0] == 'G') {
457 sd = co.Sat + co.NumberOfGPSSat;
458 ++co.NumberOfGPSSat;
459 }
460 else if (prn[0] == 'R') {
461 sd = co.Sat + CLOCKORBIT_NUMGPS + co.NumberOfGLONASSSat;
462 ++co.NumberOfGLONASSSat;
463 }
464 if (sd) {
465 QString outLine;
[1733]466 processSatellite(oldEph, ic, _caster.at(ic)->crdTrafo(),
[2046]467 _caster.at(ic)->CoM(), ep,
[1102]468 GPSweek, GPSweeks, prn, xx, sd, outLine);
[1074]469 _caster.at(ic)->printAscii(outLine);
[1066]470 }
[2291]471
472 struct Bias::BiasSat* biasSat = 0;
473 if (prn[0] == 'G') {
474 biasSat = bias.Sat + bias.NumberOfGPSSat;
475 ++bias.NumberOfGPSSat;
476 }
[2315]477// else if (prn[0] == 'R') {
478// biasSat = bias.Sat + CLOCKORBIT_NUMGPS + bias.NumberOfGLONASSSat;
479// ++bias.NumberOfGLONASSSat;
480// }
[2291]481
[2419]482 // Coefficient of Ionosphere-Free LC
483 // ---------------------------------
484 const static double a_L1_GPS = 2.54572778;
485 const static double a_L2_GPS = -1.54572778;
486 const static double a_L1_Glo = 2.53125000;
487 const static double a_L2_Glo = -1.53125000;
488
[2291]489 if (biasSat) {
[2314]490 biasSat->ID = prn.mid(1).toInt();
[2298]491 biasSat->NumberOfCodeBiases = 3;
[2314]492 if (prn[0] == 'G') {
[2364]493 biasSat->Biases[0].Type = CODETYPEGPS_L1_Z;
[2314]494 biasSat->Biases[0].Bias = 0.0;
495 biasSat->Biases[1].Type = CODETYPEGPS_L1_CA;
[2364]496 biasSat->Biases[1].Bias = xx(9) / 0.299792458; // IGS P1C1 DCB
497 biasSat->Biases[2].Type = CODETYPEGPS_L2_Z;
498 biasSat->Biases[2].Bias = xx(10) / 0.299792458; // IGS P1P2 DCB
[2314]499 }
500 else if (prn[0] == 'R') {
501 biasSat->Biases[0].Type = CODETYPEGLONASS_L1_P;
502 biasSat->Biases[0].Bias = 0.0;
503 biasSat->Biases[1].Type = CODETYPEGLONASS_L1_CA;
[2364]504 biasSat->Biases[1].Bias = xx(9) / 0.299792458; // IGS P1C1 DCB
[2314]505 biasSat->Biases[2].Type = CODETYPEGLONASS_L2_P;
[2364]506 biasSat->Biases[2].Bias = xx(10) / 0.299792458; // IGS P1P2 DCB
[2314]507 }
[2291]508 }
[1066]509 }
[873]510 }
[1066]511
[1123]512 if ( _caster.at(ic)->usedSocket() &&
[1066]513 (co.NumberOfGPSSat > 0 || co.NumberOfGLONASSSat > 0) ) {
514 char obuffer[CLOCKORBIT_BUFFERSIZE];
[2047]515
516 if (_caster.at(ic)->CoM()) {
517 co.SatRefPoint = POINT_CENTER;
518 }
519 else {
520 co.SatRefPoint = POINT_IONOFREE;
521 }
522
[1066]523 int len = MakeClockOrbit(&co, COTYPE_AUTO, 0, obuffer, sizeof(obuffer));
524 if (len > 0) {
[2349]525 if (_caster.at(ic)->ic() == 1) { emit(newOutBytes1(len));}
526 if (_caster.at(ic)->ic() == 2) { emit(newOutBytes2(len));}
527 if (_caster.at(ic)->ic() == 3) { emit(newOutBytes3(len));}
528 if (_caster.at(ic)->ic() == 4) { emit(newOutBytes4(len));}
529 if (_caster.at(ic)->ic() == 5) { emit(newOutBytes5(len));}
530 if (_caster.at(ic)->ic() == 6) { emit(newOutBytes6(len));}
531 if (_caster.at(ic)->ic() == 7) { emit(newOutBytes7(len));}
532 if (_caster.at(ic)->ic() == 8) { emit(newOutBytes8(len));}
533 if (_caster.at(ic)->ic() == 9) { emit(newOutBytes9(len));}
534 if (_caster.at(ic)->ic() == 10) { emit(newOutBytes10(len));}
[1066]535 _caster.at(ic)->write(obuffer, len);
[872]536 }
537 }
[2291]538
539 if ( _caster.at(ic)->usedSocket() &&
540 (bias.NumberOfGPSSat > 0 || bias.NumberOfGLONASSSat > 0) ) {
541 char obuffer[CLOCKORBIT_BUFFERSIZE];
542 int len = MakeBias(&bias, BTYPE_AUTO, 0, obuffer, sizeof(obuffer));
543 if (len > 0) {
544 _caster.at(ic)->write(obuffer, len);
545 }
546 }
[863]547 }
548 }
[780]549 }
[778]550}
[784]551
552//
553////////////////////////////////////////////////////////////////////////////
[1772]554void t_bns::processSatellite(int oldEph, int iCaster, const QString trafo,
[2046]555 bool CoM, t_eph* ep, int GPSweek,
[1733]556 double GPSweeks, const QString& prn,
[1066]557 const ColumnVector& xx,
[1065]558 struct ClockOrbit::SatData* sd,
559 QString& outLine) {
[784]560
[2294]561 const double secPerWeek = 7.0 * 86400.0;
[799]562
[2294]563 ColumnVector rsw(3);
564 ColumnVector rsw2(3);
565 double dClk;
[799]566
[2294]567 for (int ii = 1; ii <= 2; ++ii) {
[2046]568
[2294]569 int GPSweek12 = GPSweek;
570 double GPSweeks12 = GPSweeks;
571 if (ii == 2) {
572 GPSweeks12 += xx(11);
573 if (GPSweeks12 > secPerWeek) {
574 GPSweek12 += 1;
575 GPSweeks12 -= secPerWeek;
576 }
577 }
[2046]578
[2294]579 ColumnVector xB(4);
580 ColumnVector vv(3);
581
582 ep->position(GPSweek12, GPSweeks12, xB, vv);
583
584 ColumnVector xyz;
585 if (ii == 1) {
586 xyz = xx.Rows(1,3);
587 }
588 else {
589 xyz = xx.Rows(12,14);
590 }
591
592 // Correction Center of Mass -> Antenna Phase Center
593 // -------------------------------------------------
594 if (! CoM) {
595 xyz(1) += xx(6);
596 xyz(2) += xx(7);
597 xyz(3) += xx(8);
598 }
599
600 if (trafo != "IGS05") {
601 crdTrafo(GPSweek12, xyz, trafo);
602 }
603
[2418]604 ColumnVector dx = xB.Rows(1,3) - xyz ;
[2294]605
606 if (ii == 1) {
607 XYZ_to_RSW(xB.Rows(1,3), vv, dx, rsw);
[2417]608 dClk = (xx(4) + xx(5) - xB(4)) * 299792458.0;
[2294]609 }
610 else {
611 XYZ_to_RSW(xB.Rows(1,3), vv, dx, rsw2);
612 }
[984]613 }
[927]614
[863]615 if (sd) {
616 sd->ID = prn.mid(1).toInt();
[884]617 sd->IOD = ep->IOD();
[862]618 sd->Clock.DeltaA0 = dClk;
619 sd->Orbit.DeltaRadial = rsw(1);
620 sd->Orbit.DeltaAlongTrack = rsw(2);
621 sd->Orbit.DeltaCrossTrack = rsw(3);
[2294]622 sd->Orbit.DotDeltaRadial = (rsw2(1) - rsw(1)) / xx(11);
623 sd->Orbit.DotDeltaAlongTrack = (rsw2(2) - rsw(2)) / xx(11);
624 sd->Orbit.DotDeltaCrossTrack = (rsw2(3) - rsw(3)) / xx(11);
[863]625 }
[862]626
[1065]627 char oldCh = (oldEph ? '!' : ' ');
[2046]628 outLine.sprintf("%c %d %.1f %s %3d %10.3f %8.3f %8.3f %8.3f\n",
[1065]629 oldCh, GPSweek, GPSweeks, ep->prn().toAscii().data(),
[2046]630 ep->IOD(), dClk, rsw(1), rsw(2), rsw(3));
[1065]631
[1102]632 if (!oldEph && iCaster == 0) {
[923]633 if (_rnx) {
634 _rnx->write(GPSweek, GPSweeks, prn, xx);
635 }
636 if (_sp3) {
637 _sp3->write(GPSweek, GPSweeks, prn, xx);
638 }
[847]639 }
[784]640}
[836]641
642//
643////////////////////////////////////////////////////////////////////////////
644void t_bns::slotMoveSocket(QThread* tt) {
645 _clkSocket->setParent(0);
646 _clkSocket->moveToThread(tt);
[1209]647//slotMessage("bns::slotMoveSocket");
648 slotMessage("Clocks & orbits port: Socket moved to thread"); // weber
[836]649}
[984]650
[1772]651// Transform Coordinates
[984]652////////////////////////////////////////////////////////////////////////////
[1772]653void t_bns::crdTrafo(int GPSWeek, ColumnVector& xyz, const QString trafo) {
[984]654
[1772]655 bnsSettings settings;
656
657 if (trafo == "ETRF2000") {
[2333]658 _dx = 0.0541;
659 _dy = 0.0502;
660 _dz = -0.0538;
661 _dxr = -0.0002;
662 _dyr = 0.0001;
663 _dzr = -0.0018;
[1776]664 _ox = 0.000891;
665 _oy = 0.005390;
666 _oz = -0.008712;
667 _oxr = 0.000081;
668 _oyr = 0.000490;
669 _ozr = -0.000792;
[2333]670 _sc = 0.40;
671 _scr = 0.08;
672 _t0 = 2000.0;
[1772]673 }
[2327]674 else if (trafo == "NAD83") {
[2335]675 _dx = 0.9963;
676 _dy = -1.9024;
677 _dz = -0.5210;
678 _dxr = 0.0005;
679 _dyr = -0.0006;
680 _dzr = -0.0013;
[2333]681 _ox = 0.025915;
682 _oy = 0.009426;
683 _oz = 0.011599;
684 _oxr = 0.000067;
685 _oyr = -0.000757;
686 _ozr = -0.000051;
[2335]687 _sc = 0.78;
688 _scr = -0.10;
[2333]689 _t0 = 1997.0;
[2327]690 }
[2333]691 else if (trafo == "GDA94") {
[2351]692 _dx = 0.07167;
693 _dy = 0.00486;
694 _dz = -0.04711;
695 _dxr = -0.00342;
696 _dyr = 0.00055;
697 _dzr = 0.00136;
698 _ox = 0.0091362;
699 _oy = 0.0093086;
700 _oz = 0.0091599;
701 _oxr = 0.0014652;
702 _oyr = 0.0011005;
703 _ozr = 0.0011480;
704 _sc = -8.239;
705 _scr = -0.212;
706 _t0 = 2000.0;
[2333]707 }
[2347]708 else if (trafo == "SIRGAS2000") {
[2350]709 _dx = -0.0051;
710 _dy = -0.0065;
711 _dz = -0.0099;
[2347]712 _dxr = 0.0000;
713 _dyr = 0.0000;
714 _dzr = 0.0000;
715 _ox = 0.000150;
716 _oy = 0.000020;
717 _oz = 0.000021;
718 _oxr = 0.000000;
719 _oyr = 0.000000;
720 _ozr = 0.000000;
721 _sc = 0.000;
722 _scr = 0.000;
723 _t0 = 0000.0;
724 }
[2359]725 else if (trafo == "SIRGAS95") {
726 _dx = 0.0077;
727 _dy = 0.0058;
728 _dz = -0.0138;
729 _dxr = 0.0000;
730 _dyr = 0.0000;
731 _dzr = 0.0000;
732 _ox = 0.000000;
733 _oy = 0.000000;
[2361]734 _oz = -0.000030;
[2359]735 _oxr = 0.000000;
736 _oyr = 0.000000;
737 _ozr = 0.000000;
[2361]738 _sc = 1.570;
[2359]739 _scr = 0.000;
[2369]740 _t0 = 0000.0;
[2359]741 }
[1772]742 else if (trafo == "Custom") {
[1776]743 _dx = settings.value("trafo_dx").toDouble();
744 _dy = settings.value("trafo_dy").toDouble();
745 _dz = settings.value("trafo_dz").toDouble();
746 _dxr = settings.value("trafo_dxr").toDouble();
747 _dyr = settings.value("trafo_dyr").toDouble();
748 _dzr = settings.value("trafo_dzr").toDouble();
749 _ox = settings.value("trafo_ox").toDouble();
750 _oy = settings.value("trafo_oy").toDouble();
751 _oz = settings.value("trafo_oz").toDouble();
752 _oxr = settings.value("trafo_oxr").toDouble();
753 _oyr = settings.value("trafo_oyr").toDouble();
754 _ozr = settings.value("trafo_ozr").toDouble();
755 _sc = settings.value("trafo_sc").toDouble();
756 _scr = settings.value("trafo_scr").toDouble();
757 _t0 = settings.value("trafo_t0").toDouble();
[1772]758 }
759
[1243]760 // Current epoch minus 2000.0 in years
761 // ------------------------------------
[1772]762 double dt = (GPSWeek - (1042.0+6.0/7.0)) / 365.2422 * 7.0 + 2000.0 - _t0;
[1243]763
[985]764 ColumnVector dx(3);
[1243]765
[1772]766 dx(1) = _dx + dt * _dxr;
767 dx(2) = _dy + dt * _dyr;
768 dx(3) = _dz + dt * _dzr;
769
[1100]770 static const double arcSec = 180.0 * 3600.0 / M_PI;
[984]771
[1772]772 double ox = (_ox + dt * _oxr) / arcSec;
773 double oy = (_oy + dt * _oyr) / arcSec;
774 double oz = (_oz + dt * _ozr) / arcSec;
[1243]775
[1772]776 double sc = 1.0 + _sc * 1e-9 + dt * _scr * 1e-9;
777
[1245]778 Matrix rMat(3,3);
779 rMat(1,1) = 1.0;
[985]780 rMat(1,2) = -oz;
781 rMat(1,3) = oy;
782 rMat(2,1) = oz;
[1245]783 rMat(2,2) = 1.0;
[985]784 rMat(2,3) = -ox;
785 rMat(3,1) = -oy;
786 rMat(3,2) = ox;
[1245]787 rMat(3,3) = 1.0;
[985]788
[1245]789 xyz = sc * rMat * xyz + dx;
[984]790}
Note: See TracBrowser for help on using the repository browser.