✨ 构思设计了一套专门针对软删除与乐观锁的 CURD 扩展接口，所有后缀带 _safety 的新方法可以自动带上数据库中的相应字段工作。

Author: langyo

Cargo.lock

@@ -19,6 +19,7 @@ edition = "2024"
 
 [workspace.dependencies]
 anyhow = { version = "^1", features = ["backtrace"] }
+async-trait = "^0.1"
 derive_more = { version = "^2", features = ["full"] }
 once_cell = "^1"
 

Cargo.toml

@@ -10,6 +10,7 @@ _utils = { path = "../utils", version = "*" }
 
 
 anyhow = { workspace = true }
+async-trait = { workspace = true }
 derive_more = { workspace = true }
 once_cell = { workspace = true }
 

packages/database/Cargo.toml

@@ -1,7 +1,7 @@
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
 
-use _utils::types::HiddenFlag;
+use _utils::{impl_safe_operation, types::HiddenFlag};
 
 #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Deserialize, Serialize)]
 #[sea_orm(table_name = "area", schema_name = "genshin_map")]
@@ -75,4 +75,9 @@ impl Linked for ParentReferencingLink {
     }
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}

packages/database/src/models/area/area.rs

@@ -1,3 +1,4 @@
+use _utils::impl_safe_operation;
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
 
@@ -47,4 +48,9 @@ pub enum Relation {
     ItemId,
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}

packages/database/src/models/area/item_area_public.rs

@@ -1,7 +1,10 @@
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
 
-use _utils::types::{HistoryEditType, HistoryOperationType};
+use _utils::{
+    impl_safe_operation,
+    types::{HistoryEditType, HistoryOperationType},
+};
 
 #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Deserialize, Serialize)]
 #[sea_orm(table_name = "history", schema_name = "genshin_map")]
@@ -54,4 +57,9 @@ pub enum Relation {
     UpdaterId,
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}

packages/database/src/models/common/history.rs

@@ -1,3 +1,4 @@
+use _utils::impl_safe_operation;
 use sea_orm::{entity::prelude::*, FromJsonQueryResult};
 use serde::{Deserialize, Serialize};
 
@@ -54,4 +55,9 @@ pub enum Relation {
     UpdaterId,
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}

packages/database/src/models/common/notice.rs

@@ -1,7 +1,7 @@
 use sea_orm::{entity::prelude::*, FromJsonQueryResult};
 use serde::{Deserialize, Serialize};
 
-use _utils::types::HiddenFlag;
+use _utils::{impl_safe_operation, types::HiddenFlag};
 
 #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Deserialize, Serialize)]
 #[sea_orm(table_name = "route", schema_name = "genshin_map")]
@@ -59,4 +59,9 @@ pub enum Relation {
     UpdaterId,
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}

packages/database/src/models/common/route.rs

@@ -1,7 +1,7 @@
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
 
-use _utils::types::ScopeStatType;
+use _utils::{impl_safe_operation, types::ScopeStatType};
 
 #[derive(Clone, Debug, PartialEq, DeriveEntityModel, Deserialize, Serialize)]
 #[sea_orm(table_name = "score_stat", schema_name = "genshin_map")]
@@ -57,4 +57,9 @@ pub enum Relation {
     UpdaterId,
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}

packages/database/src/models/common/score_stat.rs

@@ -1,3 +1,4 @@
+use _utils::impl_safe_operation;
 use sea_orm::entity::prelude::*;
 use serde::{Deserialize, Serialize};
 
@@ -43,4 +44,9 @@ pub enum Relation {
     UpdaterId,
 }
 
-impl ActiveModelBehavior for ActiveModel {}
+impl_safe_operation! {
+    active_model_ty: ActiveModel,
+    updated_at_column_name: update_time,
+    updated_at_column_init_expr: chrono::Utc::now().naive_utc(),
+    del_flag_column: Column::DelFlag
+}