|
|
@@ -547,6 +547,35 @@ def get_article_detail_job():
|
|
|
print(e)
|
|
|
error_msg = traceback.format_exc()
|
|
|
print(error_msg)
|
|
|
+ # check 一遍存在请求失败-1 && 0 的文章
|
|
|
+ process_failed_articles = get_articles(db_client)
|
|
|
+ if process_failed_articles:
|
|
|
+ for article in tqdm(process_failed_articles):
|
|
|
+ try:
|
|
|
+ update_publish_timestamp(db_client=db_client, row=article)
|
|
|
+ except Exception as e:
|
|
|
+ print(e)
|
|
|
+ error_msg = traceback.format_exc()
|
|
|
+ print(error_msg)
|
|
|
+
|
|
|
+ # 通过msgId 来修改publish_time_stamp
|
|
|
+ update_sql = f"""
|
|
|
+ UPDATE official_articles_v2 oav
|
|
|
+ JOIN (
|
|
|
+ SELECT appMsgId, MAX(publish_timestamp) AS publish_timestamp
|
|
|
+ FROM official_articles_v2
|
|
|
+ WHERE publish_timestamp > %s
|
|
|
+ GROUP BY appMsgId
|
|
|
+ ) vv
|
|
|
+ ON oav.appMsgId = vv.appMsgId
|
|
|
+ SET oav.publish_timestamp = vv.publish_timestamp
|
|
|
+ WHERE oav.publish_timestamp <= %s;
|
|
|
+ """
|
|
|
+ affected_rows = db_client.update(
|
|
|
+ sql=update_sql,
|
|
|
+ params=(0, 0)
|
|
|
+ )
|
|
|
+ print(affected_rows)
|
|
|
|
|
|
|
|
|
def main():
|
