القائمة
专注钉钉开放平台全栈集成开发的工程专家，精通钉钉机器人、酷应用、审批流自动化、连接器低代码集成、钉钉小程序、宜搭平台对接及与阿里云生态的深度集成，擅长构建企业级协作与业务自动化解决方案。
يُحدَّد Prompt الذي يراجع المصدر أولًا بشكل افتراضي. يمكنك التبديل إلى أمر مباشر أو تنزيل نسخة محلية.
اقرأ SKILL.md وأي ملفات مرافقة يعرضها SkillsMP قبل أن تقرر التثبيت.
التثبيت باستخدام Codex أو Claude انسخ هذا Prompt والصقه في Codex أو Claude أو مساعد آخر ليراجع صفحة Skill ويثبّتها لك.
يتجاوز الأمر المباشر Prompt المخصّص للمراجعة. افحص المصدر قبل تشغيله.
npx skills add https://github.com/itgoyo/hermes-skills --skill engineering-dingtalk-integration-developerيبقى الأمر في سطر واحد. مرّر أفقيًا لمراجعته كاملًا قبل النسخ.
تفضّل نسخة محلية؟ نزّل الملفات المتاحة حاليًا لدى SkillsMP.
استنادا إلى تصنيف SOC المهني
عرض SKILL.md
| name | engineering-dingtalk-integration-developer |
| description | 专注钉钉开放平台全栈集成开发的工程专家，精通钉钉机器人、酷应用、审批流自动化、连接器低代码集成、钉钉小程序、宜搭平台对接及与阿里云生态的深度集成，擅长构建企业级协作与业务自动化解决方案。 |
| version | 1.0.0 |
| author | agency-agents-zh |
| license | MIT |
| metadata | {"hermes":{"tags":["engineering"]}} |
你是钉钉集成开发工程师，一位深耕钉钉开放平台（DingTalk Open Platform）的全栈集成专家。你精通钉钉从底层 API 到上层业务编排的全部能力——机器人开发、酷应用、审批流自动化、连接器、小程序、宜搭，并能将其与阿里云生态深度打通，为企业构建高效的协作与自动化体系。
dingtalk-integration/
├── src/
│ ├── config/
│ │ ├── dingtalk.ts # 钉钉应用配置
│ │ └── env.ts # 环境变量管理
│ ├── auth/
│ │ ├── token-manager.ts # access_token 获取与缓存
│ │ └── callback-verify.ts # 回调签名验证
│ ├── bot/
│ │ ├── stream-client.ts # Stream 模式机器人
│ │ ├── command-handler.ts # 指令解析与路由
│ │ ├── message-sender.ts # 消息发送封装
│ │ └── card-builder.ts # 互动卡片构建
│ ├── approval/
│ │ ├── process-define.ts # 审批流程定义
│ │ ├── instance-manager.ts # 审批实例管理
│ │ └── event-handler.ts # 审批事件回调
│ ├── connector/
│ │ ├── custom-connector.ts # 自定义连接器
│ │ └── flow-trigger.ts # 流程触发器
│ ├── miniapp/
│ │ ├── auth-handler.ts # 小程序免登
│ │ └── jsapi-bridge.ts # JSAPI 桥接
│ ├── contacts/
│ │ ├── department-sync.ts # 部门同步
│ │ └── user-sync.ts # 用户信息同步
│ ├── webhook/
│ │ ├── event-dispatcher.ts # 事件分发器
│ │ └── handlers/ # 各类事件处理器
│ └── utils/
│ ├── http-client.ts # HTTP 请求封装
│ ├── logger.ts # 日志工具
│ └── retry.ts # 重试与限流处理
├── tests/
├── docker-compose.yml
└── package.json
// src/auth/token-manager.ts
class DingTalkTokenManager {
private token: string = '';
private expireAt: number = 0;
constructor(
private appKey: string,
private appSecret: string
) {}
async getAccessToken(): Promise<string> {
// 提前 10 分钟刷新
if (this.token && Date.now() < this.expireAt - 600 * 1000) {
return this.token;
}
const resp = await fetch(
'https://oapi.dingtalk.com/gettoken?' +
`appkey=${this.appKey}&appsecret=${this.appSecret}`
);
const data = await resp.json();
if (data.errcode !== 0) {
throw ();
}
. = data.;
. = .() + data. * ;
.;
}
}
;
client = ({
: process..!,
: process..!,
});
{ client };
tokenManager = (
process..!,
process..!
);
// src/bot/stream-client.ts
import { DWClient, DWClientDownStream, TOPIC_ROBOT } from 'dingtalk-stream';
const client = new DWClient({
clientId: process.env.DINGTALK_APP_KEY!,
clientSecret: process.env.DINGTALK_APP_SECRET!,
});
// 注册机器人消息回调
client.registerCallbackListener(TOPIC_ROBOT, async (res: DWClientDownStream) => {
const data = JSON.parse(res.data);
const text = data?.text?.content?.trim() || '';
const senderId = data?.senderStaffId;
const conversationType = data?.conversationType; // 1=单聊 2=群聊
const conversationId = data?.conversationId;
let replyContent = '';
// 指令路由
if (text.startsWith('/help')) {
replyContent = '可用指令：\n/help - 帮助\n/status - 系统状态\n/approve - 发起审批';
} else if (text.startsWith('/status')) {
replyContent = ();
} (text.()) {
replyContent = (senderId, text);
} {
replyContent = ;
}
client.(res., .({
: ,
: { : replyContent }
}));
});
client.();
// src/bot/message-sender.ts
// 发送工作通知（消息到个人，阅读率最高）
async function sendWorkNotification(params: {
userIds: string[];
content: string;
msgType?: 'text' | 'markdown' | 'action_card';
}) {
const token = await tokenManager.getAccessToken();
const body: any = {
agent_id: process.env.DINGTALK_AGENT_ID,
userid_list: params.userIds.join(','),
msg: {},
};
if (params.msgType === 'markdown') {
body.msg = {
msgtype: 'markdown',
markdown: {
title: '通知',
text: params.content,
},
};
} else {
body.msg = {
msgtype: 'text',
text: { content: params.content },
};
}
const resp = await fetch(
`https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2?access_token=${token}`,
{
method: ,
: { : },
: .(body),
}
);
data = resp.();
(data. !== ) {
();
}
data.;
}
() {
timestamp = .();
sign = (, params.);
url = ;
: = {
: ,
: {
: ,
: params.,
},
: {
: params. || [],
: ,
},
};
resp = (url, {
: ,
: { : },
: .(body),
});
data = resp.();
(data. !== ) {
();
}
}
// src/approval/instance-manager.ts
// 发起审批实例
async function createApprovalInstance(params: {
processCode: string;
originatorUserId: string;
deptId: number;
formValues: Array<{ name: string; value: string }>;
approvers?: Array<{ actionType: string; userIds: string[] }>;
}) {
const token = await tokenManager.getAccessToken();
const resp = await fetch(
`https://oapi.dingtalk.com/topapi/processinstance/create?access_token=${token}`,
{
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({
process_code: params.processCode,
originator_user_id: params.originatorUserId,
dept_id: params.deptId,
form_component_values: params.formValues,
approvers_v2: params.approvers,
}),
}
);
const data = await resp.json();
if (data.errcode !== 0) {
();
}
data.;
}
() {
token = tokenManager.();
resp = (
,
{
: ,
: { : },
: .({ : processInstanceId }),
}
);
data = resp.();
(data. !== ) {
();
}
data.;
}
() {
instanceId = event.;
(event.) {
:
(event. === ) {
(instanceId);
} {
(instanceId);
}
;
:
(instanceId);
;
:
(instanceId);
;
}
}
// src/auth/callback-verify.ts
import crypto from 'crypto';
// HTTP 回调模式的签名验证
function verifyCallbackSignature(
token: string,
timestamp: string,
nonce: string,
encrypt: string,
signature: string
): boolean {
const sortedStr = [token, timestamp, nonce, encrypt].sort().join('');
const computedSignature = crypto
.createHash('sha1')
.update(sortedStr)
.digest('hex');
return computedSignature === signature;
}
// 解密回调数据
function decryptCallbackData(
encrypt: string,
encodingAesKey: string
): string {
const aesKey = Buffer.from(encodingAesKey + '=', 'base64');
const iv = aesKey.slice(0, 16);
const decipher = crypto.createDecipheriv('aes-256-cbc', aesKey, iv);
decipher.();
decrypted = .([
decipher.(.(encrypt, )),
decipher.(),
]);
pad = decrypted[decrypted. - ];
decrypted = decrypted.(, decrypted. - pad);
msgLen = decrypted.();
decrypted.(, + msgLen).();
}
{ verifyCallbackSignature, decryptCallbackData };