diff --git a/consume/canal_user_relate_consume.go b/consume/canal_user_relate_consume.go index 0e6e8f5..b3febc9 100644 --- a/consume/canal_user_relate_consume.go +++ b/consume/canal_user_relate_consume.go @@ -85,7 +85,7 @@ func handleCancalUserRelateConsume(msg []byte) error { } else { data1.TeamCount++ } - engine.Where("id=?", data1).AllCols().Update(&data1) + engine.Where("id=?", data1.Id).AllCols().Update(&data1) } return nil