video_rewriting/xssy_channel/dy_nrxs.py

import time

import requests
import json

from common import Feishu
from common.sql_help import sqlCollect


class DYNrxs:
    """
    抖音内容相似
    """
    @classmethod
    def get_dy_nrxs(cls):
        user = sqlCollect.get_machine_making_reflux("抖音", "抖音历史", "相似溯源", "单点视频")
        if user == None:
            return
        user = [item[0] for item in user]
        for uid in user:
            url = "http://8.217.190.241:8888/crawler/dou_yin/recommend_user"

            payload = json.dumps({
                "account_id": uid,
                "cursor": ""
            })
            headers = {
                'Content-Type': 'application/json'
            }

            response = requests.request("POST", url, headers=headers, data=payload)
            response = response.json()
            code = response['code']
            if code == 0:
                data_list = response['data']['data']
                if data_list == []:
                    sqlCollect.update_machine_making_reflux(uid)
                    continue
                sqlCollect.update_machine_making_reflux(uid)
                list = []
                for data in data_list:
                    name = data['nickname']
                    sec_uid = data['sec_uid']
                    time.sleep(1)
                    values = [
                        [
                            uid,
                            name,
                            sec_uid
                        ]
                    ]
                    Feishu.insert_columns("AIW2sNNjdhCgT3tug7sco7FGnse", 'GO3Abg', "ROWS", 1, 2)
                    time.sleep(0.5)
                    Feishu.update_values("AIW2sNNjdhCgT3tug7sco7FGnse", 'GO3Abg', "A2:Z2", values)
                    list.append(sec_uid)
                if list:
                    result = ','.join(list)
                    values = [
                        [
                            "抖音",
                            result,
                            "72804451",
                            "5",
                            "通用-分享到群",
                            "AI片尾引导",
                            "",
                            "",
                            "AI标题",
                            "3",
                            f"溯源账号:{uid}"
                        ]
                    ]
                    Feishu.insert_columns("WGIYsSDdxhItBwtJ0xgc0yE7nEg", '0701bd', "ROWS", 1, 2)
                    time.sleep(0.5)
                    Feishu.update_values("WGIYsSDdxhItBwtJ0xgc0yE7nEg", '0701bd', "B2:Z2", values)
            else:
                Feishu.finish_bot("dou_yin/recommend_user 请求失败",
                                  "https://open.feishu.cn/open-apis/bot/v2/hook/575ca6a1-84b4-4a2f-983b-1d178e7b16eb",
                                  "【抖音接口使用提示】")



if __name__ == '__main__':
    DYNrxs.get_dy_nrxs()