|
|
@@ -73,6 +73,9 @@ func handleEggCanalInviteUserNumsConsume(msg []byte) error { |
|
|
|
// 2. 监听插入信息 |
|
|
|
if canalMsg.Type == md2.CanalMsgInsertSqlType { |
|
|
|
for _, item := range canalMsg.Data { |
|
|
|
if item.Level != "1" { |
|
|
|
return nil |
|
|
|
} |
|
|
|
parentUid := item.ParentUid |
|
|
|
id := fmt.Sprintf("%d%d_%s", year, week, parentUid) |
|
|
|
|
|
|
|