feat: 迁移type & 迁移lark接口位置
This commit is contained in:
parent
865308ee31
commit
eb7a821549
22
db/appConfig/index.ts
Normal file
22
db/appConfig/index.ts
Normal file
@ -0,0 +1,22 @@
|
||||
import pbClient from "../pbClient";
|
||||
|
||||
const getAppId = async () => {
|
||||
const { value } = await pbClient
|
||||
.collection("config")
|
||||
.getOne("iscqaiwe0bnp8ej");
|
||||
return value as string;
|
||||
};
|
||||
|
||||
const getAppSecret = async () => {
|
||||
const { value } = await pbClient
|
||||
.collection("config")
|
||||
.getOne("9kyiw5mv8unia49");
|
||||
return value as string;
|
||||
};
|
||||
|
||||
const appConfig = {
|
||||
getAppId,
|
||||
getAppSecret,
|
||||
};
|
||||
|
||||
export default appConfig;
|
||||
@ -1,7 +1,9 @@
|
||||
import messageGroup from "./messageGroup";
|
||||
import tenantAccessToken from "./tenantAccessToken";
|
||||
import appConfig from "./appConfig";
|
||||
|
||||
const db = {
|
||||
appConfig,
|
||||
messageGroup,
|
||||
tenantAccessToken,
|
||||
};
|
||||
|
||||
@ -1,10 +1,25 @@
|
||||
import { managePb404 } from "../../utils/pbTools";
|
||||
import pbClient from "../pbClient";
|
||||
|
||||
export interface PBMessageGroup {
|
||||
collectionId: string;
|
||||
collectionName: string;
|
||||
updated: string;
|
||||
created: string;
|
||||
desc: string;
|
||||
id: string;
|
||||
name: string;
|
||||
email?: string[];
|
||||
chat_id?: string[];
|
||||
open_id?: string[];
|
||||
union_id?: string[];
|
||||
user_id?: string[];
|
||||
}
|
||||
|
||||
const getOne = (groupId: string) =>
|
||||
managePb404(
|
||||
async () => await pbClient.collection("message_group").getOne(groupId)
|
||||
);
|
||||
) as Promise<PBMessageGroup>;
|
||||
|
||||
const messageGroup = {
|
||||
getOne,
|
||||
|
||||
14
db/messageGroup/typings.d.ts
vendored
14
db/messageGroup/typings.d.ts
vendored
@ -1,14 +0,0 @@
|
||||
interface PBMessageGroup {
|
||||
collectionId: string;
|
||||
collectionName: string;
|
||||
updated: string;
|
||||
created: string;
|
||||
desc: string;
|
||||
id: string;
|
||||
name: string;
|
||||
email?: string[];
|
||||
chat_id?: string[];
|
||||
open_id?: string[];
|
||||
union_id?: string[];
|
||||
user_id?: string[];
|
||||
}
|
||||
@ -1,7 +1,8 @@
|
||||
import { sleep } from "bun";
|
||||
import { fetchCIMonitor } from "../../service";
|
||||
import { getActionType, getIsActionMsg } from "../../utils/msgTools";
|
||||
import { updateCard } from "../../utils/sendMsg";
|
||||
import { LarkUserAction } from "../../types";
|
||||
import lark from "../../service/lark";
|
||||
|
||||
const makeChatIdCard = async (body: LarkUserAction) => {
|
||||
await sleep(500);
|
||||
@ -38,7 +39,7 @@ const manageBtnClick = async (body: LarkUserAction) => {
|
||||
const card = await func(body);
|
||||
if (!card) return;
|
||||
// 更新飞书的卡片
|
||||
await updateCard(body.open_message_id, card);
|
||||
await lark.updateCard(body.open_message_id, card);
|
||||
};
|
||||
|
||||
/**
|
||||
|
||||
@ -1,5 +1,6 @@
|
||||
import lark from "../../service/lark";
|
||||
import { LarkMessageEvent } from "../../types";
|
||||
import { getChatId, getIsEventMsg, getMsgType } from "../../utils/msgTools";
|
||||
import { sendMsg } from "../../utils/sendMsg";
|
||||
|
||||
/**
|
||||
* 获取文本内容并剔除艾特信息
|
||||
@ -35,7 +36,7 @@ const filterIllegalMsg = (body: LarkMessageEvent) => {
|
||||
// 发表情包就直接发回去
|
||||
if (msgType === "sticker") {
|
||||
const content = body?.event?.message?.content;
|
||||
sendMsg("chat_id", chatId, "sticker", content);
|
||||
lark.sendMsg("chat_id", chatId, "sticker", content);
|
||||
return true;
|
||||
}
|
||||
// 剩下的非文字消息暂时不处理
|
||||
@ -50,7 +51,7 @@ const filterIllegalMsg = (body: LarkMessageEvent) => {
|
||||
const content = JSON.stringify({
|
||||
text: textList[Math.floor(Math.random() * textList.length)],
|
||||
});
|
||||
sendMsg("chat_id", chatId, "text", content);
|
||||
lark.sendMsg("chat_id", chatId, "text", content);
|
||||
return true;
|
||||
}
|
||||
// 还得过滤下艾特全体成员的消息
|
||||
@ -76,7 +77,7 @@ const replyNomalMsg = async (body: LarkMessageEvent) => {
|
||||
template_id: "ctp_AAyVx5R39xU9",
|
||||
},
|
||||
});
|
||||
await sendMsg("chat_id", chatId, "interactive", content);
|
||||
await lark.sendMsg("chat_id", chatId, "interactive", content);
|
||||
};
|
||||
|
||||
/**
|
||||
|
||||
@ -1,5 +1,6 @@
|
||||
import db from "../../db";
|
||||
import { sendMsg } from "../../utils/sendMsg";
|
||||
import lark from "../../service/lark";
|
||||
import { MsgType, ReceiveIDType } from "../../types";
|
||||
|
||||
interface BaseMsg {
|
||||
msg_type: MsgType;
|
||||
@ -59,9 +60,7 @@ export const manageMessageReq = async (req: Request) => {
|
||||
|
||||
if (body.group_id) {
|
||||
// 获取所有接收者
|
||||
const group = (await db.messageGroup.getOne(
|
||||
body.group_id!
|
||||
)) as PBMessageGroup;
|
||||
const group = await db.messageGroup.getOne(body.group_id!);
|
||||
if (!group) {
|
||||
return new Response("group not found");
|
||||
}
|
||||
@ -72,7 +71,7 @@ export const manageMessageReq = async (req: Request) => {
|
||||
const makeSendFunc = (receive_id_type: ReceiveIDType) => {
|
||||
return (receive_id: string) => {
|
||||
sendList.push(
|
||||
sendMsg(
|
||||
lark.sendMsg(
|
||||
receive_id_type,
|
||||
receive_id,
|
||||
body.msg_type,
|
||||
@ -94,7 +93,7 @@ export const manageMessageReq = async (req: Request) => {
|
||||
|
||||
if (body.receive_id && body.receive_id_type) {
|
||||
sendList.push(
|
||||
sendMsg(
|
||||
lark.sendMsg(
|
||||
body.receive_id_type,
|
||||
body.receive_id,
|
||||
body.msg_type,
|
||||
|
||||
@ -1,20 +1,21 @@
|
||||
import db from "../db"
|
||||
import db from "../db";
|
||||
|
||||
export const resetAccessToken = async () => {
|
||||
const URL = 'https://open.f.mioffice.cn/open-apis/auth/v3/tenant_access_token/internal'
|
||||
const app_id = 'cli_a1eff35b43b89063'
|
||||
const app_secret = 'IFSl8ig5DMwMnFjwPiljCfoEWlgRwDxW'
|
||||
const URL =
|
||||
"https://open.f.mioffice.cn/open-apis/auth/v3/tenant_access_token/internal";
|
||||
const app_id = await db.appConfig.getAppId();
|
||||
const app_secret = await db.appConfig.getAppSecret();
|
||||
const res = await fetch(URL, {
|
||||
method: 'POST',
|
||||
method: "POST",
|
||||
headers: {
|
||||
'Content-Type': 'application/json'
|
||||
"Content-Type": "application/json",
|
||||
},
|
||||
body: JSON.stringify({
|
||||
app_id,
|
||||
app_secret
|
||||
})
|
||||
})
|
||||
const { tenant_access_token } = await res.json() as any
|
||||
await db.tenantAccessToken.update(tenant_access_token)
|
||||
return tenant_access_token
|
||||
}
|
||||
app_secret,
|
||||
}),
|
||||
});
|
||||
const { tenant_access_token } = (await res.json()) as any;
|
||||
await db.tenantAccessToken.update(tenant_access_token);
|
||||
return tenant_access_token;
|
||||
};
|
||||
|
||||
@ -1,115 +1,125 @@
|
||||
import db from "../db";
|
||||
|
||||
/**
|
||||
* 发送消息
|
||||
* @param func fetch
|
||||
* @returns
|
||||
*/
|
||||
const manageFetch = async (func: Function) => {
|
||||
try {
|
||||
const res = await func();
|
||||
const data = (await res.json()) as ServerResponse;
|
||||
console.log("🚀 ~ manageFetch ~ data:", data);
|
||||
return data;
|
||||
} catch (error) {
|
||||
console.log("🚀 ~ manageFetch ~ error:", error);
|
||||
return {
|
||||
code: 1,
|
||||
data: null,
|
||||
msg: "sendMsg fetch error",
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* 获取header
|
||||
* @returns header
|
||||
*/
|
||||
const getHeaders = async () => {
|
||||
const tenant_access_token = await db.tenantAccessToken.get();
|
||||
return {
|
||||
"Content-Type": "application/json",
|
||||
Authorization: `Bearer ${tenant_access_token}`,
|
||||
};
|
||||
};
|
||||
|
||||
/**
|
||||
* 发送卡片
|
||||
* @param {ReceiveIDType} receive_id_type 消息接收者id类型 open_id/user_id/union_id/email/chat_id
|
||||
* @param {string} receive_id 消息接收者的ID，ID类型应与查询参数receive_id_type 对应
|
||||
* @param {MsgType} msg_type 消息类型 包括：text、post、image、file、audio、media、sticker、interactive、share_chat、share_user
|
||||
* @param {string} content 消息内容，JSON结构序列化后的字符串。不同msg_type对应不同内容
|
||||
*/
|
||||
export const sendMsg = async (
|
||||
receive_id_type: ReceiveIDType,
|
||||
receive_id: string,
|
||||
msg_type: MsgType,
|
||||
content: string
|
||||
) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/im/v1/messages?receive_id_type=${receive_id_type}`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "POST",
|
||||
headers,
|
||||
body: JSON.stringify({ receive_id, msg_type, content }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
/**
|
||||
* 更新卡片
|
||||
* @param {string} message_id 消息id
|
||||
* @param {string} content 消息内容，JSON结构序列化后的字符串。不同msg_type对应不同内容
|
||||
*/
|
||||
export const updateCard = async (message_id: string, content: string) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/im/v1/messages/${message_id}`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "PATCH",
|
||||
headers,
|
||||
body: JSON.stringify({ content }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
/**
|
||||
* 发送某人可见的卡片
|
||||
* @param {string} chat_id 对话流ID
|
||||
* @param {string} open_id 消息接收者的ID
|
||||
* @param {MsgType} msg_type 消息类型 包括：text、post、image、file、audio、media、sticker、interactive、share_chat、share_user
|
||||
* @param {*} card 消息卡片的描述内容，注意不是String
|
||||
*/
|
||||
export const sendEphemeralMsg = async (
|
||||
chat_id: string,
|
||||
open_id: string,
|
||||
msg_type: MsgType,
|
||||
card: any
|
||||
) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/ephemeral/v1/send`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "POST",
|
||||
headers,
|
||||
body: JSON.stringify({ chat_id, open_id, msg_type, card }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
/**
|
||||
* 删除某人可见的卡片
|
||||
* @param message_id 消息id
|
||||
*/
|
||||
export const delEphemeralMsg = async (message_id: string) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/ephemeral/v1/delete`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "POST",
|
||||
headers,
|
||||
body: JSON.stringify({ message_id }),
|
||||
})
|
||||
);
|
||||
};
|
||||
import db from "../db";
|
||||
import { MsgType, ReceiveIDType, ServerResponse } from "../types";
|
||||
|
||||
/**
|
||||
* 发送消息
|
||||
* @param func fetch
|
||||
* @returns
|
||||
*/
|
||||
const manageFetch = async (func: Function) => {
|
||||
try {
|
||||
const res = await func();
|
||||
const data = (await res.json()) as ServerResponse;
|
||||
console.log("🚀 ~ manageFetch ~ data:", data);
|
||||
return data;
|
||||
} catch (error) {
|
||||
console.log("🚀 ~ manageFetch ~ error:", error);
|
||||
return {
|
||||
code: 1,
|
||||
data: null,
|
||||
msg: "sendMsg fetch error",
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* 获取header
|
||||
* @returns header
|
||||
*/
|
||||
const getHeaders = async () => {
|
||||
const tenant_access_token = await db.tenantAccessToken.get();
|
||||
return {
|
||||
"Content-Type": "application/json",
|
||||
Authorization: `Bearer ${tenant_access_token}`,
|
||||
};
|
||||
};
|
||||
|
||||
/**
|
||||
* 发送卡片
|
||||
* @param {ReceiveIDType} receive_id_type 消息接收者id类型 open_id/user_id/union_id/email/chat_id
|
||||
* @param {string} receive_id 消息接收者的ID，ID类型应与查询参数receive_id_type 对应
|
||||
* @param {MsgType} msg_type 消息类型 包括：text、post、image、file、audio、media、sticker、interactive、share_chat、share_user
|
||||
* @param {string} content 消息内容，JSON结构序列化后的字符串。不同msg_type对应不同内容
|
||||
*/
|
||||
const sendMsg = async (
|
||||
receive_id_type: ReceiveIDType,
|
||||
receive_id: string,
|
||||
msg_type: MsgType,
|
||||
content: string
|
||||
) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/im/v1/messages?receive_id_type=${receive_id_type}`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "POST",
|
||||
headers,
|
||||
body: JSON.stringify({ receive_id, msg_type, content }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
/**
|
||||
* 更新卡片
|
||||
* @param {string} message_id 消息id
|
||||
* @param {string} content 消息内容，JSON结构序列化后的字符串。不同msg_type对应不同内容
|
||||
*/
|
||||
const updateCard = async (message_id: string, content: string) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/im/v1/messages/${message_id}`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "PATCH",
|
||||
headers,
|
||||
body: JSON.stringify({ content }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
/**
|
||||
* 发送某人可见的卡片
|
||||
* @param {string} chat_id 对话流ID
|
||||
* @param {string} open_id 消息接收者的ID
|
||||
* @param {MsgType} msg_type 消息类型 包括：text、post、image、file、audio、media、sticker、interactive、share_chat、share_user
|
||||
* @param {*} card 消息卡片的描述内容，注意不是String
|
||||
*/
|
||||
const sendEphemeralMsg = async (
|
||||
chat_id: string,
|
||||
open_id: string,
|
||||
msg_type: MsgType,
|
||||
card: any
|
||||
) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/ephemeral/v1/send`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "POST",
|
||||
headers,
|
||||
body: JSON.stringify({ chat_id, open_id, msg_type, card }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
/**
|
||||
* 删除某人可见的卡片
|
||||
* @param message_id 消息id
|
||||
*/
|
||||
const delEphemeralMsg = async (message_id: string) => {
|
||||
const URL = `https://open.f.mioffice.cn/open-apis/ephemeral/v1/delete`;
|
||||
const headers = await getHeaders();
|
||||
return await manageFetch(() =>
|
||||
fetch(URL, {
|
||||
method: "POST",
|
||||
headers,
|
||||
body: JSON.stringify({ message_id }),
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
const lark = {
|
||||
sendMsg,
|
||||
updateCard,
|
||||
sendEphemeralMsg,
|
||||
delEphemeralMsg,
|
||||
};
|
||||
|
||||
export default lark;
|
||||
@ -1,451 +1,466 @@
|
||||
/**
|
||||
* 用户信息
|
||||
*/
|
||||
interface User {
|
||||
/**
|
||||
* id
|
||||
*/
|
||||
id: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example zhaoyingbo
|
||||
*/
|
||||
userId: string;
|
||||
/**
|
||||
* open_id
|
||||
*/
|
||||
openId: string;
|
||||
/**
|
||||
* 提醒列表
|
||||
*/
|
||||
remindList: string[];
|
||||
}
|
||||
|
||||
/**
|
||||
* 提醒列表
|
||||
*/
|
||||
interface Remind {
|
||||
/**
|
||||
* id
|
||||
*/
|
||||
id: string;
|
||||
/**
|
||||
* 所有者信息，绑定用户表的id
|
||||
*/
|
||||
owner: string;
|
||||
/**
|
||||
* 消息Id
|
||||
*/
|
||||
messageId: string;
|
||||
/**
|
||||
* 接收者类型
|
||||
*/
|
||||
subscriberType: "open_id" | "user_id" | "union_id" | "email" | "chat_id";
|
||||
/**
|
||||
* 接收者Id
|
||||
*/
|
||||
subscriberId: string;
|
||||
/**
|
||||
* 是否需要回复，不需要回复的也不会重复提醒
|
||||
*/
|
||||
needReply: boolean;
|
||||
/**
|
||||
* 延迟时间
|
||||
*/
|
||||
delayTime: number;
|
||||
/**
|
||||
* 卡片信息，用于绘制初始卡片、确认卡片、取消卡片、延迟卡片
|
||||
*/
|
||||
cardInfo: {
|
||||
/**
|
||||
* 提醒标题，必须要有
|
||||
*/
|
||||
title: string;
|
||||
/**
|
||||
* 插图key
|
||||
*/
|
||||
imageKey?: string;
|
||||
/**
|
||||
* 提醒内容，为空不显示
|
||||
*/
|
||||
content?: string;
|
||||
/**
|
||||
* 确认文本，为空不显示，为需要回复卡片时，如果为空则默认为“完成”
|
||||
*/
|
||||
confirmText?: string;
|
||||
/**
|
||||
* 取消文本，为空不显示
|
||||
*/
|
||||
cancelText?: string;
|
||||
/**
|
||||
* 延迟文本，为空不显示
|
||||
*/
|
||||
delayText?: string;
|
||||
} | null;
|
||||
/**
|
||||
* 卡片模板信息
|
||||
*/
|
||||
templateInfo: {
|
||||
/**
|
||||
* 卡片模板ID，会注入变量
|
||||
* ${owner} 所有者
|
||||
* ${remindTime} 提醒时间
|
||||
*/
|
||||
pendingTemplateId: string;
|
||||
/**
|
||||
* 交互之后的卡片模板ID，如果有这个就不会用下边三个但是都会注入变量
|
||||
* ${owner} 所有者
|
||||
* ${remindTime} 提醒时间
|
||||
* ${result} 交互结果，会读卡片按钮绑定的变量text，如果没有则是绑定的result对应的 已确认、已取消、已延迟
|
||||
* ${interactTime} 交互时间
|
||||
*/
|
||||
interactedTemplateId: string;
|
||||
/**
|
||||
* 确认之后的卡片模板ID
|
||||
*/
|
||||
confirmedTemplateId: string;
|
||||
/**
|
||||
* 取消之后的卡片模板ID
|
||||
*/
|
||||
cancelededTemplateId: string;
|
||||
/**
|
||||
* 延迟之后的卡片模板ID
|
||||
*/
|
||||
delayedTemplateId: string;
|
||||
} | null;
|
||||
|
||||
/**
|
||||
* 提醒时间
|
||||
*/
|
||||
remindTimes: RemindTime[];
|
||||
|
||||
/**
|
||||
* 是否启用
|
||||
*/
|
||||
enabled: boolean;
|
||||
/**
|
||||
* 下次提醒的时间，格式为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
nextRemindTime: string;
|
||||
/**
|
||||
* 下次提醒时间的中文
|
||||
*/
|
||||
nextRemindTimeCHS: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 提醒时间
|
||||
* 为了支持多个时间点提醒，将时间存成数组
|
||||
*/
|
||||
interface RemindTime {
|
||||
/**
|
||||
* 重复类型
|
||||
* single: 一次性
|
||||
* daily: 每天
|
||||
* weekly: 每周
|
||||
* monthly: 每月
|
||||
* yearly: 每年
|
||||
* workday: 工作日
|
||||
* holiday: 节假日
|
||||
*/
|
||||
frequency:
|
||||
| "single"
|
||||
| "daily"
|
||||
| "weekly"
|
||||
| "monthly"
|
||||
| "yearly"
|
||||
| "workday"
|
||||
| "holiday";
|
||||
/**
|
||||
* 提醒时间，格式为HH:mm， single类型时仅作展示用，类型为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
time: string;
|
||||
/**
|
||||
* 星期几[1-7]，当frequency为weekly时有效
|
||||
*/
|
||||
daysOfWeek: number[];
|
||||
/**
|
||||
* 每月的几号[1-31]，当frequency为monthly时有效
|
||||
*/
|
||||
daysOfMonth: number[];
|
||||
/**
|
||||
* 每年的哪天提醒，当frequency为 yearly 时有效，格式为MM-dd
|
||||
*/
|
||||
dayOfYear: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 提醒记录
|
||||
* 记录提醒时间，回答结果等
|
||||
*/
|
||||
interface RemindRecord {
|
||||
/**
|
||||
* 记录Id
|
||||
*/
|
||||
id: string;
|
||||
/**
|
||||
* 关联的提醒Id
|
||||
*/
|
||||
remindId: string;
|
||||
/**
|
||||
* 发送的卡片Id
|
||||
*/
|
||||
messageId: string;
|
||||
/**
|
||||
* 提醒状态
|
||||
* pending: 待确认
|
||||
* delay: 已延迟
|
||||
* confirmed: 已确认
|
||||
* canceled: 已取消
|
||||
*/
|
||||
status: "pending" | "delayed" | "confirmed" | "canceled";
|
||||
/**
|
||||
* 本次提醒时间，格式为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
remindTime: string;
|
||||
/**
|
||||
* 用户交互的时间，格式为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
interactTime: string;
|
||||
/**
|
||||
* 用户回答的结果，类似每天 07:00
|
||||
*/
|
||||
result: object;
|
||||
}
|
||||
|
||||
/**
|
||||
* 消息事件头
|
||||
*/
|
||||
interface Header {
|
||||
/**
|
||||
* 事件ID
|
||||
* @example 0f8ab23b60993cf8dd15c8cde4d7b0f5
|
||||
*/
|
||||
event_id: string;
|
||||
/**
|
||||
* token
|
||||
* @example tV9djUKSjzVnekV7xTg2Od06NFTcsBnj
|
||||
*/
|
||||
token: string;
|
||||
/**
|
||||
* 创建时间戳
|
||||
* @example 1693565712117
|
||||
*/
|
||||
create_time: string;
|
||||
/**
|
||||
* 事件类型
|
||||
* @example im.message.receive_v1
|
||||
*/
|
||||
event_type: string;
|
||||
/**
|
||||
* tenant_key
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
/**
|
||||
* app_id
|
||||
* @example cli_a1eff35b43b89063
|
||||
*/
|
||||
app_id: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户ID信息
|
||||
*/
|
||||
interface UserIdInfo {
|
||||
/**
|
||||
* 用户标记
|
||||
* @example ou_032f507d08f9a7f28b042fcd086daef5
|
||||
*/
|
||||
open_id: string;
|
||||
/**
|
||||
* 用户标记
|
||||
* @example on_7111660fddd8302ce47bf1999147c011
|
||||
*/
|
||||
union_id: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example zhaoyingbo
|
||||
*/
|
||||
user_id: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 被AT的人的信息
|
||||
*/
|
||||
interface Mention {
|
||||
/**
|
||||
* 被艾特的人的ID信息
|
||||
*/
|
||||
id: UserIdInfo;
|
||||
/**
|
||||
* 对应到文本内的内容
|
||||
* @example "@_user_1"
|
||||
*/
|
||||
key: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example 小煎蛋
|
||||
*/
|
||||
name: string;
|
||||
/**
|
||||
* 应用ID
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 消息内容信息
|
||||
*/
|
||||
interface Message {
|
||||
/**
|
||||
* 对话流ID
|
||||
* @example oc_433b1cb7a9dbb7ebe70a4e1a59cb8bb1
|
||||
*/
|
||||
chat_id: string;
|
||||
/**
|
||||
* 消息类型
|
||||
* @example group | p2p
|
||||
*/
|
||||
chat_type: string;
|
||||
/**
|
||||
* JSON字符串文本内容
|
||||
* @example "{\"text\":\"@_user_1 测试\"}"
|
||||
*/
|
||||
content: string;
|
||||
/**
|
||||
* 消息发送时间戳
|
||||
* @example 1693565711996
|
||||
*/
|
||||
create_time: string;
|
||||
/**
|
||||
* 被艾特的人信息
|
||||
*/
|
||||
mentions?: Mention[];
|
||||
/**
|
||||
* 当前消息的ID
|
||||
* @example om_038fc0eceed6224a1abc1cdaa4266405
|
||||
*/
|
||||
message_id: string;
|
||||
/**
|
||||
* 消息类型
|
||||
* @example text、post、image、file、audio、media、sticker、interactive、share_chat、share_user
|
||||
*/
|
||||
message_type: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 消息发送者信息
|
||||
*/
|
||||
interface Sender {
|
||||
/**
|
||||
* id 相关信息
|
||||
*/
|
||||
sender_id: UserIdInfo;
|
||||
/**
|
||||
* 发送者类型
|
||||
* @example user
|
||||
*/
|
||||
sender_type: string;
|
||||
/**
|
||||
* 应用ID
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 事件详情
|
||||
*/
|
||||
interface Event {
|
||||
message: Message;
|
||||
sender: Sender;
|
||||
}
|
||||
|
||||
/**
|
||||
* 事件订阅信息
|
||||
*/
|
||||
interface LarkMessageEvent {
|
||||
/**
|
||||
* 协议版本
|
||||
* @example 2.0
|
||||
*/
|
||||
schema: string;
|
||||
/**
|
||||
* 事件头
|
||||
*/
|
||||
header: Header;
|
||||
/**
|
||||
* 事件详情
|
||||
*/
|
||||
event: Event;
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户Action信息
|
||||
*/
|
||||
interface LarkUserAction {
|
||||
/**
|
||||
* open_id
|
||||
*/
|
||||
open_id: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example zhaoyingbo
|
||||
*/
|
||||
user_id: string;
|
||||
/**
|
||||
* 当前消息的ID
|
||||
* @example om_038fc0eceed6224a1abc1cdaa4266405
|
||||
*/
|
||||
open_message_id: string;
|
||||
/**
|
||||
* 对话流ID
|
||||
* @example oc_433b1cb7a9dbb7ebe70a4e1a59cb8bb1
|
||||
*/
|
||||
open_chat_id: string;
|
||||
/**
|
||||
* 应用ID
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
/**
|
||||
* token
|
||||
* @example tV9djUKSjzVnekV7xTg2Od06NFTcsBnj
|
||||
*/
|
||||
token: string;
|
||||
/**
|
||||
* 事件结果
|
||||
*/
|
||||
action: {
|
||||
/**
|
||||
* 传的参数
|
||||
*/
|
||||
value: any;
|
||||
/**
|
||||
* 标签名
|
||||
* @example picker_datetime
|
||||
*/
|
||||
tag: string;
|
||||
/**
|
||||
* 选择的事件
|
||||
* @example 2023-09-03 10:35 +0800
|
||||
*/
|
||||
option: string;
|
||||
/**
|
||||
* 时区
|
||||
*/
|
||||
timezone: string;
|
||||
};
|
||||
}
|
||||
|
||||
type ReceiveIDType = "open_id" | "user_id" | "union_id" | "email" | "chat_id";
|
||||
|
||||
type MsgType = "text" | "post" | "image" | "file" | "audio" | "media" | "sticker" | "interactive" | "share_chat" | "share_user";
|
||||
|
||||
interface ServerResponse {
|
||||
code: number;
|
||||
data: any;
|
||||
msg: string;
|
||||
}
|
||||
/**
|
||||
* 用户信息
|
||||
*/
|
||||
export interface User {
|
||||
/**
|
||||
* id
|
||||
*/
|
||||
id: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example zhaoyingbo
|
||||
*/
|
||||
userId: string;
|
||||
/**
|
||||
* open_id
|
||||
*/
|
||||
openId: string;
|
||||
/**
|
||||
* 提醒列表
|
||||
*/
|
||||
remindList: string[];
|
||||
}
|
||||
|
||||
/**
|
||||
* 提醒列表
|
||||
*/
|
||||
export interface Remind {
|
||||
/**
|
||||
* id
|
||||
*/
|
||||
id: string;
|
||||
/**
|
||||
* 所有者信息，绑定用户表的id
|
||||
*/
|
||||
owner: string;
|
||||
/**
|
||||
* 消息Id
|
||||
*/
|
||||
messageId: string;
|
||||
/**
|
||||
* 接收者类型
|
||||
*/
|
||||
subscriberType: "open_id" | "user_id" | "union_id" | "email" | "chat_id";
|
||||
/**
|
||||
* 接收者Id
|
||||
*/
|
||||
subscriberId: string;
|
||||
/**
|
||||
* 是否需要回复，不需要回复的也不会重复提醒
|
||||
*/
|
||||
needReply: boolean;
|
||||
/**
|
||||
* 延迟时间
|
||||
*/
|
||||
delayTime: number;
|
||||
/**
|
||||
* 卡片信息，用于绘制初始卡片、确认卡片、取消卡片、延迟卡片
|
||||
*/
|
||||
cardInfo: {
|
||||
/**
|
||||
* 提醒标题，必须要有
|
||||
*/
|
||||
title: string;
|
||||
/**
|
||||
* 插图key
|
||||
*/
|
||||
imageKey?: string;
|
||||
/**
|
||||
* 提醒内容，为空不显示
|
||||
*/
|
||||
content?: string;
|
||||
/**
|
||||
* 确认文本，为空不显示，为需要回复卡片时，如果为空则默认为“完成”
|
||||
*/
|
||||
confirmText?: string;
|
||||
/**
|
||||
* 取消文本，为空不显示
|
||||
*/
|
||||
cancelText?: string;
|
||||
/**
|
||||
* 延迟文本，为空不显示
|
||||
*/
|
||||
delayText?: string;
|
||||
} | null;
|
||||
/**
|
||||
* 卡片模板信息
|
||||
*/
|
||||
templateInfo: {
|
||||
/**
|
||||
* 卡片模板ID，会注入变量
|
||||
* ${owner} 所有者
|
||||
* ${remindTime} 提醒时间
|
||||
*/
|
||||
pendingTemplateId: string;
|
||||
/**
|
||||
* 交互之后的卡片模板ID，如果有这个就不会用下边三个但是都会注入变量
|
||||
* ${owner} 所有者
|
||||
* ${remindTime} 提醒时间
|
||||
* ${result} 交互结果，会读卡片按钮绑定的变量text，如果没有则是绑定的result对应的 已确认、已取消、已延迟
|
||||
* ${interactTime} 交互时间
|
||||
*/
|
||||
interactedTemplateId: string;
|
||||
/**
|
||||
* 确认之后的卡片模板ID
|
||||
*/
|
||||
confirmedTemplateId: string;
|
||||
/**
|
||||
* 取消之后的卡片模板ID
|
||||
*/
|
||||
cancelededTemplateId: string;
|
||||
/**
|
||||
* 延迟之后的卡片模板ID
|
||||
*/
|
||||
delayedTemplateId: string;
|
||||
} | null;
|
||||
|
||||
/**
|
||||
* 提醒时间
|
||||
*/
|
||||
remindTimes: RemindTime[];
|
||||
|
||||
/**
|
||||
* 是否启用
|
||||
*/
|
||||
enabled: boolean;
|
||||
/**
|
||||
* 下次提醒的时间，格式为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
nextRemindTime: string;
|
||||
/**
|
||||
* 下次提醒时间的中文
|
||||
*/
|
||||
nextRemindTimeCHS: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 提醒时间
|
||||
* 为了支持多个时间点提醒，将时间存成数组
|
||||
*/
|
||||
export interface RemindTime {
|
||||
/**
|
||||
* 重复类型
|
||||
* single: 一次性
|
||||
* daily: 每天
|
||||
* weekly: 每周
|
||||
* monthly: 每月
|
||||
* yearly: 每年
|
||||
* workday: 工作日
|
||||
* holiday: 节假日
|
||||
*/
|
||||
frequency:
|
||||
| "single"
|
||||
| "daily"
|
||||
| "weekly"
|
||||
| "monthly"
|
||||
| "yearly"
|
||||
| "workday"
|
||||
| "holiday";
|
||||
/**
|
||||
* 提醒时间，格式为HH:mm， single类型时仅作展示用，类型为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
time: string;
|
||||
/**
|
||||
* 星期几[1-7]，当frequency为weekly时有效
|
||||
*/
|
||||
daysOfWeek: number[];
|
||||
/**
|
||||
* 每月的几号[1-31]，当frequency为monthly时有效
|
||||
*/
|
||||
daysOfMonth: number[];
|
||||
/**
|
||||
* 每年的哪天提醒，当frequency为 yearly 时有效，格式为MM-dd
|
||||
*/
|
||||
dayOfYear: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 提醒记录
|
||||
* 记录提醒时间，回答结果等
|
||||
*/
|
||||
export interface RemindRecord {
|
||||
/**
|
||||
* 记录Id
|
||||
*/
|
||||
id: string;
|
||||
/**
|
||||
* 关联的提醒Id
|
||||
*/
|
||||
remindId: string;
|
||||
/**
|
||||
* 发送的卡片Id
|
||||
*/
|
||||
messageId: string;
|
||||
/**
|
||||
* 提醒状态
|
||||
* pending: 待确认
|
||||
* delay: 已延迟
|
||||
* confirmed: 已确认
|
||||
* canceled: 已取消
|
||||
*/
|
||||
status: "pending" | "delayed" | "confirmed" | "canceled";
|
||||
/**
|
||||
* 本次提醒时间，格式为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
remindTime: string;
|
||||
/**
|
||||
* 用户交互的时间，格式为yyyy-MM-dd HH:mm
|
||||
*/
|
||||
interactTime: string;
|
||||
/**
|
||||
* 用户回答的结果，类似每天 07:00
|
||||
*/
|
||||
result: object;
|
||||
}
|
||||
|
||||
/**
|
||||
* 消息事件头
|
||||
*/
|
||||
export interface Header {
|
||||
/**
|
||||
* 事件ID
|
||||
* @example 0f8ab23b60993cf8dd15c8cde4d7b0f5
|
||||
*/
|
||||
event_id: string;
|
||||
/**
|
||||
* token
|
||||
* @example tV9djUKSjzVnekV7xTg2Od06NFTcsBnj
|
||||
*/
|
||||
token: string;
|
||||
/**
|
||||
* 创建时间戳
|
||||
* @example 1693565712117
|
||||
*/
|
||||
create_time: string;
|
||||
/**
|
||||
* 事件类型
|
||||
* @example im.message.receive_v1
|
||||
*/
|
||||
event_type: string;
|
||||
/**
|
||||
* tenant_key
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
/**
|
||||
* app_id
|
||||
* @example cli_a1eff35b43b89063
|
||||
*/
|
||||
app_id: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户ID信息
|
||||
*/
|
||||
export interface UserIdInfo {
|
||||
/**
|
||||
* 用户标记
|
||||
* @example ou_032f507d08f9a7f28b042fcd086daef5
|
||||
*/
|
||||
open_id: string;
|
||||
/**
|
||||
* 用户标记
|
||||
* @example on_7111660fddd8302ce47bf1999147c011
|
||||
*/
|
||||
union_id: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example zhaoyingbo
|
||||
*/
|
||||
user_id: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 被AT的人的信息
|
||||
*/
|
||||
export interface Mention {
|
||||
/**
|
||||
* 被艾特的人的ID信息
|
||||
*/
|
||||
id: UserIdInfo;
|
||||
/**
|
||||
* 对应到文本内的内容
|
||||
* @example "@_user_1"
|
||||
*/
|
||||
key: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example 小煎蛋
|
||||
*/
|
||||
name: string;
|
||||
/**
|
||||
* 应用ID
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 消息内容信息
|
||||
*/
|
||||
export interface Message {
|
||||
/**
|
||||
* 对话流ID
|
||||
* @example oc_433b1cb7a9dbb7ebe70a4e1a59cb8bb1
|
||||
*/
|
||||
chat_id: string;
|
||||
/**
|
||||
* 消息类型
|
||||
* @example group | p2p
|
||||
*/
|
||||
chat_type: string;
|
||||
/**
|
||||
* JSON字符串文本内容
|
||||
* @example "{\"text\":\"@_user_1 测试\"}"
|
||||
*/
|
||||
content: string;
|
||||
/**
|
||||
* 消息发送时间戳
|
||||
* @example 1693565711996
|
||||
*/
|
||||
create_time: string;
|
||||
/**
|
||||
* 被艾特的人信息
|
||||
*/
|
||||
mentions?: Mention[];
|
||||
/**
|
||||
* 当前消息的ID
|
||||
* @example om_038fc0eceed6224a1abc1cdaa4266405
|
||||
*/
|
||||
message_id: string;
|
||||
/**
|
||||
* 消息类型
|
||||
* @example text、post、image、file、audio、media、sticker、interactive、share_chat、share_user
|
||||
*/
|
||||
message_type: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 消息发送者信息
|
||||
*/
|
||||
export interface Sender {
|
||||
/**
|
||||
* id 相关信息
|
||||
*/
|
||||
sender_id: UserIdInfo;
|
||||
/**
|
||||
* 发送者类型
|
||||
* @example user
|
||||
*/
|
||||
sender_type: string;
|
||||
/**
|
||||
* 应用ID
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* 事件详情
|
||||
*/
|
||||
export interface Event {
|
||||
message: Message;
|
||||
sender: Sender;
|
||||
}
|
||||
|
||||
/**
|
||||
* 事件订阅信息
|
||||
*/
|
||||
export interface LarkMessageEvent {
|
||||
/**
|
||||
* 协议版本
|
||||
* @example 2.0
|
||||
*/
|
||||
schema: string;
|
||||
/**
|
||||
* 事件头
|
||||
*/
|
||||
header: Header;
|
||||
/**
|
||||
* 事件详情
|
||||
*/
|
||||
event: Event;
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户Action信息
|
||||
*/
|
||||
export interface LarkUserAction {
|
||||
/**
|
||||
* open_id
|
||||
*/
|
||||
open_id: string;
|
||||
/**
|
||||
* 用户名
|
||||
* @example zhaoyingbo
|
||||
*/
|
||||
user_id: string;
|
||||
/**
|
||||
* 当前消息的ID
|
||||
* @example om_038fc0eceed6224a1abc1cdaa4266405
|
||||
*/
|
||||
open_message_id: string;
|
||||
/**
|
||||
* 对话流ID
|
||||
* @example oc_433b1cb7a9dbb7ebe70a4e1a59cb8bb1
|
||||
*/
|
||||
open_chat_id: string;
|
||||
/**
|
||||
* 应用ID
|
||||
* @example 2ee61fe50f4f1657
|
||||
*/
|
||||
tenant_key: string;
|
||||
/**
|
||||
* token
|
||||
* @example tV9djUKSjzVnekV7xTg2Od06NFTcsBnj
|
||||
*/
|
||||
token: string;
|
||||
/**
|
||||
* 事件结果
|
||||
*/
|
||||
action: {
|
||||
/**
|
||||
* 传的参数
|
||||
*/
|
||||
value: any;
|
||||
/**
|
||||
* 标签名
|
||||
* @example picker_datetime
|
||||
*/
|
||||
tag: string;
|
||||
/**
|
||||
* 选择的事件
|
||||
* @example 2023-09-03 10:35 +0800
|
||||
*/
|
||||
option: string;
|
||||
/**
|
||||
* 时区
|
||||
*/
|
||||
timezone: string;
|
||||
};
|
||||
}
|
||||
|
||||
export type ReceiveIDType =
|
||||
| "open_id"
|
||||
| "user_id"
|
||||
| "union_id"
|
||||
| "email"
|
||||
| "chat_id";
|
||||
|
||||
export type MsgType =
|
||||
| "text"
|
||||
| "post"
|
||||
| "image"
|
||||
| "file"
|
||||
| "audio"
|
||||
| "media"
|
||||
| "sticker"
|
||||
| "interactive"
|
||||
| "share_chat"
|
||||
| "share_user";
|
||||
|
||||
export interface ServerResponse {
|
||||
code: number;
|
||||
data: any;
|
||||
msg: string;
|
||||
}
|
||||
@ -1,3 +1,5 @@
|
||||
import { LarkMessageEvent, LarkUserAction } from "../types";
|
||||
|
||||
/**
|
||||
* 是否为事件消息
|
||||
* @param {LarkMessageEvent} body
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user