EmcShEnCalibSvc Class Reference

#include <EmcShEnCalibSvc.h>

Inheritance diagram for EmcShEnCalibSvc:

Public Member Functions
	EmcShEnCalibSvc (const std::string &name, ISvcLocator *svcloc)
	~EmcShEnCalibSvc ()
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
void	handle (const Incident &)
void	SetBossRelease (const std::string &_bossrelease)
std::string	GetBossRelease () const
StatusCode	getSftParVer (std::string &SftVer, std::string &CalParVer, int &runfrm, int &runto, int RunNo, std::string BossRelease, std::string DataType)
bool	getEmcShEnCalibSvcInfo ()
std::string	getPi0CalibFile () const
std::string	getSingleGammaCalibFile () const
unsigned int	getRunFrom () const
unsigned int	getRunTo () const

Public Attributes
IDatabaseSvc *	m_dbsvc

Detailed Description

Definition at line 22 of file EmcShEnCalibSvc.h.

Constructor & Destructor Documentation

EmcShEnCalibSvc()

EmcShEnCalibSvc::EmcShEnCalibSvc	(	const std::string &	name,
		ISvcLocator *	svcloc )

Definition at line 40 of file EmcShEnCalibSvc.cxx.

                                                                         :
  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("EmcShEnCalibPar",m_calPar="default");
  declareProperty("EmcShEnCalibBossVer",m_bossVer="default");
  m_ReadPar = false;
  m_RunFrom = 0;
  m_RunTo = 0;
}

~EmcShEnCalibSvc()

EmcShEnCalibSvc::~EmcShEnCalibSvc

(

)

Definition at line 55 of file EmcShEnCalibSvc.cxx.

                                 {
}

Member Function Documentation

finalize()

StatusCode EmcShEnCalibSvc::finalize ( )

virtual

Definition at line 97 of file EmcShEnCalibSvc.cxx.

                                    {
  MsgStream log(messageService(), name());
  log << MSG::INFO << "EmcShEnCalibSvc::finalize()" << endreq;
  //  if(m_connect_offline) delete m_connect_offline;
  return StatusCode::SUCCESS;
}

GetBossRelease()

std::string EmcShEnCalibSvc::GetBossRelease ( ) const

inline

Definition at line 41 of file EmcShEnCalibSvc.h.

{return m_bossRelease;}

getEmcShEnCalibSvcInfo()

bool EmcShEnCalibSvc::getEmcShEnCalibSvcInfo

(

)

Definition at line 189 of file EmcShEnCalibSvc.cxx.

                                            {
  MsgStream log(messageService(), name());
  SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc,"/Event/EventHeader");
  int  run = eventHeader->runNumber();
  //cout<<"Run in getEmcShEnCalibSvcInfo() is: "<<run<<endl;
  
  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) {
    //cout << "This data is the MC sample with the Run Number: " << run << endl;
    run = -run;
  }
  
  if(m_bossRelease=="default") m_bossRelease = getenv("BES_RELEASE");
 
  cType="EmcShEnCalib";
 
  st1=getSftParVer(m_bossVer,m_calPar,runfrm1,runto1,run,m_bossRelease,cType);
  
  sprintf(stmt1, "select  RunFrom,RunTo,singleGammaCalib,pi0Calib from EmcShEnCalibConst 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_SingleGammaCalibFile = dbrec.GetString("singleGammaCalib");
    m_Pi0CalibFile = dbrec.GetString("pi0Calib");
    m_RunFrom = dbrec.GetInt("RunFrom");
    m_RunTo = dbrec.GetInt("RunTo");
 
    /*
    cout<<"BossReleaseVer="<<m_bossRelease.c_str()<<"\t"<<"EmcShEnCalibBossVer="<<m_bossVer.c_str()<<endl;
    cout<<"m_Pi0CalibFile is:"<<m_Pi0CalibFile<<endl;
    cout<<"m_SingleGammaCalibFile is:"<<m_SingleGammaCalibFile<<endl;
    cout<<"m_RunFrom is:"<<m_RunFrom<<endl;
    cout<<"m_RunTo is:"<<m_RunTo<<endl;
    cout << "Successfully fetch EmcShEnCalibSvc information for run: " << run << endl;
    //cout<<"////////// read parameters from EmcShEnCalibConst database/////////////"<<endl;
    */
    return true;
  } else if( row_no<=0 ) {
    cout << " EmcShEnCalibSvc:: can not found EmcShEnCalibSvc information of run:"
     << run << ", boss version " << m_bossRelease << endl;
    exit(1);
    return false;
  }
  return true;
}

Referenced by handle().

getPi0CalibFile()

std::string EmcShEnCalibSvc::getPi0CalibFile ( ) const

inline

Definition at line 52 of file EmcShEnCalibSvc.h.

{return m_Pi0CalibFile;}

getRunFrom()

unsigned int EmcShEnCalibSvc::getRunFrom ( ) const

inline

Definition at line 54 of file EmcShEnCalibSvc.h.

{ return m_RunFrom;}

getRunTo()

unsigned int EmcShEnCalibSvc::getRunTo ( ) const

inline

Definition at line 55 of file EmcShEnCalibSvc.h.

{ return m_RunTo;}

getSftParVer()

StatusCode EmcShEnCalibSvc::getSftParVer	(	std::string &	SftVer,
		std::string &	CalParVer,
		int &	runfrm,
		int &	runto,
		int	RunNo,
		std::string	BossRelease,
		std::string	DataType )

Definition at line 139 of file EmcShEnCalibSvc.cxx.

{
  MsgStream log(msgSvc(), "EmcShEnCalibSvc" );
  char stmt[300];
  int run_No =RunNo;
  MYSQL_RES *res_set;
  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);
  //cout<<"stmt="<<stmt<<endl;
 
  int row_no = m_dbsvc->query("offlinedb",stmt,res);
  //cout<<"raw_no="<<row_no<<endl;
  if(row_no<1){
    std::cout<<"ERROR:error searching with:"<<stmt<<std::endl;
    exit(1);
  }
  if(row_no==1){
    DatabaseRecord* records1 = res[0];
    runfrm=records1->GetInt("RunFrom");
    runto=records1->GetInt("RunTo");
    //cout<<dataType<<" runfrm,runto in getSftParVer is:"<<runfrm<<"::::"<<runto<<endl;
 
    SftVer=records1->GetString("SftVer");
    CalParVer=records1->GetString("ParVer");
    // cout<<"stmt="<<stmt<<"\t"<<SftVer<<"\t"<<CalParVer<<endl;
  }
  if(row_no>1){
    cout<<"ERROR: "<<dataType<<" set overlapped run number in the table CalVtxLumVer"<<endl;
    exit(1);
  }
  return StatusCode::SUCCESS;
}

Referenced by getEmcShEnCalibSvcInfo().

getSingleGammaCalibFile()

std::string EmcShEnCalibSvc::getSingleGammaCalibFile ( ) const

inline

Definition at line 53 of file EmcShEnCalibSvc.h.

{return m_SingleGammaCalibFile;} 

handle()

void EmcShEnCalibSvc::handle

(

const Incident &

inc

)

Definition at line 104 of file EmcShEnCalibSvc.cxx.

                                               {
  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<<"&&&&&&&&&&&&&&:&&&&&&&&&&&&&&&&&&&& EmcShEnCalibSvc handle,run="<<run<<endl;
    if (run<0) run = -run;
    log << MSG::DEBUG << "handle: " <<"Run in handle is: "<<run<< endreq;
    //cout<<"-------------in EmcShEnCalibSvc in the following-----------" <<endl;
    //cout<< "handle: " <<"Run in handle is: "<<run<<endl;
 
    if (run>=m_RunFrom&&run<=m_RunTo&&m_ReadPar==true){
      //cout<<"do not read the database repeatly in EmcShEnCalibConst"<<endl;
      //cout<<"run,RunFrom,runTo="<<run<<","<<m_RunFrom<<","<<m_RunTo<<endl;
    } else {
 
      //cout<<"read the database in EmcShEnCalibConst"<<endl;
      if(!getEmcShEnCalibSvcInfo()){
    log << MSG::ERROR << "can not initilize Shower energy Calib Constants" << endreq;
      } else {
    m_ReadPar=true;
    //std::cout << "in handle of EmcShEnCalibSvc  getPi0CalibFile()= " << getPi0CalibFile()<<std::endl;
    //std::cout << "getSingleGammaCalibFile()= " << getSingleGammaCalibFile() << std::endl;  
      }
      
    }
  } 
 
}

initialize()

StatusCode EmcShEnCalibSvc::initialize ( )

virtual

Definition at line 67 of file EmcShEnCalibSvc.cxx.

                                      {
  MsgStream log(messageService(), name());
  log << MSG::INFO << "EmcShEnCalibSvc::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;
}

SetBossRelease()

void EmcShEnCalibSvc::SetBossRelease ( const std::string & _bossrelease )

inline

Definition at line 40 of file EmcShEnCalibSvc.h.

{m_bossRelease = _bossrelease;}

Member Data Documentation

m_dbsvc

IDatabaseSvc* EmcShEnCalibSvc::m_dbsvc

Definition at line 38 of file EmcShEnCalibSvc.h.

Referenced by getEmcShEnCalibSvcInfo(), getSftParVer(), and initialize().

---

The documentation for this class was generated from the following files:

• EmcShEnCalibSvc.h
• EmcShEnCalibSvc.cxx