MdcHvDropSvc.h

Go to the documentation of this file.

/**
 * @file MdcHvDropSvc.h
 * @author zhangzeheng (zhangzeheng@ihep.ac.cn)
 * @brief header for main part.
 * @version 0.1
 * @date 2022-01-19
 *
 */
#ifndef MDCHVDROPSVC_H_
#define MDCHVDROPSVC_H_
 
// #include "CLHEP/Matrix/Vector.h"
// #include "DatabaseSvc/IDatabaseSvc.h"
#include "GaudiKernel/IDataProviderSvc.h"
#include "GaudiKernel/IIncidentListener.h"
#include "GaudiKernel/IInterface.h"
#include "GaudiKernel/IService.h"
#include "GaudiKernel/Kernel.h"
#include "GaudiKernel/Service.h"
 
#include <ctime>
#include <map>
#include <mysql.h>
#include <string>
#include <vector>
// using CLHEP::HepVector;
#include "MdcHvDropSvc/IMdcHvDropSvc.h"
// #include "DatabaseSvc/DatabaseSvc.h"
#include "VData.h"
 
template <class TYPE> class SvcFactory;
 
class MdcHvDropSvc : public extends<Service, IMdcHvDropSvc>,
                     // public Service,
                     //                      virtual public IMdcHvDropSvc,
                     virtual public IIncidentListener {
public:
  friend class SvcFactory<MdcHvDropSvc>;
 
  MdcHvDropSvc( const std::string& name, ISvcLocator* svcloc );
  ~MdcHvDropSvc();
 
  // virtual StatusCode queryInterface( const InterfaceID& riid, void** ppvUnknown );
  virtual StatusCode initialize();
  virtual StatusCode finalize();
 
  // Incident handler
  void handle( const Incident& );
 
  virtual double queryRelativeHvDrop();
  virtual void   setRelativeHvDropThreshold( double threshold ) {
    m_relativeHvDropThreshold = threshold;
  };
  virtual bool queryIsHvDrop() { return queryRelativeHvDrop() >= m_relativeHvDropThreshold; }
  // virtual bool queryIsHvValid();
 
private:
  StatusCode FetchHvInfo( Time_t timeBegin, Time_t timeEnd );
  StatusCode initMySql();
  /**
   * @brief retrive a line of HV info from a MYSQL_ROW and pushes to out and time
   * format and layout of HV info is hardcoded
   *
   * @return StatusCode returns failure if mysql returns thing different from expectated colomn
   * number
   */
  StatusCode sqlRow2Item( MYSQL_ROW row, MYSQL_RES* result, VDataItem& out, Time_t& time );
  Time_t     datetimeStr2Time_t( const char* str );
  size_t     Time_t2str( Time_t utctime, char* str, int length );
  Time_t     getRunBeginTime( int runid );
  VData      m_vData;
  MYSQL      m_mysql;
  MYSQL_ROW  m_row;
  MYSQL_RES* m_result;
  double     m_relativeHvDropThreshold;
  int        m_fetchLength;
 
  int  m_useEtsT1;
  long m_etsT1Offset;
 
  std::map<int, Time_t> m_run_begin;
 
  // common variables for BOSS & BEAN
 
  // slow control database
  std::string m_dbName;
  std::string m_host;
  std::string m_table;
  std::string m_userName;
  std::string m_password;
  bool        m_ignoreLayer_21_24;
  int         m_port;
 
  // offline database
  std::string m_dbName2;
  std::string m_host2;
  std::string m_table2;
  std::string m_userName2;
  std::string m_password2;
  int         m_port2;
 
  IDataProviderSvc* m_eventSvc;
};
 
#endif /* MDCGVDROPSVC_H_ */