feat: add delete for file_group group_tag

Author: DataEraserC

file_classification_cli/Cargo.toml

@@ -54,19 +54,26 @@ doc = false
 name = "delete_tag"
 doc = false
 
+[[bin]]
+name = "list_group_tags_by_conditions"
+doc = false
+
 [[bin]]
 name = "create_group_tag"
 doc = false
 
 [[bin]]
-name = "list_file_groups_by_conditions"
+name = "delete_group_tag"
 doc = false
 
 [[bin]]
-name = "list_group_tags_by_conditions"
+name = "list_file_groups_by_conditions"
 doc = false
 
 [[bin]]
 name = "create_file_group"
 doc = false
 
+[[bin]]
+name = "delete_file_group"
+doc = false

file_classification_cli/src/bin/delete_file_group.rs

@@ -0,0 +1,38 @@
+use file_classification_core::service::file_group::delete_file_group;
+use file_classification_core::utils::database::establish_connection;
+use std::io::{stdin, stdout, Write};
+
+fn main() {
+    let connection = &mut establish_connection();
+
+    let mut file_id_input = String::new();
+    let mut group_id_input = String::new();
+
+    print!("Please input File ID: ");
+    stdout().flush().unwrap();
+    stdin().read_line(&mut file_id_input).unwrap();
+    let file_id: i32 = file_id_input.trim().parse().expect("Invalid File ID");
+
+    print!("Please input Group ID: ");
+    stdout().flush().unwrap();
+    stdin().read_line(&mut group_id_input).unwrap();
+    let group_id: i32 = group_id_input.trim().parse().expect("Invalid Group ID");
+
+    let result = delete_file_group(connection, file_id, group_id);
+    match result {
+        Ok(deleted_file_group_num) => {
+            if (deleted_file_group_num == 0) {
+                println!("No FileGroup deleted!");
+            } else { println!("FileGroup deleted successfully!({:?} line changed)", deleted_file_group_num) }
+        }
+        Err(e) => eprintln!("Error deleting FileGroup: {}", e),
+    }
+}
+
+#[allow(dead_code)]
+#[cfg(not(windows))]
+const EOF: &str = "CTRL+D";
+
+#[allow(dead_code)]
+#[cfg(windows)]
+const EOF: &str = "CTRL+Z";

file_classification_cli/src/bin/delete_group_tag.rs

@@ -0,0 +1,40 @@
+use file_classification_core::service::group_tag::delete_group_tag;
+use file_classification_core::utils::database::establish_connection;
+use std::io::{stdin, stdout, Write};
+
+fn main() {
+    let connection = &mut establish_connection();
+
+    let mut group_id_input = String::new();
+    let mut tag_id_input = String::new();
+
+    print!("Please input Group ID: ");
+    stdout().flush().unwrap();
+    stdin().read_line(&mut group_id_input).unwrap();
+    let group_id: i32 = group_id_input.trim().parse().expect("Invalid Group ID");
+
+    print!("Please input Tag ID: ");
+    stdout().flush().unwrap();
+    stdin().read_line(&mut tag_id_input).unwrap();
+    let tag_id: i32 = tag_id_input.trim().parse().expect("Invalid Tag ID");
+
+    let result = delete_group_tag(connection, group_id, tag_id);
+    match result {
+        Ok(deleted_group_tag_num) => {
+            if (deleted_group_tag_num == 0) {
+                println!("No GroupTag deleted!");
+            } else {
+                println!("GroupTag deleted successfully!({:?} line changed)", deleted_group_tag_num)
+            }
+        }
+        Err(e) => eprintln!("Error deleting GroupTag: {}", e),
+    }
+}
+
+#[allow(dead_code)]
+#[cfg(not(windows))]
+const EOF: &str = "CTRL+D";
+
+#[allow(dead_code)]
+#[cfg(windows)]
+const EOF: &str = "CTRL+Z";

file_classification_cli/src/bin/list_file_groups_by_conditions.rs

@@ -1,7 +1,7 @@
 use file_classification_core::model::models::FileGroupCondition;
+use file_classification_core::service::file_group::select_file_groups_by_conditions;
 use file_classification_core::utils::database::establish_connection;
 use std::io::{self, Write};
-use file_classification_core::service::file_group::select_file_groups_by_conditions;
 
 fn main() {
     let connection = &mut establish_connection();

file_classification_cli/src/bin/list_files.rs

@@ -1,6 +1,6 @@
+use file_classification_core::model::models::FileFilter;
 use file_classification_core::service::files::select_files;
 use file_classification_core::utils::database::establish_connection;
-use file_classification_core::model::models::FileFilter;
 // 引入select_files和SearchFile
 
 fn main() {

file_classification_cli/src/bin/list_group_tags_by_conditions.rs

@@ -1,7 +1,7 @@
 use file_classification_core::model::models::GroupTagCondition;
+use file_classification_core::service::group_tag::select_group_tags_by_conditions;
 use file_classification_core::utils::database::establish_connection;
 use std::io::{self, Write};
-use file_classification_core::service::group_tag::select_group_tags_by_conditions;
 
 fn main() {
     let connection = &mut establish_connection();

file_classification_cli/src/bin/list_groups.rs

@@ -1,6 +1,6 @@
+use file_classification_core::model::models::GroupFilter;
 use file_classification_core::service::groups::select_groups;
 use file_classification_core::utils::database::establish_connection;
-use file_classification_core::model::models::GroupFilter;
 // 引入select_groups和SearchGroup
 
 fn main() {

file_classification_cli/src/bin/list_tags.rs

@@ -1,6 +1,6 @@
+use file_classification_core::model::models::TagFilter;
 use file_classification_core::service::tags::select_tags;
 use file_classification_core::utils::database::establish_connection;
-use file_classification_core::model::models::TagFilter;
 // 引入select_tags和SearchTag
 
 fn main() {

file_classification_core/src/internal/file_group.rs

@@ -3,7 +3,7 @@ use crate::internal::{
     files::increase_file_reference_count,
     groups::{find_group_by_id, increase_group_reference_count},
 };
-use crate::model::schema::file_groups;
+use crate::model::schema::{file_groups};
 use diesel::prelude::*;
 use std::fmt::{Debug, Formatter, Result as fmtResult};
 
@@ -27,6 +27,31 @@ pub fn create_file_group(
     let _ = result?;
     Ok(new_file_group)
 }
+
+pub fn delete_file_group(
+    conn: &mut SqliteConnection,
+    file_id: i32,
+    group_id: i32,
+) -> Result<usize, AppError> {
+    let result = conn.transaction::<_, AppError, _>(|conn| {
+        // 减少组和标签的引用计数
+        decrease_group_reference_count(conn, group_id)?;
+        decrease_file_reference_count(conn, file_id)?;
+
+        // 删除关联记录
+        let deleted_count = diesel::delete(
+            file_groups::table
+                .filter(file_groups::group_id.eq(group_id))
+                .filter(file_groups::file_id.eq(file_id))
+        )
+            .execute(conn)?;
+
+        Ok(deleted_count)
+    });
+
+    result.map_err(|e| e)
+}
+
 impl Debug for FileGroupDTO {
     fn fmt(&self, f: &mut Formatter<'_>) -> fmtResult {
         write!(f, "FileGroup {{ file_id: {}, group_id: {} }}", self.file_id, self.group_id)
@@ -39,6 +64,8 @@ use super::models::FileGroupCondition;
 use diesel::dsl::not;
 use diesel::sql_types::Bool;
 use diesel::sqlite::Sqlite;
+use crate::internal::files::decrease_file_reference_count;
+use crate::internal::groups::decrease_group_reference_count;
 
 // 将 FileGroupCondition 转换为 diesel 查询条件的辅助函数
 fn build_file_group_condition(condition: FileGroupCondition) -> Box<dyn BoxableExpression<file_groups::table, Sqlite, SqlType = diesel::sql_types::Bool>> {

file_classification_core/src/internal/group_tag.rs

@@ -17,6 +17,31 @@ pub fn create_group_tag(
     let _ = result?;
     Ok(new_group_tag)
 }
+
+pub fn delete_group_tag(
+    conn: &mut SqliteConnection,
+    group_id: i32,
+    tag_id: i32,
+) -> Result<usize, AppError> {
+    let result = conn.transaction::<_, AppError, _>(|conn| {
+        // 减少组和标签的引用计数
+        decrease_group_reference_count(conn, group_id)?;
+        decrease_tag_reference_count(conn, tag_id)?;
+
+        // 删除关联记录
+        let deleted_count = diesel::delete(
+            group_tags::table
+                .filter(group_tags::group_id.eq(group_id))
+                .filter(group_tags::tag_id.eq(tag_id))
+        )
+        .execute(conn)?;
+
+        Ok(deleted_count)
+    });
+
+    result.map_err(|e| e)
+}
+
 impl Debug for GroupTagDTO {
     fn fmt(&self, f: &mut Formatter<'_>) -> fmtResult {
         write!(f, "GroupTag {{ group_id: {}, tag_id: {} }}", self.group_id, self.tag_id)
@@ -29,6 +54,8 @@ use super::models::GroupTagCondition;
 use diesel::dsl::not;
 use diesel::sql_types::Bool;
 use diesel::sqlite::Sqlite;
+use crate::internal::groups::decrease_group_reference_count;
+use crate::internal::tags::decrease_tag_reference_count;
 
 // 将 GroupTagCondition 转换为 diesel 查询条件的辅助函数
 fn build_group_tag_condition(condition: GroupTagCondition) -> Box<dyn BoxableExpression<group_tags::table, Sqlite, SqlType = diesel::sql_types::Bool>> {