| 1145 |
if(t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
if(t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
| 1146 |
if(t==1) ID_RAW = (UInt_t)atoll(Row->GetField(t)); |
if(t==1) ID_RAW = (UInt_t)atoll(Row->GetField(t)); |
| 1147 |
if(t==2) ID_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
if(t==2) ID_TIMESYNC = (UInt_t)atoll(Row->GetField(t)); |
| 1148 |
if(t==3) PATH = Row->GetField(t); |
if(t==3) PATH = (TString)gSystem->ExpandPathName(Row->GetField(t))+'/'; |
| 1149 |
if(t==4) NAME = Row->GetField(t); |
if(t==4) NAME = Row->GetField(t); |
| 1150 |
}; |
}; |
| 1151 |
}; |
}; |
| 1170 |
// ---------------- |
// ---------------- |
| 1171 |
myquery.str(""); |
myquery.str(""); |
| 1172 |
myquery << "select ID,ID_ROOT_L0,EV_ROOT_CALIBTRK1,EV_ROOT_CALIBTRK2,FROM_TIME,TO_TIME,OBT1,OBT2,PKT1,PKT2,BOOT_NUMBER,VALIDATION from GL_TRK_CALIB where FROM_TIME <= "<< time; |
myquery << "select ID,ID_ROOT_L0,EV_ROOT_CALIBTRK1,EV_ROOT_CALIBTRK2,FROM_TIME,TO_TIME,OBT1,OBT2,PKT1,PKT2,BOOT_NUMBER,VALIDATION from GL_TRK_CALIB where FROM_TIME <= "<< time; |
| 1173 |
myquery << " AND VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; |
// myquery << " AND VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; // RIVEDERE LA VALIDAZIONE!!! |
| 1174 |
|
myquery << " and EV_ROOT_CALIBTRK1>=0 and EV_ROOT_CALIBTRK2>=0 "; // EM! SE MANCA UN PACCHETTO DEI DUE IL PROCESSAMENTO CRASHA... DA RIVEDERE LA VALIDAZIONE |
| 1175 |
|
myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 1176 |
// myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
// myquery << " ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 1177 |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return -57; |
| 1178 |
this->GetGLTABLES()->AddQ(); |
this->GetGLTABLES()->AddQ(); |
| 1340 |
// ---------------- |
// ---------------- |
| 1341 |
myquery.str(""); |
myquery.str(""); |
| 1342 |
myquery << " select "; |
myquery << " select "; |
| 1343 |
myquery << " ID, PATH, NAME, DESCR, TYPE, FROM_TIME,TO_TIME "; |
myquery << " ID, PATH, NAME, DESCR, FROM_TIME,TO_TIME, TYPE "; |
| 1344 |
myquery << " from GL_PARAM "; |
myquery << " from GL_PARAM "; |
| 1345 |
myquery << " where TYPE = '"<<type<<"' "; |
myquery << " where TYPE = '"<<type<<"' "; |
| 1346 |
myquery << " and FROM_TIME <= " << time; |
myquery << " and FROM_TIME <= " << time; |
| 1355 |
if( Row == NULL ) break; |
if( Row == NULL ) break; |
| 1356 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
| 1357 |
if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
if (t==0) ID = (UInt_t)atoll(Row->GetField(t)); |
| 1358 |
if (t==1) PATH = Row->GetField(t);// put in fpath the path to that file |
if (t==1) PATH = (TString)gSystem->ExpandPathName(Row->GetField(t))+'/';// put in fpath the path to that file |
| 1359 |
if (t==2) NAME = Row->GetField(t); |
if (t==2) NAME = Row->GetField(t); |
| 1360 |
if (t==3) DESCR = Row->GetField(t); |
if (t==3) DESCR = Row->GetField(t); |
| 1361 |
if (t==4) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
if (t==4) FROM_TIME = (UInt_t)atoll(Row->GetField(t)); |
| 1401 |
TSQLRow *Row; |
TSQLRow *Row; |
| 1402 |
stringstream myquery; |
stringstream myquery; |
| 1403 |
stringstream rname; |
stringstream rname; |
| 1404 |
|
// pcksList packetsNames; |
| 1405 |
|
// pcksList::iterator Iter; |
| 1406 |
|
// getPacketsNames(packetsNames); |
| 1407 |
rname.str(""); |
rname.str(""); |
| 1408 |
// ---------------- |
// ---------------- |
| 1409 |
myquery.str(""); |
myquery.str(""); |
| 1422 |
if( Row ){ |
if( Row ){ |
| 1423 |
stringstream fname; |
stringstream fname; |
| 1424 |
fname.str(""); |
fname.str(""); |
| 1425 |
fname << Row->GetField(0) << "/" << Row->GetField(1); |
fname << gSystem->ExpandPathName(Row->GetField(0)) << "/" << Row->GetField(1); |
| 1426 |
rname << Row->GetField(1); |
rname << Row->GetField(1); |
| 1427 |
file = new TFile(fname.str().c_str(),"READ"); |
file = new TFile(fname.str().c_str(),"READ"); |
| 1428 |
idraw = (UInt_t)atoll(Row->GetField(2)); |
idraw = (UInt_t)atoll(Row->GetField(2)); |
| 1439 |
ph = eh->GetPscuHeader(); |
ph = eh->GetPscuHeader(); |
| 1440 |
pktfirst = ph->GetCounter(); |
pktfirst = ph->GetCounter(); |
| 1441 |
obtfirst = ph->GetOrbitalTime(); |
obtfirst = ph->GetOrbitalTime(); |
| 1442 |
|
// |
| 1443 |
|
// code = eh->GetCounter(); |
| 1444 |
|
// UInt_t en = 0; |
| 1445 |
|
// for(Iter = packetsNames.begin(); Iter != packetsNames.end(); Iter++){ |
| 1446 |
|
// en = code->Get(GetPacketType(*Iter)); |
| 1447 |
|
// if ( !strcmp("CalibCalPed",*Iter) || !strcmp("CalibTrk1",*Iter) || !strcmp("CalibTrk2",*Iter) || !strcmp("CalibS4",*Iter) ){ |
| 1448 |
|
// // |
| 1449 |
|
// TTree *TC = 0; |
| 1450 |
|
// TC = (TTree*)file->Get("CalibCalPed"); |
| 1451 |
|
// if ( !TC || TC->IsZombie() ) return; |
| 1452 |
|
// EventHeader *ehc = 0; |
| 1453 |
|
// PscuHeader *phc = 0; |
| 1454 |
|
// TC->SetBranchAddress("Header", &ehc); |
| 1455 |
|
// TC->GetEntry(0); |
| 1456 |
|
// phc = ehc->GetPscuHeader(); |
| 1457 |
|
// pktfirst = phc->GetCounter(); |
| 1458 |
|
// obtfirst = phc->GetOrbitalTime(); |
| 1459 |
|
// // |
| 1460 |
|
// }; |
| 1461 |
|
// }; |
| 1462 |
|
// |
| 1463 |
}; |
}; |
| 1464 |
// |
// |
| 1465 |
// look for Resurs offset |
// look for Resurs offset |
| 1468 |
// |
// |
| 1469 |
// |
// |
| 1470 |
stringstream oss; |
stringstream oss; |
| 1471 |
|
TString frn = rname.str().c_str(); |
| 1472 |
|
frn = frn.ReplaceAll(".root",5,".pam",4); |
| 1473 |
oss.str(""); |
oss.str(""); |
| 1474 |
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE SPECIAL_FILE='" |
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE SPECIAL_FILE='" |
| 1475 |
<< rname.str().c_str() << "';"; |
<< frn.Data() << "';"; |
| 1476 |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; |
if ( !this->GetGLTABLES()->IsConnected(dbc) ) return; |
| 1477 |
this->GetGLTABLES()->AddQ(); |
this->GetGLTABLES()->AddQ(); |
| 1478 |
pResult = dbc->Query(oss.str().c_str()); |
pResult = dbc->Query(oss.str().c_str()); |
| 1493 |
for (Int_t i = 8; i<13; i++){ |
for (Int_t i = 8; i<13; i++){ |
| 1494 |
dwo.Append(name[i],1); |
dwo.Append(name[i],1); |
| 1495 |
}; |
}; |
| 1496 |
if ( dwo.IsDigit() ) dworbit = (UInt_t)dwo.Atoi(); |
if ( dwo.IsDigit() ){ |
| 1497 |
|
dworbit = (UInt_t)dwo.Atoi(); |
| 1498 |
|
} else { |
| 1499 |
|
dworbit = 1; |
| 1500 |
|
}; |
| 1501 |
}; |
}; |
| 1502 |
// |
// |
| 1503 |
|
// |
| 1504 |
if ( !Row ){ |
if ( !Row ){ |
| 1505 |
oss.str(""); |
oss.str(""); |
| 1506 |
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< " |
oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE) FROM GL_RESURS_OFFSET WHERE FROM_ORBIT< " |