In This Package:

CalibPmtWriter.cc

Go to the documentation of this file.

#include "DBWriter/CalibPmtWriter.h"
#include "DBWriter/ICalibWriter.h"

#ifdef I_LIKE_DUPLICITY 
#include "DbiDataSvc/CalibPmtSpec.h"
#else
#include "genDbi/GCalibPmtSpec.h"
#endif

#include "Context/Context.h"
#include "Context/ContextRange.h"

#include "DatabaseInterface/DbiLog.h"
#include "DatabaseInterface/DbiOutRowStream.h"
#include "DatabaseInterface/DbiResultSet.h"
#include "DatabaseInterface/DbiValidityRec.h"

#include "DaqRunInfoSvc/IDaqRunInfoSvc.h"
#include "DaqRunInfoSvc/DaqRunInfo.h"
#include "DaqRunInfoSvc/DaqCalibRunInfo.h"

#include "GaudiKernel/Service.h"
#include <iostream>
#include <sstream>
#include <fstream>
using namespace std;
CalibPmtWriter:: CalibPmtWriter(const string& type,
                                const string& name, 
                                const IInterface* parent)
              :GaudiTool(type, name, parent)
{
    declareInterface< ICalibWriter >(this);
    //aggNo = -1;
    //subsite = 0;
    //task = 0;
    //m_daqRunInfoSvcName = "DaqRunInfoSvc";
}

CalibPmtWriter::~CalibPmtWriter(){
//    delete myWriter;
}

StatusCode CalibPmtWriter::initialize(){
  cout<<"CalibPmtWriter initialzing--------------"<<endl;
  info()<< "initialize()"<< endreq;
  StatusCode sc = this->GaudiTool::initialize();
  if(sc != StatusCode::SUCCESS) return sc;

  //Get the DaqRunInfo Service
  //m_daqRunInfoSvc = svc<IDaqRunInfoSvc>("DaqRunInfoSvc", true);
  //if(!m_daqRunInfoSvc)
  //{
  //  error()<< "No DaqRunInfoSvc available."<< endreq;
  //  return StatusCode::FAILURE;
  //} 
  return StatusCode::SUCCESS;
}

StatusCode CalibPmtWriter::finalize(){
    cout<<"CalibPmtWriter finalizing--------------"<<endl;
    StatusCode sc = this->GaudiTool::finalize();
    if(sc != StatusCode::SUCCESS) return sc;
    return StatusCode::SUCCESS;
}

int CalibPmtWriter::setRunNo(int runNo){ 
    runNumber = runNo;
    return 1;
} 

int CalibPmtWriter::setFileName(string fileName){
    inputFileName = fileName; 
    return 1;
} 

int CalibPmtWriter::setTimeWindow(int time){
    timeWindow = time; 
    return 1;
} 

void CalibPmtWriter::setSubsite(int subSite)
{
    this->subsite = subSite;
}

void CalibPmtWriter::setIsSim(bool isSim)
{
    this->isSim = isSim;
}

void CalibPmtWriter::setSiteMask(int siteMask)
{
    this->siteMask = siteMask;
}

/*
int CalibPmtWriter::getRunInfo(){

    const DaqRunInfo* row;
    row = m_daqRunInfoSvc->GetRunInfo(runNo);
    if(!row){
      cout<< "runNo: "<<runNo<<" is not found in table DaqRunInfo."<<endl;
      return 0;
    }
    DbiResult* res = row->GetOwner();
    const DbiValidityRec vr = res->GetValidityRec();
    range = vr.GetContextRange();
    return 1;

}
*/

int CalibPmtWriter::init()
{
#ifdef I_LIKE_DUPLICITY 
   myWriter = new DbiWriter<CalibPmtSpec>(range,aggNo,subsite,task);
#else
   TimeStamp versionDate(0,0) ;
   UInt_t dbNo(0) ;
   const std::string logComment = "" ;
   const std::string tableName = "CalibPmtSpec" ;
   myWriter = new DbiWriter<GCalibPmtSpec>(range,aggNo,subsite,task, versionDate, dbNo, logComment, tableName );
#endif
   return 1;
}

int CalibPmtWriter::final()
{     
    cout<<"close DB"<<endl;
    myWriter->Close();
    return 1;
}

int CalibPmtWriter::run()
{
    mainProcess();
}

int CalibPmtWriter::fillRow(){ 
#ifdef I_LIKE_DUPLICITY 
    CalibPmtSpec row;
#else
#endif
    ifstream input;
    input.open(inputFileName.c_str());
    if(!input){
      cout<<"can not open file : "<<inputFileName<<endl;
      return 0;
    }else{
      int pmtID = 0;
      string description;
      int status = 0;
      double speHigh = 0;
      double sigmaSpe = 0;
      double speLow = 0;
      double timeOffset = 0;
      double timeSpread = 0;
      double efficiency = 0;
      double prePulse = 0;
      double afterPulse = 0;
      double darkRate = 0;
      char buffer[500];
      input.getline(buffer, sizeof(buffer));
      input.getline(buffer, sizeof(buffer));
      while(input.peek()!=EOF)
      {
        input.getline(buffer, sizeof(buffer));
        istringstream(buffer)>>pmtID
                             >>description
                             >>status
                             >>speHigh
                             >>sigmaSpe
                             >>speLow
                             >>timeOffset
                             >>timeSpread
                             >>efficiency 
                             >>prePulse 
                             >>afterPulse
                             >>darkRate ;

        cout<<pmtID<<"   "
            <<description<<"   "
            <<status<<"   "
            <<speHigh<<"   "
            <<sigmaSpe<<"   "
            <<speLow<<"   "
            <<timeOffset<<"   "
            <<timeSpread<<"   "
            <<efficiency<<"   "
            <<prePulse<<"   "
            <<afterPulse<<"   "
            <<darkRate<<endl;

#ifdef I_LIKE_DUPLICITY 
         row.SetCalibPmtSpecValues(
#else
         GCalibPmtSpec row(
#endif
                                   pmtID,
                                   description,
                                   status,
                                   speHigh,                             
                                   sigmaSpe,
                                   speLow,
                                   timeOffset,
                                   timeSpread,
                                   efficiency,
                                   prePulse,
                                   afterPulse,
                                   darkRate);
         //writeToDB();
         *myWriter << row;
      }
    }
    return 1;
} 

---