flow: rust_decimal install (#749)

Author: ZzIsGod1019

Cargo.toml

@@ -50,14 +50,15 @@ strip = true
 [workspace.dependencies]
 # basic
 async-recursion = { version = "1.0.4" }
-bigdecimal = { version = "0.4.3" }
 serde = { version = "1", features = ["derive"] }
 serde_json = { version = "1" }
 async-trait = { version = "0.1" }
 lazy_static = { version = "1" }
 itertools = { version = "0" }
 fancy-regex = { version = "0" }
 run_script = { version = "0.10" }
+rust_decimal = { version = "1" }
+rust_decimal_macros = { version = "1" }
 testcontainers-modules = { version = "0.3", features = ["redis"] }
 strum = { version = "0.26", features = ["derive"] }
 # tardis

backend/middlewares/flow/Cargo.toml

@@ -20,7 +20,8 @@ serde.workspace = true
 serde_json.workspace = true
 async-trait.workspace = true
 async-recursion.workspace = true
-bigdecimal.workspace = true
+rust_decimal.workspace = true
+rust_decimal_macros.workspace = true
 lazy_static.workspace = true
 itertools.workspace = true
 tardis = { workspace = true, features = ["reldb-postgres", "web-client"] }

backend/middlewares/flow/src/serv/flow_event_serv.rs

@@ -1,8 +1,8 @@
-use std::collections::HashMap;
+use std::{collections::HashMap, str::FromStr};
 
 use async_recursion::async_recursion;
-use bigdecimal::{BigDecimal, FromPrimitive, ToPrimitive};
 use bios_basic::rbum::dto::rbum_filer_dto::RbumBasicFilterReq;
+use rust_decimal::Decimal;
 use serde_json::{json, Value};
 use tardis::{
     basic::{dto::TardisContext, result::TardisResult},
@@ -243,22 +243,16 @@ impl FlowEventServ {
                                             change_info.changed_kind = Some(FlowTransitionActionByVarChangeInfoChangedKind::ChangeContent);
                                             match changed_op.as_str() {
                                                 "add" => {
-                                                    change_info.changed_val = Some(json!((BigDecimal::from_f64(
-                                                        original_value.as_str().unwrap_or_default().parse::<f64>().unwrap_or_default()
-                                                    )
-                                                    .unwrap()
-                                                        + BigDecimal::from_f64(target_value).unwrap())
-                                                    .to_f64()
-                                                    .unwrap()))
+                                                    change_info.changed_val = Some(json!(
+                                                        (Decimal::from_str(&original_value.as_str().unwrap_or_default().parse::<f64>().unwrap_or_default().to_string()).unwrap()
+                                                            + Decimal::from_str(&target_value.to_string()).unwrap())
+                                                    ))
                                                 }
                                                 "sub" => {
-                                                    change_info.changed_val = Some(json!((BigDecimal::from_f64(
-                                                        original_value.as_str().unwrap_or_default().parse::<f64>().unwrap_or_default()
-                                                    )
-                                                    .unwrap()
-                                                        - BigDecimal::from_f64(target_value).unwrap())
-                                                    .to_f64()
-                                                    .unwrap()))
+                                                    change_info.changed_val = Some(json!(
+                                                        (Decimal::from_str(&original_value.as_str().unwrap_or_default().parse::<f64>().unwrap_or_default().to_string()).unwrap()
+                                                            - Decimal::from_str(&target_value.to_string()).unwrap())
+                                                    ))
                                                 }
                                                 _ => {}
                                             }

backend/middlewares/flow/tests/test_flow_scenes_fsm.rs

@@ -1,4 +1,5 @@
 use std::collections::HashMap;
+use std::str::FromStr;
 
 use bios_basic::rbum::rbum_enumeration::RbumScopeLevelKind;
 use bios_basic::test::test_http_client::TestHttpClient;
@@ -20,6 +21,7 @@ use bios_mw_flow::dto::flow_transition_dto::{
 
 use bios_mw_flow::dto::flow_var_dto::{FlowVarInfo, RbumDataTypeKind, RbumWidgetTypeKind};
 use bios_sdk_invoke::clients::spi_kv_client::KvItemSummaryResp;
+use rust_decimal::Decimal;
 use tardis::basic::dto::TardisContext;
 
 use tardis::basic::result::TardisResult;
@@ -32,7 +34,6 @@ use tardis::TardisFuns;
 
 pub async fn test(flow_client: &mut TestHttpClient) -> TardisResult<()> {
     info!("【test_flow_scenes_fsm】");
-
     let mut ctx = TardisContext {
         own_paths: "".to_string(),
         ak: "u001".to_string(),