Merge branch 'main' of http://192.168.2.212:3000/zensol/sling_aptsell

# Conflicts:
#	sync.sh

fix_errors.sql

@@ -1,7 +0,0 @@
--- 1. Drop foreign key constraints that prevent data insertion since the parent 'users' table is not part of the replication
-ALTER TABLE `demo`.`crm_sales_visit_records` DROP FOREIGN KEY `fk_recorder_id`;
-ALTER TABLE `demo`.`user_profiles` DROP FOREIGN KEY `fk_1`;
-
--- 2. Drop the generated column 'biz_key' in 'crm_acv_targets' and recreate it as a standard VARCHAR column so Sling can import data into it
-ALTER TABLE `demo`.`crm_acv_targets` DROP COLUMN `biz_key`;
-ALTER TABLE `demo`.`crm_acv_targets` ADD COLUMN `biz_key` VARCHAR(16) NULL COMMENT '业务主键（如FY26Q1，全年为FY26）';

sync.sh

@@ -1,6 +1,10 @@
 
-sling run -r sync_aptselldemo_homelab.yaml
+sling run -r sync_aptselldemo.yaml
 
 sling run -r sync_demo_local.yaml
 
-sling run -r sync_demo_homelab.yaml
+sling run -r sync_demo.yaml
+
+# Sync particular tables to local/homelab
+sling run -r sync_aptselldemo_homelab.yaml --streams qingflow.crm_opportunities_snapshot
+sling run -r sync_demo_homelab.yaml --streams autoflow-demo.crm_opportunities_snapshot

sync_aptselldemo_homelab.yaml

@@ -58,6 +58,8 @@ streams:
     object: "aptselldemo.crm_message_work_items"
   "qingflow.crm_opportunities":
     object: "aptselldemo.crm_opportunities"
+  "qingflow.crm_opportunities_snapshot":
+    object: "aptselldemo.crm_opportunities_snapshot"
   "qingflow.crm_opportunity_review_execution_index":
     object: "aptselldemo.crm_opportunity_review_execution_index"
   "qingflow.crm_opportunity_stage_stay_bucket":

sync_demo_homelab.yaml

@@ -58,6 +58,8 @@ streams:
     object: "demo.crm_message_work_items"
   "autoflow-demo.crm_opportunities":
     object: "demo.crm_opportunities"
+  "autoflow-demo.crm_opportunities_snapshot":
+    object: "demo.crm_opportunities_snapshot"
   "autoflow-demo.crm_opportunity_review_execution_index":
     object: "demo.crm_opportunity_review_execution_index"
   "autoflow-demo.crm_opportunity_stage_stay_bucket":

sync_demo_local.yaml

@@ -58,6 +58,8 @@ streams:
     object: "demo.crm_message_work_items"
   "autoflow-demo.crm_opportunities":
     object: "demo.crm_opportunities"
+  "autoflow-demo.crm_opportunities_snapshot":
+    object: "demo.crm_opportunities_snapshot"
   "autoflow-demo.crm_opportunity_review_execution_index":
     object: "demo.crm_opportunity_review_execution_index"
   "autoflow-demo.crm_opportunity_stage_stay_bucket":