classify.go 28 KB

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