云养鸟系统：架构设计与实现#

1
// 鸟场管理系统路由（桌面端）
2
const managementRoutes = [
3
  { path: '/Home', component: Home },
4
  { path: '/Stream', component: Stream },
5
  { path: '/Device', component: Device },
6
  { path: '/Data', component: Data },
7
  { path: '/Profile', component: Profile },
8
  { path: '/UserManage', component: UserManage },
9
  { path: '/birds', component: BirdsPage }
10
];
11
// 云养鸟系统路由（移动端），统一前缀 /cloud
12
const cloudRoutes = {
13
  path: '/cloud',
14
  component: CloudApp,
15
  children: [
16
    { path: 'login', component: () => import('@/cloud/pages/LoginPage.vue') },
17
    { path: 'register', component: () => import('@/cloud/pages/RegisterPage.vue') },
18
    { path: 'home', component: () => import('@/cloud/pages/CloudHomePage.vue') },
19
    { path: 'birds', component: () => import('@/cloud/pages/BirdsPage.vue') },
20
    { path: 'adopt-birds', component: () => import('@/cloud/pages/AdoptBirdsPage.vue') },
21
    { path: 'my', component: () => import('@/cloud/pages/MyPage.vue') },
22
    { path: 'bird/:id', component: () => import('@/cloud/pages/BirdDetailPage.vue') }
23
  ]
24
};

1
server: {
2
  proxy: {
3
    '/api': {
4
      target: 'https://lark.mintlab.top',
5
      changeOrigin: true,
6
      secure: false,
7
      ws: true // 支持 WebSocket 代理
8
    },
9
    '/stream': {
10
      target: 'https://lark.mintlab.top',
11
      changeOrigin: true,
12
      ws: true
13
    }
14
  }
15
}

1
class M_Users(Base):
2
    __tablename__ = 'users'
3
    id = Column(Integer, primary_key=True)
4
    username = Column(String(50), unique=True, nullable=False)
5
    password = Column(String(255), nullable=False)
6
    role = Column(String(20), default='user')  # root/clouduser/user
7
    extra = Column(JSON, default=dict)  # 存储已认领雏鸟等信息

1
class Birds(Base):
2
    __tablename__ = 'birds'
3
    id = Column(Integer, primary_key=True)
4
    name = Column(String(100), nullable=False)  # 雏鸟名称
5
    species = Column(String(100))  # 品种
6
    birth_date = Column(Date)  # 出生日期
7
    status = Column(String(20), default='available')  # available/adopted
8
    device_id = Column(Integer, ForeignKey('devices.id'))  # 关联设备
9
    user_id = Column(Integer, ForeignKey('users.id'), nullable=True)  # 认领用户

1
// 请求队列管理，避免并发刷新
2
let isRefreshing = false;
3
let requestQueue: Array<(token: string) => void> = [];
4

5
// 处理 401 响应
6
async function handleUnauthorized(): Promise<string> {
7
  if (isRefreshing) {
8
    // 排队等待新 Token
9
    return new Promise(resolve => {
10
      requestQueue.push(resolve);
11
    });
12
  }
13
  isRefreshing = true;
14

15
  try {
16
    const newToken = await refreshToken();
17
    if (newToken) {
18
      // 通知排队请求使用新 Token
19
      requestQueue.forEach(resolve => resolve(newToken));
20
      return newToken;
21
    }
22
  } catch {
23
    // 刷新失败，跳转登录
24
    redirectToLogin();
25
  } finally {
26
    isRefreshing = false;
27
    requestQueue = [];
28
  }
29
  throw new Error('Token refresh failed');
30
}

1
@router.post("/register", response_model=CommonOut)
2
async def register_user(user: UserRegister, db: Session = Depends(GetDb)):
3
    # 验证邀请码
4
    invitation = db.query(InvitationCodes).filter_by(code=user.invitation_code).first()
5
    if not invitation:
6
        raise HTTPException(status_code=400, detail="无效的邀请码")
7

8
    # 根据邀请码决定用户角色
9
    user_role = invitation.user_type if invitation.user_type else 'clouduser'
10
    # 创建用户
11
    new_user = M_Users(
12
        username=user.username,
13
        password=hash_password(user.password),
14
        role=user_role
15
    )
16
    db.add(new_user)
17
    db.commit()
18
    return CommonOut(data={"user_id": new_user.id, "role": new_user.role})

1
@router.post("/{bird_id}/adopt", response_model=CommonOut)
2
async def adopt_bird(
3
    bird_id: int,
4
    current_user: M_Users = Depends(GetCurrentUser),
5
    db: Session = Depends(GetDb)
6
):
7
    # 检查用户是否已有认领的雏鸟
8
    if current_user.extra and current_user.extra.get('adopted_bird_id'):
9
        raise HTTPException(status_code=400, detail="您已认领一只雏鸟")
10

11
    # 检查雏鸟是否可被认领
12
    bird = db.query(Birds).filter_by(id=bird_id).first()
13
    if bird.status != 'available':
14
        raise HTTPException(status_code=400, detail="该雏鸟已被认领")
15

16
    # 执行认领
17
    bird.status = 'adopted'
18
    bird.user_id = current_user.id
19
    # 更新用户额外信息
20
    extra = dict(current_user.extra) if current_user.extra else {}
21
    extra['adopted_bird_id'] = bird_id
22
    current_user.extra = extra
23

24
    db.commit()
25
    return CommonOut(message="认领成功")

1
@router.delete("/{user_id}", response_model=CommonOut)
2
async def delete_user(
3
    user_id: int,
4
    current_user: M_Users = Depends(GetCurrentUser),
5
    db: Session = Depends(GetDb)
6
):
7
    # 仅 root 或本人可删除
8
    if current_user.role != 'root' and current_user.id != user_id:
9
        raise HTTPException(status_code=403, detail="权限不足")
10

11
    target_user = db.query(M_Users).filter_by(id=user_id).first()
12
    # 自动释放已认领雏鸟
13
    if target_user.extra and target_user.extra.get('adopted_bird_id'):
14
        ReleaseAdoptedBird(db, user_id)
15

16
    db.delete(target_user)
17
    db.commit()
18
    return CommonOut(message="注销成功")