123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714 |
- package excel
- import (
- "eta_gn/eta_api/global"
- "eta_gn/eta_api/models/data_manage"
- "eta_gn/eta_api/utils"
- "fmt"
- "strconv"
- "time"
- )
- // ExcelInfo excel表格详情表
- 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:"图表来源"`
- }
- // Update 更新 excel表格基础信息
- 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:"编辑人"`
- }
- // AddExcelInfo 新增表格
- 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
- }
- //excelInfo.ExcelInfoId = excelInfo.ExcelInfoId
- // todo 判断如果是平衡表的父级,则新增一个名叫平衡表的子表, 内容为空
- if childExcel != nil {
- // 表格信息入库
- childExcel.ParentId = excelInfo.ExcelInfoId
- err = to.Create(childExcel).Error
- if err != nil {
- err = fmt.Errorf("新增子表失败:%v", err)
- return
- }
- }
- // excel与指标的关联关系
- 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
- }
- // EditExcelInfo 编辑表格
- 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()
- }
- }()
- // ETA表格信息变更
- 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
- // excel与指标的关联关系
- 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
- }
- // GetNoContentExcelInfoAll 获取不含content的表格列表 用于分类展示
- 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
- }
- // GetBalanceNoContentExcelInfoAll 获取不含content的平衡表表格列表 用于分类展示
- 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
- }
- // GetExcelInfoById 根据id 获取eta表格详情
- 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
- }
- // GetExcelInfoByUnicode 编码获取表格
- 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
- }
- // GetNextExcelInfoByCondition 根据条件获取下一个表格
- 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
- }
- // GetNextExcelInfo 根据分类id获取下一个excel表格
- 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
- }
- // GetExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
- 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
- }
- // GetFirstExcelInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
- 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
- }
- // UpdateExcelInfoSortByClassifyId 根据表格id更新排序
- 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 > ? `
- // todo 前一个兄弟节点后移
- 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:"表格右侧最大值"`
- }
- // GetNoContentExcelListByCondition 获取没有content的excel表格列表数据
- 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 sort ASC,chart_info_id DESC LIMIT ?,? "
- 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
- }
- // GetNoContentExcelListByConditionNoPage 获取没有content的excel表格列表数据
- 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 sort ASC,chart_info_id DESC LIMIT ?,? "
- 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
- }
- // GetExcelInfoCountByClassifyId 根据分类id获取名下表格数量
- 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
- }
- // GetNoContentExcelInfoByName 根据名称 获取eta表格详情
- 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
- }
- // GetNoContentExcelInfoByUniqueCode 根据unique_code来获取excel表格详情
- 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
- }
- // GetNoContentExcelInfoByExcelId 根据表格id来获取excel表格详情
- 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
- }
- // AddExcelInfoAndSheet 新增excel
- 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
- }
- // sheet信息入库
- for _, sheetInfo := range sheetParamsList {
- dataNum := len(sheetInfo.DataList)
- //sheet信息入库
- 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
- }
- // data信息入库
- 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
- }
- // SaveExcelInfoAndSheet 编辑保存
- 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
- }
- // 先删除历史的sheet信息
- sql := `DELETE FROM excel_sheet WHERE excel_info_id = ?`
- err = to.Exec(sql, excelInfo.ExcelInfoId).Error
- if err != nil {
- return
- }
- // 再删除历史sheet中的cell data信息
- sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
- err = to.Exec(sql, excelInfo.ExcelInfoId).Error
- if err != nil {
- return
- }
- // sheet信息入库
- for _, sheetInfo := range sheetParamsList {
- dataNum := len(sheetInfo.DataList)
- //sheet信息入库
- 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
- }
- // data信息入库
- 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
- }
- // BatchRefreshExcelReq 批量刷新表格请求
- type BatchRefreshExcelReq struct {
- ExcelCodes []string `description:"表格编码"`
- PrimaryId int `description:"研报/智能研报/PPT主键"`
- SubId int `description:"报告章节ID"`
- Source string `description:"来源,枚举值:report、english_report、smart_report"`
- }
- // GetExcelMaxSortByClassifyId 获取当前分类下,且排序数最大的excel
- 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
- }
- // GetNoContentExcelListByExcelInfoIdList
- // @Description: 根据ETA表格ID列表获取列表信息
- // @param excelInfoIdList []string
- // @return items
- // @return err
- 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
- }
- // GetNoContentExcelListByUserId
- // @Description: 根据ETA表格ID列表获取列表信息
- // @param userIdList []int
- // @return items
- // @return err
- 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
- }
- // ModifyExcelInfoUserIdByCodeList
- // @Description: 根据编码列表修改表格信息
- // @author: Roc
- // @datetime 2024-03-26 14:16:30
- // @param excelIdList []string
- // @param userId int
- // @param userName string
- // @return err error
- 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
- }
- // ModifyExcelInfoUserIdByOldUserId
- // @Description: 根据旧的用户id修改创建人
- // @author: Roc
- // @datetime 2024-03-25 19:14:59
- // @param oldUserId int
- // @param userId int
- // @param userName string
- // @return err error
- 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
- }
- // ReplaceEdbInExcel 替换表格中的指标
- 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 {
- //更新配置中的指标A
- 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
- }
- //更新配置中的指标B
- // 判断是否已存在绑定,如果存在则删除
- 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
- }
- // GetChildExcelInfoByParentId 根据id 获取eta表格详情
- 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
- }
- // ExcelInfoDetailButton 操作按钮
- 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
- }
|