video_rewriting/data_channel/cljx_nrxs.py

import random
import time

import requests
import json

from common import Feishu
from common.sql_help import sqlCollect


class CLJX:
    """
    磁力聚星-内容相似
    """
    @classmethod
    def get_ks_account_id(cls, user_id):
        url = "http://8.217.190.241:8888/crawler/kuai_shou/account_info"
        payload = json.dumps({
            "account_id": user_id,

        })
        headers = {
            'Content-Type': 'application/json'
        }
        response = requests.request("POST", url, headers=headers, data=payload)
        time.sleep(1)
        response = response.json()
        code = response['code']
        if code == 0:
            data = response['data']['data']
            if '3x' in user_id:
                channel_account_id = data['digit_id']
            else:
                channel_account_id = data['channel_account_id']

            return channel_account_id
        else:
            Feishu.finish_bot("kuai_shou/account_info接口"+response["msg"],
                              "https://open.feishu.cn/open-apis/bot/v2/hook/575ca6a1-84b4-4a2f-983b-1d178e7b16eb",
                              "【快手 Token 使用提示 】")
            return None

    """
    获取用户主页id
    """
    @classmethod
    def get_cljx_user(cls, user_id):
        url = "https://k.kuaishou.com/rest/web/star/starProfile"

        payload = json.dumps({
            "starId": user_id,
            "starType": 1
        })
        headers = {
            'Accept': 'application/json',
            'Accept-Language': 'zh-CN,zh;q=0.9',
            'Content-Type': 'application/json',
            'Cookie': 'did=web_9c6a04a4004fdb7c95a658a56ed275b6; apdid=328ac94f-4040-41fe-a038-b60140291aca99fb22e9862c74736f53d57b666ee53b:1719580529:1; language=zh-CN; ud=2205012540; app_id=ks686235996059836592; expire_time=1800; userId=2574854626; didv=1723085291918; access_token=ChFvYXV0aC5hY2Nlc3NUb2tlbhIwxAynR0a25DAwASSZyFW_SXVKItA9eLgPL9QE3uhjbXbxOZKZHOd2ZN5XA28WC_yhGhI2htRBeNJJsoU2p999XVFiCx8iINiMEx_garq3ocgmbowCwQEHrGSU3DHRVgcP256vtgogKAUwAQ; nc_user_id=CiVhZC5ub3RpZnkuY2VudGVyLm9hdXRoLnVzZXIuaWQuc2VjcmV0EiD3Ti1DDwjCt6yg6dWPwJ0ORdOr8FJXzTZs1oramKY6lBoS2NP9Dh0WHkEo1U4//HlOPvrHIiCyOJ7XywzTEB831l48hsXwEUPoCfOWlivj2ImMavMg2SgFMAE=; kuaishou.ad.social_st=ChVrdWFpc2hvdS5hZC5zb2NpYWwuc3QSoAGYIByd-51FdrhEkJ0gKeGxIfc9ENhrDEzFEoCMlMJJqK3NkzgxivGEt2nrsjO9nES9Kk7_bdr2-ILnlEiCdTk3VV3tjQNJ0AIdAco58wYxSgFGoiTzm_70s9K7pNo_Xtu_Td715BLcoJWSi-8kr8c51_lK1bf5WudF6Mu0_ux3l7j3xMULUfPlgQWyOsoGLmZZc-D2nJ1y-b1mQpSDOR75GhI9XS-Z7CpEB6YeaJVDlC5cHwQiIAJYR4iZ-BOCyoxQsdkV1qXAI5Pt8XUFJaqlKkkDVDt3KAUwAQ; kuaishou.ad.social_ph=2bedb2aeb05a5b4bb0e8103a2b4e68029ecc; did=web_9c6a04a4004fdb7c95a658a56ed275b6; didv=1711522726000',
            'Origin': 'https://k.kuaishou.com',
            'Pragma': 'no-cache',
            'Referer': 'https://k.kuaishou.com/',
            'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36'
        }

        response = requests.request("POST", url, headers=headers, data=payload)
        time.sleep(1)
        response = response.json()
        result = response['result']
        if result == 1:
            profile_id = response["starProfile"]["profileId"]
            return profile_id
        else:
            print("提示")
            Feishu.finish_bot("Token 过期，请及时更换",
                              "https://open.feishu.cn/open-apis/bot/v2/hook/575ca6a1-84b4-4a2f-983b-1d178e7b16eb",
                              "【磁力聚星提示】")

    @classmethod
    def get_ks_list(cls, url_id):
        url = "http://8.217.190.241:8888/crawler/kuai_shou/blogger"
        next_cursor = ""
        payload = json.dumps({
            "account_id": url_id,
            "sort_type": "最热",
            "cursor": next_cursor
        })
        headers = {
            'Content-Type': 'application/json'
        }
        time.sleep(random.randint(1, 5))
        try:
            response = requests.request("POST", url, headers=headers, data=payload)
            response = response.json()
            data_all_list = response["data"]
            if data_all_list == None or len(data_all_list) == 0:
                if int(response["cdoe"]) == 27006:
                    Feishu.finish_bot("kuai_shou/blogger接口" + response["msg"],
                                      "https://open.feishu.cn/open-apis/bot/v2/hook/575ca6a1-84b4-4a2f-983b-1d178e7b16eb",
                                      "【快手 Token 使用提示 】")
        except Exception as exc:
            return False
        data_list = data_all_list["data"]
        for data in data_list:
            like_count = data['like_count']
            if int(like_count) >= 10000:
                return True
        return False
    @classmethod
    def get_nrxs(cls):
        user = sqlCollect.get_machine_making_reflux("快手", "快手历史")
        if user == None:
            return
        user = [item[0] for item in user]
        for uid in user:
            print(f"账号id{uid}")
            ks_id = cls.get_ks_account_id(uid)
            if ks_id == None:
                continue
            url = "https://k.kuaishou.com/rest/web/similar/simStar/list"

            payload = json.dumps({
                "next": 0,
                "similarType": 1,
                "size": 10,
                "starUserId": ks_id
            })
            headers = {
                'Accept': 'application/json',
                'Accept-Language': 'zh-CN,zh;q=0.9',
                'Content-Type': 'application/json',
                'Cookie': 'did=web_9c6a04a4004fdb7c95a658a56ed275b6; apdid=328ac94f-4040-41fe-a038-b60140291aca99fb22e9862c74736f53d57b666ee53b:1719580529:1; language=zh-CN; ud=2205012540; app_id=ks686235996059836592; expire_time=1800; userId=2574854626; didv=1723085291918; access_token=ChFvYXV0aC5hY2Nlc3NUb2tlbhIwDJriiBd_Rfw8eDYAcNrxMNVh31u9tSJA9CAjt2O16wxi9gaDtJGN2IvVJqfPwZSwGhITB63P569DkqhlagGy21IJcH4iIHbikbQYx3YJ52cgLTbYnP5Huwfrx7NEoKGZIe1AAyeIKAUwAQ; nc_user_id=CiVhZC5ub3RpZnkuY2VudGVyLm9hdXRoLnVzZXIuaWQuc2VjcmV0EiC/P102mzVQGt2+DLIVD/C0wyWnJS85OkfLevE+gvyLiRoSh6GwxLxhJBzTF971M5HbMVVPIiDgi55t2xTmfnFXnyeAyDLyzno6k2e/bw7J4u1/qifbhSgFMAE=; kuaishou.ad.social_st=ChVrdWFpc2hvdS5hZC5zb2NpYWwuc3QSoAEqrrb6oCuZkjOnvnZeoEnQ564Rqph6-AqPSgVWYrifAPjBt2YgfXHw_98ldMOg8cUR8QiOIFztsdcRTBYDvs_ckIgjC5UiJTT55LXHG8ANCYQI4NZunxSDkRjtJAxK0R-21t3-rClsYus5eFEwaBnhuD0cG_Ze5a1ZWgkliCTZRHodiOTLWKP8exhEEg6lQnWPJe3YwCi91Setn1Vj6UKjGhLsLDZ7p_FIhoJA3z3VbOn1dpkiIIaFUhkgfk2L9XCNiZIVUGL6Bs0hCk9Kqgm6HdnYn7FBKAUwAQ; kuaishou.ad.social_ph=35a38517bc185742d657a2ac0ba1e8f4a088; did=web_9c6a04a4004fdb7c95a658a56ed275b6; didv=1711522726000',
                'Origin': 'https://k.kuaishou.com',
                'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.0.0 Safari/537.36',
                'sec-ch-ua-platform': '"macOS"'
            }

            response = requests.request("POST", url, headers=headers, data=payload)
            time.sleep(1)
            response = response.json()
            result = response['result']
            if result == 1:
                data = response["data"]
                star_vo_list = data['starVoList']
                if star_vo_list == []:
                    sqlCollect.update_machine_making_reflux(uid)
                    continue
                # 修改状态
                sqlCollect.update_machine_making_reflux(uid)
                list = []
                for star in star_vo_list:
                    star_id = star['starId']
                    name = star['name']
                    time.sleep(1)
                    account_id = cls.get_cljx_user(int(star_id))  # 获取用户主页id
                    if account_id:
                        print(f"溯源账号id：{account_id}")

                        time.sleep(1)
                        like_count = cls.get_ks_list(account_id)  # 是否符合规则
                        if like_count:
                            status = 1
                        else:
                            status = 0
                        sqlCollect.insert_user_data(uid, name,  account_id, "快手", status)
                        values = [
                            [
                                uid,
                                name,
                                account_id,
                                status,
                                "快手"
                            ]
                        ]
                        Feishu.insert_columns("AIW2sNNjdhCgT3tug7sco7FGnse", 'couJYt', "ROWS", 1, 2)
                        time.sleep(0.5)
                        Feishu.update_values("AIW2sNNjdhCgT3tug7sco7FGnse", 'couJYt', "A2:Z2", values)
                        if status == 1:
                            list.append(account_id)
                if list:
                    result = ','.join(list)
                    values = [
                        [
                            "快手",
                            result,
                            "72777058",
                            "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("Token 过期，请及时更换",
                                  "https://open.feishu.cn/open-apis/bot/v2/hook/575ca6a1-84b4-4a2f-983b-1d178e7b16eb",
                                  "【磁力聚星提示】")

if __name__ == '__main__':
    CLJX.get_nrxs()