X-Git-Url: http://git.osdn.net/view?p=rec10%2Frec10-git.git;a=blobdiff_plain;f=rec10%2Ftrunk%2Fsrc%2Frecque.py;h=0471326a124ccc0bf0d4db800d892c651c841e86;hp=77125f1d86a9e82223d6b75416f3f59a5feaa551;hb=c363a10d99acf08f3a298919ffd20c5f4660b666;hpb=d0b9caef4d39a18b34f1dd6104ecc4ed9af059a7 diff --git a/rec10/trunk/src/recque.py b/rec10/trunk/src/recque.py index 77125f1..0471326 100644 --- a/rec10/trunk/src/recque.py +++ b/rec10/trunk/src/recque.py @@ -1,66 +1,66 @@ -#!/usr/bin/python -# coding: UTF-8 -# Rec10 TS Recording Tools -# Copyright (C) 2009-2010 Yukikaze -import datetime -import os -import os.path -import glob -import time -import traceback - -import configreader -import recdblist -import recdb -def writeRecQue(parentpath,chtxt,title,opts): - f=open(os.path.join(parentpath,title+".recq"),"w") - optt=opts - #optt=opts.replace("E","") - #optt=optt.replace("D","") - #optt=optt.replace("R","") - str="99"+","+datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")+","+configreader.getEnvSetting("iff")+","+chtxt+","+title+","+optt - f.write(str.encode('utf-8')) - f.close() - -def readRecQue(recquepath): - f=open(recquepath,"r") - line = unicode(f.readline(),'utf-8') - title="" - opts="" - chtxt="" - while line: - linec=line.split(",") - if len(linec)>3: - if linec[0]=="99": - title=linec[4] - opts=linec[5] - chtxt=linec[2]+u"_"+linec[3] - break - line = unicode(f.readline(),'utf-8') - dbkey="" - if opts.find("E"): - dbkey="" - opts=opts.replace("E","") - if opts.find("D"): - dbkey=recdblist.REC_ENCODE_QUE - opts=opts.replace("D","") - if opts.find("R"): - dbkey=recdblist.REC_TS_DECODE_QUE - opts=opts.replace("R","") - bt=datetime.datetime.now()+datetime.timedelta(minutes=5) - et=bt+datetime.timedelta(minutes=30) - btime=bt.strftime("%Y-%m-%d %H:%M:%S") - etime=et.strftime("%Y-%m-%d %H:%M:%S") - if len(dbkey)>2: - recdb.rec_reckey(dbkey, title, chtxt, btime, etime, opts) -def searchRecQue(folderpath): - for file in glob.glob(os.path.join(folderpath,"*.recq")): - dtime = time.time()-os.path.getmtime(file) - dtime = int(dtime) - if dtime > 300: - try: - readRecQue(os.path.join(folderpath, file)) - os.remove(os.path.join(folderpath, file)) - except Exception, inst: - recdblist.addCommonlogEX("Error", "searchRecQue(recque.py)", str(type(inst)), str(inst)+traceback.format_exc(),log_level=200) - \ No newline at end of file +#!/usr/bin/python +# coding: UTF-8 +# Rec10 TS Recording Tools +# Copyright (C) 2009-2010 Yukikaze +import datetime +import os +import os.path +import glob +import time +import traceback + +import configreader +import recdblist +import recdb +def writeRecQue(parentpath,chtxt,title,opts): + f=open(os.path.join(parentpath,title+".recq"),"w") + optt=opts + #optt=opts.replace("E","") + #optt=optt.replace("D","") + #optt=optt.replace("R","") + str="99"+","+datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")+","+configreader.getConfEnv("iff")+","+chtxt+","+title+","+optt + f.write(str.encode('utf-8')) + f.close() + +def readRecQue(recquepath): + f=open(recquepath,"r") + line = unicode(f.readline(),'utf-8') + title="" + opts="" + chtxt="" + while line: + linec=line.split(",") + if len(linec)>3: + if linec[0]=="99": + title=linec[4] + opts=linec[5] + chtxt=linec[2]+u"_"+linec[3] + break + line = unicode(f.readline(),'utf-8') + dbkey="" + if opts.find("E"): + dbkey="" + opts=opts.replace("E","") + if opts.find("D"): + dbkey=recdblist.REC_ENCODE_QUE + opts=opts.replace("D","") + if opts.find("R"): + dbkey=recdblist.REC_TS_DECODE_QUE + opts=opts.replace("R","") + bt=datetime.datetime.now()+datetime.timedelta(minutes=5) + et=bt+datetime.timedelta(minutes=30) + btime=bt.strftime("%Y-%m-%d %H:%M:%S") + etime=et.strftime("%Y-%m-%d %H:%M:%S") + if len(dbkey)>2: + recdb.reserveReckey(dbkey, title, chtxt, btime, etime, opts) +def searchRecQue(folderpath): + for file in glob.glob(os.path.join(folderpath,"*.recq")): + dtime = time.time()-os.path.getmtime(file) + dtime = int(dtime) + if dtime > 300: + try: + readRecQue(os.path.join(folderpath, file)) + os.remove(os.path.join(folderpath, file)) + except Exception, inst: + recdblist.addCommonlogEX("Error", "searchRecQue(recque.py)", str(type(inst)), str(inst)+traceback.format_exc(),log_level=200) +