crawler_kanyikan/main/download_play.py

# -*- 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
        """
        try:
            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")
        except Exception as e:
            Common.logger().error(e)


if __name__ == "__main__":
    download_play = DownloadPlay()
    get_feeds()
    download_play.download_play_video("dev")