forked from wangziqi/gongxue-base
feat: add getDeptDepthMap BFS method for org tree depth tracking
This commit is contained in:
@@ -262,6 +262,42 @@ export class DingTalkService {
|
||||
return ids;
|
||||
}
|
||||
|
||||
/**
|
||||
* BFS from rootDeptId=1, returns depth of every department.
|
||||
* Depth is 1-based (root=1). Uses listsubid API only, no detail fetches.
|
||||
*/
|
||||
private async getDeptDepthMap(token: string): Promise<Map<number, number>> {
|
||||
const depthMap = new Map<number, number>();
|
||||
const queue: Array<{ id: number; depth: number }> = [{ id: 1, depth: 1 }];
|
||||
|
||||
while (queue.length > 0) {
|
||||
const { id, depth } = queue.shift()!;
|
||||
depthMap.set(id, depth);
|
||||
|
||||
try {
|
||||
await this.rateLimit();
|
||||
const res = await fetch(
|
||||
`https://oapi.dingtalk.com/topapi/v2/department/listsubid?access_token=${token}`,
|
||||
{
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: JSON.stringify({ dept_id: id }),
|
||||
},
|
||||
);
|
||||
const body: SubDeptIdListResponse = await res.json();
|
||||
if (body.errcode === 0 && body.result?.dept_id_list) {
|
||||
for (const childId of body.result.dept_id_list) {
|
||||
queue.push({ id: childId, depth: depth + 1 });
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
this.logger.error(`getDeptDepthMap 获取部门 ${id} 子部门失败: ${(e as Error).message}`);
|
||||
}
|
||||
}
|
||||
|
||||
return depthMap;
|
||||
}
|
||||
|
||||
// ═══════════════════════════════════════════
|
||||
// Department detail
|
||||
// ═══════════════════════════════════════════
|
||||
@@ -492,6 +528,7 @@ export class DingTalkService {
|
||||
|
||||
// 拉该部门下的用户
|
||||
const dingUsers = await this.getDeptUsers(token, deptIds[i]);
|
||||
this.logger.log(`[dingtalk] dept ${deptIds[i]} (${detail.name}): ${dingUsers.length} users`);
|
||||
|
||||
nodes.push({
|
||||
id: detail.dept_id,
|
||||
|
||||
Reference in New Issue
Block a user