save-daily-rank-log

app/api/service/daily_rank_manager.py

@@ -11,6 +11,7 @@ class DailyRankManagerUtils:
         "flow_ctl_decrease_score": 1.0,
         "i2i_recommend_score": 1.0,
         "view_count_rate_score": 1.0,
+        "view_count_rate_v2_score": 1.0,
         "his_fission_open_rate_score": 1.0,
         "crawler_days_decrease_score": 1.0,
         "crawler_days_decrease_v2_score": 1.0,
@@ -100,7 +101,7 @@ class DailyRankManager(DailyRankManagerUtils):
                 content_pool_type, strategy, title, score, category,
                 account_user_category_score, category_score,
                 flow_ctl_decrease_score, i2i_recommend_score,
-                view_count_rate_score, his_fission_open_rate_score,
+                view_count_rate_score, view_count_rate_v2_score, his_fission_open_rate_score,
                 crawler_days_decrease_score, crawler_days_decrease_v2_score, similarity_score,
                 publish_times_score, source_log,
                 create_timestamp, update_timestamp
@@ -128,6 +129,7 @@ class DailyRankManager(DailyRankManagerUtils):
             "flow_ctl_decrease_score",
             "i2i_recommend_score",
             "view_count_rate_score",
+            "view_count_rate_v2_score",
             "his_fission_open_rate_score",
             "crawler_days_decrease_score",
             "crawler_days_decrease_v2_score",

app/domains/monitor_tasks/rank_log_monitor/_const.py

@@ -8,7 +8,8 @@ class RankLogMonitorConst:
         "CategoryStrategy": "category_score",
         "FlowCtlDecreaseStrategy": "flow_ctl_decrease_score",
         "I2IRecommendStrategy": "i2i_recommend_score",
-        "ViewCountRateV2Strategy": "view_count_rate_score",
+        "ViewCountRateStrategy": "view_count_rate_score",
+        "ViewCountRateV2Strategy": "view_count_rate_v2_score",
         "HisFissionOpenRateStrategy": "his_fission_open_rate_score",
         "CrawlerDaysDecreaseStrategy": "crawler_days_decrease_score",
         "CrawlerDaysDecreaseV2Strategy": "crawler_days_decrease_v2_score",
@@ -21,6 +22,7 @@ class RankLogMonitorConst:
         "flow_ctl_decrease_score",
         "i2i_recommend_score",
         "view_count_rate_score",
+        "view_count_rate_v2_score",
         "his_fission_open_rate_score",
         "crawler_days_decrease_score",
         "crawler_days_decrease_v2_score",
@@ -47,6 +49,7 @@ class RankLogMonitorConst:
         flow_ctl_decrease_score     DOUBLE       NULL COMMENT '流量控制分',
         i2i_recommend_score         DOUBLE       NULL COMMENT 'i2i推荐分',
         view_count_rate_score       DOUBLE       NULL COMMENT '阅读分',
+        view_count_rate_v2_score    DOUBLE       NULL COMMENT '阅读分V2',
         his_fission_open_rate_score DOUBLE       NULL COMMENT '打开裂变分',
         crawler_days_decrease_score DOUBLE       NULL COMMENT '阅读降权分',
         crawler_days_decrease_v2_score DOUBLE   NULL COMMENT '阅读降权分V2',
@@ -64,6 +67,7 @@ class RankLogMonitorConst:
         "ALTER TABLE long_articles_daily_rank ADD COLUMN source_id VARCHAR(64) NULL COMMENT '源内容ID' AFTER gh_id;",
         "ALTER TABLE long_articles_daily_rank ADD COLUMN publish_times_score DOUBLE NULL COMMENT '发布次数分' AFTER similarity_score;",
         "ALTER TABLE long_articles_daily_rank ADD COLUMN crawler_days_decrease_v2_score DOUBLE NULL COMMENT '阅读降权分V2' AFTER crawler_days_decrease_score;",
+        "ALTER TABLE long_articles_daily_rank ADD COLUMN view_count_rate_v2_score DOUBLE NULL COMMENT '阅读分V2' AFTER view_count_rate_score;",
         "ALTER TABLE long_articles_daily_rank ADD UNIQUE KEY uk_date_ghid_sourceid_strategy (rank_date, gh_id, source_id, strategy);",
     ]
 

app/domains/monitor_tasks/rank_log_monitor/_mapper.py

@@ -58,6 +58,7 @@ class RankLogMonitorMapper:
                     row.get("flow_ctl_decrease_score"),
                     row.get("i2i_recommend_score"),
                     row.get("view_count_rate_score"),
+                    row.get("view_count_rate_v2_score"),
                     row.get("his_fission_open_rate_score"),
                     row.get("crawler_days_decrease_score"),
                     row.get("crawler_days_decrease_v2_score"),
@@ -75,11 +76,11 @@ class RankLogMonitorMapper:
                 rank_date, account_name, gh_id, source_id, content_pool_type, strategy,
                 title, score, category,
                 account_user_category_score, category_score, flow_ctl_decrease_score,
-                i2i_recommend_score, view_count_rate_score, his_fission_open_rate_score,
+                i2i_recommend_score, view_count_rate_score, view_count_rate_v2_score, his_fission_open_rate_score,
                 crawler_days_decrease_score, crawler_days_decrease_v2_score, similarity_score, publish_times_score,
                 source_log, create_timestamp, update_timestamp
             )
-            VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
+            VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
             ON DUPLICATE KEY UPDATE
                 score = VALUES(score),
                 title = VALUES(title),
@@ -89,6 +90,7 @@ class RankLogMonitorMapper:
                 flow_ctl_decrease_score = VALUES(flow_ctl_decrease_score),
                 i2i_recommend_score = VALUES(i2i_recommend_score),
                 view_count_rate_score = VALUES(view_count_rate_score),
+                view_count_rate_v2_score = VALUES(view_count_rate_v2_score),
                 his_fission_open_rate_score = VALUES(his_fission_open_rate_score),
                 crawler_days_decrease_score = VALUES(crawler_days_decrease_score),
                 crawler_days_decrease_v2_score = VALUES(crawler_days_decrease_v2_score),