import { TeamItemType, TeamMemberWithTeamSchema } from '@fastgpt/global/support/user/team/type'; import { Types } from '../../../common/mongo'; import { TeamMemberRoleEnum, TeamMemberStatusEnum, notLeaveStatus } from '@fastgpt/global/support/user/team/constant'; import { MongoTeamMember } from './teamMemberSchema'; import { MongoTeam } from './teamSchema'; async function getTeam(match: Record): Promise { const tmb = (await MongoTeamMember.findOne(match).populate('teamId')) as TeamMemberWithTeamSchema; if (!tmb) { return Promise.reject('member not exist'); } return { userId: String(tmb.userId), teamId: String(tmb.teamId._id), teamName: tmb.teamId.name, memberName: tmb.name, avatar: tmb.teamId.avatar, balance: tmb.teamId.balance, tmbId: String(tmb._id), role: tmb.role, status: tmb.status, defaultTeam: tmb.defaultTeam, canWrite: tmb.role !== TeamMemberRoleEnum.visitor, maxSize: tmb.teamId.maxSize }; } export async function getTeamInfoByTmbId({ tmbId }: { tmbId: string }) { if (!tmbId) { return Promise.reject('tmbId or userId is required'); } return getTeam({ _id: new Types.ObjectId(tmbId), status: notLeaveStatus }); } export async function getUserDefaultTeam({ userId }: { userId: string }) { if (!userId) { return Promise.reject('tmbId or userId is required'); } return getTeam({ userId: new Types.ObjectId(userId), defaultTeam: true }); } export async function createDefaultTeam({ userId, teamName = 'My Team', avatar = '/icon/logo.svg', balance, maxSize = 5 }: { userId: string; teamName?: string; avatar?: string; balance?: number; maxSize?: number; }) { // auth default team const tmb = await MongoTeamMember.findOne({ userId: new Types.ObjectId(userId), defaultTeam: true }); if (!tmb) { console.log('create default team', userId); // create const { _id: insertedId } = await MongoTeam.create({ ownerId: userId, name: teamName, avatar, balance, maxSize, createTime: new Date() }); await MongoTeamMember.create({ teamId: insertedId, userId, name: 'Owner', role: TeamMemberRoleEnum.owner, status: TeamMemberStatusEnum.active, createTime: new Date(), defaultTeam: true }); } else { console.log('default team exist', userId); await MongoTeam.findByIdAndUpdate(tmb.teamId, { $set: { ...(balance !== undefined && { balance }), maxSize } }); } }