完善源码

cants7

[backcolor=rgba(255, 255, 255, 0.06)]我要的是钉钉发信息类，队列发送，自由添加api，api是独立使用的不是都一样群，发送错误可以走固定api发送提示。失败的要本地存储。代码精简，运行速度快，代码不要重复。可以参考我发的代码例子，发送频率为1分钟不超过20条
[backcolor=rgba(255, 255, 255, 0.06)]

  

' ===================== 钉钉消息发送类 =====================
.类名 钉钉消息类
.对象集 公开
' ---- 私有成员 ----
.私有变量 API列表, API配置, , "0"
.私有变量 告警API名称, 文本型
.私有变量 发送队列, 队列
.私有变量 线程运行, 逻辑型
.私有变量 发送计数, 整数型
.私有变量 计数窗口期, 整数型
.私有常量 固定协议头, 文本型 ＝ “Content-Type: application/json;charset=UTF-8”
.私有常量 频率上限, 整数型 ＝ 20
.私有常量 窗口期时长, 整数型 ＝ 60000
' ---- 结构体定义 ----
.自定义数据类型 API配置

数据类型名	公开	备 注
(未定义数据类型名)
成员名	类 型	传址	数组	备 注
名称	文本型
地址	文本型

.自定义数据类型 队列项

数据类型名	公开	备 注
(未定义数据类型名)
成员名	类 型	传址	数组	备 注
内容	文本型
API名称	文本型
序号	整数型

' ---- 初始化 ----

子程序名	返回值类型	公开	备 注
_初始化

计数窗口期 ＝ 取启动时间 ()
' ---- 1. 自由添加独立API ----

子程序名	返回值类型	公开	备 注
添加API	逻辑型
参数名	类 型	参考	可空	数组	备 注
API名称	文本型
API地址	文本型

变量名	类 型	静态	数组	备 注
i	整数型

计次循环首 (取数组成员数 (API列表), i)
如果真 (API列表 [i].名称 ＝ API名称) 返回 (假)
计次循环尾 ()
加入成员 (API列表, { API名称, API地址 })
返回 (真)
' ---- 2. 设置错误告警API ----

子程序名	返回值类型	公开	备 注
设置告警API	逻辑型
参数名	类 型	参考	可空	数组	备 注
API名称	文本型

变量名	类 型	静态	数组	备 注
i	整数型

计次循环首 (取数组成员数 (API列表), i)
如果真 (API列表 [i].名称 ＝ API名称)
告警API名称 ＝ API名称
返回 (真)

计次循环尾 ()
返回 (假)
' ---- 3. 消息入队（核心入口） ----

子程序名	返回值类型	公开	备 注
发送消息	逻辑型
参数名	类 型	参考	可空	数组	备 注
消息内容	文本型
目标API名称	文本型

变量名	类 型	静态	数组	备 注
项	队列项
i	整数型

计次循环首 (取数组成员数 (API列表), i)
如果真 (API列表 [i].名称 ＝ 目标API名称)
项.内容 ＝ 消息内容
项.API名称 ＝ 目标API名称
项.序号 ＝ 取启动时间 ()
发送队列.入列 (项)
如果真 (线程运行 ＝ 假)
线程运行 ＝ 真
线程_启动 (&队列消费线程)
返回 (真)

计次循环尾 ()
返回 (假)
' ---- 4. 队列消费线程（频率控制+发送） ----

子程序名	返回值类型	公开	备 注
队列消费线程	整数型

变量名	类 型	静态	数组	备 注
项	队列项
API地址	文本型
i	整数型

判断循环首 (发送队列.取计数 () ＞ 0)
项 ＝ 发送队列.出列 ()
' 获取API地址
API地址 ＝ “”
计次循环首 (取数组成员数 (API列表), i)
如果真 (API列表 [i].名称 ＝ 项.API名称)
API地址 ＝ API列表 [i].地址
跳出循环 ()

计次循环尾 ()

' 频率控制（1分钟≤20条）
如果真 (取启动时间 () － 计数窗口期 ≥ 窗口期时长)
发送计数 ＝ 0
计数窗口期 ＝ 取启动时间 ()
如果真 (发送计数 ≥ 频率上限)
延迟 (窗口期时长 ��� (取启动时间 () － 计数窗口期))
发送计数 ＝ 0
计数窗口期 ＝ 取启动时间 ()

' 发送消息
发送计数 ＝ 发送计数 ＋ 1
如果真 (核心发信 (项.内容, API地址, 项.序号) ＝ 假)
写失败日志 (项, API地址)
发送错误告警 (项, API地址)

判断循环尾 ()
线程运行 ＝ 假
返回 (0)
' ---- 5. 核心发信（精简高速） ----

子程序名	返回值类型	公开	备 注
核心发信	逻辑型
参数名	类 型	参考	可空	数组	备 注
内容	文本型
地址	文本型
序号	整数型

变量名	类 型	静态	数组	备 注
json	类_json
提交数据	文本型
返回数据	字节集
返回文本	文本型

.静态变量 JSON模板, 文本型
如果真 (JSON模板 ＝ “”)
JSON模板 ＝ “{""msgtype"":""text"",""text"":{""content"":""""},""at"":{""atUserIds"":[],""isAtAll"":false}}”

json.解析 (JSON模板)
json.置属性 (“text.content”, 内容)
提交数据 ＝ json.取数据文本 ()
返回数据 ＝ 网页_访问_对象 (地址, #POST, 提交数据, , , 固定协议头, , , 5000)
返回文本 ＝ 到文本 (编码_转换 (返回数据, #编码_UTF8, #编码_GBK ))
返回 (寻找文本 (返回文本, “errmsg":"ok”, , 假) ≠ -1)
' ---- 6. 失败日志存储 ----

子程序名	返回值类型	公开	备 注
写失败日志
参数名	类 型	参考	可空	数组	备 注
项	队列项
API地址	文本型

变量名	类 型	静态	数组	备 注
日志内容	文本型
日志路径	文本型 ＝ 取运行目录 () ＋ “\ding_fail.log”

日志内容 ＝ “[” ＋ 到文本 (取现行时间 ()) ＋ “] 序号：” ＋ 到文本 (项.序号) ＋ #换行
日志内容 ＝ 日志内容 ＋ “API：” ＋ 项.API名称 ＋ “ | 地址：” ＋ API地址 ＋ #换行
日志内容 ＝ 日志内容 ＋ “内容：” ＋ 项.内容 ＋ #换行 × 2
写到文件 (日志路径, 读入文件 (日志路径) ＋ 到字节集 (日志内容))
' ---- 7. 错误告警发送 ----

子程序名	返回值类型	公开	备 注
发送错误告警
参数名	类 型	参考	可空	数组	备 注
项	队列项
API地址	文本型

变量名	类 型	静态	数组	备 注
告警内容	文本型
告警API地址	文本型
i	整数型

告警API地址 ＝ “”
计次循环首 (取数组成员数 (API列表), i)
如果真 (API列表 [i].名称 ＝ 告警API名称)
告警API地址 ＝ API列表 [i].地址
跳出循环 ()

计次循环尾 ()
如果真 (告警API地址 ＝ “”) 返回 ()
告警内容 ＝ “【钉钉发送失败】” ＋ #换行
告警内容 ＝ 告警内容 ＋ “序号：” ＋ 到文本 (项.序号) ＋ #换行
告警内容 ＝ 告警内容 ＋ “失败API：” ＋ 项.API名称 ＋ #换行
告警内容 ＝ 告警内容 ＋ “失败地址：” ＋ API地址 ＋ #换行
告警内容 ＝ 告警内容 ＋ “消息内容：” ＋ 项.内容
核心发信 (告警内容, 告警API地址, 项.序号)
' ===================== 调用示例 =====================

子程序名	返回值类型	公开	备 注
测试调用

变量名	类 型	静态	数组	备 注
钉钉工具	钉钉消息类

' 1. 初始化类
钉钉工具.创建 ()
' 2. 添加不同群的独立API
钉钉工具.添加API (“订单群”, “https://oapi.dingtalk.com/robot/send?access_token=订单群token”)
钉钉工具.添加API (“运维群”, “https://oapi.dingtalk.com/robot/send?access_token=运维群token”)
' 3. 设置告警API
钉钉工具.设置告警API (“运维群”)
' 4. 发送消息（自动入队+频率控制）
钉钉工具.发送消息 (“订单12345支fu成功”, “订单群”)
钉钉工具.发送消息 (“服务器CPU使用率90%”, “运维群”)

i支持库列表	支持库注释
spec	特殊功能支持库
json	(未知支持库)
internet	互联网支持库
EThread	多线程支持库
dp1	数据操作支持库一

.版本 2<br /> .支持库 spec<br /> .支持库 json<br /> .支持库 internet<br /> .支持库 EThread<br /> .支持库 dp1<br /> <br /> ' ===================== 钉钉消息发送类 =====================<br /> .类名 钉钉消息类<br /> .对象集 公开<br /> <br /> ' ---- 私有成员 ----<br /> .私有变量 API列表, API配置, , "0"<br /> .私有变量 告警API名称, 文本型<br /> .私有变量 发送队列, 队列<br /> .私有变量 线程运行, 逻辑型<br /> .私有变量 发送计数, 整数型<br /> .私有变量 计数窗口期, 整数型<br /> .私有常量 固定协议头, 文本型 ＝ “Content-Type: application/json;charset=UTF-8”<br /> .私有常量 频率上限, 整数型 ＝ 20<br /> .私有常量 窗口期时长, 整数型 ＝ 60000<br /> <br /> ' ---- 结构体定义 ----<br /> .自定义数据类型 API配置<br />     .成员 名称, 文本型<br />     .成员 地址, 文本型<br /> <br /> .自定义数据类型 队列项<br />     .成员 内容, 文本型<br />     .成员 API名称, 文本型<br />     .成员 序号, 整数型<br /> <br /> ' ---- 初始化 ----<br /> .子程序 _初始化, , 公开<br /> 计数窗口期 ＝ 取启动时间 ()<br /> <br /> ' ---- 1. 自由添加独立API ----<br /> .子程序 添加API, 逻辑型, 公开<br /> .参数 API名称, 文本型<br /> .参数 API地址, 文本型<br /> .局部变量 i, 整数型<br /> .计次循环首 (取数组成员数 (API列表), i)<br />     .如果真 (API列表 <i>.名称 ＝ API名称) 返回 (假)<br /> .计次循环尾 ()<br /> 加入成员 (API列表, { API名称, API地址 })<br /> 返回 (真)<br /> <br /> ' ---- 2. 设置错误告警API ----<br /> .子程序 设置告警API, 逻辑型, 公开<br /> .参数 API名称, 文本型<br /> .局部变量 i, 整数型<br /> .计次循环首 (取数组成员数 (API列表), i)<br />     .如果真 (API列表 <i>.名称 ＝ API名称)<br />         告警API名称 ＝ API名称<br />         返回 (真)<br />     .如果真结束<br /> .计次循环尾 ()<br /> 返回 (假)<br /> <br /> ' ---- 3. 消息入队（核心入口） ----<br /> .子程序 发送消息, 逻辑型, 公开<br /> .参数 消息内容, 文本型<br /> .参数 目标API名称, 文本型<br /> .局部变量 项, 队列项<br /> .局部变量 i, 整数型<br /> .计次循环首 (取数组成员数 (API列表), i)<br />     .如果真 (API列表 <i>.名称 ＝ 目标API名称)<br />         项.内容 ＝ 消息内容<br />         项.API名称 ＝ 目标API名称<br />         项.序号 ＝ 取启动时间 ()<br />         发送队列.入列 (项)<br />         .如果真 (线程运行 ＝ 假)<br />             线程运行 ＝ 真<br />             线程_启动 (&队列消费线程)<br />         .如果真结束<br />         返回 (真)<br />     .如果真结束<br /> .计次循环尾 ()<br /> 返回 (假)<br /> <br /> ' ---- 4. 队列消费线程（频率控制+发送） ----<br /> .子程序 队列消费线程, 整数型, 私有<br /> .局部变量 项, 队列项<br /> .局部变量 API地址, 文本型<br /> .局部变量 i, 整数型<br /> <br /> .判断循环首 (发送队列.取计数 () ＞ 0)<br />     项 ＝ 发送队列.出列 ()<br />     ' 获取API地址<br />     API地址 ＝ “”<br />     .计次循环首 (取数组成员数 (API列表), i)<br />         .如果真 (API列表 <i>.名称 ＝ 项.API名称)<br />             API地址 ＝ API列表 <i>.地址<br />             跳出循环 ()<br />         .如果真结束<br />     .计次循环尾 ()<br />     <br />     ' 频率控制（1分钟≤20条）<br />     .如果真 (取启动时间 () － 计数窗口期 ≥ 窗口期时长)<br />         发送计数 ＝ 0<br />         计数窗口期 ＝ 取启动时间 ()<br />     .如果真结束<br />     .如果真 (发送计数 ≥ 频率上限)<br />         延迟 (窗口期时长 － (取启动时间 () － 计数窗口期))<br />         发送计数 ＝ 0<br />         计数窗口期 ＝ 取启动时间 ()<br />     .如果真结束<br />     <br />     ' 发送消息<br />     发送计数 ＝ 发送计数 ＋ 1<br />     .如果真 (核心发信 (项.内容, API地址, 项.序号) ＝ 假)<br />         写失败日志 (项, API地址)<br />         发送错误告警 (项, API地址)<br />     .如果真结束<br /> .判断循环尾 ()<br /> 线程运行 ＝ 假<br /> 返回 (0)<br /> <br /> ' ---- 5. 核心发信（精简高速） ----<br /> .子程序 核心发信, 逻辑型, 私有<br /> .参数 内容, 文本型<br /> .参数 地址, 文本型<br /> .参数 序号, 整数型<br /> .局部变量 json, 类_json<br /> .局部变量 提交数据, 文本型<br /> .局部变量 返回数据, 字节集<br /> .局部变量 返回文本, 文本型<br /> .静态变量 JSON模板, 文本型<br /> <br /> .如果真 (JSON模板 ＝ “”)<br />     JSON模板 ＝ “{""msgtype"":""text"",""text"":{""content"":""""},""at"":{""atUserIds"":[],""isAtAll"":false}}”<br /> .如果真结束<br /> <br /> json.解析 (JSON模板)<br /> json.置属性 (“text.content”, 内容)<br /> 提交数据 ＝ json.取数据文本 ()<br /> 返回数据 ＝ 网页_访问_对象 (地址, #POST, 提交数据, , , 固定协议头, , , 5000)<br /> 返回文本 ＝ 到文本 (编码_转换 (返回数据, #编码_UTF8, #编码_GBK))<br /> 返回 (寻找文本 (返回文本, “errmsg":"ok”, , 假) ≠ -1)<br /> <br /> ' ---- 6. 失败日志存储 ----<br /> .子程序 写失败日志, , 私有<br /> .参数 项, 队列项<br /> .参数 API地址, 文本型<br /> .局部变量 日志内容, 文本型<br /> .局部变量 日志路径, 文本型 ＝ 取运行目录 () ＋ “\ding_fail.log”<br /> <br /> 日志内容 ＝ “[” ＋ 到文本 (取现行时间 ()) ＋ “] 序号：” ＋ 到文本 (项.序号) ＋ #换行<br /> 日志内容 ＝ 日志内容 ＋ “API：” ＋ 项.API名称 ＋ “ | 地址：” ＋ API地址 ＋ #换行<br /> 日志内容 ＝ 日志内容 ＋ “内容：” ＋ 项.内容 ＋ #换行 × 2<br /> 写到文件 (日志路径, 读入文件 (日志路径) ＋ 到字节集 (日志内容))<br /> <br /> ' ---- 7. 错误告警发送 ----<br /> .子程序 发送错误告警, , 私有<br /> .参数 项, 队列项<br /> .参数 API地址, 文本型<br /> .局部变量 告警内容, 文本型<br /> .局部变量 告警API地址, 文本型<br /> .局部变量 i, 整数型<br /> <br /> 告警API地址 ＝ “”<br /> .计次循环首 (取数组成员数 (API列表), i)<br />     .如果真 (API列表 <i>.名称 ＝ 告警API名称)<br />         告警API地址 ＝ API列表 <i>.地址<br />         跳出循环 ()<br />     .如果真结束<br /> .计次循环尾 ()<br /> .如果真 (告警API地址 ＝ “”) 返回 ()<br /> <br /> 告警内容 ＝ “【钉钉发送失败】” ＋ #换行<br /> 告警内容 ＝ 告警内容 ＋ “序号：” ＋ 到文本 (项.序号) ＋ #换行<br /> 告警内容 ＝ 告警内容 ＋ “失败API：” ＋ 项.API名称 ＋ #换行<br /> 告警内容 ＝ 告警内容 ＋ “失败地址：” ＋ API地址 ＋ #换行<br /> 告警内容 ＝ 告警内容 ＋ “消息内容：” ＋ 项.内容<br /> 核心发信 (告警内容, 告警API地址, 项.序号)<br /> <br /> ' ===================== 调用示例 =====================<br /> .子程序 测试调用, , 公开<br /> .局部变量 钉钉工具, 钉钉消息类<br /> <br /> ' 1. 初始化类<br /> 钉钉工具.创建 ()<br /> ' 2. 添加不同群的独立API<br /> 钉钉工具.添加API (“订单群”, “https://oapi.dingtalk.com/robot/send?access_token=订单群token”)<br /> 钉钉工具.添加API (“运维群”, “https://oapi.dingtalk.com/robot/send?access_token=运维群token”)<br /> ' 3. 设置告警API<br /> 钉钉工具.设置告警API (“运维群”)<br /> ' 4. 发送消息（自动入队+频率控制）<br /> 钉钉工具.发送消息 (“订单12345支fu成功”, “订单群”)<br /> 钉钉工具.发送消息 (“服务器CPU使用率90%”, “运维群”)

awqear

z573277679

你这应该属于定制化功能开发需求了。而且你的代码都是错的，没什么参考价值...

可乐cl

你这个需求里真正要拆开的核心就 4 块：

1、API管理
每个API独立保存：名称、地址、启用状态、失败次数、最后发送时间

2、发送队列
入队时只放：消息内容、目标API、时间戳、重试次数
不要把业务逻辑散在各处

3、限速器
你要求 1 分钟不超过 20 条，建议不要每发一条就硬算全局，直接做一个“时间戳队列”，超过窗口期就弹出旧时间

4、失败持久化
失败消息建议写本地文本/数据库，至少记录：内容、目标API、失败原因、时间

你现在这份更像“功能都塞一起了”，后面会越改越乱。我的建议是：
发送类只负责队列调度，
API配置单独管理，
失败记录单独模块。

这样后面加告警API、重试、补发会轻松很多。