| 772 |
* \param run starting time |
* \param run starting time |
| 773 |
* \return struct of type GL_CALO_CALIB_data, which stores the query result |
* \return struct of type GL_CALO_CALIB_data, which stores the query result |
| 774 |
*/ |
*/ |
| 775 |
Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB(UInt_t time, UInt_t section, TSQLServer *dbc){ |
Int_t GL_CALO_CALIB::Query_GL_CALO_CALIB(UInt_t time, UInt_t &uptime, UInt_t section, TSQLServer *dbc){ |
| 776 |
// MySQL variables |
// MySQL variables |
| 777 |
TSQLResult *pResult; |
TSQLResult *pResult; |
| 778 |
TSQLRow *Row; |
TSQLRow *Row; |
| 779 |
int t; |
int t; |
| 780 |
stringstream myquery; |
stringstream myquery; |
| 781 |
|
uptime = 0; |
| 782 |
// |
// |
| 783 |
// select the correct calibration |
// select the correct calibration |
| 784 |
// |
// |
| 786 |
myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT,VALIDATION from GL_CALO_CALIB where SECTION=" << section; |
myquery << "select ID_ROOT_L0, FROM_TIME, TO_TIME, EV_ROOT,VALIDATION from GL_CALO_CALIB where SECTION=" << section; |
| 787 |
myquery << " and FROM_TIME <= " << time; |
myquery << " and FROM_TIME <= " << time; |
| 788 |
myquery << " and TO_TIME > " << time; |
myquery << " and TO_TIME > " << time; |
| 789 |
myquery << " and VALIDATION=1;"; |
myquery << " ;"; |
| 790 |
|
//myquery << " and VALIDATION=1;"; |
| 791 |
// |
// |
| 792 |
pResult = dbc->Query(myquery.str().c_str()); |
pResult = dbc->Query(myquery.str().c_str()); |
| 793 |
|
// printf(" mysquery is %s\n",myquery.str().c_str()); |
| 794 |
|
// |
| 795 |
|
if( !pResult->GetRowCount() ) return(-54); |
| 796 |
|
Row = pResult->Next(); |
| 797 |
|
if( Row == NULL ) return (-54); |
| 798 |
|
// |
| 799 |
|
uptime = (UInt_t)atoll(Row->GetField(2)); |
| 800 |
// |
// |
| 801 |
// if it is corrupted validation is 0 and we have no results from the query... |
// if it is corrupted validation is 0 and we have no results from the query... |
| 802 |
// |
// |
| 803 |
if( !pResult->GetRowCount() ){ |
if( atoi(Row->GetField(4)) == 0 ){ // if validation = 0 |
|
// pResult->Delete(); |
|
| 804 |
// |
// |
| 805 |
// in this case take relax the conditions and take the valid calibration that preceed the correct one |
// in this case take relax the conditions and take the valid calibration that preceed the correct one |
| 806 |
// |
// |
| 809 |
myquery << " and FROM_TIME <= " << time; |
myquery << " and FROM_TIME <= " << time; |
| 810 |
myquery << " and VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; |
myquery << " and VALIDATION=1 ORDER BY FROM_TIME DESC LIMIT 1;"; |
| 811 |
pResult = dbc->Query(myquery.str().c_str()); |
pResult = dbc->Query(myquery.str().c_str()); |
| 812 |
|
// printf(" mysquery is %s\n",myquery.str().c_str()); |
| 813 |
// |
// |
| 814 |
// if no results yet quit with error |
// if no results yet quit with error |
| 815 |
// |
// |
| 816 |
if( !pResult->GetRowCount() ) return (-54); |
if( !pResult->GetRowCount() ) return (-54); |
| 817 |
|
// |
| 818 |
|
Row = pResult->Next(); |
| 819 |
|
// |
| 820 |
}; |
}; |
| 821 |
// |
// |
| 822 |
// store infos and exit |
// store infos and exit |
| 823 |
// |
// |
|
Row = pResult->Next(); |
|
| 824 |
if( Row == NULL ) return (-54); |
if( Row == NULL ) return (-54); |
| 825 |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
for( t = 0; t < pResult->GetFieldCount(); t++){ |
| 826 |
if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
if (t==0) ID_ROOT_L0 = (UInt_t)atoll(Row->GetField(t)); |
| 1109 |
// |
// |
| 1110 |
return(rtime); |
return(rtime); |
| 1111 |
} |
} |
| 1112 |
|
|
| 1113 |
|
/* |
| 1114 |
|
* |
| 1115 |
|
* Convert the time in the DB from UInt_t to a string |
| 1116 |
|
* |
| 1117 |
|
* @param dbt time in the DB |
| 1118 |
|
* @param tzone Time Zone, can be UTC,GMT,CET,CEST,MSD default is MSK |
| 1119 |
|
* |
| 1120 |
|
*/ |
| 1121 |
|
TString GL_TIMESYNC::UnConvertTime(TString tzone, UInt_t dbt){ |
| 1122 |
|
// |
| 1123 |
|
TDatime *time = new TDatime(); |
| 1124 |
|
TString rtime; |
| 1125 |
|
// |
| 1126 |
|
time->Set(dbt,false); // MSK = Moscow Winter Time |
| 1127 |
|
// |
| 1128 |
|
if ( !strcmp(tzone.Data(),"UTC") || !strcmp(tzone.Data(),"GMT") ){ |
| 1129 |
|
// |
| 1130 |
|
UInt_t timeUTC = time->Convert() + 60*60*3; // UTC (Coordinated Universal Time) +3 hs = Moscow Winter Time |
| 1131 |
|
time->Set(timeUTC,false); |
| 1132 |
|
// |
| 1133 |
|
}; |
| 1134 |
|
// |
| 1135 |
|
if ( !strcmp(tzone.Data(),"CET") ){ |
| 1136 |
|
// |
| 1137 |
|
UInt_t timeCET = time->Convert() + 60*60*2; // CET (Central European Time) + 2 hs = Moscow Winter Time |
| 1138 |
|
time->Set(timeCET,false); |
| 1139 |
|
// |
| 1140 |
|
}; |
| 1141 |
|
// |
| 1142 |
|
if ( !strcmp(tzone.Data(),"CEST") ){ |
| 1143 |
|
// |
| 1144 |
|
UInt_t timeCEST = time->Convert() + 60*60*1; // CEST (Central European Summer Time) + 1 h = Moscow Winter Time |
| 1145 |
|
time->Set(timeCEST,false); |
| 1146 |
|
// |
| 1147 |
|
}; |
| 1148 |
|
// |
| 1149 |
|
if ( !strcmp(tzone.Data(),"MSD") ){ |
| 1150 |
|
// |
| 1151 |
|
UInt_t timeMSD = time->Convert() - 60*60*1; // MSD (Moscow Summer Time) - 1 h = Moscow Winter Time |
| 1152 |
|
time->Set(timeMSD,false); |
| 1153 |
|
// |
| 1154 |
|
}; |
| 1155 |
|
// |
| 1156 |
|
rtime = time->AsSQLString(); |
| 1157 |
|
// |
| 1158 |
|
return(rtime); |
| 1159 |
|
} |