sandbox.go 43 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537
  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. nodeAll := make([]*sandbox.SandboxClassifyItems, 0)
  871. for k := range rootList {
  872. rootNode := rootList[k]
  873. sandboxService.ChartClassifyItemsMakeTree(this.SysUser, classifyAll, rootNode)
  874. nodeAll = append(nodeAll, rootNode)
  875. }
  876. resp.AllNodes = nodeAll
  877. br.Ret = 200
  878. br.Success = true
  879. br.Msg = "获取成功"
  880. br.Data = resp
  881. }
  882. // @Title 新增沙盘分类
  883. // @Description 新增沙盘分类接口
  884. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  885. // @Success 200 Ret=200 保存成功
  886. // @router /classify/add [post]
  887. func (this *SandboxController) AddSandboxClassify() {
  888. br := new(models.BaseResponse).Init()
  889. defer func() {
  890. this.Data["json"] = br
  891. this.ServeJSON()
  892. }()
  893. var req sandbox.AddSandboxClassifyReq
  894. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  895. if err != nil {
  896. br.Msg = "参数解析异常!"
  897. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  898. return
  899. }
  900. if req.SandboxClassifyName == "" {
  901. br.Msg = "请输入分类名称"
  902. br.IsSendEmail = false
  903. return
  904. }
  905. if req.ParentId < 0 {
  906. br.Msg = "参数错误"
  907. br.IsSendEmail = false
  908. return
  909. }
  910. count, err := sandbox.GetSandboxClassifyCount(req.SandboxClassifyName, req.ParentId)
  911. if err != nil {
  912. br.Msg = "判断名称是否已存在失败"
  913. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  914. return
  915. }
  916. if count > 0 {
  917. br.Msg = "分类名称已存在,请重新输入"
  918. br.IsSendEmail = false
  919. return
  920. }
  921. //获取该层级下最大的排序数
  922. maxSort, err := sandbox.GetSandboxClassifyMaxSort(req.ParentId)
  923. classify := new(sandbox.SandboxClassify)
  924. classify.ParentId = req.ParentId
  925. classify.SandboxClassifyName = req.SandboxClassifyName
  926. classify.HasData = 0
  927. classify.CreateTime = time.Now()
  928. classify.ModifyTime = time.Now()
  929. classify.SysUserId = this.SysUser.AdminId
  930. classify.SysUserRealName = this.SysUser.RealName
  931. classify.Level = req.Level + 1
  932. classify.Sort = maxSort + 1
  933. _, err = sandbox.AddSandboxClassify(classify)
  934. if err != nil {
  935. br.Msg = "保存分类失败"
  936. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  937. return
  938. }
  939. br.Ret = 200
  940. br.Msg = "保存成功"
  941. br.Success = true
  942. }
  943. // @Title 修改沙盘分类
  944. // @Description 修改沙盘分类接口
  945. // @Param request body data_manage.EditChartClassifyReq true "type json string"
  946. // @Success 200 Ret=200 修改成功
  947. // @router /classify/edit [post]
  948. func (this *SandboxController) EditSandboxClassify() {
  949. br := new(models.BaseResponse).Init()
  950. defer func() {
  951. this.Data["json"] = br
  952. this.ServeJSON()
  953. }()
  954. var req sandbox.EditSandboxClassifyReq
  955. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  956. if err != nil {
  957. br.Msg = "参数解析异常!"
  958. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  959. return
  960. }
  961. if req.SandboxClassifyName == "" {
  962. br.Msg = "请输入分类名称"
  963. br.IsSendEmail = false
  964. return
  965. }
  966. if req.SandboxClassifyId <= 0 {
  967. br.Msg = "参数错误"
  968. br.IsSendEmail = false
  969. return
  970. }
  971. item, err := sandbox.GetSandboxClassifyById(req.SandboxClassifyId)
  972. if err != nil {
  973. br.Msg = "保存失败"
  974. br.Msg = "获取分类信息失败,Err:" + err.Error()
  975. return
  976. }
  977. if item.SandboxClassifyName != req.SandboxClassifyName {
  978. count, err := sandbox.GetSandboxClassifyCount(req.SandboxClassifyName, item.ParentId)
  979. if err != nil {
  980. br.Msg = "判断名称是否已存在失败"
  981. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  982. return
  983. }
  984. if count > 0 {
  985. br.Msg = "分类名称已存在,请重新输入"
  986. br.IsSendEmail = false
  987. return
  988. }
  989. err = sandbox.EditSandboxClassify(req.SandboxClassifyId, req.SandboxClassifyName)
  990. if err != nil {
  991. br.Msg = "保存失败"
  992. br.ErrMsg = "保存失败,Err:" + err.Error()
  993. return
  994. }
  995. }
  996. br.Ret = 200
  997. br.Msg = "保存成功"
  998. br.Success = true
  999. br.IsAddLog = true
  1000. }
  1001. // @Title 删除沙盘检测接口
  1002. // @Description 删除沙盘检测接口
  1003. // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
  1004. // @Success 200 Ret=200 检测成功
  1005. // @router /classify/delete/check [post]
  1006. func (this *SandboxController) DeleteSandboxClassifyCheck() {
  1007. br := new(models.BaseResponse).Init()
  1008. defer func() {
  1009. this.Data["json"] = br
  1010. this.ServeJSON()
  1011. }()
  1012. var req sandbox.SandboxClassifyDeleteCheckReq
  1013. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1014. if err != nil {
  1015. br.Msg = "参数解析异常!"
  1016. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1017. return
  1018. }
  1019. if req.SandboxClassifyId < 0 {
  1020. br.Msg = "参数错误"
  1021. br.IsSendEmail = false
  1022. return
  1023. }
  1024. var deleteStatus int
  1025. var tipsMsg string
  1026. //删除分类
  1027. if req.SandboxClassifyId > 0 {
  1028. //判断沙盘分类下,是否含有沙盘
  1029. count, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxClassifyId)
  1030. if err != nil {
  1031. br.Msg = "删除失败"
  1032. br.ErrMsg = "分类下是否含有指标失败,Err:" + err.Error()
  1033. return
  1034. }
  1035. if count > 0 {
  1036. deleteStatus = 1
  1037. tipsMsg = "该分类下关联沙盘不可删除"
  1038. }
  1039. }
  1040. if deleteStatus != 1 {
  1041. classifyCount, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxClassifyId)
  1042. if err != nil && err.Error() != utils.ErrNoRow() {
  1043. br.Msg = "删除失败"
  1044. br.ErrMsg = "分类下是否含有沙盘失败,Err:" + err.Error()
  1045. return
  1046. }
  1047. if classifyCount > 0 {
  1048. deleteStatus = 2
  1049. tipsMsg = "确认删除当前目录及包含的子目录吗"
  1050. }
  1051. }
  1052. if deleteStatus == 0 {
  1053. tipsMsg = "可删除,进行删除操作"
  1054. }
  1055. resp := new(sandbox.SandboxClassifyDeleteCheckResp)
  1056. resp.DeleteStatus = deleteStatus
  1057. resp.TipsMsg = tipsMsg
  1058. br.Ret = 200
  1059. br.Msg = "检测成功"
  1060. br.Success = true
  1061. br.Data = resp
  1062. }
  1063. // @Title 删除沙盘分类/沙盘
  1064. // @Description 删除沙盘分类/沙盘接口
  1065. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  1066. // @Success 200 Ret=200 删除成功
  1067. // @router /classify/delete [post]
  1068. func (this *SandboxController) DeleteSandboxClassify() {
  1069. br := new(models.BaseResponse).Init()
  1070. defer func() {
  1071. this.Data["json"] = br
  1072. this.ServeJSON()
  1073. }()
  1074. sysUser := this.SysUser
  1075. if sysUser == nil {
  1076. br.Msg = "请登录"
  1077. br.ErrMsg = "请登录,SysUser Is Empty"
  1078. br.Ret = 408
  1079. return
  1080. }
  1081. var req sandbox.DeleteSandboxClassifyReq
  1082. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1083. if err != nil {
  1084. br.Msg = "参数解析异常!"
  1085. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1086. return
  1087. }
  1088. if req.SandboxClassifyId < 0 && req.SandboxId <= 0 {
  1089. br.Msg = "参数错误"
  1090. br.IsSendEmail = false
  1091. return
  1092. }
  1093. //删除分类
  1094. if req.SandboxClassifyId > 0 && req.SandboxId == 0 {
  1095. //判断是否含有指标
  1096. count, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxId)
  1097. if err != nil && err.Error() != utils.ErrNoRow() {
  1098. br.Msg = "删除失败"
  1099. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  1100. return
  1101. }
  1102. if count > 0 {
  1103. br.Msg = "该目录下存在关联指标,不可删除"
  1104. br.IsSendEmail = false
  1105. return
  1106. }
  1107. err = sandbox.DeleteSandboxClassify(req.SandboxClassifyId)
  1108. if err != nil {
  1109. br.Msg = "删除失败"
  1110. br.ErrMsg = "删除失败,Err:" + err.Error()
  1111. return
  1112. }
  1113. }
  1114. //删除沙盘
  1115. if req.SandboxId > 0 {
  1116. sandboxInfo, err := sandbox.GetSandboxById(req.SandboxId)
  1117. if err != nil {
  1118. if err.Error() == utils.ErrNoRow() {
  1119. br.Msg = "沙盘已删除,请刷新页面"
  1120. br.ErrMsg = "指标不存在,Err:" + err.Error()
  1121. return
  1122. } else {
  1123. br.Msg = "删除失败"
  1124. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  1125. return
  1126. }
  1127. }
  1128. if sandboxInfo == nil {
  1129. br.Msg = "沙盘已删除,请刷新页面"
  1130. return
  1131. }
  1132. ////沙盘操作权限
  1133. //ok := sandbox.CheckOpSandboxPermission(sysUser, sandboxInfo.OpUserId)
  1134. //if !ok {
  1135. // br.Msg = "没有该沙盘的操作权限"
  1136. // br.ErrMsg = "没有该沙盘的操作权限"
  1137. // return
  1138. //}
  1139. ////新增操作日志
  1140. //{
  1141. // chartLog := new(data_manage.ChartInfoLog)
  1142. // chartLog.ChartName = chartInfo.ChartName
  1143. // chartLog.ChartInfoId = req.ChartInfoId
  1144. // chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  1145. // chartLog.SysUserId = sysUser.AdminId
  1146. // chartLog.SysUserRealName = sysUser.RealName
  1147. // chartLog.UniqueCode = chartInfo.UniqueCode
  1148. // chartLog.CreateTime = time.Now()
  1149. // chartLog.Content = string(this.Ctx.Input.RequestBody)
  1150. // chartLog.Status = "删除沙盘"
  1151. // chartLog.Method = this.Ctx.Input.URI()
  1152. // go data_manage.AddChartInfoLog(chartLog)
  1153. //}
  1154. }
  1155. br.Ret = 200
  1156. br.Msg = "删除成功"
  1157. br.Success = true
  1158. br.IsAddLog = true
  1159. }
  1160. // ChartClassifyMove
  1161. // @Title 沙盘分类移动接口
  1162. // @Description 沙盘分类移动接口
  1163. // @Success 200 {object} data_manage.MoveChartClassifyReq
  1164. // @router /classify/move [post]
  1165. func (this *SandboxController) ChartClassifyMove() {
  1166. br := new(models.BaseResponse).Init()
  1167. defer func() {
  1168. this.Data["json"] = br
  1169. this.ServeJSON()
  1170. }()
  1171. sysUser := this.SysUser
  1172. if sysUser == nil {
  1173. br.Msg = "请登录"
  1174. br.ErrMsg = "请登录,SysUser Is Empty"
  1175. br.Ret = 408
  1176. return
  1177. }
  1178. var req sandbox.MoveSandboxClassifyReq
  1179. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1180. if err != nil {
  1181. br.Msg = "参数解析异常!"
  1182. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1183. return
  1184. }
  1185. if req.ClassifyId <= 0 {
  1186. br.Msg = "参数错误"
  1187. br.ErrMsg = "分类id小于等于0"
  1188. return
  1189. }
  1190. //判断分类是否存在
  1191. sandboxClassifyInfo, err := sandbox.GetSandboxClassifyById(req.ClassifyId)
  1192. if err != nil {
  1193. br.Msg = "移动失败"
  1194. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  1195. return
  1196. }
  1197. updateCol := make([]string, 0)
  1198. //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  1199. if sandboxClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  1200. parentChartClassifyInfo, err := sandbox.GetSandboxClassifyById(req.ParentClassifyId)
  1201. if err != nil {
  1202. br.Msg = "移动失败"
  1203. br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  1204. return
  1205. }
  1206. sandboxClassifyInfo.ParentId = parentChartClassifyInfo.SandboxClassifyId
  1207. sandboxClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  1208. sandboxClassifyInfo.ModifyTime = time.Now()
  1209. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  1210. }
  1211. //如果有传入 上一个兄弟节点分类id
  1212. if req.PrevClassifyId > 0 {
  1213. //上一个兄弟节点
  1214. prevClassify, err := sandbox.GetSandboxClassifyById(req.PrevClassifyId)
  1215. if err != nil {
  1216. br.Msg = "移动失败"
  1217. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  1218. return
  1219. }
  1220. //如果是移动在两个兄弟节点之间
  1221. if req.NextClassifyId > 0 {
  1222. //下一个兄弟节点
  1223. nextClassify, err := sandbox.GetSandboxClassifyById(req.NextClassifyId)
  1224. if err != nil {
  1225. br.Msg = "移动失败"
  1226. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  1227. return
  1228. }
  1229. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  1230. if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == sandboxClassifyInfo.Sort {
  1231. //变更兄弟节点的排序
  1232. updateSortStr := `sort + 2`
  1233. _ = sandbox.UpdateSandboxClassifySortByParentId(prevClassify.ParentId, prevClassify.SandboxClassifyId, prevClassify.Sort, updateSortStr)
  1234. } else {
  1235. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  1236. if nextClassify.Sort-prevClassify.Sort == 1 {
  1237. //变更兄弟节点的排序
  1238. updateSortStr := `sort + 1`
  1239. _ = sandbox.UpdateSandboxClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  1240. }
  1241. }
  1242. }
  1243. sandboxClassifyInfo.Sort = prevClassify.Sort + 1
  1244. sandboxClassifyInfo.ModifyTime = time.Now()
  1245. updateCol = append(updateCol, "Sort", "ModifyTime")
  1246. } else {
  1247. firstClassify, err := sandbox.GetFirstSandboxClassifyByParentId(sandboxClassifyInfo.ParentId)
  1248. if err != nil && err.Error() != utils.ErrNoRow() {
  1249. br.Msg = "移动失败"
  1250. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  1251. return
  1252. }
  1253. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  1254. if firstClassify != nil && firstClassify.Sort == 0 {
  1255. updateSortStr := ` sort + 1 `
  1256. _ = sandbox.UpdateSandboxClassifySortByParentId(firstClassify.ParentId, firstClassify.SandboxClassifyId-1, 0, updateSortStr)
  1257. }
  1258. sandboxClassifyInfo.Sort = 0 //那就是排在第一位
  1259. sandboxClassifyInfo.ModifyTime = time.Now()
  1260. updateCol = append(updateCol, "Sort", "ModifyTime")
  1261. }
  1262. //更新
  1263. if len(updateCol) > 0 {
  1264. err = sandboxClassifyInfo.Update(updateCol)
  1265. if err != nil {
  1266. br.Msg = "移动失败"
  1267. br.ErrMsg = "修改失败,Err:" + err.Error()
  1268. return
  1269. }
  1270. }
  1271. br.Ret = 200
  1272. br.Success = true
  1273. br.Msg = "移动成功"
  1274. }
  1275. // @Title ETA图表列表接口
  1276. // @Description ETA图表列表接口
  1277. // @Param PageSize query int true "每页数据条数"
  1278. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1279. // @Param ChartClassifyId query int true "分类id"
  1280. // @Param KeyWord query string true "搜索关键词"
  1281. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1282. // @Success 200 {object} data_manage.ChartListResp
  1283. // @router /listV2 [get]
  1284. func (this *SandboxController) ListV2() {
  1285. br := new(models.BaseResponse).Init()
  1286. defer func() {
  1287. this.Data["json"] = br
  1288. this.ServeJSON()
  1289. }()
  1290. sysUser := this.SysUser
  1291. if sysUser == nil {
  1292. br.Msg = "请登录"
  1293. br.ErrMsg = "请登录,SysUser Is Empty"
  1294. br.Ret = 408
  1295. return
  1296. }
  1297. sandboxClassifyId, _ := this.GetInt("SandboxClassifyId")
  1298. pageSize, _ := this.GetInt("PageSize")
  1299. currentIndex, _ := this.GetInt("CurrentIndex")
  1300. keyWord := this.GetString("KeyWord")
  1301. var total int
  1302. page := paging.GetPaging(currentIndex, pageSize, total)
  1303. var startSize int
  1304. if pageSize <= 0 {
  1305. pageSize = utils.PageSize20
  1306. }
  1307. if currentIndex <= 0 {
  1308. currentIndex = 1
  1309. }
  1310. startSize = paging.StartIndex(currentIndex, pageSize)
  1311. var condition string
  1312. var pars []interface{}
  1313. if sandboxClassifyId > 0 {
  1314. chartClassifyId, err := sandbox.GetSandboxClassify(sandboxClassifyId)
  1315. if err != nil && err.Error() != utils.ErrNoRow() {
  1316. br.Msg = "获取图表信息失败"
  1317. br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
  1318. return
  1319. }
  1320. condition += " AND chart_classify_id IN(" + chartClassifyId + ") "
  1321. //pars = append(pars, chartClassifyId)
  1322. }
  1323. if keyWord != "" {
  1324. condition += ` AND ( name LIKE '%` + keyWord + `%' )`
  1325. }
  1326. //只看我的
  1327. isShowMe, _ := this.GetBool("IsShowMe")
  1328. if isShowMe {
  1329. condition += ` AND sys_user_id = ? `
  1330. pars = append(pars, sysUser.AdminId)
  1331. }
  1332. //获取图表信息
  1333. list, err := sandbox.GetSandboxListByCondition(condition, pars, startSize, pageSize)
  1334. if err != nil && err.Error() != utils.ErrNoRow() {
  1335. br.Success = true
  1336. br.Msg = "获取沙盘信息失败"
  1337. br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  1338. return
  1339. }
  1340. resp := new(sandbox.SandboxListResp)
  1341. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  1342. items := make([]*sandbox.Sandbox, 0)
  1343. resp.Paging = page
  1344. resp.List = items
  1345. br.Ret = 200
  1346. br.Success = true
  1347. br.Msg = "获取成功"
  1348. return
  1349. }
  1350. dataCount, err := sandbox.GetSandboxListCountByCondition(condition, pars)
  1351. if err != nil && err.Error() != utils.ErrNoRow() {
  1352. br.Msg = "获取指标信息失败"
  1353. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  1354. return
  1355. }
  1356. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  1357. resp.Paging = page
  1358. resp.List = list
  1359. br.Ret = 200
  1360. br.Success = true
  1361. br.Msg = "获取成功"
  1362. br.Data = resp
  1363. }
  1364. // Save
  1365. // @Title 新增/编辑保存沙盘
  1366. // @Description 新增/编辑保存沙盘接口
  1367. // @Param request body request.AddAndEditSandbox true "type json string"
  1368. // @Success 200 {object} sandbox.Sandbox
  1369. // @router /saveV2 [post]
  1370. func (this *SandboxController) SaveV2() {
  1371. br := new(models.BaseResponse).Init()
  1372. defer func() {
  1373. this.Data["json"] = br
  1374. this.ServeJSON()
  1375. }()
  1376. sysUser := this.SysUser
  1377. if sysUser == nil {
  1378. br.Msg = "请登录"
  1379. br.ErrMsg = "请登录,SysUser Is Empty"
  1380. br.Ret = 408
  1381. return
  1382. }
  1383. var req request.AddAndEditSandboxV2
  1384. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1385. if err != nil {
  1386. br.Msg = "参数解析异常!"
  1387. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1388. return
  1389. }
  1390. var sandboxResp *sandbox.SandboxSaveResp
  1391. var errMsg string
  1392. sandboxResp, err = sandboxService.AddSandboxV2(req, sysUser.AdminId, sysUser.RealName)
  1393. if err != nil {
  1394. br.Msg = "保存失败!"
  1395. if errMsg != `` {
  1396. br.Msg = errMsg
  1397. }
  1398. br.ErrMsg = "保存失败,Err:" + err.Error()
  1399. return
  1400. }
  1401. msg := "保存成功"
  1402. br.Ret = 200
  1403. br.Success = true
  1404. br.Msg = msg
  1405. br.Data = sandboxResp
  1406. }