#!/home/agentuser/project/we-mp-rss-main源文件/we-mp-rss-main/venv/bin/python3
"""检查 we-mp-rss 登录状态，异常时发企微群通知"""
import redis
import requests
import json
import sys
from datetime import datetime

WEBHOOK = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=d4de64e1-efaa-4f03-a833-ad85c1d6de5b"

r = redis.from_url("redis://localhost:6379", decode_responses=True)
login_status = r.get("werss:login:status")
logged_in = login_status == "1"

now = datetime.now().strftime("%Y-%m-%d %H:%M")

result = {"logged_in": logged_in, "time": now}

if logged_in:
    result["status"] = "✅ 已登录"
    print(json.dumps(result))
    sys.exit(0)

# 登录过期 → 发企微通知
msg = {
    "msgtype": "markdown",
    "markdown": {
        "content": f"""## ⚠️ we-mp-rss 登录已过期
> 检测时间：{now}
> 状态：需重新扫码

今日文章可能无法自动抓取。

👉 [点击登录](https://rss.gdcjgk.net) → admin/admin → 授权登录扫码"""
    }
}

try:
    resp = requests.post(WEBHOOK, json=msg, timeout=10)
    print(f"Webhook sent: {resp.json()}")
except Exception as e:
    print(f"Webhook failed: {e}")

result["status"] = "❌ 未登录，已发企微通知"
print(json.dumps(result))
sys.exit(1)