mirror of
https://github.com/NNTmux/newznab-tmux.git
synced 2026-08-29 17:28:55 +00:00
Fisrt batch of updates. Renaming all the columns into lower case names used.
This commit is contained in:
Darko
@@ -36,13 +36,13 @@ print(bcolors.HEADER + "\nBinaries Threaded Started at {}".format(datetime.datet
|
||||
#get active groups
|
||||
if len(sys.argv) == 2:
|
||||
try:
|
||||
cur[0].execute("SELECT name FROM groups WHERE ID IN " + sys.argv[1])
|
||||
cur[0].execute("SELECT name FROM groups WHERE id IN " + sys.argv[1])
|
||||
datas = cur[0].fetchall()
|
||||
except:
|
||||
cur[0].execute("SELECT name FROM groups WHERE name = '" + sys.argv[1] + "'")
|
||||
datas = cur[0].fetchall()
|
||||
if len(datas) == 0:
|
||||
cur[0].execute("SELECT name FROM groups WHERE ID = " + sys.argv[1])
|
||||
cur[0].execute("SELECT name FROM groups WHERE id = " + sys.argv[1])
|
||||
datas = cur[0].fetchall()
|
||||
if len(datas) == 0:
|
||||
print(bcolors.ERROR + "No Active Groups" + bcolors.ENDC)
|
||||
|
||||
@@ -23,7 +23,7 @@ pathname = os.path.abspath(os.path.dirname(sys.argv[0]))
|
||||
if len(sys.argv) == 1:
|
||||
print(bcolors.ERROR + "\nAn argument is required\n\n"
|
||||
+ "python " + sys.argv[0] + " [md5, nfo, filename, par2] ...: To process all previously unprocessed releases, using [md5, nfo, filename, par2].\n"
|
||||
+ "python " + sys.argv[0] + " [nfo, filename, par2] prehashid ...: To process all releases not matched to prehashID, using [nfo, filename, par2].\n"
|
||||
+ "python " + sys.argv[0] + " [nfo, filename, par2] prehashid ...: To process all releases not matched to prehashid, using [nfo, filename, par2].\n"
|
||||
+ "python " + sys.argv[0] + " nfo clean ...: To process all releases processed by filename, using nfo.\n"
|
||||
+ "python " + sys.argv[0] + " par2 clean ...: To process all releases processed by filename and nfo, using par2.\n"
|
||||
+ "python " + sys.argv[0] + " predbft clean ...: To process all releases using reverse match by PreDB title.\n"
|
||||
@@ -39,11 +39,11 @@ if len(sys.argv) == 3 and sys.argv[1] == "nfo" and sys.argv[2] == "clean":
|
||||
elif len(sys.argv) == 3 and sys.argv[1] == "par2" and sys.argv[2] == "clean":
|
||||
clean = " isrenamed = 0 AND proc_files = 1 AND proc_nfo = 1 "
|
||||
elif len(sys.argv) == 3 and sys.argv[1] == "nfo" and sys.argv[2] == "prehashid":
|
||||
clean = " prehashID = IS NULL "
|
||||
clean = " prehashid = IS NULL "
|
||||
elif len(sys.argv) == 3 and sys.argv[1] == "par2" and sys.argv[2] == "prehashid":
|
||||
clean = " prehashID = IS NULL "
|
||||
clean = " prehashid = IS NULL "
|
||||
elif len(sys.argv) == 3 and sys.argv[1] == "filename" and sys.argv[2] == "prehashid":
|
||||
clean = " prehashID = IS NULL "
|
||||
clean = " prehashid = IS NULL "
|
||||
else:
|
||||
clean = " isrenamed = 0 "
|
||||
|
||||
@@ -58,27 +58,27 @@ datas = []
|
||||
maxtries = 0
|
||||
|
||||
if len(sys.argv) > 1 and sys.argv[1] == "nfo":
|
||||
run = "SELECT DISTINCT ID AS releaseID FROM releases WHERE nzbstatus = 1 AND nfostatus = 1 AND proc_nfo = 0 AND" + clean + "ORDER BY postdate DESC LIMIT %s"
|
||||
run = "SELECT DISTINCT id AS releaseid FROM releases WHERE nzbstatus = 1 AND nfostatus = 1 AND proc_nfo = 0 AND" + clean + "ORDER BY postdate DESC LIMIT %s"
|
||||
cur[0].execute(run, (int(perrun[0]) * int(run_threads[0])))
|
||||
datas = cur[0].fetchall()
|
||||
elif len(sys.argv) > 1 and (sys.argv[1] == "filename"):
|
||||
run = "SELECT DISTINCT rel.ID AS releaseID FROM releases rel INNER JOIN releasefiles relfiles ON (relfiles.releaseID = rel.ID) WHERE categoryID IN (8010, 8020) AND proc_files = 0 AND" + clean + "ORDER BY postdate ASC LIMIT %s"
|
||||
run = "SELECT DISTINCT rel.id AS releaseid FROM releases rel INNER JOIN releasefiles relfiles ON (relfiles.releaseid = rel.id) WHERE categoryid IN (8010, 8020) AND proc_files = 0 AND" + clean + "ORDER BY postdate ASC LIMIT %s"
|
||||
cur[0].execute(run, (int(perrun[0]) * int(run_threads[0])))
|
||||
datas = cur[0].fetchall()
|
||||
elif len(sys.argv) > 1 and (sys.argv[1] == "md5"):
|
||||
while len(datas) == 0 and maxtries >= -5:
|
||||
run = "SELECT DISTINCT rel.ID FROM releases rel INNER JOIN releasefiles rf ON rel.ID = rf.releaseID WHERE rel.dehashstatus BETWEEN %s AND 0 AND (rel.ishashed = 1 OR rf.ishashed = 1) AND prehashID = 0 ORDER BY postdate ASC LIMIT %s"
|
||||
run = "SELECT DISTINCT rel.id FROM releases rel INNER JOIN releasefiles rf ON rel.id = rf.releaseid WHERE rel.dehashstatus BETWEEN %s AND 0 AND (rel.ishashed = 1 OR rf.ishashed = 1) AND prehashid = 0 ORDER BY postdate ASC LIMIT %s"
|
||||
cur[0].execute(run, (maxtries, int(perrun[0])*int(run_threads[0])))
|
||||
datas = cur[0].fetchall()
|
||||
maxtries = maxtries - 1
|
||||
elif len(sys.argv) > 1 and (sys.argv[1] == "par2"):
|
||||
#This one does from oldest posts to newest posts, since nfo pp does same thing but newest to oldest
|
||||
run = "SELECT ID AS releaseID, guid, groupID FROM releases WHERE categoryID IN (8010, 8020) AND proc_par2 = 0 AND" + clean + "ORDER BY postdate ASC LIMIT %s"
|
||||
run = "SELECT id AS releaseid, guid, groupid FROM releases WHERE categoryid IN (8010, 8020) AND proc_par2 = 0 AND" + clean + "ORDER BY postdate ASC LIMIT %s"
|
||||
cur[0].execute(run, (int(perrun[0]) * int(run_threads[0])))
|
||||
datas = cur[0].fetchall()
|
||||
elif len(sys.argv) > 1 and (sys.argv[1] == "predbft"):
|
||||
#This one does from oldest posts to newest posts since there are many other more efficient PreDB matching schemes
|
||||
run = "SELECT ID AS preid FROM prehash WHERE LENGTH(title) >= 15 AND searched = 0 AND title NOT REGEXP '[\"\<\> ]' ORDER BY predate ASC LIMIT %s"
|
||||
run = "SELECT id AS preid FROM prehash WHERE LENGTH(title) >= 15 AND searched = 0 AND title NOT REGEXP '[\"\<\> ]' ORDER BY predate ASC LIMIT %s"
|
||||
cur[0].execute(run, (int(perrun[0])/10 * int(run_threads[0])))
|
||||
datas = cur[0].fetchall()
|
||||
|
||||
|
||||
@@ -52,12 +52,12 @@ if threads > 16:
|
||||
maxperrun = int(run_perrun[0])
|
||||
|
||||
if sys.argv[1] == "md5":
|
||||
join = "LEFT OUTER JOIN releasefiles rf ON r.ID = rf.releaseID AND rf.ishashed = 1"
|
||||
join = "LEFT OUTER JOIN releasefiles rf ON r.id = rf.releaseid AND rf.ishashed = 1"
|
||||
where = "r.ishashed = 1 AND r.dehashstatus BETWEEN -6 AND 0"
|
||||
elif sys.argv[1] == "nfo":
|
||||
where = "r.proc_nfo = 0 AND r.nfostatus = 1"
|
||||
elif sys.argv[1] == "filename":
|
||||
join = "INNER JOIN releasefiles rf ON r.ID = rf.releaseID"
|
||||
join = "INNER JOIN releasefiles rf ON r.id = rf.releaseid"
|
||||
where = "r.proc_files = 0"
|
||||
elif sys.argv[1] == "par2":
|
||||
where = "r.proc_par2 = 0"
|
||||
@@ -67,7 +67,7 @@ elif sys.argv[1] == "predbft":
|
||||
where = "1=1"
|
||||
rowlimit = "LIMIT %s" % (threads)
|
||||
|
||||
cur[0].execute("SELECT DISTINCT LEFT(r.guid, 1), COUNT(*) AS count FROM releases r %s WHERE %s AND r.prehashID = 0 AND r.nzbstatus = 1 %s %s %s %s" % (join, where, datelimit, groupby, orderby, rowlimit))
|
||||
cur[0].execute("SELECT DISTINCT LEFT(r.guid, 1), COUNT(*) AS count FROM releases r %s WHERE %s AND r.prehashid = 0 AND r.nzbstatus = 1 %s %s %s %s" % (join, where, datelimit, groupby, orderby, rowlimit))
|
||||
datas = cur[0].fetchall()
|
||||
|
||||
guids = int(len(datas))
|
||||
|
||||
+2
-2
@@ -27,7 +27,7 @@ class NNTPClientConnector(socketpool.Connector, nntp.NNTPClient):
|
||||
raise ValueError("Bad backend")
|
||||
nntp.NNTPClient.__init__(self, self.host, self.port, username, password, timeout=timeout, use_ssl=use_ssl)
|
||||
self.id = self.socket.getsockname()[1]
|
||||
print(bcolors.PRIMARY + "New NNTP connection to %s established with ID #%5d" %
|
||||
print(bcolors.PRIMARY + "New NNTP connection to %s established with id #%5d" %
|
||||
(self.host, self.id) + bcolors.ENDC)
|
||||
self._connected = True
|
||||
self.xfeature_compress_gzip()
|
||||
@@ -54,7 +54,7 @@ class NNTPClientConnector(socketpool.Connector, nntp.NNTPClient):
|
||||
return self._life
|
||||
|
||||
def invalidate(self):
|
||||
print(bcolors.PRIMARY + "Disconnecting from NNTP connection ID #%5d after %d seconds." %
|
||||
print(bcolors.PRIMARY + "Disconnecting from NNTP connection id #%5d after %d seconds." %
|
||||
(self.id, (time.time() - self._start_time)) + bcolors.ENDC)
|
||||
self.close()
|
||||
self._connected = False
|
||||
|
||||
@@ -19,7 +19,7 @@ conf = info.readConfig()
|
||||
cur = info.connect()
|
||||
|
||||
if len(sys.argv) == 1:
|
||||
print(bcolors.ERROR + "\nWrong set of arguments.\nThe first argument [additional, nfo, movie, clean] determines the postprocessing to do.\nThe optional second argument for [additional, nfo] [groupID, categoryID] allows to process only that group or category.\nThe optional second argument for [movies, tv] [clean] allows processing only properly renamed releases.\n\npython postprocess_threaded.py [additional, nfo] (optional [groupID, categoryID])\npython postprocess_threaded.py [movie, tv] (optional [clean])\n" + bcolors.ENDC)
|
||||
print(bcolors.ERROR + "\nWrong set of arguments.\nThe first argument [additional, nfo, movie, clean] determines the postprocessing to do.\nThe optional second argument for [additional, nfo] [groupid, categoryid] allows to process only that group or category.\nThe optional second argument for [movies, tv] [clean] allows processing only properly renamed releases.\n\npython postprocess_threaded.py [additional, nfo] (optional [groupid, categoryid])\npython postprocess_threaded.py [movie, tv] (optional [clean])\n" + bcolors.ENDC)
|
||||
sys.exit()
|
||||
if len(sys.argv) == 3 and sys.argv[2] == "clean":
|
||||
print(bcolors.HEADER + "\nPostProcess {} Clean Threaded Started at {}".format(sys.argv[1],datetime.datetime.now().strftime("%H:%M:%S")) + bcolors.ENDC)
|
||||
@@ -33,40 +33,40 @@ if sys.argv[1] == "additional":
|
||||
elif sys.argv[1] == "nfo":
|
||||
print(bcolors.HEADER + "* = hidden NFO, + = NFO, - = no NFO, f = download failed." + bcolors.ENDC)
|
||||
|
||||
# You can limit postprocessing for additional and nfo by groupID or categoryID
|
||||
# You can limit postprocessing for additional and nfo by groupid or categoryid
|
||||
if len(sys.argv) == 3 and sys.argv[2].isdigit() and len(sys.argv[2]) < 4:
|
||||
groupID = 'AND groupID = '+sys.argv[2]
|
||||
print(bcolors.HEADER + "Using groupID "+sys.argv[2] + bcolors.ENDC)
|
||||
groupid = 'AND groupid = '+sys.argv[2]
|
||||
print(bcolors.HEADER + "Using groupid "+sys.argv[2] + bcolors.ENDC)
|
||||
elif len(sys.argv) == 3 and sys.argv[2].isdigit() and len(sys.argv[2]) == 4:
|
||||
if sys.argv[2] == '1000':
|
||||
groupID = 'AND categoryID BETWEEN 1000 AND 1999'
|
||||
groupid = 'AND categoryid BETWEEN 1000 AND 1999'
|
||||
print(bcolors.HEADER + "Using categoryids 1000-1999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '2000':
|
||||
groupID = 'AND categoryID BETWEEN 2000 AND 2999'
|
||||
groupid = 'AND categoryid BETWEEN 2000 AND 2999'
|
||||
print(bcolors.HEADER + "Using categoryids 2000-2999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '3000':
|
||||
groupID = 'AND categoryID BETWEEN 3000 AND 3999'
|
||||
groupid = 'AND categoryid BETWEEN 3000 AND 3999'
|
||||
print(bcolors.HEADER + "Using categoryids 3000-3999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '4000':
|
||||
groupID = 'AND categoryID BETWEEN 4000 AND 4999'
|
||||
groupid = 'AND categoryid BETWEEN 4000 AND 4999'
|
||||
print(bcolors.HEADER + "Using categoryids 4000-4999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '5000':
|
||||
groupID = 'AND categoryID BETWEEN 5000 AND 5999'
|
||||
groupid = 'AND categoryid BETWEEN 5000 AND 5999'
|
||||
print(bcolors.HEADER + "Using categoryids 5000-5999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '6000':
|
||||
groupID = 'AND categoryID BETWEEN 6000 AND 6999'
|
||||
groupid = 'AND categoryid BETWEEN 6000 AND 6999'
|
||||
print(bcolors.HEADER + "Using categoryids 6000-6999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '7000':
|
||||
groupID = 'AND categoryID BETWEEN 7000 AND 7999'
|
||||
groupid = 'AND categoryid BETWEEN 7000 AND 7999'
|
||||
print(bcolors.HEADER + "Using categoryids 7000-7999" + bcolors.ENDC)
|
||||
elif sys.argv[2] == '8000':
|
||||
groupID = 'AND categoryID BETWEEN 8000 AND 8999'
|
||||
groupid = 'AND categoryid BETWEEN 8000 AND 8999'
|
||||
print(bcolors.HEADER + "Using categoryids 8000-8999" + bcolors.ENDC)
|
||||
else:
|
||||
groupID = 'AND categoryID = '+sys.argv[2]
|
||||
print(bcolors.HEADER + "Using categoryID "+sys.argv[2] + bcolors.ENDC)
|
||||
groupid = 'AND categoryid = '+sys.argv[2]
|
||||
print(bcolors.HEADER + "Using categoryid "+sys.argv[2] + bcolors.ENDC)
|
||||
else:
|
||||
groupID = ''
|
||||
groupid = ''
|
||||
|
||||
#you can sort tv releases by searchname
|
||||
if len(sys.argv) == 3 and (sys.argv[2] == "asc" or sys.argv[2] == "desc"):
|
||||
@@ -82,7 +82,7 @@ start_time = time.time()
|
||||
pathname = os.path.abspath(os.path.dirname(sys.argv[0]))
|
||||
|
||||
if len(sys.argv) > 1 and sys.argv[1] == "additional":
|
||||
cur[0].execute("SELECT (SELECT value FROM site WHERE setting = 'postthreads') AS a, (SELECT value FROM site WHERE setting = 'maxaddprocessed') AS b, (SELECT value FROM site WHERE setting = 'maxnfoprocessed') AS c, (SELECT value FROM site WHERE setting = 'maximdbprocessed') AS d, (SELECT value FROM site WHERE setting = 'maxrageprocessed') AS e, (SELECT value FROM site WHERE setting = 'maxsizetopostprocess') AS f, (SELECT value FROM site WHERE setting = 'tmpunrarpath') AS g, (SELECT value FROM tmux WHERE setting = 'post') AS h, (SELECT value FROM tmux WHERE setting = 'post_non') AS i, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -1 "+groupID+") as j, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -2 "+groupID+") as k, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -3 "+groupID+") as l, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -4 "+groupID+") as m, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -5 "+groupID+") as n, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -6 "+groupID+") as o")
|
||||
cur[0].execute("SELECT (SELECT value FROM site WHERE setting = 'postthreads') AS a, (SELECT value FROM site WHERE setting = 'maxaddprocessed') AS b, (SELECT value FROM site WHERE setting = 'maxnfoprocessed') AS c, (SELECT value FROM site WHERE setting = 'maximdbprocessed') AS d, (SELECT value FROM site WHERE setting = 'maxrageprocessed') AS e, (SELECT value FROM site WHERE setting = 'maxsizetopostprocess') AS f, (SELECT value FROM site WHERE setting = 'tmpunrarpath') AS g, (SELECT value FROM tmux WHERE setting = 'post') AS h, (SELECT value FROM tmux WHERE setting = 'post_non') AS i, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -1 "+groupid+") as j, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -2 "+groupid+") as k, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -3 "+groupid+") as l, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -4 "+groupid+") as m, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -5 "+groupid+") as n, (SELECT count(*) FROM releases WHERE haspreview = -1 and passwordstatus = -6 "+groupid+") as o")
|
||||
dbgrab = cur[0].fetchall()
|
||||
ps1 = format(int(dbgrab[0][9]))
|
||||
ps2 = format(int(dbgrab[0][10]))
|
||||
@@ -91,7 +91,7 @@ if len(sys.argv) > 1 and sys.argv[1] == "additional":
|
||||
ps5 = format(int(dbgrab[0][13]))
|
||||
ps6 = format(int(dbgrab[0][14]))
|
||||
elif len(sys.argv) > 1 and sys.argv[1] == "nfo":
|
||||
cur[0].execute("SELECT (SELECT value FROM site WHERE setting = 'nfothreads') AS a, (SELECT value FROM site WHERE setting = 'maxaddprocessed') AS b, (SELECT value FROM site WHERE setting = 'maxnfoprocessed') AS c, (SELECT value FROM site WHERE setting = 'maximdbprocessed') AS d, (SELECT value FROM site WHERE setting = 'maxrageprocessed') AS e, (SELECT value FROM site WHERE setting = 'maxsizetopostprocess') AS f, (SELECT value FROM site WHERE setting = 'tmpunrarpath') AS g, (SELECT value FROM tmux WHERE setting = 'post') AS h, (SELECT value FROM tmux WHERE setting = 'post_non') AS i, (SELECT count(*) FROM releases WHERE nfostatus = -1 "+groupID+") as j, (SELECT count(*) FROM releases WHERE nfostatus = -2 "+groupID+") as k, (SELECT count(*) FROM releases WHERE nfostatus = -3 "+groupID+") as l, (SELECT count(*) FROM releases WHERE nfostatus = -4 "+groupID+") as m, (SELECT count(*) FROM releases WHERE nfostatus = -5 "+groupID+") as n, (SELECT count(*) FROM releases WHERE nfostatus = -6 "+groupID+") as o")
|
||||
cur[0].execute("SELECT (SELECT value FROM site WHERE setting = 'nfothreads') AS a, (SELECT value FROM site WHERE setting = 'maxaddprocessed') AS b, (SELECT value FROM site WHERE setting = 'maxnfoprocessed') AS c, (SELECT value FROM site WHERE setting = 'maximdbprocessed') AS d, (SELECT value FROM site WHERE setting = 'maxrageprocessed') AS e, (SELECT value FROM site WHERE setting = 'maxsizetopostprocess') AS f, (SELECT value FROM site WHERE setting = 'tmpunrarpath') AS g, (SELECT value FROM tmux WHERE setting = 'post') AS h, (SELECT value FROM tmux WHERE setting = 'post_non') AS i, (SELECT count(*) FROM releases WHERE nfostatus = -1 "+groupid+") as j, (SELECT count(*) FROM releases WHERE nfostatus = -2 "+groupid+") as k, (SELECT count(*) FROM releases WHERE nfostatus = -3 "+groupid+") as l, (SELECT count(*) FROM releases WHERE nfostatus = -4 "+groupid+") as m, (SELECT count(*) FROM releases WHERE nfostatus = -5 "+groupid+") as n, (SELECT count(*) FROM releases WHERE nfostatus = -6 "+groupid+") as o")
|
||||
dbgrab = cur[0].fetchall()
|
||||
ps1 = format(int(dbgrab[0][9]))
|
||||
ps2 = format(int(dbgrab[0][10]))
|
||||
@@ -130,22 +130,22 @@ process_additional = run_threads * ppperrun
|
||||
process_nfo = run_threads * nfoperrun
|
||||
|
||||
if sys.argv[1] == "additional":
|
||||
cur[0].execute("SELECT LEFT(r.guid, 1) FROM releases r LEFT JOIN category c ON c.ID = r.categoryID WHERE r.nzbstatus = 1 "+maxsize+" AND (r.haspreview = -1 AND c.disablepreview = 0) AND r.passwordstatus BETWEEN -6 AND -1 GROUP BY LEFT(r.guid, 1) LIMIT 16")
|
||||
cur[0].execute("SELECT LEFT(r.guid, 1) FROM releases r LEFT JOIN category c ON c.id = r.categoryid WHERE r.nzbstatus = 1 "+maxsize+" AND (r.haspreview = -1 AND c.disablepreview = 0) AND r.passwordstatus BETWEEN -6 AND -1 GROUP BY LEFT(r.guid, 1) LIMIT 16")
|
||||
datas = cur[0].fetchall()
|
||||
elif sys.argv[1] == "nfo":
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND nfostatus BETWEEN -8 AND -1 GROUP BY LEFT(guid, 1) LIMIT 16")
|
||||
datas = cur[0].fetchall()
|
||||
elif sys.argv[1] == "movie" and len(sys.argv) == 3 and sys.argv[2] == "clean":
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND isrenamed = 1 AND searchname IS NOT NULL AND imdbid IS NULL AND categoryID BETWEEN 2000 AND 2999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND isrenamed = 1 AND searchname IS NOT NULL AND imdbid IS NULL AND categoryid BETWEEN 2000 AND 2999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
datas = cur[0].fetchall()
|
||||
elif sys.argv[1] == "movie":
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND searchname IS NOT NULL AND imdbid IS NULL AND categoryID BETWEEN 2000 AND 2999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND searchname IS NOT NULL AND imdbid IS NULL AND categoryid BETWEEN 2000 AND 2999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
datas = cur[0].fetchall()
|
||||
elif sys.argv[1] == "tv" and len(sys.argv) == 3 and sys.argv[2] == "clean":
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND isrenamed = 1 AND searchname IS NOT NULL AND rageid = -1 AND categoryID BETWEEN 5000 AND 5999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND isrenamed = 1 AND searchname IS NOT NULL AND rageid = -1 AND categoryid BETWEEN 5000 AND 5999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
datas = cur[0].fetchall()
|
||||
elif sys.argv[1] == "tv":
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND searchname IS NOT NULL AND rageid = -1 AND categoryID BETWEEN 5000 AND 5999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
cur[0].execute("SELECT LEFT(guid, 1) FROM releases WHERE nzbstatus = 1 AND searchname IS NOT NULL AND rageid = -1 AND categoryid BETWEEN 5000 AND 5999 GROUP BY LEFT(guid, 1) "+orderBY+" LIMIT 16")
|
||||
datas = cur[0].fetchall()
|
||||
|
||||
#close connection to mysql
|
||||
@@ -232,7 +232,7 @@ def main(args):
|
||||
final = cur[0].fetchall()
|
||||
if len(datas) > 0:
|
||||
for item in final:
|
||||
run = "DELETE FROM releasenfo WHERE nfo IS NULL AND releaseID = %s"
|
||||
run = "DELETE FROM releasenfo WHERE nfo IS NULL AND releaseid = %s"
|
||||
cur[0].execute(run, (item[0]))
|
||||
final = cur[0].fetchall()
|
||||
|
||||
|
||||
@@ -47,7 +47,7 @@ print(bcolors.HEADER + "\n\nRequestID Threaded Started at {}".format(datetime.da
|
||||
cur[0].execute("SELECT value FROM site WHERE setting = 'request_hours'")
|
||||
dbgrab = cur[0].fetchone()
|
||||
request_hours = str(dbgrab[0])
|
||||
cur[0].execute("SELECT DISTINCT(g.ID) FROM releases r INNER JOIN groups g ON r.groupID = g.ID WHERE r.nzbstatus = 1 AND r.prehashID = 0 AND r.isrequestid = 1 AND r.reqidstatus in (0, -1) OR (r.reqidstatus = -3 AND r.adddate > NOW() - INTERVAL " + request_hours + " HOUR)")
|
||||
cur[0].execute("SELECT DISTINCT(g.id) FROM releases r INNER JOIN groups g ON r.groupid = g.id WHERE r.nzbstatus = 1 AND r.prehashid = 0 AND r.isrequestid = 1 AND r.reqidstatus in (0, -1) OR (r.reqidstatus = -3 AND r.adddate > NOW() - INTERVAL " + request_hours + " HOUR)")
|
||||
datas = cur[0].fetchall()
|
||||
|
||||
#close connection to mysql
|
||||
|
||||
@@ -31,7 +31,7 @@ if int(allowed[0]) == 0:
|
||||
info.disconnect(cur[0], cur[1])
|
||||
sys.exit()
|
||||
|
||||
cur[0].execute("SELECT ID FROM groups WHERE active = 1 ORDER by cast(last_record as signed) - cast(first_record as signed) DESC")
|
||||
cur[0].execute("SELECT id FROM groups WHERE active = 1 ORDER by cast(last_record as signed) - cast(first_record as signed) DESC")
|
||||
datas = cur[0].fetchall()
|
||||
|
||||
#close connection to mysql
|
||||
|
||||
Reference in New Issue
Block a user