EmcSatuDeadEnSvc.cxx

Go to the documentation of this file.

//     This service is used to read the EmcSatuDeadEnSvc  information from the database
//  
//     the joboption for this service is shown in  share/jobOptions_EmcSatuDeadEnSvc.txt
 
 
#include <iostream>
#include <sstream>
#include <cstring>
#include <cstdlib>
#include <cstdio>
 
#include "EmcSatuDeadEnSvc/EmcSatuDeadEnSvc.h"
#include "GaudiKernel/Kernel.h"
#include "GaudiKernel/IInterface.h"
#include "GaudiKernel/StatusCode.h"
#include "GaudiKernel/SvcFactory.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/SmartDataPtr.h"
#include "GaudiKernel/IDataProviderSvc.h"
#include "GaudiKernel/PropertyMgr.h"
 
 
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/Incident.h"
#include "GaudiKernel/IIncidentListener.h"
 
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/Bootstrap.h"
#include "EventModel/EventModel.h"
#include "EventModel/Event.h"
#include "EventModel/EventHeader.h"
 
#include <TMath.h>
 
using namespace std;
 
DECLARE_COMPONENT(EmcSatuDeadEnSvc)
 
EmcSatuDeadEnSvc::EmcSatuDeadEnSvc( const string& name, ISvcLocator* svcloc) :
  base_class (name, svcloc){
  // declare properties
  declareProperty("Host" , host = std::string("bes3db2.ihep.ac.cn"));
  declareProperty("DbName" , dbName = std::string("offlinedb"));
  declareProperty("UserName" , userName = std::string("guest"));
  declareProperty("Password" , password = std::string("guestpass"));
  declareProperty("BossRelease",m_bossRelease = std::string("default"));
  declareProperty("EmcSatuDeadEnPar",m_calPar="default");
  declareProperty("EmcSatuDeadEnBossVer",m_bossVer="default");
  m_ReadPar = false;
  m_RunFrom = 0;
  m_RunTo = 0;
}
 
EmcSatuDeadEnSvc::~EmcSatuDeadEnSvc(){
}
 
StatusCode EmcSatuDeadEnSvc::initialize(){
  MsgStream log(messageService(), name());
  log << MSG::INFO << "EmcSatuDeadEnSvc::initialize()" << endreq;
  
  StatusCode sc = Service::initialize();
  if( sc.isFailure() ) return sc;
  
  
  IIncidentSvc* incsvc;
  sc = service("IncidentSvc", incsvc);
  int priority = 100;
  if( sc.isSuccess() ){
    incsvc -> addListener(this, "NewRun", priority);
  }
  
  sc = serviceLocator()->service("DatabaseSvc",m_dbsvc,true);
  if (sc .isFailure() ) {
    log << MSG::ERROR << "Unable to find DatabaseSvc " << endreq;
    return sc;
  }
  
  sc = serviceLocator()->service("EventDataSvc", m_eventSvc, true);
  if (sc .isFailure() ) {
    log << MSG::ERROR << "Unable to find EventDataSvc " << endreq;
    return sc;
  }
  
  return StatusCode::SUCCESS;
}
 
StatusCode EmcSatuDeadEnSvc::finalize(){
  MsgStream log(messageService(), name());
  log << MSG::INFO << "EmcSatuDeadEnSvc::finalize()" << endreq;
 
  return StatusCode::SUCCESS;
}
 
void EmcSatuDeadEnSvc::handle(const Incident& inc){
  MsgStream log( messageService(), name() );
  log << MSG::DEBUG << "handle: " << inc.type() << endreq;
 
  /*
  if ( inc.type() == "NewRun" ){
    log << MSG::DEBUG << "NewRun" << endreq;
 
    SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc,"/Event/EventHeader");
    int  run = eventHeader->runNumber();
    //cout<<"&&&&&&&&&&&&&&:&&&&&&&&&&&&&&&&&&&& EmcSatuDeadEnSvc handle,run="<<run<<endl;
    if (run<0) run = -run;
    log << MSG::DEBUG << "handle: " <<"Run in handle is: "<<run<< endreq;
    log << MSG::DEBUG << "-------------in EmcSatuDeadEnSvc in the following-----------" <<endreq;
    log << MSG::DEBUG << "handle: " <<"Run in handle is: "<<run<<endreq;
 
    if (run>=m_RunFrom&&run<=m_RunTo&&m_ReadPar==true){
      log << MSG::DEBUG << "do not read the database repeatly in EmcSatuDeadEn"<<endreq;
      log << MSG::DEBUG << "run,RunFrom,runTo="<<run<<","<<m_RunFrom<<","<<m_RunTo <<endreq;
    } else {
 
      log << MSG::DEBUG << "read the database in EmcSatuDeadEn" <<endreq;
      if(!getEmcSatuDeadEnSvcInfo()){
    log << MSG::ERROR << "can not get EmcSatuDeadEnSvc" << endreq;
      } else {
    m_ReadPar=true;
    log << MSG::DEBUG << "in handle of EmcSatuDeadEnSvc  getSatuEnFile()= " << getSatuEnFile()<<std::endreq;
    log << MSG::DEBUG << "getDeadEnFile()= " << getDeadEnFile() << std::endreq;  
      }
      
    }
  } // NewRun
  */
}
 
//select sftver and parver frm table CalVtxLum
StatusCode EmcSatuDeadEnSvc::getSftParVer(std::string& SftVer,
                       std::string& CalParVer,
                       int &runfrm,
                       int &runto,
                       int RunNo,
                       std::string BossRelease,
                       std::string DataType
                       )
{
  MsgStream log(msgSvc(), "EmcSatuDeadEnSvc" );
  char stmt[300];
  int run_No =RunNo;
 
  IDatabaseSvc* m_dbsvc;
  DatabaseRecordVector res;
  StatusCode sc=serviceLocator()->service("DatabaseSvc",m_dbsvc,true);
  if (sc .isFailure() ) {
    log << MSG::ERROR << " Unable to find DatabaseSvc " << endreq;
    return sc;
  }
  
  const char* bossRelease = BossRelease.c_str();
  const char* dataType = DataType.c_str();
  
  sprintf(stmt,"select RunFrom,RunTo,SftVer,ParVer from CalVtxLumVer where BossRelease = '%s' and RunFrom <= %d and RunTo >= %d and DataType='%s' ",bossRelease,run_No,run_No,dataType);
  log << MSG::DEBUG <<"stmt="<<stmt<<endreq;
 
  int row_no = m_dbsvc->query("offlinedb",stmt,res);
  //cout<<"raw_no="<<row_no<<endl;
  if(row_no<1){
    log << MSG::ERROR <<"error searching with:"<<stmt<<endreq;
    exit(1);
  }
  if(row_no==1){
    DatabaseRecord* records1 = res[0];
    runfrm=records1->GetInt("RunFrom");
    runto=records1->GetInt("RunTo");
   log << MSG::DEBUG <<dataType<<" runfrm,runto in getSftParVer is:"<<runfrm<<"::::"<<runto<<endreq;
 
    SftVer=records1->GetString("SftVer");
    CalParVer=records1->GetString("ParVer");
    log << MSG::DEBUG <<"stmt="<<stmt<<"\t"<<SftVer<<"\t"<<CalParVer<<endreq;
  }
  if(row_no>1){
    log << MSG::ERROR <<"ERROR: "<<dataType<<" set overlapped run number in the table CalVtxLumVer"<<endreq;
    exit(1);
  }
  return StatusCode::SUCCESS;
}
 
bool EmcSatuDeadEnSvc::getEmcSatuDeadEnSvcInfo(){
  MsgStream log(messageService(), name());
  SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc,"/Event/EventHeader");
  int  run = eventHeader->runNumber();
  log << MSG::DEBUG <<"Run in getEmcSatuDeadEnSvcInfo() is: "<<run<<endreq;
  
  char stmt1[400];
  StatusCode st1;
  //runfrm,runto are the value from the table ***CalConst;runfrm1,runto1 are the value from the table CalVtxLumVer
  int runfrm1;
  int runto1;
  std::string cType;
  
  if(run<0) {
    log << MSG::DEBUG << "This data is the MC sample with the Run Number: " << run << endreq;
    run = -run;
  }
  
  //if(m_bossRelease=="default") m_bossRelease = getenv("BES_RELEASE");
 
 
 
  if(m_bossRelease=="default") 
    {
      log << MSG::FATAL << " Boss Release for EmcSatuDeadEnSvc not set!" << endreq;
      exit(1);
    }
  else{
 
 
    cType="EmcSatuDeadEn";
 
    st1=getSftParVer(m_bossVer,m_calPar,runfrm1,runto1,run,m_bossRelease,cType);
    
    sprintf(stmt1, "select  RunFrom,RunTo,EmcSatuEn,EmcDeadEn from EmcSatuDeadEn where SftVer = '%s' and RunFrom <= %d and RunTo >= %d ", m_bossVer.c_str(), run, run);
  }
 
 
  DatabaseRecordVector res;
  int row_no = m_dbsvc->query("offlinedb",stmt1,res);
 
  if( row_no > 0 ) {
    DatabaseRecord& dbrec = *res[row_no-1];
    m_SatuEnFile = dbrec.GetString("EmcSatuEn");
    m_DeadEnFile = dbrec.GetString("EmcDeadEn");
    m_RunFrom = dbrec.GetInt("RunFrom");
    m_RunTo = dbrec.GetInt("RunTo");
 
    log << MSG::DEBUG <<"BossReleaseVer="<<m_bossRelease.c_str()<<"\t"<<"EmcSatuDeadEnBossVer="<<m_bossVer.c_str()<<endreq;
    log << MSG::DEBUG <<"m_SatuEnFile is:"<<m_SatuEnFile<<endreq;
    log << MSG::DEBUG <<"m_DeadEnFile is:"<<m_DeadEnFile<<endreq;
    log << MSG::DEBUG <<"m_RunFrom is:"<<m_RunFrom<<endreq;
    log << MSG::DEBUG <<"m_RunTo is:"<<m_RunTo<<endreq;
    log << MSG::DEBUG <<"Successfully fetch EmcSatuDeadEnSvc information for run: " << run << endreq;
 
    
    return true;
  } else if( row_no<=0 ) {
    cout << " EmcSatuDeadEnSvc:: can not found EmcSatuDeadEnSvc information of run:"
     << run << ", boss version " << m_bossRelease << endl;
    exit(1);
    return false;
  }
  return true;
}