Changeset 9006 for trunk/MagicSoft/Mars/datacenter/macros/buildsequenceentries.C

Timestamp:

07/17/08 16:08:04 (16 years ago)

Author:

tbretz

Message:

*** empty log message ***

File:

• trunk/MagicSoft/Mars/datacenter/macros/buildsequenceentries.C (modified) (22 diffs)

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

@@ -159 +159 @@
     UInt_t fMax;
 
+    static UInt_t GetId(const TString &str)
+    {
+        const Ssiz_t dot = str.First('.');
+
+        const UInt_t run = str.Atoi();
+        const UInt_t sub = dot<0 ? 0 : atoi(str.Data()+dot+1);
+
+        return run*1000+sub;
+    }
+
     void Init(const TObjArray &arr, Int_t idx=0)
     {
@@ -179 +189 @@
             case 2: fRegexp1  = TPRegexp(Form("^%s$", str.Data())); break;
             case 3: fRegexp2  = TPRegexp(Form("^%s$", str.Data())); break;
-            case 4: fMin      = str.Atoi();               break;
-            case 5: fMax      = str.Atoi();               break;
+            case 4: fMin      = GetId(str);               break;
+            case 5: fMax      = GetId(str);               break;
             }
         }
-        //cout << endl;
     }
 
@@ -257 +266 @@
     TString fPathSequences;
 
+    Int_t fTelescopeNumber;
+
     TMap  fMap;
     TList fListRegexp;
@@ -286 +297 @@
         const TString runtime =
             "SUM(TIME_TO_SEC(TIMEDIFF(fRunStop,fRunStart))), ";
-            //"SUM(if(TIME_TO_SEC(fRunStop)-TIME_TO_SEC(fRunStart)<0,"
-            //" TIME_TO_SEC(fRunStop)-TIME_TO_SEC(fRunStart)+24*60*60,"
-            //" TIME_TO_SEC(fRunStop)-TIME_TO_SEC(fRunStart))), ";
-
-        const TString where = Form("(fRunNumber BETWEEN %d AND %d) AND fExcludedFDAKEY=1",
-                                   from, to);
+
+        const TString where = Form("(fRunNumber*1000+fFileNumber BETWEEN %d AND %d) "
+                                   "AND fTelescopeNumber=%d AND fExcludedFDAKEY=1",
+                                   from, to, fTelescopeNumber);
 
         TString query;
@@ -359 +368 @@
         }
 
-        const TString set = Form("fSequenceFirst=%d ", from);
+        const TString set = Form("fSequenceFirst=%d, fTelescopeNumber=%d ", from/1000, fTelescopeNumber);
 
         TString query1;
         query1 += set;
-        query1 += Form(",fSequenceLast=%d,",                   to);
+        query1 += Form(",fSequenceLast=%d,",                   to/1000);
         query1 += Form(" fSourceKEY=%s,",                      (*row)[0]);
         query1 += Form(" fProjectKEY=%s,",                     (*row)[1]);
@@ -400 +409 @@
         }
 
-        if (!Insert("SequenceProcessStatus", set))
+        TString prio = set;
+        prio += Form(", fPriority=%d ", from/1000);
+        if (!Insert("SequenceProcessStatus", prio))
         {
             cout << "ERROR - Could not insert Sequence into SequenceProcessStatus." << endl;
@@ -458 +469 @@
     Int_t CheckSequence(Int_t runstart, Int_t runstop)
     {
-        const char *fmt1 = "SELECT fRunNumber FROM RunData WHERE";
-        const char *fmt2 = "AND fExcludedFDAKEY=1 AND (fRunTypeKEY BETWEEN 2 AND 4) ORDER BY fRunNumber";
-
-        const TString query1 = Form("%s fSequenceFirst=%d %s",            fmt1, runstart, fmt2);
-        const TString query2 = Form("%s fRunNumber BETWEEN %d AND %d %s", fmt1, runstart, runstop, fmt2);
+        const char *fmt1 = "SELECT fRunNumber*1000+fFileNumber AS Id FROM RunData WHERE";
+        const char *fmt2 = "AND fExcludedFDAKEY=1 AND (fRunTypeKEY BETWEEN 2 AND 4) ORDER BY Id";
+
+        const TString query1 = Form("%s fTelescopeNumber=%d AND fSequenceFirst=%d %s",    fmt1, fTelescopeNumber, runstart/1000, fTelescopeNumber, fmt2);
+        const TString query2 = Form("%s fTelescopeNumber=%d AND fRunNumber*1000+fFileNumber BETWEEN %d AND %d %s", fmt1, fTelescopeNumber, runstart, runstop, fmt2);
 
         TSQLResult *res1 = Query(query1);
@@ -499 +510 @@
         TString query=
             Form("SELECT fSequenceFirst FROM RunData "
-                 " WHERE fRunNumber BETWEEN %d AND %d AND "
-                 " fSequenceFirst>0 AND "
+                 " WHERE fRunNumber*1000+fFileNumber BETWEEN %d AND %d AND "
+                 " fTelescopeNumber=%d AND fSequenceFirst>0 AND "
                  " fExcludedFDAKEY=1 AND (fRunTypeKEY BETWEEN 2 AND 4)"
-                 " GROUP BY fSequenceFirst", runstart, runstop);
+                 " GROUP BY fSequenceFirst", fTelescopeNumber, runstart, runstop);
 
         TSQLResult *res = Query(query);
@@ -554 +565 @@
     Bool_t ReadResources(const char *fname)
     {
-        TPRegexp regexp("^\\[.*\\]$");
+        // Check for the section header
+        TPRegexp regexp("^\\[(Transition|Regexp):?[0-9 ]*\\]$");
+        // Check if section header contains a number
+        TPRegexp regnum("[0-9]");
+        // Check if section header contains the telescope number
+        TPRegexp regtel(Form("[^0-9]0*%d[^0-9]", fTelescopeNumber));
 
         ifstream fin(fname);
@@ -579 +595 @@
                 continue;
 
-            if (txt[0]=='[' && section!=2)
+            if (txt[0]=='['/* && section!=2*/)
             {
-                //cout << txt << endl;
-                section = 0;
-                if (txt(regexp)=="[Transition]")
-                    section = 1;
-                if (txt(regexp)=="[Regexp]")
-                    section = 2;
-                continue;
+                TString sec = txt(regexp);
+                if (!sec.IsNull())
+                {
+                    section = 0;
+
+                    // Skip sections with the wrong telescope number
+                    if (!sec(regnum).IsNull() && !sec(regtel).IsNull())
+                        continue;
+
+                    // Check which section we are in
+                    if (sec.BeginsWith("[Transition"))
+                        section = 1;
+                    if (sec.BeginsWith("[Regexp]"))
+                        section = 2;
+                    continue;
+                }
+
+                if (section!=2)
+                {
+                    cout << "WARNING - Line starts with [ but we are not in the Regexp section." << endl;
+                    cout << txt << endl;
+                    continue;
+                }
             }
+
 
             TObjArray *arr = txt.Tokenize(" ");
@@ -705 +738 @@
     {
         return Form("SELECT RunData.f%sKEY, f%sName FROM RunData "
-                    "LEFT JOIN %s ON RunData.f%sKEY=%s.f%sKEY "
-                    "WHERE %s GROUP BY f%sName",
-                    col, col, col, col, col, col, cond, col);
+                    "LEFT JOIN %s USING (f%sKEY) WHERE %s GROUP BY f%sName",
+                    col, col, col, col, cond, col);
     }
 
@@ -864 +896 @@
         // Request data necessary to split block into sequences
         const TString query=
-            Form("SELECT fRunNumber, fRunTypeKEY, fRunStart, fRunStop"
+            Form("SELECT fRunNumber*1000+fFileNumber AS Id, fRunTypeKEY, fRunStart, fRunStop"
                  " FROM RunData "
-                 " WHERE fRunNumber BETWEEN %d AND %d AND "
+                 " WHERE fRunNumber*1000+fFileNumber BETWEEN %d AND %d AND "
                  " fExcludedFDAKEY=1 AND (fRunTypeKEY BETWEEN 2 AND 4)"
-                 " ORDER BY fRunNumber", runstart, runstop);
+                 " ORDER BY Id", runstart, runstop);
 
         // Send query
@@ -1084 +1116 @@
 
 public:
-    SequenceBuild(TEnv &env) : MSQLMagic(env)
-    {
-        cout << "buildsequences" << endl;
-        cout << "--------------" << endl;
-        cout << endl;
-        cout << "Connected to " << GetName() << endl;
-
+    SequenceBuild(Int_t tel=1, const char *rc="sql.rc") : MSQLMagic(rc), fTelescopeNumber(tel)
+    {
         fListRegexp.SetOwner();
 
@@ -1097 +1124 @@
             return;
     }
-    SequenceBuild()
+
+    SequenceBuild(TEnv &env, Int_t tel=1) : MSQLMagic(env), fTelescopeNumber(tel)
+    {
+        fListRegexp.SetOwner();
+
+        // FIXME: THIS IS NOT YET HANDLED
+        if (ReadResources("resources/sequences.rc"))
+            return;
+    }
+    ~SequenceBuild()
     {
         fMap.DeleteAll();
@@ -1113 +1149 @@
         const TString cond =
             Form("(fRunStart>ADDDATE(\"%s\", INTERVAL -1 DAY) AND fRunStart<\"%s\") "
-                 "AND fExcludedFDAKEY=1 AND fRunTypeKEY BETWEEN 2 AND 4 ",
-                 day.Data(), day.Data());
+                 "AND fExcludedFDAKEY=1 AND fRunTypeKEY BETWEEN 2 AND 4 "
+                 "AND fTelescopeNumber=%d ",
+                 day.Data(), day.Data(), fTelescopeNumber);
 
         //query all sources observed in this night
@@ -1128 +1165 @@
         // Setup query to get all values from the database,
         // that are relevant for building sequences
-        TString query("SELECT fRunNumber, fRunTypeKEY, ");
+        TString query("SELECT fRunNumber*1000+fFileNumber AS Id, fRunTypeKEY, ");
         query += elts;
         query += ", ";
@@ -1142 +1179 @@
                 query += mapkey->GetName();
             }
-        query += Form(" FROM RunData WHERE %s ORDER BY fRunNumber", cond.Data());
+        query += Form(" FROM RunData WHERE %s ORDER BY Id", cond.Data());
 
         TSQLResult *res = Query(query);
@@ -1176 +1213 @@
 ClassImp(SequenceBuild);
 
-int buildsequenceentries(TString day, TString datapath, TString sequpath, Bool_t dummy=kTRUE)
+int buildsequenceentries(TString day, TString datapath, TString sequpath, Int_t tel=1, Bool_t dummy=kTRUE)
 {
-    TEnv env("sql.rc");
-
-    SequenceBuild serv(env);
+    SequenceBuild serv(tel, "sql.rc");
     if (!serv.IsConnected())
     {
@@ -1186 +1221 @@
         return 0;
     }
+
+    cout << "buildsequenceentries" << endl;
+    cout << "--------------------" << endl;
+    cout << endl;
+    cout << "Connected to " << serv.GetName() << endl;
+    if (!datapath.IsNull())
+        cout << "DataPath:  " << datapath << endl;
+    if (!sequpath.IsNull())
+        cout << "SeqPath:   " << sequpath << endl;
+    cout << "Day:       " << day      << endl;
+    cout << "Telescope: " << tel      << endl;
+    cout << endl;
 
     serv.SetIsDummy(dummy);
@@ -1196 +1243 @@
 // Build Sequences for all Nights
 //
-int buildsequenceentries(TString datapath, TString sequpath, Bool_t dummy=kTRUE)
+int buildsequenceentries(TString datapath, TString sequpath, Int_t tel=1, Bool_t dummy=kTRUE)
 {
-    TEnv env("sql.rc");
-
-    SequenceBuild serv(env);
+    SequenceBuild serv(tel, "sql.rc");
     if (!serv.IsConnected())
     {
@@ -1206 +1251 @@
         return 0;
     }
+
+    cout << "buildsequenceentries" << endl;
+    cout << "--------------------" << endl;
+    cout << endl;
+    cout << "Connected to " << serv.GetName() << endl;
+    cout << "DataPath:  " << datapath << endl;
+    cout << "SeqPath:   " << sequpath << endl;
+    cout << "Telescope: " << tel      << endl;
+    cout << endl;
 
     serv.SetIsDummy(dummy);
@@ -1213 +1267 @@
 }
 
-int buildsequenceentries(Bool_t dummy=kTRUE)
+int buildsequenceentries(Int_t tel=1, Bool_t dummy=kTRUE)
 {
-    return buildsequenceentries("", "", dummy);
+    return buildsequenceentries("", "", tel, dummy);
 }
 
-int buildsequenceentries(TString day, Bool_t dummy=kTRUE)
+int buildsequenceentries(TString day, Int_t tel=1, Bool_t dummy=kTRUE)
 {
-    return buildsequenceentries(day, "", "", dummy);
+    return buildsequenceentries(day, "", "", tel, dummy);
 }