sandbox.go 48 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737
  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. // SandboxClassifyItems
  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) SandboxClassifyItems() {
  752. br := new(models.BaseResponse).Init()
  753. defer func() {
  754. this.Data["json"] = br
  755. this.ServeJSON()
  756. }()
  757. resp := new(sandbox.SandboxClassifyListResp)
  758. sandboxClassifyId, _ := this.GetInt("SandboxClassifyId")
  759. isShowMe, _ := this.GetBool("IsShowMe")
  760. if isShowMe {
  761. errMsg, err := sandboxService.GetSandboxClassifyListForMe(*this.SysUser, resp, sandboxClassifyId)
  762. if err != nil {
  763. br.Msg = errMsg
  764. br.ErrMsg = err.Error()
  765. return
  766. }
  767. // 移除没有权限的图表
  768. //allNodes := sandboxService.HandleNoPermissionSandbox(resp.AllNodes, nil)
  769. //resp.AllNodes = allNodes
  770. br.Ret = 200
  771. br.Success = true
  772. br.Msg = "获取成功"
  773. br.Data = resp
  774. fmt.Println("source my classify")
  775. return
  776. }
  777. rootList, err := sandbox.GetSandboxClassifyByParentId(sandboxClassifyId)
  778. if err != nil && err.Error() != utils.ErrNoRow() {
  779. br.Msg = "获取失败"
  780. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  781. return
  782. }
  783. classifyAll, err := sandbox.GetSandboxClassifyByParentId(sandboxClassifyId)
  784. if err != nil && err.Error() != utils.ErrNoRow() {
  785. br.Msg = "获取失败"
  786. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  787. return
  788. }
  789. sandboxAll, err := sandbox.GetSandboxItemsByClassifyId(sandboxClassifyId)
  790. if err != nil && err.Error() != utils.ErrNoRow() {
  791. br.Msg = "获取失败"
  792. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  793. return
  794. }
  795. sandListMap := make(map[int][]*sandbox.SandboxClassifyItems)
  796. for _, v := range sandboxAll {
  797. if _, ok := sandListMap[v.SandboxClassifyId]; !ok {
  798. list := make([]*sandbox.SandboxClassifyItems, 0)
  799. list = append(list, v)
  800. sandListMap[v.SandboxClassifyId] = list
  801. } else {
  802. sandListMap[v.SandboxClassifyId] = append(sandListMap[v.SandboxClassifyId], v)
  803. }
  804. }
  805. nodeAll := make([]*sandbox.SandboxClassifyItems, 0)
  806. for k := range rootList {
  807. rootNode := rootList[k]
  808. sandboxService.SandboxClassifyItemsMakeTree(this.SysUser, classifyAll, rootNode)
  809. nodeAll = append(nodeAll, rootNode)
  810. }
  811. //for k := range nodeAll {
  812. //
  813. //}
  814. newAll := sandboxService.SandboxItemsMakeTree(nodeAll, sandListMap, sandboxClassifyId)
  815. resp.AllNodes = newAll
  816. br.Ret = 200
  817. br.Success = true
  818. br.Msg = "获取成功"
  819. br.Data = resp
  820. }
  821. // @Title 新增沙盘分类
  822. // @Description 新增沙盘分类接口
  823. // @Param request body data_manage.AddChartClassifyReq true "type json string"
  824. // @Success 200 Ret=200 保存成功
  825. // @router /classify/add [post]
  826. func (this *SandboxController) AddSandboxClassify() {
  827. br := new(models.BaseResponse).Init()
  828. defer func() {
  829. this.Data["json"] = br
  830. this.ServeJSON()
  831. }()
  832. var req sandbox.AddSandboxClassifyReq
  833. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  834. if err != nil {
  835. br.Msg = "参数解析异常!"
  836. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  837. return
  838. }
  839. if req.SandboxClassifyName == "" {
  840. br.Msg = "请输入分类名称"
  841. br.IsSendEmail = false
  842. return
  843. }
  844. if req.ParentId < 0 {
  845. br.Msg = "参数错误"
  846. br.IsSendEmail = false
  847. return
  848. }
  849. count, err := sandbox.GetSandboxClassifyCount(req.SandboxClassifyName, req.ParentId)
  850. if err != nil {
  851. br.Msg = "判断名称是否已存在失败"
  852. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  853. return
  854. }
  855. if count > 0 {
  856. br.Msg = "分类名称已存在,请重新输入"
  857. br.IsSendEmail = false
  858. return
  859. }
  860. //获取该层级下最大的排序数
  861. maxSort, err := sandbox.GetSandboxClassifyMaxSort(req.ParentId)
  862. classify := new(sandbox.SandboxClassify)
  863. classify.ParentId = req.ParentId
  864. classify.SandboxClassifyName = req.SandboxClassifyName
  865. classify.HasData = 0
  866. classify.CreateTime = time.Now()
  867. classify.ModifyTime = time.Now()
  868. classify.SysUserId = this.SysUser.AdminId
  869. classify.SysUserRealName = this.SysUser.RealName
  870. classify.ChartPermissionId = req.ChartPermissionId
  871. classify.ChartPermissionName = req.ChartPermissionName
  872. classify.Level = req.Level + 1
  873. classify.Sort = maxSort + 1
  874. _, err = sandbox.AddSandboxClassify(classify)
  875. if err != nil {
  876. br.Msg = "保存分类失败"
  877. br.ErrMsg = "保存分类失败,Err:" + err.Error()
  878. return
  879. }
  880. br.Ret = 200
  881. br.Msg = "保存成功"
  882. br.Success = true
  883. }
  884. // @Title 修改沙盘分类
  885. // @Description 修改沙盘分类接口
  886. // @Param request body data_manage.EditChartClassifyReq true "type json string"
  887. // @Success 200 Ret=200 修改成功
  888. // @router /classify/edit [post]
  889. func (this *SandboxController) EditSandboxClassify() {
  890. br := new(models.BaseResponse).Init()
  891. defer func() {
  892. this.Data["json"] = br
  893. this.ServeJSON()
  894. }()
  895. var req sandbox.EditSandboxClassifyReq
  896. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  897. if err != nil {
  898. br.Msg = "参数解析异常!"
  899. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  900. return
  901. }
  902. if req.SandboxClassifyName == "" {
  903. br.Msg = "请输入分类名称"
  904. br.IsSendEmail = false
  905. return
  906. }
  907. if req.SandboxClassifyId <= 0 {
  908. br.Msg = "参数错误"
  909. br.IsSendEmail = false
  910. return
  911. }
  912. item, err := sandbox.GetSandboxClassifyById(req.SandboxClassifyId)
  913. if err != nil {
  914. br.Msg = "保存失败"
  915. br.Msg = "获取分类信息失败,Err:" + err.Error()
  916. return
  917. }
  918. if item.SandboxClassifyName != req.SandboxClassifyName {
  919. count, err := sandbox.GetSandboxClassifyCount(req.SandboxClassifyName, item.ParentId)
  920. if err != nil {
  921. br.Msg = "判断名称是否已存在失败"
  922. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  923. return
  924. }
  925. if count > 0 {
  926. br.Msg = "分类名称已存在,请重新输入"
  927. br.IsSendEmail = false
  928. return
  929. }
  930. err = sandbox.EditSandboxClassify(req.SandboxClassifyId, req.SandboxClassifyName)
  931. if err != nil {
  932. br.Msg = "保存失败"
  933. br.ErrMsg = "保存失败,Err:" + err.Error()
  934. return
  935. }
  936. }
  937. br.Ret = 200
  938. br.Msg = "保存成功"
  939. br.Success = true
  940. br.IsAddLog = true
  941. }
  942. // @Title 删除沙盘检测接口
  943. // @Description 删除沙盘检测接口
  944. // @Param request body data_manage.ChartClassifyDeleteCheckResp true "type json string"
  945. // @Success 200 Ret=200 检测成功
  946. // @router /classify/delete/check [post]
  947. func (this *SandboxController) DeleteSandboxClassifyCheck() {
  948. br := new(models.BaseResponse).Init()
  949. defer func() {
  950. this.Data["json"] = br
  951. this.ServeJSON()
  952. }()
  953. var req sandbox.SandboxClassifyDeleteCheckReq
  954. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  955. if err != nil {
  956. br.Msg = "参数解析异常!"
  957. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  958. return
  959. }
  960. if req.SandboxClassifyId < 0 {
  961. br.Msg = "参数错误"
  962. br.IsSendEmail = false
  963. return
  964. }
  965. var deleteStatus int
  966. var tipsMsg string
  967. //删除分类
  968. if req.SandboxClassifyId > 0 {
  969. //判断沙盘分类下,是否含有沙盘
  970. count, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxClassifyId)
  971. if err != nil {
  972. br.Msg = "删除失败"
  973. br.ErrMsg = "分类下是否含有指标失败,Err:" + err.Error()
  974. return
  975. }
  976. if count > 0 {
  977. deleteStatus = 1
  978. tipsMsg = "该分类下关联沙盘不可删除"
  979. }
  980. }
  981. if deleteStatus != 1 {
  982. classifyCount, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxClassifyId)
  983. if err != nil && err.Error() != utils.ErrNoRow() {
  984. br.Msg = "删除失败"
  985. br.ErrMsg = "分类下是否含有沙盘失败,Err:" + err.Error()
  986. return
  987. }
  988. if classifyCount > 0 {
  989. deleteStatus = 2
  990. tipsMsg = "确认删除当前目录及包含的子目录吗"
  991. }
  992. }
  993. if deleteStatus == 0 {
  994. tipsMsg = "可删除,进行删除操作"
  995. }
  996. resp := new(sandbox.SandboxClassifyDeleteCheckResp)
  997. resp.DeleteStatus = deleteStatus
  998. resp.TipsMsg = tipsMsg
  999. br.Ret = 200
  1000. br.Msg = "检测成功"
  1001. br.Success = true
  1002. br.Data = resp
  1003. }
  1004. // @Title 删除沙盘分类/沙盘
  1005. // @Description 删除沙盘分类/沙盘接口
  1006. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  1007. // @Success 200 Ret=200 删除成功
  1008. // @router /classify/delete [post]
  1009. func (this *SandboxController) DeleteSandboxClassify() {
  1010. br := new(models.BaseResponse).Init()
  1011. defer func() {
  1012. this.Data["json"] = br
  1013. this.ServeJSON()
  1014. }()
  1015. sysUser := this.SysUser
  1016. if sysUser == nil {
  1017. br.Msg = "请登录"
  1018. br.ErrMsg = "请登录,SysUser Is Empty"
  1019. br.Ret = 408
  1020. return
  1021. }
  1022. var req sandbox.DeleteSandboxClassifyReq
  1023. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1024. if err != nil {
  1025. br.Msg = "参数解析异常!"
  1026. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1027. return
  1028. }
  1029. if req.SandboxClassifyId < 0 && req.SandboxId <= 0 {
  1030. br.Msg = "参数错误"
  1031. br.IsSendEmail = false
  1032. return
  1033. }
  1034. //删除分类
  1035. if req.SandboxClassifyId > 0 && req.SandboxId == 0 {
  1036. //判断是否含有指标
  1037. count, err := sandbox.GetSandboxInfoCountByClassifyId(req.SandboxId)
  1038. if err != nil && err.Error() != utils.ErrNoRow() {
  1039. br.Msg = "删除失败"
  1040. br.ErrMsg = "判断名称是否已存在失败,Err:" + err.Error()
  1041. return
  1042. }
  1043. if count > 0 {
  1044. br.Msg = "该目录下存在关联指标,不可删除"
  1045. br.IsSendEmail = false
  1046. return
  1047. }
  1048. err = sandbox.DeleteSandboxClassify(req.SandboxClassifyId)
  1049. if err != nil {
  1050. br.Msg = "删除失败"
  1051. br.ErrMsg = "删除失败,Err:" + err.Error()
  1052. return
  1053. }
  1054. }
  1055. //删除沙盘
  1056. if req.SandboxId > 0 {
  1057. sandboxInfo, err := sandbox.GetSandboxById(req.SandboxId)
  1058. if err != nil {
  1059. if err.Error() == utils.ErrNoRow() {
  1060. br.Msg = "沙盘已删除,请刷新页面"
  1061. br.ErrMsg = "指标不存在,Err:" + err.Error()
  1062. return
  1063. } else {
  1064. br.Msg = "删除失败"
  1065. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  1066. return
  1067. }
  1068. }
  1069. if sandboxInfo == nil {
  1070. br.Msg = "沙盘已删除,请刷新页面"
  1071. return
  1072. }
  1073. err = sandboxService.DeleteSandbox(req.SandboxId)
  1074. if err != nil {
  1075. br.Msg = err.Error()
  1076. return
  1077. }
  1078. }
  1079. br.Ret = 200
  1080. br.Msg = "删除成功"
  1081. br.Success = true
  1082. br.IsAddLog = true
  1083. }
  1084. // ChartClassifyMove
  1085. // @Title 沙盘分类移动接口
  1086. // @Description 沙盘分类移动接口
  1087. // @Success 200 {object} data_manage.MoveChartClassifyReq
  1088. // @router /classify/move [post]
  1089. func (this *SandboxController) ChartClassifyMove() {
  1090. br := new(models.BaseResponse).Init()
  1091. defer func() {
  1092. this.Data["json"] = br
  1093. this.ServeJSON()
  1094. }()
  1095. sysUser := this.SysUser
  1096. if sysUser == nil {
  1097. br.Msg = "请登录"
  1098. br.ErrMsg = "请登录,SysUser Is Empty"
  1099. br.Ret = 408
  1100. return
  1101. }
  1102. var req sandbox.MoveSandboxClassifyReq
  1103. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1104. if err != nil {
  1105. br.Msg = "参数解析异常!"
  1106. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1107. return
  1108. }
  1109. if req.ClassifyId <= 0 {
  1110. br.Msg = "参数错误"
  1111. br.ErrMsg = "分类id小于等于0"
  1112. return
  1113. }
  1114. //判断分类是否存在
  1115. sandboxClassifyInfo, err := sandbox.GetSandboxClassifyById(req.ClassifyId)
  1116. if err != nil {
  1117. br.Msg = "移动失败"
  1118. br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
  1119. return
  1120. }
  1121. updateCol := make([]string, 0)
  1122. //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  1123. if sandboxClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId != 0 {
  1124. parentChartClassifyInfo, err := sandbox.GetSandboxClassifyById(req.ParentClassifyId)
  1125. if err != nil {
  1126. br.Msg = "移动失败"
  1127. br.ErrMsg = "获取上级分类信息失败,Err:" + err.Error()
  1128. return
  1129. }
  1130. sandboxClassifyInfo.ParentId = parentChartClassifyInfo.SandboxClassifyId
  1131. sandboxClassifyInfo.Level = parentChartClassifyInfo.Level + 1
  1132. sandboxClassifyInfo.ModifyTime = time.Now()
  1133. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  1134. } else if sandboxClassifyInfo.ParentId != req.ParentClassifyId && req.ParentClassifyId == 0 {
  1135. //改为一级分类
  1136. sandboxClassifyInfo.ParentId = req.ParentClassifyId
  1137. sandboxClassifyInfo.Level = 1
  1138. sandboxClassifyInfo.ModifyTime = time.Now()
  1139. updateCol = append(updateCol, "ParentId", "Level", "ModifyTime")
  1140. }
  1141. //如果有传入 上一个兄弟节点分类id
  1142. if req.PrevClassifyId > 0 {
  1143. //上一个兄弟节点
  1144. prevClassify, err := sandbox.GetSandboxClassifyById(req.PrevClassifyId)
  1145. if err != nil {
  1146. br.Msg = "移动失败"
  1147. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  1148. return
  1149. }
  1150. //如果是移动在两个兄弟节点之间
  1151. if req.NextClassifyId > 0 {
  1152. //下一个兄弟节点
  1153. nextClassify, err := sandbox.GetSandboxClassifyById(req.NextClassifyId)
  1154. if err != nil {
  1155. br.Msg = "移动失败"
  1156. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  1157. return
  1158. }
  1159. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  1160. if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == sandboxClassifyInfo.Sort {
  1161. //变更兄弟节点的排序
  1162. updateSortStr := `sort + 2`
  1163. _ = sandbox.UpdateSandboxClassifySortByParentId(prevClassify.ParentId, prevClassify.SandboxClassifyId, prevClassify.Sort, updateSortStr)
  1164. } else {
  1165. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  1166. if nextClassify.Sort-prevClassify.Sort == 1 {
  1167. //变更兄弟节点的排序
  1168. updateSortStr := `sort + 1`
  1169. _ = sandbox.UpdateSandboxClassifySortByParentId(prevClassify.ParentId, 0, prevClassify.Sort, updateSortStr)
  1170. }
  1171. }
  1172. }
  1173. sandboxClassifyInfo.Sort = prevClassify.Sort + 1
  1174. sandboxClassifyInfo.ModifyTime = time.Now()
  1175. updateCol = append(updateCol, "Sort", "ModifyTime")
  1176. } else {
  1177. firstClassify, err := sandbox.GetFirstSandboxClassifyByParentId(sandboxClassifyInfo.ParentId)
  1178. if err != nil && err.Error() != utils.ErrNoRow() {
  1179. br.Msg = "移动失败"
  1180. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  1181. return
  1182. }
  1183. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  1184. if firstClassify != nil && firstClassify.Sort == 0 {
  1185. updateSortStr := ` sort + 1 `
  1186. _ = sandbox.UpdateSandboxClassifySortByParentId(firstClassify.ParentId, firstClassify.SandboxClassifyId-1, 0, updateSortStr)
  1187. }
  1188. sandboxClassifyInfo.Sort = 0 //那就是排在第一位
  1189. sandboxClassifyInfo.ModifyTime = time.Now()
  1190. updateCol = append(updateCol, "Sort", "ModifyTime")
  1191. }
  1192. //更新
  1193. if len(updateCol) > 0 {
  1194. err = sandboxClassifyInfo.Update(updateCol)
  1195. if err != nil {
  1196. br.Msg = "移动失败"
  1197. br.ErrMsg = "修改失败,Err:" + err.Error()
  1198. return
  1199. }
  1200. }
  1201. br.Ret = 200
  1202. br.Success = true
  1203. br.Msg = "移动成功"
  1204. }
  1205. // @Title ETA图表列表接口
  1206. // @Description ETA图表列表接口
  1207. // @Param PageSize query int true "每页数据条数"
  1208. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1209. // @Param ChartClassifyId query int true "分类id"
  1210. // @Param KeyWord query string true "搜索关键词"
  1211. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1212. // @Success 200 {object} data_manage.ChartListResp
  1213. // @router /listV2 [get]
  1214. func (this *SandboxController) ListV2() {
  1215. br := new(models.BaseResponse).Init()
  1216. defer func() {
  1217. this.Data["json"] = br
  1218. this.ServeJSON()
  1219. }()
  1220. sysUser := this.SysUser
  1221. if sysUser == nil {
  1222. br.Msg = "请登录"
  1223. br.ErrMsg = "请登录,SysUser Is Empty"
  1224. br.Ret = 408
  1225. return
  1226. }
  1227. sandboxClassifyId, _ := this.GetInt("SandboxClassifyId")
  1228. pageSize, _ := this.GetInt("PageSize")
  1229. currentIndex, _ := this.GetInt("CurrentIndex")
  1230. keyWord := this.GetString("KeyWord")
  1231. var total int
  1232. page := paging.GetPaging(currentIndex, pageSize, total)
  1233. var startSize int
  1234. if pageSize <= 0 {
  1235. pageSize = utils.PageSize20
  1236. }
  1237. if currentIndex <= 0 {
  1238. currentIndex = 1
  1239. }
  1240. startSize = paging.StartIndex(currentIndex, pageSize)
  1241. var condition string
  1242. var pars []interface{}
  1243. if sandboxClassifyId > 0 {
  1244. sandboxClassifyId, err := sandbox.GetSandboxClassify(sandboxClassifyId)
  1245. if err != nil && err.Error() != utils.ErrNoRow() {
  1246. br.Msg = "获取图表信息失败"
  1247. br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
  1248. return
  1249. }
  1250. condition += " AND sandbox_classify_id IN(" + sandboxClassifyId + ") "
  1251. //pars = append(pars, chartClassifyId)
  1252. }
  1253. if keyWord != "" {
  1254. condition += ` AND ( name LIKE '%` + keyWord + `%' )`
  1255. }
  1256. //只看我的
  1257. isShowMe, _ := this.GetBool("IsShowMe")
  1258. if isShowMe {
  1259. condition += ` AND sys_user_id = ? `
  1260. pars = append(pars, sysUser.AdminId)
  1261. }
  1262. //获取图表信息
  1263. condition += ` AND is_delete = 0 `
  1264. list, err := sandbox.GetSandboxListByCondition(condition, pars, startSize, pageSize)
  1265. if err != nil && err.Error() != utils.ErrNoRow() {
  1266. br.Success = true
  1267. br.Msg = "获取沙盘信息失败"
  1268. br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  1269. return
  1270. }
  1271. for i, v := range list {
  1272. ids, err := sandbox.GetSandboxAllParentByClassifyId(v.SandboxClassifyId)
  1273. if err != nil {
  1274. br.Msg = "获取父级信息错误!"
  1275. br.ErrMsg = "获取父级信息错误,Err:" + err.Error()
  1276. return
  1277. }
  1278. list[i].ParentIds = ids
  1279. }
  1280. resp := new(sandbox.SandboxListResp)
  1281. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  1282. items := make([]*sandbox.SandboxListItems, 0)
  1283. resp.Paging = page
  1284. resp.List = items
  1285. br.Ret = 200
  1286. br.Success = true
  1287. br.Msg = "获取成功"
  1288. return
  1289. }
  1290. dataCount, err := sandbox.GetSandboxListCountByCondition(condition, pars)
  1291. if err != nil && err.Error() != utils.ErrNoRow() {
  1292. br.Msg = "获取指标信息失败"
  1293. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  1294. return
  1295. }
  1296. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  1297. resp.Paging = page
  1298. resp.List = list
  1299. br.Ret = 200
  1300. br.Success = true
  1301. br.Msg = "获取成功"
  1302. br.Data = resp
  1303. }
  1304. // Save
  1305. // @Title 新增/编辑保存沙盘
  1306. // @Description 新增/编辑保存沙盘接口
  1307. // @Param request body request.AddAndEditSandbox true "type json string"
  1308. // @Success 200 {object} sandbox.Sandbox
  1309. // @router /saveV2 [post]
  1310. func (this *SandboxController) SaveV2() {
  1311. br := new(models.BaseResponse).Init()
  1312. defer func() {
  1313. this.Data["json"] = br
  1314. this.ServeJSON()
  1315. }()
  1316. sysUser := this.SysUser
  1317. if sysUser == nil {
  1318. br.Msg = "请登录"
  1319. br.ErrMsg = "请登录,SysUser Is Empty"
  1320. br.Ret = 408
  1321. return
  1322. }
  1323. var req request.AddAndEditSandboxV2
  1324. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1325. if err != nil {
  1326. br.Msg = "参数解析异常!"
  1327. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1328. return
  1329. }
  1330. var sandboxResp *sandbox.SandboxSaveResp
  1331. var errMsg string
  1332. if req.SandboxId == 0 {
  1333. //新增沙盘
  1334. sandboxResp, err = sandboxService.AddSandboxV2(req, sysUser.AdminId, sysUser.RealName)
  1335. if err != nil {
  1336. br.Msg = "保存失败!"
  1337. if errMsg != `` {
  1338. br.Msg = errMsg
  1339. }
  1340. br.ErrMsg = "保存失败,Err:" + err.Error()
  1341. return
  1342. }
  1343. } else {
  1344. //编辑沙盘
  1345. sandboxInfo := &sandbox.Sandbox{
  1346. Name: utils.TrimStr(req.Name),
  1347. Content: req.Content,
  1348. PicUrl: utils.TrimStr(req.PicUrl),
  1349. ModifyTime: time.Now(),
  1350. SandboxClassifyId: req.SandboxClassifyId,
  1351. }
  1352. var updateSandboxColumn = []string{"Content","PicUrl","ModifyTime","SandboxClassifyId"}
  1353. err = sandboxInfo.Update(updateSandboxColumn)
  1354. if err != nil {
  1355. br.Msg = "保存失败!"
  1356. if errMsg != `` {
  1357. br.Msg = errMsg
  1358. }
  1359. br.ErrMsg = "保存失败,Err:" + err.Error()
  1360. return
  1361. }
  1362. }
  1363. msg := "保存成功"
  1364. br.Ret = 200
  1365. br.Success = true
  1366. br.Msg = msg
  1367. br.Data = sandboxResp
  1368. }
  1369. // Delete
  1370. // @Title 删除沙盘
  1371. // @Description 删除沙盘接口
  1372. // @Param request body request.DeleteSandbox true "type json string"
  1373. // @Success 200 标记成功
  1374. // @router /deleteV2 [post]
  1375. func (this *SandboxController) DeleteV2() {
  1376. br := new(models.BaseResponse).Init()
  1377. defer func() {
  1378. this.Data["json"] = br
  1379. this.ServeJSON()
  1380. }()
  1381. sysUser := this.SysUser
  1382. if sysUser == nil {
  1383. br.Msg = "请登录"
  1384. br.ErrMsg = "请登录,SysUser Is Empty"
  1385. br.Ret = 408
  1386. return
  1387. }
  1388. var req request.DeleteSandbox
  1389. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1390. if err != nil {
  1391. br.Msg = "参数解析异常!"
  1392. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1393. return
  1394. }
  1395. if req.SandboxId <= 0 {
  1396. br.Msg = "缺少沙盘编号"
  1397. return
  1398. }
  1399. //删除沙盘
  1400. err = sandboxService.DeleteSandbox(req.SandboxId)
  1401. if err != nil {
  1402. br.Msg = err.Error()
  1403. return
  1404. }
  1405. msg := "删除成功"
  1406. br.Ret = 200
  1407. br.Success = true
  1408. br.Msg = msg
  1409. }
  1410. // GetSandboxVersionDetail
  1411. // @Title 获取沙盘版本数据详情(已保存的)
  1412. // @Description 获取沙盘版本数据详情接口(已保存的)
  1413. // @Param SandboxVersionCode query string true "沙盘版本code"
  1414. // @Success 200 {object} sandbox.SandboxVersion
  1415. // @router /detail [get]
  1416. func (this *SandboxController) GetSandboxDetail() {
  1417. br := new(models.BaseResponse).Init()
  1418. defer func() {
  1419. this.Data["json"] = br
  1420. this.ServeJSON()
  1421. }()
  1422. sysUser := this.SysUser
  1423. if sysUser == nil {
  1424. br.Msg = "请登录"
  1425. br.ErrMsg = "请登录,SysUser Is Empty"
  1426. br.Ret = 408
  1427. return
  1428. }
  1429. sandboxId, _ := this.GetInt("SandboxId")
  1430. if sandboxId == 0 {
  1431. br.Msg = "缺少沙盘Id"
  1432. return
  1433. }
  1434. //获取沙盘数据详情(已保存的)
  1435. sandboxVersionInfo, err := sandbox.GetSandboxById(sandboxId)
  1436. if err != nil {
  1437. br.Msg = "获取失败"
  1438. br.ErrMsg = "获取失败,Err:" + err.Error()
  1439. return
  1440. }
  1441. msg := "获取成功"
  1442. br.Ret = 200
  1443. br.Success = true
  1444. br.Msg = msg
  1445. br.Data = sandboxVersionInfo
  1446. }
  1447. // SandboxMove
  1448. // @Title 移动沙盘接口
  1449. // @Description 移动图表接口
  1450. // @Success 200 {object} data_manage.MoveChartInfoReq
  1451. // @router /move [post]
  1452. func (this *SandboxController) SandboxMove() {
  1453. br := new(models.BaseResponse).Init()
  1454. defer func() {
  1455. this.Data["json"] = br
  1456. this.ServeJSON()
  1457. }()
  1458. sysUser := this.SysUser
  1459. if sysUser == nil {
  1460. br.Msg = "请登录"
  1461. br.ErrMsg = "请登录,SysUser Is Empty"
  1462. br.Ret = 408
  1463. return
  1464. }
  1465. var req sandbox.MoveSandboxReq
  1466. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1467. if err != nil {
  1468. br.Msg = "参数解析异常!"
  1469. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1470. return
  1471. }
  1472. if req.SandboxId <= 0 {
  1473. br.Msg = "参数错误"
  1474. br.ErrMsg = "沙盘id小于等于0"
  1475. return
  1476. }
  1477. if req.SandboxClassifyId <= 0 {
  1478. br.Msg = "请选择分类"
  1479. return
  1480. }
  1481. //判断分类是否存在
  1482. count, _ := sandbox.GetSandboxClassifyCountById(req.SandboxClassifyId)
  1483. if count <= 0 {
  1484. br.Msg = "分类已被删除,不可移动,请刷新页面"
  1485. return
  1486. }
  1487. sandboxInfo, err := sandbox.GetSandboxById(req.SandboxId)
  1488. if err != nil {
  1489. br.Msg = "移动失败"
  1490. br.ErrMsg = "获取沙盘信息失败,Err:" + err.Error()
  1491. return
  1492. }
  1493. //如果改变了分类,那么移动该图表数据
  1494. if sandboxInfo.SandboxClassifyId != req.SandboxClassifyId {
  1495. //查询需要修改的分类下是否存在同一个图表名称
  1496. tmpSandboxInfo, tmpErr := sandbox.GetSandboxByClassifyIdAndName(req.SandboxClassifyId, sandboxInfo.Name)
  1497. if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
  1498. br.Msg = "移动失败"
  1499. br.ErrMsg = "移动失败,Err:" + tmpErr.Error()
  1500. return
  1501. }
  1502. if tmpSandboxInfo != nil {
  1503. br.Msg = "移动失败,同一个分类下沙盘名称不允许重复"
  1504. br.ErrMsg = "移动失败,同一个分类下沙盘名称不允许重复"
  1505. return
  1506. }
  1507. err = sandbox.MoveSandbox(req.SandboxId, req.SandboxClassifyId)
  1508. if err != nil {
  1509. br.Msg = "移动失败"
  1510. br.ErrMsg = "移动失败,Err:" + err.Error()
  1511. return
  1512. }
  1513. }
  1514. //移动排序
  1515. updateCol := make([]string, 0)
  1516. //如果有传入 上一个兄弟节点分类id
  1517. if req.PrevSandboxId > 0 {
  1518. prevChartInfo, err := sandbox.GetSandboxById(req.PrevSandboxId)
  1519. if err != nil {
  1520. br.Msg = "移动失败"
  1521. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  1522. return
  1523. }
  1524. //如果是移动在两个兄弟节点之间
  1525. if req.NextSandboxId > 0 {
  1526. //下一个兄弟节点
  1527. nextChartInfo, err := sandbox.GetSandboxById(req.NextSandboxId)
  1528. if err != nil {
  1529. br.Msg = "移动失败"
  1530. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  1531. return
  1532. }
  1533. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  1534. if prevChartInfo.Sort == nextChartInfo.Sort || prevChartInfo.Sort == sandboxInfo.Sort {
  1535. //变更兄弟节点的排序
  1536. updateSortStr := `sort + 2`
  1537. _ = sandbox.UpdateSandboxSortByClassifyId(prevChartInfo.SandboxClassifyId, prevChartInfo.Sort, prevChartInfo.SandboxId, updateSortStr)
  1538. } else {
  1539. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  1540. if nextChartInfo.Sort-prevChartInfo.Sort == 1 {
  1541. //变更兄弟节点的排序
  1542. updateSortStr := `sort + 1`
  1543. _ = sandbox.UpdateSandboxSortByClassifyId(prevChartInfo.SandboxClassifyId, prevChartInfo.Sort, prevChartInfo.SandboxId, updateSortStr)
  1544. }
  1545. }
  1546. }
  1547. sandboxInfo.Sort = prevChartInfo.Sort + 1
  1548. sandboxInfo.ModifyTime = time.Now()
  1549. updateCol = append(updateCol, "Sort", "ModifyTime")
  1550. } else {
  1551. firstClassify, err := sandbox.GetFirstSandboxByClassifyId(req.SandboxClassifyId)
  1552. if err != nil && err.Error() != utils.ErrNoRow() {
  1553. br.Msg = "移动失败"
  1554. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  1555. return
  1556. }
  1557. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  1558. if firstClassify != nil && firstClassify.Sort == 0 {
  1559. updateSortStr := ` sort + 1 `
  1560. _ = sandbox.UpdateSandboxSortByClassifyId(firstClassify.SandboxClassifyId, 0, firstClassify.SandboxId-1, updateSortStr)
  1561. }
  1562. sandboxInfo.Sort = 0 //那就是排在第一位
  1563. sandboxInfo.ModifyTime = time.Now()
  1564. updateCol = append(updateCol, "Sort", "ModifyTime")
  1565. }
  1566. //更新
  1567. if len(updateCol) > 0 {
  1568. err = sandboxInfo.Update(updateCol)
  1569. if err != nil {
  1570. br.Msg = "移动失败"
  1571. br.ErrMsg = "修改失败,Err:" + err.Error()
  1572. return
  1573. }
  1574. }
  1575. if err != nil {
  1576. br.Msg = "移动失败"
  1577. br.ErrMsg = "修改失败,Err:" + err.Error()
  1578. return
  1579. }
  1580. br.Ret = 200
  1581. br.Success = true
  1582. br.Msg = "移动成功"
  1583. }