#!/usr/bin/python
# coding: UTF-8
# Rec10 TS Recording Tools
-# Copyright (C) 2009 Yukikaze
+# Copyright (C) 2009-2010 Yukikaze
import os
import glob
import time
+import datetime
+import commands
-import recdb
+import chdb
+import status
import recdblist
import rec10d
import os.path
import tv2mp4
+import epgdb
def Update_to_MP4(path):
"""
録画一時フォルダ内mp4ファイルを検索
avilist = glob.glob(path + "/*.avi")
mkvlist = glob.glob(path+"/*.mkv")
avilist=avilist+mkvlist
- #recdblist.printutf8(avilist)
for avif in avilist:
if avif.rfind("sa.avi")==-1:
- ##b25f is title.ts.b25 avi is title.avi
dir = os.path.split(avif)[0]
title = os.path.split(avif)[1]
title = title.replace(".avi", "")
def auto_check(path):
avilist = glob.glob(path + "/*.avi")
mkvlist = glob.glob(path+"/*.mkv")
+ mp4list = glob.glob(path+"/*.mp4")
tslist = glob.glob(path+"/*.ts")
b25list = glob.glob(path+"/*.ts.b25")
- filelist=avilist+mkvlist+tslist+b25list
- rec10d.rec10db.new_auto_proc()
+ filelist=avilist+mkvlist+tslist+b25list+mp4list
+ add=[]
+ tbtime=datetime.datetime.now()+datetime.timedelta(seconds=60)
+ tbtime2=datetime.datetime.now()+datetime.timedelta(seconds=1200)
for fn in filelist:
- if fn.rfind("sa.avi")==-1:
+ if fn.rfind("sa.avi")==-1 and fn.rfind(".120.avi")==-1 and os.path.getsize(fn)>1*1000*1000:
dir = os.path.split(fn)[0]
file = os.path.split(fn)[1]
title = os.path.splitext(file)[0]
+ title = unicode(title,'utf-8')
ext = os.path.splitext(file)[1]
- if ext == "b25":
+ if ext == ".b25":
title=title.replace(".ts","")
- proc=check_process(dir, title)
- if proc=="b25":
- rec10d.rec10db.add_auto_proc(recdblist.REC_AUTO_SUGGEST_DECODE,title)
- elif proc=="ts":
- rec10d.rec10db.add_auto_proc(recdblist.REC_AUTO_SUGGEST_ENCODE,title)
- elif proc =="avi":
- rec10d.rec10db.add_auto_proc(recdblist.REC_AUTO_SUGGEST_AVI2MP4,title)
- elif proc =="mkv":
- rec10d.rec10db.add_auto_proc(recdblist.REC_AUTO_SUGGEST_MKV2MP4,title)
+ dbs=rec10d.rec10db.select_by_name_time_timeline(title,tbtime,tbtime2)
+ if len(dbs)==0:
+ proc=check_process(dir, title)
+ chtxtt=rec10d.rec10db.select_chtxt_by_title_timeline_log(title)
+ nchtxt=""
+ if chtxtt!=None:
+ nchtxt=chtxtt
+ if proc=="b25":
+ add.append([recdblist.REC_AUTO_SUGGEST_DECODE,title,nchtxt])
+ elif proc=="ts":
+ add.append([recdblist.REC_AUTO_SUGGEST_ENCODE,title,nchtxt])
+ elif proc =="264":
+ add.append([recdblist.REC_AUTO_SUGGEST_AVI2FP,title,nchtxt])
+ #elif proc =="mp4":
+ # add.append([recdblist.REC_AUTO_SUGGEST_AP2FP,title,nchtxt])
+ #print add
+ if len(add)>0:
+ rec10d.rec10db.new_auto_proc()
+ for a in add:
+ rec10d.rec10db.add_auto_proc(a[0],a[1],a[2])
+ time.sleep(1)
"""
処理がどの段階まで言ったのかを調査し返す。
return
mp4
"""
def check_process(path,title):
- path1 = os.path.join(path,title+".mp4")
+ path1 = os.path.join(path,title+".mkv")
if os.path.exists(path1):
if int(time.time()-os.path.getmtime(path1))>300:
+ return "mkv"
+ else:
+ return "mkvmaking"
+ elif os.path.exists(os.path.join(path,title+".mp4")):
+ if int(time.time()-os.path.getmtime(os.path.join(path,title+".mp4")))>300:
return "mp4"
else:
return "mp4making"
- elif os.path.exists(os.path.join(path,title+".avi")):
- if int(time.time()-os.path.getmtime(os.path.join(path,title+".avi")))>300:
- return "avi"
+ elif os.path.exists(os.path.join(path,title+".264")):
+ if int(time.time()-os.path.getmtime(os.path.join(path,title+".264")))>300:
+ return "264"
else:
return "encoding"
+ elif os.path.exists(os.path.join(path,title+".ts.log")):
+ if int(time.time()-os.path.getmtime(os.path.join(path,title+".ts")))<300:
+ return "encoding"
+ else:
+ return "ts"
elif os.path.exists(os.path.join(path,title+".ts")):
if int(time.time()-os.path.getmtime(os.path.join(path,title+".ts")))>300:
return "ts"
return "b25"
else:
return "recording"
-
+def update_all_timeline_epg():
+ now=datetime.datetime.now()
+ et=now+datetime.timedelta(days=7)
+ update_timeline_epg(now.strftime("%Y-%m-%d %H:%M:%S"), et.strftime("%Y-%m-%d %H:%M:%S"))
+def update_timeline_epg(btime,etime):
+ update_timeline_epg_schedule(btime,etime)
+ update_timeline_dup(btime,etime)
+def update_timeline_epg_schedule(btime,etime):
+ dbl=rec10d.rec10db.select_bytime_all_timeline(btime, etime)
+ #print dbl
+ for db in dbl:
+ ret=[]
+ #[chtxtt, title, btime, etime,exp,longexp,category]
+ if db['type']==recdblist.REC_KEYWORD or db['type']==recdblist.REC_KEYWORD_EVERY_SOME_DAYS:
+ ret=epgdb.searchtime2(db['title'], db['btime'], db['deltatime'], db['chtxt'])
+ if len(ret)>4 and len(ret[2])>18:
+ rec10d.rec10db.update_epg_timeline(db['type'], db['chtxt'], db['title'], db['btime'], ret[2],ret[3],ret[1])
+ if not (db['btime'] == ret[2] and db['etime']==ret[3]):
+ rec10d.rec10db.update_status_change_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "1")
+ else:
+ rec10d.rec10db.update_status_change_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "0")
+ else:
+ rec10d.rec10db.update_status_change_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "1")
+ elif db['type']==recdblist.REC_RESERVE or db['type']==recdblist.REC_FINAL_RESERVE :
+ ret=epgdb.searchtime2(db['title'], db['btime'],"5", db['chtxt'])
+ if len(ret)>4 and len(ret[2])>18:
+ rec10d.rec10db.update_epg_timeline(db['type'], db['chtxt'], db['title'], db['btime'], ret[2],ret[3],ret[1])
+ if not (db['btime'] == ret[2] and db['etime']==ret[3]):
+ rec10d.rec10db.update_status_change_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "1")
+ else:
+ rec10d.rec10db.update_status_change_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "0")
+ else:
+ rec10d.rec10db.update_status_change_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "1")
+def update_timeline_dup(epgbtime,epgetime):
+ dbl=rec10d.rec10db.select_byepgtime_all_timeline(epgbtime, epgetime)
+ for db in dbl:
+ if db['type']==recdblist.REC_KEYWORD or db['type']==recdblist.REC_KEYWORD_EVERY_SOME_DAYS:
+ dbn=epgdb.count_epgschedule(db['epgbtime'], db['epgetime'])
+ try:
+ bctypet=chdb.chtxtsearch(db['chtxt'])['bctype']
+ if bctypet.find("cs") > -1 or bctypet.find("bs") > -1 :
+ if dbn[1]>status.getRecordingMax()[1]:
+ rec10d.rec10db.update_status_dup_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "1")
+ else:
+ rec10d.rec10db.update_status_dup_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "0")
+ else:
+ if dbn[0]>status.getRecordingMax()[0]:
+ rec10d.rec10db.update_status_dup_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "1")
+ else:
+ rec10d.rec10db.update_status_dup_timeline(db['type'], db['chtxt'], db['title'], db['btime'], "0")
+ except:
+ ""
+def kill_dead_encode(path):
+ rawlist = glob.glob(path + "/*.264")
+ for fn in rawlist:
+ if int(time.time()-os.path.getmtime(fn))>3000:
+ tspath=unicode(fn.replace(".264",".ts"),'utf-8')
+ m2vpath=unicode(fn.replace(".264",".m2v"),'utf-8')
+ x264path=unicode(fn.replace(".264",".264"),'utf-8')
+ os.environ['LANG']="ja_JP.UTF-8"
+
+ #ktmp=u"ps auxw | grep \""+tspath+u"\" | egrep -v grep | egrep -v \"sh -c\" | grep mencoder | awk '{print $2}'"
+ #kmmp=u"ps auxw | grep \""+m2vpath+u"\" | egrep -v grep | egrep -v \"sh -c\" | grep mencoder | awk '{print $2}'"
+ #ktmt=commands.getoutput(ktmp.encode('utf-8'))
+ #kmmt=commands.getoutput(kmmp.encode('utf-8'))
+ ktmp=u"ps auxw | grep \""+x264path+u"\" | egrep -v grep | egrep -v \"sh -c\" | grep x264 | awk '{print $2}'"
+ #recdblist.printutf8(ktmp)
+ ktmt=commands.getoutput(ktmp.encode('utf-8'))
+ if len(ktmt)>0:
+ ktmt=ktmt[0]
+ try:
+ if int(ktmt)>0:
+ ktmp=u"kill -9 '"+ktmp+u"'"
+ os.system(ktmp.encode('utf-8'))
+ except:
+ ""
+ """if len(kmmt)>0:
+ kmmt=kmmt[0]
+ try:
+ if int(kmmt)>0:
+ kmmp=u"kill -9 '"+kmmp+u"'"
+ os.system(kmmp.encode('utf-8'))
+ except:
+ """""
+
OSDN Git Service
