#!/usrx/local/perldbn/perl
#######################################################################################
#  This program will retrieve the OSO status file from the SOC,  and 
# generate some statistical files for the SDM.
#
# Modifications:
#  01/27/97   Initial version
#
#######################################################################################

#######################################################################################
# Start Main Program
#######################################################################################
use Time::CTime;

$pcom_root="/pcom/status";

if (!read_input()) {
   exit(1);
}
gen_report("OSO");
gen_tracker_report("TRACKER");
exit(0);
#######################################################################################
# End Main Program
#######################################################################################

sub gen_report {
   my ($filename) = @_;

   open(_OUTPUT, ">.$filename") || return -2;
   select (_OUTPUT);
   $~ = "_OUTPUT_HEADER";
   write;
   $~ = "_OUTPUT";

   foreach (@original) {
      ($index,$ptime,$job,$model,$file,$pseconds,$rseconds,$delay) = split; 
      ($i_number,$type) = split ('\.',$index);
      $success = $index =~ /^\*/;
      $file =~ /.*\/(.*)/;
      if($rseconds == 0)
         {
          $~ = "_OUTPUT1";
         }
      else
         {
          $~ = "_OUTPUT";
         }
      write ;
   }

format _OUTPUT_HEADER = 
@||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
"Cray to OSO status file transfer statistics. FILE=$filename"
@||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
"(remember delay times and reciept times are calculated using two seperate"
@||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
" computer clocks, some descrepencies will be from clock differences)"
@||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
strftime("Report Generated at %Y.%j.%H.%M.%S GMT",gmtime(time))
@||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
"--------------------------------------------------------------------------"
@<@<<<< @<<<<<<< @<<< @<<<<<<<<<<<<<<<<<< @<<<<<<<<<<<<<<<<<< @<<<<< @<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
"S","Type","Job","Key","NMCZ",  "OSOZ", "delay", "Cray Filename"
.

format _OUTPUT = 
@<@<<<< @<<<<<<< @<<< @<<<<<<<<<<<<<<<<<< @<<<<<<<<<<<<<<<<<< @##.## @<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
($success ? "*" : " "), $type, $job, $model, strftime("%Y-%m-%d-%H-%M-%S",gmtime($pseconds)), strftime("%Y-%m-%d-%H-%M-%S",gmtime($rseconds)), $delay, $file
.
format _OUTPUT1 = 
@<@<<<< @<<<<<<< @<<< @<<<<<<<<<<<<<<<<<< @<<<<<<<<<<<<<<<<<< @##.## @<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
($success ? "*" : " "), $type, $job, $model, strftime("%Y-%m-%d-%H-%M-%S",gmtime($pseconds)), strftime("0000-00-00-%H-%M-%S",gmtime($rseconds)), $delay, $file
.

   select stdout;
   close(_OUTPUT);
   rename ".$filename","$filename";
} 
sub gen_tracker_report {
   my ($filename) = @_;

   open(_OUTPUT, ">.$filename") || return -2;
   select (_OUTPUT);

   foreach (@original) {
      ($index,$ptime,$job,$model,$file,$pseconds,$rseconds,$delay) = split; 
      $file =~ /.*\/(.*)/;
      $nmctime=strftime("%Y-%m-%d-%H-%M-%S",gmtime($pseconds));
      $nmcpdy=strftime("%Y%m%d",gmtime($pseconds));
      if($rseconds == 0)
         {
          #$osotime=strftime("0000-00-00-%H-%M-%S",gmtime($rseconds));
          next;
         }
      else
         {
          $osotime=strftime("%Y-%m-%d-%H-%M-%S",gmtime($rseconds));
         }
      if($file =~ /pcom\/foreign/ || 
         $model =~ /tix/ ||
         $model =~ /tux/ ||
         $model =~ /pol/ ||
         $model =~ /for/)
         {
          next;
         }
      if($file =~ /mmus6/) 
         {
          $file=~ s+/pcom/status/data+/com/rucs/prod/rucs.$nmcpdy+g;
         }
      if($file =~ /aeus41/) 
         {
          $file=~ s+/pcom/status/data+/pcom/hourly+g;
         }
      print "$file\|$nmctime\|$osotime\n";
   }

   select stdout;
   close(_OUTPUT);
   rename ".$filename","$filename";
} 
sub read_input {
  my (@crayfile);
  my ($i) = 0;
  my ($j) = 0;
  my ($start) = 0;

  while (`wc -l ${pcom_root}/statfile` < 1915) {
    sleep (5);
  }
  `cat ${pcom_root}/statfile | sort -r +1 -2 -o origsorted` ;

  open(_FILE, "<origsorted") || return -1;
  @crayfile = <_FILE>;
  close (_FILE);

  while ((`wc -l ${pcom_root}/oso/statfile.soc` < 1500) || (`wc -l ${pcom_root}/oso/statfile.soc1` < 1500)) {
    sleep (5);
  }
  `cat ${pcom_root}/oso/statfile.soc ${pcom_root}/oso/statfile.soc1 | grep '^\*' | sort +1 -2 -o sorted` ;

  open(_FILE, "<sorted") || return -1;
  @original = <_FILE>;
  close (_FILE);
  
  @crayfile = splice(@crayfile,0,1500);
  for ( $i=0 ; (($i <=$#crayfile) && ($i < 1501)); $i++ ) {
    ($index,$ptime,$job,$model,$file) = split(" ",$crayfile[$i]);
    ($oso_index,$oso_ptime,$oso_job,$oso_model,$oso_file,$oso_how,$oso_rtime) = split(" ",$original[$#orignal]);

    ($i_number,$type) = split ('\.',$index);
    $file =~ /.*\/(.*)/;
    ($year,$day,$tmptime) = split ('\.',$ptime);
    ($hour,$min,$sec) = split (':',$tmptime);

    #calculate the number of seconds since 1970
    if ($year > 70) {
      $leapoffset=($year-72)/4+1;
      if(($year%4)==0)
         {
          if($day>59)
             {
              $leapoffset=$leapoffset-2;
             }
          else
             {
              $leapoffset=$leapoffset-1;
             }
         }
      $pseconds = ($year-70) * 365 * 24 * 60 * 60 + ($day+$leapoffset) * 24 * 60 *60 + $hour * 60 * 60 + $min * 60 + $sec;
    }
    else {
      $leapoffset=($year+28)/4+1;
      if(($year%4)==0)
         { 
          if($day>59)
             {
              $leapoffset=$leapoffset-2;
             }
          else
             {
              $leapoffset=$leapoffset-1;
             }
         }
      $pseconds = ($year+30) * 365 * 24 * 60 * 60 + ($day+$leapoffset) * 24 * 60 *60 + $hour * 60 * 60 + $min * 60 + $sec;
    }

    if ($index =~ /[ \*]$oso_index/) {
      $success = $oso_index =~ /^\*/ ?  " " : "*";
      ($hour,$min,$sec) = split (':',$oso_rtime);

      if ($year > 70) {
        $leapoffset=($year-72)/4+1;
        if(($year%4)==0)
           {
            if($day>59)
               {
                $leapoffset=$leapoffset-2;
               }
            else
               {
                $leapoffset=$leapoffset-1;
               }
           }
        $rseconds = ($year-70) * 365 * 24 * 60 * 60 + ($day+$leapoffset) * 24 * 60 *60 + $hour * 60 * 60 + $min * 60 + $sec;
      }
      else {
        $leapoffset=($year+28)/4+1;
        if(($year%4)==0)
           {
            if($day>59)
              {
               $leapoffset=$leapoffset-2;
              }
            else
              {
               $leapoffset=$leapoffset-1;
              }
           }
        $rseconds = ($year+30) * 365 * 24 * 60 * 60 + ($day+$leapoffset) * 24 * 60 *60 + $hour * 60 * 60 + $min * 60 + $sec;
      }

      $delay = ($rseconds - $pseconds ) /60;
      pop @original;
    } else  {
      $rseconds = 0;
      $delay = 0;
      $success = " ";
    }
    $crayfile[$i] = "${success}$crayfile[$i] $pseconds $rseconds $delay";
  }
  @original = @crayfile; 

  return 1;
}