|
@@ -61,6 +61,7 @@ func handleCancalUserMoneyConsume(msg []byte) error { |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|
engine := db.DBs[masterId] |
|
|
engine := db.DBs[masterId] |
|
|
|
|
|
// |
|
|
|
|
|
|
|
|
if canalMsg.Type == md.CanalMsgInsertSqlType { |
|
|
if canalMsg.Type == md.CanalMsgInsertSqlType { |
|
|
if utils.StrToFloat64(canalMsg.Data[0].Amount) > 0 && canalMsg.Data[0].Type == "0" { |
|
|
if utils.StrToFloat64(canalMsg.Data[0].Amount) > 0 && canalMsg.Data[0].Type == "0" { |
|
|