update

app/db/dbs_map.go

@@ -111,7 +111,7 @@ func GetAllDatabaseDev() *[]model.DbMapping {
 	if cfg.Local { // 本地调试 加快速度
 		fmt.Println("notice:LOCAL TEST, only masterId:** 123456 ** available!")
 		err = Db.Where("deleted_at != ? AND is_dev = '1' AND db_master_id= ?", 1, 123456).
-			Or("db_master_id = ?", 12293740).Find(&m)
+			Or("db_master_id = ?", 23674801).Find(&m)
 	} else {
 		err = Db.Where("deleted_at != ? AND is_dev = '1' ", 1).Find(&m)
 	}

consume/init.go

@@ -75,15 +75,15 @@ func initConsumes() {
 	//jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume
 
 	//////////////////////////////////////// bigData /////////////////////////////////////////////////////
-	jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume
-	jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume
-	jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume
-	jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume
-	jobs[consumeMd.CanalGuideOrderForNumericalStatementConsumeFunName] = CanalGuideOrderForNumericalStatementConsume
-	jobs[consumeMd.CanalMallOrderForNumericalStatementConsumeFunName] = CanalMallOrderForNumericalStatementConsume
-	jobs[consumeMd.CanalO2oOrderForNumericalStatementConsumeFunName] = CanalO2oOrderForNumericalStatementConsume
+	//jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume
+	//jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume
+	//jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume
+	//jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume
+	//jobs[consumeMd.CanalGuideOrderForNumericalStatementConsumeFunName] = CanalGuideOrderForNumericalStatementConsume
+	//jobs[consumeMd.CanalMallOrderForNumericalStatementConsumeFunName] = CanalMallOrderForNumericalStatementConsume
+	//jobs[consumeMd.CanalO2oOrderForNumericalStatementConsumeFunName] = CanalO2oOrderForNumericalStatementConsume
 	jobs[consumeMd.CanalO2oPayOrderForNumericalStatementConsumeFunName] = CanalO2oPayOrderForNumericalStatementConsume
-	jobs[consumeMd.CanalB2cOrderForNumericalStatementConsumeFunName] = CanalB2cOrderForNumericalStatementConsume
+	//jobs[consumeMd.CanalB2cOrderForNumericalStatementConsumeFunName] = CanalB2cOrderForNumericalStatementConsume
 
 	//////////////////////////////////////// oneCircles-v1 /////////////////////////////////////////////////////
 	//jobs[consumeMd.OneCirclesSignInGreenEnergyFunName] = OneCirclesSignInGreenEnergyConsume

consume/md/md_canal_o2o_order_consume.go

@@ -60,14 +60,14 @@ type CanalO2oOrder struct {
 }
 
 type CanalO2oOrderMessage[T any] struct {
-	Data     []T      `json:"data"`
-	Database string   `json:"database"`
-	ES       string   `json:"es"`
-	ID       string   `json:"id"`
-	IsDdl    bool     `json:"isDdl"`
-	Old      []T      `json:"old"`
-	PkNames  []string `json:"pkNames"`
-	Table    string   `json:"table"`
-	TS       string   `json:"ts"`
-	Type     string   `json:"type"`
+	Data     []T         `json:"data"`
+	Database string      `json:"database"`
+	ES       interface{} `json:"es"`
+	ID       interface{} `json:"id"`
+	IsDdl    bool        `json:"isDdl"`
+	Old      []T         `json:"old"`
+	PkNames  []string    `json:"pkNames"`
+	Table    string      `json:"table"`
+	TS       interface{} `json:"ts"`
+	Type     string      `json:"type"`
 }

consume/md/md_canal_o2o_pay_to_merchant_consume.go

@@ -26,14 +26,14 @@ type CanalO2oPayToMerchant struct {
 }
 
 type CanalO2oPayToMerchantMessage[T any] struct {
-	Data     []T      `json:"data"`
-	Database string   `json:"database"`
-	ES       string   `json:"es"`
-	ID       string   `json:"id"`
-	IsDdl    bool     `json:"isDdl"`
-	Old      []T      `json:"old"`
-	PkNames  []string `json:"pkNames"`
-	Table    string   `json:"table"`
-	TS       string   `json:"ts"`
-	Type     string   `json:"type"`
+	Data     []T         `json:"data"`
+	Database string      `json:"database"`
+	ES       interface{} `json:"es"`
+	ID       interface{} `json:"id"`
+	IsDdl    bool        `json:"isDdl"`
+	Old      []T         `json:"old"`
+	PkNames  []string    `json:"pkNames"`
+	Table    string      `json:"table"`
+	TS       interface{} `json:"ts"`
+	Type     string      `json:"type"`
 }