From 2caaad6d259b5eb821ee1b584703efde41ee3922 Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Mon, 11 Mar 2019 14:38:35 +0800 Subject: [PATCH] =?UTF-8?q?qbittorrent=20=E5=88=A0=E9=99=A4,=E4=B8=8D?= =?UTF-8?q?=E5=9C=A8=E4=B8=BB=E8=A6=81=E8=BD=AF=E4=BB=B6=E7=AE=A1=E7=90=86?= =?UTF-8?q?=E4=B8=AD..?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- plugins/qbittorrent/conf/qb.conf | 23 -- plugins/qbittorrent/conf/qb.sql | 29 -- plugins/qbittorrent/ico.png | Bin 3755 -> 0 bytes plugins/qbittorrent/index.html | 22 -- plugins/qbittorrent/index.py | 333 ----------------- plugins/qbittorrent/info.json | 17 - plugins/qbittorrent/init.d/qbittorrent.tpl | 46 --- plugins/qbittorrent/install.sh | 50 --- plugins/qbittorrent/js/qbittorrent.js | 186 ---------- plugins/qbittorrent/qb.conf | 23 -- .../qbittorrent/workers/qbittorrent_worker.py | 344 ------------------ 11 files changed, 1073 deletions(-) delete mode 100755 plugins/qbittorrent/conf/qb.conf delete mode 100644 plugins/qbittorrent/conf/qb.sql delete mode 100644 plugins/qbittorrent/ico.png delete mode 100755 plugins/qbittorrent/index.html delete mode 100755 plugins/qbittorrent/index.py delete mode 100755 plugins/qbittorrent/info.json delete mode 100644 plugins/qbittorrent/init.d/qbittorrent.tpl delete mode 100755 plugins/qbittorrent/install.sh delete mode 100755 plugins/qbittorrent/js/qbittorrent.js delete mode 100755 plugins/qbittorrent/qb.conf delete mode 100755 plugins/qbittorrent/workers/qbittorrent_worker.py diff --git a/plugins/qbittorrent/conf/qb.conf b/plugins/qbittorrent/conf/qb.conf deleted file mode 100755 index 93aaefe9a..000000000 --- a/plugins/qbittorrent/conf/qb.conf +++ /dev/null @@ -1,23 +0,0 @@ -[db] -DB_HOST = 127.0.0.1 -DB_PORT = 3306 -DB_USER = qbittorrent -DB_PASS = qbittorrent -DB_NAME = qbittorrent - -[qb] -QB_HOST = 127.0.0.1 -QB_PORT = 8080 -QB_USER = admin -QB_PWD = adminadmin - - -[file] -FILE_TO={$SERVER_PATH}/tmp -FILE_TRANSFER_TO={$SERVER_PATH}/tmp -FILE_OWN=www -FILE_GROUP=www - -[task] -TASK_RATE=4 -TASK_COMPLETED_RATE=10 \ No newline at end of file diff --git a/plugins/qbittorrent/conf/qb.sql b/plugins/qbittorrent/conf/qb.sql deleted file mode 100644 index 23eb5a0c8..000000000 --- a/plugins/qbittorrent/conf/qb.sql +++ /dev/null @@ -1,29 +0,0 @@ -CREATE TABLE `pl_hash_list` ( - `id` bigint(20) NOT NULL AUTO_INCREMENT, - `name` text NOT NULL, - `info_hash` varchar(40) NOT NULL, - `length` bigint(20) NOT NULL, - `create_time` datetime NOT NULL, - PRIMARY KEY (`id`), - UNIQUE KEY `info_hash` (`info_hash`), - KEY `create_time` (`create_time`) -) ENGINE=MyISAM DEFAULT CHARSET=utf8; - -CREATE TABLE `pl_hash_file` ( - `id` bigint(20) NOT NULL AUTO_INCREMENT, - `pid` bigint(20) NOT NULL, - `name` text NOT NULL, - `m3u8` varchar(40) NOT NULL, - `length` bigint(20) NOT NULL, - `create_time` datetime NOT NULL, - PRIMARY KEY (`id`), - KEY `create_time` (`create_time`) -) ENGINE=MyISAM DEFAULT CHARSET=utf8; - -CREATE TABLE `pl_hash_queue` ( - `id` bigint(20) NOT NULL AUTO_INCREMENT, - `info_hash` varchar(40) NOT NULL, - `create_time` datetime NOT NULL, - PRIMARY KEY (`id`), - KEY `create_time` (`create_time`) -) ENGINE=MyISAM DEFAULT CHARSET=utf8; \ No newline at end of file diff --git a/plugins/qbittorrent/ico.png b/plugins/qbittorrent/ico.png deleted file mode 100644 index 0c04d3b9e8e572063d68db99ca5f7f7a1c1109e9..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 3755 zcmV;c4pi}pP)2wwvJY-)@rp*)Vgt?7D1GuC^&JCswi7VWQ8yjMj(MC zgbfKK&v(xI-g|Qcp;g;{`TdT>aFaaGd7tx~^S+lb0RA@(`p56_!QbPB-!%Zgtq=aD zZurez@Yi+1U+b2^&-u0H9{BBaje8LOz9IO%zBm7FHNuo9uk~Q$14DqTAF%cS1P~SN zK4doz;a;^DSIY-*@nt`fiz$lwae;nbDecD{(;zY%yeOw@`8`Ak&VKn>zSl+}AFoZo zGYr^zfqDW^(sZJ5!r#Z0diUVt} zID6vZj!63{uzMbkM&K<8@4ZNV8&l)wYv8F&EvJO%vR z7z^ganDOnoMqDiHLbcN;NQ|`-AqlvZ%rp4)H%Am{nocgdB9&R!={!k-S9Pue*Mk>X zXYdUCv_*pd-HfkK)r(jdYbFw%VkH>UUlL%JeO_siPt9IzxYapY<4VSt=`t?lk{rmm z20DR3Te0R+D~cQXQDYxO%u|Oh<2uj^@YyHpFzWABC z@%f5W)?RGZ2&Ck?NG=L!MJ^)a$0cwEJzW9)Rg?)|9+7$v9a-0ObKA>{~FEcLX!oa5;F$KUMs>IYo zMuZ=%!0M!W6t#E-R<#xc0UoBfaBmv>u`*S$#gq}YIA+$Zqp~i5>xy(uN)r+AY6M1Q z{aA3;Rqzaa>Ol#9%KmbMA1KGg7aaoYfHF6Q@kq?N;=yd|osJP+uFE*ZvJ0(Plh%f< zw;cHGp$pq@JFq6zhNX$kBI66l(^n)nV>!jV(}4nAeZEm6ket;nfG<2^E{8lkLx@^;Flx^H=>Q# z+i5)RMMmQ=@@#(O+aZ2FYZ|7}xeuGJ*~uB?&{fF|Xz%ipgZPp7 zyd8VetthDLMtA>^)UTrB4jQ^LjBfmVzMisOA%K6euS|gd?6*>i5)t<*dc+vd9XgCR zBfKQh&$~j;EF_mTX?EPJ^$5T@tyJh01Nc3w6EWGH^t@lZ_K5mMTyCcz^r+q|2#6vj zsjN!02m&4&X^YG~RL~wl#@O78JH<}iqNt?j{F;x5G&%;bJg!R1I)ndoPYFKVU4qHG zUt;IAMj<0E<}lt#m6LUDpbUrd@(3!@w6cDYaRwK8*FidO2zWWg#w)D?G!x|D=S$C8 zG%x=?pIb)WMh@54`**df-1d8i> zFz-Z_1g?QE)8sPuXa$T-J>uG|$_^##1_Auz9YvV9y$DnG7?4)bA?hHEH`}R(UMxu* z?d1_?8-?~6R6;=y7RFh0GfS|Se@#DQvfLVhh}b&K4ws*)B?2Ci)mueQe08Wog5Ebm z;}qfhN^sxc5Cobi#o>Dm0{DNo7vjI$3NT@70VeG%MEtWhSh|P+pBN;*=%%cX7;#A| zY=^9826ZyClQJJXaA`A((ukrSJ46jIfki|>_3~wLHE8RU1TJLS1J0rY&r+GZi(?0?XPT&k6aWXbIFs-J%sTP+B1A2|24RkKAk>p?|IQb~B)A_%n8 zdm^ICC3phP;K%=(kB>IzBkE2wYE%MeayqpUS3f1LNNy7L$OMi)bqUaF_ne{Yo@(pg ze?LHA!KrGYarW}1F;#+qj|e0X0e!|rfhxr*G)|F}VHE`0XayD=E!9AOxH%6WZsN$r zVU++&C?Sst1a?EJvn-Cc;6a^~(5Xx}X6r^=3EmXc`VT*97i1q0f%zw^Wd|j>EQv9} zu1F{~+fD?6ZIOY?0xcB!zLskfHPAvHKW%TZ1W&*}AmAVTl8X;1j@`3L2~i>VQ)uh9 zAU4E^OL4PuKoCeS>c+fNwYscV1r1!&k5nQyyF*;d1im?0CBU;(mYk{-1o-hssS8u7 zP&HdrfD4^(D@6F7Vq}y1@WVtFIpJ3YJb`|HV~&XNn{yHS#3qZFkNeWgd&veZx)HZl z8@7%=bqY{i%-@o?>qlHw<7|m+jW>*a8iBddCVZwyCE|pU3Q`g<+xsx@Xqm7>74!t1 z#uptcA?*)}Ym=Td<9!AAxDDBO?`MuIOx%)(OL-1yqkLAGQ8yqur?AE7;1PG}*?Q4| zSsHQKZp=Jpk{$GrQS);Cx$mA0IW0a(fUI}!@k(m_Qs)sTDuko(L+lBjw_tK)z!ufw z{A_0d?iIBOsdduc_Ui-17^i{H!n^A^GV$q-d_1h|mW_-LTFYpsvofi1%#Fp~d$Kqg zU`lZhRwtV=^N0~MD0oabm**yuL$pdBaSaogbId4 z%AhPxX^HycoJCnb`OK+}3i{xc$)pux68rDkkSz!dV)l`8P2&rWl?eh)0>3S#1_fjv z1D;`R5)C>99Pr|DrWF%^&6OEv&=ha4eNOQV|5@`4za&)!hB>b?PT#NW3%Qk3bv}cN zbkpS~#Adm0xuh5AMm}-w760Fq)+h$ANE(xQrI^61sB*19r|*A>%Q-frW>OE>RV1<= zb)z1S4DG0B>_%-%4@zkyxLat)jtf=zcuTG>;{=?7fy>Ci&6n=LI1P0}s;OeNr=5s_4ODFp5lftiQPlp-wOrest~!e-(Dhjwa1Auc<*hXt8gP!c>Hp`R*@Cx} z>ZYF0=Xt~YBW?4-^;6=$&@)TWh^t5?@s5j5hCnRVTW%YMG|dVs(*(tYTx=ZwnwJ4)6i_|d>Q#;t#j z(|=gSG2^IX75%{$A0DkcZx(w`xsB6j+z>RgFlfD(@1U)oO5m$~h7cJKcsbi)D2Ly0yS>Wc?%nck;WFxos~@=3_CH=}{|ugWzBZ{AsfI4ZXFKsZ zHK!n*Gx&7@xx5N+j*mBIlWlgq+Tm`{@j7WOG20;qFBP|I*q?KD&xUk z{wlyZ#&66-Ea|@LRgc&8E8!Bo!H0y*cGB}pMJ@_(y)FJC3v`^$Su~xGw8d8h&M|Rw z7GfW_z~mU#4zb?s789|*Q`UvKQM|GE6I%?W^L4MT^O2grY3LA{f1_JWp>FbJ*7sv& zY$Yac&Hr0o{%0}nr{}_LxM2VGO}$S=c~{ceC#~`y zz0p0^pBk8`$ZyePxG}j3Q+K_@m`@7NZ@cjjRO?FG_F=lmJ} z`kxwvT9JOQToG%xtdSC%7Y{1Ba3Q-5rye%r@T~^yy=E41=%z)y#=qlh_*#As%hJ&& zKg;L)KmD;skW=}kL-4B5UIp!a@+P5~GRh|gHM%gnk002ovPDHLkV1n4kCCmT- diff --git a/plugins/qbittorrent/index.html b/plugins/qbittorrent/index.html deleted file mode 100755 index 17931bd32..000000000 --- a/plugins/qbittorrent/index.html +++ /dev/null @@ -1,22 +0,0 @@ -
-
-
-

服务

-

自启动

-

导入SQL

-

配置

-

日志

-

列表

- -
-
-
-
-
-
- -
- \ No newline at end of file diff --git a/plugins/qbittorrent/index.py b/plugins/qbittorrent/index.py deleted file mode 100755 index f05332555..000000000 --- a/plugins/qbittorrent/index.py +++ /dev/null @@ -1,333 +0,0 @@ -# coding: utf-8 - -import time -import random -import os -import json -import re -import sys - -sys.path.append(os.getcwd() + "/class/core") -import public - -reload(sys) -sys.setdefaultencoding("utf8") - -sys.path.append('/usr/local/lib/python2.7/site-packages') - - -app_debug = False -if public.isAppleSystem(): - app_debug = True - - -def getPluginName(): - return 'qbittorrent' - - -def getPluginDir(): - return public.getPluginDir() + '/' + getPluginName() - - -def getServerDir(): - return public.getServerDir() + '/' + getPluginName() - - -def getInitDFile(): - if app_debug: - return '/tmp/' + getPluginName() - return '/etc/init.d/' + getPluginName() - - -def getArgs(): - args = sys.argv[2:] - tmp = {} - args_len = len(args) - - if args_len == 1: - t = args[0].strip('{').strip('}') - t = t.split(':') - tmp[t[0]] = t[1] - elif args_len > 1: - for i in range(len(args)): - t = args[i].split(':') - tmp[t[0]] = t[1] - - return tmp - - -def checkArgs(data, ck=[]): - for i in range(len(ck)): - if not ck[i] in data: - return (False, public.returnJson(False, '参数:(' + ck[i] + ')没有!')) - return (True, public.returnJson(True, 'ok')) - - -def getInitDTpl(): - path = getPluginDir() + "/init.d/" + getPluginName() + ".tpl" - return path - - -def getSqlFile(): - file = getPluginDir() + "/conf/qb.sql" - return file - - -def getConf(): - file = getServerDir() + "/qb.conf" - return file - - -def getRunLog(): - file = getServerDir() + "/logs.pl" - return file - - -def initDreplace(): - - ddir = getServerDir() + '/workers' - if not os.path.exists(ddir): - sdir = getPluginDir() + '/workers' - public.execShell('cp -rf ' + sdir + ' ' + getServerDir()) - - cfg = getServerDir() + '/qb.conf' - if not os.path.exists(cfg): - cfg_tpl = getPluginDir() + '/conf/qb.conf' - content = public.readFile(cfg_tpl) - public.writeFile(cfg, content) - - file_tpl = getInitDTpl() - service_path = os.path.dirname(os.getcwd()) - - initD_path = getServerDir() + '/init.d' - if not os.path.exists(initD_path): - os.mkdir(initD_path) - file_bin = initD_path + '/' + getPluginName() - - # initd replace - if not os.path.exists(file_bin): - content = public.readFile(file_tpl) - content = content.replace('{$SERVER_PATH}', service_path) - public.writeFile(file_bin, content) - public.execShell('chmod +x ' + file_bin) - - return file_bin - - -def status(): - data = public.execShell( - "ps -ef|grep qbittorrent_worker | grep -v grep | awk '{print $2}'") - if data[0] == '': - return 'stop' - return 'start' - - -def start(): - file = initDreplace() - - data = public.execShell(file + ' start') - if data[1] == '': - return 'ok' - return data[1] - - -def stop(): - file = initDreplace() - data = public.execShell(file + ' stop') - if data[1] == '': - return 'ok' - return data[1] - - -def restart(): - file = initDreplace() - data = public.execShell(file + ' restart') - if data[1] == '': - return 'ok' - return data[1] - - -def reload(): - file = initDreplace() - data = public.execShell(file + ' reload') - if data[1] == '': - return 'ok' - return data[1] - - -def initdStatus(): - if not app_debug: - if public.isAppleSystem(): - return "Apple Computer does not support" - - initd_bin = getInitDFile() - if os.path.exists(initd_bin): - return 'ok' - return 'fail' - - -def initdInstall(): - import shutil - if not app_debug: - if public.isAppleSystem(): - return "Apple Computer does not support" - - mysql_bin = initDreplace() - initd_bin = getInitDFile() - shutil.copyfile(mysql_bin, initd_bin) - public.execShell('chmod +x ' + initd_bin) - return 'ok' - - -def initdUinstall(): - if not app_debug: - if public.isAppleSystem(): - return "Apple Computer does not support" - initd_bin = getInitDFile() - os.remove(initd_bin) - return 'ok' - - -def matchData(reg, content): - tmp = re.search(reg, content).groups() - return tmp[0] - - -def getDbConfInfo(): - cfg = getConf() - content = public.readFile(cfg) - data = {} - data['DB_HOST'] = matchData("DB_HOST\s*=\s(.*)", content) - data['DB_USER'] = matchData("DB_USER\s*=\s(.*)", content) - data['DB_PORT'] = matchData("DB_PORT\s*=\s(.*)", content) - data['DB_PASS'] = matchData("DB_PASS\s*=\s(.*)", content) - data['DB_NAME'] = matchData("DB_NAME\s*=\s(.*)", content) - return data - - -def getQbConf(): - cfg = getConf() - content = public.readFile(cfg) - data = {} - data['QB_HOST'] = matchData("QB_HOST\s*=\s(.*)", content) - data['QB_PORT'] = matchData("QB_PORT\s*=\s(.*)", content) - data['QB_USER'] = matchData("QB_USER\s*=\s(.*)", content) - data['QB_PWD'] = matchData("QB_PWD\s*=\s(.*)", content) - return data - - -def pMysqlDb(): - data = getDbConfInfo() - conn = mysql.mysql() - conn.setHost(data['DB_HOST']) - conn.setUser(data['DB_USER']) - conn.setPwd(data['DB_PASS']) - conn.setPort(int(data['DB_PORT'])) - conn.setDb(data['DB_NAME']) - return conn - - -def pQbClient(): - from qbittorrent import Client - info = getQbConf() - url = 'http://' + info['QB_HOST'] + ':' + info['QB_PORT'] + '/' - qb = Client(url) - qb.login(info['QB_USER'], info['QB_PWD']) - return qb - - -def getQbUrl(): - info = getQbConf() - url = 'http://' + info['QB_HOST'] + ':' + info['QB_PORT'] + '/' - return public.returnJson(True, 'ok', url) - - -def qbList(): - args = getArgs() - # data = checkArgs(args, ['type']) - # if not data[0]: - # return data[1] - args_type = '' - if 'type' in args: - args_type = args['type'] - - f = ['downloading', 'completed'] - tfilter = '' - if args_type in f: - tfilter = args['type'] - try: - qb = pQbClient() - torrents = qb.torrents(filter=tfilter) - data = {} - data['type'] = tfilter - data['torrents'] = torrents - return public.returnJson(True, 'ok', data) - except Exception as e: - return public.returnJson(False, str(e)) - - -def qbDel(): - args = getArgs() - data = checkArgs(args, ['hash']) - if not data[0]: - return data[1] - qb = pQbClient() - data = qb.delete(args['hash']) - return public.returnJson(True, '操作成功!', data) - - -def qbAdd(): - args = getArgs() - data = checkArgs(args, ['hash']) - if not data[0]: - return data[1] - url = 'magnet:?xt=urn:btih:' + args['hash'] - qb = pQbClient() - data = qb.download_from_link(url) - return public.returnJson(True, '操作成功!', data) - - -def test(): - qb = pQbClient() - # magnet_link = "magnet:?xt=urn:btih:57a0ec92a61c60585f1b7a206a75798aa69285a5" - # print qb.download_from_link(magnet_link) - torrents = qb.torrents(filter='downloading') - for torrent in torrents: - print public.returnJson(False, torrent) - -if __name__ == "__main__": - func = sys.argv[1] - if func == 'status': - print status() - elif func == 'start': - print start() - elif func == 'stop': - print stop() - elif func == 'restart': - print restart() - elif func == 'reload': - print reload() - elif func == 'initd_status': - print initdStatus() - elif func == 'initd_install': - print initdInstall() - elif func == 'initd_uninstall': - print initdUinstall() - elif func == 'get_sql': - print getSqlFile() - elif func == 'conf': - print getConf() - elif func == 'get_run_Log': - print getRunLog() - elif func == 'qb_list': - print qbList() - elif func == 'qb_del': - print qbDel() - elif func == 'qb_add': - print qbAdd() - elif func == 'qb_url': - print getQbUrl() - elif func == 'test': - print test() - else: - print 'error' diff --git a/plugins/qbittorrent/info.json b/plugins/qbittorrent/info.json deleted file mode 100755 index 4aa33e725..000000000 --- a/plugins/qbittorrent/info.json +++ /dev/null @@ -1,17 +0,0 @@ -{ - "sort": 7, - "ps": "一个新的轻量级BitTorrent客户端", - "name": "qbittorrent", - "title": "qBittorrent", - "shell": "install.sh", - "versions":["4.1.5"], - "updates":["4.1.5"], - "tip": "soft", - "checks": "server/qbittorrent", - "display": 1, - "author": "Zend", - "date": "2017-04-01", - "home": "https://www.qbittorrent.org", - "type": 0, - "pid": "5" -} \ No newline at end of file diff --git a/plugins/qbittorrent/init.d/qbittorrent.tpl b/plugins/qbittorrent/init.d/qbittorrent.tpl deleted file mode 100644 index a6fb06707..000000000 --- a/plugins/qbittorrent/init.d/qbittorrent.tpl +++ /dev/null @@ -1,46 +0,0 @@ -#!/bin/sh -# chkconfig: 2345 55 25 -# description: qbittorrent Service - -### BEGIN INIT INFO -# Provides: qbittorrent -# Required-Start: $all -# Required-Stop: $all -# Default-Start: 2 3 4 5 -# Default-Stop: 0 1 6 -# Short-Description: starts qbittorrent -# Description: starts the MDW-Web -### END INIT INFO - - -qb_start(){ - cd {$SERVER_PATH}/qbittorrent/workers - nohup python qbittorrent_worker.py > {$SERVER_PATH}/qbittorrent/logs.pl 2>&1 & - echo "qbittorrent started" -} - -qb_stop(){ - echo "Stopping ..." - #ps -ef | grep qbittorrent-nox-bin | grep -v grep | awk '{print $2}' | xargs kill -9 - ps -ef | grep "qbittorrent_worker.py" | grep -v grep | awk '{print $2}' | xargs kill -9 - echo "qbittorrent stopped" -} - - -case "$1" in - start) - qb_start - ;; - stop) - qb_stop - ;; - restart|reload) - qb_stop - sleep 0.3 - qb_start - ;; - *) - echo "Please use start or stop as first argument" - ;; -esac - diff --git a/plugins/qbittorrent/install.sh b/plugins/qbittorrent/install.sh deleted file mode 100755 index 20462f45d..000000000 --- a/plugins/qbittorrent/install.sh +++ /dev/null @@ -1,50 +0,0 @@ -#!/bin/bash -PATH=/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin:~/bin -export PATH - -curPath=`pwd` -rootPath=$(dirname "$curPath") -rootPath=$(dirname "$rootPath") -serverPath=$(dirname "$rootPath") -sysName=`uname` - -install_tmp=${rootPath}/tmp/bt_install.pl - - -Install_qbittorrent() -{ - if [ $sysName == 'Darwin' ]; then - echo 'apple system' - else - yum -y install qbittorrent-nox - #安装Nux-Dextop源 - sudo rpm --import http://li.nux.ro/download/nux/RPM-GPG-KEY-nux.ro - sudo rpm -Uvh http://li.nux.ro/download/nux/dextop/el7/x86_64/nux-dextop-release-0-1.el7.nux.noarch.rpm - yum install -y ffmpeg - fi - - pip install python-qbittorrent - - echo '正在安装脚本文件...' > $install_tmp - mkdir -p $serverPath/qbittorrent - - QB_DIR=${serverPath}/source/qbittorrent - mkdir -p $QB_DIR - - echo '4.1.5' > $serverPath/qbittorrent/version.pl - echo '安装完成' > $install_tmp -} - -Uninstall_qbittorrent() -{ - rm -rf $serverPath/qbittorrent - which yum && yum -y remove qbittorrent-nox - echo "Uninstall_qbittorrent" > $install_tmp -} - -action=$1 -if [ "${1}" == 'install' ];then - Install_qbittorrent -else - Uninstall_qbittorrent -fi diff --git a/plugins/qbittorrent/js/qbittorrent.js b/plugins/qbittorrent/js/qbittorrent.js deleted file mode 100755 index e00249172..000000000 --- a/plugins/qbittorrent/js/qbittorrent.js +++ /dev/null @@ -1,186 +0,0 @@ -function qbPostMin(method, args, callback){ - - var req_data = {}; - req_data['name'] = 'qbittorrent'; - req_data['func'] = method; - - if (typeof(args) != 'undefined' && args!=''){ - req_data['args'] = JSON.stringify(args); - } - - $.post('/plugins/run', req_data, function(data) { - if (!data.status){ - layer.msg(data.msg,{icon:0,time:2000,shade: [0.3, '#000']}); - return; - } - - if(typeof(callback) == 'function'){ - callback(data); - } - },'json'); -} - -function qbPost(method, args, callback){ - var loadT = layer.msg('正在获取...', { icon: 16, time: 0, shade: 0.3 }); - qbPostMin(method,args,function(data){ - layer.close(loadT); - if(typeof(callback) == 'function'){ - callback(data); - } - }); -} - -function showHideHash(obj){ - var a = "glyphicon-eye-open"; - var b = "glyphicon-eye-close"; - - if($(obj).hasClass(a)){ - $(obj).removeClass(a).addClass(b); - $(obj).prev().text($(obj).prev().attr('data-pw')) - } else{ - $(obj).removeClass(b).addClass(a); - $(obj).prev().text($(obj).attr('data-pw')); - } -} - - -function copyText(password){ - var clipboard = new ClipboardJS('#bt_copys'); - clipboard.on('success', function (e) { - layer.msg('复制成功',{icon:1,time:2000}); - }); - - clipboard.on('error', function (e) { - layer.msg('复制失败，浏览器不兼容!',{icon:2,time:2000}); - }); - $("#bt_copys").attr('data-clipboard-text',password); - $("#bt_copys").click(); -} - -function getLocalTime(nS) { - return new Date(parseInt(nS) * 1000).toLocaleString().replace(/:\d{1,2}$/,' '); -} - - - -function qbAdd(){ - - var loadOpen = layer.open({ - type: 1, - title: '添加资源', - area: '400px', - content:"
\ -
\ -
\ -
\ -
\ - \ - \ -
\ -
" - }); - - $('#qb_close').click(function(){ - layer.close(loadOpen); - }); - - $('#qb_ok').click(function(){ - var hash = $('#qb_hash').val(); - qbPost('qb_add', {hash:hash}, function(data){ - - var rdata = $.parseJSON(data.data); - if (rdata['status']){ - showMsg(rdata.msg, function(){ - qbList(); - },{icon:1,time:2000,shade: [0.3, '#000']}); - layer.close(loadOpen); - } else { - layer.msg(rdata.msg,{icon:2,time:2000,shade: [0.3, '#000']}); - } - }); - }); -} - - -function qbDel(hash){ - qbPost('qb_del', {hash:hash}, function(data){ - var rdata = $.parseJSON(data.data); - if (rdata['status']){ - layer.msg(rdata.msg,{icon:1,time:2000,shade: [0.3, '#000']}); - } else { - layer.msg(rdata.msg,{icon:2,time:2000,shade: [0.3, '#000']}); - } - }); -} - -function qbListFind(){ - var qbs = $('#qb_selected').val(); - if ( qbs == '0' ){ - qbList(); - } else { - qbList(qbs); - } -} - -function openAdminUrl(){ - qbPost('qb_url', '', function(data){ - var rdata = $.parseJSON(data.data); - window.open(rdata.data); - }); -} - -function qbList(search){ - var _data = {}; - _data['test'] ='yes'; - if(typeof(search) != 'undefined'){ - _data['type'] = search; - } - - qbPost('qb_list', _data, function(data){ - - var rdata = $.parseJSON(data.data); - if (!rdata['status']){ - layer.msg(rdata.msg,{icon:0,time:2000,shade: [0.3, '#000']}); - return; - } - - content = ''; - content += ''; - - content += '
'; - content += ''; - content += ''; - content += ''; - content += ''; - content += ''; - - content += ''; - - ulist = rdata.data.torrents; - for (i in ulist){ - content += ''+ - ''+ - ''; - } - - content += ''; - content += '
种子(hash)添加时间操作(添加 | 管理)
'+ - ''+ulist[i]['hash'].substr(0,3)+'' + - ''+ - ''+ - ''+getLocalTime(ulist[i]['added_on'])+'删除
'; - - $(".soft-man-con").html(content); - - var type = rdata.data.type; - if (type == ''){ - $("#qb_selected option[value='0']").attr("selected", true); - } else { - $("#qb_selected option[value='"+type+"']").attr("selected", true); - } - }); -} diff --git a/plugins/qbittorrent/qb.conf b/plugins/qbittorrent/qb.conf deleted file mode 100755 index d2dcb6b51..000000000 --- a/plugins/qbittorrent/qb.conf +++ /dev/null @@ -1,23 +0,0 @@ -[db] -DB_HOST = 154.48.251.71 -DB_PORT = 33061 -DB_USER = qbittorrent -DB_PASS = qbittorrent -DB_NAME = qbittorrent - -[qb] -QB_HOST = 127.0.0.1 -QB_PORT = 8080 -QB_USER = admin -QB_PWD = adminadmin - - -[file] -FILE_TO={$SERVER_PATH}/tmp -FILE_TRANSFER_TO={$SERVER_PATH}/tmp -FILE_OWN=www -FILE_GROUP=www - -[task] -TASK_RATE=4 -TASK_COMPLETED_RATE=10 \ No newline at end of file diff --git a/plugins/qbittorrent/workers/qbittorrent_worker.py b/plugins/qbittorrent/workers/qbittorrent_worker.py deleted file mode 100755 index 2b3e3d565..000000000 --- a/plugins/qbittorrent/workers/qbittorrent_worker.py +++ /dev/null @@ -1,344 +0,0 @@ -#!/usr/bin/env python -# encoding: utf-8 -""" -下载检测 -""" - -import hashlib -import os -import time -import datetime -import traceback -import sys -import json -import socket -import threading -from hashlib import sha1 -from random import randint -from struct import unpack -from socket import inet_ntoa -from threading import Timer, Thread -from time import sleep - -reload(sys) -sys.setdefaultencoding("utf8") - -sys.path.append('/usr/local/lib/python2.7/site-packages') - -# import pygeoip -import MySQLdb as mdb - - -from configparser import ConfigParser -cp = ConfigParser() -cp.read("../qb.conf") -section_db = cp.sections()[0] -DB_HOST = cp.get(section_db, "DB_HOST") -DB_USER = cp.get(section_db, "DB_USER") -DB_PORT = cp.getint(section_db, "DB_PORT") -DB_PASS = cp.get(section_db, "DB_PASS") -DB_NAME = cp.get(section_db, "DB_NAME") - - -section_qb = cp.sections()[1] -QB_HOST = cp.get(section_qb, "QB_HOST") -QB_PORT = cp.get(section_qb, "QB_PORT") -QB_USER = cp.get(section_qb, "QB_USER") -QB_PWD = cp.get(section_qb, "QB_PWD") - -section_file = cp.sections()[2] -FILE_TO = cp.get(section_file, "FILE_TO") -FILE_TRANSFER_TO = cp.get(section_file, "FILE_TRANSFER_TO") -FILE_OWN = cp.get(section_file, "FILE_OWN") -FILE_GROUP = cp.get(section_file, "FILE_GROUP") - -section_task = cp.sections()[3] -TASK_RATE = cp.getint(section_task, "TASK_RATE") -TASK_COMPLETED_RATE = cp.getint(section_task, "TASK_COMPLETED_RATE") - - -def formatTime(): - return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()) - - -class downloadBT(Thread): - - def __init__(self): - Thread.__init__(self) - self.setDaemon(True) - self.dbconn = mdb.connect( - DB_HOST, DB_USER, DB_PASS, DB_NAME, port=DB_PORT, charset='utf8') - self.dbconn.autocommit(False) - self.dbcurr = self.dbconn.cursor() - self.dbcurr.execute('SET NAMES utf8') - self.qb = self.qb() - - _has_suffix = ['mp4', 'rmvb', 'flv', 'avi', 'mpg', 'mkv', 'wmv', 'avi'] - has_suffix = [] - for x in range(len(_has_suffix)): - has_suffix.append('.' + _has_suffix[x]) - has_suffix.append('.' + _has_suffix[x].upper()) - self.has_suffix = has_suffix - - def query(self, sql): - self.dbcurr.execute(sql) - result = self.dbcurr.fetchall() - data = map(list, result) - return data - - def qb(self): - from qbittorrent import Client - url = 'http://' + QB_HOST + ':' + QB_PORT + '/' - qb = Client(url) - qb.login(QB_USER, QB_PWD) - return qb - - def execShell(self, cmdstring, cwd=None, timeout=None, shell=True): - import subprocess - if shell: - cmdstring_list = cmdstring - else: - cmdstring_list = shlex.split(cmdstring) - if timeout: - end_time = datetime.datetime.now() + datetime.timedelta(seconds=timeout) - - sub = subprocess.Popen(cmdstring_list, cwd=cwd, stdin=subprocess.PIPE, - shell=shell, bufsize=4096, stdout=subprocess.PIPE, stderr=subprocess.PIPE) - - while sub.poll() is None: - time.sleep(0.1) - if timeout: - if end_time <= datetime.datetime.now(): - raise Exception("Timeout：%s" % cmdstring) - - return sub.communicate() - - def md5(self, str): - # 生成MD5 - try: - m = hashlib.md5() - m.update(str) - return m.hexdigest() - except: - return False - - def get_transfer_ts_file(self, to): - return FILE_TRANSFER_TO + '/' + to + '.ts' - - def get_transfer_mp4_file(self, to): - return FILE_TRANSFER_TO + '/' + to + '.mp4' - - def get_lock_file(self, to): - return FILE_TRANSFER_TO + '/' + to + '.lock' - - def get_transfer_m3u5_dir(self, dirname): - return FILE_TO + '/m3u8/' + dirname - - def fg_transfer_mp4_cmd(self, sfile, dfile): - cmd = 'ffmpeg -y -i "' + sfile + \ - '" -threads 1 -preset veryslow -crf 28 -c:v libx264 -strict -2 ' + dfile - return cmd - - def fg_transfer_ts_cmd(self, file, to_file): - cmd = 'ffmpeg -y -i ' + file + \ - ' -s 480x360 -vcodec copy -acodec copy -vbsf h264_mp4toannexb ' + to_file - return cmd - - def fg_m3u8_cmd(self, ts_file, m3u8_file, to_file): - cmd = 'ffmpeg -y -i ' + ts_file + ' -c copy -map 0 -f segment -segment_list ' + \ - m3u8_file + ' -segment_time 3 ' + to_file - return cmd - - def debug(self, msg): - return formatTime() + ":" + msg - - def lock(self, sign): - l = self.get_lock_file(sign) - self.execShell('touch ' + l) - - def unlock(self, sign): - l = self.get_lock_file(sign) - self.execShell('rm -rf ' + l) - - def islock(self, sign): - l = self.get_lock_file(sign) - if os.path.exists(l): - return True - return False - - def ffmpeg(self, file=''): - - md5file = self.md5(file)[0:6] - - if not os.path.exists(file): - print formatTime(), 'file not exists:', file - return - print self.debug('source file ' + file) - - mp4file = self.get_transfer_mp4_file(md5file) - cmd_mp4 = self.fg_transfer_mp4_cmd(file, mp4file) - print self.debug('cmd_mp4:' + cmd_mp4) - - if not os.path.exists(mp4file): - os.system(cmd_mp4) - else: - print self.debug('mp4 exists:' + mp4file) - - if not os.path.exists(mp4file): - print self.debug('mp4 not exists') - return - - tsfile = self.get_transfer_ts_file(md5file) - cmd_ts = self.fg_transfer_ts_cmd(mp4file, tsfile) - print self.debug('cmd_ts:' + cmd_ts) - if not os.path.exists(tsfile): - os.system(cmd_ts) - else: - print self.debug('data_ts exists:' + mp4file) - - if not os.path.exists(tsfile): - print self.debug('ts not exists') - return - - m3u8_dir = self.get_transfer_m3u5_dir(md5file) - if not os.path.exists(m3u8_dir): - self.execShell('mkdir -p ' + m3u8_dir) - - m3u8_file = m3u8_dir + '/' + md5file + '.m3u8' - tofile = m3u8_dir + '/%010d.ts' - cmd_m3u8 = self.fg_m3u8_cmd(tsfile, m3u8_file, tofile) - print self.debug('cmd_m3u8:' + cmd_m3u8) - if not os.path.exists(m3u8_file): - os.system(cmd_m3u8) - self.execShell('chown -R ' + FILE_OWN + ':' + - FILE_GROUP + ' ' + m3u8_dir) - self.add_hash(md5file) - else: - self.add_hash(md5file) - print self.debug('m3u8 exists:' + tofile) - - def add_hash_file(self): - pass - - def add_hash(self, m3u8_name): - print '-------------------------add_hash---start-----------------------' - ct = formatTime() - # print (self.sign_torrent) - total_size = str(self.sign_torrent['total_size']) - shash = self.sign_torrent['hash'] - sname = self.sign_torrent['name'] - - info = self.query( - "select id from pl_hash_list where info_hash='" + shash + "'") - - sname = mdb.escape_string(sname) - if len(info) > 0: - pid = str(info[0][0]) - file_data = self.query( - "select id from pl_hash_file where name='" + sname + "' and pid='" + pid + "'") - if len(file_data) == 0: - self.query("insert into pl_hash_file (`pid`,`name`,`m3u8`,`length`,`create_time`) values('" + - pid + "','" + sname + "','" + m3u8_name + "','" + total_size + "','" + ct + "')") - else: - print shash, 'already is exists!' - else: - print 'insert into pl_hash_list' - pid = self.dbcurr.execute("insert into pl_hash_list (`name`,`info_hash`,`length`,`create_time`) values('" + - sname + "','" + shash + "','" + total_size + "','" + ct + "')") - file_data = self.query( - "select id from pl_hash_file where name='" + sname + "' and pid='" + pid + "'") - if len(file_data) == 0: - self.query("insert into pl_hash_file (`pid`,`name`,`m3u8`,`length`,`create_time`) values('" + - pid + "','" + sname + "','" + m3u8_name + "','" + total_size + "','" + ct + "')") - else: - print shash, 'already is exists!' - print '-------------------------add_hash---end--------------------------' - - def file_arr(self, path, filters=['.DS_Store']): - file_list = [] - flist = os.listdir(path) - # print flist - for i in range(len(flist)): - file_path = os.path.join(path, flist[i]) - if flist[i] in filters: - continue - if os.path.isdir(file_path): - tmp = self.file_arr(file_path, filters) - file_list.extend(tmp) - else: - file_list.append(file_path) - return file_list - - def find_dir_video(self, path): - flist = self.file_arr(path) - video = [] - for i in range(len(flist)): - t = os.path.splitext(flist[i]) - if t[1] in self.has_suffix: - video.append(flist[i]) - return video - - def video_do(self, path): - if os.path.isfile(path): - t = os.path.splitext(path) - if t[1] in self.has_suffix: - self.ffmpeg(path) - else: - vlist = self.find_dir_video(path) - for i in range(len(vlist)): - self.ffmpeg(vlist[i]) - return '' - - def checkTask(self): - while True: - torrents = self.qb.torrents(filter='downloading') - tlen = len(torrents) - if tlen > 0: - print "downloading torrents count:", tlen - for torrent in torrents: - print torrent['name'], ' task downloading!' - else: - print formatTime(), "no downloading task!" - time.sleep(TASK_RATE) - - def completed(self): - while True: - - torrents = self.qb.torrents(filter='completed') - tlen = len(torrents) - print "completed torrents count:", tlen - if tlen > 0: - for torrent in torrents: - self.sign_torrent = torrent - # print torrent - path = torrent['save_path'] + torrent['name'] - path = path.encode() - try: - self.video_do(path) - except Exception as e: - print formatTime(), str(e) - - print formatTime(), "done task!" - else: - print formatTime(), "no completed task!" - time.sleep(TASK_COMPLETED_RATE) - - -def test(): - while True: - print formatTime(), "no download task!", - time.sleep(1) - test() - -if __name__ == "__main__": - - dl = downloadBT() - - import threading - task = threading.Thread(target=dl.checkTask) - task.start() - - completed = threading.Thread(target=dl.completed) - completed.start() - - # test()