RunDCSLVDat.cc

Go to the documentation of this file.

#include <stdexcept>
#include <string>
#include <cmath>

#include "OnlineDB/EcalCondDB/interface/RunDCSLVDat.h"
#include "OnlineDB/EcalCondDB/interface/RunIOV.h"

using namespace std;
using namespace oracle::occi;

RunDCSLVDat::RunDCSLVDat()
{
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;

  m_lv = 0;
  m_lvnom = 0;
  m_status= 0;
  m_tstatus= 0;
}



RunDCSLVDat::~RunDCSLVDat()
{
}



void RunDCSLVDat::prepareWrite()
  noexcept(false)
{


}



void RunDCSLVDat::writeDB(const EcalLogicID* ecid, const RunDCSLVDat* item, RunIOV* iov)
  noexcept(false)
{
}



void RunDCSLVDat::fetchData(map< EcalLogicID, RunDCSLVDat >* fillMap, RunIOV* iov)
  noexcept(false)
{
  fetchLastData(fillMap);

}

ResultSet *RunDCSLVDat::getBarrelRset() {
  ResultSet* rset = nullptr;
  string query = "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
    " d.value_number , '5' NOMINAL_VALUE , d.VALUE_TIMESTAMP "
    "FROM "+ getEBAccount()+".FWWIENERMARATHONCHANNEL_LV d "
    " JOIN "+ getEBAccount()+".LV_MAPPING h on "
    " h.DPID = d.DPID join channelview cv on cv.logic_id=h.logic_id WHERE cv.maps_to = cv.name and dpe_name='MEASUREMENTSENSEVOLTAGE' "; 
  try {
    m_readStmt->setSQL(query);
    rset = m_readStmt->executeQuery();
  }
  catch (SQLException e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::getBarrelRset():  ") + getOraMessage(&e) + " " + query));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::getBarrelRset():  error code ") + std::to_string(e.getErrorCode()) + " " + query));
#endif
  }
  return rset;
}

ResultSet *RunDCSLVDat::getEndcapRset() {
  ResultSet* rset = nullptr;
  string query = "SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
    " d.VALUE_NUMBER, '5' NOMINAL_VALUE , d.VALUE_TIMESTAMP "
    "FROM "+ getEEAccount()+".FWWIENERMARATHONCHANNEL_LV d "
    " JOIN "+ getEEAccount()+".EE_LV_MAPPING h on "
    " h.DPID = d.DPID join channelview cv on cv.logic_id=h.logic_id WHERE cv.maps_to = cv.name and dpe_name='MEASUREMENTSENSEVOLTAGE' "; 
  try {
    m_readStmt->setSQL(query);
    rset = m_readStmt->executeQuery();
  }
  catch (SQLException e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::getEndcapRset():  ") + getOraMessage(&e) + " " + query));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::getEndcapRset():  error code ") + std::to_string(e.getErrorCode()) + " " + query));
#endif
  }
  return rset;
}

void RunDCSLVDat::fillTheMap(ResultSet *rset, 
                   map< EcalLogicID, RunDCSLVDat >* fillMap) {
  std::pair< EcalLogicID, RunDCSLVDat > p;
  RunDCSLVDat dat;
  DateHandler dh(m_env, m_conn);

  try {
    while(rset->next()) {
      p.first = EcalLogicID( getOraString(rset,1),     // name
                 rset->getInt(2),        // logic_id
                 rset->getInt(3),        // id1
                 rset->getInt(4),        // id2
                 rset->getInt(5),        // id3
                 getOraString(rset,6));    // maps_to
      
      dat.setLV(        rset->getFloat(7) );
      dat.setLVNominal( rset->getFloat(8) );
      Date sinceDate = rset->getDate(9);
      Tm  sinceTm = dh.dateToTm( sinceDate );
      dat.setStatus(0);
      if (p.first.getName() == "EB_LV_channel") {
    setStatusForBarrel(dat, sinceTm);      
      } else {
    setStatusForEndcaps(dat, sinceTm);      
      }
      p.second = dat;
      fillMap->insert(p);
    } 
  }
  catch (SQLException &e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  ")+getOraMessage(&e)));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  error code ") + std::to_string(e.getErrorCode())));
#endif
  }
}

int  RunDCSLVDat::nowMicroseconds() {
  Tm t_now_gmt;
  
  t_now_gmt.setToCurrentGMTime();
  int t_now_gmt_micros = t_now_gmt.microsTime();
  return t_now_gmt_micros;
}


void RunDCSLVDat::setStatusForBarrel(RunDCSLVDat &dat, const Tm& sinceTm) {
  int t_now_gmt_micros = nowMicroseconds();

  if (fabs(dat.getLV() - dat.getLVNominal())*1000 > maxLVDifferenceEB) {
    dat.setStatus(LVNOTNOMINAL);
  }
  if (dat.getLV()*1000 < minLV) {
    dat.setStatus(LVOFF);
  }

  int result=0;
  int d= ((int)t_now_gmt_micros - (int)sinceTm.microsTime()) ;
  if (d> maxDifference) {
    result= -d/1000000 ;
  }
  dat.setTimeStatus(result);


}

void  RunDCSLVDat::setStatusForEndcaps(RunDCSLVDat &dat, const Tm& sinceTm) {
  int t_now_gmt_micros = nowMicroseconds();

  if (fabs(dat.getLV() - dat.getLVNominal())*1000 > maxLVDifferenceEE) {
    dat.setStatus(LVNOTNOMINAL);
  }
  if (dat.getLV()*1000 < minLV) {
    dat.setStatus(LVOFF);
  }

  int result=0;
  int d= ((int)t_now_gmt_micros - (int)sinceTm.microsTime()) ;
  if (d> maxDifference) {
    result= -d/1000000 ;
  }
  dat.setTimeStatus(result);


}

void RunDCSLVDat::fetchLastData(map< EcalLogicID, RunDCSLVDat >* fillMap )
  noexcept(false)
{
  this->checkConnection();

  fillMap->clear();

  try {
    std::pair< EcalLogicID, RunDCSLVDat > p;
    RunDCSLVDat dat;

    ResultSet* rset = getBarrelRset();
    
    fillTheMap(rset, fillMap);
    rset = getEndcapRset();
    
    fillTheMap(rset, fillMap);
  } 
  catch (SQLException &e) {
#if defined(_GLIBCXX_USE_CXX11_ABI) && (_GLIBCXX_USE_CXX11_ABI == 0)
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  ")+getOraMessage(&e)));
#else
    throw(std::runtime_error(std::string("RunDCSLVDat::fetchData():  error code ") + std::to_string(e.getErrorCode())));
#endif
  }
}