# 添加飞书告警渠道；

vapao · vapao · commit 774d10f26da8 · 2026-03-08T22:11:23.000+08:00
# 钉钉支持设置secret；
diff --git a/spug_api/apps/alarm/models.py b/spug_api/apps/alarm/models.py
@@ -15,6 +15,7 @@ class Alarm(models.Model, ModelMixin):
         ('4', '邮件'),
         ('5', '企业微信'),
         ('6', '电话'),
+        ('7', '飞书'),
     )
     STATUS = (
         ('1', '报警发生'),
@@ -71,6 +72,8 @@ class Contact(models.Model, ModelMixin):
     ding = models.CharField(max_length=255, null=True)
     wx_token = models.CharField(max_length=255, null=True)
     qy_wx = models.CharField(max_length=255, null=True)
+    feishu = models.CharField(max_length=255, null=True)
+    secret = models.TextField(null=True)
 
     created_at = models.CharField(max_length=20, default=human_datetime)
     created_by = models.ForeignKey(User, models.PROTECT, related_name='+')
diff --git a/spug_api/apps/alarm/views.py b/spug_api/apps/alarm/views.py
@@ -85,6 +85,8 @@ def post(self, request):
             Argument('ding', required=False),
             Argument('wx_token', required=False),
             Argument('qy_wx', required=False),
+            Argument('feishu', required=False),
+            Argument('secret', required=False),
         ).parse(request.body)
         if error is None:
             if form.id:
@@ -116,9 +118,11 @@ def handle_test(request):
     if error is None:
         notify = Notification(None, '1', 'https://spug.cc', 'Spug官网（测试）', '这是一条测试告警信息', None)
         if form.mode == '3':
-            notify.monitor_by_dd([form.value])
+            notify.monitor_by_dd([(form.value, None)])
         elif form.mode == '4':
             notify.monitor_by_email([form.value])
         elif form.mode == '5':
             notify.monitor_by_qy_wx([form.value])
+        elif form.mode == '7':
+            notify.monitor_by_fs([(form.value, None)])
     return json_response(error=error)
diff --git a/spug_api/libs/spug.py b/spug_api/libs/spug.py
@@ -9,6 +9,27 @@
 from libs.push import push_server
 import requests
 import json
+import time
+import hmac
+import hashlib
+import base64
+from urllib.parse import urlencode
+
+
+def _gen_dd_sign(secret):
+    timestamp = str(int(time.time() * 1000))
+    string_to_sign = f'{timestamp}\n{secret}'
+    hmac_code = hmac.new(secret.encode('utf-8'), string_to_sign.encode('utf-8'), digestmod=hashlib.sha256).digest()
+    sign = base64.b64encode(hmac_code).decode('utf-8')
+    return timestamp, sign
+
+
+def _gen_fs_sign(secret):
+    timestamp = str(int(time.time()))
+    string_to_sign = f'{timestamp}\n{secret}'
+    hmac_code = hmac.new(string_to_sign.encode('utf-8'), b'', digestmod=hashlib.sha256).digest()
+    sign = base64.b64encode(hmac_code).decode('utf-8')
+    return timestamp, sign
 
 
 class Notification:
@@ -87,9 +108,41 @@ def monitor_by_dd(self, users):
                 'isAtAll': True
             }
         }
-        for url in users:
+        for url, secret in users:
+            if secret:
+                timestamp, sign = _gen_dd_sign(secret)
+                url = f'{url}&{urlencode({"timestamp": timestamp, "sign": sign})}'
             self.handle_request(url, data, 'dd')
 
+    def monitor_by_fs(self, users):
+        title = '监控告警通知' if self.event == '1' else '告警恢复通知'
+        content = [
+            [{'tag': 'text', 'text': f'告警名称：{self.title}'}],
+            [{'tag': 'text', 'text': f'告警对象：{self.target}'}],
+            [{'tag': 'text', 'text': f'{"告警" if self.event == "1" else "恢复"}时间：{human_datetime()}'}],
+            [{'tag': 'text', 'text': f'告警描述：{self.message}'}],
+        ]
+        if self.event == '2':
+            content.append([{'tag': 'text', 'text': f'持续时间：{self.duration}'}])
+        content.append([{'tag': 'text', 'text': '来自 Spug运维平台'}])
+        for url, secret in users:
+            data = {
+                'msg_type': 'post',
+                'content': {
+                    'post': {
+                        'zh_cn': {
+                            'title': title,
+                            'content': content
+                        }
+                    }
+                }
+            }
+            if secret:
+                timestamp, sign = _gen_fs_sign(secret)
+                data['timestamp'] = timestamp
+                data['sign'] = sign
+            self.handle_request(url, data, 'fs')
+
     def monitor_by_qy_wx(self, users):
         color, title = ('warning', '监控告警通知') if self.event == '1' else ('info', '告警恢复通知')
         texts = [
@@ -149,7 +202,13 @@ def dispatch_monitor(self, modes):
                 sms_ids = set(x for x in push_ids if x.startswith('sms_'))
                 targets.update(sms_ids)
             elif mode == '3':
-                users = set(x.ding for x in Contact.objects.filter(id__in=u_ids, ding__isnull=False))
+                contacts = Contact.objects.filter(id__in=u_ids, ding__isnull=False)
+                users = []
+                for c in contacts:
+                    sec = None
+                    if c.secret:
+                        sec = json.loads(c.secret).get('ding')
+                    users.append((c.ding, sec))
                 if not users:
                     Notify.make_monitor_notify(
                         '发送报警信息失败',
@@ -181,6 +240,21 @@ def dispatch_monitor(self, modes):
             elif mode == '6':
                 voice_ids = set(x for x in push_ids if x.startswith('voice_'))
                 targets.update(voice_ids)
+            elif mode == '7':
+                contacts = Contact.objects.filter(id__in=u_ids, feishu__isnull=False)
+                users = []
+                for c in contacts:
+                    sec = None
+                    if c.secret:
+                        sec = json.loads(c.secret).get('feishu')
+                    users.append((c.feishu, sec))
+                if not users:
+                    Notify.make_monitor_notify(
+                        '发送报警信息失败',
+                        '未找到可用的通知对象，请确保设置了相关报警联系人的飞书。'
+                    )
+                    continue
+                self.monitor_by_fs(users)
 
         if targets:
             self.monitor_by_spug_push(targets)
diff --git a/spug_web/src/pages/alarm/contact/Form.js b/spug_web/src/pages/alarm/contact/Form.js
@@ -3,22 +3,82 @@
  * Copyright (c) <spug.dev@gmail.com>
  * Released under the AGPL-3.0 License.
  */
-import React, { useState } from 'react';
+import React, { useState, useMemo } from 'react';
 import { observer } from 'mobx-react';
-import { Modal, Form, Input, Tooltip, message } from 'antd';
+import { Modal, Form, Input, Tooltip, Checkbox, Divider, message } from 'antd';
 import { ThunderboltOutlined, LoadingOutlined } from '@ant-design/icons';
 import http from 'libs/http';
 import store from './store';
 
+const channelConfig = [
+  {
+    key: 'email',
+    label: '邮箱',
+    fields: [
+      { name: 'email', label: '邮箱地址', placeholder: '请输入邮箱地址', testMode: '4' }
+    ]
+  },
+  {
+    key: 'ding',
+    label: '钉钉',
+    fields: [
+      { name: 'ding', label: 'Webhook', placeholder: 'https://oapi.dingtalk.com/robot/send?access_token=xxx', testMode: '3' },
+      { name: 'ding_secret', label: 'Secret', placeholder: 'SECxxxxxxxx', extra: '可选，机器人安全设置中的加签密钥' }
+    ],
+    help: { text: '钉钉收不到通知？请参考', link: 'https://ops.spug.cc/docs/use-problem#use-dd', linkText: '官方文档' }
+  },
+  {
+    key: 'feishu',
+    label: '飞书',
+    fields: [
+      { name: 'feishu', label: 'Webhook', placeholder: 'https://open.feishu.cn/open-apis/bot/v2/hook/xxx', testMode: '7' },
+      { name: 'feishu_secret', label: 'Secret', placeholder: 'xxxxxxxx', extra: '可选，机器人安全设置中的签名校验密钥' }
+    ]
+  },
+  {
+    key: 'qy_wx',
+    label: '企业微信',
+    fields: [
+      { name: 'qy_wx', label: 'Webhook', placeholder: 'https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=xxx', testMode: '5' }
+    ]
+  }
+];
+
 export default observer(function () {
   const [form] = Form.useForm();
   const [loading, setLoading] = useState(false);
   const [testLoading, setTestLoading] = useState('0');
 
+  const initialChannels = useMemo(() => ({
+    email: !!store.record.email,
+    ding: !!store.record.ding,
+    feishu: !!store.record.feishu,
+    qy_wx: !!store.record.qy_wx,
+  }), []);
+
+  const [channels, setChannels] = useState(initialChannels);
+
+  function handleChannelToggle(key, checked) {
+    setChannels(prev => ({ ...prev, [key]: checked }));
+    if (!checked) {
+      const channel = channelConfig.find(c => c.key === key);
+      if (channel) {
+        const resetFields = channel.fields.map(f => f.name);
+        form.resetFields(resetFields);
+      }
+    }
+  }
+
   function handleSubmit() {
     setLoading(true);
     const formData = form.getFieldsValue();
     formData['id'] = store.record.id;
+    const secret = {};
+    if (formData.ding_secret) secret.ding = formData.ding_secret;
+    if (formData.feishu_secret) secret.feishu = formData.feishu_secret;
+    delete formData.ding_secret;
+    delete formData.feishu_secret;
+    formData.secret = Object.keys(secret).length ? JSON.stringify(secret) : null;
     http.post('/api/alarm/contact/', formData)
       .then(res => {
         message.success('操作成功');
@@ -39,19 +99,15 @@ export default observer(function () {
   }
 
   function Test(props) {
-    return (
-      <div style={{position: 'absolute', right: -30, top: 8}}>
-        {testLoading === props.mode ? (
-          <LoadingOutlined style={{fontSize: 18, color: '#faad14'}}/>
-        ) : (
-          <Tooltip title="执行测试">
-            <ThunderboltOutlined
-              style={{fontSize: 18, color: '#faad14'}}
-              onClick={() => handleTest(props.mode, props.name)}/>
-          </Tooltip>
-        )}
-      </div>
-    )
+    return testLoading === props.mode ? (
+      <LoadingOutlined style={{fontSize: 16, color: '#faad14'}}/>
+    ) : (
+      <Tooltip title="执行测试">
+        <ThunderboltOutlined
+          style={{fontSize: 16, color: '#faad14', cursor: 'pointer'}}
+          onClick={() => handleTest(props.mode, props.name)}/>
+      </Tooltip>
+    );
   }
 
   return (
@@ -63,36 +119,47 @@ export default observer(function () {
       onCancel={() => store.formVisible = false}
       confirmLoading={loading}
       onOk={handleSubmit}>
-      <Form form={form} initialValues={store.record} labelCol={{span: 6}} wrapperCol={{span: 14}}>
+      <Form form={form} initialValues={{
+        ...store.record,
+        ding_secret: store.record.secret ? JSON.parse(store.record.secret).ding : undefined,
+        feishu_secret: store.record.secret ? JSON.parse(store.record.secret).feishu : undefined,
+      }} labelCol={{span: 6}} wrapperCol={{span: 14}}>
         <Form.Item required name="name" label="姓名">
           <Input placeholder="请输入联系人姓名"/>
         </Form.Item>
         <Form.Item name="phone" label="手机号">
           <Input placeholder="请输入手机号"/>
         </Form.Item>
-        <Form.Item label="邮箱">
-          <Form.Item noStyle name="email">
-            <Input placeholder="请输入邮箱地址"/>
-          </Form.Item>
-          <Test mode="4" name="email"/>
-        </Form.Item>
-        <Form.Item label="钉钉" extra={<span>
-            钉钉收不到通知？请参考
-            <a target="_blank" rel="noopener noreferrer"
-               href="https://ops.spug.cc/docs/use-problem#use-dd">官方文档</a>
-          </span>}>
-          <Form.Item noStyle name="ding">
-            <Input placeholder="https://oapi.dingtalk.com/robot/send?access_token=xxx"/>
-          </Form.Item>
-          <Test mode="3" name="ding"/>
-        </Form.Item>
-        <Form.Item label="企业微信">
-          <Form.Item noStyle name="qy_wx">
-            <Input placeholder="https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=xxx"/>
-          </Form.Item>
-          <Test mode="5" name="qy_wx"/>
-        </Form.Item>
+        <Divider orientation="left" style={{margin: '8px 0 16px'}}>通知渠道</Divider>
+        {channelConfig.map(channel => (
+          <div key={channel.key} style={{marginBottom: channels[channel.key] ? 16 : 4}}>
+            <Form.Item wrapperCol={{offset: 6, span: 14}} style={{marginBottom: 0}}>
+              <Checkbox
+                checked={channels[channel.key]}
+                onChange={e => handleChannelToggle(channel.key, e.target.checked)}
+              >
+                {channel.label}
+              </Checkbox>
+            </Form.Item>
+            {channels[channel.key] && channel.fields.map(field => {
+              const extra = field.extra || (channel.help && field === channel.fields[0] ? (
+                <span>
+                  {channel.help.text}
+                  <a target="_blank" rel="noopener noreferrer" href={channel.help.link}>{channel.help.linkText}</a>
+                </span>
+              ) : undefined);
+              return (
+                <Form.Item key={field.name} name={field.name} label={field.label} extra={extra}>
+                  <Input
+                    placeholder={field.placeholder}
+                    suffix={field.testMode ? <Test mode={field.testMode} name={field.name}/> : <span/>}
+                  />
+                </Form.Item>
+              );
+            })}
+          </div>
+        ))}
       </Form>
     </Modal>
   )
-})
+})
diff --git a/spug_web/src/pages/alarm/contact/Table.js b/spug_web/src/pages/alarm/contact/Table.js
@@ -59,6 +59,7 @@ class ComTable extends React.Component {
         <Table.Column ellipsis hide title="钉钉" dataIndex="ding"/>
         <Table.Column ellipsis hide title="微信" dataIndex="wx_token"/>
         <Table.Column ellipsis hide title="企业微信" dataIndex="qy_wx"/>
+        <Table.Column ellipsis hide title="飞书" dataIndex="feishu"/>
         {hasPermission('alarm.contact.edit|alarm.contact.del') && (
           <Table.Column title="操作" render={info => (
             <Action>
diff --git a/spug_web/src/pages/monitor/Step2.js b/spug_web/src/pages/monitor/Step2.js
@@ -19,6 +19,7 @@ const modeOptions = [
   {label: '邮件', 'value': '4'},
   {label: '钉钉', 'value': '3'},
   {label: '企业微信', 'value': '5'},
+  {label: '飞书', 'value': '7'},
 ];
 
 export default observer(function () {
