飞书记账机器人代码演示

feishu_bot
1
<?php
2
// 配置区（示例值已脱敏）
3
define('APP_ID', 'cli_xxxxxxxxxxxxxxxx');               // 飞书应用 ID
4
define('APP_SECRET', 'xxxxxxxxxxxxxxxxxxxxxxxxxxxx');   // 飞书应用密钥
5
define('APP_TOKEN', 'xxxxxxxxxxxxxxxxxxxxxxxxxxxx');    // 事件校验 Token（可选）
6
define('APP_BTABLE_APP_ID', 'xxxxxxxxxxxxxxxxxxxxxxxx'); // 多维表格 App ID
7
define('TABLE_ID', 'tblxxxxxxxxxxxxxx');                 // 多维表格 Table ID
8
define('LOG_FILE', __DIR__.'/log.txt');                  // 日志文件路径
9
define('DEBUG_MODE', true);                              // 是否开启调试模式
10

11
// 简单写日志函数
12
function log_write($msg) {
13
    if (!DEBUG_MODE) return;
14
    file_put_contents(LOG_FILE, date('Y-m-d H:i:s').' '.$msg.PHP_EOL, FILE_APPEND);
15
}
16

17
// 获取 tenant_access_token
18
function get_token() {
19
    $url = 'https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal/';
20
    $post = json_encode(['app_id'=>APP_ID, 'app_secret'=>APP_SECRET]);
21
    $ch = curl_init($url);
22
    curl_setopt_array($ch, [
23
        CURLOPT_POST => true,
24
        CURLOPT_POSTFIELDS => $post,
25
        CURLOPT_RETURNTRANSFER => true,
26
        CURLOPT_HTTPHEADER => ['Content-Type: application/json'],
27
    ]);
28
    $res = curl_exec($ch);
29
    curl_close($ch);
30
    log_write("token response: $res");
31
    $data = json_decode($res, true);
32
    return $data['tenant_access_token'] ?? '';
33
}
34

35
// 清理文本，去除所有@标签及尾部多余内容，返回纯文本
36
function clean_text($text) {
37
    // 去除飞书的 <at ...>...</at> 标签
38
    $text = preg_replace('/<at[^>]*>.*?<\/at>/s', '', $text);
39
    // 去除尾部类似 @xxx 的残留（例如@_user_1）
40
    $text = preg_replace('/@[\w_-]+$/', '', $text);
41
    // 多余空白变成单空格，且两端去空
42
    $text = trim(preg_replace('/\s+/', ' ', $text));
43
    return $text;
44
}
45

46
// 解析文本，返回字段数组或false
47
function parse_text($text) {
48
    $parts = explode(' ', $text);
49
    if (count($parts) < 4) return false;
50
    return [
51
        '名称' => $parts[0],
52
        '金额' => floatval($parts[1]),
53
        '用途' => $parts[2],
54
        '平台' => $parts[3],
55
    ];
56
}
57

58
// 写入多维表格
59
function write_bitable($token, $fields) {
60
    $url = "https://open.feishu.cn/open-apis/bitable/v1/apps/".APP_BTABLE_APP_ID."/tables/".TABLE_ID."/records";
61
    $post = json_encode(['fields'=>$fields], JSON_UNESCAPED_UNICODE);
62
    $ch = curl_init($url);
63
    curl_setopt_array($ch, [
64
        CURLOPT_POST => true,
65
        CURLOPT_POSTFIELDS => $post,
66
        CURLOPT_RETURNTRANSFER => true,
67
        CURLOPT_HTTPHEADER => [
68
            'Authorization: Bearer '.$token,
69
            'Content-Type: application/json',
70
        ],
71
    ]);
72
    $res = curl_exec($ch);
73
    curl_close($ch);
74
    log_write("bitable response: $res");
75
    return json_decode($res,true);
76
}
77

78
// 回复消息，支持群聊和私聊，引用原消息
79
function reply_msg($token, $chat_id, $root_id, $text) {
80
    $url = 'https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=chat_id';
81
    $post = json_encode([
82
        'receive_id' => $chat_id,
83
        'msg_type' => 'text',
84
        'content' => json_encode(['text' => $text], JSON_UNESCAPED_UNICODE),
85
        'root_id' => $root_id,
86
    ], JSON_UNESCAPED_UNICODE);
87
    $ch = curl_init($url);
88
    curl_setopt_array($ch, [
89
        CURLOPT_POST => true,
90
        CURLOPT_POSTFIELDS => $post,
91
        CURLOPT_RETURNTRANSFER => true,
92
        CURLOPT_HTTPHEADER => [
93
            'Authorization: Bearer '.$token,
94
            'Content-Type: application/json',
95
        ],
96
    ]);
97
    $res = curl_exec($ch);
98
    curl_close($ch);
99
    log_write("reply response: $res");
100
}
101

102
// 主入口
103
$input = file_get_contents('php://input');
104
log_write("raw input: $input");
105

106
$data = json_decode($input, true);
107
if (!$data) {
108
    echo json_encode(['code'=>400, 'msg'=>'Invalid JSON']);
109
    exit;
110
}
111

112
// URL 验证请求
113
if (isset($data['type']) && $data['type'] === 'url_verification') {
114
    echo json_encode(['challenge'=>$data['challenge']]);
115
    exit;
116
}
117

118
// 只处理消息事件
119
if (($data['header']['event_type'] ?? '') === 'im.message.receive_v1') {
120
    $open_id = $data['event']['sender']['sender_id']['open_id'] ?? '';
121
    $chat_id = $data['event']['message']['chat_id'] ?? '';
122
    $message_id = $data['event']['message']['message_id'] ?? '';
123
    $msg_content = $data['event']['message']['content'] ?? '{}';
124
    $msg_arr = json_decode($msg_content, true);
125
    $text_raw = $msg_arr['text'] ?? '';
126

127
    log_write("原始文本: $text_raw");
128

129
    // 清理文本
130
    $text = clean_text($text_raw);
131
    log_write("清理后文本: $text");
132

133
    // 解析
134
    $fields = parse_text($text);
135
    if (!$fields) {
136
        $token = get_token();
137
        reply_msg($token, $chat_id, $message_id, "❗ 格式错误，请输入：名称 金额 用途 平台\n示例：电视 300 设备 京东");
138
        echo json_encode(['code'=>0, 'msg'=>'ok']);
139
        exit;
140
    }
141

142
    // 获取token，写入多维表格
143
    $token = get_token();
144
    $res = write_bitable($token, $fields);
145
    if (($res['code'] ?? 1) === 0) {
146
        reply_msg($token, $chat_id, $message_id, "✅ 记账成功：{$fields['名称']} - {$fields['金额']} 元");
147
    } else {
148
        reply_msg($token, $chat_id, $message_id, "❌ 记账失败：" . ($res['msg'] ?? '未知错误'));
149
    }
150

151
    echo json_encode(['code'=>0, 'msg'=>'ok']);
152
    exit;
153
}
154

155
// 其他事件直接返回ok
156
echo json_encode(['code'=>0, 'msg'=>'ok']);