📝 定义了所有系统模块下的路由。

Author: langyo

packages/router/src/routes/system/action_log.rs

@@ -0,0 +1,72 @@
+use anyhow::Result;
+use serde::{Deserialize, Serialize};
+
+use axum::{extract::Query, http::StatusCode, response::IntoResponse};
+
+use crate::middlewares::ExtractAuthInfo;
+use _utils::models::wrapper::Pagination;
+
+/// 设备状态
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+pub enum Action {
+    #[serde(rename = "LOGIN")]
+    Login,
+}
+
+/// 操作日志排序枚举
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+pub enum ActionLogSort {
+    #[serde(rename = "action-")]
+    Action,
+    #[serde(rename = "deviceId-")]
+    DeviceId,
+    #[serde(rename = "id-")]
+    Id,
+    #[serde(rename = "ipv4-")]
+    Ipv4,
+    #[serde(rename = "isError-")]
+    IsError,
+    #[serde(rename = "action+")]
+    SortAction,
+    #[serde(rename = "deviceId+")]
+    SortDeviceId,
+    #[serde(rename = "id+")]
+    SortId,
+    #[serde(rename = "ipv4+")]
+    SortIpv4,
+    #[serde(rename = "isError+")]
+    SortIsError,
+    #[serde(rename = "updateTime+")]
+    SortUpdateTime,
+    #[serde(rename = "updateTime-")]
+    UpdateTime,
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct ActionLogParams {
+    /// 设备状态
+    pub action: Option<Action>,
+    #[serde(flatten)]
+    pub pagination: Option<Pagination>,
+    /// 设备ID
+    pub device_id: Option<String>,
+    /// IPv4
+    pub ipv4: Option<String>,
+    /// 是否是错误日志
+    pub is_error: Option<bool>,
+    /// 排序
+    pub sort: Option<Vec<ActionLogSort>>,
+    /// 用户ID
+    pub user_id: Option<i64>,
+}
+
+/// 获取操作日志
+/// POST /action_log/list
+#[tracing::instrument(skip_all)]
+pub async fn list(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Query(query): Query<ActionLogParams>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}

packages/router/src/routes/system/archive.rs

@@ -0,0 +1,100 @@
+use anyhow::Result;
+use chrono::{DateTime, Local};
+use serde::{Deserialize, Serialize};
+
+use axum::{
+    extract::{Json, Path},
+    http::StatusCode,
+    response::IntoResponse,
+};
+
+use crate::middlewares::ExtractAuthInfo;
+
+/// 获取指定槽位的最新存档
+/// GET /archive/last/{slot_index}
+#[tracing::instrument(skip_all)]
+pub async fn get_last(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path(slot_index): Path<u64>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 获取指定槽位的所有历史存档
+/// GET /archive/history/{slot_index}
+#[tracing::instrument(skip_all)]
+pub async fn get_history(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path(slot_index): Path<u64>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 获取所有槽位的历史存档
+/// GET /archive/all_history
+#[tracing::instrument(skip_all)]
+pub async fn get_all_history(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct ArchiveSaveParams {
+    pub time: DateTime<Local>,
+    pub archive: String,
+    pub history_index: u32,
+}
+
+/// 新建存档槽位并将存档存入
+/// PUT /archive/{slot_index}/{name}
+#[tracing::instrument(skip_all)]
+pub async fn put(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path((slot_index, name)): Path<(u64, String)>,
+    Json(payload): Json<ArchiveSaveParams>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 存档入指定槽位
+/// POST /archive/save/{slot_index}
+#[tracing::instrument(skip_all)]
+pub async fn save(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path(slot_index): Path<u64>,
+    Json(payload): Json<ArchiveSaveParams>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 重命名指定槽位
+/// POST /archive/rename/{slot_index}/{new_name}
+#[tracing::instrument(skip_all)]
+pub async fn rename(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path((slot_index, new_name)): Path<(u64, String)>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 删除最近一次存档（恢复为上次存档）
+/// DELETE /archive/restore/{slot_index}
+#[tracing::instrument(skip_all)]
+pub async fn restore(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path(slot_index): Path<u64>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 删除存档槽位
+/// DELETE /archive/slot/{slot_index}
+#[tracing::instrument(skip_all)]
+pub async fn delete_slot(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path(slot_index): Path<u64>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}

packages/router/src/routes/system/device.rs

@@ -0,0 +1,81 @@
+use anyhow::Result;
+use serde::{Deserialize, Serialize};
+
+use axum::{extract::Json, http::StatusCode, response::IntoResponse};
+
+use crate::middlewares::ExtractAuthInfo;
+use _utils::models::wrapper::Pagination;
+
+/// 格式：字段+ 字段-
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+pub enum DeviceSort {
+    #[serde(rename = "deviceId-")]
+    DeviceId,
+    #[serde(rename = "id-")]
+    Id,
+    #[serde(rename = "ipv4-")]
+    Ipv4,
+    #[serde(rename = "lastLoginTime-")]
+    LastLoginTime,
+    #[serde(rename = "deviceId+")]
+    SortDeviceId,
+    #[serde(rename = "id+")]
+    SortId,
+    #[serde(rename = "ipv4+")]
+    SortIpv4,
+    #[serde(rename = "lastLoginTime+")]
+    SortLastLoginTime,
+    #[serde(rename = "status+")]
+    SortStatus,
+    #[serde(rename = "updateTime+")]
+    SortUpdateTime,
+    #[serde(rename = "status-")]
+    Status,
+    #[serde(rename = "updateTime-")]
+    UpdateTime,
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct DeviceListParams {
+    #[serde(flatten)]
+    pub pagination: Option<Pagination>,
+    /// 设备ID
+    pub device_id: Option<String>,
+    /// IPv4
+    pub ipv4: Option<String>,
+    /// 排序
+    pub sort: Option<Vec<DeviceSort>>,
+    /// 设备状态
+    pub status: Option<i64>,
+    /// 用户ID
+    pub user_id: i64,
+}
+
+/// 获取用户设备
+/// POST /device/list
+#[tracing::instrument(skip_all)]
+pub async fn list(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Json(payload): Json<DeviceListParams>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct DeviceUpdateParams {
+    /// ID
+    pub id: i64,
+    pub status: Option<i64>,
+}
+
+/// 更新用户设备信息
+/// POST /device/update
+#[tracing::instrument(skip_all)]
+pub async fn update(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Json(payload): Json<DeviceUpdateParams>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}

packages/router/src/routes/system/invitation.rs

@@ -0,0 +1,130 @@
+use anyhow::Result;
+use serde::{Deserialize, Serialize};
+
+use axum::{
+    extract::{Json, Path},
+    http::StatusCode,
+    response::IntoResponse,
+};
+
+use crate::middlewares::ExtractAuthInfo;
+use _utils::{models::wrapper::Pagination, types::AccessPolicyItemEnum};
+
+/// 获取用户邀请列表的请求参数
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct InvitationListRequest {
+    /// 邀请码
+    pub code: Option<String>,
+    #[serde(flatten)]
+    pub pagination: Option<Pagination>,
+    /// 排序
+    pub sort: Option<Vec<InvitationSort>>,
+    /// 用户名
+    pub username: Option<String>,
+}
+
+/// 邀请排序枚举
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+pub enum InvitationSort {
+    #[serde(rename = "createTime-")]
+    CreateTime,
+    #[serde(rename = "id-")]
+    Id,
+    #[serde(rename = "createTime+")]
+    SortCreateTime,
+    #[serde(rename = "id+")]
+    SortId,
+    #[serde(rename = "updateTime+")]
+    SortUpdateTime,
+    #[serde(rename = "username+")]
+    SortUsername,
+    #[serde(rename = "updateTime-")]
+    UpdateTime,
+    #[serde(rename = "username-")]
+    Username,
+}
+
+/// 新增/更新用户邀请的请求参数
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct InvitationUpdateRequest {
+    /// 权限策略
+    pub access_policy: Vec<AccessPolicyItemEnum>,
+    /// 邀请码
+    pub code: String,
+    /// 备注
+    pub remark: String,
+    /// 角色列表
+    pub role_id: i64,
+    /// 用户名
+    pub username: String,
+}
+
+/// 使用用户邀请的请求参数
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct InvitationConsumeRequest {
+    /// 邀请码
+    pub code: String,
+    /// 用户名
+    pub username: String,
+}
+
+/// 检查用户邀请数据的请求参数
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct InvitationInfoRequest {
+    /// 邀请码
+    pub code: String,
+}
+
+/// 获取用户邀请列表
+/// POST /invitation/list
+#[tracing::instrument(skip_all)]
+pub async fn list(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Json(payload): Json<InvitationListRequest>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 新增/更新用户邀请
+/// POST /invitation/update
+#[tracing::instrument(skip_all)]
+pub async fn update(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Json(payload): Json<InvitationUpdateRequest>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 检查用户邀请数据
+/// POST /invitation/info
+#[tracing::instrument(skip_all)]
+pub async fn info(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Json(payload): Json<InvitationInfoRequest>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 使用用户邀请
+/// POST /invitation/consume
+#[tracing::instrument(skip_all)]
+pub async fn consume(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Json(payload): Json<InvitationConsumeRequest>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}
+
+/// 删除用户邀请
+/// DELETE /invitation/{invitation_id}
+#[tracing::instrument(skip_all)]
+pub async fn delete(
+    ExtractAuthInfo(auth): ExtractAuthInfo,
+    Path(invitation_id): Path<u64>,
+) -> Result<impl IntoResponse, (StatusCode, String)> {
+    Ok(())
+}