123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740 |
- package material
- import (
- "archive/zip"
- "encoding/json"
- "eta/eta_mobile/controllers"
- "eta/eta_mobile/models"
- "eta/eta_mobile/models/material"
- materialService "eta/eta_mobile/services/material"
- "eta/eta_mobile/utils"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/http"
- "github.com/rdlucklib/rdluck_tools/paging"
- "os"
- "path"
- "strconv"
- "strings"
- "time"
- )
- // MaterialController 逻辑导图
- type MaterialController struct {
- controllers.BaseAuthController
- }
- // AddMaterialClassify
- // @Title 新增素材库分类
- // @Description 新增材库分类接口
- // @Param request body data_manage.AddChartClassifyReq true "type json string"
- // @Success 200 Ret=200 保存成功
- // @router /classify/add [post]
- func (this *MaterialController) AddMaterialClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req material.AddMaterialClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyName == "" {
- br.Msg = "请输入分类名称"
- br.IsSendEmail = false
- return
- }
- if req.ParentId < 0 {
- br.Msg = "参数错误"
- br.IsSendEmail = false
- return
- }
- level := 1
- levelPath := ""
- if req.ParentId > 0 {
- //查找父级分类
- parentClassify, e := material.GetMaterialClassifyById(req.ParentId)
- if e != nil {
- br.Msg = "获取父级分类失败"
- br.ErrMsg = "获取父级分类失败,Err:" + e.Error()
- return
- }
- level = parentClassify.Level + 1
- levelPath = parentClassify.LevelPath
- }
- var count int
- switch this.Lang {
- case utils.LANG_EN:
- count, err = material.GetMaterialClassifyNameEnCount(req.ClassifyName, req.ParentId)
- default:
- count, err = material.GetMaterialClassifyNameCount(req.ClassifyName, req.ParentId)
- }
- if err != nil {
- br.Msg = "判断名称是否已存在失败"
- br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
- return
- }
- if count > 0 {
- br.Msg = "分类名称已存在,请重新输入"
- br.IsSendEmail = false
- return
- }
- //获取该层级下最大的排序数
- classify := new(material.MaterialClassify)
- maxSort, _ := material.GetMaterialClassifyMaxSort(req.ParentId)
- classify.ParentId = req.ParentId
- classify.ClassifyName = req.ClassifyName
- classify.ClassifyNameEn = req.ClassifyName
- classify.CreateTime = time.Now()
- classify.ModifyTime = time.Now()
- classify.SysUserId = this.SysUser.AdminId
- classify.SysUserRealName = this.SysUser.RealName
- classify.Level = level
- classify.Sort = maxSort + 1
- classifyId, e := material.AddMaterialClassify(classify)
- if e != nil {
- br.Msg = "保存分类失败"
- br.ErrMsg = "保存分类失败,Err:" + e.Error()
- return
- }
- if req.ParentId > 0 {
- levelPath = fmt.Sprintf("%s,%d", levelPath, classifyId)
- } else {
- levelPath = fmt.Sprintf("%d", classifyId)
- }
- classify.ClassifyId = int(classifyId)
- classify.LevelPath = levelPath
- e = classify.Update([]string{"LevelPath"})
- if e != nil {
- br.Msg = "保存分类失败"
- br.ErrMsg = "保存分类失败,Err:" + e.Error()
- return
- }
- br.Ret = 200
- br.Msg = "保存成功"
- br.Success = true
- }
- // EditMaterialClassify
- // @Title 修改素材库分类
- // @Description 修改素材库分类接口
- // @Param request body data_manage.EditChartClassifyReq true "type json string"
- // @Success 200 Ret=200 修改成功
- // @router /classify/edit [post]
- func (this *MaterialController) EditMaterialClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req material.EditMaterialClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyName == "" {
- br.Msg = "请输入分类名称"
- br.IsSendEmail = false
- return
- }
- if req.ClassifyId <= 0 {
- br.Msg = "参数错误"
- br.IsSendEmail = false
- return
- }
- // 只允许修改分类名称
- item, err := material.GetMaterialClassifyById(req.ClassifyId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "分类不存在"
- return
- }
- br.Msg = "保存失败"
- br.Msg = "获取分类信息失败,Err:" + err.Error()
- return
- }
- var count int
- updateStr := make([]string, 0)
- switch this.Lang {
- case utils.LANG_EN:
- count, err = material.GetMaterialClassifyNameEnNotSelfCount(req.ClassifyId, req.ClassifyName, item.ParentId)
- item.ClassifyNameEn = req.ClassifyName
- updateStr = append(updateStr, "ClassifyNameEn")
- default:
- count, err = material.GetMaterialClassifyNameNotSelfCount(req.ClassifyId, req.ClassifyName, item.ParentId)
- item.ClassifyName = req.ClassifyName
- updateStr = append(updateStr, "ClassifyName")
- }
- if err != nil {
- br.Msg = "判断名称是否已存在失败"
- br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
- return
- }
- if count > 0 {
- br.Msg = "分类名称已存在,请重新输入"
- br.IsSendEmail = false
- return
- }
- item.ModifyTime = time.Now()
- updateStr = append(updateStr, "ModifyTime")
- err = item.Update(updateStr)
- if err != nil {
- br.Msg = "保存分类失败"
- br.ErrMsg = "保存分类失败,Err:" + err.Error()
- return
- }
- //todo 测试更新子集的levelPath
- /*levelPath := ""
- oldLevelPath := item.LevelPath
- if item.ParentId > 0 {
- //查找父级分类
- parentClassify, e := material.GetMaterialClassifyById(item.ParentId)
- if e != nil {
- br.Msg = "获取父级分类失败"
- br.ErrMsg = "获取父级分类失败,Err:" + e.Error()
- return
- }
- levelPath = fmt.Sprintf("%s,%d", parentClassify.LevelPath, item.ClassifyId)
- tmpList, e := material.GetMaterialClassifyByLevelPath(oldLevelPath)
- if e != nil {
- br.Msg = "保存分类失败"
- br.ErrMsg = "保存分类失败,Err:" + e.Error()
- return
- }
- // 把原先的父级levePath,替换成最新的父级序列
- for _, tmp := range tmpList {
- tmp.LevelPath = strings.Replace(tmp.LevelPath, oldLevelPath, levelPath, -1)
- tmp.ModifyTime = time.Now()
- e = tmp.Update([]string{"LevelPath", "ModifyTime"})
- if e != nil {
- br.Msg = "保存分类失败"
- br.ErrMsg = "保存分类失败,Err:" + e.Error()
- return
- }
- }
- } else {
- // 只有更改了父级才需要更新levelPath
- }*/
- br.Ret = 200
- br.Msg = "保存成功"
- br.Success = true
- br.IsAddLog = true
- }
- // DeleteMaterialClassifyCheck
- // @Title 删除素材库检测接口
- // @Description 删除素材库检测接口
- // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
- // @Success 200 Ret=200 检测成功
- // @router /classify/del/check [post]
- func (this *MaterialController) DeleteMaterialClassifyCheck() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req material.MaterialClassifyDeleteCheckReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId < 0 {
- br.Msg = "参数错误"
- br.IsSendEmail = false
- return
- }
- var deleteStatus int
- var tipsMsg string
- //删除分类
- // 查询当前的分类
- classifyInfo, err := material.GetMaterialClassifyById(req.ClassifyId)
- if err != nil {
- br.Msg = "分类不存在"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- return
- }
- classifyIds := strings.Split(classifyInfo.LevelPath, ",")
- if len(classifyIds) > 0 {
- //判断素材库分类下,是否含有素材库
- count, e := material.GetMaterialInfoCountByClassifyIds(classifyIds)
- if e != nil {
- br.Msg = "删除失败"
- br.ErrMsg = "分类下是否含有指标失败,Err:" + e.Error()
- return
- }
- if count > 0 {
- deleteStatus = 1
- tipsMsg = "该分类下关联素材库不可删除"
- } else {
- if len(classifyIds) > 1 {
- deleteStatus = 2
- tipsMsg = "确认删除当前目录及包含的子目录吗"
- }
- }
- }
- if deleteStatus == 0 {
- tipsMsg = "可删除,进行删除操作"
- }
- resp := new(material.MaterialClassifyDeleteCheckResp)
- resp.DeleteStatus = deleteStatus
- resp.TipsMsg = tipsMsg
- br.Ret = 200
- br.Msg = "检测成功"
- br.Success = true
- br.Data = resp
- }
- // DeleteMaterialClassify
- // @Title 删除素材库分类/素材库
- // @Description 删除素材库分类/素材库接口
- // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
- // @Success 200 Ret=200 删除成功
- // @router /classify/del [post]
- func (this *MaterialController) DeleteMaterialClassify() {
- 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 material.DeleteMaterialClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId < 0 {
- br.Msg = "参数错误"
- br.IsSendEmail = false
- return
- }
- // 查询当前的分类
- classifyInfo, err := material.GetMaterialClassifyById(req.ClassifyId)
- if err != nil {
- br.Msg = "分类不存在"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- return
- }
- classifyIds := strings.Split(classifyInfo.LevelPath, ",")
- if len(classifyIds) > 0 {
- //判断素材库分类下,是否含有素材库
- count, e := material.GetMaterialInfoCountByClassifyIds(classifyIds)
- if e != nil {
- br.Msg = "删除失败"
- br.ErrMsg = "分类下是否含有指标失败,Err:" + e.Error()
- return
- }
- if count > 0 {
- br.Msg = "该目录下存在关联指标,不可删除"
- br.IsSendEmail = false
- return
- }
- err = material.DeleteMaterialClassify(classifyIds)
- if err != nil {
- br.Msg = "删除失败"
- br.ErrMsg = "删除失败,Err:" + err.Error()
- return
- }
- }
- //删除素材库
- /*if req.MaterialId > 0 {
- materialInfo, err := material.GetMaterialById(req.MaterialId)
- 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 materialInfo == nil {
- br.Msg = "素材库已删除,请刷新页面"
- return
- }
- err = materialService.DeleteMaterial(req.MaterialId)
- if err != nil {
- br.Msg = err.Error()
- return
- }
- }*/
- br.Ret = 200
- br.Msg = "删除成功"
- br.Success = true
- br.IsAddLog = true
- }
- // ClassifyMove
- // @Title 素材库分类移动接口
- // @Description 素材库分类移动接口
- // @Success 200 {object} data_manage.MoveChartClassifyReq
- // @router /classify/move [post]
- func (this *MaterialController) ClassifyMove() {
- 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 material.MoveMaterialClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId <= 0 {
- br.Msg = "参数错误"
- br.ErrMsg = "分类id小于等于0"
- return
- }
- //判断分类是否存在
- materialClassifyInfo, err := material.GetMaterialClassifyById(req.ClassifyId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "分类不存在,请刷新页面"
- br.ErrMsg = "分类不存在,Err:" + err.Error()
- return
- }
- br.Msg = "移动失败"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- return
- }
- if materialClassifyInfo.ParentId != req.ParentClassifyId {
- count, err := material.GetMaterialClassifyNameNotSelfCount(materialClassifyInfo.ClassifyId, materialClassifyInfo.ClassifyName, materialClassifyInfo.ParentId)
- if err != nil {
- br.Msg = "判断名称是否已存在失败"
- br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
- return
- }
- if count > 0 {
- br.Msg = "移动失败,分类名称已存在"
- br.IsSendEmail = false
- return
- }
- }
- err, errMsg := materialService.MoveMaterialClassify(materialClassifyInfo, &req)
- if err != nil {
- br.Msg = errMsg
- if errMsg == "" {
- br.Msg = "移动失败"
- }
- br.ErrMsg = err.Error()
- }
- // todo权限校验
- //移动的是分类
- //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
- /*updateCol := make([]string, 0)
- if MaterialClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
- parentChartClassifyInfo, err := material.GetMaterialClassifyById(req.ParentClassifyId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
- return
- }
- MaterialClassifyInfo.ParentId = parentChartClassifyInfo.ClassifyId
- MaterialClassifyInfo.Level = parentChartClassifyInfo.Level + 1
- MaterialClassifyInfo.ModifyTime = time.Now()
- updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
- } else if MaterialClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId == 0 {
- //改为一级分类
- MaterialClassifyInfo.ParentId = req.ParentClassifyId
- MaterialClassifyInfo.Level = 1
- MaterialClassifyInfo.ModifyTime = time.Now()
- updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
- }
- //如果有传入 上一个兄弟节点分类id
- if req.PrevId > 0 {
- if req.PrevType == 1 {
- //上一个节点是分类
- //上一个兄弟节点
- prevClassify, err := material.GetMaterialClassifyById(req.PrevId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
- return
- }
- //如果是移动在两个兄弟节点之间
- if req.NextId > 0 {
- if req.NextType == 1 {
- //上一个节点是分类 下一个节点是分类的情况
- //下一个兄弟节点
- nextClassify, err := material.GetMaterialClassifyById(req.NextId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
- return
- }
- //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
- if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == MaterialClassifyInfo.Sort {
- //变更兄弟节点的排序
- updateSortStr := `sort + 2`
- _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, prevClassify.ClassifyId, prevClassify.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
- } else {
- //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
- if nextClassify.Sort-prevClassify.Sort == 1 {
- //变更兄弟节点的排序
- updateSortStr := `sort + 1`
- _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
- }
- }
- } else {
- //上一个节点是分类 下一个节点是素材库的情况
- //下一个兄弟节点
- nextChartInfo, err := material.GetMaterialById(req.NextId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
- return
- }
- //如果上一个兄弟(分类)与下一个兄弟(素材库)的排序权重是一致的,那么需要将下一个兄弟(素材库)(以及下个兄弟(素材库)的同样排序权重)的排序权重+2,自己变成上一个兄弟(分类)的排序权重+1
- if prevClassify.Sort == nextChartInfo.Sort || prevClassify.Sort == MaterialClassifyInfo.Sort {
- //变更兄弟节点的排序
- updateSortStr := `sort + 2`
- _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, prevClassify.ClassifyId, prevClassify.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
- } else {
- //如果下一个兄弟(素材库)的排序权重正好是上个兄弟节点(分类)的下一层,那么需要再加一层了
- if nextChartInfo.Sort-prevClassify.Sort == 1 {
- //变更兄弟节点的排序
- updateSortStr := `sort + 1`
- _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.ClassifyId, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
- }
- }
- }
- }
- MaterialClassifyInfo.Sort = prevClassify.Sort + 1
- MaterialClassifyInfo.ModifyTime = time.Now()
- updateCol = append(updateCol, "Sort", "ModifyTime")
- } else {
- //上一个节点是素材库
- prevMaterial, err := material.GetMaterialById(req.PrevId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
- return
- }
- //如果是移动在两个兄弟节点之间
- if req.NextId > 0 {
- if req.NextType == 1 {
- //上一个节点是素材库 下一个节点是分类的情况
- //下一个兄弟节点
- nextClassify, err := material.GetMaterialClassifyById(req.NextId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
- return
- }
- //如果上一个兄弟(素材库)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(素材库)的排序权重+1
- if prevMaterial.Sort == nextClassify.Sort || prevMaterial.Sort == MaterialClassifyInfo.Sort {
- //变更兄弟节点的排序
- updateSortStr := `sort + 2`
- _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
- } else {
- //如果下一个兄弟(分类)的排序权重正好是上个兄弟(素材库)节点的下一层,那么需要再加一层了
- if nextClassify.Sort-prevMaterial.Sort == 1 {
- //变更兄弟节点的排序
- updateSortStr := `sort + 1`
- _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
- }
- }
- } else {
- //上一个节点是素材库 下一个节点是素材库的情况
- //下一个兄弟节点
- nextChartInfo, err := material.GetMaterialById(req.NextId)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
- return
- }
- //如果上一个兄弟(素材库)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(素材库)的排序权重+1
- if prevMaterial.Sort == nextChartInfo.Sort || prevMaterial.Sort == MaterialClassifyInfo.Sort {
- //变更兄弟节点的排序
- updateSortStr := `sort + 2`
- _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
- } else {
- //如果下一个兄弟(分类)的排序权重正好是上个兄弟(素材库)节点的下一层,那么需要再加一层了
- if nextChartInfo.Sort-prevMaterial.Sort == 1 {
- //变更兄弟节点的排序
- updateSortStr := `sort + 1`
- _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
- _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
- }
- }
- }
- }
- MaterialClassifyInfo.Sort = prevMaterial.Sort + 1
- MaterialClassifyInfo.ModifyTime = time.Now()
- updateCol = append(updateCol, "Sort", "ModifyTime")
- }
- } else {
- firstClassify, err := material.GetFirstMaterialClassifyByParentId(MaterialClassifyInfo.ParentId)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "移动失败"
- br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
- return
- }
- //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
- if firstClassify != nil && firstClassify.Sort == 0 {
- updateSortStr := ` sort + 1 `
- _ = material.UpdateMaterialClassifySortByParentId(firstClassify.ParentId, firstClassify.ClassifyId-1, 0, updateSortStr)
- }
- MaterialClassifyInfo.Sort = 0 //那就是排在第一位
- MaterialClassifyInfo.ModifyTime = time.Now()
- updateCol = append(updateCol, "Sort", "ModifyTime")
- }
- //更新
- if len(updateCol) > 0 {
- err = MaterialClassifyInfo.Update(updateCol)
- if err != nil {
- br.Msg = "移动失败"
- br.ErrMsg = "修改失败,Err:" + err.Error()
- return
- }
- // todo 记录整个层级的分类ID
- }*/
- br.Ret = 200
- br.Success = true
- br.Msg = "移动成功"
- }
- // List
- // @Title 素材列表接口
- // @Description 素材列表接口
- // @Param PageSize query int true "每页数据条数"
- // @Param CurrentIndex query int true "当前页页码,从1开始"
- // @Param ClassifyId query int true "分类id"
- // @Param Keyword query string true "搜索关键词"
- // @Param IsShowMe query bool true "是否只看我的,true、false"
- // @Success 200 {object} data_manage.ChartListResp
- // @router /list [get]
- func (this *MaterialController) List() {
- 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
- }
- classifyId, _ := this.GetInt("ClassifyId")
- pageSize, _ := this.GetInt("PageSize")
- currentIndex, _ := this.GetInt("CurrentIndex")
- keyword := this.GetString("Keyword")
- var total int
- page := paging.GetPaging(currentIndex, pageSize, total)
- var startSize int
- if pageSize <= 0 {
- pageSize = utils.PageSize20
- }
- if currentIndex <= 0 {
- currentIndex = 1
- }
- startSize = paging.StartIndex(currentIndex, pageSize)
- var condition string
- var pars []interface{}
- classifyIds := make([]string, 0)
- childClassifyMap := make(map[int]*material.MaterialClassify)
- if classifyId > 0 {
- classifyIds = append(classifyIds, strconv.Itoa(classifyId))
- // 查询当前的分类
- classifyInfo, err := material.GetMaterialClassifyById(classifyId)
- if err != nil {
- br.Msg = "分类不存在"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- return
- }
- // 获取所有子分类
- childList, e := material.GetMaterialClassifyByLevelPath(classifyInfo.LevelPath)
- if e != nil {
- err = fmt.Errorf("保存分类失败,Err:" + e.Error())
- return
- }
- // 把原先的父级levePath,替换成最新的父级序列
- classifyIdMap := make(map[string]struct{})
- for _, tmp := range childList {
- childClassifyMap[tmp.ClassifyId] = tmp
- //获取字符串前缀的位置
- after, _ := strings.CutPrefix(tmp.LevelPath, classifyInfo.LevelPath)
- fmt.Println("after", after)
- // 拼接字符串
- if after != "" {
- ids := strings.Split(after, ",")
- for _, v := range ids {
- if _, ok := classifyIdMap[v]; !ok {
- classifyIds = append(classifyIds, v)
- classifyIdMap[v] = struct{}{}
- }
- }
- }
- }
- }
- if len(classifyIds) > 0 {
- condition += " AND classify_id IN(" + utils.GetOrmInReplace(len(classifyIds)) + ") "
- pars = append(pars, classifyIds)
- }
- if keyword != "" {
- switch this.Lang {
- case utils.LANG_EN:
- condition += ` AND ( material_name_en LIKE '%` + keyword + `%' )`
- default:
- condition += ` AND ( material_name LIKE '%` + keyword + `%' )`
- }
- }
- //只看我的
- isShowMe, _ := this.GetBool("IsShowMe")
- if isShowMe {
- condition += ` AND sys_user_id = ? `
- pars = append(pars, sysUser.AdminId)
- }
- //获取图表信息
- list, err := material.GetMaterialListPageByCondition(condition, pars, startSize, pageSize)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Success = true
- br.Msg = "获取素材库信息失败"
- br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
- return
- }
- resp := new(material.MaterialListResp)
- if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
- items := make([]*material.MaterialListItems, 0)
- resp.Paging = page
- resp.List = items
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- return
- }
- dataCount, err := material.GetMaterialListCountByCondition(condition, pars)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取指标信息失败"
- br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
- return
- }
- page = paging.GetPaging(currentIndex, pageSize, dataCount)
- resp.Paging = page
- resp.List = list
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // SaveAsMaterial
- // @Title 将图表等封面上传至素材库
- // @Description 将图表等封面上传至素材库
- // @Param request body material.AddAndEditSandbox true "type json string"
- // @Success 200 {object} material.Material
- // @router /saveAs [post]
- func (this *MaterialController) SaveAsMaterial() {
- 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 material.SaveAsMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- req.MaterialName = strings.Trim(req.MaterialName, " ")
- if req.MaterialName == "" {
- br.Msg = "缺少素材库名称"
- return
- }
- var exist *material.Material
- switch this.Lang {
- case utils.LANG_EN:
- exist, err = material.GetMaterialByNameEn(req.MaterialName)
- default:
- // 判断名称是否重复
- exist, err = material.GetMaterialByName(req.MaterialName)
- }
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- if err == nil && exist.MaterialId > 0 {
- br.Msg = "图片名称已存在"
- return
- }
- err, errMsg := materialService.AddToMaterial(req, sysUser.AdminId, sysUser.RealName)
- if err != nil {
- br.Msg = "保存失败!"
- if errMsg != `` {
- br.Msg = errMsg
- }
- br.ErrMsg = "保存失败,Err:" + err.Error()
- return
- }
- msg := "保存成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // MyChartSaveAsMaterial
- // @Title 将我的图表等封面上传至素材库
- // @Description 将图表等封面上传至素材库
- // @Param request body material.AddAndEditSandbox true "type json string"
- // @Success 200 {object} material.Material
- // @router /my_chart/saveAs [post]
- func (this *MaterialController) MyChartSaveAsMaterial() {
- 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 material.MyChartSaveAsMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- materialNames := make([]string, 0)
- namesMap := make(map[string]struct{})
- for _, v := range req.MaterialList {
- if v.ClassifyId <= 0 {
- br.Msg = "请选择分类"
- return
- }
- v.MaterialName = strings.Trim(v.MaterialName, " ")
- if v.MaterialName == "" {
- br.Msg = "请填写图片名称"
- return
- }
- if v.ChartInfoId <= 0 {
- br.Msg = "请选择图表"
- return
- }
- if v.MyChartId <= 0 {
- br.Msg = "请选择我的图表"
- return
- }
- if _, ok := namesMap[v.MaterialName]; ok {
- br.Msg = "图片名称不能重复"
- return
- }
- namesMap[v.MaterialName] = struct{}{}
- materialNames = append(materialNames, v.MaterialName)
- }
- if len(materialNames) == 0 {
- br.Msg = "请填写图片名称"
- return
- }
- existList := make([]*material.Material, 0)
- switch this.Lang {
- case utils.LANG_EN:
- existList, err = material.GetMaterialByNameEns(materialNames)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- if len(existList) > 0 {
- msg := "图片名称:"
- for _, v := range existList {
- msg += v.MaterialNameEn + " "
- }
- br.Msg = fmt.Sprintf("%s 已存在", msg)
- return
- }
- default:
- // 判断文件名是否已存在
- existList, err = material.GetMaterialByNames(materialNames)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- if len(existList) > 0 {
- msg := "图片名称:"
- for _, v := range existList {
- msg += v.MaterialName + " "
- }
- br.Msg = fmt.Sprintf("%s 已存在", msg)
- return
- }
- }
- if len(req.MaterialList) > 30 {
- br.Msg = "最多支持选择30个图表"
- return
- }
- err, errMsg := materialService.MyChartAddToMaterial(req, sysUser.AdminId, sysUser.RealName)
- if err != nil {
- br.Msg = "保存失败!"
- if errMsg != `` {
- br.Msg = errMsg
- }
- br.ErrMsg = "保存失败,Err:" + err.Error()
- return
- }
- msg := "保存成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // Delete
- // @Title 删除素材库
- // @Description 删除素材库接口
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /del [post]
- func (this *MaterialController) Delete() {
- 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 material.DeleteMaterial
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.MaterialId <= 0 {
- br.Msg = "缺少素材库编号"
- return
- }
- //删除素材库
- err = material.DeleteByMaterialIds([]int{req.MaterialId})
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "操作失败,Err:" + err.Error()
- return
- }
- msg := "删除成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // BatchDelete
- // @Title 批量删除素材库
- // @Description 删除素材库接口
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /batch/del [post]
- func (this *MaterialController) BatchDelete() {
- 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 material.BatchDeleteMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- deleteMaterialIds := make([]int, 0)
- if req.IsSelectAll {
- classifyId := req.ClassifyId
- keyword := req.Keyword
- isShowMe := req.IsShowMe
- //获取图表信息
- list, e, msg := materialService.GetBatchSelectedMaterialList(classifyId, keyword, isShowMe, sysUser, this.Lang)
- if e != nil {
- br.Msg = "获取素材库信息失败"
- if msg != "" {
- br.Msg = msg
- }
- br.ErrMsg = "获取素材库信息失败,Err:" + e.Error()
- return
- }
- notSelectIds := make(map[int]struct{})
- if len(req.MaterialIds) >= 0 {
- for _, v := range req.MaterialIds {
- notSelectIds[v] = struct{}{}
- }
- }
- for _, v := range list {
- if _, ok := notSelectIds[v.MaterialId]; !ok {
- deleteMaterialIds = append(deleteMaterialIds, v.MaterialId)
- }
- }
- } else {
- deleteMaterialIds = req.MaterialIds
- }
- if len(deleteMaterialIds) <= 0 {
- br.Msg = "请选择删除的素材"
- return
- }
- //删除素材库
- err = material.DeleteByMaterialIds(deleteMaterialIds)
- if err != nil {
- br.Msg = err.Error()
- return
- }
- msg := "删除成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // MaterialClassifyList
- // @Title 获取所有素材库分类接口-不包含素材库
- // @Description 获取所有素材库分类接口-不包含素材库
- // @Param IsShowMe query bool true "是否只看我的,true、false"
- // @Success 200 {object} data_manage.ChartClassifyListResp
- // @router /classify/list [get]
- func (this *MaterialController) MaterialClassifyList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- resp := new(material.MaterialClassifyListResp)
- rootList, err := material.GetMaterialClassifyByParentId(0)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- classifyAll, err := material.GetMaterialClassifyAll()
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- nodeAll := make([]*material.MaterialClassifyItems, 0)
- for k := range rootList {
- rootNode := rootList[k]
- materialService.MaterialClassifyItemsMakeTree(this.SysUser, classifyAll, rootNode)
- nodeAll = append(nodeAll, rootNode)
- }
- resp.AllNodes = nodeAll
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- // BatchAdd
- // @Title 批量新增素材
- // @Description 新增/编辑保存素材库接口
- // @Param request body material.AddAndEditSandbox true "type json string"
- // @Success 200 {object} material.Material
- // @router /batch/add [post]
- func (this *MaterialController) BatchAdd() {
- 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 material.BatchAddMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- classifyId := req.ClassifyId
- if classifyId <= 0 {
- br.Msg = "请选择分类"
- return
- }
- materialNames := make([]string, 0)
- namesMap := make(map[string]struct{})
- for _, v := range req.MaterialList {
- if v.MaterialName == "" {
- br.Msg = "请填写图片名称"
- return
- }
- if v.ImgUrl == "" {
- br.Msg = "请上传图片"
- return
- }
- if _, ok := namesMap[v.MaterialName]; ok {
- br.Msg = "图片名称不能重复"
- return
- }
- namesMap[v.MaterialName] = struct{}{}
- materialNames = append(materialNames, v.MaterialName)
- }
- if len(materialNames) == 0 {
- br.Msg = "请填写图片名称"
- return
- }
- existList := make([]*material.Material, 0)
- switch this.Lang {
- case utils.LANG_EN:
- existList, err = material.GetMaterialByNameEns(materialNames)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- if len(existList) > 0 {
- msg := "图片名称:"
- for _, v := range existList {
- msg += v.MaterialNameEn + " "
- }
- br.Msg = fmt.Sprintf("%s 已存在", msg)
- return
- }
- default:
- // 判断文件名是否已存在
- existList, err = material.GetMaterialByNames(materialNames)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- if len(existList) > 0 {
- msg := "图片名称:"
- for _, v := range existList {
- msg += v.MaterialName + " "
- }
- br.Msg = fmt.Sprintf("%s 已存在", msg)
- return
- }
- }
- err = materialService.BatchAddMaterial(req.MaterialList, classifyId, sysUser.AdminId, sysUser.AdminName)
- if err != nil {
- br.Msg = "文件上传失败"
- br.ErrMsg = "文件上传失败,Err:" + err.Error()
- return
- }
- msg := "添加成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // BatchChangeClassify
- // @Title 批量更换分类
- // @Description 批量更换分类
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /batch/changeClassify [post]
- func (this *MaterialController) BatchChangeClassify() {
- 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 material.BatchChangeClassifyMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.NewClassifyId <= 0 {
- br.Msg = "请选择新的分类"
- return
- }
- updateMaterialIds := make([]int, 0)
- if req.IsSelectAll {
- classifyId := req.ClassifyId
- keyword := req.Keyword
- isShowMe := req.IsShowMe
- //获取图表信息
- list, e, msg := materialService.GetBatchSelectedMaterialList(classifyId, keyword, isShowMe, sysUser, this.Lang)
- if e != nil {
- br.Msg = "获取素材库信息失败"
- if msg != "" {
- br.Msg = msg
- }
- br.ErrMsg = "获取素材库信息失败,Err:" + e.Error()
- return
- }
- notSelectIds := make(map[int]struct{})
- if len(req.MaterialIds) >= 0 {
- for _, v := range req.MaterialIds {
- notSelectIds[v] = struct{}{}
- }
- }
- for _, v := range list {
- if _, ok := notSelectIds[v.MaterialId]; !ok {
- updateMaterialIds = append(updateMaterialIds, v.MaterialId)
- }
- }
- } else {
- updateMaterialIds = req.MaterialIds
- }
- if len(updateMaterialIds) <= 0 {
- br.Msg = "请选择变更的素材"
- return
- }
- // 判断新分类是否存在
- _, err = material.GetMaterialClassifyById(req.NewClassifyId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "分类不存在"
- return
- }
- br.Msg = "获取分类信息失败"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- }
- //更换分类素材库
- err = material.UpdateClassifyByMaterialIds(updateMaterialIds, req.NewClassifyId, time.Now())
- if err != nil {
- br.Msg = err.Error()
- return
- }
- msg := "操作成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // ChangeClassify
- // @Title 更换分类
- // @Description 批量更换分类
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /changeClassify [post]
- func (this *MaterialController) ChangeClassify() {
- 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 material.ChangeClassifyMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.MaterialId <= 0 {
- br.Msg = "缺少素材库编号"
- return
- }
- if req.NewClassifyId <= 0 {
- br.Msg = "请选择新的分类"
- return
- }
- // 判断素材是否存在
- info, err := material.GetMaterialById(req.MaterialId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "素材不存在"
- return
- }
- br.Msg = "获取素材库信息失败"
- br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
- return
- }
- if req.NewClassifyId == info.ClassifyId {
- br.Msg = "请选择不同的分类"
- return
- }
- // 判断新分类是否存在
- _, err = material.GetMaterialClassifyById(req.NewClassifyId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "分类不存在"
- return
- }
- br.Msg = "获取分类信息失败"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- }
- info.ClassifyId = req.NewClassifyId
- info.ModifyTime = time.Now()
- //更换分类素材库
- err = info.Update([]string{"ClassifyId", "ModifyTime"})
- if err != nil {
- br.Msg = err.Error()
- return
- }
- msg := "操作成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // Rename
- // @Title 素材重命名
- // @Description 素材重命名
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /rename [post]
- func (this *MaterialController) Rename() {
- 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 material.RenameMaterialReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.MaterialId <= 0 {
- br.Msg = "缺少素材库编号"
- return
- }
- if req.MaterialName == "" {
- br.Msg = "缺少素材库名称"
- return
- }
- // 判断素材是否存在
- info, err := material.GetMaterialById(req.MaterialId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "素材不存在"
- return
- }
- br.Msg = "获取素材库信息失败"
- br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
- return
- }
- var exist *material.Material
- updateStr := make([]string, 0)
- switch this.Lang {
- case utils.LANG_EN:
- // 判断名称是否重复
- if info.MaterialNameEn == req.MaterialName {
- br.Msg = "名称未修改"
- return
- }
- exist, err = material.GetMaterialByNameEn(req.MaterialName)
- info.MaterialNameEn = req.MaterialName
- updateStr = append(updateStr, "MaterialNameEn")
- default:
- // 判断名称是否重复
- if info.MaterialName == req.MaterialName {
- br.Msg = "名称未修改"
- return
- }
- exist, err = material.GetMaterialByName(req.MaterialName)
- info.MaterialName = req.MaterialName
- updateStr = append(updateStr, "MaterialName")
- }
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败"
- br.ErrMsg = "获取数据失败,Err:" + err.Error()
- return
- }
- if err == nil && exist.MaterialId > 0 {
- br.Msg = "图片名称已存在"
- return
- }
- info.ModifyTime = time.Now()
- updateStr = append(updateStr, "ModifyTime")
- //更换分类素材库
- err = info.Update(updateStr)
- if err != nil {
- br.Msg = err.Error()
- return
- }
- msg := "操作成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // BatchDownload
- // @Title 批量下载素材
- // @Description 批量下载素材
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /batch/download [get]
- func (this *MaterialController) BatchDownload() {
- 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 material.BatchDeleteMaterialReq
- materialIdStr := this.GetString("MaterialIds")
- isSelectAll, _ := this.GetBool("IsSelectAll")
- classifyId, _ := this.GetInt("ClassifyId")
- keyword := this.GetString("Keyword")
- isShowMe, _ := this.GetBool("IsShowMe")
- downMaterialList := make([]*material.MaterialListItems, 0)
- materialIds := strings.Split(materialIdStr, ",")
- var err error
- if isSelectAll {
- //获取图表信息
- list, e, msg := materialService.GetBatchSelectedMaterialList(classifyId, keyword, isShowMe, sysUser, this.Lang)
- if e != nil {
- br.Msg = "获取素材库信息失败"
- if msg != "" {
- br.Msg = msg
- }
- br.ErrMsg = "获取素材库信息失败,Err:" + e.Error()
- return
- }
- notSelectIds := make(map[int]struct{})
- if len(materialIds) >= 0 {
- //转成数组
- for _, v := range materialIds {
- id, _ := strconv.Atoi(v)
- notSelectIds[id] = struct{}{}
- }
- }
- for _, v := range list {
- if _, ok := notSelectIds[v.MaterialId]; !ok {
- downMaterialList = append(downMaterialList, v)
- }
- }
- } else {
- if len(materialIds) > 0 {
- // 批量查询指标数据
- materialIdsInt := make([]int, 0)
- for _, v := range materialIds {
- id, _ := strconv.Atoi(v)
- materialIdsInt = append(materialIdsInt, id)
- }
- downMaterialList, err = material.GetMaterialByIds(materialIdsInt)
- if err != nil {
- br.Msg = "获取素材库信息失败"
- br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
- return
- }
- }
- }
- if len(downMaterialList) <= 0 {
- br.Msg = "请选择要下载的素材"
- return
- }
- // 创建zip
- zipName := time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandString(5) + ".zip"
- savePath := zipName
- zipFile, err := os.Create(zipName)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "生成压缩文件失败, Err: " + err.Error()
- return
- }
- zipWriter := zip.NewWriter(zipFile)
- // 生成zip过程中报错关闭
- defer func() {
- if err != nil {
- _ = zipWriter.Close()
- _ = zipFile.Close()
- }
- _ = os.Remove(savePath)
- }()
- // 获取资源, 写入zip
- zipFileName := ""
- for i := range downMaterialList {
- if downMaterialList[i].MaterialName == "" || downMaterialList[i].ImgUrl == "" {
- continue
- }
- fmt.Printf("开始压缩第%d个文件\n", i+1)
- dotIndex := strings.LastIndex(downMaterialList[i].ImgUrl, ".")
- // 如果找不到点,或者点是文件名的第一个字符(不合法情况),则返回空字符串
- if dotIndex == -1 || dotIndex == 0 {
- continue
- }
- fileExt := downMaterialList[i].ImgUrl[dotIndex+1:]
- ioWriter, err := zipWriter.Create(fmt.Sprintf("%s.%s", downMaterialList[i].MaterialName, fileExt))
- if err != nil {
- if os.IsPermission(err) {
- br.Msg = "操作失败"
- br.ErrMsg = "打包权限不足, Err: " + err.Error()
- return
- }
- br.Msg = "操作失败"
- br.ErrMsg = "压缩出错, Err: " + err.Error()
- return
- }
- var content []byte
- content, err = http.Get(downMaterialList[i].ImgUrl)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "资源获取失败, Err: " + err.Error()
- return
- }
- _, err = ioWriter.Write(content)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "压缩文件写入失败, Err: " + err.Error()
- return
- }
- if zipFileName == "" {
- zipFileName = downMaterialList[i].MaterialName
- }
- fmt.Printf("第%d个文件写入成功\n", i+1)
- }
- // 生成zip后关闭,否则下载文件会损坏
- _ = zipWriter.Close()
- _ = zipFile.Close()
- this.Ctx.Output.Download(savePath, fmt.Sprintf("%s.zip", zipFileName))
- msg := "操作成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- }
- // Download
- // @Title 下载素材
- // @Description 下载素材
- // @Param request body material.DeleteSandbox true "type json string"
- // @Success 200 标记成功
- // @router /download [get]
- func (this *MaterialController) Download() {
- 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
- }
- materialId, _ := this.GetInt("MaterialId")
- if materialId <= 0 {
- br.Msg = "缺少素材库编号"
- return
- }
- // 判断素材是否存在
- info, err := material.GetMaterialById(materialId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "素材不存在"
- return
- }
- br.Msg = "获取素材库信息失败"
- br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
- return
- }
- if info.ImgUrl == "" {
- br.Msg = "素材地址为空"
- return
- }
- fileName := info.MaterialName
- // 查找文件名中最后一个点的位置
- dotIndex := strings.LastIndex(info.ImgUrl, ".")
- // 如果找不到点,或者点是文件名的第一个字符(不合法情况),则返回空字符串
- if dotIndex == -1 || dotIndex == 0 {
- br.Msg = "素材地址错误"
- return
- }
- fileName += "." + info.ImgUrl[dotIndex+1:] // 添加扩展名到文件名
- // 获取路径中的文件名
- urlFileName := path.Base(info.ImgUrl)
- uploadDir := utils.STATIC_DIR + "hongze/" + time.Now().Format("20060102")
- if e := os.MkdirAll(uploadDir, utils.DIR_MOD); e != nil {
- br.Msg = "存储目录创建失败"
- br.ErrMsg = "存储目录创建失败, Err:" + e.Error()
- return
- }
- var content []byte
- content, err = http.Get(info.ImgUrl)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "资源获取失败, Err: " + err.Error()
- return
- }
- filePath := uploadDir + "/" + urlFileName
- ioWriter, err := os.Create(filePath)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "文件创建失败, Err: " + err.Error()
- return
- }
- n, err := ioWriter.Write(content)
- fmt.Println("n", n)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "压缩文件写入失败, Err: " + err.Error()
- return
- }
- this.Ctx.Output.Download(filePath, fileName)
- defer func() {
- _ = os.Remove(filePath)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "success"
- }
|