Changeset 9005 for trunk/MagicSoft/Mars/datacenter/macros

Timestamp:

07/17/08 15:58:20 (16 years ago)

Author:

tbretz

Message:

*** empty log message ***

Location:

trunk/MagicSoft/Mars/datacenter/macros

Files:

• fillsignal.C (modified) (13 diffs)
• writesequencefile.C (modified) (2 diffs)

trunk/MagicSoft/Mars/datacenter/macros/fillsignal.C

@@ -114 +114 @@
     if (!cam)
     {
-        cout << "WARNING - Reading of PedRMS;avg failed." << endl;
+        cout << "ERROR - Reading of PedRMS;avg failed." << endl;
         return 2;
     }
@@ -122 +122 @@
     if (!pul)
     {
-        cout << "WARNING - Reading of PulsePos;avg failed." << endl;
+        cout << "ERROR - Reading of PulsePos;avg failed." << endl;
         return 2;
     }
@@ -129 +129 @@
     if (!difflo)
     {
-        cout << "WARNING - Reading of DiffLo;avg failed." << endl;
+        cout << "ERROR - Reading of DiffLo;avg failed." << endl;
         return 2;
     }
@@ -135 +135 @@
     if (!diffhi)
     {
-        cout << "WARNING - Reading of DiffHi;avg failed." << endl;
+        cout << "ERROR - Reading of DiffHi;avg failed." << endl;
         return 2;
     }
@@ -144 +144 @@
     if (sequence.IsNull())
     {
-        cout << "WARNING - Sequ# empty" << endl;
+        cout << "ERROR - Sequ# empty" << endl;
         cout << "Sequ# " << sequence << endl;
         return 2;
@@ -161 +161 @@
         if (!hilooff)
         {
-            cout << "WARNING - Reading of HiLoOff failed." << endl;
+            cout << "ERROR - Reading of HiLoOff failed." << endl;
             return 2;
         }
@@ -168 +168 @@
         if (!hilocal)
         {
-            cout << "WARNING - Reading of HiLoCal failed." << endl;
+            cout << "ERROR - Reading of HiLoCal failed." << endl;
             return 2;
         }
@@ -191 +191 @@
     if (meanrmsi<0 || meanrmso<0)
     {
-        cout << "WARNING - MeanPedRMS inner or outer < 0 " << endl;
+        cout << "ERROR - MeanPedRMS inner or outer < 0 " << endl;
         cout << "MeanPedRMS inner " << meanrmsi << endl;
         cout << "MeanPedRMS outer " << meanrmso << endl;
@@ -203 +203 @@
     if (!cam)
     {
-        cout << "WARNING - Reading of Interp'd;avg failed." << endl;
+        cout << "ERROR - Reading of Interp'd;avg failed." << endl;
         return 2;
     }
@@ -212 +212 @@
     if (meansigi<0 || meansigo<0)
     {
-        cout << "WARNING - MeanInterp'd inner or outer < 0 " << endl;
+        cout << "ERRROR - MeanInterp'd inner or outer < 0 " << endl;
         cout << "MeanInterp'd inner " << meansigi << endl;
         cout << "MeanInterp'd outer " << meansigo << endl;
@@ -225 +225 @@
     if (pul->GetMean()<0 || pul->GetRMS()<0)
     {
-        cout << "WARNING - PulsePos'd mean or rms < 0 " << endl;
+        cout << "ERROR - PulsePos'd mean or rms < 0 " << endl;
         cout << "PulsePos'd mean " << pul->GetMean() << endl;
         cout << "PulsePos'd rms  " << pul->GetRMS() << endl;
@@ -258 +258 @@
     if (!cam)
     {
-        cout << "WARNING - Reading of Unsuitable;avg failed." << endl;
+        cout << "ERROR - Reading of Unsuitable;avg failed." << endl;
         return 2;
     }
@@ -375 +375 @@
 
 
-    return serv.Update("Calibration", vars, Form("fSequenceFirst=%d", seq));
+    return serv.Update("Calibration", vars, Form("fSequenceFirst=%d", seq)) ? 1 : 2;
 }
 

trunk/MagicSoft/Mars/datacenter/macros/writesequencefile.C

@@ -41 +41 @@
 // to the database is not working.
 //
+//
+// This tool will work from Period017 (2004_05_17) on...
+//
+// For more details see MSequence and MSequenceSQL
+//
 /////////////////////////////////////////////////////////////////////////////
-#include <iostream>
-#include <iomanip>
-#include <fstream>
-
-#include <TSQLRow.h>
-#include <TSQLResult.h>
-
-#include <TEnv.h>
-#include <TMath.h>
-#include <TRegexp.h>
-
-#include "MAstro.h"
-#include "MTime.h"
-#include "MDirIter.h"
-
-#include "MSQLMagic.h"
+#include "MSequence.h"
 
 using namespace std;
 
-Bool_t GetRuns(MSQLServer &serv, ofstream &fout, TString query, TString name, UInt_t nevts=(UInt_t)-1)
+int writeseq(Int_t sequno, Int_t tel, TString sequpath="")
 {
-    TSQLResult *res = serv.Query(query);
-    if (!res)
-        return kFALSE;
-
-    UInt_t cnt=0;
-    UInt_t evts=0;
-
-    fout << name << ":";
-    TSQLRow *row=0;
-    while ((row = res->Next()) && evts<nevts)
-    {
-        fout << " " << (*row)[0];
-        evts += atoi((*row)[1]);
-        cnt++;
-    }
-    fout << endl;
-
-    delete res;
-
-    if (cnt==0)
-    {
-        cout << "ERROR - No " << name << " belonging to this sequence found." << endl;
-        return kFALSE;
-    }
-
-    return kTRUE;
-}
-
-TString GetTime(const char *type)
-{
-    return Form("if(TIME_TO_SEC(fRun%s)<12*60*60,"
-                " TIME_TO_SEC(fRun%s)+24*60*60,"
-                " TIME_TO_SEC(fRun%s))", type, type, type);
-}
-
-Int_t GetTimeC(MSQLServer &serv, const TString &str)
-{
-    TSQLResult *res = serv.Query(str);
-    if (!res)
-        return -1;
-
-    TSQLRow *row=res->Next();
-    if (!row)
-    {
-        delete res;
-        return -1;
-    }
-
-    Int_t rc = (*row)[0] ? atoi((*row)[0]) : -1;
-    delete res;
-    return rc;
-}
-
-Bool_t GetSequence(MSQLMagic &serv, TSQLRow &data, TString sequpath)
-{
-    UShort_t y;
-    Byte_t m, d;
-
-    MTime time;
-    time.SetSqlDateTime(data[8]);
-    time.GetDateOfSunrise(y, m, d);
-
-    TString date = Form("%04d-%02d-%02d", y, (int)m, (int)d);
-
-    Int_t period = MAstro::GetMagicPeriod(time.GetMjd());
-
-    TString str[6];
-    str[0] = serv.QueryNameOfKey("Project",         data[2]);
-    str[1] = serv.QueryNameOfKey("Source",          data[3]);
-    str[2] = serv.QueryNameOfKey("L1TriggerTable",  data[4]);
-    str[3] = serv.QueryNameOfKey("L2TriggerTable",  data[5]);
-    str[4] = serv.QueryNameOfKey("HvSettings",      data[6]);
-    str[5] = serv.QueryNameOfKey("LightConditions", data[7]);
-
-    if (str[0].IsNull() || str[1].IsNull() || str[2].IsNull() || str[3].IsNull() || str[4].IsNull() || str[5].IsNull())
-        return kFALSE;
-
-    //create sequence file
-    TString fname(Form("%s/%04d/sequence%08d.txt", sequpath.Data(), atoi(data[0])/10000, atoi(data[0])));
-    cout << "Creating " << fname << "..." << flush;
-
-    ofstream fout(fname);
-    if (!fout)
-    {
-        cout << "ERROR - Cannot open file." << endl;
-        return kFALSE;
-    }
-
-    //write information into file
-    fout << "Sequence:        " << data[0]  << endl;
-    fout << "Period:          " << period   << endl;
-    fout << "Night:           " << date     << endl;
-    fout << "LightConditions: " << str[5]   << endl;
-    fout << endl;
-    fout << "Start:           " << data[8]  << endl;
-    fout << "LastRun:         " << data[1]  << endl;
-    fout << "Project:         " << str[0]   << endl;
-    fout << "Source:          " << str[1]   << endl;
-    fout << "ZdMin:           " << data[10] << endl;
-    fout << "ZdMax:           " << data[11] << endl;
-    fout << "L1TriggerTable:  " << str[2]   << endl;
-    fout << "L2TriggerTable:  " << str[3]   << endl;
-    fout << "HvSettings:      " << str[4]   << endl;
-    fout << "NumEvents:       " << data[9]  << endl;
-    fout << endl;
-
-    TString where(Form(" FROM RunData WHERE fSequenceFirst=%s AND fExcludedFDAKEY=1"
-                       " AND fRunTypeKEY%%s", data[0]));
-
-    TString query1(Form("SELECT fRunNumber, fNumEvents %s", where.Data()));
-    TString query2(Form("SELECT %s %s", GetTime("Start").Data(), where.Data()));
-    TString query3(Form("SELECT %s %s", GetTime("Stop").Data(),  where.Data()));
-
-    TString queryA(Form(query1.Data(), " BETWEEN 2 AND 4 ORDER BY fRunNumber"));
-    TString queryC(Form(query1.Data(), "=4 ORDER BY fRunNumber"));
-    TString queryD(Form(query1.Data(), "=2 ORDER BY fRunNumber"));
-    TString queryT(Form(query2.Data(), "=4 ORDER BY fRunNumber LIMIT 1"));
-
-    Int_t timec = GetTimeC(serv, queryT);
-    if (timec<0)
-    {
-        cout << "WARNING - Requesting start time of first calibration run failed." << endl;
-        queryT = Form(query3.Data(), "=4 ORDER BY fRunNumber LIMIT 1");
-        timec = GetTimeC(serv, queryT);
-        if (timec<0)
-        {
-            cout << "ERROR - Neither start nor stop time of first calibration could be requested." << endl;
-            return kFALSE;
-        }
-    }
-
-    TString query4(Form("=3 ORDER BY ABS(%s-%d) ASC", GetTime("Stop").Data(), timec));
-    TString queryP(Form(query1.Data(), query4.Data()));
-
-    //write runs into sequence file
-    if (!GetRuns(serv, fout, queryA, "Runs"))
-        return kFALSE;
-
-    fout << endl;
-
-    if (!GetRuns(serv, fout, queryC, "CalRuns"))
-        return kFALSE;
-    if (!GetRuns(serv, fout, queryP, "PedRuns", 1000))
-        return kFALSE;
-    if (!GetRuns(serv, fout, queryD, "DatRuns"))
-        return kFALSE;
-
-    fout << endl;
-
-    cout << " done <Nevts=" << data[9] << ">" << endl;
-
-    return kTRUE;
-}
-
-// This tool will work from Period017 (2004_05_17) on...
-int writesequencefile(Int_t sequno, TString sequpath)
-{
-    TEnv env("sql.rc");
-
-    MSQLMagic serv(env);
+    MSQLMagic serv("sql.rc");
     if (!serv.IsConnected())
     {
@@ -233 +64 @@
     cout << endl;
     cout << "Connected to " << serv.GetName() << endl;
+    cout << "Sequence:  " << sequno << endl;
+    cout << "Telescope: " << tel << endl;
     cout << endl;
 
-    //get sequence information from database
-    TString query(Form("SELECT fSequenceFirst, fSequenceLast, fProjectKEY, fSourceKEY,"
-                       " fL1TriggerTableKEY, fL2TriggerTableKEY, fHvSettingsKEY, "
-                       " fLightConditionsKEY, fRunStart, fNumEvents, "
-                       " fZenithDistanceMin, fZenithDistanceMax "
-                       " FROM Sequences WHERE fSequenceFirst=%d", sequno));
-    TSQLResult *res = serv.Query(query);
+    const MSequenceSQL s(serv, sequno, tel);
+    if (!s.IsValid())
+        return 2;
 
-    TSQLRow *row = 0;
-    while ((row = res->Next()))
-        if (!GetSequence(serv, *row, sequpath))
-            return 2;
+    if (sequpath.IsNull())
+    {
+        s.Print();
+        return 1;
+    }
 
-    delete res;
+    const TString fname(Form("%s/%04d/sequence%08d.txt", sequpath.Data(), sequno/10000, sequno));
 
-    cout << endl;
+    cout << "File:     " << fname << endl;
 
-    return 1;
+    return s.WriteFile(fname) ? 1 : 2;
 }