carry_video_rewriting/data_channel/shipinhaodandian.py

from common import AliyunLogger
from common.sql_help import sqlCollect


class SPHDD:

    @classmethod
    def get_sphdd_data(cls, url, channel_id, name):
        list = []
        try:
            data_list = sqlCollect.get_shp_dd_data(url)

            if data_list:
                for data in data_list:
                    cover_url = data[4]
                    video_url = data[5]
                    if video_url and cover_url:
                        video_id = data[0]
                        old_title = data[1]
                        # author_id = data[2]
                        author_name = data[3]
                        video_duration = data[6]
                        from_user_id = data[7]
                        from_user_name = data[8]
                        from_group_id = data[9]
                        from_group_name = data[10]
                        source = data[11]
                        wx_msg = data[12]
                        is_encrypted = data[13]
                        decode_key = data[14]
                        log_data = f"user:{url},,video_id:{video_id},,video_url:{video_url},,original_title:{old_title}"
                        AliyunLogger.logging(f"{channel_id}-{source}", name, url, video_id, "扫描到一条视频", "2001", log_data)
                        AliyunLogger.logging(f"{channel_id}-{source}", name, url, video_id, "符合规则等待改造", "2004", log_data)
                        all_data = {"video_id": video_id, "cover": cover_url, "video_url": video_url, "rule": author_name,
                                    "old_title": old_title, "from_user_name": from_user_name, "from_group_name": from_group_name, "source": source, "wx_msg": wx_msg, "is_encrypted": is_encrypted, "decode_key": decode_key}
                        list.append(all_data)
                return list
            else:
                return list
        except Exception:
            return list




if __name__ == '__main__':

    SPHDD.get_sphdd_data("刘坤宇", '', '')