1 | #!/bin/bash
|
---|
2 | #
|
---|
3 | source `dirname $0`/../Sourcefile.sh
|
---|
4 | printprocesslog "INFO starting $0"
|
---|
5 |
|
---|
6 | if [ "$1" = "" ]
|
---|
7 | then
|
---|
8 | hour=`date +%k`
|
---|
9 | # get date (before 18h there is no new data to be processed)
|
---|
10 | if [ $hour -le 7 ] || [ $hour -ge 19 ]
|
---|
11 | then
|
---|
12 | datepaths=( `date --date="-19HOUR" +%Y/%m/%d` )
|
---|
13 | else
|
---|
14 | datepaths=( `date +%Y/%m/%d --date="-12hour"` `date +%Y/%m/%d --date="-36hour"` `date +%Y/%m/%d --date="-60hour"` \
|
---|
15 | `date +%Y/%m/%d --date="-84hour"` `date +%Y/%m/%d --date="-108hour"` `date +%Y/%m/%d --date="-132hour"` \
|
---|
16 | # `date +%Y/%m/%d --date="-156hour"` `date +%Y/%m/%d --date="-180hour"` `date +%Y/%m/%d --date="-204hour"` \
|
---|
17 | )
|
---|
18 | fi
|
---|
19 | #datepaths=( `find -L $datapath/star -mindepth 3 -type d | sort -r | sed "s/\${datapath_for_sed}\/star//g" | sed -e 's/^\///'` ) #all available dates in star-directory
|
---|
20 | else
|
---|
21 | datepaths=( $1 )
|
---|
22 | fi
|
---|
23 |
|
---|
24 | for datepath in ${datepaths[@]}
|
---|
25 | do
|
---|
26 | printprocesslog "INFO processing "$datepath
|
---|
27 | #echo "INFO processing "$datepath
|
---|
28 | night=`echo $datepath | sed -e 's/\///g'`
|
---|
29 |
|
---|
30 | numganymeds=0
|
---|
31 |
|
---|
32 | # getting all image files for this night
|
---|
33 | printprocesslog "INFO get file list for night "$datepath
|
---|
34 | files=( `find $anapath/star/$datepath -type f -name '*_I.root' 2>/dev/null | sort` )
|
---|
35 | if [ ${#files[@]} -eq 0 ]
|
---|
36 | then
|
---|
37 | printprocesslog "INFO no image files available for night "$datepath
|
---|
38 | continue
|
---|
39 | fi
|
---|
40 | # write data set file
|
---|
41 | #dspath=$anapath/$source/datasets`printf %03d $min`min/$datepath
|
---|
42 | #dspath=$anapath/$source/datasets_run/$datepath
|
---|
43 | dspath=$anapath/datasets_run/$datepath
|
---|
44 | makedir $dspath
|
---|
45 |
|
---|
46 | for (( i=1 ; i<=${#files[@]} ; i++ ))
|
---|
47 | do
|
---|
48 | night=`basename ${files[$i-1]} | cut -d_ -f1`
|
---|
49 | run=`basename ${files[$i-1]} | cut -d_ -f2`
|
---|
50 | printprocesslog "DEBUG night: "$night" run: "$run
|
---|
51 | dsfile=$dspath"/dataset"$night"_"$run".txt"
|
---|
52 | #echo $dsfile
|
---|
53 | printprocesslog "INFO writing dataset file "$dsfile
|
---|
54 | # write dataset only if merpp-log is available to make sure that star-file is complete
|
---|
55 | if echo $resulttable1 | grep ISDC >/dev/null 2>&1
|
---|
56 | then
|
---|
57 | query="SELECT LPAD(fSequenceID, 3, 0) FROM RunInfo WHERE fNight="$night" AND fRunID="$run
|
---|
58 | seq=`sendquery`
|
---|
59 | merpplog=`dirname ${files[$i-1]}`"/"$night"_"$seq"-merpp.log"
|
---|
60 | else
|
---|
61 | merpplog=`echo ${files[$i-1]} | sed -e 's/_I.root/-merpp.log/'`
|
---|
62 | fi
|
---|
63 | stillrunning=`find $merpplog -mmin -1 2>/dev/null`
|
---|
64 | if [ -e $merpplog ] && [ "$stillrunning" == "" ]
|
---|
65 | then
|
---|
66 | echo `dirname ${files[$i-1]}`" "`basename ${files[$i-1]}` > $dsfile
|
---|
67 | else
|
---|
68 | printprocesslog "INFO merpp still running - wait with file "${files[$i-1]}
|
---|
69 | continue
|
---|
70 | fi
|
---|
71 | # process only if ganymedlogfiles is not yet there
|
---|
72 | logfile=`echo $dsfile | sed -e 's/datasets/ganymed/' -e 's/dataset//' -e 's/[.]txt/-ganymed[.]log/'`
|
---|
73 | if ! ls $logfile >/dev/null 2>&1
|
---|
74 | then
|
---|
75 | # fixme: why is this double?
|
---|
76 | night=`basename ${files[$i-1]} | cut -d_ -f1`
|
---|
77 | runid=`basename ${files[$i-1]} | cut -d_ -f2 | cut -d. -f1`
|
---|
78 | drivefile=$auxdata"/"$datepath"/"`basename ${files[$i-1]} | cut -d_ -f1`".DRIVE_CONTROL_SOURCE_POSITION.fits"
|
---|
79 | rawfilepath=$rawdata"/"$datepath"/"
|
---|
80 | rawfilename=`basename ${files[$i-1]} | sed -e 's/_I.root/.fits/'`
|
---|
81 | rawfile=`find $rawfilepath -name $rawfilename* 2>/dev/null`
|
---|
82 | if ! [ "$rawfile" == "" ]
|
---|
83 | then
|
---|
84 | printprocesslog "INFO processing "$rawfile
|
---|
85 | tstopi=`$factpath/fitsdump -h $rawfile 2>/dev/null | grep TSTOPI | grep -E -o '[0-9]+'`
|
---|
86 | tstopf=`$factpath/fitsdump -h $rawfile 2>/dev/null | grep TSTOPF | grep -E -o '[.][0-9]+'`
|
---|
87 | tstop=${tstopi}${tstopf}
|
---|
88 | fi
|
---|
89 | #echo "tstop: "$tstop
|
---|
90 | if [ ls $drivefile >/dev/null 2>&1 ] && ! [ "$tstop" == "" ]
|
---|
91 | then
|
---|
92 | printprocesslog "INFO getting coordinates from "$drivefile
|
---|
93 | coordinates=( `${factpath}/fitsdump ${drivefile} -c Ra_src Dec_src -r --filter='Time<'${tstop} 2>/dev/null | tail -1 2>&1` )
|
---|
94 | if [ "${coordinates[0]}" == "" ] || [ "${coordinates[1]}" == "" ]
|
---|
95 | then
|
---|
96 | printprocesslog "WARN couldn't get coordinates ("${coordinates[@]}") from "$drivefile
|
---|
97 | #echo "WARN couldn't get coordinates ("${coordinates[@]}") from "$drivefile
|
---|
98 | continue
|
---|
99 | fi
|
---|
100 | if [ "${coordinates[0]}" == "0" ] || [ "${coordinates[1]}" == "0" ]
|
---|
101 | then
|
---|
102 | printprocesslog "WARN coordinates "${coordinates[@]}
|
---|
103 | #echo "WARN coordinates "${coordinates[@]}
|
---|
104 | continue
|
---|
105 | fi
|
---|
106 | else
|
---|
107 | printprocesslog "INFO getting coordinates from DB."
|
---|
108 | query="SELECT fSourceKEY FROM RunInfo WHERE fNight="$night" AND fRunID="$runid
|
---|
109 | sourcekey=`sendquery`
|
---|
110 | if [ "$sourcekey" == "" ]
|
---|
111 | then
|
---|
112 | printprocesslog "WARN sourcekey empty - coordinates"${coordinates[@]}
|
---|
113 | #echo "WARN sourcekey empty - coordinates"${coordinates[@]}" for "$rawfile
|
---|
114 | continue
|
---|
115 | fi
|
---|
116 | query="SELECT Round(fRightAscension,6), Round(fDeclination,6) from source WHERE fSourceKey="$sourcekey
|
---|
117 | coordinates=( `sendquery` )
|
---|
118 | if [ "${coordinates[0]}" == "" ] || [ "${coordinates[1]}" == "" ]
|
---|
119 | then
|
---|
120 | printprocesslog "WARN couldn't get coordinates ("${coordinates[@]}") from DB."
|
---|
121 | #echo "WARN couldn't get coordinates ("${coordinates[@]}") from "$drivefile
|
---|
122 | continue
|
---|
123 | fi
|
---|
124 | if [ "${coordinates[0]}" == "0" ] || [ "${coordinates[1]}" == "0" ]
|
---|
125 | then
|
---|
126 | printprocesslog "WARN coordinates "${coordinates[@]}
|
---|
127 | #echo "WARN coordinates "${coordinates[@]}
|
---|
128 | continue
|
---|
129 | fi
|
---|
130 | fi
|
---|
131 |
|
---|
132 | printprocesslog "DEBUG "$logfile" "${files[$i-1]}" -"${coordinates[0]}"-"${coordinates[1]}
|
---|
133 | printprocesslog "DEBUG `dirname $0`/RunGanymed.sh $dsfile "${coordinates[0]}" "${coordinates[1]}
|
---|
134 | if [ "$qlasge" = "yes" ]
|
---|
135 | then
|
---|
136 | printprocesslog "$sgepath/qsub -b y -q fact_short -v AUTOMATIONSETUP=$AUTOMATIONSETUP -v dsfile=$dsfile -v ra=${coordinates[0]} -v dec=${coordinates[1]} -e bla.txt -o bla.txt `dirname $0`/RunGanymed.sh"
|
---|
137 | $sgepath/qsub -b y -q fact_short -v AUTOMATIONSETUP=$AUTOMATIONSETUP -v dsfile=$dsfile -v ra=${coordinates[0]} -v dec=${coordinates[1]} -e bla.txt -o bla.txt `dirname $0`/RunGanymed.sh
|
---|
138 | else
|
---|
139 | `dirname $0`/RunGanymed.sh $dsfile ${coordinates[0]} ${coordinates[1]}
|
---|
140 | #echo "ganymed for "$dsfile" "${coordinates[0]}" "${coordinates[1]}
|
---|
141 | fi
|
---|
142 | numganymeds=`echo " $numganymeds + 1 " | bc -l`
|
---|
143 | fi
|
---|
144 | done
|
---|
145 | printprocesslog "INFO found "$numganymeds" ganymeds."
|
---|
146 | done
|
---|
147 |
|
---|
148 | finish
|
---|
149 |
|
---|