bug fix

applications/tasks/data_recycle_tasks/recycle_daily_publish_articles.py

@@ -363,7 +363,7 @@ class UpdateRootSourceIdAndUpdateTimeTask(Const):
             set oav.publish_timestamp = vv.publish_timestamp
             where oav.publish_timestamp <= %s;
         """
-        await self.pool.async_save(query=update_sql, params=(0, 0), db_name="piaoquan_crawler")
+        affected_rows_1 = await self.pool.async_save(query=update_sql, params=(0, 0), db_name="piaoquan_crawler")
 
         # 若还是无 publish_timestamp，用update_time当作 publish_timestamp
         update_sql_2 = f"""
@@ -371,7 +371,16 @@ class UpdateRootSourceIdAndUpdateTimeTask(Const):
             set publish_timestamp = updateTime
             where publish_timestamp < %s;
         """
-        await self.pool.async_save(query=update_sql_2, params=0)
+        affected_rows_2 = await self.pool.async_save(query=update_sql_2, params=0)
+        if affected_rows_1 or affected_rows_2:
+            await feishu_robot.bot(
+                title="执行兜底修改发布时间戳",
+                detail={
+                    "通过msgId修改": affected_rows_1,
+                    "通过update_timestamp修改": affected_rows_2
+                },
+                mention=False
+            )
 
     async def deal(self):
         task_list = await self.get_article_list()