|
@@ -9,8 +9,6 @@ import (
|
|
|
excel3 "eta/eta_api/models/data_manage/excel"
|
|
|
"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"
|
|
|
excel2 "eta/eta_api/services/data/excel"
|
|
|
"eta/eta_api/services/excel"
|
|
@@ -198,7 +196,7 @@ func (c *ExcelInfoController) Add() {
|
|
|
|
|
|
// 更新excel下载地址(默认的EXCEL需要更新,自定义表格不需要更新)
|
|
|
if req.Source == 1 {
|
|
|
- go UpdateExcelInfoFileUrl(excelInfo)
|
|
|
+ go excel2.UpdateExcelInfoFileUrl(excelInfo)
|
|
|
}
|
|
|
|
|
|
resp := new(response.AddExcelInfoResp)
|
|
@@ -563,7 +561,7 @@ func (c *ExcelInfoController) Edit() {
|
|
|
|
|
|
// 更新excel下载地址(默认的EXCEL需要更新,自定义表格不需要更新)
|
|
|
if excelInfo.Source == 1 {
|
|
|
- go UpdateExcelInfoFileUrl(excelInfo)
|
|
|
+ go excel2.UpdateExcelInfoFileUrl(excelInfo)
|
|
|
}
|
|
|
|
|
|
// 加入草稿
|
|
@@ -830,23 +828,15 @@ func (c *ExcelInfoController) Delete() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- // 操作权限校验
|
|
|
- {
|
|
|
- button := excel2.GetExcelInfoOpButton(sysUser, excelInfo.SysUserId, excelInfo.Source)
|
|
|
- if !button.DeleteButton {
|
|
|
- br.Msg = "无操作权限"
|
|
|
- br.Msg = "无操作权限"
|
|
|
- br.IsSendEmail = false
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- //更新
|
|
|
- excelInfo.IsDelete = 1
|
|
|
- err = excelInfo.Update([]string{"IsDelete"})
|
|
|
+ // 删除excel
|
|
|
+ err, errMsg, isSendEmail := excel2.Delete(excelInfo, sysUser)
|
|
|
if err != nil {
|
|
|
br.Msg = "删除失败"
|
|
|
+ if errMsg != `` {
|
|
|
+ br.Msg = errMsg
|
|
|
+ }
|
|
|
br.ErrMsg = "删除失败,Err:" + err.Error()
|
|
|
+ br.IsSendEmail = isSendEmail
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -1137,48 +1127,6 @@ func (c *ExcelInfoController) GetExcelTableData() {
|
|
|
br.Data = resp
|
|
|
}
|
|
|
|
|
|
-// UpdateExcelInfoFileUrl 更新excel表格的下载地址
|
|
|
-func UpdateExcelInfoFileUrl(excelInfo *excel3.ExcelInfo) {
|
|
|
- var err error
|
|
|
- defer func() {
|
|
|
- if err != nil {
|
|
|
- go alarm_msg.SendAlarmMsg(fmt.Sprintf("更新excel表格的下载地址失败,表格id:%d;表格名称:%s; ERR:%s", excelInfo.ExcelInfoId, excelInfo.ExcelName, err), 3)
|
|
|
- }
|
|
|
- }()
|
|
|
- fileName := excelInfo.ExcelName + "_" + excelInfo.UniqueCode + ".xlsx"
|
|
|
-
|
|
|
- var downloadFilePath string // excel文件下载地址
|
|
|
-
|
|
|
- switch excelInfo.Source {
|
|
|
- case utils.EXCEL_DEFAULT: // 自定义表格
|
|
|
- luckySheetData, err := excel.GetLuckySheetData(excelInfo.Content)
|
|
|
- if err != nil {
|
|
|
- fmt.Println("err:", err)
|
|
|
- return
|
|
|
- }
|
|
|
- //_, err = luckySheetData.GetTableDataByLuckySheetDataStr()
|
|
|
- downloadFilePath, err = luckySheetData.ToExcel()
|
|
|
- case utils.CUSTOM_ANALYSIS_TABLE: // 自定义分析表格
|
|
|
- downloadFilePath, err, _ = excel2.GenerateExcelCustomAnalysisExcel(excelInfo)
|
|
|
- }
|
|
|
-
|
|
|
- if err != nil {
|
|
|
- fmt.Println("err:", err)
|
|
|
- return
|
|
|
- }
|
|
|
- defer func() {
|
|
|
- _ = os.Remove(downloadFilePath)
|
|
|
- }()
|
|
|
-
|
|
|
- //上传到阿里云
|
|
|
- resourceUrl, err := services.UploadAliyunV2(fileName, downloadFilePath)
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
- excelInfo.FileUrl = resourceUrl
|
|
|
- err = excelInfo.Update([]string{"FileUrl"})
|
|
|
-}
|
|
|
-
|
|
|
//func init() {
|
|
|
//
|
|
|
// excelInfo, err := data_manage.GetExcelInfoById(52)
|
|
@@ -1927,7 +1875,6 @@ func (c *ExcelInfoController) Copy() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- deleteCache := true
|
|
|
var req request.CopyExcelInfoReq
|
|
|
err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
@@ -1941,17 +1888,15 @@ func (c *ExcelInfoController) Copy() {
|
|
|
}
|
|
|
|
|
|
cacheKey := "CACHE_TABLE_INFO_EDIT_" + strconv.Itoa(req.ExcelInfoId)
|
|
|
- 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
|
|
|
}
|
|
|
+ defer func() {
|
|
|
+ _ = utils.Rc.Delete(cacheKey)
|
|
|
+ }()
|
|
|
+
|
|
|
req.ExcelName = strings.Trim(req.ExcelName, " ")
|
|
|
if req.ExcelName == "" {
|
|
|
br.Msg = "请填写表格名称!"
|
|
@@ -1965,96 +1910,16 @@ func (c *ExcelInfoController) Copy() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- excelClassify, err := excel3.GetExcelClassifyById(req.ExcelClassifyId)
|
|
|
+ excelInfo, err, errMsg, isSendEmail := excel2.Copy(req.ExcelInfoId, req.ExcelClassifyId, req.ExcelName, sysUser)
|
|
|
if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
- br.Msg = "分类不存在"
|
|
|
- br.ErrMsg = "分类不存在"
|
|
|
- br.IsSendEmail = false
|
|
|
- return
|
|
|
+ br.Msg = "复制失败"
|
|
|
+ if errMsg != `` {
|
|
|
+ br.Msg = errMsg
|
|
|
}
|
|
|
- br.Msg = "获取分类信息失败"
|
|
|
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
|
|
|
+ br.ErrMsg = "复制失败,Err:" + err.Error()
|
|
|
+ br.IsSendEmail = isSendEmail
|
|
|
return
|
|
|
}
|
|
|
- if excelClassify == nil {
|
|
|
- br.Msg = "分类不存在"
|
|
|
- br.ErrMsg = "分类不存在"
|
|
|
- br.IsSendEmail = false
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 获取原ETA表格信息
|
|
|
- oldExcelInfo, err := excel3.GetExcelInfoById(req.ExcelInfoId)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "获取ETA表格失败"
|
|
|
- br.ErrMsg = "获取ETA表格失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 操作权限校验
|
|
|
- {
|
|
|
- button := excel2.GetExcelInfoOpButton(sysUser, oldExcelInfo.SysUserId, oldExcelInfo.Source)
|
|
|
- if !button.CopyButton {
|
|
|
- br.Msg = "无操作权限"
|
|
|
- br.Msg = "无操作权限"
|
|
|
- br.IsSendEmail = false
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // 检验分类下是否存在该表格名称
|
|
|
- {
|
|
|
- var condition string
|
|
|
- var pars []interface{}
|
|
|
- condition += " AND excel_classify_id=? "
|
|
|
- pars = append(pars, req.ExcelClassifyId)
|
|
|
-
|
|
|
- condition += " AND excel_name=? "
|
|
|
- pars = append(pars, req.ExcelName)
|
|
|
-
|
|
|
- count, err := excel3.GetExcelInfoCountByCondition(condition, pars)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "判断表格名称是否存在失败"
|
|
|
- br.ErrMsg = "判断表格名称是否存在失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if count > 0 {
|
|
|
- br.Msg = "表格名称已存在,请重新填写表格名称"
|
|
|
- br.IsSendEmail = false
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
|
|
|
- excelInfo := &excel3.ExcelInfo{
|
|
|
- //ExcelInfoId: 0,
|
|
|
- ExcelName: req.ExcelName,
|
|
|
- Source: oldExcelInfo.Source,
|
|
|
- ExcelType: oldExcelInfo.ExcelType,
|
|
|
- UniqueCode: utils.MD5(utils.EXCEL_DATA_PREFIX + "_" + timestamp),
|
|
|
- ExcelClassifyId: req.ExcelClassifyId,
|
|
|
- SysUserId: sysUser.AdminId,
|
|
|
- SysUserRealName: sysUser.RealName,
|
|
|
- Content: oldExcelInfo.Content,
|
|
|
- ExcelImage: oldExcelInfo.ExcelImage,
|
|
|
- Sort: 0,
|
|
|
- IsDelete: 0,
|
|
|
- ModifyTime: time.Now(),
|
|
|
- CreateTime: time.Now(),
|
|
|
- }
|
|
|
-
|
|
|
- err = excel3.AddExcelInfo(excelInfo)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "保存失败"
|
|
|
- br.ErrMsg = "保存失败,Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- // 更新excel下载地址(默认的EXCEL需要更新,自定义表格不需要更新)
|
|
|
- if excelInfo.Source == 1 {
|
|
|
- go UpdateExcelInfoFileUrl(excelInfo)
|
|
|
- }
|
|
|
|
|
|
resp := new(response.AddExcelInfoResp)
|
|
|
resp.ExcelInfoId = excelInfo.ExcelInfoId
|