|
@@ -2,19 +2,19 @@ package data_manage
|
|
|
|
|
|
import (
|
|
|
"encoding/json"
|
|
|
+ "eta/eta_api/controllers"
|
|
|
+ "eta/eta_api/models"
|
|
|
+ "eta/eta_api/models/data_manage"
|
|
|
+ "eta/eta_api/models/data_manage/request"
|
|
|
+ "eta/eta_api/models/data_manage/response"
|
|
|
+ "eta/eta_api/services"
|
|
|
+ "eta/eta_api/services/alarm_msg"
|
|
|
+ "eta/eta_api/services/data"
|
|
|
+ "eta/eta_api/services/excel"
|
|
|
+ "eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
"github.com/rdlucklib/rdluck_tools/paging"
|
|
|
"github.com/yidane/formula"
|
|
|
- "hongze/hz_eta_api/controllers"
|
|
|
- "hongze/hz_eta_api/models"
|
|
|
- "hongze/hz_eta_api/models/data_manage"
|
|
|
- "hongze/hz_eta_api/models/data_manage/request"
|
|
|
- "hongze/hz_eta_api/models/data_manage/response"
|
|
|
- "hongze/hz_eta_api/services"
|
|
|
- "hongze/hz_eta_api/services/alarm_msg"
|
|
|
- "hongze/hz_eta_api/services/data"
|
|
|
- "hongze/hz_eta_api/services/excel"
|
|
|
- "hongze/hz_eta_api/utils"
|
|
|
"os"
|
|
|
"strconv"
|
|
|
"strings"
|
|
@@ -32,14 +32,14 @@ type ExcelInfoController struct {
|
|
|
// @Param request body request.AddExcelInfoReq true "type json string"
|
|
|
// @Success 200 {object} response.AddExcelInfoResp
|
|
|
// @router /excel_info/add [post]
|
|
|
-func (this *ExcelInfoController) Add() {
|
|
|
+func (c *ExcelInfoController) Add() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -56,11 +56,11 @@ func (this *ExcelInfoController) Add() {
|
|
|
if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
|
|
|
deleteCache = false
|
|
|
br.Msg = "系统处理中,请稍后重试!"
|
|
|
- br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
|
|
|
+ br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody)
|
|
|
return
|
|
|
}
|
|
|
var req request.AddExcelInfoReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -211,9 +211,9 @@ func (this *ExcelInfoController) Add() {
|
|
|
// SysUserRealName: sysUser.RealName,
|
|
|
// UniqueCode: excelInfo.UniqueCode,
|
|
|
// CreateTime: time.Now(),
|
|
|
- // Content: string(this.Ctx.Input.RequestBody),
|
|
|
+ // Content: string(c.Ctx.Input.RequestBody),
|
|
|
// Status: "新增表格",
|
|
|
- // Method: this.Ctx.Input.URI(),
|
|
|
+ // Method: c.Ctx.Input.URI(),
|
|
|
// }
|
|
|
// go data_manage.AddExcelInfoLog(excelLog)
|
|
|
//}
|
|
@@ -235,13 +235,13 @@ func (this *ExcelInfoController) Add() {
|
|
|
// @Param AdminId query int false "创建人id"
|
|
|
// @Success 200 {object} response.ExcelListResp
|
|
|
// @router /excel_info/list [get]
|
|
|
-func (this *ExcelInfoController) List() {
|
|
|
+func (c *ExcelInfoController) List() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -249,12 +249,12 @@ func (this *ExcelInfoController) List() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- excelClassifyId, _ := this.GetInt("ExcelClassifyId")
|
|
|
+ excelClassifyId, _ := c.GetInt("ExcelClassifyId")
|
|
|
|
|
|
- pageSize, _ := this.GetInt("PageSize")
|
|
|
- currentIndex, _ := this.GetInt("CurrentIndex")
|
|
|
- keyword := this.GetString("Keyword")
|
|
|
- adminId, _ := this.GetInt("AdminId")
|
|
|
+ pageSize, _ := c.GetInt("PageSize")
|
|
|
+ currentIndex, _ := c.GetInt("CurrentIndex")
|
|
|
+ keyword := c.GetString("Keyword")
|
|
|
+ adminId, _ := c.GetInt("AdminId")
|
|
|
|
|
|
var total int
|
|
|
page := paging.GetPaging(currentIndex, pageSize, total)
|
|
@@ -327,13 +327,13 @@ func (this *ExcelInfoController) List() {
|
|
|
// @Param ExcelInfoId query int true "表格id"
|
|
|
// @Success 200 {object} data_manage.ExcelInfo
|
|
|
// @router /excel_info/detail [get]
|
|
|
-func (this *ExcelInfoController) Detail() {
|
|
|
+func (c *ExcelInfoController) Detail() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -341,7 +341,7 @@ func (this *ExcelInfoController) Detail() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- excelInfoId, _ := this.GetInt("ExcelInfoId")
|
|
|
+ excelInfoId, _ := c.GetInt("ExcelInfoId")
|
|
|
if excelInfoId <= 0 {
|
|
|
br.Msg = "请选择表格"
|
|
|
br.ErrMsg = "ExcelInfoId未传"
|
|
@@ -372,14 +372,14 @@ func (this *ExcelInfoController) Detail() {
|
|
|
// @Param request body request.EditExcelInfoReq true "type json string"
|
|
|
// @Success 200 {object} response.AddExcelInfoResp
|
|
|
// @router /excel_info/edit [post]
|
|
|
-func (this *ExcelInfoController) Edit() {
|
|
|
+func (c *ExcelInfoController) Edit() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -388,7 +388,7 @@ func (this *ExcelInfoController) Edit() {
|
|
|
}
|
|
|
deleteCache := true
|
|
|
var req request.EditExcelInfoReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -408,7 +408,7 @@ func (this *ExcelInfoController) Edit() {
|
|
|
if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
|
|
|
deleteCache = false
|
|
|
br.Msg = "系统处理中,请稍后重试!"
|
|
|
- br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
|
|
|
+ br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody)
|
|
|
return
|
|
|
}
|
|
|
req.ExcelName = strings.Trim(req.ExcelName, " ")
|
|
@@ -582,14 +582,14 @@ func (this *ExcelInfoController) Edit() {
|
|
|
// @Param request body request.MoveExcelInfoReq true "type json string"
|
|
|
// @Success Ret=200 移动成功
|
|
|
// @router /excel_info/move [post]
|
|
|
-func (this *ExcelInfoController) Move() {
|
|
|
+func (c *ExcelInfoController) Move() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -598,7 +598,7 @@ func (this *ExcelInfoController) Move() {
|
|
|
}
|
|
|
|
|
|
var req request.MoveExcelInfoReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -752,9 +752,9 @@ func (this *ExcelInfoController) Move() {
|
|
|
// ExcelLog.SysUserRealName = sysUser.RealName
|
|
|
// ExcelLog.UniqueCode = ExcelInfo.UniqueCode
|
|
|
// ExcelLog.CreateTime = time.Now()
|
|
|
- // ExcelLog.Content = string(this.Ctx.Input.RequestBody)
|
|
|
+ // ExcelLog.Content = string(c.Ctx.Input.RequestBody)
|
|
|
// ExcelLog.Status = "移动表格"
|
|
|
- // ExcelLog.Method = this.Ctx.Input.URL()
|
|
|
+ // ExcelLog.Method = c.Ctx.Input.URL()
|
|
|
// go data_manage.AddExcelInfoLog(ExcelLog)
|
|
|
//}
|
|
|
|
|
@@ -770,16 +770,16 @@ func (this *ExcelInfoController) Move() {
|
|
|
// @Param request body request.DeleteExcelInfoReq true "type json string"
|
|
|
// @Success Ret=200 删除成功
|
|
|
// @router /excel_info/delete [post]
|
|
|
-func (this *ExcelInfoController) Delete() {
|
|
|
+func (c *ExcelInfoController) Delete() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
resp := response.AddExcelInfoResp{}
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -788,7 +788,7 @@ func (this *ExcelInfoController) Delete() {
|
|
|
}
|
|
|
|
|
|
var req request.DeleteExcelInfoReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -911,14 +911,14 @@ func (this *ExcelInfoController) Delete() {
|
|
|
// @Param request body request.AddExcelDraftReq true "type json string"
|
|
|
// @Success Ret=200 添加成功
|
|
|
// @router /excel_info/draft/add [post]
|
|
|
-func (this *ExcelInfoController) AddDraft() {
|
|
|
+func (c *ExcelInfoController) AddDraft() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -928,7 +928,7 @@ func (this *ExcelInfoController) AddDraft() {
|
|
|
|
|
|
var req request.AddExcelDraftReq
|
|
|
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -1010,20 +1010,20 @@ func (this *ExcelInfoController) AddDraft() {
|
|
|
// @Param UniqueCode query string true "表格code"
|
|
|
// @Success 200 {object} response.ExcelTableDetailResp
|
|
|
// @router /excel_info/table_data [get]
|
|
|
-func (this *ExcelInfoController) GetExcelTableData() {
|
|
|
+func (c *ExcelInfoController) GetExcelTableData() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
br.Ret = 408
|
|
|
return
|
|
|
}
|
|
|
- uniqueCode := this.GetString("UniqueCode")
|
|
|
+ uniqueCode := c.GetString("UniqueCode")
|
|
|
|
|
|
var err error
|
|
|
if uniqueCode == `` {
|
|
@@ -1134,7 +1134,7 @@ func UpdateExcelInfoFileUrl(excelInfo *data_manage.ExcelInfo) {
|
|
|
//_, err = luckySheetData.GetTableDataByLuckySheetDataStr()
|
|
|
downloadFilePath, err := luckySheetData.ToExcel()
|
|
|
defer func() {
|
|
|
- os.Remove(downloadFilePath)
|
|
|
+ _ = os.Remove(downloadFilePath)
|
|
|
}()
|
|
|
if err != nil {
|
|
|
fmt.Println("err:", err)
|
|
@@ -1178,14 +1178,14 @@ func UpdateExcelInfoFileUrl(excelInfo *data_manage.ExcelInfo) {
|
|
|
// @Description 公式计算接口
|
|
|
// @Param request body request.CalculateReq true "type json string"
|
|
|
// @router /excel_info/table/calculate [post]
|
|
|
-func (this *ExcelInfoController) Calculate() {
|
|
|
+func (c *ExcelInfoController) Calculate() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1194,7 +1194,7 @@ func (this *ExcelInfoController) Calculate() {
|
|
|
}
|
|
|
|
|
|
var req request.CalculateReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -1242,12 +1242,21 @@ func (this *ExcelInfoController) Calculate() {
|
|
|
br.ErrMsg = "计算失败:计算结果是:NAN;formulaStr:" + formulaFormStr
|
|
|
return
|
|
|
}
|
|
|
- calVal := calResult.String()
|
|
|
- if err != nil {
|
|
|
+ // 计算结果格式化
|
|
|
+ calFloat, e := calResult.Float64()
|
|
|
+ if e != nil {
|
|
|
br.Msg = "计算失败"
|
|
|
- br.ErrMsg = "计算失败,结果转 string 失败:Err:" + err.Error() + ";formulaStr:" + formulaFormStr
|
|
|
+ br.ErrMsg = "计算失败, Err: " + e.Error()
|
|
|
return
|
|
|
}
|
|
|
+ calVal := utils.FormatTableDataShowValue(calFloat)
|
|
|
+
|
|
|
+ //calVal := calResult.String()
|
|
|
+ //if err != nil {
|
|
|
+ // br.Msg = "计算失败"
|
|
|
+ // br.ErrMsg = "计算失败,结果转 string 失败:Err:" + err.Error() + ";formulaStr:" + formulaFormStr
|
|
|
+ // return
|
|
|
+ //}
|
|
|
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
@@ -1260,15 +1269,16 @@ func (this *ExcelInfoController) Calculate() {
|
|
|
// @Description 获取未来日期数据接口
|
|
|
// @Param EdbInfoId query int true "指标id"
|
|
|
// @Param Num query int true "默认期数"
|
|
|
+// @Param SortType query string true "如何排序,是正序还是倒序,枚举值:`asc 正序`,`desc 倒序`,不传默认倒序"
|
|
|
// @router /excel_info/table/first_edb_data_list [get]
|
|
|
-func (this *ExcelInfoController) GetFirstEdbData() {
|
|
|
+func (c *ExcelInfoController) GetFirstEdbData() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1276,8 +1286,9 @@ func (this *ExcelInfoController) GetFirstEdbData() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- edbInfoId, _ := this.GetInt("EdbInfoId")
|
|
|
- num, _ := this.GetInt("Num")
|
|
|
+ edbInfoId, _ := c.GetInt("EdbInfoId")
|
|
|
+ num, _ := c.GetInt("Num")
|
|
|
+ sortType := c.GetString("SortType")
|
|
|
|
|
|
if edbInfoId <= 0 {
|
|
|
br.Msg = "请选择指标"
|
|
@@ -1304,6 +1315,13 @@ func (this *ExcelInfoController) GetFirstEdbData() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ // 默认是倒序返回的数据,如果要正序的话,那么翻转下就好了
|
|
|
+ if sortType == "asc" {
|
|
|
+ for i, j := 0, len(dataList)-1; i < j; i, j = i+1, j-1 {
|
|
|
+ dataList[i], dataList[j] = dataList[j], dataList[i]
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
|
br.Msg = "获取成功"
|
|
@@ -1318,14 +1336,14 @@ func (this *ExcelInfoController) GetFirstEdbData() {
|
|
|
// @Description 获取未来日期数据接口
|
|
|
// @Param request body request.GetOtherEdbDateDataReq true "type json string"
|
|
|
// @router /excel_info/table/other_edb_data_list [post]
|
|
|
-func (this *ExcelInfoController) GetOtherEdbData() {
|
|
|
+func (c *ExcelInfoController) GetOtherEdbData() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1334,7 +1352,7 @@ func (this *ExcelInfoController) GetOtherEdbData() {
|
|
|
}
|
|
|
|
|
|
var req request.GetOtherEdbDateDataReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -1365,6 +1383,13 @@ func (this *ExcelInfoController) GetOtherEdbData() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ // 默认是倒序返回的数据,如果要正序的话,那么翻转下就好了
|
|
|
+ if req.SortType == "asc" {
|
|
|
+ for i, j := 0, len(dataList)-1; i < j; i, j = i+1, j-1 {
|
|
|
+ dataList[i], dataList[j] = dataList[j], dataList[i]
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
|
br.Msg = "获取成功"
|
|
@@ -1379,14 +1404,14 @@ func (this *ExcelInfoController) GetOtherEdbData() {
|
|
|
// @Description 获取未来日期数据接口
|
|
|
// @Param request body request.GetFutureDateDataReq true "type json string"
|
|
|
// @router /excel_info/table/future_date_list [post]
|
|
|
-func (this *ExcelInfoController) GetFutureDateData() {
|
|
|
+func (c *ExcelInfoController) GetFutureDateData() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1395,7 +1420,7 @@ func (this *ExcelInfoController) GetFutureDateData() {
|
|
|
}
|
|
|
|
|
|
var req request.GetFutureDateDataReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -1549,14 +1574,14 @@ func (this *ExcelInfoController) GetFutureDateData() {
|
|
|
// @Description 获取历史日期数据接口
|
|
|
// @Param request body request.GetFutureDateDataReq true "type json string"
|
|
|
// @router /excel_info/table/history_date_list [post]
|
|
|
-func (this *ExcelInfoController) GetHistoryDateData() {
|
|
|
+func (c *ExcelInfoController) GetHistoryDateData() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1565,7 +1590,7 @@ func (this *ExcelInfoController) GetHistoryDateData() {
|
|
|
}
|
|
|
|
|
|
var req request.GetHistoryDateDataReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -1661,14 +1686,14 @@ func (this *ExcelInfoController) GetHistoryDateData() {
|
|
|
// @Description 刷新接口
|
|
|
// @Param ExcelInfoId query int true "表格id"
|
|
|
// @router /excel_info/table/refresh [get]
|
|
|
-func (this *ExcelInfoController) Refresh() {
|
|
|
+func (c *ExcelInfoController) Refresh() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1676,7 +1701,7 @@ func (this *ExcelInfoController) Refresh() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- excelInfoId, _ := this.GetInt("ExcelInfoId")
|
|
|
+ excelInfoId, _ := c.GetInt("ExcelInfoId")
|
|
|
if excelInfoId <= 0 {
|
|
|
br.Msg = "请选择表格"
|
|
|
br.ErrMsg = "ExcelInfoId未传"
|
|
@@ -1741,13 +1766,13 @@ func (this *ExcelInfoController) Refresh() {
|
|
|
// @Param ExcelInfoId query int true "表格id"
|
|
|
// @Success 200 {object} data_manage.ExcelInfo
|
|
|
// @router /excel_info/table/download [get]
|
|
|
-func (this *ExcelInfoController) Download() {
|
|
|
+func (c *ExcelInfoController) Download() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1755,8 +1780,8 @@ func (this *ExcelInfoController) Download() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- excelInfoId, _ := this.GetInt("ExcelInfoId")
|
|
|
- uniqueCode := this.GetString("UniqueCode")
|
|
|
+ excelInfoId, _ := c.GetInt("ExcelInfoId")
|
|
|
+ uniqueCode := c.GetString("UniqueCode")
|
|
|
if excelInfoId <= 0 && uniqueCode == `` {
|
|
|
br.Msg = "请选择表格"
|
|
|
br.ErrMsg = "ExcelInfoId和UniqueCode都未传"
|
|
@@ -1840,11 +1865,11 @@ func (this *ExcelInfoController) Download() {
|
|
|
return
|
|
|
}
|
|
|
defer func() {
|
|
|
- os.Remove(downloadFilePath)
|
|
|
+ _ = os.Remove(downloadFilePath)
|
|
|
}()
|
|
|
|
|
|
downloadFileName := excelInfo.ExcelName + ".xlsx"
|
|
|
- this.Ctx.Output.Download(downloadFilePath, downloadFileName)
|
|
|
+ c.Ctx.Output.Download(downloadFilePath, downloadFileName)
|
|
|
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
@@ -1858,13 +1883,13 @@ func (this *ExcelInfoController) Download() {
|
|
|
// @Param request body request.EditExcelInfoReq true "type json string"
|
|
|
// @Success 200 {object} response.AddExcelInfoResp
|
|
|
// @router /excel_info/copy [post]
|
|
|
-func (this *ExcelInfoController) Copy() {
|
|
|
+func (c *ExcelInfoController) Copy() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
- this.Data["json"] = br
|
|
|
- this.ServeJSON()
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
}()
|
|
|
- sysUser := this.SysUser
|
|
|
+ sysUser := c.SysUser
|
|
|
if sysUser == nil {
|
|
|
br.Msg = "请登录"
|
|
|
br.ErrMsg = "请登录,SysUser Is Empty"
|
|
@@ -1874,7 +1899,7 @@ func (this *ExcelInfoController) Copy() {
|
|
|
|
|
|
deleteCache := true
|
|
|
var req request.CopyExcelInfoReq
|
|
|
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
|
br.Msg = "参数解析异常!"
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
@@ -1894,7 +1919,7 @@ func (this *ExcelInfoController) Copy() {
|
|
|
if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
|
|
|
deleteCache = false
|
|
|
br.Msg = "系统处理中,请稍后重试!"
|
|
|
- br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody)
|
|
|
+ br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody)
|
|
|
return
|
|
|
}
|
|
|
req.ExcelName = strings.Trim(req.ExcelName, " ")
|