eta_bridge/models/eta/sys_group.go

package eta

import (
	"eta/eta_bridge/global"
	"gorm.io/gorm/clause"
	"time"
)

type SysGroup struct {
	GroupId      int       `gorm:"primaryKey;column:group_id;type:int(11);not null" json:"group_id"`
	DepartmentId int       `gorm:"index:idx_department_id;column:department_id;type:int(11)" json:"department_id"` // 部门id
	GroupName    string    `gorm:"column:group_name;type:varchar(255);default:''" json:"group_name"`               // 分组名称
	CreateTime   time.Time `gorm:"column:create_time;type:datetime" json:"create_time"`
	ParentId     int       `gorm:"column:parent_id;type:int(11);default:0" json:"parent_id"`
	Sort         int       `gorm:"column:sort;type:int(10);not null;default:0" json:"sort"` // 排序
	OutID        string    `gorm:"column:out_id" json:"out_id"`                             // 外部id
}

func (m *SysGroup) TableName() string {
	return "sys_group"
}

// Create 新增分组
func (m *SysGroup) Create() (err error) {
	err = global.MYSQL["hz_eta"].Create(m).Error
	return
}

// Update 更新分组
func (m *SysGroup) Update(cols []string) (err error) {
	err = global.MYSQL["hz_eta"].Model(m).Select(cols).Updates(m).Error
	return
}

// GetSysGroupByGroupId 获取分组-根据主键
func GetSysGroupByGroupId(groupId int) (item *SysGroup, err error) {
	err = global.MYSQL["hz_eta"].Where("group_id = ?", groupId).First(&item).Error
	return
}

// GetAllSysGroup 获取所有的分组
func GetAllSysGroup() (items []*SysGroup, err error) {
	err = global.MYSQL["hz_eta"].Find(&items).Error
	return
}

// DeleteGroupByGroupId 删除分组-根据主键
func DeleteGroupByGroupId(groupId int) (err error) {
	sql := `DELETE FROM sys_group WHERE group_id = ? LIMIT 1`
	err = global.MYSQL["hz_eta"].Exec(sql, groupId).Error
	if err != nil {
		return
	}
	// 清除关联
	sql = `UPDATE admin SET group_id = 0, group_name = '' WHERE group_id = ? `
	err = global.MYSQL["hz_eta"].Exec(sql, groupId).Error
	return
}
func BatchInsertOrUpdateGroup(departments []SysGroup) (err error) {
	db := global.MYSQL["hz_eta"]
	OnConflictFunc := clause.OnConflict{
		Columns:   []clause.Column{{Name: "group_id"}},
		DoUpdates: clause.AssignmentColumns([]string{"department_id", "group_name", "parent_id", "sort"}),
	}
	// 执行批量插入或更新操作
	err = db.Clauses(OnConflictFunc).Create(&departments).Error
	return
}