diff --git a/consume/canal_user_money_consume.go b/consume/canal_user_money_consume.go index f0175a7..0ab4c99 100644 --- a/consume/canal_user_money_consume.go +++ b/consume/canal_user_money_consume.go @@ -61,6 +61,7 @@ func handleCancalUserMoneyConsume(msg []byte) error { return nil } engine := db.DBs[masterId] + // if canalMsg.Type == md.CanalMsgInsertSqlType { if utils.StrToFloat64(canalMsg.Data[0].Amount) > 0 && canalMsg.Data[0].Type == "0" {