10 |
// |
// |
11 |
#include <TFile.h> |
#include <TFile.h> |
12 |
#include <TTree.h> |
#include <TTree.h> |
13 |
|
#include <TTimeStamp.h> |
14 |
#include <EventHeader.h> |
#include <EventHeader.h> |
15 |
#include <PscuHeader.h> |
#include <PscuHeader.h> |
16 |
// |
// |
374 |
|
|
375 |
} |
} |
376 |
|
|
377 |
|
/** |
378 |
|
* This method delete the run from the "FromTable" table and store it in the GL_RUN_TRASH table |
379 |
|
* If IDRUN is 0 "this->ID" run is used. |
380 |
|
* |
381 |
|
**/ |
382 |
|
Int_t GL_RUN::DeleteRun(TSQLServer *dbc,UInt_t IDRUN,TString FromTable){ |
383 |
|
// MySQL variables |
384 |
|
TSQLResult *pResult; |
385 |
|
TSQLRow *Row; |
386 |
|
stringstream myquery; |
387 |
|
// |
388 |
|
if ( !IDRUN ) IDRUN = ID; |
389 |
|
if ( !IDRUN ) return 1; |
390 |
|
// ---------------- |
391 |
|
myquery.str(""); |
392 |
|
myquery << " INSERT INTO GL_RUN_TRASH ("; |
393 |
|
myquery << "ID"; |
394 |
|
myquery << ",ID_RUN_FRAG"; |
395 |
|
myquery << ",ID_ROOT_L0"; |
396 |
|
myquery << ",ID_ROOT_L2"; |
397 |
|
myquery << ",RUNHEADER_TIME"; |
398 |
|
myquery << ",RUNTRAILER_TIME"; |
399 |
|
myquery << ",RUNHEADER_OBT"; |
400 |
|
myquery << ",RUNTRAILER_OBT"; |
401 |
|
myquery << ",RUNHEADER_PKT"; |
402 |
|
myquery << ",RUNTRAILER_PKT"; |
403 |
|
myquery << ",BOOT_NUMBER"; |
404 |
|
myquery << ",EV_FROM"; |
405 |
|
myquery << ",EV_TO"; |
406 |
|
myquery << ",NEVENTS"; |
407 |
|
myquery << ",PKT_COUNTER"; |
408 |
|
myquery << ",PKT_READY_COUNTER"; |
409 |
|
myquery << ",COMPILATIONTIMESTAMP"; |
410 |
|
myquery << ",FAV_WRK_SCHEDULE"; |
411 |
|
myquery << ",EFF_WRK_SCHEDULE"; |
412 |
|
myquery << ",PRH_VAR_TRG_MODE_A"; |
413 |
|
myquery << ",PRH_VAR_TRG_MODE_B"; |
414 |
|
myquery << ",ACQ_BUILD_INFO"; |
415 |
|
myquery << ",ACQ_VAR_INFO"; |
416 |
|
myquery << ",RM_ACQ_AFTER_CALIB"; |
417 |
|
myquery << ",RM_ACQ_SETTING_MODE"; |
418 |
|
myquery << ",TRK_CALIB_USED"; |
419 |
|
myquery << ",CAL_DSP_MASK"; |
420 |
|
myquery << ",LAST_TIMESYNC"; |
421 |
|
myquery << ",OBT_TIMESYNC"; |
422 |
|
myquery << ",VALIDATION"; |
423 |
|
myquery << ",INSERT_TIME"; |
424 |
|
myquery << ") SELECT * FROM "; |
425 |
|
myquery << FromTable.Data(); |
426 |
|
myquery << " WHERE ID="; |
427 |
|
myquery << (UInt_t)IDRUN << ";"; |
428 |
|
// |
429 |
|
// printf("1myquery is %s \n",myquery.str().c_str()); |
430 |
|
// |
431 |
|
dbc->Query(myquery.str().c_str()); |
432 |
|
// |
433 |
|
// retrieve this ID_TRASH |
434 |
|
// |
435 |
|
myquery.str(""); |
436 |
|
myquery << " SELECT ID_TRASH,ID_ROOT_L0,ID_ROOT_L2 FROM GL_RUN_TRASH ORDER BY ID_TRASH DESC LIMIT 1"; |
437 |
|
pResult = dbc->Query(myquery.str().c_str()); |
438 |
|
// |
439 |
|
UInt_t idtrash = 0; |
440 |
|
UInt_t idl0 = 0; |
441 |
|
UInt_t idl2 = 0; |
442 |
|
// |
443 |
|
Row = pResult->Next(); |
444 |
|
if( Row != NULL ){ |
445 |
|
idtrash = (UInt_t)atoll(Row->GetField(0)); |
446 |
|
idl0 = (UInt_t)atoll(Row->GetField(1)); |
447 |
|
idl2 = (UInt_t)atoll(Row->GetField(2)); |
448 |
|
}; |
449 |
|
// |
450 |
|
TString fileL0 = ""; |
451 |
|
TString fileL2 = ""; |
452 |
|
myquery.str(""); |
453 |
|
myquery << " SELECT NAME FROM GL_ROOT WHERE ID="; |
454 |
|
myquery << idl0 << ";"; |
455 |
|
// |
456 |
|
// printf("2myquery is %s \n",myquery.str().c_str()); |
457 |
|
// |
458 |
|
pResult = dbc->Query(myquery.str().c_str()); |
459 |
|
// |
460 |
|
Row = pResult->Next(); |
461 |
|
if( Row != NULL ){ |
462 |
|
fileL0 = (TString)Row->GetField(0); |
463 |
|
}; |
464 |
|
// |
465 |
|
// |
466 |
|
// |
467 |
|
myquery.str(""); |
468 |
|
myquery << " SELECT NAME FROM GL_ROOT WHERE ID="; |
469 |
|
myquery << idl2 << ";"; |
470 |
|
// |
471 |
|
// printf("3myquery is %s \n",myquery.str().c_str()); |
472 |
|
// |
473 |
|
pResult = dbc->Query(myquery.str().c_str()); |
474 |
|
// |
475 |
|
Row = pResult->Next(); |
476 |
|
if( Row != NULL ){ |
477 |
|
fileL2 = (TString)Row->GetField(0); |
478 |
|
}; |
479 |
|
// |
480 |
|
// |
481 |
|
// |
482 |
|
myquery.str(""); |
483 |
|
myquery << " UPDATE GL_RUN_TRASH SET FILENAMEL0='"; |
484 |
|
myquery << fileL0.Data() << "' where ID_TRASH="; |
485 |
|
myquery << idtrash << ";"; |
486 |
|
// |
487 |
|
// printf("4myquery is %s \n",myquery.str().c_str()); |
488 |
|
// |
489 |
|
dbc->Query(myquery.str().c_str()); |
490 |
|
// |
491 |
|
myquery.str(""); |
492 |
|
myquery << " UPDATE GL_RUN_TRASH SET FILENAMEL2='"; |
493 |
|
myquery << fileL2.Data() << "' where ID_TRASH="; |
494 |
|
myquery << idtrash << ";"; |
495 |
|
// |
496 |
|
// printf("4myquery is %s \n",myquery.str().c_str()); |
497 |
|
// |
498 |
|
dbc->Query(myquery.str().c_str()); |
499 |
|
// |
500 |
|
myquery.str(""); |
501 |
|
myquery << " UPDATE GL_RUN_TRASH SET BELONGED_TO='"; |
502 |
|
myquery << FromTable.Data() << "' where ID_TRASH="; |
503 |
|
myquery << idtrash << ";"; |
504 |
|
// |
505 |
|
// printf("4myquery is %s \n",myquery.str().c_str()); |
506 |
|
// |
507 |
|
// |
508 |
|
dbc->Query(myquery.str().c_str()); |
509 |
|
// |
510 |
|
myquery.str(""); |
511 |
|
myquery << " DELETE FROM "; |
512 |
|
myquery << FromTable.Data() << " where ID="; |
513 |
|
myquery << IDRUN << ";"; |
514 |
|
// |
515 |
|
// printf("5myquery is %s \n",myquery.str().c_str()); |
516 |
|
// |
517 |
|
// |
518 |
|
dbc->Query(myquery.str().c_str()); |
519 |
|
// |
520 |
|
return 0; |
521 |
|
}; |
522 |
|
|
523 |
|
|
524 |
|
|
525 |
|
/** |
526 |
|
* This method restore a run from the GL_RUN_TRASH table. |
527 |
|
* If ID is 0 "this->ID" is used; if "ToTable" is empty BELONG_TO field of GL_RUN_TRASH is used. |
528 |
|
* |
529 |
|
**/ |
530 |
|
Int_t GL_RUN::RestoreRun(TSQLServer *dbc,UInt_t IDRUN,TString ToTable){ |
531 |
|
// insert into GL_RUN_FRAGMENTS select * FROM GL_RUN where ID=11; |
532 |
|
//insert into GL_RUN_TRASH VALUES (ID , ID_RUN_FRAG , ID_ROOT_L0 , ID_ROOT_L2 , RUNHEADER_TIME , RUNTRAILER_TIME , RUNHEADER_OBT , RUNTRAILER_OBT , RUNHEADER_PKT , RUNTRAILER_PKT , BOOT_NUMBER , EV_FROM , EV_TO , NEVENTS , PKT_COUNTER , PKT_READY_COUNTER , COMPILATIONTIMESTAMP , FAV_WRK_SCHEDULE , EFF_WRK_SCHEDULE , PRH_VAR_TRG_MODE_A , PRH_VAR_TRG_MODE_B , ACQ_BUILD_INFO , ACQ_VAR_INFO , RM_ACQ_AFTER_CALIB , RM_ACQ_SETTING_MODE, TRK_CALIB_USED,CAL_DSP_MASK, LAST_TIMESYNC, OBT_TIMESYNC, VALIDATION, INSERT_TIME) select * FROM GL_RUN where ID=11; |
533 |
|
// MySQL variables |
534 |
|
TSQLResult *pResult; |
535 |
|
TSQLRow *Row; |
536 |
|
stringstream myquery; |
537 |
|
// |
538 |
|
if ( !IDRUN ) IDRUN = ID; |
539 |
|
if ( !IDRUN ) return 1; |
540 |
|
// |
541 |
|
if ( !strcmp(ToTable.Data(),"") ){ |
542 |
|
// |
543 |
|
myquery.str(""); |
544 |
|
myquery << " SELECT BELONGED_TO FROM GL_RUN_TRASH WHERE ID="; |
545 |
|
myquery << (UInt_t)IDRUN << ";"; |
546 |
|
// |
547 |
|
printf(" qui? myquery is %s \n",myquery.str().c_str()); |
548 |
|
// |
549 |
|
pResult = dbc->Query(myquery.str().c_str()); |
550 |
|
// |
551 |
|
Row = pResult->Next(); |
552 |
|
if( Row != NULL ){ |
553 |
|
ToTable = (TString)Row->GetField(0); |
554 |
|
} else { |
555 |
|
return 1; |
556 |
|
}; |
557 |
|
}; |
558 |
|
// ---------------- |
559 |
|
myquery.str(""); |
560 |
|
myquery << " INSERT INTO "; |
561 |
|
myquery << ToTable.Data(); |
562 |
|
myquery << " ("; |
563 |
|
myquery << "ID"; |
564 |
|
myquery << ",ID_RUN_FRAG"; |
565 |
|
myquery << ",ID_ROOT_L0"; |
566 |
|
myquery << ",ID_ROOT_L2"; |
567 |
|
myquery << ",RUNHEADER_TIME"; |
568 |
|
myquery << ",RUNTRAILER_TIME"; |
569 |
|
myquery << ",RUNHEADER_OBT"; |
570 |
|
myquery << ",RUNTRAILER_OBT"; |
571 |
|
myquery << ",RUNHEADER_PKT"; |
572 |
|
myquery << ",RUNTRAILER_PKT"; |
573 |
|
myquery << ",BOOT_NUMBER"; |
574 |
|
myquery << ",EV_FROM"; |
575 |
|
myquery << ",EV_TO"; |
576 |
|
myquery << ",NEVENTS"; |
577 |
|
myquery << ",PKT_COUNTER"; |
578 |
|
myquery << ",PKT_READY_COUNTER"; |
579 |
|
myquery << ",COMPILATIONTIMESTAMP"; |
580 |
|
myquery << ",FAV_WRK_SCHEDULE"; |
581 |
|
myquery << ",EFF_WRK_SCHEDULE"; |
582 |
|
myquery << ",PRH_VAR_TRG_MODE_A"; |
583 |
|
myquery << ",PRH_VAR_TRG_MODE_B"; |
584 |
|
myquery << ",ACQ_BUILD_INFO"; |
585 |
|
myquery << ",ACQ_VAR_INFO"; |
586 |
|
myquery << ",RM_ACQ_AFTER_CALIB"; |
587 |
|
myquery << ",RM_ACQ_SETTING_MODE"; |
588 |
|
myquery << ",TRK_CALIB_USED"; |
589 |
|
myquery << ",CAL_DSP_MASK"; |
590 |
|
myquery << ",LAST_TIMESYNC"; |
591 |
|
myquery << ",OBT_TIMESYNC"; |
592 |
|
myquery << ",VALIDATION"; |
593 |
|
myquery << ",INSERT_TIME"; |
594 |
|
myquery << ") SELECT "; |
595 |
|
myquery << "ID"; |
596 |
|
myquery << ",ID_RUN_FRAG"; |
597 |
|
myquery << ",ID_ROOT_L0"; |
598 |
|
myquery << ",ID_ROOT_L2"; |
599 |
|
myquery << ",RUNHEADER_TIME"; |
600 |
|
myquery << ",RUNTRAILER_TIME"; |
601 |
|
myquery << ",RUNHEADER_OBT"; |
602 |
|
myquery << ",RUNTRAILER_OBT"; |
603 |
|
myquery << ",RUNHEADER_PKT"; |
604 |
|
myquery << ",RUNTRAILER_PKT"; |
605 |
|
myquery << ",BOOT_NUMBER"; |
606 |
|
myquery << ",EV_FROM"; |
607 |
|
myquery << ",EV_TO"; |
608 |
|
myquery << ",NEVENTS"; |
609 |
|
myquery << ",PKT_COUNTER"; |
610 |
|
myquery << ",PKT_READY_COUNTER"; |
611 |
|
myquery << ",COMPILATIONTIMESTAMP"; |
612 |
|
myquery << ",FAV_WRK_SCHEDULE"; |
613 |
|
myquery << ",EFF_WRK_SCHEDULE"; |
614 |
|
myquery << ",PRH_VAR_TRG_MODE_A"; |
615 |
|
myquery << ",PRH_VAR_TRG_MODE_B"; |
616 |
|
myquery << ",ACQ_BUILD_INFO"; |
617 |
|
myquery << ",ACQ_VAR_INFO"; |
618 |
|
myquery << ",RM_ACQ_AFTER_CALIB"; |
619 |
|
myquery << ",RM_ACQ_SETTING_MODE"; |
620 |
|
myquery << ",TRK_CALIB_USED"; |
621 |
|
myquery << ",CAL_DSP_MASK"; |
622 |
|
myquery << ",LAST_TIMESYNC"; |
623 |
|
myquery << ",OBT_TIMESYNC"; |
624 |
|
myquery << ",VALIDATION"; |
625 |
|
myquery << ",INSERT_TIME"; |
626 |
|
myquery << " FROM GL_RUN_TRASH "; |
627 |
|
myquery << " WHERE BELONGED_TO='GL_RUN_FRAGMENTS' AND ID="; |
628 |
|
myquery << (UInt_t)IDRUN << ";"; |
629 |
|
// |
630 |
|
// printf("5myquery is %s \n",myquery.str().c_str()); |
631 |
|
// |
632 |
|
dbc->Query(myquery.str().c_str()); |
633 |
|
// |
634 |
|
// |
635 |
|
myquery.str(""); |
636 |
|
myquery << " DELETE FROM GL_RUN_TRASH where BELONGED_TO='GL_RUN_FRAGMENTS' AND ID="; |
637 |
|
myquery << IDRUN << ";"; |
638 |
|
// |
639 |
|
dbc->Query(myquery.str().c_str()); |
640 |
|
// |
641 |
|
return 0; |
642 |
|
}; |
643 |
|
|
644 |
/** |
/** |
645 |
* Function to fill the GL_RUN table of the DB. |
* Function to fill the GL_RUN table of the DB. |
862 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
863 |
// Set_GL_RUN(Row); |
// Set_GL_RUN(Row); |
864 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
865 |
if (t== 0) ID = (UInt_t)atoll(Row->GetField(t)); |
if (t== 0) ID = (UInt_t)atoll(Row->GetField(t)); |
866 |
if (t== 1) ID_RUN_FRAG = (UInt_t)atoll(Row->GetField(t)); |
if (t== 1) ID_RUN_FRAG = (UInt_t)atoll(Row->GetField(t)); |
867 |
if (t== 2) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
if (t== 2) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
868 |
if (t== 3) ID_ROOT_L2 = (UInt_t)atoll(Row->GetField(t)); |
if (t== 3) ID_ROOT_L2 = (UInt_t)atoll(Row->GetField(t)); |
869 |
if (t== 4) RUNHEADER_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t== 4) RUNHEADER_TIME = (UInt_t)atoll(Row->GetField(t)); |
870 |
if (t== 5) RUNTRAILER_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t== 5) RUNTRAILER_TIME = (UInt_t)atoll(Row->GetField(t)); |
871 |
if (t== 6) RUNHEADER_OBT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 6) RUNHEADER_OBT = (UInt_t)atoll(Row->GetField(t)); |
872 |
if (t== 7) RUNTRAILER_OBT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 7) RUNTRAILER_OBT = (UInt_t)atoll(Row->GetField(t)); |
873 |
if (t== 8) RUNHEADER_PKT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 8) RUNHEADER_PKT = (UInt_t)atoll(Row->GetField(t)); |
874 |
if (t== 9) RUNTRAILER_PKT = (UInt_t)atoll(Row->GetField(t)); |
if (t== 9) RUNTRAILER_PKT = (UInt_t)atoll(Row->GetField(t)); |
875 |
if (t==10) EV_FROM = (UInt_t)atoll(Row->GetField(t)); |
if (t==10) EV_FROM = (UInt_t)atoll(Row->GetField(t)); |
876 |
if (t==11) EV_TO = (UInt_t)atoll(Row->GetField(t)); |
if (t==11) EV_TO = (UInt_t)atoll(Row->GetField(t)); |
877 |
if (t==12) NEVENTS = (UInt_t)atoll(Row->GetField(t)); |
if (t==12) NEVENTS = (UInt_t)atoll(Row->GetField(t)); |
878 |
if (t==13) LAST_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
if (t==13) LAST_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
879 |
if (t==14) OBT_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
if (t==14) OBT_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
880 |
if (t==15) COMPILATIONTIMESTAMP = (UInt_t)atoll(Row->GetField(t)); |
if (t==15) COMPILATIONTIMESTAMP = (UInt_t)atoll(Row->GetField(t)); |
881 |
if (t==16) FAV_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
if (t==16) FAV_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
882 |
if (t==17) EFF_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
if (t==17) EFF_WRK_SCHEDULE = (UInt_t)atoll(Row->GetField(t)); |
883 |
if (t==18) PRH_VAR_TRG_MODE_A= (UInt_t)atoll(Row->GetField(t)); |
if (t==18) PRH_VAR_TRG_MODE_A= (UInt_t)atoll(Row->GetField(t)); |
884 |
if (t==19) PRH_VAR_TRG_MODE_B= (UInt_t)atoll(Row->GetField(t)); |
if (t==19) PRH_VAR_TRG_MODE_B= (UInt_t)atoll(Row->GetField(t)); |
885 |
if (t==20) ACQ_BUILD_INFO = (UInt_t)atoll(Row->GetField(t)); |
if (t==20) ACQ_BUILD_INFO = (UInt_t)atoll(Row->GetField(t)); |
886 |
if (t==21) ACQ_VAR_INFO = (UInt_t)atoll(Row->GetField(t)); |
if (t==21) ACQ_VAR_INFO = (UInt_t)atoll(Row->GetField(t)); |
887 |
if (t==22) RM_ACQ_AFTER_CALIB= (UInt_t)atoll(Row->GetField(t)); |
if (t==22) RM_ACQ_AFTER_CALIB= (UInt_t)atoll(Row->GetField(t)); |
888 |
if (t==23) RM_ACQ_SETTING_MODE = (UInt_t)atoll(Row->GetField(t)); |
if (t==23) RM_ACQ_SETTING_MODE = (UInt_t)atoll(Row->GetField(t)); |
889 |
if (t==24) PKT_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
if (t==24) PKT_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
890 |
if (t==25) PKT_READY_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
if (t==25) PKT_READY_COUNTER = (UInt_t)atoll(Row->GetField(t)); |
891 |
if (t==26) TRK_CALIB_USED = (UInt_t)atoll(Row->GetField(t)); |
if (t==26) TRK_CALIB_USED = (UInt_t)atoll(Row->GetField(t)); |
892 |
if (t==27) CAL_DSP_MASK = (UInt_t)atoll(Row->GetField(t)); |
if (t==27) CAL_DSP_MASK = (UInt_t)atoll(Row->GetField(t)); |
893 |
if (t==28) BOOT_NUMBER = (UInt_t)atoll(Row->GetField(t)); |
if (t==28) BOOT_NUMBER = (UInt_t)atoll(Row->GetField(t)); |
894 |
if (t==29) VALIDATION = (UInt_t)atoll(Row->GetField(t)); |
if (t==29) VALIDATION = (UInt_t)atoll(Row->GetField(t)); |
895 |
}; |
}; |
896 |
}; |
}; |
897 |
// delete pResult; |
// delete pResult; |
1266 |
TSQLResult *pResult; |
TSQLResult *pResult; |
1267 |
TSQLRow *Row; |
TSQLRow *Row; |
1268 |
stringstream myquery; |
stringstream myquery; |
1269 |
|
stringstream rname; |
1270 |
|
rname.str(""); |
1271 |
// ---------------- |
// ---------------- |
1272 |
myquery.str(""); |
myquery.str(""); |
1273 |
myquery << "select "; |
myquery << "select "; |
1284 |
stringstream fname; |
stringstream fname; |
1285 |
fname.str(""); |
fname.str(""); |
1286 |
fname << Row->GetField(0) << "/" << Row->GetField(1); |
fname << Row->GetField(0) << "/" << Row->GetField(1); |
1287 |
|
rname << Row->GetField(1); |
1288 |
file = new TFile(fname.str().c_str(),"READ"); |
file = new TFile(fname.str().c_str(),"READ"); |
1289 |
idraw = (UInt_t)atoll(Row->GetField(2)); |
idraw = (UInt_t)atoll(Row->GetField(2)); |
1290 |
}; |
}; |
1306 |
// |
// |
1307 |
UInt_t t0 = 0; |
UInt_t t0 = 0; |
1308 |
// |
// |
1309 |
myquery.str(""); |
// |
1310 |
myquery << "SELECT OFFSET_DATE FROM GL_RESURS_OFFSET WHERE FROM_ID_RAW<= " |
stringstream oss; |
1311 |
<< idraw << " AND TO_ID_RAW >= " |
oss.str(""); |
1312 |
<< idraw << ";"; |
oss << "SELECT OFFSET_DATE FROM GL_RESURS_OFFSET WHERE SPECIAL_FILE='" |
1313 |
pResult = dbc->Query(myquery.str().c_str()); |
<< rname.str().c_str() << "';"; |
1314 |
if ( pResult ){ |
// if ( IsDebug() ) printf(" %s \n",oss.str().c_str()); |
1315 |
|
pResult = dbc->Query(oss.str().c_str()); |
1316 |
|
Row = pResult->Next(); |
1317 |
|
// |
1318 |
|
TString name=rname.str().c_str(); |
1319 |
|
UInt_t dworbit = 0; |
1320 |
|
Int_t nlength = name.Length(); |
1321 |
|
if ( nlength < 5 ) return; |
1322 |
|
TString dwo = 0; |
1323 |
|
for (Int_t i = 0; i<5; i++){ |
1324 |
|
dwo.Append(name[i],1); |
1325 |
|
}; |
1326 |
|
if ( dwo.IsDigit() ){ |
1327 |
|
dworbit = (UInt_t)dwo.Atoi(); |
1328 |
|
} else { |
1329 |
|
dwo=""; |
1330 |
|
for (Int_t i = 8; i<13; i++){ |
1331 |
|
dwo.Append(name[i],1); |
1332 |
|
}; |
1333 |
|
if ( dwo.IsDigit() ) dworbit = (UInt_t)dwo.Atoi(); |
1334 |
|
}; |
1335 |
|
// if ( IsDebug() ) printf(" Downlink orbit is %i (dwo = %s) \n",dworbit,dwo.Data()); |
1336 |
|
// |
1337 |
|
if ( !Row ){ |
1338 |
|
oss.str(""); |
1339 |
|
oss << "SELECT OFFSET_DATE FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< " |
1340 |
|
<< dworbit << " order by FROM_ORBIT desc limit 1;"; |
1341 |
|
// if ( IsDebug() ) printf(" %s \n",oss.str().c_str()); |
1342 |
|
pResult = dbc->Query(oss.str().c_str()); |
1343 |
Row = pResult->Next(); |
Row = pResult->Next(); |
1344 |
if ( Row ){ |
if ( !Row ){ |
1345 |
// |
printf(" ERROR FROM GLTables! cannot determine Resurs offset \n"); |
1346 |
t0 = (UInt_t)TDatime(Row->GetField(0)).Convert(); |
return; |
|
// |
|
1347 |
}; |
}; |
1348 |
}; |
}; |
1349 |
// |
// |
1350 |
|
// |
1351 |
|
TDatime ti = TDatime(Row->GetField(0)); |
1352 |
|
TTimeStamp tu = TTimeStamp((UInt_t)ti.GetYear(),(UInt_t)ti.GetMonth(),(UInt_t)ti.GetDay(),(UInt_t)ti.GetHour(),(UInt_t)ti.GetMinute(),(UInt_t)ti.GetSecond(),0,true,0); |
1353 |
|
t0 = (UInt_t)tu.GetSec(); |
1354 |
// |
// |
1355 |
// look for the correct timesync entry |
// look for the correct timesync entry |
1356 |
// |
// |
1424 |
*/ |
*/ |
1425 |
TString GL_TIMESYNC::ConvertTime(TString &tzone, UInt_t dbt){ |
TString GL_TIMESYNC::ConvertTime(TString &tzone, UInt_t dbt){ |
1426 |
// |
// |
1427 |
TDatime *time = new TDatime(); |
Int_t offset = 0; |
1428 |
TString rtime; |
TString rtime; |
1429 |
Bool_t found = false; |
Bool_t found = false; |
1430 |
// |
// |
|
time->Set(dbt,false); // UTC (Coordinated Universal Time) |
|
|
// |
|
1431 |
if ( !strcmp(tzone.Data(),"MSK") || !strcmp(tzone.Data(),"MWT") ){ |
if ( !strcmp(tzone.Data(),"MSK") || !strcmp(tzone.Data(),"MWT") ){ |
1432 |
// |
// |
1433 |
UInt_t timeMSK = time->Convert() + 60*60*3; // UTC (Coordinated Universal Time) + 3hs = Moscow Winter Time |
offset = 60*60*3; // UTC (Coordinated Universal Time) + 3hs = Moscow Winter Time |
|
time->Set(timeMSK,false); |
|
1434 |
found = true; |
found = true; |
1435 |
// |
// |
1436 |
}; |
}; |
1437 |
// |
// |
1438 |
if ( !strcmp(tzone.Data(),"CET") ){ |
if ( !strcmp(tzone.Data(),"CET") ){ |
1439 |
// |
// |
1440 |
UInt_t timeCET = time->Convert() + 60*60*1; // CET (Central European Time) = UTC + 1 hs |
offset = 60*60*1; // CET (Central European Time) = UTC + 1 hs |
|
time->Set(timeCET,false); |
|
1441 |
found = true; |
found = true; |
1442 |
// |
// |
1443 |
}; |
}; |
1444 |
// |
// |
1445 |
if ( !strcmp(tzone.Data(),"CEST") ){ |
if ( !strcmp(tzone.Data(),"CEST") ){ |
1446 |
// |
// |
1447 |
UInt_t timeCEST = time->Convert() + 60*60*2; // CEST (Central European Summer Time) = UTC + 2 h |
offset = 60*60*2; // CEST (Central European Summer Time) = UTC + 2 h |
|
time->Set(timeCEST,false); |
|
1448 |
found = true; |
found = true; |
1449 |
// |
// |
1450 |
}; |
}; |
1451 |
// |
// |
1452 |
if ( !strcmp(tzone.Data(),"MSD") || !strcmp(tzone.Data(),"MST")){ |
if ( !strcmp(tzone.Data(),"MSD") || !strcmp(tzone.Data(),"MST")){ |
1453 |
// |
// |
1454 |
UInt_t timeMSD = time->Convert() + 60*60*4; // MSD (Moscow Summer Time) = UTC + 4 h |
offset = 60*60*4; // MSD (Moscow Summer Time) = UTC + 4 h |
|
time->Set(timeMSD,false); |
|
1455 |
found = true; |
found = true; |
1456 |
// |
// |
1457 |
}; |
}; |
1461 |
tzone = "UTC"; |
tzone = "UTC"; |
1462 |
}; |
}; |
1463 |
// |
// |
1464 |
rtime = time->AsSQLString(); |
dbt += offset; |
1465 |
|
// |
1466 |
|
TTimeStamp *time = new TTimeStamp((time_t)dbt,0); |
1467 |
|
// |
1468 |
|
rtime = time->AsString("s"); |
1469 |
|
// |
1470 |
|
delete time; |
1471 |
// |
// |
1472 |
return(rtime); |
return(rtime); |
1473 |
} |
} |
1474 |
|
|
1475 |
/* |
/* |
1476 |
* |
* |
1477 |
* Convert the time in the DB from UInt_t to a string |
* Convert the time from TZONE to UTC |
1478 |
* |
* |
1479 |
* @param dbt time in the DB |
* @param dbt time in the DB |
1480 |
* @param tzone Time Zone, can be UTC,GMT,CET,CEST,MSD default is MSK |
* @param tzone Time Zone, can be UTC,GMT,CET,CEST,MSD default is MSK |
1482 |
*/ |
*/ |
1483 |
TString GL_TIMESYNC::UnConvertTime(TString &tzone, UInt_t dbt){ |
TString GL_TIMESYNC::UnConvertTime(TString &tzone, UInt_t dbt){ |
1484 |
// |
// |
1485 |
TDatime *time = new TDatime(); |
Int_t offset = 0; |
1486 |
TString rtime; |
TString rtime; |
1487 |
// |
// |
1488 |
Bool_t found = false; |
Bool_t found = false; |
1489 |
// |
// |
|
time->Set(dbt,false); // tzone |
|
|
// |
|
1490 |
if ( !strcmp(tzone.Data(),"MSK") || !strcmp(tzone.Data(),"MWT") ){ |
if ( !strcmp(tzone.Data(),"MSK") || !strcmp(tzone.Data(),"MWT") ){ |
1491 |
// |
// |
1492 |
UInt_t timeUTC = time->Convert() - 60*60*3; // UTC (Coordinated Universal Time) = Moscow Winter Time - 3hs |
offset = -60*60*3; // UTC (Coordinated Universal Time) = Moscow Winter Time - 3hs |
|
time->Set(timeUTC,false); |
|
1493 |
found = true; |
found = true; |
1494 |
// |
// |
1495 |
}; |
}; |
1496 |
// |
// |
1497 |
if ( !strcmp(tzone.Data(),"CET") ){ |
if ( !strcmp(tzone.Data(),"CET") ){ |
1498 |
// |
// |
1499 |
UInt_t timeCET = time->Convert() - 60*60*1; // CET (Central European Time) - 1 hs = UTC |
offset = -60*60*1; // CET (Central European Time) - 1 hs = UTC |
|
time->Set(timeCET,false); |
|
1500 |
found = true; |
found = true; |
1501 |
// |
// |
1502 |
}; |
}; |
1503 |
// |
// |
1504 |
if ( !strcmp(tzone.Data(),"CEST") ){ |
if ( !strcmp(tzone.Data(),"CEST") ){ |
1505 |
// |
// |
1506 |
UInt_t timeCEST = time->Convert() - 60*60*2; // CEST (Central European Summer Time) - 2 h = UTC |
offset = -60*60*2; // CEST (Central European Summer Time) - 2 h = UTC |
|
time->Set(timeCEST,false); |
|
1507 |
found = true; |
found = true; |
1508 |
// |
// |
1509 |
}; |
}; |
1510 |
// |
// |
1511 |
if ( !strcmp(tzone.Data(),"MSD") || !strcmp(tzone.Data(),"MST") ){ |
if ( !strcmp(tzone.Data(),"MSD") || !strcmp(tzone.Data(),"MST") ){ |
1512 |
// |
// |
1513 |
UInt_t timeMSD = time->Convert() - 60*60*4; // MSD (Moscow Summer Time) - 4 h = UTC |
offset = -60*60*4; // MSD (Moscow Summer Time) - 4 h = UTC |
|
time->Set(timeMSD,false); |
|
1514 |
found = true; |
found = true; |
1515 |
// |
// |
1516 |
}; |
}; |
1517 |
// |
// |
1518 |
if ( !found && strcmp(tzone.Data(),"UTC") && strcmp(tzone.Data(),"GMT") && strcmp(tzone.Data(),"") ){ |
if ( !found && strcmp(tzone.Data(),"UTC") && strcmp(tzone.Data(),"GMT") && strcmp(tzone.Data(),"") ){ |
1519 |
// |
// |
1520 |
|
offset = 0; |
1521 |
printf("\n Unknown time zone %s using UTC \n",tzone.Data()); |
printf("\n Unknown time zone %s using UTC \n",tzone.Data()); |
1522 |
tzone = "UTC"; |
tzone = "UTC"; |
1523 |
}; |
}; |
1524 |
// |
// |
1525 |
rtime = time->AsSQLString(); |
dbt += offset; |
1526 |
|
TTimeStamp *time = new TTimeStamp((time_t)dbt,0); |
1527 |
|
// |
1528 |
|
rtime = time->AsString("s"); |
1529 |
// |
// |
1530 |
return(rtime); |
return(rtime); |
1531 |
} |
} |