|
@@ -1,3 +1,4 @@
|
|
|
|
|
+import datetime
|
|
|
import time
|
|
import time
|
|
|
import re
|
|
import re
|
|
|
import os
|
|
import os
|
|
@@ -17,7 +18,12 @@ class db():
|
|
|
self.ul_files = self.client[self.DB]["ul"]
|
|
self.ul_files = self.client[self.DB]["ul"]
|
|
|
|
|
|
|
|
def uploaded(self):
|
|
def uploaded(self):
|
|
|
- ret = [ jsonable(f) for f in self.ul_files.find() ]
|
|
|
|
|
|
|
+ ret = []
|
|
|
|
|
+ for f in self.ul_files.find():
|
|
|
|
|
+ item = jsonable(f)
|
|
|
|
|
+ item["enqueued_at"]=item["enqueued_at"].strftime("%d/%m/%Y %H:%M")
|
|
|
|
|
+ item["finished_at"]=item["finished_at"].strftime("%d/%m/%Y %H:%M")
|
|
|
|
|
+ ret.append(item)
|
|
|
return ret
|
|
return ret
|
|
|
|
|
|
|
|
def raw(self, _id=None):
|
|
def raw(self, _id=None):
|
|
@@ -25,7 +31,12 @@ class db():
|
|
|
if _id:
|
|
if _id:
|
|
|
ret = jsonable(self.raw_files.find_one({"_id": ObjectId(_id)}))
|
|
ret = jsonable(self.raw_files.find_one({"_id": ObjectId(_id)}))
|
|
|
else:
|
|
else:
|
|
|
- ret = [ jsonable(fix_date(r)) for r in self.raw_files.find() ]
|
|
|
|
|
|
|
+ ret=[]
|
|
|
|
|
+ for r in self.raw_files.find():
|
|
|
|
|
+ item = jsonable(r)
|
|
|
|
|
+ #item["date"]=item["date"].strftime("%d/%m/%Y %H:%M")
|
|
|
|
|
+ ret.append(item)
|
|
|
|
|
+
|
|
|
|
|
|
|
|
return ret
|
|
return ret
|
|
|
|
|
|
|
@@ -34,7 +45,7 @@ class db():
|
|
|
if _id:
|
|
if _id:
|
|
|
ret = jsonable(self.cut_files.find_one({"_id": ObjectId(_id)}))
|
|
ret = jsonable(self.cut_files.find_one({"_id": ObjectId(_id)}))
|
|
|
else:
|
|
else:
|
|
|
- ret = [ jsonable(fix_date(c)) for c in self.cut_files.find() ]
|
|
|
|
|
|
|
+ ret = [ jsonable(c) for c in self.cut_files.find() ]
|
|
|
|
|
|
|
|
return ret
|
|
return ret
|
|
|
|
|
|
|
@@ -69,10 +80,6 @@ class db():
|
|
|
self.insert_raw(file_info(os.path.join(RAW_PATH,fname)))
|
|
self.insert_raw(file_info(os.path.join(RAW_PATH,fname)))
|
|
|
|
|
|
|
|
|
|
|
|
|
-def fix_date(obj):
|
|
|
|
|
- ret = obj
|
|
|
|
|
- #ret["date"]=ret["date"].strftime('%Y-%m-%dT%H:%M:%S')
|
|
|
|
|
- return ret
|
|
|
|
|
def get_video_length(fname):
|
|
def get_video_length(fname):
|
|
|
process="ffprobe -v error -show_entries format=duration -of default=noprint_wrappers=1:nokey=1 -sexagesimal %s" % fname
|
|
process="ffprobe -v error -show_entries format=duration -of default=noprint_wrappers=1:nokey=1 -sexagesimal %s" % fname
|
|
|
process=process.split(" ")
|
|
process=process.split(" ")
|