spi-stats:fix event.

ideal-world · Dec 4, 2024 · def2140 · def2140
1 parent c853e5e
commit def2140
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/backend/spi/spi-stats/src/event.rs b/backend/spi/spi-stats/src/event.rs
@@ -1,4 +1,4 @@
-use crate::{get_tardis_inst, serv::stats_record_serv};
+use crate::{dto::stats_record_dto::StatsFactRecordLoadReq, get_tardis_inst, serv::stats_record_serv};
 use bios_sdk_invoke::clients::{
     event_client::{get_topic, mq_error, ContextHandler, SPI_RPC_TOPIC},
     spi_log_client::{StatsItemAddReq, StatsItemDeleteReq},
@@ -12,7 +12,15 @@ use tardis::{
 async fn handle_add_event(req: StatsItemAddReq, ctx: TardisContext) -> TardisResult<()> {
     let funs = get_tardis_inst();
     if let Some(ref key) = req.key {
-        stats_record_serv::fact_record_load(&req.tag, key.as_ref(), req.clone().into(), &funs, &ctx).await?;
+        let record_load_req = StatsFactRecordLoadReq {
+            own_paths: req.own_paths.unwrap_or_default(),
+            ct: req.ts.unwrap_or_default(),
+            idempotent_id: req.idempotent_id,
+            ignore_updates: Some(true),
+            data: req.content,
+            ext: req.ext,
+        };
+        stats_record_serv::fact_record_load(&req.tag, key.as_ref(), record_load_req, &funs, &ctx).await?;
     }
     Ok(())
 }