classify.go 28 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078
  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. if iceMessageUsers, ok := reportMsgConfigMap[v.Id]; ok {
  611. v.IceMsgUsers = iceMessageUsers
  612. }
  613. list = append(list, v)
  614. }
  615. }
  616. // 有关键词,那么按照上面的方法再筛一遍
  617. keyWord = strings.TrimSpace(keyWord)
  618. if keyWord != `` {
  619. classifyIds := make([]int, 0)
  620. for _, v := range list {
  621. if !strings.Contains(v.ClassifyName, keyWord) {
  622. continue
  623. }
  624. pathArr := strings.Split(v.LevelPath, ",")
  625. for _, p := range pathArr {
  626. id, _ := strconv.Atoi(p)
  627. if id <= 0 {
  628. continue
  629. }
  630. if utils.InArrayByInt(classifyIds, id) {
  631. continue
  632. }
  633. classifyIds = append(classifyIds, id)
  634. }
  635. }
  636. for _, v := range originList {
  637. if !utils.InArrayByInt(classifyIds, v.Id) {
  638. continue
  639. }
  640. if configList, ok := reportMsgConfigMap[v.Id]; ok {
  641. v.IceMsgUsers = configList
  642. }
  643. list = append(list, v)
  644. }
  645. }
  646. // 先将分类列表排序
  647. services.SortClassifyListBySortAndCreateTime(list)
  648. // 接着转换结构
  649. list = services.GetClassifyListTreeRecursive(list, 0)
  650. // 过滤掉没有子目录的分类
  651. list = services.RecursiveFilterNoChildTreeClassify(list)
  652. resp := new(models.ClassifyListResp)
  653. resp.List = list
  654. br.Data = resp
  655. br.Ret = 200
  656. br.Success = true
  657. br.Msg = "获取成功"
  658. }
  659. // ClassifyPermission
  660. // @Title 获取分类权限列表
  661. // @Description 获取分类权限列表
  662. // @Param ClassifyId query int true "分类id"
  663. // @Success 200 {object} []models.ChartPermissionSearchKeyWordMapping
  664. // @router /permission_list [get]
  665. func (this *ClassifyController) ClassifyPermission() {
  666. br := new(models.BaseResponse).Init()
  667. defer func() {
  668. this.Data["json"] = br
  669. this.ServeJSON()
  670. }()
  671. classifyId, _ := this.GetInt("ClassifyId")
  672. if classifyId <= 0 {
  673. br.Msg = "参数错误"
  674. return
  675. }
  676. //获取报告分类详情
  677. classifyInfo, err := models.GetClassifyById(classifyId)
  678. if err != nil {
  679. br.Msg = "获取分类信息失败"
  680. br.ErrMsg = "获取失败,Err:" + err.Error()
  681. return
  682. }
  683. //获取报告分类权限列表
  684. list, err := models.GetPermissionByClassifyId(classifyInfo.Id)
  685. if err != nil {
  686. br.Msg = "获取分类信息失败"
  687. br.ErrMsg = "获取失败,Err:" + err.Error()
  688. return
  689. }
  690. br.Data = list
  691. br.Ret = 200
  692. br.Success = true
  693. br.Msg = "获取成功"
  694. }
  695. // EditClassifyPermission
  696. // @Title 编辑分类权限
  697. // @Description 编辑分类权限
  698. // @Param ClassifyId query int true "分类id"
  699. // @Success 200 {object} models.EditClassifyPermissionReq
  700. // @router /permission/edit [post]
  701. func (this *ClassifyController) EditClassifyPermission() {
  702. br := new(models.BaseResponse).Init()
  703. defer func() {
  704. this.Data["json"] = br
  705. this.ServeJSON()
  706. }()
  707. var req models.EditClassifyPermissionReq
  708. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  709. if err != nil {
  710. br.Msg = "参数解析异常!"
  711. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  712. return
  713. }
  714. if req.ClassifyId <= 0 {
  715. br.Msg = "参数错误"
  716. return
  717. }
  718. if len(req.ChartPermissionIdList) <= 0 {
  719. br.Msg = "请选择权限"
  720. return
  721. }
  722. //获取报告分类详情
  723. classifyInfo, err := models.GetClassifyById(req.ClassifyId)
  724. if err != nil {
  725. br.Msg = "获取分类信息失败"
  726. br.ErrMsg = "获取失败,Err:" + err.Error()
  727. return
  728. }
  729. //获取报告分类权限列表
  730. err = models.EditChartPermissionSearchKeyWordMappingMulti(classifyInfo.ClassifyName, req.ChartPermissionIdList, req.ClassifyId)
  731. if err != nil {
  732. br.Msg = "修改分类权限失败"
  733. br.ErrMsg = "修改分类权限失败,Err:" + err.Error()
  734. return
  735. }
  736. go func() {
  737. _ = services.EditClassifyChartPermissionSync(classifyInfo.ClassifyName, req.ClassifyId)
  738. }()
  739. // 是关联电话会二级分类修改了权限, 同步关联报告电话会的分类
  740. //if classifyInfo.ParentId > 0 && classifyInfo.RelateTel == 1 {
  741. // go func() {
  742. // _ = yb.SyncClassifyAndFiccActivityType()
  743. // }()
  744. //}
  745. br.Ret = 200
  746. br.Success = true
  747. br.Msg = "修改成功"
  748. }
  749. // @Title 含电话会分类列表
  750. // @Description 含电话会分类列表
  751. // @Success 200 {object} models.Classify
  752. // @router /tel_list [get]
  753. func (this *ClassifyController) TelListClassify() {
  754. br := new(models.BaseResponse).Init()
  755. defer func() {
  756. this.Data["json"] = br
  757. this.ServeJSON()
  758. }()
  759. resp := make([]*models.SimpleClassifyList, 0)
  760. var condition, orderRule string
  761. var pars []interface{}
  762. telList, e := models.GetClassifyByCondition(condition, orderRule, pars)
  763. if e != nil {
  764. return
  765. }
  766. firstList := make([]*models.SimpleClassifyList, 0)
  767. secondList := make([]*models.SimpleClassifyList, 0)
  768. secondMap := make(map[int][]*models.SimpleClassifyList, 0)
  769. for i := range telList {
  770. if telList[i].ParentId == 0 {
  771. firstList = append(firstList, telList[i])
  772. } else {
  773. secondList = append(secondList, telList[i])
  774. secondMap[telList[i].ParentId] = append(secondMap[telList[i].ParentId], telList[i])
  775. }
  776. }
  777. for i := range firstList {
  778. firstList[i].Child = secondMap[firstList[i].Id]
  779. }
  780. resp = firstList
  781. br.Data = resp
  782. br.Ret = 200
  783. br.Success = true
  784. br.Msg = "获取成功"
  785. }
  786. // Move
  787. // @Title 移动分类接口
  788. // @Description 移动分类
  789. // @Param request body models.ClassifyMoveReq true "type json string"
  790. // @Success 200 新增成功
  791. // @router /move [post]
  792. func (this *ClassifyController) Move() {
  793. br := new(models.BaseResponse).Init()
  794. defer func() {
  795. this.Data["json"] = br
  796. this.ServeJSON()
  797. }()
  798. var req models.ClassifyMoveReq
  799. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  800. if err != nil {
  801. br.Msg = "参数解析异常!"
  802. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  803. return
  804. }
  805. if req.ClassifyId <= 0 {
  806. br.Msg = "请选择分类"
  807. return
  808. }
  809. e, msg := services.MoveReportClassify(req)
  810. if e != nil {
  811. br.Msg = msg
  812. br.ErrMsg = "移动分类失败, Err: " + e.Error()
  813. return
  814. }
  815. br.Ret = 200
  816. br.Success = true
  817. br.Msg = "操作成功"
  818. }
  819. // SetEnabled
  820. // @Title 启用/禁用分类接口
  821. // @Description 启用/禁用分类
  822. // @Param request body models.ClassifyMoveReq true "type json string"
  823. // @Success 200 新增成功
  824. // @router /enabled/set [post]
  825. func (this *ClassifyController) SetEnabled() {
  826. br := new(models.BaseResponse).Init()
  827. defer func() {
  828. this.Data["json"] = br
  829. this.ServeJSON()
  830. }()
  831. var req models.ClassifySetEnabledReq
  832. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  833. if err != nil {
  834. br.Msg = "参数解析异常!"
  835. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  836. return
  837. }
  838. if req.ClassifyId <= 0 {
  839. br.Msg = "请选择分类"
  840. return
  841. }
  842. if req.Enabled != 0 && req.Enabled != 1 {
  843. br.Msg = "请选择正确的启用禁用状态"
  844. return
  845. }
  846. item, err := models.GetClassifyById(req.ClassifyId)
  847. if err != nil {
  848. if utils.IsErrNoRow(err) {
  849. br.Msg = "分类不存在"
  850. return
  851. }
  852. br.Msg = "获取信息失败"
  853. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  854. return
  855. }
  856. if item == nil {
  857. br.Msg = "分类不存在"
  858. return
  859. }
  860. ob := new(models.Classify)
  861. //设置分类启用、禁用状态
  862. err = ob.SetEnabled(req.ClassifyId, req.Enabled)
  863. if err != nil {
  864. br.Msg = "操作失败"
  865. br.ErrMsg = "操作失败,Err:" + err.Error()
  866. return
  867. }
  868. br.Ret = 200
  869. br.Success = true
  870. br.Msg = "操作成功"
  871. }
  872. // ClassifyPermissionV2
  873. // @Title 获取权限设置基础信息
  874. // @Description 获取权限设置基础信息接口
  875. // @Param CompanyType query string true "客户类型:传空字符串或者不传为全部,'ficc','权益'"
  876. // @Param NoUpgrade query bool false "是否不展示升级权限,默认为 false"
  877. // @Success 200 {object} company.PermissionSetResp
  878. // @router /permission/list [get]
  879. func (this *ClassifyController) ClassifyPermissionV2() {
  880. br := new(models.BaseResponse).Init()
  881. defer func() {
  882. this.Data["json"] = br
  883. this.ServeJSON()
  884. }()
  885. sysUser := this.SysUser
  886. if sysUser == nil {
  887. br.Msg = "请登录"
  888. br.ErrMsg = "请登录,SysUser Is Empty"
  889. br.Ret = 408
  890. return
  891. }
  892. classifyId, _ := this.GetInt("ClassifyId")
  893. if classifyId <= 0 {
  894. br.Msg = "参数错误"
  895. return
  896. }
  897. resp := make([]*models.ChartPermissionItem, 0)
  898. // 拥有的品种ID列表
  899. permissionIdMap := make(map[int]bool)
  900. {
  901. //获取报告分类详情
  902. classifyInfo, err := models.GetClassifyById(classifyId)
  903. if err != nil {
  904. br.Msg = "获取分类信息失败"
  905. br.ErrMsg = "获取失败,Err:" + err.Error()
  906. return
  907. }
  908. //获取报告分类权限列表
  909. list, err := models.GetPermission(classifyInfo.Id)
  910. if err != nil {
  911. br.Msg = "获取分类信息失败"
  912. br.ErrMsg = "获取失败,Err:" + err.Error()
  913. return
  914. }
  915. for _, v := range list {
  916. permissionIdMap[v.ChartPermissionId] = true
  917. }
  918. }
  919. // 没有关联品种时,直接返回
  920. num := len(permissionIdMap)
  921. if num <= 0 {
  922. br.Ret = 200
  923. br.Success = true
  924. br.Msg = "获取成功"
  925. br.Data = resp
  926. return
  927. }
  928. cond := ` and product_id = ?`
  929. pars := make([]interface{}, 0)
  930. pars = append(pars, 1)
  931. list, e := services.GetChartPermissionList(cond, pars)
  932. if e != nil {
  933. br.Msg = "获取失败"
  934. br.ErrMsg = "获取品种列表失败, Err: " + e.Error()
  935. return
  936. }
  937. // 品种树
  938. childMap := make(map[int][]*models.ChartPermissionItem)
  939. tmpResp := make([]*models.ChartPermissionItem, 0)
  940. for _, v := range list {
  941. t := new(models.ChartPermissionItem)
  942. t.PermissionId = v.ChartPermissionId
  943. t.PermissionName = v.PermissionName
  944. t.ParentId = v.ParentId
  945. t.IsPublic = v.IsPublic
  946. t.Enabled = v.Enabled
  947. t.Sort = v.Sort
  948. t.CreateTime = v.CreatedTime.Format(utils.FormatDateTime)
  949. t.Child = make([]*models.ChartPermissionItem, 0)
  950. if v.ParentId == 0 {
  951. tmpResp = append(tmpResp, t)
  952. continue
  953. }
  954. if v.ParentId > 0 {
  955. if _, ok := permissionIdMap[v.ChartPermissionId]; ok {
  956. if childMap[v.ParentId] == nil {
  957. childMap[v.ParentId] = make([]*models.ChartPermissionItem, 0)
  958. }
  959. childMap[v.ParentId] = append(childMap[v.ParentId], t)
  960. }
  961. }
  962. }
  963. for _, r := range tmpResp {
  964. childList, ok := childMap[r.PermissionId]
  965. if !ok {
  966. continue
  967. }
  968. r.Child = childList
  969. resp = append(resp, r)
  970. }
  971. br.Ret = 200
  972. br.Success = true
  973. br.Msg = "获取成功"
  974. br.Data = resp
  975. }
  976. // AdminList
  977. // @Title 用户列表
  978. // @Description 用户列表
  979. // @Success 200 {object} company.PermissionSetResp
  980. // @router /user/list [get]
  981. func (this *ClassifyController) AdminList() {
  982. br := new(models.BaseResponse).Init()
  983. defer func() {
  984. this.Data["json"] = br
  985. this.ServeJSON()
  986. }()
  987. adminList, err := system.GetSysAdminListAll()
  988. if err != nil {
  989. br.Msg = "获取管理员列表失败"
  990. br.ErrMsg = "获取管理员列表失败, Err: " + err.Error()
  991. }
  992. list := make([]*response.AdminItem, 0)
  993. for _, v := range adminList {
  994. item := new(response.AdminItem)
  995. item.AdminId = v.AdminId
  996. item.AdminName = v.AdminName
  997. item.RealName = v.RealName
  998. list = append(list, item)
  999. }
  1000. resp := new(response.AdminListResp)
  1001. resp.List = list
  1002. br.Data = resp
  1003. br.Ret = 200
  1004. br.Success = true
  1005. br.Msg = "获取成功"
  1006. }