xng_zh_job.py 700 B

12345678910111213141516171819202122232425262728
  1. import schedule
  2. import time
  3. from common import MysqlHelper, Feishu
  4. def select_xng_uid_count():
  5. sql = """SELECT COUNT(0) FROM xng_uid WHERE DATE(data_time) = CURDATE();"""
  6. data = MysqlHelper.get_values(sql)
  7. return data
  8. def fs_bot():
  9. count = select_xng_uid_count()
  10. value = int(count[0][0])
  11. text = (
  12. f"**今日小年糕账号入库量**: {value} 条\n"
  13. )
  14. Feishu.finish_bot(text, "https://open.feishu.cn/open-apis/bot/v2/hook/d4862d7e-c97d-456a-85ac-763301c0d958",
  15. "【 小年糕入库数量每日通知 】")
  16. # 每天上午十一点
  17. schedule.every().day.at("11:00").do(fs_bot)
  18. while True:
  19. schedule.run_pending()
  20. time.sleep(1)