账号联想测试

updatePublishedMsgDaily.py

@@ -422,12 +422,12 @@ def get_article_detail_job(db_client: DatabaseConnector):
     update_sql = f"""
         UPDATE {ARTICLE_TABLE} oav 
         JOIN (
-            SELECT appMsgId, MAX(publish_timestamp) AS publish_timestamp 
+            SELECT ghId, appMsgId, MAX(publish_timestamp) AS publish_timestamp 
             FROM {ARTICLE_TABLE} 
             WHERE publish_timestamp > %s 
             GROUP BY appMsgId
             ) vv 
-            ON oav.appMsgId = vv.appMsgId
+            ON oav.appMsgId = vv.appMsgId AND oav.ghId = vv.ghId
         SET oav.publish_timestamp = vv.publish_timestamp
         WHERE oav.publish_timestamp <= %s;
     """