sandbox.go 44 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561
  1. package sandbox
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/controllers"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/sandbox"
  7. "eta/eta_api/models/sandbox/request"
  8. "eta/eta_api/models/sandbox/response"
  9. sandboxService "eta/eta_api/services/sandbox"
  10. "eta/eta_api/utils"
  11. "fmt"
  12. "github.com/rdlucklib/rdluck_tools/paging"
  13. "time"
  14. )
  15. // versionSize 版本列表第一页数据约定是:3条
  16. var versionSize = 3
  17. // SandboxController 逻辑导图
  18. type SandboxController struct {
  19. controllers.BaseAuthController
  20. }
  21. // List
  22. // @Title 逻辑导图列表
  23. // @Description 逻辑导图列表接口
  24. // @Param PageSize query int true "每页数据条数"
  25. // @Param CurrentIndex query int true "当前页页码,从1开始"
  26. // @Param ChartPermissionId query int true "权限编号id"
  27. // @Param Keyword query string false "搜索关键词:沙盘名称/编辑人名称"
  28. // @Success 200 {object} response.SandboxListResp
  29. // @router /list [get]
  30. func (this *SandboxController) List() {
  31. br := new(models.BaseResponse).Init()
  32. defer func() {
  33. this.Data["json"] = br
  34. this.ServeJSON()
  35. }()
  36. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  37. keyword := this.GetString("Keyword")
  38. pageSize, _ := this.GetInt("PageSize")
  39. currentIndex, _ := this.GetInt("CurrentIndex")
  40. var startSize int
  41. if pageSize <= 0 {
  42. pageSize = utils.PageSize20
  43. }
  44. if currentIndex <= 0 {
  45. currentIndex = 1
  46. }
  47. startSize = paging.StartIndex(currentIndex, pageSize)
  48. var condition string
  49. var pars []interface{}
  50. if chartPermissionId > 0 {
  51. condition += " AND a.chart_permission_id=? "
  52. pars = append(pars, chartPermissionId)
  53. }
  54. if keyword != "" {
  55. condition += ` AND ( a.name LIKE '%` + keyword + `%' OR b.name LIKE '%` + keyword + `%' )`
  56. }
  57. //获取指标信息
  58. total, list, err := sandbox.GetList(condition, pars, startSize, pageSize)
  59. if err != nil && err.Error() != utils.ErrNoRow() {
  60. br.Success = true
  61. br.Msg = "获取沙盘列表失败"
  62. br.ErrMsg = "获取沙盘列表失败,Err:" + err.Error()
  63. return
  64. }
  65. if list == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  66. list = make([]*sandbox.SandboxListItem, 0)
  67. }
  68. if len(list) > 0 {
  69. sandboxIdList := make([]int, 0)
  70. for _, v := range list {
  71. sandboxIdList = append(sandboxIdList, v.SandboxId)
  72. }
  73. sandboxVersionTotalList, err := sandbox.GetTotalSandboxVersionBySandboxIdList(sandboxIdList)
  74. if err != nil {
  75. br.Success = true
  76. br.Msg = "获取沙盘版本数量失败"
  77. br.ErrMsg = "获取沙盘版本数量失败,Err:" + err.Error()
  78. return
  79. }
  80. sandboxVersionTotalMap := make(map[int]int)
  81. for _, v := range sandboxVersionTotalList {
  82. sandboxVersionTotalMap[v.SandboxId] = v.Total
  83. }
  84. for _, item := range list {
  85. /*key := fmt.Sprint(`crm:sandbox:edit:`, item.SandboxId)
  86. opUserId, _ := utils.Rc.RedisInt(key)
  87. //如果当前没有人操作,获取当前操作人是本人,那么编辑按钮可用
  88. if opUserId <= 0 || (opUserId == this.SysUser.AdminId) {
  89. item.CanEdit = true
  90. } else {
  91. adminInfo, errAdmin := system.GetSysUserById(opUserId)
  92. if errAdmin != nil {
  93. br.Msg = "获取失败"
  94. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  95. return
  96. }
  97. item.Editor = adminInfo.RealName
  98. }*/
  99. markStatus, err := sandboxService.UpdateSandboxEditMark(item.SandboxId, this.SysUser.AdminId, 2, this.SysUser.RealName)
  100. if err != nil {
  101. br.Msg = "查询标记状态失败"
  102. br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  103. return
  104. }
  105. if markStatus.Status == 0 {
  106. item.CanEdit = true
  107. } else {
  108. item.Editor = markStatus.Editor
  109. }
  110. // 沙盘版本数量
  111. versionTotal := sandboxVersionTotalMap[item.SandboxId]
  112. item.VersionTotal = versionTotal
  113. }
  114. }
  115. page := paging.GetPaging(currentIndex, pageSize, total)
  116. resp := response.SandboxListResp{
  117. Paging: page,
  118. List: list,
  119. }
  120. br.Ret = 200
  121. br.Success = true
  122. br.Msg = "获取成功"
  123. br.Data = resp
  124. }
  125. // FirstVersionList
  126. // @Title 逻辑导图版本列表(列表页第一页)
  127. // @Description 逻辑导图版本列表接口(列表页第一页)
  128. // @Param SandboxId query int true "沙盘id"
  129. // @Success 200 {object} response.SandboxVersionListResp
  130. // @router /version/first_list [get]
  131. func (this *SandboxController) FirstVersionList() {
  132. br := new(models.BaseResponse).Init()
  133. defer func() {
  134. this.Data["json"] = br
  135. this.ServeJSON()
  136. }()
  137. sandboxId, _ := this.GetInt("SandboxId")
  138. keyword := this.GetString("Keyword")
  139. currentIndex := 1
  140. pageSize := versionSize
  141. startSize := 0
  142. var condition string
  143. var pars []interface{}
  144. if sandboxId <= 0 {
  145. br.Msg = "参数错误,沙盘编号id必传!"
  146. br.ErrMsg = "参数错误,沙盘编号id必传"
  147. return
  148. }
  149. condition += " AND a.sandbox_id=? "
  150. pars = append(pars, sandboxId)
  151. //不能筛选出当前版本
  152. condition += " AND b.curr_version < a.curr_version "
  153. if keyword != "" {
  154. condition += ` AND ( a.name LIKE '%` + keyword + `%' OR b.name LIKE '%` + keyword + `%' )`
  155. }
  156. //获取指标信息
  157. total, list, err := sandbox.GetVersionList(condition, pars, startSize, pageSize)
  158. if err != nil && err.Error() != utils.ErrNoRow() {
  159. br.Success = true
  160. br.Msg = "获取沙盘列表失败"
  161. br.ErrMsg = "获取沙盘列表失败,Err:" + err.Error()
  162. return
  163. }
  164. if list == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  165. list = make([]*sandbox.SandboxVersionListItem, 0)
  166. }
  167. for _, v := range list {
  168. v.ModifyTime = v.CreateTime
  169. }
  170. page := paging.GetPaging(currentIndex, pageSize, total)
  171. resp := response.SandboxVersionListResp{
  172. Paging: page,
  173. List: list,
  174. }
  175. br.Ret = 200
  176. br.Success = true
  177. br.Msg = "获取成功"
  178. br.Data = resp
  179. }
  180. // VersionList
  181. // @Title 逻辑导图版本列表
  182. // @Description 逻辑导图版本列表接口
  183. // @Param PageSize query int true "每页数据条数"
  184. // @Param CurrentIndex query int true "当前页页码,从1开始"
  185. // @Param SandboxId query int true "沙盘id"
  186. // @Success 200 {object} response.SandboxVersionListResp
  187. // @router /version/list [get]
  188. func (this *SandboxController) VersionList() {
  189. br := new(models.BaseResponse).Init()
  190. defer func() {
  191. this.Data["json"] = br
  192. this.ServeJSON()
  193. }()
  194. sandboxId, _ := this.GetInt("SandboxId")
  195. keyWord := this.GetString("Keyword")
  196. pageSize, _ := this.GetInt("PageSize")
  197. currentIndex, _ := this.GetInt("CurrentIndex")
  198. var startSize int
  199. if pageSize <= 0 {
  200. pageSize = utils.PageSize20
  201. }
  202. //第一页需要返回的几条数据(目前是3条)
  203. startSize = paging.StartIndex(currentIndex, pageSize) + versionSize
  204. var condition string
  205. var pars []interface{}
  206. if sandboxId <= 0 {
  207. br.Msg = "参数错误,沙盘编号id必传!"
  208. br.ErrMsg = "参数错误,沙盘编号id必传"
  209. return
  210. }
  211. condition += " AND a.sandbox_id=? "
  212. pars = append(pars, sandboxId)
  213. //不能筛选出当前版本
  214. condition += " AND b.curr_version < a.curr_version "
  215. if keyWord != "" {
  216. condition += ` AND ( a.op_user_name LIKE '%` + keyWord + `%' OR a.name LIKE '%` + keyWord + `%' or a.op_user_name LIKE '%` + keyWord + `%' OR a.name LIKE '%` + keyWord + `%' )`
  217. }
  218. //获取指标信息
  219. total, list, err := sandbox.GetVersionList(condition, pars, startSize, pageSize)
  220. if err != nil && err.Error() != utils.ErrNoRow() {
  221. br.Success = true
  222. br.Msg = "获取沙盘列表失败"
  223. br.ErrMsg = "获取沙盘列表失败,Err:" + err.Error()
  224. return
  225. }
  226. if list == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  227. list = make([]*sandbox.SandboxVersionListItem, 0)
  228. }
  229. for _, v := range list {
  230. v.ModifyTime = v.CreateTime
  231. /*key := fmt.Sprint(`crm:sandbox:edit:`, v.SandboxId)
  232. opUserId, _ := utils.Rc.RedisInt(key)
  233. //如果当前没有人操作,获取当前操作人是本人,那么编辑按钮可用
  234. if opUserId <= 0 || (opUserId == this.SysUser.AdminId) {
  235. v.CanEdit = true
  236. }*/
  237. markStatus, err := sandboxService.UpdateSandboxEditMark(v.SandboxId, this.SysUser.AdminId, 2, this.SysUser.RealName)
  238. if err != nil {
  239. br.Msg = "查询标记状态失败"
  240. br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  241. return
  242. }
  243. if markStatus.Status == 0 {
  244. v.CanEdit = true
  245. }
  246. }
  247. //过滤第一页的几条数据(目前是3条)
  248. total = total - versionSize
  249. if total <= 0 {
  250. total = 0
  251. }
  252. page := paging.GetPaging(currentIndex, pageSize, total)
  253. resp := response.SandboxVersionListResp{
  254. Paging: page,
  255. List: list,
  256. }
  257. br.Ret = 200
  258. br.Success = true
  259. br.Msg = "获取成功"
  260. br.Data = resp
  261. }
  262. //// Save
  263. //// @Title 新增/编辑保存沙盘
  264. //// @Description 新增/编辑保存沙盘接口
  265. //// @Param request body request.AddAndEditSandbox true "type json string"
  266. //// @Success 200 {object} sandbox.Sandbox
  267. //// @router /save [post]
  268. //func (this *SandboxController) Save() {
  269. // br := new(models.BaseResponse).Init()
  270. // defer func() {
  271. // this.Data["json"] = br
  272. // this.ServeJSON()
  273. // }()
  274. // sysUser := this.SysUser
  275. // if sysUser == nil {
  276. // br.Msg = "请登录"
  277. // br.ErrMsg = "请登录,SysUser Is Empty"
  278. // br.Ret = 408
  279. // return
  280. // }
  281. // var req request.AddAndEditSandbox
  282. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  283. // if err != nil {
  284. // br.Msg = "参数解析异常!"
  285. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  286. // return
  287. // }
  288. //
  289. // var sandboxResp *sandbox.SandboxSaveResp
  290. // // 获取系统菜单, 如果没有对应的字段的特殊处理项, 则忽略必填
  291. // menus, e := system.GetSysMenuItemsByCondition(` AND hidden = 0`, make([]interface{}, 0), []string{}, ``)
  292. // if e != nil {
  293. // br.Msg = "保存失败"
  294. // br.ErrMsg = "获取菜单列表失败, Err: " + e.Error()
  295. // return
  296. // }
  297. // menuMap := make(map[string]bool)
  298. // for _, m := range menus {
  299. // if m.ButtonCode != "" {
  300. // menuMap[m.ButtonCode] = true
  301. // }
  302. // }
  303. // ignoreVariety := false
  304. // if !menuMap[system.MenuSpecialHandleSandboxVariety] {
  305. // ignoreVariety = true
  306. // }
  307. //
  308. // var errMsg string
  309. // if req.SandboxVersionCode == `` {
  310. // //新增沙盘
  311. // sandboxResp, err = sandboxService.AddSandbox(req, sysUser.AdminId, sysUser.RealName, ignoreVariety)
  312. // } else {
  313. // ////更新当前编辑中的状态缓存
  314. // //err = sandboxService.UpdateSandboxEditMark(req.SandboxId, sysUser.AdminId, 1)
  315. // //if err != nil {
  316. // // br.Msg = err.Error()
  317. // // return
  318. // //}
  319. //
  320. // //编辑沙盘
  321. // sandboxResp, err, errMsg = sandboxService.UpdateSandbox(req, sysUser.AdminId, sysUser.RealName, ignoreVariety)
  322. // }
  323. // if err != nil {
  324. // br.Msg = "保存失败!"
  325. // if errMsg != `` {
  326. // br.Msg = errMsg
  327. // }
  328. // br.ErrMsg = "保存失败,Err:" + err.Error()
  329. // return
  330. // }
  331. //
  332. // msg := "保存成功"
  333. // br.Ret = 200
  334. // br.Success = true
  335. // br.Msg = msg
  336. // br.Data = sandboxResp
  337. //}
  338. // AddSandboxDraft
  339. // @Title 添加沙盘草稿
  340. // @Description 添加沙盘草稿接口
  341. // @Param request body request.AddAndEditSandbox true "type json string"
  342. // @Success 200 {object} sandbox.SandboxDraft
  343. // @Fail 202 另外的人在操作,不要重复添加草稿;204 错误了,当时不是必要性的错误,不用将错误信息暴露给用户
  344. // @router /draft/add [post]
  345. func (this *SandboxController) AddSandboxDraft() {
  346. br := new(models.BaseResponse).Init()
  347. br.IsSendEmail = false
  348. defer func() {
  349. this.Data["json"] = br
  350. this.ServeJSON()
  351. }()
  352. sysUser := this.SysUser
  353. if sysUser == nil {
  354. br.Msg = "请登录"
  355. br.ErrMsg = "请登录,SysUser Is Empty"
  356. br.Ret = 408
  357. return
  358. }
  359. var req request.AddAndEditSandbox
  360. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  361. if err != nil {
  362. br.Msg = "参数解析异常!"
  363. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  364. return
  365. }
  366. if req.SandboxVersionCode == `` {
  367. br.Msg = "请传入沙盘版本!"
  368. return
  369. }
  370. // 获取沙盘版本信息
  371. sandboxVersion, err := sandbox.GetSandboxVersionBySandboxVersionCode(req.SandboxVersionCode)
  372. if err != nil {
  373. if err.Error() == utils.ErrNoRow() {
  374. br.Msg = "找不到该版本!"
  375. br.ErrMsg = "找不到该版本"
  376. return
  377. }
  378. br.Msg = "找不到该版本!"
  379. br.ErrMsg = "找不到该版本,Err:" + err.Error()
  380. br.IsSendEmail = false
  381. return
  382. }
  383. //更新标记key
  384. markStatus, err := sandboxService.UpdateSandboxEditMark(sandboxVersion.SandboxId, sysUser.AdminId, 1, sysUser.RealName)
  385. if err != nil {
  386. br.Msg = err.Error()
  387. return
  388. }
  389. if markStatus.Status == 1 {
  390. br.Msg = markStatus.Msg
  391. return
  392. }
  393. //新增沙盘草稿
  394. sandboxDraftInfo, err := sandboxService.AddSandboxDraft(sandboxVersion.SandboxId, req, sysUser.AdminId, sysUser.RealName)
  395. if err != nil {
  396. br.Msg = "保存失败!"
  397. br.ErrMsg = "保存失败,Err:" + err.Error()
  398. br.Ret = 204 //204 (无内容) :服务器成功处理了请求,但没有返回任何内容。
  399. return
  400. }
  401. msg := "保存成功"
  402. br.Ret = 200
  403. br.Success = true
  404. br.Msg = msg
  405. br.Data = sandboxDraftInfo
  406. }
  407. // MarkEditStatus
  408. // @Title 标记沙盘编辑状态
  409. // @Description 标记沙盘编辑状态接口
  410. // @Param request body request.MarkEditSandbox true "type json string"
  411. // @Success 200 标记成功 ;202 标记成功
  412. // @router /mark [post]
  413. func (this *SandboxController) MarkEditStatus() {
  414. br := new(models.BaseResponse).Init()
  415. defer func() {
  416. this.Data["json"] = br
  417. this.ServeJSON()
  418. }()
  419. sysUser := this.SysUser
  420. if sysUser == nil {
  421. br.Msg = "请登录"
  422. br.ErrMsg = "请登录,SysUser Is Empty"
  423. br.Ret = 408
  424. return
  425. }
  426. var req request.MarkEditSandbox
  427. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  428. if err != nil {
  429. br.Msg = "参数解析异常!"
  430. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  431. return
  432. }
  433. if req.SandboxId <= 0 {
  434. br.Msg = "缺少沙盘编号"
  435. return
  436. }
  437. if req.Status <= 0 {
  438. br.Msg = "标记状态异常"
  439. return
  440. }
  441. //更新标记key
  442. data, err := sandboxService.UpdateSandboxEditMark(req.SandboxId, sysUser.AdminId, req.Status, sysUser.RealName)
  443. if err != nil {
  444. br.Msg = err.Error()
  445. return
  446. }
  447. msg := "标记成功"
  448. br.Ret = 200
  449. br.Success = true
  450. br.Msg = msg
  451. br.Data = data
  452. }
  453. // GetSandboxVersionDetail
  454. // @Title 获取沙盘版本数据详情(已保存的)
  455. // @Description 获取沙盘版本数据详情接口(已保存的)
  456. // @Param SandboxVersionCode query string true "沙盘版本code"
  457. // @Success 200 {object} sandbox.SandboxVersion
  458. // @router /version/detail [get]
  459. func (this *SandboxController) GetSandboxVersionDetail() {
  460. br := new(models.BaseResponse).Init()
  461. defer func() {
  462. this.Data["json"] = br
  463. this.ServeJSON()
  464. }()
  465. sysUser := this.SysUser
  466. if sysUser == nil {
  467. br.Msg = "请登录"
  468. br.ErrMsg = "请登录,SysUser Is Empty"
  469. br.Ret = 408
  470. return
  471. }
  472. sandboxVersionCode := this.GetString("SandboxVersionCode")
  473. if sandboxVersionCode == "" {
  474. br.Msg = "缺少沙盘版本编号"
  475. return
  476. }
  477. //获取沙盘数据详情(已保存的)
  478. sandboxVersionInfo, err := sandboxService.GetSandboxVersionDetailByCode(sandboxVersionCode)
  479. if err != nil {
  480. br.Msg = "获取失败"
  481. br.ErrMsg = "获取失败,Err:" + err.Error()
  482. return
  483. }
  484. msg := "获取成功"
  485. br.Ret = 200
  486. br.Success = true
  487. br.Msg = msg
  488. br.Data = sandboxVersionInfo
  489. }
  490. // GetLastSandboxInfo
  491. // @Title 获取最后一次编辑的沙盘数据详情
  492. // @Description 获取最后一次编辑的沙盘数据详情接口
  493. // @Param SandboxId query int true "沙盘编号id"
  494. // @Success 200 {object} sandbox.Sandbox
  495. // @router /last_info [get]
  496. func (this *SandboxController) GetLastSandboxInfo() {
  497. br := new(models.BaseResponse).Init()
  498. defer func() {
  499. this.Data["json"] = br
  500. this.ServeJSON()
  501. }()
  502. sysUser := this.SysUser
  503. if sysUser == nil {
  504. br.Msg = "请登录"
  505. br.ErrMsg = "请登录,SysUser Is Empty"
  506. br.Ret = 408
  507. return
  508. }
  509. sandboxId, _ := this.GetInt("SandboxId", 0)
  510. if sandboxId <= 0 {
  511. br.Msg = "缺少沙盘编号"
  512. return
  513. }
  514. //获取最后一次操作的沙盘数据
  515. sandboxInfo, err := sandboxService.GetLastSandboxInfo(sandboxId)
  516. if err != nil {
  517. br.Msg = err.Error()
  518. return
  519. }
  520. msg := "获取成功"
  521. br.Ret = 200
  522. br.Success = true
  523. br.Msg = msg
  524. br.Data = sandboxInfo
  525. }
  526. // Delete
  527. // @Title 删除沙盘
  528. // @Description 删除沙盘接口
  529. // @Param request body request.DeleteSandbox true "type json string"
  530. // @Success 200 标记成功
  531. // @router /delete [post]
  532. func (this *SandboxController) Delete() {
  533. br := new(models.BaseResponse).Init()
  534. defer func() {
  535. this.Data["json"] = br
  536. this.ServeJSON()
  537. }()
  538. sysUser := this.SysUser
  539. if sysUser == nil {
  540. br.Msg = "请登录"
  541. br.ErrMsg = "请登录,SysUser Is Empty"
  542. br.Ret = 408
  543. return
  544. }
  545. var req request.DeleteSandbox
  546. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  547. if err != nil {
  548. br.Msg = "参数解析异常!"
  549. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  550. return
  551. }
  552. if req.SandboxId <= 0 {
  553. br.Msg = "缺少沙盘编号"
  554. return
  555. }
  556. /*key := fmt.Sprint(`crm:sandbox:edit:`, req.SandboxId)
  557. opUserId, _ := utils.Rc.RedisInt(key)
  558. //如果当前有人操作,且获取当前操作人不是本人,那么不允许删除
  559. if opUserId > 0 && opUserId != this.SysUser.AdminId {
  560. br.Msg = "当前有其他人正在编辑,不允许删除该沙盘"
  561. return
  562. }*/
  563. markStatus, err := sandboxService.UpdateSandboxEditMark(req.SandboxId, this.SysUser.AdminId, 2, this.SysUser.RealName)
  564. if err != nil {
  565. br.Msg = "查询标记状态失败"
  566. br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  567. return
  568. }
  569. if markStatus.Status == 1 {
  570. br.Msg = fmt.Sprintf("当前%s正在编辑,不允许删除该沙盘", markStatus.Editor)
  571. return
  572. }
  573. //删除沙盘
  574. err = sandboxService.DeleteSandbox(req.SandboxId)
  575. if err != nil {
  576. br.Msg = err.Error()
  577. return
  578. }
  579. msg := "删除成功"
  580. br.Ret = 200
  581. br.Success = true
  582. br.Msg = msg
  583. }
  584. //// DeleteVersion
  585. //// @Title 删除沙盘版本
  586. //// @Description 删除沙盘版本接口
  587. //// @Param request body request.DeleteSandbox true "type json string"
  588. //// @Success 200 标记成功
  589. //// @router /version/delete [post]
  590. //func (this *SandboxController) DeleteVersion() {
  591. // br := new(models.BaseResponse).Init()
  592. // defer func() {
  593. // this.Data["json"] = br
  594. // this.ServeJSON()
  595. // }()
  596. // sysUser := this.SysUser
  597. // if sysUser == nil {
  598. // br.Msg = "请登录"
  599. // br.ErrMsg = "请登录,SysUser Is Empty"
  600. // br.Ret = 408
  601. // return
  602. // }
  603. // var req request.DeleteSandboxVersion
  604. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  605. // if err != nil {
  606. // br.Msg = "参数解析异常!"
  607. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  608. // return
  609. // }
  610. //
  611. // if req.SandboxVersionCode == `` {
  612. // br.Msg = "缺少沙盘版本号"
  613. // return
  614. // }
  615. // //删除沙盘
  616. // err, errMsg := sandboxService.DeleteSandboxVersion(req.SandboxVersionCode, this.SysUser.AdminId)
  617. // if err != nil {
  618. // br.Msg = "删除版本失败"
  619. // if errMsg != `` {
  620. // br.Msg = errMsg
  621. // }
  622. // br.ErrMsg = err.Error()
  623. // return
  624. // }
  625. //
  626. // msg := "删除成功"
  627. // br.Ret = 200
  628. // br.Success = true
  629. // br.Msg = msg
  630. //}
  631. //// ResetDraftToLastVersion
  632. //// @Title 重置沙盘草稿至最新版本
  633. //// @Description 重置沙盘草稿至最新版本接口
  634. //// @Param request body request.DeleteSandbox true "type json string"
  635. //// @Success 200 {object} sandbox.SandboxDraft
  636. //// @Fail 202 另外的人在操作,不要重复添加草稿;204 错误了,当时不是必要性的错误,不用将错误信息暴露给用户
  637. //// @router /draft/reset [post]
  638. //func (this *SandboxController) ResetDraftToLastVersion() {
  639. // br := new(models.BaseResponse).Init()
  640. // defer func() {
  641. // this.Data["json"] = br
  642. // this.ServeJSON()
  643. // }()
  644. // sysUser := this.SysUser
  645. // if sysUser == nil {
  646. // br.Msg = "请登录"
  647. // br.ErrMsg = "请登录,SysUser Is Empty"
  648. // br.Ret = 408
  649. // return
  650. // }
  651. // var req request.DeleteSandbox
  652. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  653. // if err != nil {
  654. // br.Msg = "参数解析异常!"
  655. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  656. // return
  657. // }
  658. //
  659. // if req.SandboxId <= 0 {
  660. // br.Msg = "缺少沙盘编号"
  661. // return
  662. // }
  663. //
  664. // //更新标记key
  665. // markStatus, err := sandboxService.UpdateSandboxEditMark(req.SandboxId, sysUser.AdminId, 0, sysUser.RealName)
  666. // if err != nil {
  667. // br.Msg = err.Error()
  668. // return
  669. // }
  670. // if markStatus.Status == 1 {
  671. // br.Msg = markStatus.Msg
  672. // return
  673. // }
  674. //
  675. // //重置沙盘草稿至最新版本
  676. // sandboxDraftInfo, err := sandboxService.ResetDraftToLastVersion(req.SandboxId, sysUser.AdminId, sysUser.RealName)
  677. // if err != nil {
  678. // br.Msg = "保存失败!"
  679. // br.ErrMsg = "保存失败,Err:" + err.Error()
  680. // return
  681. // }
  682. // msg := "保存成功"
  683. // br.Ret = 200
  684. // br.Success = true
  685. // br.Msg = msg
  686. // br.Data = sandboxDraftInfo
  687. //}
  688. // ListByQuote
  689. // @Title 逻辑导图列表(其他地方引用到的,莫名其妙要根据输入的关键字匹配品种)
  690. // @Description 逻辑导图列表接口(其他地方引用到的,莫名其妙要根据输入的关键字匹配品种)
  691. // @Param PageSize query int true "每页数据条数"
  692. // @Param CurrentIndex query int true "当前页页码,从1开始"
  693. // @Param ChartPermissionId query int true "权限编号id"
  694. // @Param Keyword query string false "搜索关键词:沙盘名称/编辑人名称"
  695. // @Success 200 {object} response.SandboxListResp
  696. // @router /list_by_quote [get]
  697. func (this *SandboxController) ListByQuote() {
  698. br := new(models.BaseResponse).Init()
  699. defer func() {
  700. this.Data["json"] = br
  701. this.ServeJSON()
  702. }()
  703. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  704. keyword := this.GetString("Keyword")
  705. pageSize, _ := this.GetInt("PageSize")
  706. currentIndex, _ := this.GetInt("CurrentIndex")
  707. var startSize int
  708. if pageSize <= 0 {
  709. pageSize = utils.PageSize20
  710. }
  711. if currentIndex <= 0 {
  712. currentIndex = 1
  713. }
  714. startSize = paging.StartIndex(currentIndex, pageSize)
  715. var condition string
  716. var pars []interface{}
  717. if chartPermissionId > 0 {
  718. condition += " AND a.chart_permission_id=? "
  719. pars = append(pars, chartPermissionId)
  720. }
  721. if keyword != "" {
  722. condition += ` AND ( a.name LIKE '%` + keyword + `%' OR b.name LIKE '%` + keyword + `%' OR a.chart_permission_name LIKE '%` + keyword + `%' )`
  723. }
  724. //获取指标信息
  725. total, list, err := sandbox.GetList(condition, pars, startSize, pageSize)
  726. if err != nil && err.Error() != utils.ErrNoRow() {
  727. br.Success = true
  728. br.Msg = "获取沙盘列表失败"
  729. br.ErrMsg = "获取沙盘列表失败,Err:" + err.Error()
  730. return
  731. }
  732. if list == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  733. list = make([]*sandbox.SandboxListItem, 0)
  734. }
  735. page := paging.GetPaging(currentIndex, pageSize, total)
  736. resp := response.SandboxListResp{
  737. Paging: page,
  738. List: list,
  739. }
  740. br.Ret = 200
  741. br.Success = true
  742. br.Msg = "获取成功"
  743. br.Data = resp
  744. }
  745. //// ChartClassifyListV2
  746. //// @Title 沙盘分类列表
  747. //// @Description 沙盘分类列表接口
  748. //// @Param IsShowMe query bool true "是否只看我的,true、false"
  749. //// @Success 200 {object} data_manage.ChartClassifyListResp
  750. //// @router /classify/list [get]
  751. //func (this *SandboxController) ClassifyList() {
  752. // br := new(models.BaseResponse).Init()
  753. // defer func() {
  754. // this.Data["json"] = br
  755. // this.ServeJSON()
  756. // }()
  757. // resp := new(sandbox.SandboxClassifyListResp)
  758. //
  759. // rootList, err := sandbox.GetSandboxClassifyByParentId(0)
  760. // if err != nil && err.Error() != utils.ErrNoRow() {
  761. // br.Msg = "获取失败"
  762. // br.ErrMsg = "获取数据失败,Err:" + err.Error()
  763. // return
  764. // }
  765. //
  766. // classifyAll, err := sandbox.GetSandboxClassifyAll()
  767. // if err != nil && err.Error() != utils.ErrNoRow() {
  768. // br.Msg = "获取失败"
  769. // br.ErrMsg = "获取数据失败,Err:" + err.Error()
  770. // return
  771. // }
  772. //
  773. // sandboxClassifyId, _ := this.GetInt("SandboxClassifyId")
  774. // if sandboxClassifyId <= 0 {
  775. // br.Msg = "参数错误"
  776. // return
  777. // }
  778. //
  779. // allSandboxInfo, err := sandbox.GetSandboxAll(sandboxClassifyId)
  780. // if err != nil && err.Error() != utils.ErrNoRow() {
  781. // br.Msg = "获取失败"
  782. // br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  783. // return
  784. // }
  785. //
  786. //
  787. // sandboxInfoMap := make(map[int][]*sandbox.SandboxClassifyItems)
  788. // for _, v := range allSandboxInfo {
  789. // sandboxInfoMap[v.SandboxClassifyId] = append(sandboxInfoMap[v.SandboxClassifyId], v)
  790. // }
  791. // rootChildMap := make(map[int][]*sandbox.SandboxClassifyItems)
  792. // for _, v := range classifyAll {
  793. // rootChildMap[v.ParentId] = append(rootChildMap[v.ParentId], v)
  794. // if existItems, ok := sandboxInfoMap[v.SandboxClassifyId]; ok {
  795. // v.Children = existItems
  796. // } else {
  797. // items := make([]*sandbox.SandboxClassifyItems, 0)
  798. // v.Children = items
  799. // }
  800. // }
  801. // nodeAll := make([]*sandbox.SandboxClassifyItems, 0)
  802. // for _, v := range rootList {
  803. // if existItems, ok := rootChildMap[v.SandboxClassifyId]; ok {
  804. // v.Children = existItems
  805. // } else {
  806. // items := make([]*sandbox.SandboxClassifyItems, 0)
  807. // v.Children = items
  808. // }
  809. // nodeAll = append(nodeAll, v)
  810. // }
  811. // //
  812. // //
  813. // //nodeAll := make([]*data_manage.ChartClassifyItems, 0)
  814. // //for k := range rootList {
  815. // // rootNode := rootList[k]
  816. // // data.ChartClassifyListMakeTree(classifyAll, rootNode)
  817. // // nodeAll = append(nodeAll, rootNode)
  818. // //}
  819. // resp.AllNodes = nodeAll
  820. //
  821. //
  822. // br.Ret = 200
  823. // br.Success = true
  824. // br.Msg = "获取成功"
  825. // br.Data = resp
  826. //}
  827. // SandboxClassifyItems
  828. // @Title 获取所有沙盘分类接口-不包含沙盘
  829. // @Description 获取所有沙盘分类接口-不包含沙盘
  830. // @Param IsShowMe query bool true "是否只看我的,true、false"
  831. // @Success 200 {object} data_manage.ChartClassifyListResp
  832. // @router /classify/list [get]
  833. func (this *SandboxController) SandboxClassifyItems() {
  834. br := new(models.BaseResponse).Init()
  835. defer func() {
  836. this.Data["json"] = br
  837. this.ServeJSON()
  838. }()
  839. resp := new(sandbox.SandboxClassifyListResp)
  840. isShowMe, _ := this.GetBool("IsShowMe")
  841. if isShowMe {
  842. errMsg, err := sandboxService.GetSandboxClassifyListForMe(*this.SysUser, resp)
  843. if err != nil {
  844. br.Msg = errMsg
  845. br.ErrMsg = err.Error()
  846. return
  847. }
  848. // 移除没有权限的图表
  849. allNodes := sandboxService.HandleNoPermissionSandbox(resp.AllNodes, nil)
  850. resp.AllNodes = allNodes
  851. br.Ret = 200
  852. br.Success = true
  853. br.Msg = "获取成功"
  854. br.Data = resp
  855. fmt.Println("source my classify")
  856. return
  857. }
  858. rootList, err := sandbox.GetSandboxClassifyByParentId(0)
  859. if err != nil && err.Error() != utils.ErrNoRow() {
  860. br.Msg = "获取失败"
  861. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  862. return
  863. }
  864. classifyAll, err := sandbox.GetSandboxClassifyAll()
  865. if err != nil && err.Error() != utils.ErrNoRow() {
  866. br.Msg = "获取失败"
  867. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  868. return
  869. }
  870. sandboxAll, err := sandbox.GetSandboxAll()
  871. if err != nil && err.Error() != utils.ErrNoRow() {
  872. br.Msg = "获取失败"
  873. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  874. return
  875. }
  876. sandListMap := make(map[int][]*sandbox.SandboxClassifyItems)
  877. for _, v := range sandboxAll {
  878. if _, ok := sandListMap[v.SandboxClassifyId]; !ok {
  879. list := make([]*sandbox.SandboxClassifyItems, 0)
  880. list = append(list, v)
  881. sandListMap[v.SandboxClassifyId] = list
  882. } else {
  883. sandListMap[v.SandboxClassifyId] = append(sandListMap[v.SandboxClassifyId], v)
  884. }
  885. }
  886. nodeAll := make([]*sandbox.SandboxClassifyItems, 0)
  887. for k := range rootList {
  888. rootNode := rootList[k]
  889. sandboxService.SandboxClassifyItemsMakeTree(this.SysUser, classifyAll, rootNode)
  890. nodeAll = append(nodeAll, rootNode)
  891. }
  892. //for k := range nodeAll {
  893. //
  894. //}
  895. sandboxService.SandboxItemsMakeTree(nodeAll,nil, sandListMap)
  896. resp.AllNodes = nodeAll
  897. br.Ret = 200
  898. br.Success = true
  899. br.Msg = "获取成功"
  900. br.Data = resp
  901. }
  902. // @Title 新增沙盘分类
  903. // @Description 新增沙盘分类接口
  904. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  905. // @Success 200 Ret=200 保存成功
  906. // @router /classify/add [post]
  907. func (this *SandboxController) AddSandboxClassify() {
  908. br := new(models.BaseResponse).Init()
  909. defer func() {
  910. this.Data["json"] = br
  911. this.ServeJSON()
  912. }()
  913. var req sandbox.AddSandboxClassifyReq
  914. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  915. if err != nil {
  916. br.Msg = "参数解析异常!"
  917. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  918. return
  919. }
  920. if req.SandboxClassifyName == "" {
  921. br.Msg = "请输入分类名称"
  922. br.IsSendEmail = false
  923. return
  924. }
  925. if req.ParentId < 0 {
  926. br.Msg = "参数错误"
  927. br.IsSendEmail = false
  928. return
  929. }
  930. count, err := sandbox.GetSandboxClassifyCount(req.SandboxClassifyName, req.ParentId)
  931. if err != nil {
  932. br.Msg = "判断名称是否已存在失败"
  933. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  934. return
  935. }
  936. if count > 0 {
  937. br.Msg = "分类名称已存在,请重新输入"
  938. br.IsSendEmail = false
  939. return
  940. }
  941. //获取该层级下最大的排序数
  942. maxSort, err := sandbox.GetSandboxClassifyMaxSort(req.ParentId)
  943. classify := new(sandbox.SandboxClassify)
  944. classify.ParentId = req.ParentId
  945. classify.SandboxClassifyName = req.SandboxClassifyName
  946. classify.HasData = 0
  947. classify.CreateTime = time.Now()
  948. classify.ModifyTime = time.Now()
  949. classify.SysUserId = this.SysUser.AdminId
  950. classify.SysUserRealName = this.SysUser.RealName
  951. classify.ChartPermissionId = req.ChartPermissionId
  952. classify.ChartPermissionName = req.ChartPermissionName
  953. classify.Level = req.Level + 1
  954. classify.Sort = maxSort + 1
  955. _, err = sandbox.AddSandboxClassify(classify)
  956. if err != nil {
  957. br.Msg = "保存分类失败"
  958. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  959. return
  960. }
  961. br.Ret = 200
  962. br.Msg = "保存成功"
  963. br.Success = true
  964. }
  965. // @Title 修改沙盘分类
  966. // @Description 修改沙盘分类接口
  967. // @Param request body data_manage.EditChartClassifyReq true "type json string"
  968. // @Success 200 Ret=200 修改成功
  969. // @router /classify/edit [post]
  970. func (this *SandboxController) EditSandboxClassify() {
  971. br := new(models.BaseResponse).Init()
  972. defer func() {
  973. this.Data["json"] = br
  974. this.ServeJSON()
  975. }()
  976. var req sandbox.EditSandboxClassifyReq
  977. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  978. if err != nil {
  979. br.Msg = "参数解析异常!"
  980. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  981. return
  982. }
  983. if req.SandboxClassifyName == "" {
  984. br.Msg = "请输入分类名称"
  985. br.IsSendEmail = false
  986. return
  987. }
  988. if req.SandboxClassifyId <= 0 {
  989. br.Msg = "参数错误"
  990. br.IsSendEmail = false
  991. return
  992. }
  993. item, err := sandbox.GetSandboxClassifyById(req.SandboxClassifyId)
  994. if err != nil {
  995. br.Msg = "保存失败"
  996. br.Msg = "获取分类信息失败,Err:" + err.Error()
  997. return
  998. }
  999. if item.SandboxClassifyName != req.SandboxClassifyName {
  1000. count, err := sandbox.GetSandboxClassifyCount(req.SandboxClassifyName, item.ParentId)
  1001. if err != nil {
  1002. br.Msg = "判断名称是否已存在失败"
  1003. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  1004. return
  1005. }
  1006. if count > 0 {
  1007. br.Msg = "分类名称已存在,请重新输入"
  1008. br.IsSendEmail = false
  1009. return
  1010. }
  1011. err = sandbox.EditSandboxClassify(req.SandboxClassifyId, req.SandboxClassifyName)
  1012. if err != nil {
  1013. br.Msg = "保存失败"
  1014. br.ErrMsg = "保存失败,Err:" + err.Error()
  1015. return
  1016. }
  1017. }
  1018. br.Ret = 200
  1019. br.Msg = "保存成功"
  1020. br.Success = true
  1021. br.IsAddLog = true
  1022. }
  1023. // @Title 删除沙盘检测接口
  1024. // @Description 删除沙盘检测接口
  1025. // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
  1026. // @Success 200 Ret=200 检测成功
  1027. // @router /classify/delete/check [post]
  1028. func (this *SandboxController) DeleteSandboxClassifyCheck() {
  1029. br := new(models.BaseResponse).Init()
  1030. defer func() {
  1031. this.Data["json"] = br
  1032. this.ServeJSON()
  1033. }()
  1034. var req sandbox.SandboxClassifyDeleteCheckReq
  1035. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1036. if err != nil {
  1037. br.Msg = "参数解析异常!"
  1038. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1039. return
  1040. }
  1041. if req.SandboxClassifyId < 0 {
  1042. br.Msg = "参数错误"
  1043. br.IsSendEmail = false
  1044. return
  1045. }
  1046. var deleteStatus int
  1047. var tipsMsg string
  1048. //删除分类
  1049. if req.SandboxClassifyId > 0 {
  1050. //判断沙盘分类下,是否含有沙盘
  1051. count, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxClassifyId)
  1052. if err != nil {
  1053. br.Msg = "删除失败"
  1054. br.ErrMsg = "分类下是否含有指标失败,Err:" + err.Error()
  1055. return
  1056. }
  1057. if count > 0 {
  1058. deleteStatus = 1
  1059. tipsMsg = "该分类下关联沙盘不可删除"
  1060. }
  1061. }
  1062. if deleteStatus != 1 {
  1063. classifyCount, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxClassifyId)
  1064. if err != nil && err.Error() != utils.ErrNoRow() {
  1065. br.Msg = "删除失败"
  1066. br.ErrMsg = "分类下是否含有沙盘失败,Err:" + err.Error()
  1067. return
  1068. }
  1069. if classifyCount > 0 {
  1070. deleteStatus = 2
  1071. tipsMsg = "确认删除当前目录及包含的子目录吗"
  1072. }
  1073. }
  1074. if deleteStatus == 0 {
  1075. tipsMsg = "可删除,进行删除操作"
  1076. }
  1077. resp := new(sandbox.SandboxClassifyDeleteCheckResp)
  1078. resp.DeleteStatus = deleteStatus
  1079. resp.TipsMsg = tipsMsg
  1080. br.Ret = 200
  1081. br.Msg = "检测成功"
  1082. br.Success = true
  1083. br.Data = resp
  1084. }
  1085. // @Title 删除沙盘分类/沙盘
  1086. // @Description 删除沙盘分类/沙盘接口
  1087. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  1088. // @Success 200 Ret=200 删除成功
  1089. // @router /classify/delete [post]
  1090. func (this *SandboxController) DeleteSandboxClassify() {
  1091. br := new(models.BaseResponse).Init()
  1092. defer func() {
  1093. this.Data["json"] = br
  1094. this.ServeJSON()
  1095. }()
  1096. sysUser := this.SysUser
  1097. if sysUser == nil {
  1098. br.Msg = "请登录"
  1099. br.ErrMsg = "请登录,SysUser Is Empty"
  1100. br.Ret = 408
  1101. return
  1102. }
  1103. var req sandbox.DeleteSandboxClassifyReq
  1104. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1105. if err != nil {
  1106. br.Msg = "参数解析异常!"
  1107. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1108. return
  1109. }
  1110. if req.SandboxClassifyId < 0 && req.SandboxId <= 0 {
  1111. br.Msg = "参数错误"
  1112. br.IsSendEmail = false
  1113. return
  1114. }
  1115. //删除分类
  1116. if req.SandboxClassifyId > 0 && req.SandboxId == 0 {
  1117. //判断是否含有指标
  1118. count, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxId)
  1119. if err != nil && err.Error() != utils.ErrNoRow() {
  1120. br.Msg = "删除失败"
  1121. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  1122. return
  1123. }
  1124. if count > 0 {
  1125. br.Msg = "该目录下存在关联指标,不可删除"
  1126. br.IsSendEmail = false
  1127. return
  1128. }
  1129. err = sandbox.DeleteSandboxClassify(req.SandboxClassifyId)
  1130. if err != nil {
  1131. br.Msg = "删除失败"
  1132. br.ErrMsg = "删除失败,Err:" + err.Error()
  1133. return
  1134. }
  1135. }
  1136. //删除沙盘
  1137. if req.SandboxId > 0 {
  1138. sandboxInfo, err := sandbox.GetSandboxById(req.SandboxId)
  1139. if err != nil {
  1140. if err.Error() == utils.ErrNoRow() {
  1141. br.Msg = "沙盘已删除,请刷新页面"
  1142. br.ErrMsg = "指标不存在,Err:" + err.Error()
  1143. return
  1144. } else {
  1145. br.Msg = "删除失败"
  1146. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  1147. return
  1148. }
  1149. }
  1150. if sandboxInfo == nil {
  1151. br.Msg = "沙盘已删除,请刷新页面"
  1152. return
  1153. }
  1154. ////沙盘操作权限
  1155. //ok := sandbox.CheckOpSandboxPermission(sysUser, sandboxInfo.OpUserId)
  1156. //if !ok {
  1157. // br.Msg = "没有该沙盘的操作权限"
  1158. // br.ErrMsg = "没有该沙盘的操作权限"
  1159. // return
  1160. //}
  1161. ////新增操作日志
  1162. //{
  1163. // chartLog := new(data_manage.ChartInfoLog)
  1164. // chartLog.ChartName = chartInfo.ChartName
  1165. // chartLog.ChartInfoId = req.ChartInfoId
  1166. // chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  1167. // chartLog.SysUserId = sysUser.AdminId
  1168. // chartLog.SysUserRealName = sysUser.RealName
  1169. // chartLog.UniqueCode = chartInfo.UniqueCode
  1170. // chartLog.CreateTime = time.Now()
  1171. // chartLog.Content = string(this.Ctx.Input.RequestBody)
  1172. // chartLog.Status = "删除沙盘"
  1173. // chartLog.Method = this.Ctx.Input.URI()
  1174. // go data_manage.AddChartInfoLog(chartLog)
  1175. //}
  1176. }
  1177. br.Ret = 200
  1178. br.Msg = "删除成功"
  1179. br.Success = true
  1180. br.IsAddLog = true
  1181. }
  1182. // ChartClassifyMove
  1183. // @Title 沙盘分类移动接口
  1184. // @Description 沙盘分类移动接口
  1185. // @Success 200 {object} data_manage.MoveChartClassifyReq
  1186. // @router /classify/move [post]
  1187. func (this *SandboxController) ChartClassifyMove() {
  1188. br := new(models.BaseResponse).Init()
  1189. defer func() {
  1190. this.Data["json"] = br
  1191. this.ServeJSON()
  1192. }()
  1193. sysUser := this.SysUser
  1194. if sysUser == nil {
  1195. br.Msg = "请登录"
  1196. br.ErrMsg = "请登录,SysUser Is Empty"
  1197. br.Ret = 408
  1198. return
  1199. }
  1200. var req sandbox.MoveSandboxClassifyReq
  1201. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1202. if err != nil {
  1203. br.Msg = "参数解析异常!"
  1204. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1205. return
  1206. }
  1207. if req.ClassifyId <= 0 {
  1208. br.Msg = "参数错误"
  1209. br.ErrMsg = "分类id小于等于0"
  1210. return
  1211. }
  1212. //判断分类是否存在
  1213. sandboxClassifyInfo, err := sandbox.GetSandboxClassifyById(req.ClassifyId)
  1214. if err != nil {
  1215. br.Msg = "移动失败"
  1216. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  1217. return
  1218. }
  1219. updateCol := make([]string, 0)
  1220. //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  1221. if sandboxClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  1222. parentChartClassifyInfo, err := sandbox.GetSandboxClassifyById(req.ParentClassifyId)
  1223. if err != nil {
  1224. br.Msg = "移动失败"
  1225. br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  1226. return
  1227. }
  1228. sandboxClassifyInfo.ParentId = parentChartClassifyInfo.SandboxClassifyId
  1229. sandboxClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  1230. sandboxClassifyInfo.ModifyTime = time.Now()
  1231. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  1232. }
  1233. //如果有传入 上一个兄弟节点分类id
  1234. if req.PrevClassifyId > 0 {
  1235. //上一个兄弟节点
  1236. prevClassify, err := sandbox.GetSandboxClassifyById(req.PrevClassifyId)
  1237. if err != nil {
  1238. br.Msg = "移动失败"
  1239. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  1240. return
  1241. }
  1242. //如果是移动在两个兄弟节点之间
  1243. if req.NextClassifyId > 0 {
  1244. //下一个兄弟节点
  1245. nextClassify, err := sandbox.GetSandboxClassifyById(req.NextClassifyId)
  1246. if err != nil {
  1247. br.Msg = "移动失败"
  1248. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  1249. return
  1250. }
  1251. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  1252. if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == sandboxClassifyInfo.Sort {
  1253. //变更兄弟节点的排序
  1254. updateSortStr := `sort + 2`
  1255. _ = sandbox.UpdateSandboxClassifySortByParentId(prevClassify.ParentId, prevClassify.SandboxClassifyId, prevClassify.Sort, updateSortStr)
  1256. } else {
  1257. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  1258. if nextClassify.Sort-prevClassify.Sort == 1 {
  1259. //变更兄弟节点的排序
  1260. updateSortStr := `sort + 1`
  1261. _ = sandbox.UpdateSandboxClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  1262. }
  1263. }
  1264. }
  1265. sandboxClassifyInfo.Sort = prevClassify.Sort + 1
  1266. sandboxClassifyInfo.ModifyTime = time.Now()
  1267. updateCol = append(updateCol, "Sort", "ModifyTime")
  1268. } else {
  1269. firstClassify, err := sandbox.GetFirstSandboxClassifyByParentId(sandboxClassifyInfo.ParentId)
  1270. if err != nil && err.Error() != utils.ErrNoRow() {
  1271. br.Msg = "移动失败"
  1272. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  1273. return
  1274. }
  1275. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  1276. if firstClassify != nil && firstClassify.Sort == 0 {
  1277. updateSortStr := ` sort + 1 `
  1278. _ = sandbox.UpdateSandboxClassifySortByParentId(firstClassify.ParentId, firstClassify.SandboxClassifyId-1, 0, updateSortStr)
  1279. }
  1280. sandboxClassifyInfo.Sort = 0 //那就是排在第一位
  1281. sandboxClassifyInfo.ModifyTime = time.Now()
  1282. updateCol = append(updateCol, "Sort", "ModifyTime")
  1283. }
  1284. //更新
  1285. if len(updateCol) > 0 {
  1286. err = sandboxClassifyInfo.Update(updateCol)
  1287. if err != nil {
  1288. br.Msg = "移动失败"
  1289. br.ErrMsg = "修改失败,Err:" + err.Error()
  1290. return
  1291. }
  1292. }
  1293. br.Ret = 200
  1294. br.Success = true
  1295. br.Msg = "移动成功"
  1296. }
  1297. // @Title ETA图表列表接口
  1298. // @Description ETA图表列表接口
  1299. // @Param PageSize query int true "每页数据条数"
  1300. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1301. // @Param ChartClassifyId query int true "分类id"
  1302. // @Param KeyWord query string true "搜索关键词"
  1303. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1304. // @Success 200 {object} data_manage.ChartListResp
  1305. // @router /listV2 [get]
  1306. func (this *SandboxController) ListV2() {
  1307. br := new(models.BaseResponse).Init()
  1308. defer func() {
  1309. this.Data["json"] = br
  1310. this.ServeJSON()
  1311. }()
  1312. sysUser := this.SysUser
  1313. if sysUser == nil {
  1314. br.Msg = "请登录"
  1315. br.ErrMsg = "请登录,SysUser Is Empty"
  1316. br.Ret = 408
  1317. return
  1318. }
  1319. sandboxClassifyId, _ := this.GetInt("SandboxClassifyId")
  1320. pageSize, _ := this.GetInt("PageSize")
  1321. currentIndex, _ := this.GetInt("CurrentIndex")
  1322. keyWord := this.GetString("KeyWord")
  1323. var total int
  1324. page := paging.GetPaging(currentIndex, pageSize, total)
  1325. var startSize int
  1326. if pageSize <= 0 {
  1327. pageSize = utils.PageSize20
  1328. }
  1329. if currentIndex <= 0 {
  1330. currentIndex = 1
  1331. }
  1332. startSize = paging.StartIndex(currentIndex, pageSize)
  1333. var condition string
  1334. var pars []interface{}
  1335. if sandboxClassifyId > 0 {
  1336. sandboxClassifyId, err := sandbox.GetSandboxClassify(sandboxClassifyId)
  1337. if err != nil && err.Error() != utils.ErrNoRow() {
  1338. br.Msg = "获取图表信息失败"
  1339. br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
  1340. return
  1341. }
  1342. condition += " AND sandbox_classify_id IN(" + sandboxClassifyId + ") "
  1343. //pars = append(pars, chartClassifyId)
  1344. }
  1345. if keyWord != "" {
  1346. condition += ` AND ( name LIKE '%` + keyWord + `%' )`
  1347. }
  1348. //只看我的
  1349. isShowMe, _ := this.GetBool("IsShowMe")
  1350. if isShowMe {
  1351. condition += ` AND sys_user_id = ? `
  1352. pars = append(pars, sysUser.AdminId)
  1353. }
  1354. //获取图表信息
  1355. list, err := sandbox.GetSandboxListByCondition(condition, pars, startSize, pageSize)
  1356. if err != nil && err.Error() != utils.ErrNoRow() {
  1357. br.Success = true
  1358. br.Msg = "获取沙盘信息失败"
  1359. br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  1360. return
  1361. }
  1362. resp := new(sandbox.SandboxListResp)
  1363. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  1364. items := make([]*sandbox.Sandbox, 0)
  1365. resp.Paging = page
  1366. resp.List = items
  1367. br.Ret = 200
  1368. br.Success = true
  1369. br.Msg = "获取成功"
  1370. return
  1371. }
  1372. dataCount, err := sandbox.GetSandboxListCountByCondition(condition, pars)
  1373. if err != nil && err.Error() != utils.ErrNoRow() {
  1374. br.Msg = "获取指标信息失败"
  1375. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  1376. return
  1377. }
  1378. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  1379. resp.Paging = page
  1380. resp.List = list
  1381. br.Ret = 200
  1382. br.Success = true
  1383. br.Msg = "获取成功"
  1384. br.Data = resp
  1385. }
  1386. // Save
  1387. // @Title 新增/编辑保存沙盘
  1388. // @Description 新增/编辑保存沙盘接口
  1389. // @Param request body request.AddAndEditSandbox true "type json string"
  1390. // @Success 200 {object} sandbox.Sandbox
  1391. // @router /saveV2 [post]
  1392. func (this *SandboxController) SaveV2() {
  1393. br := new(models.BaseResponse).Init()
  1394. defer func() {
  1395. this.Data["json"] = br
  1396. this.ServeJSON()
  1397. }()
  1398. sysUser := this.SysUser
  1399. if sysUser == nil {
  1400. br.Msg = "请登录"
  1401. br.ErrMsg = "请登录,SysUser Is Empty"
  1402. br.Ret = 408
  1403. return
  1404. }
  1405. var req request.AddAndEditSandboxV2
  1406. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1407. if err != nil {
  1408. br.Msg = "参数解析异常!"
  1409. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1410. return
  1411. }
  1412. var sandboxResp *sandbox.SandboxSaveResp
  1413. var errMsg string
  1414. sandboxResp, err = sandboxService.AddSandboxV2(req, sysUser.AdminId, sysUser.RealName)
  1415. if err != nil {
  1416. br.Msg = "保存失败!"
  1417. if errMsg != `` {
  1418. br.Msg = errMsg
  1419. }
  1420. br.ErrMsg = "保存失败,Err:" + err.Error()
  1421. return
  1422. }
  1423. msg := "保存成功"
  1424. br.Ret = 200
  1425. br.Success = true
  1426. br.Msg = msg
  1427. br.Data = sandboxResp
  1428. }