report.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949
  1. package english_report
  2. import "hongze/hz_crm_api/controllers"
  3. // EnglishReportController 研报活动模块
  4. type EnglishReportController struct {
  5. controllers.BaseAuthController
  6. }
  7. //// @Title 新增报告接口
  8. //// @Description 新增报告
  9. //// @Param request body models.AddEnglishReportReq true "type json string"
  10. //// @Success 200 {object} models.AddEnglishReportResp
  11. //// @router /add [post]
  12. //func (this *EnglishReportController) Add() {
  13. // br := new(models.BaseResponse).Init()
  14. // defer func() {
  15. // this.Data["json"] = br
  16. // this.ServeJSON()
  17. // }()
  18. // sysUser := this.SysUser
  19. // if sysUser == nil {
  20. // br.Msg = "请登录"
  21. // br.ErrMsg = "请登录,SysUser Is Empty"
  22. // br.Ret = 408
  23. // return
  24. // }
  25. // var req models.AddEnglishReportReq
  26. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  27. // if err != nil {
  28. // br.Msg = "参数解析异常!"
  29. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  30. // return
  31. // }
  32. // if req.Content == "" {
  33. // br.Msg = "请输入内容"
  34. // return
  35. // }
  36. // if req.Overview == "" {
  37. // br.Msg = "请输入overview"
  38. // return
  39. // }
  40. // if req.Abstract == "" {
  41. // br.Msg = "请输入摘要"
  42. // return
  43. // }
  44. //
  45. // var contentSub string
  46. // if req.Content != "" {
  47. // content, e := services.FilterReportContentBr(req.Content)
  48. // if e != nil {
  49. // br.Msg = "内容去除前后空格失败"
  50. // br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  51. // return
  52. // }
  53. // req.Content = content
  54. //
  55. // contentSub, err = services.GetReportContentSub(req.Content)
  56. // if err != nil {
  57. // go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+err.Error(), 3)
  58. // //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  59. // }
  60. // }
  61. // maxStage, err := models.GetEnglishReportStage(req.ClassifyIdFirst, req.ClassifyIdSecond)
  62. // if err != nil {
  63. // br.Msg = "期数获取失败!"
  64. // br.ErrMsg = "期数获取失败,Err:" + err.Error()
  65. // return
  66. // }
  67. //
  68. // item := new(models.EnglishReport)
  69. // item.AddType = req.AddType
  70. // item.ClassifyIdFirst = req.ClassifyIdFirst
  71. // item.ClassifyNameFirst = req.ClassifyNameFirst
  72. // item.ClassifyIdSecond = req.ClassifyIdSecond
  73. // item.ClassifyNameSecond = req.ClassifyNameSecond
  74. // item.Title = req.Title
  75. // item.Abstract = req.Abstract
  76. // item.Author = req.Author
  77. // item.Frequency = req.Frequency
  78. // item.State = req.State
  79. // item.Content = html.EscapeString(req.Content)
  80. // item.Stage = maxStage + 1
  81. // item.ContentSub = html.EscapeString(contentSub)
  82. // item.CreateTime = req.CreateTime
  83. // item.ModifyTime = time.Now()
  84. // item.Overview = req.Overview
  85. // item.AdminId = sysUser.AdminId
  86. // item.AdminRealName = sysUser.RealName
  87. // newReportId, err := models.AddEnglishReport(item)
  88. // if err != nil {
  89. // br.Msg = "保存失败"
  90. // br.ErrMsg = "保存失败,Err:" + err.Error()
  91. // return
  92. // }
  93. // reportCode := utils.MD5(strconv.Itoa(int(newReportId)))
  94. // //修改唯一编码
  95. // {
  96. // go models.ModifyEnglishReportCode(newReportId, reportCode)
  97. // }
  98. // resp := new(models.AddEnglishReportResp)
  99. // resp.ReportId = newReportId
  100. // resp.ReportCode = reportCode
  101. // br.Ret = 200
  102. // br.Success = true
  103. // br.Msg = "保存成功"
  104. // br.Data = resp
  105. //}
  106. //
  107. //// @Title 编辑报告接口
  108. //// @Description 编辑报告
  109. //// @Param request body models.EditEnglishReportReq true "type json string"
  110. //// @Success 200 {object} models.EditEnglishReportResp
  111. //// @router /edit [post]
  112. //func (this *EnglishReportController) Edit() {
  113. // br := new(models.BaseResponse).Init()
  114. // defer func() {
  115. // this.Data["json"] = br
  116. // this.ServeJSON()
  117. // }()
  118. // sysUser := this.SysUser
  119. // if sysUser == nil {
  120. // br.Msg = "请登录"
  121. // br.ErrMsg = "请登录,SysUser Is Empty"
  122. // br.Ret = 408
  123. // return
  124. // }
  125. // var req models.EditEnglishReportReq
  126. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  127. // if err != nil {
  128. // br.Msg = "参数解析异常!"
  129. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  130. // return
  131. // }
  132. // if req.Content == "" {
  133. // br.Msg = "请输入内容"
  134. // return
  135. // }
  136. // if req.Overview == "" {
  137. // br.Msg = "请输入overview"
  138. // return
  139. // }
  140. // if req.Abstract == "" {
  141. // br.Msg = "请输入摘要"
  142. // return
  143. // }
  144. //
  145. // markStatus, err := services.UpdateEnReportEditMark(int(req.ReportId), sysUser.AdminId, 1, sysUser.RealName)
  146. // if err != nil {
  147. // br.Msg = err.Error()
  148. // return
  149. // }
  150. // if markStatus.Status == 1 {
  151. // br.Msg = markStatus.Msg
  152. // return
  153. // }
  154. // var contentSub string
  155. // if req.Content != "" {
  156. // content, e := services.FilterReportContentBr(req.Content)
  157. // if e != nil {
  158. // br.Msg = "内容去除前后空格失败"
  159. // br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  160. // return
  161. // }
  162. // req.Content = content
  163. //
  164. // contentSub, err = services.GetReportContentSub(req.Content)
  165. // if err != nil {
  166. // go alarm_msg.SendAlarmMsg("解析 ContentSub 失败,Err:"+err.Error(), 3)
  167. // //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  168. // }
  169. // }
  170. //
  171. // var stage int
  172. // report, _ := models.GetEnglishReportById(int(req.ReportId))
  173. // if report != nil {
  174. // if report.ClassifyNameFirst != req.ClassifyNameFirst || report.ClassifyNameSecond != req.ClassifyNameSecond {
  175. // maxStage, _ := models.GetEnglishReportStageEdit(req.ClassifyIdFirst, req.ClassifyIdSecond, int(req.ReportId))
  176. // maxStage = maxStage + 1
  177. // stage = maxStage
  178. // } else {
  179. // stage = report.Stage
  180. // }
  181. // }
  182. //
  183. // item := new(models.EnglishReport)
  184. // item.ClassifyIdFirst = req.ClassifyIdFirst
  185. // item.ClassifyNameFirst = req.ClassifyNameFirst
  186. // item.ClassifyIdSecond = req.ClassifyIdSecond
  187. // item.ClassifyNameSecond = req.ClassifyNameSecond
  188. // item.Title = req.Title
  189. // item.Abstract = req.Abstract
  190. // item.Author = req.Author
  191. // item.Frequency = req.Frequency
  192. // item.State = req.State
  193. // item.Stage = stage
  194. // item.Content = html.EscapeString(req.Content)
  195. // item.ContentSub = html.EscapeString(contentSub)
  196. // item.CreateTime = req.CreateTime
  197. // item.Overview = req.Overview
  198. // err = models.EditEnglishReport(item, req.ReportId)
  199. // if err != nil {
  200. // br.Msg = "保存失败"
  201. // br.ErrMsg = "保存失败,Err:" + err.Error()
  202. // return
  203. // }
  204. //
  205. // reportCode := utils.MD5(strconv.Itoa(int(req.ReportId)))
  206. // resp := new(models.EditEnglishReportResp)
  207. // resp.ReportId = req.ReportId
  208. // resp.ReportCode = reportCode
  209. // br.Ret = 200
  210. // br.Success = true
  211. // br.Msg = "保存成功"
  212. // br.Data = resp
  213. //}
  214. //
  215. //// @Title 获取报告详情接口
  216. //// @Description 获取报告详情
  217. //// @Param request body models.ReportDetailReq true "type json string"
  218. //// @Success 200 {object} models.EnglishReportDetailView
  219. //// @router /detail [get]
  220. //func (this *EnglishReportController) Detail() {
  221. // br := new(models.BaseResponse).Init()
  222. // defer func() {
  223. // this.Data["json"] = br
  224. // this.ServeJSON()
  225. // }()
  226. // /*var req models.ReportDetailReq
  227. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  228. // if err != nil {
  229. // br.Msg = "参数解析异常!"
  230. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  231. // return
  232. // }
  233. // if req.ReportId <= 0 {
  234. // br.Msg = "参数错误"
  235. // return
  236. // }*/
  237. // reportId, err := this.GetInt("ReportId")
  238. // if err != nil {
  239. // br.Msg = "获取参数失败!"
  240. // br.ErrMsg = "获取参数失败,Err:" + err.Error()
  241. // return
  242. // }
  243. // if reportId <= 0 {
  244. // br.Msg = "参数错误"
  245. // return
  246. // }
  247. // item, err := models.GetEnglishReportById(reportId)
  248. // if err != nil {
  249. // br.Msg = "获取失败"
  250. // br.ErrMsg = "获取失败,Err:" + err.Error()
  251. // return
  252. // }
  253. //
  254. // item.Content = html.UnescapeString(item.Content)
  255. // item.ContentSub = html.UnescapeString(item.ContentSub)
  256. //
  257. // br.Ret = 200
  258. // br.Success = true
  259. // br.Msg = "获取成功"
  260. // br.Data = item
  261. //}
  262. //
  263. //// @Title 获取报告列表接口
  264. //// @Description 获取报告列表
  265. //// @Param PageSize query int true "每页数据条数"
  266. //// @Param CurrentIndex query int true "当前页页码,从1开始"
  267. //// @Param StartDate query string true "开始时间"
  268. //// @Param EndDate query string true "结束时间"
  269. //// @Param Frequency query string true "频度"
  270. //// @Param ClassifyNameFirst query string true "一级分类名称"
  271. //// @Param ClassifyNameSecond query string true "二级分类名称"
  272. //// @Param State query int true "状态"
  273. //// @Param KeyWord query string true "搜索关键词"
  274. //// @Param PublishSort query string true "desc:降序,asc 升序(预留)"
  275. //// @Param CompanyType query string false "产品类型,枚举值:'ficc','权益';不传默认返回全部"
  276. //// @Success 200 {object} models.ReportListResp
  277. //// @router /list [get]
  278. //func (this *EnglishReportController) ListReport() {
  279. // br := new(models.BaseResponse).Init()
  280. // defer func() {
  281. // this.Data["json"] = br
  282. // this.ServeJSON()
  283. // }()
  284. // sysUser := this.SysUser
  285. // if sysUser == nil {
  286. // br.Msg = "请登录"
  287. // br.ErrMsg = "请登录,SysUser Is Empty"
  288. // br.Ret = 408
  289. // return
  290. // }
  291. //
  292. // pageSize, _ := this.GetInt("PageSize")
  293. // currentIndex, _ := this.GetInt("CurrentIndex")
  294. //
  295. // startDate := this.GetString("StartDate")
  296. // endDate := this.GetString("EndDate")
  297. // frequency := this.GetString("Frequency")
  298. // classifyNameFirst := this.GetString("ClassifyNameFirst")
  299. // classifyNameSecond := this.GetString("ClassifyNameSecond")
  300. // state, _ := this.GetInt("State")
  301. // keyWord := this.GetString("KeyWord")
  302. // companyType := this.GetString("CompanyType")
  303. // // 群发邮件状态筛选
  304. // emailState, _ := this.GetInt("EmailState")
  305. //
  306. // var startSize int
  307. // if pageSize <= 0 {
  308. // pageSize = utils.PageSize20
  309. // }
  310. // if currentIndex <= 0 {
  311. // currentIndex = 1
  312. // }
  313. // startSize = utils.StartIndex(currentIndex, pageSize)
  314. //
  315. // var condition string
  316. // var pars []interface{}
  317. //
  318. // if keyWord != "" {
  319. // condition += ` AND (title LIKE '%` + keyWord + `%' OR author LIKE '%` + keyWord + `%' ) `
  320. // }
  321. // if startDate != "" {
  322. // condition += ` AND create_time >= ? `
  323. // pars = append(pars, startDate)
  324. // }
  325. // if endDate != "" {
  326. // condition += ` AND create_time <= ? `
  327. // pars = append(pars, endDate)
  328. // }
  329. // if frequency != "" {
  330. // condition += ` AND frequency = ? `
  331. // pars = append(pars, frequency)
  332. // }
  333. // if classifyNameFirst != "" {
  334. // condition += ` AND classify_name_first = ? `
  335. // pars = append(pars, classifyNameFirst)
  336. // }
  337. //
  338. // if classifyNameSecond != "" {
  339. // condition += ` AND classify_name_second = ? `
  340. // pars = append(pars, classifyNameSecond)
  341. // }
  342. // if state > 0 {
  343. // condition += ` AND state = ? `
  344. // pars = append(pars, state)
  345. // }
  346. // // 未群发邮件(包含推送邮件失败的)
  347. // if emailState == 1 {
  348. // failIds, e := models.GetHasFailEmailLogReportIds()
  349. // if e != nil {
  350. // br.Msg = "获取失败"
  351. // br.ErrMsg = "获取存在邮件推送失败记录的英文报告IDs失败, Err:" + e.Error()
  352. // return
  353. // }
  354. // condition += ` AND email_state = 0`
  355. // if len(failIds) > 0 {
  356. // condition += ` OR id IN (` + utils.GetOrmInReplace(len(failIds)) + `)`
  357. // pars = append(pars, failIds)
  358. // }
  359. // }
  360. // // 已群发邮件
  361. // if emailState == 2 {
  362. // successIds, e := models.GetSuccessEmailLogReportIds()
  363. // if e != nil {
  364. // br.Msg = "获取失败"
  365. // br.ErrMsg = "获取邮件推送记录均为成功的英文报告IDs失败, Err:" + e.Error()
  366. // return
  367. // }
  368. // condition += ` AND email_state = 1`
  369. // if len(successIds) > 0 {
  370. // condition += ` AND id IN (` + utils.GetOrmInReplace(len(successIds)) + `)`
  371. // pars = append(pars, successIds)
  372. // }
  373. // }
  374. //
  375. // total, err := models.GetEnglishReportListCount(condition, pars, companyType)
  376. // if err != nil {
  377. // br.Msg = "获取失败"
  378. // br.ErrMsg = "获取失败,Err:" + err.Error()
  379. // return
  380. // }
  381. // list, err := models.GetEnglishReportList(condition, pars, companyType, startSize, pageSize)
  382. // if err != nil {
  383. // br.Msg = "获取失败"
  384. // br.ErrMsg = "获取失败,Err:" + err.Error()
  385. // return
  386. // }
  387. //
  388. // // 获取邮件配置-是否有权限群发
  389. // conf := new(models.EnglishReportEmailConf)
  390. // authKey := "english_report_email_conf"
  391. // confAuth, e := company.GetConfigDetailByCode(authKey)
  392. // if e != nil {
  393. // br.Msg = "获取失败"
  394. // br.ErrMsg = "获取群发邮件权限失败, Err: " + e.Error()
  395. // return
  396. // }
  397. // if confAuth.ConfigValue == "" {
  398. // br.Msg = "获取失败"
  399. // br.ErrMsg = "群发邮件配置为空"
  400. // return
  401. // }
  402. // if e := json.Unmarshal([]byte(confAuth.ConfigValue), &conf); e != nil {
  403. // br.Msg = "获取失败"
  404. // br.ErrMsg = "群发邮件配置有误"
  405. // return
  406. // }
  407. // authOk := false
  408. // authArr := strings.Split(conf.SendAuthGroup, ",")
  409. // if utils.InArrayByStr(authArr, sysUser.RoleTypeCode) {
  410. // authOk = true
  411. // }
  412. //
  413. // // 是否有群发邮件失败的记录,标记红点
  414. // failList, e := models.GetEnglishReportEmailLogFailList(0)
  415. // if e != nil {
  416. // br.Msg = "获取失败"
  417. // br.ErrMsg = "获取群发邮件记录失败, Err: " + e.Error()
  418. // return
  419. // }
  420. // failMap := make(map[int]bool, 0)
  421. // for i := range failList {
  422. // failMap[failList[i].ReportId] = true
  423. // }
  424. //
  425. // for _, item := range list {
  426. // if item.State == 2 {
  427. // item.ShareUrl = "https://share.hzinsights.com/reportEn?code=" + item.ReportCode
  428. // }
  429. // item.EmailAuth = authOk
  430. // item.EmailHasFail = failMap[item.Id]
  431. // // 邮箱PV大于0的时候, 不展示最初版本的PV
  432. // if item.PvEmail > 0 {
  433. // item.Pv = 0
  434. // }
  435. //
  436. // /*key := fmt.Sprint(`crm:enReport:edit:`, item.Id)
  437. // opUserId, _ := utils.Rc.RedisInt(key)
  438. // //如果当前没有人操作,获取当前操作人是本人,那么编辑按钮可用
  439. // if opUserId <= 0 || (opUserId == this.SysUser.AdminId) {
  440. // item.CanEdit = true
  441. // } else {
  442. // adminInfo, errAdmin := system.GetSysUserById(opUserId)
  443. // if errAdmin != nil {
  444. // br.Msg = "获取失败"
  445. // br.ErrMsg = "获取失败,Err:" + errAdmin.Error()
  446. // return
  447. // }
  448. // item.Editor = adminInfo.RealName
  449. // }*/
  450. // markStatus, err := services.UpdateEnReportEditMark(item.Id, this.SysUser.AdminId, 2, this.SysUser.RealName)
  451. // if err != nil {
  452. // br.Msg = "查询标记状态失败"
  453. // br.ErrMsg = "查询标记状态失败,Err:" + err.Error()
  454. // return
  455. // }
  456. // if markStatus.Status == 0 {
  457. // item.CanEdit = true
  458. // } else {
  459. // item.Editor = markStatus.Editor
  460. // }
  461. // }
  462. // page := paging.GetPaging(currentIndex, pageSize, total)
  463. // resp := new(models.EnglishReportListResp)
  464. // resp.Paging = page
  465. // resp.List = list
  466. // br.Ret = 200
  467. // br.Success = true
  468. // br.Msg = "获取成功"
  469. // br.Data = resp
  470. //}
  471. //
  472. //// @Title 发布报告接口
  473. //// @Description 发布报告
  474. //// @Param request body models.PublishReq true "type json string"
  475. //// @Success 200 Ret=200 发布成功
  476. //// @router /publish [post]
  477. //func (this *EnglishReportController) PublishReport() {
  478. // br := new(models.BaseResponse).Init()
  479. // defer func() {
  480. // this.Data["json"] = br
  481. // this.ServeJSON()
  482. // }()
  483. // var req models.PublishReq
  484. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  485. // if err != nil {
  486. // br.Msg = "参数解析异常!"
  487. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  488. // return
  489. // }
  490. // reportIds := req.ReportIds
  491. // if reportIds == "" {
  492. // br.Msg = "参数错误"
  493. // br.ErrMsg = "参数错误,报告id不可为空"
  494. // return
  495. // }
  496. //
  497. // reportArr := strings.Split(reportIds, ",")
  498. // for _, v := range reportArr {
  499. // vint, err := strconv.Atoi(v)
  500. // if err != nil {
  501. // br.Msg = "参数错误"
  502. // br.ErrMsg = "参数错误,Err:" + err.Error()
  503. // return
  504. // }
  505. // report, err := models.GetEnglishReportById(vint)
  506. // if err != nil {
  507. // br.Msg = "获取报告信息失败"
  508. // br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
  509. // return
  510. // }
  511. // if report == nil {
  512. // br.Msg = "报告不存在"
  513. // return
  514. // }
  515. //
  516. // var tmpErr error
  517. //
  518. // if report.Content == "" {
  519. // br.Msg = "报告内容为空,不可发布"
  520. // br.ErrMsg = "报告内容为空,不需要生成,report_id:" + strconv.Itoa(report.Id)
  521. // return
  522. // }
  523. // if tmpErr = models.PublishEnglishReportById(report.Id); tmpErr != nil {
  524. // br.Msg = "报告发布失败"
  525. // br.ErrMsg = "报告发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(report.Id)
  526. // return
  527. // }
  528. // go func() {
  529. // _ = services.UpdateEnglishReportEs(report.Id, 2)
  530. // }()
  531. // }
  532. //
  533. // br.Ret = 200
  534. // br.Success = true
  535. // br.Msg = "发布成功"
  536. //}
  537. //
  538. //// @Title 取消发布报告接口
  539. //// @Description 取消发布报告
  540. //// @Param request body models.PublishCancelReq true "type json string"
  541. //// @Success 200 Ret=200 取消发布成功
  542. //// @router /publish/cancel [post]
  543. //func (this *EnglishReportController) PublishCancleReport() {
  544. // br := new(models.BaseResponse).Init()
  545. // defer func() {
  546. // this.Data["json"] = br
  547. // this.ServeJSON()
  548. // }()
  549. // var req models.PublishCancelReq
  550. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  551. // if err != nil {
  552. // br.Msg = "参数解析异常!"
  553. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  554. // return
  555. // }
  556. // if req.ReportIds <= 0 {
  557. // br.Msg = "参数错误"
  558. // br.ErrMsg = "参数错误,报告id不可为空"
  559. // return
  560. // }
  561. // err = models.PublishCancelEnglishReport(req.ReportIds)
  562. // if err != nil {
  563. // br.Msg = "取消发布失败"
  564. // br.ErrMsg = "取消发布失败,Err:" + err.Error()
  565. // return
  566. // }
  567. // // 更新es里的报告状态
  568. // go func() {
  569. // _ = services.UpdateEnglishReportEs(req.ReportIds, 1)
  570. // }()
  571. // br.Ret = 200
  572. // br.Success = true
  573. // br.Msg = "取消发布成功"
  574. //}
  575. //
  576. //// @Title 删除报告接口
  577. //// @Description 删除报告
  578. //// @Param request body models.DeleteReq true "type json string"
  579. //// @Success 200 Ret=200 删除成功
  580. //// @router /delete [post]
  581. //func (this *EnglishReportController) Delete() {
  582. // br := new(models.BaseResponse).Init()
  583. // defer func() {
  584. // this.Data["json"] = br
  585. // this.ServeJSON()
  586. // }()
  587. // var req models.DeleteReq
  588. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  589. // if err != nil {
  590. // br.Msg = "参数解析异常!"
  591. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  592. // return
  593. // }
  594. // if req.ReportIds <= 0 {
  595. // br.Msg = "参数错误"
  596. // br.ErrMsg = "参数错误,报告id不可为空"
  597. // return
  598. // }
  599. // reportInfo, err := models.GetEnglishReportById(req.ReportIds)
  600. // if err != nil {
  601. // if err.Error() == utils.ErrNoRow() {
  602. // br.Msg = "报告不存在"
  603. // return
  604. // }
  605. // br.Msg = "查询报告信息失败"
  606. // br.ErrMsg = "查询报告信息失败, Err" + err.Error()
  607. // return
  608. // }
  609. //
  610. // // 更新es里的报告状态
  611. // _ = services.UpdateEnglishReportEs(req.ReportIds, 1)
  612. // if err = models.DeleteEnglishReportAndChapter(reportInfo); err != nil {
  613. // br.Msg = "删除失败"
  614. // br.ErrMsg = "删除报告失败, Err: " + err.Error()
  615. // return
  616. // }
  617. //
  618. // // 重置PPT关联报告
  619. // go func() {
  620. // _ = services.ResetPPTReport(req.ReportIds, true)
  621. // }()
  622. //
  623. // go func() {
  624. // _ = services.EnglishPolicyReportSyncCancel(reportInfo)
  625. // }()
  626. // br.Ret = 200
  627. // br.Success = true
  628. // br.Msg = "删除成功"
  629. //}
  630. //
  631. //// @Title 保存草稿
  632. //// @Description 保存草稿
  633. //// @Param request body models.SaveReportContent true "type json string"
  634. //// @Success 200 {object} models.ReportAuthorResp
  635. //// @router /saveReportContent [post]
  636. //func (this *EnglishReportController) SaveReportContent() {
  637. // br := new(models.BaseResponse).Init()
  638. // br.IsSendEmail = false
  639. // defer func() {
  640. // this.Data["json"] = br
  641. // this.ServeJSON()
  642. // }()
  643. // var req models.SaveReportContent
  644. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  645. // if err != nil {
  646. // br.Msg = "参数解析异常!"
  647. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  648. // return
  649. // }
  650. //
  651. // sysUser := this.SysUser
  652. // if sysUser == nil {
  653. // br.Msg = "请登录"
  654. // br.ErrMsg = "请登录,SysUser Is Empty"
  655. // br.Ret = 408
  656. // return
  657. // }
  658. //
  659. // reportId := req.ReportId
  660. // noChangeFlag := req.NoChange
  661. // fmt.Println("reportId:", reportId)
  662. // if reportId <= 0 {
  663. // br.Msg = "请输入报告ID"
  664. // return
  665. // }
  666. // markStatus, err := services.UpdateEnReportEditMark(int(req.ReportId), sysUser.AdminId, 1, sysUser.RealName)
  667. // if err != nil {
  668. // br.Msg = err.Error()
  669. // return
  670. // }
  671. // if markStatus.Status == 1 {
  672. // br.Msg = markStatus.Msg
  673. // return
  674. // }
  675. //
  676. // if noChangeFlag != 1 {
  677. // content := req.Content
  678. // if content == "" {
  679. // content = this.GetString("Content")
  680. // }
  681. // if content != "" {
  682. // contentClean, e := services.FilterReportContentBr(req.Content)
  683. // if e != nil {
  684. // br.Msg = "内容去除前后空格失败"
  685. // br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  686. // return
  687. // }
  688. // content = contentClean
  689. //
  690. // contentSub, err := services.GetReportContentSub(content)
  691. // if err != nil {
  692. // go alarm_msg.SendAlarmMsg("解析 ContentSub 失败,Err:"+err.Error(), 3)
  693. // //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  694. // }
  695. // content = html.EscapeString(content)
  696. // contentSub = html.EscapeString(contentSub)
  697. // err = models.EditEnglishReportContent(reportId, content, contentSub)
  698. // if err != nil {
  699. // br.Msg = "保存失败"
  700. // br.ErrMsg = "保存失败,Err:" + err.Error()
  701. // return
  702. // }
  703. // go models.AddEnglishReportSaveLog(reportId, this.SysUser.AdminId, content, contentSub, this.SysUser.AdminName)
  704. // }
  705. // }
  706. // resp := new(models.SaveReportContentResp)
  707. // resp.ReportId = reportId
  708. // br.Ret = 200
  709. // br.Success = true
  710. // br.Msg = "保存成功成功"
  711. // br.Data = resp
  712. //}
  713. //
  714. //// @Title 根据分类获取最近一次报告详情接口
  715. //// @Description 根据分类获取最近一次报告详情
  716. //// @Param request body models.ClassifyIdDetailReq true "type json string"
  717. //// @Success 200 {object} models.Report
  718. //// @router /classifyIdDetail [get]
  719. //func (this *EnglishReportController) ClassifyIdDetail() {
  720. // br := new(models.BaseResponse).Init()
  721. // defer func() {
  722. // this.Data["json"] = br
  723. // this.ServeJSON()
  724. // }()
  725. // //classify_id_first=34&classify_id_second=36
  726. //
  727. // /*var req models.ClassifyIdDetailReq
  728. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  729. // if err != nil {
  730. // br.Msg = "参数解析异常!"
  731. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  732. // return
  733. // }*/
  734. // classifyIdFirst, _ := this.GetInt("classify_id_first")
  735. // if classifyIdFirst <= 0 {
  736. // classifyIdFirst, _ = this.GetInt("ClassifyIdFirst")
  737. // }
  738. // classifyIdSecond, _ := this.GetInt("classify_id_second")
  739. // if classifyIdSecond <= 0 {
  740. // classifyIdSecond, _ = this.GetInt("ClassifyIdSecond")
  741. // }
  742. // item, err := models.GetEnglishReportDetailByClassifyId(classifyIdFirst, classifyIdSecond)
  743. // if err != nil && err.Error() != utils.ErrNoRow() {
  744. // br.Msg = "获取失败!"
  745. // br.ErrMsg = "获取失败,Err:" + err.Error()
  746. // return
  747. // }
  748. // if item != nil {
  749. // item.Content = html.UnescapeString(item.Content)
  750. // item.ContentSub = html.UnescapeString(item.ContentSub)
  751. // }
  752. // br.Ret = 200
  753. // br.Success = true
  754. // br.Msg = "获取成功"
  755. // br.Data = item
  756. //}
  757. //
  758. //// Author
  759. //// @Title 获取报告作者接口
  760. //// @Description 获取报告作者
  761. //// @Param AuthorType query int true "来源类型,1:中文,2:英文"
  762. //// @Param Keyword query string true "搜索关键词"
  763. //// @Param CurrentIndex query int true "当前页页码,从1开始"
  764. //// @Param StartDate query string true "开始时间"
  765. //// @Success 200 {object} models.ReportAuthorResp
  766. //// @router /author [get]
  767. //func (this *EnglishReportController) Author() {
  768. // br := new(models.BaseResponse).Init()
  769. // defer func() {
  770. // this.Data["json"] = br
  771. // this.ServeJSON()
  772. // }()
  773. //
  774. // keyword := this.GetString("Keyword")
  775. //
  776. // var condition string
  777. // var pars []interface{}
  778. // condition += ` AND author_type = 2 AND enable = 1`
  779. //
  780. // if keyword != `` {
  781. // condition += ` AND report_author like ? `
  782. // pars = append(pars, "%"+keyword+"%")
  783. // }
  784. //
  785. // _, items, err := models.GetReportAuthorList(condition, pars, 0, 10000)
  786. // if err != nil {
  787. // br.Msg = "获取失败!"
  788. // br.ErrMsg = "获取失败,Err:" + err.Error()
  789. // return
  790. // }
  791. // resp := models.ReportAuthorResp{
  792. // List: items,
  793. // }
  794. // br.Ret = 200
  795. // br.Success = true
  796. // br.Msg = "获取成功"
  797. // br.Data = resp
  798. //}
  799. //
  800. //// MarkEditStatus
  801. //// @Title 标记报告编辑状态
  802. //// @Description 标记报告编辑状态接口
  803. //// @Param request body request.MarkEditEnReport true "type json string"
  804. //// @Success 200 标记成功 ;202 标记成功
  805. //// @router /mark [post]
  806. //func (this *EnglishReportController) MarkEditStatus() {
  807. // br := new(models.BaseResponse).Init()
  808. // defer func() {
  809. // this.Data["json"] = br
  810. // this.ServeJSON()
  811. // }()
  812. // sysUser := this.SysUser
  813. // if sysUser == nil {
  814. // br.Msg = "请登录"
  815. // br.ErrMsg = "请登录,SysUser Is Empty"
  816. // br.Ret = 408
  817. // return
  818. // }
  819. // var req models.MarkEditEnReport
  820. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  821. // if err != nil {
  822. // br.Msg = "参数解析异常!"
  823. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  824. // return
  825. // }
  826. //
  827. // if req.ReportId <= 0 {
  828. // br.Msg = "缺少报告Id"
  829. // return
  830. // }
  831. // if req.Status <= 0 {
  832. // br.Msg = "标记状态异常"
  833. // return
  834. // }
  835. // //更新标记key
  836. // data, err := services.UpdateEnReportEditMark(req.ReportId, sysUser.AdminId, req.Status, sysUser.RealName)
  837. // if err != nil {
  838. // br.Msg = err.Error()
  839. // return
  840. // }
  841. //
  842. // msg := "标记成功"
  843. // br.Ret = 200
  844. // br.Success = true
  845. // br.Msg = msg
  846. // br.Data = data
  847. //}
  848. //
  849. //// @Title 编辑来自策略报告的报告
  850. //// @Description 编辑来自策略报告的报告
  851. //// @Param request body models.EditEnglishReportFromPolicyReq true "type json string"
  852. //// @Success 200 {object} models.EditEnglishReportResp
  853. //// @router /edit_policy [post]
  854. //func (this *EnglishReportController) EditPolicy() {
  855. // br := new(models.BaseResponse).Init()
  856. // defer func() {
  857. // this.Data["json"] = br
  858. // this.ServeJSON()
  859. // }()
  860. // sysUser := this.SysUser
  861. // if sysUser == nil {
  862. // br.Msg = "请登录"
  863. // br.ErrMsg = "请登录,SysUser Is Empty"
  864. // br.Ret = 408
  865. // return
  866. // }
  867. // var req models.EditEnglishReportFromPolicyReq
  868. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  869. // if err != nil {
  870. // br.Msg = "参数解析异常!"
  871. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  872. // return
  873. // }
  874. // if req.ReportId <= 0 {
  875. // br.Msg = "请选择报告ID"
  876. // return
  877. // }
  878. // if req.Title == "" {
  879. // br.Msg = "请输入标题"
  880. // return
  881. // }
  882. // if req.Abstract == "" {
  883. // br.Msg = "请输入摘要"
  884. // return
  885. // }
  886. //
  887. // if req.Frequency == "" {
  888. // br.Msg = "请输入频度"
  889. // return
  890. // }
  891. // if req.Author == "" {
  892. // br.Msg = "请输入作者"
  893. // return
  894. // }
  895. //
  896. // if req.CreateTime == "" {
  897. // br.Msg = "请输入创建时间"
  898. // return
  899. // }
  900. // //查询报告是否存在
  901. // reportInfo, err := models.GetEnglishReportItemById(int(req.ReportId))
  902. // if err != nil {
  903. // if err.Error() == utils.ErrNoRow() {
  904. // br.Msg = "报告不存在"
  905. // return
  906. // }
  907. // br.Msg = "查询报告信息失败"
  908. // br.ErrMsg = "查询报告信息失败, Err" + err.Error()
  909. // return
  910. // }
  911. // if reportInfo.State == 2 {
  912. // br.Msg = "报告已发布不允许编辑"
  913. // return
  914. // }
  915. // markStatus, err := services.UpdateEnReportEditMark(int(req.ReportId), sysUser.AdminId, 1, sysUser.RealName)
  916. // if err != nil {
  917. // br.Msg = err.Error()
  918. // return
  919. // }
  920. // if markStatus.Status == 1 {
  921. // br.Msg = markStatus.Msg
  922. // return
  923. // }
  924. //
  925. // item := reportInfo
  926. // item.Title = req.Title
  927. // item.Abstract = req.Abstract
  928. // item.Author = req.Author
  929. // item.Frequency = req.Frequency
  930. // item.CreateTime = req.CreateTime
  931. // item.ModifyTime = time.Now()
  932. // err = item.Update([]string{"Title", "Abstract", "Author", "Frequency", "CreateTime", "ModifyTime"})
  933. // if err != nil {
  934. // br.Msg = "保存失败"
  935. // br.ErrMsg = "保存失败,Err:" + err.Error()
  936. // return
  937. // }
  938. // reportCode := reportInfo.ReportCode
  939. // resp := new(models.EditEnglishReportResp)
  940. // resp.ReportId = req.ReportId
  941. // resp.ReportCode = reportCode
  942. // br.Ret = 200
  943. // br.Success = true
  944. // br.Msg = "保存成功"
  945. // br.Data = resp
  946. //}