report_v2.go 52 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "eta_gn/eta_api/models"
  5. "eta_gn/eta_api/models/report"
  6. "eta_gn/eta_api/models/report_approve"
  7. "eta_gn/eta_api/models/smart_report"
  8. "eta_gn/eta_api/models/system"
  9. "eta_gn/eta_api/services"
  10. "eta_gn/eta_api/services/alarm_msg"
  11. "eta_gn/eta_api/services/data"
  12. "eta_gn/eta_api/utils"
  13. "fmt"
  14. "html"
  15. "strconv"
  16. "strings"
  17. "time"
  18. "github.com/rdlucklib/rdluck_tools/paging"
  19. )
  20. // ListReport
  21. // @Title 获取报告列表接口
  22. // @Description 获取报告列表
  23. // @Param PageSize query int true "每页数据条数"
  24. // @Param CurrentIndex query int true "当前页页码,从1开始"
  25. // @Param TimeType query string true "筛选的时间类别:publish_time(发布时间),modify_time(更新时间);approve_time(审批时间)"
  26. // @Param StartDate query string true "开始时间"
  27. // @Param EndDate query string true "结束时间"
  28. // @Param Frequency query string true "频度"
  29. // @Param ClassifyIdFirst query int true "一级分类id"
  30. // @Param ClassifyIdSecond query int true "二级分类id"
  31. // @Param ClassifyIdThird query int true "三级分类id"
  32. // @Param State query int true "状态"
  33. // @Param KeyWord query string true "搜索关键词"
  34. // @Param PublishSort query string true "desc:降序,asc 升序(预留)"
  35. // @Param FilterReportType query string true "筛选报告类型,1:公共研报,2:共享研报,3:我的研报"
  36. // @Success 200 {object} models.ReportListResp
  37. // @router /list [get]
  38. func (this *ReportController) ListReport() {
  39. br := new(models.BaseResponse).Init()
  40. defer func() {
  41. this.Data["json"] = br
  42. this.ServeJSON()
  43. }()
  44. pageSize, _ := this.GetInt("PageSize")
  45. currentIndex, _ := this.GetInt("CurrentIndex")
  46. timeType := this.GetString("TimeType")
  47. startDate := this.GetString("StartDate")
  48. endDate := this.GetString("EndDate")
  49. frequency := this.GetString("Frequency")
  50. classifyIdFirst, _ := this.GetInt("ClassifyIdFirst", 0)
  51. classifyIdSecond, _ := this.GetInt("ClassifyIdSecond", 0)
  52. classifyIdThird, _ := this.GetInt("ClassifyIdThird", 0)
  53. state, _ := this.GetInt("State")
  54. keyWord := this.GetString("KeyWord")
  55. msgIsSend, _ := this.GetInt("MsgIsSend")
  56. filterReportType, _ := this.GetInt("FilterReportType", 1)
  57. var startSize int
  58. if pageSize <= 0 {
  59. pageSize = utils.PageSize20
  60. }
  61. if currentIndex <= 0 {
  62. currentIndex = 1
  63. }
  64. startSize = utils.StartIndex(currentIndex, pageSize)
  65. if timeType == "" {
  66. timeType = "publish_time"
  67. }
  68. if timeType != "publish_time" && timeType != "modify_time" && timeType != "approve_time" {
  69. br.Msg = "请选择正确的时间"
  70. br.ErrMsg = "请选择正确的时间"
  71. return
  72. }
  73. var condition string
  74. var pars []interface{}
  75. pars = append(pars, this.SysUser.AdminId, this.SysUser.AdminId, this.SysUser.AdminId)
  76. if keyWord != "" {
  77. condition += ` AND (a.title LIKE ? OR a.admin_real_name LIKE ? ) `
  78. pars = utils.GetLikeKeywordPars(pars, keyWord, 2)
  79. }
  80. if startDate != "" {
  81. condition += ` AND a.` + timeType + ` >= ? `
  82. pars = append(pars, startDate)
  83. }
  84. if endDate != "" {
  85. condition += ` AND a.` + timeType + ` <= ? `
  86. pars = append(pars, endDate)
  87. }
  88. if frequency != "" {
  89. condition += ` AND a.frequency = ? `
  90. pars = append(pars, frequency)
  91. }
  92. if classifyIdFirst > 0 {
  93. condition += ` AND a.classify_id_first = ? `
  94. pars = append(pars, classifyIdFirst)
  95. }
  96. if classifyIdSecond > 0 {
  97. condition += ` AND a.classify_id_second = ? `
  98. pars = append(pars, classifyIdSecond)
  99. }
  100. if classifyIdThird > 0 {
  101. condition += ` AND a.classify_id_third = ? `
  102. pars = append(pars, classifyIdThird)
  103. }
  104. if state > 0 {
  105. condition += ` AND a.state = ? `
  106. pars = append(pars, state)
  107. }
  108. // 消息是否已推送 1-未推送; 2-已推送
  109. if msgIsSend == 1 {
  110. condition += ` AND (a.msg_is_send = 0 OR a.ths_msg_is_send = 0) `
  111. }
  112. if msgIsSend == 2 {
  113. condition += ` AND a.msg_is_send = 1 AND a.ths_msg_is_send = 1 `
  114. }
  115. var err error
  116. var total int
  117. var list []*models.ReportList
  118. switch filterReportType {
  119. // 筛选报告类型,1:公共研报,2:共享研报,3:我的研报
  120. case 1:
  121. condition += ` AND a.is_public_publish = ? `
  122. pars = append(pars, 1)
  123. condition += ` AND a.state in (2,6) `
  124. case 3:
  125. condition += ` AND a.admin_id = ? `
  126. pars = append(pars, this.SysUser.AdminId)
  127. case 2:
  128. condition += ` AND (a.admin_id = ? or b.admin_id = ?) `
  129. pars = append(pars, this.SysUser.AdminId, this.SysUser.AdminId)
  130. }
  131. // 共享报告需要连表查询,所以需要单独写
  132. if filterReportType == 2 {
  133. total, err = models.GetReportListCountByGrant(condition, pars)
  134. if err != nil {
  135. br.Msg = "获取失败"
  136. br.ErrMsg = "获取失败,Err:" + err.Error()
  137. return
  138. }
  139. list, err = models.GetReportListByGrant(condition, pars, startSize, pageSize)
  140. if err != nil {
  141. br.Msg = "获取失败"
  142. br.ErrMsg = "获取失败,Err:" + err.Error()
  143. return
  144. }
  145. } else {
  146. total, err = models.GetReportListCountV1(condition, pars)
  147. if err != nil {
  148. br.Msg = "获取失败"
  149. br.ErrMsg = "获取失败,Err:" + err.Error()
  150. return
  151. }
  152. list, err = models.GetReportListV1(condition, pars, startSize, pageSize)
  153. if err != nil {
  154. br.Msg = "获取失败"
  155. br.ErrMsg = "获取失败,Err:" + err.Error()
  156. return
  157. }
  158. }
  159. listLen := len(list)
  160. if listLen > 0 {
  161. pvMap := make(map[int]int)
  162. uvMap := make(map[int]int)
  163. reportIdArr := make([]int, 0)
  164. syncReportIdArr := make([]string, 0) // 同步过来的报告IDs
  165. oldAndNewReportIdMap := make(map[int]int) // 旧报告和新报告的id对应关系
  166. for i := 0; i < listLen; i++ {
  167. reportIdArr = append(reportIdArr, list[i].Id)
  168. if list[i].OldReportId > 0 && list[i].ReportLayout == 1 {
  169. syncReportIdArr = append(syncReportIdArr, strconv.Itoa(list[i].OldReportId))
  170. oldAndNewReportIdMap[list[i].OldReportId] = list[i].Id
  171. }
  172. pvMap[list[i].Id] = list[i].Pv
  173. uvMap[list[i].Id] = list[i].Uv
  174. }
  175. // 当下报告的pv,uv
  176. if len(reportIdArr) > 0 {
  177. pvList, e := models.GetReportPvUvByReportIdList(reportIdArr)
  178. if e != nil {
  179. br.Msg = "获取失败"
  180. br.ErrMsg = "获取同步报告对应的PV、UV失败, Err: " + e.Error()
  181. return
  182. }
  183. for _, v := range pvList {
  184. pv := pvMap[v.ReportId]
  185. uv := uvMap[v.ReportId]
  186. pvMap[v.ReportId] = v.PvTotal + pv
  187. uvMap[v.ReportId] = v.UvTotal + uv
  188. }
  189. }
  190. //reportIds := strings.Join(reportIdArr, ",")
  191. //syncReportIds := strings.Join(syncReportIdArr, ",")
  192. // 查询同步过来的报告对应的老报告PV+UV
  193. if len(syncReportIdArr) > 0 {
  194. puvList, e := models.GetPUVByResearchReportIds(syncReportIdArr)
  195. if e != nil {
  196. br.Msg = "获取失败"
  197. br.ErrMsg = "获取同步报告对应的PV、UV失败, Err: " + e.Error()
  198. return
  199. }
  200. puvLen := len(puvList)
  201. for i := 0; i < puvLen; i++ {
  202. newReportId, ok := oldAndNewReportIdMap[puvList[i].ResearchReportId]
  203. if ok {
  204. pv := pvMap[newReportId]
  205. uv := uvMap[newReportId]
  206. pvMap[newReportId] = puvList[i].Pv + pv
  207. uvMap[newReportId] = puvList[i].Uv + uv
  208. }
  209. }
  210. }
  211. // 晨周报音频列表
  212. videoList, err := models.GetReportChapterVideoListByReportIds(reportIdArr)
  213. if err != nil {
  214. br.Msg = "获取失败"
  215. br.ErrMsg = "获取报告音频文件失败,Err:" + err.Error()
  216. return
  217. }
  218. for i := 0; i < listLen; i++ {
  219. list[i].Content = html.UnescapeString(list[i].Content)
  220. list[i].ContentSub = html.UnescapeString(list[i].ContentSub)
  221. // 除周报外其余报告均可推送客群
  222. list[i].NeedThsMsg = 1
  223. //if list[i].HasChapter == 1 && list[i].ChapterType == utils.REPORT_TYPE_WEEK {
  224. // list[i].NeedThsMsg = 0
  225. //}
  226. chapterList := make([]*models.ReportChapterVideoList, 0)
  227. for ii := 0; ii < len(videoList); ii++ {
  228. if list[i].Id == videoList[ii].ReportId {
  229. chapterList = append(chapterList, videoList[ii])
  230. }
  231. }
  232. list[i].ChapterVideoList = chapterList
  233. list[i].Pv = pvMap[list[i].Id]
  234. list[i].Uv = uvMap[list[i].Id]
  235. }
  236. // 多人协作的协作报告,需要判断是否可编辑
  237. {
  238. grantObj := report.ReportGrant{}
  239. grantList, err := grantObj.GetGrantListByIdList(reportIdArr)
  240. if err != nil {
  241. br.Msg = "获取失败"
  242. br.ErrMsg = "获取报告授权失败,Err:" + err.Error()
  243. return
  244. }
  245. //grantMap := make(map[报告id]map[用户id]bool)
  246. grantMap := make(map[int]map[int]bool)
  247. for _, v := range grantList {
  248. grantUserMap, ok := grantMap[v.ReportId]
  249. if !ok {
  250. grantUserMap = make(map[int]bool)
  251. }
  252. grantUserMap[v.AdminId] = true
  253. grantMap[v.ReportId] = grantUserMap
  254. }
  255. for i, item := range list {
  256. if item.AdminId == this.SysUser.AdminId {
  257. list[i].HasAuth = true
  258. continue
  259. }
  260. // 查找授权
  261. var hasAuth bool
  262. grantUserMap, ok := grantMap[item.Id]
  263. // 如果报告根本没有授权用户,说明没有授权当前用户
  264. if !ok {
  265. continue
  266. }
  267. _, ok = grantUserMap[this.SysUser.AdminId]
  268. list[i].HasAuth = hasAuth
  269. // 如果报告关联用户找到,说明有授权当前用户
  270. if ok {
  271. list[i].HasAuth = true
  272. }
  273. }
  274. }
  275. }
  276. for _, item := range list {
  277. /*key := fmt.Sprint(`crm:report:edit:`, item.Id)
  278. opUserId, _ := utils.Rc.RedisInt(key)
  279. //如果当前没有人操作,获取当前操作人是本人,那么编辑按钮可用
  280. if opUserId <= 0 || (opUserId == this.SysUser.AdminId) || item.ClassifyNameFirst == "周报" || item.ClassifyNameFirst == "晨报" {
  281. item.CanEdit = true
  282. } else {
  283. adminInfo, errAdmin := system.GetSysUserById(opUserId)
  284. if errAdmin != nil {
  285. br.Msg = "获取失败"
  286. br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  287. return
  288. }
  289. item.Editor = adminInfo.RealName
  290. }*/
  291. if item.HasChapter == 1 {
  292. item.CanEdit = true
  293. continue
  294. }
  295. markStatus, err := services.UpdateReportEditMark(item.Id, 0, this.SysUser.AdminId, 2, this.SysUser.RealName, this.Lang)
  296. if err != nil {
  297. br.Msg = "查询标记状态失败"
  298. br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  299. return
  300. }
  301. if markStatus.Status == 0 {
  302. item.CanEdit = true
  303. } else {
  304. item.Editor = markStatus.Editor
  305. }
  306. }
  307. page := paging.GetPaging(currentIndex, pageSize, total)
  308. resp := new(models.ReportListResp)
  309. resp.Paging = page
  310. resp.List = list
  311. br.Ret = 200
  312. br.Success = true
  313. br.Msg = "获取成功"
  314. br.Data = resp
  315. }
  316. // Add
  317. // @Title 新增报告接口
  318. // @Description 新增报告(不区分报告类型)
  319. // @Param request body models.AddReq true "type json string"
  320. // @Success 200 {object} models.AddResp
  321. // @router /add [post]
  322. func (this *ReportController) Add() {
  323. br := new(models.BaseResponse).Init()
  324. defer func() {
  325. this.Data["json"] = br
  326. this.ServeJSON()
  327. }()
  328. sysUser := this.SysUser
  329. if sysUser == nil {
  330. br.Msg = "请登录"
  331. br.ErrMsg = "请登录,SysUser Is Empty"
  332. br.Ret = 408
  333. return
  334. }
  335. var req models.AddReq
  336. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  337. if err != nil {
  338. br.Msg = "参数解析异常!"
  339. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  340. return
  341. }
  342. if req.Title == `` {
  343. br.Msg = "标题不能为空"
  344. br.ErrMsg = "标题不能为空"
  345. br.IsSendEmail = false
  346. return
  347. }
  348. if req.ClassifyIdFirst <= 0 {
  349. br.Msg = "分类必填"
  350. br.ErrMsg = "分类必填"
  351. br.IsSendEmail = false
  352. return
  353. }
  354. var contentSub string
  355. if req.Content != "" {
  356. e := utils.ContentXssCheck(req.Content)
  357. if e != nil {
  358. br.Msg = "存在非法标签"
  359. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  360. return
  361. }
  362. content, e := services.FilterReportContentBr(req.Content)
  363. if e != nil {
  364. br.Msg = "内容去除前后空格失败"
  365. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  366. return
  367. }
  368. req.Content = content
  369. contentSub, err = services.GetReportContentSub(req.Content)
  370. if err != nil {
  371. go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+err.Error(), 3)
  372. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  373. }
  374. }
  375. // 报告期数
  376. maxStage, err := models.GetReportStage(req.ClassifyIdFirst, req.ClassifyIdSecond, req.ClassifyIdThird)
  377. if err != nil {
  378. br.Msg = "期数获取失败!"
  379. br.ErrMsg = "期数获取失败,Err:" + err.Error()
  380. return
  381. }
  382. // 根据审批开关及审批流判断当前报告状态
  383. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeChinese, req.ClassifyIdFirst, req.ClassifyIdSecond, req.ClassifyIdThird, models.ReportOperateAdd)
  384. if e != nil {
  385. br.Msg = "操作失败"
  386. br.ErrMsg = "校验报告当前状态失败, Err: " + e.Error()
  387. return
  388. }
  389. // 协作方式,1:个人,2:多人协作。默认:1
  390. if req.CollaborateType == 0 {
  391. req.CollaborateType = 1
  392. }
  393. // 报告布局,1:常规布局,2:智能布局。默认:1
  394. if req.ReportLayout == 0 {
  395. req.ReportLayout = 1
  396. }
  397. // 是否公开发布,1:是,2:否
  398. req.IsPublicPublish = 2 // 本地报告固定不公开
  399. //if req.IsPublicPublish == 0 {
  400. // req.IsPublicPublish = 1
  401. //}
  402. classifyItemList, err := models.GetClassifyListByIdList([]int{req.ClassifyIdFirst, req.ClassifyIdSecond, req.ClassifyIdThird})
  403. classifyMap := make(map[int]string)
  404. for _, v := range classifyItemList {
  405. classifyMap[v.Id] = v.ClassifyName
  406. }
  407. item := new(models.Report)
  408. item.AddType = req.AddType
  409. item.ReportVersion = 2
  410. item.ClassifyIdFirst = req.ClassifyIdFirst
  411. item.ClassifyNameFirst = classifyMap[req.ClassifyIdFirst]
  412. item.ClassifyIdSecond = req.ClassifyIdSecond
  413. item.ClassifyNameSecond = classifyMap[req.ClassifyIdSecond]
  414. item.Title = req.Title
  415. item.Abstract = req.Abstract
  416. item.Author = req.Author
  417. item.Frequency = req.Frequency
  418. item.State = state
  419. item.Content = html.EscapeString(req.Content)
  420. item.Stage = maxStage + 1
  421. item.ContentSub = html.EscapeString(contentSub)
  422. if req.CreateTime != `` {
  423. formatDate := utils.FormatDateTime
  424. if !strings.Contains(req.CreateTime, ":") {
  425. formatDate = utils.FormatDate
  426. }
  427. createTime, tmpErr := time.ParseInLocation(formatDate, req.CreateTime, time.Local)
  428. if tmpErr != nil {
  429. br.Msg = "时间解析异常"
  430. br.ErrMsg = "时间解析异常,Err:" + err.Error()
  431. return
  432. }
  433. item.CreateTime = createTime
  434. }
  435. item.ModifyTime = time.Now()
  436. item.ReportVersion = req.ReportVersion
  437. item.AdminId = sysUser.AdminId
  438. item.AdminRealName = sysUser.RealName
  439. item.ClassifyIdThird = req.ClassifyIdThird
  440. item.ClassifyNameThird = classifyMap[req.ClassifyIdThird]
  441. // 产品要求,如果是多人协作,那么就是章节类型的报告
  442. if req.CollaborateType == 2 {
  443. item.HasChapter = 1
  444. item.ChapterType = ""
  445. }
  446. item.LastModifyAdminId = sysUser.AdminId
  447. item.LastModifyAdminName = sysUser.RealName
  448. item.ContentModifyTime = time.Now()
  449. item.NeedSplice = 1
  450. item.ContentStruct = html.EscapeString(req.ContentStruct)
  451. item.HeadImg = req.HeadImg
  452. item.EndImg = req.EndImg
  453. item.CanvasColor = req.CanvasColor
  454. item.HeadResourceId = req.HeadResourceId
  455. item.EndResourceId = req.EndResourceId
  456. item.CollaborateType = req.CollaborateType
  457. item.ReportLayout = req.ReportLayout
  458. item.IsPublicPublish = req.IsPublicPublish
  459. item.ReportCreateTime = time.Now()
  460. item.ReportSource = utils.ReportSourceLocal
  461. err, errMsg := services.AddReportAndChapter(item, req.InheritReportId, req.GrantAdminIdList)
  462. if err != nil {
  463. br.Msg = "保存失败"
  464. if errMsg != "" {
  465. br.Msg = errMsg
  466. }
  467. br.ErrMsg = "保存失败,Err:" + err.Error()
  468. return
  469. }
  470. recordItem := &models.ReportStateRecord{
  471. ReportId: item.Id,
  472. ReportType: 1,
  473. State: 1,
  474. AdminId: this.SysUser.AdminId,
  475. AdminName: this.SysUser.AdminName,
  476. CreateTime: time.Now(),
  477. }
  478. go func() {
  479. _, _ = models.AddReportStateRecord(recordItem)
  480. }()
  481. resp := new(models.AddResp)
  482. resp.ReportId = int64(item.Id)
  483. resp.ReportCode = item.ReportCode
  484. br.Ret = 200
  485. br.Success = true
  486. br.Msg = "保存成功"
  487. br.Data = resp
  488. }
  489. // Edit
  490. // @Title 编辑报告基础信息接口
  491. // @Description 编辑报告基础信息(不区分报告类型)
  492. // @Param request body models.EditReq true "type json string"
  493. // @Success 200 {object} models.EditResp
  494. // @router /edit [post]
  495. func (this *ReportController) Edit() {
  496. br := new(models.BaseResponse).Init()
  497. defer func() {
  498. this.Data["json"] = br
  499. this.ServeJSON()
  500. }()
  501. sysUser := this.SysUser
  502. if sysUser == nil {
  503. br.Msg = "请登录"
  504. br.ErrMsg = "请登录,SysUser Is Empty"
  505. br.Ret = 408
  506. return
  507. }
  508. var req models.EditReq
  509. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  510. if err != nil {
  511. br.Msg = "参数解析异常!"
  512. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  513. return
  514. }
  515. //if req.Content == "" {
  516. // br.Msg = "报告内容不能为空"
  517. // return
  518. //}
  519. //更新标记key
  520. markStatus, err := services.UpdateReportEditMark(int(req.ReportId), 0, sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  521. if err != nil {
  522. br.Msg = err.Error()
  523. return
  524. }
  525. if markStatus.Status == 1 {
  526. br.Msg = markStatus.Msg
  527. //br.Ret = 202 //202 服务器已接受请求,但尚未处理。
  528. return
  529. }
  530. reportInfo, e := models.GetReportByReportId(int(req.ReportId))
  531. if e != nil {
  532. if utils.IsErrNoRow(e) {
  533. br.Msg = "报告已被删除, 请刷新页面"
  534. return
  535. }
  536. br.Msg = "操作失败"
  537. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  538. return
  539. }
  540. if reportInfo.State == models.ReportStatePublished || reportInfo.State == models.ReportStatePass {
  541. br.Msg = "该报告已发布,不允许编辑"
  542. br.ErrMsg = "该报告已发布,不允许编辑"
  543. br.IsSendEmail = false
  544. return
  545. }
  546. // 编辑报告信息
  547. err, errMsg := services.EditReport(reportInfo, req, sysUser)
  548. if err != nil {
  549. br.Msg = "保存失败"
  550. if errMsg != "" {
  551. br.Msg = errMsg
  552. }
  553. br.ErrMsg = "保存失败,Err:" + err.Error()
  554. return
  555. }
  556. reportCode := utils.MD5(strconv.Itoa(int(req.ReportId)))
  557. resp := new(models.EditResp)
  558. resp.ReportId = req.ReportId
  559. resp.ReportCode = reportCode
  560. br.Ret = 200
  561. br.Success = true
  562. br.Msg = "保存成功"
  563. br.Data = resp
  564. }
  565. // Detail
  566. // @Title 获取报告详情接口
  567. // @Description 获取报告详情
  568. // @Param request body models.ReportDetailReq true "type json string"
  569. // @Success 200 {object} models.Report
  570. // @router /detail [get]
  571. func (this *ReportController) Detail() {
  572. br := new(models.BaseResponse).Init()
  573. defer func() {
  574. this.Data["json"] = br
  575. this.ServeJSON()
  576. }()
  577. /*var req models.ReportDetailReq
  578. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  579. if err != nil {
  580. br.Msg = "参数解析异常!"
  581. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  582. return
  583. }
  584. if req.ReportId <= 0 {
  585. br.Msg = "参数错误"
  586. return
  587. }*/
  588. reportId, err := this.GetInt("ReportId")
  589. if err != nil {
  590. br.Msg = "获取参数失败!"
  591. br.ErrMsg = "获取参数失败,Err:" + err.Error()
  592. return
  593. }
  594. if reportId <= 0 {
  595. br.Msg = "参数错误"
  596. return
  597. }
  598. item, err := models.GetReportById(reportId)
  599. if err != nil {
  600. if utils.IsErrNoRow(err) {
  601. br.Msg = "报告已被删除"
  602. return
  603. }
  604. br.Msg = "获取失败"
  605. br.ErrMsg = "获取失败,Err:" + err.Error()
  606. return
  607. }
  608. chapterList := make([]*models.ReportChapter, 0)
  609. if item.HasChapter == 1 {
  610. // 获取章节内容
  611. tmpChapterList, err := models.GetPublishedChapterListByReportId(item.Id)
  612. if err != nil {
  613. br.Msg = "获取失败"
  614. br.ErrMsg = "获取晨/周报章节列表失败, Err: " + err.Error()
  615. return
  616. }
  617. if len(tmpChapterList) > 0 {
  618. // 章节类型的字段赋值
  619. for _, item := range tmpChapterList {
  620. item.Content = html.UnescapeString(item.Content)
  621. item.ContentSub = html.UnescapeString(item.ContentSub)
  622. chapterList = append(chapterList, item)
  623. }
  624. }
  625. //item.Abstract = item.Title
  626. }
  627. item.Content = html.UnescapeString(item.Content)
  628. item.ContentSub = html.UnescapeString(item.ContentSub)
  629. item.ContentStruct = html.UnescapeString(item.ContentStruct)
  630. if item.HeadResourceId > 0 {
  631. headResource, err := smart_report.GetResourceItemById(item.HeadResourceId)
  632. if err != nil {
  633. br.Msg = "操作失败"
  634. br.ErrMsg = "获取资源库版头失败, Err: " + err.Error()
  635. return
  636. }
  637. item.HeadImg = headResource.ImgUrl
  638. item.HeadStyle = headResource.Style
  639. }
  640. if item.EndResourceId > 0 {
  641. endResource, err := smart_report.GetResourceItemById(item.EndResourceId)
  642. if err != nil {
  643. br.Msg = "操作失败"
  644. br.ErrMsg = "获取资源库版头失败, Err: " + err.Error()
  645. return
  646. }
  647. item.EndImg = endResource.ImgUrl
  648. item.EndStyle = endResource.Style
  649. }
  650. resp := &models.ReportDetailView{
  651. ReportDetail: item,
  652. ChapterList: chapterList,
  653. }
  654. br.Ret = 200
  655. br.Success = true
  656. br.Msg = "获取成功"
  657. br.Data = resp
  658. }
  659. // SaveReportContent
  660. // @Title 保存草稿
  661. // @Description 保存草稿
  662. // @Param request body models.SaveReportContent true "type json string"
  663. // @Success 200 {object} models.ReportAuthorResp
  664. // @router /saveReportContent [post]
  665. func (this *ReportController) SaveReportContent() {
  666. br := new(models.BaseResponse).Init()
  667. br.IsSendEmail = false
  668. defer func() {
  669. this.Data["json"] = br
  670. this.ServeJSON()
  671. }()
  672. sysUser := this.SysUser
  673. if sysUser == nil {
  674. br.Msg = "请登录"
  675. br.ErrMsg = "请登录,SysUser Is Empty"
  676. br.Ret = 408
  677. return
  678. }
  679. var req models.SaveReportContent
  680. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  681. if err != nil {
  682. br.Msg = "参数解析异常!"
  683. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  684. return
  685. }
  686. reportId := req.ReportId
  687. noChangeFlag := req.NoChange
  688. if reportId <= 0 {
  689. resp := new(models.SaveReportContentResp)
  690. resp.ReportId = reportId
  691. br.Ret = 200
  692. br.Success = true
  693. br.Msg = "保存成功"
  694. br.Data = resp
  695. return
  696. }
  697. // 获取报告详情
  698. reportInfo, _ := models.GetReportByReportId(req.ReportId)
  699. if reportInfo != nil && reportInfo.State == 2 {
  700. br.Msg = "该报告已发布,不允许编辑"
  701. br.ErrMsg = "该报告已发布,不允许编辑"
  702. br.IsSendEmail = false
  703. return
  704. }
  705. // 标记更新中
  706. {
  707. markStatus, err := services.UpdateReportEditMark(req.ReportId, 0, sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  708. if err != nil {
  709. br.Msg = err.Error()
  710. return
  711. }
  712. if markStatus.Status == 1 {
  713. br.Msg = markStatus.Msg
  714. return
  715. }
  716. }
  717. // 内容有过修改的话,那么逻辑处理
  718. if noChangeFlag != 1 {
  719. content := req.Content
  720. if content == "" {
  721. content = this.GetString("Content")
  722. }
  723. if content != "" {
  724. e := utils.ContentXssCheck(req.Content)
  725. if e != nil {
  726. br.Msg = "存在非法标签"
  727. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  728. return
  729. }
  730. contentClean, e := services.FilterReportContentBr(req.Content)
  731. if e != nil {
  732. br.Msg = "内容去除前后空格失败"
  733. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  734. return
  735. }
  736. content = contentClean
  737. contentSub, err := services.GetReportContentSub(content)
  738. if err != nil {
  739. go alarm_msg.SendAlarmMsg("解析 ContentSub 失败,Err:"+err.Error(), 3)
  740. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  741. }
  742. reportInfo.Content = html.EscapeString(content)
  743. reportInfo.ContentSub = html.EscapeString(contentSub)
  744. reportInfo.ContentStruct = html.EscapeString(req.ContentStruct)
  745. reportInfo.HeadImg = req.HeadImg
  746. reportInfo.EndImg = req.EndImg
  747. reportInfo.CanvasColor = req.CanvasColor
  748. reportInfo.HeadResourceId = req.HeadResourceId
  749. reportInfo.EndResourceId = req.EndResourceId
  750. reportInfo.ModifyTime = time.Now()
  751. reportInfo.ContentModifyTime = time.Now()
  752. updateCols := []string{"Content", "ContentSub", "ContentStruct", "HeadImg", "EndImg", "CanvasColor", "HeadResourceId", "EndResourceId", "ModifyTime", "ContentModifyTime"}
  753. err = reportInfo.UpdateReport(updateCols)
  754. if err != nil {
  755. br.Msg = "保存失败"
  756. br.ErrMsg = "保存失败,Err:" + err.Error()
  757. return
  758. }
  759. go models.AddReportSaveLog(reportId, this.SysUser.AdminId, reportInfo.Content, reportInfo.ContentSub, reportInfo.ContentStruct, reportInfo.CanvasColor, this.SysUser.AdminName, reportInfo.HeadResourceId, reportInfo.EndResourceId)
  760. }
  761. }
  762. resp := new(models.SaveReportContentResp)
  763. resp.ReportId = reportId
  764. br.Ret = 200
  765. br.Success = true
  766. br.Msg = "保存成功"
  767. br.Data = resp
  768. }
  769. // AuthorizedListReport
  770. // @Title 获取有权限的报告列表接口
  771. // @Description 获取有权限的报告列表接口
  772. // @Param PageSize query int true "每页数据条数"
  773. // @Param CurrentIndex query int true "当前页页码,从1开始"
  774. // @Param Keyword query string true "搜索关键词"
  775. // @Param ClassifyIdFirst query int true "一级分类id"
  776. // @Param ClassifyIdSecond query int true "二级分类id"
  777. // @Param ClassifyIdThird query int true "三级分类id"
  778. // @Success 200 {object} models.ReportListResp
  779. // @router /list/authorized [get]
  780. func (this *ReportController) AuthorizedListReport() {
  781. br := new(models.BaseResponse).Init()
  782. defer func() {
  783. this.Data["json"] = br
  784. this.ServeJSON()
  785. }()
  786. pageSize, _ := this.GetInt("PageSize")
  787. currentIndex, _ := this.GetInt("CurrentIndex")
  788. keyword := this.GetString("Keyword")
  789. classifyIdFirst, _ := this.GetInt("ClassifyIdFirst", 0)
  790. classifyIdSecond, _ := this.GetInt("ClassifyIdSecond", 0)
  791. classifyIdThird, _ := this.GetInt("ClassifyIdThird", 0)
  792. var startSize int
  793. if pageSize <= 0 {
  794. pageSize = utils.PageSize20
  795. }
  796. if currentIndex <= 0 {
  797. currentIndex = 1
  798. }
  799. startSize = utils.StartIndex(currentIndex, pageSize)
  800. var list []*models.ReportList
  801. // 没有输入信息,那就不展示
  802. if keyword == `` && classifyIdFirst <= 0 {
  803. page := paging.GetPaging(currentIndex, pageSize, 0)
  804. resp := new(models.ReportListResp)
  805. resp.Paging = page
  806. resp.List = list
  807. br.Ret = 200
  808. br.Success = true
  809. br.Msg = "获取成功"
  810. br.Data = resp
  811. return
  812. }
  813. // 当前用户有权限的报告id列表
  814. grantReportIdList := make([]int, 0)
  815. {
  816. obj := report.ReportGrant{}
  817. grantList, err := obj.GetGrantListByAdminId(this.SysUser.AdminId)
  818. if err != nil {
  819. br.Msg = "获取失败"
  820. br.ErrMsg = "获取授权报告id失败,Err:" + err.Error()
  821. return
  822. }
  823. for _, v := range grantList {
  824. grantReportIdList = append(grantReportIdList, v.ReportId)
  825. }
  826. }
  827. var condition string
  828. var pars []interface{}
  829. if classifyIdFirst > 0 {
  830. condition += ` AND a.classify_id_first = ? `
  831. pars = append(pars, classifyIdFirst)
  832. }
  833. if classifyIdSecond > 0 {
  834. condition += ` AND a.classify_id_second = ? `
  835. pars = append(pars, classifyIdSecond)
  836. }
  837. if classifyIdThird > 0 {
  838. condition += ` AND a.classify_id_third = ? `
  839. pars = append(pars, classifyIdThird)
  840. }
  841. if keyword != `` {
  842. condition += ` AND a.title LIKE ? `
  843. pars = utils.GetLikeKeywordPars(pars, keyword, 1)
  844. }
  845. var err error
  846. var total int
  847. orCondition := `AND ( (a.is_public_publish = ? AND a.state in (2,6)) or a.admin_id = ? `
  848. pars = append(pars, 1, this.SysUser.AdminId)
  849. // 当前用户有权限的报告id列表
  850. num := len(grantReportIdList)
  851. if num > 0 {
  852. orCondition += ` OR a.id in (` + utils.GetOrmInReplace(num) + `)`
  853. pars = append(pars, grantReportIdList)
  854. }
  855. orCondition += ` ) `
  856. condition += orCondition
  857. total, err = models.GetReportListCountByAuthorized(condition, pars)
  858. if err != nil {
  859. br.Msg = "获取失败"
  860. br.ErrMsg = "获取失败,Err:" + err.Error()
  861. return
  862. }
  863. list, err = models.GetReportListByAuthorized(condition, pars, startSize, pageSize)
  864. if err != nil {
  865. br.Msg = "获取失败"
  866. br.ErrMsg = "获取失败,Err:" + err.Error()
  867. return
  868. }
  869. //for _, item := range list {
  870. // if item.HasChapter == 1 {
  871. // item.CanEdit = true
  872. // } else {
  873. // markStatus, err := services.UpdateReportEditMark(item.Id, this.SysUser.AdminId, 2, this.SysUser.RealName, this.Lang)
  874. // if err != nil {
  875. // br.Msg = "查询标记状态失败"
  876. // br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  877. // return
  878. // }
  879. // if markStatus.Status == 0 {
  880. // item.CanEdit = true
  881. // } else {
  882. // item.Editor = markStatus.Editor
  883. // }
  884. // }
  885. //}
  886. page := paging.GetPaging(currentIndex, pageSize, total)
  887. resp := new(models.ReportListResp)
  888. resp.Paging = page
  889. resp.List = list
  890. br.Ret = 200
  891. br.Success = true
  892. br.Msg = "获取成功"
  893. br.Data = resp
  894. }
  895. // BaseDetail
  896. // @Title 获取报告基础信息详情接口
  897. // @Description 获取报告基础信息详情接口
  898. // @Param request body models.ReportDetailReq true "type json string"
  899. // @Success 200 {object} models.Report
  900. // @router /detail/base [get]
  901. func (this *ReportController) BaseDetail() {
  902. br := new(models.BaseResponse).Init()
  903. defer func() {
  904. this.Data["json"] = br
  905. this.ServeJSON()
  906. }()
  907. /*var req models.ReportDetailReq
  908. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  909. if err != nil {
  910. br.Msg = "参数解析异常!"
  911. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  912. return
  913. }
  914. if req.ReportId <= 0 {
  915. br.Msg = "参数错误"
  916. return
  917. }*/
  918. reportId, err := this.GetInt("ReportId")
  919. if err != nil {
  920. br.Msg = "获取参数失败!"
  921. br.ErrMsg = "获取参数失败,Err:" + err.Error()
  922. return
  923. }
  924. if reportId <= 0 {
  925. br.Msg = "参数错误"
  926. return
  927. }
  928. reportInfo, err := models.GetReportById(reportId)
  929. if err != nil {
  930. if utils.IsErrNoRow(err) {
  931. br.Msg = "报告已被删除"
  932. return
  933. }
  934. br.Msg = "获取失败"
  935. br.ErrMsg = "获取失败,Err:" + err.Error()
  936. return
  937. }
  938. fmt.Println(reportInfo)
  939. // 基础信息就不获取章节信息了
  940. chapterList := make([]*models.ReportChapter, 0)
  941. reportInfo.Content = html.UnescapeString(reportInfo.Content)
  942. reportInfo.ContentSub = html.UnescapeString(reportInfo.ContentSub)
  943. grandAdminList := make([]models.ReportDetailViewAdmin, 0)
  944. permissionList := make([]models.ReportDetailViewPermission, 0)
  945. // 处理报告授权用户列表
  946. {
  947. obj := report.ReportGrant{}
  948. grantList, tmpErr := obj.GetGrantListById(reportId)
  949. if tmpErr != nil {
  950. br.Msg = "获取章节id授权用户列表失败"
  951. br.ErrMsg = "获取章节id授权用户列表失败, Err: " + tmpErr.Error()
  952. return
  953. }
  954. if len(grantList) > 0 {
  955. grandAdminIdList := make([]int, 0)
  956. for _, v := range grantList {
  957. grandAdminIdList = append(grandAdminIdList, v.AdminId)
  958. }
  959. adminList, tmpErr := system.GetAdminListByIdList(grandAdminIdList)
  960. if tmpErr != nil {
  961. br.Msg = "获取章节id授权用户列表失败"
  962. br.ErrMsg = "获取章节id授权用户列表失败, Err: " + tmpErr.Error()
  963. return
  964. }
  965. for _, v := range adminList {
  966. grandAdminList = append(grandAdminList, models.ReportDetailViewAdmin{
  967. AdminId: v.AdminId,
  968. AdminName: v.RealName,
  969. })
  970. }
  971. }
  972. }
  973. // 处理章节id关联品种id列表
  974. {
  975. minClassifyId := reportInfo.ClassifyIdThird
  976. if minClassifyId <= 0 {
  977. minClassifyId = reportInfo.ClassifyIdSecond
  978. }
  979. if minClassifyId <= 0 {
  980. minClassifyId = reportInfo.ClassifyIdFirst
  981. }
  982. if minClassifyId <= 0 {
  983. br.Msg = "分类异常"
  984. br.ErrMsg = "分类异常"
  985. return
  986. }
  987. // 获取分类关联的品种id
  988. classifyPermissionList, tmpErr := models.GetPermission(minClassifyId)
  989. if tmpErr != nil {
  990. br.Msg = "获取分类信息失败"
  991. br.ErrMsg = "获取失败,Err:" + tmpErr.Error()
  992. return
  993. }
  994. if len(classifyPermissionList) > 0 {
  995. permissionIdList := make([]int, 0)
  996. for _, v := range classifyPermissionList {
  997. permissionIdList = append(permissionIdList, v.ChartPermissionId)
  998. }
  999. adminList, tmpErr := models.GetChartPermissionByIdList(permissionIdList)
  1000. if tmpErr != nil {
  1001. br.Msg = "获取章节id授权用户列表失败"
  1002. br.ErrMsg = "获取章节id授权用户列表失败, Err: " + tmpErr.Error()
  1003. return
  1004. }
  1005. for _, v := range adminList {
  1006. permissionList = append(permissionList, models.ReportDetailViewPermission{
  1007. PermissionId: v.ChartPermissionId,
  1008. PermissionName: v.PermissionName,
  1009. })
  1010. }
  1011. }
  1012. }
  1013. resp := &models.ReportDetailView{
  1014. ReportDetail: reportInfo,
  1015. ChapterList: chapterList,
  1016. GrandAdminList: grandAdminList,
  1017. PermissionList: permissionList,
  1018. }
  1019. br.Ret = 200
  1020. br.Success = true
  1021. br.Msg = "获取成功"
  1022. br.Data = resp
  1023. }
  1024. // EditLayoutImg
  1025. // @Title 版图设置接口
  1026. // @Description 版图设置接口
  1027. // @Param request body models.EditLayoutImgReq true "type json string"
  1028. // @Success 200 {object} models.EditResp
  1029. // @router /layout_img/edit [post]
  1030. func (this *ReportController) EditLayoutImg() {
  1031. br := new(models.BaseResponse).Init()
  1032. defer func() {
  1033. this.Data["json"] = br
  1034. this.ServeJSON()
  1035. }()
  1036. sysUser := this.SysUser
  1037. if sysUser == nil {
  1038. br.Msg = "请登录"
  1039. br.ErrMsg = "请登录,SysUser Is Empty"
  1040. br.Ret = 408
  1041. return
  1042. }
  1043. var req models.EditLayoutImgReq
  1044. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1045. if err != nil {
  1046. br.Msg = "参数解析异常!"
  1047. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1048. return
  1049. }
  1050. //if req.Content == "" {
  1051. // br.Msg = "报告内容不能为空"
  1052. // return
  1053. //}
  1054. //更新标记key
  1055. markStatus, err := services.UpdateReportEditMark(int(req.ReportId), 0, sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  1056. if err != nil {
  1057. br.Msg = err.Error()
  1058. return
  1059. }
  1060. if markStatus.Status == 1 {
  1061. br.Msg = markStatus.Msg
  1062. //br.Ret = 202 //202 服务器已接受请求,但尚未处理。
  1063. return
  1064. }
  1065. reportInfo, e := models.GetReportByReportId(int(req.ReportId))
  1066. if e != nil {
  1067. if utils.IsErrNoRow(e) {
  1068. br.Msg = "报告已被删除, 请刷新页面"
  1069. return
  1070. }
  1071. br.Msg = "操作失败"
  1072. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  1073. return
  1074. }
  1075. if reportInfo.State == models.ReportStatePublished || reportInfo.State == models.ReportStatePass {
  1076. br.Msg = "该报告已发布,不允许编辑"
  1077. br.ErrMsg = "该报告已发布,不允许编辑"
  1078. br.IsSendEmail = false
  1079. return
  1080. }
  1081. // 编辑报告信息
  1082. err, errMsg := services.EditReportLayoutImg(reportInfo, req, sysUser)
  1083. if err != nil {
  1084. br.Msg = "保存失败"
  1085. if errMsg != "" {
  1086. br.Msg = errMsg
  1087. }
  1088. br.ErrMsg = "保存失败,Err:" + err.Error()
  1089. return
  1090. }
  1091. reportCode := utils.MD5(strconv.Itoa(int(req.ReportId)))
  1092. resp := new(models.EditResp)
  1093. resp.ReportId = req.ReportId
  1094. resp.ReportCode = reportCode
  1095. br.Ret = 200
  1096. br.Success = true
  1097. br.Msg = "保存成功"
  1098. br.Data = resp
  1099. }
  1100. // PublishReport
  1101. // @Title 发布报告接口
  1102. // @Description 发布报告
  1103. // @Param request body models.PublishReq true "type json string"
  1104. // @Success 200 Ret=200 发布成功
  1105. // @router /publish [post]
  1106. func (this *ReportController) PublishReport() {
  1107. br := new(models.BaseResponse).Init()
  1108. defer func() {
  1109. this.Data["json"] = br
  1110. this.ServeJSON()
  1111. }()
  1112. var req models.PublishReq
  1113. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1114. if err != nil {
  1115. br.Msg = "参数解析异常!"
  1116. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1117. return
  1118. }
  1119. reportIds := req.ReportIds
  1120. if reportIds == "" {
  1121. br.Msg = "参数错误"
  1122. br.ErrMsg = "参数错误,报告id不可为空"
  1123. return
  1124. }
  1125. // 这里实际上不会批量发布了...
  1126. reportArr := strings.Split(reportIds, ",")
  1127. tips := ""
  1128. for _, v := range reportArr {
  1129. vint, err := strconv.Atoi(v)
  1130. if err != nil {
  1131. br.Msg = "参数错误"
  1132. br.ErrMsg = "参数错误,Err:" + err.Error()
  1133. return
  1134. }
  1135. // 报告的图表刷新状态校验
  1136. refreshResult := data.CheckBatchChartRefreshResult("report", vint, 0)
  1137. if !refreshResult {
  1138. br.Msg = "图表刷新未完成,请稍后操作"
  1139. br.ErrMsg = "图表刷新未完成,请稍后操作"
  1140. br.IsSendEmail = false
  1141. return
  1142. }
  1143. // 报告发布
  1144. tmpTips, err, errMsg := services.PublishReportV2(vint, this.SysUser)
  1145. if err != nil {
  1146. br.Msg = errMsg
  1147. br.ErrMsg = "报告发布失败,Err:" + err.Error()
  1148. return
  1149. }
  1150. tips = tmpTips
  1151. }
  1152. // 发布晨周报部分章节未发布的提示
  1153. if tips != "" {
  1154. br.Data = tips
  1155. }
  1156. br.Ret = 200
  1157. br.Success = true
  1158. br.Msg = "发布成功"
  1159. }
  1160. // PublishCancelReport
  1161. // @Title 取消发布报告接口
  1162. // @Description 取消发布报告
  1163. // @Param request body models.PublishCancelReq true "type json string"
  1164. // @Success 200 Ret=200 取消发布成功
  1165. // @router /publish/cancle [post]
  1166. func (this *ReportController) PublishCancelReport() {
  1167. br := new(models.BaseResponse).Init()
  1168. defer func() {
  1169. this.Data["json"] = br
  1170. this.ServeJSON()
  1171. }()
  1172. var req models.PublishCancelReq
  1173. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1174. if err != nil {
  1175. br.Msg = "参数解析异常!"
  1176. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1177. return
  1178. }
  1179. if req.ReportIds <= 0 {
  1180. br.Msg = "参数错误"
  1181. br.ErrMsg = "参数错误,报告id不可为空"
  1182. return
  1183. }
  1184. publishTimeNullFlag := true
  1185. reportInfo, err := models.GetReportById(req.ReportIds)
  1186. if err != nil {
  1187. br.Msg = "获取报告信息失败"
  1188. br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
  1189. return
  1190. }
  1191. if reportInfo.MsgIsSend == 1 {
  1192. publishTimeNullFlag = false
  1193. }
  1194. // 根据审批开关及审批流判断当前报告状态
  1195. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperateCancelPublish)
  1196. if e != nil {
  1197. br.Msg = "操作失败"
  1198. br.ErrMsg = "校验报告当前状态失败, Err: " + e.Error()
  1199. return
  1200. }
  1201. err = models.PublishCancelReport(req.ReportIds, state, publishTimeNullFlag, this.SysUser.AdminId, this.SysUser.RealName)
  1202. if err != nil {
  1203. br.Msg = "取消发布失败"
  1204. br.ErrMsg = "取消发布失败,Err:" + err.Error()
  1205. return
  1206. }
  1207. // 更新ES禁用
  1208. {
  1209. go services.UpdateReportEs(req.ReportIds, 1)
  1210. }
  1211. //// 获取审批流设置
  1212. //confKey := "approval_flow"
  1213. //confTmp, e := company.GetConfigDetailByCode(confKey)
  1214. //if e != nil {
  1215. // br.Msg = "获取审批流配置失败"
  1216. // br.ErrMsg = "获取审批流配置失败, Err: " + e.Error()
  1217. // return
  1218. //}
  1219. //if confTmp.ConfigValue == "1" || confTmp.ConfigValue == "2" || confTmp.ConfigValue == "3" {
  1220. // br.Msg = "撤销成功"
  1221. //} else {
  1222. // br.Msg = "取消发布成功"
  1223. //}
  1224. recordItem := &models.ReportStateRecord{
  1225. ReportId: req.ReportIds,
  1226. ReportType: 1,
  1227. State: state,
  1228. AdminId: this.SysUser.AdminId,
  1229. AdminName: this.SysUser.AdminName,
  1230. CreateTime: time.Now(),
  1231. }
  1232. go func() {
  1233. _, _ = models.AddReportStateRecord(recordItem)
  1234. }()
  1235. br.Ret = 200
  1236. br.Success = true
  1237. }
  1238. // PrePublishReport
  1239. // @Title 设置定时发布接口
  1240. // @Description 设置定时发布接口
  1241. // @Param request body models.PrePublishReq true "type json string"
  1242. // @Success 200 Ret=200 发布成功
  1243. // @router /pre_publish [post]
  1244. func (this *ReportController) PrePublishReport() {
  1245. br := new(models.BaseResponse).Init()
  1246. defer func() {
  1247. this.Data["json"] = br
  1248. this.ServeJSON()
  1249. }()
  1250. var req models.PrePublishReq
  1251. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1252. if err != nil {
  1253. br.Msg = "参数解析异常!"
  1254. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1255. return
  1256. }
  1257. reportId := req.ReportId
  1258. if reportId == 0 {
  1259. br.Msg = "参数错误"
  1260. br.ErrMsg = "参数错误,报告id不可为空"
  1261. return
  1262. }
  1263. if req.PrePublishTime == "" {
  1264. br.Msg = "发布时间不能为空"
  1265. return
  1266. }
  1267. if req.PreMsgSend != 0 && req.PreMsgSend != 1 {
  1268. br.Msg = "参数错误"
  1269. br.ErrMsg = "是否发送模版消息标识错误"
  1270. return
  1271. }
  1272. prePublishTime, err := time.ParseInLocation(utils.FormatDateTime, req.PrePublishTime, time.Local)
  1273. if err != nil {
  1274. br.Msg = "发布时间格式错误"
  1275. br.ErrMsg = "发布时间格式错误,Err:" + err.Error()
  1276. return
  1277. }
  1278. if prePublishTime.Before(time.Now()) {
  1279. br.Msg = "发布时间不允许选择过去时间"
  1280. return
  1281. }
  1282. if prePublishTime.Before(time.Now().Add(2 * time.Minute)) {
  1283. br.Msg = "发布时间距离当前时间太近了"
  1284. return
  1285. }
  1286. reportDetail, err := models.GetReportById(reportId)
  1287. if err != nil {
  1288. br.Msg = "获取报告信息失败"
  1289. br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
  1290. return
  1291. }
  1292. if reportDetail == nil {
  1293. br.Msg = "报告不存在"
  1294. return
  1295. }
  1296. // 如果是章节类型的报告,那么需要确认所有章节已发布
  1297. if reportDetail.HasChapter == 1 {
  1298. chapterList, err := models.GetChapterListByReportId(reportId)
  1299. if err != nil {
  1300. return
  1301. }
  1302. for _, chapter := range chapterList {
  1303. if chapter.PublishState == 1 {
  1304. br.Msg = "还存在未发布的章节"
  1305. br.ErrMsg = "还存在未发布的章节"
  1306. return
  1307. }
  1308. }
  1309. } else {
  1310. if reportDetail.Content == "" {
  1311. br.Msg = "报告内容为空,不可设置定时发布"
  1312. br.ErrMsg = "报告内容为空,不可设置定时发布,report_id:" + strconv.Itoa(reportDetail.Id)
  1313. return
  1314. }
  1315. }
  1316. if reportDetail.State == 2 {
  1317. br.Msg = "报告已发布,不可设置定时发布"
  1318. return
  1319. }
  1320. // 校验是否开启了审批流
  1321. opening, e := services.CheckReportOpenApprove(report_approve.FlowReportTypeChinese, reportDetail.ClassifyIdFirst, reportDetail.ClassifyIdSecond, reportDetail.ClassifyIdThird)
  1322. if e != nil {
  1323. br.Msg = "操作失败"
  1324. br.ErrMsg = "校验报告是否开启审批流失败, Err: " + e.Error()
  1325. return
  1326. }
  1327. if opening {
  1328. br.Msg = "报告已开启审批流, 不可设置定时发布"
  1329. return
  1330. }
  1331. var tmpErr error
  1332. if tmpErr = models.SetPrePublishReportById(reportDetail.Id, req.PrePublishTime, req.PreMsgSend); tmpErr != nil {
  1333. br.Msg = "设置定时发布失败"
  1334. br.ErrMsg = "设置定时发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(reportDetail.Id)
  1335. return
  1336. }
  1337. // 生成报告pdf和长图
  1338. {
  1339. reportPdfUrl := services.GetGeneralPdfUrl(reportDetail.ReportCode, reportDetail.ClassifyNameFirst, reportDetail.ReportLayout)
  1340. go services.Report2pdfAndJpeg(reportPdfUrl, reportDetail.Id, 1)
  1341. }
  1342. br.Ret = 200
  1343. br.Success = true
  1344. br.Msg = "定时发布成功"
  1345. }
  1346. // SubmitApprove
  1347. // @Title 提交审批
  1348. // @Description 提交审批接口
  1349. // @Param request body models.ReportSubmitApproveReq true "type json string"
  1350. // @Success 200 Ret=200 操作成功
  1351. // @router /approve/submit [post]
  1352. func (this *ReportController) SubmitApprove() {
  1353. br := new(models.BaseResponse).Init()
  1354. defer func() {
  1355. if br.ErrMsg == "" {
  1356. br.IsSendEmail = false
  1357. }
  1358. this.Data["json"] = br
  1359. this.ServeJSON()
  1360. }()
  1361. sysUser := this.SysUser
  1362. if sysUser == nil {
  1363. br.Msg = "请登录"
  1364. br.ErrMsg = "请登录,SysUser Is Empty"
  1365. return
  1366. }
  1367. var req models.ReportSubmitApproveReq
  1368. if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
  1369. br.Msg = "参数有误"
  1370. br.ErrMsg = "参数解析失败, Err: " + e.Error()
  1371. return
  1372. }
  1373. reportId := req.ReportId
  1374. if reportId <= 0 {
  1375. br.Msg = "参数有误"
  1376. br.ErrMsg = fmt.Sprintf("参数有误, ReportId: %d", req.ReportId)
  1377. return
  1378. }
  1379. reportOb := new(models.Report)
  1380. reportItem, e := reportOb.GetItemById(reportId)
  1381. if e != nil {
  1382. if utils.IsErrNoRow(e) {
  1383. br.Msg = "报告已被删除, 请刷新页面"
  1384. return
  1385. }
  1386. br.Msg = "操作失败"
  1387. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  1388. return
  1389. }
  1390. // 如果是章节类型的报告,那么需要确认所有章节已发布
  1391. if reportItem.HasChapter == 1 {
  1392. chapterList, err := models.GetChapterListByReportId(reportId)
  1393. if err != nil {
  1394. return
  1395. }
  1396. for _, chapter := range chapterList {
  1397. if chapter.PublishState == 1 {
  1398. br.Msg = "还存在未发布的章节"
  1399. br.ErrMsg = "还存在未发布的章节"
  1400. return
  1401. }
  1402. }
  1403. } else {
  1404. if reportItem.Content == "" {
  1405. br.Msg = "报告内容为空,不可提交"
  1406. br.ErrMsg = "报告内容为空,不可提交,report_id:" + strconv.Itoa(reportItem.Id)
  1407. return
  1408. }
  1409. }
  1410. // 校验当前审批配置, 返回下一个状态
  1411. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeChinese, reportItem.ClassifyIdFirst, reportItem.ClassifyIdSecond, reportItem.ClassifyIdThird, models.ReportOperateSubmitApprove)
  1412. if e != nil {
  1413. br.Msg = "操作失败"
  1414. br.ErrMsg = "校验报告状态失败, Err: " + e.Error()
  1415. return
  1416. }
  1417. // 下一个状态不为待审批时, 仅更新状态
  1418. if state != models.ReportStateWaitApprove {
  1419. reportItem.State = state
  1420. e = reportItem.UpdateReport([]string{"State"})
  1421. if e != nil {
  1422. br.Msg = "操作失败"
  1423. br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1424. return
  1425. }
  1426. br.Ret = 200
  1427. br.Success = true
  1428. br.Msg = "操作成功"
  1429. return
  1430. }
  1431. // 提交审批
  1432. approveId, e := services.SubmitReportApprove(report_approve.FlowReportTypeChinese, reportItem.Id, reportItem.Title, reportItem.ClassifyIdFirst, reportItem.ClassifyIdSecond, reportItem.ClassifyIdThird, sysUser.AdminId, sysUser.RealName)
  1433. if e != nil {
  1434. br.Msg = "操作失败"
  1435. br.ErrMsg = "提交审批失败, Err: " + e.Error()
  1436. return
  1437. }
  1438. reportItem.ApproveId = approveId
  1439. reportItem.State = models.ReportStateWaitApprove
  1440. reportItem.ModifyTime = time.Now().Local()
  1441. e = reportItem.UpdateReport([]string{"ApproveId", "State", "ModifyTime"})
  1442. if e != nil {
  1443. br.Msg = "操作失败"
  1444. br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1445. return
  1446. }
  1447. // 报告权限处理
  1448. {
  1449. go services.HandleReportPermission(reportItem)
  1450. }
  1451. br.Ret = 200
  1452. br.Success = true
  1453. br.Msg = "操作成功"
  1454. }
  1455. // CancelApprove
  1456. // @Title 撤销审批
  1457. // @Description 撤销审批
  1458. // @Param request body models.ReportCancelApproveReq true "type json string"
  1459. // @Success 200 Ret=200 操作成功
  1460. // @router /approve/cancel [post]
  1461. func (this *ReportController) CancelApprove() {
  1462. br := new(models.BaseResponse).Init()
  1463. defer func() {
  1464. if br.ErrMsg == "" {
  1465. br.IsSendEmail = false
  1466. }
  1467. this.Data["json"] = br
  1468. this.ServeJSON()
  1469. }()
  1470. sysUser := this.SysUser
  1471. if sysUser == nil {
  1472. br.Msg = "请登录"
  1473. br.ErrMsg = "请登录,SysUser Is Empty"
  1474. return
  1475. }
  1476. var req models.ReportCancelApproveReq
  1477. if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
  1478. br.Msg = "参数有误"
  1479. br.ErrMsg = "参数解析失败, Err: " + e.Error()
  1480. return
  1481. }
  1482. reportId := req.ReportId
  1483. if reportId <= 0 {
  1484. br.Msg = "参数有误"
  1485. br.ErrMsg = fmt.Sprintf("参数有误, ReportId: %d", req.ReportId)
  1486. return
  1487. }
  1488. reportOb := new(models.Report)
  1489. reportItem, e := reportOb.GetItemById(reportId)
  1490. if e != nil {
  1491. if utils.IsErrNoRow(e) {
  1492. br.Msg = "报告已被删除, 请刷新页面"
  1493. return
  1494. }
  1495. br.Msg = "操作失败"
  1496. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  1497. return
  1498. }
  1499. // 校验当前审批配置, 返回下一个状态
  1500. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeChinese, reportItem.ClassifyIdFirst, reportItem.ClassifyIdSecond, reportItem.ClassifyIdThird, models.ReportOperateCancelApprove)
  1501. if e != nil {
  1502. br.Msg = "操作失败"
  1503. br.ErrMsg = "校验报告状态失败, Err: " + e.Error()
  1504. return
  1505. }
  1506. // 下一个状态不为待提交时, 仅更新状态
  1507. if state != models.ReportStateWaitSubmit {
  1508. reportItem.State = state
  1509. e = reportItem.UpdateReport([]string{"State"})
  1510. if e != nil {
  1511. br.Msg = "操作失败"
  1512. br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1513. return
  1514. }
  1515. br.Ret = 200
  1516. br.Success = true
  1517. br.Msg = "操作成功"
  1518. return
  1519. }
  1520. //if reportItem.ApproveId <= 0 {
  1521. // br.Msg = "报告审批不存在"
  1522. // br.ErrMsg = fmt.Sprintf("报告审批不存在, ApproveId: %d", reportItem.ApproveId)
  1523. // return
  1524. //}
  1525. // 撤销审批
  1526. e = services.CancelReportApprove(report_approve.FlowReportTypeChinese, reportItem.Id, reportItem.ApproveId, sysUser.AdminId, sysUser.RealName)
  1527. if e != nil {
  1528. br.Msg = "操作失败"
  1529. br.ErrMsg = "撤销审批失败, Err: " + e.Error()
  1530. return
  1531. }
  1532. //reportItem.ApproveId = 0
  1533. //reportItem.State = models.ReportStateWaitSubmit
  1534. //reportItem.ModifyTime = time.Now().Local()
  1535. //e = reportItem.UpdateReport([]string{"ApproveId", "State", "ModifyTime"})
  1536. //if e != nil {
  1537. // br.Msg = "操作失败"
  1538. // br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1539. // return
  1540. //}
  1541. br.Ret = 200
  1542. br.Success = true
  1543. br.Msg = "操作成功"
  1544. }
  1545. // MessageList
  1546. // @Title 报告消息列表
  1547. // @Description 报告消息列表
  1548. // @Param PageSize query int true "每页数据条数"
  1549. // @Param CurrentIndex query int true "当前页页码"
  1550. // @Success 200 {object} models.ReportMessageListResp
  1551. // @router /message/list [get]
  1552. func (this *ReportController) MessageList() {
  1553. br := new(models.BaseResponse).Init()
  1554. defer func() {
  1555. if br.ErrMsg == "" {
  1556. br.IsSendEmail = false
  1557. }
  1558. this.Data["json"] = br
  1559. this.ServeJSON()
  1560. }()
  1561. sysUser := this.SysUser
  1562. if sysUser == nil {
  1563. br.Msg = "请登录"
  1564. br.ErrMsg = "请登录,SysUser Is Empty"
  1565. br.Ret = 408
  1566. return
  1567. }
  1568. pageSize, _ := this.GetInt("PageSize")
  1569. pageIndex, _ := this.GetInt("CurrentIndex")
  1570. // 分页
  1571. var startSize int
  1572. if pageSize <= 0 {
  1573. pageSize = utils.PageSize20
  1574. }
  1575. if pageIndex <= 0 {
  1576. pageIndex = 1
  1577. }
  1578. startSize = utils.StartIndex(pageIndex, pageSize)
  1579. resp := new(models.ReportMessageListResp)
  1580. resp.List = make([]*models.ReportMessageItem, 0)
  1581. cond := fmt.Sprintf(` AND %s = ?`, models.ReportMessageCols.ReceiveUserId)
  1582. pars := make([]interface{}, 0)
  1583. pars = append(pars, sysUser.AdminId)
  1584. order := fmt.Sprintf(`%s ASC, %s DESC`, models.ReportMessageCols.IsRead, models.ReportMessageCols.CreateTime)
  1585. messageOb := new(models.ReportMessage)
  1586. total, e := messageOb.GetCountByCondition(cond, pars)
  1587. if e != nil {
  1588. br.Msg = "获取失败"
  1589. br.ErrMsg = "获取消息列表总数失败, Err: " + e.Error()
  1590. return
  1591. }
  1592. list, e := messageOb.GetPageItemsByCondition(cond, pars, []string{}, order, startSize, pageSize)
  1593. if e != nil {
  1594. br.Msg = "获取失败"
  1595. br.ErrMsg = "获取消息列表失败, Err: " + e.Error()
  1596. return
  1597. }
  1598. var reportIds, pptIds []int
  1599. for _, v := range list {
  1600. t := models.FormatReportMessage2Item(v)
  1601. if v.ExtraContent != "" {
  1602. am := new(models.ReportMessageApproveItem)
  1603. if e = json.Unmarshal([]byte(v.ExtraContent), &am); e != nil {
  1604. br.Msg = "获取失败"
  1605. br.ErrMsg = fmt.Sprintf("消息列表审批信息解析失败, %v", e)
  1606. return
  1607. }
  1608. t.ApproveMsg = am
  1609. }
  1610. resp.List = append(resp.List, t)
  1611. // 报告状态,这里动态去获取
  1612. if v.ReportType == utils.ReportTypeDefault {
  1613. reportIds = append(reportIds, v.ReportId)
  1614. }
  1615. if v.ReportType == utils.ReportTypePPT {
  1616. pptIds = append(pptIds, v.ReportId)
  1617. }
  1618. }
  1619. stateReport := make(map[int]int)
  1620. statePpt := make(map[int]int)
  1621. if len(reportIds) > 0 {
  1622. ob := new(models.Report)
  1623. cond := ` AND id IN (?)`
  1624. pars := make([]interface{}, 0)
  1625. pars = append(pars, reportIds)
  1626. items, e := ob.GetItemsByCondition(cond, pars, []string{"id", "state"}, "")
  1627. if e != nil {
  1628. br.Msg = "获取失败"
  1629. br.ErrMsg = fmt.Sprintf("获取报告列表失败, %v", e)
  1630. return
  1631. }
  1632. for _, v := range items {
  1633. stateReport[v.Id] = v.State
  1634. }
  1635. }
  1636. if len(pptIds) > 0 {
  1637. ob := new(models.PptV2)
  1638. cond := ` AND ppt_id IN (?)`
  1639. pars := make([]interface{}, 0)
  1640. pars = append(pars, pptIds)
  1641. items, e := ob.GetItemsByCondition(cond, pars, []string{"ppt_id", "state"}, "")
  1642. if e != nil {
  1643. br.Msg = "获取失败"
  1644. br.ErrMsg = fmt.Sprintf("获取PPT列表失败, %v", e)
  1645. return
  1646. }
  1647. for _, v := range items {
  1648. statePpt[v.PptId] = v.State
  1649. }
  1650. }
  1651. for _, v := range resp.List {
  1652. if v.ReportType == utils.ReportTypeDefault {
  1653. v.ReportState = stateReport[v.ReportId]
  1654. }
  1655. if v.ReportType == utils.ReportTypePPT {
  1656. v.ReportState = statePpt[v.ReportId]
  1657. }
  1658. }
  1659. // 未读消息数
  1660. cond += fmt.Sprintf(` AND %s = ?`, models.ReportMessageCols.IsRead)
  1661. pars = append(pars, 0)
  1662. unreadTotal, e := messageOb.GetCountByCondition(cond, pars)
  1663. if e != nil {
  1664. br.Msg = "获取失败"
  1665. br.ErrMsg = "获取消息列表总数失败, Err: " + e.Error()
  1666. return
  1667. }
  1668. resp.UnreadTotal = unreadTotal
  1669. page := paging.GetPaging(pageIndex, pageSize, total)
  1670. resp.Paging = page
  1671. br.Data = resp
  1672. br.Ret = 200
  1673. br.Success = true
  1674. br.Msg = "获取成功"
  1675. }
  1676. // MessageRead
  1677. // @Title 消息已读
  1678. // @Description 消息已读
  1679. // @Param request body models.ReportMessageReadReq true "type json string"
  1680. // @Success 200 string "操作成功"
  1681. // @router /message/read [post]
  1682. func (this *ReportController) MessageRead() {
  1683. br := new(models.BaseResponse).Init()
  1684. defer func() {
  1685. if br.ErrMsg == "" {
  1686. br.IsSendEmail = false
  1687. }
  1688. this.Data["json"] = br
  1689. this.ServeJSON()
  1690. }()
  1691. sysUser := this.SysUser
  1692. if sysUser == nil {
  1693. br.Msg = "请登录"
  1694. br.ErrMsg = "请登录,SysUser Is Empty"
  1695. br.Ret = 408
  1696. return
  1697. }
  1698. var req models.ReportMessageReadReq
  1699. if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
  1700. br.Msg = "参数有误"
  1701. br.ErrMsg = "参数解析失败, Err: " + e.Error()
  1702. return
  1703. }
  1704. if req.MessageId <= 0 {
  1705. br.Msg = "参数有误"
  1706. br.ErrMsg = fmt.Sprintf("参数有误, MessageId: %d", req.MessageId)
  1707. return
  1708. }
  1709. messageOb := new(models.ReportMessage)
  1710. messageItem, e := messageOb.GetItemById(req.MessageId)
  1711. if e != nil {
  1712. if utils.IsErrNoRow(e) {
  1713. br.Msg = "消息不存在, 请刷新页面"
  1714. return
  1715. }
  1716. br.Msg = "获取失败"
  1717. br.ErrMsg = "获取消息失败, Err: " + e.Error()
  1718. return
  1719. }
  1720. messageItem.IsRead = 1
  1721. messageItem.ModifyTime = time.Now().Local()
  1722. cols := []string{"IsRead", "ModifyTime"}
  1723. if e = messageItem.Update(cols); e != nil {
  1724. br.Msg = "操作失败"
  1725. br.ErrMsg = "更新消息已读失败, Err: " + e.Error()
  1726. return
  1727. }
  1728. br.Ret = 200
  1729. br.Success = true
  1730. br.Msg = "操作成功"
  1731. }