|
@@ -607,53 +607,6 @@ class AutoReplyCardsMonitor(AutoReplyCardsMonitorMapper):
|
|
|
account_detail["gh_id"], account.公众号名
|
|
account_detail["gh_id"], account.公众号名
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
- # # 旧逻辑，考虑账号是否关注
|
|
|
|
|
- # follow_status = account_detail["follow_status"]
|
|
|
|
|
- # match follow_status:
|
|
|
|
|
- # case self.INIT_STATUS:
|
|
|
|
|
- # await self.create_follow_single_account_task(
|
|
|
|
|
- # account_detail["gh_id"]
|
|
|
|
|
- # )
|
|
|
|
|
- #
|
|
|
|
|
- # case self.PROCESSING_STATUS:
|
|
|
|
|
- # fetch_response = await self.fetch_follow_account_status(
|
|
|
|
|
- # account_detail["gh_id"]
|
|
|
|
|
- # )
|
|
|
|
|
- # if not fetch_response:
|
|
|
|
|
- # await self.update_follow_status(
|
|
|
|
|
- # account_detail["gh_id"],
|
|
|
|
|
- # self.PROCESSING_STATUS,
|
|
|
|
|
- # self.INIT_STATUS,
|
|
|
|
|
- # )
|
|
|
|
|
- #
|
|
|
|
|
- # task_status = fetch_response[0]["task_status"]
|
|
|
|
|
- # match task_status:
|
|
|
|
|
- # case self.FETCH_INIT_STATUS:
|
|
|
|
|
- # continue
|
|
|
|
|
- # case self.FETCH_PROCESSING_STATUS:
|
|
|
|
|
- # continue
|
|
|
|
|
- # case self.FETCH_SUCCESS_STATUS:
|
|
|
|
|
- # await self.update_follow_status(
|
|
|
|
|
- # account_detail["gh_id"],
|
|
|
|
|
- # self.PROCESSING_STATUS,
|
|
|
|
|
- # self.SUCCESS_STATUS,
|
|
|
|
|
- # )
|
|
|
|
|
- # case self.FETCH_FAIL_STATUS:
|
|
|
|
|
- # await self.update_follow_status(
|
|
|
|
|
- # account_detail["gh_id"],
|
|
|
|
|
- # self.PROCESSING_STATUS,
|
|
|
|
|
- # self.FAIL_STATUS,
|
|
|
|
|
- # )
|
|
|
|
|
- #
|
|
|
|
|
- # case self.SUCCESS_STATUS:
|
|
|
|
|
- # # 账号已经关注，创建获取自动回复任务
|
|
|
|
|
- # await self.create_auto_reply_single_account_task(
|
|
|
|
|
- # account_detail["gh_id"], account.公众号名
|
|
|
|
|
- # )
|
|
|
|
|
- #
|
|
|
|
|
- # case _:
|
|
|
|
|
- # print(f"{account.公众号名}账号状态异常")
|
|
|
|
|
-
|
|
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
|
print(f"处理账号{account.公众号名}异常", e)
|
|
print(f"处理账号{account.公众号名}异常", e)
|
|
|
|
|
|
luojunhui