eta_api/models/system/research_group.go

package system

import (
	"eta/eta_api/global"
	"eta/eta_api/utils"
	"fmt"
	"time"
)

// ResearchGroup 研究方向分组表
type ResearchGroup struct {
	ResearchGroupId   int       `orm:"column(research_group_id);pk" gorm:"primaryKey" description:"研究方向分组ID"`
	ResearchGroupName string    `json:"research_group_name" description:"研究方向分组名称"`
	ParentId          int       `json:"parent_id" description:"父类ID"`
	ChartPermissionId int       `json:"chart_permission_id" description:"品种权限ID"`
	Sort              int       `json:"sort" description:"排序"`
	State             int       `json:"state" description:"显示状态 0-不显示 1-显示"`
	CreateTime        time.Time `json:"create_time" description:"创建时间"`
	ModifyTime        time.Time `json:"modify_time" description:"更新时间"`
}

// GetResearchGroupList 获取研究方向分组列表
func GetResearchGroupList() (list []*ResearchGroup, err error) {
	o := global.DbMap[utils.DbNameWeekly]
	sql := `SELECT * FROM research_group WHERE state = 1 ORDER BY sort`
	err = o.Raw(sql).Find(&list).Error
	return
}

// GetResearchGroupById 主键获取分组
func GetResearchGroupById(groupId int) (item *ResearchGroup, err error) {
	o := global.DbMap[utils.DbNameMaster]
	sql := `SELECT * FROM research_group WHERE research_group_id = ? LIMIT 1`
	err = o.Raw(sql, groupId).First(&item).Error
	return
}

// ResearchGroupRelation 研究方向关系表
type ResearchGroupRelation struct {
	Id              int `orm:"column(id);pk" gorm:"primaryKey"`
	ResearchGroupId int `json:"research_group_id" description:"分组ID"`
	AdminId         int `json:"admin_id" description:"研究员ID"`
}

// ResearchGroupRelationListByAdminId 根据研究员ID获取研究方向分组关系列表
func ResearchGroupRelationListByAdminId(adminId int) (list []*ResearchGroupRelation, err error) {
	o := global.DbMap[utils.DbNameMaster]
	sql := `SELECT * FROM research_group_relation WHERE admin_id = ?`
	err = o.Raw(sql, adminId).Find(&list).Error
	return
}

// ResearchGroupRelation 研究方向分组关系表
type ResearchGroupRelationItem struct {
	ResearchGroupId int    `json:"research_group_id" description:"研究方向分组ID"`
	AdminId         int    `json:"admin_id" description:"研究员ID"`
	AdminName       string `json:"admin_name" description:"研究员姓名"`
}

// GetResearchGroupRelationList 获取研究方向分组关系列表
func GetResearchGroupRelationList(include int) (list []*ResearchGroupRelationItem, err error) {
	// 是否包含已禁止的研究员, 默认不包含
	condition := ` WHERE b.enabled = 1 `
	if include == 1 {
		condition = ` WHERE 1=1 `
	}
	o := global.DbMap[utils.DbNameMaster]
	sql := `SELECT
				a.research_group_id,
				a.admin_id,
				b.real_name AS admin_name
			FROM
				research_group_relation AS a
			INNER JOIN admin AS b ON a.admin_id = b.admin_id `
	sql += condition
	sql += ` ORDER BY
				a.research_group_id ASC,
				a.admin_id ASC`
	sql = utils.ReplaceDriverKeywords("", sql)
	err = o.Raw(sql).Find(&list).Error
	return
}

// UpdateAdminResearchGroup 更新研究员研究方向分组
func UpdateAdminResearchGroup(adminId int, items []*ResearchGroupRelation) (err error) {
	o := global.DbMap[utils.DbNameMaster]
	to := o.Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	sql := `DELETE FROM research_group_relation WHERE admin_id = ?`
	if err = o.Exec(sql, adminId).Error; err != nil {
		return
	}
	itemsLen := len(items)
	if itemsLen > 0 {
		err = o.CreateInBatches(items, utils.MultiAddNum).Error
	}
	return
}

// AdminResearchGroupList 研究员研究方向分组列表
type AdminResearchGroupList struct {
	AdminId      int    `json:"admin_id"`
	GroupNameStr string `json:"group_name_str"`
}

// GetAdminResearchGroupListByAdminId 获取研究员研究方向分组列表
func GetAdminResearchGroupListByAdminId(adminIds []int) (list []*AdminResearchGroupList, err error) {
	if len(adminIds) == 0 {
		return
	}
	o := global.DbMap[utils.DbNameMaster]
	sql := fmt.Sprintf(`SELECT
				a.admin_id,
				%s AS group_name_str
			FROM
				research_group_relation AS a
			INNER JOIN research_group AS b ON a.research_group_id = b.research_group_id
			WHERE
				a.admin_id IN (` + utils.GetOrmInReplace(len(adminIds)) + `)
			GROUP BY
				a.admin_id`, utils.GroupUnitFunc(utils.DbDriverName, "b.research_group_name", ",", false, "", "", false))
	err = o.Raw(sql, adminIds).Find(&list).Error
	return
}