计算阅读率，阅读均值 v3

applications/pqMysql.py

@@ -26,10 +26,14 @@ class PQMySQL(object):
         cursor = cls.connection.cursor()
         try:
             cursor.execute(sql, params)
+            affected = cursor.rowcount
             cls.connection.commit()
+            return affected
+
         except Exception as e:
             print(e)
             cls.connection.rollback()
+            raise e
 
     @classmethod
     def select(cls, sql):
@@ -56,4 +60,5 @@ class PQMySQL(object):
             cls.connection.commit()
         except Exception as e:
             print("Insert Many Defeat--{}".format(e))
-            cls.connection.rollback()
+            cls.connection.rollback()
+            raise e

not_used_tasks/cal_account_read_rate_avg.py

@@ -1,495 +0,0 @@
-"""
-@author: luojunhui
-cal each account && position reading rate
-"""
-import json
-import time
-from tqdm import tqdm
-from datetime import datetime, timezone
-from pandas import DataFrame
-
-from applications import DeNetMysql, PQMySQL, longArticlesMySQL
-
-
-def timestamp_to_str(timestamp) -> str:
-    """
-    :param timestamp:
-    """
-    dt_object = datetime.utcfromtimestamp(timestamp).replace(tzinfo=timezone.utc).astimezone()
-    date_string = dt_object.strftime('%Y-%m-%d')
-    return date_string
-
-
-def get_account_fans_by_dt(db_client) -> dict:
-    """
-    获取每个账号发粉丝，通过日期来区分
-    :return:
-    """
-    sql = f"""
-        SELECT 
-            t1.date_str, 
-            t1.fans_count, 
-            t2.gh_id
-        FROM datastat_wx t1
-        JOIN publish_account t2 ON t1.account_id = t2.id
-        WHERE 
-            t2.channel = 5 
-        AND t2.status = 1 
-        AND t1.date_str >= '2024-07-01' 
-        ORDER BY t1.date_str;
-    """
-    result = db_client.select(sql)
-    D = {}
-    for line in result:
-        dt = line[0]
-        fans = line[1]
-        gh_id = line[2]
-        if D.get(gh_id):
-            D[gh_id][dt] = fans
-        else:
-            D[gh_id] = {dt: fans}
-    return D
-
-
-def get_account_articles_detail(db_client, gh_id_tuple) -> list[dict]:
-    """
-    get articles details
-    :return:
-    """
-    sql = f"""
-            SELECT 
-                ghId, accountName, updateTime, ItemIndex, show_view_count 
-            FROM 
-                official_articles_v2
-            WHERE 
-                ghId IN {gh_id_tuple};
-            """
-    result = db_client.select(sql)
-    response_list = [
-        {
-            "ghId": i[0],
-            "accountName": i[1],
-            "updateTime": i[2],
-            "ItemIndex": i[3],
-            "show_view_count": i[4]
-        }
-        for i in result
-    ]
-    return response_list
-
-
-def cal_account_read_rate(gh_id_tuple) -> DataFrame:
-    """
-    计算账号位置的阅读率
-    :return:
-    """
-    pq_db = PQMySQL()
-    de_db = DeNetMysql()
-    response = []
-    fans_dict_each_day = get_account_fans_by_dt(db_client=de_db)
-    account_article_detail = get_account_articles_detail(
-        db_client=pq_db,
-        gh_id_tuple=gh_id_tuple
-    )
-    for line in account_article_detail:
-        gh_id = line['ghId']
-        dt = timestamp_to_str(line['updateTime'])
-        fans = fans_dict_each_day.get(gh_id, {}).get(dt, 0)
-        line['fans'] = fans
-        if fans:
-            line['readRate'] = line['show_view_count'] / fans if fans else 0
-            response.append(line)
-    return DataFrame(response,
-                     columns=['ghId', 'accountName', 'updateTime', 'ItemIndex', 'show_view_count', 'readRate'])
-
-
-def cal_avg_account_read_rate(df, gh_id, index) -> tuple:
-    """
-    计算账号的阅读率均值
-    :return:
-    """
-    min_time = int(time.time()) - 60 * 24 * 3600
-    max_time = int(time.time())
-    filterDataFrame = df[
-        (df["ghId"] == gh_id)
-        & (min_time <= df["updateTime"])
-        & (df["updateTime"] <= max_time)
-        & (df['ItemIndex'] == index)
-        ]
-    return (
-        filterDataFrame['readRate'].mean(),
-        filterDataFrame['updateTime'].max(),
-        filterDataFrame['updateTime'].min(),
-        len(filterDataFrame)
-    )
-
-
-def main() -> None:
-    """
-    main function
-    :return:
-    """
-    lam = longArticlesMySQL()
-    account_gh_id_list = [
-        {
-            "gh_id": "gh_9e559b3b94ca",
-            "account_name": "票圈大事件"
-        },
-        {
-            "gh_id": "gh_084a485e859a",
-            "account_name": "生活情感叁读"
-        },
-        {
-            "gh_id": "gh_1ee2e1b39ccf",
-            "account_name": "票圈最新消息"
-        },
-        {
-            "gh_id": "gh_4c058673c07e",
-            "account_name": "家家生活指南"
-        },
-        {
-            "gh_id": "gh_de9f9ebc976b",
-            "account_name": "妙招持家帮手"
-        },
-        {
-            "gh_id": "gh_058e41145a0c",
-            "account_name": "多彩妙生活"
-        },
-        {
-            "gh_id": "gh_7b4a5f86d68c",
-            "account_name": "异闻趣事多"
-        },
-        {
-            "gh_id": "gh_4568b5a7e2fe",
-            "account_name": "窦都事说"
-        },
-        {
-            "gh_id": "gh_adca24a8f429",
-            "account_name": "史记趣言"
-        },
-        {
-            "gh_id": "gh_e24da99dc899",
-            "account_name": "缘来养心厅"
-        },
-        {
-            "gh_id": "gh_e0eb490115f5",
-            "account_name": "心灵情感驿站"
-        },
-        {
-            "gh_id": "gh_d2cc901deca7",
-            "account_name": "票圈极速版"
-        },
-        {
-            "gh_id": "gh_26a307578776",
-            "account_name": "票圈美文速递"
-        },
-        {
-            "gh_id": "gh_183d80deffb8",
-            "account_name": "生活良读"
-        },
-        {
-            "gh_id": "gh_5ff48e9fb9ef",
-            "account_name": "祝福养心厅"
-        },
-        {
-            "gh_id": "gh_9f8dc5b0c74e",
-            "account_name": "音药金曲厅"
-        },
-        {
-            "gh_id": "gh_6d9f36e3a7be",
-            "account_name": "音药养心馆"
-        },
-        {
-            "gh_id": "gh_ac43e43b253b",
-            "account_name": "小阳看天下"
-        },
-        {
-            "gh_id": "gh_d5f935d0d1f2",
-            "account_name": "繁花史阁"
-        },
-        {
-            "gh_id": "gh_be8c29139989",
-            "account_name": "退休无忧生活"
-        },
-        {
-            "gh_id": "gh_c91b42649690",
-            "account_name": "农耕趣时刻"
-        },
-        {
-            "gh_id": "gh_93e00e187787",
-            "account_name": "小惠爱厨房"
-        },
-        {
-            "gh_id": "gh_744cb16f6e16",
-            "account_name": "趣史论"
-        },
-        {
-            "gh_id": "gh_9877c8541764",
-            "account_name": "退休老年圈"
-        },
-        {
-            "gh_id": "gh_0c89e11f8bf3",
-            "account_name": "幸福启示"
-        },
-        {
-            "gh_id": "gh_6d205db62f04",
-            "account_name": "指尖奇文"
-        },
-        {
-            "gh_id": "gh_c69776baf2cd",
-            "account_name": "老友欢聚地"
-        },
-        {
-            "gh_id": "gh_6b7c2a257263",
-            "account_name": "幸福晚年知音"
-        },
-        {
-            "gh_id": "gh_bfe5b705324a",
-            "account_name": "奇趣百味生活"
-        },
-        {
-            "gh_id": "gh_29074b51f2b7",
-            "account_name": "老来生活家"
-        },
-        {
-            "gh_id": "gh_7e5818b2dd83",
-            "account_name": "便捷生活好方法"
-        },
-        {
-            "gh_id": "gh_89ef4798d3ea",
-            "account_name": "生活百态观"
-        },
-        {
-            "gh_id": "gh_bff0bcb0694a",
-            "account_name": "喜乐生活派"
-        },
-        {
-            "gh_id": "gh_a2901d34f75b",
-            "account_name": "畅聊奇闻"
-        },
-        {
-            "gh_id": "gh_b15de7c99912",
-            "account_name": "人生百事观"
-        },
-        {
-            "gh_id": "gh_56ca3dae948c",
-            "account_name": "老友闲谈"
-        },
-        {
-            "gh_id": "gh_e75dbdc73d80",
-            "account_name": "票圈正能量"
-        },
-        {
-            "gh_id": "gh_192c9cf58b13",
-            "account_name": "天天学生活技巧"
-        },
-        {
-            "gh_id": "gh_6cfd1132df94",
-            "account_name": "趣味晚年"
-        },
-        {
-            "gh_id": "gh_f25b5fb01977",
-            "account_name": "生活晓常识"
-        },
-        {
-            "gh_id": "gh_080bb43aa0dc",
-            "account_name": "态度说"
-        },
-        {
-            "gh_id": "gh_d49df5e974ca",
-            "account_name": "生活指示录"
-        },
-        {
-            "gh_id": "gh_5ae65db96cb7",
-            "account_name": "路边闲聊社"
-        },
-        {
-            "gh_id": "gh_72bace6b3059",
-            "account_name": "幸福妙招合集"
-        },
-        {
-            "gh_id": "gh_9eef14ad6c16",
-            "account_name": "快乐精选集"
-        },
-        {
-            "gh_id": "gh_c5cdf60d9ab4",
-            "account_name": "老友快乐谈"
-        },
-        {
-            "gh_id": "gh_7f5075624a50",
-            "account_name": "都市镜头"
-        },
-        {
-            "gh_id": "gh_d4dffc34ac39",
-            "account_name": "情为老友"
-        },
-        {
-            "gh_id": "gh_ff487cb5dab3",
-            "account_name": "趣味生活达人"
-        },
-        {
-            "gh_id": "gh_1b27dd1beeca",
-            "account_name": "小贝生活课堂"
-        },
-        {
-            "gh_id": "gh_1d887d61088c",
-            "account_name": "乐享生活小窍门"
-        },
-        {
-            "gh_id": "gh_3ed305b5817f",
-            "account_name": "看不够妙招"
-        },
-        {
-            "gh_id": "gh_dd4c857bbb36",
-            "account_name": "无忧自在生活"
-        },
-        {
-            "gh_id": "gh_f902cea89e48",
-            "account_name": "无忧潮生活"
-        },
-        {
-            "gh_id": "gh_b676b7ad9b74",
-            "account_name": "无忧生活小妙招"
-        },
-        {
-            "gh_id": "gh_b6f2c5332c72",
-            "account_name": "巷尾风声"
-        },
-        {
-            "gh_id": "gh_ee78360d06f5",
-            "account_name": "实用妙招800个"
-        },
-        {
-            "gh_id": "gh_68e7fdc09fe4",
-            "account_name": "史趣探秘"
-        },
-        {
-            "gh_id": "gh_789a40fe7935",
-            "account_name": "史记有言"
-        },
-        {
-            "gh_id": "gh_77f36c109fb1",
-            "account_name": "暖心一隅"
-        },
-        {
-            "gh_id": "gh_ac43eb24376d",
-            "account_name": "麒阁史记"
-        },
-        {
-            "gh_id": "gh_969f5ea5fee1",
-            "account_name": "心海情澜起"
-        },
-        {
-            "gh_id": "gh_57573f01b2ee",
-            "account_name": "那些历史"
-        },
-        {
-            "gh_id": "gh_008ef23062ee",
-            "account_name": "日常生活小技巧集"
-        },
-        {
-            "gh_id": "gh_3e91f0624545",
-            "account_name": "趣谈史记"
-        },
-        {
-            "gh_id": "gh_30816d8adb52",
-            "account_name": "日常巧思集"
-        },
-        {
-            "gh_id": "gh_51e4ad40466d",
-            "account_name": "日常小妙招秘籍"
-        },
-        {
-            "gh_id": "gh_7c66e0dbd2cf",
-            "account_name": "晚年家人"
-        },
-        {
-            "gh_id": "gh_03d32e83122f",
-            "account_name": "快乐生活妙技巧"
-        },
-        {
-            "gh_id": "gh_0e4fd9e88386",
-            "account_name": "持家有妙招"
-        },
-        {
-            "gh_id": "gh_95ed5ecf9363",
-            "account_name": "生活小优招"
-        },
-        {
-            "gh_id": "gh_970460d9ccec",
-            "account_name": "生活之大全"
-        },
-        {
-            "gh_id": "gh_749271f1ccd5",
-            "account_name": "轻松生活方法"
-        },
-        {
-            "gh_id": "gh_660afe87b6fd",
-            "account_name": "趣读奇事"
-        },
-        {
-            "gh_id": "gh_03d45c260115",
-            "account_name": "晚年多享乐"
-        },
-        {
-            "gh_id": "gh_1686250f15b6",
-            "account_name": "福康俏生活"
-        },
-        {
-            "gh_id": "gh_98ec0ffe69b3",
-            "account_name": "博史鉴览"
-        },
-        {
-            "gh_id": "gh_2e615fa75ffb",
-            "account_name": "好招妙"
-        },
-        {
-            "gh_id": "gh_57c9e8babea7",
-            "account_name": "福享暮年"
-        },
-        {
-            "gh_id": "gh_bfea052b5baa",
-            "account_name": "奇读趣史"
-        },
-        {
-            "gh_id": "gh_6d3aa9d13402",
-            "account_name": "悠读生活"
-        }
-    ]
-    df = cal_account_read_rate(tuple([i['gh_id'] for i in account_gh_id_list]))
-    index_list = [1, 2, 3, 4, 5, 6, 7, 8]
-    for account in tqdm(account_gh_id_list):
-        for index in index_list:
-            avg_rate, max_time, min_time, a_count = cal_avg_account_read_rate(df, account['gh_id'], index)
-            print(account['account_name'], "\t", index, "\t", avg_rate, "\t", max_time, "\t", min_time, "\t", a_count,
-                  "\t", account['gh_id'])
-            try:
-                if avg_rate == 0:
-                    continue
-                update_sql = f"""
-                    INSERT INTO long_articles_read_rate
-                    (account_name, gh_id, position, read_rate_avg, remark, articles_count, earliest_publish_time, latest_publish_time, dt_version, is_delete)
-                    values
-                    (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s);
-                """
-                lam.update(
-                    sql=update_sql,
-                    params=(
-                        account['account_name'],
-                        account['gh_id'],
-                        index,
-                        avg_rate,
-                        "1022去掉粉丝为 0的计数",
-                        a_count,
-                        timestamp_to_str(min_time),
-                        timestamp_to_str(max_time),
-                        1022,
-                        0
-                    )
-                )
-            except Exception as e:
-                print(e)
-
-
-if __name__ == '__main__':
-    main()

not_used_tasks/cal_account_read_rate_avg_daily.py

@@ -0,0 +1,266 @@
+"""
+@author: luojunhui
+cal each account && position reading rate
+"""
+from tqdm import tqdm
+from datetime import datetime, timezone, timedelta
+from pandas import DataFrame
+
+from applications import DeNetMysql, PQMySQL, longArticlesMySQL
+
+STATISTICS_PERIOD = 31 * 24 * 60 * 60
+
+
+def filter_outlier_data(group, key='show_view_count'):
+    """
+
+    :param group:
+    :param key:
+    :return:
+    """
+    mean = group[key].mean()
+    std = group[key].std()
+    # 过滤二倍标准差的数据
+    filtered_group = group[(group[key] > mean - 2 * std) & (group[key] < mean + 2 * std)]
+    # 过滤均值倍数大于5的数据
+    new_mean = filtered_group[key].mean()
+    filtered_group = filtered_group[filtered_group[key] < new_mean * 5]
+    return filtered_group
+
+
+def timestamp_to_str(timestamp) -> str:
+    """
+    :param timestamp:
+    """
+    dt_object = datetime.utcfromtimestamp(timestamp).replace(tzinfo=timezone.utc).astimezone()
+    date_string = dt_object.strftime('%Y-%m-%d')
+    return date_string
+
+
+def str_to_timestamp(date_string) -> int:
+    """
+    :param date_string:
+    :return:
+    """
+    date_obj = datetime.strptime(date_string, '%Y-%m-%d')
+
+    # 使用timestamp()方法将datetime对象转换为时间戳
+    timestamp = date_obj.timestamp()
+    return timestamp
+
+
+def get_account_fans_by_dt(db_client) -> dict:
+    """
+    获取每个账号发粉丝，通过日期来区分
+    :return:
+    """
+    sql = f"""
+        SELECT 
+            t1.date_str, 
+            t1.fans_count, 
+            t2.gh_id
+        FROM datastat_wx t1
+        JOIN publish_account t2 ON t1.account_id = t2.id
+        WHERE 
+            t2.channel = 5 
+        AND t2.status = 1 
+        AND t1.date_str >= '2024-07-01' 
+        ORDER BY t1.date_str;
+    """
+    result = db_client.select(sql)
+    D = {}
+    for line in result:
+        dt = line[0]
+        fans = line[1]
+        gh_id = line[2]
+        if D.get(gh_id):
+            D[gh_id][dt] = fans
+        else:
+            D[gh_id] = {dt: fans}
+    return D
+
+
+def get_publishing_accounts(db_client) -> list[dict]:
+    """
+    获取每日正在发布的账号
+    :return:
+    """
+    sql = f"""
+    SELECT DISTINCT
+        t3.`name`,
+        t3.gh_id,
+        t3.follower_count,
+        t6.account_source_name,
+        t6.mode_type,
+        t6.account_type,
+        t6.`status`
+    FROM
+        publish_plan t1
+        JOIN publish_plan_account t2 ON t1.id = t2.plan_id
+        JOIN publish_account t3 ON t2.account_id = t3.id
+        LEFT JOIN publish_account_wx_type t4 on t3.id = t4.account_id
+        LEFT JOIN wx_statistics_group_source_account t5 on t3.id = t5.account_id
+        LEFT JOIN wx_statistics_group_source t6 on t5.group_source_name = t6.account_source_name
+    WHERE
+        t1.plan_status = 1
+        AND t3.channel = 5
+        AND t3.follower_count > 0
+        GROUP BY t3.id;
+    """
+    account_list = db_client.select(sql)
+    result_list = [
+        {
+            "account_name": i[0],
+            "gh_id": i[1]
+        } for i in account_list
+    ]
+    return result_list
+
+
+def get_account_articles_detail(db_client, gh_id_tuple) -> list[dict]:
+    """
+    get articles details
+    :return:
+    """
+    sql = f"""
+            SELECT 
+                ghId, accountName, updateTime, ItemIndex, show_view_count 
+            FROM 
+                official_articles_v2
+            WHERE 
+                ghId IN {gh_id_tuple} and Type = '9';
+            """
+    result = db_client.select(sql)
+    response_list = [
+        {
+            "ghId": i[0],
+            "accountName": i[1],
+            "updateTime": i[2],
+            "ItemIndex": i[3],
+            "show_view_count": i[4]
+        }
+        for i in result
+    ]
+    return response_list
+
+
+def cal_account_read_rate(gh_id_tuple) -> DataFrame:
+    """
+    计算账号位置的阅读率
+    :return:
+    """
+    pq_db = PQMySQL()
+    de_db = DeNetMysql()
+    response = []
+    fans_dict_each_day = get_account_fans_by_dt(db_client=de_db)
+    account_article_detail = get_account_articles_detail(
+        db_client=pq_db,
+        gh_id_tuple=gh_id_tuple
+    )
+    for line in account_article_detail:
+        gh_id = line['ghId']
+        dt = timestamp_to_str(line['updateTime'])
+        fans = fans_dict_each_day.get(gh_id, {}).get(dt, 0)
+        line['fans'] = fans
+        if fans:
+            line['readRate'] = line['show_view_count'] / fans if fans else 0
+            response.append(line)
+    return DataFrame(response,
+                     columns=['ghId', 'accountName', 'updateTime', 'ItemIndex', 'show_view_count', 'readRate'])
+
+
+def cal_avg_account_read_rate(df, gh_id, index, dt) -> tuple:
+    """
+    计算账号的阅读率均值
+    :return:
+    """
+    max_time = str_to_timestamp(dt)
+    min_time = max_time - STATISTICS_PERIOD
+
+    filterDataFrame = df[
+        (df["ghId"] == gh_id)
+        & (min_time <= df["updateTime"])
+        & (df["updateTime"] <= max_time)
+        & (df['ItemIndex'] == index)
+        ]
+    finalDF = filter_outlier_data(filterDataFrame)
+    return (
+        finalDF['readRate'].mean(),
+        finalDF['updateTime'].max(),
+        finalDF['updateTime'].min(),
+        len(finalDF)
+    )
+
+
+def update_single_day(dt, account_list, article_df, lam):
+    """
+    更新单天数据
+    :param article_df:
+    :param lam:
+    :param account_list:
+    :param dt:
+    :return:
+    """
+    index_list = [1, 2, 3, 4, 5, 6, 7, 8]
+    for account in tqdm(account_list):
+        for index in index_list:
+            avg_rate, max_time, min_time, a_count = cal_avg_account_read_rate(article_df, account['gh_id'], index, dt)
+            # print(account['account_name'], "\t", index, "\t", avg_rate, "\t", max_time, "\t", min_time, "\t", a_count,
+            #       "\t", account['gh_id'])
+            try:
+                if avg_rate == 0:
+                    continue
+                insert_sql = f"""
+                    INSERT INTO long_articles_read_rate_dev
+                    (account_name, gh_id, position, read_rate_avg, remark, articles_count, earliest_publish_time, latest_publish_time, dt_version, is_delete)
+                    values
+                    (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s);
+                """
+                lam.update(
+                    sql=insert_sql,
+                    params=(
+                        account['account_name'],
+                        account['gh_id'],
+                        index,
+                        avg_rate,
+                        "从 {} 开始往前计算 31  天".format(dt),
+                        a_count,
+                        timestamp_to_str(min_time),
+                        timestamp_to_str(max_time),
+                        dt.replace("-", ""),
+                        0
+                    )
+                )
+            except Exception as e:
+                print(e)
+
+
+def main() -> None:
+    """
+    main function
+    :return:
+    """
+    lam = longArticlesMySQL()
+    de = DeNetMysql()
+    # dt = '2024-10-22'
+    account_list = get_publishing_accounts(db_client=de)
+    # 获取这些账号所有的文章
+    df = cal_account_read_rate(tuple([i['gh_id'] for i in account_list]))
+    start_dt = start_date = datetime(2024, 8, 1)
+    end_date = datetime(2024, 10, 22)
+    # 计算日期差
+    delta = end_date - start_date
+    # 生成日期字符串列表
+    date_strings = []
+    for i in range(delta.days + 1):
+        date_strings.append((start_date + timedelta(days=i)).strftime('%Y-%m-%d'))
+
+    # 打印结果
+    date_str = '2024-09-11'
+    date_strings = [date_str,]
+    for date_str in tqdm(date_strings):
+        update_single_day(date_str, account_list, df, lam)
+
+
+if __name__ == '__main__':
+    main()

updateAccountV3.py

@@ -21,6 +21,36 @@ TOULIU_ACCOUNTS = {
 ARTICLES_DAILY = 1
 TOULIU = 2
 
+def get_account_fans_by_dt(db_client) -> dict:
+    """
+    获取每个账号发粉丝，通过日期来区分
+    :return:
+    """
+    sql = f"""
+        SELECT 
+            t1.date_str, 
+            t1.fans_count, 
+            t2.gh_id
+        FROM datastat_wx t1
+        JOIN publish_account t2 ON t1.account_id = t2.id
+        WHERE 
+            t2.channel = 5 
+        AND t2.status = 1 
+        AND t1.date_str >= '2024-09-01' 
+        ORDER BY t1.date_str;
+    """
+    result = db_client.select(sql)
+    D = {}
+    for line in result:
+        dt = line[0]
+        fans = line[1]
+        gh_id = line[2]
+        if D.get(gh_id):
+            D[gh_id][dt] = fans
+        else:
+            D[gh_id] = {dt: fans}
+    return D
+
 
 class UpdateAccountInfoVersion3(object):
     """
@@ -32,18 +62,20 @@ class UpdateAccountInfoVersion3(object):
         self.de = DeNetMysql()
         self.lam = longArticlesMySQL()
 
-    def get_account_position_read_rate(self):
+    def get_account_position_read_rate(self, dt):
         """
         从长文数据库获取账号阅读均值
         :return:
         """
+        dt = int(dt.replace("-", ""))
         sql = f"""
             SELECT 
                 gh_id, position, read_rate_avg
             FROM
                 long_articles_read_rate
-            WHERE is_delete = 0;
+            WHERE dt_version = {dt};
         """
+
         result = self.lam.select(sql)
         account_read_rate_dict = {}
         for item in result:
@@ -98,17 +130,19 @@ class UpdateAccountInfoVersion3(object):
         """
         do it
         """
+        fans_dict = get_account_fans_by_dt(db_client=self.de)
         account_list = self.get_publishing_accounts()
-        rate_dict = self.get_account_position_read_rate()
+        rate_dict = self.get_account_position_read_rate(dt)
         for account in tqdm(account_list):
             business_type = TOULIU if account['gh_id'] in TOULIU_ACCOUNTS else ARTICLES_DAILY
-            fans = account['fans']
+            fans = fans_dict.get(account['gh_id'], {}).get(dt, 0)
             if fans:
                 for index in range(1, 9):
                     gh_id_position = "{}_{}".format(account['gh_id'], index)
                     if rate_dict.get(gh_id_position):
                         rate = rate_dict[gh_id_position]
                         read_avg = fans * rate
+                        print(rate, read_avg)
                         insert_sql = f"""
                         INSERT INTO account_avg_info_v3
                         (gh_id, position, update_time, account_name, fans, read_avg, like_avg, status, account_type, account_mode, account_source, account_status, business_type, read_rate_avg)
@@ -138,32 +172,32 @@ class UpdateAccountInfoVersion3(object):
                         except Exception as e:
                             updateSQL = f"""
                             UPDATE account_avg_info_v3
-                            set fans = %s, read_avg = %s
+                            set fans = %s, read_avg = %s, read_rate_avg = %s
                             where gh_id = %s and position = %s and update_time = %s
                             """
                             try:
-                                self.pq.update(
+                                affected_rows = self.pq.update(
                                     sql=updateSQL,
                                     params=(
                                         fans,
                                         read_avg,
+                                        rate,
                                         account['gh_id'],
                                         index,
                                         dt
                                     )
                                 )
-                                print("update success")
                             except Exception as e:
                                 print(e)
 
                         # 修改前一天的状态为 0
-                        uuu_sql = f"""
+                        update_status_sql = f"""
                         UPDATE account_avg_info_v3
                         SET status = %s
                         where update_time != %s and gh_id = %s and position = %s;
                         """
-                        self.pq.update(
-                            sql=uuu_sql,
+                        rows_affected = self.pq.update(
+                            sql=update_status_sql,
                             params=(
                                 0, dt, account['gh_id'], index
                             )