piaoquan_utils.py 9.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250
  1. import random
  2. import time
  3. import json
  4. import requests
  5. from urllib.parse import urlencode
  6. from common import Common
  7. from common.sql_help import sqlCollect
  8. class PQ:
  9. """
  10. 获取视频链接
  11. """
  12. @classmethod
  13. def get_audio_url(cls, task_mark, user_id, title, mark):
  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. list = []
  36. video_id = data["content"]["id"]
  37. if mark:
  38. status = sqlCollect.is_used(task_mark, video_id, mark)
  39. else:
  40. status = True
  41. if status:
  42. if title == '' or title == None:
  43. new_title = data["content"]["title"]
  44. else:
  45. if '/' in title:
  46. titles = title.split('/')
  47. else:
  48. titles = [title]
  49. new_title = random.choice(titles)
  50. video_url = data["content"]["transedVideoPath"]
  51. cover = data["content"]["coverImgPath"]
  52. all_data = {"video_id": video_id, "title": new_title, "cover": cover, "video_url": video_url}
  53. list.append(all_data)
  54. return list
  55. return list
  56. except Exception as e:
  57. Common.logger("video").warning(f"获取视频链接失败:{e}\n")
  58. return ""
  59. """
  60. 获取用户下的所有视频
  61. """
  62. @classmethod
  63. def get_user_url(cls, task_mark, user_id, number, title, mark):
  64. url = f"https://admin.piaoquantv.com/manager/video/page?uid={user_id}&pageNum=1&pageSize=100"
  65. payload = {}
  66. headers = {
  67. 'accept': 'application/json, text/plain, */*',
  68. 'cookie': 'SESSION=NjRmMGVjNTAtNzJiNi00ODE0LThjYzQtYmZiNTJhMDNiZTcz',
  69. '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'
  70. }
  71. response = requests.request("GET", url, headers=headers, data=payload)
  72. data = response.json()
  73. try:
  74. content = data["content"]["objs"]
  75. list = []
  76. for url in content:
  77. video_id = url["id"]
  78. status = sqlCollect.is_used(task_mark, video_id, mark)
  79. if status:
  80. if title == '' or title == None:
  81. new_title = url["title"]
  82. else:
  83. if '/' in title:
  84. titles = title.split('/')
  85. else:
  86. titles = [title]
  87. new_title = random.choice(titles)
  88. cover = url["coverImgPath"]
  89. video_url = url["transedVideoPath"]
  90. all_data = {"video_id": video_id, "title": new_title, "cover": cover, "video_url": video_url}
  91. list.append(all_data)
  92. if len(list) == int(number):
  93. return list
  94. return list
  95. except Exception as e:
  96. Common.logger("log").warning(f"获取音频视频链接失败:{e}\n")
  97. return ""
  98. """
  99. 获取封面
  100. """
  101. @classmethod
  102. def get_cover(cls, uid):
  103. time.sleep(1)
  104. url = "https://admin.piaoquantv.com/manager/video/multiCover/listV2"
  105. payload = json.dumps({
  106. "videoId": uid,
  107. "range": "2h"
  108. })
  109. headers = {
  110. 'accept': 'application/json',
  111. 'accept-language': 'zh-CN,zh;q=0.9',
  112. 'cache-control': 'no-cache',
  113. 'content-type': 'application/json',
  114. 'cookie': 'SESSION=YjU3MzgwNTMtM2QyYi00YjljLWI3YWUtZTBjNWYwMGQzYWNl',
  115. 'origin': 'https://admin.piaoquantv.com',
  116. 'pragma': 'no-cache',
  117. 'priority': 'u=1, i',
  118. 'sec-ch-ua': '"Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99"',
  119. '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'
  120. }
  121. response = requests.request("POST", url, headers=headers, data=payload)
  122. data = response.json()
  123. content = data["content"]
  124. if len(content) == 1:
  125. return content[0]["coverUrl"]
  126. max_share_count = 0
  127. selected_cover_url = ""
  128. for item in content:
  129. share_count = item.get("shareWeight")
  130. if share_count is not None and share_count > max_share_count:
  131. max_share_count = share_count
  132. selected_cover_url = item["coverUrl"]
  133. elif share_count == max_share_count and item["createUser"] == "用户":
  134. selected_cover_url = item["coverUrl"]
  135. return selected_cover_url
  136. """
  137. 获取标题
  138. """
  139. @classmethod
  140. def get_title(cls, uid):
  141. url = "https://admin.piaoquantv.com/manager/video/multiTitleV2/listV2"
  142. payload = json.dumps({
  143. "videoId": uid,
  144. "range": "4h"
  145. })
  146. headers = {
  147. 'accept': 'application/json',
  148. 'accept-language': 'zh-CN,zh;q=0.9',
  149. 'cache-control': 'no-cache',
  150. 'content-type': 'application/json',
  151. 'cookie': 'SESSION=YjU3MzgwNTMtM2QyYi00YjljLWI3YWUtZTBjNWYwMGQzYWNl',
  152. 'origin': 'https://admin.piaoquantv.com',
  153. 'pragma': 'no-cache',
  154. 'priority': 'u=1, i',
  155. 'sec-ch-ua': '"Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99"',
  156. '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'
  157. }
  158. response = requests.request("POST", url, headers=headers, data=payload)
  159. data = response.json()
  160. content = data["content"]
  161. if len(content) == 1:
  162. return content[0]["title"]
  163. max_share_count = 0
  164. selected_title = ""
  165. for item in content:
  166. share_count = item.get("shareWeight")
  167. if share_count is not None and share_count > max_share_count:
  168. max_share_count = share_count
  169. selected_title = item["title"]
  170. elif share_count == max_share_count and item["createUser"] == "用户":
  171. selected_title = item["title"]
  172. return selected_title
  173. """
  174. 新生成视频上传到对应账号下
  175. """
  176. @classmethod
  177. def insert_piaoquantv(cls, new_video_path, new_title, cover, n_id):
  178. url = "https://vlogapi.piaoquantv.com/longvideoapi/crawler/video/send"
  179. headers = {
  180. 'User-Agent': 'PQSpeed/486 CFNetwork/1410.1 Darwin/22.6.0',
  181. 'cookie': 'JSESSIONID=4DEA2B5173BB9A9E82DB772C0ACDBC9F; JSESSIONID=D02C334150025222A0B824A98B539B78',
  182. 'referer': 'http://appspeed.piaoquantv.com',
  183. 'token': '524a8bc871dbb0f4d4717895083172ab37c02d2f',
  184. 'accept-language': 'zh-CN,zh-Hans;q=0.9',
  185. 'Content-Type': 'application/x-www-form-urlencoded'
  186. }
  187. payload = {
  188. 'coverImgPath': cover,
  189. 'deviceToken': '9ef064f2f7869b3fd67d6141f8a899175dddc91240971172f1f2a662ef891408',
  190. 'fileExtensions': 'MP4',
  191. 'loginUid': n_id,
  192. 'networkType': 'Wi-Fi',
  193. 'platform': 'iOS',
  194. 'requestId': 'fb972cbd4f390afcfd3da1869cd7d001',
  195. 'sessionId': '362290597725ce1fa870d7be4f46dcc2',
  196. 'subSessionId': '362290597725ce1fa870d7be4f46dcc2',
  197. 'title': new_title,
  198. 'token': '524a8bc871dbb0f4d4717895083172ab37c02d2f',
  199. 'uid': n_id,
  200. 'versionCode': '486',
  201. 'versionName': '3.4.12',
  202. 'videoFromScene': '1',
  203. 'videoPath': new_video_path,
  204. 'viewStatus': '1'
  205. }
  206. encoded_payload = urlencode(payload)
  207. response = requests.request("POST", url, headers=headers, data=encoded_payload)
  208. data = response.json()
  209. code = data["code"]
  210. if code == 0:
  211. new_video_id = data["data"]["id"]
  212. return new_video_id
  213. else:
  214. return ''
  215. """
  216. 票圈站内视频下载
  217. """
  218. @classmethod
  219. def download_video(cls, video_url, video_path_url, video_id):
  220. for i in range(3):
  221. payload = {}
  222. headers = {}
  223. response = requests.request("GET", video_url, headers=headers, data=payload)
  224. if response.status_code == 200:
  225. # 以二进制写入模式打开文件
  226. video = video_path_url + str(video_id) + '.mp4'
  227. with open(f"{video}", "wb") as file:
  228. # 将响应内容写入文件
  229. file.write(response.content)
  230. time.sleep(5)
  231. return video
  232. return ''