# -*- coding: utf-8 -*- # @Author: wangkun # @Time: 2022/4/18 """ 下载并上传:播放量视频 """ import os import sys import time sys.path.append(os.getcwd()) from main.common import Common from main.get_feeds import get_feeds from main.publish import Publish from main.feishu_lib import Feishu class DownloadPlay: @staticmethod def play_rule(play_width, play_height, play_duration, play_play_cnt): """ 1.分辨率,宽或者高 >= 720 or ==0 2.600s >= 时长 >= 60s 3.视频播放量 >= 150000 """ if int(play_width) >= 720 or int(play_height) >= 720 or play_width == "0" or play_height == "0": if 600 >= int(play_duration) >= 60: if int(play_play_cnt) >= 150000: return True else: return False else: return False else: return False @classmethod def download_play_video(cls, env): """ 下载播放量视频 测试环境:env == dev 正式环境:env == prod """ if len(Feishu.get_values_batch("SdCHOM")) == 1: pass else: for i in range(len(Feishu.get_values_batch("SdCHOM"))): time.sleep(1) try: download_video_id = Feishu.get_values_batch("SdCHOM")[i+1][1] download_video_play_cnt = Feishu.get_values_batch("SdCHOM")[i+1][2] download_video_title = Feishu.get_values_batch("SdCHOM")[i+1][3] download_video_duration = Feishu.get_values_batch("SdCHOM")[i+1][4] download_video_comment_cnt = Feishu.get_values_batch("SdCHOM")[i+1][5] download_video_like_cnt = Feishu.get_values_batch("SdCHOM")[i+1][6] download_video_share_cnt = Feishu.get_values_batch("SdCHOM")[i+1][7] download_video_resolution = Feishu.get_values_batch("SdCHOM")[i+1][8] download_video_width = download_video_resolution.split("*")[0] download_video_height = download_video_resolution.split("*")[-1] download_video_send_time = Feishu.get_values_batch("SdCHOM")[i+1][9] download_user_name = Feishu.get_values_batch("SdCHOM")[i+1][10] download_head_url = Feishu.get_values_batch("SdCHOM")[i+1][11] download_cover_url = Feishu.get_values_batch("SdCHOM")[i+1][12] download_video_url = Feishu.get_values_batch("SdCHOM")[i+1][13] download_video_session = Feishu.get_values_batch("SdCHOM")[i+1][14] if cls.play_rule(download_video_width, download_video_height, download_video_duration, download_video_play_cnt) is True: Common.logger().info("开始下载视频:{}", download_video_title) # 下载封面 Common.download_method(text="cover", d_name=download_video_title, d_url=download_cover_url) # 下载视频 Common.download_method(text="video", d_name=download_video_title, d_url=download_video_url) # 保存视频信息至 "./videos/{download_video_title}/info.txt" with open(r"./videos/" + download_video_title + r"/info.txt", "a", encoding="utf8") as f_a: f_a.write(str(download_video_id) + "\n" + str(download_video_title) + "\n" + str(download_video_duration) + "\n" + str(download_video_play_cnt) + "\n" + str(download_video_comment_cnt) + "\n" + str(download_video_like_cnt) + "\n" + str(download_video_share_cnt) + "\n" + str(download_video_resolution) + "\n" + str(download_video_send_time) + "\n" + str(download_user_name) + "\n" + str(download_head_url) + "\n" + str(download_video_url) + "\n" + str(download_cover_url) + "\n" + str(download_video_session)) # 上传视频 Common.logger().info("开始上传视频:{}", download_video_title) Publish.upload_and_publish(env, "play") # 保存视频 ID 到云文档:https://w42nne6hzg.feishu.cn/sheets/shtcngRPoDYAi24x52j2nDuHMih?sheet=20ce0c Common.logger().info("保存视频ID至云文档:{}", download_video_title) # 看一看+ ,视频ID工作表,插入首行 Feishu.insert_columns("20ce0c") # 看一看+ ,视频ID工作表,首行写入数据 Feishu.update_values("20ce0c", download_video_id, "", "", "", "", "", "", "", "", "", "", "", "", "", "") # 从云文档删除该视频信息:https://w42nne6hzg.feishu.cn/sheets/shtcngRPoDYAi24x52j2nDuHMih?sheet=SdCHOM Common.logger().info("从云文档删除该视频信息:{}", download_video_title) # 删除行或列,可选 ROWS、COLUMNS Feishu.dimension_range("SdCHOM", "ROWS", i + 2, i + 2) else: # 从云文档删除该视频信息:https://w42nne6hzg.feishu.cn/sheets/shtcngRPoDYAi24x52j2nDuHMih?sheet=SdCHOM Common.logger().info("该视频不满足下载规则,删除在云文档中的信息:{}", download_video_title) # 删除行或列,可选 ROWS、COLUMNS Feishu.dimension_range("SdCHOM", "ROWS", i + 2, i + 2) except Exception as e: Common.logger().error("视频 info 异常,删除该视频信息", e) # 删除行或列,可选 ROWS、COLUMNS Feishu.dimension_range("SdCHOM", "ROWS", i + 2, i + 2) cls.download_play_video("prod") if __name__ == "__main__": download_play = DownloadPlay() get_feeds() download_play.download_play_video("dev")