package dao import ( "errors" "fmt" "yintai-api/app/common/model" "gorm.io/gorm" ) type UserRole struct { db *gorm.DB } func NewUserRole(db ...*gorm.DB) *UserRole { return &UserRole{db: getDB(db...)} } func (r *UserRole) TableName() string { return "yt_user_role" } func (r *UserRole) Create(m *model.UserRole) error { return r.db.Table(r.TableName()).Create(m).Error } func (r *UserRole) Update(m *model.UserRole) error { return r.db.Table(r.TableName()).Save(m).Error } func (r *UserRole) Delete(userID int64) error { return r.db.Table(r.TableName()).Where("user_id = ? ", userID).Delete(&UserRole{}).Error } func (r *UserRole) RoleDelete(roleID int64) error { return r.db.Table(r.TableName()).Where("role_id = ? ", roleID).Delete(&UserRole{}).Error } func (r *UserRole) Get(id int64) (*model.UserRole, error) { var res model.UserRole if err := r.db.Table(r.TableName()).Where("id = ?", id).First(&res).Error; err != nil { if errors.Is(err, gorm.ErrRecordNotFound) { return nil, nil } return nil, err } return &res, nil } func (r *UserRole) Exists(id int64) (bool, error) { var count int64 if err := r.db.Table(r.TableName()).Where("id = ?", id).Count(&count).Error; err != nil { return false, err } return count > 0, nil } func (r *UserRole) List(...any) ([]*model.UserRole, int64, error) { panic("implement me") } func (r *UserRole) GetAccount(roleID int64) ([]*model.User, error) { var res []*model.User tx := r.db.Table(r.TableName()+" as ur ").Where("ur.role_id = ? ", roleID) tx = tx.Joins(fmt.Sprintf(" JOIN %s u ON u.id = ur.user_id", NewUser().TableName())) if err := tx.Order("id desc").Select("u.*").Find(&res).Error; err != nil { return nil, err } return res, nil }