spi-stats:fix sync task.

ideal-world · Dec 12, 2024 · a3dbe2f · a3dbe2f
1 parent af2f666
commit a3dbe2f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/backend/spi/spi-search/src/serv/pg/search_pg_item_serv.rs b/backend/spi/spi-search/src/serv/pg/search_pg_item_serv.rs
@@ -941,6 +941,7 @@ fn package_ext(
     }
     Ok(())
 }
+
 fn merge(a: &mut serde_json::Value, b: serde_json::Value) {
     match (a, b) {
         (a @ &mut serde_json::Value::Object(_), serde_json::Value::Object(b)) => {

diff --git a/backend/spi/spi-stats/src/serv/pg/stats_pg_conf_fact_serv.rs b/backend/spi/spi-stats/src/serv/pg/stats_pg_conf_fact_serv.rs
@@ -77,7 +77,7 @@ VALUES
         AddOrModifySyncTaskReq {
             code: format!("{}_{}", SYNC_FACT_TASK_CODE, add_req.key),
             cron: add_req.sync_cron.clone().unwrap_or("".to_string()),
-            callback_url: format!("{}/ci/{}/sync", funs.conf::<StatsConfig>().base_url, add_req.key),
+            callback_url: format!("{}/ci/fact/{}/sync", funs.conf::<StatsConfig>().base_url, add_req.key),
             callback_method: "PUT".to_string(),
             callback_body: None,
             enable: add_req.is_sync.unwrap_or_default(),
@@ -165,7 +165,7 @@ WHERE key = $1
             code: format!("{}_{}", SYNC_FACT_TASK_CODE, fact_conf_key),
             enable: modify_req.is_sync.unwrap_or_default(),
             cron: modify_req.sync_cron.clone().unwrap_or("".to_string()),
-            callback_url: format!("{}/ci/{}/sync", funs.conf::<StatsConfig>().base_url, fact_conf_key),
+            callback_url: format!("{}/ci/fact/{}/sync", funs.conf::<StatsConfig>().base_url, fact_conf_key),
             callback_method: "PUT".to_string(),
             callback_body: None,
             callback_headers,
-Original file line number
+Diff line change
@@ Expand Up / @@ -941,6 +941,7 @@ fn package_ext( @@
         }
         Ok(())
     }
     fn merge(a: &mut serde_json::Value, b: serde_json::Value) {
         match (a, b) {
             (a @ &mut serde_json::Value::Object(_), serde_json::Value::Object(b)) => {
@@ Expand Down @@