2025-06-13服务号数据统计

fwh_data_manager.py

@@ -0,0 +1,12 @@
+from tasks.data_tasks.fwh_data_recycle import FwhGroupPublishRecordManager
+from tasks.data_tasks.fwh_data_recycle import SaveFwhDataToDatabase
+
+
+if __name__ == '__main__':
+    # 1. 从 aigc 获取数据
+    fwh_group_publish_record_manager = FwhGroupPublishRecordManager()
+    fwh_group_publish_record_manager.deal()
+
+    # 2. 保存数据到数据库
+    save_fwh_data_to_database = SaveFwhDataToDatabase()
+    save_fwh_data_to_database.deal()

sh/run_fwh_data_manager.sh

@@ -0,0 +1,26 @@
+#!/bin/bash
+
+# 获取当前日期，格式为 YYYY-MM-DD
+CURRENT_DATE=$(date +%F)
+
+# 日志文件路径，包含日期
+LOG_FILE="/root/luojunhui/logs/fwh_data_manage_task_log_$CURRENT_DATE.txt"
+
+# 重定向整个脚本的输出到带日期的日志文件
+exec >> "$LOG_FILE" 2>&1
+if pgrep -f "python3 fwh_data_manager.py" > /dev/null
+then
+    echo "$(date '+%Y-%m-%d %H:%M:%S') - fwh_data_manager.py is running"
+else
+    echo "$(date '+%Y-%m-%d %H:%M:%S') - trying to restart fwh_data_manager.py"
+    # 切换到指定目录
+    cd /root/luojunhui/LongArticlesJob
+
+    # 激活 Conda 环境
+    source /root/miniconda3/etc/profile.d/conda.sh
+    conda activate tasks
+
+    # 在后台运行 Python 脚本并重定向日志输出
+    nohup python3 fwh_data_manager.py >> "${LOG_FILE}" 2>&1 &
+    echo "$(date '+%Y-%m-%d %H:%M:%S') - successfully restarted fwh_data_manager.py"
+fi

tasks/data_tasks/fwh_data_recycle.py

@@ -138,6 +138,9 @@ class SaveFwhDataToDatabase(FwhDataRecycle):
         """
         update article read cnt
         """
+        if new_read_cnt <= 0:
+            return 0
+
         update_query = f"""
             update official_articles_v2
             set show_view_count = %s