yan/mdserver-web
1
0
Fork 0
mirror of https://github.com/midoks/mdserver-web.git synced 2026-10-18 23:45:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update qbittorrent_worker.py

Browse Source
This commit is contained in:
Mr Chen
2019-02-07 15:36:23 +08:00
parent 973e2fa1ac
commit 9cce88755e
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/qbittorrent/workers/qbittorrent_worker.py
+10 -8
View File
@@ -163,12 +163,6 @@ class downloadBT(Thread):
md5file = self.md5(file)[0:6] md5file = self.md5(file)[0:6]
# if self.islock(md5file):
# print self.debug('file:' + file + ' is lock, doing')
# return
# else:
# self.lock(md5file)
if not os.path.exists(file): if not os.path.exists(file):
print formatTime(), 'file not exists:', file print formatTime(), 'file not exists:', file
return return
@@ -211,13 +205,13 @@ class downloadBT(Thread):
os.system(cmd_m3u8) os.system(cmd_m3u8)
self.execShell('chown -R ' + FILE_OWN + ':' + self.execShell('chown -R ' + FILE_OWN + ':' +
FILE_GROUP + ' ' + m3u8_dir) FILE_GROUP + ' ' + m3u8_dir)
self.add_hash() self.add_hash()
else: else:
self.add_hash()
print self.debug('m3u8 exists:' + tofile) print self.debug('m3u8 exists:' + tofile)
# self.unlock(md5file)
def add_hash(self): def add_hash(self):
print '-------------------------add_hash---start-----------------------'
ct = formatTime() ct = formatTime()
print self.sign_torrent print self.sign_torrent
total_size = str(self.sign_torrent['total_size']) total_size = str(self.sign_torrent['total_size'])
@@ -228,9 +222,17 @@ class downloadBT(Thread):
info = self.query(sql) info = self.query(sql)
if len(info[0]) > 0: if len(info[0]) > 0:
sid = str(info[0][0]) sid = str(info[0][0])
print info
sql = "select id from pl_hash_file where name='" + \
sname + "' and pid='" + pid + "'"
print self.query(sql)
print self.query("insert into pl_hash_file (`pid`,`name`,`m3u8`,`length`,`create_time`) values('" + sid + "','" + sname + "','" + 'dd' + "','" + total_size + "','" + ct + "')") print self.query("insert into pl_hash_file (`pid`,`name`,`m3u8`,`length`,`create_time`) values('" + sid + "','" + sname + "','" + 'dd' + "','" + total_size + "','" + ct + "')")
else: else:
print self.query("insert into pl_hash_list (`name`,`info_hash`,`data_hash`,`length`,`create_time`) values('" + sname + "','" + shash + "','da12','" + total_size + "','" + ct + "')") print self.query("insert into pl_hash_list (`name`,`info_hash`,`data_hash`,`length`,`create_time`) values('" + sname + "','" + shash + "','da12','" + total_size + "','" + ct + "')")
print '-------------------------add_hash---end-------------------------'
def file_arr(self, path, filters=['.DS_Store']): def file_arr(self, path, filters=['.DS_Store']):
file_list = [] file_list = []