diff --git a/internal/rpc/user/user.go b/internal/rpc/user/user.go index 910c9b5ab479b61b99f145ec504122b644834bfb..bcdea833f49c264f1f7566c9847bf8bf8a13019a 100644 --- a/internal/rpc/user/user.go +++ b/internal/rpc/user/user.go @@ -148,8 +148,8 @@ func (s *userServer) DeleteUsers(_ context.Context, req *pbUser.DeleteUsersReq) var common pbUser.CommonResp resp := pbUser.DeleteUsersResp{CommonResp: &common} for _, userID := range req.DeleteUserIDList { - err := imdb.DeleteUser(userID) - if err != nil { + i := imdb.DeleteUser(userID) + if i == 0 { log.NewError(req.OperationID, "delete user error", userID) common.ErrCode = 201 common.ErrMsg = "some uid deleted failed" diff --git a/pkg/common/db/mysql_model/im_mysql_model/user_model.go b/pkg/common/db/mysql_model/im_mysql_model/user_model.go index 42d573b5e443aa428222253b83c529397ba28ba5..6c9069558ed866aaa798838aef7dfa6f13fe044f 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/user_model.go +++ b/pkg/common/db/mysql_model/im_mysql_model/user_model.go @@ -62,13 +62,13 @@ func UserRegister(user User) error { // CreateTime time.Time `gorm:"column:create_time"` //} -func DeleteUser(userID string) error { +func DeleteUser(userID string) (i int64) { dbConn, err := db.DB.MysqlDB.DefaultGormDB() if err != nil { - return err + return 0 } - err = dbConn.Table("user").Where("user_id=?", userID).Delete(User{}).Error - return err + i = dbConn.Table("user").Where("user_id=?", userID).Delete(User{}).RowsAffected + return i } func GetUserByUserID(userID string) (*User, error) {