eta_api/models/data_manage/excel/excel_info.go

package excel

import (
	"eta_gn/eta_api/global"
	"eta_gn/eta_api/models/data_manage"
	"eta_gn/eta_api/utils"
	"fmt"
	"strconv"
	"time"
)

type ExcelInfo struct {
	ExcelInfoId        int       `orm:"column(excel_info_id);pk" gorm:"primaryKey" `
	Source             int       `description:"表格来源，1：excel插件的表格，2：自定义表格，3：混合表格，4：自定义分析，默认：1"`
	ExcelType          int       `description:"表格类型，1：指标列，2：日期列，默认：1"`
	ExcelName          string    `description:"表格名称"`
	UniqueCode         string    `description:"表格唯一编码"`
	ExcelClassifyId    int       `description:"表格分类id"`
	SysUserId          int       `description:"操作人id"`
	SysUserRealName    string    `description:"操作人真实姓名"`
	Content            string    `description:"表格内容"`
	ExcelImage         string    `description:"表格图片"`
	FileUrl            string    `description:"表格下载地址"`
	Sort               int       `description:"排序字段，数字越小越排前面"`
	IsDelete           int       `description:"是否删除，0：未删除，1：已删除"`
	ModifyTime         time.Time `description:"最近修改日期"`
	CreateTime         time.Time `description:"创建日期"`
	IsJoinPermission   int       `description:"是否加入权限管控，0：不加入；1：加入；默认：0"`
	ParentId           int       `description:"表格的父级id"`
	BalanceType        int       `description:"平衡表类型：0 动态表，1静态表"`
	UpdateUserId       int       `description:"更新人id"`
	UpdateUserRealName string    `description:"更新人真实姓名"`
	RelExcelInfoId     int       `description:"平衡表里静态表关联的动态表excel id"`
	VersionName        string    `description:"静态表版本名称"`
	SourcesFrom        string    `description:"图表来源"`
}

func (excelInfo *ExcelInfo) Update(cols []string) (err error) {
	err = global.DmSQL["data"].Select(cols).Updates(excelInfo).Error
	return
}

type MyExcelInfoList struct {
	ExcelInfoId        int                   `orm:"column(excel_info_id);pk" gorm:"primaryKey" `
	Source             int                   `description:"表格来源，1：excel插件的表格，2：自定义表格，默认：1"`
	ExcelType          int                   `description:"表格类型，1：指标列，2：日期列，默认：1"`
	ExcelName          string                `description:"表格名称"`
	UniqueCode         string                `description:"表格唯一编码"`
	ExcelClassifyId    int                   `description:"表格分类id"`
	SysUserId          int                   `description:"操作人id"`
	SysUserRealName    string                `description:"操作人真实姓名"`
	ExcelImage         string                `description:"表格图片"`
	FileUrl            string                `description:"表格下载地址"`
	Sort               int                   `description:"排序字段，数字越小越排前面"`
	ModifyTime         time.Time             `description:"最近修改日期"`
	CreateTime         time.Time             `description:"创建日期"`
	IsJoinPermission   int                   `description:"是否加入权限管控，0：不加入；1：加入；默认：0"`
	HaveOperaAuth      bool                  `description:"是否有数据权限"`
	UpdateUserId       int                   `description:"更新人id"`
	UpdateUserRealName string                `description:"更新人真实姓名"`
	Button             ExcelInfoDetailButton `description:"操作权限" gorm:"-"`
	CanEdit            bool                  `description:"是否可编辑"`
	Editor             string                `description:"编辑人"`
}

func AddExcelInfo(excelInfo *ExcelInfo, excelEdbMappingList []*ExcelEdbMapping, childExcel *ExcelInfo) (err error) {
	to := global.DmSQL["data"].Begin()

	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	err = to.Create(excelInfo).Error
	if err != nil {
		return
	}
	if childExcel != nil {
		childExcel.ParentId = excelInfo.ExcelInfoId
		err = to.Create(childExcel).Error
		if err != nil {
			err = fmt.Errorf("新增子表失败：%v", err)
			return
		}
	}
	dataNum := len(excelEdbMappingList)
	if dataNum > 0 {
		for k, v := range excelEdbMappingList {
			v.ExcelInfoId = excelInfo.ExcelInfoId
			excelEdbMappingList[k] = v
		}
		err = to.CreateInBatches(excelEdbMappingList, utils.MultiAddNum).Error
	}

	return
}

func EditExcelInfo(excelInfo *ExcelInfo, updateExcelInfoParams []string, excelEdbMappingList []*ExcelEdbMapping) (err error) {
	to := global.DmSQL["data"].Begin()

	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	err = to.Select(updateExcelInfoParams).Updates(excelInfo).Error
	if err != nil {
		return
	}
	if excelInfo.Source == utils.BALANCE_TABLE && excelInfo.ParentId == 0 {
		sql := `UPDATE FROM excel_info set excel_classify_id = ? WHERE parent_id=? `
		err = to.Exec(sql, excelInfo.ExcelClassifyId, excelInfo.ExcelInfoId).Error
	}

	sql := `DELETE FROM excel_edb_mapping WHERE excel_info_id=? `
	err = to.Exec(sql, excelInfo.ExcelInfoId).Error

	dataNum := len(excelEdbMappingList)
	if dataNum > 0 {
		for k, v := range excelEdbMappingList {
			v.ExcelInfoId = excelInfo.ExcelInfoId
			excelEdbMappingList[k] = v
		}
		err = to.CreateInBatches(excelEdbMappingList, utils.MultiAddNum).Error
	}

	return
}

func GetNoContentExcelInfoAll(source, userId int) (items []*ExcelClassifyItems, err error) {
	sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
	        unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission
	       FROM excel_info where is_delete=0 AND source = ?  `

	pars := []interface{}{source}

	if userId > 0 {
		sql += ` AND sys_user_id = ? `
		pars = append(pars, userId)
	}
	sql += `  ORDER BY sort asc,excel_info_id desc `
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
	return
}

func GetBalanceNoContentExcelInfoAll(source int, excelInfoIds []int, userId int) (items []*ExcelClassifyItems, err error) {
	sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
	        unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission
	       FROM excel_info where is_delete=0 AND source = ?  AND parent_id = 0 AND balance_type=0 `

	pars := []interface{}{source}

	if userId > 0 {
		if len(excelInfoIds) > 0 {
			sql += ` AND (excel_info_id in (` + utils.GetOrmInReplace(len(excelInfoIds)) + `) or sys_user_id = ?)`
			pars = append(pars, excelInfoIds, userId)
		} else {
			sql += ` AND sys_user_id = ? `
			pars = append(pars, userId)
		}
	}

	sql += `  ORDER BY sort asc,excel_info_id desc `
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
	return
}

func GetExcelInfoById(excelInfoId int) (item *ExcelInfo, err error) {
	sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
	err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
	return
}

func GetExcelInfoByUnicode(unicode string) (item *ExcelInfo, err error) {
	sql := ` SELECT * FROM excel_info WHERE unique_code = ? AND is_delete = 0 `
	err = global.DmSQL["data"].Raw(sql, unicode).First(&item).Error
	return
}

func GetExcelInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
	sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
	if condition != "" {
		sql += condition
	}
	err = global.DmSQL["data"].Raw(sql, pars...).Scan(&count).Error
	return
}

func GetNoContentExcelInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ExcelClassifyItems, err error) {
	sql := `SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
	        unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission FROM excel_info WHERE 1=1 `
	if condition != "" {
		sql += condition
	}

	sql += ` AND is_delete=0 ORDER BY excel_info_id DESC LIMIT ?,? `

	pars = append(pars, startSize)
	pars = append(pars, pageSize)
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
	return
}

func GetNoContentExcelInfoListByConditionNoPage(condition string, pars []interface{}) (items []*ExcelInfo, err error) {
	sql := `SELECT excel_info_id,excel_classify_id,excel_name,
	        unique_code,sys_user_id,sys_user_real_name,sort,is_join_permission, parent_id, balance_type, update_user_id,update_user_real_name,rel_excel_info_id,version_name FROM excel_info WHERE is_delete=0 `
	if condition != "" {
		sql += condition
	}

	sql += ` ORDER BY excel_info_id DESC `
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error

	return
}

func GetExcelInfoListByCondition(condition string, pars []interface{}) (items []*ExcelInfo, err error) {
	sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
	if condition != "" {
		sql += condition
	}
	sql += ` ORDER BY sort asc, excel_info_id asc`
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&items).Error
	return
}

func GetNextExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
	sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
	if condition != "" {
		sql += condition
	}
	sql += " ORDER BY sort asc , create_time desc LIMIT 1 "
	err = global.DmSQL["data"].Raw(sql, pars...).First(&item).Error
	return
}

func GetNextExcelInfo(classifyId, classifySort, source int) (item *ExcelInfo, err error) {
	sql := ` SELECT b.* FROM excel_classify AS a
			INNER JOIN excel_info AS b ON a.excel_classify_id=b.excel_classify_id
			WHERE (a.sort>? OR (a.sort=? and a.excel_classify_id>?) ) AND a.is_delete=0 AND b.is_delete=0
			AND a.source = ? AND b.source = ? 
			ORDER BY a.sort ASC,b.sort asc,b.create_time desc
			LIMIT 1 `
	err = global.DmSQL["data"].Raw(sql, classifySort, classifySort, classifyId, source, source).First(&item).Error
	return
}

func GetExcelInfoByUniqueCode(uniqueCode string) (item *ExcelInfo, err error) {
	sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
	err = global.DmSQL["data"].Raw(sql, uniqueCode).First(&item).Error
	return
}

func GetFirstExcelInfoByClassifyId(classifyId int) (item *ExcelInfo, err error) {
	sql := ` SELECT * FROM excel_info WHERE excel_classify_id=? AND is_delete=0 order by sort asc,excel_info_id desc limit 1`
	err = global.DmSQL["data"].Raw(sql, classifyId).First(&item).Error
	return
}

func UpdateExcelInfoSortByClassifyId(classifyId, nowSort, prevExcelInfoId int, updateSort string, source int) (err error) {
	sql := ` update excel_info set sort = ` + updateSort + ` WHERE excel_classify_id=? AND source=? AND is_delete=0 AND ( sort > ? `
	if prevExcelInfoId > 0 {
		sql += ` or (excel_info_id < ` + fmt.Sprint(prevExcelInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `)`
	}
	sql += `)`
	err = global.DmSQL["data"].Exec(sql, classifyId, source, nowSort).Error
	return
}

type ExcelInfoView struct {
	ExcelInfoId       int    `orm:"column(excel_info_id);pk" gorm:"primaryKey" `
	ExcelName         string `description:"来源名称"`
	ExcelClassifyId   int    `description:"表格分类id"`
	ExcelClassifyName string `description:"表格名称"`
	SysUserId         int
	SysUserRealName   string
	UniqueCode        string `description:"表格唯一编码"`
	CreateTime        time.Time
	ModifyTime        time.Time
	DateType          int    `description:"日期类型:1:00年至今,2:10年至今,3:15年至今，4：年初至今，5:自定义时间"`
	StartDate         string `description:"自定义开始日期"`
	EndDate           string `description:"自定义结束日期"`
	IsSetName         int    `description:"设置名称"`
	EdbInfoIds        string `description:"指标id"`
	ExcelType         int    `description:"生成样式:1:曲线图,2:季节性图"`
	Calendar          string `description:"公历/农历"`
	SeasonStartDate   string `description:"季节性图开始日期"`
	SeasonEndDate     string `description:"季节性图开始日期"`
	ExcelImage        string `description:"表格图片"`
	Sort              int    `description:"排序字段，数字越小越排前面"`
	IsAdd             bool   `description:"true:已加入我的图库,false:未加入我的图库"`
	MyExcelId         int
	MyExcelClassifyId string `description:"我的表格分类，多个用逗号隔开"`
	ExcelClassify     []*ExcelClassifyView
	EdbEndDate        string `description:"指标最新更新日期"`
	LeftMin           string `description:"表格左侧最小值"`
	LeftMax           string `description:"表格左侧最大值"`
	RightMin          string `description:"表格右侧最小值"`
	RightMax          string `description:"表格右侧最大值"`
}

func GetNoContentExcelListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyExcelInfoList, err error) {
	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
	FROM excel_info WHERE 1=1 AND is_delete=0 `
	if condition != "" {
		sql += condition
	}
	sql += " ORDER BY create_time DESC LIMIT ?,? "

	pars = append(pars, startSize)
	pars = append(pars, pageSize)
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&item).Error
	return
}

func GetNoContentExcelListByConditionNoPage(condition string, pars []interface{}) (item []*MyExcelInfoList, err error) {
	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name
	FROM excel_info WHERE 1=1 AND is_delete=0 `
	if condition != "" {
		sql += condition
	}
	sql += " ORDER BY create_time DESC"
	err = global.DmSQL["data"].Raw(sql, pars...).Find(&item).Error
	return
}

func GetExcelListCountByCondition(condition string, pars []interface{}) (count int, err error) {
	sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
	if condition != "" {
		sql += condition
	}
	err = global.DmSQL["data"].Raw(sql, pars...).Scan(&count).Error
	return
}

func GetExcelInfoCountByClassifyId(classifyId int) (total int64, err error) {
	sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
	err = global.DmSQL["data"].Raw(sql, classifyId).First(&total).Error
	return
}

func GetNoContentExcelInfoByName(excelName string, source, adminId int) (item *MyExcelInfoList, err error) {
	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name 
	FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 AND sys_user_id = ? `
	err = global.DmSQL["data"].Raw(sql, excelName, source, adminId).First(&item).Error
	return
}

func GetNoContentExcelInfoByUniqueCode(uniqueCode string) (item *MyExcelInfoList, err error) {
	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name 
	FROM excel_info WHERE unique_code=? AND is_delete=0 `
	err = global.DmSQL["data"].Raw(sql, uniqueCode).First(&item).Error
	return
}

func GetNoContentExcelInfoByExcelId(excelInfoId int) (item *MyExcelInfoList, err error) {
	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission,update_user_id,update_user_real_name 
	FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
	err = global.DmSQL["data"].Raw(sql, excelInfoId).First(&item).Error
	return
}

func AddExcelInfoAndSheet(excelInfo *ExcelInfo, sheetParamsList []AddExcelSheetParams) (err error) {
	to := global.DmSQL["data"].Begin()

	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	err = to.Create(excelInfo).Error
	if err != nil {
		return
	}
	for _, sheetInfo := range sheetParamsList {
		dataNum := len(sheetInfo.DataList)

		excelSheetInfo := &ExcelSheet{
			ExcelSheetId: 0,
			ExcelInfoId:  excelInfo.ExcelInfoId,
			SheetName:    sheetInfo.SheetName,
			PageNum:      dataNum,
			Index:        sheetInfo.Index,
			Sort:         sheetInfo.Sort,
			Config:       sheetInfo.Config,
			CalcChain:    sheetInfo.CalcChain,
			ModifyTime:   time.Now(),
			CreateTime:   time.Now(),
		}

		tmpErr := to.Create(excelSheetInfo).Error
		if tmpErr != nil {
			err = tmpErr
			return
		}

		if dataNum > 0 {
			for k, _ := range sheetInfo.DataList {
				sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
				sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
			}

			tmpErr = to.CreateInBatches(sheetInfo.DataList, utils.MultiAddNum).Error
			if tmpErr != nil {
				err = tmpErr
				return
			}
		}
	}

	return
}

func SaveExcelInfoAndSheet(excelInfo *ExcelInfo, updateExcelInfoParam []string, sheetParamsList []AddExcelSheetParams) (err error) {
	to := global.DmSQL["data"].Begin()

	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	err = to.Select(updateExcelInfoParam).Updates(excelInfo).Error
	if err != nil {
		return
	}

	sql := `DELETE FROM excel_sheet WHERE excel_info_id = ?`
	err = to.Exec(sql, excelInfo.ExcelInfoId).Error
	if err != nil {
		return
	}


	sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
	err = to.Exec(sql, excelInfo.ExcelInfoId).Error
	if err != nil {
		return
	}

	for _, sheetInfo := range sheetParamsList {
		dataNum := len(sheetInfo.DataList)

		excelSheetInfo := &ExcelSheet{
			ExcelSheetId: 0,
			ExcelInfoId:  excelInfo.ExcelInfoId,
			SheetName:    sheetInfo.SheetName,
			PageNum:      dataNum,
			Index:        sheetInfo.Index,
			Sort:         sheetInfo.Sort,
			Config:       sheetInfo.Config,
			CalcChain:    sheetInfo.CalcChain,
			ModifyTime:   time.Now(),
			CreateTime:   time.Now(),
		}

		tmpErr := to.Create(excelSheetInfo).Error
		if tmpErr != nil {
			err = tmpErr
			return
		}
		if dataNum > 0 {
			for k, _ := range sheetInfo.DataList {
				sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
				sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
			}
			tmpErr = to.CreateInBatches(sheetInfo.DataList, utils.MultiAddNum).Error
		}
	}

	return
}

type BatchRefreshExcelReq struct {
	ExcelCodes []string `description:"表格编码"`
	PrimaryId  int      `description:"研报/智能研报/PPT主键"`
	SubId      int      `description:"报告章节ID"`
	Source     string   `description:"来源，枚举值：report、english_report、smart_report"`
}

func GetExcelMaxSortByClassifyId(classifyId int, source int) (sort int, err error) {
	sql := ` SELECT COALESCE(MAX(sort),0) AS sort FROM excel_info WHERE excel_classify_id=? AND source = ? AND is_delete=0 order by sort desc,excel_info_id desc limit 1`
	err = global.DmSQL["data"].Raw(sql, classifyId, source).Scan(&sort).Error
	return
}

func GetNoContentExcelListByExcelInfoIdList(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
	num := len(excelInfoIdList)
	if num <= 0 {
		return
	}
	sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
	err = global.DmSQL["data"].Raw(sql, excelInfoIdList).Find(&items).Error
	return
}

func GetNoContentExcelListByExcelInfoIdAndParentId(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
	num := len(excelInfoIdList)
	if num <= 0 {
		return
	}
	sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) OR parent_id in (` + utils.GetOrmInReplace(num) + `)   order by excel_info_id DESC `
	err = global.DmSQL["data"].Raw(sql, excelInfoIdList, excelInfoIdList).Find(&items).Error
	return
}

func GetNoContentExcelListByUserId(userIdList []int) (items []*MyExcelInfoList, err error) {
	num := len(userIdList)
	if num <= 0 {
		return
	}
	sql := ` SELECT * FROM excel_info WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
	err = global.DmSQL["data"].Raw(sql, userIdList).Find(&items).Error

	return
}

func ModifyExcelInfoUserIdByCodeList(excelIdList []string, userId int, userName string) (err error) {
	num := len(excelIdList)
	if num <= 0 {
		return
	}
	sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
	err = global.DmSQL["data"].Exec(sql, userId, userName, excelIdList).Error
	return
}

func ModifyExcelInfoUserIdByOldUserId(oldUserIdList []int, userId int, userName string) (err error) {
	num := len(oldUserIdList)
	if num <= 0 {
		return
	}

	sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE is_delete=0 AND sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
	err = global.DmSQL["data"].Exec(sql, userId, userName, oldUserIdList).Error
	return
}

func GetExcelBaseInfoByExcelInfoIdList(excelInfoIdList []int) (items []*data_manage.ExcelBaseInfo, err error) {
	num := len(excelInfoIdList)
	if num <= 0 {
		return
	}

	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
	err = global.DmSQL["data"].Raw(sql, excelInfoIdList).Find(&items).Error
	return
}

func ReplaceEdbInExcel(oldEdbInfoId, newEdbInfoId int, updateExcelList []*ExcelInfo) (err error) {
	var errmsg string
	logMsg := `` // 记录替换的日志
	replaceTotal := 0
	to := global.DmSQL["data"].Begin()

	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
			if logMsg != `` {
				utils.FileLog.Info(fmt.Sprintf("替换表格中的指标记录，替换总表格数：%d,旧的指标id:%d，新的指标id:%d;%s", replaceTotal, oldEdbInfoId, newEdbInfoId, logMsg))
			}
		}

		if errmsg != "" {
			fmt.Println("errmsg:" + errmsg)
		}
		if err != nil && errmsg != "" {
		}
	}()
	for _, excelInfo := range updateExcelList {

		sql := `UPDATE excel_info SET content=?, modify_time=? WHERE excel_info_id=?`
		err = to.Exec(sql, excelInfo.Content, time.Now(), excelInfo.ExcelInfoId).Error
		if err != nil {
			errmsg = "更新表格内容失败：Err:" + err.Error()
			return
		}

		sql = `DELETE FROM excel_edb_mapping WHERE excel_info_id=? and edb_info_id=?`
		err = to.Exec(sql, excelInfo.ExcelInfoId, newEdbInfoId).Error
		if err != nil {
			errmsg = "删除指标B关联图表配置信息失败：Err:" + err.Error()
			return
		}
		sql = `UPDATE excel_edb_mapping SET edb_info_id=?, modify_time=? WHERE excel_info_id=? and edb_info_id=?`
		err = to.Exec(sql, newEdbInfoId, time.Now(), excelInfo.ExcelInfoId, oldEdbInfoId).Error
		if err != nil {
			errmsg = "更新指标B关联图表配置信息失败：Err:" + err.Error()
			return
		}

		logMsg += `涉及到的表格id：` + strconv.Itoa(excelInfo.ExcelInfoId) + ";"
		replaceTotal += 1
	}
	return
}

func GetChildExcelInfoByParentId(parentId int) (items []*ExcelInfo, err error) {
	sql := ` SELECT excel_info_id,source,excel_type,excel_name,unique_code,excel_classify_id,sys_user_id,sys_user_real_name,excel_image,file_url,sort,create_time,modify_time,is_join_permission, parent_id, balance_type, update_user_id,update_user_real_name FROM excel_info WHERE parent_id=? AND is_delete=0 order by sort asc, excel_info_id asc`
	err = global.DmSQL["data"].Raw(sql, parentId).Find(&items).Error
	return
}

type ExcelInfoDetailButton struct {
	RefreshButton    bool `description:"是否可刷新"`
	CopyButton       bool `description:"是否可另存为"`
	DownloadButton   bool `description:"是否可下载"`
	OpButton         bool `description:"是否可编辑"`
	DeleteButton     bool `description:"是否可删除"`
	OpEdbButton      bool `description:"是否可生成指标"`
	RefreshEdbButton bool `description:"是否可刷新指标"`
	OpWorkerButton   bool `description:"是否修改协作人"`
}

func UpdateExcelInfoClassifyIdByIds(classifyId int, excelIds []int) (err error) {
	if len(excelIds) == 0 {
		return
	}
	sql := fmt.Sprintf(`UPDATE excel_info SET excel_classify_id = ? WHERE excel_info_id IN (%s)`, utils.GetOrmInReplace(len(excelIds)))
	err = global.DmSQL["data"].Exec(sql, classifyId, excelIds).Error
	return
}