import randomfrom datetime import datetimedef fetch_live_data():    """    模拟从接口获取直播间数据    :return: dict    """    data = {        "timestamp": datetime.now(),        "online_count": random.randint(800, 1500),  # 模拟在线人数        "gmv": round(random.uniform(1000, 5000), 2) # 模拟成交额    }    return data

import timeimport pandas as pdimport numpy as np# ========== 配置区 ==========CHECK_INTERVAL = 300  # 5分钟 = 300秒UV_DROP_THRESHOLD = 0.20  # 在线人数下跌20%GMV_ZERO_THRESHOLD = 0    # 成交为0# 用于存储历史数据的全局变量（实际生产中建议存数据库）history_data = []def send_alert(message):    """模拟发送警报（实际可替换为钉钉/邮件）"""    print(f"🚨 警报：{message}")    # 钉钉机器人示例：    # import requests    # webhook = "你的钉钉Webhook地址"    # requests.post(webhook, json={"msgtype": "text", "text": {"content": message}})def monitor_logic(current_data):    """核心监控逻辑"""    history_data.append(current_data)    # 至少需要两个周期的数据才能比较    if len(history_data) < 2:        print(f"[{current_data['timestamp']}] 首次记录，基准数据已建立。")        return    prev_data = history_data[-2]    # 计算环比变化率    uv_change = (current_data['online_count'] - prev_data['online_count']) / prev_data['online_count']    gmv_current = current_data['gmv']    alert_messages = []    # 规则1：在线人数大跌    if uv_change < -UV_DROP_THRESHOLD:        alert_messages.append(f"在线人数骤降！当前:{current_data['online_count']}，环比下跌{abs(uv_change):.2%}")    # 规则2：成交断崖    if gmv_current <= GMV_ZERO_THRESHOLD:        alert_messages.append(f"成交异常！当前5分钟GMV为0")    # 规则3：连续下跌（进阶逻辑）    if len(history_data) >= 3:        uv_prev_change = (prev_data['online_count'] - history_data[-3]['online_count']) / history_data[-3]['online_count']        if uv_change < 0 and uv_prev_change < 0:            total_drop = (current_data['online_count'] - history_data[-3]['online_count']) / history_data[-3]['online_count']            if total_drop < -0.3:                alert_messages.append(f"连续两周期下跌，累计跌幅{abs(total_drop):.2%}")    if alert_messages:        for msg in alert_messages:            send_alert(msg)    else:        print(f"[{current_data['timestamp']}] 数据正常。UV:{current_data['online_count']}, GMV:{current_data['gmv']}")def main():    print("直播间监控系统启动...")    while True:        try:            current_data = fetch_live_data()            monitor_logic(current_data)            # 使用pandas保存数据，方便后续复盘分析            df = pd.DataFrame(history_data)            df.to_excel("live_monitor_log.xlsx", index=False)            time.sleep(CHECK_INTERVAL)        except Exception as e:            print(f"程序出错: {e}")            time.sleep(60)if __name__ == "__main__":    main()

Dim NextRun As Double ' 定义公共变量，存储下次运行时间Sub StartMonitor()    ' 开始监控    Dim Interval As Integer    Interval = 5 ' 间隔分钟数    ' 记录当前数据    Call RecordData    ' 安排下一次运行    NextRun = Now + TimeSerial(0, Interval, 0)    Application.OnTime NextRun, "StartMonitor"End SubSub StopMonitor()    ' 停止监控    On Error Resume Next    Application.OnTime NextRun, "StartMonitor", , False    MsgBox "监控已停止"End Sub

Sub RecordData()    Dim ws As Worksheet    Set ws = ThisWorkbook.Sheets(1)    ' 找到最后一行    Dim lastRow As Long    lastRow = ws.Cells(ws.Rows.Count, 1).End(xlUp).Row + 1    ' 模拟获取数据（实际应用中这里可能是从网页抓取或手动粘贴）    Dim CurrentUV As Long    Dim CurrentGMV As Double    Randomize ' 初始化随机数种子    CurrentUV = Int(Rnd * 700) + 800 ' 800-1500随机数    CurrentGMV = Rnd * 4000 + 1000   ' 1000-5000随机数    ' 写入数据    ws.Cells(lastRow, 1).Value = Now    ws.Cells(lastRow, 2).Value = CurrentUV    ws.Cells(lastRow, 3).Value = Round(CurrentGMV, 2)    ' ===== 异常检测逻辑 =====    Dim AlertMsg As String    AlertMsg = ""    If lastRow > 2 Then        Dim PrevUV As Long, PrevGMV As Double        PrevUV = ws.Cells(lastRow - 1, 2).Value        PrevGMV = ws.Cells(lastRow - 1, 3).Value        ' 计算环比        Dim UvChange As Double        UvChange = (CurrentUV - PrevUV) / PrevUV        ws.Cells(lastRow, 4).Value = Format(UvChange, "0.00%")        ' 规则1：人数下跌20%        If UvChange < -0.2 Then            AlertMsg = AlertMsg & "在线人数暴跌！"        End If        ' 规则2：成交为0        If CurrentGMV <= 0 Then            AlertMsg = AlertMsg & "成交挂零！"        End If        ' 规则3：连续两期下跌        If lastRow > 3 Then            Dim PrevChange As Double            PrevChange = (PrevUV - ws.Cells(lastRow - 2, 2).Value) / ws.Cells(lastRow - 2, 2).Value            If UvChange < 0 And PrevChange < 0 Then                AlertMsg = AlertMsg & "连续下跌趋势！"            End If        End If    End If    ' 输出预警    ws.Cells(lastRow, 5).Value = AlertMsg    ' ===== 触发提醒 =====    If AlertMsg <> "" Then        Call TriggerAlert(AlertMsg)    End IfEnd Sub