rec10/trunk/src/timerec.py

   1 #!/usr/bin/python
   2 # coding: UTF-8
   3 # Rec10 TS Recording Tools
   4 # Copyright (C) 2009 Yukikaze
   5 import sys
   6 import time
   7 import os
   8 import datetime
   9 import epgdb
  10 import configreader
  11 import ts2x264
  12 import tv2avi
  13 import recdb
  14 import chdb
  15 import status
  16 import re
  17 recpath=configreader.getpath('recpath')
  18 tmppath=configreader.getpath('temppath')
  19 path=str(os.path.dirname(os.path.abspath(__file__)))+"/"
  20 def task():
  21     """
  22     数分毎に実行されるタスク処理
  23     予定によって子プロセスを生成し処理する。
  24     """
  25     recdb.delete_old("6")
  26     tasks=recdb.getnow("1")
  27     if len(tasks)==0:
  28         update=chdb.update()
  29         print "番組表更新処理"
  30         print update
  31         if len(update)>0:
  32             print "番組表を更新"
  33             print update
  34             pid=os.fork()
  35             if pid>0:#親プロセスの場合
  36                 ""
  37             else:#子プロセスの場合　アップデートを行って終了
  38                 for bctype in update:
  39                     time.sleep(1)
  40                     print bctype
  41                     epgdb.updatebc(bctype)
  42                 sys.exit(0)
  43
  44     for task in tasks:
  45         try:
  46             chtxt=task['chtxt']
  47         except:
  48             chtxt=""
  49         try:
  50             title=task['title']
  51         except:
  52             title=""
  53         try:
  54             btime=task['btime']
  55             bt=datetime.datetime.strptime(btime,"%Y-%m-%d %H:%M:%S")
  56         except:
  57             btime=""
  58             bt=datetime.datetime.strptime("2009-01-01 00:00:00","%Y-%m-%d %H:%M:%S")
  59         try:
  60             etime=task['etime']
  61             et=datetime.datetime.strptime(etime,"%Y-%m-%d %H:%M:%S")
  62         except:
  63             etime=""
  64             et=datetime.datetime.strptime("2009-01-01 00:00:00","%Y-%m-%d %H:%M:%S")
  65         try:
  66             opt=task['opt']
  67         except:
  68             opt=""
  69         tnow=datetime.datetime.now()
  70         dtt=bt-tnow#
  71         dt=dtt.days*24*60*60+dtt.seconds
  72
  73         if task["type"]==recdb.REC_RESERVE:#"res,"+chtxt+","+title+","+btime+","+etime+","+opt
  74             if dt<58*60:
  75                 recdb.del_reckey(recdb.REC_RESERVE, title, chtxt, btime)
  76                 recdb.rec_reckey(recdb.REC_FINAL_RESERVE, title, chtxt, btime, etime, opt)
  77
  78         elif task["type"]==recdb.REC_KEYWORD:#"key,"+chtxt+","+keyword+","+btime+","+deltatime+","+opt
  79             deltatime=task['deltatime']
  80             if dt<30*60:
  81                 recdatum=epgdb.searchtime(title,btime,deltatime)
  82                 if len(recdatum)>0:
  83                     recdb.del_reckey(recdb.REC_KEYWORD, title, chtxt, btime)
  84                     for recdata in recdatum:
  85                         recds=recdata.split(",")
  86                         chtxt=recds[0]
  87                         title=recds[1]
  88                         btime=recds[2]
  89                         etime=recds[3]
  90                         bt=datetime.datetime.strptime(btime,"%Y-%m-%d %H:%M:%S")
  91                         et=datetime.datetime.strptime(etime,"%Y-%m-%d %H:%M:%S")
  92                         btime=bt.strftime("%Y-%m-%d %H:%M:%S")
  93                         etime=et.strftime("%Y-%m-%d %H:%M:%S")
  94                         recdb.rec_reckey(recdb.REC_FINAL_RESERVE, title, chtxt, btime, etime, opt)
  95                 else :
  96                     print "nothing match"
  97
  98         elif task["type"]==recdb.REC_KEYWORD_EVERY_SOME_DAYS:#"keyevery,"+chtxt+","+keyword+","+btime+","+deltatime+","+opt+","+deltaday
  99             deltatime=task['deltatime']
 100             deltaday=task['deltaday']
 101             dd=datetime.timedelta(days=int(deltaday))
 102             if dtt.days<0:
 103                 recdb.del_reckey(recdb.REC_KEYWORD_EVERY_SOME_DAYS, title, chtxt, btime)
 104                 bt=bt+dd
 105                 et=et+dd
 106                 btxt=bt.strftime("%Y-%m-%d %H:%M:%S")
 107                 etxt=et.strftime("%Y-%m-%d %H:%M:%S")
 108                 recdb.everyreserv(title,chtxt,btxt,etxt,deltatime,opt,deltaday)
 109             elif dt<30*60*60:
 110                 recdb.keyreserv(title,chtxt,btime,etime,deltatime,opt)
 111                 recdb.del_reckey(recdb.REC_KEYWORD_EVERY_SOME_DAYS, title, chtxt, btime)
 112                 bt=bt+dd
 113                 et=et+dd
 114                 btxt=bt.strftime("%Y-%m-%d %H:%M:%S")
 115                 etxt=et.strftime("%Y-%m-%d %H:%M:%S")
 116                 recdb.everyreserv(title,chtxt,btxt,etxt,deltatime,opt,deltaday)
 117
 118         elif task["type"]==recdb.REC_FINAL_RESERVE:#"rec,"+chtxt+","+title+","+btime+","+etime+","+opt
 119             print dt
 120             if dt<6*60:
 121                 recdb.del_reckey(recdb.REC_FINAL_RESERVE, title, chtxt, btime)
 122                 recdb.rec_reckey(recdb.REC_TS_DECODING, title, chtxt, btime, etime, opt)
 123                 print "録画開始"
 124                 pid=os.fork()
 125                 if pid>0:#親プロセスの場合
 126                     ""
 127                 else:
 128                     #print title
 129                     tv2avi.timetv2avi(recpath+"/"+title+".avi",chtxt,btime,etime,opt)
 130                     if not os.access(recpath+"/"+title+".ts", os.F_OK):
 131                         time.sleep(60)
 132                         tnow2=datetime.datetime.now()
 133                         dtt2=et-tnow
 134                         dt2=dtt2.days*24*60*60+dtt2.seconds
 135                         if dt2>0:
 136                             title="rt-"+title
 137                             tv2avi.timetv2avi(recpath+"/"+title+".avi",chtxt,btime,etime,opt)
 138                         if not os.access(recpath+"/"+title+".ts", os.F_OK):
 139                             recdb.del_reckey(recdb.REC_TS_DECODING, title, chtxt, btime)
 140                             recdb.rec_reckey(recdb.REC_MISS_DECODE, title, chtxt, btime, etime, opt)
 141                         else:
 142                             recdb.del_reckey(recdb.REC_TS_DECODING, title, chtxt, btime)
 143                             tnow=datetime.datetime.now()
 144                             bt=datetime.datetime.strptime(btime,"%Y-%m-%d %H:%M:%S")
 145                             et=datetime.datetime.strptime(etime,"%Y-%m-%d %H:%M:%S")
 146                             dt=tnow-bt
 147                             bt=tnow+datetime.timedelta(seconds=600)
 148                             et=et+dt+datetime.timedelta(seconds=600)
 149                             btime=bt.strftime("%Y-%m-%d %H:%M:%S")
 150                             etime=et.strftime("%Y-%m-%d %H:%M:%S")
 151                             recdb.rec_reckey(recdb.REC_ENCODE_QUE,title,chtxt,btime,etime,opt)
 152                             recdb.rec_reckey(recdb.REC_FIN_DECODE,title,chtxt,btime,etime,opt)
 153                     else:
 154                         recdb.del_reckey(recdb.REC_TS_DECODING, title, chtxt, btime)
 155                         tnow=datetime.datetime.now()
 156                         bt=datetime.datetime.strptime(btime,"%Y-%m-%d %H:%M:%S")
 157                         et=datetime.datetime.strptime(etime,"%Y-%m-%d %H:%M:%S")
 158                         dt=tnow-bt
 159                         bt=tnow+datetime.timedelta(seconds=600)
 160                         et=et+dt+datetime.timedelta(seconds=600)
 161                         btime=bt.strftime("%Y-%m-%d %H:%M:%S")
 162                         etime=et.strftime("%Y-%m-%d %H:%M:%S")
 163                         recdb.rec_reckey(recdb.REC_ENCODE_QUE,title,chtxt,btime,etime,opt)
 164                         recdb.rec_reckey(recdb.REC_FIN_DECODE,title,chtxt,btime,etime,opt)
 165                     sys.exit(0)
 166
 167         elif task["type"]==recdb.REC_ENCODE_QUE:
 168             if dt<10*60:
 169                 if status.getEncoding()<2:
 170                     pid=os.fork()
 171                     if pid>0:#親プロセスの場合
 172                             ""
 173                     else:
 174                         pin=recpath+"/"+title+".ts"
 175                         if re.search("d",opt):
 176                             pin=recpath+"/"+title+"sa.avi"
 177                         if re.search("5",opt):
 178                             pin=recpath+"/"+title+"sa.avi"
 179                         pout=recpath+"/"+title+".avi"
 180                         print pin+":"+pout+":"+opt
 181                         recdb.del_reckey(recdb.REC_ENCODE_QUE,title,chtxt,btime)
 182                         recdb.rec_reckey(recdb.REC_ENCODE_LOCAL, title, chtxt, btime, etime, opt)
 183                         ts2x264.ts2x264(pin, pout, opt)
 184                         recdb.del_reckey(recdb.REC_ENCODE_LOCAL,title,chtxt,btime)
 185                         recdb.rec_reckey(recdb.REC_FIN_LOCAL, title, chtxt, btime, etime, opt)
 186                         sys.exit(0)
 187                 else:
 188                     recdb.del_reckey(recdb.REC_ENCODE_QUE,title,chtxt,btime)
 189                     bt=bt+datetime.timedelta(seconds=600)
 190                     et=et+datetime.timedelta(seconds=600)
 191                     btime=bt.strftime("%Y-%m-%d %H:%M:%S")
 192                     etime=et.strftime("%Y-%m-%d %H:%M:%S")
 193                     recdb.rec_reckey(recdb.REC_ENCODE_QUE,title,chtxt,btime,etime,opt)