/home/bes3soft/bes3soft/Boss/7.0.2/dist/7.0.2/Tof/TofEnergyCalibSvc/TofEnergyCalibSvc-00-00-01/src/TofEnergyCalibSvc.cxx

Go to the documentation of this file.

//     This service is used to read the TofEnergyCalibSvc  information from the database
//
//     an example to use this service is shown in test/test_read.cxx
//
//    the joboption for the example is shown in share/job-test.txt
//  
//     the joboption for this service is shown in  share/jobOptions_TofEnergyCalibSvc.txt


#include <iostream>
#include <sstream>
#include <cstring>
#include <cstdlib>
#include <cstdio>

#include "TofEnergyCalibSvc/TofEnergyCalibSvc.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;


TofEnergyCalibSvc::TofEnergyCalibSvc( const string& name, ISvcLocator* svcloc) :
        Service (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("IsData" , m_IsData = std::string("default"));
                declareProperty("BossRelease",m_bossRelease = std::string("default"));
                //      m_dbsvc = DatabaseSvc::instance();
        }

TofEnergyCalibSvc::~TofEnergyCalibSvc(){
}

StatusCode TofEnergyCalibSvc::queryInterface(const InterfaceID& riid, void** ppvInterface){
        if( IID_ITofEnergyCalibSvc.versionMatch(riid) ){
                *ppvInterface = static_cast<ITofEnergyCalibSvc*> (this);
        } else{
                return Service::queryInterface(riid, ppvInterface);
        }
        return StatusCode::SUCCESS;
}

StatusCode TofEnergyCalibSvc::initialize(){
        MsgStream log(messageService(), name());
        log << MSG::INFO << "TofEnergyCalibSvc::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 TofEnergyCalibSvc::finalize(){
        MsgStream log(messageService(), name());
        log << MSG::INFO << "TofEnergyCalibSvc::finalize()" << endreq;
        //  if(m_connect_offline) delete m_connect_offline;
        return StatusCode::SUCCESS;
}

void TofEnergyCalibSvc::handle(const Incident& inc){
        MsgStream log( messageService(), name() );
        log << MSG::DEBUG << "handle: " << inc.type() << endreq;

        if ( inc.type() == "NewRun" ){
                log << MSG::DEBUG << "NewRun" << endreq;
                if(!getTofEnergyCalibSvcInfo()){
                        log << MSG::ERROR << "can not initilize Tof energy Calib Constants" << endreq;
                }
        } 
}


bool TofEnergyCalibSvc::getTofEnergyCalibSvcInfo(){
        MsgStream log(messageService(), name());
        SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc,"/Event/EventHeader");
        int  run = eventHeader->runNumber();
  cout<<"Run in getTofEnergyCalibSvcInfo() is: "<<run<<endl;

        char stmt1[400];
        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");
        sprintf(stmt1, "select CalibConst,Para1,Para2,Para3,Para4,Para5 from TofEnergyCalib where BossVer = '%s' and RunFrom <= %d and RunTo >= %d and IsData = '%s'", m_bossRelease.c_str(), run, run, m_IsData.c_str());
        cout<<"stmt is:"<<stmt1<<endl;
        DatabaseRecordVector res;
        int row_no = m_dbsvc->query("offlinedb",stmt1,res);
        if( row_no > 0 ) {
                DatabaseRecord& dbrec = *res[row_no-1];
                m_CalibConst = dbrec.GetDouble("CalibConst");
                m_Para1 = dbrec.GetDouble("Para1");
                m_Para2 = dbrec.GetDouble("Para2");
                m_Para3 = dbrec.GetDouble("Para3");
                m_Para4 = dbrec.GetDouble("Para4");
                m_Para5 = dbrec.GetDouble("Para5");
                cout<<"m_CalibConst is:"<<m_CalibConst<<endl;
                cout << "Successfully fetch TofEnergyCalibSvc information for run: "
                        << run << endl;
                return true;
        } else if( row_no<=0 ) {
                cout << " TofEnergyCalibSvc:: can not found TofEnergyCalibSvc information of run:"
                        << run << ", boss version " << m_bossRelease << endl;
                exit(1);
                return false;
        }
        return true;
}

---