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

Last change on this file since 1944 was 1867, checked in by mervart, 15 years ago

* empty log message *
File size: 16.6 KB
Line 
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
17#include <math.h>
18#include <iostream>
19#include <newmatio.h>
20
21#include "bns.h"
22#include "bnsutils.h"
23#include "bnsrinex.h"
24#include "bnssp3.h"
25#include "bnssettings.h"
26extern "C" {
27#include "RTCM/rtcm3torinex.h"
28}
29
30using namespace std;
31
32// Error Handling
33////////////////////////////////////////////////////////////////////////////
34void RTCM3Error(const char*, ...) {
35}
36
37// Constructor
38////////////////////////////////////////////////////////////////////////////
39t_bns::t_bns(QObject* parent) : QThread(parent) {
40
41 this->setTerminationEnabled(true);
42
43 connect(this, SIGNAL(moveSocket(QThread*)),
44 this, SLOT(slotMoveSocket(QThread*)));
45
46 bnsSettings settings;
47
48 // Set Proxy (application-wide)
49 // ----------------------------
50 QString proxyHost = settings.value("proxyHost").toString();
51 int proxyPort = settings.value("proxyPort").toInt();
52
53 QNetworkProxy proxy;
54 if (proxyHost.isEmpty()) {
55 proxy.setType(QNetworkProxy::NoProxy);
56 }
57 else {
58 proxy.setType(QNetworkProxy::Socks5Proxy);
59 proxy.setHostName(proxyHost);
60 proxy.setPort(proxyPort);
61 }
62 QNetworkProxy::setApplicationProxy(proxy);
63
64 // Thread that handles broadcast ephemeris
65 // ---------------------------------------
66 _bnseph = new t_bnseph(parent);
67
68 connect(_bnseph, SIGNAL(newEph(t_eph*, int)),
69 this, SLOT(slotNewEph(t_eph*, int)));
70 connect(_bnseph, SIGNAL(newMessage(QByteArray)),
71 this, SLOT(slotMessage(const QByteArray)));
72 connect(_bnseph, SIGNAL(error(QByteArray)),
73 this, SLOT(slotError(const QByteArray)));
74
75 // Server listening for rtnet results
76 // ----------------------------------
77 _clkSocket = 0;
78 _clkServer = new QTcpServer;
79 _clkServer->listen(QHostAddress::Any, settings.value("clkPort").toInt());
80 connect(_clkServer, SIGNAL(newConnection()),this, SLOT(slotNewConnection()));
81
82 // Socket and file for outputting the results
83 // -------------------------------------------
84 for (int ic = 1; ic <= 3; ic++) {
85 QString mountpoint = settings.value(QString("mountpoint_%1").arg(ic)).toString();
86 QString outFileName = settings.value(QString("outFile_%1").arg(ic)).toString();
87 if (!mountpoint.isEmpty() || !outFileName.isEmpty()) {
88 _caster.push_back(new t_bnscaster(mountpoint, outFileName, ic));
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 }
94 }
95
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);
104 connect(_casterEph, SIGNAL(error(const QByteArray)),
105 this, SLOT(slotError(const QByteArray)));
106 connect(_casterEph, SIGNAL(newMessage(const QByteArray)),
107 this, SLOT(slotMessage(const QByteArray)));
108 }
109
110 // Log File
111 // --------
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
120 QString logFileName = settings.value("logFile").toString();
121 if (logFileName.isEmpty()) {
122 _logFile = 0;
123 _logStream = 0;
124 }
125 else {
126 _logFile = new QFile(logFileName);
127 if (_logFile->open(oMode)) {
128 _logStream = new QTextStream(_logFile);
129 }
130 else {
131 _logStream = 0;
132 }
133 }
134
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
152 // RINEX writer
153 // ------------
154 if ( settings.value("rnxPath").toString().isEmpty() ) {
155 _rnx = 0;
156 }
157 else {
158 QString prep = "BNS";
159 QString ext = ".clk";
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);
164 }
165
166 // SP3 writer
167 // ----------
168 if ( settings.value("sp3Path").toString().isEmpty() ) {
169 _sp3 = 0;
170 }
171 else {
172 QString prep = "BNS";
173 QString ext = ".sp3";
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);
178 }
179}
180
181// Destructor
182////////////////////////////////////////////////////////////////////////////
183t_bns::~t_bns() {
184 deleteBnsEph();
185 delete _clkServer;
186 delete _clkSocket;
187 for (int ic = 0; ic < _caster.size(); ic++) {
188 delete _caster.at(ic);
189 }
190 delete _casterEph;
191 delete _logStream;
192 delete _logFile;
193 delete _echoStream;
194 delete _echoFile;
195 QMapIterator<QString, t_ephPair*> it(_ephList);
196 while (it.hasNext()) {
197 it.next();
198 delete it.value();
199 }
200 delete _rnx;
201 delete _sp3;
202}
203
204// Delete bns thread
205////////////////////////////////////////////////////////////////////////////
206void t_bns::deleteBnsEph() {
207 if (_bnseph) {
208 _bnseph->terminate();
209 _bnseph->wait(100);
210 delete _bnseph;
211 _bnseph = 0;
212 }
213}
214
215// Write a Program Message
216////////////////////////////////////////////////////////////////////////////
217void t_bns::slotMessage(const QByteArray msg) {
218 if (_logStream) {
219 QString txt = QDateTime::currentDateTime().toUTC().toString("yy-MM-dd hh:mm:ss ");
220 *_logStream << txt << msg << endl;
221 _logStream->flush();
222 }
223 emit(newMessage(msg));
224}
225
226// Write a Program Message
227////////////////////////////////////////////////////////////////////////////
228void t_bns::slotError(const QByteArray msg) {
229 if (_logStream) {
230 *_logStream << msg << endl;
231 _logStream->flush();
232 }
233 deleteBnsEph();
234 emit(error(msg));
235}
236
237// New Connection
238////////////////////////////////////////////////////////////////////////////
239void t_bns::slotNewConnection() {
240//slotMessage("t_bns::slotNewConnection");
241 slotMessage("Clocks & orbits port: Waiting for client to connect"); // weber
242 delete _clkSocket;
243 _clkSocket = _clkServer->nextPendingConnection();
244}
245
246//
247////////////////////////////////////////////////////////////////////////////
248void t_bns::slotNewEph(t_eph* ep, int nBytes) {
249
250 QMutexLocker locker(&_mutex);
251
252 emit(newEphBytes(nBytes));
253
254 // Output Ephemerides as they are
255 // ------------------------------
256 if (_casterEph) {
257 _casterEph->open();
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));
263 }
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 //// }
270 }
271
272 t_ephPair* pair;
273 if ( !_ephList.contains(ep->prn()) ) {
274 pair = new t_ephPair();
275 _ephList.insert(ep->prn(), pair);
276 }
277 else {
278 pair = _ephList[ep->prn()];
279 }
280
281 if (pair->eph == 0) {
282 pair->eph = ep;
283 }
284 else {
285 if (ep->isNewerThan(pair->eph)) {
286 delete pair->oldEph;
287 pair->oldEph = pair->eph;
288 pair->eph = ep;
289 }
290 else {
291 delete ep;
292 }
293 }
294}
295
296// Start
297////////////////////////////////////////////////////////////////////////////
298void t_bns::run() {
299
300 slotMessage("============ Start BNS ============");
301
302 // Start Thread that retrieves broadcast Ephemeris
303 // -----------------------------------------------
304 _bnseph->start();
305
306 // Endless loop
307 // ------------
308 while (true) {
309
310 if (_clkSocket && _clkSocket->thread() != currentThread()) {
311 emit(moveSocket(currentThread()));
312 }
313
314 if (_clkSocket && _clkSocket->state() == QAbstractSocket::ConnectedState) {
315 if ( _clkSocket->canReadLine()) {
316 readEpoch();
317 }
318 else {
319 _clkSocket->waitForReadyRead(10);
320 }
321 }
322 else {
323 msleep(10);
324 }
325 }
326}
327
328//
329////////////////////////////////////////////////////////////////////////////
330void t_bns::readEpoch() {
331
332 bnsSettings settings;
333
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()));
343 }
344
345 if (_clkLine.indexOf('*') == -1) {
346 return;
347 }
348
349 QTextStream in(_clkLine);
350
351 QString hlp;
352 int year, month, day, hour, min;
353 double sec;
354 in >> hlp >> year >> month >> day >> hour >> min >> sec;
355
356 int GPSweek;
357 double GPSweeks;
358
359 GPSweekFromYMDhms(year, month, day, hour, min, sec, GPSweek, GPSweeks);
360
361 QStringList prns;
362
363 // Loop over all satellites
364 // ------------------------
365 QStringList lines;
366 for (;;) {
367 if (!_clkSocket->canReadLine()) {
368 break;
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
386 QStringList prns;
387
388 for (int ic = 0; ic < _caster.size(); ic++) {
389 _caster.at(ic)->open();
390
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;
396 co.GLONASSEpochTime = (int)fmod(GPSweeks, 86400.0)
397 + 3 * 3600 - gnumleap(year, month, day);
398 co.ClockDataSupplied = 1;
399 co.OrbitDataSupplied = 1;
400 co.SatRefPoint = POINT_CENTER;
401 co.SatRefDatum = DATUM_ITRF;
402
403 for (int ii = 0; ii < lines.size(); ii++) {
404
405 QString prn;
406 ColumnVector xx(5); xx = 0.0;
407 t_eph* ep = 0;
408
409 if (oldEph == 0 && ic == 0) {
410 QTextStream in(lines[ii].toAscii());
411 in >> prn;
412 prns << prn;
413 if ( _ephList.contains(prn) ) {
414 in >> xx(1) >> xx(2) >> xx(3) >> xx(4) >> xx(5);
415 xx(1) *= 1e3;
416 xx(2) *= 1e3;
417 xx(3) *= 1e3;
418 xx(4) *= 1e-6;
419 xx(5) *= 1e-6;
420
421 t_ephPair* pair = _ephList[prn];
422 pair->xx = xx;
423 ep = pair->eph;
424 }
425 }
426 else {
427 prn = prns[ii];
428 if ( _ephList.contains(prn) ) {
429 t_ephPair* pair = _ephList[prn];
430 prn = pair->eph->prn();
431 xx = pair->xx;
432 if (oldEph) {
433 ep = pair->oldEph;
434 }
435 else {
436 ep = pair->eph;
437 }
438 }
439 }
440
441 if (ep != 0) {
442 struct ClockOrbit::SatData* sd = 0;
443 if (prn[0] == 'G') {
444 sd = co.Sat + co.NumberOfGPSSat;
445 ++co.NumberOfGPSSat;
446 }
447 else if (prn[0] == 'R') {
448 sd = co.Sat + CLOCKORBIT_NUMGPS + co.NumberOfGLONASSSat;
449 ++co.NumberOfGLONASSSat;
450 }
451 if (sd) {
452 QString outLine;
453 processSatellite(oldEph, ic, _caster.at(ic)->crdTrafo(),
454 _caster.at(ic)->beClocks(), ep,
455 GPSweek, GPSweeks, prn, xx, sd, outLine);
456 _caster.at(ic)->printAscii(outLine);
457 }
458 }
459 }
460
461 if ( _caster.at(ic)->usedSocket() &&
462 (co.NumberOfGPSSat > 0 || co.NumberOfGLONASSSat > 0) ) {
463 char obuffer[CLOCKORBIT_BUFFERSIZE];
464 int len = MakeClockOrbit(&co, COTYPE_AUTO, 0, obuffer, sizeof(obuffer));
465 if (len > 0) {
466 if (_caster.at(ic)->ic() == 1) { emit(newOutBytes1(len));}
467 if (_caster.at(ic)->ic() == 2) { emit(newOutBytes2(len));}
468 if (_caster.at(ic)->ic() == 3) { emit(newOutBytes3(len));}
469 _caster.at(ic)->write(obuffer, len);
470 }
471 }
472 }
473 }
474 }
475}
476
477//
478////////////////////////////////////////////////////////////////////////////
479void t_bns::processSatellite(int oldEph, int iCaster, const QString trafo,
480 bool beClocks, t_eph* ep, int GPSweek,
481 double GPSweeks, const QString& prn,
482 const ColumnVector& xx,
483 struct ClockOrbit::SatData* sd,
484 QString& outLine) {
485
486 ColumnVector xB(4);
487 ColumnVector vv(3);
488
489 ep->position(GPSweek, GPSweeks, xB, vv);
490
491 ColumnVector xyz = xx.Rows(1,3);
492 if (trafo != "IGS05") {
493 crdTrafo(GPSweek, xyz, trafo);
494 }
495
496 ColumnVector dx = xyz - xB.Rows(1,3);
497
498 ColumnVector rsw(3);
499 XYZ_to_RSW(xB.Rows(1,3), vv, dx, rsw);
500
501 double dClk;
502 if (beClocks) {
503 dClk = (xx(4) - xB(4) - xx(5)) * 299792458.0;
504 }
505 else {
506 dClk = (xx(4) - xB(4)) * 299792458.0;
507 }
508
509 if (sd) {
510 sd->ID = prn.mid(1).toInt();
511 sd->IOD = ep->IOD();
512 sd->Clock.DeltaA0 = dClk;
513 sd->Orbit.DeltaRadial = rsw(1);
514 sd->Orbit.DeltaAlongTrack = rsw(2);
515 sd->Orbit.DeltaCrossTrack = rsw(3);
516 }
517
518 char oldCh = (oldEph ? '!' : ' ');
519 outLine.sprintf("%c %d %.1f %s %3d %10.3f %8.3f %8.3f %8.3f\n",
520 oldCh, GPSweek, GPSweeks, ep->prn().toAscii().data(),
521 ep->IOD(), dClk, rsw(1), rsw(2), rsw(3));
522
523 if (!oldEph && iCaster == 0) {
524 if (_rnx) {
525 _rnx->write(GPSweek, GPSweeks, prn, xx);
526 }
527 if (_sp3) {
528 _sp3->write(GPSweek, GPSweeks, prn, xx);
529 }
530 }
531}
532
533//
534////////////////////////////////////////////////////////////////////////////
535void t_bns::slotMoveSocket(QThread* tt) {
536 _clkSocket->setParent(0);
537 _clkSocket->moveToThread(tt);
538//slotMessage("bns::slotMoveSocket");
539 slotMessage("Clocks & orbits port: Socket moved to thread"); // weber
540}
541
542// Transform Coordinates
543////////////////////////////////////////////////////////////////////////////
544void t_bns::crdTrafo(int GPSWeek, ColumnVector& xyz, const QString trafo) {
545
546 bnsSettings settings;
547
548 if (trafo == "ETRF2000") {
549 _dx = 0.0541;
550 _dy = 0.0502;
551 _dz = -0.0538;
552 _dxr = -0.0002;
553 _dyr = 0.0001;
554 _dzr = -0.0018;
555 _ox = 0.000891;
556 _oy = 0.005390;
557 _oz = -0.008712;
558 _oxr = 0.000081;
559 _oyr = 0.000490;
560 _ozr = -0.000792;
561 _sc = 0.40;
562 _scr = 0.08;
563 _t0 = 2000.0;
564 }
565 else if (trafo == "Custom") {
566 _dx = settings.value("trafo_dx").toDouble();
567 _dy = settings.value("trafo_dy").toDouble();
568 _dz = settings.value("trafo_dz").toDouble();
569 _dxr = settings.value("trafo_dxr").toDouble();
570 _dyr = settings.value("trafo_dyr").toDouble();
571 _dzr = settings.value("trafo_dzr").toDouble();
572 _ox = settings.value("trafo_ox").toDouble();
573 _oy = settings.value("trafo_oy").toDouble();
574 _oz = settings.value("trafo_oz").toDouble();
575 _oxr = settings.value("trafo_oxr").toDouble();
576 _oyr = settings.value("trafo_oyr").toDouble();
577 _ozr = settings.value("trafo_ozr").toDouble();
578 _sc = settings.value("trafo_sc").toDouble();
579 _scr = settings.value("trafo_scr").toDouble();
580 _t0 = settings.value("trafo_t0").toDouble();
581 }
582
583 // Current epoch minus 2000.0 in years
584 // ------------------------------------
585 double dt = (GPSWeek - (1042.0+6.0/7.0)) / 365.2422 * 7.0 + 2000.0 - _t0;
586
587 ColumnVector dx(3);
588
589 dx(1) = _dx + dt * _dxr;
590 dx(2) = _dy + dt * _dyr;
591 dx(3) = _dz + dt * _dzr;
592
593 static const double arcSec = 180.0 * 3600.0 / M_PI;
594
595 double ox = (_ox + dt * _oxr) / arcSec;
596 double oy = (_oy + dt * _oyr) / arcSec;
597 double oz = (_oz + dt * _ozr) / arcSec;
598
599 double sc = 1.0 + _sc * 1e-9 + dt * _scr * 1e-9;
600
601 Matrix rMat(3,3);
602 rMat(1,1) = 1.0;
603 rMat(1,2) = -oz;
604 rMat(1,3) = oy;
605 rMat(2,1) = oz;
606 rMat(2,2) = 1.0;
607 rMat(2,3) = -ox;
608 rMat(3,1) = -oy;
609 rMat(3,2) = ox;
610 rMat(3,3) = 1.0;
611
612 xyz = sc * rMat * xyz + dx;
613}
Note: See TracBrowser for help on using the repository browser.