eta_api/models/data_manage/public_chart_info.go

package data_manage

import (
	"eta_gn/eta_api/global"
	"eta_gn/eta_api/utils"
)

// GetChartInfoByPublicClassifyId
// @Description: 根据公共分类id获取指标列表
// @author: Roc
// @datetime 2024-12-03 14:09:32
// @param classifyId int
// @param chartInfoType int
// @param source int
// @return items []*ChartClassifyItems
// @return err error
func GetChartInfoByPublicClassifyId(classifyId, chartInfoType, source int) (items []*ChartClassifyItems, err error) {
	o := global.DmSQL["data"]
	sql := ` SELECT chart_info_id,classify_id,chart_name AS classify_name,chart_name_en AS classify_name_en,unique_code,source_name,source,sys_user_id,sys_user_real_name,start_date,chart_code,chart_type, sort,is_join_permission FROM chart_info WHERE chart_public_classify_id = ? AND chart_info_type = ?`

	pars := []interface{}{classifyId, chartInfoType}

	// 如果筛选了指标类型，那么就根据条件来
	if source > 0 {
		sql += ` AND source = ? `
		pars = append(pars, source)
	}

	sql += ` order by sort asc,chart_info_id asc `
	err = o.Raw(sql, pars...).Scan(&items).Error

	return
}

// UpdatePublicChartSuccess
// @Description: 更新指标的公开成功状态
// @author: Roc
// @datetime 2024-12-06 13:37:01
// @param chartInfoId int
// @param classifyId int
// @return err error
func UpdatePublicChartSuccess(chartInfoId, classifyId int) (err error) {
	sql := `UPDATE chart_info set public_status = ?,chart_public_classify_id = ? ,modify_time=now(),public_time = now()  WHERE chart_info_id  = ?`
	err = global.DmSQL["data"].Exec(sql, utils.DataPublicSuccess, classifyId, chartInfoId).Error

	return
}

// UpdatePublicChart
// @Description: 更新指标的公开状态
// @author: Roc
// @datetime 2024-12-06 11:10:53
// @param chartInfoIdList []int
// @param status int
// @return err error
func UpdatePublicChart(chartInfoIdList []int, status int) (err error) {
	if len(chartInfoIdList) <= 0 {
		return
	}
	sql := `UPDATE chart_info set public_status = ?,modify_time=now() `
	if status == utils.DataPublicSuccess {
		sql += `,public_time = now() `
	}
	sql += ` WHERE chart_info_id in (?) `
	err = global.DmSQL["data"].Exec(sql, status, chartInfoIdList).Error

	return
}

// UpdatePublicClassifyIdByChartInfoIdList
// @Description: 根据指标id列表更新所属公共分类id
// @author: Roc
// @datetime 2024-12-10 13:18:52
// @param chartInfoId int
// @param chartClassifyId int
// @return err error
func UpdatePublicClassifyIdByChartInfoIdList(chartInfoIdList []int, chartClassifyId int) (err error) {
	if len(chartInfoIdList) <= 0 {
		return
	}
	sql := ` UPDATE chart_info SET chart_public_classify_id = ? WHERE  chart_info_id in (?) AND public_status = 3 `
	err = global.DmSQL["data"].Exec(sql, chartClassifyId, chartInfoIdList).Error

	return
}