classify.go 28 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "eta_gn/eta_api/models"
  5. "eta_gn/eta_api/models/system"
  6. "eta_gn/eta_api/models/system/response"
  7. "eta_gn/eta_api/services"
  8. "eta_gn/eta_api/utils"
  9. "fmt"
  10. "strconv"
  11. "strings"
  12. "time"
  13. )
  14. // 分类
  15. type ClassifyController struct {
  16. BaseAuthController
  17. }
  18. // Add
  19. // @Title 新增分类接口
  20. // @Description 新增分类
  21. // @Param request body models.ClassifyAddReq true "type json string"
  22. // @Success 200 新增成功
  23. // @router /add [post]
  24. func (this *ClassifyController) Add() {
  25. br := new(models.BaseResponse).Init()
  26. defer func() {
  27. if br.ErrMsg == "" {
  28. br.IsSendEmail = false
  29. }
  30. this.Data["json"] = br
  31. this.ServeJSON()
  32. }()
  33. var req models.ClassifyAddReq
  34. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  35. if err != nil {
  36. br.Msg = "参数解析异常!"
  37. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  38. return
  39. }
  40. // 获取系统菜单, 如果没有对应的字段的特殊处理项, 则忽略必填
  41. /*menus, e := system.GetSysMenuItemsByCondition(` AND hidden = 0`, make([]interface{}, 0), []string{}, ``)
  42. if e != nil {
  43. br.Msg = "保存失败"
  44. br.ErrMsg = "获取菜单列表失败, Err: " + e.Error()
  45. return
  46. }
  47. menuMap := make(map[string]bool)
  48. for _, m := range menus {
  49. if m.ButtonCode != "" {
  50. menuMap[m.ButtonCode] = true
  51. }
  52. }*/
  53. if req.ClassifyName == "" {
  54. br.Msg = "分类名称不可为空"
  55. return
  56. }
  57. if req.ClassifyType != utils.ReportTypeDefault && req.ClassifyType != utils.ReportTypePPT {
  58. br.Msg = "分类类型有误"
  59. br.ErrMsg = fmt.Sprintf("分类类型有误, %d", req.ClassifyType)
  60. return
  61. }
  62. if req.IsRemind == 1 {
  63. if req.RemindTime == "" {
  64. br.Msg = "请选择报告提醒时间"
  65. return
  66. }
  67. _, e := time.Parse("15:04", req.RemindTime)
  68. if e != nil {
  69. br.Msg = "提醒时间格式有误"
  70. br.ErrMsg = fmt.Sprintf("提醒时间格式有误, %s", req.RemindTime)
  71. return
  72. }
  73. }
  74. // 新增分类
  75. err, errMsg, isSentEmail := services.AddReportClassify(req.ClassifyName, req.ParentId, req.ClassifyType, req.IsRemind, req.RemindTime, req.VisibleUserIds)
  76. if err != nil {
  77. br.Msg = "添加失败"
  78. if errMsg != "" {
  79. br.Msg = errMsg
  80. }
  81. br.ErrMsg = "添加失败,Err:" + err.Error()
  82. br.IsSendEmail = isSentEmail
  83. return
  84. }
  85. br.Ret = 200
  86. br.Success = true
  87. br.Msg = "新增成功"
  88. }
  89. // CheckDeleteClassify
  90. // @Title 删除分类-检测接口
  91. // @Description 删除分类-信息检测,是否符合删除条件
  92. // @Param ClassifyId query int true "分类ID"
  93. // @Success 200 {object} models.CheckDeleteClassifyResp
  94. // @router /checkDeleteClassify [get]
  95. func (this *ClassifyController) CheckDeleteClassify() {
  96. br := new(models.BaseResponse).Init()
  97. defer func() {
  98. this.Data["json"] = br
  99. this.ServeJSON()
  100. }()
  101. classifyId, err := this.GetInt("ClassifyId")
  102. if classifyId <= 0 {
  103. br.Msg = "参数错误"
  104. return
  105. }
  106. classify, e := models.GetClassifyById(classifyId)
  107. if e != nil {
  108. if utils.IsErrNoRow(e) {
  109. br.Msg = "分类不存在,请刷新页面"
  110. return
  111. }
  112. br.Msg = "获取信息失败"
  113. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  114. return
  115. }
  116. resp := new(models.CheckDeleteClassifyResp)
  117. if classify == nil {
  118. br.Msg = "分类不存在"
  119. resp.Code = 1
  120. resp.Msg = "分类不存在"
  121. br.Data = resp
  122. br.Ret = 200
  123. br.Success = true
  124. return
  125. }
  126. if classify.ReportNum > 0 {
  127. resp.Code = 2
  128. resp.Msg = "该分类或子分类下有关联报告,不允许删除"
  129. br.Data = resp
  130. br.Ret = 200
  131. br.Msg = "该分类或子分类下有关联报告,不允许删除"
  132. br.Success = true
  133. return
  134. }
  135. //判断分类是否关联了报告
  136. //if classify.ParentId > 0 {
  137. // count, err := models.GetReportCountByClassifyId(classifyId)
  138. // if err != nil {
  139. // br.Msg = "获取信息失败"
  140. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  141. // return
  142. // }
  143. // if count > 0 {
  144. // resp.Code = 2
  145. // resp.Msg = "该分类有关联报告,不允许删除"
  146. // br.Data = resp
  147. // br.Ret = 200
  148. // br.Msg = "该分类有关联报告,不允许删除"
  149. // br.Success = true
  150. // return
  151. // }
  152. //} else {
  153. // subCount, err := models.GetClassifySubCountByClassifyId(classifyId)
  154. // if err != nil {
  155. // br.Msg = "获取信息失败"
  156. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  157. // return
  158. // }
  159. // if subCount > 0 {
  160. // resp.Code = 3
  161. // resp.Msg = "二级分类有关联报告,不允许删除"
  162. // br.Data = resp
  163. // br.Ret = 200
  164. // br.Msg = "二级分类有关联报告,不允许删除"
  165. // br.Success = true
  166. // return
  167. // }
  168. // subTotal, err := models.GetClassifySubCountByParentId(classifyId)
  169. // if err != nil {
  170. // br.Msg = "获取信息失败"
  171. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  172. // return
  173. // }
  174. // if subTotal > 0 {
  175. // resp.Code = 4
  176. // resp.Msg = "请先删除该分类下关联分类"
  177. // br.Data = resp
  178. // br.Ret = 200
  179. // br.Msg = "请先删除该分类下关联分类"
  180. // br.Success = true
  181. // return
  182. // }
  183. //}
  184. // 查询该分类是否关联了审批流
  185. //flowOb := new(report_approve.ReportApproveFlow)
  186. //flowCond := fmt.Sprintf(` AND %s = ? AND (%s = ? OR %s = ?)`, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId, report_approve.ReportApproveFlowCols.ClassifySecondId)
  187. //flowPars := make([]interface{}, 0)
  188. //flowPars = append(flowPars, report_approve.FlowReportTypeChinese, classifyId, classifyId)
  189. //flowCount, e := flowOb.GetCountByCondition(flowCond, flowPars)
  190. //if e != nil {
  191. // br.Msg = "检测失败"
  192. // br.ErrMsg = "获取关联审批流失败, Err: " + e.Error()
  193. // return
  194. //}
  195. //if flowCount > 0 {
  196. // resp.Code = 5
  197. // resp.Msg = "该分类关联审批流,不允许删除"
  198. // br.Data = resp
  199. // br.Ret = 200
  200. // br.Msg = resp.Msg
  201. // br.Success = true
  202. // return
  203. //}
  204. resp.Code = 0
  205. resp.Msg = "检测完成,可进行删除操作"
  206. br.Ret = 200
  207. br.Data = resp
  208. br.Success = true
  209. br.Msg = "检测成功"
  210. }
  211. // Delete
  212. // @Title 删除分类接口
  213. // @Description 删除分类
  214. // @Param request body models.DeleteClassifyReq true "type json string"
  215. // @Success 200 Ret=200,删除成功
  216. // @router /delete [post]
  217. func (this *ClassifyController) Delete() {
  218. br := new(models.BaseResponse).Init()
  219. defer func() {
  220. this.Data["json"] = br
  221. this.ServeJSON()
  222. }()
  223. var req models.DeleteClassifyReq
  224. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  225. if err != nil {
  226. br.Msg = "参数解析异常!"
  227. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  228. return
  229. }
  230. if req.ClassifyId <= 0 {
  231. br.Msg = "参数错误"
  232. return
  233. }
  234. item, e := models.GetClassifyById(req.ClassifyId)
  235. if e != nil {
  236. if utils.IsErrNoRow(e) {
  237. br.Ret = 200
  238. br.Success = true
  239. br.Msg = "删除成功"
  240. return
  241. }
  242. br.Msg = "删除失败"
  243. br.ErrMsg = fmt.Sprintf("获取分类失败, %v", e)
  244. return
  245. }
  246. // 删除校验(上级分类报告数为子分类总和)
  247. if item.ReportNum > 0 {
  248. br.Msg = "分类下或子分类下有关联报告, 不允许删除"
  249. return
  250. }
  251. var removeIds []int
  252. {
  253. list, e := models.GetAllClassify()
  254. if e != nil {
  255. br.Msg = "删除失败"
  256. br.ErrMsg = fmt.Sprintf("获取所有分类失败, %v", e)
  257. return
  258. }
  259. removeIds = services.GetClassifyChildIdsTreeRecursive(list, item.Id)
  260. }
  261. removeIds = append(removeIds, item.Id)
  262. if e = models.DeleteClassify(removeIds); e != nil {
  263. br.Msg = "删除失败"
  264. br.ErrMsg = fmt.Sprintf("删除分类及子分类失败, %v", e)
  265. return
  266. }
  267. br.Ret = 200
  268. br.Success = true
  269. br.Msg = "删除成功"
  270. }
  271. // Edit
  272. // @Title 修改分类接口
  273. // @Description 修改分类
  274. // @Param request body models.EditClassifyReq true "type json string"
  275. // @Success 200 Ret=200,修改成功
  276. // @router /edit [post]
  277. func (this *ClassifyController) Edit() {
  278. br := new(models.BaseResponse).Init()
  279. defer func() {
  280. this.Data["json"] = br
  281. this.ServeJSON()
  282. }()
  283. var req models.EditClassifyReq
  284. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  285. if err != nil {
  286. br.Msg = "参数解析异常!"
  287. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  288. return
  289. }
  290. if req.ClassifyId <= 0 {
  291. br.Msg = "参数错误"
  292. return
  293. }
  294. if req.ClassifyName == "" {
  295. br.Msg = "分类名称不可为空"
  296. return
  297. }
  298. if req.IsRemind == 1 {
  299. if req.RemindTime == "" {
  300. br.Msg = "请选择报告提醒时间"
  301. return
  302. }
  303. _, e := time.Parse("15:04", req.RemindTime)
  304. if e != nil {
  305. br.Msg = "提醒时间格式有误"
  306. br.ErrMsg = fmt.Sprintf("提醒时间格式有误, %s", req.RemindTime)
  307. return
  308. }
  309. }
  310. // 修改分类
  311. err, errMsg, isSentEmail := services.EditReportClassify(req.ClassifyId, req.ClassifyName, req.IsRemind, req.RemindTime, req.VisibleUserIds)
  312. if err != nil {
  313. br.Msg = "修改失败"
  314. if errMsg != "" {
  315. br.Msg = errMsg
  316. }
  317. br.ErrMsg = "修改失败,Err:" + err.Error()
  318. br.IsSendEmail = isSentEmail
  319. return
  320. }
  321. br.Ret = 200
  322. br.Success = true
  323. br.Msg = "修改成功"
  324. }
  325. // ParentClassify
  326. // @Title 获取父级分类接口
  327. // @Description 获取父级分类
  328. // @Success 200 {object} models.Classify
  329. // @router /parent [get]
  330. func (this *ClassifyController) ParentClassify() {
  331. br := new(models.BaseResponse).Init()
  332. defer func() {
  333. this.Data["json"] = br
  334. this.ServeJSON()
  335. }()
  336. items, err := models.GetAllClassify()
  337. if err != nil {
  338. br.Msg = "获取失败"
  339. br.ErrMsg = "获取失败,Err:" + err.Error()
  340. return
  341. }
  342. classifyIds := make([]int, 0)
  343. for i := range items {
  344. classifyIds = append(classifyIds, items[i].Id)
  345. }
  346. classifyLen := len(classifyIds)
  347. if classifyLen == 0 {
  348. br.Ret = 200
  349. br.Success = true
  350. br.Msg = "获取成功"
  351. return
  352. }
  353. // 获取一级分类-子目录列表
  354. menuListMap := make(map[int][]*models.ClassifyMenu, 0)
  355. var menuCond string
  356. var menuPars []interface{}
  357. menuCond += ` AND classify_id IN (` + utils.GetOrmInReplace(classifyLen) + `)`
  358. menuPars = append(menuPars, classifyIds)
  359. parentMenus, e := models.GetClassifyMenuList(menuCond, menuPars)
  360. if e != nil {
  361. br.Msg = "获取失败"
  362. br.ErrMsg = "获取一级分类子目录列表失败"
  363. return
  364. }
  365. for i := range parentMenus {
  366. if menuListMap[parentMenus[i].ClassifyId] == nil {
  367. menuListMap[parentMenus[i].ClassifyId] = make([]*models.ClassifyMenu, 0)
  368. }
  369. menuListMap[parentMenus[i].ClassifyId] = append(menuListMap[parentMenus[i].ClassifyId], parentMenus[i])
  370. }
  371. resp := make([]*models.ClassifyItem, 0)
  372. for i := range items {
  373. resp = append(resp, &models.ClassifyItem{
  374. Classify: *items[i],
  375. ClassifyMenuList: menuListMap[items[i].Id],
  376. })
  377. }
  378. resp = services.GetClassifyTreeRecursive(resp, 0)
  379. br.Data = resp
  380. br.Ret = 200
  381. br.Success = true
  382. br.Msg = "获取成功"
  383. }
  384. // @Title 根据id获取分类详情接口
  385. // @Description 根据id获取分类详情
  386. // @Param request body models.FindByIdClassifyReq true "type json string"
  387. // @Success 200 {object} models.Classify
  388. // @router /findById [get]
  389. func (this *ClassifyController) FindByIdClassify() {
  390. br := new(models.BaseResponse).Init()
  391. defer func() {
  392. this.Data["json"] = br
  393. this.ServeJSON()
  394. }()
  395. var req models.FindByIdClassifyReq
  396. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  397. if err != nil {
  398. br.Msg = "参数解析异常!"
  399. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  400. return
  401. }
  402. items, err := models.FindByIdClassify(req.ClassifyId)
  403. if err != nil {
  404. br.Msg = "获取失败"
  405. br.ErrMsg = "获取失败,Err:" + err.Error()
  406. return
  407. }
  408. br.Data = items
  409. br.Ret = 200
  410. br.Success = true
  411. br.Msg = "获取成功"
  412. }
  413. // ListClassify
  414. // @Title 获取分类列表
  415. // @Description 获取分类列表
  416. // @Param KeyWord query string true "检索关键词"
  417. // @Param ClassifyType query int false "分类类型:0-全部(默认);1-研报;2-PPT"
  418. // @Param Enabled query int false "启用状态:-1-全部(默认);0-禁用;1-启用"
  419. // @Success 200 {object} models.Classify
  420. // @router /list [get]
  421. func (this *ClassifyController) ListClassify() {
  422. br := new(models.BaseResponse).Init()
  423. defer func() {
  424. this.Data["json"] = br
  425. this.ServeJSON()
  426. }()
  427. classifyType, _ := this.GetInt("ClassifyType", 0)
  428. keyWord := this.GetString("KeyWord")
  429. reqEnabled, _ := this.GetInt("Enabled", -1)
  430. enabled := -1
  431. if reqEnabled == 1 {
  432. enabled = reqEnabled
  433. }
  434. //list, err := models.GetClassifyListByKeyword(keyWord, enabled, classifyType)
  435. //if err != nil {
  436. // br.Msg = "获取失败"
  437. // br.ErrMsg = "获取失败,Err:" + err.Error()
  438. // return
  439. //}
  440. //
  441. //if keyWord != `` {
  442. // idMap := make(map[int]bool)
  443. //
  444. // currParentClassifyIdList := make([]int, 0)
  445. // for _, v := range list {
  446. // idMap[v.Id] = true
  447. // if v.ParentId > 0 {
  448. // currParentClassifyIdList = append(currParentClassifyIdList, v.ParentId)
  449. // }
  450. // }
  451. //
  452. // findList := list
  453. // list = make([]*models.ClassifyList, 0)
  454. //
  455. // tmpList, tmpErr := services.GetParentClassifyListByParentIdList(currParentClassifyIdList)
  456. // if tmpErr != nil {
  457. // br.Msg = "获取失败"
  458. // br.ErrMsg = "获取上级分类信息失败,Err:" + tmpErr.Error()
  459. // return
  460. // }
  461. // for _, v := range tmpList {
  462. // if _, ok := idMap[v.Id]; !ok {
  463. // list = append(list, v)
  464. // }
  465. // }
  466. //
  467. // list = append(list, findList...)
  468. //}
  469. //
  470. //classifyIdList := make([]int, 0)
  471. //for i := range list {
  472. // classifyIdList = append(classifyIdList, list[i].Id)
  473. //}
  474. //parentIdLen := len(classifyIdList)
  475. //if parentIdLen == 0 {
  476. // resp := &models.ClassifyListResp{
  477. // List: list,
  478. // }
  479. // br.Data = resp
  480. // br.Ret = 200
  481. // br.Success = true
  482. // br.Msg = "获取成功"
  483. // return
  484. //}
  485. //
  486. //// 获取子目录列表
  487. //menuListMap := make(map[int][]*models.ClassifyMenu, 0)
  488. //var menuCond string
  489. //var menuPars []interface{}
  490. //menuCond += ` AND classify_id IN (` + utils.GetOrmInReplace(parentIdLen) + `)`
  491. //menuPars = append(menuPars, classifyIdList)
  492. //parentMenus, e := models.GetClassifyMenuList(menuCond, menuPars)
  493. //if e != nil {
  494. // br.Msg = "获取失败"
  495. // br.ErrMsg = "获取一级分类子目录列表失败"
  496. // return
  497. //}
  498. //for i := range parentMenus {
  499. // if menuListMap[parentMenus[i].ClassifyId] == nil {
  500. // menuListMap[parentMenus[i].ClassifyId] = make([]*models.ClassifyMenu, 0)
  501. // }
  502. // menuListMap[parentMenus[i].ClassifyId] = append(menuListMap[parentMenus[i].ClassifyId], parentMenus[i])
  503. //}
  504. //
  505. //// 分类与子目录关联
  506. //relateMap := make(map[int]int, 0)
  507. //{
  508. // var relateCond string
  509. // var relatePars []interface{}
  510. // relateCond += ` AND classify_id IN (` + utils.GetOrmInReplace(parentIdLen) + `)`
  511. // relatePars = append(relatePars, classifyIdList)
  512. // relates, e := models.GetClassifyMenuRelationList(relateCond, relatePars)
  513. // if e != nil {
  514. // br.Msg = "获取失败"
  515. // br.ErrMsg = "获取二级分类子目录关联失败, Err: " + e.Error()
  516. // return
  517. // }
  518. // for i := range relates {
  519. // relateMap[relates[i].ClassifyId] = relates[i].MenuId
  520. // }
  521. //}
  522. //
  523. //// 查询分类绑定的权限
  524. //permissionList, _ := models.GetAllPermissionMapping()
  525. //classifyPermissionMap := make(map[int][]int)
  526. //if len(permissionList) > 0 {
  527. // for _, v := range permissionList {
  528. // classifyPermissionMap[v.ClassifyId] = append(classifyPermissionMap[v.ClassifyId], v.ChartPermissionId)
  529. // }
  530. //}
  531. //// 遍历分类并绑定子目录和权限
  532. //for i, v := range list {
  533. // list[i].ClassifyMenuList = menuListMap[v.Id]
  534. //
  535. // list[i].ClassifyMenuId = relateMap[v.Id]
  536. // if permissionIds, ok := classifyPermissionMap[v.Id]; ok {
  537. // list[i].ChartPermissionIdList = permissionIds
  538. // }
  539. //}
  540. // 获取所有分类
  541. originList, err := models.GetClassifyListByKeyword("", enabled, 0)
  542. if err != nil {
  543. br.Msg = "获取失败"
  544. br.ErrMsg = "获取失败,Err:" + err.Error()
  545. return
  546. }
  547. list := originList
  548. visibleUsers, err := models.GetClassifyVisibleAll()
  549. if err != nil {
  550. br.Msg = "获取失败"
  551. br.ErrMsg = "获取失败,Err:" + err.Error()
  552. return
  553. }
  554. visibleUserMap := make(map[int][]int)
  555. for _, v := range visibleUsers {
  556. visibleUserMap[v.ClassifyId] = append(visibleUserMap[v.ClassifyId], v.AdminId)
  557. }
  558. for i, v := range list {
  559. list[i].VisiableUsers = visibleUserMap[v.Id]
  560. }
  561. // 指定分类类型(上级中的分类类型可能与最下层的不一致,但是要把上级也一起取出来, 这需求...=_=!)'
  562. reportMsgConfigMap := make(map[int][]int)
  563. if classifyType > 0 {
  564. list = make([]*models.ClassifyList, 0)
  565. // 先取出指定分类以及他对应的LevelPath中的所有ID
  566. classifyIds := make([]int, 0)
  567. for _, v := range originList {
  568. if v.ClassifyType != classifyType {
  569. continue
  570. }
  571. pathArr := strings.Split(v.LevelPath, ",")
  572. for _, p := range pathArr {
  573. id, _ := strconv.Atoi(p)
  574. if id <= 0 {
  575. continue
  576. }
  577. if utils.InArrayByInt(classifyIds, id) {
  578. continue
  579. }
  580. classifyIds = append(classifyIds, id)
  581. }
  582. }
  583. // 根据分类ID获取配置项
  584. reportMsgObj := new(models.ReportMessageConfig)
  585. configList, err := reportMsgObj.GetListByClassifyIdList(classifyIds)
  586. if err != nil {
  587. br.Msg = "获取失败"
  588. br.ErrMsg = "获取失败,Err:" + err.Error()
  589. return
  590. }
  591. for _, v := range configList {
  592. if v.NotifyUsers != "" {
  593. notifyUsers := strings.Split(v.NotifyUsers, ",")
  594. for _, user := range notifyUsers {
  595. userInt, _ := strconv.Atoi(user)
  596. reportMsgConfigMap[v.ClassifyId] = append(reportMsgConfigMap[v.ClassifyId], userInt)
  597. }
  598. }
  599. }
  600. // 过滤掉不在ID中的
  601. for _, v := range originList {
  602. if !utils.InArrayByInt(classifyIds, v.Id) {
  603. continue
  604. }
  605. if visible, ok := visibleUserMap[v.Id]; ok {
  606. if !utils.InArrayByInt(visible, this.SysUser.AdminId) {
  607. continue
  608. }
  609. }
  610. list = append(list, v)
  611. }
  612. }
  613. // 有关键词,那么按照上面的方法再筛一遍
  614. keyWord = strings.TrimSpace(keyWord)
  615. if keyWord != `` {
  616. classifyIds := make([]int, 0)
  617. for _, v := range list {
  618. if !strings.Contains(v.ClassifyName, keyWord) {
  619. continue
  620. }
  621. pathArr := strings.Split(v.LevelPath, ",")
  622. for _, p := range pathArr {
  623. id, _ := strconv.Atoi(p)
  624. if id <= 0 {
  625. continue
  626. }
  627. if utils.InArrayByInt(classifyIds, id) {
  628. continue
  629. }
  630. classifyIds = append(classifyIds, id)
  631. }
  632. }
  633. for _, v := range originList {
  634. if !utils.InArrayByInt(classifyIds, v.Id) {
  635. continue
  636. }
  637. if configList, ok := reportMsgConfigMap[v.Id]; ok {
  638. v.IceMsgUsers = configList
  639. }
  640. list = append(list, v)
  641. }
  642. }
  643. // 先将分类列表排序
  644. services.SortClassifyListBySortAndCreateTime(list)
  645. // 接着转换结构
  646. list = services.GetClassifyListTreeRecursive(list, 0)
  647. // 过滤掉没有子目录的分类
  648. list = services.RecursiveFilterNoChildTreeClassify(list)
  649. resp := new(models.ClassifyListResp)
  650. resp.List = list
  651. br.Data = resp
  652. br.Ret = 200
  653. br.Success = true
  654. br.Msg = "获取成功"
  655. }
  656. // ClassifyPermission
  657. // @Title 获取分类权限列表
  658. // @Description 获取分类权限列表
  659. // @Param ClassifyId query int true "分类id"
  660. // @Success 200 {object} []models.ChartPermissionSearchKeyWordMapping
  661. // @router /permission_list [get]
  662. func (this *ClassifyController) ClassifyPermission() {
  663. br := new(models.BaseResponse).Init()
  664. defer func() {
  665. this.Data["json"] = br
  666. this.ServeJSON()
  667. }()
  668. classifyId, _ := this.GetInt("ClassifyId")
  669. if classifyId <= 0 {
  670. br.Msg = "参数错误"
  671. return
  672. }
  673. //获取报告分类详情
  674. classifyInfo, err := models.GetClassifyById(classifyId)
  675. if err != nil {
  676. br.Msg = "获取分类信息失败"
  677. br.ErrMsg = "获取失败,Err:" + err.Error()
  678. return
  679. }
  680. //获取报告分类权限列表
  681. list, err := models.GetPermissionByClassifyId(classifyInfo.Id)
  682. if err != nil {
  683. br.Msg = "获取分类信息失败"
  684. br.ErrMsg = "获取失败,Err:" + err.Error()
  685. return
  686. }
  687. br.Data = list
  688. br.Ret = 200
  689. br.Success = true
  690. br.Msg = "获取成功"
  691. }
  692. // EditClassifyPermission
  693. // @Title 编辑分类权限
  694. // @Description 编辑分类权限
  695. // @Param ClassifyId query int true "分类id"
  696. // @Success 200 {object} models.EditClassifyPermissionReq
  697. // @router /permission/edit [post]
  698. func (this *ClassifyController) EditClassifyPermission() {
  699. br := new(models.BaseResponse).Init()
  700. defer func() {
  701. this.Data["json"] = br
  702. this.ServeJSON()
  703. }()
  704. var req models.EditClassifyPermissionReq
  705. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  706. if err != nil {
  707. br.Msg = "参数解析异常!"
  708. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  709. return
  710. }
  711. if req.ClassifyId <= 0 {
  712. br.Msg = "参数错误"
  713. return
  714. }
  715. if len(req.ChartPermissionIdList) <= 0 {
  716. br.Msg = "请选择权限"
  717. return
  718. }
  719. //获取报告分类详情
  720. classifyInfo, err := models.GetClassifyById(req.ClassifyId)
  721. if err != nil {
  722. br.Msg = "获取分类信息失败"
  723. br.ErrMsg = "获取失败,Err:" + err.Error()
  724. return
  725. }
  726. //获取报告分类权限列表
  727. err = models.EditChartPermissionSearchKeyWordMappingMulti(classifyInfo.ClassifyName, req.ChartPermissionIdList, req.ClassifyId)
  728. if err != nil {
  729. br.Msg = "修改分类权限失败"
  730. br.ErrMsg = "修改分类权限失败,Err:" + err.Error()
  731. return
  732. }
  733. go func() {
  734. _ = services.EditClassifyChartPermissionSync(classifyInfo.ClassifyName, req.ClassifyId)
  735. }()
  736. // 是关联电话会二级分类修改了权限, 同步关联报告电话会的分类
  737. //if classifyInfo.ParentId > 0 && classifyInfo.RelateTel == 1 {
  738. // go func() {
  739. // _ = yb.SyncClassifyAndFiccActivityType()
  740. // }()
  741. //}
  742. br.Ret = 200
  743. br.Success = true
  744. br.Msg = "修改成功"
  745. }
  746. // @Title 含电话会分类列表
  747. // @Description 含电话会分类列表
  748. // @Success 200 {object} models.Classify
  749. // @router /tel_list [get]
  750. func (this *ClassifyController) TelListClassify() {
  751. br := new(models.BaseResponse).Init()
  752. defer func() {
  753. this.Data["json"] = br
  754. this.ServeJSON()
  755. }()
  756. resp := make([]*models.SimpleClassifyList, 0)
  757. var condition, orderRule string
  758. var pars []interface{}
  759. telList, e := models.GetClassifyByCondition(condition, orderRule, pars)
  760. if e != nil {
  761. return
  762. }
  763. firstList := make([]*models.SimpleClassifyList, 0)
  764. secondList := make([]*models.SimpleClassifyList, 0)
  765. secondMap := make(map[int][]*models.SimpleClassifyList, 0)
  766. for i := range telList {
  767. if telList[i].ParentId == 0 {
  768. firstList = append(firstList, telList[i])
  769. } else {
  770. secondList = append(secondList, telList[i])
  771. secondMap[telList[i].ParentId] = append(secondMap[telList[i].ParentId], telList[i])
  772. }
  773. }
  774. for i := range firstList {
  775. firstList[i].Child = secondMap[firstList[i].Id]
  776. }
  777. resp = firstList
  778. br.Data = resp
  779. br.Ret = 200
  780. br.Success = true
  781. br.Msg = "获取成功"
  782. }
  783. // Move
  784. // @Title 移动分类接口
  785. // @Description 移动分类
  786. // @Param request body models.ClassifyMoveReq true "type json string"
  787. // @Success 200 新增成功
  788. // @router /move [post]
  789. func (this *ClassifyController) Move() {
  790. br := new(models.BaseResponse).Init()
  791. defer func() {
  792. this.Data["json"] = br
  793. this.ServeJSON()
  794. }()
  795. var req models.ClassifyMoveReq
  796. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  797. if err != nil {
  798. br.Msg = "参数解析异常!"
  799. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  800. return
  801. }
  802. if req.ClassifyId <= 0 {
  803. br.Msg = "请选择分类"
  804. return
  805. }
  806. e, msg := services.MoveReportClassify(req)
  807. if e != nil {
  808. br.Msg = msg
  809. br.ErrMsg = "移动分类失败, Err: " + e.Error()
  810. return
  811. }
  812. br.Ret = 200
  813. br.Success = true
  814. br.Msg = "操作成功"
  815. }
  816. // SetEnabled
  817. // @Title 启用/禁用分类接口
  818. // @Description 启用/禁用分类
  819. // @Param request body models.ClassifyMoveReq true "type json string"
  820. // @Success 200 新增成功
  821. // @router /enabled/set [post]
  822. func (this *ClassifyController) SetEnabled() {
  823. br := new(models.BaseResponse).Init()
  824. defer func() {
  825. this.Data["json"] = br
  826. this.ServeJSON()
  827. }()
  828. var req models.ClassifySetEnabledReq
  829. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  830. if err != nil {
  831. br.Msg = "参数解析异常!"
  832. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  833. return
  834. }
  835. if req.ClassifyId <= 0 {
  836. br.Msg = "请选择分类"
  837. return
  838. }
  839. if req.Enabled != 0 && req.Enabled != 1 {
  840. br.Msg = "请选择正确的启用禁用状态"
  841. return
  842. }
  843. item, err := models.GetClassifyById(req.ClassifyId)
  844. if err != nil {
  845. if utils.IsErrNoRow(err) {
  846. br.Msg = "分类不存在"
  847. return
  848. }
  849. br.Msg = "获取信息失败"
  850. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  851. return
  852. }
  853. if item == nil {
  854. br.Msg = "分类不存在"
  855. return
  856. }
  857. ob := new(models.Classify)
  858. //设置分类启用、禁用状态
  859. err = ob.SetEnabled(req.ClassifyId, req.Enabled)
  860. if err != nil {
  861. br.Msg = "操作失败"
  862. br.ErrMsg = "操作失败,Err:" + err.Error()
  863. return
  864. }
  865. br.Ret = 200
  866. br.Success = true
  867. br.Msg = "操作成功"
  868. }
  869. // ClassifyPermissionV2
  870. // @Title 获取权限设置基础信息
  871. // @Description 获取权限设置基础信息接口
  872. // @Param CompanyType query string true "客户类型:传空字符串或者不传为全部,'ficc','权益'"
  873. // @Param NoUpgrade query bool false "是否不展示升级权限,默认为 false"
  874. // @Success 200 {object} company.PermissionSetResp
  875. // @router /permission/list [get]
  876. func (this *ClassifyController) ClassifyPermissionV2() {
  877. br := new(models.BaseResponse).Init()
  878. defer func() {
  879. this.Data["json"] = br
  880. this.ServeJSON()
  881. }()
  882. sysUser := this.SysUser
  883. if sysUser == nil {
  884. br.Msg = "请登录"
  885. br.ErrMsg = "请登录,SysUser Is Empty"
  886. br.Ret = 408
  887. return
  888. }
  889. classifyId, _ := this.GetInt("ClassifyId")
  890. if classifyId <= 0 {
  891. br.Msg = "参数错误"
  892. return
  893. }
  894. resp := make([]*models.ChartPermissionItem, 0)
  895. // 拥有的品种ID列表
  896. permissionIdMap := make(map[int]bool)
  897. {
  898. //获取报告分类详情
  899. classifyInfo, err := models.GetClassifyById(classifyId)
  900. if err != nil {
  901. br.Msg = "获取分类信息失败"
  902. br.ErrMsg = "获取失败,Err:" + err.Error()
  903. return
  904. }
  905. //获取报告分类权限列表
  906. list, err := models.GetPermission(classifyInfo.Id)
  907. if err != nil {
  908. br.Msg = "获取分类信息失败"
  909. br.ErrMsg = "获取失败,Err:" + err.Error()
  910. return
  911. }
  912. for _, v := range list {
  913. permissionIdMap[v.ChartPermissionId] = true
  914. }
  915. }
  916. // 没有关联品种时,直接返回
  917. num := len(permissionIdMap)
  918. if num <= 0 {
  919. br.Ret = 200
  920. br.Success = true
  921. br.Msg = "获取成功"
  922. br.Data = resp
  923. return
  924. }
  925. cond := ` and product_id = ?`
  926. pars := make([]interface{}, 0)
  927. pars = append(pars, 1)
  928. list, e := services.GetChartPermissionList(cond, pars)
  929. if e != nil {
  930. br.Msg = "获取失败"
  931. br.ErrMsg = "获取品种列表失败, Err: " + e.Error()
  932. return
  933. }
  934. // 品种树
  935. childMap := make(map[int][]*models.ChartPermissionItem)
  936. tmpResp := make([]*models.ChartPermissionItem, 0)
  937. for _, v := range list {
  938. t := new(models.ChartPermissionItem)
  939. t.PermissionId = v.ChartPermissionId
  940. t.PermissionName = v.PermissionName
  941. t.ParentId = v.ParentId
  942. t.IsPublic = v.IsPublic
  943. t.Enabled = v.Enabled
  944. t.Sort = v.Sort
  945. t.CreateTime = v.CreatedTime.Format(utils.FormatDateTime)
  946. t.Child = make([]*models.ChartPermissionItem, 0)
  947. if v.ParentId == 0 {
  948. tmpResp = append(tmpResp, t)
  949. continue
  950. }
  951. if v.ParentId > 0 {
  952. if _, ok := permissionIdMap[v.ChartPermissionId]; ok {
  953. if childMap[v.ParentId] == nil {
  954. childMap[v.ParentId] = make([]*models.ChartPermissionItem, 0)
  955. }
  956. childMap[v.ParentId] = append(childMap[v.ParentId], t)
  957. }
  958. }
  959. }
  960. for _, r := range tmpResp {
  961. childList, ok := childMap[r.PermissionId]
  962. if !ok {
  963. continue
  964. }
  965. r.Child = childList
  966. resp = append(resp, r)
  967. }
  968. br.Ret = 200
  969. br.Success = true
  970. br.Msg = "获取成功"
  971. br.Data = resp
  972. }
  973. // AdminList
  974. // @Title 用户列表
  975. // @Description 用户列表
  976. // @Success 200 {object} company.PermissionSetResp
  977. // @router /user/list [get]
  978. func (this *ClassifyController) AdminList() {
  979. br := new(models.BaseResponse).Init()
  980. defer func() {
  981. this.Data["json"] = br
  982. this.ServeJSON()
  983. }()
  984. adminList, err := system.GetSysAdminListAll()
  985. if err != nil {
  986. br.Msg = "获取管理员列表失败"
  987. br.ErrMsg = "获取管理员列表失败, Err: " + err.Error()
  988. }
  989. list := make([]*response.AdminItem, 0)
  990. for _, v := range adminList {
  991. item := new(response.AdminItem)
  992. item.AdminId = v.AdminId
  993. item.AdminName = v.AdminName
  994. item.RealName = v.RealName
  995. list = append(list, item)
  996. }
  997. resp := new(response.AdminListResp)
  998. resp.List = list
  999. br.Data = resp
  1000. br.Ret = 200
  1001. br.Success = true
  1002. br.Msg = "获取成功"
  1003. }