65 lines
2.1 KiB
Plaintext
65 lines
2.1 KiB
Plaintext
require('dotenv').config({ path: '/opt/guanghulab-dingtalk/dingtalk-bot/.env' });
|
||
var express = require('express');
|
||
var axios = require('axios');
|
||
var app = express();
|
||
var PORT = process.env.PORT || 3007;
|
||
|
||
// 引入路由器（不用 AI 引擎）
|
||
var router = require('./message-router');
|
||
|
||
app.use(require('cors')());
|
||
app.use(require('body-parser').json());
|
||
|
||
// GET验证
|
||
app.get('/dingtalk/callback', (req, res) => {
|
||
console.log('[DingTalk] GET验证请求');
|
||
res.status(200).json({ success: true });
|
||
});
|
||
|
||
// POST接收消息并按分类回复
|
||
app.post('/dingtalk/callback', async (req, res) => {
|
||
console.log('[DingTalk] POST收到消息');
|
||
|
||
res.status(200).json({ success: true });
|
||
|
||
const sessionWebhook = req.body.sessionWebhook;
|
||
const senderNick = req.body.senderNick || '未知用户';
|
||
const text = req.body.text || {};
|
||
const content = text.content || '';
|
||
|
||
if (!sessionWebhook) {
|
||
console.log('[DingTalk] 没有 sessionWebhook，无法回复');
|
||
return;
|
||
}
|
||
|
||
// 调用路由器分类
|
||
const classification = router.classifyMessage(content);
|
||
console.log('[DingTalk] 分类:', classification);
|
||
|
||
// 根据分类生成不同回复
|
||
let replyContent = '';
|
||
if (classification.type === 'syslog') {
|
||
replyContent = `📡 收到 SYSLOG：${classification.broadcastId || '未知编号'}`;
|
||
} else if (classification.type === 'question') {
|
||
replyContent = `❓ 收到问题，秋秋正在思考中...\n\n问题：${content}`;
|
||
} else {
|
||
replyContent = `@${senderNick} 收到你的消息：${content}`;
|
||
}
|
||
|
||
try {
|
||
await axios.post(sessionWebhook, {
|
||
msgtype: 'text',
|
||
text: { content: replyContent }
|
||
});
|
||
console.log('[DingTalk] 回复成功');
|
||
} catch (err) {
|
||
console.error('[DingTalk] 回复失败:', err.message);
|
||
}
|
||
});
|
||
|
||
app.listen(PORT, '0.0.0.0', () => {
|
||
console.log('🚀 服务启动 http://localhost:' + PORT);
|
||
});
|
||
process.stdin.resume();
|
||
process.on('uncaughtException', (err) => { console.error('❌', err.message); });
|