In This Package:

FeeCableMapWriter.cc

Go to the documentation of this file.

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

#ifdef I_LIKE_DUPLICITY
#include "DbiDataSvc/FeeCableMap.h"
#else
#include "genDbi/GFeeCableMap.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;
FeeCableMapWriter:: FeeCableMapWriter(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";
}

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

StatusCode FeeCableMapWriter::initialize(){
  cout<<"FeeCableMapWriter 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 FeeCableMapWriter::finalize(){
    cout<<"FeeCableMapWriter finalizing--------------"<<endl;
    StatusCode sc = this->GaudiTool::finalize();
    if(sc != StatusCode::SUCCESS) return sc;
    return StatusCode::SUCCESS;
}

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

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

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

/*
int FeeCableMapWriter::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 FeeCableMapWriter::init()
{
#ifdef I_LIKE_DUPLICITY
   myWriter = new DbiWriter<FeeCableMap>(range,aggNo,subsite,task);
#else
   TimeStamp versionDate(0,0) ;
   UInt_t dbNo(0) ;
   const std::string logComment = "" ;
   const std::string tableName = "FeeCableMap" ;
   myWriter = new DbiWriter<GFeeCableMap>(range,aggNo,subsite,task, versionDate, dbNo, logComment, tableName );
#endif
   return 1;
}

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

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

int FeeCableMapWriter::fillRow(){ 
#ifdef I_LIKE_DUPLICITY
    FeeCableMap row;
#else
#endif
    ifstream input;
    input.open(inputFileName.c_str());
    if(!input){
      cout<<"can not open file : "<<inputFileName<<endl;
      return 0;
    }else{
          int feeChannelId = 0;
          string channelDesc;
          int feeHardwareId = 0;
          string chanHrdwDesc;
          int sensorId = 0;
          string sensorDesc;
          int pmtHardwareId = 0;
          string pmtHrdwDesc;

        char buffer[500];
//      input.getline(buffer, sizeof(buffer));
//      input.getline(buffer, sizeof(buffer));
      while(input.peek()!=EOF)
      {
        input.getline(buffer, sizeof(buffer));
        istringstream(buffer)>>feeChannelId
                             >>channelDesc
                             >>feeHardwareId
                             >>chanHrdwDesc
                             >>sensorId
                             >>sensorDesc
                             >>pmtHardwareId
                             >>pmtHrdwDesc;

cout<< feeChannelId<<"   "
    << channelDesc<<"   "
    << feeHardwareId<<"   "
    << chanHrdwDesc<<"   "
    << sensorId<<"   "
    << sensorDesc<<"   "
    << pmtHardwareId<<"   "
    << pmtHrdwDesc;


#ifdef I_LIKE_DUPLICITY
row.SetFeeCableMapValues(
#else
  GFeeCableMap row( 
#endif
feeChannelId,
channelDesc,
feeHardwareId,
chanHrdwDesc,
sensorId,
sensorDesc,
pmtHardwareId,
pmtHrdwDesc
              );
         //writeToDB();
         *myWriter << row;
      }
    }
    return 1;
} 

int FeeCableMapWriter::setContextRange(){
    ifstream input;
    input.open("/publicfs/dyb/user/anfp/DBIW/DBWriter/share/feeCableMap.conf");
     if(!input){
      cout<<"can not open file : "<<"/publicfs/dyb/user/anfp/DBIW/DBWriter/share/feeCableMap.conf"<<endl;
      return 0;
    }else{
      int Syear;
      int Smonth;
      int Sday;
      int Shour;
      int Smin;
      int Ssec;

      int Eyear;
      int Emonth;
      int Eday;
      int Ehour;
      int Emin;
      int Esec;

      int sitemask;
      int simmask;

      input>> Syear
           >> Smonth
           >> Sday
           >> Shour
           >> Smin
           >> Ssec;

      input>> Eyear
           >> Emonth
           >> Eday
           >> Ehour
           >> Emin
           >> Esec;

      input>> sitemask
           >> simmask;



//    startTime.Set(Syear, Smonth, Sday, Shour, Smin, Ssec,0,0,0);///
TimeStamp Tstart(Syear, Smonth, Sday, Shour, Smin, Ssec,0,1,0);
//TimeStamp Tstart(2010, 4, 1, 0, 0, 0,0,0,0);
    startTime = Tstart;

TimeStamp Tend(Eyear, Emonth, Eday, Ehour, Emin, Esec,0,1,0);
//    TimeStamp Tend(2020, 12, 22, 0, 0, 0,0,0,0);
    endTime = Tend;

//    endTime.Set(Eyear, Emonth, Eday, Ehour, Emin, Esec,0,0,0);///
    ContextRange Cr(sitemask, simmask, startTime, endTime);
// ContextRange Cr(32, 1, startTime, endTime);///
    range = Cr;
}

}

---