piaoquan.py 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312
  1. import random
  2. import time
  3. import json
  4. import requests
  5. from urllib.parse import urlencode
  6. from common import Common, AliyunLogger
  7. from common.sql_help import sqlCollect
  8. class PQ:
  9. """
  10. 获取视频链接
  11. """
  12. @classmethod
  13. def get_pw_url(cls, user_id):
  14. url = f"https://admin.piaoquantv.com/manager/video/detail/{user_id}"
  15. payload = {}
  16. headers = {
  17. 'authority': 'admin.piaoquantv.com',
  18. 'accept': 'application/json, text/plain, */*',
  19. 'accept-language': 'zh-CN,zh;q=0.9',
  20. 'cache-control': 'no-cache',
  21. 'cookie': 'SESSION=YjU3MzgwNTMtM2QyYi00YjljLWI3YWUtZTBjNWYwMGQzYWNl',
  22. 'pragma': 'no-cache',
  23. 'referer': f'https://admin.piaoquantv.com/cms/post-detail/{user_id}/detail',
  24. 'sec-ch-ua': '"Not_A Brand";v="8", "Chromium";v="120", "Google Chrome";v="120"',
  25. 'sec-ch-ua-mobile': '?0',
  26. 'sec-ch-ua-platform': '"macOS"',
  27. 'sec-fetch-dest': 'empty',
  28. 'sec-fetch-mode': 'cors',
  29. 'sec-fetch-site': 'same-origin',
  30. 'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
  31. }
  32. response = requests.request("GET", url, headers=headers, data=payload)
  33. data = response.json()
  34. try:
  35. video_url = data["content"]["transedVideoPath"]
  36. return video_url
  37. except Exception as e:
  38. Common.logger("video").warning(f"获取视频链接失败:{e}\n")
  39. return ""
  40. """
  41. 获取视频链接
  42. """
  43. @classmethod
  44. def get_audio_url(cls, task_mark, user_id, title, mark):
  45. url = f"https://admin.piaoquantv.com/manager/video/detail/{user_id}"
  46. payload = {}
  47. headers = {
  48. 'authority': 'admin.piaoquantv.com',
  49. 'accept': 'application/json, text/plain, */*',
  50. 'accept-language': 'zh-CN,zh;q=0.9',
  51. 'cache-control': 'no-cache',
  52. 'cookie': 'SESSION=YjU3MzgwNTMtM2QyYi00YjljLWI3YWUtZTBjNWYwMGQzYWNl',
  53. 'pragma': 'no-cache',
  54. 'referer': f'https://admin.piaoquantv.com/cms/post-detail/{user_id}/detail',
  55. 'sec-ch-ua': '"Not_A Brand";v="8", "Chromium";v="120", "Google Chrome";v="120"',
  56. 'sec-ch-ua-mobile': '?0',
  57. 'sec-ch-ua-platform': '"macOS"',
  58. 'sec-fetch-dest': 'empty',
  59. 'sec-fetch-mode': 'cors',
  60. 'sec-fetch-site': 'same-origin',
  61. 'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
  62. }
  63. response = requests.request("GET", url, headers=headers, data=payload)
  64. data = response.json()
  65. try:
  66. list = []
  67. video_id = data["content"]["id"]
  68. if mark:
  69. status = sqlCollect.is_used(task_mark, video_id, mark, "票圈")
  70. else:
  71. status = True
  72. if status:
  73. if title == '' or title == None:
  74. new_title = data["content"]["title"]
  75. else:
  76. if '/' in title:
  77. titles = [t for t in title.split('/') if t and t != "None"]
  78. else:
  79. titles = [title]
  80. new_title = random.choice(titles)
  81. video_url = data["content"]["transedVideoPath"]
  82. cover = data["content"]["coverImgPath"]
  83. all_data = {"video_id": video_id, "title": new_title, "cover": cover, "video_url": video_url, "rule": "无", "old_title": data["content"]["title"]}
  84. list.append(all_data)
  85. return list
  86. return list
  87. except Exception as e:
  88. Common.logger("video").warning(f"获取视频链接失败:{e}\n")
  89. return ""
  90. """
  91. 获取用户下的所有视频
  92. """
  93. @classmethod
  94. def get_pq_url(cls, task_mark, user_id, number, mark, channel_id, name):
  95. url = f"https://admin.piaoquantv.com/manager/video/page?uid={user_id}&pageNum=1&pageSize=100"
  96. payload = {}
  97. headers = {
  98. 'accept': 'application/json, text/plain, */*',
  99. 'cookie': 'SESSION=NjRmMGVjNTAtNzJiNi00ODE0LThjYzQtYmZiNTJhMDNiZTcz',
  100. 'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36'
  101. }
  102. response = requests.request("GET", url, headers=headers, data=payload)
  103. data = response.json()
  104. try:
  105. content = data["content"]["objs"]
  106. list = []
  107. for url in content:
  108. video_id = url["id"]
  109. status = sqlCollect.is_used(task_mark, video_id, mark, "票圈")
  110. cover = url["coverImgPath"]
  111. video_url = url["transedVideoPath"]
  112. old_title = url["title"]
  113. log_data = f"user:{user_id},video_id:{video_id},video_url:{video_url},original_title:{old_title}"
  114. AliyunLogger.logging(channel_id, name, user_id, video_id, "扫描到一条视频", "2001", log_data)
  115. if status:
  116. AliyunLogger.logging(channel_id, name, user_id, video_id, "该视频已改造过", "2001", log_data)
  117. continue
  118. AliyunLogger.logging(channel_id, name, user_id, video_id, "符合规则等待改造", "2004", log_data)
  119. all_data = {"video_id": video_id, "cover": cover, "video_url": video_url, "rule": "无", "old_title": old_title}
  120. list.append(all_data)
  121. if len(list) == int(number):
  122. Common.logger("pq").info(f"获取视频总数:{len(list)}\n")
  123. return list
  124. Common.logger("pq").info(f"获取票圈视频总数:{len(list)}\n")
  125. return list
  126. except Exception as e:
  127. Common.logger("pq").warning(f"获取音频视频链接失败:{e}\n")
  128. return ""
  129. """
  130. 获取封面
  131. """
  132. @classmethod
  133. def get_cover(cls, uid):
  134. time.sleep(1)
  135. url = "https://admin.piaoquantv.com/manager/video/multiCover/listV2"
  136. payload = json.dumps({
  137. "videoId": uid,
  138. "range": "2h"
  139. })
  140. headers = {
  141. 'accept': 'application/json',
  142. 'accept-language': 'zh-CN,zh;q=0.9',
  143. 'cache-control': 'no-cache',
  144. 'content-type': 'application/json',
  145. 'cookie': 'SESSION=YjU3MzgwNTMtM2QyYi00YjljLWI3YWUtZTBjNWYwMGQzYWNl',
  146. 'origin': 'https://admin.piaoquantv.com',
  147. 'pragma': 'no-cache',
  148. 'priority': 'u=1, i',
  149. 'sec-ch-ua': '"Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99"',
  150. 'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36'
  151. }
  152. response = requests.request("POST", url, headers=headers, data=payload)
  153. data = response.json()
  154. content = data["content"]
  155. if len(content) == 1:
  156. return content[0]["coverUrl"]
  157. max_share_count = 0
  158. selected_cover_url = ""
  159. for item in content:
  160. share_count = item.get("shareWeight")
  161. if share_count is not None and share_count > max_share_count:
  162. max_share_count = share_count
  163. selected_cover_url = item["coverUrl"]
  164. elif share_count == max_share_count and item["createUser"] == "用户":
  165. selected_cover_url = item["coverUrl"]
  166. return selected_cover_url
  167. """
  168. 获取标题
  169. """
  170. @classmethod
  171. def get_title(cls, uid):
  172. url = "https://admin.piaoquantv.com/manager/video/multiTitleV2/listV2"
  173. payload = json.dumps({
  174. "videoId": uid,
  175. "range": "4h"
  176. })
  177. headers = {
  178. 'accept': 'application/json',
  179. 'accept-language': 'zh-CN,zh;q=0.9',
  180. 'cache-control': 'no-cache',
  181. 'content-type': 'application/json',
  182. 'cookie': 'SESSION=YjU3MzgwNTMtM2QyYi00YjljLWI3YWUtZTBjNWYwMGQzYWNl',
  183. 'origin': 'https://admin.piaoquantv.com',
  184. 'pragma': 'no-cache',
  185. 'priority': 'u=1, i',
  186. 'sec-ch-ua': '"Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99"',
  187. 'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36'
  188. }
  189. response = requests.request("POST", url, headers=headers, data=payload)
  190. data = response.json()
  191. content = data["content"]
  192. if len(content) == 1:
  193. return content[0]["title"]
  194. max_share_count = 0
  195. selected_title = ""
  196. for item in content:
  197. share_count = item.get("shareWeight")
  198. if share_count is not None and share_count > max_share_count:
  199. max_share_count = share_count
  200. selected_title = item["title"]
  201. elif share_count == max_share_count and item["createUser"] == "用户":
  202. selected_title = item["title"]
  203. return selected_title
  204. """
  205. 新生成视频上传到对应账号下
  206. """
  207. @classmethod
  208. def insert_piaoquantv(cls, new_video_path, new_title, cover, n_id):
  209. url = "https://vlogapi.piaoquantv.com/longvideoapi/crawler/video/send"
  210. headers = {
  211. 'User-Agent': 'PQSpeed/486 CFNetwork/1410.1 Darwin/22.6.0',
  212. 'cookie': 'JSESSIONID=4DEA2B5173BB9A9E82DB772C0ACDBC9F; JSESSIONID=D02C334150025222A0B824A98B539B78',
  213. 'referer': 'http://appspeed.piaoquantv.com',
  214. 'token': '524a8bc871dbb0f4d4717895083172ab37c02d2f',
  215. 'accept-language': 'zh-CN,zh-Hans;q=0.9',
  216. 'Content-Type': 'application/x-www-form-urlencoded'
  217. }
  218. payload = {
  219. 'deviceToken': '9ef064f2f7869b3fd67d6141f8a899175dddc91240971172f1f2a662ef891408',
  220. 'fileExtensions': 'MP4',
  221. 'loginUid': n_id,
  222. 'networkType': 'Wi-Fi',
  223. 'platform': 'iOS',
  224. 'requestId': 'fb972cbd4f390afcfd3da1869cd7d001',
  225. 'sessionId': '362290597725ce1fa870d7be4f46dcc2',
  226. 'subSessionId': '362290597725ce1fa870d7be4f46dcc2',
  227. 'title': new_title,
  228. 'token': '524a8bc871dbb0f4d4717895083172ab37c02d2f',
  229. 'uid': n_id,
  230. 'versionCode': '486',
  231. 'versionName': '3.4.12',
  232. 'videoFromScene': '1',
  233. 'videoPath': new_video_path,
  234. 'viewStatus': '1'
  235. }
  236. if cover:
  237. payload['coverImgPath'] = cover
  238. encoded_payload = urlencode(payload)
  239. response = requests.request("POST", url, headers=headers, data=encoded_payload)
  240. data = response.json()
  241. code = data["code"]
  242. if code == 0:
  243. new_video_id = data["data"]["id"]
  244. return new_video_id
  245. else:
  246. return ''
  247. """
  248. 票圈站内视频下载
  249. """
  250. @classmethod
  251. def download_video(cls, video_url, video_path_url, video_id):
  252. video = video_path_url + str(video_id) + '.mp4'
  253. try:
  254. for i in range(3):
  255. payload = {}
  256. headers = {}
  257. response = requests.request("GET", video_url, headers=headers, data=payload)
  258. if response.status_code == 200:
  259. with open(f"{video}", "wb") as file:
  260. # 将响应内容写入文件
  261. file.write(response.content)
  262. time.sleep(5)
  263. return video
  264. return video
  265. except Exception:
  266. return video
  267. """
  268. 票圈站内视频下载
  269. """
  270. @classmethod
  271. def download_video_jpg(cls, video_url, video_path_url, video_id):
  272. try:
  273. payload = {}
  274. headers = {}
  275. response = requests.request("GET", video_url, headers=headers, data=payload)
  276. if response.status_code == 200:
  277. # 以二进制写入模式打开文件
  278. video = video_path_url + str(video_id) + '.jpg'
  279. with open(f"{video}", "wb") as file:
  280. # 将响应内容写入文件
  281. file.write(response.content)
  282. time.sleep(5)
  283. return video
  284. except Exception:
  285. return None
  286. if __name__ == '__main__':
  287. url= 'http://111.51.148.73/ksc1/55LDHcm2DuGHbBbzIDfqMh-vfVhaCuIXZG0szwmCZj9pXLmq7otQhUyGXtBtc13Rb0C49a4FzRU5xfUaRQb6De46IO6hQBVqzjOkFArRDfTC7u9BThi0Bsa2w6PP_6dg7WQYKxU6ZIbYI2tnLfOXU5Ira-DEZuGDQbgpZstADnGtvLMkOiB6DImlhfgdxWIZ.mp4?tag=1-1724839019-sp-0-lgl7lhkrnt-8937a5c247b0f313&provider=self&ocid=341&clientCacheKey=3x3br4x5z5hew32_bF.mp4&tt=bF&di=6f31a709&bp=10001'
  288. a = PQ.download_video(url,'/Users/tzld/Desktop/video_rewriting/path','70100016')
  289. print(a)