SiStripDetVOffBuilder.h

Go to the documentation of this file.

#ifndef SISTRIPDETVOFF_SRC_BUILDER_H
#define SISTRIPDETVOFF_SRC_BUILDER_H
#define USING_NEW_CORAL


#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"

#include "CondFormats/SiStripObjects/interface/SiStripDetVOff.h"
#include "CondFormats/DataRecord/interface/SiStripCondDataRecords.h"
#include "CalibTracker/SiStripCommon/interface/SiStripDetInfoFileReader.h"

#include "CalibTracker/SiStripDCS/interface/SiStripCoralIface.h"
#include "CalibTracker/SiStripDCS/interface/SiStripPsuDetIdMap.h"
// #include "CalibTracker/SiStripDCS/interface/SiStripPsuDetIdMapFromFile.h"

#include "CoralBase/TimeStamp.h"
#include "CondFormats/Common/interface/Time.h"
#include "CondFormats/Common/interface/TimeConversions.h"
//#include "DataFormats/Provenance/interface/Timestamp.h"


#include <fstream>
#include <iostream>
#include <memory>

class SiStripDetVOffBuilder
{
 public:
  ~SiStripDetVOffBuilder();
  SiStripDetVOffBuilder(const edm::ParameterSet&,const edm::ActivityRegistry&);
  void BuildDetVOffObj();
  std::vector< std::pair<SiStripDetVOff*,cond::Time_t> > getModulesVOff(const int deltaTmin = 1, const int maxIOVlength = 120) {
    reduction(deltaTmin, maxIOVlength);
    return modulesOff;
  }
  std::vector< std::vector<uint32_t> > getPayloadStats() {return payloadStats;}
  void setLastSiStripDetVOff( SiStripDetVOff * lastPayload, cond::Time_t lastTimeStamp );

  void reduce( std::vector< std::pair<SiStripDetVOff*,cond::Time_t> >::iterator & it,
           std::vector< std::pair<SiStripDetVOff*,cond::Time_t> >::iterator & initialIt,
           std::vector< std::pair<SiStripDetVOff*,cond::Time_t> > & resultVec,
           const bool last = false);

  void reduction(const uint32_t deltaTmin, const uint32_t maxIOVlength);

  void discardIOVs( std::vector< std::pair<SiStripDetVOff*,cond::Time_t> >::iterator & it,
                    std::vector< std::pair<SiStripDetVOff*,cond::Time_t> >::iterator & initialIt,
                    std::vector< std::pair<SiStripDetVOff*,cond::Time_t> > & resultVec,
                    const bool last, const unsigned int first );
  bool FileExists(std::string filename);
 private:
  // typedefs
  typedef std::vector< std::pair< std::vector<uint32_t>,coral::TimeStamp> > DetIdTimeStampVector;
  

  bool whichQuery;


  void printPar(std::stringstream& ss, const std::vector<int>& par);

  std::string timeToStream(const coral::TimeStamp & coralTime, const string & comment = "");
  std::string timeToStream(const cond::Time_t & condTime, const string & comment = "");

  int findSetting(uint32_t id, 
          coral::TimeStamp changeDate, 
          std::vector<uint32_t> settingID, 
          std::vector<coral::TimeStamp> settingDate);

  int findSetting(std::string dpname, 
          coral::TimeStamp changeDate, 
          std::vector<std::string> settingDpname, 
          std::vector<coral::TimeStamp> settingDate);

  void readLastValueFromFile(std::vector<uint32_t> &dpIDs,
                 std::vector<float> &vmonValues, 
                 std::vector<coral::TimeStamp> &dateChange);

  cond::Time_t getCondTime(coral::TimeStamp coralTime);

  coral::TimeStamp getCoralTime(cond::Time_t iovTime);

  void removeDuplicates( std::vector<uint32_t> & vec );
  cond::Time_t findMostRecentTimeStamp( std::vector<coral::TimeStamp> coralDate );
  
  // member data
  std::vector< std::vector<uint32_t> > payloadStats;
  std::vector< std::pair<SiStripDetVOff*,cond::Time_t> > modulesOff;
  std::pair<SiStripDetVOff *, cond::Time_t> lastStoredCondObj;
  
  // configurable parameters
  std::string onlineDbConnectionString;
  std::string authenticationPath;
  std::string whichTable;
  std::string lastValueFileName;
  bool fromFile;
  std::string psuDetIdMapFile_;
  bool debug_;
  coral::TimeStamp tmax, tmin, tsetmin;
  std::vector<int> tDefault, tmax_par, tmin_par, tset_par;

  std::string detIdListFile_;
  std::string excludedDetIdListFile_;
  // Threshold to consider a high voltage channel on
  double highVoltageOnThreshold_;

  // Structure used to store variables needed when building the database objects
  struct TimesAndValues
  {
    TimesAndValues() :
      latestTime(0)
    {}
    std::vector<coral::TimeStamp> changeDate;    // used by both
    std::vector<std::string>      dpname;        // only used by DB access, not file access
    std::vector<float>            actualValue;   // only used by DB access, not file access
    std::vector<uint32_t>         dpid;          // only used by file access
    std::vector<int>              actualStatus;  // filled using actualValue info
    cond::Time_t                  latestTime;    // used for timestamp when using lastValue from file
  };
  
  struct DetIdListTimeAndStatus
  {
    DetIdListTimeAndStatus() :
      notMatched(0)
    {}
    DetIdTimeStampVector detidV;
    std::vector<bool> StatusGood;
    unsigned int notMatched;
    std::vector<std::string> psuName;
    std::vector<unsigned int> isHV;
  };

  void statusChange( cond::Time_t & lastTime, TimesAndValues & tStruct );
  void lastValue( TimesAndValues & tStruct );
  void lastValueFromFile( TimesAndValues & tStruct );

  void buildPSUdetIdMap(TimesAndValues & tStruct, DetIdListTimeAndStatus & dStruct);

  void setPayloadStats(const uint32_t afterV, const uint32_t numAdded, const uint32_t numRemoved);
  std::pair<int, int> extractDetIdVector(const unsigned int i, SiStripDetVOff * modV, DetIdListTimeAndStatus & detIdStruct);

  std::auto_ptr<SiStripCoralIface> coralInterface;

};
#endif