.

Author: danbai225

py/gxpa.py

@@ -20,8 +20,8 @@
 	# ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
 	host='127.0.0.1',
 	port=3306,
-	user='123',
-	password='123',
+	user='ys',
+	password='password',
 	database='ys',
 	charset='utf8'
 )
@@ -31,31 +31,12 @@ class Ji:
 	def __init__(self, name, url):
 		self.name = name
 		self.url = url
-
-proxys=[]
 header = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/77.0.3865.90 Safari/537.36'}
-#获取代理
-def get_proxy():
-	global proxys
-	r=requests.get("http://ip.jiangxianli.com/")
-	if(r.status_code==200):
-		selector=etree.HTML(r.text)
-		proxys=proxys+selector.xpath("//button[@class=\"btn btn-sm btn-copy\"]/@data-url")
 #获取页面html
 def getHtml(url):
-	global proxys
-	p=proxys[random.randint(0,len(proxys)-1)]
-	try:
-		html = requests.get(url,proxies={'http':p},headers=header,timeout=5)
-		if html!=None:
-			return html.text
-	except Exception:
-		proxys.remove(p)
-		if len(proxys)<2:
-			get_proxy()
-		return getHtml(url)
+	html = requests.get(url,headers=header,timeout=5)
+	return html.text
 def main():
-	get_proxy()
 	list=[]
 	for i in range(1,5):
 		selector=etree.HTML(getHtml("http://www.zuidazy1.net/?m=vod-type-id-{}.html".format(i)))

py/pa.py

@@ -23,8 +23,8 @@
 	host='127.0.0.1',
 	port=3306,
 	user='ys',
-	password='***',
-	database='**',
+	password='password',
+	database='ys',
 	charset='utf8'
 )
 class Ji:

py/tagpa.py

@@ -19,10 +19,10 @@
 	setsession=[],	# 开始会话前执行的命令列表。如：["set datestyle to ...", "set time zone ..."]
 	ping=0,
 	# ping MySQL服务端，检查是否服务可用。# 如：0 = None = never, 1 = default = whenever it is requested, 2 = when a cursor is created, 4 = when a query is executed, 7 = always
-	host='39.108.110.44',
+	host='127.0.0.1',
 	port=3306,
 	user='ys',
-	password='***',
+	password='password',
 	database='ys',
 	charset='utf8'
 )
@@ -36,28 +36,32 @@ def get_proxy():
 		selector=etree.HTML(r.text)
 		proxys=proxys+selector.xpath('//button[@class="layui-btn layui-btn-sm btn-copy"]/@data-url')
 #获取页面html
-def getHtml(url):
-	global proxys
-	p=proxys[random.randint(0,len(proxys)-1)]
-	try:
-		pp=p.replace("http://","")
-		pp=pp.replace("https://","")
-		html = requests.get(url,proxies={'http':pp},headers=header,timeout=5)
-		if html!=None:
-			return html.text
-	except Exception:
-		proxys.remove(p)
-		if len(proxys)<2:
-			get_proxy()
-		return getHtml(url)
+def getHtml(url,p):
+	if p:
+		global proxys
+		p=proxys[random.randint(0,len(proxys)-1)]
+		try:
+			pp=p.replace("http://","")
+			pp=pp.replace("https://","")
+			html = requests.get(url,proxies={"http":pp},headers=header,timeout=5)
+			if html!=None:
+				return html.text
+		except Exception:
+			proxys.remove(p)
+			if len(proxys)<2:
+				get_proxy()
+			return getHtml(url,True)
+	else :
+		html = requests.get(url,headers=header,timeout=5)
+		return html.text
 def main():
 	global proxys
 	get_proxy()
 	conn = POOL.connection()
 	cursor = conn.cursor()
-	cursor.execute("SELECT id,pm,dy,lx,gkdz,xzdz FROM `ysb` ORDER BY `gxtime` DESC LIMIT 30")
+	cursor.execute("SELECT id,pm,dy,lx,gkdz,xzdz FROM `ysb` ORDER BY `gxtime` DESC LIMIT 60")
 	data = cursor.fetchall()
-	rpool = redis.ConnectionPool(host='39.108.110.44', port=6379,db=0,password='***')
+	rpool = redis.ConnectionPool(host='127.0.0.1', port=6379,db=0)
 	pool = ThreadPool(30)
 	for ys in data:
 		try:
@@ -80,15 +84,15 @@ def run(ys,r):
 	else:
 		tnum=int(tnum)
 	if tnum<len(jys):
-		fh=getHtml("http://v.qq.com/x/search/?q="+pm)
+		fh=getHtml("http://v.qq.com/x/search/?q="+pm,False)
 		ysid=re.compile("{id: '(.*)'; type: '2';}",re.M).findall(fh)[0]
-		fh=getHtml("http://s.video.qq.com/get_playsource?plat=2&type=4&range=1&otype=json&id="+ysid)
+		fh=getHtml("http://s.video.qq.com/get_playsource?plat=2&type=4&range=1&otype=json&id="+ysid,True)
 		jsonj=json.loads(fh[13:-1])
 		jlist=jsonj["PlaylistItem"]["videoPlayList"]
 		taglist=[]
 		if jsonj["PlaylistItem"]['payType']==2:
 			for i in range (0,len(jlist)):
-				tfh=getHtml("http://bullet.video.qq.com/fcgi-bin/target/regist?otype=json&vid="+jlist[i]['id'])
+				tfh=getHtml("http://bullet.video.qq.com/fcgi-bin/target/regist?otype=json&vid="+jlist[i]['id'],False)
 				tagid=json.loads(tfh[13:-1])['targetid']
 				taglist.append(tagid)
 			taglist.reverse()