|
@@ -55,7 +55,7 @@ func handleCanalGuideOrderByUserUpLvConsume(msg []byte, geoIp2db *geoip2.DBReade |
|
|
var canalMsg *md.CanalOrderMessage[md.CanalGuideOrder] |
|
|
var canalMsg *md.CanalOrderMessage[md.CanalGuideOrder] |
|
|
err := json.Unmarshal(msg, &canalMsg) |
|
|
err := json.Unmarshal(msg, &canalMsg) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return err |
|
|
|
|
|
|
|
|
return nil |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
masterId := strings.Split(canalMsg.Database, "_")[1] |
|
|
masterId := strings.Split(canalMsg.Database, "_")[1] |
|
|