📚 抖音用户视频更新监控系统#

1
sudo tee /opt/douyin_monitor/douyin_monitor.sh << 'EOF'
2
#!/bin/bash
3
# ========================================
4
# 抖音多用户视频更新监听脚本（防置顶 + 钉钉群机器人推送）
5
# 支持 .env 安全配置 | 使用钉钉群机器人推送通知
6
# ========================================
7

8
# =================== 路径配置 ===================
9
WORK_DIR="/opt/douyin_monitor"
10
USERS_CONF="$WORK_DIR/users.conf"
11
STATE_DIR="$WORK_DIR/state"
12
LOG_FILE="$WORK_DIR/log/monitor.log"
13
ENV_FILE="$WORK_DIR/.env"
14

15
# API 配置
16
API_URL="http://你的服务器IP/api/douyin/web/fetch_user_post_videos"
17
COUNT=10
18

19
# 创建必要目录
20
mkdir -p "$STATE_DIR" "$WORK_DIR/log"
21

22
# =================== 加载环境变量 ===================
23
if [ -f "$ENV_FILE" ]; then
24
    source "$ENV_FILE"
25
else
26
    echo "❌ 错误：环境变量文件未找到 $ENV_FILE" >&2
27
    exit 1
28
fi
29

30
# =================== 日志函数 ===================
31
log() {
32
    echo "[$(date '+%Y-%m-%d %H:%M:%S')] $1" | tee -a "$LOG_FILE"
33
}
34

35
# =================== 推送通知（钉钉群机器人）===================
36
send_notification() {
37
    local title="$1"
38
    local content="$2"
39
    local video_url="$3"
40
    local cover_url="$4"
41
    local webhook_url="https://oapi.dingtalk.com/robot/send?access_token=YOUR_ACCESS_TOKEN"
42
    # local webhook_url="https://oapi.dingtalk.com/robot/send?access_token=YOUR_ACCESS_TOKEN" 替换为你自己的群机器人webhook地址
43

44
    # 构造整体跳转 ActionCard 消息格式
45
    local json_data=$(cat <<EOF
46
{
47
    "msgtype": "actionCard",
48
    "actionCard": {
49
        "title": "$title",
50
        "text": "$content",
51
        "singleTitle": "点击观看",
52
        "singleURL": "$video_url"
53
    }
54
}
55
EOF
56
)
57

58
    # 推送通知
59
    curl -s -X POST "$webhook_url" \
60
        -H "Content-Type: application/json" \
61
        -d "$json_data" \
62
        >> "$LOG_FILE" 2>&1 &
63

64
    log "📤 推送通知至钉钉群机器人"
65
}
66

67
# =================== 检查用户更新 ===================
68
check_user() {
69
    local sec_user_id="$1"
70
    local nickname="$2"
71

72
    log "🔍 检查用户: $nickname (sec_user_id: $sec_user_id)"
73

74
    local response
75
    response=$(curl -s -G \
76
        --data-urlencode "sec_user_id=$sec_user_id" \
77
        --data-urlencode "count=$COUNT" \
78
        "$API_URL")
79

80
    # 检查接口返回
81
    if ! echo "$response" | jq -e '.code == 200' >/dev/null; then
82
        local msg=$(echo "$response" | jq -r '.msg // "未知错误"')
83
        log "❌ 请求失败: $msg"
84
        return 1
85
    fi
86

87
    # 提取非置顶最新视频（按时间倒序）
88
    local latest=$(echo "$response" | jq -r '
89
        .data.aweme_list[]?
90
        | select(.is_top != 1)
91
        | .create_time |= tonumber
92
        | .
93
    ' | jq -s 'sort_by(-.create_time) | .[0] // empty')
94

95
    [ -z "$latest" ] && {
96
        log "⚠️ 未获取到有效视频数据"
97
        return 1
98
    }
99

100
    local new_id=$(echo "$latest" | jq -r '.aweme_id')
101
    local title=$(echo "$latest" | jq -r '.item_title // .desc // "无标题"')
102
    local create_time=$(echo "$latest" | jq -r '.create_time')
103
    local time_str=$(date -d "@$create_time" "+%Y-%m-%d %H:%M:%S")
104
    local cover_url=$(echo "$latest" | jq -r '.cover_original_scale.url_list[0] // ""')
105
    local state_file="$STATE_DIR/${sec_user_id}.txt"
106
    local old_id=$(cat "$state_file" 2>/dev/null || echo "")
107

108
    if [ -z "$old_id" ]; then
109
        log "🆕 首次记录: $new_id"
110
        echo "$new_id" > "$state_file"
111
    elif [ "$new_id" != "$old_id" ]; then
112
        log "🎉 检测到新视频: $new_id"
113

114
        # 构造 ActionCard 消息内容
115
        local message_content="### 新视频发布
116

117
用户：$nickname
118

119
标题：$title
120

121
时间：$time_str
122

123
检测时间：$(date '+%Y-%m-%d %H:%M:%S')"
124

125
        # 如果有封面图，添加到最下面
126
        if [ -n "$cover_url" ]; then
127
            message_content="$message_content
128

129
![视频封面]($cover_url)"
130
        fi
131

132
        send_notification "$nickname 发布新视频" "$message_content" "https://www.douyin.com/video/$new_id" "$cover_url"
133
        echo "$new_id" > "$state_file"
134
    else
135
        log "✅ 无更新"
136
    fi
137
}
138

139
# =================== 主函数 ===================
140
main() {
141
    log "✅ 抖音监控服务已启动（使用钉钉群机器人推送）"
142

143
    while true; do
144
        while IFS='|' read -r sec_user_id nickname || [ -n "$sec_user_id" ]; do
145
            # 跳过空行或注释
146
            [[ -z "$sec_user_id" || "$sec_user_id" =~ ^[[:space:]]*# ]] && continue
147

148
            # 清理空白字符
149
            sec_user_id=$(echo "$sec_user_id" | xargs)
150
            nickname=$(echo "$nickname" | xargs)
151

152
            check_user "$sec_user_id" "$nickname"
153

154
            # 随机延迟 3~8 秒，避免请求过快
155
            sleep $((3 + RANDOM % 6))
156
        done < "$USERS_CONF"
157

158
        # 记录本轮完成并显示等待时间（15~40秒）
159
        local wait_time=$((15 + RANDOM % 26))
160
        log "💤 本轮检测完成，等待 $wait_time 秒后重新检测..."
161
        sleep $wait_time
162
    done
163
}
164

165
# 启动主程序
166
main
167
EOF