package excel import ( "encoding/json" "eta/eta_api/models" "eta/eta_api/models/data_manage" "eta/eta_api/models/data_manage/excel" "eta/eta_api/models/data_manage/excel/request" "eta/eta_api/models/data_manage/excel/response" "eta/eta_api/models/system" "eta/eta_api/services/data" "eta/eta_api/services/data/data_manage_permission" excelService "eta/eta_api/services/data/excel" etaTrialService "eta/eta_api/services/eta_trial" "eta/eta_api/utils" "strconv" "strings" "time" ) // GetChildTable // @Title 获取子表 // @Description 获取子表 // @Param request body request.MixedTableCellDataReq true "type json string" // @router /excel_info/child_table [get] func (c *ExcelInfoController) GetChildTable() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } parentId, _ := c.GetInt("ParentId") if parentId <= 0 { br.Msg = "请选择父表" return } list := make([]*excel.ExcelInfo, 0) // 查询所有子表 childList, err := excel.GetChildExcelInfoByParentId(parentId) if err != nil { br.Msg = "查询子表失败" return } if len(childList) > 0 { list = childList } resp := &response.BalanceChildTableResp{List: list} br.Ret = 200 br.Success = true br.Msg = "查询成功" br.Data = resp } // Rename // @Title 表格重命名接口 // @Description 表格重命名接口 // @Param request body request.EditExcelInfoReq true "type json string" // @Success 200 {object} response.AddExcelInfoResp // @router /excel_info/rename [post] func (c *ExcelInfoController) Rename() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } var req request.RenameExcelInfoReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } if req.ExcelInfoId <= 0 { br.Msg = "请传入ETA表格标识!" return } req.ExcelName = strings.Trim(req.ExcelName, " ") if req.ExcelName == "" { br.Msg = "请填写表格名称!" br.IsSendEmail = false return } excelInfo, err := excel.GetExcelInfoById(req.ExcelInfoId) if err != nil { br.Msg = "获取ETA表格失败" br.ErrMsg = "获取ETA表格失败,Err:" + err.Error() return } //判断表格是否存在 var condition string var pars []interface{} condition += " AND excel_info_id != ? AND excel_classify_id=? AND excel_name=? AND parent_id=?" pars = append(pars, req.ExcelInfoId, excelInfo.ExcelClassifyId, req.ExcelName, excelInfo.ParentId) // 获取分类下是否存在该表格名称 count, err := excel.GetExcelInfoCountByCondition(condition, pars) if err != nil { br.Msg = "ETA判断表格名称是否存在失败" br.ErrMsg = "判断ETA表格名称是否存在失败,Err:" + err.Error() return } if count > 0 { br.Msg = "ETA表格名称已存在,请重新填写" br.IsSendEmail = false return } // todo 操作权限校验, 增加协作人判断 { // 数据权限 haveOperaAuth, err := data_manage_permission.CheckExcelPermissionByExcelInfoId(excelInfo.ExcelInfoId, excelInfo.ExcelClassifyId, excelInfo.IsJoinPermission, c.SysUser.AdminId) if err != nil { br.Msg = "获取ETA表格失败" br.ErrMsg = "获取ETA表格权限失败,Err:" + err.Error() return } button := excelService.GetExcelInfoOpButton(sysUser, excelInfo.SysUserId, excelInfo.Source, haveOperaAuth) if !button.OpButton { br.Msg = "无操作权限" br.Msg = "无操作权限" br.IsSendEmail = false return } } excelInfo.ModifyTime = time.Now() excelInfo.ExcelName = req.ExcelName excelInfo.UpdateUserId = sysUser.AdminId excelInfo.UpdateUserRealName = sysUser.RealName // 自动保存时不会传缩略图,也就不更新这个字段 updateExcelInfoParams := []string{"ModifyTime", "ExcelName", "UpdateUserId", "UpdateUserRealName"} err = excelInfo.Update(updateExcelInfoParams) if err != nil { br.Msg = "保存失败" br.ErrMsg = "保存失败,Err:" + err.Error() return } resp := response.AddExcelInfoResp{ ExcelInfoId: excelInfo.ExcelInfoId, UniqueCode: excelInfo.UniqueCode, } //删除公共图库那边的缓存 _ = utils.Rc.Delete(utils.HZ_CHART_LIB_EXCEL_TABLE_DETAIL + ":" + excelInfo.UniqueCode) br.Ret = 200 br.Success = true br.Msg = "修改成功" br.Data = resp br.IsAddLog = true } // SaveExcelWorker // @Title 新增编辑表格协作人接口 // @Description 新增编辑表格协作人接口 // @Param request body request.EditExcelInfoReq true "type json string" // @Success 200 {object} response.AddExcelInfoResp // @router /excel_info/worker/save [post] func (c *ExcelInfoController) SaveExcelWorker() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } var req request.SaveExcelInfoWorkerReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } if req.ExcelInfoId <= 0 { br.Msg = "请传入ETA表格标识!" return } excelInfo, err := excel.GetExcelInfoById(req.ExcelInfoId) if err != nil { br.Msg = "获取ETA表格失败" br.ErrMsg = "获取ETA表格失败,Err:" + err.Error() return } if excelInfo.SysUserId != sysUser.AdminId { br.Msg = "您没有权限操作!" br.ErrMsg = "您没有权限操作!" return } // todo 操作权限校验, 增加协作人判断 { // 数据权限 haveOperaAuth, err := data_manage_permission.CheckExcelPermissionByExcelInfoId(excelInfo.ExcelInfoId, excelInfo.ExcelClassifyId, excelInfo.IsJoinPermission, c.SysUser.AdminId) if err != nil { br.Msg = "获取ETA表格失败" br.ErrMsg = "获取ETA表格权限失败,Err:" + err.Error() return } button := excelService.GetExcelInfoOpButton(sysUser, excelInfo.SysUserId, excelInfo.Source, haveOperaAuth) if !button.OpButton { br.Msg = "无操作权限" br.Msg = "无操作权限" br.IsSendEmail = false return } } obj := new(excel.ExcelWorker) notDeleteWorkerIds := make([]string, 0) workerMap := make(map[int]struct{}) if req.SysUserIds != "" { notDeleteWorkerIds = strings.Split(req.SysUserIds, ",") } existList, err := obj.GetByExcelInfoId(req.ExcelInfoId) if err != nil { br.Msg = "获取表格协作人失败!" br.ErrMsg = "获取表格协作人失败,Err:" + err.Error() return } for _, v := range existList { workerMap[v.SysUserId] = struct{}{} } addIds := make([]int, 0) for _, v := range notDeleteWorkerIds { id, _ := strconv.Atoi(v) if _, ok := workerMap[id]; !ok { addIds = append(addIds, id) } } // 查询协作人姓名 adminList, err := system.GetAdminListByIdListWithoutEnable(addIds) addList := make([]*excel.ExcelWorker, 0) for _, v := range adminList { addList = append(addList, &excel.ExcelWorker{ ExcelInfoId: req.ExcelInfoId, SysUserId: v.AdminId, SysUserRealName: v.RealName, CreateTime: time.Now(), ModifyTime: time.Now(), }) } // 保存协作人 err = obj.AddWorker(req.ExcelInfoId, addList, notDeleteWorkerIds) if err != nil { br.Msg = "保存失败" br.ErrMsg = "保存失败,Err:" + err.Error() return } br.Ret = 200 br.Success = true br.Msg = "操作成功" } // GetWorker // @Title 查询协作人接口 // @Description 新增编辑表格协作人接口 // @Param request body request.EditExcelInfoReq true "type json string" // @Success 200 {object} response.AddExcelInfoResp // @router /excel_info/worker [get] func (c *ExcelInfoController) GetWorker() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } excelInfoId, _ := c.GetInt("ExcelInfoId") if excelInfoId <= 0 { br.Msg = "请选择表格" br.ErrMsg = "ExcelInfoId未传" br.IsSendEmail = false return } obj := new(excel.ExcelWorker) list, err := obj.GetByExcelInfoId(excelInfoId) if err != nil { br.Msg = "获取表格协作人失败!" br.ErrMsg = "获取表格协作人失败,Err:" + err.Error() return } data := &response.BalanceTableWorkerResp{List: list} br.Data = data br.Ret = 200 br.Success = true br.Msg = "操作成功" } // BalanceChartInfoAdd // @Title 新增图表接口 // @Description 新增图表接口 // @Param request body data_manage.AddChartInfoReq true "type json string" // @Success 200 {object} data_manage.AddChartInfoResp // @router /excel_info/balance/chart_add [post] func (c *ExcelInfoController) BalanceChartInfoAdd() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } deleteCache := true cacheKey := "CACHE_EXCEL_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId) defer func() { if deleteCache { utils.Rc.Delete(cacheKey) } }() if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) { deleteCache = false br.Msg = "系统处理中,请稍后重试!" br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody) return } var req request.AddBalanceTableChartReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } req.ChartName = strings.Trim(req.ChartName, " ") if req.ChartName == "" { br.Msg = "请填写图表名称!" return } chartInfo, err, errMsg, isSendEmail := data.AddBalanceExcelChart(req, sysUser) if err != nil { br.Msg = "保存失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = err.Error() br.IsSendEmail = isSendEmail return } resp := new(data_manage.AddChartInfoResp) resp.ChartInfoId = chartInfo.ChartInfoId resp.UniqueCode = chartInfo.UniqueCode resp.ChartType = req.ChartType //新增操作日志 { chartLog := new(data_manage.ChartInfoLog) chartLog.ChartInfoId = chartInfo.ChartInfoId chartLog.ChartName = req.ChartName chartLog.ChartClassifyId = 0 chartLog.SysUserId = sysUser.AdminId chartLog.SysUserRealName = sysUser.RealName chartLog.UniqueCode = chartInfo.UniqueCode chartLog.CreateTime = time.Now() chartLog.Content = string(c.Ctx.Input.RequestBody) chartLog.Status = "新增图表" chartLog.Method = c.Ctx.Input.URI() go data_manage.AddChartInfoLog(chartLog) } // 试用平台更新用户累计新增图表数 adminItem, e := system.GetSysAdminById(sysUser.AdminId) if e != nil { br.Msg = "操作失败" br.ErrMsg = "获取系统用户数据失败,Err:" + err.Error() return } if utils.BusinessCode == utils.BusinessCodeSandbox && adminItem.DepartmentName == "ETA试用客户" { go func() { var r etaTrialService.EtaTrialUserReq r.Mobile = adminItem.Mobile _, _ = etaTrialService.UpdateUserChartNum(r) }() } br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true } // BalanceChartInfoEdit // @Title 编辑图表接口 // @Description 新增图表接口 // @Param request body data_manage.AddChartInfoReq true "type json string" // @Success 200 {object} data_manage.AddChartInfoResp // @router /excel_info/balance/chart_edit [post] func (c *ExcelInfoController) BalanceChartInfoEdit() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } deleteCache := true cacheKey := "CACHE_EXCEL_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId) defer func() { if deleteCache { utils.Rc.Delete(cacheKey) } }() if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) { deleteCache = false br.Msg = "系统处理中,请稍后重试!" br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody) return } var req request.AddBalanceTableChartReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } req.ChartName = strings.Trim(req.ChartName, " ") if req.ChartName == "" { br.Msg = "请填写图表名称!" return } if req.ChartInfoId <= 0 { br.Msg = "请选择图表" return } chartItem, err, errMsg, isSendEmail := data.EditBalanceExcelChart(req, sysUser) if err != nil { br.Msg = "保存失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = err.Error() br.IsSendEmail = isSendEmail return } resp := new(data_manage.AddChartInfoResp) resp.ChartInfoId = chartItem.ChartInfoId resp.UniqueCode = chartItem.UniqueCode resp.ChartType = req.ChartType //新增操作日志 { chartLog := new(data_manage.ChartInfoLog) chartLog.ChartName = chartItem.ChartName chartLog.ChartInfoId = req.ChartInfoId chartLog.ChartClassifyId = chartItem.ChartClassifyId chartLog.SysUserId = sysUser.AdminId chartLog.SysUserRealName = sysUser.RealName chartLog.UniqueCode = chartItem.UniqueCode chartLog.CreateTime = time.Now() chartLog.Content = string(c.Ctx.Input.RequestBody) chartLog.Status = "编辑图表" chartLog.Method = c.Ctx.Input.URL() go data_manage.AddChartInfoLog(chartLog) } br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true } // GetBalanceChartList // @Title 获取平衡表表关联的图表 // @Description 获取平衡表表关联的图表 // @Param request body request.MixedTableCellDataReq true "type json string" // @router /excel_info/balance/chart_list [get] func (c *ExcelInfoController) GetBalanceChartList() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } excelInfoId, _ := c.GetInt("ExcelInfoId") if excelInfoId <= 0 { br.Msg = "请选择平衡表" return } // 查询所有子表 excelInfo, err := excel.GetExcelInfoById(excelInfoId) if err != nil { if err.Error() == utils.ErrNoRow() { br.Msg = "表格不存在" return } br.Msg = "查询子表失败" br.ErrMsg = "查询子表失败,Err:" + err.Error() return } list := make([]*data_manage.BalanceChartInfoDetailResp, 0) chartInfoList, mappingListMap, dataListMap, err, errMsg := excelService.GetBalanceExcelChartList(excelInfo, "") if err != nil { if errMsg != "" { br.Msg = errMsg br.ErrMsg = err.Error() return } else { br.Msg = "查询图表失败" br.ErrMsg = "查询图表失败,Err:" + err.Error() } return } for _, chartInfo := range chartInfoList { mappingList, ok := mappingListMap[chartInfo.ChartInfoId] if !ok { br.Msg = "未找到图表关联的指标信息" return } var chartInfoResp *data_manage.ChartInfoDetailResp chartInfoResp, err, errMsg = data.GetBalanceExcelChartDetail(chartInfo, mappingList, sysUser, dataListMap) if err != nil { br.Msg = "查询图表详情失败" br.ErrMsg = "查询图表详情失败,Err:" + err.Error() return } chartEdbList := make([]*data_manage.ExcelChartEdbView, 0) for _, v := range mappingList { tmp := &data_manage.ExcelChartEdbView{ ExcelChartEdbId: v.ExcelChartEdbId, DateSequenceStr: v.DateSequence, DataSequenceStr: v.DataSequence, FromTag: v.FromTag, } chartEdbList = append(chartEdbList, tmp) } balanceChartInfoResp := &data_manage.BalanceChartInfoDetailResp{ ChartInfoDetailResp: chartInfoResp, ExcelEdbList: chartEdbList, } list = append(list, balanceChartInfoResp) } ret := &data_manage.BalanceTableChartListResp{List: list} br.Ret = 200 br.Success = true br.Msg = "查询成功" br.Data = ret } // DeleteBalanceChart // @Title 删除平衡表图表 // @Description 删除平衡表图表 // @Param request body data_manage.DeleteChartClassifyReq true "type json string" // @Success 200 Ret=200 删除成功 // @router /excel_info/balance/chart_del [post] func (c *ExcelInfoController) DeleteBalanceChart() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } var req data_manage.DeleteChartClassifyReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } if req.ChartInfoId <= 0 { br.Msg = "参数错误" br.IsSendEmail = false return } //删除图表 if req.ChartInfoId > 0 { chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId) if err != nil { if err.Error() == utils.ErrNoRow() { br.Msg = "图表已删除,请刷新页面" br.ErrMsg = "指标不存在,Err:" + err.Error() return } else { br.Msg = "删除失败" br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error() return } } if chartInfo == nil { br.Msg = "图表已删除,请刷新页面" return } // todo 查询权限 /*chartClassifyItem, err := data_manage.GetChartClassifyById(chartInfo.ChartClassifyId) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表分类详情数据失败,Err:" + err.Error() return } // 已授权图表、分类id permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, chartInfo.ChartInfoId, chartInfo.ChartClassifyId) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取已授权分类id数据失败,Err:" + err.Error() return } // 权限校验 { haveOperaAuth := data_manage_permission.CheckChartPermissionByPermissionIdList(chartInfo.IsJoinPermission, chartClassifyItem.IsJoinPermission, chartInfo.ChartInfoId, chartInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList) //图表操作权限 ok := data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, haveOperaAuth) if !ok { br.Msg = "没有该图表的操作权限" br.ErrMsg = "没有该图表的操作权限" return } }*/ // 获取引用该图表的MyCharts, 用于ES删除 var myCond string var myPars []interface{} myCond += ` AND a.chart_info_id = ? ` myPars = append(myPars, req.ChartInfoId) myCharts, e := data_manage.GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition(myCond, myPars) if e != nil { br.Msg = "删除失败" br.ErrMsg = "获取引用图表的MyChats失败, Err: " + e.Error() return } myIds := make([]int, 0) for _, m := range myCharts { myIds = append(myIds, m.MyChartId) } // 查询图表相关联的数据 edbIds := make([]int, 0) // 查询图表相关联的指标 edbList, e := excel.GetExcelChartEdbMappingByChartInfoId(req.ChartInfoId) if e != nil { br.Msg = "删除失败" br.ErrMsg = "获取图表相关联的指标失败, Err: " + e.Error() return } for _, v := range edbList { edbIds = append(edbIds, v.ExcelChartEdbId) } //删除图表及关联指标 e = data_manage.DeleteBalanceExcelChartInfoAndData(req.ChartInfoId, edbIds) if e != nil { br.Msg = "删除失败" br.ErrMsg = "删除失败,Err:" + e.Error() return } //删除ES { go data.EsDeleteChartInfo(req.ChartInfoId) // 删除MY ETA 图表 es数据 //go data.EsDeleteMyChartInfoByChartInfoId(req.ChartInfoId) go data.EsDeleteMyChartInfoByMyChartIds(myIds) } //新增操作日志 { chartLog := new(data_manage.ChartInfoLog) chartLog.ChartName = chartInfo.ChartName chartLog.ChartInfoId = req.ChartInfoId chartLog.ChartClassifyId = chartInfo.ChartClassifyId chartLog.SysUserId = sysUser.AdminId chartLog.SysUserRealName = sysUser.RealName chartLog.UniqueCode = chartInfo.UniqueCode chartLog.CreateTime = time.Now() chartLog.Content = string(c.Ctx.Input.RequestBody) chartLog.Status = "删除图表" chartLog.Method = c.Ctx.Input.URI() go data_manage.AddChartInfoLog(chartLog) } } br.Ret = 200 br.Msg = "删除成功" br.Success = true br.IsAddLog = true } // BalanceSeasonChartLegendPreview // @Title 季节性图例预览接口 // @Description 季节性图例预览接口 // @Param request body request.BalanceSeasonChartLegendPreviewReq true "type json string" // @Success 200 {object} data_manage.BalanceSeasonChartLegendPreviewResp // @router /excel_info/balance/chartLegend/preview [post] func (c *ExcelInfoController) BalanceSeasonChartLegendPreview() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } var req request.BalanceSeasonChartLegendPreviewReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } if len(req.DateArr) == 0 || len(req.DateArr) == 0 || len(req.DateArr) != len(req.DataArr) { br.Msg = "请输入正确的日期和数据" return } newDataMap := make(map[int]float64) for i, v := range req.DataArr { fv, e := strconv.ParseFloat(v, 64) if e != nil { br.Msg = "数据格式错误" return } newDataMap[i] = fv } //组装成excelEdbData dataList := make([]*data_manage.EdbDataList, 0) for i, v := range req.DateArr { // todo 处理DataTimestamp dataTime, e := time.ParseInLocation(utils.FormatDate, v, time.Local) if e != nil { br.Msg = "日期格式错误" br.ErrMsg = v + "日期格式错误,Err:" + e.Error() return } timestamp := dataTime.UnixNano() / 1e6 tmp := &data_manage.EdbDataList{ EdbDataId: i, DataTime: v, DataTimestamp: timestamp, Value: newDataMap[i], } dataList = append(dataList, tmp) } list, err, errMsg := data.GetBalanceExcelSeasonChartLegendPreview(dataList, req.Calendar, req.SeasonExtraConfig) if err != nil { if errMsg != "" { br.Msg = errMsg } else { br.Msg = "预览失败" } br.ErrMsg = err.Error() return } ret := &data_manage.BalanceSeasonChartLegendPreviewResp{List: list} br.Data = ret br.Ret = 200 br.Success = true br.Msg = "操作成功" } // AddStaticExcel // @Title 新增静态表 // @Description 新增静态表 // @Param request body request.EditExcelInfoReq true "type json string" // @Success 200 {object} response.AddExcelInfoResp // @router /excel_info/balance/static/add [post] func (c *ExcelInfoController) AddStaticExcel() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } var req request.AddBalanceStaticExcelInfoReq err := json.Unmarshal(c.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常!" br.ErrMsg = "参数解析失败,Err:" + err.Error() return } if req.ExcelInfoId <= 0 { br.Msg = "请传入ETA表格标识!" return } cacheKey := "CACHE_TABLE_INFO_BALANCE_STATIC_ADD_" + strconv.Itoa(req.ExcelInfoId) if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) { br.Msg = "系统处理中,请稍后重试!" br.ErrMsg = "系统处理中,请稍后重试!" return } defer func() { _ = utils.Rc.Delete(cacheKey) }() req.VersionName = strings.Trim(req.VersionName, " ") if req.VersionName == "" { br.Msg = "请填写版本名称!" br.IsSendEmail = false return } excelInfo, err, errMsg, isSendEmail := excelService.AddBalanceStaticExcel(req.ExcelInfoId, req.VersionName, sysUser, 0) if err != nil { br.Msg = "复制失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = "复制失败,Err:" + err.Error() br.IsSendEmail = isSendEmail return } resp := new(response.AddExcelInfoResp) resp.ExcelInfoId = excelInfo.ExcelInfoId resp.UniqueCode = excelInfo.UniqueCode br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true }