Method Delete

models/member.go:383–456

删除一个用户.

(oldId int, adminId int)

//删除一个用户.

func (m *Member) Delete(oldId int, adminId int) (err error) {
	o := orm.NewOrm()
	err = o.Begin()
	if err != nil {
		return err
	}
	defer func() {
		if err != nil {
			o.Rollback()
		} else {
			o.Commit()
		}
	}()

	_, err = o.Raw("DELETE FROM md_members WHERE member_id = ?", oldId).Exec()
	if err != nil {
		return
	}

	var books []Book
	o.QueryTable("md_books").Filter("member_id", oldId).Limit(10000000).All(&books, "book_id")

	if len(books) > 0 {
		var booksId []interface{}

		for _, book := range books {
			booksId = append(booksId, book.BookId)
		}

		_, err = o.Raw("UPDATE md_books SET member_id = ? WHERE member_id = ?", adminId, oldId).Exec()
		if err != nil {
			return
		}

		_, err = o.Raw("UPDATE md_document_history SET member_id=? WHERE member_id = ?", adminId, oldId).Exec()
		if err != nil {
			return err
		}

		_, err = o.QueryTable("md_documents").Filter("book_id__in", booksId...).Update(orm.Params{"member_id": adminId})
		if err != nil {
			return err
		}
	}

	var relationshipList []*Relationship

	_, err = o.QueryTable(NewRelationship().TableNameWithPrefix()).Filter("member_id", oldId).All(&relationshipList)
	if err == nil {
		for _, relationship := range relationshipList {
			//如果存在创始人，则删除
			if relationship.RoleId == 0 {
				rel := NewRelationship()
				err = o.QueryTable(relationship.TableNameWithPrefix()).Filter("book_id", relationship.BookId).Filter("member_id", adminId).One(rel)
				if err == nil {
					if _, err = o.Delete(relationship); err != nil {
						beego.Error(err)
					}