report_v2.go 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/models"
  5. "eta/eta_api/models/report"
  6. "eta/eta_api/models/report_approve"
  7. "eta/eta_api/models/system"
  8. "eta/eta_api/services"
  9. "eta/eta_api/services/alarm_msg"
  10. "eta/eta_api/services/data"
  11. "eta/eta_api/utils"
  12. "fmt"
  13. "github.com/rdlucklib/rdluck_tools/paging"
  14. "html"
  15. "strconv"
  16. "time"
  17. )
  18. // TODO 报告的权限校验(跳过列表页,直接进入详情页,不管是普通报告还是章节报告)
  19. // ListReport
  20. // @Title 获取报告列表接口
  21. // @Description 获取报告列表
  22. // @Param PageSize query int true "每页数据条数"
  23. // @Param CurrentIndex query int true "当前页页码,从1开始"
  24. // @Param TimeType query string true "筛选的时间类别:publish_time(发布时间),modify_time(更新时间);approve_time(审批时间)"
  25. // @Param StartDate query string true "开始时间"
  26. // @Param EndDate query string true "结束时间"
  27. // @Param Frequency query string true "频度"
  28. // @Param ClassifyIdFirst query int true "一级分类id"
  29. // @Param ClassifyIdSecond query int true "二级分类id"
  30. // @Param ClassifyIdThird query int true "三级分类id"
  31. // @Param State query int true "状态"
  32. // @Param KeyWord query string true "搜索关键词"
  33. // @Param PublishSort query string true "desc:降序,asc 升序(预留)"
  34. // @Param FilterReportType query string true "筛选报告类型,1:公共研报,2:共享研报,3:我的研报"
  35. // @Success 200 {object} models.ReportListResp
  36. // @router /list [get]
  37. func (this *ReportController) ListReport() {
  38. br := new(models.BaseResponse).Init()
  39. defer func() {
  40. this.Data["json"] = br
  41. this.ServeJSON()
  42. }()
  43. pageSize, _ := this.GetInt("PageSize")
  44. currentIndex, _ := this.GetInt("CurrentIndex")
  45. timeType := this.GetString("TimeType")
  46. startDate := this.GetString("StartDate")
  47. endDate := this.GetString("EndDate")
  48. frequency := this.GetString("Frequency")
  49. classifyIdFirst, _ := this.GetInt("ClassifyIdFirst", 0)
  50. classifyIdSecond, _ := this.GetInt("ClassifyIdSecond", 0)
  51. classifyIdThird, _ := this.GetInt("ClassifyIdThird", 0)
  52. state, _ := this.GetInt("State")
  53. keyWord := this.GetString("KeyWord")
  54. msgIsSend, _ := this.GetInt("MsgIsSend")
  55. filterReportType, _ := this.GetInt("FilterReportType", 1)
  56. var startSize int
  57. if pageSize <= 0 {
  58. pageSize = utils.PageSize20
  59. }
  60. if currentIndex <= 0 {
  61. currentIndex = 1
  62. }
  63. startSize = utils.StartIndex(currentIndex, pageSize)
  64. if timeType == "" {
  65. timeType = "publish_time"
  66. }
  67. if timeType != "publish_time" && timeType != "modify_time" && timeType != "approve_time" {
  68. br.Msg = "请选择正确的时间"
  69. br.ErrMsg = "请选择正确的时间"
  70. return
  71. }
  72. var condition string
  73. var pars []interface{}
  74. if keyWord != "" {
  75. condition += ` AND (a.title LIKE ? OR a.admin_real_name LIKE ? ) `
  76. pars = utils.GetLikeKeywordPars(pars, keyWord, 2)
  77. }
  78. if startDate != "" {
  79. condition += ` AND a.` + timeType + ` >= ? `
  80. pars = append(pars, startDate)
  81. }
  82. if endDate != "" {
  83. condition += ` AND a.` + timeType + ` <= ? `
  84. pars = append(pars, endDate)
  85. }
  86. if frequency != "" {
  87. condition += ` AND a.frequency = ? `
  88. pars = append(pars, frequency)
  89. }
  90. if classifyIdFirst > 0 {
  91. condition += ` AND a.classify_id_first = ? `
  92. pars = append(pars, classifyIdFirst)
  93. }
  94. if classifyIdSecond > 0 {
  95. condition += ` AND a.classify_id_second = ? `
  96. pars = append(pars, classifyIdSecond)
  97. }
  98. if classifyIdThird > 0 {
  99. condition += ` AND a.classify_id_third = ? `
  100. pars = append(pars, classifyIdSecond)
  101. }
  102. if state > 0 {
  103. condition += ` AND a.state = ? `
  104. pars = append(pars, state)
  105. }
  106. // 消息是否已推送 1-未推送; 2-已推送
  107. if msgIsSend == 1 {
  108. condition += ` AND (a.msg_is_send = 0 OR a.ths_msg_is_send = 0) `
  109. }
  110. if msgIsSend == 2 {
  111. condition += ` AND a.msg_is_send = 1 AND a.ths_msg_is_send = 1 `
  112. }
  113. var err error
  114. var total int
  115. var list []*models.ReportList
  116. switch filterReportType {
  117. // 筛选报告类型,1:公共研报,2:共享研报,3:我的研报
  118. case 1:
  119. condition += ` AND a.is_public_publish = ? `
  120. //condition += ` AND a.state in (2,6) `
  121. pars = append(pars, 1)
  122. case 3:
  123. condition += ` AND a.admin_id = ? `
  124. pars = append(pars, this.SysUser.AdminId)
  125. case 2:
  126. condition += ` AND (a.admin_id = ? or b.admin_id = ?) `
  127. pars = append(pars, this.SysUser.AdminId, this.SysUser.AdminId)
  128. }
  129. // 共享报告需要连表查询,所以需要单独写
  130. if filterReportType == 2 {
  131. total, err = models.GetReportListCountByGrant(condition, pars)
  132. if err != nil {
  133. br.Msg = "获取失败"
  134. br.ErrMsg = "获取失败,Err:" + err.Error()
  135. return
  136. }
  137. list, err = models.GetReportListByGrant(condition, pars, startSize, pageSize)
  138. if err != nil {
  139. br.Msg = "获取失败"
  140. br.ErrMsg = "获取失败,Err:" + err.Error()
  141. return
  142. }
  143. } else {
  144. total, err = models.GetReportListCountV1(condition, pars)
  145. if err != nil {
  146. br.Msg = "获取失败"
  147. br.ErrMsg = "获取失败,Err:" + err.Error()
  148. return
  149. }
  150. list, err = models.GetReportListV1(condition, pars, startSize, pageSize)
  151. if err != nil {
  152. br.Msg = "获取失败"
  153. br.ErrMsg = "获取失败,Err:" + err.Error()
  154. return
  155. }
  156. }
  157. listLen := len(list)
  158. if listLen > 0 {
  159. pvMap := make(map[int]int)
  160. uvMap := make(map[int]int)
  161. reportIdArr := make([]string, 0)
  162. syncReportIdArr := make([]string, 0) // 同步过来的报告IDs
  163. oldAndNewReportIdMap := make(map[int]int) // 旧报告和新报告的id对应关系
  164. for i := 0; i < listLen; i++ {
  165. reportIdArr = append(reportIdArr, strconv.Itoa(list[i].Id))
  166. if list[i].OldReportId > 0 {
  167. syncReportIdArr = append(syncReportIdArr, strconv.Itoa(list[i].OldReportId))
  168. oldAndNewReportIdMap[list[i].OldReportId] = list[i].Id
  169. }
  170. pvMap[list[i].Id] = list[i].Pv
  171. uvMap[list[i].Id] = list[i].Uv
  172. }
  173. // 当下报告的pv,uv
  174. if len(reportIdArr) > 0 {
  175. pvList, e := models.GetReportPvUvByReportIdList(reportIdArr)
  176. if e != nil {
  177. br.Msg = "获取失败"
  178. br.ErrMsg = "获取同步报告对应的PV、UV失败, Err: " + e.Error()
  179. return
  180. }
  181. for _, v := range pvList {
  182. pv := pvMap[v.ReportId]
  183. uv := uvMap[v.ReportId]
  184. pvMap[v.ReportId] = v.PvTotal + pv
  185. uvMap[v.ReportId] = v.UvTotal + uv
  186. }
  187. }
  188. //reportIds := strings.Join(reportIdArr, ",")
  189. //syncReportIds := strings.Join(syncReportIdArr, ",")
  190. // 查询同步过来的报告对应的老报告PV+UV
  191. if len(syncReportIdArr) > 0 {
  192. puvList, e := models.GetPUVByResearchReportIds(syncReportIdArr)
  193. if e != nil {
  194. br.Msg = "获取失败"
  195. br.ErrMsg = "获取同步报告对应的PV、UV失败, Err: " + e.Error()
  196. return
  197. }
  198. puvLen := len(puvList)
  199. for i := 0; i < puvLen; i++ {
  200. newReportId, ok := oldAndNewReportIdMap[puvList[i].ResearchReportId]
  201. if ok {
  202. pv := pvMap[newReportId]
  203. uv := uvMap[newReportId]
  204. pvMap[newReportId] = puvList[i].Pv + pv
  205. uvMap[newReportId] = puvList[i].Uv + uv
  206. }
  207. }
  208. }
  209. // 晨周报音频列表
  210. videoList, err := models.GetReportChapterVideoListByReportIds(reportIdArr)
  211. if err != nil {
  212. br.Msg = "获取失败"
  213. br.ErrMsg = "获取报告音频文件失败,Err:" + err.Error()
  214. return
  215. }
  216. for i := 0; i < listLen; i++ {
  217. list[i].Content = html.UnescapeString(list[i].Content)
  218. list[i].ContentSub = html.UnescapeString(list[i].ContentSub)
  219. // 除周报外其余报告均可推送客群
  220. list[i].NeedThsMsg = 1
  221. //if list[i].HasChapter == 1 && list[i].ChapterType == utils.REPORT_TYPE_WEEK {
  222. // list[i].NeedThsMsg = 0
  223. //}
  224. chapterList := make([]*models.ReportChapterVideoList, 0)
  225. for ii := 0; ii < len(videoList); ii++ {
  226. if list[i].Id == videoList[ii].ReportId {
  227. chapterList = append(chapterList, videoList[ii])
  228. }
  229. }
  230. list[i].ChapterVideoList = chapterList
  231. list[i].Pv += pvMap[list[i].Id]
  232. list[i].Uv += uvMap[list[i].Id]
  233. }
  234. }
  235. for _, item := range list {
  236. /*key := fmt.Sprint(`crm:report:edit:`, item.Id)
  237. opUserId, _ := utils.Rc.RedisInt(key)
  238. //如果当前没有人操作,获取当前操作人是本人,那么编辑按钮可用
  239. if opUserId <= 0 || (opUserId == this.SysUser.AdminId) || item.ClassifyNameFirst == "周报" || item.ClassifyNameFirst == "晨报" {
  240. item.CanEdit = true
  241. } else {
  242. adminInfo, errAdmin := system.GetSysUserById(opUserId)
  243. if errAdmin != nil {
  244. br.Msg = "获取失败"
  245. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  246. return
  247. }
  248. item.Editor = adminInfo.RealName
  249. }*/
  250. if item.HasChapter == 1 {
  251. item.CanEdit = true
  252. continue
  253. }
  254. markStatus, err := services.UpdateReportEditMark(item.Id, 0, this.SysUser.AdminId, 2, this.SysUser.RealName, this.Lang)
  255. if err != nil {
  256. br.Msg = "查询标记状态失败"
  257. br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  258. return
  259. }
  260. if markStatus.Status == 0 {
  261. item.CanEdit = true
  262. } else {
  263. item.Editor = markStatus.Editor
  264. }
  265. }
  266. page := paging.GetPaging(currentIndex, pageSize, total)
  267. resp := new(models.ReportListResp)
  268. resp.Paging = page
  269. resp.List = list
  270. br.Ret = 200
  271. br.Success = true
  272. br.Msg = "获取成功"
  273. br.Data = resp
  274. }
  275. // Add
  276. // @Title 新增报告接口
  277. // @Description 新增报告(不区分报告类型)
  278. // @Param request body models.AddReq true "type json string"
  279. // @Success 200 {object} models.AddResp
  280. // @router /add [post]
  281. func (this *ReportController) Add() {
  282. br := new(models.BaseResponse).Init()
  283. defer func() {
  284. this.Data["json"] = br
  285. this.ServeJSON()
  286. }()
  287. sysUser := this.SysUser
  288. if sysUser == nil {
  289. br.Msg = "请登录"
  290. br.ErrMsg = "请登录,SysUser Is Empty"
  291. br.Ret = 408
  292. return
  293. }
  294. var req models.AddReq
  295. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  296. if err != nil {
  297. br.Msg = "参数解析异常!"
  298. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  299. return
  300. }
  301. if req.Title == `` {
  302. br.Msg = "标题不能为空"
  303. br.ErrMsg = "标题不能为空"
  304. br.IsSendEmail = false
  305. return
  306. }
  307. if req.ClassifyIdFirst <= 0 {
  308. br.Msg = "分类必填"
  309. br.ErrMsg = "分类必填"
  310. br.IsSendEmail = false
  311. return
  312. }
  313. var contentSub string
  314. if req.Content != "" {
  315. e := utils.ContentXssCheck(req.Content)
  316. if e != nil {
  317. br.Msg = "存在非法标签"
  318. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  319. return
  320. }
  321. content, e := services.FilterReportContentBr(req.Content)
  322. if e != nil {
  323. br.Msg = "内容去除前后空格失败"
  324. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  325. return
  326. }
  327. req.Content = content
  328. contentSub, err = services.GetReportContentSub(req.Content)
  329. if err != nil {
  330. go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+err.Error(), 3)
  331. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  332. }
  333. }
  334. // 报告期数
  335. maxStage, err := models.GetReportStage(req.ClassifyIdFirst, req.ClassifyIdSecond, req.ClassifyIdThird)
  336. if err != nil {
  337. br.Msg = "期数获取失败!"
  338. br.ErrMsg = "期数获取失败,Err:" + err.Error()
  339. return
  340. }
  341. // 根据审批开关及审批流判断当前报告状态
  342. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeChinese, req.ClassifyIdFirst, req.ClassifyIdSecond, models.ReportOperateAdd)
  343. if e != nil {
  344. br.Msg = "操作失败"
  345. br.ErrMsg = "校验报告当前状态失败, Err: " + e.Error()
  346. return
  347. }
  348. item := new(models.Report)
  349. item.AddType = req.AddType
  350. item.ReportVersion = 2
  351. item.ClassifyIdFirst = req.ClassifyIdFirst
  352. item.ClassifyNameFirst = req.ClassifyNameFirst
  353. item.ClassifyIdSecond = req.ClassifyIdSecond
  354. item.ClassifyNameSecond = req.ClassifyNameSecond
  355. item.Title = req.Title
  356. item.Abstract = req.Abstract
  357. item.Author = req.Author
  358. item.Frequency = req.Frequency
  359. item.State = state
  360. item.Content = html.EscapeString(req.Content)
  361. item.Stage = maxStage + 1
  362. item.ContentSub = html.EscapeString(contentSub)
  363. item.CreateTime = req.CreateTime
  364. item.ModifyTime = time.Now()
  365. item.ReportVersion = req.ReportVersion
  366. item.AdminId = sysUser.AdminId
  367. item.AdminRealName = sysUser.RealName
  368. item.ClassifyIdThird = req.ClassifyIdThird
  369. item.ClassifyNameThird = req.ClassifyNameThird
  370. // 产品要求,如果是多人协作,那么就是章节类型的报告
  371. if req.CollaborateType == 2 {
  372. item.HasChapter = 1
  373. item.ChapterType = ""
  374. }
  375. item.LastModifyAdminId = sysUser.AdminId
  376. item.LastModifyAdminName = sysUser.RealName
  377. item.ContentModifyTime = time.Now()
  378. item.NeedSplice = 0
  379. item.ContentStruct = html.EscapeString(req.ContentStruct)
  380. item.HeadImg = req.HeadImg
  381. item.EndImg = req.EndImg
  382. item.CanvasColor = req.CanvasColor
  383. item.HeadResourceId = req.HeadResourceId
  384. item.EndResourceId = req.EndResourceId
  385. item.CollaborateType = req.CollaborateType
  386. item.ReportLayout = req.ReportLayout
  387. item.IsPublicPublish = req.IsPublicPublish
  388. item.ReportCreateTime = time.Now()
  389. err, errMsg := services.AddReportAndChapter(item, req.InheritReportId, req.GrantAdminIdList)
  390. if err != nil {
  391. br.Msg = "保存失败"
  392. if errMsg != "" {
  393. br.Msg = errMsg
  394. }
  395. br.ErrMsg = "保存失败,Err:" + err.Error()
  396. return
  397. }
  398. recordItem := &models.ReportStateRecord{
  399. ReportId: item.Id,
  400. ReportType: 1,
  401. State: 1,
  402. AdminId: this.SysUser.AdminId,
  403. AdminName: this.SysUser.AdminName,
  404. CreateTime: time.Now(),
  405. }
  406. go func() {
  407. _, _ = models.AddReportStateRecord(recordItem)
  408. }()
  409. resp := new(models.AddResp)
  410. resp.ReportId = int64(item.Id)
  411. resp.ReportCode = item.ReportCode
  412. br.Ret = 200
  413. br.Success = true
  414. br.Msg = "保存成功"
  415. br.Data = resp
  416. }
  417. // Edit
  418. // @Title 编辑报告基础信息接口
  419. // @Description 编辑报告基础信息(不区分报告类型)
  420. // @Param request body models.EditReq true "type json string"
  421. // @Success 200 {object} models.EditResp
  422. // @router /edit [post]
  423. func (this *ReportController) Edit() {
  424. br := new(models.BaseResponse).Init()
  425. defer func() {
  426. this.Data["json"] = br
  427. this.ServeJSON()
  428. }()
  429. sysUser := this.SysUser
  430. if sysUser == nil {
  431. br.Msg = "请登录"
  432. br.ErrMsg = "请登录,SysUser Is Empty"
  433. br.Ret = 408
  434. return
  435. }
  436. var req models.EditReq
  437. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  438. if err != nil {
  439. br.Msg = "参数解析异常!"
  440. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  441. return
  442. }
  443. //if req.Content == "" {
  444. // br.Msg = "报告内容不能为空"
  445. // return
  446. //}
  447. //更新标记key
  448. markStatus, err := services.UpdateReportEditMark(int(req.ReportId), 0, sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  449. if err != nil {
  450. br.Msg = err.Error()
  451. return
  452. }
  453. if markStatus.Status == 1 {
  454. br.Msg = markStatus.Msg
  455. //br.Ret = 202 //202 服务器已接受请求,但尚未处理。
  456. return
  457. }
  458. reportInfo, e := models.GetReportByReportId(int(req.ReportId))
  459. if e != nil {
  460. if e.Error() == utils.ErrNoRow() {
  461. br.Msg = "报告已被删除, 请刷新页面"
  462. return
  463. }
  464. br.Msg = "操作失败"
  465. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  466. return
  467. }
  468. if reportInfo.State == models.ReportStatePublished || reportInfo.State == models.ReportStatePass {
  469. br.Msg = "该报告已发布,不允许编辑"
  470. br.ErrMsg = "该报告已发布,不允许编辑"
  471. return
  472. }
  473. // 编辑报告信息
  474. err, errMsg := services.EditReport(reportInfo, req, sysUser)
  475. if err != nil {
  476. br.Msg = "保存失败"
  477. if errMsg != "" {
  478. br.Msg = errMsg
  479. }
  480. br.ErrMsg = "保存失败,Err:" + err.Error()
  481. return
  482. }
  483. reportCode := utils.MD5(strconv.Itoa(int(req.ReportId)))
  484. resp := new(models.EditResp)
  485. resp.ReportId = req.ReportId
  486. resp.ReportCode = reportCode
  487. br.Ret = 200
  488. br.Success = true
  489. br.Msg = "保存成功"
  490. br.Data = resp
  491. }
  492. // Detail
  493. // @Title 获取报告详情接口
  494. // @Description 获取报告详情
  495. // @Param request body models.ReportDetailReq true "type json string"
  496. // @Success 200 {object} models.Report
  497. // @router /detail [get]
  498. func (this *ReportController) Detail() {
  499. br := new(models.BaseResponse).Init()
  500. defer func() {
  501. this.Data["json"] = br
  502. this.ServeJSON()
  503. }()
  504. /*var req models.ReportDetailReq
  505. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  506. if err != nil {
  507. br.Msg = "参数解析异常!"
  508. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  509. return
  510. }
  511. if req.ReportId <= 0 {
  512. br.Msg = "参数错误"
  513. return
  514. }*/
  515. reportId, err := this.GetInt("ReportId")
  516. if err != nil {
  517. br.Msg = "获取参数失败!"
  518. br.ErrMsg = "获取参数失败,Err:" + err.Error()
  519. return
  520. }
  521. if reportId <= 0 {
  522. br.Msg = "参数错误"
  523. return
  524. }
  525. item, err := models.GetReportById(reportId)
  526. if err != nil {
  527. if err.Error() == utils.ErrNoRow() {
  528. br.Msg = "报告已被删除"
  529. return
  530. }
  531. br.Msg = "获取失败"
  532. br.ErrMsg = "获取失败,Err:" + err.Error()
  533. return
  534. }
  535. chapterList := make([]*models.ReportChapter, 0)
  536. if item.HasChapter == 1 {
  537. // 获取章节内容
  538. tmpChapterList, err := models.GetPublishedChapterListByReportId(item.Id)
  539. if err != nil {
  540. br.Msg = "获取失败"
  541. br.ErrMsg = "获取晨/周报章节列表失败, Err: " + err.Error()
  542. return
  543. }
  544. // TODO 更新规则
  545. if len(tmpChapterList) > 0 {
  546. // 获取更新规则
  547. researchType := tmpChapterList[0].ReportType
  548. chapterTypeList, tmpErr := models.GetAllReportChapterTypeListByResearchType(researchType)
  549. if tmpErr != nil {
  550. br.Msg = "获取更新规则失败"
  551. br.ErrMsg = "获取更新规则失败, Err: " + tmpErr.Error()
  552. return
  553. }
  554. // 调整章节更新
  555. nowTime := time.Now().Local()
  556. for _, item := range tmpChapterList {
  557. stop := false
  558. for _, rule := range chapterTypeList {
  559. if rule.ReportChapterTypeId == item.TypeId {
  560. //fmt.Println("rule.Enabled :", rule.Enabled, ";name=", rule.ReportChapterTypeName, "item.IsEdit:", item.IsEdit, "rule.IsSet:", rule.IsSet)
  561. // 如果被永久暂停更新了
  562. if rule.Enabled == 0 && item.IsEdit == 0 { //该章节已被永久禁用,同时未被操作过
  563. stop = true
  564. } else if rule.PauseStartTime != "" && rule.PauseEndTime != "" && rule.PauseStartTime != utils.EmptyDateStr && rule.PauseEndTime != utils.EmptyDateStr {
  565. startTime, timeErr := time.ParseInLocation(utils.FormatDate, rule.PauseStartTime, time.Local)
  566. if timeErr != nil {
  567. br.Msg = "获取更新规则失败"
  568. br.ErrMsg = "更新规则时间转换失败4001, Err: " + timeErr.Error()
  569. return
  570. }
  571. endTime, timeErr := time.ParseInLocation(utils.FormatDate, rule.PauseEndTime, time.Local)
  572. if timeErr != nil {
  573. br.Msg = "获取更新规则失败"
  574. br.ErrMsg = "更新规则时间转换失败4002, Err: " + timeErr.Error()
  575. return
  576. }
  577. // 暂停更新
  578. if nowTime.After(startTime) && nowTime.Before(endTime.AddDate(0, 0, 1)) {
  579. stop = true
  580. }
  581. break
  582. }
  583. }
  584. }
  585. if !stop {
  586. item.Content = html.UnescapeString(item.Content)
  587. item.ContentSub = html.UnescapeString(item.ContentSub)
  588. chapterList = append(chapterList, item)
  589. }
  590. }
  591. }
  592. item.Abstract = item.Title
  593. }
  594. item.Content = html.UnescapeString(item.Content)
  595. item.ContentSub = html.UnescapeString(item.ContentSub)
  596. resp := &models.ReportDetailView{
  597. ReportDetail: item,
  598. ChapterList: chapterList,
  599. }
  600. br.Ret = 200
  601. br.Success = true
  602. br.Msg = "获取成功"
  603. br.Data = resp
  604. }
  605. // SaveReportContent
  606. // @Title 保存草稿
  607. // @Description 保存草稿
  608. // @Param request body models.SaveReportContent true "type json string"
  609. // @Success 200 {object} models.ReportAuthorResp
  610. // @router /saveReportContent [post]
  611. func (this *ReportController) SaveReportContent() {
  612. br := new(models.BaseResponse).Init()
  613. br.IsSendEmail = false
  614. defer func() {
  615. this.Data["json"] = br
  616. this.ServeJSON()
  617. }()
  618. sysUser := this.SysUser
  619. if sysUser == nil {
  620. br.Msg = "请登录"
  621. br.ErrMsg = "请登录,SysUser Is Empty"
  622. br.Ret = 408
  623. return
  624. }
  625. var req models.SaveReportContent
  626. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  627. if err != nil {
  628. br.Msg = "参数解析异常!"
  629. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  630. return
  631. }
  632. reportId := req.ReportId
  633. noChangeFlag := req.NoChange
  634. if reportId <= 0 {
  635. resp := new(models.SaveReportContentResp)
  636. resp.ReportId = reportId
  637. br.Ret = 200
  638. br.Success = true
  639. br.Msg = "保存成功"
  640. br.Data = resp
  641. return
  642. }
  643. // 获取报告详情
  644. reportInfo, _ := models.GetReportByReportId(int(req.ReportId))
  645. if reportInfo != nil && reportInfo.State == 2 {
  646. br.Msg = "该报告已发布,不允许编辑"
  647. br.ErrMsg = "该报告已发布,不允许编辑"
  648. return
  649. }
  650. // 标记更新中
  651. {
  652. markStatus, err := services.UpdateReportEditMark(int(req.ReportId), 0, sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  653. if err != nil {
  654. br.Msg = err.Error()
  655. return
  656. }
  657. if markStatus.Status == 1 {
  658. br.Msg = markStatus.Msg
  659. return
  660. }
  661. }
  662. // 内容有过修改的话,那么逻辑处理
  663. if noChangeFlag != 1 {
  664. content := req.Content
  665. if content == "" {
  666. content = this.GetString("Content")
  667. }
  668. if content != "" {
  669. e := utils.ContentXssCheck(req.Content)
  670. if e != nil {
  671. br.Msg = "存在非法标签"
  672. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  673. return
  674. }
  675. contentClean, e := services.FilterReportContentBr(req.Content)
  676. if e != nil {
  677. br.Msg = "内容去除前后空格失败"
  678. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  679. return
  680. }
  681. content = contentClean
  682. contentSub, err := services.GetReportContentSub(content)
  683. if err != nil {
  684. go alarm_msg.SendAlarmMsg("解析 ContentSub 失败,Err:"+err.Error(), 3)
  685. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  686. }
  687. reportInfo.Content = html.EscapeString(content)
  688. reportInfo.ContentSub = html.EscapeString(contentSub)
  689. reportInfo.ContentStruct = html.EscapeString(req.ContentStruct)
  690. reportInfo.HeadImg = req.HeadImg
  691. reportInfo.EndImg = req.EndImg
  692. reportInfo.CanvasColor = req.CanvasColor
  693. reportInfo.HeadResourceId = req.HeadResourceId
  694. reportInfo.EndResourceId = req.EndResourceId
  695. reportInfo.ModifyTime = time.Now()
  696. reportInfo.ContentModifyTime = time.Now()
  697. updateCols := []string{"Content", "ContentSub", "HeadImg", "EndImg", "CanvasColor", "HeadResourceId", "EndResourceId", "ModifyTime", "ContentModifyTime"}
  698. err = reportInfo.UpdateReport(updateCols)
  699. if err != nil {
  700. br.Msg = "保存失败"
  701. br.ErrMsg = "保存失败,Err:" + err.Error()
  702. return
  703. }
  704. go models.AddReportSaveLog(reportId, this.SysUser.AdminId, reportInfo.Content, reportInfo.ContentSub, reportInfo.ContentStruct, reportInfo.CanvasColor, this.SysUser.AdminName, reportInfo.HeadResourceId, reportInfo.EndResourceId)
  705. }
  706. }
  707. resp := new(models.SaveReportContentResp)
  708. resp.ReportId = reportId
  709. br.Ret = 200
  710. br.Success = true
  711. br.Msg = "保存成功"
  712. br.Data = resp
  713. }
  714. // PublishDayWeekReportChapter
  715. // @Title 发布晨周报章节
  716. // @Description 发布晨周报章节
  717. // @Param request body models.PublishReportChapterReq true "type json string"
  718. // @Success 200 Ret=200 操作成功
  719. // @router /publishDayWeekReportChapter [post]
  720. func (this *ReportController) PublishDayWeekReportChapter() {
  721. br := new(models.BaseResponse).Init()
  722. defer func() {
  723. this.Data["json"] = br
  724. this.ServeJSON()
  725. }()
  726. sysUser := this.SysUser
  727. if sysUser == nil {
  728. br.Msg = "请登录"
  729. br.ErrMsg = "请登录,SysUser Is Empty"
  730. br.Ret = 408
  731. return
  732. }
  733. var req models.PublishReportChapterReq
  734. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  735. if err != nil {
  736. br.Msg = "参数解析异常!"
  737. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  738. return
  739. }
  740. if req.ReportChapterId <= 0 {
  741. br.Msg = "参数有误"
  742. return
  743. }
  744. if req.Title == "" {
  745. br.Msg = "请输入标题"
  746. return
  747. }
  748. if req.Content == "" {
  749. br.Msg = "请输入内容"
  750. return
  751. }
  752. if req.AddType == 0 {
  753. br.Msg = "请选择新增方式"
  754. return
  755. }
  756. reqTickerList := req.TickerList
  757. chapterInfo, err := models.GetReportChapterInfoById(req.ReportChapterId)
  758. if err != nil {
  759. br.Msg = "章节信息有误"
  760. br.ErrMsg = "获取章节信息失败, Err: " + err.Error()
  761. return
  762. }
  763. reportInfo, err := models.GetReportById(chapterInfo.ReportId)
  764. if err != nil {
  765. br.Msg = "查询报告有误"
  766. br.ErrMsg = "查询报告信息失败, Err: " + err.Error()
  767. return
  768. }
  769. if reportInfo.State == 2 {
  770. br.Msg = "该报告已发布,不允许编辑"
  771. br.ErrMsg = "该报告已发布,不允许编辑"
  772. return
  773. }
  774. // 图表刷新状态
  775. refreshResult := data.CheckBatchChartRefreshResult("report", chapterInfo.ReportId, chapterInfo.ReportChapterId)
  776. if !refreshResult {
  777. br.Msg = "图表刷新未完成,请稍后操作"
  778. br.ErrMsg = "图表刷新未完成,请稍后操作"
  779. br.IsSendEmail = false
  780. return
  781. }
  782. // 获取规则配置
  783. reportChapterTypeRule, err := models.GetReportChapterTypeById(chapterInfo.TypeId)
  784. if err != nil {
  785. br.Msg = "获取配置信息异常"
  786. br.ErrMsg = "获取配置信息异常, Err: " + err.Error()
  787. return
  788. }
  789. if reportChapterTypeRule.Enabled == 0 {
  790. br.Msg = "该章节已永久停更"
  791. br.ErrMsg = "该章节已永久停更 "
  792. br.IsSendEmail = false
  793. return
  794. }
  795. updateCols := make([]string, 0)
  796. updateCols = append(updateCols, "Title", "AddType", "Author", "Content", "ContentSub", "IsEdit", "CreateTime", "PublishState", "PublishTime")
  797. var needHandleVideo bool // 是否需要处理音频文件
  798. nowTime := time.Now()
  799. var publishTime time.Time
  800. if reportInfo.MsgIsSend == 1 && reportInfo.PublishTime != "" { //如果报告曾经发布过,并且已经发送过模版消息,则章节的发布时间为报告的发布时间
  801. publishTime, _ = time.ParseInLocation(utils.FormatDateTime, reportInfo.PublishTime, time.Local)
  802. } else {
  803. publishTime = time.Now()
  804. }
  805. if req.VideoUrl != "" {
  806. chapterInfo.VideoUrl = req.VideoUrl
  807. chapterInfo.VideoName = req.VideoName
  808. chapterInfo.VideoSize = req.VideoSize
  809. chapterInfo.VideoPlaySeconds = req.VideoPlaySeconds
  810. chapterInfo.VideoKind = 1
  811. updateCols = append(updateCols, "VideoUrl", "VideoName", "VideoSize", "VideoPlaySeconds", "VideoKind")
  812. // 手动上传的音频需要处理音频文件
  813. needHandleVideo = true
  814. } else {
  815. if chapterInfo.VideoUrl == "" {
  816. // 生成video
  817. videoUrl, videoName, videoSize, videoPlaySeconds, err := services.CreateReportVideo(req.Title, req.Content, publishTime.Format(utils.FormatDateTime))
  818. if err != nil {
  819. br.Msg = "生成video失败"
  820. br.ErrMsg = "生成video失败, Err: " + err.Error()
  821. return
  822. }
  823. chapterInfo.VideoUrl = videoUrl
  824. chapterInfo.VideoName = videoName
  825. chapterInfo.VideoSize = videoSize
  826. chapterInfo.VideoPlaySeconds = fmt.Sprintf("%.2f", videoPlaySeconds)
  827. chapterInfo.VideoKind = 2
  828. updateCols = append(updateCols, "VideoUrl", "VideoName", "VideoSize", "VideoPlaySeconds", "VideoKind")
  829. }
  830. }
  831. // 更新章节信息
  832. contentSub := ""
  833. if req.Content != "" {
  834. e := utils.ContentXssCheck(req.Content)
  835. if e != nil {
  836. br.Msg = "存在非法标签"
  837. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  838. return
  839. }
  840. contentClean, e := services.FilterReportContentBr(req.Content)
  841. if e != nil {
  842. br.Msg = "内容去除前后空格失败"
  843. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  844. return
  845. }
  846. req.Content = contentClean
  847. contentSub, err = services.GetReportContentSub(req.Content)
  848. if err != nil {
  849. br.Msg = "内容分段解析失败"
  850. br.ErrMsg = "编辑报告章节-解析 ContentSub 失败, Err: " + err.Error()
  851. return
  852. }
  853. }
  854. chapterInfo.Title = req.Title
  855. chapterInfo.AddType = req.AddType
  856. chapterInfo.Author = req.Author
  857. chapterInfo.Content = html.EscapeString(req.Content)
  858. chapterInfo.ContentSub = html.EscapeString(contentSub)
  859. chapterInfo.IsEdit = 1
  860. chapterInfo.CreateTime = req.CreateTime
  861. chapterInfo.PublishState = 2
  862. chapterInfo.PublishTime = publishTime
  863. // 晨报更新指标
  864. tickerList := make([]*models.ReportChapterTicker, 0)
  865. if chapterInfo.ReportType == "day" && len(reqTickerList) > 0 {
  866. for i := 0; i < len(reqTickerList); i++ {
  867. tickerList = append(tickerList, &models.ReportChapterTicker{
  868. ReportChapterId: chapterInfo.ReportChapterId,
  869. Sort: reqTickerList[i].Sort,
  870. Ticker: reqTickerList[i].Ticker,
  871. CreateTime: nowTime,
  872. UpdateTime: nowTime,
  873. })
  874. }
  875. }
  876. if err = models.UpdateChapterAndTicker(chapterInfo, updateCols, tickerList); err != nil {
  877. br.Msg = "发布失败"
  878. br.ErrMsg = "报告章节内容保存失败, Err: " + err.Error()
  879. return
  880. }
  881. // 更新章节ES
  882. {
  883. go services.UpdateReportChapterEs(chapterInfo.ReportChapterId)
  884. }
  885. // 同时发布报告
  886. if req.PublishReport == 1 {
  887. if _, e := services.PublishDayWeekReport(chapterInfo.ReportId); e != nil {
  888. br.Msg = "章节发布成功,报告发布失败,请手动发布报告"
  889. br.ErrMsg = "发布晨/周报失败, Err: " + e.Error()
  890. return
  891. }
  892. }
  893. // 处理报告中的音频文件分贝
  894. if needHandleVideo {
  895. go services.HandleVideoDecibel(chapterInfo)
  896. }
  897. br.Ret = 200
  898. br.Success = true
  899. br.Msg = "操作成功"
  900. }
  901. // AuthorizedListReport
  902. // @Title 获取有权限的报告列表接口
  903. // @Description 获取有权限的报告列表接口
  904. // @Param PageSize query int true "每页数据条数"
  905. // @Param CurrentIndex query int true "当前页页码,从1开始"
  906. // @Param Keyword query string true "搜索关键词"
  907. // @Param ClassifyIdFirst query int true "一级分类id"
  908. // @Param ClassifyIdSecond query int true "二级分类id"
  909. // @Param ClassifyIdThird query int true "三级分类id"
  910. // @Success 200 {object} models.ReportListResp
  911. // @router /list/authorized [get]
  912. func (this *ReportController) AuthorizedListReport() {
  913. br := new(models.BaseResponse).Init()
  914. defer func() {
  915. this.Data["json"] = br
  916. this.ServeJSON()
  917. }()
  918. pageSize, _ := this.GetInt("PageSize")
  919. currentIndex, _ := this.GetInt("CurrentIndex")
  920. keyword := this.GetString("Keyword")
  921. classifyIdFirst, _ := this.GetInt("ClassifyIdFirst", 0)
  922. classifyIdSecond, _ := this.GetInt("ClassifyIdSecond", 0)
  923. classifyIdThird, _ := this.GetInt("ClassifyIdThird", 0)
  924. var startSize int
  925. if pageSize <= 0 {
  926. pageSize = utils.PageSize20
  927. }
  928. if currentIndex <= 0 {
  929. currentIndex = 1
  930. }
  931. startSize = utils.StartIndex(currentIndex, pageSize)
  932. var list []*models.ReportList
  933. // 没有输入信息,那就不展示
  934. if keyword == `` && classifyIdFirst <= 0 {
  935. page := paging.GetPaging(currentIndex, pageSize, 0)
  936. resp := new(models.ReportListResp)
  937. resp.Paging = page
  938. resp.List = list
  939. br.Ret = 200
  940. br.Success = true
  941. br.Msg = "获取成功"
  942. br.Data = resp
  943. return
  944. }
  945. // 当前用户有权限的报告id列表
  946. grantReportIdList := make([]int, 0)
  947. {
  948. obj := report.ReportGrant{}
  949. grantList, err := obj.GetGrantListByAdminId(this.SysUser.AdminId)
  950. if err != nil {
  951. br.Msg = "获取失败"
  952. br.ErrMsg = "获取授权报告id失败,Err:" + err.Error()
  953. return
  954. }
  955. for _, v := range grantList {
  956. grantReportIdList = append(grantReportIdList, v.ReportId)
  957. }
  958. }
  959. var condition string
  960. var pars []interface{}
  961. if classifyIdFirst > 0 {
  962. condition += ` AND a.classify_id_first = ? `
  963. pars = append(pars, classifyIdFirst)
  964. }
  965. if classifyIdSecond > 0 {
  966. condition += ` AND a.classify_id_second = ? `
  967. pars = append(pars, classifyIdSecond)
  968. }
  969. if classifyIdThird > 0 {
  970. condition += ` AND a.classify_id_third = ? `
  971. pars = append(pars, classifyIdSecond)
  972. }
  973. if keyword != `` {
  974. condition += ` AND a.title LIKE ? `
  975. pars = utils.GetLikeKeywordPars(pars, keyword, 1)
  976. }
  977. var err error
  978. var total int
  979. orCondition := `AND ( (a.is_public_publish = ? AND a.state in (2,6)) or a.admin_id = ? `
  980. pars = append(pars, 1, this.SysUser.AdminId)
  981. // 当前用户有权限的报告id列表
  982. num := len(grantReportIdList)
  983. if num > 0 {
  984. orCondition += ` OR a.id in (` + utils.GetOrmInReplace(num) + `)`
  985. pars = append(pars, grantReportIdList)
  986. }
  987. orCondition += ` ) `
  988. condition += orCondition
  989. total, err = models.GetReportListCountByAuthorized(condition, pars)
  990. if err != nil {
  991. br.Msg = "获取失败"
  992. br.ErrMsg = "获取失败,Err:" + err.Error()
  993. return
  994. }
  995. list, err = models.GetReportListByAuthorized(condition, pars, startSize, pageSize)
  996. if err != nil {
  997. br.Msg = "获取失败"
  998. br.ErrMsg = "获取失败,Err:" + err.Error()
  999. return
  1000. }
  1001. //for _, item := range list {
  1002. // if item.HasChapter == 1 {
  1003. // item.CanEdit = true
  1004. // } else {
  1005. // markStatus, err := services.UpdateReportEditMark(item.Id, this.SysUser.AdminId, 2, this.SysUser.RealName, this.Lang)
  1006. // if err != nil {
  1007. // br.Msg = "查询标记状态失败"
  1008. // br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  1009. // return
  1010. // }
  1011. // if markStatus.Status == 0 {
  1012. // item.CanEdit = true
  1013. // } else {
  1014. // item.Editor = markStatus.Editor
  1015. // }
  1016. // }
  1017. //}
  1018. page := paging.GetPaging(currentIndex, pageSize, total)
  1019. resp := new(models.ReportListResp)
  1020. resp.Paging = page
  1021. resp.List = list
  1022. br.Ret = 200
  1023. br.Success = true
  1024. br.Msg = "获取成功"
  1025. br.Data = resp
  1026. }
  1027. // BaseDetail
  1028. // @Title 获取报告基础信息详情接口
  1029. // @Description 获取报告基础信息详情接口
  1030. // @Param request body models.ReportDetailReq true "type json string"
  1031. // @Success 200 {object} models.Report
  1032. // @router /detail/base [get]
  1033. func (this *ReportController) BaseDetail() {
  1034. br := new(models.BaseResponse).Init()
  1035. defer func() {
  1036. this.Data["json"] = br
  1037. this.ServeJSON()
  1038. }()
  1039. /*var req models.ReportDetailReq
  1040. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1041. if err != nil {
  1042. br.Msg = "参数解析异常!"
  1043. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1044. return
  1045. }
  1046. if req.ReportId <= 0 {
  1047. br.Msg = "参数错误"
  1048. return
  1049. }*/
  1050. reportId, err := this.GetInt("ReportId")
  1051. if err != nil {
  1052. br.Msg = "获取参数失败!"
  1053. br.ErrMsg = "获取参数失败,Err:" + err.Error()
  1054. return
  1055. }
  1056. if reportId <= 0 {
  1057. br.Msg = "参数错误"
  1058. return
  1059. }
  1060. reportInfo, err := models.GetReportById(reportId)
  1061. if err != nil {
  1062. if err.Error() == utils.ErrNoRow() {
  1063. br.Msg = "报告已被删除"
  1064. return
  1065. }
  1066. br.Msg = "获取失败"
  1067. br.ErrMsg = "获取失败,Err:" + err.Error()
  1068. return
  1069. }
  1070. // 基础信息就不获取章节信息了
  1071. chapterList := make([]*models.ReportChapter, 0)
  1072. reportInfo.Content = html.UnescapeString(reportInfo.Content)
  1073. reportInfo.ContentSub = html.UnescapeString(reportInfo.ContentSub)
  1074. grandAdminList := make([]models.ReportDetailViewAdmin, 0)
  1075. permissionList := make([]models.ReportDetailViewPermission, 0)
  1076. // 处理报告授权用户列表
  1077. {
  1078. obj := report.ReportGrant{}
  1079. grantList, tmpErr := obj.GetGrantListById(reportId)
  1080. if tmpErr != nil {
  1081. br.Msg = "获取章节id授权用户列表失败"
  1082. br.ErrMsg = "获取章节id授权用户列表失败, Err: " + tmpErr.Error()
  1083. return
  1084. }
  1085. if len(grantList) > 0 {
  1086. grandAdminIdList := make([]int, 0)
  1087. for _, v := range grantList {
  1088. grandAdminIdList = append(grandAdminIdList, v.AdminId)
  1089. }
  1090. adminList, tmpErr := system.GetAdminListByIdList(grandAdminIdList)
  1091. if tmpErr != nil {
  1092. br.Msg = "获取章节id授权用户列表失败"
  1093. br.ErrMsg = "获取章节id授权用户列表失败, Err: " + tmpErr.Error()
  1094. return
  1095. }
  1096. for _, v := range adminList {
  1097. grandAdminList = append(grandAdminList, models.ReportDetailViewAdmin{
  1098. AdminId: v.AdminId,
  1099. AdminName: v.RealName,
  1100. })
  1101. }
  1102. }
  1103. }
  1104. // 处理章节id关联品种id列表
  1105. {
  1106. minClassifyId := reportInfo.ClassifyIdThird
  1107. if minClassifyId <= 0 {
  1108. minClassifyId = reportInfo.ClassifyIdSecond
  1109. }
  1110. if minClassifyId <= 0 {
  1111. minClassifyId = reportInfo.ClassifyIdFirst
  1112. }
  1113. if minClassifyId <= 0 {
  1114. br.Msg = "分类异常"
  1115. br.ErrMsg = "分类异常"
  1116. return
  1117. }
  1118. // 获取分类关联的品种id
  1119. classifyPermissionList, tmpErr := models.GetPermission(minClassifyId)
  1120. if tmpErr != nil {
  1121. br.Msg = "获取分类信息失败"
  1122. br.ErrMsg = "获取失败,Err:" + tmpErr.Error()
  1123. return
  1124. }
  1125. if len(classifyPermissionList) > 0 {
  1126. permissionIdList := make([]int, 0)
  1127. for _, v := range classifyPermissionList {
  1128. permissionIdList = append(permissionIdList, v.ChartPermissionId)
  1129. }
  1130. adminList, tmpErr := models.GetChartPermissionByIdList(permissionIdList)
  1131. if tmpErr != nil {
  1132. br.Msg = "获取章节id授权用户列表失败"
  1133. br.ErrMsg = "获取章节id授权用户列表失败, Err: " + tmpErr.Error()
  1134. return
  1135. }
  1136. for _, v := range adminList {
  1137. permissionList = append(permissionList, models.ReportDetailViewPermission{
  1138. PermissionId: v.ChartPermissionId,
  1139. PermissionName: v.ChartPermissionName,
  1140. })
  1141. }
  1142. }
  1143. }
  1144. resp := &models.ReportDetailView{
  1145. ReportDetail: reportInfo,
  1146. ChapterList: chapterList,
  1147. GrandAdminList: grandAdminList,
  1148. PermissionList: permissionList,
  1149. }
  1150. br.Ret = 200
  1151. br.Success = true
  1152. br.Msg = "获取成功"
  1153. br.Data = resp
  1154. }