|
@@ -0,0 +1,1732 @@
|
|
|
+package excel
|
|
|
+
|
|
|
+import (
|
|
|
+ "archive/zip"
|
|
|
+ "encoding/json"
|
|
|
+ "errors"
|
|
|
+ "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"
|
|
|
+ excel2 "eta/eta_api/services/excel"
|
|
|
+ "eta/eta_api/utils"
|
|
|
+ "fmt"
|
|
|
+ "github.com/tealeg/xlsx"
|
|
|
+ "io/ioutil"
|
|
|
+ "os"
|
|
|
+ "sort"
|
|
|
+ "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
|
|
|
+ }
|
|
|
+
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ checkExcelInfo := excelInfo
|
|
|
+ if excelInfo.Source == utils.BALANCE_TABLE {
|
|
|
+ checkExcelInfoId := excelInfo.ExcelInfoId
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ checkExcelInfoId = excelInfo.RelExcelInfoId
|
|
|
+ } else {
|
|
|
+ if excelInfo.ParentId > 0 {
|
|
|
+ checkExcelInfoId = excelInfo.ParentId
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if checkExcelInfoId != excelInfo.ExcelInfoId {
|
|
|
+ checkExcelInfo, err = excel.GetExcelInfoById(checkExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取平衡表格信息失败"
|
|
|
+ br.ErrMsg = "获取平衡表格信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 数据权限
|
|
|
+ haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, c.SysUser.AdminId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取ETA表格权限失败"
|
|
|
+ br.ErrMsg = "获取表格权限信息失败,Err" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ button := excelService.GetBalanceExcelInfoOpButton(sysUser.AdminId, checkExcelInfo.SysUserId, haveOperaAuth, checkExcelInfo.ExcelInfoId)
|
|
|
+ if !button.OpButton {
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ // 数据权限
|
|
|
+ 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.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
|
|
|
+ }
|
|
|
+ ret := &response.BalanceTableWorkerResp{List: list}
|
|
|
+ br.Data = ret
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ // 获取表格信息
|
|
|
+ excelInfo, err := excel.GetExcelInfoById(req.ExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取ETA表格失败"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if excelInfo.Source != utils.BALANCE_TABLE {
|
|
|
+ br.Msg = "EXCEL类型错误!"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ checkExcelInfo := excelInfo
|
|
|
+ if excelInfo.Source == utils.BALANCE_TABLE {
|
|
|
+ checkExcelInfoId := excelInfo.ExcelInfoId
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ checkExcelInfoId = excelInfo.RelExcelInfoId
|
|
|
+ } else {
|
|
|
+ if excelInfo.ParentId > 0 {
|
|
|
+ checkExcelInfoId = excelInfo.ParentId
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if checkExcelInfoId != excelInfo.ExcelInfoId {
|
|
|
+ checkExcelInfo, err = excel.GetExcelInfoById(checkExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取平衡表格信息失败"
|
|
|
+ br.ErrMsg = "获取平衡表格信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 数据权限
|
|
|
+ haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, c.SysUser.AdminId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取ETA表格权限失败"
|
|
|
+ br.ErrMsg = "获取表格权限信息失败,Err" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ button := excelService.GetBalanceExcelInfoOpButton(sysUser.AdminId, checkExcelInfo.SysUserId, haveOperaAuth, checkExcelInfo.ExcelInfoId)
|
|
|
+ if !button.OpButton {
|
|
|
+ br.Msg = "无操作权限"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 判断如果是静态表,则查询表数据,落库
|
|
|
+ dataListMap := make(map[int][]*data_manage.EdbDataList)
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ newExcelDataMap, excelAllRows, excelAllCols, e, errMsg := excelService.GetBalanceExcelData(excelInfo, c.Lang)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取表格数据失败"
|
|
|
+ if errMsg != "" {
|
|
|
+ br.Msg = errMsg
|
|
|
+ }
|
|
|
+ br.ErrMsg = "获取表格数据失败,Err:" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for k, mapping := range req.ChartEdbInfoList {
|
|
|
+ tmpMapping := &excel.ExcelChartEdb{
|
|
|
+ ExcelChartEdbId: k,
|
|
|
+ DateSequence: mapping.DateSequenceStr,
|
|
|
+ DataSequence: mapping.DataSequenceStr,
|
|
|
+ }
|
|
|
+ er, msg := excelService.GetBalanceExcelEdbData(tmpMapping, newExcelDataMap, dataListMap, excelAllRows, excelAllCols)
|
|
|
+ if er != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf(" 获取图表,指标信息失败 Err:%s, %s", msg, er.Error()))
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ chartInfo, err, errMsg, isSendEmail := data.AddBalanceExcelChart(excelInfo, req, sysUser, dataListMap)
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ // 获取表格信息
|
|
|
+ excelInfo, err := excel.GetExcelInfoById(req.ExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取ETA表格失败"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if excelInfo.Source != utils.BALANCE_TABLE {
|
|
|
+ br.Msg = "EXCEL类型错误!"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ checkExcelInfo := excelInfo
|
|
|
+ if excelInfo.Source == utils.BALANCE_TABLE {
|
|
|
+ checkExcelInfoId := excelInfo.ExcelInfoId
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ checkExcelInfoId = excelInfo.RelExcelInfoId
|
|
|
+ } else {
|
|
|
+ if excelInfo.ParentId > 0 {
|
|
|
+ checkExcelInfoId = excelInfo.ParentId
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if checkExcelInfoId != excelInfo.ExcelInfoId {
|
|
|
+ checkExcelInfo, err = excel.GetExcelInfoById(checkExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取平衡表格信息失败"
|
|
|
+ br.ErrMsg = "获取平衡表格信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 数据权限
|
|
|
+ haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, c.SysUser.AdminId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取ETA表格权限失败"
|
|
|
+ br.ErrMsg = "获取表格权限信息失败,Err" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ button := excelService.GetBalanceExcelInfoOpButton(sysUser.AdminId, checkExcelInfo.SysUserId, haveOperaAuth, checkExcelInfo.ExcelInfoId)
|
|
|
+ if !button.OpButton {
|
|
|
+ br.Msg = "无操作权限"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 判断如果是静态表,则查询表数据,落库
|
|
|
+ dataListMap := make(map[int][]*data_manage.EdbDataList)
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ newExcelDataMap, excelAllRows, excelAllCols, e, errMsg := excelService.GetBalanceExcelData(excelInfo, c.Lang)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取表格数据失败"
|
|
|
+ if errMsg != "" {
|
|
|
+ br.Msg = errMsg
|
|
|
+ }
|
|
|
+ br.ErrMsg = "获取表格数据失败,Err:" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for k, mapping := range req.ChartEdbInfoList {
|
|
|
+ tmpMapping := &excel.ExcelChartEdb{
|
|
|
+ ExcelChartEdbId: k,
|
|
|
+ DateSequence: mapping.DateSequenceStr,
|
|
|
+ DataSequence: mapping.DataSequenceStr,
|
|
|
+ }
|
|
|
+ er, msg := excelService.GetBalanceExcelEdbData(tmpMapping, newExcelDataMap, dataListMap, excelAllRows, excelAllCols)
|
|
|
+ if er != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf(" 获取图表,指标信息失败 Err:%s, %s", msg, er.Error()))
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ chartItem, err, errMsg, isSendEmail := data.EditBalanceExcelChart(excelInfo, req, sysUser, dataListMap)
|
|
|
+ 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
|
|
|
+ }
|
|
|
+
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ // 获取表格信息
|
|
|
+ excelInfo, e := excel.GetExcelInfoByChartInfoId(req.ChartInfoId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取ETA表格失败"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ checkExcelInfo := excelInfo
|
|
|
+ if excelInfo.Source == utils.BALANCE_TABLE {
|
|
|
+ checkExcelInfoId := excelInfo.ExcelInfoId
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ checkExcelInfoId = excelInfo.RelExcelInfoId
|
|
|
+ } else {
|
|
|
+ if excelInfo.ParentId > 0 {
|
|
|
+ checkExcelInfoId = excelInfo.ParentId
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if checkExcelInfoId != excelInfo.ExcelInfoId {
|
|
|
+ checkExcelInfo, e = excel.GetExcelInfoById(checkExcelInfoId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取平衡表格信息失败"
|
|
|
+ br.ErrMsg = "获取平衡表格信息失败,Err:" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 数据权限
|
|
|
+ haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, c.SysUser.AdminId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取ETA表格权限失败"
|
|
|
+ br.ErrMsg = "获取表格权限信息失败,Err" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ button := excelService.GetBalanceExcelInfoOpButton(sysUser.AdminId, checkExcelInfo.SysUserId, haveOperaAuth, checkExcelInfo.ExcelInfoId)
|
|
|
+ if !button.OpButton {
|
|
|
+ br.Msg = "无操作权限"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ 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)
|
|
|
+ }
|
|
|
+
|
|
|
+ //删除图表及关联指标
|
|
|
+ e = excel.DeleteBalanceExcelChartInfoAndData(req.ChartInfoId)
|
|
|
+ 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 {
|
|
|
+ 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)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 对dataList 根据dataTimestamp 进行排序
|
|
|
+ sort.Slice(dataList, func(i, j int) bool {
|
|
|
+ return dataList[i].DataTimestamp < dataList[j].DataTimestamp
|
|
|
+ })
|
|
|
+
|
|
|
+ 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
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取原ETA表格信息
|
|
|
+ oldExcelInfo, err := excel.GetExcelInfoById(req.ExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取ETA表格失败"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ // 数据权限
|
|
|
+ haveOperaAuth, err := data_manage_permission.CheckExcelPermissionByExcelInfoId(oldExcelInfo.ExcelInfoId, oldExcelInfo.ExcelClassifyId, oldExcelInfo.IsJoinPermission, c.SysUser.AdminId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取ETA表格失败"
|
|
|
+ br.ErrMsg = "获取ETA表格权限失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ button := excelService.GetExcelInfoOpButton(sysUser, oldExcelInfo.SysUserId, oldExcelInfo.Source, haveOperaAuth)
|
|
|
+ if !button.OpButton {
|
|
|
+ br.Msg = "无操作权限"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 查询出每个子表的内容,并将内容转为静态版本
|
|
|
+ excelDataMap := make(map[int]map[int][]*data_manage.EdbDataList)
|
|
|
+ //查询动态表所有的子表,并复制为静态表
|
|
|
+ condition := " AND parent_id = ? AND balance_type = 0 "
|
|
|
+ var pars []interface{}
|
|
|
+ pars = append(pars, req.ExcelInfoId)
|
|
|
+ childExcelList, err := excel.GetExcelInfoListByCondition(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取子表失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取子表失败 %s", err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for k, childExcelInfo := range childExcelList {
|
|
|
+ //得到表格数据并落库
|
|
|
+
|
|
|
+ newExcelDataMap, excelAllRows, excelAllCols, e, errMsg := excelService.GetBalanceExcelData(childExcelInfo, c.Lang)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取表格数据失败"
|
|
|
+ if errMsg != "" {
|
|
|
+ br.Msg = errMsg
|
|
|
+ }
|
|
|
+ br.ErrMsg = "获取表格数据失败,Err:" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpMappingList, e := excel.GetExcelChartEdbMappingByExcelInfoId(childExcelInfo.ExcelInfoId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取图表,指标信息失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf(" 获取图表,指标信息失败 Err:%s", err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tmpMappingList) > 0 {
|
|
|
+ for _, mapping := range tmpMappingList {
|
|
|
+ child, ok := excelDataMap[mapping.ChartInfoId]
|
|
|
+ if !ok {
|
|
|
+ child = make(map[int][]*data_manage.EdbDataList)
|
|
|
+ }
|
|
|
+ er, msg := excelService.GetBalanceExcelEdbData(mapping, newExcelDataMap, child, excelAllRows, excelAllCols)
|
|
|
+ if er != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf(" 获取图表,指标信息失败 Err:%s, %s", msg, er.Error()))
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ excelDataMap[mapping.ChartInfoId] = child
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ content, e := excelService.TransferBalanceExcelContentToStatic(childExcelInfo, c.Lang)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "动态内容转成静态失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("动态内容转成静态失败 %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ childExcelList[k].Content = content
|
|
|
+ }
|
|
|
+
|
|
|
+ excelInfo, err, errMsg, isSendEmail := data.AddBalanceStaticExcel(oldExcelInfo, oldExcelInfo.ExcelClassifyId, req.VersionName, sysUser, 0, req.ExcelInfoId, 1, childExcelList, true, excelDataMap)
|
|
|
+ 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
|
|
|
+}
|
|
|
+
|
|
|
+// BalanceVersionList
|
|
|
+// @Title 查询平衡表版本号列表
|
|
|
+// @Description 查询平衡表版本号列表
|
|
|
+// @Param request body request.EditExcelInfoReq true "type json string"
|
|
|
+// @Success 200 {object} response.AddExcelInfoResp
|
|
|
+// @router /excel_info/balance/version [get]
|
|
|
+func (c *ExcelInfoController) BalanceVersionList() {
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ excelInfo, err := excel.GetExcelInfoById(excelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取ETA表格失败"
|
|
|
+ br.ErrMsg = "获取ETA表格失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if excelInfo.Source != utils.BALANCE_TABLE {
|
|
|
+ br.Msg = "请选择平衡表"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if excelInfo.BalanceType != 0 && excelInfo.ParentId != 0 {
|
|
|
+ br.Msg = "请选择动态平衡表"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ list := make([]*response.BalanceTableVersionListItem, 0)
|
|
|
+ list = append(list, &response.BalanceTableVersionListItem{
|
|
|
+ ExcelInfoId: excelInfo.ExcelInfoId,
|
|
|
+ UniqueCode: excelInfo.UniqueCode,
|
|
|
+ BalanceType: excelInfo.BalanceType,
|
|
|
+ RelExcelInfoId: excelInfo.RelExcelInfoId,
|
|
|
+ VersionName: "动态表", //todo 有个默认的版本名称
|
|
|
+ })
|
|
|
+ //查询动态表所有的子表,并复制为静态表
|
|
|
+ condition := " AND rel_excel_info_id=? AND parent_id = 0 AND balance_type = 1 "
|
|
|
+ var pars []interface{}
|
|
|
+ pars = append(pars, excelInfoId)
|
|
|
+
|
|
|
+ staticList, err := excel.GetNoContentExcelInfoListByConditionNoPage(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取子表失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取子表失败 %s", err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, staticInfo := range staticList {
|
|
|
+ tmp := &response.BalanceTableVersionListItem{
|
|
|
+ ExcelInfoId: staticInfo.ExcelInfoId,
|
|
|
+ UniqueCode: staticInfo.UniqueCode,
|
|
|
+ BalanceType: staticInfo.BalanceType,
|
|
|
+ RelExcelInfoId: staticInfo.RelExcelInfoId,
|
|
|
+ VersionName: staticInfo.VersionName,
|
|
|
+ }
|
|
|
+ list = append(list, tmp)
|
|
|
+ }
|
|
|
+ ret := &response.BalanceTableVersionListResp{List: list}
|
|
|
+ br.Data = ret
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|
|
|
+
|
|
|
+// ModifyBalanceExcelVersion
|
|
|
+// @Title 版本号重命名
|
|
|
+// @Description 版本号重命名
|
|
|
+// @Param request body request.AddBalanceStaticExcelInfoReq true "type json string"
|
|
|
+// @Success 200 {object} response.AddExcelInfoResp
|
|
|
+// @router /excel_info/balance/version/modify [post]
|
|
|
+func (c *ExcelInfoController) ModifyBalanceExcelVersion() {
|
|
|
+ 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
|
|
|
+ }
|
|
|
+
|
|
|
+ req.VersionName = strings.Trim(req.VersionName, " ")
|
|
|
+ if req.VersionName == "" {
|
|
|
+ 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
|
|
|
+ }
|
|
|
+ if excelInfo.Source != utils.BALANCE_TABLE {
|
|
|
+ br.Msg = "请选择平衡表"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if excelInfo.BalanceType != 1 && excelInfo.ParentId != 0 {
|
|
|
+ br.Msg = "请选择静态表"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 操作权限校验, 增加协作人判断
|
|
|
+ {
|
|
|
+ checkExcelInfo := excelInfo
|
|
|
+ if excelInfo.Source == utils.BALANCE_TABLE {
|
|
|
+ checkExcelInfoId := excelInfo.ExcelInfoId
|
|
|
+ if excelInfo.BalanceType == 1 {
|
|
|
+ checkExcelInfoId = excelInfo.RelExcelInfoId
|
|
|
+ } else {
|
|
|
+ if excelInfo.ParentId > 0 {
|
|
|
+ checkExcelInfoId = excelInfo.ParentId
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if checkExcelInfoId != excelInfo.ExcelInfoId {
|
|
|
+ checkExcelInfo, err = excel.GetExcelInfoById(checkExcelInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "获取平衡表格信息失败"
|
|
|
+ br.ErrMsg = "获取平衡表格信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 数据权限
|
|
|
+ haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, c.SysUser.AdminId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取ETA表格权限失败"
|
|
|
+ br.ErrMsg = "获取表格权限信息失败,Err" + e.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ button := excelService.GetBalanceExcelInfoOpButton(sysUser.AdminId, checkExcelInfo.SysUserId, haveOperaAuth, checkExcelInfo.ExcelInfoId)
|
|
|
+ if !button.OpButton {
|
|
|
+ br.Msg = "无操作权限"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 检验分类下是否存在该版本号
|
|
|
+ {
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ condition += " AND rel_excel_info_id=? AND parent_id=0"
|
|
|
+ pars = append(pars, req.ExcelInfoId)
|
|
|
+
|
|
|
+ condition += " AND version_name=? "
|
|
|
+ pars = append(pars, req.VersionName)
|
|
|
+
|
|
|
+ count, tmpErr := excel.GetExcelInfoCountByCondition(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ br.Msg = "查询版本名称失败"
|
|
|
+ br.ErrMsg = tmpErr.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if count > 0 {
|
|
|
+ br.Msg = "表格版本名称已存在,请重新填写版本名称"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ excelInfo.ModifyTime = time.Now()
|
|
|
+ excelInfo.VersionName = req.VersionName
|
|
|
+ updateExcelInfoParams := []string{"ModifyTime", "VersionName"}
|
|
|
+ // todo 同步修改静态表中的图表和指标名称
|
|
|
+ // ETA表格信息变更
|
|
|
+ err = excelInfo.Update(updateExcelInfoParams)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = "操作失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+ br.IsAddLog = true
|
|
|
+}
|
|
|
+
|
|
|
+func downloadBalanceTable(excelInfo *excel.ExcelInfo, lang string) (savePath, zipName string, uploadDir string, err error, errMsg string) {
|
|
|
+ dateDir := time.Now().Format("20060102")
|
|
|
+ randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
|
|
|
+ uploadDir = "static/xls/" + dateDir + "/" + randStr
|
|
|
+ err = os.MkdirAll(uploadDir, utils.DIR_MOD)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ fileList := make([]string, 0)
|
|
|
+ if excelInfo.ParentId != 0 && excelInfo.BalanceType != 0 {
|
|
|
+ errMsg = "平衡表类型错误"
|
|
|
+ err = fmt.Errorf("平衡表类型错误 ")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //复制静态表
|
|
|
+ staticCondition := " AND parent_id = 0 AND balance_type = 1 AND rel_excel_info_id=? "
|
|
|
+ var staticPars []interface{}
|
|
|
+ staticPars = append(staticPars, excelInfo.ExcelInfoId)
|
|
|
+ excelList, err := excel.GetExcelInfoListByCondition(staticCondition, staticPars)
|
|
|
+ if err != nil {
|
|
|
+ errMsg = "获取表格失败"
|
|
|
+ err = fmt.Errorf("获取表格失败 %s", err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ excelList = append(excelList, excelInfo)
|
|
|
+ for _, staticExcelInfo := range excelList {
|
|
|
+ cCondition := " AND parent_id = ?"
|
|
|
+ var cPars []interface{}
|
|
|
+ cPars = append(cPars, staticExcelInfo.ExcelInfoId)
|
|
|
+ childList, e := excel.GetExcelInfoListByCondition(cCondition, cPars)
|
|
|
+ if e != nil {
|
|
|
+ errMsg = "获取子表失败"
|
|
|
+ err = fmt.Errorf("获取子表失败 %s", err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ xlsxFile := xlsx.NewFile()
|
|
|
+ fileName := staticExcelInfo.ExcelName + ".xlsx"
|
|
|
+ fpath := uploadDir + "/" + fileName
|
|
|
+ for _, childExcelInfo := range childList {
|
|
|
+ var result request.MixedTableReq
|
|
|
+ err = json.Unmarshal([]byte(childExcelInfo.Content), &result)
|
|
|
+ if err != nil {
|
|
|
+ errMsg = "获取失败"
|
|
|
+ err = fmt.Errorf("表格json转结构体失败,Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ newResult, er, msg := excelService.GetMixedTableCellData(result, lang)
|
|
|
+ if er != nil {
|
|
|
+ err = er
|
|
|
+ errMsg = msg
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tableData, er := excel2.GetTableDataByMixedTableData(newResult)
|
|
|
+ if er != nil {
|
|
|
+ errMsg = "获取失败"
|
|
|
+ err = fmt.Errorf("转换成table失败,Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 将单个sheet的数据写入到excel
|
|
|
+ err = tableData.WriteExcelSheetData(xlsxFile, childExcelInfo.ExcelName)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //处理excel文件
|
|
|
+ //return
|
|
|
+ err = xlsxFile.Save(fpath)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ fileList = append(fileList, fileName)
|
|
|
+ }
|
|
|
+ // 创建zip
|
|
|
+ zipName = excelInfo.ExcelName + ".zip"
|
|
|
+
|
|
|
+ savePath = uploadDir + "/" + zipName
|
|
|
+ fmt.Println(savePath)
|
|
|
+ zipFile, err := os.Create(savePath)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ zipWriter := zip.NewWriter(zipFile)
|
|
|
+ // 生成zip过程中报错关闭
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ zipWriter.Close()
|
|
|
+ zipFile.Close()
|
|
|
+ }
|
|
|
+ //os.Remove(savePath)
|
|
|
+ }()
|
|
|
+ //写入zip
|
|
|
+ for i := 0; i < len(fileList); i++ {
|
|
|
+ ioWriter, e := zipWriter.Create(fileList[i])
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("创建zip失败,Err:" + e.Error())
|
|
|
+ if os.IsPermission(e) {
|
|
|
+ fmt.Println("权限不足: ", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+ }
|
|
|
+ fullPath := uploadDir + "/" + fileList[i]
|
|
|
+ content, e := ioutil.ReadFile(fullPath)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("读取文件失败,Err:" + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ ioWriter.Write(content)
|
|
|
+ }
|
|
|
+ // 生成zip后关闭,否则下载文件会损坏
|
|
|
+ zipWriter.Close()
|
|
|
+ zipFile.Close()
|
|
|
+ //this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func refreshBalanceTable(excelDetail response.ExcelInfoDetail, lang string) (err error) {
|
|
|
+ edbInfoIds := make([]int, 0)
|
|
|
+ edbInfoIdExist := make(map[int]bool)
|
|
|
+ if excelDetail.ParentId > 0 {
|
|
|
+ newResult := excelDetail.TableData.(request.MixedTableReq)
|
|
|
+ newData := newResult.Data
|
|
|
+ if len(newData) > 0 {
|
|
|
+ for _, t := range newData {
|
|
|
+ for _, v := range t {
|
|
|
+ if v.EdbInfoId > 0 && !edbInfoIdExist[v.EdbInfoId] {
|
|
|
+ edbInfoIdExist[v.EdbInfoId] = true
|
|
|
+ edbInfoIds = append(edbInfoIds, v.EdbInfoId)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 清除缓存
|
|
|
+ key := utils.HZ_CHART_LIB_EXCEL_TABLE_DETAIL + ":" + excelDetail.UniqueCode
|
|
|
+ if utils.Re == nil {
|
|
|
+ _ = utils.Rc.Delete(key)
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ //查询父表和子表
|
|
|
+ cCondition := " AND parent_id = ? AND balance_type=0"
|
|
|
+ var cPars []interface{}
|
|
|
+ cPars = append(cPars, excelDetail.ExcelInfoId)
|
|
|
+ childList, e := excel.GetExcelInfoListByCondition(cCondition, cPars)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("获取子表失败 %s", err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 遍历
|
|
|
+ for _, child := range childList {
|
|
|
+ var result request.MixedTableReq
|
|
|
+ err = json.Unmarshal([]byte(child.Content), &result)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("表格json转结构体失败,Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var newData [][]request.MixedTableCellDataReq
|
|
|
+ newData, err, _ = excelService.GetMixedTableCellData(result, lang)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(newData) > 0 {
|
|
|
+ for _, t := range newData {
|
|
|
+ for _, v := range t {
|
|
|
+ if v.EdbInfoId > 0 && !edbInfoIdExist[v.EdbInfoId] {
|
|
|
+ edbInfoIdExist[v.EdbInfoId] = true
|
|
|
+ edbInfoIds = append(edbInfoIds, v.EdbInfoId)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 清除缓存
|
|
|
+ key := utils.HZ_CHART_LIB_EXCEL_TABLE_DETAIL + ":" + child.UniqueCode
|
|
|
+ if utils.Re == nil {
|
|
|
+ _ = utils.Rc.Delete(key)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(edbInfoIds) > 0 {
|
|
|
+ err, _ = data.EdbInfoRefreshAllFromBaseV3(edbInfoIds, false, true, false)
|
|
|
+ if err != nil {
|
|
|
+ err = fmt.Errorf("刷新混合表格数据失败, Err: " + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// BalanceChartInfoBaseEdit
|
|
|
+// @Title 编辑图表基础信息接口
|
|
|
+// @Description 编辑图表基础信息接口
|
|
|
+// @Param request body data_manage.EditChartEnInfoBaseReq true "type json string"
|
|
|
+// @Success Ret=200 编辑成功
|
|
|
+// @router /excel_info/balance/chart_base_edit [post]
|
|
|
+func (this *ExcelInfoController) BalanceChartInfoBaseEdit() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var req data_manage.EditChartInfoBaseReq
|
|
|
+ err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "参数解析异常!"
|
|
|
+ br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ req.ChartName = strings.Trim(req.ChartName, " ")
|
|
|
+ if req.ChartInfoId <= 0 {
|
|
|
+ br.Msg = "请选择图表"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //判断指标名称是否存在
|
|
|
+ chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "图表已被删除,请刷新页面"
|
|
|
+ br.ErrMsg = "图表已被删除,请刷新页面"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "获取图表信息失败"
|
|
|
+ br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 判断是否有传入对应的指标配置
|
|
|
+ noEdbInfoType := []int{10}
|
|
|
+ if len(req.ChartEdbInfoList) <= 0 && !utils.InArrayByInt(noEdbInfoType, chartItem.ChartType) {
|
|
|
+ br.Msg = "请选择指标!"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var edbCondition string
|
|
|
+ var edbPars []interface{}
|
|
|
+ for _, v := range req.ChartEdbInfoList {
|
|
|
+ edbInfoId := v.EdbInfoId
|
|
|
+ edbInfo, err := excel.GetExcelChartEdbById(edbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "图表不存在!"
|
|
|
+ br.ErrMsg = "图表指标不存在,ChartInfoId:" + strconv.Itoa(edbInfoId)
|
|
|
+ return
|
|
|
+ } else {
|
|
|
+ br.Msg = "获取图表信息失败!"
|
|
|
+ br.ErrMsg = "获取图表的指标信息失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if edbInfo == nil {
|
|
|
+ br.Msg = "指标不存在!"
|
|
|
+ br.ErrMsg = "指标不存在,ChartInfoId:" + strconv.Itoa(edbInfoId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //判断指标名称是否重复
|
|
|
+ if v.EdbName != "" {
|
|
|
+ edbCondition = ""
|
|
|
+ edbPars = make([]interface{}, 0)
|
|
|
+
|
|
|
+ edbCondition += " AND excel_chart_edb_id<>? AND chart_info_id=?"
|
|
|
+ edbPars = append(edbPars, edbInfo.ExcelChartEdbId, chartItem.ChartInfoId)
|
|
|
+
|
|
|
+ switch this.Lang {
|
|
|
+ case utils.EnLangVersion:
|
|
|
+ edbCondition += " AND edb_name_en =? "
|
|
|
+ default:
|
|
|
+ edbCondition += " AND edb_name =? "
|
|
|
+ }
|
|
|
+
|
|
|
+ edbPars = append(edbPars, v.EdbName)
|
|
|
+
|
|
|
+ edbExist, err := excel.GetBalanceChartEdbByCondition(edbCondition, edbPars)
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "判断英文指标名称是否存在失败"
|
|
|
+ br.ErrMsg = "判断英文指标名称是否存在失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if err == nil && edbExist.ExcelChartEdbId > 0 {
|
|
|
+ br.Msg = edbExist.EdbName + ":" + v.EdbName + "指标名称已存在"
|
|
|
+ br.ErrMsg = "指标名称已存在,请重新填写"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if req.ChartName != "" || req.ExtraConfig != `` {
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ condition += " AND chart_info_id<>? "
|
|
|
+ pars = append(pars, req.ChartInfoId)
|
|
|
+
|
|
|
+ switch this.Lang {
|
|
|
+ case utils.EnLangVersion:
|
|
|
+ condition += " AND chart_name_en = ? "
|
|
|
+ default:
|
|
|
+ condition += " AND chart_name = ? "
|
|
|
+ }
|
|
|
+
|
|
|
+ pars = append(pars, req.ChartName)
|
|
|
+
|
|
|
+ existItem, err := data_manage.GetChartInfoByCondition(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "判断英文图表名称是否存在失败"
|
|
|
+ br.ErrMsg = "判断英文图表名称是否存在失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if err == nil && existItem.ChartInfoId > 0 {
|
|
|
+ br.Msg = existItem.ChartName + ":" + req.ChartName + "图表名称已存在"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ err = excel.EditBalanceChartBaseInfoAndEdbEnInfo(&req, chartItem, this.Lang)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "保存失败"
|
|
|
+ br.ErrMsg = "保存失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //添加es数据
|
|
|
+ go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
|
|
|
+ //修改my eta es数据
|
|
|
+ go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
|
|
|
+
|
|
|
+ //新增操作日志
|
|
|
+ {
|
|
|
+ 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(this.Ctx.Input.RequestBody)
|
|
|
+ chartLog.Status = "编辑图表英文信息"
|
|
|
+ chartLog.Method = this.Ctx.Input.URL()
|
|
|
+ go data_manage.AddChartInfoLog(chartLog)
|
|
|
+ }
|
|
|
+ //清除缓存
|
|
|
+ if utils.Re == nil && utils.Rc != nil {
|
|
|
+ utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
|
|
|
+ utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "编辑成功"
|
|
|
+ br.IsAddLog = true
|
|
|
+}
|