ScanEnergySvc.cxx

Go to the documentation of this file.

//     This service is used to read the ScanEnergySvc  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_ScanEnergySvc.txt
 
 
#include <iostream>
#include <sstream>
#include <cstring>
#include <cstdlib>
#include <cstdio>
 
#include "ScanEnergySvc/ScanEnergySvc.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(ScanEnergySvc)
ScanEnergySvc::ScanEnergySvc( 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"));
        //  m_dbsvc = DatabaseSvc::instance();
    }
 
ScanEnergySvc::~ScanEnergySvc(){
}
 
/*StatusCode ScanEnergySvc::queryInterface(const InterfaceID& riid, void** ppvInterface){
    if( IID_IScanEnergySvc.versionMatch(riid) ){
        *ppvInterface = static_cast<IScanEnergySvc*> (this);
    } else{
        return Service::queryInterface(riid, ppvInterface);
    }
    return StatusCode::SUCCESS;
}
*/
StatusCode ScanEnergySvc::initialize(){
    MsgStream log(messageService(), name());
    log << MSG::INFO << "ScanEnergySvc::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 ScanEnergySvc::finalize(){
    MsgStream log(messageService(), name());
    log << MSG::INFO << "ScanEnergySvc::finalize()" << endreq;
    //  if(m_connect_offline) delete m_connect_offline;
    return StatusCode::SUCCESS;
}
 
void ScanEnergySvc::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(!getScanEnergySvcInfo()){
            log << MSG::ERROR << "can not initilize Tof energy Calib Constants" << endreq;
        }
    } 
}
 
 
bool ScanEnergySvc::getScanEnergySvcInfo(){
    MsgStream log(messageService(), name());
    SmartDataPtr<Event::EventHeader> eventHeader(m_eventSvc,"/Event/EventHeader");
    int  run = eventHeader->runNumber();
 
    if (run>=55054&&run<=55859){
 
      cout<<"Run in getScanEnergySvcInfo() is: "<<run<<endl;
      
      char stmt1[400];
      if(run<0) {
        cout << "This data is the MC sample with the Run Number: " << run << endl;
        run = -run;
      }
      
      sprintf(stmt1, "select runStart,runEnd,Energy from ScanEnergy where runStart <= %d and runEnd >= %d ", run, run);
      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_ScanEnergy = dbrec.GetDouble("Energy");
        m_RunStart =dbrec.GetInt("runStart");
        m_RunEnd =dbrec.GetInt("runEnd");
        cout<<"m_ScanEnergy is:"<<m_ScanEnergy<<" m_RunStart is:"<<m_RunStart<<" m_RunEnd is:"<<m_RunEnd<<endl;
        cout << "Successfully fetch ScanEnergySvc information for run: "
         << run << endl;
        return true;
      } else if( row_no<=0 ) {
        cout << " ScanEnergySvc:: can not found ScanEnergySvc information of run:"
         << run << endl;
        exit(1);
        return false;
      }
    }
 
    return true;
}