From 8043d6397410a01b9dffc5ec9073d52d8313b106 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Wed, 10 Apr 2024 14:03:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=80=E4=B8=AA=E6=A9=98=E5=AD=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consume/canal_user_money_consume.go | 1 + 1 file changed, 1 insertion(+) 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" {