Changeset 19684 for trunk/FACT++

Timestamp:

09/27/19 16:27:20 (5 years ago)

Author:

Daniela Dorner

Message:

added new algorithms (visiblity ratio, time-shift) and featues (plotting, zd-histogram)

File:

• trunk/FACT++/src/makeschedule.cc (modified) (28 diffs)

trunk/FACT++/src/makeschedule.cc

@@ -19 +19 @@
     control.add_options()
         ("date", var<string>(), "SQL time (UTC), e.g. '2016-12-24' (equiv. '2016-12-24 12:00:00' to '2016-12-25 11:59:59')")
+        ("svg", var<string>(), "File name to write a SVG file. Use together with --loop")
+        ("hist", var<string>(), "File name to write a histogram file. Use together with --loop; default: false")
+        ("loop", var<uint16_t>(uint16_t(0)), "Number of days to loop over (0:default, >=1:turns off database entry)")
         ("source-database", var<string>()->required(), "Database link as in\n\tuser:password@server[:port]/database[?compress=0|1].")
         ("schedule-database", var<string>(), "Database link as in\n\tuser:password@server[:port]/database[?compress=0|1].")
         ("max-current", var<double>(90), "Global maximum current limit in uA")
         ("max-zd", var<double>(75), "Global zenith distance limit in degree")
+        ("min-moon", var<double>(5), "Minimum angular separation to moon in degree")
+        ("exponent-visibility-ratio", var<double>(1), "Global exponent for visibility ratio")
+        ("exponent-time-shift", var<double>(1), "Global exponent for time shift visibility ratio")
         ("source", vars<string>(), "List of all TeV sources to be included, names according to the database")
         ("setup.*", var<double>(), "Setup for the sources to be observed")
@@ -29 +35 @@
         ("data-taking.start", var<double>(-12), "Begin of data-taking in degree of sun below horizon")
         ("data-taking.end", var<double>(-13.75), "End of data-taking in degree of sun below horizon")
+        ("use-visibility-ratio", po_bool(), "Use visibility ratio for scaling of threshold)")
+        ("use-lst-shadow", po_bool(), "Respect shadow from LST for scheduling")
+        ("print-hist", var<bool>(), "Print histogram to console; default: false)")
         ("enter-schedule-into-database", var<bool>(), "Enter schedule into database (required schedule-database, false: dry-run)")
         ;
@@ -34 +43 @@
     po::positional_options_description p;
     p.add("date", 1); // The first positional options
+    p.add("loop", 1); // The first positional options
 
     conf.AddOptions(control);
@@ -44 +54 @@
         "makeschedule - Creates an automatic schedule\n"
         "\n"
-        "Usage: makeschedule [yyyy-mm-dd]\n";
+        "Usage: makeschedule [yyyy-mm-dd [N]]\n";
     cout << endl;
 }
@@ -50 +60 @@
 void PrintHelp()
 {
-#ifdef HAVE_ROOT
     cout <<
         "First for each minute of the night a list is calculated of all "
-        "selected sources fulfiling all global and all source specific "
+        "selected sources fulfilling all global and all source specific "
         "constraints, e.g. on the zenith distance or the current.\n"
         "\n"
@@ -105 +114 @@
         "\n";
     cout << endl;
-#endif
 }
 
@@ -141 +149 @@
     static double max_current;
     static double max_zd;
-
-    // Source descrition
+    static double min_moon;
+    static double vis_exponent;
+    static double ts_exponent;
+    static bool   vis_ratio;
+    static bool   lst_shadow;
+
+    // Source description
     string name;
     uint16_t key;
@@ -151 +164 @@
     MyDouble maxcurrent;
     double penalty;
+    double time_shift;
+    double visexponent;
+    double tsexponent;
+
+    // Derived values
+    double visratio;
+    double timeshift;
 
     // Possible observation time
@@ -168 +188 @@
     //bool IsSpecial() const { return threshold==std::numeric_limits<double>::max(); }
 
+    //distribution of zenith distance
+    int zddistr[90];
+
     double zd(const double &jd) const
     {
@@ -173 +196 @@
     }
 
+    /*
+     // See https://www.fact-project.org/logbook/showthread.php?tid=6601
+
+     75 -135    outmost knot left side
+     70 -134    tower left side
+     65 -128    dish left side
+     58 -125    intermediate position of dish on left side
+     52 -118    intermediate position of dish on left side
+     50 ~ -110  top of dish - to have the rail outside the FoV zd has to be 49 (see attached picture taken at zd50, az-113.5)
+     52 -100    intermediate position of dish on right side
+     58 -92     intermediate position of dish on right side
+     65 -89     dish right side
+     71 -85     tower right side
+     75 -84     outmost knot right side
+     */
+
+    bool HasShadowFromLST(const ZdAzPosn &hrz) const
+    {
+        return (hrz.zd > 0.0379373*pow(hrz.az+109.23, 2) + 49.1224)
+            || (hrz.az>-79 && hrz.az<=-59 && hrz.zd>=70);
+    }
+
     bool valid(const SolarObjects &so) const
     {
-        const HrzPosn hrz     = GetHrzFromEqu(equ, so.fJD);
-        const double  current = FACT::PredictI(so, equ);
+        const ZdAzPosn hrz      = GetHrzFromEqu(equ, so.fJD+timeshift);
+        const ZdAzPosn true_hrz = timeshift==0 ? hrz : ZdAzPosn(GetHrzFromEqu(equ, so.fJD));
+        const double   current  = FACT::PredictI(so, equ);
 
         if (current>max_current)
             return false;
 
-        if (hrz.alt<=0 || 90-hrz.alt>max_zd)
+        if (true_hrz.zd>max_zd)
             return false;
 
-        if (maxzd.valid && 90-hrz.alt>maxzd.val)
+        if (maxzd.valid && true_hrz.zd>maxzd.val)
             return false;
 
+        if (lst_shadow && HasShadowFromLST(true_hrz))
+            return false;
+
         if (maxcurrent.valid && current>maxcurrent.val)
+            return false;
+
+        if (Nova::GetAngularSeparation(so.fMoonEqu, equ)<min_moon)
             return false;
 
@@ -205 +257 @@
     double getThreshold(const SolarObjects &so) const
     {
-        const HrzPosn hrz = GetHrzFromEqu(equ, so.fJD);
-        const double  current = FACT::PredictI(so, equ);
-
-        const double ratio = pow(cos((90-hrz.alt)*M_PI/180), -2.664);
-
-        return penalty*ratio*pow(current/6.2, 0.394);
+        const ZdAzPosn hrz     = GetHrzFromEqu(equ, so.fJD+timeshift);
+        const double   current = FACT::PredictI(so, equ);
+
+        const double ratio = pow(cos(hrz.zd*M_PI/180), -2.664);
+        const double ratio2 = pow(current/6.2, 0.394);
+
+        return penalty*visratio*ratio*ratio2;
     }
 
     bool calcThreshold(const SolarObjects &so)
     {
-        const HrzPosn hrz     = GetHrzFromEqu(equ, so.fJD);
-        const double  current = FACT::PredictI(so, equ);
+        const ZdAzPosn hrz      = GetHrzFromEqu(equ, so.fJD+timeshift);
+        const ZdAzPosn true_hrz = timeshift==0 ? hrz : ZdAzPosn(GetHrzFromEqu(equ, so.fJD));
+        const double   current  = FACT::PredictI(so, equ);
 
         if (current>max_current)
             return false;
 
-        if (hrz.alt<=0 || 90-hrz.alt>max_zd)
+        if (true_hrz.zd>max_zd)
             return false;
 
-        if (maxzd.valid && 90-hrz.alt>maxzd.val)
+        if (maxzd.valid && true_hrz.zd>maxzd.val)
+            return false;
+
+        if (lst_shadow && HasShadowFromLST(true_hrz))
             return false;
 
@@ -230 +287 @@
             return false;
 
-        const double ratio = pow(cos((90-hrz.alt)*M_PI/180), -2.664);
-        threshold = penalty*ratio*pow(current/6.2, 0.394);
+        if (Nova::GetAngularSeparation(so.fMoonEqu, equ)<min_moon)
+            return false;
+
+        const double ratio = pow(cos(hrz.zd*M_PI/180), -2.664);
+        const double ratio2 = pow(current/6.2, 0.394);
+
+        threshold = penalty*visratio*ratio*ratio2;
 
         return true;
@@ -239 +301 @@
 double Source::max_zd;
 double Source::max_current;
+double Source::min_moon;
+double Source::vis_exponent;
+double Source::ts_exponent;
+bool Source::vis_ratio;
+bool Source::lst_shadow;
 
 bool SortByThreshold(const Source &i, const Source &j) { return i.threshold<j.threshold; }
@@ -367 +434 @@
 bool RescheduleIntermediateSources(vector<Source> &obs)
 {
+    bool changed = false;
+
     for (size_t i=1; i<obs.size()-1; i++)
     {
@@ -413 +482 @@
         cout << "Intermediate source [" << obs[i].name << "] removed" << endl;
 
-        const bool underflow = obs[i-1].duration()*24*60<40 || obs[i+1].duration()*24*60<40;
+        // const bool underflow = obs[i-1].duration()*24*60<40 || obs[i+1].duration()*24*60<40;
 
         obs[i-1].end   = intersection;
@@ -421 +490 @@
         i--;
 
+        changed = true;
+
         if (obs.size()>1 && obs[i].name==obs[i+1].name)
         {
@@ -433 +504 @@
         }
 
-        if (underflow)
-            cout << "WARNING - Neighbor source < 40min as well." << endl;
-    }
-    return false;
-}
-
-void RemoveMiniSources(vector<Source> &obs)
-{
+        // if (underflow)
+        //     cout << "WARNING - Neighbor source < 40min as well." << endl;
+    }
+    return changed;
+}
+
+// Remove mini source is able to violate limits
+bool RemoveMiniSources(vector<Source> &obs)
+{
+    bool changed = false;
+
     for (size_t i=1; i<obs.size()-1; i++)
     {
@@ -446 +520 @@
             continue;
 
-        if (obs[i-1].name=="SLEEP" && obs[i+1].name=="SLEEP")
+        // if (obs[i-1].name=="SLEEP" && obs[i+1].name=="SLEEP")
+        //     continue;
+
+        cout << "Mini source [" << obs[i].name << "] detected < 5min" << endl;
+
+        if (obs[i-1].name==obs[i+1].name)
+        {
+            cout << "Combined surrounding identical sources [" << obs[i-1].name << "]" << endl;
+
+            obs[i-1].end = obs[i+1].end;
+            obs.erase(obs.begin()+i, obs.begin()+i+1);
+            i -= 2;
+
+            changed = true;
+
             continue;
-
-        cout << "Mini source [" << obs[i].name << "] detected < 5min" << endl;
-
+        }
+
+        /*
         if (obs[i-1].name=="SLEEP" && obs[i+1].name=="SLEEP")
         {
@@ -460 +548 @@
             i -= 2;
 
+            changed = true;
+
             cout << "Combined two surrounding sleep into one" << endl;
 
             continue;
-        }
+        }*/
+
+        // Note that this (intentionally) violates our safety limits
 
         if (obs[i-1].name=="SLEEP")
         {
+            cout << "Preceding SLEEP detected... extended next source [" << obs[i+1].name << "]" << endl;
+
             obs[i-1].end = obs[i+1].begin;
             obs.erase(obs.begin()+i);
             i--;
 
-            cout << "Extended previous sleep" << endl;
+            changed = true;
 
             continue;
@@ -478 +572 @@
         if (obs[i+1].name=="SLEEP")
         {
-            obs[i+1].begin = obs[i-1].end;
+            cout << "Following SLEEP detected... extended previous source [" << obs[i-1].name << "]" << endl;
+
+            obs[i-1].end = obs[i+1].begin;
             obs.erase(obs.begin()+i);
-
-            cout << "Extended following sleep" << endl;
-
             i--;
+
+            changed = true;
+
             continue;
         }
-    }
+
+        // Algorithm based on RescheduleIntermediateSources
+        // Note that this (intentionally) violates our safety limits
+
+        const SolarObjects so1(obs[i-1].end);
+        const SolarObjects so2(obs[i+1].begin);
+
+        const double th1 = obs[i-1].getThreshold(so1);
+        const double th2 = obs[i+1].getThreshold(so2);
+
+        const double intersection = th1<th2 ? obs[i+1].begin : obs[i-1].end;
+
+        cout << "Intermediate mini source [" << obs[i].name << "] detected" << endl;
+        cout << (th1<th2?"Previous":"Next") << " source [" << (th1<th2?obs[i-1].name:obs[i+1].name) << "] extended" << endl;
+
+        obs[i-1].end   = intersection;
+        obs[i+1].begin = intersection;
+        obs.erase(obs.begin()+i);
+
+        i--;
+
+        changed = true;
+    }
+
+    return changed;
 }
 
@@ -504 +624 @@
 }
 
-void Print(const vector<Source> &obs, double startup_offset)
-{
-    cout << Time(obs[0].begin-startup_offset).GetAsStr() << "  STARTUP\n";
+void Print(char id, const vector<Source> &obs, double startup_offset)
+{
+    cout << id << " " << Time(obs[0].begin-startup_offset).GetAsStr() << "  STARTUP\n";
     for (const auto& src: obs)
     {
@@ -514 +634 @@
             for (const auto& pre: src.preobs)
             {
-                cout << tm << "  " << pre << "\n";
+                cout << id << " " << tm << "  " << pre << "\n";
                 tm = "                   ";
             }
         }
 
-        cout << tm << "  " << src.name << " [";
+        cout << id << " " << tm << "  " << src.name << " [";
         cout << src.duration()*24*60 << "'";
         if (src.name!="SLEEP")
-            cout << Tools::Form("; %.1f/%.1f", src.zd(src.begin), src.zd(src.end));
+            cout << Tools::Form("; %.1f/%.1f; %.2f; %.2fh", src.zd(src.begin), src.zd(src.end), src.visratio, src.timeshift*24);
         cout << "]";
 
@@ -530 +650 @@
         cout << "\n";
     }
-    cout << Time(obs.back().end).GetAsStr() << "  SHUTDOWN" << endl;
+    cout << id << " " << Time(obs.back().end).GetAsStr() << "  SHUTDOWN" << endl;
+}
+
+void PrintRect(ofstream &svg, const uint16_t &x, const int16_t &y, const uint16_t &w, const uint16_t &h, const Source &src)
+{
+    static vector<string> colors =
+    {
+        "gray",     // rgb(0,0,0)
+        "red",
+        "olive",
+        "blue",
+        "maroon",
+        "green",
+        "teal",
+        "navy",
+        "purple",
+        "silver",
+        "lime",
+        "fuchsia",
+        "yellow",
+    };
+
+    static map<uint16_t, uint16_t> col_keys;
+
+    const auto ic = col_keys.find(src.key);
+    if (ic==col_keys.end())
+    {
+        if (col_keys.size()>=colors.size())
+            cerr << "WARNING: More different sources (" << col_keys.size() << ") than colors (" << colors.size() << ")." << endl;
+
+        const auto n = col_keys.size();
+
+        col_keys[src.key] = n%colors.size();
+
+        svg << "<g>\n";
+        svg << " <rect x=\"" << 0 << "\" y=\"" << n*18    << "\" width=\"140\" height=\"18\" fill=\"" << colors[col_keys[src.key]] << "\"/>\n";
+        svg << " <text x=\"" << 0 << "\" y=\"" << n*18+14 << "\" font-family=\"Verdana\" font-size=\"16\" fill=\"white\">" << src.name << "</text>\n";
+        svg << "</g>\n";
+    }
+
+    const string color = colors[col_keys[src.key]];
+
+    svg << "<g>\n";
+    svg << " <defs>\n";
+    svg << "  <linearGradient x1=\"0\" x2=\"0\" y1=\"0\" y2=\"1\" id=\"grad\">\n";
+
+    for (int i=0; i<11; i++)
+    {
+        const double opa = 1-src.zd(src.begin+(src.end-src.begin)*0.10*i)/(src.maxzd.valid?src.maxzd.val:src.max_zd);
+        svg << "   <stop style=\"stop-color:" << color << "; stop-opacity:" << opa << "\" offset=\"" << i*10 << "%\"/>\n";
+    }
+    svg << "  </linearGradient>\n";
+    svg << " </defs>\n";
+
+    svg << " <rect";
+    svg << " x=\"" << x*w+150 << "\"";
+    svg << " y=\"" << y << "\"";
+    svg << " width=\""  << w << "\"";
+    svg << " height=\"" << h << "\"";
+    svg << " style=\"fill:url(#grad);\"";
+    svg << "/>\n";
+    svg << "</g>\n";
+}
+
+
+void PrintSVG(ofstream &svg, const uint16_t &scale, const Time &T0, const vector<Source> &obs)
+{
+    const double jd = floor(T0.JD());
+
+    for (const auto& src: obs)
+    {
+        if (src.preobs.size()>0 || src.key==0 || src.name=="SLEEP")
+            continue;
+
+        const double diff = src.begin-jd;
+
+        const uint32_t b = 24*60*diff;
+        const uint32_t d = 24*60*(src.end-src.begin)+0.5;
+
+        PrintRect(svg, diff, b%(24*60)-6*60, scale, d, src);
+    }
 }
 
@@ -594 +794 @@
 }
 
-int main(int argc, const char* argv[])
-{
-//    gROOT->SetBatch();
-
-    Configuration conf(argv[0]);
-    conf.SetPrintUsage(PrintUsage);
-    SetupConfiguration(conf);
-
-    if (!conf.DoParse(argc, argv, PrintHelp))
-        return 127;
-
-    // ------------------ Eval config ---------------------
-
-    const int enter = conf.Has("enter-schedule-into-database") ? (conf.Get<bool>("enter-schedule-into-database") ? 1 : -1) : 0;
-    if (enter && !conf.Has("schedule-database"))
-        throw runtime_error("enter-schedule-into-database required schedule-database.");
-
-    Time time;
-    if (conf.Has("date"))
-        time.SetFromStr(conf.Get<string>("date")+" 12:00:00");
-
-    if (enter && floor(time.JD())<ceil(Time().JD()))
-        throw runtime_error("Only future schedules can be entered into the database.");
-
-    Source::max_current = conf.Get<double>("max-current");
-    Source::max_zd      = conf.Get<double>("max-zd");
-
-    const double startup_offset = conf.Get<double>("startup.offset")/60/24;
-
-    const double angle_sun_set  = conf.Get<double>("data-taking.start");
-    const double angle_sun_rise = conf.Get<double>("data-taking.end");
-
-    if (startup_offset<0 || startup_offset>120)
-        throw runtime_error("Only values [0;120] are allowed for startup.offset");
-
-    if (angle_sun_set>-6)
-        throw runtime_error("datataking.start not allowed before sun at -6deg");
-
-    if (angle_sun_rise>-6)
-        throw runtime_error("datataking.end not allowed after sun at -6deg");
-
-    // -12: nautical
-    // Sun set with the same date than th provided date
-    // Sun rise on the following day
-    const RstTime sun_set  = GetSolarRst(floor(time.JD())-0.5, angle_sun_set);
-    const RstTime sun_rise = GetSolarRst(floor(time.JD())+0.5, angle_sun_rise);
-
-    const double sunset  = ceil(sun_set.set*24*60)   /24/60 + 1e-9;
-    const double sunrise = floor(sun_rise.rise*24*60)/24/60 + 1e-9;
-
-    cout << "\n";
-
-    cout << "Date: " << Time(floor(sunset)).GetAsStr() << "\n";
-    cout << "Set:  " << Time(sunset).GetAsStr()  << "  [" << Time(sun_set.set)   << "]\n";
-    cout << "Rise: " << Time(sunrise).GetAsStr() << "  [" << Time(sun_rise.rise) << "]\n";
-
-    cout << "\n";
-
-    cout << "Global maximum current:  " << Source::max_current << " uA/pix\n";
-    cout << "Global zenith distance:  " << Source::max_zd << " deg\n";
-
-    cout << "\n";
-
-    // ------------- Get Sources from databasse ---------------------
-
-    const vector<string> ourcenames = conf.Vec<string>("source");
+vector<Source> GetSources(Configuration &conf)
+{
     const vector<string> sourcenames = conf.Vec<string>("source");
     cout << "Nsources = " << sourcenames.size() << "\n";
@@ -676 +812 @@
     for (const auto &row: res)
     {
+        //cout << endl;
         const string name = string(row[0]);
 
@@ -687 +824 @@
         src.penalty = conf.Has("setup."+name+".penalty") ?
             conf.Get<double>("setup."+name+".penalty") : 1;
+        src.visexponent = conf.Has("setup."+name+".exponent-visibility-ratio") ?
+            conf.Get<double>("setup."+name+".exponent-visibility-ratio") : 1;
+        src.tsexponent = conf.Has("setup."+name+".exponent-time-shift") ?
+            conf.Get<double>("setup."+name+".exponent-time-shift") : 1;
+        src.time_shift = conf.Has("setup."+name+".time-shift") ?
+            conf.Get<double>("setup."+name+".time-shift")/24 : 0;
 
         src.preobs = conf.Vec<string>("preobs."+name);
 
-
-        cout << "[" << name << "]";
+        cout << "[" << src.key << ":" << name << "]";
 
         if (src.maxzd.valid)
@@ -697 +839 @@
         if (src.penalty!=1)
             cout << " Penalty=" << src.penalty;
+        if (src.visexponent!=1)
+            cout << " Exponent [VR]=" << src.visexponent;
+        if (src.tsexponent!=1)
+            cout << " Exponent [TS]=" << src.tsexponent;
+        if (src.time_shift!=0)
+            cout << " Time-shift=" << src.time_shift*24 << "h";
 
         cout << " " << boost::algorithm::join(src.preobs, "+") << endl;
 
+        for (int k=0; k<90; k++)
+            src.zddistr[k]=0;
         /*
          RstTime t1 = GetObjectRst(floor(sunset)-1, src.equ);
@@ -713 +863 @@
     cout << endl;
 
-    // -------------------------------------------------------------------------
-
-    vector<Source> obs;
-
-    const uint32_t n = nearbyint((sunrise-sunset)*24*60);
-    for (uint32_t i=0; i<n; i++)
-    {
-        const double jd = sunset + i/24./60.;
-
-        const SolarObjects so(jd);
-
-        vector<Source> vis;
+    return sources;
+}
+
+int main(int argc, const char* argv[])
+{
+//    gROOT->SetBatch();
+
+    Configuration conf(argv[0]);
+    conf.SetPrintUsage(PrintUsage);
+    SetupConfiguration(conf);
+
+    if (!conf.DoParse(argc, argv, PrintHelp))
+        return 127;
+
+    // ------------------ Eval config ---------------------
+
+    const int enter = conf.Has("enter-schedule-into-database") ? (conf.Get<bool>("enter-schedule-into-database") ? 1 : -1) : 0;
+    if (enter && !conf.Has("schedule-database"))
+        throw runtime_error("enter-schedule-into-database requires schedule-database.");
+
+    Time time;
+    if (conf.Has("date"))
+        time.SetFromStr(conf.Get<string>("date")+" 12:00:00");
+    else
+        time=floor(Time().JD());
+
+    /*
+    cout << "-------> " << setprecision(12) << time.JD() << endl;
+    cout << "         " << time.GetAsStr()
+        << " " << ceil(Time().JD())
+        << " " << floor(Time().JD())
+        << endl;
+    */
+    const uint16_t loop = conf.Get<uint16_t>("loop");
+
+    if (enter && floor(time.JD())<ceil(Time().JD()))
+        throw runtime_error("Only future schedules can be entered into the database.");
+
+    Source::max_current = conf.Get<double>("max-current");
+    Source::max_zd      = conf.Get<double>("max-zd");
+    Source::min_moon    = conf.Get<double>("min-moon");
+    Source::vis_exponent= conf.Get<double>("exponent-visibility-ratio");
+    Source::ts_exponent = conf.Get<double>("exponent-time-shift");
+    Source::vis_ratio   = conf.Get<bool>("use-visibility-ratio");
+    Source::lst_shadow  = conf.Get<bool>("use-lst-shadow");
+
+    const double startup_offset = conf.Get<double>("startup.offset")/60/24;
+
+    const double angle_sun_set  = conf.Get<double>("data-taking.start");
+    const double angle_sun_rise = conf.Get<double>("data-taking.end");
+
+    if (startup_offset<0 || startup_offset>120)
+        throw runtime_error("Only values [0;120] are allowed for startup.offset");
+
+    if (angle_sun_set>-6)
+        throw runtime_error("datataking.start not allowed before sun at -6deg");
+
+    if (angle_sun_rise>-6)
+        throw runtime_error("datataking.end not allowed after sun at -6deg");
+
+    cout << "\n";
+
+    cout << "Global maximum current allowed:  " << Source::max_current << " uA/pix\n";
+    cout << "Global maximum zenith distance:  " << Source::max_zd      << " deg\n";
+    cout << "Min. angular separation to moon: " << Source::min_moon    << " deg\n";
+
+    cout << "\n";
+
+    // ------------- SVG ---------------------------------------------
+
+    const uint16_t svgscale = loop>0 ? ::min((2*1080)/loop, 5) : 0;
+
+    ofstream svg;
+    if (conf.Has("svg") && loop>0)
+    {
+        svg.open(conf.Get<string>("svg"));
+        if (!svg)
+        {
+            cerr << "ERROR: Writing to '" << conf.Get<string>("svg") << "' failed: " << strerror(errno) << endl;
+            return 1;
+        }
+
+        svg << "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n";
+        svg << "<svg width=\""  << loop*svgscale+150 << "\" height=\"840\" xmlns=\"http://www.w3.org/2000/svg\">\n";
+        svg << "<rect width=\"" << loop*svgscale+150 << "\" height=\"840\" fill=\"black\"/>\n";
+
+        //svg << "<svg width=\"" << loop*svgscale+150 << "\" height=\"840\">\n";
+        //svg << "<rect x=\"0\" y=\"0\" width=\"" << loop*svgscale+150 << "\" height=\"840\" fill=\"black\"/>\n";
+    }
+
+    // ------------- Get Sources from databasse ---------------------
+
+    vector<Source> sources = GetSources(conf);
+
+    //cout << "VR: " << Source::vis_ratio << endl;
+
+    const uint16_t N = ::max<uint16_t>(loop, 1);
+    for (int iday=0; iday<N; iday++)
+    {
+        // ----------- Define time slots for the day ---------------------
+
+        // -12: nautical
+        // Sun set with the same date than th provided date
+        // Sun rise on the following day
+        const RstTime sun_set  = GetSolarRst(floor(time.JD()+iday)-0.5, angle_sun_set);
+        const RstTime sun_rise = GetSolarRst(floor(time.JD()+iday)+0.5, angle_sun_rise);
+
+        const double sunset  = ceil(sun_set.set*24*60)   /24/60 + 1e-9;
+        const double sunrise = floor(sun_rise.rise*24*60)/24/60 + 1e-9;
+
+        cout << "Date: " << Time(floor(sunset)).GetAsStr() << "\n";
+        cout << "Set:  " << Time(sunset).GetAsStr()  << "  [" << Time(sun_set.set)   << "]\n";
+        cout << "Rise: " << Time(sunrise).GetAsStr() << "  [" << Time(sun_rise.rise) << "]\n";
+        cout << "\n";
+
+        const double vis_sun = sun_rise.rise - sun_set.set;
+
         for (auto& src: sources)
         {
-            if (src.calcThreshold(so))
-                vis.emplace_back(src);
+            const double maxzd = min(Source::max_zd, src.maxzd.valid?src.maxzd.val:90);
+
+            int8_t sign = 0;
+
+            RstTime rst;
+            const int rc = GetObjectRst(rst, src.equ, sun_set.set, 90-maxzd);
+            switch (rc)
+            {
+            case -1:
+                // circumpolar below horizon - not visible
+                src.visratio = 0;
+                break;
+
+            case 0:
+                {
+                    // Although, according to the documentation, everything should be alinged
+                    // between JD and JD+1, it is not... therefore, we align ourselves
+                    if (rst.rise-sun_set.set>1)
+                        rst.rise -= 1;
+                    if (rst.set-sun_set.set>1)
+                        rst.set -= 1;
+                    if (rst.rise-sun_set.set<0)
+                        rst.rise += 1;
+                    if (rst.set-sun_set.set<0)
+                        rst.set += 1;
+
+                    // Now: rst.rise/rst.set is aligned between sunset and sunset+1:
+                    //
+                    //              JD                                 JD+1
+                    // 1) SUN.SET |                        | sun.rise  RST.RISE rst.set  ... SUN.SET |
+                    // 2) SUN.SET |++++++++++++++++++++++++| sun.rise  rst.set  RST.RISE ... SUN.SET |
+                    // 3) SUN.SET |       RST.RISE+++++++++| sun.rise  rst.set           ... SUN.SET |
+                    // 4) SUN.SET |++++++++rst.set         | sun.rise  rst.rise          ... SUN.SET |
+                    // 5) SUN.SET |  RST.RISE+++rst.set    | sun.rise                    ... SUN.SET |
+                    // 6) SUN.SET |+++rst.set   RST.RISE+++| sun.rise                    ... SUN.SET |
+
+                    if (rst.rise<sun_rise.rise && sun_rise.rise<rst.set)
+                        sign = 1;
+                    if (rst.set<sun_rise.rise && sun_rise.rise<rst.rise)
+                        sign = -1;
+
+                    // Identify case 6
+                    const bool case6 = rst.set<rst.rise && rst.rise<sun_rise.rise;
+
+                    // make sure that the visibility calculation of the source
+                    // yields positive valiues and the overlap calculation works
+                    if (rst.set<rst.rise)
+                        rst.rise -= 1;
+
+                    // Now: rst.rise is always before rst.set
+                    //
+                    //                    JD                               JD+1
+                    // 1) ...          SUN.SET |                        | sun.rise  RST.RISE rst.set ...
+                    // 2) ... RST.RISE SUN.SET |++++++++++++++++++++++++| sun.rise  rst.set          ...
+                    // 3) ...          SUN.SET |       RST.RISE+++++++++| sun.rise  rst.set          ...
+                    // 4) ... RST.RISE SUN.SET |++++++++rst.set         | sun.rise  rst.rise         ...
+                    // 5) ...          SUN.SET |  RST.RISE+++rst.set    | sun.rise                   ...
+                    // 6) ... RST.RISE SUN.SET |+++rst.set  [RST.RISE]++| sun.rise                   ...
+
+                    // Total visibility of the source itself (this is now always positive)
+                    const double vis_rst = rst.set-rst.rise;
+
+                    // Calculate overlap region
+                    // Visibility of the source between sunset and sunrise
+                    const double vis_night = case6 ? vis_sun - (1-vis_rst) : min(rst.set, sun_rise.rise) - max(rst.rise, sun_set.set);
+
+                    //vis_sun-(1-vis_rst) = vis_sun-(1-(set-rise)) = vis_sun-(1-(set-(rise-1))) = vis_sun-(1-set+(rise-1)) = vis_sun-(rise-set)
+
+                    // General visibility of the source (but maximum one night)
+                    const double vis_total = min(vis_rst, vis_sun);
+
+                    // Special treatment of case 1 (vis_night<0 means that there is no overlap)
+                    src.visratio = vis_night<0 ? 0 : vis_night / vis_total;
+
+                    // cout << src.name << "   " << Time(rst.rise).GetAsStr() << "   " << Time(rst.set).GetAsStr() << "   " << vis_night << " " << vis_total << " " << vis_rst << " " << vis_sun << " " << case6 << " " << test << endl;
+                    break;
+                }
+
+            case 1:
+                // circumpolar above horizon -> always visible
+                src.visratio = 1;
+                break;
+            }
+
+            src.timeshift = src.time_shift * sign*(1-pow(src.visratio, src.tsexponent*Source::ts_exponent));
+
+            src.visratio = Source::vis_ratio ? pow(src.visratio, src.visexponent*Source::vis_exponent) : 1;
         }
 
-        // In case no source was found, add a sleep source
-        Source src("SLEEP");
-        vis.emplace_back(src);
-
-        // Source has higher priority if minimum observation time not yet fullfilled
-        sort(vis.begin(), vis.end(), SortByThreshold);
-
-        if (obs.size()>0 && obs.back().name==vis[0].name)
+        // -------------------------------------------------------------------------
+
+        vector<Source> obs;
+
+        const uint32_t n = nearbyint((sunrise-sunset)*24*60);
+        for (uint32_t i=0; i<n; i++)
+        {
+            const double jd = sunset + i/24./60.;
+
+            const SolarObjects so(jd);
+
+            vector<Source> vis;
+            for (auto& src: sources)
+            {
+                if (src.calcThreshold(so))
+                    vis.emplace_back(src);
+            }
+
+            // In case no source was found, add a sleep source
+            Source src("SLEEP");
+            vis.emplace_back(src);
+
+            // Source has higher priority if minimum observation time not yet fullfilled
+            sort(vis.begin(), vis.end(), SortByThreshold);
+
+            if (obs.size()>0 && obs.back().name==vis[0].name)
+                continue;
+
+            vis[0].begin = jd;
+            obs.emplace_back(vis[0]);
+        }
+
+        if (obs.size()==0)
+        {
+            cout << "No source found." << endl;
+            return 1;
+        }
+
+        // -------------------------------------------------------------------------
+
+        for (auto it=obs.begin(); it<obs.end()-1; it++)
+            it[0].end = it[1].begin;
+        obs.back().end = sunrise;
+
+        // -------------------------------------------------------------------------
+
+        Print('-', obs, startup_offset);
+        cout << endl;
+
+        // -------------------------------------------------------------------------
+
+        while (RescheduleFirstSources(obs));
+        while (RescheduleLastSources(obs));
+        while (RescheduleIntermediateSources(obs));
+        while (RemoveMiniSources(obs));
+
+        CheckStartupAndShutdown(obs);
+
+        // ---------------------------------------------------------------------
+
+        cout << endl;
+        Print('*', obs, startup_offset);
+        cout << endl;
+
+        // ---------------------------------------------------------------------
+
+        //fill zd-distribution
+        for (auto& src2: sources)
+        {
+            //cout << "source: " << src2.name << " " << src2.key << endl;
+            for (const auto& src: obs)
+            {
+                //cout << "source: " << src.name << " " << src.key << endl;
+                const uint32_t n2 = nearbyint((src.end-src.begin)*24*60);
+                for (uint32_t i=0; i<n2; i++)
+                {
+                    const double jd = src.begin + i/24./60.;
+                    const int zd = (int)src.zd(jd);
+                    //cout << " zd:" << floor(zd) << " " << zd << endl;
+                    //cout << " zd: " << zd << " " << src2.zddistr[zd] << flush;
+                    if (src.key==src2.key)
+                    {
+                        //cout << " -> " << flush;
+                        src2.zddistr[zd]++;
+                    }
+                    //cout << " " << src2.zddistr[zd] << endl;
+                }
+            }
+        }
+
+        // ---------------------------------------------------------------------
+
+        if (svg.is_open())
+            PrintSVG(svg, svgscale, time, obs);
+
+        // ---------------------------------------------------------------------
+
+        if (loop>0)
             continue;
 
-        vis[0].begin = jd;
-        obs.emplace_back(vis[0]);
-    }
-
-    if (obs.size()==0)
-    {
-        cout << "No source found." << endl;
+        if (!enter)
+            return 0;
+
+        const string scheduledb = conf.Get<string>("schedule-database");
+
+        Database db(scheduledb);
+
+        if (enter>0)
+            db.query("LOCK TABLES Schedule WRITE");
+
+        const int rc = FillSql(db, enter, obs, startup_offset);
+
+        if (enter>0)
+            db.query("UNLOCK TABLES");
+
+        return rc;
+    }
+
+    if (svg.is_open())
+        svg << "</svg>" << endl;
+
+    // ---------------------------------------------------------------------
+    if (conf.Has("print-hist") && conf.Get<bool>("print-hist"))
+    {
+        for (const auto& src: sources)
+        {
+            cout << "ZD-DISTRIBUTION [" << src.name << "]: " << flush;
+            //print zd-distr
+            for (int k=0; k<90; k++)
+                cout << src.zddistr[k] << " " << flush;
+            cout << endl;
+            //plot zd-distr
+            for (int k=0; k<90; k++)
+            {
+                if (src.zddistr[k]==0)
+                    continue;
+                printf("%02d", k);
+                for (int k2=0; k2<(int)(src.zddistr[k]/loop); k2++)
+                    cout << "*" << flush;
+                cout << endl;
+            }
+        }
+    }
+
+    if (!conf.Has("hist"))
+        return 0;
+
+    ofstream hist(conf.Get<string>("hist").c_str());
+    if (!hist)
+    {
+        cerr << "ERROR: Writing to '" << conf.Get<string>("hist") << "' failed: " << strerror(errno) << endl;
         return 1;
     }
 
-    // -------------------------------------------------------------------------
-
-    for (auto it=obs.begin(); it<obs.end()-1; it++)
-        it[0].end = it[1].begin;
-    obs.back().end = sunrise;
-
-    // -------------------------------------------------------------------------
-
-    Print(obs, startup_offset);
-    cout << endl;
-
-    // -------------------------------------------------------------------------
-
-    while (RescheduleFirstSources(obs));
-    while (RescheduleLastSources(obs));
-    while (RescheduleIntermediateSources(obs));
-
-    RemoveMiniSources(obs);
-    CheckStartupAndShutdown(obs);
-
-    // ---------------------------------------------------------------------
-
-    cout << endl;
-    Print(obs, startup_offset);
-    cout << endl;
-
-    // ---------------------------------------------------------------------
-
-    if (!enter)
-        return 0;
-
-    const string scheduledb = conf.Get<string>("schedule-database");
-
-    Database db(scheduledb);
-
-    if (enter>0)
-        db.query("LOCK TABLES Schedule WRITE");
-
-    const int rc = FillSql(db, enter, obs, startup_offset);
-
-    if (enter>0)
-        db.query("UNLOCK TABLES");
-
-    // ---------------------------------------------------------------------
-
-    return rc;
-}
+    hist << "# " << flush;
+    for (const auto& src: sources)
+        hist << src.name << " " << flush;
+    hist << endl;
+
+    hist << "# " << flush;
+    for (const auto& src: sources)
+        hist << src.key << " " << flush;
+    hist << endl;
+
+    for (int k=0; k<90; k++)
+    {
+        hist << k << " " << flush;
+        for (const auto& src: sources)
+            hist << src.zddistr[k] << " " << flush;
+        hist << endl;
+    }
+
+    return 0;
+}