|
@@ -0,0 +1,625 @@
|
|
|
+package excel
|
|
|
+
|
|
|
+import (
|
|
|
+ "eta/eta_chart_lib/utils"
|
|
|
+ "fmt"
|
|
|
+ "github.com/beego/beego/v2/client/orm"
|
|
|
+ "time"
|
|
|
+)
|
|
|
+
|
|
|
+
|
|
|
+type ExcelInfo struct {
|
|
|
+ ExcelInfoId int `orm:"column(excel_info_id);pk"`
|
|
|
+ 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"`
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func (excelInfo *ExcelInfo) Update(cols []string) (err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ _, err = o.Update(excelInfo, cols...)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+type MyExcelInfoList struct {
|
|
|
+ ExcelInfoId int `orm:"column(excel_info_id);pk"`
|
|
|
+ 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:"是否有数据权限"`
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func AddExcelInfo(excelInfo *ExcelInfo, excelEdbMappingList []*ExcelEdbMapping) (err error) {
|
|
|
+ o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ _ = o.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = o.Commit()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+ lastId, err := o.Insert(excelInfo)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ excelInfo.ExcelInfoId = int(lastId)
|
|
|
+
|
|
|
+
|
|
|
+ dataNum := len(excelEdbMappingList)
|
|
|
+ if dataNum > 0 {
|
|
|
+ for k, v := range excelEdbMappingList {
|
|
|
+ v.ExcelInfoId = excelInfo.ExcelInfoId
|
|
|
+ excelEdbMappingList[k] = v
|
|
|
+ }
|
|
|
+ _, err = o.InsertMulti(dataNum, excelEdbMappingList)
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func EditExcelInfo(excelInfo *ExcelInfo, updateExcelInfoParams []string, excelEdbMappingList []*ExcelEdbMapping) (err error) {
|
|
|
+ o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ _ = o.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = o.Commit()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+
|
|
|
+ _, err = o.Update(excelInfo, updateExcelInfoParams...)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ sql := `DELETE FROM excel_edb_mapping WHERE excel_info_id=? `
|
|
|
+ _, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
|
|
|
+
|
|
|
+
|
|
|
+ dataNum := len(excelEdbMappingList)
|
|
|
+ if dataNum > 0 {
|
|
|
+ for k, v := range excelEdbMappingList {
|
|
|
+ v.ExcelInfoId = excelInfo.ExcelInfoId
|
|
|
+ excelEdbMappingList[k] = v
|
|
|
+ }
|
|
|
+ _, err = o.InsertMulti(dataNum, excelEdbMappingList)
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelInfoAll() (items []*ExcelClassifyItems, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT excel_info_id,excel_classify_id,excel_name AS excel_classify_name,
|
|
|
+ unique_code,sys_user_id,sys_user_real_name,is_join_permission
|
|
|
+ FROM excel_info where is_delete=0 ORDER BY sort asc,create_time ASC `
|
|
|
+ _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelInfoAll(source, userId int) (items []*ExcelClassifyItems, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 = o.Raw(sql, pars...).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetAllExcelInfoBySource(source int) (items []*ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info where is_delete=0 AND source = ? ORDER BY sort asc,create_time desc `
|
|
|
+ _, err = o.Raw(sql, source).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelInfoById(excelInfoId int) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, excelInfoId).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelInfoByUnicode(unicode string) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE unique_code = ? AND is_delete = 0 `
|
|
|
+ err = o.Raw(sql, unicode).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetExcelInfoViewById(excelInfoId int) (item *ExcelInfoView, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, excelInfoId).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetExcelInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
|
|
|
+ if condition != "" {
|
|
|
+ sql += condition
|
|
|
+ }
|
|
|
+ err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetNoContentExcelInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ExcelClassifyItems, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 ?,? `
|
|
|
+ _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE 1=1 AND is_delete=0 `
|
|
|
+ if condition != "" {
|
|
|
+ sql += condition
|
|
|
+ }
|
|
|
+ err = o.Raw(sql, pars).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNextExcelInfoByCondition(condition string, pars []interface{}) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 = o.Raw(sql, pars).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNextExcelInfo(classifyId, classifySort, source int) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 = o.Raw(sql, classifySort, classifySort, classifyId, source, source).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func EditExcelInfoImage(excelInfoId int, imageUrl string) (err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+
|
|
|
+ sql := ` UPDATE excel_info SET excel_image=?, modify_time = NOW() WHERE excel_info_id = ? AND is_delete=0 `
|
|
|
+ _, err = o.Raw(sql, imageUrl, excelInfoId).Exec()
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("EditExcelInfoImage Err:", err.Error())
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelInfoByUniqueCode(uniqueCode string) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE unique_code=? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, uniqueCode).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetFirstExcelInfoByClassifyId(classifyId int) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE excel_classify_id=? AND is_delete=0 order by sort asc,excel_info_id desc limit 1`
|
|
|
+ err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func UpdateExcelInfoSortByClassifyId(classifyId, nowSort, prevExcelInfoId int, updateSort string, source int) (err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 = o.Raw(sql, classifyId, source, nowSort).Exec()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+type ExcelInfoView struct {
|
|
|
+ ExcelInfoId int `orm:"column(excel_info_id);pk"`
|
|
|
+ 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 GetExcelInfoByClassifyIdAndName(classifyId int, excelName string) (item *ExcelInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE excel_classify_id = ? and excel_name=? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, classifyId, excelName).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*MyExcelInfoList, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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
|
|
|
+FROM excel_info WHERE 1=1 AND is_delete=0 `
|
|
|
+ if condition != "" {
|
|
|
+ sql += condition
|
|
|
+ }
|
|
|
+
|
|
|
+ sql += " ORDER BY create_time DESC LIMIT ?,? "
|
|
|
+ _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetExcelListCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT COUNT(1) AS count FROM excel_info WHERE 1=1 AND is_delete=0 `
|
|
|
+ if condition != "" {
|
|
|
+ sql += condition
|
|
|
+ }
|
|
|
+ err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelViewInfoByExcelInfoId(excelInfoId int) (item *MyExcelInfoList, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 FROM excel_info WHERE excel_info_id = ? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, excelInfoId).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelInfoCountByClassifyId(classifyId int) (total int64, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT count(1) total FROM excel_info WHERE excel_classify_id = ? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, classifyId).QueryRow(&total)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func UpdateExcelInfoClassifyId(classifyId, excelInfoId int) (err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` update excel_info set excel_classify_id = ? WHERE excel_info_id=? `
|
|
|
+ _, err = o.Raw(sql, classifyId, excelInfoId).Exec()
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelInfoByName(excelName string, source int) (item *MyExcelInfoList, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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
|
|
|
+ FROM excel_info WHERE excel_name = ? AND source = ? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, excelName, source).QueryRow(&item)
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelInfoByUniqueCode(uniqueCode string) (item *MyExcelInfoList, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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
|
|
|
+ FROM excel_info WHERE unique_code=? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, uniqueCode).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelInfoByExcelId(excelInfoId int) (item *MyExcelInfoList, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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
|
|
|
+ FROM excel_info WHERE excel_info_id=? AND is_delete=0 `
|
|
|
+ err = o.Raw(sql, excelInfoId).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func AddExcelInfoAndSheet(excelInfo *ExcelInfo, sheetParamsList []AddExcelSheetParams) (err error) {
|
|
|
+ o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ _ = o.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = o.Commit()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+
|
|
|
+ lastId, err := o.Insert(excelInfo)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ excelInfo.ExcelInfoId = int(lastId)
|
|
|
+
|
|
|
+
|
|
|
+ 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(),
|
|
|
+ }
|
|
|
+ sheetId, tmpErr := o.Insert(excelSheetInfo)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ excelSheetInfo.ExcelSheetId = int(sheetId)
|
|
|
+
|
|
|
+
|
|
|
+ if dataNum > 0 {
|
|
|
+ for k, _ := range sheetInfo.DataList {
|
|
|
+ sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
|
|
|
+ sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
|
|
|
+ }
|
|
|
+ _, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func SaveExcelInfoAndSheet(excelInfo *ExcelInfo, updateExcelInfoParam []string, sheetParamsList []AddExcelSheetParams) (err error) {
|
|
|
+ o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ _ = o.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = o.Commit()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+
|
|
|
+ _, err = o.Update(excelInfo, updateExcelInfoParam...)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ sql := `DELETE FROM excel_sheet WHERE excel_info_id = ?`
|
|
|
+ _, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ sql = `DELETE FROM excel_sheet_data WHERE excel_info_id = ?`
|
|
|
+ _, err = o.Raw(sql, excelInfo.ExcelInfoId).Exec()
|
|
|
+ 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(),
|
|
|
+ }
|
|
|
+ sheetId, tmpErr := o.Insert(excelSheetInfo)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ excelSheetInfo.ExcelSheetId = int(sheetId)
|
|
|
+
|
|
|
+
|
|
|
+ if dataNum > 0 {
|
|
|
+ for k, _ := range sheetInfo.DataList {
|
|
|
+ sheetInfo.DataList[k].ExcelSheetId = excelSheetInfo.ExcelSheetId
|
|
|
+ sheetInfo.DataList[k].ExcelInfoId = excelSheetInfo.ExcelInfoId
|
|
|
+ }
|
|
|
+ _, tmpErr = o.InsertMulti(dataNum, sheetInfo.DataList)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+type BatchRefreshExcelReq struct {
|
|
|
+ ExcelCodes []string `description:"表格编码"`
|
|
|
+ ReportId int `description:"报告ID"`
|
|
|
+ ReportChapterId int `description:"报告章节ID"`
|
|
|
+ Source string `description:"来源,枚举值:report、english_report、smart_report"`
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func GetExcelMaxSortByClassifyId(classifyId int, source int) (sort int, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT Max(sort) 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 = o.Raw(sql, classifyId, source).QueryRow(&sort)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelListByExcelInfoIdList(excelInfoIdList []string) (items []*MyExcelInfoList, err error) {
|
|
|
+ num := len(excelInfoIdList)
|
|
|
+ if num <= 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
|
|
|
+ _, err = o.Raw(sql, excelInfoIdList).QueryRows(&items)
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func GetNoContentExcelListByUserId(userIdList []int) (items []*MyExcelInfoList, err error) {
|
|
|
+ num := len(userIdList)
|
|
|
+ if num <= 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT * FROM excel_info WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) order by excel_info_id DESC `
|
|
|
+ _, err = o.Raw(sql, userIdList).QueryRows(&items)
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func ModifyExcelInfoUserIdByCodeList(excelIdList []string, userId int, userName string) (err error) {
|
|
|
+ num := len(excelIdList)
|
|
|
+ if num <= 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := `UPDATE excel_info SET sys_user_id=?,sys_user_real_name=? WHERE excel_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ _, err = o.Raw(sql, userId, userName, excelIdList).Exec()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func ModifyExcelInfoUserIdByOldUserId(oldUserIdList []int, userId int, userName string) (err error) {
|
|
|
+ num := len(oldUserIdList)
|
|
|
+ if num <= 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ 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 = o.Raw(sql, userId, userName, oldUserIdList).Exec()
|
|
|
+ return
|
|
|
+}
|