material.go 46 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602
  1. package material
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/controllers"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/material"
  7. "eta/eta_api/services"
  8. materialService "eta/eta_api/services/material"
  9. "eta/eta_api/utils"
  10. "fmt"
  11. "github.com/h2non/filetype"
  12. "github.com/rdlucklib/rdluck_tools/paging"
  13. "io/ioutil"
  14. "path"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. // MaterialController 逻辑导图
  20. type MaterialController struct {
  21. controllers.BaseAuthController
  22. }
  23. // ClassifyMaterialItems
  24. // @Title 获取所有素材库分类接口-包含素材库
  25. // @Description 获取所有素材库分类接口-包含素材库
  26. // @Param IsShowMe query bool true "是否只看我的,true、false"
  27. // @Success 200 {object} data_manage.ChartClassifyListResp
  28. // @router /classify/materialList [get]
  29. func (this *MaterialController) ClassifyMaterialItems() {
  30. br := new(models.BaseResponse).Init()
  31. defer func() {
  32. this.Data["json"] = br
  33. this.ServeJSON()
  34. }()
  35. resp := new(material.MaterialClassifyListResp)
  36. MaterialClassifyId, _ := this.GetInt("MaterialClassifyId")
  37. isShowMe, _ := this.GetBool("IsShowMe")
  38. if isShowMe {
  39. errMsg, err := materialService.GetMaterialClassifyListForMe(*this.SysUser, resp, MaterialClassifyId)
  40. if err != nil {
  41. br.Msg = errMsg
  42. br.ErrMsg = err.Error()
  43. return
  44. }
  45. // 移除没有权限的图表
  46. br.Ret = 200
  47. br.Success = true
  48. br.Msg = "获取成功"
  49. br.Data = resp
  50. fmt.Println("source my classify")
  51. return
  52. }
  53. rootList, err := material.GetMaterialClassifyAndInfoByParentId(MaterialClassifyId)
  54. if err != nil && err.Error() != utils.ErrNoRow() {
  55. br.Msg = "获取失败"
  56. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  57. return
  58. }
  59. classifyAll, err := material.GetMaterialClassifyAndInfoByParentId(MaterialClassifyId)
  60. if err != nil && err.Error() != utils.ErrNoRow() {
  61. br.Msg = "获取失败"
  62. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  63. return
  64. }
  65. nodeAll := make([]*material.MaterialClassifyItems, 0)
  66. for k := range rootList {
  67. rootNode := rootList[k]
  68. materialService.MaterialClassifyItemsMakeTreeV2(this.SysUser, classifyAll, rootNode)
  69. nodeAll = append(nodeAll, rootNode)
  70. }
  71. //newAll := materialService.MaterialItemsMakeTree(nodeAll, sandListMap, MaterialClassifyId)
  72. resp.AllNodes = nodeAll
  73. br.Ret = 200
  74. br.Success = true
  75. br.Msg = "获取成功"
  76. br.Data = resp
  77. }
  78. // AddMaterialClassify
  79. // @Title 新增素材库分类
  80. // @Description 新增材库分类接口
  81. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  82. // @Success 200 Ret=200 保存成功
  83. // @router /classify/add [post]
  84. func (this *MaterialController) AddMaterialClassify() {
  85. br := new(models.BaseResponse).Init()
  86. defer func() {
  87. this.Data["json"] = br
  88. this.ServeJSON()
  89. }()
  90. var req material.AddMaterialClassifyReq
  91. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  92. if err != nil {
  93. br.Msg = "参数解析异常!"
  94. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  95. return
  96. }
  97. if req.ClassifyName == "" {
  98. br.Msg = "请输入分类名称"
  99. br.IsSendEmail = false
  100. return
  101. }
  102. if req.ParentId < 0 {
  103. br.Msg = "参数错误"
  104. br.IsSendEmail = false
  105. return
  106. }
  107. level := 1
  108. levelPath := ""
  109. if req.ParentId > 0 {
  110. //查找父级分类
  111. parentClassify, e := material.GetMaterialClassifyById(req.ParentId)
  112. if e != nil {
  113. br.Msg = "获取父级分类失败"
  114. br.ErrMsg = "获取父级分类失败,Err:" + e.Error()
  115. return
  116. }
  117. level = parentClassify.Level + 1
  118. levelPath = parentClassify.LevelPath
  119. }
  120. count, e := material.GetMaterialClassifyNameCount(req.ClassifyName, req.ParentId)
  121. if e != nil {
  122. br.Msg = "判断名称是否已存在失败"
  123. br.ErrMsg = "判断名称是否已存在失败,Err:" + e.Error()
  124. return
  125. }
  126. if count > 0 {
  127. br.Msg = "分类名称已存在,请重新输入"
  128. br.IsSendEmail = false
  129. return
  130. }
  131. //获取该层级下最大的排序数
  132. classify := new(material.MaterialClassify)
  133. maxSort, _ := material.GetMaterialClassifyMaxSort(req.ParentId)
  134. classify.ParentId = req.ParentId
  135. classify.ClassifyName = req.ClassifyName
  136. classify.CreateTime = time.Now()
  137. classify.ModifyTime = time.Now()
  138. classify.SysUserId = this.SysUser.AdminId
  139. classify.SysUserRealName = this.SysUser.RealName
  140. classify.Level = level
  141. classify.Sort = maxSort + 1
  142. classifyId, e := material.AddMaterialClassify(classify)
  143. if e != nil {
  144. br.Msg = "保存分类失败"
  145. br.ErrMsg = "保存分类失败,Err:" + e.Error()
  146. return
  147. }
  148. if req.ParentId > 0 {
  149. levelPath = fmt.Sprintf("%s,%d", levelPath, classifyId)
  150. } else {
  151. levelPath = fmt.Sprintf("%d", classifyId)
  152. }
  153. classify.ClassifyId = int(classifyId)
  154. classify.LevelPath = levelPath
  155. e = classify.Update([]string{"LevelPath"})
  156. if e != nil {
  157. br.Msg = "保存分类失败"
  158. br.ErrMsg = "保存分类失败,Err:" + e.Error()
  159. return
  160. }
  161. br.Ret = 200
  162. br.Msg = "保存成功"
  163. br.Success = true
  164. }
  165. // EditMaterialClassify
  166. // @Title 修改素材库分类
  167. // @Description 修改素材库分类接口
  168. // @Param request body data_manage.EditChartClassifyReq true "type json string"
  169. // @Success 200 Ret=200 修改成功
  170. // @router /classify/edit [post]
  171. func (this *MaterialController) EditMaterialClassify() {
  172. br := new(models.BaseResponse).Init()
  173. defer func() {
  174. this.Data["json"] = br
  175. this.ServeJSON()
  176. }()
  177. var req material.EditMaterialClassifyReq
  178. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  179. if err != nil {
  180. br.Msg = "参数解析异常!"
  181. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  182. return
  183. }
  184. if req.ClassifyName == "" {
  185. br.Msg = "请输入分类名称"
  186. br.IsSendEmail = false
  187. return
  188. }
  189. if req.ClassifyId <= 0 {
  190. br.Msg = "参数错误"
  191. br.IsSendEmail = false
  192. return
  193. }
  194. // 只允许修改分类名称
  195. item, err := material.GetMaterialClassifyById(req.ClassifyId)
  196. if err != nil {
  197. if err.Error() == utils.ErrNoRow() {
  198. br.Msg = "分类不存在"
  199. return
  200. }
  201. br.Msg = "保存失败"
  202. br.Msg = "获取分类信息失败,Err:" + err.Error()
  203. return
  204. }
  205. count, err := material.GetMaterialClassifyNameNotSelfCount(req.ClassifyId, req.ClassifyName, item.ParentId)
  206. if err != nil {
  207. br.Msg = "判断名称是否已存在失败"
  208. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  209. return
  210. }
  211. if count > 0 {
  212. br.Msg = "分类名称已存在,请重新输入"
  213. br.IsSendEmail = false
  214. return
  215. }
  216. //levelPath = fmt.Sprintf("%s,%d", levelPath, req.ClassifyId)
  217. //item.LevelPath = levelPath
  218. //item.ParentId = req.ParentId
  219. item.ClassifyName = req.ClassifyName
  220. item.ModifyTime = time.Now()
  221. //e = item.Update([]string{"LevelPath", "ParentId", "ClassifyName", "ModifyTime"})
  222. err = item.Update([]string{"ClassifyName", "ModifyTime"})
  223. if err != nil {
  224. br.Msg = "保存分类失败"
  225. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  226. return
  227. }
  228. //todo 测试更新子集的levelPath
  229. /*levelPath := ""
  230. oldLevelPath := item.LevelPath
  231. if item.ParentId > 0 {
  232. //查找父级分类
  233. parentClassify, e := material.GetMaterialClassifyById(item.ParentId)
  234. if e != nil {
  235. br.Msg = "获取父级分类失败"
  236. br.ErrMsg = "获取父级分类失败,Err:" + e.Error()
  237. return
  238. }
  239. levelPath = fmt.Sprintf("%s,%d", parentClassify.LevelPath, item.ClassifyId)
  240. tmpList, e := material.GetMaterialClassifyByLevelPath(oldLevelPath)
  241. if e != nil {
  242. br.Msg = "保存分类失败"
  243. br.ErrMsg = "保存分类失败,Err:" + e.Error()
  244. return
  245. }
  246. // 把原先的父级levePath,替换成最新的父级序列
  247. for _, tmp := range tmpList {
  248. tmp.LevelPath = strings.Replace(tmp.LevelPath, oldLevelPath, levelPath, -1)
  249. tmp.ModifyTime = time.Now()
  250. e = tmp.Update([]string{"LevelPath", "ModifyTime"})
  251. if e != nil {
  252. br.Msg = "保存分类失败"
  253. br.ErrMsg = "保存分类失败,Err:" + e.Error()
  254. return
  255. }
  256. }
  257. } else {
  258. // 只有更改了父级才需要更新levelPath
  259. }*/
  260. br.Ret = 200
  261. br.Msg = "保存成功"
  262. br.Success = true
  263. br.IsAddLog = true
  264. }
  265. // DeleteMaterialClassifyCheck
  266. // @Title 删除素材库检测接口
  267. // @Description 删除素材库检测接口
  268. // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
  269. // @Success 200 Ret=200 检测成功
  270. // @router /classify/del/check [post]
  271. func (this *MaterialController) DeleteMaterialClassifyCheck() {
  272. br := new(models.BaseResponse).Init()
  273. defer func() {
  274. this.Data["json"] = br
  275. this.ServeJSON()
  276. }()
  277. var req material.MaterialClassifyDeleteCheckReq
  278. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  279. if err != nil {
  280. br.Msg = "参数解析异常!"
  281. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  282. return
  283. }
  284. if req.ClassifyId < 0 {
  285. br.Msg = "参数错误"
  286. br.IsSendEmail = false
  287. return
  288. }
  289. var deleteStatus int
  290. var tipsMsg string
  291. //删除分类
  292. // 查询当前的分类
  293. classifyInfo, err := material.GetMaterialClassifyById(req.ClassifyId)
  294. if err != nil {
  295. br.Msg = "分类不存在"
  296. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  297. return
  298. }
  299. classifyIds := strings.Split(classifyInfo.LevelPath, ",")
  300. if len(classifyIds) > 0 {
  301. //判断素材库分类下,是否含有素材库
  302. count, e := material.GetMaterialInfoCountByClassifyIds(classifyIds)
  303. if e != nil {
  304. br.Msg = "删除失败"
  305. br.ErrMsg = "分类下是否含有指标失败,Err:" + e.Error()
  306. return
  307. }
  308. if count > 0 {
  309. deleteStatus = 1
  310. tipsMsg = "该分类下关联素材库不可删除"
  311. } else {
  312. if len(classifyIds) > 1 {
  313. deleteStatus = 2
  314. tipsMsg = "确认删除当前目录及包含的子目录吗"
  315. }
  316. }
  317. }
  318. if deleteStatus == 0 {
  319. tipsMsg = "可删除,进行删除操作"
  320. }
  321. resp := new(material.MaterialClassifyDeleteCheckResp)
  322. resp.DeleteStatus = deleteStatus
  323. resp.TipsMsg = tipsMsg
  324. br.Ret = 200
  325. br.Msg = "检测成功"
  326. br.Success = true
  327. br.Data = resp
  328. }
  329. // DeleteMaterialClassify
  330. // @Title 删除素材库分类/素材库
  331. // @Description 删除素材库分类/素材库接口
  332. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  333. // @Success 200 Ret=200 删除成功
  334. // @router /classify/del [post]
  335. func (this *MaterialController) DeleteMaterialClassify() {
  336. br := new(models.BaseResponse).Init()
  337. defer func() {
  338. this.Data["json"] = br
  339. this.ServeJSON()
  340. }()
  341. sysUser := this.SysUser
  342. if sysUser == nil {
  343. br.Msg = "请登录"
  344. br.ErrMsg = "请登录,SysUser Is Empty"
  345. br.Ret = 408
  346. return
  347. }
  348. var req material.DeleteMaterialClassifyReq
  349. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  350. if err != nil {
  351. br.Msg = "参数解析异常!"
  352. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  353. return
  354. }
  355. if req.ClassifyId < 0 {
  356. br.Msg = "参数错误"
  357. br.IsSendEmail = false
  358. return
  359. }
  360. // 查询当前的分类
  361. classifyInfo, err := material.GetMaterialClassifyById(req.ClassifyId)
  362. if err != nil {
  363. br.Msg = "分类不存在"
  364. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  365. return
  366. }
  367. classifyIds := strings.Split(classifyInfo.LevelPath, ",")
  368. if len(classifyIds) > 0 {
  369. //判断素材库分类下,是否含有素材库
  370. count, e := material.GetMaterialInfoCountByClassifyIds(classifyIds)
  371. if e != nil {
  372. br.Msg = "删除失败"
  373. br.ErrMsg = "分类下是否含有指标失败,Err:" + e.Error()
  374. return
  375. }
  376. if count > 0 {
  377. br.Msg = "该目录下存在关联指标,不可删除"
  378. br.IsSendEmail = false
  379. return
  380. }
  381. err = material.DeleteMaterialClassify(classifyIds)
  382. if err != nil {
  383. br.Msg = "删除失败"
  384. br.ErrMsg = "删除失败,Err:" + err.Error()
  385. return
  386. }
  387. }
  388. //删除素材库
  389. /*if req.MaterialId > 0 {
  390. materialInfo, err := material.GetMaterialById(req.MaterialId)
  391. if err != nil {
  392. if err.Error() == utils.ErrNoRow() {
  393. br.Msg = "素材库已删除,请刷新页面"
  394. br.ErrMsg = "指标不存在,Err:" + err.Error()
  395. return
  396. } else {
  397. br.Msg = "删除失败"
  398. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  399. return
  400. }
  401. }
  402. if materialInfo == nil {
  403. br.Msg = "素材库已删除,请刷新页面"
  404. return
  405. }
  406. err = materialService.DeleteMaterial(req.MaterialId)
  407. if err != nil {
  408. br.Msg = err.Error()
  409. return
  410. }
  411. }*/
  412. br.Ret = 200
  413. br.Msg = "删除成功"
  414. br.Success = true
  415. br.IsAddLog = true
  416. }
  417. // ClassifyMove
  418. // @Title 素材库分类移动接口
  419. // @Description 素材库分类移动接口
  420. // @Success 200 {object} data_manage.MoveChartClassifyReq
  421. // @router /classify/move [post]
  422. func (this *MaterialController) ClassifyMove() {
  423. br := new(models.BaseResponse).Init()
  424. defer func() {
  425. this.Data["json"] = br
  426. this.ServeJSON()
  427. }()
  428. sysUser := this.SysUser
  429. if sysUser == nil {
  430. br.Msg = "请登录"
  431. br.ErrMsg = "请登录,SysUser Is Empty"
  432. br.Ret = 408
  433. return
  434. }
  435. var req material.MoveMaterialClassifyReq
  436. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  437. if err != nil {
  438. br.Msg = "参数解析异常!"
  439. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  440. return
  441. }
  442. if req.ClassifyId <= 0 {
  443. br.Msg = "参数错误"
  444. br.ErrMsg = "分类id小于等于0"
  445. return
  446. }
  447. //判断分类是否存在
  448. materialClassifyInfo, err := material.GetMaterialClassifyById(req.ClassifyId)
  449. if err != nil {
  450. if err.Error() == utils.ErrNoRow() {
  451. br.Msg = "分类不存在,请刷新页面"
  452. br.ErrMsg = "分类不存在,Err:" + err.Error()
  453. return
  454. }
  455. br.Msg = "移动失败"
  456. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  457. return
  458. }
  459. if materialClassifyInfo.ParentId != req.ParentClassifyId {
  460. count, err := material.GetMaterialClassifyNameNotSelfCount(materialClassifyInfo.ClassifyId, materialClassifyInfo.ClassifyName, materialClassifyInfo.ParentId)
  461. if err != nil {
  462. br.Msg = "判断名称是否已存在失败"
  463. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  464. return
  465. }
  466. if count > 0 {
  467. br.Msg = "移动失败,分类名称已存在"
  468. br.IsSendEmail = false
  469. return
  470. }
  471. }
  472. err, errMsg := materialService.MoveMaterialClassify(materialClassifyInfo, &req)
  473. if err != nil {
  474. br.Msg = errMsg
  475. if errMsg == "" {
  476. br.Msg = "移动失败"
  477. }
  478. br.ErrMsg = err.Error()
  479. }
  480. // todo权限校验
  481. //移动的是分类
  482. //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  483. /*updateCol := make([]string, 0)
  484. if MaterialClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  485. parentChartClassifyInfo, err := material.GetMaterialClassifyById(req.ParentClassifyId)
  486. if err != nil {
  487. br.Msg = "移动失败"
  488. br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  489. return
  490. }
  491. MaterialClassifyInfo.ParentId = parentChartClassifyInfo.ClassifyId
  492. MaterialClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  493. MaterialClassifyInfo.ModifyTime = time.Now()
  494. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  495. } else if MaterialClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId == 0 {
  496. //改为一级分类
  497. MaterialClassifyInfo.ParentId = req.ParentClassifyId
  498. MaterialClassifyInfo.Level = 1
  499. MaterialClassifyInfo.ModifyTime = time.Now()
  500. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  501. }
  502. //如果有传入 上一个兄弟节点分类id
  503. if req.PrevId > 0 {
  504. if req.PrevType == 1 {
  505. //上一个节点是分类
  506. //上一个兄弟节点
  507. prevClassify, err := material.GetMaterialClassifyById(req.PrevId)
  508. if err != nil {
  509. br.Msg = "移动失败"
  510. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  511. return
  512. }
  513. //如果是移动在两个兄弟节点之间
  514. if req.NextId > 0 {
  515. if req.NextType == 1 {
  516. //上一个节点是分类 下一个节点是分类的情况
  517. //下一个兄弟节点
  518. nextClassify, err := material.GetMaterialClassifyById(req.NextId)
  519. if err != nil {
  520. br.Msg = "移动失败"
  521. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  522. return
  523. }
  524. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  525. if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == MaterialClassifyInfo.Sort {
  526. //变更兄弟节点的排序
  527. updateSortStr := `sort + 2`
  528. _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, prevClassify.ClassifyId, prevClassify.Sort, updateSortStr)
  529. _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
  530. } else {
  531. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  532. if nextClassify.Sort-prevClassify.Sort == 1 {
  533. //变更兄弟节点的排序
  534. updateSortStr := `sort + 1`
  535. _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  536. _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
  537. }
  538. }
  539. } else {
  540. //上一个节点是分类 下一个节点是素材库的情况
  541. //下一个兄弟节点
  542. nextChartInfo, err := material.GetMaterialById(req.NextId)
  543. if err != nil {
  544. br.Msg = "移动失败"
  545. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  546. return
  547. }
  548. //如果上一个兄弟(分类)与下一个兄弟(素材库)的排序权重是一致的,那么需要将下一个兄弟(素材库)(以及下个兄弟(素材库)的同样排序权重)的排序权重+2,自己变成上一个兄弟(分类)的排序权重+1
  549. if prevClassify.Sort == nextChartInfo.Sort || prevClassify.Sort == MaterialClassifyInfo.Sort {
  550. //变更兄弟节点的排序
  551. updateSortStr := `sort + 2`
  552. _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, prevClassify.ClassifyId, prevClassify.Sort, updateSortStr)
  553. _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
  554. } else {
  555. //如果下一个兄弟(素材库)的排序权重正好是上个兄弟节点(分类)的下一层,那么需要再加一层了
  556. if nextChartInfo.Sort-prevClassify.Sort == 1 {
  557. //变更兄弟节点的排序
  558. updateSortStr := `sort + 1`
  559. _ = material.UpdateMaterialClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.ClassifyId, updateSortStr)
  560. _ = material.UpdateMaterialSortByClassifyId(prevClassify.ClassifyId, prevClassify.Sort, 0, updateSortStr)
  561. }
  562. }
  563. }
  564. }
  565. MaterialClassifyInfo.Sort = prevClassify.Sort + 1
  566. MaterialClassifyInfo.ModifyTime = time.Now()
  567. updateCol = append(updateCol, "Sort", "ModifyTime")
  568. } else {
  569. //上一个节点是素材库
  570. prevMaterial, err := material.GetMaterialById(req.PrevId)
  571. if err != nil {
  572. br.Msg = "移动失败"
  573. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  574. return
  575. }
  576. //如果是移动在两个兄弟节点之间
  577. if req.NextId > 0 {
  578. if req.NextType == 1 {
  579. //上一个节点是素材库 下一个节点是分类的情况
  580. //下一个兄弟节点
  581. nextClassify, err := material.GetMaterialClassifyById(req.NextId)
  582. if err != nil {
  583. br.Msg = "移动失败"
  584. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  585. return
  586. }
  587. //如果上一个兄弟(素材库)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(素材库)的排序权重+1
  588. if prevMaterial.Sort == nextClassify.Sort || prevMaterial.Sort == MaterialClassifyInfo.Sort {
  589. //变更兄弟节点的排序
  590. updateSortStr := `sort + 2`
  591. _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
  592. _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
  593. } else {
  594. //如果下一个兄弟(分类)的排序权重正好是上个兄弟(素材库)节点的下一层,那么需要再加一层了
  595. if nextClassify.Sort-prevMaterial.Sort == 1 {
  596. //变更兄弟节点的排序
  597. updateSortStr := `sort + 1`
  598. _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
  599. _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
  600. }
  601. }
  602. } else {
  603. //上一个节点是素材库 下一个节点是素材库的情况
  604. //下一个兄弟节点
  605. nextChartInfo, err := material.GetMaterialById(req.NextId)
  606. if err != nil {
  607. br.Msg = "移动失败"
  608. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  609. return
  610. }
  611. //如果上一个兄弟(素材库)与下一个兄弟(分类)的排序权重是一致的,那么需要将下一个兄弟(分类)(以及下个兄弟(分类)的同样排序权重)的排序权重+2,自己变成上一个兄弟(素材库)的排序权重+1
  612. if prevMaterial.Sort == nextChartInfo.Sort || prevMaterial.Sort == MaterialClassifyInfo.Sort {
  613. //变更兄弟节点的排序
  614. updateSortStr := `sort + 2`
  615. _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
  616. _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
  617. } else {
  618. //如果下一个兄弟(分类)的排序权重正好是上个兄弟(素材库)节点的下一层,那么需要再加一层了
  619. if nextChartInfo.Sort-prevMaterial.Sort == 1 {
  620. //变更兄弟节点的排序
  621. updateSortStr := `sort + 1`
  622. _ = material.UpdateMaterialClassifySortByParentId(prevMaterial.ClassifyId, 0, prevMaterial.Sort, updateSortStr)
  623. _ = material.UpdateMaterialSortByClassifyId(prevMaterial.ClassifyId, prevMaterial.Sort, prevMaterial.MaterialId, updateSortStr)
  624. }
  625. }
  626. }
  627. }
  628. MaterialClassifyInfo.Sort = prevMaterial.Sort + 1
  629. MaterialClassifyInfo.ModifyTime = time.Now()
  630. updateCol = append(updateCol, "Sort", "ModifyTime")
  631. }
  632. } else {
  633. firstClassify, err := material.GetFirstMaterialClassifyByParentId(MaterialClassifyInfo.ParentId)
  634. if err != nil && err.Error() != utils.ErrNoRow() {
  635. br.Msg = "移动失败"
  636. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  637. return
  638. }
  639. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  640. if firstClassify != nil && firstClassify.Sort == 0 {
  641. updateSortStr := ` sort + 1 `
  642. _ = material.UpdateMaterialClassifySortByParentId(firstClassify.ParentId, firstClassify.ClassifyId-1, 0, updateSortStr)
  643. }
  644. MaterialClassifyInfo.Sort = 0 //那就是排在第一位
  645. MaterialClassifyInfo.ModifyTime = time.Now()
  646. updateCol = append(updateCol, "Sort", "ModifyTime")
  647. }
  648. //更新
  649. if len(updateCol) > 0 {
  650. err = MaterialClassifyInfo.Update(updateCol)
  651. if err != nil {
  652. br.Msg = "移动失败"
  653. br.ErrMsg = "修改失败,Err:" + err.Error()
  654. return
  655. }
  656. // todo 记录整个层级的分类ID
  657. }*/
  658. br.Ret = 200
  659. br.Success = true
  660. br.Msg = "移动成功"
  661. }
  662. // List
  663. // @Title 素材列表接口
  664. // @Description 素材列表接口
  665. // @Param PageSize query int true "每页数据条数"
  666. // @Param CurrentIndex query int true "当前页页码,从1开始"
  667. // @Param ClassifyId query int true "分类id"
  668. // @Param Keyword query string true "搜索关键词"
  669. // @Param IsShowMe query bool true "是否只看我的,true、false"
  670. // @Success 200 {object} data_manage.ChartListResp
  671. // @router /list [get]
  672. func (this *MaterialController) List() {
  673. br := new(models.BaseResponse).Init()
  674. defer func() {
  675. this.Data["json"] = br
  676. this.ServeJSON()
  677. }()
  678. sysUser := this.SysUser
  679. if sysUser == nil {
  680. br.Msg = "请登录"
  681. br.ErrMsg = "请登录,SysUser Is Empty"
  682. br.Ret = 408
  683. return
  684. }
  685. classifyId, _ := this.GetInt("ClassifyId")
  686. pageSize, _ := this.GetInt("PageSize")
  687. currentIndex, _ := this.GetInt("CurrentIndex")
  688. keyword := this.GetString("Keyword")
  689. var total int
  690. page := paging.GetPaging(currentIndex, pageSize, total)
  691. var startSize int
  692. if pageSize <= 0 {
  693. pageSize = utils.PageSize20
  694. }
  695. if currentIndex <= 0 {
  696. currentIndex = 1
  697. }
  698. startSize = paging.StartIndex(currentIndex, pageSize)
  699. var condition string
  700. var pars []interface{}
  701. if classifyId <= 0 {
  702. br.Msg = "请选择分类"
  703. return
  704. }
  705. // 查询当前的分类
  706. classifyInfo, err := material.GetMaterialClassifyById(classifyId)
  707. if err != nil {
  708. br.Msg = "分类不存在"
  709. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  710. return
  711. }
  712. // 获取所有子分类
  713. childList, e := material.GetMaterialClassifyByLevelPath(classifyInfo.LevelPath)
  714. if e != nil {
  715. err = fmt.Errorf("保存分类失败,Err:" + e.Error())
  716. return
  717. }
  718. // 把原先的父级levePath,替换成最新的父级序列
  719. classifyIdMap := make(map[string]struct{})
  720. classifyIds := make([]string, 0)
  721. childClassifyMap := make(map[int]*material.MaterialClassify)
  722. for _, tmp := range childList {
  723. childClassifyMap[tmp.ClassifyId] = tmp
  724. //获取字符串前缀的位置
  725. after, _ := strings.CutPrefix(tmp.LevelPath, classifyInfo.LevelPath)
  726. fmt.Println("after", after)
  727. // 拼接字符串
  728. if after != "" {
  729. ids := strings.Split(after, ",")
  730. for _, v := range ids {
  731. if _, ok := classifyIdMap[v]; !ok {
  732. classifyIds = append(classifyIds, v)
  733. classifyIdMap[v] = struct{}{}
  734. }
  735. }
  736. }
  737. }
  738. classifyIds = append(classifyIds, strconv.Itoa(classifyId))
  739. if len(classifyIds) > 0 {
  740. condition += " AND classify_id IN(" + utils.GetOrmInReplace(len(classifyIds)) + ") "
  741. pars = append(pars, classifyIds)
  742. }
  743. if keyword != "" {
  744. condition += ` AND ( material_name LIKE '%` + keyword + `%' )`
  745. }
  746. //只看我的
  747. isShowMe, _ := this.GetBool("IsShowMe")
  748. if isShowMe {
  749. condition += ` AND sys_user_id = ? `
  750. pars = append(pars, sysUser.AdminId)
  751. }
  752. //获取图表信息
  753. list, err := material.GetMaterialListPageByCondition(condition, pars, startSize, pageSize)
  754. if err != nil && err.Error() != utils.ErrNoRow() {
  755. br.Success = true
  756. br.Msg = "获取素材库信息失败"
  757. br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
  758. return
  759. }
  760. for i, v := range list {
  761. if classifyTmp, ok := childClassifyMap[v.ClassifyId]; ok {
  762. list[i].ParentIds = classifyTmp.LevelPath
  763. }
  764. }
  765. resp := new(material.MaterialListResp)
  766. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  767. items := make([]*material.MaterialListItems, 0)
  768. resp.Paging = page
  769. resp.List = items
  770. br.Ret = 200
  771. br.Success = true
  772. br.Msg = "获取成功"
  773. br.Data = resp
  774. return
  775. }
  776. dataCount, err := material.GetMaterialListCountByCondition(condition, pars)
  777. if err != nil && err.Error() != utils.ErrNoRow() {
  778. br.Msg = "获取指标信息失败"
  779. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  780. return
  781. }
  782. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  783. resp.Paging = page
  784. resp.List = list
  785. br.Ret = 200
  786. br.Success = true
  787. br.Msg = "获取成功"
  788. br.Data = resp
  789. }
  790. // Save
  791. // @Title 新增/编辑保存素材库
  792. // @Description 新增/编辑保存素材库接口
  793. // @Param request body material.AddAndEditSandbox true "type json string"
  794. // @Success 200 {object} material.Material
  795. // @router /save [post]
  796. func (this *MaterialController) Save() {
  797. br := new(models.BaseResponse).Init()
  798. defer func() {
  799. this.Data["json"] = br
  800. this.ServeJSON()
  801. }()
  802. sysUser := this.SysUser
  803. if sysUser == nil {
  804. br.Msg = "请登录"
  805. br.ErrMsg = "请登录,SysUser Is Empty"
  806. br.Ret = 408
  807. return
  808. }
  809. var req material.AddAndEditMaterial
  810. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  811. if err != nil {
  812. br.Msg = "参数解析异常!"
  813. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  814. return
  815. }
  816. var materialResp *material.MaterialSaveResp
  817. var errMsg string
  818. if req.MaterialId <= 0 {
  819. //新增素材库
  820. materialResp, err = materialService.AddMaterial(req, sysUser.AdminId, sysUser.RealName)
  821. if err != nil {
  822. br.Msg = "保存失败!"
  823. if errMsg != `` {
  824. br.Msg = errMsg
  825. }
  826. br.ErrMsg = "保存失败,Err:" + err.Error()
  827. return
  828. }
  829. } else {
  830. //编辑素材库
  831. materialInfo := &material.Material{
  832. MaterialId: req.MaterialId,
  833. MaterialName: utils.TrimStr(req.MaterialName),
  834. ImgUrl: utils.TrimStr(req.ImgUrl),
  835. ModifyTime: time.Now(),
  836. ClassifyId: req.ClassifyId,
  837. }
  838. //缩略图为空时不更新
  839. var updateSandboxColumn = []string{}
  840. if req.ImgUrl == "" {
  841. updateSandboxColumn = []string{"Name", "Content", "MindmapData", "ModifyTime", "MaterialClassifyId", "Style"}
  842. } else {
  843. updateSandboxColumn = []string{"Name", "Content", "MindmapData", "ImgUrl", "ModifyTime", "MaterialClassifyId", "Style"}
  844. }
  845. err = materialInfo.Update(updateSandboxColumn)
  846. if err != nil {
  847. br.Msg = "保存失败!"
  848. if errMsg != `` {
  849. br.Msg = errMsg
  850. }
  851. br.ErrMsg = "保存失败,Err:" + err.Error()
  852. return
  853. }
  854. }
  855. msg := "保存成功"
  856. br.Ret = 200
  857. br.Success = true
  858. br.Msg = msg
  859. br.Data = materialResp
  860. }
  861. // Delete
  862. // @Title 删除素材库
  863. // @Description 删除素材库接口
  864. // @Param request body material.DeleteSandbox true "type json string"
  865. // @Success 200 标记成功
  866. // @router /del [post]
  867. func (this *MaterialController) Delete() {
  868. br := new(models.BaseResponse).Init()
  869. defer func() {
  870. this.Data["json"] = br
  871. this.ServeJSON()
  872. }()
  873. sysUser := this.SysUser
  874. if sysUser == nil {
  875. br.Msg = "请登录"
  876. br.ErrMsg = "请登录,SysUser Is Empty"
  877. br.Ret = 408
  878. return
  879. }
  880. var req material.DeleteMaterial
  881. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  882. if err != nil {
  883. br.Msg = "参数解析异常!"
  884. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  885. return
  886. }
  887. if req.MaterialId <= 0 {
  888. br.Msg = "缺少素材库编号"
  889. return
  890. }
  891. //删除素材库
  892. err = material.DeleteByMaterialIds([]int{req.MaterialId})
  893. if err != nil {
  894. br.Msg = "操作失败"
  895. br.ErrMsg = "操作失败,Err:" + err.Error()
  896. return
  897. }
  898. msg := "删除成功"
  899. br.Ret = 200
  900. br.Success = true
  901. br.Msg = msg
  902. }
  903. // BatchDelete
  904. // @Title 批量删除素材库
  905. // @Description 删除素材库接口
  906. // @Param request body material.DeleteSandbox true "type json string"
  907. // @Success 200 标记成功
  908. // @router /batch/del [post]
  909. func (this *MaterialController) BatchDelete() {
  910. br := new(models.BaseResponse).Init()
  911. defer func() {
  912. this.Data["json"] = br
  913. this.ServeJSON()
  914. }()
  915. sysUser := this.SysUser
  916. if sysUser == nil {
  917. br.Msg = "请登录"
  918. br.ErrMsg = "请登录,SysUser Is Empty"
  919. br.Ret = 408
  920. return
  921. }
  922. var req material.BatchDeleteMaterialReq
  923. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  924. if err != nil {
  925. br.Msg = "参数解析异常!"
  926. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  927. return
  928. }
  929. deleteMaterialIds := make([]int, 0)
  930. if req.IsSelectAll {
  931. classifyId := req.ClassifyId
  932. keyword := req.Keyword
  933. isShowMe := req.IsShowMe
  934. //获取图表信息
  935. list, e, msg := materialService.GetBatchSelectedMaterialList(classifyId, keyword, isShowMe, sysUser)
  936. if e != nil {
  937. br.Msg = "获取素材库信息失败"
  938. if msg != "" {
  939. br.Msg = msg
  940. }
  941. br.ErrMsg = "获取素材库信息失败,Err:" + e.Error()
  942. return
  943. }
  944. notSelectIds := make(map[int]struct{})
  945. if len(req.MaterialIds) >= 0 {
  946. for _, v := range req.MaterialIds {
  947. notSelectIds[v] = struct{}{}
  948. }
  949. }
  950. for _, v := range list {
  951. if _, ok := notSelectIds[v.MaterialId]; !ok {
  952. deleteMaterialIds = append(deleteMaterialIds, v.MaterialId)
  953. }
  954. }
  955. } else {
  956. deleteMaterialIds = req.MaterialIds
  957. }
  958. if len(deleteMaterialIds) <= 0 {
  959. br.Msg = "请选择删除的素材"
  960. return
  961. }
  962. //删除素材库
  963. err = material.DeleteByMaterialIds(deleteMaterialIds)
  964. if err != nil {
  965. br.Msg = err.Error()
  966. return
  967. }
  968. msg := "删除成功"
  969. br.Ret = 200
  970. br.Success = true
  971. br.Msg = msg
  972. }
  973. // GetMaterialVersionDetail
  974. // @Title 获取素材库版本数据详情(已保存的)
  975. // @Description 获取素材库版本数据详情接口(已保存的)
  976. // @Param SandboxVersionCode query string true "素材库版本code"
  977. // @Success 200 {object} material.MaterialVersion
  978. // @router /detail [get]
  979. func (this *MaterialController) GetMaterialDetail() {
  980. br := new(models.BaseResponse).Init()
  981. defer func() {
  982. this.Data["json"] = br
  983. this.ServeJSON()
  984. }()
  985. sysUser := this.SysUser
  986. if sysUser == nil {
  987. br.Msg = "请登录"
  988. br.ErrMsg = "请登录,SysUser Is Empty"
  989. br.Ret = 408
  990. return
  991. }
  992. sandboxId, _ := this.GetInt("SandboxId")
  993. if sandboxId == 0 {
  994. br.Msg = "缺少素材库Id"
  995. return
  996. }
  997. //获取素材库数据详情(已保存的)
  998. materialInfo, err := material.GetMaterialById(sandboxId)
  999. if err != nil {
  1000. br.Msg = "获取失败"
  1001. br.ErrMsg = "获取失败,Err:" + err.Error()
  1002. return
  1003. }
  1004. msg := "获取成功"
  1005. br.Ret = 200
  1006. br.Success = true
  1007. br.Msg = msg
  1008. br.Data = materialInfo
  1009. }
  1010. // MaterialClassifyList
  1011. // @Title 获取所有素材库分类接口-不包含素材库
  1012. // @Description 获取所有素材库分类接口-不包含素材库
  1013. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1014. // @Success 200 {object} data_manage.ChartClassifyListResp
  1015. // @router /classify/list [get]
  1016. func (this *MaterialController) MaterialClassifyList() {
  1017. br := new(models.BaseResponse).Init()
  1018. defer func() {
  1019. this.Data["json"] = br
  1020. this.ServeJSON()
  1021. }()
  1022. resp := new(material.MaterialClassifyListResp)
  1023. rootList, err := material.GetMaterialClassifyByParentId(0)
  1024. if err != nil && err.Error() != utils.ErrNoRow() {
  1025. br.Msg = "获取失败"
  1026. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1027. return
  1028. }
  1029. classifyAll, err := material.GetMaterialClassifyAll()
  1030. if err != nil && err.Error() != utils.ErrNoRow() {
  1031. br.Msg = "获取失败"
  1032. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1033. return
  1034. }
  1035. nodeAll := make([]*material.MaterialClassifyItems, 0)
  1036. for k := range rootList {
  1037. rootNode := rootList[k]
  1038. materialService.MaterialClassifyItemsMakeTree(this.SysUser, classifyAll, rootNode)
  1039. nodeAll = append(nodeAll, rootNode)
  1040. }
  1041. resp.AllNodes = nodeAll
  1042. br.Ret = 200
  1043. br.Success = true
  1044. br.Msg = "获取成功"
  1045. br.Data = resp
  1046. }
  1047. // BatchAdd
  1048. // @Title 批量新增素材
  1049. // @Description 新增/编辑保存素材库接口
  1050. // @Param request body material.AddAndEditSandbox true "type json string"
  1051. // @Success 200 {object} material.Material
  1052. // @router /batch/add [post]
  1053. func (this *MaterialController) BatchAdd() {
  1054. br := new(models.BaseResponse).Init()
  1055. defer func() {
  1056. this.Data["json"] = br
  1057. this.ServeJSON()
  1058. }()
  1059. sysUser := this.SysUser
  1060. if sysUser == nil {
  1061. br.Msg = "请登录"
  1062. br.ErrMsg = "请登录,SysUser Is Empty"
  1063. br.Ret = 408
  1064. return
  1065. }
  1066. var req material.BatchAddMaterialReq
  1067. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1068. if err != nil {
  1069. br.Msg = "参数解析异常!"
  1070. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1071. return
  1072. }
  1073. classifyId := req.ClassifyId
  1074. if classifyId <= 0 {
  1075. br.Msg = "请选择分类"
  1076. return
  1077. }
  1078. materialNames := make([]string, 0)
  1079. for _, v := range req.MaterialList {
  1080. if v.MaterialName == "" {
  1081. br.Msg = "请填写图片名称"
  1082. return
  1083. }
  1084. if v.ImgUrl == "" {
  1085. br.Msg = "请上传图片"
  1086. return
  1087. }
  1088. materialNames = append(materialNames, v.MaterialName)
  1089. }
  1090. if len(materialNames) == 0 {
  1091. br.Msg = "请填写图片名称"
  1092. return
  1093. }
  1094. // 判断文件名是否已存在
  1095. exist, e := material.GetMaterialByNames(materialNames)
  1096. if e != nil && e.Error() != utils.ErrNoRow() {
  1097. br.Msg = "获取失败"
  1098. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1099. return
  1100. }
  1101. if e == nil && exist.MaterialId > 0 {
  1102. br.Msg = fmt.Sprintf("图片名称:%s 已存在", exist.MaterialName)
  1103. return
  1104. }
  1105. // 获取表单中的所有文件
  1106. /*files, err := this.GetFiles("Files")
  1107. if err != nil {
  1108. br.Msg = "文件上传失败"
  1109. br.ErrMsg = "文件上传失败,Err:" + err.Error()
  1110. return
  1111. }
  1112. if len(files) == 0 {
  1113. br.Msg = "请选择文件"
  1114. return
  1115. }
  1116. if len(materialNames) != len(files) {
  1117. br.Msg = "图片数量与名称数量不一致"
  1118. return
  1119. }
  1120. // 创建目标目录(如果不存在)
  1121. uploadDir := utils.STATIC_DIR + "hongze/" + time.Now().Format("20060102")
  1122. if err = os.MkdirAll(uploadDir, utils.DIR_MOD); err != nil {
  1123. br.Msg = "存储目录创建失败"
  1124. br.ErrMsg = "存储目录创建失败, Err:" + err.Error()
  1125. return
  1126. }
  1127. // 处理单个文件(这里假设files是一个多文件字段)
  1128. // 实际上,当使用<input type="file" name="files" multiple>时,
  1129. // 它会作为多个文件字段发送到服务器,名字相同但后缀不同,例如:files, files[1], files[2]等。
  1130. // 所以我们需要遍历这些字段。
  1131. // 创建一个map来存储所有文件
  1132. fileUrlMap := make(map[string]string)
  1133. // 获取上传文件的头部信息
  1134. //fileHeaders := this.Ctx.Request.Header["Content-Disposition"]
  1135. for k, fileHeader := range files {
  1136. // 解析Content-Disposition头以获取文件名
  1137. // 获取文件名(避免路径遍历攻击,只使用文件名部分)
  1138. fileName := filepath.Base(fileHeader.Filename)
  1139. fileName = strings.TrimSpace(strings.Replace(fileName, "\\", "/", -1)) // 替换可能存在的反斜杠
  1140. fileName = strings.Trim(fileName, " \"\n\r\t") // 去除文件名两侧的空白字符和引号
  1141. ext := path.Ext(fileName)
  1142. ossFileName := utils.GetRandStringNoSpecialChar(28) + ext
  1143. filePath := filepath.Join(uploadDir, ossFileName)
  1144. // 创建目标文件
  1145. dst, e := os.Create(filePath)
  1146. if e != nil {
  1147. br.Msg = "文件创建失败"
  1148. br.ErrMsg = "文件创建失败, Err:" + e.Error()
  1149. //http.Error(w, e.Error(), http.StatusInternalServerError)
  1150. return
  1151. }
  1152. defer dst.Close()
  1153. src, e := fileHeader.Open()
  1154. if e != nil {
  1155. br.Msg = "文件打开失败"
  1156. br.ErrMsg = "文件打开失败, Err:" + e.Error()
  1157. return
  1158. }
  1159. // 将上传的文件内容复制到目标文件
  1160. if _, err = io.Copy(dst, src); err != nil {
  1161. br.Msg = "文件保存失败"
  1162. br.ErrMsg = "文件保存失败, Err:" + err.Error()
  1163. return
  1164. }
  1165. defer func() {
  1166. _ = os.Remove(filePath)
  1167. }()
  1168. // 上传到阿里云
  1169. ossDir := utils.RESOURCE_DIR + "cloud_disk/"
  1170. savePath := ossDir + time.Now().Format("200601/20060102/") + ossFileName
  1171. ossClient := services.NewOssClient()
  1172. if ossClient == nil {
  1173. br.Msg = "上传失败"
  1174. br.ErrMsg = "初始化OSS服务失败"
  1175. return
  1176. }
  1177. resourceUrl, e := ossClient.UploadFile(ossFileName, filePath, savePath)
  1178. if e != nil {
  1179. br.Msg = "文件上传失败"
  1180. br.ErrMsg = "文件上传失败,Err:" + e.Error()
  1181. return
  1182. }
  1183. // 将文件保存到map中(这里主要是为了演示,实际使用中可能不需要)
  1184. fileUrlMap[materialNames[k]] = resourceUrl
  1185. }*/
  1186. err = materialService.BatchAddMaterial(req.MaterialList, classifyId, sysUser.AdminId, sysUser.AdminName)
  1187. if err != nil {
  1188. br.Msg = "文件上传失败"
  1189. br.ErrMsg = "文件上传失败,Err:" + err.Error()
  1190. return
  1191. }
  1192. msg := "添加成功"
  1193. br.Ret = 200
  1194. br.Success = true
  1195. br.Msg = msg
  1196. }
  1197. // Upload
  1198. // @Title 上传素材
  1199. // @Description 上传素材接口
  1200. // @Param request body material.AddAndEditSandbox true "type json string"
  1201. // @Success 200 {object} material.Material
  1202. // @router /upload [post]
  1203. func (this *MaterialController) Upload() {
  1204. br := new(models.BaseResponse).Init()
  1205. defer func() {
  1206. this.Data["json"] = br
  1207. this.ServeJSON()
  1208. }()
  1209. sysUser := this.SysUser
  1210. if sysUser == nil {
  1211. br.Msg = "请登录"
  1212. br.ErrMsg = "请登录,SysUser Is Empty"
  1213. br.Ret = 408
  1214. return
  1215. }
  1216. f, h, err := this.GetFile("file")
  1217. if err != nil {
  1218. br.Msg = "获取资源信息失败"
  1219. br.ErrMsg = "获取资源信息失败,Err:" + err.Error()
  1220. return
  1221. }
  1222. defer f.Close() //关闭上传文件
  1223. // 不依赖于文件扩展名检查文件格式
  1224. fileData, e := ioutil.ReadAll(f)
  1225. if e != nil {
  1226. br.Msg = "上传失败"
  1227. br.ErrMsg = "读取文件失败, Err: " + e.Error()
  1228. return
  1229. }
  1230. pass := filetype.IsImage(fileData)
  1231. if !pass {
  1232. br.Msg = "文件格式有误"
  1233. br.ErrMsg = "文件格式有误"
  1234. return
  1235. }
  1236. ext := path.Ext(h.Filename)
  1237. randStr := utils.GetRandStringNoSpecialChar(28)
  1238. fileName := randStr + ext
  1239. // 上传到阿里云
  1240. ossDir := utils.RESOURCE_DIR + "material_dir/"
  1241. savePath := ossDir + time.Now().Format("200601/20060102/") + fileName
  1242. // 上传文件
  1243. resourceUrl, err := services.CommonUploadToOssAndFileName(f, fileName, savePath)
  1244. if err != nil {
  1245. br.Msg = "文件上传失败"
  1246. br.ErrMsg = "文件上传失败,Err:" + err.Error()
  1247. return
  1248. }
  1249. resp := new(models.UploadImgResp)
  1250. resp.ResourceUrl = resourceUrl
  1251. br.Msg = "上传成功"
  1252. br.Ret = 200
  1253. br.Success = true
  1254. br.Data = resp
  1255. }
  1256. // BatchChangeClassify
  1257. // @Title 批量更换分类
  1258. // @Description 批量更换分类
  1259. // @Param request body material.DeleteSandbox true "type json string"
  1260. // @Success 200 标记成功
  1261. // @router /batch/changeClassify [post]
  1262. func (this *MaterialController) BatchChangeClassify() {
  1263. br := new(models.BaseResponse).Init()
  1264. defer func() {
  1265. this.Data["json"] = br
  1266. this.ServeJSON()
  1267. }()
  1268. sysUser := this.SysUser
  1269. if sysUser == nil {
  1270. br.Msg = "请登录"
  1271. br.ErrMsg = "请登录,SysUser Is Empty"
  1272. br.Ret = 408
  1273. return
  1274. }
  1275. var req material.BatchChangeClassifyMaterialReq
  1276. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1277. if err != nil {
  1278. br.Msg = "参数解析异常!"
  1279. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1280. return
  1281. }
  1282. if req.NewClassifyId <= 0 {
  1283. br.Msg = "请选择新的分类"
  1284. return
  1285. }
  1286. updateMaterialIds := make([]int, 0)
  1287. if req.IsSelectAll {
  1288. classifyId := req.ClassifyId
  1289. keyword := req.Keyword
  1290. isShowMe := req.IsShowMe
  1291. //获取图表信息
  1292. list, e, msg := materialService.GetBatchSelectedMaterialList(classifyId, keyword, isShowMe, sysUser)
  1293. if e != nil {
  1294. br.Msg = "获取素材库信息失败"
  1295. if msg != "" {
  1296. br.Msg = msg
  1297. }
  1298. br.ErrMsg = "获取素材库信息失败,Err:" + e.Error()
  1299. return
  1300. }
  1301. notSelectIds := make(map[int]struct{})
  1302. if len(req.MaterialIds) >= 0 {
  1303. for _, v := range req.MaterialIds {
  1304. notSelectIds[v] = struct{}{}
  1305. }
  1306. }
  1307. for _, v := range list {
  1308. if _, ok := notSelectIds[v.MaterialId]; !ok {
  1309. updateMaterialIds = append(updateMaterialIds, v.MaterialId)
  1310. }
  1311. }
  1312. } else {
  1313. updateMaterialIds = req.MaterialIds
  1314. }
  1315. if len(updateMaterialIds) <= 0 {
  1316. br.Msg = "请选择变更的素材"
  1317. return
  1318. }
  1319. // 判断新分类是否存在
  1320. _, err = material.GetMaterialClassifyById(req.NewClassifyId)
  1321. if err != nil {
  1322. if err.Error() == utils.ErrNoRow() {
  1323. br.Msg = "分类不存在"
  1324. return
  1325. }
  1326. br.Msg = "获取分类信息失败"
  1327. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  1328. }
  1329. //更换分类素材库
  1330. err = material.UpdateClassifyByMaterialIds(updateMaterialIds, req.NewClassifyId, time.Now())
  1331. if err != nil {
  1332. br.Msg = err.Error()
  1333. return
  1334. }
  1335. msg := "操作成功"
  1336. br.Ret = 200
  1337. br.Success = true
  1338. br.Msg = msg
  1339. }
  1340. // ChangeClassify
  1341. // @Title 更换分类
  1342. // @Description 批量更换分类
  1343. // @Param request body material.DeleteSandbox true "type json string"
  1344. // @Success 200 标记成功
  1345. // @router /changeClassify [post]
  1346. func (this *MaterialController) ChangeClassify() {
  1347. br := new(models.BaseResponse).Init()
  1348. defer func() {
  1349. this.Data["json"] = br
  1350. this.ServeJSON()
  1351. }()
  1352. sysUser := this.SysUser
  1353. if sysUser == nil {
  1354. br.Msg = "请登录"
  1355. br.ErrMsg = "请登录,SysUser Is Empty"
  1356. br.Ret = 408
  1357. return
  1358. }
  1359. var req material.ChangeClassifyMaterialReq
  1360. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1361. if err != nil {
  1362. br.Msg = "参数解析异常!"
  1363. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1364. return
  1365. }
  1366. if req.MaterialId <= 0 {
  1367. br.Msg = "缺少素材库编号"
  1368. return
  1369. }
  1370. if req.NewClassifyId <= 0 {
  1371. br.Msg = "请选择新的分类"
  1372. return
  1373. }
  1374. // 判断素材是否存在
  1375. info, err := material.GetMaterialById(req.MaterialId)
  1376. if err != nil {
  1377. if err.Error() == utils.ErrNoRow() {
  1378. br.Msg = "素材不存在"
  1379. return
  1380. }
  1381. br.Msg = "获取素材库信息失败"
  1382. br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
  1383. return
  1384. }
  1385. if req.NewClassifyId == info.ClassifyId {
  1386. br.Msg = "请选择不同的分类"
  1387. return
  1388. }
  1389. // 判断新分类是否存在
  1390. _, err = material.GetMaterialClassifyById(req.NewClassifyId)
  1391. if err != nil {
  1392. if err.Error() == utils.ErrNoRow() {
  1393. br.Msg = "分类不存在"
  1394. return
  1395. }
  1396. br.Msg = "获取分类信息失败"
  1397. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  1398. }
  1399. info.ClassifyId = req.NewClassifyId
  1400. info.ModifyTime = time.Now()
  1401. //更换分类素材库
  1402. err = info.Update([]string{"ClassifyId", "ModifyTime"})
  1403. if err != nil {
  1404. br.Msg = err.Error()
  1405. return
  1406. }
  1407. msg := "操作成功"
  1408. br.Ret = 200
  1409. br.Success = true
  1410. br.Msg = msg
  1411. }
  1412. // Rename
  1413. // @Title 素材重命名
  1414. // @Description 素材重命名
  1415. // @Param request body material.DeleteSandbox true "type json string"
  1416. // @Success 200 标记成功
  1417. // @router /rename [post]
  1418. func (this *MaterialController) Rename() {
  1419. br := new(models.BaseResponse).Init()
  1420. defer func() {
  1421. this.Data["json"] = br
  1422. this.ServeJSON()
  1423. }()
  1424. sysUser := this.SysUser
  1425. if sysUser == nil {
  1426. br.Msg = "请登录"
  1427. br.ErrMsg = "请登录,SysUser Is Empty"
  1428. br.Ret = 408
  1429. return
  1430. }
  1431. var req material.RenameMaterialReq
  1432. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1433. if err != nil {
  1434. br.Msg = "参数解析异常!"
  1435. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1436. return
  1437. }
  1438. if req.MaterialId <= 0 {
  1439. br.Msg = "缺少素材库编号"
  1440. return
  1441. }
  1442. if req.MaterialName == "" {
  1443. br.Msg = "缺少素材库名称"
  1444. return
  1445. }
  1446. // 判断素材是否存在
  1447. info, err := material.GetMaterialById(req.MaterialId)
  1448. if err != nil {
  1449. if err.Error() == utils.ErrNoRow() {
  1450. br.Msg = "素材不存在"
  1451. return
  1452. }
  1453. br.Msg = "获取素材库信息失败"
  1454. br.ErrMsg = "获取素材库信息失败,Err:" + err.Error()
  1455. return
  1456. }
  1457. // 判断名称是否重复
  1458. if info.MaterialName == req.MaterialName {
  1459. br.Msg = "名称未修改"
  1460. return
  1461. }
  1462. // 查询名称是否已存在
  1463. exist, e := material.GetMaterialByNames([]string{req.MaterialName})
  1464. if e != nil && e.Error() != utils.ErrNoRow() {
  1465. br.Msg = "获取失败"
  1466. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1467. return
  1468. }
  1469. if e == nil && exist.MaterialId > 0 {
  1470. br.Msg = "图片名称已存在"
  1471. return
  1472. }
  1473. info.MaterialName = req.MaterialName
  1474. info.ModifyTime = time.Now()
  1475. //更换分类素材库
  1476. err = info.Update([]string{"MaterialName", "ModifyTime"})
  1477. if err != nil {
  1478. br.Msg = err.Error()
  1479. return
  1480. }
  1481. msg := "操作成功"
  1482. br.Ret = 200
  1483. br.Success = true
  1484. br.Msg = msg
  1485. }