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 datetime
   6 import os
   7 import os.path
   8 import re
   9 import sys
  10 import time
  11 import shutil
  12
  13 import auto_rec
  14 import auto_process
  15 import chdb
  16 import checker
  17 import configreader
  18 import epgdb
  19 import rec10d
  20 import recdb
  21 import status
  22 import tv2avi
  23 import tv2mkv
  24 import tv2mp4
  25 import recdblist
  26 recpath = configreader.getpath('recpath')
  27 movepath = configreader.getpath('move_destpath')
  28 path = str(os.path.dirname(os.path.abspath(__file__))) + "/"
  29 def task():
  30     """
  31     数分毎に実行されるタスク処理
  32     予定によって子プロセスを生成し処理する。
  33     """
  34     recdb.delete_old("24")
  35     recdb.delete_old_auto_bayes("1")
  36     recdb.delete_old_auto_keyword("1")
  37     tasks = recdb.getnow("2")
  38     inum = recdb.countRecNow_minutes("10")
  39     recdblist.printutf8(u"rec10処理開始"+ datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
  40     recdblist.printutf8(u"直近録画予約件数:" + str(inum) + u"BS/CS録画中件数:" + str(status.getBSCSRecording()) + u"TE録画中件数:" + str(status.getTERecording()) )
  41     encodenum=0
  42     b25num=0
  43     dnow=datetime.datetime.now()
  44     if dnow.hour==12 and dnow.minute<5 :
  45         pid = os.fork()
  46         if pid != 0:
  47             time.sleep(1)
  48         else:
  49             for k in recdb.get_key():
  50                 search_keyword(k)
  51             sys.exit()
  52     else:
  53         pid = os.fork()
  54         if pid!=0:
  55             time.sleep(1)
  56         else:
  57             auto_process.auto_check(recpath)
  58             sys.exit()
  59     update = chdb.update()
  60     if len(update) > 0:
  61         pid = os.fork()
  62         if pid != 0:
  63             time.sleep(1)
  64         else:
  65             i = 0
  66             for bctype in update:
  67                 recnum = 0
  68                 if bctype.find('te') > -1:
  69                     recnum = status.getTERecording() + recdb.countRecNow_minutes_TE("10")
  70                     recdblist.printutf8(u"放送種別:"+bctype + u"||該当チューナー実行中件数:" + str(status.getTERecording()) + u":直近予約件数:" + str(recdb.countRecNow_minutes_TE("10")))
  71                     recnum = int(configreader.getenv("te_max")) -recnum
  72                 else:
  73                     recnum = status.getBSCSRecording() + recdb.countRecNow_minutes_BSCS("10")
  74                     recdblist.printutf8(u"放送種別:"+bctype + u"||該当チューナー実行中件数:" + str(status.getBSCSRecording()) + u":直近予約件数:" + str(recdb.countRecNow_minutes_BSCS("10")))
  75                     recnum = int(configreader.getenv("bscs_max")) -recnum
  76                 if recnum >0 :
  77                     print update
  78                     rec10d.rec10db.update_status_by_bctype_epg_ch(bctype, "0")
  79                     epgdb.updatebc(bctype)
  80                     update = chdb.update()
  81                     i = i + 1
  82                 if i > 0:
  83                     break
  84             sys.exit()
  85     for task in tasks:
  86         typetxt = task["type"]
  87         try:
  88             chtxt = task['chtxt']
  89         except:
  90             chtxt = ""
  91         try:
  92             title = task['title']
  93         except:
  94             title = ""
  95         try:
  96             btime = task['btime']
  97             bt = datetime.datetime.strptime(btime, "%Y-%m-%d %H:%M:%S")
  98         except:
  99             btime = ""
 100             bt = datetime.datetime.strptime("2009-01-01 00:00:00", "%Y-%m-%d %H:%M:%S")
 101         try:
 102             etime = task['etime']
 103             et = datetime.datetime.strptime(etime, "%Y-%m-%d %H:%M:%S")
 104         except:
 105             etime = ""
 106             et = datetime.datetime.strptime("2009-01-01 00:00:00", "%Y-%m-%d %H:%M:%S")
 107         try:
 108             opt = task['opt']
 109         except:
 110             opt = ""
 111         tnow = datetime.datetime.now()
 112         dtt = bt-tnow
 113         dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 114         if task["type"] == recdblist.REC_RESERVE:#"res,"+chtxt+","+title+","+btime+","+etime+","+opt
 115             pid = os.fork()
 116             if pid != 0:#親プロセスの場合
 117                 ""
 118             else:#子プロセスの場合　アップデートを行って終了
 119                 type_reserve(task["type"],chtxt,title,bt,et,opt)
 120                 sys.exit()
 121         elif task["type"] == recdblist.REC_KEYWORD:#"key,"+chtxt+","+keyword+","+btime+","+deltatime+","+opt
 122             deltatime = task['deltatime']
 123             pid = os.fork()
 124             if pid != 0:#親プロセスの場合
 125                 ""
 126             else:#子プロセスの場合　アップデートを行って終了
 127                 type_keyword(task["type"],chtxt,title, bt, et, opt, deltatime)
 128                 sys.exit()
 129         elif task["type"] == recdblist.REC_KEYWORD_EVERY_SOME_DAYS:#"keyevery,"+chtxt+","+keyword+","+btime+","+deltatime+","+opt+","+deltaday
 130             deltatime = task['deltatime']
 131             deltaday = task['deltaday']
 132             pid = os.fork()
 133             if pid != 0:#親プロセスの場合
 134                 ""
 135             else:#子プロセスの場合　アップデートを行って終了
 136                 type_keyword_every_day(task["type"],chtxt, title, bt, et, opt, deltatime, deltaday)
 137                 sys.exit()
 138         elif task["type"] == recdblist.REC_FINAL_RESERVE:#"rec,"+chtxt+","+title+","+btime+","+etime+","+opt
 139             pid = os.fork()
 140             if pid != 0:#親プロセスの場合
 141                 ""
 142             else:#子プロセスの場合　アップデートを行って終了
 143                 type_final(task["type"],chtxt, title, bt, et, opt)
 144                 sys.exit()
 145         elif task["type"] == recdblist.REC_TS_DECODE_QUE:
 146             b25num=b25num+1
 147             pid = os.fork()
 148             if pid != 0:#親プロセスの場合
 149                 ""
 150             else:#子プロセスの場合　アップデートを行って終了
 151                 time.sleep(5*b25num)
 152                 type_decode_que(task["type"],chtxt, title, bt, et, opt)
 153                 sys.exit()
 154         elif task["type"] == recdblist.REC_ENCODE_QUE:
 155             encodenum=encodenum+1
 156             pid = os.fork()
 157             if pid != 0:#親プロセスの場合
 158                 ""
 159             else:#子プロセスの場合　アップデートを行って終了
 160                 time.sleep(5*encodenum)
 161                 type_encode_que(task["type"],chtxt, title, bt, et, opt)
 162                 sys.exit()
 163         elif task["type"] == recdblist.REC_AVI_TO_MKV:
 164             if dt < 10 * 60:
 165                 pid = os.fork()
 166                 if pid > 0:#親プロセスの場合
 167                     ""
 168                 else:
 169                     recdb.del_reckey(recdblist.REC_AVI_TO_MKV, title, chtxt, btime)
 170                     recdb.rec_reckey(recdblist.REC_CHANGING_CANTAINER, title, chtxt, btime, etime, opt)
 171                     tv2mkv.avi2mkv(os.path.join(recpath,title+".avi"),os.path.join(recpath,title+".mkv"))
 172                     recdb.del_reckey(recdblist.REC_CHANGING_CANTAINER, title, chtxt, btime)
 173                     sys.exit()
 174         elif task["type"] == recdblist.REC_AVI_TO_MP4:
 175             if dt < 10 * 60:
 176                 pid = os.fork()
 177                 if pid > 0:#親プロセスの場合
 178                     ""
 179                 else:
 180                     recdb.del_reckey(recdblist.REC_AVI_TO_MP4, title, chtxt, btime)
 181                     recdb.rec_reckey(recdblist.REC_CHANGING_CANTAINER, title, chtxt, btime, etime, opt)
 182                     tv2mp4.avi2mp4(os.path.join(recpath,title+".avi"),os.path.join(recpath,title+".mp4"))
 183                     recdb.del_reckey(recdblist.REC_CHANGING_CANTAINER, title, chtxt, btime)
 184                     sys.exit()
 185         elif task["type"] == recdblist.REC_MKV_TO_MP4:
 186             if dt < 10 * 60:
 187                 pid = os.fork()
 188                 if pid > 0:#親プロセスの場合
 189                     ""
 190                 else:
 191                     recdb.del_reckey(recdblist.REC_AVI_TO_MP4, title, chtxt, btime)
 192                     recdb.rec_reckey(recdblist.REC_CHANGING_CANTAINER, title, chtxt, btime, etime, opt)
 193                     tv2mp4.mkv2mp4(os.path.join(recpath,title+".mkv"),os.path.join(recpath,title+".mp4"))
 194                     recdb.del_reckey(recdblist.REC_CHANGING_CANTAINER, title, chtxt, btime)
 195                     sys.exit()
 196         elif task["type"] == recdblist.REC_AUTO_KEYWORD:#"key,"+chtxt+","+keyword+","+btime+","+deltatime+","+opt
 197             deltatime = "24"
 198             if dt < 90 * 60:
 199                 recdatum = epgdb.searchtime_auto(title, btime, deltatime, chtxt)
 200                 for recdata in recdatum:
 201                     if recdata[1] != "":
 202                         chtxtt = recdata[0]
 203                         titlet = recdata[1]
 204                         btimet = recdata[2]
 205                         etimet = recdata[3]
 206                         exp = recdata[4]
 207                         longexp = recdata[5]
 208                         category=recdata[6]
 209                         btt = datetime.datetime.strptime(btimet, "%Y-%m-%d %H:%M:%S")
 210                         ett = datetime.datetime.strptime(etimet, "%Y-%m-%d %H:%M:%S")
 211                         btimet = btt.strftime("%Y-%m-%d %H:%M:%S")
 212                         etimet = ett.strftime("%Y-%m-%d %H:%M:%S")
 213                         try:
 214                             recdb.rec_reckey(recdblist.REC_AUTO_SUGGEST_REC, titlet, chtxtt, btimet, etimet, opt)
 215                         except Exception, inst:
 216                             print "Error occures in REC_AUTO_KEYWORD(1)"
 217                             print type(inst)
 218                             print inst
 219                 dd = datetime.timedelta(days=1)
 220                 bt = bt + dd
 221                 et = et + dd
 222                 btxt = bt.strftime("%Y-%m-%d %H:%M:%S")
 223                 etxt = et.strftime("%Y-%m-%d %H:%M:%S")
 224                 try:
 225                     recdb.del_reckey(recdblist.REC_AUTO_KEYWORD, title, chtxt, btime)
 226                     recdb.auto_keyreserv(title, chtxt, btxt, etxt, "24", opt)
 227                 except Exception, inst:
 228                     print "Error occures in REC_AUTO_KEYWORD(1)"
 229                     print type(inst)
 230                     print inst
 231     sys.exit()
 232 def search_keyword(key):
 233     tnow = datetime.datetime.now()
 234     nows =tnow.strftime("%Y-%m-%d %H:%M:%S")
 235     for k in key:
 236         recdatum = epgdb.searchtime_auto(k,nows, "144")
 237         for recdata in recdatum:
 238             if recdata[1] != "":
 239                 chtxtt = recdata[0]
 240                 titlet = recdata[1]
 241                 btimet = recdata[2]
 242                 etimet = recdata[3]
 243                 btt = datetime.datetime.strptime(btimet, "%Y-%m-%d %H:%M:%S")
 244                 ett = datetime.datetime.strptime(etimet, "%Y-%m-%d %H:%M:%S")
 245                 btimet = btt.strftime("%Y-%m-%d %H:%M:%S")
 246                 etimet = ett.strftime("%Y-%m-%d %H:%M:%S")
 247                 try:
 248                     recdb.add_auto_keyword(chtxtt, titlet, btimet, etimet)
 249                 except Exception, inst:
 250                     print "error occures in search_keyword"
 251                     print type(inst)
 252                     print inst
 253 def type_reserve(typetxt,chtxt,title,bt,et,opt):
 254     btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 255     etime = et.strftime("%Y-%m-%d %H:%M:%S")
 256     typetxtnow=typetxt
 257     typetxtfinal=""
 258     if typetxt==recdblist.REC_RESERVE:
 259         typetxtfinal=recdblist.REC_FINAL_RESERVE
 260     tnow = datetime.datetime.now()
 261     dtt = bt-tnow
 262     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 263     if (dt < 58 * 60 and dt > 20 * 60):
 264         bctypet = chdb.chtxtsearch(chtxt)['bctype']
 265         chdatat = rec10d.rec10db.select_by_bctype_epg_ch(bctypet)
 266         dt1 = datetime.datetime.strptime(chdatat[0][5], "%Y-%m-%d %H:%M:%S")-datetime.datetime.now()
 267         dt1 = dt1.days * 24 * 60 * 60 + dt1.seconds
 268         if dt1 < 60 * 60:
 269             recdata = epgdb.searchtime2(title, btime, "5", chtxt)
 270             chtxtn = recdata[0]
 271             titlen = recdata[1]
 272             btimen = recdata[2]
 273             etimen = recdata[3]
 274             exp = recdata[4]
 275             longexp = recdata[5]
 276             category=recdata[6]
 277             bt = datetime.datetime.strptime(btimen, "%Y-%m-%d %H:%M:%S")
 278             et = datetime.datetime.strptime(etimen, "%Y-%m-%d %H:%M:%S")
 279             btimen = bt.strftime("%Y-%m-%d %H:%M:%S")
 280             etimen = et.strftime("%Y-%m-%d %H:%M:%S")
 281             if chtxt != "":
 282                 try:
 283                     recdb.del_reckey(typetxtnow, title, chtxt, btime)
 284                     recdb.rec_reckey(typetxtfinal, titlen, chtxtn, btimen, etimen, opt)
 285                     recdb.rec_reclog(titlen, chtxtn, btimen, etimen, opt, exp, longexp, category)
 286                     auto_rec.add_key(chtxt, titlen,exp+" "+longexp)
 287                     auto_rec.add_key("ALL", titlen,exp+" "+longexp)
 288                     recdblist.printutf8("Oikake "+title+" : "+titlen+" "+btimen+" "+etimen)
 289                 except Exception, inst:
 290                     print "Error happended in Oikake DB"
 291                     print type(inst)
 292                     print inst
 293             else:
 294                 recdblist.printutf8("nothing match")
 295         else:
 296             if rec10d.rec10db.select_by_bctype_epg_ch(bctypet)[0][6] != "0":
 297                 rec10d.rec10db.update_status_by_bctype_epg_ch(bctypet, "3")
 298         sys.exit()
 299     elif dt <= 20 * 60:
 300         try:
 301             recdb.del_reckey(typetxtnow, title, chtxt, btime)
 302             recdb.rec_reckey(typetxtfinal, title, chtxt, btime, etime, opt)
 303         except Exception, inst:
 304             print type(inst)
 305             print inst
 306 def type_final(typetxt,chtxt,title,bt,et,opt):
 307     btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 308     etime = et.strftime("%Y-%m-%d %H:%M:%S")
 309     typetxtnow=typetxt
 310     typetxting=""
 311     typetxtdecque=""
 312     if typetxt==recdblist.REC_FINAL_RESERVE:
 313         typetxting=recdblist.REC_TS_RECORDING
 314         typetxtdecque=recdblist.REC_TS_DECODE_QUE
 315     tnow = datetime.datetime.now()
 316     dtt = bt-tnow
 317     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 318     print dt
 319     if dt < 6 * 60 and dt > 0:
 320         recdb.del_reckey(typetxtnow, title, chtxt, btime)
 321         recdb.rec_reckey(typetxting, title, chtxt, btime, etime, opt)
 322         recdblist.printutf8(u"録画開始 "+title+" "+btime+" "+etime)
 323         ttitle=title
 324         #recdblist.printutf8(title)
 325         testpath=[os.path.join(recpath,title+".ts.b25")]
 326         testpath.append(os.path.join(recpath,title+".ts"))
 327         testpath.append(os.path.join(recpath,title+".avi"))
 328         testpath.append(os.path.join(recpath,title+".mkv"))
 329         testpath.append(os.path.join(recpath,title+".log"))
 330         tcheck=0
 331         for ti in testpath:
 332             if os.path.exists(ti):
 333                 tcheck=tcheck+1
 334         if tcheck>0:
 335             ttitle=title+"_"+datetime.datetime.now().strftime("%Y%m%d%H%M")
 336         tv2avi.timetv2b25(recpath + "/" + ttitle + ".avi", chtxt, btime, etime, opt)
 337         recdb.del_reckey(typetxting, title, chtxt, btime)
 338         if not re.search("R", opt):
 339             tnow = datetime.datetime.now()
 340             bt = datetime.datetime.strptime(btime, "%Y-%m-%d %H:%M:%S")
 341             et = datetime.datetime.strptime(etime, "%Y-%m-%d %H:%M:%S")
 342             dt = tnow-bt
 343             bt = tnow + datetime.timedelta(seconds=600)
 344             et = et + dt + datetime.timedelta(seconds=600)
 345             btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 346             etime = et.strftime("%Y-%m-%d %H:%M:%S")
 347             recdb.rec_reckey(typetxtdecque, ttitle, chtxt, btime, etime, opt)
 348         else:
 349             shutil.copy(os.path.join(recpath,title+".ts.b25"), os.path.join(movepath,title+".ts.b25"))
 350             recdb.rec_reckey(recdblist.REC_MOVE_END, ttitle, chtxt, btime, etime, opt)
 351         sys.exit()
 352 def type_keyword(typetxt,chtxt,title,bt,et,opt,deltatime):
 353     btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 354     etime = et.strftime("%Y-%m-%d %H:%M:%S")
 355     typetxtnow=typetxt
 356     typetxtres=""
 357     if typetxt==recdblist.REC_KEYWORD:
 358         typetxtres=recdblist.REC_RESERVE
 359     tnow = datetime.datetime.now()
 360     dtt = bt-tnow
 361     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 362     print dt
 363     if dt < 90 * 60:
 364         recdata = epgdb.searchtime2(title, btime, deltatime, chtxt)
 365         if recdata[1] != "":
 366             chtxtt = recdata[0]
 367             titlet = recdata[1]
 368             btimet = recdata[2]
 369             etimet = recdata[3]
 370             exp = recdata[4]
 371             longexp = recdata[5]
 372             category=recdata[6]
 373             bt = datetime.datetime.strptime(btimet, "%Y-%m-%d %H:%M:%S")
 374             et = datetime.datetime.strptime(etimet, "%Y-%m-%d %H:%M:%S")
 375             btimet = bt.strftime("%Y-%m-%d %H:%M:%S")
 376             etimet = et.strftime("%Y-%m-%d %H:%M:%S")
 377             #try:
 378             recdb.del_reckey(typetxtnow, title, chtxt, btime)
 379             recdb.rec_reckey(typetxtres, titlet, chtxtt, btimet, etimet, opt)
 380             recdb.rec_reclog(titlet, chtxtt, btimet, etimet, opt, exp,longexp,category)
 381             auto_rec.add_key(chtxt, titlet,exp+" "+longexp)
 382             auto_rec.add_key("ALL", titlet,exp+" "+longexp)
 383             recdblist.printutf8(u"key "+title+u" : "+titlet+u" "+btimet+u" "+etimet)
 384             #except Exception, inst:
 385             #    recdblist.printutf8("Error happened in REC_KEYWORD DB")
 386             #    recdblist.printutf8(type(inst))
 387             #    recdblist.printutf8(inst)
 388         else:
 389             recdblist.printutf8("nothing match")
 390
 391 def type_keyword_every_day(type,chtxt,title,bt,et,opt,deltatime,deltaday):
 392     btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 393     etime = et.strftime("%Y-%m-%d %H:%M:%S")
 394     tnow = datetime.datetime.now()
 395     dtt = bt-tnow
 396     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 397     dd = datetime.timedelta(days=int(deltaday))
 398     if dtt.days < 0:
 399         recdb.del_reckey(recdblist.REC_KEYWORD_EVERY_SOME_DAYS, title, chtxt, btime)
 400         bt = bt + dd
 401         et = et + dd
 402         btxt = bt.strftime("%Y-%m-%d %H:%M:%S")
 403         etxt = et.strftime("%Y-%m-%d %H:%M:%S")
 404         recdb.everyreserv(title, chtxt, btxt, etxt, deltatime, opt, deltaday)
 405     elif dt < 120 * 60:
 406         recdb.keyreserv(title, chtxt, btime, etime, deltatime, opt)
 407         recdb.del_reckey(recdblist.REC_KEYWORD_EVERY_SOME_DAYS, title, chtxt, btime)
 408         bt = bt + dd
 409         et = et + dd
 410         btxt = bt.strftime("%Y-%m-%d %H:%M:%S")
 411         etxt = et.strftime("%Y-%m-%d %H:%M:%S")
 412         recdb.everyreserv(title, chtxt, btxt, etxt, deltatime, opt, deltaday)
 413
 414
 415 def type_decode_que(typetxt,chtxt,title,bt,et,opt):
 416     btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 417     etime = et.strftime("%Y-%m-%d %H:%M:%S")
 418     tnow = datetime.datetime.now()
 419     dtt = bt-tnow
 420     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 421     typetxtnow=typetxt
 422     typetxting=""
 423     typetxtmiss=""
 424     typetxtencque=""
 425     if typetxt== recdblist.REC_TS_DECODE_QUE:
 426         typetxting=recdblist.REC_TS_DECODING
 427         typetxtmiss=recdblist.REC_MISS_DECODE
 428         typetxtencque=recdblist.REC_ENCODE_QUE
 429     tnow = datetime.datetime.now()
 430     dtt = bt-tnow
 431     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 432     if dt < 10 * 60:
 433         if status.getB25Decoding() < 2:
 434             pin = recpath + "/" + title
 435             recdb.del_reckey(typetxtnow, title, chtxt, btime)
 436             recdb.rec_reckey(typetxting, title, chtxt, btime, etime, opt)
 437             tv2avi.b252ts(pin, chtxt, btime, etime, opt)
 438             recdb.del_reckey(typetxting, title, chtxt, btime)
 439             if not os.access(recpath + "/" + title + ".ts", os.F_OK):
 440                 recdb.del_reckey(typetxting, title, chtxt, btime)
 441                 recdb.rec_reckey(typetxtmiss, title, chtxt, btime, etime, opt)
 442             bt = datetime.datetime.strptime(btime, "%Y-%m-%d %H:%M:%S")
 443             et = datetime.datetime.strptime(etime, "%Y-%m-%d %H:%M:%S")
 444             dt = et-bt
 445             if not re.search("D", opt):
 446                 tnow = datetime.datetime.now()
 447                 bt = tnow + datetime.timedelta(seconds=600)
 448                 et = bt + dt
 449                 btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 450                 etime = et.strftime("%Y-%m-%d %H:%M:%S")
 451                 recdb.rec_reckey(typetxtencque, title, chtxt, btime, etime, opt)
 452             else:
 453                 if opt.rfind("d")>=0:
 454                     shutil.copy(os.path.join(recpath,title+".sa.avi"),os.path.join(movepath,title+".sa.avi"))
 455                 elif opt.rfind("5")>=0:
 456                     shutil.copy(os.path.join(recpath,title+".sa.avi"),os.path.join(movepath,title+".sa.avi"))
 457                 else:
 458                     shutil.copy(os.path.join(recpath,title+".ts"), os.path.join(movepath,title+".ts"))
 459                 recdb.rec_reckey(recdblist.REC_MOVE_END, title, chtxt, btime, etime, opt)
 460             #recdblist.printutf8(checker.checkB25Decode(recpath + "/" + title + ".ts.b25", recpath + "/" + title + ".ts"))
 461             if checker.checkB25Decode(recpath + "/" + title + ".ts.b25", recpath + "/" + title + ".ts") == 1:
 462                 os.remove(recpath + "/" + title + ".ts.b25")
 463         else:
 464             recdb.del_reckey(typetxtnow, title, chtxt, btime)
 465             bt = bt + datetime.timedelta(seconds=600)
 466             et = et + datetime.timedelta(seconds=600)
 467             btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 468             etime = et.strftime("%Y-%m-%d %H:%M:%S")
 469             recdb.rec_reckey(typetxtnow, title, chtxt, btime, etime, opt)
 470     sys.exit()
 471
 472 def type_encode_que(typetxt,chtxt,title,bt,et,opt):
 473     btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 474     etime = et.strftime("%Y-%m-%d %H:%M:%S")
 475     tnow = datetime.datetime.now()
 476     dtt = bt-tnow
 477     dt = dtt.days * 24 * 60 * 60 + dtt.seconds
 478     typetxtnow=typetxt
 479     typetxting=""
 480     typetxtfin=""
 481     if typetxt==recdblist.REC_ENCODE_QUE:
 482         typetxting=recdblist.REC_ENCODE_LOCAL
 483         typetxtfin=recdblist.REC_FIN_LOCAL
 484     if dt < 10 * 60:
 485         if status.getEncoding() < int(configreader.getenv("enc_max")):
 486             recdblist.printutf8(opt)
 487             pin = recpath + "/" + title + ".ts"
 488             if re.search("d", opt):
 489                 pin = recpath + "/" + title + ".sa.avi"
 490             if re.search("5", opt):
 491                 pin = recpath + "/" + title + ".sa.avi"
 492             #pout = recpath + "/" + title + ".avi"
 493             pout = recpath + "/" + title + ".mp4"
 494             recdblist.printutf8(pin)
 495             #recdblist.printutf8(pin+":"+pout+":"+opt)
 496             recdb.del_reckey(typetxtnow, title, chtxt, btime)
 497             recdb.rec_reckey(typetxting, title, chtxt, btime, etime, opt)
 498             #tv2mkv.ts2mkv(pin, pout, opt)
 499             tv2mp4.ts2mp4(pin, pout, opt)
 500             #tv2avi.ts2avi(pin, pout, opt)
 501             recdb.del_reckey(typetxting, title, chtxt, btime)
 502             if re.search("R", opt):
 503                 shutil.copy(os.path.join(recpath,title+".mp4"), os.path.join(movepath,title+".mp4"))
 504                 recdb.rec_reckey(recdblist.REC_MOVE_END, title, chtxt, btime, etime, opt)
 505             recdb.rec_reckey(typetxtfin, title, chtxt, btime, etime, opt)
 506             sys.exit()
 507         else:
 508             recdb.del_reckey(typetxtnow, title, chtxt, btime)
 509             bt = bt + datetime.timedelta(seconds=600)
 510             et = et + datetime.timedelta(seconds=600)
 511             btime = bt.strftime("%Y-%m-%d %H:%M:%S")
 512             etime = et.strftime("%Y-%m-%d %H:%M:%S")
 513             recdb.rec_reckey(typetxtnow, title, chtxt, btime, etime, opt)
 514             sys.exit()