Agent-06 预警监控与报告推送

# APScheduler配置
scheduler.add_job(
    func='report_tasks:daily_business_report',
    trigger=CronTrigger(hour=8, minute=0),
    id='daily_business_report',
    name='每日经营日报'
)

scheduler.add_job(
    func='report_tasks:weekly_summary_report',
    trigger=CronTrigger(day_of_week='mon', hour=9, minute=0),
    id='weekly_summary_report',
    name='周报-经营汇总'
)

class WeChatWorkAdapter:
    async def send(self, message, recipients):
        payload = {
            "msgtype": "markdown",
            "markdown": {"content": message['content']}
        }
        async with aiohttp.ClientSession() as session:
            async with session.post(self.webhook_url, json=payload) as resp:
                return resp.status == 200

class DingTalkAdapter:
    async def send(self, message, recipients):
        import hmac, hashlib, base64, time, urllib.parse
        timestamp = str(int(time.time() * 1000))
        secret_enc = self.secret.encode('utf-8')
        string_to_sign = f'{timestamp}\n{self.secret}'
        sign = urllib.parse.quote_plus(base64.b64encode(
            hmac.new(secret_enc, string_to_sign.encode('utf-8'), digestmod=hashlib.sha256).digest()
        ).decode('utf-8'))
        url = f"{self.webhook_url}&timestamp={timestamp}&sign={sign}"
        async with aiohttp.ClientSession() as session:
            async with session.post(url, json={"msgtype": "markdown", "markdown": {"text": message['content']}}) as resp:
                return resp.status == 200